调整重置创客交易额

AppStart/Helper/StatResetService.cs

@@ -47,6 +47,7 @@ namespace MySystem
         public void StatTrade(string content)
         {
             JsonData jsonObj = JsonMapper.ToObject(content);
+            string Kind = jsonObj["Kind"].ToString();
             string BrandId = jsonObj["BrandId"].ToString();
             string TradeDate = jsonObj["TradeDate"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置创客交易额日志");
@@ -54,12 +55,21 @@ namespace MySystem
             try
             {
                 string TradeDateStr = TradeDate.Replace("-", "");
-                CustomerSqlConn.op("delete from TradeDaySummary where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
-                CustomerSqlConn.op("delete from TradeDaySummary2 where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
-                CustomerSqlConn.op("delete from TradeDaySummaryBefore where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
-                CustomerSqlConn.op("delete from TradeDaySummary2Before where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
-                CustomerSqlConn.op("delete from TradeDaySummaryAfter where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
-                CustomerSqlConn.op("delete from TradeDaySummary2After where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                if(Kind.Contains("1"))
+                {
+                    CustomerSqlConn.op("delete from TradeDaySummary where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                    CustomerSqlConn.op("delete from TradeDaySummary2 where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                }
+                if(Kind.Contains("2"))
+                {
+                    CustomerSqlConn.op("delete from TradeDaySummaryBefore where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                    CustomerSqlConn.op("delete from TradeDaySummary2Before where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                }
+                if(Kind.Contains("3"))
+                {
+                    CustomerSqlConn.op("delete from TradeDaySummaryAfter where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                    CustomerSqlConn.op("delete from TradeDaySummary2After where TradeDate='" + TradeDateStr + "' and BrandId in (" + BrandId + ")", AppConfig.Base.SqlConn);
+                }
                 string startId = "20000000";
                 bool op = true;
                 while(op)
@@ -80,7 +90,10 @@ namespace MySystem
                             function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置创客交易额日志");
                             foreach (DataRow selfDr in selfDt.Rows)
                             {
-                                StatService.Instance.StatTrade(db, selfDr);
+                                if(Kind.Contains("1"))
+                                {
+                                    StatService.Instance.StatTrade(db, selfDr);
+                                }
 
                                 int UserId = int.Parse(selfDr["UserId"].ToString());
                                 string SnNo = selfDr["SnNo"].ToString();
@@ -93,11 +106,17 @@ namespace MySystem
                                 string ParentNav = user.ParentNav; //selfDr["ParentNav"].ToString();
                                 if (pos.BindingTime < DateTime.Parse("2023-07-01 00:00:00"))
                                 {
-                                    Stat2Service.Instance.StatBefore(db, selfDr, UserId, ParentNav);
+                                    if(Kind.Contains("2"))
+                                    {
+                                        Stat2Service.Instance.StatBefore(db, selfDr, UserId, ParentNav);
+                                    }
                                 }
                                 else
                                 {
-                                    Stat2Service.Instance.StatAfter(db, selfDr, UserId, ParentNav);
+                                    if(Kind.Contains("3"))
+                                    {
+                                        Stat2Service.Instance.StatAfter(db, selfDr, UserId, ParentNav);
+                                    }
                                 }
                             }
                         }

Controllers/HomeController.cs

@@ -70,47 +70,7 @@ namespace MySystem.Controllers
         public string test()
         {
             string result = "ok";
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-01\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-02\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-03\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-04\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-05\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-06\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-07\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-08\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-09\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-10\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-11\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-12\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-13\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-14\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-15\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-16\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-17\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-18\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-19\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-20\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-21\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-22\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-23\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-24\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-25\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-26\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-27\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-28\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-29\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-01\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-02\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-03\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-04\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-05\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-06\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-07\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-08\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-09\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-10\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-11\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-03-12\"}");
+            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"Kind\":\"23\",\"BrandId\":\"1,2,3,4,5,6,7,8,9,10,11,12,13,15\",\"TradeDate\":\"2024-02-01\"}");
             return result;
         }
     }

Startup.cs

@@ -99,34 +99,34 @@ namespace MySystem
             initMain();
             
             //必须打开的
-            // StatService.Instance.StartEverDayV2(); //实时统计交易额
-            // Stat2Service.Instance.Start(); //实时统计归档交易额
-            // StatService.Instance.StartOther(); //补充统计交易额
-            // StatService.Instance.StartPosActNum(); //实时统计激活数
-            // StatService.Instance.StartNewUserNum(); //实时统计新增创客数
-            // StatHelpProfitService.Instance.StartUserTrade();
-            // StatHelpProfitService.Instance.ResetMaxTradeAmount(); //每月重置助利宝最大交易总额
-            // OperateService.Instance.Start(); //统计运营中心发货量
-            // OperateService.Instance.StartPosActNum(); //统计运营中心激活量
-            // OperateService.Instance.StartPosCouponSaleNum(); //统计运营中心机具券销售量
+            StatService.Instance.StartEverDayV2(); //实时统计交易额
+            Stat2Service.Instance.Start(); //实时统计归档交易额
+            StatService.Instance.StartOther(); //补充统计交易额
+            StatService.Instance.StartPosActNum(); //实时统计激活数
+            StatService.Instance.StartNewUserNum(); //实时统计新增创客数
+            StatHelpProfitService.Instance.StartUserTrade();
+            StatHelpProfitService.Instance.ResetMaxTradeAmount(); //每月重置助利宝最大交易总额
+            OperateService.Instance.Start(); //统计运营中心发货量
+            OperateService.Instance.StartPosActNum(); //统计运营中心激活量
+            OperateService.Instance.StartPosCouponSaleNum(); //统计运营中心机具券销售量
             
-            // StatNewService.Instance.StartStat(); //实时统计交易额RDS
-            // StatNewService.Instance.StartMer(); //实时统计商户交易额到RDS
-            // StatNewService.Instance.StartAct(); //统计激活数到RDS
+            StatNewService.Instance.StartStat(); //实时统计交易额RDS
+            StatNewService.Instance.StartMer(); //实时统计商户交易额到RDS
+            StatNewService.Instance.StartAct(); //统计激活数到RDS
 
-            // AddRecordService.Instance.StartTradeRecord(); //RDS交易记录队列
-            // AddRecordService.Instance.StartUserAccountRecord(); //RDS收支明细队列
+            AddRecordService.Instance.StartTradeRecord(); //RDS交易记录队列
+            AddRecordService.Instance.StartUserAccountRecord(); //RDS收支明细队列
 
-            // StatNewService.Instance.CreateTable(); //创建RDS分表
+            StatNewService.Instance.CreateTable(); //创建RDS分表
             
-            // StatHelpProfitService.Instance.AddUserHelpProfit(); //补创客助利宝交易额
+            StatHelpProfitService.Instance.AddUserHelpProfit(); //补创客助利宝交易额
             
-            // StatResetService.Instance.Start(); //重置创客交易额
+            StatResetService.Instance.Start(); //重置创客交易额
             // ProfitService.Instance.AddRds(); //补RDS数据
             //必须打开的
 
             // StatTradeService.Instance.Start();
-            StatTradeCheckService.Instance.Start();
+            // StatTradeCheckService.Instance.Start();
 
         }