kxs_activity_server/AppStart/Helper/RecommandKingHelper.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using MySystem.JavaUserModels;
using MySystem.JavaStatModels;
using Library;
using LitJson;
using System.Threading;
using GraphQL;

namespace MySystem
{
    public class RecommandKingHelper
    {
        public readonly static RecommandKingHelper Instance = new RecommandKingHelper();
        private RecommandKingHelper()
        { }
    
    
        public void Start()
        {
            Thread th = new Thread(StartFor);
            th.IsBackground = true;
            th.Start();
        }
        public void StartFor()
        {
            // while (true)
            // {
            //     if(DateTime.Now.Hour > 13 && DateTime.Now.Hour < 23)
            //     {
            //         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());

            //             if(DateTime.Now.Day == 2)
            //             {
            //                 Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 1);
            //                 Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 2);
            //                 // Recommend(DateTime.Now.AddMonths(-1).ToString("yyyyMM"), 3);
            //             }
            //             Recommend(DateTime.Now.ToString("yyyyMM"), 1);
            //             Recommend(DateTime.Now.ToString("yyyyMM"), 2);
            //             // Recommend(DateTime.Now.ToString("yyyyMM"), 3);
            //         }
            //     }
            //     Thread.Sleep(600000);
            // }
            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)
        {
            int TradeMonthNum = int.Parse(TradeMonth);
            int CheckCount = 0;
            if(Kind == 1) CheckCount = 40;
            if(Kind >= 2) CheckCount = 50;
            List<int> ReduceUserId = new List<int>();
            MySystem.JavaUserModels.WebCMSEntities db = new MySystem.JavaUserModels.WebCMSEntities();
            List<KxsInviteKing> list = new List<KxsInviteKing>();
            List<int> Historys = new List<int>();

            if(Kind < 3)
            {
                Historys = db.KxsInviteKing.Where(m => m.StepNum >= 40 && m.Kind == 1).ToList().Select(m => m.UserId).ToList();
                Historys.Add(565);
                Historys.Add(139473);
                Historys.Add(173790);
                Historys.Add(174506);
                Historys.Add(127023);
                Historys.Add(173790);
                Historys.Add(174506);
                Historys.Add(139473);
                Historys.Add(565);
                Historys.Add(127023);
                Historys.Add(176218);
                Historys.Add(195205);
                Historys.Add(193048);
                Historys.Add(182658);
                Historys.Add(173793);
                Historys.Add(146503);
                Historys.Add(168578);
                Historys.Add(71648);
                Historys.Add(730);
                Historys.Add(1421);
                Historys.Add(133571);
                Historys.Add(588);
                Historys.Add(609);
                Historys.Add(582);
                Historys.Add(196795);
                Historys.Add(195002);
                Historys.Add(205459);
                Historys.Add(198621);
                Historys.Add(197509);
                Historys.Add(202230);
                Historys.Add(205490);
                Historys.Add(193837);
                Historys.Add(195612);
                Historys.Add(193350);
                Historys.Add(164983);
                Historys.Add(176444);
                Historys.Add(141621);
                Historys.Add(10618);
                Historys.Add(134503);
                Historys.Add(168546);
                Historys.Add(149335);
                Historys.Add(415);
                Historys.Add(218);
                Historys.Add(180152);
                Historys.Add(198178);
                Historys.Add(190609);
                Historys.Add(145176);
                Historys.Add(134929);
                Historys.Add(4858);
                Historys.Add(391);
                Historys.Add(193891);
                Historys.Add(206512);
                Historys.Add(197367);
                Historys.Add(174434);
                Historys.Add(210112);
                Historys.Add(209078);
                Historys.Add(175907);
                Historys.Add(146169);
                Historys.Add(160481);
                Historys.Add(181934);
                Historys.Add(39041);
                Historys.Add(206658);
                Historys.Add(223045);
                Historys.Add(212269);
                Historys.Add(170063);
                Historys.Add(179072);
                Historys.Add(150694);
                Historys.Add(8573);
                Historys.Add(32534);
                Historys.Add(232054);
                Historys.Add(225212);
                Historys.Add(219510);
                Historys.Add(222996);
                Historys.Add(216389);
                Historys.Add(216513);
                Historys.Add(200374);
                Historys.Add(193740);
                Historys.Add(229240);
                Historys.Add(150696);
            }
            else if(Kind == 3)
            {
                Historys = db.KxsInviteKing.Where(m => m.StepNum >= 40 && m.TradeMonth == TradeMonthNum && m.Kind == 1).ToList().Select(m => m.UserId).ToList();
            }

            DateTime check = DateTime.Parse("2023-10-01 00:00:00");
            DateTime checkEnd = DateTime.Parse(TradeMonth.Substring(0, 4) + "-" + TradeMonth.Substring(4, 2) + "-01 00:00:00").AddMonths(1);
            DateTime start = DateTime.Parse(TradeMonth.Substring(0, 4) + "-" + TradeMonth.Substring(4, 2) + "-01 00:00:00");
            DateTime end = start.AddMonths(1);
            CustomerSqlConn.op("delete from kxs_invite_king where trade_month='" + TradeMonth + "' and kind=" + Kind, MysqlConn.JavaUserSqlConnStr);
            List<int> ProductIds = new List<int>();
            ProductIds.Add(10);
            ProductIds.Add(11);
            ProductIds.Add(77);
            ProductIds.Add(78);
            ProductIds.Add(79);
            ProductIds.Add(27);
            ProductIds.Add(28);
            ProductIds.Add(39);
            ProductIds.Add(40);
            ProductIds.Add(92);
            List<RecommandKingItem> users = new List<RecommandKingItem>();
            JavaStatModels.WebCMSEntities statdb = new JavaStatModels.WebCMSEntities();
            JavaProductModels.WebCMSEntities productdb = new JavaProductModels.WebCMSEntities();
            MpMainModels.WebCMSEntities mpdb = new MpMainModels.WebCMSEntities();
            MpMainModels2.WebCMSEntities mpdb2 = new MpMainModels2.WebCMSEntities();
            //统计当月下单名单
            var orderids = productdb.KxsShopOrderInfo.Where(m => ProductIds.Contains(m.GoodsId)).ToList().Select(m => m.OrderId).ToList();
            List<int> statusList = new List<int>();
            statusList.Add(1);
            statusList.Add(2);
            statusList.Add(3);
            var orders = productdb.KxsShopOrder.Where(m => m.PayTime >= check && m.PayTime < checkEnd && statusList.Contains(m.Status) && m.UserId > 1 && orderids.Contains(m.Id) && m.ReturnStatus == 0).ToList();
            function.WriteLog("kind:" + Kind + "--" + orders.Count.ToString(), "推荐王日志");
            List<int> uids = orders.Select(m => m.UserId).Distinct().ToList();
            foreach(int uid in uids)
            {
                JavaUserModels.KxsUser user = db.KxsUser.FirstOrDefault(m => m.Id == uid);
                if(user != null)
                {
                    if(!users.Any(m => m.UserId == user.Id))
                    {
                        users.Add(new RecommandKingItem()
                        {
                            UserId = user.Id,
                            ParentUserId = user.Pid,
                            ParentNav = user.PidPath,
                            // PreAmount = PreMonthAmt.ContainsKey(user.Id) ? PreMonthAmt[user.Id] : 0,
                            Level = user.PidPath.Replace(",,", ",").Trim(',').Split(',').Length + 1,
                            UserLevel = user.UserLevel,
                            Kind = 1,
                            Op = false,
                        });
                        function.WriteLog("kind:" + Kind + "-1-" + user.Id.ToString(), "推荐王日志");
                    }
                }
            }
            foreach(RecommandKingItem user in users)
            {
                int uid = user.UserId;
                int ActCount = 0;
                if(ActCount == 0)
                {
                    if(statdb.KxsUserActTrade.Any(m => m.UserId == uid && m.TradeMonth == TradeMonthNum && m.TotalType == 0))
                    {
                        ActCount += statdb.KxsUserActTrade.Where(m => m.UserId == uid && m.TradeMonth == TradeMonthNum && m.TotalType == 0).Sum(m => m.ActNum);
                    }
                }
                if(ActCount == 0)
                {
                    ActCount += mpdb.MerchantDepositOrder.Count(m => m.UserId == uid && m.CreateDate >= start && m.CreateDate < end && m.Status > 0 && m.UserId == uid);
                }
                if(ActCount == 0)
                {
                    ActCount += mpdb2.MerchantDepositOrder.Count(m => m.UserId == uid && m.CreateDate >= start && m.CreateDate < end && m.Status > 0 && m.UserId == uid);
                }
                if(ActCount > 0)
                {
                    user.Op = true;
                    function.WriteLog("有效标记-kind:" + Kind + "--" + user.ParentNav.ToString() + "->" + user.UserId.ToString(), "推荐王日志");
                }
            }
            foreach(int uid in uids)
            {
                JavaUserModels.KxsUser user = db.KxsUser.FirstOrDefault(m => m.Id == uid);
                if(user != null)
                {
                    string[] ParentIds = user.PidPath.Replace(",,", ",").Trim(',').Split(',');
                    foreach(string ParentId in ParentIds)
                    {
                        int ParentUserId = int.Parse(ParentId);
                        JavaUserModels.KxsUser puser = db.KxsUser.FirstOrDefault(m => m.Id == ParentUserId && m.Id > 1);
                        if(puser != null)
                        {
                            if(!users.Any(m => m.UserId == puser.Id))
                            {
                                users.Add(new RecommandKingItem()
                                {
                                    UserId = puser.Id,
                                    ParentUserId = puser.Pid,
                                    ParentNav = puser.PidPath,
                                    // PreAmount = PreMonthAmt.ContainsKey(puser.Id) ? PreMonthAmt[puser.Id] : 0,
                                    Level = puser.PidPath.Replace(",,", ",").Trim(',').Split(',').Length + 1,
                                    UserLevel = puser.UserLevel,
                                    Kind = 2,
                                    Op = false,
                                });
                                function.WriteLog("kind:" + Kind + "--" + puser.Id.ToString() + "-p", "推荐王日志");
                            }
                        }
                    }
                }
            }
            users = users.OrderByDescending(m => m.Level).ToList();
            foreach(RecommandKingItem user in users)
            {
                string UserIdStr = "," + user.UserId + ",";
                int Count = users.Count(m => m.ParentNav.Contains(UserIdStr) && m.Op);
                user.ActCount = Count;
                user.ChkActCount = Count;
                function.WriteLog("kind:" + Kind + "--" + user.UserId + ":" + Count, "推荐王日志");
                // RedisDbconn.Instance.AddList("userstmp2024", user);
            }
            // users = RedisDbconn.Instance.GetList<RecommandKingItem>("userstmp2024", 1, 999999).OrderByDescending(m => m.Level).ToList();
            users = users.OrderByDescending(m => m.Level).ToList();
            foreach(RecommandKingItem user in users)
            {
                function.WriteLog("kind:" + Kind + "--" + user.UserId.ToString() + "-" + user.UserLevel, "推荐王日志");
                int ActCount = 0;
                List<RecommandKingItem> subs = users.Where(m => m.ParentUserId == user.UserId).ToList();
                foreach(RecommandKingItem sub in subs)
                {
                    function.WriteLog("kind:" + Kind + "--" + sub.UserId + ":" + sub.ActCount, "推荐王日志");
                    if(sub.ActCount < CheckCount && sub.UserLevel < 5 && !Historys.Contains(sub.UserId))
                    {
                        ActCount += sub.ActCount;
                        if(sub.Op) ActCount += 1;
                    }
                }
                user.ActCount = ActCount;
                function.WriteLog("\n\n\n", "推荐王日志");
            }

            int num = 0;
            foreach(RecommandKingItem user in users)
            {
                bool op = true;
                if(Kind == 1)
                {
                    op = !Historys.Contains(user.UserId);
                }
                if(op)
                {
                    num += 1;
                    KxsInviteKing item = db.KxsInviteKing.FirstOrDefault(m => m.UserId == user.UserId && m.TradeMonth == TradeMonthNum && m.Kind == Kind);
                    if(item == null)
                    {
                        if(user.ActCount > 0)
                        {
                            function.WriteLog("入库-kind:" + Kind + "--" + user.UserId.ToString(), "推荐王日志");
                            item = db.KxsInviteKing.Add(new KxsInviteKing()
                            {
                                UserId = user.UserId,
                                TradeMonth = TradeMonthNum,
                                StepNum = user.ActCount > CheckCount ? CheckCount : user.ActCount,
                                Kind = Kind,
                            }).Entity;
                        }
                        if(num % 200 == 0)
                        {
                            db.SaveChanges();
                        }
                    }
                }
            }
            db.SaveChanges();
            db.Dispose();
            statdb.Dispose();
            productdb.Dispose();
            mpdb.Dispose();
            mpdb2.Dispose();
        }

        public decimal GetTradeAmt(int UserId, string TradeMonth)
        {
            ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
            MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
            MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
            decimal TradeAmount = 0;
            //创客团队交易额
            bool check = rdb.TradeDaySummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                TradeAmount += rdb.TradeDaySummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
            }
            check = rdb.TradeDaySummary2.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                TradeAmount += rdb.TradeDaySummary2.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.ProfitTradeAmt + m.ProfitDebitTradeAmt);
            }
            //码牌团队交易额（直联）
            check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
            }
            //码牌团队交易额（银联）
            check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
            }
            //广电卡扶持期按1万/张计入职级
            check = rdb.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14);
            if (check)
            {
                TradeAmount += rdb.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
            }
            return TradeAmount;
        }

        public Dictionary<int, decimal> GetTradeAmtList(string TradeMonth)
        {
            Dictionary<int, decimal> dic = new Dictionary<int, decimal>();
            ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
            MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
            MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
            //创客团队交易额
            bool check = rdb.TradeDaySummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                var list = rdb.TradeDaySummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team").ToList().GroupBy(m => m.UserId);
                foreach(var item in list)
                {
                    int UserId = item.Key;
                    decimal Amt = item.Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
                    if(!dic.ContainsKey(UserId))
                    {
                        dic.Add(UserId, Amt);
                    }
                    else
                    {
                        dic[UserId] += Amt;
                    }
                }
            }
            check = rdb.TradeDaySummary2.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                var list = rdb.TradeDaySummary2.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team").ToList().GroupBy(m => m.UserId);
                foreach(var item in list)
                {
                    int UserId = item.Key;
                    decimal Amt = item.Sum(m => m.ProfitTradeAmt + m.ProfitDebitTradeAmt);
                    if(!dic.ContainsKey(UserId))
                    {
                        dic.Add(UserId, Amt);
                    }
                    else
                    {
                        dic[UserId] += Amt;
                    }
                }
            }
            //码牌团队交易额（直联）
            check = mpmaindb.UserAmountSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                var list = mpmaindb.UserAmountSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).ToList().GroupBy(m => m.UserId);
                foreach(var item in list)
                {
                    int UserId = item.Key;
                    decimal Amt = item.Sum(m => m.TotalAmount) * 4;
                    if(!dic.ContainsKey(UserId))
                    {
                        dic.Add(UserId, Amt);
                    }
                    else
                    {
                        dic[UserId] += Amt;
                    }
                }
            }
            //码牌团队交易额（银联）
            check = mpmaindb2.UserAmountSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
            if (check)
            {
                var list = mpmaindb2.UserAmountSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).ToList().GroupBy(m => m.UserId);
                foreach(var item in list)
                {
                    int UserId = item.Key;
                    decimal Amt = item.Sum(m => m.TotalAmount) * 4;
                    if(!dic.ContainsKey(UserId))
                    {
                        dic.Add(UserId, Amt);
                    }
                    else
                    {
                        dic[UserId] += Amt;
                    }
                }
            }
            //广电卡扶持期按1万/张计入职级
            check = rdb.UserTradeMonthSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14);
            if (check)
            {
                var list = rdb.UserTradeMonthSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).ToList().GroupBy(m => m.UserId);
                foreach(var item in list)
                {
                    int UserId = item.Key;
                    decimal Amt = item.Sum(m => m.ActiveBuddyMerStatus) * 10000;
                    if(!dic.ContainsKey(UserId))
                    {
                        dic.Add(UserId, Amt);
                    }
                    else
                    {
                        dic[UserId] += Amt;
                    }
                }
            }
            return dic;
        }



        public void StartTest()
        {
            Thread th = new Thread(StartTestFor);
            th.IsBackground = true;
            th.Start();
        }
        public void StartTestFor()
        {
            Recommend("202411", 1);
            Recommend("202411", 2);
            // Recommend("202410", 3);
        }
    }
}