分润通过

AppStart/Helper/Profit/ProfitHelper.cs

@@ -334,7 +334,7 @@ namespace MySystem
         {
             // while(true)
             // {
-            //     if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 0)
+            //     if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 2 && DateTime.Now.Hour < 5)
             //     {
                     DoProfit();
             //         Thread.Sleep(600000);
@@ -349,7 +349,13 @@ namespace MySystem
         //分润算法
         public void DoProfit()
         {
-            string TradeMonth = DateTime.Now.ToString("yyyyMM");
+            string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
+            string check = function.ReadInstance("/ProfitFlag/" + TradeMonth + ".txt");
+            if(!string.IsNullOrEmpty(check))
+            {
+                return;
+            }
+            function.WritePage("/ProfitFlag/", TradeMonth + ".txt", DateTime.Now.ToString());
             KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
             WebCMSEntities dbnew = new WebCMSEntities();
             DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", MysqlConn.SqlConnStr);
@@ -708,6 +714,7 @@ namespace MySystem
         #region 分润算法
         public List<ProfitResult> StartProft(decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
         {
+            function.WriteLog("\n\nTotalAmount：" + TotalAmount + "；", "来客吧分润日志");
             string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
             WebCMSEntities db = new WebCMSEntities();
             List<UserLevelSet> levels = db.UserLevelSet.ToList();
@@ -718,6 +725,13 @@ namespace MySystem
                 int maxLevel = obj.MaxLevel; //最大等级
                 int maxFloor = obj.MaxFloor; //最大层级
                 decimal diffLevelProfit = 0;  //等级级差
+                ProfitObjectLevels maxlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == 9) ?? new ProfitObjectLevels(); //获取最高等级参数
+                decimal maxPercent = IsActive ? maxlevel.DebitPercents : maxlevel.Percents;
+                function.WriteLog("maxPercent：" + maxPercent + "；", "来客吧分润日志");
+                decimal maxLevelProfit = TotalAmount * maxPercent;
+                function.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
+                maxLevelProfit = PublicFunction.NumberFormat(maxLevelProfit);
+                function.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
                 // decimal diffDiviProfit = 0; //分红级差
                 int curLevel = 0; //当前层级的会员等级
                 for (int curFloor = 1; curFloor <= users.Count; curFloor++)
@@ -730,7 +744,7 @@ namespace MySystem
                     SubUser selfUser = GetUser(user.UserId, Month) ?? new SubUser();
                     int UserLevel = selfUser.PreUserLevel > selfUser.UserLevel ? selfUser.PreUserLevel : selfUser.UserLevel; //当前会员等级
                     //判断当前创客是否有直推的激活机具，并且在活动时间内
-                    if (UserLevel == maxLevel && UserLevel == curLevel)
+                    if (curLevel == maxLevel)
                     {
                         break;
                     }
@@ -742,9 +756,12 @@ namespace MySystem
                             decimal getLevelProfit = 0;  //等级分润
                             UserProfitSet profitSet = new UserProfitSet();
                             decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
+                            function.WriteLog("money：" + UserLevel + "：" + profitPercent + "；", "来客吧分润日志");
                             if (profitPercent > 0)
                             {
-                                getLevelProfit += TotalAmount * profitPercent;
+                                decimal profitTmp = TotalAmount * profitPercent;
+                                getLevelProfit += profitTmp;
+                                function.WriteLog("money：" + UserLevel + "：" + profitTmp + "；", "来客吧分润日志");
                             }
                             decimal money = getLevelProfit;
                             getLevelProfit -= diffLevelProfit;
@@ -758,16 +775,20 @@ namespace MySystem
                                 {
                                     UserId = user.UserId,
                                     UserNav = user.UserNav,
-                                    Money = getLevelProfit,
+                                    Money = PublicFunction.NumberFormat(getLevelProfit),
                                     ProfitRate = profitSet.ProfitRate,
                                     ProfitPercent = profitSet.ProfitPercent,
                                     AddOrSubRate = profitSet.AddOrSubRate,
                                     ProfitRateBase = profitSet.ProfitRateBase,
                                 });
+                                function.WriteLog("money：" + UserLevel + "：" + PublicFunction.NumberFormat(getLevelProfit) + "；", "来客吧分润日志");
                             }
                         }
                     }
-                    curLevel = UserLevel;
+                    if(curLevel < UserLevel)
+                    {
+                        curLevel = UserLevel;
+                    }
                 }
             }
             db.Dispose();

Startup.cs

@@ -170,23 +170,28 @@ namespace MySystem
             });
 
             //必须打开的
-            MerchantConfirmService.Instance.Start(); //特约商户进件队列
-            CheckAlipaySignService.Instance.Start(); //特约商户签约队列（支付宝）
-            CheckWeChatSignService.Instance.Start(); //特约商户签约队列（微信）
-            AlipayPayBackService.Instance.Start(); //支付宝支付回调队列
-            AlipayPayBackService.Instance.StartProfitShare(); //监听已支付订单，超过1分钟的订单执行分账
-            WeChatPayBackService.Instance.Start(); //微信支付回调队列
-            WeChatPayBackService.Instance.StartProfitShare(); //监听已支付订单，超过1分钟的订单执行分账
-            ProfitHelper.Instance.StartActive(); //发放达标奖励队列
-            ProfitHelper.Instance.StartListenTrade(); //支付宝返现队列
-            ProfitHelper.Instance.StartListenWxTrade(); //微信返现队列
-            ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现（微信）
-            AlipayShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现（支付宝）
+            if(Library.ConfigurationManager.EnvironmentFlag == 2)
+            {
+                MerchantConfirmService.Instance.Start(); //特约商户进件队列
+                CheckAlipaySignService.Instance.Start(); //特约商户签约队列（支付宝）
+                CheckWeChatSignService.Instance.Start(); //特约商户签约队列（微信）
+                AlipayPayBackService.Instance.Start(); //支付宝支付回调队列
+                AlipayPayBackService.Instance.StartProfitShare(); //监听已支付订单，超过1分钟的订单执行分账
+                WeChatPayBackService.Instance.Start(); //微信支付回调队列
+                WeChatPayBackService.Instance.StartProfitShare(); //监听已支付订单，超过1分钟的订单执行分账
+                ProfitHelper.Instance.StartActive(); //发放达标奖励队列
+                ProfitHelper.Instance.StartListenTrade(); //支付宝返现队列
+                ProfitHelper.Instance.StartListenWxTrade(); //微信返现队列
+                ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现（微信）
+                AlipayShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现（支付宝）
+            }
+            else
+            {
+                ProfitHelper.Instance.StartListenProfit();
+            }
             //必须打开的
 
-
-
-            // ProfitHelper.Instance.StartListenProfit();
+            
         }
     }
 }