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 logger, IOptions setting) : base(accessor, logger, setting) { } #region 创客-红包活动-参与记录 [Authorize] public JsonResult List(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ListDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> 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> dataList = new List>(); IQueryable 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 curData = new Dictionary(); 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 Obj = DetailDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj }); } public Dictionary 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("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 Obj = new Dictionary(); Dictionary MyTopInfo1 = new Dictionary(); Dictionary MyTopInfo2 = new Dictionary(); 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("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("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 Obj = new Dictionary(); List 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("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 PreInfo = new Dictionary(); 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,不合法返回提示信息 /// /// 检查签名是否合法,合法返回1,不合法返回提示信息 /// /// 请求的参数(json字符串) /// 要签名的字段 /// private string CheckSign(string value, string[] signField) { JsonData json = JsonMapper.ToObject(value); Dictionary dic = new Dictionary(); 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 } }