领导人达标奖修改

调整费率设置逻辑

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -29,13 +29,20 @@ namespace MySystem
             {
                 if(DateTime.Now.Hour > 0 && DateTime.Now.Hour < 23)
                 {
-                    if(DateTime.Now.Day == 1)
+                    
+                    string check = function.ReadInstance("/LeaderComp/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
+                    if(string.IsNullOrEmpty(check))
                     {
-                        Ready(DateTime.Now.AddMonths(-1).ToString("yyyy-MM"));
-                        Thread.Sleep(2000);
-                        CustomerSqlConn.op("insert into LeaderCompTradeStatBak select * from LeaderCompTradeStat;insert into LeaderCompTmpBak select * from LeaderCompTmp;insert into LeaderCompPrizeBak select * from LeaderCompPrize;insert into LeaderCompAddTradeBak select * from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
+                        function.WritePage("/LeaderComp/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString());
+                        // if(DateTime.Now.Day == 1)
+                        // {
+                        //     Ready(DateTime.Now.AddMonths(-1).ToString("yyyy-MM"));
+                        //     Thread.Sleep(2000);
+                        //     CustomerSqlConn.op("insert into LeaderCompTradeStatBak select * from LeaderCompTradeStat;insert into LeaderCompTmpBak select * from LeaderCompTmp;insert into LeaderCompPrizeBak select * from LeaderCompPrize;insert into LeaderCompAddTradeBak select * from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
+                        // }
+                        // // Ready(DateTime.Now.ToString("yyyy-MM"));
+                        Ready("202310");
                     }
-                    Ready(DateTime.Now.ToString("yyyy-MM"));
                 }
                 Thread.Sleep(60000);
             }
@@ -43,31 +50,27 @@ namespace MySystem
 
         public void Ready(string curMonth)
         {
-            string check = function.ReadInstance("/LeaderComp/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
-            if(!string.IsNullOrEmpty(check))
-            {
-                return;
-            }
-            function.WritePage("/LeaderComp/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString());
             CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;delete from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
-            Thread.Sleep(10000);
-            DateTime Start = DateTime.Parse("2023-06-01 00:00:00");
-            DateTime now = DateTime.Parse(curMonth + "-01 00:00:00");
-            while(now > Start)
-            {
-                string month = now.ToString("yyyyMM");
-                string checkMonth = Start.ToString("yyyyMM");
-                doSomething(month, checkMonth);
-                Start = Start.AddMonths(1);
-            }
-            Start = DateTime.Parse("2023-06-01 00:00:00");
-            while(now > Start)
-            {
-                string month = now.ToString("yyyyMM");
-                string checkMonth = Start.ToString("yyyyMM");
-                SendPrize(month, checkMonth);
-                Start = Start.AddMonths(1);
-            }
+            // Thread.Sleep(10000);
+            // DateTime Start = DateTime.Parse("2023-06-01 00:00:00");
+            // DateTime now = DateTime.Parse(curMonth + "-01 00:00:00");
+            // while(now > Start)
+            // {
+            //     string month = now.ToString("yyyyMM");
+            //     string checkMonth = Start.ToString("yyyyMM");
+            //     doSomething(month, checkMonth);
+            //     now = now.AddMonths(-1);
+            // }
+            // now = DateTime.Parse(curMonth + "-01 00:00:00");
+            // while(now > Start)
+            // {
+            //     string month = now.ToString("yyyyMM");
+            //     string checkMonth = Start.ToString("yyyyMM");
+            //     SendPrize(month, checkMonth);
+            //     now = now.AddMonths(-1);
+            // }
+            doSomething("202310", "202309");
+            SendPrize("202310", "202309");
         }
 
         public void doSomething(string month, string checkMonth)
@@ -76,16 +79,52 @@ namespace MySystem
             {
                 WebCMSEntities db = new WebCMSEntities();
                 OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
+                MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
+                MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
                 string MonthString = month + "-" + checkMonth;
 
                 //统计交易增量
                 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
-                DataTable dt = CustomerSqlConn.dtable("select CONCAT('insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount,SelfTradeAmount,CheckTradeAmount,CheckSelfTradeAmount) values (now(),', UserId,',\\\'" + month + "-" + checkMonth + "\\\',', amt" + month + ",',', samt" + month + ",',', amt" + checkMonth + ",',', samt" + checkMonth + ",');') from (select UserId,(case when amt" + month + " is null then 0 else amt" + month + " end) amt" + month + ",(case when samt" + month + " is null then 0 else samt" + month + " end) samt" + month + ",(case when amt" + checkMonth + " is null then 0 else amt" + checkMonth + " end) amt" + checkMonth + ",(case when samt" + checkMonth + " is null then 0 else samt" + checkMonth + " end) samt" + checkMonth + " from (select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) amt" + month + ",(select sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='team' and UserId=main.UserId) amt" + checkMonth + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + month + " where SeoTitle='self' and UserId=main.UserId) samt" + month + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='self' and UserId=main.UserId) samt" + checkMonth + " from TradeDaySummary" + month + " main where SeoTitle='team' and UserId>0 group by UserId) tb) tb2", MysqlConn.RdsStatSqlConnStr);
+
+
+                
+                //创客团队交易额
                 string sql = "";
                 int num = 0;
+                DataTable dt = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) Amt from TradeDaySummary" + month + " where SeoTitle='team' and UserId>0 group by UserId", MysqlConn.StatSqlConnStr);
                 foreach(DataRow dr in dt.Rows)
                 {
-                    sql += dr[0].ToString();
+                    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 + ")";
                     num += 1;
                     if(num >= 200)
                     {
@@ -94,40 +133,58 @@ namespace MySystem
                         num = 0;
                     }
                 }
+
+
+                // DataTable dt = CustomerSqlConn.dtable("select CONCAT('insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount,SelfTradeAmount,CheckTradeAmount,CheckSelfTradeAmount) values (now(),', UserId,',\\\'" + month + "-" + checkMonth + "\\\',', amt" + month + ",',', samt" + month + ",',', amt" + checkMonth + ",',', samt" + checkMonth + ",');') from (select UserId,(case when amt" + month + " is null then 0 else amt" + month + " end) amt" + month + ",(case when samt" + month + " is null then 0 else samt" + month + " end) samt" + month + ",(case when amt" + checkMonth + " is null then 0 else amt" + checkMonth + " end) amt" + checkMonth + ",(case when samt" + checkMonth + " is null then 0 else samt" + checkMonth + " end) samt" + checkMonth + " from (select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) amt" + month + ",(select sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='team' and UserId=main.UserId) amt" + checkMonth + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + month + " where SeoTitle='self' and UserId=main.UserId) samt" + month + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='self' and UserId=main.UserId) samt" + checkMonth + " from TradeDaySummary" + month + " main where SeoTitle='team' and UserId>0 group by UserId) tb) tb2", MysqlConn.RdsStatSqlConnStr);
+
+
                 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='" + month + "-" + checkMonth + "' and UserId>1", 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(DateTime.Now.ToString(), "领导人达标奖励日志");
+                function.WriteLog("start-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
 
                 //计算创客名下的达标人数，直推和间接
                 function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志");
+                
+                // DataTable stats = CustomerSqlConn.dtable("select SelfTradeAmount-CheckSelfTradeAmount from LeaderCompTradeStat p where StatMonth='" + MonthString + "'", MysqlConn.SqlConnStr);
+
                 List<LeaderCompTradeStat> stats = db.LeaderCompTradeStat.Where(m => m.StatMonth == MonthString).ToList();
                 function.WriteLog(stats.Count.ToString(), "领导人达标奖励日志");
                 foreach(LeaderCompTradeStat stat in stats)
                 {
-                    decimal totalAmount = stat.SelfTradeAmount - stat.CheckSelfTradeAmount; //当月交易
-                    List<LeaderCompTradeStat> directs = stats.Where(m => m.ParentUserId == stat.UserId).ToList();
-                    foreach(LeaderCompTradeStat direct in directs)
-                    {
-                        decimal parentTotalAmount = direct.TradeAmount - direct.CheckTradeAmount;
-                        if(parentTotalAmount < 30000000)
-                        {
-                            totalAmount += parentTotalAmount;
-                        }
-                    }
+                    function.WriteLog("1-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
+                    decimal totalAmount = stat.TradeAmount; // - stat.CheckSelfTradeAmount; //当月交易
+                    // List<LeaderCompTradeStat> directs = stats.Where(m => m.ParentUserId == stat.UserId).ToList();
+                    // foreach(LeaderCompTradeStat direct in directs)
+                    // {
+                    //     decimal parentTotalAmount = direct.TradeAmount - direct.CheckTradeAmount;
+                    //     if(parentTotalAmount < 30000000)
+                    //     {
+                    //         totalAmount += parentTotalAmount;
+                    //     }
+                    // }
+                    // DataTable directs = CustomerSqlConn.dtable("select sum(TradeAmount) from LeaderCompTradeStat where ParentUserId=" + stat.UserId + " and StatMonth='" + MonthString + "' and TradeAmount<30000000", MysqlConn.SqlConnStr);
+                    // function.WriteLog("2-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
+                    // if(directs.Rows.Count > 0)
+                    // {
+                    //     totalAmount += decimal.Parse(function.CheckNum(directs.Rows[0][0].ToString()));
+                    // }
+
                     function.WriteLog("UserId:" + stat.UserId, "领导人达标奖励日志");
                     function.WriteLog("totalAmount:" + totalAmount, "领导人达标奖励日志");
+                    function.WriteLog("3-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
+                    LeaderCompTradeStat statEdit = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString);
+                    if(statEdit != null)
+                    {
+                        statEdit.ResultTradeAmount = totalAmount;
+                        // db.SaveChanges();
+                    }
                     if(totalAmount >= 30000000 && !string.IsNullOrEmpty(stat.ParentNav))
                     {
-                        LeaderCompTradeStat statEdit = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString);
-                        if(statEdit != null)
-                        {
-                            statEdit.ResultTradeAmount = totalAmount;
-                            db.SaveChanges();
-                        }
+                        function.WriteLog("4-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                         LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == stat.UserId);
                         if(tmp == null)
                         {
@@ -154,6 +211,7 @@ namespace MySystem
                         }
                         tmp.EveryMonthData = Newtonsoft.Json.JsonConvert.SerializeObject(EveryMonthData);
                         db.SaveChanges();
+                        function.WriteLog("5-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                         string[] parents = stat.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                         Array.Reverse(parents);
                         int index = 0;
@@ -185,24 +243,33 @@ namespace MySystem
                             }
                             db.SaveChanges();
                         }
+                        function.WriteLog("6-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     }
-                    LeaderCompAddTrade addTrade = db.LeaderCompAddTrade.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString);
-                    if(addTrade == null)
-                    {
-                        addTrade = db.LeaderCompAddTrade.Add(new LeaderCompAddTrade()
-                        {
-                            CreateDate = DateTime.Now,
-                            UserId = stat.UserId,
-                            StatMonth = MonthString,
-                        }).Entity;
-                        db.SaveChanges();
-                    }
-                    addTrade.AddTradeAmount = totalAmount < 0 ? 0 : totalAmount;
-                    db.SaveChanges();
+                    // LeaderCompAddTrade addTrade = db.LeaderCompAddTrade.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString);
+                    // if(addTrade == null)
+                    // {
+                    //     addTrade = db.LeaderCompAddTrade.Add(new LeaderCompAddTrade()
+                    //     {
+                    //         CreateDate = DateTime.Now,
+                    //         UserId = stat.UserId,
+                    //         StatMonth = MonthString,
+                    //     }).Entity;
+                    //     db.SaveChanges();
+                    // }
+                    // addTrade.AddTradeAmount = totalAmount < 0 ? 0 : totalAmount;
+                    // db.SaveChanges();
+                    function.WriteLog("7-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     function.WriteLog(DateTime.Now.ToString() + "------" + stat.UserId, "领导人达标奖励日志");
                 }
+                db.SaveChanges();
+                opdb.Dispose();
+                mpmaindb.Dispose();
+                mpmaindb2.Dispose();
                 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
-                db.Dispose();
+                
+                CustomerSqlConn.op("insert into LeaderCompAddTrade (UserId,StatMonth,CreateDate,AddTradeAmount) select UserId,StatMonth,now(),ResultTradeAmount from LeaderCompTradeStat where ResultTradeAmount>0 and StatMonth='" + MonthString + "'", MysqlConn.SqlConnStr);
+                
+                CustomerSqlConn.op("update LeaderCompTradeStat set ResultTradeAmount=0 where ResultTradeAmount<30000000 and StatMonth='" + MonthString + "'", MysqlConn.SqlConnStr);
             }
             catch(Exception ex)
             {
@@ -213,6 +280,7 @@ namespace MySystem
         private void SendPrize(string month, string checkDate)
         {
             string MonthFlag = month + "-" + checkDate;
+            function.WriteLog("发放奖励" + MonthFlag, "领导人达标奖励日志");
             WebCMSEntities db = new WebCMSEntities();
             OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
             //计算运营中心或大盟主达标奖励
@@ -220,24 +288,26 @@ namespace MySystem
             function.WriteLog(leaderPrizes.Count.ToString(), "领导人达标奖励日志");
             foreach(LeaderCompPrize leaderPrize in leaderPrizes)
             {
+                function.WriteLog("发放人" + leaderPrize.UserId, "领导人达标奖励日志");
                 Users user = db.Users.FirstOrDefault(m => m.Id == leaderPrize.UserId) ?? new Users();
-                // if(user.UserType == 1)
-                // {
-                //     OpModels.SysAdmin opSys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == user.Id);
-                //     if(opSys != null)
-                //     {
-                //         // checkDate = opSys.CreateDate.Value.AddMonths(-1).ToString("yyyyMM");
-                //     }
-                // }
-                // else if(user.LeaderLevel == 2)
-                // {
-                //     Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == user.Id);
-                //     if(leader != null)
-                //     {
-                //         // checkDate = leader.LastBuyDate.Value.AddMonths(-1).ToString("yyyyMM");
-                //     }
-                // }
+                if(user.UserType == 1)
+                {
+                    OpModels.SysAdmin opSys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == user.Id);
+                    if(opSys != null)
+                    {
+                        checkDate = opSys.CreateDate.Value.AddMonths(-1).ToString("yyyyMM");
+                    }
+                }
+                else if(user.LeaderLevel == 2)
+                {
+                    Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == user.Id);
+                    if(leader != null)
+                    {
+                        checkDate = leader.LastBuyDate.Value.AddMonths(-1).ToString("yyyyMM");
+                    }
+                }
                 string CheckJson = "\"" + MonthFlag + "\":1";
+                function.WriteLog("CheckJson：" + CheckJson, "领导人达标奖励日志");
                 string NavUserId = "," + user.Id + ",";
                 int person = 0;
                 int directPerson = 0;
@@ -246,6 +316,7 @@ namespace MySystem
                 foreach(var subuser in subusers)
                 {
                     string subNavUserId = "," + subuser.Id + ",";
+                    function.WriteLog("------subNavUserId：" + subNavUserId, "领导人达标奖励日志");
                     if(db.LeaderCompTmp.Count(m => (m.ParentNav.Contains(subNavUserId) || m.Id == subuser.Id) && m.EveryMonthData.Contains(CheckJson)) > 0)
                     {
                         person += 1;
@@ -255,16 +326,9 @@ namespace MySystem
                         directPerson += 1;
                     }
                 }
-
-                // List<LeaderCompPrize> list = db.LeaderCompPrize.Where(m => m.StatMonth == MonthFlag && m.ParentUserId == user.Id).ToList();
-                // foreach(LeaderCompPrize sub in list)
-                // { 
-                //     if(sub.DirectCount + sub.NotDirectCount > 0)
-                //     {
-                //         person += 1;
-                //     }
-                //     totalPerson += sub.DirectCount + sub.NotDirectCount;
-                // }
+                function.WriteLog("directPerson：" + directPerson, "领导人达标奖励日志");
+                function.WriteLog("person" + person, "领导人达标奖励日志");
+                function.WriteLog("totalPerson" + totalPerson, "领导人达标奖励日志");
 
                 int maxPerson = person * person;
                 decimal CompPrize = 0;
@@ -284,6 +348,7 @@ namespace MySystem
                     edit.NotDirectCount = totalPerson - person;
                     edit.SecDirectCount = person;
                     edit.CompPrize = CompPrize;
+                    function.WriteLog("已设置", "领导人达标奖励日志");
                 }
                 db.SaveChanges();
             }
@@ -295,30 +360,31 @@ namespace MySystem
         private decimal GetPrize(int count, int direct)
         {
             decimal prize = 0;
-            if (count + direct >= 30)
-            {
-                prize = 3000 * (count + direct * 2);
-            }
-            else if (count + direct >= 25)
-            {
-                prize = 2500 * (count + direct * 2);
-            }
-            else if (count + direct >= 20)
-            {
-                prize = 2000 * (count + direct * 2);
-            }
-            else if (count + direct >= 15)
-            {
-                prize = 1500 * (count + direct * 2);
-            }
-            else if (count + direct >= 10)
-            {
-                prize = 1000 * (count + direct * 2);
-            }
-            else if (count + direct >= 5)
-            {
-                prize = 500 * (count + direct * 2);
-            }
+            // if (count + direct >= 30)
+            // {
+            //     prize = 3000 * (count + direct * 2);
+            // }
+            // else if (count + direct >= 25)
+            // {
+            //     prize = 2500 * (count + direct * 2);
+            // }
+            // else if (count + direct >= 20)
+            // {
+            //     prize = 2000 * (count + direct * 2);
+            // }
+            // else if (count + direct >= 15)
+            // {
+            //     prize = 1500 * (count + direct * 2);
+            // }
+            // else if (count + direct >= 10)
+            // {
+            //     prize = 1000 * (count + direct * 2);
+            // }
+            // else if (count + direct >= 5)
+            // {
+            //     prize = 500 * (count + direct * 2);
+            // }
+            prize = 500 * count;
             return prize;
         }
     

AppStart/Helper/SetDepositService.cs

@@ -83,9 +83,20 @@ namespace MySystem
                                         pos.DownFeeFlag = 1;
                                         pos.DownFeeMan = OpMan;
                                         pos.DownFeeDate = DateTime.Now;
+                                        pos.DownFee = 0.63M;
                                         merchant.Status = 0;
                                         // merchant.SeoKeyword = "";
-                                        SetRecordResult(db, RecordId, 1);
+                                        // SetRecordResult(db, RecordId, 1);
+                                    }
+                                    else if(Kind == 3)
+                                    {
+                                        pos.DownFeeFlag = 1;
+                                        pos.DownFeeMan = OpMan;
+                                        pos.DownFeeDate = DateTime.Now;
+                                        pos.DownFee = 0.6M;
+                                        merchant.Status = 0;
+                                        // merchant.SeoKeyword = "";
+                                        // SetRecordResult(db, RecordId, 1);
                                     }
                                     db.SaveChanges();
                                     pos.QueryCount = Kind;

Config/MysqlConn.cs

@@ -7,5 +7,8 @@ namespace MySystem
         public static string SqlConnStr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
         public static string OpSqlConnStr = ConfigurationManager.AppSettings["OpSqlConnStr"].ToString();
         public static string RdsStatSqlConnStr = ConfigurationManager.AppSettings["RdsStatSqlConnStr"].ToString();
+        public static string StatSqlConnStr = ConfigurationManager.AppSettings["MainSqlConnStr"].ToString();
+
+        
     }
 }

Startup.cs

@@ -163,6 +163,7 @@ namespace MySystem
             //必须打开的
             if(Library.ConfigurationManager.EnvironmentFlag == 1)
             {
+                LeaderCompPrizeHelper.Instance.Ready("202310");
             }
             if(Library.ConfigurationManager.EnvironmentFlag == 2)
             {

appsettings.json

@@ -19,7 +19,7 @@
     "Database": "KxsMainServer",
     "SqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;",
     "Pxc1SqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;",
-    "MainSqlConnStr": "server=47.108.231.170;port=3306;user=KxsMain;password=mzeqjriUWore0dwT;database=KxsStatServer;charset=utf8;",
+    "MainSqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsStatServer;charset=utf8;",
     "SpSqlConnStr": "server=47.108.229.115;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
     "OpSqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsOpServer;charset=utf8;",
     "MpSqlConnStr": "server=rm-2vc27k81v217qs1t55o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=QrCodePlateMainServer;password=ll4DFaALMu9YIooM;database=QrCodePlateMainServer;charset=utf8;",