开启队列，恢复领导人达标奖执行代码

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -49,8 +49,8 @@ namespace MySystem
 
         public void Ready(string curMonth)
         {
-            // CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;delete from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
-            // doSomething(curMonth, curMonth);
+            CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;delete from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
+            doSomething(curMonth, curMonth);
             SendPrize(curMonth, curMonth);
         }
 
@@ -66,60 +66,58 @@ namespace MySystem
 
                 //统计交易增量
                 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
-
-
                 
                 //创客团队交易额
-                // string sql = "";
-                // int num = 0;
-                // DataTable dt = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) Amt from TradeDaySummary where Id>=15055757 and TradeMonth='" + month + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.ReadSqlConnStr);
-                // foreach(DataRow dr in dt.Rows)
-                // {
-                //     int UserId = int.Parse(dr["UserId"].ToString());
-                //     decimal TradeAmount = decimal.Parse(dr["Amt"].ToString());
-                //     //码牌团队交易额（直联）
-                //     bool check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
-                //     if (check)
-                //     {
-                //         TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
-                //     }
-                //     check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
-                //     if (check)
-                //     {
-                //         TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount);
-                //     }
-                //     //码牌团队交易额（银联）
-                //     check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
-                //     if (check)
-                //     {
-                //         TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
-                //     }
-                //     check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
-                //     if (check)
-                //     {
-                //         TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount);
-                //     }
-                //     //广电卡扶持期按1万/张计入职级
-                //     check = db.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14);
-                //     if (check)
-                //     {
-                //         TradeAmount += db.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
-                //     }
-                //     sql += "insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount) values (now(), " + UserId + ", '" + month + "-" + checkMonth + "', " + TradeAmount + ");\n";
-                //     num += 1;
-                //     if(num >= 200)
-                //     {
-                //         CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
-                //         sql = "";
-                //         num = 0;
-                //     }
-                // }
+                string sql = "";
+                int num = 0;
+                DataTable dt = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) Amt from TradeDaySummary where Id>=15055757 and TradeMonth='" + month + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.ReadSqlConnStr);
+                foreach(DataRow dr in dt.Rows)
+                {
+                    int UserId = int.Parse(dr["UserId"].ToString());
+                    decimal TradeAmount = decimal.Parse(dr["Amt"].ToString());
+                    //码牌团队交易额（直联）
+                    bool check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
+                    if (check)
+                    {
+                        TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
+                    }
+                    check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
+                    if (check)
+                    {
+                        TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount);
+                    }
+                    //码牌团队交易额（银联）
+                    check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
+                    if (check)
+                    {
+                        TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
+                    }
+                    check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1);
+                    if (check)
+                    {
+                        TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount);
+                    }
+                    //广电卡扶持期按1万/张计入职级
+                    check = db.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14);
+                    if (check)
+                    {
+                        TradeAmount += db.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
+                    }
+                    sql += "insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount) values (now(), " + UserId + ", '" + month + "-" + checkMonth + "', " + TradeAmount + ");\n";
+                    num += 1;
+                    if(num >= 200)
+                    {
+                        CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
+                        sql = "";
+                        num = 0;
+                    }
+                }
 
-                // if(!string.IsNullOrEmpty(sql))
-                // {
-                //     CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
-                // }
-                // CustomerSqlConn.op("update LeaderCompTradeStat leader set ParentUserId=case when (select ParentUserId from Users where Id=leader.UserId) is null then 0 else (select ParentUserId from Users where Id=leader.UserId) end,ParentNav=(select ParentNav from Users where Id=leader.UserId) where StatMonth='" + MonthString + "' and UserId>1", MysqlConn.SqlConnStr);
+                if(!string.IsNullOrEmpty(sql))
+                {
+                    CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
+                }
+                CustomerSqlConn.op("update LeaderCompTradeStat leader set ParentUserId=case when (select ParentUserId from Users where Id=leader.UserId) is null then 0 else (select ParentUserId from Users where Id=leader.UserId) end,ParentNav=(select ParentNav from Users where Id=leader.UserId) where StatMonth='" + MonthString + "' and UserId>1", MysqlConn.SqlConnStr);
 
                 function.WriteLog("start-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
 

Startup.cs

@@ -163,67 +163,67 @@ namespace MySystem
             //必须打开的
             if(Library.ConfigurationManager.EnvironmentFlag == 1)
             {
-                LeaderCompPrizeHelper.Instance.Ready("202312"); //领导人达标奖
+                // LeaderCompPrizeHelper.Instance.Ready("202312"); //领导人达标奖
                 // StatService.Instance.StatUserLevelStartNew();
             }
             if(Library.ConfigurationManager.EnvironmentFlag == 2)
             {
-                // SycnSpBindService.Instance.Start(); //同步SP绑定数据
-                // SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
-                // SycnSpMerchantService.Instance.Start(); //同步SP商户数据
-                // SycnSpActiveService.Instance.Start(); //同步SP激活数据
-                // SycnSpTradeService.Instance.Start(); //同步SP交易数据
-                // SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
-                // SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
-                // SycnSpMerchantRecordService.Instance.Start(); //同步SP商户记录数据
+                SycnSpBindService.Instance.Start(); //同步SP绑定数据
+                SycnSpBindService.Instance.StartSim(); //同步SP广电卡绑定数据
+                SycnSpMerchantService.Instance.Start(); //同步SP商户数据
+                SycnSpActiveService.Instance.Start(); //同步SP激活数据
+                SycnSpTradeService.Instance.Start(); //同步SP交易数据
+                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.StartSimActive(); //实时广电卡激活奖励
-                // StatService.Instance.StartOpenReward(); //实时获取开机奖励
-                // LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
-                // OperatePrizeService.Instance.Start(); //运营中心奖励发奖
-                // ActRewardService.Instance.Start(); //发放激活奖励
-                // HelpProfitPreMerchantHelper.Instance.Start(); //助利宝每天增加指定数量商机
-                // AddActService.Instance.Start(); //划拨后检查机具激活状态，并自动补录
-                // PrePosRingService.Instance.Start(); //预发未申请提醒
-                // PrePosWithholdService.Instance.Start(); //预发机过期未申请提交到预扣款
-                // PrePosWithholdService.Instance.StartPre(); //预发机申请成功，处理预扣款
-                // SycnMerchantTradeService.Instance.Start(); //同步商户交易额
+                StatService.Instance.StartActiveReward(); //实时处理激活奖励
+                StatService.Instance.StartActiveReward1(); //实时处理0押激活奖励
+                StatService.Instance.StartActiveReward2(); //实时处理盒易付0押激活奖励
+                StatService.Instance.StartSimActive(); //实时广电卡激活奖励
+                StatService.Instance.StartOpenReward(); //实时获取开机奖励
+                LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
+                OperatePrizeService.Instance.Start(); //运营中心奖励发奖
+                ActRewardService.Instance.Start(); //发放激活奖励
+                HelpProfitPreMerchantHelper.Instance.Start(); //助利宝每天增加指定数量商机
+                AddActService.Instance.Start(); //划拨后检查机具激活状态，并自动补录
+                PrePosRingService.Instance.Start(); //预发未申请提醒
+                PrePosWithholdService.Instance.Start(); //预发机过期未申请提交到预扣款
+                PrePosWithholdService.Instance.StartPre(); //预发机申请成功，处理预扣款
+                SycnMerchantTradeService.Instance.Start(); //同步商户交易额
 
-                // MessageCenterService.Instance.Start(); // 消息队列
-                // LeaderTimeoutSendMessageService.Instance.Start(); //盟主过期消息提醒
+                MessageCenterService.Instance.Start(); // 消息队列
+                LeaderTimeoutSendMessageService.Instance.Start(); //盟主过期消息提醒
 
-                // AlipayPayBack2Service.Instance.Start(); //支付宝回调处理
-                // BalancePayBackService.Instance.Start(); //余额支付队列
-                // ReservePayBackService.Instance.Start(); //储备金支付队列
-                // OrderRefundService.Instance.Start(); //商城订单退款
+                AlipayPayBack2Service.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号重置小分仓额度
-                // OperateService.Instance.Start(); //运营中心每天统计一次发货量、库存
-                // TimeOutPosChargeService.Instance.StartDoChargeAmount(); //实时监听待扣款记录，并扣费
-                // InstallmentDeductionService.Instance.Start(); //分期扣款(每月20号执行)
-                // LeaderAmountMonthChangeQueue.Instance.Start(); //每月一号记录上月盟主储蓄金和可提现余额
-                // LeaderCompPrizeHelper.Instance.Start(); //领导人达标奖
-                // ResetPosFirstFlagAndIsExecuteService.Instance.Start(); //每月1号计算商户首台机具标记
+                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号重置小分仓额度
+                OperateService.Instance.Start(); //运营中心每天统计一次发货量、库存
+                TimeOutPosChargeService.Instance.StartDoChargeAmount(); //实时监听待扣款记录，并扣费
+                InstallmentDeductionService.Instance.Start(); //分期扣款(每月20号执行)
+                LeaderAmountMonthChangeQueue.Instance.Start(); //每月一号记录上月盟主储蓄金和可提现余额
+                LeaderCompPrizeHelper.Instance.Start(); //领导人达标奖
+                ResetPosFirstFlagAndIsExecuteService.Instance.Start(); //每月1号计算商户首台机具标记
 
-                // 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(); //补机具券奖励
 
                 // TestHelper.Instance.Start();
             }