SycnSpTradeService.cs 37 KB

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