助利宝商机生成条件调整

分仓额度每个月重置调整

AppStart/Helper/Profit/HelpProfitPreMerchantHelper.cs

@@ -43,9 +43,9 @@ namespace MySystem
             }
             function.WritePage("/HelpProfitResetMerchant/", Date + ".txt", DateTime.Now.ToString());
             DateTime start = DateTime.Parse(Date.Substring(0, 4) + "-" + Date.Substring(4, 2) + "-" + Date.Substring(6, 2) + " 00:00:00");
-            string Month1 = start.ToString("yyyyMM");
-            string Month2 = start.AddMonths(-1).ToString("yyyyMM");
-            string Month3 = start.AddMonths(-2).ToString("yyyyMM");
+            string Month1 = start.AddMonths(-1).ToString("yyyyMM");
+            string Month2 = start.AddMonths(-2).ToString("yyyyMM");
+            string Month3 = start.AddMonths(-3).ToString("yyyyMM");
             OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
             string GetCount = function.ReadInstance("/PublicParam/HelpProfitMerCount.txt");
             string BrandId = function.ReadInstance("/PublicParam/HelpProfitMerBrandId.txt");

AppStart/Helper/Profit/ProfitHelper.cs

@@ -2096,7 +2096,7 @@ namespace MySystem
                     left join Users u on tb.SubsidyUserId=u.Id 
                     LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
                     left join PosMerchantInfo m on tb.MerchantId=m.Id 
-                    left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00'
+                    left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00'
 
                     // TODO:做到后台查询，换绑机器遗漏交易额补差
                     select UserId,sum(TradeAmount) from TradeRecord where SnNo in (

AppStart/Helper/Profit/ProfitHelperV2.cs

@@ -373,7 +373,7 @@ namespace MySystem
                     ) tb 
                     left join Users u on tb.UserId=u.Id 
                     LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
-                    left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' 
+                    left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00' 
                     ORDER BY u.MakerCode
 
                     //查补贴

AppStart/Timer/StoreApplyHelper.cs

@@ -34,8 +34,8 @@ public class StoreApplyHelper
             OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
             try
             {
-                // if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 0 && DateTime.Now.Hour < 3)
-                // {
+                if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 0 && DateTime.Now.Hour < 3)
+                {
                     string check = function.ReadInstance("/StoreApply/" + DateTime.Now.ToString("yyyyMM") + ".txt");
                     if(string.IsNullOrEmpty(check))
                     {
@@ -98,11 +98,7 @@ public class StoreApplyHelper
                             {
                                 Amount = 10000;
                             }
-                            if(Amount < 20000 && SpecialUsers20000().Contains(UserId))
-                            {
-                                Amount = 20000;
-                            }
-                            if(Amount < 20000)
+                            else if(Amount < 20000 && !SpecialUsers0().Contains(UserId))
                             {
                                 Amount = 20000;
                             }
@@ -147,7 +143,7 @@ public class StoreApplyHelper
                         }
                         db.SaveChanges();
                     }
-                // }
+                }
             }
             catch (Exception ex)
             {
@@ -382,140 +378,60 @@ public class StoreApplyHelper
     private List<int> SpecialUsers10000()
     {
         List<int> ids = new List<int>();
-        ids.Add(514);
-        ids.Add(548);
-        ids.Add(730);
-        ids.Add(3596);
-        ids.Add(11211);
         ids.Add(13185);
+        ids.Add(514);
         ids.Add(24302);
-        ids.Add(32630);
-        ids.Add(33002);
+        ids.Add(548);
         ids.Add(37887);
+        ids.Add(33002);
+        ids.Add(730);
         ids.Add(40950);
-        ids.Add(46284);
-        ids.Add(59190);
         ids.Add(72099);
-        ids.Add(120875);
+        ids.Add(6898);
+        ids.Add(46284);
         ids.Add(127884);
+        ids.Add(3596);
+        ids.Add(32630);
+        ids.Add(11211);
+        ids.Add(59190);
         return ids;
     }
 
-    private List<int> SpecialUsers20000()
+    private List<int> SpecialUsers0()
     {
         List<int> ids = new List<int>();
-        ids.Add(8);
-        ids.Add(415);
-        ids.Add(527);
-        ids.Add(532);
-        ids.Add(553);
-        ids.Add(558);
-        ids.Add(1193);
-        ids.Add(1195);
-        ids.Add(1703);
-        ids.Add(1797);
-        ids.Add(1893);
-        ids.Add(2275);
-        ids.Add(2825);
-        ids.Add(3015);
-        ids.Add(3211);
-        ids.Add(3492);
-        ids.Add(4216);
-        ids.Add(4328);
-        ids.Add(4507);
-        ids.Add(5774);
-        ids.Add(6446);
-        ids.Add(6538);
-        ids.Add(6619);
-        ids.Add(6751);
-        ids.Add(10677);
-        ids.Add(13650);
-        ids.Add(15506);
-        ids.Add(15600);
-        ids.Add(15714);
-        ids.Add(17767);
-        ids.Add(18833);
-        ids.Add(20667);
-        ids.Add(21051);
-        ids.Add(23099);
-        ids.Add(23564);
-        ids.Add(23883);
-        ids.Add(23944);
-        ids.Add(24528);
-        ids.Add(26577);
-        ids.Add(26875);
-        ids.Add(27632);
-        ids.Add(30869);
-        ids.Add(32427);
-        ids.Add(32458);
-        ids.Add(32534);
-        ids.Add(35808);
-        ids.Add(37242);
-        ids.Add(37556);
-        ids.Add(40282);
-        ids.Add(40886);
-        ids.Add(41420);
-        ids.Add(43735);
-        ids.Add(44417);
-        ids.Add(44697);
-        ids.Add(46548);
-        ids.Add(49927);
-        ids.Add(50886);
-        ids.Add(52449);
-        ids.Add(52814);
-        ids.Add(54784);
-        ids.Add(58960);
-        ids.Add(60371);
-        ids.Add(60846);
-        ids.Add(63010);
-        ids.Add(68483);
-        ids.Add(68705);
-        ids.Add(70879);
-        ids.Add(71019);
-        ids.Add(71648);
-        ids.Add(72029);
-        ids.Add(74591);
-        ids.Add(77107);
-        ids.Add(77489);
-        ids.Add(78313);
-        ids.Add(80516);
-        ids.Add(84627);
-        ids.Add(88225);
-        ids.Add(88579);
-        ids.Add(89269);
-        ids.Add(93049);
-        ids.Add(93825);
-        ids.Add(97771);
-        ids.Add(99622);
-        ids.Add(105286);
-        ids.Add(106581);
-        ids.Add(120563);
-        ids.Add(120814);
-        ids.Add(120844);
-        ids.Add(120997);
-        ids.Add(121082);
-        ids.Add(121218);
-        ids.Add(121465);
-        ids.Add(121710);
-        ids.Add(123354);
-        ids.Add(123362);
-        ids.Add(124423);
-        ids.Add(124462);
-        ids.Add(125184);
-        ids.Add(125377);
-        ids.Add(125578);
-        ids.Add(125848);
-        ids.Add(126613);
-        ids.Add(126620);
-        ids.Add(127561);
-        ids.Add(128758);
-        ids.Add(129380);
-        ids.Add(129796);
-        ids.Add(131010);
-        ids.Add(132488);
-        ids.Add(133216);
-        ids.Add(133590);
-        ids.Add(135440);
+        ids.Add(21135);
+        ids.Add(598);
+        ids.Add(109913);
+        ids.Add(609);
+        ids.Add(588);
+        ids.Add(12107);
+        ids.Add(7641);
+        ids.Add(4317);
+        ids.Add(560);
+        ids.Add(120998);
+        ids.Add(3905);
+        ids.Add(959);
+        ids.Add(2502);
+        ids.Add(1001);
+        ids.Add(68868);
+        ids.Add(11718);
+        ids.Add(15493);
+        ids.Add(459);
+        ids.Add(97952);
+        ids.Add(10719);
+        ids.Add(134503);
+        ids.Add(16453);
+        ids.Add(1337);
+        ids.Add(110198);
+        ids.Add(582);
+        ids.Add(89);
+        ids.Add(9319);
+        ids.Add(128525);
+        ids.Add(1109);
+        ids.Add(28538);
+        ids.Add(2927);
+        ids.Add(584);
         return ids;
     }
 }

Startup.cs

@@ -91,8 +91,8 @@ namespace MySystem
             // services.AddHostedService<SycnSpTimer>(); //同步SP数据
 
             // services.AddHostedService<TimerStatTimer>(); //实时统计创客、激活商户数
-            // services.AddHostedService<PosTradeStatTimer>(); // 统计头天的交易额、商户型创客、激活奖励、开机奖励
-            // services.AddHostedService<AlipayPayBack2Timer>(); //支付宝回调处理
+            services.AddHostedService<PosTradeStatTimer>(); // 统计头天的交易额、商户型创客、激活奖励、开机奖励
+            services.AddHostedService<AlipayPayBack2Timer>(); //支付宝回调处理
 
             //services.AddHttpContextAccessor();
 
@@ -190,31 +190,31 @@ namespace MySystem
             // TradeStatTimer2.Instance.Start(); //交易统计
 
             //必须打开的
-            // ActiveRewardTimer.Instance.Start(); //实时处理激活记录
-            // TradeStatTimer.Instance.Start(); //交易统计
-            // ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
-            // MakeReferenceQrCodeService.Instance.StartListen(); //生成创客邀请二维码
-            // SycnSpBindService.Instance.Start(); //同步SP绑定数据
-            // SycnSpMerchantService.Instance.Start(); //同步SP商户数据
-            // SycnSpActiveService.Instance.Start(); //同步SP激活数据
-            // SycnSpTradeService.Instance.Start(); //同步SP交易数据
-            // SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
-            // SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
-            // RedPackageV2Helper.Instance.Start(); //每天生成红包
-            // RedPackageV2Helper.Instance.StartStatTop10(); //红包活动统计排行
-            // RedPackageV2Helper.Instance.StartSendPrize(); //红包活动发奖
-            // BalancePayBackService.Instance.Start(); //余额支付队列
-            // ReservePayBackService.Instance.Start(); //储备金支付队列
-            // LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
-            // MessageCenterService.Instance.Start(); // 消息队列
-            // RecommendActStatService.Instance.Start(); //推荐王奖励数据统计
-            // StoreApplyHelper.Instance.Start(); // 每月1号重置仓库额度
-            // StoreApplyHelper.Instance.StartEverTime();
-            // StatService.Instance.StatUserLevel(); //升级并分润
+            ActiveRewardTimer.Instance.Start(); //实时处理激活记录
+            TradeStatTimer.Instance.Start(); //交易统计
+            ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
+            MakeReferenceQrCodeService.Instance.StartListen(); //生成创客邀请二维码
+            SycnSpBindService.Instance.Start(); //同步SP绑定数据
+            SycnSpMerchantService.Instance.Start(); //同步SP商户数据
+            SycnSpActiveService.Instance.Start(); //同步SP激活数据
+            SycnSpTradeService.Instance.Start(); //同步SP交易数据
+            SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
+            SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
+            RedPackageV2Helper.Instance.Start(); //每天生成红包
+            RedPackageV2Helper.Instance.StartStatTop10(); //红包活动统计排行
+            RedPackageV2Helper.Instance.StartSendPrize(); //红包活动发奖
+            BalancePayBackService.Instance.Start(); //余额支付队列
+            ReservePayBackService.Instance.Start(); //储备金支付队列
+            LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
+            MessageCenterService.Instance.Start(); // 消息队列
+            RecommendActStatService.Instance.Start(); //推荐王奖励数据统计
+            StoreApplyHelper.Instance.Start(); // 每月1号重置仓库额度
+            StoreApplyHelper.Instance.StartEverTime();
+            StatService.Instance.StatUserLevel(); //升级并分润
             //必须打开的
 
-            // HelpProfitHelper.Instance.Start();
-            // HelpProfitPreMerchantHelper.Instance.Start();
+            HelpProfitHelper.Instance.Start();
+            HelpProfitPreMerchantHelper.Instance.Start();
             // StatService.Instance.StartPosActNum(); //实时统计激活数
             // StatService.Instance.StartNewUserNum(); //实时统计新增创客数
             // StatService.Instance.StatProfit(); //实时统计创客收益
@@ -226,7 +226,7 @@ namespace MySystem
             // StatService.Instance.ListenFluxRecord();
             // StatService.Instance.StartEverDay2();
             // TestHelper.Instance.Start();
-            TestService.Instance.Start();
+            // TestService.Instance.Start();
             // StatService.Instance.StartEverDay();
             // RabbitMQClient.Instance.StartReceive("MerchantConfirmList");
             // RabbitMQClient.Instance.StartReceive("CheckWeChatSign");