kxs_activity_server/AppStart/Helper/LeaderCompPrizeHelper.cs

using System;
using System.Threading;
using System.Linq;
using System.Data;
using Library;
using LitJson;
using System.Collections.Generic;
using MySystem.PxcModels;

namespace MySystem
{
    public class LeaderCompPrizeHelper
    {
        public readonly static LeaderCompPrizeHelper Instance = new LeaderCompPrizeHelper();
        private LeaderCompPrizeHelper()
        {
        }

        public void Start()//启动
        {
            Thread thread = new Thread(Listen);
            thread.IsBackground = true;
            thread.Start();
        }

        public void Listen()//启动
        {
            while(true)
            {
                if(DateTime.Now.Hour >= 0 && DateTime.Now.Hour < 23)
                {
                    string check = function.ReadInstance("/LeaderComp/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
                    if(string.IsNullOrEmpty(check))
                    {
                        function.WritePage("/LeaderComp/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString());
                        Ready(DateTime.Now.ToString("yyyyMM"));
                    }
                }
                Thread.Sleep(60000);
            }
        }

        public void StartTest()//启动
        {
            Thread thread = new Thread(ListenTest);
            thread.IsBackground = true;
            thread.Start();
        }

        public void ListenTest()//启动
        {
            Ready("202410");
        }

        public void Ready(string curMonth)
        {
            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);
        }

        public void doSomething(string month)
        {
            try
            {
                WebCMSEntities db = new WebCMSEntities();
                string MonthString = month;
                string PreMonthString = DateTime.Parse(month.Substring(0, 4) + "-" + month.Substring(4, 2) + "-01 00:00:00").AddMonths(-1).ToString("yyyyMM");

                //统计交易增量
                function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");
                
                //创客团队交易额
                string sql = "";
                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,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)
                {
                    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 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)
                    {
                        CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
                        sql = "";
                        num = 0;
                    }
                }

                if(!string.IsNullOrEmpty(sql))
                {
                    CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
                }

                //计算创客名下的达标人数，直推和间接
                function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志");
                
                // 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 + "'", MysqlConn.SqlConnStr);
                function.WriteLog(stats.Rows.Count.ToString(), "领导人达标奖励日志");
                string sqlString = "";
                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();
                    
                    //计算达标市场
                    if((totalAmount >= 30000000 && totalAmount - bigTradeAmount >= 12000000) || BigCount >= 2 || totalAmount - bigTradeAmount >= 30000000)
                    {
                        LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == UserId);
                        if(tmp == null)
                        {
                            tmp = db.LeaderCompTmp.Add(new LeaderCompTmp()
                            {
                                Id = UserId,
                                ParentUserId = ParentUserId,
                                ParentNav = ParentNav
                            }).Entity;
                            db.SaveChanges();
                        }
                        tmp.EveryMonthData = "1";
                        db.SaveChanges();
                    }

                    //培养奖
                    if(totalAmount - bigTradeAmount < 30000000) BigCount -= 1;
                    if(BigCount > 0)
                    {
                        decimal leaderOnePrize = 2500;
                        decimal operaterOnePrize = 3000;
                        decimal onePrize = 0;
                        if(BigCount == 1) onePrize = 2000;
                        if(BigCount == 2) onePrize = 2500;
                        if(BigCount == 3) 
                        {
                            onePrize = 3000;
                            leaderOnePrize = 3000;
                        }
                        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; //培养奖金额
                        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();
                function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志");

                CustomerSqlConn.op(sqlString, MysqlConn.JavaUserSqlConnStr);
            }
            catch(Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "领导达标人奖励异常");
            }
        }

        private void SendPrize(string month)
        {
            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);
            foreach(DataRow dr in dt.Rows)
            {
                int ParentUserId = int.Parse(function.CheckInt(dr["ParentUserId"].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);
                if(edit == null)
                {
                    edit = db.LeaderCompPrize.Add(new LeaderCompPrize()
                    {
                        CreateDate = DateTime.Now,
                        StatMonth = MonthFlag,
                        UserId = ParentUserId,
                    }).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);
                foreach(DataRow drsub in dtsub.Rows)
                {
                    int SubCount = int.Parse(function.CheckInt(drsub[1].ToString()));
                    edit.NotDirectCount += SubCount; //深度达标总数
                    if(SubCount > Count * Count)
                    {
                        SubCount = Count * Count;
                    }
                    edit.SecDirectCount += SubCount; //深度达标计奖数
                }
                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)
                {
                    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(), "领导人达标奖励日志");
            db.Dispose();
        }        
    }
}