调整奖励

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -27,7 +27,7 @@ namespace MySystem
         {
             while(true)
             {
-                if(DateTime.Now.Hour >= 0 && DateTime.Now.Hour < 19)
+                if(DateTime.Now.Hour >= 0 && DateTime.Now.Hour < 23)
                 {
                     string check = function.ReadInstance("/LeaderComp/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
                     if(string.IsNullOrEmpty(check))
@@ -57,7 +57,7 @@ namespace MySystem
             CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;delete from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
             CustomerSqlConn.op("delete from kxs_shd_leader where trade_month='" + curMonth + "'", MysqlConn.JavaUserSqlConnStr);
             doSomething(curMonth);
-            SendPrize(curMonth, curMonth);
+            SendPrize(curMonth);
         }
 
         public void doSomething(string month)
@@ -75,22 +75,92 @@ namespace MySystem
                 string sql = "";
                 int rownum = 0;
                 int num = 0;
-                DataTable dt = CustomerSqlConn.dtable("select user_id,pid,pid_path,leader_type,(case when amt is null then 0 else amt end) amt from (select tb1.user_id,pid,pid_path,leader_type,trade_amt+act_trade_amt+unact_trade_amt+act_num-logout_num amt from (select user_id,sum(help_direct_trade_amt+pro_direct_trade_amt+pro_a_direct_trade_amt+pro_b_direct_trade_amt) trade_amt from kxs_user_trade_" + month + " where total_type=1 and brand_id not in (18,19,20,21,29,101,100) group by user_id) tb1 LEFT JOIN (select user_id,sum(help_direct_trade_amt)*4 act_trade_amt,sum(pro_direct_trade_amt) unact_trade_amt from kxs_user_trade_" + month + " where total_type=1 and brand_id in (101,100,18,19,20,21,29) group by user_id) tb2 on tb1.user_id=tb2.user_id LEFT JOIN (select user_id,sum(act_num)*10000 act_num from kxs_user_act_trade where total_type=1 and brand_id in (14,23,24,25,26,32) and trade_month<'" + month + "' group by user_id) tb3 on tb1.user_id=tb3.user_id LEFT JOIN (select user_id,logout_num*10000 logout_num from kxs_user_logout_trade where total_type=1 and trade_month='" + PreMonthString + "') tb4 on tb1.user_id=tb4.user_id LEFT JOIN kxs_user.kxs_user u on tb1.user_id=u.id LEFT JOIN kxs_user.kxs_leader l on tb1.user_id=l.id and l.expired_date>now()) tball where amt>0", MysqlConn.JavaStatSqlConnStr);
-                function.WriteLog("交易数:" + dt.Rows.Count.ToString(), "领导人达标奖励日志");
+                List<LeaderCompUser> UserData = new List<LeaderCompUser>();
+                string rootsql = "select tb.user_id,pid,pid_path,leader_type,trade_amt,act_trade_amt,unact_trade_amt from (select user_id,sum(if(brand_id not in (18,19,20,21,29,23,24,25,26,32,101,100),help_direct_trade_amt+pro_direct_trade_amt+pro_a_direct_trade_amt+pro_b_direct_trade_amt,0)) trade_amt,sum(if(brand_id in (101,100,18,19,20,21,29),help_direct_trade_amt,0))*4 act_trade_amt,sum(if(brand_id in (101,100,18,19,20,21,29),pro_direct_trade_amt,0)) unact_trade_amt from kxs_user_trade_" + month + " where total_type=1 group by user_id) tb LEFT JOIN kxs_user.kxs_user u on tb.user_id=u.id LEFT JOIN kxs_user.kxs_leader l on tb.user_id=l.id and l.expired_date>now()";
+                function.WriteLog(rootsql, "领导人达标奖励日志");
+                DataTable dt = CustomerSqlConn.dtable(rootsql, MysqlConn.JavaStatSqlConnStr);
+                foreach(DataRow dr in dt.Rows)
+                {
+                    int UserId = int.Parse(dr["user_id"].ToString());
+                    int ParentUserId = int.Parse(function.CheckInt(dr["pid"].ToString()));
+                    string ParentNav = dr["pid_path"].ToString();
+                    int LeaderType = int.Parse(function.CheckInt(dr["leader_type"].ToString()));
+                    decimal TradeAmt = decimal.Parse(function.CheckNum(dr["trade_amt"].ToString()));
+                    decimal ActTradeAmt = decimal.Parse(function.CheckNum(dr["act_trade_amt"].ToString()));
+                    decimal UnactTradeAmt = decimal.Parse(function.CheckNum(dr["unact_trade_amt"].ToString()));
+                    decimal Amt = TradeAmt + ActTradeAmt + UnactTradeAmt;
+                    LeaderCompUser item = UserData.FirstOrDefault(m => m.UserId == UserId);
+                    if(item == null)
+                    {
+                        UserData.Add(new LeaderCompUser()
+                        {
+                            UserId = UserId,
+                            ParentUserId = ParentUserId,
+                            ParentNav = ParentNav,
+                            LeaderType = LeaderType,
+                            Amt = Amt,
+                        });
+                    }
+                    else
+                    {
+                        item.Amt += Amt;
+                    }
+                }
+                rootsql = "select tb.user_id,pid,pid_path,leader_type,amt from (select user_id,sum(act_num)*10000 amt from kxs_user_act_trade where total_type=1 and brand_id in (14,23,24,25,26,32) and trade_month<='" + month + "' group by user_id) tb LEFT JOIN kxs_user.kxs_user u on tb.user_id=u.id LEFT JOIN kxs_user.kxs_leader l on tb.user_id=l.id and l.expired_date>now()";
+                function.WriteLog(rootsql, "领导人达标奖励日志");
+                dt = CustomerSqlConn.dtable(rootsql, MysqlConn.JavaStatSqlConnStr);
                 foreach(DataRow dr in dt.Rows)
                 {
-                    rownum += 1;
-                    function.WriteLog("rownum:" + rownum.ToString(), "领导人达标奖励日志");
                     int UserId = int.Parse(dr["user_id"].ToString());
-                    decimal TradeAmount = decimal.Parse(dr["amt"].ToString());
-                    int ParentUserld = int.Parse(dr["pid"].ToString());
+                    int ParentUserId = int.Parse(function.CheckInt(dr["pid"].ToString()));
                     string ParentNav = dr["pid_path"].ToString();
-                    int LeaderType = int.Parse(dr["leader_type"].ToString());
-                    sql += "insert into LeaderCompTradeStat (LeaderType,ParentNav,ParentUserld,TradeAmount,StatMonth,Userld,CreateDate) values (" + LeaderType + ", '" + ParentNav + "', " + ParentUserld + ", " + TradeAmount + ", '" + month + "', " + UserId + ",now());\n";
+                    int LeaderType = int.Parse(function.CheckInt(dr["leader_type"].ToString()));
+                    decimal Amt = decimal.Parse(function.CheckNum(dr["amt"].ToString()));
+                    LeaderCompUser item = UserData.FirstOrDefault(m => m.UserId == UserId);
+                    if(item == null)
+                    {
+                        UserData.Add(new LeaderCompUser()
+                        {
+                            UserId = UserId,
+                            ParentUserId = ParentUserId,
+                            ParentNav = ParentNav,
+                            LeaderType = LeaderType,
+                            Amt = Amt,
+                        });
+                    }
+                    else
+                    {
+                        item.Amt += Amt;
+                    }
+                }
+                rootsql = "select user_id,logout_num*10000 logout_num from kxs_user_logout_trade where total_type=1 and trade_month='" + PreMonthString + "'";
+                function.WriteLog(rootsql, "领导人达标奖励日志");
+                dt = CustomerSqlConn.dtable(rootsql, MysqlConn.JavaStatSqlConnStr);
+                foreach(DataRow dr in dt.Rows)
+                {
+                    int UserId = int.Parse(dr["user_id"].ToString());
+                    decimal Amt = decimal.Parse(function.CheckNum(dr["logout_num"].ToString()));
+                    LeaderCompUser item = UserData.FirstOrDefault(m => m.UserId == UserId);
+                    if(item != null)
+                    {
+                        item.Amt -= Amt;
+                    }
+                }
+                function.WriteLog("交易数:" + dt.Rows.Count.ToString(), "领导人达标奖励日志");
+                foreach(LeaderCompUser SubUser in UserData)
+                {
+                    rownum += 1;
+                    function.WriteLog("rownum:" + rownum.ToString(), "领导人达标奖励日志");
+                    int UserId = SubUser.UserId;
+                    function.WriteLog("UserId:" + UserId.ToString(), "领导人达标奖励日志");
+                    decimal TradeAmount = SubUser.Amt;
+                    int ParentUserId = SubUser.ParentUserId;
+                    string ParentNav = SubUser.ParentNav;
+                    int LeaderType = SubUser.LeaderType;
+                    sql += "insert into LeaderCompTradeStat (LeaderType,ParentNav,ParentUserId,TradeAmount,StatMonth,UserId,CreateDate) values (" + LeaderType + ", '" + ParentNav + "', " + ParentUserId + ", " + TradeAmount + ", '" + month + "', " + UserId + ",now());\n";
                     num += 1;
                     if(num >= 200)
                     {
-                        function.WriteLog("执行一次sql:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                         CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
                         sql = "";
                         num = 0;
@@ -99,17 +169,14 @@ namespace MySystem
 
                 if(!string.IsNullOrEmpty(sql))
                 {
-                    function.WriteLog("最后执行sql:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
                 }
 
                 //计算创客名下的达标人数，直推和间接
                 function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志");
-
-                Thread.Sleep(600);
                 
                 // List<LeaderCompTradeStat> stats = db.LeaderCompTradeStat.Where(m => m.StatMonth == MonthString).ToList();
-                DataTable stats = CustomerSqlConn.dtable("select UserId,ParentUserId,ParentNav,TradeAmount,LeaderType,(select sum(TradeAmount) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigTradeAmount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount<30000000) SmallCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType=2) LeaderCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType>2) OperaterCount from LeaderCompTradeStat p where StatMonth='" + MonthString + "' and UserId>1", MysqlConn.SqlConnStr);
+                DataTable stats = CustomerSqlConn.dtable("select UserId,ParentUserId,ParentNav,TradeAmount,LeaderType,(select sum(TradeAmount) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigTradeAmount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount<30000000) SmallCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType=2) LeaderCount,(select count(1) from LeaderCompTradeStat where ParentUserId=p.UserId and LeaderType>2) OperaterCount from LeaderCompTradeStat p where StatMonth='" + MonthString + "'", MysqlConn.SqlConnStr);
                 function.WriteLog(stats.Rows.Count.ToString(), "领导人达标奖励日志");
                 string sqlString = "";
                 foreach(DataRow stat in stats.Rows)
@@ -146,7 +213,7 @@ namespace MySystem
 
                     //培养奖
                     if(totalAmount - bigTradeAmount < 30000000) BigCount -= 1;
-                    if(BigCount > 0 && LeaderType > 1)
+                    if(BigCount > 0)
                     {
                         decimal leaderOnePrize = 2500;
                         decimal operaterOnePrize = 3000;
@@ -177,7 +244,7 @@ namespace MySystem
                             operaterOnePrize = 6000;
                         }
                         decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
-                        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 + "'," + ParentUserId + ");";
+                        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();
@@ -191,10 +258,10 @@ namespace MySystem
             }
         }
 
-        private void SendPrize(string month, string checkDate)
+        private void SendPrize(string month)
         {
             string sql = "";
-            string MonthFlag = month + "-" + checkDate;
+            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);
             foreach(DataRow dr in dt.Rows)
@@ -219,9 +286,9 @@ namespace MySystem
                 {
                     int SubCount = int.Parse(function.CheckInt(drsub[1].ToString()));
                     edit.NotDirectCount += SubCount; //深度达标总数
-                    if(SubCount > Count)
+                    if(SubCount > Count * Count)
                     {
-                        SubCount = Count;
+                        SubCount = Count * Count;
                     }
                     edit.SecDirectCount += SubCount; //深度达标计奖数
                 }
@@ -230,7 +297,10 @@ namespace MySystem
                 db.SaveChanges();
 
                 LeaderCompTradeStat stat = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == ParentUserId) ?? new LeaderCompTradeStat();
-                sql += "insert into kxs_shd_leader (shd_type,trade_amt,source_bonus_amt,create_time,trade_month,user_id) values (1," + CompPrize + "," + stat.TradeAmount + ",now(),'" + MonthFlag + "'," + ParentUserId + ");";
+                if(stat.LeaderType > 1)
+                {
+                    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 + ");";
+                }
             }
             CustomerSqlConn.op(sql, MysqlConn.JavaUserSqlConnStr);
             function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");

AppStart/Helper/RecommandKingHelper.cs

@@ -49,8 +49,16 @@ namespace MySystem
             //     }
             //     Thread.Sleep(600000);
             // }
-            RecommandKingHelper.Instance.Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 1);
-            RecommandKingHelper.Instance.Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 2);
+            string today = DateTime.Now.ToString("yyyy-MM-dd");
+            string checkFlag = function.ReadInstance("/RecommandKing/" + today + ".txt");
+            if(string.IsNullOrEmpty(checkFlag))
+            {
+                function.WritePage("/RecommandKing/", today + ".txt", DateTime.Now.ToString());
+                Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 1);
+                Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 2);
+                Recommend(DateTime.Now.ToString("yyyyMM"), 1);
+                Recommend(DateTime.Now.ToString("yyyyMM"), 2);
+            }
         }
         public void Recommend(string TradeMonth, int Kind)
         {

AppStart/Tables/LeaderCompUser.cs

@@ -0,0 +1,11 @@
+namespace MySystem
+{
+    public class LeaderCompUser
+    {
+        public int UserId { get; set; }
+        public int ParentUserId { get; set; }
+        public string ParentNav { get; set; }
+        public int LeaderType { get; set; }
+        public decimal Amt { get; set; }
+    }
+}

appsettings.json

@@ -26,6 +26,9 @@
     "MpSqlConnStr": "server=rm-2vc27k81v217qs1t55o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=QrCodePlateMainServer;password=ll4DFaALMu9YIooM;database=QrCodePlateMainServer;charset=utf8;",
     "MpSqlConnStr2": "server=rm-2vc27k81v217qs1t55o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=QrCodePlateMainServer;password=ll4DFaALMu9YIooM;database=QrCodePlateMainServer2;charset=utf8;",
     "RdsStatSqlConnStr": "server=rm-2vc27k81v217qs1t55o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsStatServer;password=mzeqjriUWore0dwT;database=KxsStatServer;charset=utf8;",
+    "JavaUserSqlConnStr": "server=47.109.61.191;port=3306;user=root;password=HDlNs1ZpG5iR9D9I;database=kxs_user;charset=utf8;",
+    "JavaStatSqlConnStr": "server=47.109.61.191;port=3306;user=root;password=HDlNs1ZpG5iR9D9I;database=kxs_stat;charset=utf8;",
+    "JavaProductSqlConnStr": "server=47.109.61.191;port=3306;user=root;password=HDlNs1ZpG5iR9D9I;database=kxs_product;charset=utf8;",
     "RedisConnStr": "r-2vc7uglenfmzmlvrnopd.redis.cn-chengdu.rds.aliyuncs.com:6379,password=AZp2ns01w07YW9K0,DefaultDatabase=0,poolsize=500,preheat=50,asyncPipeline=true",
     "IOSAppVersion": "1.0.0",
     "AndroidAppVersion": "1.0.0",