每天统计我的创客交易额更新

AppStart/Helper/StatService.cs

@@ -28,7 +28,7 @@ namespace MySystem
                     // dosomething1(doDate);
                     // dosomething11(doDate);
                     // dosomething2(doDate);
-                    StartEverDay(doDate);
+                    // StartEverDay(doDate);
                     // StartEverDayV2(doDate);
                     StatMerchantTrade(doDate);
                     dosomething4(doDate);
@@ -1408,7 +1408,7 @@ namespace MySystem
         // 每天统计头一天的交易额
         public void StartEverDay(string date)
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
             // DateTime end = DateTime.Parse("2022-04-19 00:00:00");
             // DateTime check = DateTime.Parse("2022-03-11");
             // while (check <= end)
@@ -1423,7 +1423,7 @@ namespace MySystem
             {
                 TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
             }
-            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' GROUP BY UserId");
+            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
             foreach (DataRow dr in list.Rows)
             {
                 string UserId = dr["UserId"].ToString();
@@ -1701,7 +1701,7 @@ namespace MySystem
         {
             while (true)
             {
-                if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 1)
+                if(DateTime.Now.Day <= 3 && DateTime.Now.Hour > 1)
                 {
                     string Month = DateTime.Now.AddDays(-1).ToString("yyyy-MM");
                     string flag = function.ReadInstance("/ProfitFlag/" + Month + ".txt");
@@ -2391,6 +2391,44 @@ namespace MySystem
 
 
 
+        // 实时统计我的创客交易额
+        public void StatMyUserThisTrade()
+        {
+            Thread th = new Thread(StatMyUserThisTradeDo);
+            th.IsBackground = true;
+            th.Start();
+        }
+        public void StatMyUserThisTradeDo()
+        {
+            while (true)
+            {
+                if(DateTime.Now.Hour > 3)
+                {
+                    StatMyUserThisTradeListen();
+                }
+                int timespan = 1000 * 3600;
+                Thread.Sleep(timespan);
+            }
+        }
+        public void StatMyUserThisTradeListen()
+        {
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            string TradeMonth = DateTime.Now.ToString("yyyyMM");
+            // if(DateTime.Now.Day == 1)
+            // {
+            //     TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
+            // }
+            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
+            foreach (DataRow dr in list.Rows)
+            {
+                string UserId = dr["UserId"].ToString();
+                string ThisMonthTrade = dr[1].ToString();
+                OtherMySqlConn.op("update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId);
+            }
+        }
+
+
+
 
         #region 判断品牌互斥条件，根据身份证号
 

Startup.cs

@@ -209,6 +209,7 @@ namespace MySystem
             MessageCenterService.Instance.Start(); // 消息队列
             //必须打开的
 
+            StatService.Instance.StatMyUserThisTrade();
             // StatService.Instance.StartPosActNum(); //实时统计激活数
             // StatService.Instance.StartNewUserNum(); //实时统计新增创客数
             // StatService.Instance.StatProfit(); //实时统计创客收益
@@ -216,7 +217,7 @@ namespace MySystem
             // StatService.Instance.StartEverDay("");
             // StatService.Instance.StartEverDayV2();
             // RedPackageHelper.Instance.Start();
-            StatService.Instance.StatUserLevel();
+            // StatService.Instance.StatUserLevel();
             // ProfitHelperV2.Instance.StatProfit(); //统计分润
             // StatService.Instance.ListenFluxRecord();
             // StatService.Instance.StartEverDay2();