kxs-main/AppStart/Helper/StatService.cs

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

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

        public void Start(JobMqMsg jobInfo)
        {
            string content = "";
            try
            {
                if(DateTime.Now.Hour > 0)
                {
                    string doDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
                    string flag = function.ReadInstance("/Stat/" + doDate + ".txt");
                    if (string.IsNullOrEmpty(flag))
                    {
                        function.WritePage("/Stat/", doDate + ".txt", DateTime.Now.ToString("HH:mm:ss"));
                        // dosomething1(doDate);
                        // dosomething11(doDate);
                        // dosomething2(doDate);
                        StartEverDay(doDate);
                        // StartEverDayV2(doDate);
                        StatMerchantTrade(doDate);
                        dosomething4(doDate);
                        ListenFluxRecord(doDate);
                    }
                    string Msg = "success";
                    jobInfo.Status = Msg == "success" ? 1 : 0;
                    jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
                    RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
                }
            }
            catch (Exception ex)
            {
                if (!string.IsNullOrEmpty(content))
                {
                    Dictionary<string, string> data = new Dictionary<string, string>();
                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                    data.Add("ErrMsg", ex.ToString());
                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
                }
                else
                {
                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
                }
            }
        }

        public void ActiveReward(JobMqMsg jobInfo)
        {
            string content = "";
            try
            {
                dosomething3();
                activePrizeWithoutDeposit();
                string Msg = "success";
                jobInfo.Status = Msg == "success" ? 1 : 0;
                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
                function.WritePage("/static/", "act.txt", DateTime.Now.ToString());
            }
            catch (Exception ex)
            {
                if (!string.IsNullOrEmpty(content))
                {
                    Dictionary<string, string> data = new Dictionary<string, string>();
                    data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                    data.Add("ErrMsg", ex.ToString());
                    function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
                }
                else
                {
                    function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
                }
            }
        }











        public void clear()
        {
            RedisDbconn.Instance.Clear("TotalAmount*");
            RedisDbconn.Instance.Clear("TotalCloudPayAmount*");
            RedisDbconn.Instance.Clear("TotalPosAmount*");
            RedisDbconn.Instance.Clear("TeamTotalAmount*");
            RedisDbconn.Instance.Clear("TeamTotalCloudPayAmount*");
            RedisDbconn.Instance.Clear("TeamTotalPosAmount*");

            // RedisDbconn.Instance.Clear("TotalUser*");
            // RedisDbconn.Instance.Clear("TeamTotalUser*");
            // RedisDbconn.Instance.Clear("AddUser*");
            // RedisDbconn.Instance.Clear("TeamAddUser*");

            // RedisDbconn.Instance.Clear("TotalPosMerchant*");
            // RedisDbconn.Instance.Clear("TeamTotalPosMerchant*");

            RedisDbconn.Instance.Clear("MerTotalAmount*");
        }


        // 1. 前一天的绑定记录和创客信息匹配，设置商户型创客
        public void dosomething1(string date)
        {
            // TODO: 每天扫描非商户型创客的持有机具数量
            SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Parse(date + " 00:00:00");
            DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
            List<SpModels.BindRecord> binds = spdb.BindRecord.Where(m => m.CreateTime >= yesterday && m.CreateTime < today).ToList();
            foreach (SpModels.BindRecord bind in binds)
            {
                string Mobile = bind.MerNewSnNo;
                string MerNo = bind.MerNo;
                string BeforeNum = "";
                string AfterNum = "";
                if (Mobile.Contains("****") && Mobile.Length == 11)
                {
                    BeforeNum = Mobile.Substring(0, 3);
                    AfterNum = Mobile.Substring(7);
                }
                string Name = bind.MerName;
                if (bind.ProductType == "2")
                {
                    if (Name.Contains("-"))
                    {
                        Name = Name.Split('-')[1];
                    }
                    else if (Name.Contains("_"))
                    {
                        Name = Name.Split('_')[1];
                    }
                }
                else if (bind.ProductType == "4")
                {
                    Name = bind.SeoTitle;
                }
                PxcModels.Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0);
                if (user != null)
                {
                    bool checkPos = db.PosMachinesTwo.Any(m => m.UserId == user.Id);
                    if (!checkPos)
                    {
                        PxcModels.MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == bind.MerSnNo) ?? new PxcModels.MachineForSnNo();
                        PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId && m.UserId != user.Id);
                        if (pos != null)
                        {
                            pos.UserId = user.Id;
                            user.MerchantType = 1;
                            PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PxcModels.PosMerchantInfo();
                            merchant.UserId = user.Id;
                            merchant.MerUserType = 1;
                            pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
                            RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
                            db.SaveChanges();
                            RedisDbconn.Instance.Set("Users:" + user.Id, user);
                            RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
                        }
                    }
                }
            }
            spdb.Dispose();
            db.Dispose();
        }

        // 1. 前一天的商户型创客，判断名下是否3台激活机器，是则变为非商户型创客
        public void dosomething11(string date)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Parse(date + " 00:00:00");
            DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
            var users = db.Users.Select(m => new { m.Id, m.MerchantType }).Where(m => m.MerchantType == 1).ToList();
            foreach (var user in users)
            {
                int machineCount = db.PosMachinesTwo.Count(m => m.UserId == user.Id && m.PosSnType == 0);
                int couponCount = db.PosCoupons.Count(m => m.UserId == user.Id && m.IsUse == 0); //判断是否拥有3张券
                if (machineCount + couponCount >= 3)
                {
                    Users edit = db.Users.FirstOrDefault(m => m.Id == user.Id);
                    if (edit != null)
                    {
                        edit.MerchantType = 0;
                        db.SaveChanges();
                        RedisDbconn.Instance.Set("Users:" + user.Id, edit);
                    }
                }
            }
            db.Dispose();
        }


        public void testStatTrade(string date)
        {
            string yesterday = date + " 00:00:00";
            string today = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
            string TradeMonth = DateTime.Parse(date).ToString("yyyyMM");
            string TradeDate = DateTime.Parse(date).ToString("yyyyMMdd");
            DataTable dt = dbconn.dtable("select UserId,BrandId,MerchantId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where CreateDate>='" + yesterday + "' and CreateDate<'" + today + "' group by UserId,BrandId,MerchantId,BankCardType,QrPayFlag");
            foreach (DataRow dr in dt.Rows)
            {
                int UserId = int.Parse(dr["UserId"].ToString()); //创客ID
                int BrandId = int.Parse(dr["BrandId"].ToString()); //品牌
                int MerchantId = int.Parse(dr["MerchantId"].ToString()); //商户Id
                int BankCardType = int.Parse(dr["BankCardType"].ToString()); //卡类型
                int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString()); //云闪付
                decimal TradeAmount = decimal.Parse(dr[5].ToString()); //当日交易额
                string content = "{";
                content += "\"DateString\":\"" + date + "\",";
                content += "\"UserId\":\"" + UserId + "\",";
                content += "\"BrandId\":\"" + BrandId + "\",";
                content += "\"MerchantId\":\"" + MerchantId + "\",";
                content += "\"BankCardType\":\"" + BankCardType + "\",";
                content += "\"QrPayFlag\":\"" + QrPayFlag + "\",";
                content += "\"TradeAmount\":\"" + TradeAmount + "\"";
                content += "}";
                RedisDbconn.Instance.AddList("TradeStatQueueTest", content);
            }
        }

        // 3. 前一天的激活记录，根据创客类型，如果是商户型创客，则激活奖励的起始人从此人上级计算。如果不是，则从此人开始计算
        public void dosomething3(int posid = 0)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Now.AddDays(-1);
            DateTime today = DateTime.Now;
            IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword));
            if (posid > 0)
            {
                posList = posList.Where(m => m.Id == posid);
            }
            else
            {
                posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
            }
            foreach (PosMachinesTwo pos in posList.ToList())
            {
                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
                PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                if (merchant != null)
                {
                    // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
                    // if (otherInfo != null)
                    // {
                    //     otherInfo.PrizeFlag1 = 1;
                    //     db.SaveChanges();
                    string ParentNav = "";
                    Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                    if (user != null)
                    {
                        int GetUserId = user.Id;
                        ParentNav = user.ParentNav;
                        int TopUserId = 0;
                        if (!string.IsNullOrEmpty(ParentNav))
                        {
                            TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                        }
                        decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
                        if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9)
                        {
                            ActPrize = ActPrize / 100;
                        }
                        if (ActPrize > 0)
                        {
                            if (ActPrize == 99)
                            {
                                ActPrize = 100;
                            }
                            else if (ActPrize == 199)
                            {
                                ActPrize = 200;
                            }
                            else if (ActPrize == 299)
                            {
                                ActPrize = 300;
                            }
                            else if (ActPrize == 249)
                            {
                                ActPrize = 260;
                            }
                            if (GetUserId > 0)
                            {
                                doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize);
                            }
                        }
                        else if(pos.BrandId == 6 && ActPrize == 0)
                        {
                            doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
                        }
                    }
                    // }
                }
            }
            db.Dispose();
        }
        public void activePrizeWithoutDeposit(int posid = 0)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Now.AddDays(-1);
            DateTime today = DateTime.Now;
            IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && string.IsNullOrEmpty(m.SeoKeyword));
            if (posid > 0)
            {
                posList = posList.Where(m => m.Id == posid);
            }
            else
            {
                posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
            }
            foreach (PosMachinesTwo pos in posList.ToList())
            {
                PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                if (merchant != null)
                {
                    string ParentNav = "";
                    Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                    if (user != null)
                    {
                        int GetUserId = user.Id;
                        ParentNav = user.ParentNav;
                        int TopUserId = 0;
                        if (!string.IsNullOrEmpty(ParentNav))
                        {
                            TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                        }
                        if(pos.BrandId == 6)
                        {
                            doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
                        }
                    }
                }
            }
            db.Dispose();
        }

        public void doActiveReward(WebCMSEntities db, PosMerchantInfo merchant, PosMachinesTwo pos, int GetUserId, string ParentNav, int TopUserId, decimal ActPrize, int ChangeType = 0)
        {
            bool check = db.ActiveReward.Any(m => m.KqMerNo == merchant.KqMerNo && m.RewardAmount == ActPrize);
            if (!check)
            {
                Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                db.ActiveReward.Add(new ActiveReward()
                {
                    CreateDate = DateTime.Now,
                    UpdateDate = DateTime.Now,
                    UserId = GetUserId, //创客
                    MerchantId = pos.BindMerchantId, //商户
                    StandardDate = pos.ActivationTime, //达标日期
                    RewardAmount = ActPrize, //奖励金额
                    BrandId = pos.BrandId, //品牌
                    UserNav = ParentNav, //创客父级
                    DirectBuddyNo = merchant.UserId, //商户直属创客
                    KqMerNo = merchant.KqMerNo, //渠道商户编号
                    KqSnNo = pos.PosSn, //渠道SN号
                    SnType = pos.PosSnType, //机具类型
                    SnApplyUserId = pos.BuyUserId, //机具申请创客
                    ActType = 0, //激活类型
                    SnStoreId = pos.StoreId, //SN仓库
                    RewardTips = "激活奖励", //奖励描述
                    Remark = "激活奖励", //备注
                    ActDate = pos.ActivationTime, //激活时间
                    TopUserId = TopUserId, //顶级创客
                    SeoTitle = machineUser.RealName,
                });
                db.SaveChanges();
                string IdBrand = GetUserId + "_" + pos.BrandId;
                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                if (userData == null)
                {
                    userData = db.UserMachineData.Add(new UserMachineData()
                    {
                        IdBrand = IdBrand,
                    }).Entity;
                    db.SaveChanges();
                }
                userData.ActProfit += ActPrize;
                db.SaveChanges();
                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                if (account == null)
                {
                    account = db.UserAccount.Add(new UserAccount()
                    {
                        Id = GetUserId,
                        UserId = GetUserId,
                    }).Entity;
                    db.SaveChanges();
                }
                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                account.BalanceAmount += ActPrize;
                account.TotalAmount += ActPrize;
                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                {
                    CreateDate = DateTime.Now,
                    UpdateDate = DateTime.Now,
                    UserId = GetUserId, //创客
                    ChangeType = ChangeType, //变动类型
                    ProductType = pos.BrandId, //产品类型
                    ChangeAmount = ActPrize, //变更金额
                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                }).Entity;
                db.SaveChanges();
                RedisDbconn.Instance.Set("UserAccount:" + GetUserId, account);

                string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd");
                string monthString = pos.ActivationTime.Value.ToString("yyyyMM");
                // 激活奖励列表
                List<string> dates = RedisDbconn.Instance.GetList<string>("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId);
                if (!dates.Contains(dateString))
                {
                    RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString);
                }
                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize);

                List<string> months = RedisDbconn.Instance.GetList<string>("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId);
                if (!months.Contains(monthString))
                {
                    RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString);
                }
                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize);

                // 激活奖励详情
                List<int> actPrizeList = RedisDbconn.Instance.GetList<int>("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString);
                if (!actPrizeList.Contains(pos.BindMerchantId))
                {
                    RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId);
                }
                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize);

                //收支明细
                RedisDbconn.Instance.AddList("UserAccountRecord:" + GetUserId + ":1:" + monthString, userAccountRecord);
                RedisDbconn.Instance.AddNumber("UserAccount:" + GetUserId + ":1:" + monthString, ActPrize);
                RedisDbconn.Instance.Clear("UserAccount:Income:" + GetUserId + ":" + monthString);
            }
        }


        //根据商户信息发放激活奖励
        public void dosomething32(int merid = 0)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Now.AddHours(-3);
            DateTime today = DateTime.Now;
            IQueryable<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && !string.IsNullOrEmpty(m.SeoKeyword));
            if (merid > 0)
            {
                merList = merList.Where(m => m.Id == merid);
            }
            else
            {
                merList = merList.Where(m => m.MerStandardDate >= yesterday && m.MerStandardDate < today);
            }
            foreach (PosMerchantInfo merchant in merList.ToList())
            {
                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
                // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
                // if (otherInfo != null)
                // {
                //     otherInfo.PrizeFlag1 = 1;
                //     db.SaveChanges();
                MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
                PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
                string ParentNav = "";
                Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                if (user != null)
                {
                    int GetUserId = user.Id;
                    ParentNav = user.ParentNav;
                    int TopUserId = 0;
                    if (!string.IsNullOrEmpty(ParentNav))
                    {
                        TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                    }
                    decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
                    if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9)
                    {
                        ActPrize = ActPrize / 100;
                    }
                    if (ActPrize > 0)
                    {
                        bool check = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn);
                        if (!check)
                        {
                            if (ActPrize == 99)
                            {
                                ActPrize = 100;
                            }
                            else if (ActPrize == 199)
                            {
                                ActPrize = 200;
                            }
                            else if (ActPrize == 299)
                            {
                                ActPrize = 300;
                            }
                            Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                            db.ActiveReward.Add(new ActiveReward()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = GetUserId, //创客
                                MerchantId = pos.BindMerchantId, //商户
                                StandardDate = pos.ActivationTime, //达标日期
                                RewardAmount = ActPrize, //奖励金额
                                BrandId = pos.BrandId, //品牌
                                UserNav = ParentNav, //创客父级
                                DirectBuddyNo = merchant.UserId, //商户直属创客
                                KqMerNo = merchant.KqMerNo, //渠道商户编号
                                KqSnNo = pos.PosSn, //渠道SN号
                                SnType = pos.PosSnType, //机具类型
                                SnApplyUserId = pos.BuyUserId, //机具申请创客
                                ActType = 0, //激活类型
                                SnStoreId = pos.StoreId, //SN仓库
                                RewardTips = "激活奖励", //奖励描述
                                Remark = "激活奖励", //备注
                                ActDate = pos.ActivationTime, //激活时间
                                TopUserId = TopUserId, //顶级创客
                                SeoTitle = machineUser.RealName,
                            });
                            db.SaveChanges();
                            string IdBrand = GetUserId + "_" + pos.BrandId;
                            UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                            if (userData == null)
                            {
                                userData = db.UserMachineData.Add(new UserMachineData()
                                {
                                    IdBrand = IdBrand,
                                }).Entity;
                                db.SaveChanges();
                            }
                            userData.ActProfit += ActPrize;
                            db.SaveChanges();
                            RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                            if (account == null)
                            {
                                account = db.UserAccount.Add(new UserAccount()
                                {
                                    Id = GetUserId,
                                    UserId = GetUserId,
                                }).Entity;
                                db.SaveChanges();
                            }
                            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                            account.BalanceAmount += ActPrize;
                            account.TotalAmount += ActPrize;
                            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                            UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = GetUserId, //创客
                                ChangeType = 0, //变动类型
                                ProductType = pos.BrandId, //产品类型
                                ChangeAmount = ActPrize, //变更金额
                                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                            }).Entity;
                            db.SaveChanges();
                            RedisDbconn.Instance.Set("UserAccount:" + GetUserId, account);

                            string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd");
                            string monthString = pos.ActivationTime.Value.ToString("yyyyMM");
                            // 激活奖励列表
                            List<string> dates = RedisDbconn.Instance.GetList<string>("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId);
                            if (!dates.Contains(dateString))
                            {
                                RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString);
                            }
                            RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize);

                            List<string> months = RedisDbconn.Instance.GetList<string>("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId);
                            if (!months.Contains(monthString))
                            {
                                RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString);
                            }
                            RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize);

                            // 激活奖励详情
                            List<int> actPrizeList = RedisDbconn.Instance.GetList<int>("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString);
                            if (!actPrizeList.Contains(pos.BindMerchantId))
                            {
                                RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId);
                            }
                            RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize);

                            //收支明细
                            RedisDbconn.Instance.AddList("UserAccountRecord:" + GetUserId + ":1:" + monthString, userAccountRecord);
                            RedisDbconn.Instance.AddNumber("UserAccount:" + GetUserId + ":1:" + monthString, ActPrize);
                        }
                    }
                }
                // }
            }
            db.Dispose();
        }



        //3. 前一天的激活记录，根据创客类型，如果是商户型创客，则开机奖励的起始人从此人上级计算。如果不是，则从此人开始计算
        public void dosomething4(string date)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Parse(date + " 00:00:00");
            DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
            List<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.ActivationTime >= yesterday && m.ActivationTime < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000).ToList();
            foreach (PosMachinesTwo pos in posList)
            {
                if (pos.BindingTime > DateTime.Now.AddDays(-30))
                {
                    decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
                    if (ActPrize > 0)
                    {
                        // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
                        // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
                        PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                        if (merchant != null)
                        {
                            // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
                            // if (otherInfo != null)
                            // {
                            //     otherInfo.PrizeFlag2 = 1;
                            //     db.SaveChanges();
                            // 从机具所属人上级开始分开机奖励
                            Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                            if (user != null)
                            {
                                if (!string.IsNullOrEmpty(user.ParentNav))
                                {
                                    decimal Prize = 20;
                                    string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    for (int i = ParentNavs.Length - 1; i >= 0; i--)
                                    {
                                        int UserId = int.Parse(ParentNavs[i]);
                                        Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
                                        if (puser != null && Prize > 0)
                                        {
                                            int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台购买机
                                            int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
                                            int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
                                            // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
                                            // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机（不限购买或赠送）
                                            if (machineCount + ActiveCount + couponCount >= 3)
                                            {
                                                int pTopUserId = 0;
                                                if (!string.IsNullOrEmpty(puser.ParentNav))
                                                {
                                                    pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                                                }
                                                Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                                                OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
                                                {
                                                    CreateDate = DateTime.Now,
                                                    UpdateDate = DateTime.Now,
                                                    TradeMonth = yesterday.ToString("yyyyMM"), //交易月
                                                    TradeDate = yesterday, //达标日期
                                                    UserId = puser.Id, //创客
                                                    BrandId = pos.BrandId, //品牌
                                                    ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
                                                    MerchantId = pos.BindMerchantId, //商户
                                                    DirectUserId = merchant.UserId, //商户直属人
                                                    SnNo = pos.PosSn, //SN号
                                                    MerNo = merchant.KqMerNo, //渠道商户号
                                                    SnType = pos.PosSnType, //机具类型
                                                    StandardDate = pos.ActivationTime, //商户的激活日期
                                                    SnStoreId = pos.StoreId, //SN仓库
                                                    MerBuddyType = puser.MerchantType, //商户创客类型
                                                    RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励
                                                    RewardTips = "开机奖励", //奖励描述
                                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                                    RewardDesc = "开机奖励", //奖励描述
                                                    TopUserId = pTopUserId, //顶级创客
                                                    SeoTitle = machineUser.RealName,
                                                }).Entity;
                                                db.OpenReward.Add(new OpenReward()
                                                {
                                                    CreateDate = DateTime.Now,
                                                    UpdateDate = DateTime.Now,
                                                    TradeMonth = yesterday.ToString("yyyyMM"), //交易月
                                                    TradeDate = DateTime.Now, //达标日期
                                                    UserId = puser.Id, //创客
                                                    BrandId = pos.BrandId, //品牌
                                                    RewardType = 2, //奖励类型
                                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                                    RewardDesc = "开机奖励", //奖励描述
                                                    TopUserId = pTopUserId, //顶级创客
                                                });
                                                string IdBrand = puser.Id + "_" + pos.BrandId;
                                                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                                                if (userData == null)
                                                {
                                                    userData = db.UserMachineData.Add(new UserMachineData()
                                                    {
                                                        IdBrand = IdBrand,
                                                    }).Entity;
                                                    db.SaveChanges();
                                                }
                                                userData.OpenProfit += Prize;
                                                db.SaveChanges();
                                                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                                //账户入库
                                                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
                                                if (account == null)
                                                {
                                                    account = db.UserAccount.Add(new UserAccount()
                                                    {
                                                        Id = puser.Id,
                                                        UserId = puser.Id,
                                                    }).Entity;
                                                    db.SaveChanges();
                                                }
                                                //收支明细入库
                                                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                                                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                                                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                                                account.BalanceAmount += Prize;
                                                account.TotalAmount += Prize;
                                                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                                                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                                                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                                                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                                                {
                                                    CreateDate = DateTime.Now,
                                                    UpdateDate = DateTime.Now,
                                                    UserId = puser.Id, //创客
                                                    ChangeType = 50, //变动类型
                                                    ProductType = pos.BrandId, //产品类型
                                                    ChangeAmount = Prize, //变更金额
                                                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                                                }).Entity;
                                                db.SaveChanges();
                                                RedisDbconn.Instance.Set("UserAccount:" + puser.Id, account);

                                                string dateString = yesterday.ToString("yyyyMMdd");
                                                string monthString = yesterday.ToString("yyyyMM");
                                                // 开机奖励列表
                                                List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
                                                if (!dates.Contains(dateString))
                                                {
                                                    RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
                                                }
                                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);

                                                List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
                                                if (!months.Contains(monthString))
                                                {
                                                    RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
                                                }
                                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);

                                                // 开机奖励详情
                                                RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);

                                                //收支明细
                                                RedisDbconn.Instance.AddList("UserAccountRecord:" + puser.Id + ":1:" + monthString, userAccountRecord);
                                                RedisDbconn.Instance.AddNumber("UserAccount:" + puser.Id + ":1:" + monthString, Prize);

                                                Prize -= 10;
                                            }
                                        }
                                    }
                                }
                            }
                            // }
                        }
                    }
                }
            }
            db.Dispose();
        }

        public void dosomething42(string date)
        {
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Parse(date + " 00:00:00");
            DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
            List<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && m.MerStandardDate >= yesterday && m.MerStandardDate < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0").ToList();
            foreach (PosMerchantInfo merchant in merList)
            {
                MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
                PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
                if (pos.ActivationTime > DateTime.Now.AddDays(-20) && pos.CreditTrade >= 1000)
                {
                    decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
                    if (ActPrize > 0)
                    {
                        // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
                        // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
                        // if (otherInfo != null)
                        // {
                        //     otherInfo.PrizeFlag2 = 1;
                        //     db.SaveChanges();
                        // 从机具所属人上级开始分开机奖励
                        Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                        if (user != null)
                        {
                            if (!string.IsNullOrEmpty(user.ParentNav))
                            {
                                decimal Prize = 20;
                                string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                for (int i = ParentNavs.Length - 1; i >= 0; i--)
                                {
                                    int UserId = int.Parse(ParentNavs[i]);
                                    Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
                                    if (puser != null && Prize > 0)
                                    {
                                        int machineCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台购买机
                                        int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
                                        int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
                                        // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
                                        // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机（不限购买或赠送）
                                        if (machineCount + ActiveCount + couponCount >= 3)
                                        {
                                            int pTopUserId = 0;
                                            if (!string.IsNullOrEmpty(puser.ParentNav))
                                            {
                                                pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                                            }
                                            Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                                            OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
                                            {
                                                CreateDate = DateTime.Now,
                                                UpdateDate = DateTime.Now,
                                                TradeMonth = yesterday.ToString("yyyyMM"), //交易月
                                                TradeDate = yesterday, //达标日期
                                                UserId = puser.Id, //创客
                                                BrandId = pos.BrandId, //品牌
                                                ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
                                                MerchantId = pos.BindMerchantId, //商户
                                                DirectUserId = merchant.UserId, //商户直属人
                                                SnNo = pos.PosSn, //SN号
                                                MerNo = merchant.KqMerNo, //渠道商户号
                                                SnType = pos.PosSnType, //机具类型
                                                StandardDate = pos.ActivationTime, //商户的激活日期
                                                SnStoreId = pos.StoreId, //SN仓库
                                                MerBuddyType = puser.MerchantType, //商户创客类型
                                                RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励
                                                RewardTips = "开机奖励", //奖励描述
                                                CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                                DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                                CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                                RewardDesc = "开机奖励", //奖励描述
                                                TopUserId = pTopUserId, //顶级创客
                                                SeoTitle = machineUser.RealName,
                                            }).Entity;
                                            db.OpenReward.Add(new OpenReward()
                                            {
                                                CreateDate = DateTime.Now,
                                                UpdateDate = DateTime.Now,
                                                TradeMonth = yesterday.ToString("yyyyMM"), //交易月
                                                TradeDate = DateTime.Now, //达标日期
                                                UserId = puser.Id, //创客
                                                BrandId = pos.BrandId, //品牌
                                                RewardType = 2, //奖励类型
                                                CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                                DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                                CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                                RewardDesc = "开机奖励", //奖励描述
                                                TopUserId = pTopUserId, //顶级创客
                                            });
                                            string IdBrand = puser.Id + "_" + pos.BrandId;
                                            UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                                            if (userData == null)
                                            {
                                                userData = db.UserMachineData.Add(new UserMachineData()
                                                {
                                                    IdBrand = IdBrand,
                                                }).Entity;
                                                db.SaveChanges();
                                            }
                                            userData.OpenProfit += Prize;
                                            db.SaveChanges();
                                            RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                            //账户入库
                                            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
                                            if (account == null)
                                            {
                                                account = db.UserAccount.Add(new UserAccount()
                                                {
                                                    Id = puser.Id,
                                                    UserId = puser.Id,
                                                }).Entity;
                                                db.SaveChanges();
                                            }
                                            //收支明细入库
                                            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                                            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                                            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                                            account.BalanceAmount += Prize;
                                            account.TotalAmount += Prize;
                                            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                                            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                                            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                                            UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                                            {
                                                CreateDate = DateTime.Now,
                                                UpdateDate = DateTime.Now,
                                                UserId = puser.Id, //创客
                                                ChangeType = 50, //变动类型
                                                ProductType = pos.BrandId, //产品类型
                                                ChangeAmount = Prize, //变更金额
                                                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                                            }).Entity;
                                            db.SaveChanges();
                                            RedisDbconn.Instance.Set("UserAccount:" + puser.Id, account);

                                            string dateString = yesterday.ToString("yyyyMMdd");
                                            string monthString = yesterday.ToString("yyyyMM");
                                            // 开机奖励列表
                                            List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
                                            if (!dates.Contains(dateString))
                                            {
                                                RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
                                            }
                                            RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);

                                            List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
                                            if (!months.Contains(monthString))
                                            {
                                                RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
                                            }
                                            RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);

                                            // 开机奖励详情
                                            RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);

                                            //收支明细
                                            RedisDbconn.Instance.AddList("UserAccountRecord:" + puser.Id + ":1:" + monthString, userAccountRecord);
                                            RedisDbconn.Instance.AddNumber("UserAccount:" + puser.Id + ":1:" + monthString, Prize);

                                            Prize -= 10;
                                        }
                                    }
                                }
                            }
                        }
                        // }
                    }
                }
            }
            db.Dispose();
        }


        // 4. 前一天的流量卡记录和匹配
        public void ListenFluxRecord(string date)
        {
            Thread th = new Thread(CheckFluxForTrade);
            th.IsBackground = true;
            th.Start(date);
        }
        public void doFluxRecord(string date)
        {
            function.WriteLog(DateTime.Now.ToString(), "执行流量费返佣");
            SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
            WebCMSEntities db = new WebCMSEntities();
            DateTime yesterday = DateTime.Parse(date + " 00:00:00");
            DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
            List<SpModels.TradeFluxRecord> trades = spdb.TradeFluxRecord.Where(m => m.CreateDate >= yesterday && m.CreateDate < today && m.Status == 1).ToList();
            foreach (SpModels.TradeFluxRecord trade in trades)
            {
                try
                {
                    string OrderNo = trade.TradeSerialNo; //单号
                    DateTime TradeDate = trade.CreateDate.Value;
                    string TradeMonth = TradeDate.ToString("yyyyMM");
                    decimal FeeAmount = trade.FeeAmount; //流量费
                    if (trade.ProductType == "1" || trade.ProductType == "4" || trade.ProductType == "6" || trade.ProductType == "8" || trade.ProductType == "9")
                    {
                        FeeAmount = FeeAmount / 100;
                    }
                    string TradeSnNo = trade.TradeSnNo; //机具SN
                    decimal FluxProfit = 0;
                    if (trade.ProductType == "1" && FeeAmount == 60)
                    {
                        FluxProfit = 24;
                    }
                    else if (trade.ProductType == "7" && FeeAmount == 46)
                    {
                        FluxProfit = 10;
                    }
                    else if (trade.ProductType != "1" && FeeAmount == 48)
                    {
                        FluxProfit = 12;
                    }
                    if (FluxProfit > 0)
                    {
                        MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new MachineForSnNo();
                        PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
                        // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
                        PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                        if (merchant != null && pos.BrandId != 6)
                        {
                            bool checkExist = db.FluxProfitDetail.Any(m => m.MerNo == merchant.KqMerNo);
                            if (!checkExist && decimal.Parse(function.CheckNum(pos.SeoKeyword)) > 0)
                            {
                                Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                                int GetUserId = user.Id;
                                int TopUserId = 0;
                                string ParentNav = user.ParentNav;
                                if (!string.IsNullOrEmpty(ParentNav))
                                {
                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    if (ParentNavList.Length > 1)
                                    {
                                        TopUserId = int.Parse(ParentNavList[1]);
                                    }
                                    else if (ParentNavList.Length == 1)
                                    {
                                        TopUserId = int.Parse(ParentNavList[0]);
                                    }
                                }
                                FluxProfitSummary fluxProfit = db.FluxProfitSummary.FirstOrDefault(m => m.UserId == GetUserId && m.BrandId == pos.BrandId && m.TradeMonth == TradeMonth);
                                if (fluxProfit == null)
                                {
                                    fluxProfit = db.FluxProfitSummary.Add(new FluxProfitSummary()
                                    {
                                        CreateDate = DateTime.Now,
                                        UpdateDate = DateTime.Now,
                                        UserId = GetUserId, //创客
                                        BrandId = pos.BrandId,
                                        TopUserId = TopUserId, //顶级创客
                                        TradeMonth = TradeMonth, //交易月
                                        MerUserType = user.MerchantType, //商户创客类型
                                        Remark = "流量卡分佣", //备注
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                fluxProfit.FluxProfitAmt += FluxProfit; //流量分润总金额
                                db.FluxProfitDetail.Add(new FluxProfitDetail()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    RecordNo = OrderNo, //单号
                                    TradeDate = TradeDate.ToString("yyyyMMdd"), //交易日期
                                    TradeTime = TradeDate.ToString("HHmmss"), //交易时间
                                    TradeMonth = TradeMonth, //交易月
                                    UserId = GetUserId, //创客
                                    MerchantId = pos.BindMerchantId, //商户
                                    MerchantUserId = pos.UserId, //商户直属人
                                    MerNo = merchant.KqMerNo, //渠道商户编号
                                    SnNo = pos.PosSn, //渠道SN号
                                    FluxOrderNo = OrderNo, //流量扣费单号
                                    TradeOrderNo = OrderNo, //交易流水号
                                    TradeAmt = trade.TradeAmount, //商户交易额
                                    FluxFeeAmt = FeeAmount, //流量费
                                    FluxProfitAmt = FluxProfit, //流量分润总金额
                                    PosType = pos.PosSnType.ToString(), //POS类型
                                    Remark = "流量卡分佣", //备注
                                    BrandId = pos.BrandId, //品牌
                                    TopUserId = TopUserId, //顶级创客
                                    MerUserType = user.MerchantType, //商户创客类型
                                });
                                string IdBrand = user.Id + "_" + pos.BrandId;
                                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                                if (userData == null)
                                {
                                    userData = db.UserMachineData.Add(new UserMachineData()
                                    {
                                        IdBrand = IdBrand,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                userData.FluxProfit += FluxProfit;
                                db.SaveChanges();
                                RedisDbconn.Instance.Clear("UserMachineData:" + IdBrand);
                                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                                if (account == null)
                                {
                                    account = db.UserAccount.Add(new UserAccount()
                                    {
                                        Id = GetUserId,
                                        UserId = GetUserId,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                                account.BalanceAmount += FluxProfit;
                                account.TotalAmount += FluxProfit;
                                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    UserId = GetUserId, //创客
                                    ChangeType = 60, //变动类型
                                    ProductType = pos.BrandId, //产品类型
                                    ChangeAmount = FluxProfit, //变更金额
                                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                                }).Entity;
                                db.SaveChanges();
                                RedisDbconn.Instance.Clear("UserAccount:" + GetUserId);
                            }
                            SpModels.TradeFluxRecord edit = spdb.TradeFluxRecord.FirstOrDefault(m => m.Id == trade.Id);
                            if (edit != null)
                            {
                                edit.Status = 2;
                                spdb.SaveChanges();
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
                }
            }
            spdb.Dispose();
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣");
        }
        public void CheckFluxForTrade(object sender)
        {
            string date = sender.ToString();
            function.WriteLog(DateTime.Now.ToString(), "扫描金控交易记录中的流量费");
            SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
            DateTime start = DateTime.Parse(date + " 00:00:00");
            DateTime end = start.AddDays(1);
            var list = spdb.TradeRecord.Select(m => new { m.Id, m.CreateDate, m.ProductType }).Where(m => m.CreateDate > start && m.CreateDate < end && m.ProductType == "1").OrderBy(m => m.CreateDate);
            foreach (var sub in list.ToList())
            {
                try
                {
                    SpModels.TradeRecord trade = spdb.TradeRecord.FirstOrDefault(m => m.Id == sub.Id);
                    if (trade != null)
                    {
                        string content = trade.SeoDescription;
                        if (!string.IsNullOrEmpty(content))
                        {
                            content = System.Web.HttpUtility.UrlDecode(content);
                            JsonData jsonObj = JsonMapper.ToObject(content);
                            decimal terminalDataFlowFee = decimal.Parse(function.CheckNum(jsonObj["terminalDataFlowFee"].ToString()));
                            if (terminalDataFlowFee > 0)
                            {
                                spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord()
                                {
                                    SeoDescription = trade.TradeSerialNo,
                                    FeeAmount = terminalDataFlowFee,
                                    TradeSerialNo = function.MD5_16(trade.TradeSerialNo),
                                    CreateDate = trade.CreateDate,
                                    TradeSnNo = trade.TradeSnNo,
                                    ProductType = trade.ProductType,
                                    Status = 1,
                                });
                                spdb.SaveChanges();
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描金控交易记录中的流量费异常");
                }
            }
            spdb.Dispose();
            function.WriteLog(DateTime.Now.ToString() + "\n", "扫描金控交易记录中的流量费");

            doFluxRecord(date);
        }






        // 统计交易额V2
        public void StartEverDayV2()
        {
            Thread th = new Thread(StartEverDayV2Do);
            th.IsBackground = true;
            th.Start();
        }
        public void StartEverDayV2Do()
        {
            while (true)
            {
                if(DateTime.Now.Hour >= 2)
                {
                    StatTradeAmountEverDayV2();
                }
                Thread.Sleep(100);
            }
        }
        public void StatTradeAmountEverDayV2()
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行交易额V2日志");
            WebCMSEntities db = new WebCMSEntities();
            using (var tran = db.Database.BeginTransaction())
            {
                try
                {
                    string startId = function.ReadInstance("/TradeRecord/Id.txt");
                    if(string.IsNullOrEmpty(startId))
                    {
                        startId = "718574";
                    }
                    DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
                    if(idsDt.Rows.Count > 0)
                    {
                        string ids = "";
                        foreach (DataRow idsDr in idsDt.Rows)
                        {
                            ids += idsDr["Id"].ToString() + ",";
                            startId = idsDr["Id"].ToString();
                        }
                        DataTable selfDt = OtherMySqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d')");
                        if (selfDt.Rows.Count > 0)
                        {
                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时交易额V2日志");
                            foreach (DataRow selfDr in selfDt.Rows)
                            {
                                int UserId = int.Parse(selfDr["UserId"].ToString());
                                Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                                string ParentNav = user.ParentNav; //selfDr["ParentNav"].ToString();
                                int BrandId = int.Parse(selfDr["BrandId"].ToString());
                                int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
                                int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
                                int MerHelpFlag = int.Parse(selfDr["MerHelpFlag"].ToString());
                                int CapFlag = int.Parse(selfDr["CapFlag"].ToString());
                                int VipFlag = int.Parse(selfDr["VipFlag"].ToString());
                                int PayType = int.Parse(selfDr["PayType"].ToString());
                                string TradeDate = selfDr[9].ToString();
                                decimal TradeAmount = decimal.Parse(selfDr[10].ToString());
                                int TradeCount = int.Parse(selfDr[11].ToString());
                                string TradeMonth = TradeDate.Substring(0, 6);
                                TradeDaySummary selfStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "self");
                                if (selfStat == null)
                                {
                                    selfStat = db.TradeDaySummary.Add(new TradeDaySummary()
                                    {
                                        UserId = UserId,
                                        TradeMonth = TradeMonth,
                                        TradeDate = TradeDate,
                                        BrandId = BrandId,
                                        QueryCount = QrPayFlag,
                                        VipFlag = VipFlag,
                                        PayType = PayType,
                                        SeoTitle = "self",
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                if (BankCardType == 0)
                                {
                                    if (MerHelpFlag == 1)
                                    {
                                        selfStat.HelpDirectDebitTradeAmt += TradeAmount;
                                        if (CapFlag == 1)
                                        {
                                            selfStat.HelpDirectDebitCapTradeAmt += TradeAmount;
                                            selfStat.HelpDirectDebitCapNum += TradeCount;
                                        }
                                    }
                                    else
                                    {
                                        selfStat.NotHelpDirectDebitTradeAmt += TradeAmount;
                                        if (CapFlag == 1)
                                        {
                                            selfStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
                                            selfStat.NotHelpDirectDebitCapNum += TradeCount;
                                        }
                                    }
                                }
                                else if (BankCardType != 0)
                                {
                                    if (MerHelpFlag == 1)
                                    {
                                        selfStat.HelpDirectTradeAmt += TradeAmount;
                                    }
                                    else
                                    {
                                        selfStat.NotHelpDirectTradeAmt += TradeAmount;
                                    }
                                }
                                ParentNav += "," + UserId + ",";
                                if (!string.IsNullOrEmpty(ParentNav))
                                {
                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    foreach (string NavUserIdString in ParentNavList)
                                    {
                                        int NavUserId = int.Parse(NavUserIdString);
                                        TradeDaySummary teamStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "team");
                                        if (teamStat == null)
                                        {
                                            teamStat = db.TradeDaySummary.Add(new TradeDaySummary()
                                            {
                                                UserId = NavUserId,
                                                TradeMonth = TradeMonth,
                                                TradeDate = TradeDate,
                                                BrandId = BrandId,
                                                QueryCount = QrPayFlag,
                                                VipFlag = VipFlag,
                                                PayType = PayType,
                                                SeoTitle = "team",
                                            }).Entity;
                                            db.SaveChanges();
                                        }
                                        if (BankCardType == 0)
                                        {
                                            if (MerHelpFlag == 1)
                                            {
                                                teamStat.HelpNonDirectDebitTradeAmt += TradeAmount;
                                                if (CapFlag == 1)
                                                {
                                                    teamStat.HelpDirectDebitCapTradeAmt += TradeAmount;
                                                    teamStat.HelpDirectDebitCapNum += TradeCount;
                                                }
                                            }
                                            else
                                            {
                                                teamStat.NotHelpNonDirectDebitTradeAmt += TradeAmount;
                                                if (CapFlag == 1)
                                                {
                                                    teamStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
                                                    teamStat.NotHelpDirectDebitCapNum += TradeCount;
                                                }
                                            }
                                        }
                                        else if (BankCardType != 0)
                                        {
                                            if (MerHelpFlag == 1)
                                            {
                                                teamStat.HelpNonDirectTradeAmt += TradeAmount;
                                            }
                                            else
                                            {
                                                teamStat.NotHelpNonDirectTradeAmt += TradeAmount;
                                            }
                                        }
                                    }
                                }
                            }
                            OtherMySqlConn.op("update TradeRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                            function.WritePage("/TradeRecord/", "Id.txt", startId);
                        }
                        db.SaveChanges();
                    }
                    tran.Commit();
                }
                catch (Exception ex)
                {
                    tran.Rollback();
                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天交易额V2异常");
                }
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行交易额V2日志");
        }


        // 每天统计头一天的交易额
        public void StartEverDay(string date)
        {
            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            // DateTime end = DateTime.Parse("2022-04-19 00:00:00");
            // DateTime check = DateTime.Parse("2022-03-11");
            // while (check <= end)
            // {
            //     Thread th = new Thread(StatTradeAmountEverDay);
            //     th.IsBackground = true;
            //     th.Start(check.ToString("yyyy-MM-dd"));
            //     check = check.AddDays(1);
            // }
            string TradeMonth = DateTime.Now.ToString("yyyyMM");
            if(DateTime.Now.Day == 1)
            {
                TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            }
            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
            foreach (DataRow dr in list.Rows)
            {
                string UserId = dr["UserId"].ToString();
                string ThisMonthTrade = dr[1].ToString();
                OtherMySqlConn.op("update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId);
            }
            // Thread th = new Thread(StatTradeAmountEverDay);
            // th.IsBackground = true;
            // th.Start(date);
        }
        public void StatTradeAmountEverDay(object sender)
        {
            string date = sender.ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                string TradeDate = date.Replace("-", "");
                string TradeMonth = TradeDate.Substring(0, 6);
                string start = date + " 00:00:00";
                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                string startId = "0", endId = "9999999999";
                List<string> uids = new List<string>();
                DataTable startDt = OtherMySqlConn.dtable("select min(Id) from TradeRecord where CreateDate>='" + start + "'");
                if (startDt.Rows.Count > 0)
                {
                    startId = startDt.Rows[0][0].ToString();
                }
                function.WriteLog(startId + "\n\n", "执行昨天交易额日志");
                // DataTable endDt = OtherMySqlConn.dtable("select max(Id) from TradeRecord where CreateDate<'" + end + "'");
                // if (endDt.Rows.Count > 0)
                // {
                //     endId = endDt.Rows[0][0].ToString();
                // }
                DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
                function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志");
                foreach (DataRow userDr in userDt.Rows)
                {
                    int UserId = int.Parse(userDr["Id"].ToString());
                    string ParentNav = userDr["ParentNav"].ToString();
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
                    DataTable selfdt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by BrandId,BankCardType,QrPayFlag");
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
                    foreach (DataRow selfDr in selfdt.Rows)
                    {
                        int BrandId = int.Parse(selfDr["BrandId"].ToString());
                        int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
                        int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
                        decimal TradeAmount = decimal.Parse(selfDr[3].ToString());
                        UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
                        if (selfStat == null)
                        {
                            selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                            {
                                UserId = UserId,
                                TradeMonth = TradeMonth,
                                TradeDate = TradeDate,
                                BrandId = BrandId,
                                QueryCount = QrPayFlag,
                                SeoTitle = "self",
                            }).Entity;
                            db.SaveChanges();
                        }
                        if (BankCardType == 0)
                        {
                            selfStat.DirectDebitTradeAmt += TradeAmount;
                        }
                        else if (BankCardType != 0)
                        {
                            selfStat.DirectTradeAmt += TradeAmount;
                        }
                        db.SaveChanges();
                    }
                    if (!string.IsNullOrEmpty(ParentNav))
                    {
                        ParentNav += "," + UserId + ",";
                        string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                        foreach (string NavUserIdString in ParentNavList)
                        {
                            if (!uids.Contains(NavUserIdString + start))
                            {
                                uids.Add(NavUserIdString + start);
                                int NavUserId = int.Parse(NavUserIdString);
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
                                DataTable teamDt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId,BankCardType,QrPayFlag");
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
                                foreach (DataRow teamDr in teamDt.Rows)
                                {
                                    int BrandId = int.Parse(teamDr["BrandId"].ToString());
                                    int BankCardType = int.Parse(teamDr["BankCardType"].ToString());
                                    int QrPayFlag = int.Parse(teamDr["QrPayFlag"].ToString());
                                    decimal TradeAmount = decimal.Parse(teamDr[3].ToString());
                                    UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                                        {
                                            UserId = NavUserId,
                                            TradeMonth = TradeMonth,
                                            TradeDate = TradeDate,
                                            BrandId = BrandId,
                                            QueryCount = QrPayFlag,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    if (BankCardType == 0)
                                    {
                                        teamStat.NonDirectDebitTradeAmt += TradeAmount;
                                    }
                                    else if (BankCardType != 0)
                                    {
                                        teamStat.NonDirectTradeAmt += TradeAmount;
                                    }
                                    db.SaveChanges();
                                }
                            }
                        }
                    }
                }
                if (DateTime.Now.Day >= 2)
                {
                    Thread.Sleep(5000);
                    DataTable list = OtherMySqlConn.dtable("select UserId,sum(NonDirectTradeAmt) from UserTradeDaySummary where TradeDate='" + TradeDate + "' GROUP BY UserId");
                    foreach (DataRow dr in list.Rows)
                    {
                        string UserId = dr["UserId"].ToString();
                        string ThisMonthTrade = dr[1].ToString();
                        OtherMySqlConn.op("update Users set ThisMonthTrade=ThisMonthTrade+" + ThisMonthTrade + " where Id=" + UserId);
                    }
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");

            StatMerchantTrade(date);
        }
        public void StatTradeAmountEverDaySum()
        {
            // WebCMSEntities db = new WebCMSEntities();
            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            // DataTable dt = OtherMySqlConn.dtable("select UserId,BrandId,QueryCount,TradeDate,TradeMonth,sum(DirectDebitTradeAmt) as DirectDebitTradeAmt,sum(DirectTradeAmt) as DirectTradeAmt,sum(NonDirectDebitTradeAmt) as NonDirectDebitTradeAmt,sum(NonDirectTradeAmt) as NonDirectTradeAmt from UserTradeDaySummary group by UserId,BrandId,QueryCount,TradeDate,TradeMonth order by UserId,BrandId,QueryCount");
            // string html = "<table>";
            // foreach (DataRow dr in dt.Rows)
            // {
            //     html += "<tr>";
            //     string TradeDate = dr["TradeDate"].ToString();
            //     string TradeMonth = dr["TradeMonth"].ToString();
            //     int UserId = int.Parse(dr["UserId"].ToString());
            //     int BrandId = int.Parse(dr["BrandId"].ToString());
            //     int QrPayFlag = int.Parse(dr["QueryCount"].ToString());
            //     decimal DirectDebitTradeAmt = decimal.Parse(dr["DirectDebitTradeAmt"].ToString());
            //     decimal DirectTradeAmt = decimal.Parse(dr["DirectTradeAmt"].ToString());
            //     decimal NonDirectDebitTradeAmt = decimal.Parse(dr["NonDirectDebitTradeAmt"].ToString());
            //     decimal NonDirectTradeAmt = decimal.Parse(dr["NonDirectTradeAmt"].ToString());
            //     decimal CurAmount = 0, CurTotalAmount = 0, CurMonthAmount = 0, CurDayAmount = 0;

            //     CurTotalAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId); //总交易
            //     CurMonthAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + TradeDate); //总交易
            //     CurDayAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + TradeMonth); //总交易
            //     CurAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + BrandId + ":" + TradeDate); //总交易
            //     decimal TotalPosAmount = 0;
            //     decimal TotalCloudPayAmount = 0;
            //     decimal TeamTotalPosAmount = 0;
            //     decimal TeamTotalCloudPayAmount = 0;
            //     if (QrPayFlag == 1)
            //     {
            //         TotalCloudPayAmount = RedisDbconn.Instance.Get<decimal>("TotalCloudPayAmount:" + UserId + ":" + TradeDate); //云闪付小额交易额
            //         TeamTotalCloudPayAmount = RedisDbconn.Instance.Get<decimal>("TeamTotalCloudPayAmount:" + UserId + ":" + TradeDate); //POS机刷卡交易额
            //     }
            //     else
            //     {
            //         TotalPosAmount = RedisDbconn.Instance.Get<decimal>("TotalPosAmount:" + UserId + ":" + TradeDate); //POS机刷卡交易额
            //         TeamTotalPosAmount = RedisDbconn.Instance.Get<decimal>("TeamTotalPosAmount:" + UserId + ":" + TradeDate); //云闪付小额交易额
            //     }
            //     Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
            //     html += "<td>应得</td>";
            //     html += "<td>" + user.MakerCode + "</td>";
            //     html += "<td>" + user.RealName + "</td>";
            //     html += "<td>" + user.Mobile + "</td>";
            //     html += "<td>" + BrandId + "</td>";
            //     html += "<td>" + QrPayFlag + "</td>";
            //     html += "<td>" + DirectDebitTradeAmt + "</td>";
            //     html += "<td>" + DirectTradeAmt + "</td>";
            //     html += "<td>" + NonDirectDebitTradeAmt + "</td>";
            //     html += "<td>" + NonDirectTradeAmt + "</td>";
            //     html += "</tr>";

            //     html += "<tr>";
            //     html += "<td>当前</td>";
            //     html += "<td></td>";
            //     html += "<td></td>";
            //     html += "<td>当天品牌：" + CurAmount + "</td>";
            //     html += "<td>总交易：" + CurTotalAmount + "</td>";
            //     html += "<td>当月：" + CurMonthAmount + "</td>";
            //     html += "<td>当天：" + CurDayAmount + "</td>";
            //     html += "<td>" + TotalPosAmount + "</td>";
            //     html += "<td>" + TotalCloudPayAmount + "</td>";
            //     html += "<td>" + TeamTotalPosAmount + "</td>";
            //     html += "<td>" + TeamTotalCloudPayAmount + "</td>";
            //     html += "</tr>";
            // }
            // html += "</table>";
            // db.Dispose();
            // // OtherMySqlConn.connstr = ;
            // function.WritePage("/html/", "1.html", html);
        }









        //统计商户交易额
        private void StatMerchantTrade(string date)
        {
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
            // WebCMSEntities db = new WebCMSEntities();
            try
            {
                string start = date + " 00:00:00";
                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                OtherMySqlConn.op("insert into PosMerchantTradeSummay (MerchantId,BrandId,TradeDate,TradeMonth,TradeAmount,CreateDate)  select *,now() from (select MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d') as TradeDate,DATE_FORMAT(CreateDate,'%Y%m') as TradeMonth,sum(TradeAmount) as TradeAmount from TradeRecord where CreateDate>='" + start + "' and CreateDate<'" + end + "' group by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d'),TradeDate,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d')) tb");
                RedisDbconn.Instance.Clear("PosMerchantAmount:*");
                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "").Substring(0, 6)); //商户当月交易
                RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "")); //商户当日交易
                // foreach (DataRow selfDr in selfdt.Rows)
                // {
                //     int BrandId = int.Parse(selfDr["BrandId"].ToString());
                //     int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
                //     string TradeDate = selfDr["TradeDate"].ToString();
                //     TradeDate = TradeDate.Replace("-", "");
                //     string TradeMonth = TradeDate.Substring(0, 6);
                //     decimal TradeAmount = decimal.Parse(selfDr["TradeAmount"].ToString());
                //     PosMerchantTradeSummay merStat = db.PosMerchantTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId);
                //     if (merStat == null)
                //     {
                //         merStat = db.PosMerchantTradeSummay.Add(new PosMerchantTradeSummay()
                //         {
                //             MerchantId = MerchantId,
                //             TradeMonth = TradeMonth,
                //             TradeDate = TradeDate,
                //             BrandId = BrandId,
                //         }).Entity;
                //         db.SaveChanges();
                //     }
                //     merStat.TradeAmount += TradeAmount;
                //     db.SaveChanges();                    
                // }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
            }
            // db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
        }


        // 5. 创客升级
        public void StatUserLevel()
        {
            Thread th = new Thread(StatUserLevelDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatUserLevelDo()
        {
            while (true)
            {
                if(DateTime.Now.Day <= 3 && DateTime.Now.Hour > 1)
                {
                    string Month = DateTime.Now.AddDays(-1).ToString("yyyy-MM");
                    string flag = function.ReadInstance("/ProfitFlag/" + Month + ".txt");
                    if (string.IsNullOrEmpty(flag))
                    {
                        function.WritePage("/ProfitFlag/", Month + ".txt", DateTime.Now.ToString("HH:mm:ss"));
                        StatUserLevelStart();
                    }
                }
                Thread.Sleep(60000);
            }
        }
        public void StatUserLevelStart()
        {
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
                DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
                DateTime end = start.AddDays(1);
                string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
                List<UserLevelSet> sets = db.UserLevelSet.ToList();
                bool op = true;
                int startid = 0;
                while(op)
                {
                    var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(50).ToList();
                    function.WriteLog(users.Count.ToString(), "创客升级日志");
                    if(users.Count > 0)
                    {
                        foreach (var subuser in users)
                        {
                            Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
                            if (user != null)
                            {
                                int BeforeLevel = user.UserLevel;
                                int AfterLevel = 0;
                                decimal TradeAmount = 0;
                                bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
                                if (check)
                                {
                                    TradeAmount = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
                                }
                                UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
                                if (set != null)
                                {
                                    AfterLevel = set.Id;
                                }
                                if (AfterLevel > BeforeLevel && AfterLevel > 1)
                                {
                                    function.WriteLog("升级：" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
                                    user.UserLevel = AfterLevel;
                                    db.UserRank.Add(new UserRank()
                                    {
                                        CreateDate = DateTime.Now,
                                        UpdateDate = DateTime.Now,
                                        UserId = user.Id, //创客
                                        WhiteRank = BeforeLevel,
                                        Rank = AfterLevel, //当前等级
                                        StatYear = DateTime.Now.Year, //统计年份
                                        StatMonth = DateTime.Now.Month, //统计月份
                                        TradeAmt = TradeAmount, //团队交易总额
                                        UpgradeFlag = 1, //升级标识
                                        OperateDate = DateTime.Now, //操作时间
                                    });
                                    db.SaveChanges();
                                }
                            }
                            startid = subuser.Id;
                        }
                    }
                    else
                    {
                        op = false;
                    }
                }
                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
            }
            catch (Exception ex)
            {
                function.WriteLog(ex.ToString(), "创客升级异常");
            }
            db.Dispose();

            // ProfitHelperV2.Instance.StatProfit(); //统计分润
        }
        public void StatUserLevelStartTest()
        {
            Thread th = new Thread(StatUserLevelStartTestDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatUserLevelStartTestDo()
        {
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
                DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
                DateTime end = start.AddDays(1);
                string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
                List<UserLevelSet> sets = db.UserLevelSet.ToList();
                List<int> uids = new List<int>();
                uids.Add(6341);
                uids.Add(6904);
                uids.Add(7060);
                uids.Add(19085);
                uids.Add(19770);
                uids.Add(19849);
                uids.Add(19917);
                uids.Add(19954);
                uids.Add(19956);
                uids.Add(19977);
                uids.Add(22106);
                uids.Add(22931);
                uids.Add(23133);
                uids.Add(23140);
                uids.Add(26022);
                uids.Add(26351);
                uids.Add(26383);
                uids.Add(28245);
                uids.Add(29180);
                uids.Add(29186);
                uids.Add(29800);
                uids.Add(30038);
                uids.Add(30142);
                uids.Add(30236);
                uids.Add(31068);
                uids.Add(31103);
                uids.Add(31192);
                uids.Add(31314);
                uids.Add(32530);
                uids.Add(32607);
                uids.Add(32610);
                uids.Add(34323);
                uids.Add(34485);
                uids.Add(35171);
                uids.Add(36255);
                uids.Add(36441);
                uids.Add(36622);
                uids.Add(36737);
                uids.Add(37229);
                uids.Add(37732);
                uids.Add(37874);
                uids.Add(37972);
                uids.Add(38231);
                uids.Add(38412);
                uids.Add(38420);
                uids.Add(38432);
                uids.Add(38512);
                uids.Add(38622);
                uids.Add(38736);
                uids.Add(38819);
                uids.Add(38856);
                uids.Add(38861);
                uids.Add(38883);
                uids.Add(39578);
                uids.Add(40695);
                uids.Add(40780);
                uids.Add(41279);
                uids.Add(41452);
                uids.Add(42018);
                uids.Add(42268);
                uids.Add(42353);
                uids.Add(42523);
                uids.Add(42630);
                uids.Add(43076);
                uids.Add(43587);
                uids.Add(43667);
                uids.Add(43891);
                uids.Add(44998);
                uids.Add(45769);
                uids.Add(46596);
                uids.Add(47037);
                uids.Add(47475);
                uids.Add(49470);
                uids.Add(50156);
                uids.Add(50222);
                uids.Add(50327);
                uids.Add(52627);
                uids.Add(52662);
                uids.Add(52704);
                uids.Add(54371);
                uids.Add(54453);
                uids.Add(54581);
                uids.Add(55210);
                uids.Add(55968);
                uids.Add(56194);
                uids.Add(58064);
                uids.Add(59291);
                uids.Add(59451);
                uids.Add(59553);
                uids.Add(59596);
                uids.Add(60161);
                uids.Add(60612);
                uids.Add(61495);
                uids.Add(61567);
                uids.Add(61846);
                uids.Add(63659);
                uids.Add(64248);
                uids.Add(65215);
                uids.Add(67245);
                uids.Add(71748);
                uids.Add(72237);
                uids.Add(73923);
                uids.Add(74777);
                uids.Add(75147);
                uids.Add(76917);
                uids.Add(80974);
                uids.Add(81624);
                uids.Add(82394);
                uids.Add(83665);
                uids.Add(85512);
                uids.Add(87484);
                uids.Add(87977);
                uids.Add(91247);
                uids.Add(91542);
                uids.Add(91627);
                uids.Add(92322);
                uids.Add(92348);
                uids.Add(93754);
                uids.Add(94959);
                uids.Add(95680);
                uids.Add(95873);
                uids.Add(96871);
                uids.Add(97271);
                uids.Add(97727);
                uids.Add(99454);
                uids.Add(99511);
                uids.Add(99515);
                uids.Add(99798);
                uids.Add(100701);
                uids.Add(102435);
                uids.Add(103472);
                uids.Add(105305);
                uids.Add(107404);
                uids.Add(108062);
                uids.Add(120652);
                uids.Add(120794);
                uids.Add(120796);
                uids.Add(120882);
                uids.Add(121192);
                uids.Add(121221);
                uids.Add(121236);
                uids.Add(121246);
                uids.Add(121266);
                uids.Add(121340);
                uids.Add(121373);
                uids.Add(121377);
                uids.Add(121509);
                uids.Add(121544);
                uids.Add(121589);
                uids.Add(121598);
                uids.Add(121611);
                uids.Add(121631);
                uids.Add(121651);
                uids.Add(121679);
                uids.Add(121745);
                uids.Add(121751);
                uids.Add(121768);
                uids.Add(121789);
                uids.Add(121794);
                uids.Add(121809);
                uids.Add(121866);
                uids.Add(121936);
                uids.Add(121986);
                uids.Add(121995);
                uids.Add(121996);
                uids.Add(121999);
                uids.Add(122034);
                uids.Add(122054);
                uids.Add(122058);
                uids.Add(122103);
                uids.Add(122159);
                uids.Add(122160);
                uids.Add(122198);
                uids.Add(122215);
                uids.Add(122271);
                uids.Add(122273);
                uids.Add(122437);
                uids.Add(122472);
                uids.Add(122497);
                uids.Add(122748);
                uids.Add(122759);
                uids.Add(123052);
                uids.Add(123441);
                uids.Add(123491);
                uids.Add(123541);
                uids.Add(123618);
                uids.Add(123845);
                uids.Add(123918);
                uids.Add(123966);
                uids.Add(124121);
                uids.Add(124244);
                uids.Add(124249);
                uids.Add(124337);
                uids.Add(124338);
                uids.Add(124343);
                uids.Add(124416);
                uids.Add(124423);
                uids.Add(124489);
                uids.Add(124523);
                uids.Add(124537);
                uids.Add(124613);
                uids.Add(124626);
                uids.Add(124658);
                uids.Add(124670);
                uids.Add(124825);
                uids.Add(124861);
                uids.Add(125150);
                uids.Add(125264);
                uids.Add(125362);
                uids.Add(125717);
                uids.Add(125772);
                uids.Add(126023);
                uids.Add(126141);
                uids.Add(126271);
                uids.Add(126664);
                uids.Add(127072);
                uids.Add(127194);
                uids.Add(127254);
                uids.Add(127377);
                uids.Add(127550);
                uids.Add(127716);
                uids.Add(128111);
                uids.Add(128370);
                uids.Add(128915);
                uids.Add(130345);
                uids.Add(130755);
                uids.Add(130871);
                uids.Add(130967);
                uids.Add(131795);
                uids.Add(133726);
                uids.Add(134801);
                uids.Add(3032);
                uids.Add(3136);
                uids.Add(7519);
                uids.Add(7524);
                uids.Add(7528);
                uids.Add(7608);
                uids.Add(10617);
                uids.Add(14883);
                uids.Add(15102);
                uids.Add(15296);
                uids.Add(15386);
                uids.Add(15464);
                uids.Add(15511);
                uids.Add(15714);
                uids.Add(15719);
                uids.Add(16184);
                uids.Add(16464);
                uids.Add(16473);
                uids.Add(16483);
                uids.Add(16867);
                uids.Add(17199);
                uids.Add(17737);
                uids.Add(18222);
                uids.Add(18441);
                uids.Add(19275);
                uids.Add(19335);
                uids.Add(20261);
                uids.Add(20311);
                uids.Add(20721);
                uids.Add(21051);
                uids.Add(21219);
                uids.Add(21486);
                uids.Add(21846);
                uids.Add(22263);
                uids.Add(22589);
                uids.Add(22606);
                uids.Add(22970);
                uids.Add(22986);
                uids.Add(23164);
                uids.Add(23272);
                uids.Add(24303);
                uids.Add(25946);
                uids.Add(26213);
                uids.Add(26267);
                uids.Add(26547);
                uids.Add(27164);
                uids.Add(27254);
                uids.Add(27846);
                uids.Add(27855);
                uids.Add(27942);
                uids.Add(28083);
                uids.Add(28470);
                uids.Add(29715);
                uids.Add(29844);
                uids.Add(30869);
                uids.Add(31400);
                uids.Add(31908);
                uids.Add(32072);
                uids.Add(32458);
                uids.Add(33070);
                uids.Add(33152);
                uids.Add(33583);
                uids.Add(34030);
                uids.Add(34884);
                uids.Add(34945);
                uids.Add(35120);
                uids.Add(35212);
                uids.Add(35541);
                uids.Add(35706);
                uids.Add(35812);
                uids.Add(35861);
                uids.Add(35965);
                uids.Add(35989);
                uids.Add(36014);
                uids.Add(36054);
                uids.Add(36212);
                uids.Add(36591);
                uids.Add(37037);
                uids.Add(37094);
                uids.Add(37102);
                uids.Add(37161);
                uids.Add(37242);
                uids.Add(37245);
                uids.Add(37534);
                uids.Add(37584);
                uids.Add(37979);
                uids.Add(37980);
                uids.Add(38254);
                uids.Add(38688);
                uids.Add(38707);
                uids.Add(38862);
                uids.Add(38902);
                uids.Add(39215);
                uids.Add(39599);
                uids.Add(39863);
                uids.Add(39865);
                uids.Add(40592);
                uids.Add(41976);
                uids.Add(41998);
                uids.Add(42020);
                uids.Add(43070);
                uids.Add(43138);
                uids.Add(43269);
                uids.Add(43461);
                uids.Add(43514);
                uids.Add(43876);
                uids.Add(43881);
                uids.Add(43906);
                uids.Add(44240);
                uids.Add(44299);
                uids.Add(44516);
                uids.Add(44806);
                uids.Add(45001);
                uids.Add(45176);
                uids.Add(45798);
                uids.Add(45919);
                uids.Add(45983);
                uids.Add(46177);
                uids.Add(46507);
                uids.Add(46702);
                uids.Add(47901);
                uids.Add(49427);
                uids.Add(49429);
                uids.Add(49646);
                uids.Add(50109);
                uids.Add(51345);
                uids.Add(51619);
                uids.Add(52742);
                uids.Add(53643);
                uids.Add(53668);
                uids.Add(53793);
                uids.Add(53882);
                uids.Add(54010);
                uids.Add(54213);
                uids.Add(55000);
                uids.Add(55569);
                uids.Add(56453);
                uids.Add(57213);
                uids.Add(57620);
                uids.Add(58235);
                uids.Add(58347);
                uids.Add(58572);
                uids.Add(59669);
                uids.Add(60367);
                uids.Add(60454);
                uids.Add(60903);
                uids.Add(60933);
                uids.Add(61132);
                uids.Add(62108);
                uids.Add(62412);
                uids.Add(63059);
                uids.Add(63065);
                uids.Add(63451);
                uids.Add(64408);
                uids.Add(64730);
                uids.Add(64793);
                uids.Add(64800);
                uids.Add(65604);
                uids.Add(65785);
                uids.Add(65813);
                uids.Add(67408);
                uids.Add(67540);
                uids.Add(67637);
                uids.Add(67889);
                uids.Add(68782);
                uids.Add(68883);
                uids.Add(68914);
                uids.Add(69176);
                uids.Add(69299);
                uids.Add(69318);
                uids.Add(69553);
                uids.Add(69562);
                uids.Add(69654);
                uids.Add(69960);
                uids.Add(70155);
                uids.Add(71086);
                uids.Add(71141);
                uids.Add(71502);
                uids.Add(71520);
                uids.Add(71588);
                uids.Add(71753);
                uids.Add(71810);
                uids.Add(72961);
                uids.Add(73105);
                uids.Add(73117);
                uids.Add(73161);
                uids.Add(73219);
                uids.Add(73909);
                uids.Add(74052);
                uids.Add(74156);
                uids.Add(74276);
                uids.Add(75136);
                uids.Add(75261);
                uids.Add(75502);
                uids.Add(75584);
                uids.Add(75595);
                uids.Add(76105);
                uids.Add(76846);
                uids.Add(77412);
                uids.Add(77537);
                uids.Add(78021);
                uids.Add(78234);
                uids.Add(78316);
                uids.Add(78392);
                uids.Add(78605);
                uids.Add(78819);
                uids.Add(79322);
                uids.Add(79814);
                uids.Add(80144);
                uids.Add(80289);
                uids.Add(80508);
                uids.Add(81649);
                uids.Add(81763);
                uids.Add(81774);
                uids.Add(82015);
                uids.Add(82502);
                uids.Add(82519);
                uids.Add(83020);
                uids.Add(83043);
                uids.Add(83269);
                uids.Add(83308);
                uids.Add(83331);
                uids.Add(83474);
                uids.Add(84475);
                uids.Add(84493);
                uids.Add(84650);
                uids.Add(85072);
                uids.Add(85431);
                uids.Add(85467);
                uids.Add(85613);
                uids.Add(85665);
                uids.Add(85718);
                uids.Add(85797);
                uids.Add(85833);
                uids.Add(86096);
                uids.Add(86289);
                uids.Add(86515);
                uids.Add(86537);
                uids.Add(86806);
                uids.Add(86828);
                uids.Add(86919);
                uids.Add(87015);
                uids.Add(87027);
                uids.Add(87530);
                uids.Add(87905);
                uids.Add(88021);
                uids.Add(88321);
                uids.Add(88413);
                uids.Add(88554);
                uids.Add(88575);
                uids.Add(88951);
                uids.Add(88995);
                uids.Add(89142);
                uids.Add(89248);
                uids.Add(89276);
                uids.Add(89640);
                uids.Add(90000);
                uids.Add(90204);
                uids.Add(90537);
                uids.Add(90573);
                uids.Add(90630);
                uids.Add(90823);
                uids.Add(90940);
                uids.Add(90954);
                uids.Add(91048);
                uids.Add(91190);
                uids.Add(91328);
                uids.Add(91584);
                uids.Add(91892);
                uids.Add(92192);
                uids.Add(92233);
                uids.Add(92556);
                uids.Add(92826);
                uids.Add(92907);
                uids.Add(94165);
                uids.Add(94308);
                uids.Add(94333);
                uids.Add(94438);
                uids.Add(95092);
                uids.Add(95264);
                uids.Add(96559);
                uids.Add(96934);
                uids.Add(97455);
                uids.Add(97605);
                uids.Add(98636);
                uids.Add(99278);
                uids.Add(99602);
                uids.Add(99881);
                uids.Add(99986);
                uids.Add(100799);
                uids.Add(100871);
                uids.Add(101138);
                uids.Add(102019);
                uids.Add(102498);
                uids.Add(102993);
                uids.Add(104594);
                uids.Add(105145);
                uids.Add(105568);
                uids.Add(106287);
                uids.Add(106884);
                uids.Add(107104);
                uids.Add(107946);
                uids.Add(109212);
                uids.Add(109251);
                uids.Add(109606);
                uids.Add(120602);
                uids.Add(120749);
                uids.Add(120874);
                uids.Add(120892);
                uids.Add(120926);
                uids.Add(120940);
                uids.Add(120961);
                uids.Add(120971);
                uids.Add(120981);
                uids.Add(121038);
                uids.Add(121042);
                uids.Add(121057);
                uids.Add(121079);
                uids.Add(121094);
                uids.Add(121181);
                uids.Add(121188);
                uids.Add(121193);
                uids.Add(121213);
                uids.Add(121276);
                uids.Add(121328);
                uids.Add(121402);
                uids.Add(121457);
                uids.Add(121465);
                uids.Add(121475);
                uids.Add(121480);
                uids.Add(121539);
                uids.Add(121632);
                uids.Add(121641);
                uids.Add(121685);
                uids.Add(121708);
                uids.Add(121735);
                uids.Add(121750);
                uids.Add(121791);
                uids.Add(121810);
                uids.Add(121817);
                uids.Add(121836);
                uids.Add(121842);
                uids.Add(121854);
                uids.Add(121901);
                uids.Add(121908);
                uids.Add(121948);
                uids.Add(121950);
                uids.Add(121952);
                uids.Add(121960);
                uids.Add(121981);
                uids.Add(121997);
                uids.Add(122002);
                uids.Add(122016);
                uids.Add(122027);
                uids.Add(122059);
                uids.Add(122154);
                uids.Add(122165);
                uids.Add(122222);
                uids.Add(122278);
                uids.Add(122294);
                uids.Add(122357);
                uids.Add(122362);
                uids.Add(122390);
                uids.Add(122395);
                uids.Add(122407);
                uids.Add(122433);
                uids.Add(122455);
                uids.Add(122462);
                uids.Add(122469);
                uids.Add(122478);
                uids.Add(122481);
                uids.Add(122516);
                uids.Add(122526);
                uids.Add(122536);
                uids.Add(122549);
                uids.Add(122595);
                uids.Add(122659);
                uids.Add(122701);
                uids.Add(122719);
                uids.Add(122766);
                uids.Add(122827);
                uids.Add(122861);
                uids.Add(122866);
                uids.Add(122868);
                uids.Add(122877);
                uids.Add(122880);
                uids.Add(122926);
                uids.Add(122958);
                uids.Add(122959);
                uids.Add(122969);
                uids.Add(122977);
                uids.Add(122998);
                uids.Add(123004);
                uids.Add(123012);
                uids.Add(123044);
                uids.Add(123068);
                uids.Add(123076);
                uids.Add(123094);
                uids.Add(123152);
                uids.Add(123158);
                uids.Add(123173);
                uids.Add(123193);
                uids.Add(123201);
                uids.Add(123236);
                uids.Add(123253);
                uids.Add(123282);
                uids.Add(123302);
                uids.Add(123313);
                uids.Add(123328);
                uids.Add(123333);
                uids.Add(123334);
                uids.Add(123367);
                uids.Add(123451);
                uids.Add(123455);
                uids.Add(123456);
                uids.Add(123558);
                uids.Add(123563);
                uids.Add(123580);
                uids.Add(123664);
                uids.Add(123684);
                uids.Add(123702);
                uids.Add(123714);
                uids.Add(123724);
                uids.Add(123732);
                uids.Add(123754);
                uids.Add(123769);
                uids.Add(123807);
                uids.Add(123818);
                uids.Add(123853);
                uids.Add(123934);
                uids.Add(123938);
                uids.Add(123956);
                uids.Add(123968);
                uids.Add(123969);
                uids.Add(123991);
                uids.Add(124007);
                uids.Add(124049);
                uids.Add(124062);
                uids.Add(124114);
                uids.Add(124131);
                uids.Add(124146);
                uids.Add(124168);
                uids.Add(124180);
                uids.Add(124232);
                uids.Add(124255);
                uids.Add(124258);
                uids.Add(124287);
                uids.Add(124302);
                uids.Add(124310);
                uids.Add(124348);
                uids.Add(124447);
                uids.Add(124450);
                uids.Add(124455);
                uids.Add(124472);
                uids.Add(124611);
                uids.Add(124636);
                uids.Add(124674);
                uids.Add(124701);
                uids.Add(124726);
                uids.Add(124747);
                uids.Add(124803);
                uids.Add(124804);
                uids.Add(124868);
                uids.Add(124887);
                uids.Add(124889);
                uids.Add(124891);
                uids.Add(124903);
                uids.Add(124954);
                uids.Add(124979);
                uids.Add(124982);
                uids.Add(125001);
                uids.Add(125015);
                uids.Add(125019);
                uids.Add(125039);
                uids.Add(125161);
                uids.Add(125352);
                uids.Add(125434);
                uids.Add(125441);
                uids.Add(125453);
                uids.Add(125454);
                uids.Add(125455);
                uids.Add(125490);
                uids.Add(125516);
                uids.Add(125523);
                uids.Add(125613);
                uids.Add(125629);
                uids.Add(125682);
                uids.Add(125764);
                uids.Add(125801);
                uids.Add(125812);
                uids.Add(125823);
                uids.Add(125844);
                uids.Add(125854);
                uids.Add(125960);
                uids.Add(126144);
                uids.Add(126285);
                uids.Add(126312);
                uids.Add(126410);
                uids.Add(126425);
                uids.Add(126465);
                uids.Add(126474);
                uids.Add(126491);
                uids.Add(126556);
                uids.Add(126596);
                uids.Add(126609);
                uids.Add(126719);
                uids.Add(126730);
                uids.Add(126800);
                uids.Add(126806);
                uids.Add(126810);
                uids.Add(126814);
                uids.Add(126816);
                uids.Add(126820);
                uids.Add(126940);
                uids.Add(126966);
                uids.Add(127029);
                uids.Add(127108);
                uids.Add(127260);
                uids.Add(127429);
                uids.Add(127487);
                uids.Add(128235);
                uids.Add(128423);
                uids.Add(128430);
                uids.Add(128590);
                uids.Add(128743);
                uids.Add(128914);
                uids.Add(128966);
                uids.Add(129103);
                uids.Add(129879);
                uids.Add(130673);
                uids.Add(130731);
                uids.Add(131368);
                uids.Add(131386);
                uids.Add(132112);
                uids.Add(132295);
                uids.Add(132302);
                uids.Add(132418);
                uids.Add(134015);
                uids.Add(134363);
                uids.Add(134888);
                uids.Add(360);
                uids.Add(4064);
                uids.Add(4173);
                uids.Add(4298);
                uids.Add(4467);
                uids.Add(4648);
                uids.Add(5677);
                uids.Add(9845);
                uids.Add(10586);
                uids.Add(10988);
                uids.Add(11353);
                uids.Add(11554);
                uids.Add(11627);
                uids.Add(11628);
                uids.Add(12054);
                uids.Add(12057);
                uids.Add(12061);
                uids.Add(13968);
                uids.Add(14117);
                uids.Add(15946);
                uids.Add(16034);
                uids.Add(16330);
                uids.Add(16641);
                uids.Add(16705);
                uids.Add(17001);
                uids.Add(17471);
                uids.Add(17783);
                uids.Add(18373);
                uids.Add(18394);
                uids.Add(18739);
                uids.Add(19682);
                uids.Add(20153);
                uids.Add(22556);
                uids.Add(22596);
                uids.Add(22705);
                uids.Add(23355);
                uids.Add(23802);
                uids.Add(24160);
                uids.Add(24547);
                uids.Add(25276);
                uids.Add(26302);
                uids.Add(26303);
                uids.Add(29910);
                uids.Add(30029);
                uids.Add(30440);
                uids.Add(30764);
                uids.Add(31090);
                uids.Add(31231);
                uids.Add(31601);
                uids.Add(33509);
                uids.Add(34255);
                uids.Add(34585);
                uids.Add(35314);
                uids.Add(35585);
                uids.Add(37372);
                uids.Add(37934);
                uids.Add(38484);
                uids.Add(40237);
                uids.Add(43131);
                uids.Add(43782);
                uids.Add(45120);
                uids.Add(45345);
                uids.Add(47524);
                uids.Add(47646);
                uids.Add(47843);
                uids.Add(50227);
                uids.Add(52412);
                uids.Add(56852);
                uids.Add(57218);
                uids.Add(58125);
                uids.Add(58162);
                uids.Add(60071);
                uids.Add(60095);
                uids.Add(61151);
                uids.Add(61954);
                uids.Add(62377);
                uids.Add(63707);
                uids.Add(63886);
                uids.Add(65628);
                uids.Add(67058);
                uids.Add(68124);
                uids.Add(69152);
                uids.Add(70493);
                uids.Add(70788);
                uids.Add(72129);
                uids.Add(72425);
                uids.Add(72476);
                uids.Add(72492);
                uids.Add(73352);
                uids.Add(73730);
                uids.Add(73898);
                uids.Add(74209);
                uids.Add(74701);
                uids.Add(76191);
                uids.Add(77363);
                uids.Add(77623);
                uids.Add(78353);
                uids.Add(79156);
                uids.Add(79311);
                uids.Add(79439);
                uids.Add(80363);
                uids.Add(81289);
                uids.Add(81557);
                uids.Add(81633);
                uids.Add(82292);
                uids.Add(83620);
                uids.Add(84456);
                uids.Add(84606);
                uids.Add(84716);
                uids.Add(87819);
                uids.Add(90031);
                uids.Add(90286);
                uids.Add(90416);
                uids.Add(92352);
                uids.Add(92525);
                uids.Add(92835);
                uids.Add(93155);
                uids.Add(94764);
                uids.Add(95743);
                uids.Add(96082);
                uids.Add(96783);
                uids.Add(97507);
                uids.Add(97708);
                uids.Add(98304);
                uids.Add(98343);
                uids.Add(98485);
                uids.Add(98487);
                uids.Add(98729);
                uids.Add(99404);
                uids.Add(99418);
                uids.Add(101490);
                uids.Add(101790);
                uids.Add(103242);
                uids.Add(104704);
                uids.Add(105140);
                uids.Add(107237);
                uids.Add(107238);
                uids.Add(107429);
                uids.Add(108010);
                uids.Add(108078);
                uids.Add(108308);
                uids.Add(108485);
                uids.Add(108623);
                uids.Add(109424);
                uids.Add(109550);
                uids.Add(120566);
                uids.Add(120573);
                uids.Add(120586);
                uids.Add(120636);
                uids.Add(120658);
                uids.Add(120671);
                uids.Add(120688);
                uids.Add(120760);
                uids.Add(120773);
                uids.Add(120805);
                uids.Add(120847);
                uids.Add(120863);
                uids.Add(120910);
                uids.Add(120928);
                uids.Add(120934);
                uids.Add(120944);
                uids.Add(121010);
                uids.Add(121014);
                uids.Add(121137);
                uids.Add(121138);
                uids.Add(121224);
                uids.Add(121308);
                uids.Add(121558);
                uids.Add(121743);
                uids.Add(121850);
                uids.Add(122039);
                uids.Add(122414);
                uids.Add(122473);
                uids.Add(122492);
                uids.Add(122520);
                uids.Add(122527);
                uids.Add(122535);
                uids.Add(122571);
                uids.Add(122572);
                uids.Add(122716);
                uids.Add(122775);
                uids.Add(123014);
                uids.Add(123032);
                uids.Add(123284);
                uids.Add(123306);
                uids.Add(123535);
                uids.Add(123551);
                uids.Add(123564);
                uids.Add(123642);
                uids.Add(123653);
                uids.Add(123660);
                uids.Add(123672);
                uids.Add(123673);
                uids.Add(123677);
                uids.Add(123848);
                uids.Add(123858);
                uids.Add(123953);
                uids.Add(123994);
                uids.Add(124015);
                uids.Add(124029);
                uids.Add(124178);
                uids.Add(124183);
                uids.Add(124352);
                uids.Add(124353);
                uids.Add(124406);
                uids.Add(124497);
                uids.Add(124543);
                uids.Add(124553);
                uids.Add(124560);
                uids.Add(124561);
                uids.Add(124639);
                uids.Add(124661);
                uids.Add(124662);
                uids.Add(124681);
                uids.Add(124696);
                uids.Add(124739);
                uids.Add(124763);
                uids.Add(124842);
                uids.Add(124847);
                uids.Add(124849);
                uids.Add(125016);
                uids.Add(125032);
                uids.Add(125057);
                uids.Add(125145);
                uids.Add(125211);
                uids.Add(125242);
                uids.Add(125284);
                uids.Add(125292);
                uids.Add(125297);
                uids.Add(125350);
                uids.Add(125393);
                uids.Add(125428);
                uids.Add(125522);
                uids.Add(125673);
                uids.Add(125684);
                uids.Add(125685);
                uids.Add(125697);
                uids.Add(125708);
                uids.Add(125729);
                uids.Add(125766);
                uids.Add(125841);
                uids.Add(125864);
                uids.Add(125971);
                uids.Add(126026);
                uids.Add(126079);
                uids.Add(126108);
                uids.Add(126147);
                uids.Add(126193);
                uids.Add(126222);
                uids.Add(126233);
                uids.Add(126320);
                uids.Add(126325);
                uids.Add(126380);
                uids.Add(126489);
                uids.Add(126663);
                uids.Add(126683);
                uids.Add(126859);
                uids.Add(126881);
                uids.Add(127065);
                uids.Add(127408);
                uids.Add(127807);
                uids.Add(127853);
                uids.Add(127904);
                uids.Add(127939);
                uids.Add(128162);
                uids.Add(128585);
                uids.Add(128641);
                uids.Add(128812);
                uids.Add(128868);
                uids.Add(128870);
                uids.Add(129566);
                uids.Add(129596);
                uids.Add(129618);
                uids.Add(130939);
                uids.Add(131249);
                uids.Add(131770);
                uids.Add(132028);
                uids.Add(132466);
                uids.Add(135370);
                uids.Add(363);
                uids.Add(4595);
                uids.Add(4716);
                uids.Add(7016);
                uids.Add(7249);
                uids.Add(10321);
                uids.Add(10677);
                uids.Add(13129);
                uids.Add(14264);
                uids.Add(14272);
                uids.Add(14678);
                uids.Add(14706);
                uids.Add(14716);
                uids.Add(15124);
                uids.Add(15200);
                uids.Add(15335);
                uids.Add(16506);
                uids.Add(17210);
                uids.Add(17218);
                uids.Add(19381);
                uids.Add(20078);
                uids.Add(20133);
                uids.Add(20193);
                uids.Add(21034);
                uids.Add(21569);
                uids.Add(21979);
                uids.Add(22252);
                uids.Add(22660);
                uids.Add(22793);
                uids.Add(22797);
                uids.Add(23387);
                uids.Add(23978);
                uids.Add(24513);
                uids.Add(24592);
                uids.Add(25207);
                uids.Add(25231);
                uids.Add(25326);
                uids.Add(26165);
                uids.Add(26632);
                uids.Add(27412);
                uids.Add(27630);
                uids.Add(28997);
                uids.Add(29973);
                uids.Add(30708);
                uids.Add(31246);
                uids.Add(34474);
                uids.Add(35794);
                uids.Add(36176);
                uids.Add(36887);
                uids.Add(37752);
                uids.Add(39326);
                uids.Add(39329);
                uids.Add(39573);
                uids.Add(41128);
                uids.Add(41462);
                uids.Add(44066);
                uids.Add(44140);
                uids.Add(44153);
                uids.Add(44664);
                uids.Add(44684);
                uids.Add(44932);
                uids.Add(45545);
                uids.Add(46160);
                uids.Add(46397);
                uids.Add(46964);
                uids.Add(48252);
                uids.Add(49717);
                uids.Add(50145);
                uids.Add(50408);
                uids.Add(52495);
                uids.Add(54346);
                uids.Add(55824);
                uids.Add(55899);
                uids.Add(56196);
                uids.Add(56381);
                uids.Add(57505);
                uids.Add(58092);
                uids.Add(60633);
                uids.Add(61043);
                uids.Add(63331);
                uids.Add(64381);
                uids.Add(65080);
                uids.Add(65523);
                uids.Add(66667);
                uids.Add(69088);
                uids.Add(69559);
                uids.Add(70556);
                uids.Add(70771);
                uids.Add(71739);
                uids.Add(72027);
                uids.Add(72473);
                uids.Add(72564);
                uids.Add(72733);
                uids.Add(74498);
                uids.Add(74504);
                uids.Add(75236);
                uids.Add(75390);
                uids.Add(76061);
                uids.Add(76855);
                uids.Add(77256);
                uids.Add(77263);
                uids.Add(79066);
                uids.Add(79090);
                uids.Add(82185);
                uids.Add(82275);
                uids.Add(82806);
                uids.Add(83464);
                uids.Add(83549);
                uids.Add(83550);
                uids.Add(84152);
                uids.Add(85258);
                uids.Add(87252);
                uids.Add(88278);
                uids.Add(88991);
                uids.Add(89089);
                uids.Add(89167);
                uids.Add(91329);
                uids.Add(92453);
                uids.Add(93296);
                uids.Add(94180);
                uids.Add(94249);
                uids.Add(95741);
                uids.Add(95966);
                uids.Add(96534);
                uids.Add(97116);
                uids.Add(97930);
                uids.Add(98252);
                uids.Add(98621);
                uids.Add(98694);
                uids.Add(99291);
                uids.Add(99596);
                uids.Add(100273);
                uids.Add(100727);
                uids.Add(101397);
                uids.Add(101551);
                uids.Add(104321);
                uids.Add(105035);
                uids.Add(105569);
                uids.Add(106336);
                uids.Add(106494);
                uids.Add(106642);
                uids.Add(106935);
                uids.Add(107146);
                uids.Add(108862);
                uids.Add(109272);
                uids.Add(109628);
                uids.Add(109638);
                uids.Add(120621);
                uids.Add(120628);
                uids.Add(120803);
                uids.Add(122057);
                uids.Add(122060);
                uids.Add(122063);
                uids.Add(122070);
                uids.Add(122074);
                uids.Add(122126);
                uids.Add(122239);
                uids.Add(122308);
                uids.Add(122470);
                uids.Add(122477);
                uids.Add(122579);
                uids.Add(122602);
                uids.Add(122630);
                uids.Add(122933);
                uids.Add(123072);
                uids.Add(123143);
                uids.Add(123344);
                uids.Add(123873);
                uids.Add(123885);
                uids.Add(123908);
                uids.Add(124110);
                uids.Add(124210);
                uids.Add(124431);
                uids.Add(124458);
                uids.Add(124557);
                uids.Add(124569);
                uids.Add(124848);
                uids.Add(125128);
                uids.Add(125217);
                uids.Add(125334);
                uids.Add(125356);
                uids.Add(125359);
                uids.Add(125394);
                uids.Add(125415);
                uids.Add(125422);
                uids.Add(125452);
                uids.Add(125478);
                uids.Add(125487);
                uids.Add(125504);
                uids.Add(125541);
                uids.Add(125609);
                uids.Add(125642);
                uids.Add(125727);
                uids.Add(125825);
                foreach (int uid in uids)
                {
                    Users user = db.Users.FirstOrDefault(m => m.Id == uid);
                    if (user != null)
                    {
                        int BeforeLevel = user.UserLevel;
                        int AfterLevel = 0;
                        decimal TradeAmount = 0;
                        bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
                        if (check)
                        {
                            TradeAmount = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
                        }
                        function.WriteLog(user.Id.ToString() + "----" + TradeAmount, "创客升级业绩");
                        UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
                        if (set != null)
                        {
                            AfterLevel = set.Id;
                        }
                        function.WriteLog("update Users set UserLevel=" + AfterLevel + " where Id=" + user.Id.ToString() + ";", "创客升级日志");
                    }
                }
                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
            }
            catch (Exception ex)
            {
                function.WriteLog(ex.ToString(), "创客升级异常");
            }
            db.Dispose();
        }


        // 统计创客激活数
        public void StartPosActNum()
        {
            Thread th = new Thread(StartPosActNumFor);
            th.IsBackground = true;
            th.Start();
        }
        public void StartPosActNumFor()
        {
            // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
            // DateTime check = DateTime.Parse("2022-06-14");
            // while (check <= end)
            // {
            //     StartPosActNumDo(check.ToString("yyyy-MM-dd"));
            //     check = check.AddDays(1);
            // }
            while (true)
            {
                if(DateTime.Now.Hour >= 2)
                {
                    StartPosActNumEverTime();
                }
                Thread.Sleep(100);
            }
        }
        public void StartPosActNumDo(object sender)
        {
            string date = sender.ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                string TradeDate = date.Replace("-", "");
                string TradeMonth = TradeDate.Substring(0, 6);
                string start = date + " 00:00:00";
                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                List<string> uids = new List<string>();
                DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT BuyUserId from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "')");
                function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志");
                foreach (DataRow userDr in userDt.Rows)
                {
                    int UserId = int.Parse(userDr["Id"].ToString());
                    string ParentNav = userDr["ParentNav"].ToString();
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
                    DataTable selfdt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId=" + UserId + " group by BrandId");
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
                    foreach (DataRow selfDr in selfdt.Rows)
                    {
                        int BrandId = int.Parse(selfDr["BrandId"].ToString());
                        int QrPayFlag = 0;
                        int ActCount = int.Parse(selfDr[1].ToString());
                        UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
                        if (selfStat == null)
                        {
                            selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                            {
                                UserId = UserId,
                                TradeMonth = TradeMonth,
                                TradeDate = TradeDate,
                                BrandId = BrandId,
                                QueryCount = QrPayFlag,
                                SeoTitle = "self",
                            }).Entity;
                            db.SaveChanges();
                        }
                        selfStat.DirectDebitCapNum += ActCount;
                        db.SaveChanges();
                    }
                    if (!string.IsNullOrEmpty(ParentNav))
                    {
                        ParentNav += "," + UserId + ",";
                        string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                        foreach (string NavUserIdString in ParentNavList)
                        {
                            if (!uids.Contains(NavUserIdString + start))
                            {
                                uids.Add(NavUserIdString + start);
                                int NavUserId = int.Parse(NavUserIdString);
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
                                DataTable teamDt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId");
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
                                foreach (DataRow teamDr in teamDt.Rows)
                                {
                                    int BrandId = int.Parse(teamDr["BrandId"].ToString());
                                    int QrPayFlag = 0;
                                    int ActCount = int.Parse(teamDr[1].ToString());
                                    UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                                        {
                                            UserId = NavUserId,
                                            TradeMonth = TradeMonth,
                                            TradeDate = TradeDate,
                                            BrandId = BrandId,
                                            QueryCount = QrPayFlag,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.NonDirectDebitCapNum += ActCount;
                                    db.SaveChanges();
                                }
                            }
                        }
                    }
                }
                OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "'");
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
            Thread.Sleep(60000);
        }
        public void StartPosActNumEverTime()
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and BuyUserId>0 limit 50");
                if(idsDt.Rows.Count > 0)
                {
                    string ids = "";
                    foreach (DataRow idsDr in idsDt.Rows)
                    {
                        ids += idsDr["Id"].ToString() + ",";
                    }
                    DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')");
                    if (userDt.Rows.Count > 0)
                    {
                        function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
                        foreach (DataRow userDr in userDt.Rows)
                        {
                            int UserId = int.Parse(userDr["BuyUserId"].ToString());
                            int BrandId = int.Parse(userDr["BrandId"].ToString());
                            string TradeDate = userDr[2].ToString();
                            int ActCount = int.Parse(function.CheckInt(userDr[3].ToString()));
                            int QrPayFlag = 0;
                            string TradeMonth = TradeDate.Substring(0, 6);
                            string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
                            string start = date + " 00:00:00";
                            string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                            Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                            string ParentNav = user.ParentNav;
                            UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
                            if (selfStat == null)
                            {
                                selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                                {
                                    UserId = UserId,
                                    TradeMonth = TradeMonth,
                                    TradeDate = TradeDate,
                                    BrandId = BrandId,
                                    QueryCount = QrPayFlag,
                                    SeoTitle = "self",
                                }).Entity;
                                db.SaveChanges();
                            }
                            selfStat.DirectDebitCapNum += ActCount;
                            ParentNav += "," + UserId + ",";
                            if (!string.IsNullOrEmpty(ParentNav))
                            {
                                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                foreach (string NavUserIdString in ParentNavList)
                                {
                                    int NavUserId = int.Parse(NavUserIdString);
                                    UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
                                        {
                                            UserId = NavUserId,
                                            TradeMonth = TradeMonth,
                                            TradeDate = TradeDate,
                                            BrandId = BrandId,
                                            QueryCount = QrPayFlag,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.NonDirectDebitCapNum += ActCount;
                                }
                            }
                        }
                        db.SaveChanges();
                        OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                    }
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志");
        }

        // 统计新增创客数
        public void StartNewUserNum()
        {
            Thread th = new Thread(StartNewUserNumFor);
            th.IsBackground = true;
            th.Start();
        }
        public void StartNewUserNumFor()
        {
            // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
            // DateTime check = DateTime.Parse("2022-06-14");
            // while (check <= end)
            // {
            //     StartNewUserNumDo(check.ToString("yyyy-MM-dd"));
            //     check = check.AddDays(1);
            // }
            while (true)
            {
                if(DateTime.Now.Hour >= 2)
                {
                    StartNewUserNumEverTime();
                }
                Thread.Sleep(120000);
            }
        }
        public void StartNewUserNumDo(object sender)
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            string date = sender.ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                string StatDate = date.Replace("-", "");
                string StatMonth = StatDate.Substring(0, 6);
                string start = date + " 00:00:00";
                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                List<string> uids = new List<string>();
                DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
                function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志");
                foreach (DataRow userDr in userDt.Rows)
                {
                    int UserId = int.Parse(userDr["Id"].ToString());
                    string ParentNav = userDr["ParentNav"].ToString();
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
                    DataTable selfdt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentUserId=" + UserId + "");
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
                    foreach (DataRow selfDr in selfdt.Rows)
                    {
                        int AddCount = int.Parse(selfDr[0].ToString());
                        PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
                        if (selfStat == null)
                        {
                            selfStat = db.PullnewSummary.Add(new PullnewSummary()
                            {
                                UserId = UserId,
                                StatMonth = StatMonth,
                                StatDate = StatDate,
                                SeoTitle = "self",
                            }).Entity;
                            db.SaveChanges();
                        }
                        selfStat.RecUserAuthNum += AddCount;
                        db.SaveChanges();
                    }
                    if (!string.IsNullOrEmpty(ParentNav))
                    {
                        ParentNav += "," + UserId + ",";
                        string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                        foreach (string NavUserIdString in ParentNavList)
                        {
                            if (!uids.Contains(NavUserIdString + start))
                            {
                                uids.Add(NavUserIdString + start);
                                int NavUserId = int.Parse(NavUserIdString);
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
                                DataTable teamDt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentNav like '%," + NavUserId + ",%'");
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
                                foreach (DataRow teamDr in teamDt.Rows)
                                {
                                    int AddCount = int.Parse(teamDr[0].ToString());
                                    PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.PullnewSummary.Add(new PullnewSummary()
                                        {
                                            UserId = NavUserId,
                                            StatMonth = StatMonth,
                                            StatDate = StatDate,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.RecUserAuthNum += AddCount;
                                    db.SaveChanges();
                                }
                            }
                        }
                    }
                }
                OtherMySqlConn.op("update Users set QueryCount=1 where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
            Thread.Sleep(60000);
        }
        public void StartNewUserNumEverTime()
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                DataTable idsDt = OtherMySqlConn.dtable("select Id from Users where QueryCount=0 and AuthFlag=1 and AuthDate is not null limit 50");
                if(idsDt.Rows.Count > 0)
                {
                    string ids = "";
                    foreach (DataRow idsDr in idsDt.Rows)
                    {
                        ids += idsDr["Id"].ToString() + ",";
                    }
                    DataTable userDt = OtherMySqlConn.dtable("select ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d'),count(Id) from Users where Id in (" + ids.TrimEnd(',') + ") group by ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d')");
                    if(userDt.Rows.Count > 0)
                    {
                        function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志");
                        foreach (DataRow userDr in userDt.Rows)
                        {
                            string StatDate = userDr[1].ToString();
                            int UserId = int.Parse(userDr["ParentUserId"].ToString());
                            string StatMonth = StatDate.Substring(0, 6);
                            string date = StatDate.Substring(0, 4) + "-" + StatDate.Substring(4, 2) + "-" + StatDate.Substring(6, 2);
                            string start = date + " 00:00:00";
                            string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                            int AddCount = int.Parse(userDr[2].ToString());
                            Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                            string ParentNav = user.ParentNav;
                            PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
                            if (selfStat == null)
                            {
                                selfStat = db.PullnewSummary.Add(new PullnewSummary()
                                {
                                    UserId = UserId,
                                    StatMonth = StatMonth,
                                    StatDate = StatDate,
                                    SeoTitle = "self",
                                }).Entity;
                                db.SaveChanges();
                            }
                            selfStat.RecUserAuthNum += AddCount;
                            ParentNav += "," + UserId + ",";
                            if (!string.IsNullOrEmpty(ParentNav))
                            {
                                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                foreach (string NavUserIdString in ParentNavList)
                                {
                                    int NavUserId = int.Parse(NavUserIdString);                            
                                    PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.PullnewSummary.Add(new PullnewSummary()
                                        {
                                            UserId = NavUserId,
                                            StatMonth = StatMonth,
                                            StatDate = StatDate,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.RecUserAuthNum += AddCount;
                                }
                            }
                        }
                        db.SaveChanges();
                        OtherMySqlConn.op("update Users set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                    }
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志");
        }



        // 每天统计头一天的收益
        public void StatProfit()
        {
            Thread th = new Thread(StatProfitDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatProfitDo()
        {
            // DateTime end = DateTime.Parse("2022-06-16 00:00:00");
            // DateTime check = DateTime.Parse("2022-06-16");
            // while (check <= end)
            // {
            //     StatProfitEverDay(check.ToString("yyyy-MM-dd"));
            //     Thread.Sleep(1000);
            //     check = check.AddDays(1);
            // }
            while (true)
            {
                if(DateTime.Now.Hour >= 2)
                {
                    StatProfitEverDayEverTime();
                }
                Thread.Sleep(120000);
            }
        }
        public void StatProfitEverDay(object sender)
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            string date = sender.ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                string TradeDate = date.Replace("-", "");
                string TradeMonth = TradeDate.Substring(0, 6);
                string start = date + " 00:00:00";
                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                string startId = "0";
                List<string> uids = new List<string>();
                DataTable startDt = OtherMySqlConn.dtable("select min(Id) from UserAccountRecord where CreateDate>='" + start + "'");
                if (startDt.Rows.Count > 0)
                {
                    startId = startDt.Rows[0][0].ToString();
                }
                function.WriteLog(startId + "\n\n", "执行昨天收益日志");
                DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
                function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志");
                foreach (DataRow userDr in userDt.Rows)
                {
                    int UserId = int.Parse(userDr["Id"].ToString());
                    string ParentNav = userDr["ParentNav"].ToString();
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
                    DataTable selfdt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by ChangeType,ProductType");
                    function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
                    foreach (DataRow selfDr in selfdt.Rows)
                    {
                        int ChangeType = int.Parse(selfDr["ChangeType"].ToString());
                        int ProductType = int.Parse(selfDr["ProductType"].ToString());
                        decimal ProfitAmount = decimal.Parse(selfDr[2].ToString());
                        UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
                        if (selfStat == null)
                        {
                            selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
                            {
                                UserId = UserId,
                                TradeMonth = TradeMonth,
                                TradeDate = TradeDate,
                                RebateType = ChangeType,
                                ProductType = ProductType,
                                SeoTitle = "self",
                            }).Entity;
                            db.SaveChanges();
                        }
                        selfStat.CreditRewardAmount += ProfitAmount;
                        db.SaveChanges();
                    }
                    if (!string.IsNullOrEmpty(ParentNav))
                    {
                        ParentNav += "," + UserId + ",";
                        string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                        foreach (string NavUserIdString in ParentNavList)
                        {
                            if (!uids.Contains(NavUserIdString + start))
                            {
                                uids.Add(NavUserIdString + start);
                                int NavUserId = int.Parse(NavUserIdString);
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
                                DataTable teamDt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by ChangeType,ProductType");
                                function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
                                foreach (DataRow teamDr in teamDt.Rows)
                                {
                                    int ChangeType = int.Parse(teamDr["ChangeType"].ToString());
                                    int ProductType = int.Parse(teamDr["ProductType"].ToString());
                                    decimal ProfitAmount = decimal.Parse(teamDr[2].ToString());
                                    UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
                                        {
                                            UserId = NavUserId,
                                            TradeMonth = TradeMonth,
                                            TradeDate = TradeDate,
                                            RebateType = ChangeType,
                                            ProductType = ProductType,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.CreditRewardAmount += ProfitAmount;
                                    db.SaveChanges();
                                }
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
        }

        public void StatProfitEverDayEverTime()
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
            WebCMSEntities db = new WebCMSEntities();
            try
            {
                string startId = function.ReadInstance("/UserAccountRecord/Id.txt");
                if(string.IsNullOrEmpty(startId))
                {
                    startId = "160653";
                }
                DataTable idsDt = OtherMySqlConn.dtable("select Id from UserAccountRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
                if(idsDt.Rows.Count > 0)
                {
                    string ids = "";
                    foreach (DataRow idsDr in idsDt.Rows)
                    {
                        ids += idsDr["Id"].ToString() + ",";
                        startId = idsDr["Id"].ToString();
                    }
                    DataTable userDt = OtherMySqlConn.dtable("select UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d'),sum(ChangeAmount)  from UserAccountRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d')");
                    if (userDt.Rows.Count > 0)
                    {
                        function.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志");
                        foreach (DataRow userDr in userDt.Rows)
                        {
                            int UserId = int.Parse(userDr["UserId"].ToString());
                            int ChangeType = int.Parse(userDr["ChangeType"].ToString());
                            int ProductType = int.Parse(userDr["ProductType"].ToString());
                            string TradeDate = userDr[3].ToString();
                            decimal ProfitAmount = decimal.Parse(userDr[4].ToString());
                            string TradeMonth = TradeDate.Substring(0, 6);
                            string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
                            string start = date + " 00:00:00";
                            string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
                            Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                            string ParentNav = user.ParentNav;
                            UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
                            if (selfStat == null)
                            {
                                selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
                                {
                                    UserId = UserId,
                                    TradeMonth = TradeMonth,
                                    TradeDate = TradeDate,
                                    RebateType = ChangeType,
                                    ProductType = ProductType,
                                    SeoTitle = "self",
                                }).Entity;
                                db.SaveChanges();
                            }
                            selfStat.CreditRewardAmount += ProfitAmount;
                            ParentNav += "," + UserId + ",";
                            if (!string.IsNullOrEmpty(ParentNav))
                            {
                                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                foreach (string NavUserIdString in ParentNavList)
                                {
                                    int NavUserId = int.Parse(NavUserIdString);
                                    UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
                                    if (teamStat == null)
                                    {
                                        teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
                                        {
                                            UserId = NavUserId,
                                            TradeMonth = TradeMonth,
                                            TradeDate = TradeDate,
                                            RebateType = ChangeType,
                                            ProductType = ProductType,
                                            SeoTitle = "team",
                                        }).Entity;
                                        db.SaveChanges();
                                    }
                                    teamStat.CreditRewardAmount += ProfitAmount;
                                }
                            }
                        }
                        db.SaveChanges();
                        OtherMySqlConn.op("update UserAccountRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                        function.WritePage("/UserAccountRecord/", "Id.txt", startId);
                    }
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常");
            }
            db.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志");
        }





        // 实时统计我的创客交易额
        public void StatMyUserThisTrade()
        {
            Thread th = new Thread(StatMyUserThisTradeDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatMyUserThisTradeDo()
        {
            while (true)
            {
                if(DateTime.Now.Hour > 3)
                {
                    StatMyUserThisTradeListen();
                }
                int timespan = 1000 * 3600 * 3;
                Thread.Sleep(timespan);
            }
        }
        public void StatMyUserThisTradeListen()
        {
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
            string TradeMonth = DateTime.Now.ToString("yyyyMM");
            // if(DateTime.Now.Day == 1)
            // {
            //     TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            // }
            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
            string sql = "";
            foreach (DataRow dr in list.Rows)
            {
                string UserId = dr["UserId"].ToString();
                string ThisMonthTrade = dr[1].ToString();
                sql += "update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId + ";";
            }
            if(!string.IsNullOrEmpty(sql))
            {
                OtherMySqlConn.op(sql);
            }
        }




        #region 判断品牌互斥条件，根据身份证号

        public bool CheckRepeatByBrand(WebCMSEntities db, int MerchantId)
        {
            int check = db.PosMachinesTwo.Count(m => m.Status > -1 && m.BindMerchantId == MerchantId);

            return false;
        }

        #endregion

    }
}