SycnSpTradeService.cs 31 KB

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