SycnSpTradeService.cs 40 KB

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