领导达标奖调整

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -194,7 +194,7 @@ namespace MySystem
                     string ParentNav = stat["ParentNav"].ToString();
                     
                     //计算达标市场
-                    if((totalAmount >= 30000000 && totalAmount - bigTradeAmount >= 12000000) || BigCount >= 2 || totalAmount - bigTradeAmount >= 30000000)
+                    if((BigCount == 1 && smallTradeAmount >= 12000000) || BigCount >= 2 || smallTradeAmount >= 30000000)
                     {
                         LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == UserId);
                         if(tmp == null)
@@ -212,38 +212,41 @@ namespace MySystem
                     }
 
                     //培养奖
-                    if(totalAmount - bigTradeAmount < 30000000) BigCount -= 1;
+                    if(smallTradeAmount < 30000000) BigCount -= 1;
                     if(BigCount > 0)
                     {
-                        decimal leaderOnePrize = 2500;
-                        decimal operaterOnePrize = 3000;
+                        // decimal leaderOnePrize = 2500;
+                        // decimal operaterOnePrize = 3000;
                         decimal onePrize = 0;
                         if(BigCount == 1) onePrize = 2000;
                         if(BigCount == 2) onePrize = 2500;
+                        if(LeaderType == 2) onePrize = 2500;
                         if(BigCount == 3) 
                         {
                             onePrize = 3000;
-                            leaderOnePrize = 3000;
+                            // leaderOnePrize = 3000;
                         }
+                        if(LeaderType > 2) onePrize = 3000;
                         if(BigCount == 4) 
                         {
                             onePrize = 4000;
-                            leaderOnePrize = 4000;
-                            operaterOnePrize = 4000;
+                            // leaderOnePrize = 4000;
+                            // operaterOnePrize = 4000;
                         }
                         if(BigCount == 5) 
                         {
                             onePrize = 5000;
-                            leaderOnePrize = 5000;
-                            operaterOnePrize = 5000;
+                            // leaderOnePrize = 5000;
+                            // operaterOnePrize = 5000;
                         }
                         if(BigCount >= 6) 
                         {
                             onePrize = 6000;
-                            leaderOnePrize = 6000;
-                            operaterOnePrize = 6000;
+                            // leaderOnePrize = 6000;
+                            // operaterOnePrize = 6000;
                         }
-                        decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
+                        // decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
+                        decimal tradePrize = onePrize * BigCount; //培养奖金额
                         sqlString += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (0," + totalAmount + "," + tradePrize + ",now(),'" + MonthString + "'," + UserId + ");";
                     }
                 }
@@ -263,43 +266,52 @@ namespace MySystem
             string sql = "";
             string MonthFlag = month;
             WebCMSEntities db = new WebCMSEntities();
-            DataTable dt = CustomerSqlConn.dtable("select ParentUserId,ParentNav,count(1) from LeaderCompTmp where EveryMonthData='1' GROUP BY ParentUserId,ParentNav", MysqlConn.SqlConnStr);
+            DataTable dt = CustomerSqlConn.dtable("select * from (select UserId,ParentUserId,ParentNav,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigCount from LeaderCompTradeStat p where StatMonth='" + month + "' and LeaderType>=2) tb where BigCount>0", MysqlConn.SqlConnStr);
             foreach(DataRow dr in dt.Rows)
             {
-                int ParentUserId = int.Parse(function.CheckInt(dr["ParentUserId"].ToString()));
+                int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
+                function.WriteLog(UserId.ToString(), "核对");
                 string ParentNav = dr["ParentNav"].ToString();
-                int Count = int.Parse(function.CheckInt(dr[2].ToString()));
-                LeaderCompPrize edit = db.LeaderCompPrize.FirstOrDefault(m => m.StatMonth == MonthFlag && m.UserId == ParentUserId);
+                int Count = int.Parse(function.CheckInt(dr["BigCount"].ToString()));
+                function.WriteLog(Count.ToString(), "核对");
+                LeaderCompPrize edit = db.LeaderCompPrize.FirstOrDefault(m => m.StatMonth == MonthFlag && m.UserId == UserId);
                 if(edit == null)
                 {
                     edit = db.LeaderCompPrize.Add(new LeaderCompPrize()
                     {
                         CreateDate = DateTime.Now,
                         StatMonth = MonthFlag,
-                        UserId = ParentUserId,
+                        UserId = UserId,
                     }).Entity;
                     db.SaveChanges();
                 }
                 edit.DirectCount = Count; //达标市场
-                DataTable dtsub = CustomerSqlConn.dtable("select SUBSTRING_INDEX(SUBSTRING_INDEX(REPLACE(ParentNav, '" + ParentNav + "', ''),',',1),',',-1),count(1) from LeaderCompTmp where ParentUserId!=" + ParentUserId + " and ParentNav like '%," + ParentUserId + ",%' and EveryMonthData='1' group by SUBSTRING_INDEX(SUBSTRING_INDEX(REPLACE(ParentNav, '" + ParentNav + "', ''),',',1),',',-1)", MysqlConn.SqlConnStr);
+                DataTable dtsub = CustomerSqlConn.dtable("select UserId from LeaderCompTradeStat where ParentUserId=" + UserId, MysqlConn.SqlConnStr);
                 foreach(DataRow drsub in dtsub.Rows)
                 {
-                    int SubCount = int.Parse(function.CheckInt(drsub[1].ToString()));
+                    int SubCount = 0;
+                    DataTable subuser = CustomerSqlConn.dtable("select count(1) from LeaderCompTmp where ParentNav like '%," + drsub["UserId"].ToString() + ",%'", MysqlConn.SqlConnStr);
+                    if(subuser.Rows.Count > 0)
+                    {
+                        SubCount = int.Parse(function.CheckInt(subuser.Rows[0][0].ToString()));
+                    }
+                    function.WriteLog("SubCount:" + SubCount, "核对");
                     edit.NotDirectCount += SubCount; //深度达标总数
-                    if(SubCount > Count * Count)
+                    if(SubCount > Count)
                     {
-                        SubCount = Count * Count;
+                        SubCount = Count;
                     }
                     edit.SecDirectCount += SubCount; //深度达标计奖数
                 }
+                function.WriteLog(edit.SecDirectCount.ToString(), "核对");
                 decimal CompPrize = edit.SecDirectCount * 1000;
                 edit.CompPrize = CompPrize;
                 db.SaveChanges();
 
-                LeaderCompTradeStat stat = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == ParentUserId) ?? new LeaderCompTradeStat();
-                if(stat.LeaderType > 1)
+                LeaderCompTradeStat stat = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == UserId) ?? new LeaderCompTradeStat();
+                if(stat.LeaderType > 1 && CompPrize > 0)
                 {
-                    sql += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (1," + stat.TradeAmount + "," + CompPrize + ",now(),'" + MonthFlag + "'," + ParentUserId + ");";
+                    sql += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (1," + stat.TradeAmount + "," + CompPrize + ",now(),'" + MonthFlag + "'," + UserId + ");";
                 }
             }
             CustomerSqlConn.op(sql, MysqlConn.JavaUserSqlConnStr);