mp-ap/Areas/Api/Controllers/v1/Activity/ActivityRedPackageJoinsController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Microsoft.AspNetCore.Authorization;
using System.Web;
using MySystem.MainModels;
using LitJson;
using Library;

namespace MySystem.Areas.Api.Controllers.v1
{
    [Area("Api")]
    [Route("Api/v1/[controller]/[action]")]
    public class ActivityRedPackageJoinsController : BaseController
    {
        public ActivityRedPackageJoinsController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
        {
        }




        #region 创客-红包活动-参与记录
        [Authorize]
        public JsonResult List(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            List<Dictionary<string, object>> dataList = ListDo(value);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList });
        }
        public List<Dictionary<string, object>> ListDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString()));
            int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString()));
            List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();
            IQueryable<ActivityRedPackageJoins> query = maindb.ActivityRedPackageJoins.Where(m => m.UserId == UserId);
            if (PageNum == 1)
            {
                query = query.Take(PageSize);
            }
            else
            {
                int skipNum = PageSize * (PageNum - 1);
                query = query.Skip(skipNum).Take(PageSize);
            }
            foreach (var subdata in query.ToList())
            {
                Dictionary<string, object> curData = new Dictionary<string, object>();
                curData.Add("ActivityDate", subdata.ActivityDate); //期数
                curData.Add("PrizeAmt", subdata.PrizeAmt); //中奖金额
                curData.Add("Status", subdata.Status);
                dataList.Add(curData);
            }
            return dataList;
        }
        #endregion



        #region 创客-红包活动-获取创客当前信息
        [Authorize]
        public JsonResult Detail(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            Dictionary<string, object> Obj = DetailDo(value);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj });
        }
        public Dictionary<string, object> DetailDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            DateTime today = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00");
            DateTime start = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 22:00:00");
            string DateString = DateTime.Now.ToString("yyyyMMdd");
            string PreDateString = DateTime.Now.AddDays(-1).ToString("yyyyMMdd");
            string PreInfoString = RedisDbconn.Instance.Get<string>("PreInfoString:" + PreDateString);
            if(string.IsNullOrEmpty(PreInfoString))
            {
                bool checkPre = maindb.ActivityRedPackageStock.Any(m => m.ActivityDate == PreDateString);
                if (checkPre)
                {
                    ActivityRedPackageStock preInfo = maindb.ActivityRedPackageStock.Where(m => m.ActivityDate == PreDateString).OrderByDescending(m => m.PrizeAmt).FirstOrDefault();
                    if (preInfo != null)
                    {
                        Users user = maindb.Users.FirstOrDefault(m => m.Id == preInfo.UserId) ?? new Users();
                        string PreMakerCode = user.MakerCode;
                        string PreRealName = user.RealName;
                        decimal PrePrizeAmt = preInfo.PrizeAmt;
                        RedisDbconn.Instance.Set("PreInfoString:" + PreDateString, PreMakerCode + "|" + PreRealName + "|" + PrePrizeAmt);
                        RedisDbconn.Instance.SetExpire("PreInfoString:" + PreDateString, 7200);
                    }
                }
            }
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            Dictionary<string, object> MyTopInfo1 = new Dictionary<string, object>();
            Dictionary<string, object> MyTopInfo2 = new Dictionary<string, object>();
            int GetStatus = 0; //0-未达标，1-可领取，2-已领取，3-未开始，4-抢光了
            int StaStatus = 0;
            int PreStatus = 0;
            PosMachinesTwo pos = maindb.PosMachinesTwo.FirstOrDefault(m => m.BuyUserId == UserId && m.ActivationState == 1 && m.ActivationTime >= today);
            if (pos != null)
            {
                StaStatus = 1;
                RedisDbconn.Instance.Set("CheckStaStatus:" + UserId + ":" + DateString, StaStatus.ToString());
                RedisDbconn.Instance.SetExpire("CheckStaStatus:" + UserId + ":" + DateString, 7200);
                if (DateTime.Now >= start)
                {
                    bool check = maindb.ActivityRedPackageStock.Any(m => m.ActivityDate == DateString && m.UserId == 0);
                    if (check)
                    {
                        bool query = maindb.ActivityRedPackageStock.Any(m => m.UserId == UserId && m.ActivityDate == DateString);
                        if (query)
                        {
                            GetStatus = 2;
                        }
                        else
                        {
                            GetStatus = 1;
                        }
                    }
                    else
                    {
                        GetStatus = 4;
                    }
                }
                else
                {
                    GetStatus = 3;
                }
            }
            else
            {
                GetStatus = 0;
            }
            bool pre = maindb.ActivityRedPackageJoins.Any(m => m.UserId == UserId && m.ActivityDate == PreDateString);
            PreStatus = pre ? 1 : 0;
            Users myInfo = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
            MyTopInfo1.Add("MakerCode", myInfo.MakerCode);
            MyTopInfo1.Add("RealName", myInfo.RealName);
            MyTopInfo2.Add("MakerCode", myInfo.MakerCode);
            MyTopInfo2.Add("RealName", myInfo.RealName);
            ActivityRedPackageTop10 mytop1 = maindb.ActivityRedPackageTop10.FirstOrDefault(m => m.UserId == UserId && m.Kind == 1) ?? new ActivityRedPackageTop10();
            MyTopInfo1.Add("Num", mytop1.Sort);
            MyTopInfo1.Add("Data", mytop1.PrizeAmt);
            ActivityRedPackageTop10 mytop2 = maindb.ActivityRedPackageTop10.FirstOrDefault(m => m.UserId == UserId && m.Kind == 2) ?? new ActivityRedPackageTop10();
            MyTopInfo2.Add("Num", mytop2.Sort);
            MyTopInfo2.Add("Data", mytop2.TimeNum);
            Obj.Add("GetStatus", GetStatus); //领取状态
            Obj.Add("StaStatus", StaStatus); //达标状态
            Obj.Add("PreStatus", PreStatus); //上期参与状态
            Obj.Add("MyTopInfo1", MyTopInfo1); //我的排行信息
            Obj.Add("MyTopInfo2", MyTopInfo2);
            return Obj;
        }
        #endregion



        #region 创客-红包活动-领取奖励
        [Authorize]
        public JsonResult GetPrize(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            AppResultJson result = GetPrizeDo(value);
            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
        }
        public AppResultJson GetPrizeDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            DateTime start = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 22:00:00");
            DateTime today = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00");
            string ActivityDate = DateTime.Now.ToString("yyyyMMdd");
            string tmpCheck = RedisDbconn.Instance.Get<string>("GetPrizeFlag:" + UserId + ":" + ActivityDate);
            if(!string.IsNullOrEmpty(tmpCheck))
            {
                return new AppResultJson() { Status = "-1", Info = "请无频繁操作，谢谢合作" };
            }
            RedisDbconn.Instance.Set("GetPrizeFlag:" + UserId + ":" + ActivityDate, "wait");
            RedisDbconn.Instance.SetExpire("GetPrizeFlag:" + UserId + ":" + ActivityDate, 120);
            string PreDate = DateTime.Now.AddDays(-1).ToString("yyyyMMdd");
            bool op = false;
            if (DateTime.Now >= start)
            {
                string pos = RedisDbconn.Instance.Get<string>("CheckStaStatus:" + UserId + ":" + ActivityDate);
                // bool pos = maindb.PosMachinesTwo.Any(m => m.BuyUserId == UserId && m.ActivationState == 1 && m.ActivationTime >= today);
                if (pos == "1")
                {
                    bool check = maindb.ActivityRedPackageStock.Any(m => m.ActivityDate == ActivityDate && m.UserId == 0);
                    if (check)
                    {
                        check = maindb.ActivityRedPackageStock.Any(m => m.UserId == UserId && m.ActivityDate == ActivityDate);
                        if (!check)
                        {
                            op = true;
                        }
                    }
                }
            }
            bool IsNull = maindb.ActivityRedPackageStock.Any(m => m.ActivityDate == ActivityDate && m.UserId ==0);//判断是否存在数据
            if (!IsNull)
            {
                return new AppResultJson() { Status = "2", Info = "已抢光" };
            }
            if (!op)
            {
                return new AppResultJson() { Status = "-1", Info = "领取失败" };
            }
            
            Dictionary<string, object> Obj = new Dictionary<string, object>();            
            List<ActivityRedPackageStock> list = maindb.ActivityRedPackageStock.Where(m => m.ActivityDate == ActivityDate && m.UserId == 0).ToList();
            ActivityRedPackageStock edit = new ActivityRedPackageStock();
            if(list.Count == 200 - 17 || list.Count == 200 - 27 || list.Count == 200 - 37 || list.Count == 200 - 47 || list.Count == 200 - 57 || list.Count == 200 - 67)
            {
                edit = list.FirstOrDefault(m => m.PrizeAmt == 88.88M && m.UserId == 0);
            }
            if(edit == null)
            {
                edit = new ActivityRedPackageStock();
            }
            if(edit.Id == 0)
            {
                edit = list[function.get_Random(0,list.Count-1)];
            }
            edit.UserId = UserId;
            edit.UpdateDate = DateTime.Now;
            ActivityRedPackageJoins query = maindb.ActivityRedPackageJoins.Add(new ActivityRedPackageJoins()
            {
                CreateDate = DateTime.Now, //创建时间
                Status = 1,
                UserId = UserId, //创客
                ActivityDate = ActivityDate, //期数
                PrizeAmt = edit.PrizeAmt,
            }).Entity;
            maindb.SaveChanges();
            
            RedisDbconn.Instance.AddList("RedPrizeQueue", query.Id.ToString());
            Obj.Add("PrizeAmt", query.PrizeAmt); //中奖金额

            string PreMakerCode = "";
            string PreRealName = "";
            decimal PrePrizeAmt = 0;
            string PreInfoString = RedisDbconn.Instance.Get<string>("PreInfoString:" + PreDate);
            if(string.IsNullOrEmpty(PreInfoString))
            {
                bool checkPre = maindb.ActivityRedPackageStock.Any(m => m.ActivityDate == PreDate);
                if (checkPre)
                {
                    ActivityRedPackageStock preInfo = maindb.ActivityRedPackageStock.Where(m => m.ActivityDate == PreDate).OrderByDescending(m => m.PrizeAmt).FirstOrDefault();
                    if (preInfo != null)
                    {
                        Users user = maindb.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);
                    }
                }
            }
            else
            {
                string[] datalist = PreInfoString.Split('|');
                PreMakerCode = datalist[0];
                PreRealName = datalist[1];
                PrePrizeAmt = decimal.Parse(datalist[2]);
            }
            Dictionary<string, object> PreInfo = new Dictionary<string, object>();
            PreInfo.Add("MakerCode", PreMakerCode);
            PreInfo.Add("RealName", PreRealName);
            PreInfo.Add("PrizeAmt", PrePrizeAmt);
            Obj.Add("PreInfo", PreInfo);
            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
        }
        #endregion



        #region 检查签名是否合法，合法返回1，不合法返回提示信息

        /// <summary>
        /// 检查签名是否合法，合法返回1，不合法返回提示信息
        /// </summary>
        /// <param name="value">请求的参数(json字符串)</param>
        /// <param name="signField">要签名的字段</param>
        /// <returns></returns>
        private string CheckSign(string value, string[] signField)
        {
            JsonData json = JsonMapper.ToObject(value);
            Dictionary<string, string> dic = new Dictionary<string, string>();
            for (int i = 0; i < signField.Length; i++)
            {
                dic.Add(signField[i], json[signField[i]].ToString());
            }
            string sign = json["sign"].ToString(); //客户端签名字符串
            return new Sign().sign(dic, sign);
        }

        #endregion

    }
}