kxs-main/AppStart/Helper/StatTimerService.cs

using System;
using System.Collections.Generic;
using Library;
using LitJson;
using System.Linq;
using System.Data;
using MySystem.PxcModels;

namespace MySystem
{
    public class StatTimerService
    {
        public readonly static StatTimerService Instance = new StatTimerService();
        private StatTimerService()
        { }

        public void Start(JobMqMsg jobInfo)
        {
            string content = "";
            try
            {
                dosomething();
                string Msg = "success";
                jobInfo.Status = Msg == "success" ? 1 : 0;
                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
            }
            catch (Exception ex)
            {
                if (!string.IsNullOrEmpty(content))
                {
                    Dictionary<string, string> data = new Dictionary<string, string>();
                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                    data.Add("ErrMsg", ex.ToString());
                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
                }
                else
                {
                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
                }
            }
        }

        public void dosomething()
        {
            WebCMSEntities db = new WebCMSEntities();
            string yesterday = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd HH:mm:ss");
            string today = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            
            // DataTable dt = dbconn.dtable("select Id from Users where CreateDate>='" + yesterday + "' and CreateDate<'" + today + "' order by Id");
            // foreach (DataRow dr in dt.Rows)
            // {
            //     int UserId = int.Parse(dr["Id"].ToString()); //创客ID
            //     int Level = 0;
            //     while (UserId > 0)
            //     {
            //         Level += 1;
            //         Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
            //         if (user != null)
            //         {
            //             if (user.AuthFlag == 1)
            //             {
            //                 if (Level == 1)
            //                 {
            //                     RedisDbconn.Instance.AddInt("TotalUser:" + UserId); //累计总创客                
            //                     RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeDate); //新增创客       
            //                     RedisDbconn.Instance.AddInt("AddUser:" + UserId + ":" + TradeMonth); //新增创客
            //                 }
            //                 RedisDbconn.Instance.AddInt("TeamTotalUser:" + UserId); //累计总创客                
            //                 RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeDate); //新增创客
            //                 RedisDbconn.Instance.AddInt("TeamAddUser:" + UserId + ":" + TradeMonth); //新增创客
            //             }
            //             UserId = user.ParentUserId;
            //         }
            //     }
            // }

            DataTable dt = dbconn.dtable("select UserId,BrandId,MerStandardDate from PosMerchantInfo where MerStandardDate>='" + yesterday + "' and MerStandardDate<'" + today + "' and QueryCount=0");
            dbconn.op("update PosMerchantInfo set QueryCount=1 where MerStandardDate>='" + yesterday + "' and MerStandardDate<'" + today + "' and QueryCount=0");
            foreach (DataRow dr in dt.Rows)
            {
                DateTime date = DateTime.Parse(dr["MerStandardDate"].ToString());
                string TradeMonth = date.ToString("yyyyMM");
                string TradeDate = date.ToString("yyyyMMdd");
                int UserId = int.Parse(dr["UserId"].ToString()); //创客ID
                int BrandId = int.Parse(dr["BrandId"].ToString()); //品牌
                int MerchantCount = 1;
                int Level = 0;
                while (UserId > 0)
                {
                    Level += 1;
                    Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
                    if (user != null)
                    {
                        if (user.AuthFlag == 1)
                        {
                            if (Level == 1)
                            {
                                RedisDbconn.Instance.AddInt("TotalPosMerchant:" + UserId + ":" + TradeDate, MerchantCount); //累计激活POS机商户
                                RedisDbconn.Instance.AddInt("TotalPosMerchant:" + UserId + ":" + TradeMonth, MerchantCount); //累计激活POS机商户
                                RedisDbconn.Instance.AddInt("TotalPosMerchant:" + UserId + ":" + BrandId + ":" + TradeDate, MerchantCount); //累计激活POS机商户
                                RedisDbconn.Instance.AddInt("TotalPosMerchant:" + UserId + ":" + BrandId + ":" + TradeMonth, MerchantCount); //累计激活POS机商户
                            }
                            RedisDbconn.Instance.AddInt("TeamTotalPosMerchant:" + UserId + ":" + TradeDate, MerchantCount); //累计激活POS机商户
                            RedisDbconn.Instance.AddInt("TeamTotalPosMerchant:" + UserId + ":" + TradeMonth, MerchantCount); //累计激活POS机商户
                            RedisDbconn.Instance.AddInt("TeamTotalPosMerchant:" + UserId + ":" + BrandId + ":" + TradeDate, MerchantCount); //累计激活POS机商户
                            RedisDbconn.Instance.AddInt("TeamTotalPosMerchant:" + UserId + ":" + BrandId + ":" + TradeMonth, MerchantCount); //累计激活POS机商户
                        }
                        UserId = user.ParentUserId;
                    }
                }
            }
            db.Dispose();
        }
    }
}