测试wifi每月交易统计

AppStart/Helper/SycnSpServer/SycnSpTradeWifiService.cs

@@ -119,8 +119,10 @@ namespace MySystem
                                 if(pos.BrandId == 26 && TradeAmount == 1399) Months = 12;
                                 if(pos.BrandId == 26 && TradeAmount == 2698) Months = 24;
                             }
+                            string TradeMonth = DateTime.Now.ToString("yyyyMM");
 
                             add.Duration = Months;
+                            add.LastMonth = TradeMonth;
                             add.DoMonths = 1;
                             add.Unit = "m";
                             db.SaveChanges();
@@ -129,7 +131,6 @@ namespace MySystem
                             // {
                                 decimal TradeAmt = TradeAmount / Months;
                                 TradeAmt = PublicFunction.NumberFormat(TradeAmt);
-                                string TradeMonth = DateTime.Now.ToString("yyyyMM");
                                 // if(statFlag)
                                 // {
                                 //     PxcModels.TradeDaySummary stat = db.TradeDaySummary.Where(m => m.UserId == pos.BuyUserId && m.BrandId == pos.BrandId).OrderByDescending(m => m.Id).FirstOrDefault() ?? new PxcModels.TradeDaySummary();

AppStart/WifiTradeHelper.cs

@@ -50,32 +50,228 @@ public class WifiTradeHelper
     public void DoSomething(string Month)
     {
         WebCMSEntities db = new WebCMSEntities();
-        List<WifiTradeRecord> trades = db.WifiTradeRecord.Where(m => m.Duration > m.DoMonths && m.LastMonth != Month).ToList();
-        foreach(WifiTradeRecord trade in trades)
+        MySystem.ReadModels.WebCMSEntities rdb = new MySystem.ReadModels.WebCMSEntities();
+        // List<WifiTradeRecord> trades = db.WifiTradeRecord.Where(m => m.Duration > m.DoMonths && m.LastMonth != Month).ToList();
+        DateTime end = DateTime.Parse(Month + "-01 00:00:00").AddMonths(1);
+        List<string> SnNos = new List<string>();
+        List<MySystem.ReadModels.WifiTradeRecord> trades = rdb.WifiTradeRecord.Where(m => m.Duration >= m.DoMonths && m.CreateDate < end).ToList();
+        List<MySystem.ReadModels.Users> users = rdb.Users.Where(m => m.AuthFlag == 1).ToList();
+        List<string> PosSns = trades.Select(m => m.SnNo).ToList();
+        List<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => PosSns.Contains(m.PosSn)).ToList();
+        List<TradeDaySummary> statTrade = new List<TradeDaySummary>();
+        List<TradeDaySummaryBefore> statTradeBefore = new List<TradeDaySummaryBefore>();
+        List<TradeDaySummaryAfter> statTradeAfter = new List<TradeDaySummaryAfter>();
+        foreach(MySystem.ReadModels.WifiTradeRecord trade in trades)
         {
-            if(trade.Unit == "m" && trade.Duration > 0)
+            if(trade.Unit == "m" && trade.Duration > 0 && !SnNos.Contains(trade.SnNo))
             {
                 decimal TradeAmt = trade.TradeAmount / trade.Duration;
-                DateTime StartMonth = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
-                PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == trade.SnNo) ?? new PosMachinesTwo();
-                SycnSpTradeWifiService.Instance.StatTrade(db, pos.BuyUserId, pos.BrandId, StartMonth.ToString("yyyyMM"), TradeAmt);
+                PosMachinesTwo pos = posList.FirstOrDefault(m => m.PosSn == trade.SnNo) ?? new PosMachinesTwo();
+                StatTrade(statTrade, users, pos.BuyUserId, pos.BrandId, Month.Replace("-", ""), TradeAmt);
                 if (pos.BindingTime < trade.CreateDate.Value.AddMonths(-9))
                 {
-                    SycnSpTradeWifiService.Instance.StatTradeBefore(db, pos.BuyUserId, pos.BrandId, StartMonth.ToString("yyyyMM"), TradeAmt);
+                    StatTradeBefore(statTradeBefore, users, pos.BuyUserId, pos.BrandId, Month.Replace("-", ""), TradeAmt);
                 }
                 else
                 {
-                    SycnSpTradeWifiService.Instance.StatTradeAfter(db, pos.BuyUserId, pos.BrandId, StartMonth.ToString("yyyyMM"), TradeAmt);
+                    StatTradeAfter(statTradeAfter, users, pos.BuyUserId, pos.BrandId, Month.Replace("-", ""), TradeAmt);
                 }
-                WifiTradeRecord edit = db.WifiTradeRecord.FirstOrDefault(m => m.Id == trade.Id);
-                if(edit != null)
+                // WifiTradeRecord edit = db.WifiTradeRecord.FirstOrDefault(m => m.Id == trade.Id);
+                // if(edit != null)
+                // {
+                //     edit.DoMonths += 1;
+                //     edit.LastMonth = Month;
+                // }
+                SnNos.Add(trade.SnNo);
+            }
+        }
+        
+        int index = 0;
+        foreach(TradeDaySummary sub in statTrade)
+        {
+            index += 1;
+            db.TradeDaySummary.Add(sub);
+            if(index % 200 == 0)
+            {
+                db.SaveChanges();
+            }
+        }
+        db.SaveChanges();
+        index = 0;
+        foreach(TradeDaySummaryBefore sub in statTradeBefore)
+        {
+            index += 1;
+            db.TradeDaySummaryBefore.Add(sub);
+            if(index % 200 == 0)
+            {
+                db.SaveChanges();
+            }
+        }
+        db.SaveChanges();
+        index = 0;
+        foreach(TradeDaySummaryAfter sub in statTradeAfter)
+        {
+            index += 1;
+            db.TradeDaySummaryAfter.Add(sub);
+            if(index % 200 == 0)
+            {
+                db.SaveChanges();
+            }
+        }
+        db.SaveChanges();
+        db.Dispose();
+    }
+
+    public void StatTrade(List<TradeDaySummary> statTrade, List<MySystem.ReadModels.Users> users, int UserId, int BrandId, string TradeMonth, decimal TradeAmount)
+    {
+        MySystem.ReadModels.Users user = users.FirstOrDefault(m => m.Id == UserId) ?? new MySystem.ReadModels.Users();
+        string ParentNav = user.ParentNav;
+        string TradeDate = TradeMonth + "01";
+        ParentNav += "," + UserId + ",";
+
+        TradeDaySummary selfStat = statTrade.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "self");
+        if (selfStat == null)
+        {
+            statTrade.Add(new TradeDaySummary()
+            {
+                UserId = UserId,
+                TradeMonth = TradeMonth,
+                TradeDate = TradeDate,
+                BrandId = BrandId,
+                SeoTitle = "self",
+                HelpDirectTradeAmt = TradeAmount,
+            });
+        }
+        else
+        {
+            selfStat.HelpDirectTradeAmt += TradeAmount;
+        }
+        if (!string.IsNullOrEmpty(ParentNav))
+        {
+            string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
+            foreach (string NavUserIdString in ParentNavList)
+            {
+                int NavUserId = int.Parse(NavUserIdString);
+                TradeDaySummary teamStat = statTrade.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "team");
+                if (teamStat == null)
                 {
-                    edit.DoMonths += 1;
-                    edit.LastMonth = Month;
+                    statTrade.Add(new TradeDaySummary()
+                    {
+                        UserId = NavUserId,
+                        TradeMonth = TradeMonth,
+                        TradeDate = TradeDate,
+                        BrandId = BrandId,
+                        SeoTitle = "team",
+                        HelpNonDirectTradeAmt = TradeAmount,
+                    });
+                }
+                else
+                {
+                    teamStat.HelpNonDirectTradeAmt += TradeAmount;
+                }
+            }
+        }
+    }
+
+    public void StatTradeBefore(List<TradeDaySummaryBefore> statTrade, List<MySystem.ReadModels.Users> users, int UserId, int BrandId, string TradeMonth, decimal TradeAmount)
+    {
+        MySystem.ReadModels.Users user = users.FirstOrDefault(m => m.Id == UserId) ?? new MySystem.ReadModels.Users();
+        string ParentNav = user.ParentNav;
+        string TradeDate = TradeMonth + "01";
+        ParentNav += "," + UserId + ",";
+
+        TradeDaySummaryBefore selfStat = statTrade.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "self");
+        if (selfStat == null)
+        {
+            statTrade.Add(new TradeDaySummaryBefore()
+            {
+                UserId = UserId,
+                TradeMonth = TradeMonth,
+                TradeDate = TradeDate,
+                BrandId = BrandId,
+                SeoTitle = "self",
+                HelpDirectTradeAmt = TradeAmount,
+            });
+        }
+        else
+        {
+            selfStat.HelpDirectTradeAmt += TradeAmount;
+        }
+        if (!string.IsNullOrEmpty(ParentNav))
+        {
+            string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
+            foreach (string NavUserIdString in ParentNavList)
+            {
+                int NavUserId = int.Parse(NavUserIdString);
+                TradeDaySummaryBefore teamStat = statTrade.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "team");
+                if (teamStat == null)
+                {
+                    statTrade.Add(new TradeDaySummaryBefore()
+                    {
+                        UserId = NavUserId,
+                        TradeMonth = TradeMonth,
+                        TradeDate = TradeDate,
+                        BrandId = BrandId,
+                        SeoTitle = "team",
+                        HelpNonDirectTradeAmt = TradeAmount,
+                    });
+                }
+                else
+                {
+                    teamStat.HelpNonDirectTradeAmt += TradeAmount;
+                }
+            }
+        }
+    }
+
+    public void StatTradeAfter(List<TradeDaySummaryAfter> statTrade, List<MySystem.ReadModels.Users> users, int UserId, int BrandId, string TradeMonth, decimal TradeAmount)
+    {
+        MySystem.ReadModels.Users user = users.FirstOrDefault(m => m.Id == UserId) ?? new MySystem.ReadModels.Users();
+        string ParentNav = user.ParentNav;
+        string TradeDate = TradeMonth + "01";
+        ParentNav += "," + UserId + ",";
+
+        TradeDaySummaryAfter selfStat = statTrade.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "self");
+        if (selfStat == null)
+        {
+            statTrade.Add(new TradeDaySummaryAfter()
+            {
+                UserId = UserId,
+                TradeMonth = TradeMonth,
+                TradeDate = TradeDate,
+                BrandId = BrandId,
+                SeoTitle = "self",
+                HelpDirectTradeAmt = TradeAmount,
+            });
+        }
+        else
+        {
+            selfStat.HelpDirectTradeAmt += TradeAmount;
+        }
+        if (!string.IsNullOrEmpty(ParentNav))
+        {
+            string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
+            foreach (string NavUserIdString in ParentNavList)
+            {
+                int NavUserId = int.Parse(NavUserIdString);
+                TradeDaySummaryAfter teamStat = statTrade.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.SeoTitle == "team");
+                if (teamStat == null)
+                {
+                    statTrade.Add(new TradeDaySummaryAfter()
+                    {
+                        UserId = NavUserId,
+                        TradeMonth = TradeMonth,
+                        TradeDate = TradeDate,
+                        BrandId = BrandId,
+                        SeoTitle = "team",
+                        HelpNonDirectTradeAmt = TradeAmount,
+                    });
+                }
+                else
+                {
+                    teamStat.HelpNonDirectTradeAmt += TradeAmount;
                 }
             }
-            db.SaveChanges();
         }
-        db.Dispose();
     }
 }

ReadModels/Leaders.cs

@@ -18,5 +18,6 @@ namespace MySystem.ReadModels
         public int UserId { get; set; }
         public DateTime? ExpiredDate { get; set; }
         public DateTime? LastBuyDate { get; set; }
+        public int BusinessFlag { get; set; }
     }
 }

ReadModels/MpProfitRecord.cs

@@ -0,0 +1,38 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.ReadModels
+{
+    public partial class MpProfitRecord
+    {
+        public int Id { get; set; }
+        public int Sort { get; set; }
+        public int QueryCount { get; set; }
+        public int Status { get; set; }
+        public int Version { get; set; }
+        public DateTime? CreateDate { get; set; }
+        public DateTime? UpdateDate { get; set; }
+        public string CreateMan { get; set; }
+        public string UpdateMan { get; set; }
+        public string SeoTitle { get; set; }
+        public string SeoKeyword { get; set; }
+        public string SeoDescription { get; set; }
+        public int TradeId { get; set; }
+        public string ParentNav { get; set; }
+        public string Remark { get; set; }
+        public int BrandId { get; set; }
+        public ulong DirectFlag { get; set; }
+        public int CapFlag { get; set; }
+        public int QrPayFlag { get; set; }
+        public decimal ProfitAmount { get; set; }
+        public DateTime? ClearDate { get; set; }
+        public DateTime? TradeDate { get; set; }
+        public string SnNo { get; set; }
+        public int MerBuddyType { get; set; }
+        public int HelpMonthCount { get; set; }
+        public ulong MerHelpFlag { get; set; }
+        public string MerNo { get; set; }
+        public int MerchantId { get; set; }
+        public int UserId { get; set; }
+    }
+}

ReadModels/PosCoupons.cs

@@ -25,5 +25,6 @@ namespace MySystem.ReadModels
         public ulong HelpProfitFlag { get; set; }
         public int OpId { get; set; }
         public int OrderId { get; set; }
+        public int OpenPrizeUserId { get; set; }
     }
 }

ReadModels/PosFeeWarningRecord.cs

@@ -7,6 +7,7 @@ namespace MySystem.ReadModels
     {
         public int Id { get; set; }
         public int Sort { get; set; }
+        public int QueryCount { get; set; }
         public int Status { get; set; }
         public int Version { get; set; }
         public DateTime? CreateDate { get; set; }
@@ -22,7 +23,6 @@ namespace MySystem.ReadModels
         public string PosSn { get; set; }
         public int BrandId { get; set; }
         public int PosId { get; set; }
-        public int QueryCount { get; set; }
         public DateTime? DoDate { get; set; }
     }
 }

ReadModels/PosMachineOtherTmp.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.ReadModels
+{
+    public partial class PosMachineOtherTmp
+    {
+        public int Id { get; set; }
+        public string CustomerNo { get; set; }
+        public string LeMerNo { get; set; }
+        public string LeMerNo4 { get; set; }
+        public string SnNo { get; set; }
+        public int MerId { get; set; }
+    }
+}

ReadModels/PosMachineOtherTmp2.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.ReadModels
+{
+    public partial class PosMachineOtherTmp2
+    {
+        public int Id { get; set; }
+        public string CustomerNo { get; set; }
+        public string LeMerNo { get; set; }
+        public string LeMerNo4 { get; set; }
+        public string LmerNo { get; set; }
+    }
+}

ReadModels/RecommendDirectUser.cs

@@ -17,5 +17,6 @@ namespace MySystem.ReadModels
         public string TradeMonth { get; set; }
         public int DirectUserId { get; set; }
         public int UserId { get; set; }
+        public int Kind { get; set; }
     }
 }

ReadModels/StoreHouse.cs

@@ -43,5 +43,6 @@ namespace MySystem.ReadModels
         public string FilePath { get; set; }
         public decimal Deposit { get; set; }
         public int OpId { get; set; }
+        public int ApplyNum { get; set; }
     }
 }

ReadModels/UserRankWhiteSetRecord.cs

@@ -11,6 +11,8 @@ namespace MySystem.ReadModels
         public int Version { get; set; }
         public DateTime? CreateDate { get; set; }
         public DateTime? UpdateDate { get; set; }
+        public string Remark { get; set; }
+        public int UserType { get; set; }
         public int BeforeLevel { get; set; }
         public DateTime? ExpireDate { get; set; }
         public DateTime? PresetDate { get; set; }
@@ -18,7 +20,5 @@ namespace MySystem.ReadModels
         public int Level { get; set; }
         public int SetType { get; set; }
         public int UserId { get; set; }
-        public int UserType { get; set; }
-        public string Remark { get; set; }
     }
 }

ReadModels/WifiTradeRecord.cs

@@ -13,5 +13,9 @@ namespace MySystem.ReadModels
         public int BrandId { get; set; }
         public decimal TradeAmount { get; set; }
         public string SnNo { get; set; }
+        public int Duration { get; set; }
+        public string Unit { get; set; }
+        public int DoMonths { get; set; }
+        public string LastMonth { get; set; }
     }
 }

Startup.cs

@@ -168,90 +168,92 @@ namespace MySystem
             // }
             // if(Library.ConfigurationManager.EnvironmentFlag == 2)
             // {
-                SycnSpBindService.Instance.Start(); //同步SP绑定数据
-                SycnSpBindZkbService.Instance.Start(); //同步吱客宝SP绑定数据
-                SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
-                SycnSpMerchantService.Instance.Start(); //同步SP商户数据
-                SycnSpActiveService.Instance.Start(); //同步SP激活数据
-                SycnSpTradeService.Instance.Start(); //同步SP交易数据
-                SycnSpTradeWifiService.Instance.Start(); //同步WIFISP交易数据
-                SycnSpTradeZkbService.Instance.Start(); //同步吱客宝SP交易数据
-                SycnSpTradeService.Instance.StartSim(); //同步SP广电卡交易数据
-                SycnSpTradeService.Instance.StartTradeStatus(); //恢复原始交易没有统计上的数据
-                SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
-                SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
-                SycnSpMerchantRecordService.Instance.Start(); //同步SP商户记录数据
+                // SycnSpBindService.Instance.Start(); //同步SP绑定数据
+                // SycnSpBindZkbService.Instance.Start(); //同步吱客宝SP绑定数据
+                // SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
+                // SycnSpMerchantService.Instance.Start(); //同步SP商户数据
+                // SycnSpActiveService.Instance.Start(); //同步SP激活数据
+                // SycnSpTradeService.Instance.Start(); //同步SP交易数据
+                // SycnSpTradeWifiService.Instance.Start(); //同步WIFISP交易数据
+                // SycnSpTradeZkbService.Instance.Start(); //同步吱客宝SP交易数据
+                // SycnSpTradeService.Instance.StartSim(); //同步SP广电卡交易数据
+                // SycnSpTradeService.Instance.StartTradeStatus(); //恢复原始交易没有统计上的数据
+                // SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
+                // SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
+                // SycnSpMerchantRecordService.Instance.Start(); //同步SP商户记录数据
 
-                StatService.Instance.StartActiveReward(); //实时处理激活奖励
-                StatService.Instance.StartActiveReward1(); //实时处理0押激活奖励
-                StatService.Instance.StartActiveReward2(); //实时处理盒易付0押激活奖励
-                StatService.Instance.StartActiveReward15(); //实时处理来客吧0押激活奖励
-                StatService.Instance.StartSimActive(); //实时广电卡激活奖励
-                StatService.Instance.StartOpenReward(); //实时获取开机奖励
-                StatService.Instance.StartLeaderReward(); //盟主开机奖励发放
-                StatService.Instance.StartPreActPrize(); //押金奖励发放(激活奖励新规)
-                ActPrizeCheckService.Instance.Start(); //监听无商户号的机具，并再次发奖励
-                StatService.Instance.ListenFluxRecord(); //同步流量费
-                LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
-                OperatePrizeService.Instance.Start(); //运营中心奖励发奖
-                ActRewardService.Instance.Start(); //发放激活奖励
-                ActRewardService.Instance.StartAfterAdd(); //补激活奖励
-                HelpProfitPreMerchantHelper.Instance.Start(); //助利宝每天增加指定数量商机
-                AddActService.Instance.Start(); //划拨后检查机具激活状态，并自动补录
-                PrePosRingService.Instance.Start(); //预发未申请提醒
-                PrePosWithholdService.Instance.Start(); //预发机过期未申请提交到预扣款
-                PrePosWithholdService.Instance.StartPre(); //预发机申请成功，处理预扣款
-                PosWithholdService.Instance.Start(); //过期机具激活，清理预扣款
-                SycnMerchantTradeService.Instance.Start(); //同步商户交易额
-                WifiWarningService.Instance.Start(); //wifi设备过期提醒
-                WifiWithholdService.Instance.Start(); //wifi设备过期预扣款
-                WifiWithholdBackService.Instance.Start(); //wifi设备激活后预扣款处理
+                // StatService.Instance.StartActiveReward(); //实时处理激活奖励
+                // StatService.Instance.StartActiveReward1(); //实时处理0押激活奖励
+                // StatService.Instance.StartActiveReward2(); //实时处理盒易付0押激活奖励
+                // StatService.Instance.StartActiveReward15(); //实时处理来客吧0押激活奖励
+                // StatService.Instance.StartSimActive(); //实时广电卡激活奖励
+                // StatService.Instance.StartOpenReward(); //实时获取开机奖励
+                // StatService.Instance.StartLeaderReward(); //盟主开机奖励发放
+                // StatService.Instance.StartPreActPrize(); //押金奖励发放(激活奖励新规)
+                // ActPrizeCheckService.Instance.Start(); //监听无商户号的机具，并再次发奖励
+                // StatService.Instance.ListenFluxRecord(); //同步流量费
+                // LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
+                // OperatePrizeService.Instance.Start(); //运营中心奖励发奖
+                // ActRewardService.Instance.Start(); //发放激活奖励
+                // ActRewardService.Instance.StartAfterAdd(); //补激活奖励
+                // HelpProfitPreMerchantHelper.Instance.Start(); //助利宝每天增加指定数量商机
+                // AddActService.Instance.Start(); //划拨后检查机具激活状态，并自动补录
+                // PrePosRingService.Instance.Start(); //预发未申请提醒
+                // PrePosWithholdService.Instance.Start(); //预发机过期未申请提交到预扣款
+                // PrePosWithholdService.Instance.StartPre(); //预发机申请成功，处理预扣款
+                // PosWithholdService.Instance.Start(); //过期机具激活，清理预扣款
+                // SycnMerchantTradeService.Instance.Start(); //同步商户交易额
+                // WifiWarningService.Instance.Start(); //wifi设备过期提醒
+                // WifiWithholdService.Instance.Start(); //wifi设备过期预扣款
+                // WifiWithholdBackService.Instance.Start(); //wifi设备激活后预扣款处理
 
-                MessageCenterService.Instance.Start(); // 消息队列
-                LeaderTimeoutSendMessageService.Instance.Start(); //盟主过期消息提醒
+                // MessageCenterService.Instance.Start(); // 消息队列
+                // LeaderTimeoutSendMessageService.Instance.Start(); //盟主过期消息提醒
 
-                AlipayPayBack2Service.Instance.Start(); //支付宝回调处理
-                PosCouponPrizeService.Instance.Start(); //购券奖励队列
-                PosCouponPrizeService.Instance.Start2(); //购券奖励队列（补奖励）
-                OperateAddService.Instance.Start(); //购买运营中心队列
-                BalancePayBackService.Instance.Start(); //余额支付队列
-                ReservePayBackService.Instance.Start(); //储备金支付队列
-                OrderRefundService.Instance.Start(); //商城订单退款
+                // AlipayPayBack2Service.Instance.Start(); //支付宝回调处理
+                // PosCouponPrizeService.Instance.Start(); //购券奖励队列
+                // PosCouponPrizeService.Instance.Start2(); //购券奖励队列（补奖励）
+                // OperateAddService.Instance.Start(); //购买运营中心队列
+                // BalancePayBackService.Instance.Start(); //余额支付队列
+                // ReservePayBackService.Instance.Start(); //储备金支付队列
+                // OrderRefundService.Instance.Start(); //商城订单退款
 
-                StatService.Instance.Start(); //每日重置交易额
-                StoreApplyHelper.Instance.Start(); // 每月1号重置仓库额度
-                DepositReturnStatService.Instance.Start(); //每月1号统计达标商户（退押需要的）
-                DepositReturnStatService.Instance.StartEverTime(); //统计单个商户达标数据（退押需要的）
-                AutoOpOrderService.Instance.StartOrderCancel(); //自动取消超时订单（15分钟）
-                OperateStockService.Instance.Start(); //运营中心库存实时更新
-                ResetSmallStoreHelper.Instance.Start(); //每月重置小分仓额度
-                ResetSmallStoreHelper.Instance.Listen(); //监听每月1号重置小分仓额度
-                ResetSmallStoreHelper.Instance.StartReset(); //监听每月1号重置小分仓额度
-                OperateService.Instance.Start(); //运营中心每天统计一次发货量、库存
-                TimeOutPosChargeService.Instance.StartDoChargeAmount(); //实时监听待扣款记录，并扣费
-                InstallmentDeductionService.Instance.Start(); //分期扣款(每月20号执行)
-                LeaderAmountMonthChangeQueue.Instance.Start(); //每月一号记录上月盟主储蓄金和可提现余额
-                ResetPosFirstFlagAndIsExecuteService.Instance.Start(); //每月1号计算商户首台机具标记
-                OperateAmountRecordService.Instance.Start(); //运营中心额度变更
-                VirtualApplyHelper.Instance.Start(); //申请虚拟广电卡
+                // StatService.Instance.Start(); //每日重置交易额
+                // StoreApplyHelper.Instance.Start(); // 每月1号重置仓库额度
+                // DepositReturnStatService.Instance.Start(); //每月1号统计达标商户（退押需要的）
+                // DepositReturnStatService.Instance.StartEverTime(); //统计单个商户达标数据（退押需要的）
+                // AutoOpOrderService.Instance.StartOrderCancel(); //自动取消超时订单（15分钟）
+                // OperateStockService.Instance.Start(); //运营中心库存实时更新
+                // ResetSmallStoreHelper.Instance.Start(); //每月重置小分仓额度
+                // ResetSmallStoreHelper.Instance.Listen(); //监听每月1号重置小分仓额度
+                // ResetSmallStoreHelper.Instance.StartReset(); //监听每月1号重置小分仓额度
+                // OperateService.Instance.Start(); //运营中心每天统计一次发货量、库存
+                // TimeOutPosChargeService.Instance.StartDoChargeAmount(); //实时监听待扣款记录，并扣费
+                // InstallmentDeductionService.Instance.Start(); //分期扣款(每月20号执行)
+                // LeaderAmountMonthChangeQueue.Instance.Start(); //每月一号记录上月盟主储蓄金和可提现余额
+                // ResetPosFirstFlagAndIsExecuteService.Instance.Start(); //每月1号计算商户首台机具标记
+                // OperateAmountRecordService.Instance.Start(); //运营中心额度变更
+                // VirtualApplyHelper.Instance.Start(); //申请虚拟广电卡
 
-                ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
-                RecommendActStatService.Instance.Start(); //推荐王奖励数据统计
-                StoreApplyHelper.Instance.StartEverTime(); //分仓临时额度变更
-                PreStoreApplyHelper.Instance.StartEverTime(); //小分仓临时额度变更
-                OperateAmountService.Instance.Start(); //运营中心额度变更
-                LeaderApplyCouponsHelper.Instance.Start(); //盟主储蓄金申请机具券打标记
-                DepositReturnService.Instance.Start(); //退押金到支付宝余额
-                StoreApplyHelper.Instance.ResetStoreReserve(); //重置分仓额度
-                AddPosCouponPrizeHelper.Instance.Start(); //补机具券奖励
+                // ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
+                // RecommendActStatService.Instance.Start(); //推荐王奖励数据统计
+                // StoreApplyHelper.Instance.StartEverTime(); //分仓临时额度变更
+                // PreStoreApplyHelper.Instance.StartEverTime(); //小分仓临时额度变更
+                // OperateAmountService.Instance.Start(); //运营中心额度变更
+                // LeaderApplyCouponsHelper.Instance.Start(); //盟主储蓄金申请机具券打标记
+                // DepositReturnService.Instance.Start(); //退押金到支付宝余额
+                // StoreApplyHelper.Instance.ResetStoreReserve(); //重置分仓额度
+                // AddPosCouponPrizeHelper.Instance.Start(); //补机具券奖励
                 
-                PosChannelHelper.Instance.Start(); //实时查询查询终端收单机构
-                UpUserSaveService.Instance.Start(); //每天凌晨保存头一天的创客关系数据
-                HyfAddPrizeService.Instance.Start(); //盒力四射加码奖励发放
-                PrizeFlowRecordService.Instance.Start(); //奖励返现逻辑日志记录
-                PosCouponExchangeHelper.Instance.Start(); //电签券兑换大机券
-                ToBigHelper.Instance.Start(); //机具通对资格
-                TradeFilterService.Instance.Start(); //营训奖励拦截
+                // PosChannelHelper.Instance.Start(); //实时查询查询终端收单机构
+                // UpUserSaveService.Instance.Start(); //每天凌晨保存头一天的创客关系数据
+                // HyfAddPrizeService.Instance.Start(); //盒力四射加码奖励发放
+                // PrizeFlowRecordService.Instance.Start(); //奖励返现逻辑日志记录
+                // PosCouponExchangeHelper.Instance.Start(); //电签券兑换大机券
+                // ToBigHelper.Instance.Start(); //机具通对资格
+                // TradeFilterService.Instance.Start(); //营训奖励拦截
+
+                WifiTradeHelper.Instance.DoSomething("2024-11");
 
                 
                 // RabbitMQClientV2.Instance.CreateConn("KXS_WIFI_TRADE_QUEUE"); //推送wifi每月交易额