MerchantStandardService.cs 9.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Data;
  5. using System.Threading;
  6. using MySystem.Models.Main;
  7. using Library;
  8. using LitJson;
  9. namespace MySystem
  10. {
  11. public class MerchantStandardService
  12. {
  13. public readonly static MerchantStandardService Instance = new MerchantStandardService();
  14. private MerchantStandardService()
  15. { }
  16. public void Start()
  17. {
  18. Thread th = new Thread(Listen);
  19. th.IsBackground = true;
  20. th.Start();
  21. }
  22. private void Listen()
  23. {
  24. while (true)
  25. {
  26. try
  27. {
  28. DoSomething();
  29. }
  30. catch(Exception ex)
  31. {
  32. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "商户达标奖异常");
  33. }
  34. Thread.Sleep(600000);
  35. }
  36. }
  37. public void DoSomething()
  38. {
  39. WebCMSEntities db = new WebCMSEntities();
  40. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  41. DateTime end = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  42. string month = DateTime.Now.ToString("yyyyMM");
  43. var orders = db.MerchantDepositOrder.Where(m => m.Status > 0 && m.Version == 0 && m.UpdateDate >= start && m.UpdateDate < end);
  44. foreach(var order in orders)
  45. {
  46. decimal TradeMoney = 0;
  47. bool has = db.MerchantAmountSummay.Any(m => m.MerchantId == order.MerchantId && m.TradeMonth == month);
  48. if(has)
  49. {
  50. TradeMoney = db.MerchantAmountSummay.Where(m => m.MerchantId == order.MerchantId && m.TradeMonth == month).Sum(m => m.TradeAmount);
  51. }
  52. if(TradeMoney >= 10000)
  53. {
  54. RedisDbconn.Instance.AddList("StandardProfitQueue2", "{\"MerchantId\":\"" + order.MerchantId + "\",\"Prize\":\"50\"}");
  55. MerchantDepositOrder edit = db.MerchantDepositOrder.FirstOrDefault(m => m.Id == order.Id);
  56. if(edit != null)
  57. {
  58. edit.Version = 1;
  59. }
  60. }
  61. db.SaveChanges();
  62. }
  63. db.Dispose();
  64. }
  65. public void StartThree()
  66. {
  67. Thread th = new Thread(ListenThree);
  68. th.IsBackground = true;
  69. th.Start();
  70. }
  71. private void ListenThree()
  72. {
  73. while (true)
  74. {
  75. try
  76. {
  77. DoSomethingThree();
  78. }
  79. catch(Exception ex)
  80. {
  81. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "商户连续3月达标奖异常");
  82. }
  83. Thread.Sleep(605000);
  84. }
  85. }
  86. public void DoSomethingThree()
  87. {
  88. WebCMSEntities db = new WebCMSEntities();
  89. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-3).ToString("yyyy-MM") + "-01 00:00:00");
  90. DateTime end = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  91. string month = DateTime.Now.AddMonths(-2).ToString("yyyyMM");
  92. string month2 = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  93. string month3 = DateTime.Now.ToString("yyyyMM");
  94. var orders = db.MerchantDepositOrder.Where(m => m.Status > 0 && m.Version == 1 && m.UpdateDate >= start && m.UpdateDate < end);
  95. foreach(var order in orders)
  96. {
  97. decimal TradeMoney = 0, TradeMoney2 = 0, TradeMoney3 = 0;
  98. bool has = db.MerchantAmountSummay.Any(m => m.MerchantId == order.MerchantId && m.TradeMonth == month);
  99. if(has)
  100. {
  101. TradeMoney = db.MerchantAmountSummay.Where(m => m.MerchantId == order.MerchantId && m.TradeMonth == month).Sum(m => m.TradeAmount);
  102. }
  103. has = db.MerchantAmountSummay.Any(m => m.MerchantId == order.MerchantId && m.TradeMonth == month2);
  104. if(has)
  105. {
  106. TradeMoney2 = db.MerchantAmountSummay.Where(m => m.MerchantId == order.MerchantId && m.TradeMonth == month2).Sum(m => m.TradeAmount);
  107. }
  108. has = db.MerchantAmountSummay.Any(m => m.MerchantId == order.MerchantId && m.TradeMonth == month3);
  109. if(has)
  110. {
  111. TradeMoney3 = db.MerchantAmountSummay.Where(m => m.MerchantId == order.MerchantId && m.TradeMonth == month3).Sum(m => m.TradeAmount);
  112. }
  113. if(TradeMoney >= 10000 && TradeMoney2 >= 10000 && TradeMoney3 >= 10000)
  114. {
  115. RedisDbconn.Instance.AddList("StandardProfitQueue2", "{\"MerchantId\":\"" + order.MerchantId + "\",\"Prize\":\"100\"}");
  116. MerchantDepositOrder edit = db.MerchantDepositOrder.FirstOrDefault(m => m.Id == order.Id);
  117. if(edit != null)
  118. {
  119. edit.Version = 2;
  120. }
  121. }
  122. db.SaveChanges();
  123. }
  124. db.Dispose();
  125. }
  126. #region 达标奖励队列
  127. public void StartActive()
  128. {
  129. Thread th = new Thread(StartListenActive);
  130. th.IsBackground = true;
  131. th.Start();
  132. }
  133. public void StartListenActive()
  134. {
  135. while (true)
  136. {
  137. string content = RedisDbconn.Instance.RPop<string>("StandardProfitQueue2");
  138. if (!string.IsNullOrEmpty(content))
  139. {
  140. StartListenActiveDo(content);
  141. }
  142. else
  143. {
  144. Thread.Sleep(60000);
  145. }
  146. }
  147. }
  148. public void StartListenActiveDo(string content)
  149. {
  150. try
  151. {
  152. JsonData jsonObj = JsonMapper.ToObject(content);
  153. int MerchantId = int.Parse(jsonObj["MerchantId"].ToString());
  154. decimal Prize = decimal.Parse(jsonObj["Prize"].ToString());
  155. Models.KxsMain.WebCMSEntities kxsdb = new Models.KxsMain.WebCMSEntities();
  156. WebCMSEntities db = new WebCMSEntities();
  157. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId) ?? new MerchantInfo();
  158. string IdBrand = merchant.UserId + "_0";
  159. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  160. if (userData == null)
  161. {
  162. userData = db.UserMachineData.Add(new UserMachineData()
  163. {
  164. IdBrand = IdBrand,
  165. }).Entity;
  166. db.SaveChanges();
  167. }
  168. userData.OtherProfit += Prize;
  169. db.SaveChanges();
  170. int GetUserId = merchant.UserId;
  171. Models.KxsMain.UserAccount account = kxsdb.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  172. if (account == null)
  173. {
  174. account = kxsdb.UserAccount.Add(new Models.KxsMain.UserAccount()
  175. {
  176. Id = GetUserId,
  177. UserId = GetUserId,
  178. }).Entity;
  179. kxsdb.SaveChanges();
  180. }
  181. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  182. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  183. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  184. account.BalanceAmount += Prize;
  185. account.TotalAmount += Prize;
  186. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  187. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  188. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  189. Models.KxsMain.UserAccountRecord userAccountRecord = kxsdb.UserAccountRecord.Add(new Models.KxsMain.UserAccountRecord()
  190. {
  191. CreateDate = DateTime.Now,
  192. UpdateDate = DateTime.Now,
  193. UserId = GetUserId, //创客
  194. ChangeType = 315, //变动类型
  195. ChangeAmount = Prize, //变更金额
  196. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  197. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  198. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  199. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  200. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  201. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  202. }).Entity;
  203. kxsdb.SaveChanges();
  204. kxsdb.Dispose();
  205. db.Dispose();
  206. }
  207. catch (Exception ex)
  208. {
  209. LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "达标奖励服务异常");
  210. }
  211. }
  212. #endregion
  213. }
  214. }