调整领导奖入库条件

AppStart/Helper/LeaderCompPrize2Helper.cs

@@ -97,7 +97,8 @@ namespace MySystem
                 int rownum = 0;
                 int num = 0;
                 List<LeaderCompUser> UserData = new List<LeaderCompUser>();
-                string rootsql = "select tb.user_id,pid,pid_path,leader_type,trade_amt from (select user_id,trade_amt from kxs_user_trade_info where trade_month='" + month + "' and trade_amt>0) tb LEFT JOIN kxs_user u on tb.user_id=u.id LEFT JOIN kxs_leader l on tb.user_id=l.id and l.expired_date>='" + Now + "'";
+                // string rootsql = "select tb.user_id,pid,pid_path,leader_type,trade_amt from (select user_id,trade_amt from kxs_user_trade_info where trade_month='" + month + "' and trade_amt>0) tb LEFT JOIN kxs_user u on tb.user_id=u.id LEFT JOIN kxs_leader l on tb.user_id=l.id and l.expired_date>='" + Now + "'";
+                string rootsql = "select tb.user_id,pid,pid_path,leader_type,trade_amt,tb.is_vip,i.full_region_num from (select user_id,is_vip,trade_amt from kxs_user_trade_info where trade_month='" + month + "' and trade_amt>0) tb LEFT JOIN kxs_user u on tb.user_id=u.id LEFT JOIN kxs_leader l on tb.user_id=l.id and l.expired_date>='" + Now + "' left join kxs_lkb_isv i on tb.user_id=i.user_id";
                 Utils.WriteLog(rootsql, "领导人达标奖励日志");
                 DataTable dt = CustomerSqlConn.dtable(rootsql, MysqlConn.JavaUserSqlConnStr);
                 foreach(DataRow dr in dt.Rows)
@@ -116,6 +117,8 @@ namespace MySystem
                             ParentUserId = ParentUserId,
                             ParentNav = ParentNav,
                             LeaderType = LeaderType,
+                            IsVip = int.Parse(function.CheckInt(dr["is_vip"].ToString())),
+                            CityService = int.Parse(function.CheckInt(dr["full_region_num"].ToString())),
                             Amt = Amt,
                         });
                     }
@@ -250,7 +253,8 @@ namespace MySystem
                         }
                         // decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
                         decimal tradePrize = onePrize * BigCount; //培养奖金额
-                        if(LeaderType > 0) 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 + ");";
+                        LeaderCompUser userData = UserData.FirstOrDefault(m => m.UserId == UserId) ?? new LeaderCompUser();
+                        if((LeaderType > 0 && userData.IsVip == 1) || userData.CityService > 0) 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 + ");";
                     }
                 }
                 db.SaveChanges();

AppStart/Tables/LeaderCompUser.cs

@@ -6,6 +6,8 @@
         public int ParentUserId { get; set; }
         public string ParentNav { get; set; }
         public int LeaderType { get; set; }
+        public int IsVip { get; set; }
+        public int CityService { get; set; }
         public decimal Amt { get; set; }
     }
 }