DepositReturnStatService.cs 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. using System;
  2. using System.Collections.Generic;
  3. using Library;
  4. using LitJson;
  5. using System.Linq;
  6. using System.Data;
  7. using System.Threading;
  8. using MySystem.PxcModels;
  9. namespace MySystem
  10. {
  11. public class DepositReturnStatService
  12. {
  13. public readonly static DepositReturnStatService Instance = new DepositReturnStatService();
  14. private DepositReturnStatService()
  15. { }
  16. public void Start()
  17. {
  18. Thread th = new Thread(StartEverDay);
  19. th.IsBackground = true;
  20. th.Start();
  21. }
  22. public void StartEverDay()
  23. {
  24. while(true)
  25. {
  26. // if(DateTime.Now.Day == 1 && DateTime.Now.Hour == 1)
  27. // {
  28. try
  29. {
  30. StartEverDayDo();
  31. }
  32. catch(Exception ex)
  33. {
  34. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计押金达标数据异常");
  35. }
  36. // }
  37. Thread.Sleep(1000);
  38. }
  39. }
  40. public void StartEverDayDo()
  41. {
  42. string Month = DateTime.Now.ToString("yyyyMM");
  43. // string chk = function.ReadInstance("/DepositReturn/" + Month + ".txt");
  44. // if(!string.IsNullOrEmpty(chk))
  45. // {
  46. // return;
  47. // }
  48. // function.WritePage("/DepositReturn/", Month + ".txt", DateTime.Now.ToString());
  49. WebCMSEntities db = new WebCMSEntities();
  50. int startid = int.Parse(function.CheckInt(function.ReadInstance("/DepositReturn/MerchantId.txt")));
  51. List<PosMerchantInfo> merchants = db.PosMerchantInfo.Where(m => m.Id > startid && m.StandardStatus == 0).OrderBy(m => m.Id).Take(50).ToList();
  52. foreach(PosMerchantInfo merchant in merchants)
  53. {
  54. if(merchant.ActiveStatus == 1)
  55. {
  56. string start = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
  57. int StandardMonths = merchant.StandardMonths;
  58. int StandardStatus = merchant.StandardStatus;
  59. DateTime ActDate = merchant.CreateDate.Value;
  60. if(merchant.MerStandardDate == null)
  61. {
  62. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == merchant.KqSnNo && m.ActivationState == 1 && m.ActivationTime != null);
  63. if(pos != null)
  64. {
  65. ActDate = pos.ActivationTime.Value;
  66. }
  67. }
  68. else
  69. {
  70. ActDate = merchant.MerStandardDate.Value;
  71. }
  72. int MonthNum = StandardMonths;
  73. for (int i = StandardMonths + 1; i <= 10; i++)
  74. {
  75. string TradeMonth = ActDate.AddMonths(i).ToString("yyyyMM");
  76. if(int.Parse(TradeMonth) < int.Parse(DateTime.Now.ToString("yyyyMM")))
  77. {
  78. decimal TradeAmount = 0;
  79. bool CheckAmount = db.PosMerchantTradeSummay.Any(m => m.MerchantId == merchant.Id && m.TradeMonth == TradeMonth);
  80. if(CheckAmount)
  81. {
  82. TradeAmount = db.PosMerchantTradeSummay.Where(m => m.MerchantId == merchant.Id && m.TradeMonth == TradeMonth).Sum(m => m.TradeAmount);
  83. }
  84. if(TradeAmount >= 10000)
  85. {
  86. MonthNum = i;
  87. }
  88. else
  89. {
  90. StandardStatus = -1;
  91. break;
  92. }
  93. }
  94. }
  95. if(MonthNum >= 10)
  96. {
  97. StandardStatus = 4;
  98. }
  99. PosMerchantInfo edit = db.PosMerchantInfo.FirstOrDefault(m => m.Id == merchant.Id);
  100. if(edit != null)
  101. {
  102. edit.StandardMonths = MonthNum;
  103. edit.StandardStatus = StandardStatus;
  104. db.SaveChanges();
  105. }
  106. string end = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
  107. }
  108. startid = merchant.Id;
  109. }
  110. function.WritePage("/DepositReturn/", "MerchantId.txt", startid.ToString());
  111. db.Dispose();
  112. }
  113. }
  114. }