mp-main/AppStart/Timer/RedPackageV2Helper.cs

using System;
using System.Collections.Generic;
using System.Threading;
using System.Linq;
using System.Data;
using MySystem;
using MySystem.Models;
using Library;

public class RedPackageV2Helper
{
    public readonly static RedPackageV2Helper Instance = new RedPackageV2Helper();
    private RedPackageV2Helper()
    {
    }

    public void Start()
    {
        Thread th = new Thread(DoWorks);
        th.IsBackground = true;
        th.Start();
    }

    private void DoWorks()
    {
        while (true)
        {
            if (DateTime.Now.Hour >= 3)
            {
                string ActivityDate = DateTime.Now.AddDays(-1).ToString("yyyyMMdd");
                string check = function.ReadInstance("/Activity/RedPackage/" + ActivityDate + ".txt");
                if (string.IsNullOrEmpty(check))
                {
                    function.WritePage("/Activity/RedPackage/", ActivityDate + ".txt", DateTime.Now.ToString());
                    LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "生成指定未领取红包日志");
                    WebCMSEntities db = new WebCMSEntities();
                    try
                    {
                        // decimal TotalPrize = 888.88M;
                        // DateTime start = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 07:50:00");
                        // DateTime today = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00");
                        // string PreDate = DateTime.Now.AddDays(-2).ToString("yyyyMMdd");
                        List<decimal> list = new List<decimal>();
                        list.Add(88.88M);
                        list.Add(40.76M);
                        list.Add(38.88M);
                        list.Add(18.88M);
                        list.Add(15.88M);
                        list.Add(11.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(8.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(5.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(3.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        list.Add(1.88M);
                        // TotalPrize -= 88.88M;
                        // for (int i = 1; i < 150; i++)
                        // {
                        //     list.Add(0.88M);
                        //     TotalPrize -= 0.88M;
                        // }
                        // for (int i = 0; i < 150; i++)
                        // {
                        //     if (TotalPrize > 0)
                        //     {
                        //         int BigPrize = function.get_Random(1, 150);
                        //         decimal PrizeAmt = (decimal)function.get_Random(88, 1000) / 100M;
                        //         if (TotalPrize > PrizeAmt)
                        //         {
                        //             list[BigPrize] += PrizeAmt;
                        //             TotalPrize -= PrizeAmt;
                        //         }
                        //         else
                        //         {
                        //             list[BigPrize] += TotalPrize;
                        //             TotalPrize = 0;
                        //         }
                        //     }
                        //     else
                        //     {
                        //         break;
                        //     }
                        // }
                        foreach (decimal PrizeAmt in list)
                        {
                            db.ActivityRedPackageStock.Add(new ActivityRedPackageStock()
                            {
                                CreateDate = DateTime.Now,
                                PrizeAmt = PrizeAmt,
                                ActivityDate = ActivityDate,
                                SeoTitle = function.get_Random(20),
                            });
                        }
                        db.SaveChanges();
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "生成指定未领取红包异常");
                    }
                    db.Dispose();
                    LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "生成指定未领取红包日志");
                }
                redisStock();
            }
            Thread.Sleep(60000);
        }
    }

    // 将红包加入缓存
    public void redisStock()
    {
        string ActivityDate = DateTime.Now.AddDays(-1).ToString("yyyyMMdd");
        string check = function.ReadInstance("/Activity/RedPackageRedis/" + ActivityDate + ".txt");
        if (!string.IsNullOrEmpty(check))
        {
            return;
        }
        function.WritePage("/Activity/RedPackageRedis/", ActivityDate + ".txt", DateTime.Now.ToString());
        WebCMSEntities db = new WebCMSEntities();
        List<ActivityRedPackageStock> list = db.ActivityRedPackageStock.Where(m => m.ActivityDate == ActivityDate && m.PrizeAmt != 88.88M).OrderBy(m => m.SeoTitle).ToList();
        int i = 0;
        foreach(ActivityRedPackageStock sub in list)
        {
            i += 1;
            if(i == 18)
            {
                ActivityRedPackageStock best = db.ActivityRedPackageStock.FirstOrDefault(m => m.ActivityDate == ActivityDate && m.PrizeAmt == 88.88M);
                if(best != null)
                {
                    RedisDbconn.Instance.AddList("RedPackageList:" + ActivityDate, best);
                }
            }
            RedisDbconn.Instance.AddList("RedPackageList:" + ActivityDate, sub);
        }

        string PreDate = DateTime.Now.AddDays(-2).ToString("yyyyMMdd");
        string PreMakerCode = "";
        string PreRealName = "";
        decimal PrePrizeAmt = 0;
        bool checkPre = db.ActivityRedPackageStock.Any(m => m.ActivityDate == PreDate);
        if (checkPre)
        {
            ActivityRedPackageStock preInfo = db.ActivityRedPackageStock.Where(m => m.ActivityDate == PreDate).OrderByDescending(m => m.PrizeAmt).FirstOrDefault();
            if (preInfo != null)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == preInfo.UserId) ?? new Users();
                PreMakerCode = user.MakerCode;
                PreRealName = user.RealName;
                PrePrizeAmt = preInfo.PrizeAmt;
                RedisDbconn.Instance.Set("PreInfoString:" + PreDate, PreMakerCode + "|" + PreRealName + "|" + PrePrizeAmt);
                RedisDbconn.Instance.SetExpire("PreInfoString:" + PreDate, 7200);
            }
        }
        db.Dispose();
    }





    public void StartStatTop10()
    {
        Thread th = new Thread(StartStatTop10Do);
        th.IsBackground = true;
        th.Start();
    }

    private void StartStatTop10Do()
    {
        while (true)
        {
            if(DateTime.Now.Hour >= 7 && DateTime.Now.Hour <= 10)
            {
                OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
                OtherMySqlConn.op("delete from ActivityRedPackageTop10");
                using (WebCMSEntities db = new WebCMSEntities())
                {
                    DataTable dt = OtherMySqlConn.dtable("select UserId,sum(PrizeAmt) from ActivityRedPackageJoins group by UserId order by sum(PrizeAmt) desc");
                    int index = 0;
                    foreach (DataRow dr in dt.Rows)
                    {
                        index += 1;
                        int UserId = int.Parse(dr["UserId"].ToString());
                        decimal PrizeAmt = decimal.Parse(dr[1].ToString());
                        db.ActivityRedPackageTop10.Add(new ActivityRedPackageTop10()
                        {
                            Sort = index,
                            UserId = UserId,
                            PrizeAmt = PrizeAmt,
                            Kind = 1,
                        });
                    }
                    dt = OtherMySqlConn.dtable("select UserId,count(Id) from ActivityRedPackageJoins group by UserId order by count(Id) desc");
                    index = 0;
                    foreach (DataRow dr in dt.Rows)
                    {
                        index += 1;
                        int UserId = int.Parse(dr["UserId"].ToString());
                        int PrizeCount = int.Parse(dr[1].ToString());
                        db.ActivityRedPackageTop10.Add(new ActivityRedPackageTop10()
                        {
                            Sort = index,
                            UserId = UserId,
                            TimeNum = PrizeCount,
                            Kind = 2,
                        });
                    }
                    db.SaveChanges();
                }
            }
            Thread.Sleep(300000);
        }
    }


    public void StartSendPrize()
    {
        Thread th = new Thread(StartSendPrizeNewDo);
        th.IsBackground = true;
        th.Start();
    }

    private void StartSendPrizeNewDo()
    {
        while (true)
        {
            string content = RedisDbconn.Instance.RPop<string>("RedPrizeQueue");
            if (!string.IsNullOrEmpty(content))
            {
                try
                {
                    string[] data = content.Split(':');
                    int Id = int.Parse(function.CheckInt(data[0]));
                    int UserId = int.Parse(function.CheckInt(data[1]));
                    string ActivityDate = data[2];
                    using (WebCMSEntities db = new WebCMSEntities())
                    {
                        ActivityRedPackageStock edit = db.ActivityRedPackageStock.FirstOrDefault(m => m.Id == Id);
                        if(edit != null)
                        {
                            edit.UserId = UserId;
                            edit.UpdateDate = DateTime.Now;
                            ActivityRedPackageJoins query = db.ActivityRedPackageJoins.Add(new ActivityRedPackageJoins()
                            {
                                CreateDate = DateTime.Now, //创建时间
                                Status = 1,
                                UserId = UserId, //创客
                                ActivityDate = ActivityDate, //期数
                                PrizeAmt = edit.PrizeAmt,
                            }).Entity;
                            db.SaveChanges();
                            StartGetAccount(db, UserId, query.Id, edit.PrizeAmt);
                        }
                    }
                }
                catch (Exception ex)
                {
                    LogHelper.Instance.WriteLog(ex.ToString(), "发放红包奖励异常");
                }
                Thread.Sleep(200);
            }
            else
            {
                Thread.Sleep(500);
            }
        }
    }
    
    private void StartGetAccount(WebCMSEntities db, int UserId, int Id, decimal PrizeAmt)
    {
        try
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
            account.BalanceAmount += PrizeAmt;
            account.TotalAmount += PrizeAmt;
            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 = UserId, //创客
                ChangeType = 31, //变动类型
                ChangeAmount = PrizeAmt, //变更金额
                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                QueryCount = Id,
                Remark = "开机抢红包活动",
            }).Entity;
            db.SaveChanges();
        }
        catch (Exception ex)
        {
            LogHelper.Instance.WriteLog(ex.ToString(), "领取红包奖励异常");
        }
    }    
}