kxs-main/AppStart/Helper/StatService.cs

using System;
using System.Collections.Generic;
using Library;
using LitJson;
using System.Linq;
using System.Data;
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
            {
                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);
                    dosomething4(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();
                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 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];
                    }
                }
                PxcModels.Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0 && m.CreateDate >= yesterday && m.CreateDate < today);
                if (user != null)
                {
                    user.MerchantType = 1;
                    PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PxcModels.PosMerchantInfo();
                    merchant.MerUserType = 1;
                    PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.BindMerchantId == merchant.Id);
                    if (pos != null)
                    {
                        pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
                    }
                    db.SaveChanges();
                    RedisDbconn.Instance.Set("Users:" + user.Id, user);
                    RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
                    RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
                }
            }
            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);
                if (machineCount >= 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();
        }

        // 2. 每天统计前一天的交易额，每笔交易判断商户号的所属人是商户型创客，如果是，则从此人开始累计交易额，若不是，则从此人上级开始累计交易额 
        public void dosomething2(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("TradeStatQueue", content);    
                // RedisDbconn.Instance.AddList("TradeStatQueue2", content);
            }
        }

        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.AddHours(-3);
            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);
                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.UserId);
                    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)
                        {
                            ActPrize = ActPrize / 100;
                        }
                        if (ActPrize > 0)
                        {
                            bool check = db.ActiveReward.Any(m => m.KqMerNo == merchant.KqMerNo);
                            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.UserId) ?? 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);
                                RedisDbconn.Instance.Clear("UserAccount:Income:" + GetUserId + ":" + monthString);
                            }
                        }
                    }
                    // }
                }
            }
            db.Dispose();
        }


        //根据商户信息发放激活奖励
        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.UserId);
                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)
                    {
                        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.UserId) ?? 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.ActivationTime > DateTime.Now.AddDays(-20))
                {
                    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);
                        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.UserId);
                                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); //判断是否拥有3台购买机
                                                int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1); //判断是否拥有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 >= 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.UserId) ?? 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.UserId);
                        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); //判断是否拥有3台购买机
                                        int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1); //判断是否拥有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 >= 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.UserId) ?? 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();
        }
    }
}