StatHelpProfitService.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505
  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 StatHelpProfitService
  12. {
  13. public readonly static StatHelpProfitService Instance = new StatHelpProfitService();
  14. private StatHelpProfitService()
  15. { }
  16. // 统计交易额V2
  17. public void StartEverDayV2()
  18. {
  19. Thread th = new Thread(StartEverDayV2Do);
  20. th.IsBackground = true;
  21. th.Start();
  22. }
  23. public void StartEverDayV2Do()
  24. {
  25. while (true)
  26. {
  27. if (DateTime.Now.Hour >= 3)
  28. {
  29. StatTradeAmountEverDayV2();
  30. }
  31. Thread.Sleep(30000);
  32. }
  33. }
  34. public void StatTradeAmountEverDayV2()
  35. {
  36. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  37. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行助利宝交易额日志");
  38. WebCMSEntities db = new WebCMSEntities();
  39. using (var tran = db.Database.BeginTransaction())
  40. {
  41. try
  42. {
  43. string startId = function.ReadInstance("/TradeRecord/Id3.txt");
  44. if (string.IsNullOrEmpty(startId))
  45. {
  46. startId = "2750000";
  47. }
  48. DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and CreateDate>='2022-09-05 00:00:00' and MerchantId in (select MerchantId from HelpProfitMerIds) and SeoTitle='HelpProfit' and QueryCount>0 and QueryCount<3 order by Id limit 50");
  49. if (idsDt.Rows.Count > 0)
  50. {
  51. string ids = "";
  52. foreach (DataRow idsDr in idsDt.Rows)
  53. {
  54. ids += idsDr["Id"].ToString() + ",";
  55. startId = idsDr["Id"].ToString();
  56. }
  57. DataTable selfDt = OtherMySqlConn.dtable("select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d')");
  58. if (selfDt.Rows.Count > 0)
  59. {
  60. function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时执行助利宝交易额日志");
  61. foreach (DataRow selfDr in selfDt.Rows)
  62. {
  63. int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
  64. string TradeDate = selfDr[1].ToString();
  65. string TradeMonth = TradeDate.Substring(0, 6);
  66. decimal TradeAmount = decimal.Parse(selfDr[2].ToString());
  67. HelpProfitMerIds merIds = db.HelpProfitMerIds.FirstOrDefault(m => m.MerchantId == MerchantId) ?? new HelpProfitMerIds();
  68. bool Check = CheckAmount(db, MerchantId, merIds.UserId, TradeMonth);
  69. if (Check)
  70. {
  71. decimal MoreAmount = TradeAmount * 0.01M;
  72. int random = function.get_Random(0, 10000);
  73. // if(MoreAmount > 1 && random < 5000)
  74. // {
  75. MoreAmount = decimal.Parse(function.CheckInt(MoreAmount.ToString().Split(".")[0]));
  76. // }
  77. HelpProfitMerTradeSummay selfStat = db.HelpProfitMerTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate);
  78. if (selfStat == null)
  79. {
  80. selfStat = db.HelpProfitMerTradeSummay.Add(new HelpProfitMerTradeSummay()
  81. {
  82. TradeMonth = TradeMonth,
  83. TradeDate = TradeDate,
  84. MerchantId = MerchantId,
  85. }).Entity;
  86. db.SaveChanges();
  87. }
  88. selfStat.TradeAmount += TradeAmount + MoreAmount;
  89. HelpProfitMerTradeMonthSummay monthStat = db.HelpProfitMerTradeMonthSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth);
  90. if (monthStat == null)
  91. {
  92. monthStat = db.HelpProfitMerTradeMonthSummay.Add(new HelpProfitMerTradeMonthSummay()
  93. {
  94. TradeMonth = TradeMonth,
  95. MerchantId = MerchantId,
  96. }).Entity;
  97. db.SaveChanges();
  98. }
  99. monthStat.TradeAmount += TradeAmount + MoreAmount;
  100. }
  101. }
  102. OtherMySqlConn.op("update TradeRecord set QueryCount=3 where Id in (" + ids.TrimEnd(',') + ")");
  103. function.WritePage("/TradeRecord/", "Id3.txt", startId);
  104. }
  105. db.SaveChanges();
  106. }
  107. tran.Commit();
  108. }
  109. catch (Exception ex)
  110. {
  111. tran.Rollback();
  112. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行助利宝交易额异常");
  113. }
  114. }
  115. db.Dispose();
  116. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行助利宝交易额日志");
  117. }
  118. public void StatTradeAmountTmp()
  119. {
  120. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  121. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行助利宝交易额日志");
  122. WebCMSEntities db = new WebCMSEntities();
  123. using (var tran = db.Database.BeginTransaction())
  124. {
  125. try
  126. {
  127. DataTable selfDt = OtherMySqlConn.dtable("select MerchantId,DATE_FORMAT(CreateDate,'%Y%m'),sum(TradeAmount) from TradeRecord where CreateDate>='2022-09-05 00:00:00' and MerchantId in (select MerchantId from HelpProfitMerIds) and SeoTitle='HelpProfit' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,DATE_FORMAT(CreateDate,'%Y%m')");
  128. if (selfDt.Rows.Count > 0)
  129. {
  130. function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时执行助利宝交易额日志");
  131. foreach (DataRow selfDr in selfDt.Rows)
  132. {
  133. int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
  134. string TradeMonth = selfDr[1].ToString();
  135. decimal TradeAmount = decimal.Parse(selfDr[2].ToString());
  136. HelpProfitMerIds merIds = db.HelpProfitMerIds.FirstOrDefault(m => m.MerchantId == MerchantId) ?? new HelpProfitMerIds();
  137. HelpProfitAmountSummary profitStat = db.HelpProfitAmountSummary.FirstOrDefault(m => m.UserId == merIds.UserId && m.TradeMonth == TradeMonth);
  138. if (profitStat == null)
  139. {
  140. int Month = db.HelpProfitAmountSummary.Count(m => m.UserId == merIds.UserId && Convert.ToInt32(m.TradeMonth) <= Convert.ToInt32(TradeMonth));
  141. profitStat = db.HelpProfitAmountSummary.Add(new HelpProfitAmountSummary()
  142. {
  143. TradeMonth = TradeMonth,
  144. UserId = merIds.UserId,
  145. QueryCount = Month + 1,
  146. }).Entity;
  147. db.SaveChanges();
  148. }
  149. profitStat.TradeAmount += TradeAmount;
  150. }
  151. }
  152. db.SaveChanges();
  153. tran.Commit();
  154. }
  155. catch (Exception ex)
  156. {
  157. tran.Rollback();
  158. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行助利宝交易额2异常");
  159. }
  160. }
  161. db.Dispose();
  162. }
  163. // 统计创客商机台数
  164. public void StartUserTrade()
  165. {
  166. Thread th = new Thread(StartUserTradeDo);
  167. th.IsBackground = true;
  168. th.Start();
  169. }
  170. public void StartUserTradeDo()
  171. {
  172. while (true)
  173. {
  174. if (DateTime.Now.Hour >= 3)
  175. {
  176. StartUserTradeGo();
  177. }
  178. Thread.Sleep(30000);
  179. }
  180. }
  181. public void StartUserTradeGo()
  182. {
  183. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  184. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计助利宝创客交易额日志");
  185. WebCMSEntities db = new WebCMSEntities();
  186. using (var tran = db.Database.BeginTransaction())
  187. {
  188. try
  189. {
  190. bool op = true;
  191. while(op)
  192. {
  193. string startId = function.ReadInstance("/TradeRecord/HelpProfitMerchantForUserId.txt");
  194. if (string.IsNullOrEmpty(startId))
  195. {
  196. startId = "0";
  197. }
  198. DataTable idsDt = OtherMySqlConn.dtable("select Id from HelpProfitMerchantForUser where Id>=" + startId + " and Status=0 order by Id limit 50");
  199. if (idsDt.Rows.Count > 0)
  200. {
  201. string ids = "";
  202. foreach (DataRow idsDr in idsDt.Rows)
  203. {
  204. ids += idsDr["Id"].ToString() + ",";
  205. startId = idsDr["Id"].ToString();
  206. }
  207. DataTable selfDt = OtherMySqlConn.dtable("select UserId,DATE_FORMAT(CreateDate,'%Y%m'),count(Id) from HelpProfitMerchantForUser where Id in (" + ids.TrimEnd(',') + ") group by UserId,DATE_FORMAT(CreateDate,'%Y%m')");
  208. if (selfDt.Rows.Count > 0)
  209. {
  210. function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时统计助利宝创客交易额日志");
  211. foreach (DataRow selfDr in selfDt.Rows)
  212. {
  213. int UserId = int.Parse(selfDr["UserId"].ToString());
  214. string TradeMonth = selfDr[1].ToString();
  215. int MerCount = int.Parse(selfDr[2].ToString());
  216. HelpProfitAmountSummary selfStat = db.HelpProfitAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth);
  217. if (selfStat == null)
  218. {
  219. int CheckMonth = db.HelpProfitAmountSummary.Count(m => m.UserId == UserId && Convert.ToInt32(m.TradeMonth) <= Convert.ToInt32(TradeMonth));
  220. selfStat = db.HelpProfitAmountSummary.Add(new HelpProfitAmountSummary()
  221. {
  222. TradeMonth = TradeMonth,
  223. UserId = UserId,
  224. QueryCount = CheckMonth + 1,
  225. }).Entity;
  226. db.SaveChanges();
  227. }
  228. selfStat.MerCount += MerCount;
  229. int Month = selfStat.QueryCount;
  230. if(Month > 24)
  231. {
  232. Month = 24;
  233. }
  234. selfStat.MaxAmount += EveryMonthFixedVal()[Month] * MerCount;
  235. }
  236. OtherMySqlConn.op("update HelpProfitMerchantForUser set Status=1 where Id in (" + ids.TrimEnd(',') + ")");
  237. function.WritePage("/TradeRecord/", "HelpProfitMerchantForUserId.txt", startId);
  238. }
  239. db.SaveChanges();
  240. }
  241. else
  242. {
  243. op = false;
  244. }
  245. }
  246. tran.Commit();
  247. }
  248. catch (Exception ex)
  249. {
  250. tran.Rollback();
  251. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计助利宝创客交易额异常");
  252. }
  253. }
  254. db.Dispose();
  255. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计助利宝创客交易额日志");
  256. }
  257. //计算商户交易额是否入账
  258. private bool CheckAmount(WebCMSEntities db, int MerchantId, int UserId, string TradeMonth)
  259. {
  260. HelpProfitAmountSummary Summary = db.HelpProfitAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth) ?? new HelpProfitAmountSummary();
  261. decimal MaxTradeAmount = Summary.MaxAmount; //当月最大交易总额
  262. decimal CheckAmount = 500000 < MaxTradeAmount * 0.3M ? 500000 : MaxTradeAmount * 0.3M;
  263. //当月单台交易额 <= 50万或当月最大交易总额的30%(取小值),则入账
  264. HelpProfitMerTradeMonthSummay MonthStat = db.HelpProfitMerTradeMonthSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth) ?? new HelpProfitMerTradeMonthSummay();
  265. decimal SingleTradeAmount = MonthStat.TradeAmount;
  266. if (SingleTradeAmount < CheckAmount)
  267. {
  268. //当月总交易额不超过当月最大交易总额,则入账
  269. if (Summary.TradeAmount < CheckAmount)
  270. {
  271. return true;
  272. }
  273. }
  274. return false;
  275. }
  276. //商户24个月,每月固定额度
  277. private Dictionary<int, decimal> EveryMonthFixedVal()
  278. {
  279. Dictionary<int, decimal> obj = new Dictionary<int, decimal>();
  280. obj.Add(0, 0M);
  281. obj.Add(1, 70000M);
  282. obj.Add(2, 60000M);
  283. obj.Add(3, 50000M);
  284. obj.Add(4, 40000M);
  285. obj.Add(5, 30000M);
  286. obj.Add(6, 30000M);
  287. obj.Add(7, 27000M);
  288. obj.Add(8, 25000M);
  289. obj.Add(9, 20000M);
  290. obj.Add(10, 17000M);
  291. obj.Add(11, 14000M);
  292. obj.Add(12, 14000M);
  293. obj.Add(13, 13000M);
  294. obj.Add(14, 12000M);
  295. obj.Add(15, 12000M);
  296. obj.Add(16, 10000M);
  297. obj.Add(17, 8000M);
  298. obj.Add(18, 7000M);
  299. obj.Add(19, 6000M);
  300. obj.Add(20, 5000M);
  301. obj.Add(21, 4000M);
  302. obj.Add(22, 3000M);
  303. obj.Add(23, 2000M);
  304. obj.Add(24, 1000M);
  305. return obj;
  306. }
  307. #region 每月重置最大交易总额
  308. public void ResetMaxTradeAmount()
  309. {
  310. Thread th = new Thread(ResetMaxTradeAmountDo);
  311. th.IsBackground = true;
  312. th.Start();
  313. }
  314. public void ResetMaxTradeAmountDo()
  315. {
  316. while (true)
  317. {
  318. if (DateTime.Now.Day == 1 && DateTime.Now.Hour > 0 && DateTime.Now.Hour < 3)
  319. {
  320. string TradeMonth = DateTime.Now.ToString("yyyyMM");
  321. ResetMaxTradeAmountGo(TradeMonth);
  322. }
  323. Thread.Sleep(30000);
  324. }
  325. }
  326. public void ResetMaxTradeAmountGo(string TradeMonth)
  327. {
  328. try
  329. {
  330. string CheckExist = function.ReadInstance("/HelpProfitAmountSummary/" + TradeMonth + ".txt");
  331. if(string.IsNullOrEmpty(CheckExist))
  332. {
  333. function.WritePage("/HelpProfitAmountSummary/", TradeMonth + ".txt", DateTime.Now.ToString());
  334. WebCMSEntities db = new WebCMSEntities();
  335. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  336. DataTable userlist = OtherMySqlConn.dtable("select DISTINCT UserId from HelpProfitAmountSummary order by UserId");
  337. // DataTable userlist = OtherMySqlConn.dtable("select DISTINCT UserId from HelpProfitAmountSummary where (TradeMonth='202209' or TradeMonth='202210') and UserId not in (select UserId from HelpProfitAmountSummary where TradeMonth='202211')");
  338. foreach (DataRow user in userlist.Rows)
  339. {
  340. int UserId = int.Parse(user["UserId"].ToString());
  341. int MonthCount = db.HelpProfitAmountSummary.Count(m => m.UserId == UserId) + 1;
  342. int Month = MonthCount;
  343. if(Month > 24)
  344. {
  345. Month = 24;
  346. }
  347. decimal MonthAmount1 = 0; //本月额度
  348. decimal MonthAmount2 = 0; //上月额度
  349. decimal MonthAmount3 = 0; //上上月额度
  350. if(Month > 0)
  351. {
  352. MonthAmount1 = EveryMonthFixedVal()[Month]; //上月额度
  353. }
  354. if(Month > 1)
  355. {
  356. MonthAmount2 = EveryMonthFixedVal()[Month - 1]; //上月额度
  357. }
  358. if(Month > 2)
  359. {
  360. MonthAmount3 = EveryMonthFixedVal()[Month - 2]; //上上月额度
  361. }
  362. List<int> MerCounts = new List<int>(); //近3月月台数,包含当月
  363. List<decimal> MaxTradeAmounts = new List<decimal>(); //近3月最大额度,包含当月
  364. int MerCount1 = 0; //本月台数
  365. int MerCount2 = 0; //上月台数
  366. int MerCount3 = 0; //上上月台数
  367. decimal PreMaxTradeAmount = 0; //上月最大额度
  368. decimal PreTradeAmount = 0; //上月创客交易额
  369. List<HelpProfitAmountSummary> Summarys = db.HelpProfitAmountSummary.Where(m => m.UserId == UserId && Convert.ToInt32(m.TradeMonth) <= Convert.ToInt32(TradeMonth)).OrderByDescending(m => m.TradeMonth).Take(3).ToList();
  370. foreach(HelpProfitAmountSummary Summary in Summarys)
  371. {
  372. MerCounts.Add(Summary.MerCount);
  373. MaxTradeAmounts.Add(Summary.MaxAmount);
  374. }
  375. if(MerCounts.Count > 0)
  376. {
  377. MerCount1 = MerCounts[0];
  378. }
  379. if(MerCounts.Count > 1)
  380. {
  381. MerCount2 = MerCounts[1];
  382. PreMaxTradeAmount = MaxTradeAmounts[1];
  383. string PreMonthString = DateTime.Parse(TradeMonth.Substring(0, 4) + "-" + TradeMonth.Substring(4, 2) + "-01").AddMonths(-1).ToString("yyyyMM");
  384. DataTable dt = OtherMySqlConn.dtable("SELECT SUM(TradeAmount) TradeAmount FROM HelpProfitMerTradeSummay WHERE MerchantId IN(SELECT MerchantId FROM HelpProfitMerIds WHERE UserId=" + UserId + ") AND TradeMonth=" + PreMonthString + "");
  385. if (dt.Rows.Count > 0)
  386. {
  387. PreTradeAmount = decimal.Parse(function.CheckNum(dt.Rows[0]["TradeAmount"].ToString()));
  388. }
  389. }
  390. if(MerCounts.Count > 2)
  391. {
  392. MerCount3 = MerCounts[2];
  393. }
  394. decimal MaxTradeAmount = MerCount1 * MonthAmount1 + MerCount2 * MonthAmount2 + MerCount3 * MonthAmount3; //当月最大交易总额
  395. MaxTradeAmount = PreMaxTradeAmount - PreTradeAmount + MaxTradeAmount; //上月最大额度-实际交易额+本月最大交易额
  396. HelpProfitAmountSummary selfStat = db.HelpProfitAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth);
  397. if(selfStat == null)
  398. {
  399. selfStat = db.HelpProfitAmountSummary.Add(new HelpProfitAmountSummary()
  400. {
  401. UserId = UserId,
  402. TradeMonth = TradeMonth,
  403. QueryCount = MonthCount,
  404. }).Entity;
  405. db.SaveChanges();
  406. }
  407. selfStat.MaxAmount = MaxTradeAmount;
  408. }
  409. db.SaveChanges();
  410. db.Dispose();
  411. }
  412. }
  413. catch(Exception ex)
  414. {
  415. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月重置最大交易总额异常");
  416. }
  417. }
  418. #endregion
  419. public void StatTradeTmp()
  420. {
  421. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  422. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行助利宝交易额日志");
  423. WebCMSEntities db = new WebCMSEntities();
  424. using (var tran = db.Database.BeginTransaction())
  425. {
  426. try
  427. {
  428. DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=4150000 and CreateDate>='2022-11-27 00:00:00' and CreateDate<'2022-11-28 00:00:00' and MerchantId in (select MerchantId from HelpProfitMerIds) and SeoTitle='HelpProfit' and QueryCount=3 and MerchantId in (select MerchantId from HelpProfitMerchantForUser where UserId in (144214,144213,144170,144046,143420,143294,142953,142861,142736,142642,142608,142545,142532,142484,142297,142263,141951,141878,141838,141814,141562,141469,141295,141239,141073,140952,140816,140470,140221,140220,139917,139815,139729,139639,139094,138877,138516,138173,138021,138014,137967,137870,137706,137361,136263,136181,135950,135524,135448,135373,135251,135224,135121,134915,134503,133783,133420,132996,132839,132726,132642,132488,132469,132234,131903,131845,131025,130767,130744,130334,130113,129947,129814,129111,128853,128758,128640,128513,128322,127634,127188,126802,126782,126620,126613,125981,125848,125778,125754,124875,124822,124344,123770,123747,123115,122986,121779,121749,121570,121404,121108,120998,120957,120776,120720,120663,120650,120604,110031,109906,109405,106581,105286,100934,99148,93049,91467,88519,88494,84401,80747,72018,69881,69195,68888,64167,63784,62252,60846,60561,60035,59740,59159,57366,56869,56182,56080,55049,54784,54517,52449,52265,51193,50886,49838,49145,48849,46655,46284,45892,41420,41200,40498,40282,40280,39109,38520,37033,36932,36488,35805,33055,32534,27524,24528,21108,18724,15600,15509,15506,11124,9367,7601,7487,6764,6267,4861,3885,3835,3015,1893,1797,1703,1195,1052,668,609,602,599,598,588,586,583,582,565,560,558,514,415,392,391,389,387,281,276,237,45,1))");
  429. if (idsDt.Rows.Count > 0)
  430. {
  431. string ids = "";
  432. foreach (DataRow idsDr in idsDt.Rows)
  433. {
  434. ids += idsDr["Id"].ToString() + ",";
  435. }
  436. DataTable selfDt = OtherMySqlConn.dtable("select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d')");
  437. if (selfDt.Rows.Count > 0)
  438. {
  439. function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时执行助利宝交易额日志");
  440. foreach (DataRow selfDr in selfDt.Rows)
  441. {
  442. int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
  443. string TradeDate = selfDr[1].ToString();
  444. string TradeMonth = TradeDate.Substring(0, 6);
  445. decimal TradeAmount = decimal.Parse(selfDr[2].ToString());
  446. HelpProfitMerIds merIds = db.HelpProfitMerIds.FirstOrDefault(m => m.MerchantId == MerchantId) ?? new HelpProfitMerIds();
  447. bool Check = CheckAmount(db, MerchantId, merIds.UserId, TradeMonth);
  448. if (Check)
  449. {
  450. HelpProfitMerTradeSummay selfStat = db.HelpProfitMerTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate);
  451. if (selfStat == null)
  452. {
  453. selfStat = db.HelpProfitMerTradeSummay.Add(new HelpProfitMerTradeSummay()
  454. {
  455. TradeMonth = TradeMonth,
  456. TradeDate = TradeDate,
  457. MerchantId = MerchantId,
  458. }).Entity;
  459. db.SaveChanges();
  460. }
  461. decimal MoreAmount = TradeAmount * 0.01M;
  462. MoreAmount = decimal.Parse(function.CheckInt(MoreAmount.ToString().Split(".")[0]));
  463. selfStat.TradeAmount = TradeAmount + MoreAmount;
  464. }
  465. }
  466. }
  467. db.SaveChanges();
  468. }
  469. tran.Commit();
  470. }
  471. catch (Exception ex)
  472. {
  473. tran.Rollback();
  474. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行助利宝交易额异常");
  475. }
  476. }
  477. db.Dispose();
  478. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行助利宝交易额日志");
  479. }
  480. }
  481. }