领导人达标奖励

AppStart/Helper/LeaderCompPrizeHelper.cs

@@ -33,14 +33,14 @@ namespace MySystem
                     if(string.IsNullOrEmpty(check))
                     {
                         function.WritePage("/LeaderComp/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString());
-                        if(DateTime.Now.Day == 1)
-                        {
-                            Ready(DateTime.Now.AddMonths(-1).ToString("yyyyMM"));
-                            Thread.Sleep(2000);
-                            CustomerSqlConn.op("insert into LeaderCompPrizeBak select * from LeaderCompPrize;insert into LeaderCompAddTradeBak select * from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
-                            CustomerSqlConn.op("delete from LeaderCompTmpBak;insert into LeaderCompTmpBak (Id,EveryMonthData,ParentNav,ParentUserId) select Id,EveryMonthData,ParentNav,ParentUserId from LeaderCompTmp;", MysqlConn.SqlConnStr);
-                            CustomerSqlConn.op("insert into LeaderCompTradeStatBak (`CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth`) select `CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth` from LeaderCompTradeStat;", MysqlConn.SqlConnStr);
-                        }
+                        // if(DateTime.Now.Day == 1)
+                        // {
+                        //     Ready(DateTime.Now.AddMonths(-1).ToString("yyyyMM"));
+                        //     Thread.Sleep(2000);
+                        //     CustomerSqlConn.op("insert into LeaderCompPrizeBak select * from LeaderCompPrize;insert into LeaderCompAddTradeBak select * from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
+                        //     CustomerSqlConn.op("delete from LeaderCompTmpBak;insert into LeaderCompTmpBak (Id,EveryMonthData,ParentNav,ParentUserId) select Id,EveryMonthData,ParentNav,ParentUserId from LeaderCompTmp;", MysqlConn.SqlConnStr);
+                        //     CustomerSqlConn.op("insert into LeaderCompTradeStatBak (`CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth`) select `CreateDate`, `TradeAmount`, `ParentNav`, `ParentUserId`, `UserId`, `StatMonth` from LeaderCompTradeStat;", MysqlConn.SqlConnStr);
+                        // }
                         Ready(DateTime.Now.ToString("yyyyMM"));
                     }
                 }
@@ -63,11 +63,11 @@ namespace MySystem
         public void Ready(string curMonth)
         {
             CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;delete from LeaderCompAddTrade;", MysqlConn.SqlConnStr);
-            doSomething(curMonth, curMonth);
+            doSomething(curMonth);
             SendPrize(curMonth, curMonth);
         }
 
-        public void doSomething(string month, string checkMonth)
+        public void doSomething(string month)
         {
             try
             {
@@ -76,7 +76,7 @@ namespace MySystem
                 OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
                 MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
                 MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
-                string MonthString = month + "-" + checkMonth;
+                string MonthString = month;
 
                 //统计交易增量
                 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
@@ -85,68 +85,18 @@ namespace MySystem
                 string sql = "";
                 int rownum = 0;
                 int num = 0;
-                DataTable dt = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) Amt from TradeDaySummary where Id>=15055757 and TradeMonth='" + month + "' and SeoTitle='team' and UserId>0 and UserId not in (select Id from Users where Status<0) group by UserId", MysqlConn.ReadSqlConnStr);
+                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_#{now,yyyyMM}# 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_#{now,yyyyMM}# 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<'#{now,yyyyMM}#' 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='#{now,-1,MONTH,yyyyMM}#') 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(), "领导人达标奖励日志");
                 foreach(DataRow dr in dt.Rows)
                 {
                     rownum += 1;
                     function.WriteLog("rownum:" + rownum.ToString(), "领导人达标奖励日志");
-                    int UserId = int.Parse(dr["UserId"].ToString());
-                    decimal TradeAmount = decimal.Parse(dr["Amt"].ToString());
-                    //稳定期B
-                    bool check = readdb.TradeDaySummary2.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team");
-                    if (check)
-                    {
-                        TradeAmount += readdb.TradeDaySummary2.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team").Sum(m => m.ProfitTradeAmt + m.ProfitDebitTradeAmt);
-                    }
-                    //码牌团队交易额（直联）
-                    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 == 0);
-                    if (check)
-                    {
-                        TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 0).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 == 0);
-                    if (check)
-                    {
-                        TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.IsAct == 0).Sum(m => m.TotalAmount);
-                    }
-                    //广电卡扶持期按1万/张计入职级
-                    check = readdb.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14);
-                    if (check)
-                    {
-                        int ActCount = readdb.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus);
-                        ActCount += UserDataDbconn.Instance.GetSimActTradeAmt(UserId, month, "Team");
-                        // if(readdb.UserSimActSummary.Any(m => m.UserId == UserId && m.Kind == 1))
-                        // {
-                        //     ActCount -= readdb.UserSimActSummary.Where(m => m.UserId == UserId && m.Kind == 1).Sum(m => m.ActCount);
-                        // }
-                        TradeAmount += ActCount * 10000;
-                    }
-                    //WIFI扶持期按1万/张计入职级
-                    List<int> bids = new List<int>();
-                    bids.Add(23);
-                    bids.Add(24);
-                    bids.Add(25);
-                    bids.Add(26);
-                    check = readdb.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && bids.Contains(m.BrandId));
-                    if (check)
-                    {
-                        int ActCount = readdb.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == month && m.SeoTitle == "team" && bids.Contains(m.BrandId)).Sum(m => m.ActiveBuddyMerStatus);
-                        ActCount += UserDataDbconn.Instance.GetWifiActTradeAmt(UserId, month, "Team");
-                        TradeAmount += ActCount * 10000;
-                    }
-                    sql += "insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount) values (now(), " + UserId + ", '" + month + "-" + checkMonth + "', " + TradeAmount + ");\n";
+                    int UserId = int.Parse(dr["user_id"].ToString());
+                    decimal TradeAmount = decimal.Parse(dr["amt"].ToString());
+                    int ParentUserld = int.Parse(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";
                     num += 1;
                     if(num >= 200)
                     {
@@ -162,34 +112,33 @@ namespace MySystem
                     function.WriteLog("最后执行sql:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     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='" + MonthString + "' and UserId>1", MysqlConn.SqlConnStr);
-
-                function.WriteLog("start2-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
 
                 //计算创客名下的达标人数，直推和间接
                 function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志");
 
-                Thread.Sleep(600000);
+                Thread.Sleep(600);
                 
                 // List<LeaderCompTradeStat> stats = db.LeaderCompTradeStat.Where(m => m.StatMonth == MonthString).ToList();
-                DataTable stats = CustomerSqlConn.dtable("select UserId,ParentUserId,ParentNav,TradeAmount,(select sum(TradeAmount) from LeaderCompTradeStat where ParentUserId=p.UserId and TradeAmount>=30000000) BigTradeAmount 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 + "' and UserId>1", MysqlConn.SqlConnStr);
                 function.WriteLog(stats.Rows.Count.ToString(), "领导人达标奖励日志");
+                string sql = "";
                 foreach(DataRow stat in stats.Rows)
                 {
                     int UserId = int.Parse(function.CheckInt(stat["UserId"].ToString()));
                     int ParentUserId = int.Parse(function.CheckInt(stat["ParentUserId"].ToString()));
+                    int LeaderType = int.Parse(function.CheckInt(stat["LeaderType"].ToString()));
                     decimal totalAmount = decimal.Parse(function.CheckNum(stat["TradeAmount"].ToString()));
                     decimal bigTradeAmount = decimal.Parse(function.CheckNum(stat["BigTradeAmount"].ToString()));
+                    decimal smallTradeAmount = totalAmount - bigTradeAmount;
+                    int BigCount = int.Parse(function.CheckInt(stat["BigCount"].ToString()));
+                    int SmallCount = int.Parse(function.CheckInt(stat["SmallCount"].ToString()));
+                    int LeaderCount = int.Parse(function.CheckInt(stat["LeaderCount"].ToString()));
+                    int OperaterCount = int.Parse(function.CheckInt(stat["OperaterCount"].ToString()));
                     string ParentNav = stat["ParentNav"].ToString();
-                    function.WriteLog("1-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
-                    function.WriteLog("UserId:" + UserId, "领导人达标奖励日志");
-                    function.WriteLog("totalAmount:" + totalAmount, "领导人达标奖励日志");
-                    function.WriteLog("3-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     
-                    //直推创客交易额大于等于3000万即成为达标市场
-                    if(totalAmount >= 30000000 && !string.IsNullOrEmpty(ParentNav))
+                    //计算达标市场
+                    if((totalAmount >= 30000000 && totalAmount - bigTradeAmount >= 12000000) || BigCount >= 2 || totalAmount - bigTradeAmount >= 30000000)
                     {
-                        function.WriteLog("4-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                         LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == UserId);
                         if(tmp == null)
                         {
@@ -201,31 +150,45 @@ namespace MySystem
                             }).Entity;
                             db.SaveChanges();
                         }
-                        tmp.EveryMonthData += "1";
+                        tmp.EveryMonthData = "1";
                         db.SaveChanges();
-                        function.WriteLog("5-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
                     }
-                    if(totalAmount - bigTradeAmount >= 30000000 && !string.IsNullOrEmpty(ParentNav))
+
+                    //培养奖
+                    if(totalAmount - bigTradeAmount < 30000000) BigCount -= 1;
+                    if(BigCount > 0 && LeaderType > 1)
                     {
-                        function.WriteLog("4-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
-                        LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == UserId);
-                        if(tmp == null)
+                        decimal leaderOnePrize = 2500;
+                        decimal operaterOnePrize = 3000;
+                        decimal onePrize = 0;
+                        if(BigCount == 1) onePrize = 2000;
+                        if(BigCount == 2) onePrize = 2500;
+                        if(BigCount == 3) 
                         {
-                            tmp = db.LeaderCompTmp.Add(new LeaderCompTmp()
-                            {
-                                Id = UserId,
-                                ParentUserId = ParentUserId,
-                                ParentNav = ParentNav
-                            }).Entity;
-                            db.SaveChanges();
+                            onePrize = 3000;
+                            leaderOnePrize = 3000;
                         }
-                        tmp.EveryMonthData += "2";
-                        db.SaveChanges();
-                        function.WriteLog("5-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
+                        if(BigCount == 4) 
+                        {
+                            onePrize = 4000;
+                            leaderOnePrize = 4000;
+                            operaterOnePrize = 4000;
+                        }
+                        if(BigCount == 5) 
+                        {
+                            onePrize = 5000;
+                            leaderOnePrize = 5000;
+                            operaterOnePrize = 5000;
+                        }
+                        if(BigCount >= 6) 
+                        {
+                            onePrize = 6000;
+                            leaderOnePrize = 6000;
+                            operaterOnePrize = 6000;
+                        }
+                        decimal tradePrize = onePrize * (BigCount - LeaderCount - OperaterCount) + LeaderCount * leaderOnePrize + OperaterCount * operaterOnePrize; //培养奖金额
+                        sql += "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 + ");";
                     }
-                    
-                    function.WriteLog("7-----" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "领导人达标奖励日志");
-                    function.WriteLog(DateTime.Now.ToString() + "------" + UserId, "领导人达标奖励日志");
                 }
                 db.SaveChanges();
                 readdb.SaveChanges();
@@ -233,6 +196,8 @@ namespace MySystem
                 mpmaindb.Dispose();
                 mpmaindb2.Dispose();
                 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
+
+                CustomerSqlConn.op(sql, MysqlConn.JavaUserSqlConnStr);
             }
             catch(Exception ex)
             {
@@ -242,9 +207,10 @@ namespace MySystem
 
         private void SendPrize(string month, string checkDate)
         {
+            string sql = "";
             string MonthFlag = month + "-" + checkDate;
             WebCMSEntities db = new WebCMSEntities();
-            DataTable dt = CustomerSqlConn.dtable("select ParentUserId,ParentNav,count(1) from LeaderCompTmp where SUBSTR(EveryMonthData,1,1)='1' GROUP BY ParentUserId,ParentNav", MysqlConn.SqlConnStr);
+            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)
             {
                 int ParentUserId = int.Parse(function.CheckInt(dr["ParentUserId"].ToString()));
@@ -262,7 +228,7 @@ namespace MySystem
                     db.SaveChanges();
                 }
                 edit.DirectCount = Count; //达标市场
-                DataTable dtsub = CustomerSqlConn.dtable("select SUBSTRING_INDEX(SUBSTRING_INDEX(REPLACE(ParentNav, '" + ParentNav + "', ''),',',2),',',-1),count(1) from LeaderCompTmp where ParentUserId!=" + ParentUserId + " and ParentNav like '%," + ParentUserId + ",%' and SUBSTR(EveryMonthData,2,1)='2' group by SUBSTRING_INDEX(SUBSTRING_INDEX(REPLACE(ParentNav, '" + ParentNav + "', ''),',',2),',',-1)", MysqlConn.SqlConnStr);
+                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);
                 foreach(DataRow drsub in dtsub.Rows)
                 {
                     int SubCount = int.Parse(function.CheckInt(drsub[1].ToString()));
@@ -273,43 +239,16 @@ namespace MySystem
                     }
                     edit.SecDirectCount += SubCount; //深度达标计奖数
                 }
-                edit.CompPrize = edit.SecDirectCount * 500;
+                decimal CompPrize = edit.SecDirectCount * 1000;
+                edit.CompPrize = CompPrize;
                 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 + ");";
             }
+            CustomerSqlConn.op(sql, MysqlConn.JavaUserSqlConnStr);
             function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
             db.Dispose();
-        }
-
-        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);
-            // }
-            prize = 500 * count;
-            return prize;
-        }
-        
+        }        
     }
 }

PxcModels/KxsLeader.cs

@@ -0,0 +1,24 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class KxsLeader
+    {
+        public int Id { get; set; }
+        public int LeaderLevel { get; set; }
+        public DateTime? LastBuyDate { get; set; }
+        public DateTime? ExpiredDate { get; set; }
+        public int LeaderType { get; set; }
+        public int UserId { get; set; }
+        public int Version { get; set; }
+        public int DelFlag { get; set; }
+        public DateTime? UpdateTime { get; set; }
+        public DateTime? CreateTime { get; set; }
+        public string CreateBy { get; set; }
+        public string UpdateBy { get; set; }
+        public string Remark { get; set; }
+        public int Status { get; set; }
+        public int ComFlag { get; set; }
+    }
+}

PxcModels/KxsLeaderAccountLog.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class KxsLeaderAccountLog
+    {
+        public int Id { get; set; }
+        public int TradeDate { get; set; }
+        public int TradeMonth { get; set; }
+        public int DataId { get; set; }
+        public int ChangeType { get; set; }
+        public int SourceUserId { get; set; }
+        public string Remark { get; set; }
+        public string Kind { get; set; }
+        public string VariationCause { get; set; }
+        public int VariationType { get; set; }
+        public decimal Amount { get; set; }
+        public decimal AfterAmount { get; set; }
+        public decimal BeforeAmount { get; set; }
+        public int UserId { get; set; }
+        public int Version { get; set; }
+        public int DelFlag { get; set; }
+        public DateTime? UpdateTime { get; set; }
+        public DateTime? CreateTime { get; set; }
+    }
+}

PxcModels/KxsLeaderByOrder.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class KxsLeaderByOrder
+    {
+        public int Id { get; set; }
+        public int UserId { get; set; }
+        public string ByData { get; set; }
+        public int ByNum { get; set; }
+        public string OrderSn { get; set; }
+        public int Version { get; set; }
+        public string DelFlag { get; set; }
+        public DateTime? UpdateTime { get; set; }
+        public DateTime? CreateTime { get; set; }
+    }
+}

PxcModels/KxsLeaderByOrderInfo.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class KxsLeaderByOrderInfo
+    {
+        public int Id { get; set; }
+        public int OrderId { get; set; }
+        public int BrandType { get; set; }
+        public string TicketCode { get; set; }
+        public int UserId { get; set; }
+        public int Version { get; set; }
+        public string DelFlag { get; set; }
+        public DateTime? UpdateTime { get; set; }
+        public DateTime? CreateTime { get; set; }
+    }
+}

PxcModels/LeaderCompTmp.cs

@@ -9,5 +9,6 @@ namespace MySystem.PxcModels
         public string EveryMonthData { get; set; }
         public string ParentNav { get; set; }
         public int ParentUserId { get; set; }
+        public int LeaderType { get; set; }
     }
 }

PxcModels/LeaderCompTradeStat.cs

@@ -27,5 +27,6 @@ namespace MySystem.PxcModels
         public decimal SelfResultTradeAmount { get; set; }
         public decimal SelfTradeAmount { get; set; }
         public decimal CheckSelfTradeAmount { get; set; }
+        public int LeaderType { get; set; }
     }
 }

PxcModels/LklMerNo.cs

@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class LklMerNo
+    {
+        public string ExtMerNo { get; set; }
+        public string MerNo { get; set; }
+    }
+}

PxcModels/MpProfitRecord.cs

@@ -0,0 +1,38 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class MpProfitRecord
+    {
+        public int Id { get; set; }
+        public int Sort { get; set; }
+        public int QueryCount { get; set; }
+        public int Status { get; set; }
+        public int Version { get; set; }
+        public DateTime? CreateDate { get; set; }
+        public DateTime? UpdateDate { get; set; }
+        public string CreateMan { get; set; }
+        public string UpdateMan { get; set; }
+        public string SeoTitle { get; set; }
+        public string SeoKeyword { get; set; }
+        public string SeoDescription { get; set; }
+        public int TradeId { get; set; }
+        public string ParentNav { get; set; }
+        public string Remark { get; set; }
+        public int BrandId { get; set; }
+        public ulong DirectFlag { get; set; }
+        public int CapFlag { get; set; }
+        public int QrPayFlag { get; set; }
+        public decimal ProfitAmount { get; set; }
+        public DateTime? ClearDate { get; set; }
+        public DateTime? TradeDate { get; set; }
+        public string SnNo { get; set; }
+        public int MerBuddyType { get; set; }
+        public int HelpMonthCount { get; set; }
+        public ulong MerHelpFlag { get; set; }
+        public string MerNo { get; set; }
+        public int MerchantId { get; set; }
+        public int UserId { get; set; }
+    }
+}

PxcModels/PosFeeWarningRecord.cs

@@ -7,6 +7,7 @@ namespace MySystem.PxcModels
     {
         public int Id { get; set; }
         public int Sort { get; set; }
+        public int QueryCount { get; set; }
         public int Status { get; set; }
         public int Version { get; set; }
         public DateTime? CreateDate { get; set; }
@@ -22,7 +23,6 @@ namespace MySystem.PxcModels
         public string PosSn { get; set; }
         public int BrandId { get; set; }
         public int PosId { get; set; }
-        public int QueryCount { get; set; }
         public DateTime? DoDate { get; set; }
     }
 }

PxcModels/PosMachineOtherTmp.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class PosMachineOtherTmp
+    {
+        public int Id { get; set; }
+        public string CustomerNo { get; set; }
+        public string LeMerNo { get; set; }
+        public string LeMerNo4 { get; set; }
+        public string SnNo { get; set; }
+        public int MerId { get; set; }
+    }
+}

PxcModels/PosMachineOtherTmp2.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+
+namespace MySystem.PxcModels
+{
+    public partial class PosMachineOtherTmp2
+    {
+        public int Id { get; set; }
+        public string CustomerNo { get; set; }
+        public string LeMerNo { get; set; }
+        public string LeMerNo4 { get; set; }
+        public string LmerNo { get; set; }
+    }
+}

PxcModels/UserRankWhiteSetRecord.cs

@@ -11,6 +11,8 @@ namespace MySystem.PxcModels
         public int Version { get; set; }
         public DateTime? CreateDate { get; set; }
         public DateTime? UpdateDate { get; set; }
+        public string Remark { get; set; }
+        public int UserType { get; set; }
         public int BeforeLevel { get; set; }
         public DateTime? ExpireDate { get; set; }
         public DateTime? PresetDate { get; set; }
@@ -18,7 +20,5 @@ namespace MySystem.PxcModels
         public int Level { get; set; }
         public int SetType { get; set; }
         public int UserId { get; set; }
-        public int UserType { get; set; }
-        public string Remark { get; set; }
     }
 }

PxcModels/WifiTradeRecord.cs

@@ -13,5 +13,9 @@ namespace MySystem.PxcModels
         public int BrandId { get; set; }
         public decimal TradeAmount { get; set; }
         public string SnNo { get; set; }
+        public int Duration { get; set; }
+        public string Unit { get; set; }
+        public int DoMonths { get; set; }
+        public string LastMonth { get; set; }
     }
 }

Startup.cs

@@ -166,7 +166,7 @@ namespace MySystem
             // }
             // if(Library.ConfigurationManager.EnvironmentFlag == 2)
             // {
-                // LeaderCompPrizeHelper.Instance.Start(); //领导人达标奖
+                LeaderCompPrizeHelper.Instance.Start(); //领导人达标奖
                 RecommandKingHelper.Instance.Start(); //推荐王
                 // AddSourcePosSnHelper.Instance.Start(); //补来源机具
             // }