wifi每月交易统计上月的

AppStart/Helper/SycnSpServer/SycnSpTradeWifiService.cs

@@ -122,15 +122,15 @@ namespace MySystem
                             string TradeMonth = DateTime.Now.ToString("yyyyMM");
 
                             add.Duration = Months;
-                            add.LastMonth = TradeMonth;
-                            add.DoMonths = 1;
+                            // add.LastMonth = TradeMonth;
+                            // add.DoMonths = 1;
                             add.Unit = "m";
                             db.SaveChanges();
 
                             // if(Months > 0)
                             // {
-                                decimal TradeAmt = TradeAmount / Months;
-                                TradeAmt = PublicFunction.NumberFormat(TradeAmt);
+                                // decimal TradeAmt = TradeAmount / Months;
+                                // TradeAmt = PublicFunction.NumberFormat(TradeAmt);
                                 // 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();
@@ -140,15 +140,15 @@ namespace MySystem
                                 // for (int i = 1; i <= Months; i++)
                                 // {
                                     // StartMonth = StartMonth.AddMonths(1);
-                                    StatTrade(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
-                                    if (pos.BindingTime < DateTime.Now.AddMonths(-9))
-                                    {
-                                        StatTradeBefore(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
-                                    }
-                                    else
-                                    {
-                                        StatTradeAfter(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
-                                    }
+                                    // StatTrade(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
+                                    // if (pos.BindingTime < DateTime.Now.AddMonths(-9))
+                                    // {
+                                    //     StatTradeBefore(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
+                                    // }
+                                    // else
+                                    // {
+                                    //     StatTradeAfter(db, pos.BuyUserId, pos.BrandId, TradeMonth, TradeAmt);
+                                    // }
                                     //推送延时队列
                                     // TimeSpan ts = DateTime.Now - StartMonth;
                                     // RabbitMQClientV2.Instance.SendMsg("{\"pos_sn\":\"" + pos.PosSn + "\",\"amt\":\"" + TradeAmt + "\"}", "KXS_WIFI_TRADE_QUEUE", (uint)ts.TotalMilliseconds);

AppStart/WifiTradeHelper.cs

@@ -30,7 +30,7 @@ public class WifiTradeHelper
             {
                 if(DateTime.Now.Day == 1 && DateTime.Now.Hour < 6)
                 {
-                    string Month = DateTime.Now.ToString("yyyyMM");
+                    string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
                     string chk = function.ReadInstance("/wifi/trade" + Month + ".txt");
                     if(string.IsNullOrEmpty(chk))
                     {
@@ -66,6 +66,7 @@ public class WifiTradeHelper
             if(trade.Unit == "m" && trade.Duration > 0 && !SnNos.Contains(trade.SnNo))
             {
                 decimal TradeAmt = trade.TradeAmount / trade.Duration;
+                TradeAmt = PublicFunction.NumberFormat(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))
@@ -76,12 +77,12 @@ public class WifiTradeHelper
                 {
                     StatTradeAfter(statTradeAfter, users, pos.BuyUserId, pos.BrandId, Month.Replace("-", ""), TradeAmt);
                 }
-                // WifiTradeRecord edit = db.WifiTradeRecord.FirstOrDefault(m => m.Id == trade.Id);
-                // if(edit != null)
-                // {
-                //     edit.DoMonths += 1;
-                //     edit.LastMonth = Month;
-                // }
+                WifiTradeRecord edit = db.WifiTradeRecord.FirstOrDefault(m => m.Id == trade.Id);
+                if(edit != null)
+                {
+                    edit.DoMonths += 1;
+                    edit.LastMonth = Month;
+                }
                 SnNos.Add(trade.SnNo);
             }
         }

Startup.cs

@@ -168,92 +168,91 @@ 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(); //营训奖励拦截
-
-                WifiTradeHelper.Instance.DoSomething("2024-11");
+                PosChannelHelper.Instance.Start(); //实时查询查询终端收单机构
+                UpUserSaveService.Instance.Start(); //每天凌晨保存头一天的创客关系数据
+                HyfAddPrizeService.Instance.Start(); //盒力四射加码奖励发放
+                PrizeFlowRecordService.Instance.Start(); //奖励返现逻辑日志记录
+                PosCouponExchangeHelper.Instance.Start(); //电签券兑换大机券
+                ToBigHelper.Instance.Start(); //机具通对资格
+                TradeFilterService.Instance.Start(); //营训奖励拦截
+                WifiTradeHelper.Instance.Start(); //每月1号统计上月wifi交易
 
                 
                 // RabbitMQClientV2.Instance.CreateConn("KXS_WIFI_TRADE_QUEUE"); //推送wifi每月交易额