SycnSpActiveService.cs 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using MySystem.SpModels;
  5. using Library;
  6. using LitJson;
  7. using System.Threading;
  8. namespace MySystem
  9. {
  10. public class SycnSpActiveService
  11. {
  12. public readonly static SycnSpActiveService Instance = new SycnSpActiveService();
  13. private SycnSpActiveService()
  14. { }
  15. public void Start()
  16. {
  17. Thread th = new Thread(StartDo);
  18. th.IsBackground = true;
  19. th.Start();
  20. }
  21. public void StartDo()
  22. {
  23. while (true)
  24. {
  25. try
  26. {
  27. WebCMSEntities spdb = new WebCMSEntities();
  28. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  29. string Month = DateTime.Now.ToString("yyyyMM");
  30. string Date = DateTime.Now.ToString("yyyyMMdd");
  31. DateTime start = DateTime.Now.AddDays(-5);
  32. DateTime end = DateTime.Now.AddMinutes(-1);
  33. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/ActivateRecordId.txt")));
  34. IQueryable<ActivateRecord> acts = spdb.ActivateRecord.Where(m => m.Id >= StartId && m.ActivateDate >= start && m.ActivateDate < end && m.Status == 1).OrderByDescending(m => m.Id);
  35. foreach (ActivateRecord act in acts.ToList())
  36. {
  37. PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == act.MerNo) ?? new PxcModels.MachineForMerNo();
  38. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  39. if (pos != null)
  40. {
  41. PxcModels.KqProducts kqproduct = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new PxcModels.KqProducts();
  42. if (kqproduct.SingleDepositApi == 1)
  43. {
  44. pos.SeoKeyword = act.SeoTitle;
  45. if(pos.BrandId == 15 || pos.BrandId == 16) //来客吧
  46. {
  47. pos.Detail = ""; //清除激活奖励标记
  48. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString()); //发开机奖励
  49. }
  50. db.SaveChanges();
  51. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  52. StatService.Instance.PreActPrize(db, pos, merchant, act.SeoTitle);
  53. }
  54. if(pos.BrandId == 12 || pos.BrandId == 13 || pos.BrandId == 15 || pos.BrandId == 16)
  55. {
  56. decimal CheckMoney = kqproduct.ActTradeAmount > 0 ? kqproduct.ActTradeAmount : 1000;
  57. int CheckDays = 30;
  58. SycnSpTradeService.Instance.ActPos(db, pos, CheckMoney, CheckDays);
  59. if(pos.ActivationState == 1)
  60. {
  61. decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  62. DateTime now = DateTime.Now;
  63. if (Deposit > 0 && pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100)
  64. {
  65. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  66. }
  67. //发放运营中心奖励
  68. if (Deposit > 0 && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100)
  69. {
  70. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  71. }
  72. }
  73. }
  74. ActivateRecord edit = spdb.ActivateRecord.FirstOrDefault(m => m.Id == act.Id);
  75. if (edit != null)
  76. {
  77. edit.Status = 2;
  78. }
  79. }
  80. pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId && m.ActivationState == 1);
  81. if (pos != null)
  82. {
  83. ActivateRecord edit = spdb.ActivateRecord.FirstOrDefault(m => m.Id == act.Id);
  84. if (edit != null)
  85. {
  86. edit.Status = 2;
  87. }
  88. }
  89. }
  90. spdb.SaveChanges();
  91. spdb.Dispose();
  92. db.SaveChanges();
  93. db.Dispose();
  94. }
  95. catch (Exception ex)
  96. {
  97. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP激活数据到MAIN异常");
  98. }
  99. Thread.Sleep(1000);
  100. }
  101. }
  102. }
  103. }