StatResetService.cs 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366
  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 StatResetService
  12. {
  13. public readonly static StatResetService Instance = new StatResetService();
  14. private StatResetService()
  15. { }
  16. public void StartReset()
  17. {
  18. Thread th = new Thread(StartResetMerchantDo);
  19. th.IsBackground = true;
  20. th.Start();
  21. Thread thUser = new Thread(StartResetUserSelfDo);
  22. thUser.IsBackground = true;
  23. thUser.Start();
  24. Thread thUserTeam = new Thread(StartResetUserTeamDo);
  25. thUserTeam.IsBackground = true;
  26. thUserTeam.Start();
  27. Thread thSn = new Thread(StartResetSnDo);
  28. thSn.IsBackground = true;
  29. thSn.Start();
  30. }
  31. public void StartResetMerchantDo()
  32. {
  33. while (true)
  34. {
  35. string content = RedisDbconn.Instance.RPop<string>("ResetMerchantStatDataQueue");
  36. if (!string.IsNullOrEmpty(content))
  37. {
  38. StatResetMerchantAmount(content);
  39. }
  40. Thread.Sleep(10000);
  41. }
  42. }
  43. public void StatResetMerchantAmount(string content)
  44. {
  45. JsonData jsonObj = JsonMapper.ToObject(content);
  46. string merchantId = jsonObj["MerchantId"].ToString();
  47. string startDate = jsonObj["StartDate"].ToString();
  48. string endDate = jsonObj["EndDate"].ToString();
  49. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置商户交易额日志");
  50. WebCMSEntities db = new WebCMSEntities();
  51. MySystem.KxsMainModels.WebCMSEntities kxsdb = new MySystem.KxsMainModels.WebCMSEntities();
  52. var merId = int.Parse(merchantId);
  53. var merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == merId) ?? new MerchantInfo();
  54. var order = db.ConsumerOrders.Where(m => m.MerchantId == merchant.Id && m.Status > 0).ToList();
  55. merchant.TotalConsumeCount = order.Count();
  56. merchant.TotalAmount = order.Sum(m => m.PayMoney);
  57. merchant.TotalActual = order.Sum(m => m.MerchantActualAmount);
  58. merchant.TotalActAmount = order.Where(m => m.IsAct == 1).Sum(m => m.PayMoney);
  59. merchant.TotalActActual = order.Where(m => m.IsAct == 1).Sum(m => m.MerchantActualAmount);
  60. db.SaveChanges();
  61. var user = kxsdb.Users.FirstOrDefault(m => m.Id == merchant.UserId) ?? new KxsMainModels.Users();
  62. var ParentNavs = user.ParentNav + "," + user.Id;
  63. string[] ParentNavList = ParentNavs.Trim(',').Replace(",,", ",").Split(',');
  64. var ParentNav = ParentNavs.Trim(',').Replace(",,", ",").TrimEnd(',');
  65. var SnNos = "";
  66. DataTable SnNoInfo = CustomerSqlConn.dtable("SELECT SnNo FROM ConsumerOrders WHERE Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' GROUP BY SnNo", AppConfig.Base.SqlConn);
  67. if (SnNoInfo.Rows.Count > 0)
  68. {
  69. foreach (DataRow selfDr in SnNoInfo.Rows)
  70. {
  71. SnNos += "'" + selfDr["SnNo"].ToString() + "'" + ",";
  72. }
  73. SnNos = SnNos.TrimEnd(',');
  74. }
  75. try
  76. {
  77. for (DateTime start = DateTime.Parse(startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2)); start <= DateTime.Parse(endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2)); start = start.AddDays(1))
  78. {
  79. var date = start.ToString("yyyy-MM-dd");
  80. var smonth = start.ToString("yyyy-MM");
  81. var emonth = start.AddMonths(1).ToString("yyyy-MM");
  82. ResetMerchantTrade(date, merchantId);
  83. CustomerSqlConn.op("delete from UserAmountSummary where UserId in(" + ParentNav + ") and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn);
  84. CustomerSqlConn.op("INSERT INTO UserAmountSummary (SeoTitle,PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct) select 'self' SeoTitle,PayMode,SUM(PayMoney) TotalAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate, " + merchant.UserId + " UserId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  85. for (int a = 0; a < ParentNavList.Length; a++)
  86. {
  87. var UserId = ParentNavList[a];
  88. CustomerSqlConn.op("INSERT INTO UserAmountSummary (SeoTitle,PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct) select 'team' SeoTitle,PayMode,SUM(PayMoney) TotalAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate, " + UserId + " UserId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  89. }
  90. CustomerSqlConn.op("delete from QrCodeAmountSummay where SnNo IN (" + SnNos + ") and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn);
  91. CustomerSqlConn.op("INSERT INTO QrCodeAmountSummay (IsAct,TradeCount,PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,SnNo) SELECT IsAct,TradeCount,PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,SnNo FROM(SELECT PayMode, sum(MerchantActualAmount) TotalActual, sum(PayMoney) TradeAmount, DATE_FORMAT(CreateDate, '%Y%m%d') TradeDate, DATE_FORMAT(CreateDate, '%Y%m') TradeMonth, MerchantId, count(Id) TradeCount, IsAct, SnNo FROM ConsumerOrders WHERE Status > 0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' GROUP BY MerchantId, PayMode, IsAct, SnNo, DATE_FORMAT(CreateDate, '%Y%m%d'), DATE_FORMAT(CreateDate, '%Y%m'))a", AppConfig.Base.SqlConn);
  92. CustomerSqlConn.op("delete from QrCodePlateStatServer.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + "", AppConfig.Base.StatSqlConn);
  93. CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " (MerchantId,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount,TradeMonth) select MerchantId,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + smonth + "-01" + " 00:00:00' and CreateDate<'" + emonth + "-01" + " 00:00:00' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  94. CustomerSqlConn.op("delete from QrCodePlateStatServer.MerchantTradeSummaryList" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + " and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.StatSqlConn);
  95. CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer.MerchantTradeSummaryList" + date.Replace("-", "").Substring(0, 6) + " (MerchantId,TradeDate,TradeMonth,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount) select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d') Date ,DATE_FORMAT(CreateDate,'%Y%m') Month,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  96. }
  97. }
  98. catch (Exception ex)
  99. {
  100. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置商户交易额异常");
  101. }
  102. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置商户交易额日志");
  103. }
  104. public void ResetMerchantTrade(string date, string merchantId = "0")
  105. {
  106. string MerchantCondition = "";
  107. if(merchantId != "0")
  108. {
  109. MerchantCondition = "MerchantId=" + merchantId + " and ";
  110. }
  111. CustomerSqlConn.op("delete from QrCodePlateStatServer.MerchantTradeSummary" + date.Replace("-", "") + " where " + MerchantCondition + "TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.StatSqlConn);
  112. CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer.MerchantTradeSummary" + date.Replace("-", "") + " (MerchantId,TradeDate,TradeMonth,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount) select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d') Date ,DATE_FORMAT(CreateDate,'%Y%m') Month,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount from ConsumerOrders where Status>0 AND " + MerchantCondition + "CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  113. CustomerSqlConn.op("delete from MerchantAmountSummay where " + MerchantCondition + "TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn);
  114. CustomerSqlConn.op("INSERT INTO MerchantAmountSummay (PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,MerchantId,TradeCount,IsAct) select PayMode,sum(MerchantActualAmount) TotalActual,sum(PayMoney) TradeAmount,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,MerchantId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND " + MerchantCondition + "CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn);
  115. }
  116. public void StartResetSnDo()
  117. {
  118. while (true)
  119. {
  120. string content = RedisDbconn.Instance.RPop<string>("ResetSnStatDataQueue");
  121. if (!string.IsNullOrEmpty(content))
  122. {
  123. StatResetSnAmount(content);
  124. }
  125. Thread.Sleep(10000);
  126. }
  127. }
  128. public void StatResetSnAmount(string content)
  129. {
  130. JsonData jsonObj = JsonMapper.ToObject(content);
  131. string snNo = jsonObj["SnNo"].ToString();
  132. string startDate = jsonObj["StartDate"].ToString();
  133. string endDate = jsonObj["EndDate"].ToString();
  134. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置码牌交易额日志");
  135. WebCMSEntities db = new WebCMSEntities();
  136. KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
  137. using (var tran = db.Database.BeginTransaction())
  138. {
  139. try
  140. {
  141. DataTable selfDt = CustomerSqlConn.dtable("select SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MerchantActualAmount) from ConsumerOrders where SnNo=" + snNo + " and CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' group by SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn);
  142. if (selfDt.Rows.Count > 0)
  143. {
  144. Utils.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置码牌交易额日志");
  145. foreach (DataRow selfDr in selfDt.Rows)
  146. {
  147. int PayMode = int.Parse(selfDr["PayMode"].ToString());
  148. int IsAct = int.Parse(selfDr["IsAct"].ToString());
  149. string SnNo = selfDr["SnNo"].ToString();
  150. string TradeDate = selfDr[3].ToString();
  151. decimal TradeAmount = decimal.Parse(selfDr[4].ToString());
  152. int TradeCount = int.Parse(selfDr[5].ToString());
  153. decimal ActualAmount = decimal.Parse(selfDr[6].ToString());
  154. string TradeMonth = TradeDate.Substring(0, 6);
  155. //码牌交易额
  156. QrCodeAmountSummay qrcode = db.QrCodeAmountSummay.FirstOrDefault(m => m.SnNo == SnNo && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
  157. if (qrcode == null)
  158. {
  159. qrcode = db.QrCodeAmountSummay.Add(new QrCodeAmountSummay()
  160. {
  161. SnNo = SnNo,
  162. TradeMonth = TradeMonth,
  163. TradeDate = TradeDate,
  164. PayMode = PayMode,
  165. IsAct = IsAct,
  166. }).Entity;
  167. db.SaveChanges();
  168. }
  169. qrcode.TradeAmount += TradeAmount;
  170. qrcode.TradeCount += TradeCount;
  171. qrcode.TotalActual += ActualAmount;
  172. db.SaveChanges();
  173. }
  174. }
  175. tran.Commit();
  176. }
  177. catch (Exception ex)
  178. {
  179. tran.Rollback();
  180. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置码牌交易额异常");
  181. }
  182. }
  183. db.Dispose();
  184. maindb.Dispose();
  185. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置码牌交易额日志");
  186. }
  187. public void StartResetUserSelfDo()
  188. {
  189. while (true)
  190. {
  191. string content = RedisDbconn.Instance.RPop<string>("ResetUserSelfStatDataQueue");
  192. if (!string.IsNullOrEmpty(content))
  193. {
  194. StatResetUserSelfAmount(content);
  195. }
  196. Thread.Sleep(10000);
  197. }
  198. }
  199. public void StatResetUserSelfAmount(string content)
  200. {
  201. JsonData jsonObj = JsonMapper.ToObject(content);
  202. string userId = jsonObj["UserId"].ToString();
  203. string startDate = jsonObj["StartDate"].ToString();
  204. string endDate = jsonObj["EndDate"].ToString();
  205. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置创客个人交易额日志");
  206. WebCMSEntities db = new WebCMSEntities();
  207. KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
  208. using (var tran = db.Database.BeginTransaction())
  209. {
  210. try
  211. {
  212. DataTable selfDt = CustomerSqlConn.dtable("select UserId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id) from ConsumerOrders where UserId=" + userId + " and CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' group by UserId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn);
  213. if (selfDt.Rows.Count > 0)
  214. {
  215. Utils.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置创客个人交易额日志");
  216. foreach (DataRow selfDr in selfDt.Rows)
  217. {
  218. int UserId = int.Parse(selfDr["UserId"].ToString());
  219. KxsMainModels.Users user = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new KxsMainModels.Users();
  220. int PayMode = int.Parse(selfDr["PayMode"].ToString());
  221. int IsAct = int.Parse(selfDr["IsAct"].ToString());
  222. string TradeDate = selfDr[3].ToString();
  223. decimal TradeAmount = decimal.Parse(selfDr[4].ToString());
  224. int TradeCount = int.Parse(selfDr[5].ToString());
  225. string TradeMonth = TradeDate.Substring(0, 6);
  226. //创客交易额
  227. UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self");
  228. if (selfStat == null)
  229. {
  230. selfStat = db.UserAmountSummary.Add(new UserAmountSummary()
  231. {
  232. UserId = UserId,
  233. TradeMonth = TradeMonth,
  234. TradeDate = TradeDate,
  235. PayMode = PayMode,
  236. IsAct = IsAct,
  237. SeoTitle = "self",
  238. }).Entity;
  239. db.SaveChanges();
  240. }
  241. selfStat.TotalAmount = TradeAmount;
  242. selfStat.TradeCount = TradeCount;
  243. db.SaveChanges();
  244. string ParentNav = user.ParentNav + "," + userId + ",";
  245. if (!string.IsNullOrEmpty(ParentNav))
  246. {
  247. string[] ParentNavList = ParentNav.Replace(",,", ",").Trim(',').Split(',');
  248. foreach (string id in ParentNavList)
  249. {
  250. string reqdata = "{\"UserId\":\"" + id + "\",\"StartDate\":\"" + startDate + "\",\"EndDate\":\"" + endDate + "\"}";
  251. RedisDbconn.Instance.AddList("ResetUserTeamStatDataQueue", reqdata);
  252. }
  253. }
  254. }
  255. }
  256. tran.Commit();
  257. }
  258. catch (Exception ex)
  259. {
  260. tran.Rollback();
  261. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置创客个人交易额异常");
  262. }
  263. }
  264. db.Dispose();
  265. maindb.Dispose();
  266. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置创客个人交易额日志");
  267. }
  268. public void StartResetUserTeamDo()
  269. {
  270. while (true)
  271. {
  272. string content = RedisDbconn.Instance.RPop<string>("ResetUserTeamStatDataQueue");
  273. if (!string.IsNullOrEmpty(content))
  274. {
  275. StatResetUserTeamAmount(content);
  276. }
  277. Thread.Sleep(10000);
  278. }
  279. }
  280. public void StatResetUserTeamAmount(string content)
  281. {
  282. JsonData jsonObj = JsonMapper.ToObject(content);
  283. int userId = int.Parse(jsonObj["UserId"].ToString());
  284. string startDate = jsonObj["StartDate"].ToString();
  285. string endDate = jsonObj["EndDate"].ToString();
  286. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置团队创客交易额日志");
  287. WebCMSEntities db = new WebCMSEntities();
  288. KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
  289. using (var tran = db.Database.BeginTransaction())
  290. {
  291. try
  292. {
  293. string subUserId = "0";
  294. var subusers = maindb.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == userId).ToList();
  295. foreach (var subuser in subusers)
  296. {
  297. subUserId += "," + subuser.Id;
  298. }
  299. DataTable selfDt = CustomerSqlConn.dtable("select PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct from UserAmountSummary where UserId in (" + subUserId + ") and TradeDate>='" + startDate + "' and TradeDate<='" + endDate + "' and SeoTitle='team'", AppConfig.Base.SqlConn);
  300. if (selfDt.Rows.Count > 0)
  301. {
  302. Utils.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置团队创客交易额日志");
  303. foreach (DataRow selfDr in selfDt.Rows)
  304. {
  305. int UserId = int.Parse(selfDr["UserId"].ToString());
  306. int PayMode = int.Parse(selfDr["PayMode"].ToString());
  307. int IsAct = int.Parse(selfDr["IsAct"].ToString());
  308. string TradeDate = selfDr["TradeDate"].ToString();
  309. decimal TradeAmount = decimal.Parse(selfDr["TotalAmount"].ToString());
  310. int TradeCount = int.Parse(selfDr["TradeCount"].ToString());
  311. string TradeMonth = selfDr["TradeMonth"].ToString();
  312. //创客交易额
  313. UserAmountSummary teamStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "Team");
  314. if (teamStat == null)
  315. {
  316. teamStat = db.UserAmountSummary.Add(new UserAmountSummary()
  317. {
  318. UserId = UserId,
  319. TradeMonth = TradeMonth,
  320. TradeDate = TradeDate,
  321. PayMode = PayMode,
  322. IsAct = IsAct,
  323. SeoTitle = "self",
  324. }).Entity;
  325. db.SaveChanges();
  326. }
  327. teamStat.TotalAmount = TradeAmount;
  328. teamStat.TradeCount = TradeCount;
  329. db.SaveChanges();
  330. }
  331. }
  332. tran.Commit();
  333. }
  334. catch (Exception ex)
  335. {
  336. tran.Rollback();
  337. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置团队创客交易额异常");
  338. }
  339. }
  340. db.Dispose();
  341. maindb.Dispose();
  342. Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置团队创客交易额日志");
  343. }
  344. }
  345. }