SycnSpTradeService.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474
  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 SycnSpTradeService
  11. {
  12. public readonly static SycnSpTradeService Instance = new SycnSpTradeService();
  13. private SycnSpTradeService()
  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. DateTime start = DateTime.Now.AddDays(-30);
  30. IQueryable<TradeRecord> trades = spdb.TradeRecord;
  31. trades = trades.Where(m => m.CreateDate >= start && m.Status == 1);
  32. trades = trades.OrderBy(m => m.CreateDate);
  33. foreach (TradeRecord trade in trades.ToList())
  34. {
  35. bool op = true;
  36. if (trade.SerEntryMode == "N")
  37. {
  38. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  39. {
  40. op = false;
  41. PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  42. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  43. if (pos != null)
  44. {
  45. if (trade.SerEntryMode == "N" && trade.ProductType == "1")
  46. {
  47. pos.SeoKeyword = trade.TradeAmount.ToString("f2");
  48. // pos.IsPurchase = 0;
  49. db.SaveChanges();
  50. }
  51. }
  52. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  53. if (edit != null)
  54. {
  55. edit.Status = 2;
  56. }
  57. spdb.SaveChanges();
  58. }
  59. }
  60. if (trade.DiscountRateFlag == "True")
  61. {
  62. op = false;
  63. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  64. if (edit != null)
  65. {
  66. edit.Status = 2;
  67. }
  68. spdb.SaveChanges();
  69. }
  70. if(trade.ProductType == "7" && trade.TradeStatus != "00")
  71. {
  72. op = false;
  73. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  74. if (edit != null)
  75. {
  76. edit.Status = 2;
  77. }
  78. spdb.SaveChanges();
  79. }
  80. if (op)
  81. {
  82. PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  83. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  84. if (pos != null)
  85. {
  86. if (pos.BindMerchantId > 0)
  87. {
  88. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  89. int TopUserId = 0;
  90. if (!string.IsNullOrEmpty(user.ParentNav))
  91. {
  92. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  93. }
  94. // TODO: 交易记录表,每月的Id单独存放,解决查询效率问题
  95. bool check = db.TradeRecord.Any(m => m.Id >= 700000 && m.RecordNo == trade.TradeSerialNo);
  96. if (!check)
  97. {
  98. decimal TradeAmount = trade.TradeAmount;
  99. int BankCardType = -1;
  100. int QrPayFlag = 0;
  101. int VipFlag = 0;
  102. int PayType = 0;
  103. if (pos.BrandId == 1 || pos.BrandId == 3)
  104. {
  105. TradeAmount = TradeAmount / 100;
  106. BankCardType = int.Parse(trade.BankCardType);
  107. if (trade.TradeType == "02") QrPayFlag = 1;
  108. else if (trade.TradeType == "NQ") PayType = 1;
  109. if (trade.SettleMethod == "E") VipFlag = 1;
  110. }
  111. else if (pos.BrandId == 2)
  112. {
  113. if (trade.TradeType == "CREDIT_BY_CARD")
  114. {
  115. BankCardType = 1;
  116. }
  117. else if (trade.TradeType == "DEBIT_BY_CARD")
  118. {
  119. BankCardType = 0;
  120. }
  121. if (trade.TradeType == "CLOUD_PAY") QrPayFlag = 1;
  122. }
  123. else if (pos.BrandId == 4 || pos.BrandId == 5)
  124. {
  125. TradeAmount = TradeAmount / 100;
  126. if (trade.BankCardType == "100")
  127. {
  128. BankCardType = 1;
  129. }
  130. else if (trade.BankCardType == "200")
  131. {
  132. BankCardType = 0;
  133. }
  134. if (trade.TradeType == "200") QrPayFlag = 1;
  135. if (trade.Field1 == "1") VipFlag = 1;
  136. }
  137. else if (pos.BrandId == 6)
  138. {
  139. TradeAmount = TradeAmount / 100;
  140. if (trade.BankCardType == "01" || trade.BankCardType == "11")
  141. {
  142. BankCardType = 0;
  143. }
  144. else
  145. {
  146. BankCardType = 1;
  147. }
  148. }
  149. else if (pos.BrandId == 7)
  150. {
  151. TradeAmount = TradeAmount / 100;
  152. if (trade.BankCardType == "OA" || trade.BankCardType == "CC" || trade.BankCardType == "SCC")
  153. {
  154. BankCardType = 1;
  155. }
  156. else
  157. {
  158. BankCardType = 0;
  159. }
  160. }
  161. int BrandId = int.Parse(trade.ProductType);
  162. if (BrandId == 1 && trade.MerNo.StartsWith("M900"))
  163. {
  164. BrandId = 3;
  165. }
  166. if (BrandId == 4 && trade.DeviceType == "200")
  167. {
  168. BrandId = 5;
  169. }
  170. decimal SourceTradeAmount = TradeAmount;
  171. if (pos.Sort == 0 && pos.BrandId == 7)
  172. {
  173. decimal deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  174. if (deposit > 0)
  175. {
  176. TradeAmount -= deposit;
  177. pos.Sort = 1;
  178. }
  179. }
  180. if (TradeAmount > 0)
  181. {
  182. ulong MerHelpFlag = 0;
  183. decimal DepositAmt = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  184. if (DepositAmt > 0)
  185. {
  186. int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + pos.BrandId + ":HelpPolicy:Days")); //天数
  187. if (pos.BindingTime != null)
  188. {
  189. if (pos.BindingTime.Value.AddDays(Days) > DateTime.Now)
  190. {
  191. MerHelpFlag = 1;
  192. }
  193. }
  194. }
  195. int CapFlag = 0;
  196. if(BankCardType == 0 && TradeAmount >= 1666.67M)
  197. {
  198. CapFlag = 1;
  199. }
  200. db.TradeRecord.Add(new PxcModels.TradeRecord()
  201. {
  202. CreateDate = trade.CreateDate,
  203. UpdateDate = trade.UpdateDate,
  204. RecordNo = trade.TradeSerialNo, //单号
  205. UserId = pos.UserId, //创客
  206. MerchantId = pos.BindMerchantId, //商户
  207. MerNo = trade.MerNo, //渠道商户编号
  208. MerHelpFlag = MerHelpFlag, //是否属于扶持周期内商户
  209. HelpMonthCount = 0, //扶持第几个月
  210. MerBuddyType = user.MerchantType, //商户创客类型
  211. SnNo = trade.TradeSnNo, //渠道SN号
  212. TradeSerialNo = trade.ChannelSerial, //交易流水号
  213. TradeAmount = TradeAmount, //交易金额
  214. BankCardType = BankCardType, //银行卡类型
  215. QrPayFlag = QrPayFlag, //云闪付标识
  216. CapFlag = CapFlag, //借记卡是否封顶
  217. VipFlag = VipFlag, //会员标记
  218. PayType = PayType, //支付方式
  219. BrandId = BrandId, //品牌
  220. Remark = trade.Remark, //备注
  221. TopUserId = TopUserId, //顶级创客
  222. MerUserId = pos.UserId, //商户直属创客
  223. ParentNav = user.ParentNav,
  224. });
  225. }
  226. decimal CheckMoney = 1000;
  227. int CheckDays = 30;
  228. if (pos.BrandId == 6)
  229. {
  230. CheckMoney = 5000;
  231. }
  232. if (BankCardType == 1 || (BankCardType == 2 && pos.BrandId == 1) || (BankCardType == 2 && pos.BrandId == 3))
  233. {
  234. pos.CreditTrade += SourceTradeAmount;
  235. }
  236. else if (BankCardType == 0)
  237. {
  238. pos.DebitCardTrade += TradeAmount;
  239. }
  240. // if (pos.CreditTrade < CheckMoney)
  241. // {
  242. // decimal deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  243. // if (deposit > 0 && pos.IsPurchase != 1)
  244. // {
  245. // pos.IsPurchase = 0;
  246. // }
  247. // }
  248. if (pos.CreditTrade >= CheckMoney && pos.ActivationState == 0 && pos.TransferTime < pos.BindingTime && pos.BindingTime > DateTime.Now.AddDays(-CheckDays))
  249. {
  250. // decimal deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  251. // if (deposit == 0 && pos.IsPurchase != 1)
  252. // {
  253. // pos.IsPurchase = 0;
  254. // }
  255. pos.ActivationState = 1;
  256. pos.ActivationTime = DateTime.Now;
  257. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  258. if (merchant != null)
  259. {
  260. merchant.ActiveStatus = 1;
  261. merchant.MerStandardDate = DateTime.Now;
  262. db.SaveChanges();
  263. RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
  264. }
  265. //发放大盟主奖励
  266. if(pos.LeaderUserId > 0)
  267. {
  268. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  269. }
  270. }
  271. // 立刷60天内刷满10000,再返40
  272. if (pos.BrandId == 6 && pos.ActivationState == 1 && pos.CreditTrade >= 10000 && pos.BindingTime > DateTime.Now.AddDays(-60))
  273. {
  274. // PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  275. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  276. if(merchant != null)
  277. {
  278. PxcModels.Users getUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users();
  279. int BuyTopUserId = 0;
  280. string ParentNav = getUser.ParentNav;
  281. if (!string.IsNullOrEmpty(ParentNav))
  282. {
  283. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  284. if (ParentNavList.Length > 1)
  285. {
  286. BuyTopUserId = int.Parse(ParentNavList[1]);
  287. }
  288. else if (ParentNavList.Length == 1)
  289. {
  290. BuyTopUserId = int.Parse(ParentNavList[0]);
  291. }
  292. }
  293. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, 40, 12);
  294. }
  295. }
  296. db.SaveChanges();
  297. }
  298. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  299. if (edit != null)
  300. {
  301. edit.Status = 2;
  302. }
  303. spdb.SaveChanges();
  304. }
  305. }
  306. }
  307. }
  308. spdb.Dispose();
  309. db.Dispose();
  310. }
  311. catch (Exception ex)
  312. {
  313. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  314. }
  315. Thread.Sleep(1000);
  316. }
  317. }
  318. public void StartTest()
  319. {
  320. DateTime today = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00");
  321. DateTime check = DateTime.Parse("2022-04-19");
  322. while (check <= today)
  323. {
  324. Thread th = new Thread(StartTestDo);
  325. th.IsBackground = true;
  326. th.Start(check.ToString("yyyy-MM-dd"));
  327. check = check.AddDays(1);
  328. }
  329. }
  330. public void StartTestDo(object sender)
  331. {
  332. string date = sender.ToString();
  333. DateTime start = DateTime.Parse(date);
  334. DateTime end = start.AddDays(1);
  335. try
  336. {
  337. WebCMSEntities spdb = new WebCMSEntities();
  338. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  339. IQueryable<TradeRecord> trades = spdb.TradeRecord;
  340. trades = trades.Where(m => m.CreateDate >= start && m.CreateDate < end);
  341. trades = trades.OrderBy(m => m.Id);
  342. foreach (TradeRecord trade in trades.ToList())
  343. {
  344. bool op = true;
  345. if (trade.SerEntryMode == "N")
  346. {
  347. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  348. {
  349. op = false;
  350. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  351. if (edit != null)
  352. {
  353. edit.Status = 2;
  354. }
  355. spdb.SaveChanges();
  356. }
  357. }
  358. if (trade.DiscountRateFlag == "True")
  359. {
  360. op = false;
  361. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  362. if (edit != null)
  363. {
  364. edit.Status = 2;
  365. }
  366. spdb.SaveChanges();
  367. }
  368. if (op)
  369. {
  370. PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  371. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  372. if (pos != null)
  373. {
  374. if (pos.BindMerchantId > 0)
  375. {
  376. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  377. int TopUserId = 0;
  378. if (!string.IsNullOrEmpty(user.ParentNav))
  379. {
  380. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  381. }
  382. bool check = db.TradeRecord.Any(m => m.RecordNo == trade.TradeSerialNo);
  383. if (!check)
  384. {
  385. decimal TradeAmount = trade.TradeAmount;
  386. int BankCardType = -1;
  387. int QrPayFlag = 0;
  388. if (pos.BrandId == 1 || pos.BrandId == 3)
  389. {
  390. TradeAmount = TradeAmount / 100;
  391. BankCardType = int.Parse(trade.BankCardType);
  392. if (trade.TradeType == "02") QrPayFlag = 1;
  393. }
  394. else if (pos.BrandId == 2)
  395. {
  396. if (trade.TradeType == "CREDIT_BY_CARD")
  397. {
  398. BankCardType = 1;
  399. }
  400. else if (trade.TradeType == "DEBIT_BY_CARD")
  401. {
  402. BankCardType = 0;
  403. }
  404. if (trade.TradeType == "CLOUD_PAY") QrPayFlag = 1;
  405. }
  406. else if (pos.BrandId == 4 || pos.BrandId == 5)
  407. {
  408. TradeAmount = TradeAmount / 100;
  409. if (trade.BankCardType == "100")
  410. {
  411. BankCardType = 1;
  412. }
  413. else if (trade.BankCardType == "200")
  414. {
  415. BankCardType = 0;
  416. }
  417. if (trade.TradeType == "200") QrPayFlag = 1;
  418. }
  419. int BrandId = int.Parse(trade.ProductType);
  420. if (trade.MerNo.StartsWith("M900"))
  421. {
  422. BrandId = 3;
  423. }
  424. db.TradeRecord.Add(new PxcModels.TradeRecord()
  425. {
  426. CreateDate = trade.CreateDate,
  427. UpdateDate = trade.UpdateDate,
  428. RecordNo = trade.TradeSerialNo, //单号
  429. UserId = pos.UserId, //创客
  430. MerchantId = pos.BindMerchantId, //商户
  431. MerNo = trade.MerNo, //渠道商户编号
  432. MerHelpFlag = 0, //是否属于扶持周期内商户
  433. HelpMonthCount = 0, //扶持第几个月
  434. MerBuddyType = user.MerchantType, //商户创客类型
  435. SnNo = trade.TradeSnNo, //渠道SN号
  436. // TradeDate = DateTime.Parse(trade.TradeTime), //交易日期
  437. TradeSerialNo = trade.ChannelSerial, //交易流水号
  438. TradeAmount = TradeAmount, //交易金额
  439. BankCardType = BankCardType, //银行卡类型
  440. QrPayFlag = QrPayFlag, //云闪付标识
  441. BrandId = BrandId, //品牌
  442. Remark = trade.Remark, //备注
  443. TopUserId = TopUserId, //顶级创客
  444. MerUserId = pos.UserId, //商户直属创客
  445. });
  446. db.SaveChanges();
  447. }
  448. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  449. if (edit != null)
  450. {
  451. edit.Status = 2;
  452. }
  453. spdb.SaveChanges();
  454. }
  455. }
  456. }
  457. }
  458. spdb.Dispose();
  459. db.Dispose();
  460. }
  461. catch (Exception ex)
  462. {
  463. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  464. }
  465. }
  466. }
  467. }