SycnSpTradeService.cs 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547
  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. if (Utils.PushTimeCheck())
  28. {
  29. List<string> BrandIds = new List<string>();
  30. BrandIds.Add("14");
  31. BrandIds.Add("17");
  32. BrandIds.Add("23");
  33. BrandIds.Add("24");
  34. BrandIds.Add("25");
  35. BrandIds.Add("26");
  36. BrandIds.Add("32");
  37. List<string> SaveDataBindIds = Utils.Instance.SaveDataBindIds();
  38. WebCMSEntities spdb = new WebCMSEntities();
  39. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  40. JavaProductModels.WebCMSEntities pdb = new JavaProductModels.WebCMSEntities();
  41. DateTime start = DateTime.Now.AddDays(-60);
  42. DateTime end = DateTime.Now.AddMinutes(-3);
  43. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  44. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && !BrandIds.Contains(m.ProductType) && SaveDataBindIds.Contains(m.ProductType) && m.CreateDate >= start && m.Status == 1).OrderBy(m => m.CreateDate).Take(20);
  45. foreach (TradeRecord trade in trades.ToList())
  46. {
  47. DoQueueTrade(db, pdb, trade);
  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. spdb.Dispose();
  56. db.Dispose();
  57. pdb.Dispose();
  58. }
  59. }
  60. catch (Exception ex)
  61. {
  62. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  63. }
  64. Thread.Sleep(500);
  65. }
  66. }
  67. public void DoQueueTrade(PxcModels.WebCMSEntities db, JavaProductModels.WebCMSEntities pdb, TradeRecord trade)
  68. {
  69. string TradeSnNo = trade.TradeSnNo;
  70. if (trade.ProductType == "30" && !trade.TradeSnNo.StartsWith("LKLYSMZCFYH"))
  71. {
  72. trade.MerNo = trade.Field2;
  73. }
  74. bool op = true;
  75. //判断盒易付吱码交易
  76. if (trade.ProductType == "12" && trade.TradeType == "2")
  77. {
  78. JavaProductModels.KxsMerchant merchant = pdb.KxsMerchant.FirstOrDefault(m => m.MerchantNo == trade.MerNo);
  79. if (merchant != null)
  80. {
  81. JavaProductModels.KxsMachine pos = pdb.KxsMachine.FirstOrDefault(m => m.Id == merchant.MachineId);
  82. if (pos != null)
  83. {
  84. trade.TradeSnNo = pos.PosSn;
  85. }
  86. }
  87. }
  88. if (trade.SerEntryMode == "N" && trade.ProductType == "1") //金控押金获取
  89. {
  90. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  91. {
  92. op = false;
  93. PosPushDataNewHelper.Deposit(trade);
  94. }
  95. }
  96. else if (trade.SerEntryMode == "1" && trade.ProductType == "27") //金控押金获取
  97. {
  98. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  99. {
  100. op = false;
  101. PosPushDataNewHelper.Deposit(trade);
  102. }
  103. }
  104. else if ((trade.ProductType == "4" || trade.ProductType == "8" || trade.ProductType == "9") && (trade.ErrorCode == "5200" || trade.ErrorCode == "5800")) //乐刷海科费率0.52,0.58的不入库
  105. {
  106. op = false;
  107. }
  108. else if (trade.SerEntryMode == "1" && trade.ProductType == "10") //联动押金获取
  109. {
  110. if (trade.TradeAmount == 99 || trade.TradeAmount == 199 || trade.TradeAmount == 299)
  111. {
  112. op = false;
  113. PosPushDataNewHelper.Deposit(trade);
  114. }
  115. }
  116. else if (trade.SerEntryMode == "40" && trade.ProductType == "12") //盒易付押金获取
  117. {
  118. if (trade.TradeAmount == 99 || trade.TradeAmount == 199 || trade.TradeAmount == 299)
  119. {
  120. op = false;
  121. PosPushDataNewHelper.Deposit(trade);
  122. //创业帮押金数据推送
  123. string conn = ConfigurationManager.AppSettings["PushSqlConnStr"].ToString();
  124. CustomerSqlConn.op("INSERT INTO `u_kxs_trade_info_" + trade.CreateDate.Value.ToString("yyyyMM") + "` (`user_id`, `cash_flag`, `merch_no`, `agent_id`, `pos_sn`, `order_id`, `amount`, `trans_time`, `card_type`, `pay_type`) VALUES (123005, 1, '" + trade.MerNo + "', '01', '" + trade.TradeSnNo + "', '" + trade.TradeSerialNo + "', " + trade.TradeAmount + ", '" + trade.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + "', 1, 0);", conn);
  125. }
  126. }
  127. else if (trade.SettleFee == 0 && trade.ProductType == "15") //联客宝押金获取
  128. {
  129. if (trade.TradeAmount == 99 || trade.TradeAmount == 199 || trade.TradeAmount == 299)
  130. {
  131. op = false;
  132. }
  133. }
  134. else if (trade.Field2 == "1590" && trade.ProductType == "22") //立刷微智能押金获取
  135. {
  136. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  137. {
  138. PosPushDataNewHelper.Deposit(trade);
  139. op = false;
  140. }
  141. }
  142. else if (trade.SerEntryMode == "DEPOSIT" && trade.ProductType == "30") //拉卡拉押金获取
  143. {
  144. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  145. {
  146. op = false;
  147. if (trade.ProductType == "30")
  148. {
  149. PxcModels.LklMerNo mer = db.LklMerNo.FirstOrDefault(m => m.ExtMerNo == trade.MerNo);
  150. if (mer != null)
  151. {
  152. trade.MerNo = mer.MerNo;
  153. }
  154. }
  155. PosPushDataNewHelper.Deposit(trade);
  156. }
  157. }
  158. else if (trade.SerEntryMode == "MACHINE" && trade.ProductType == "34") //联动掌中宝押金获取
  159. {
  160. PosPushDataNewHelper.Deposit(trade);
  161. op = false;
  162. }
  163. else if (trade.BankCardType == "11" && trade.ProductType == "38") //国通星驿付押金获取
  164. {
  165. PosPushDataNewHelper.Deposit(trade);
  166. op = false;
  167. }
  168. if (trade.DiscountRateFlag == "True")
  169. {
  170. op = false;
  171. }
  172. if (trade.ProductType == "7" && trade.TradeStatus != "00")
  173. {
  174. op = false;
  175. }
  176. if (trade.ProductType == "34" && trade.TradeStatus != "SUCCESS")
  177. {
  178. op = false;
  179. }
  180. if (op)
  181. {
  182. bool check = db.SpOrderNos.Any(m => m.OrderNo == trade.TradeSerialNo);
  183. if (!check)
  184. {
  185. PosPushDataNewHelper.Trade(trade);
  186. //创业帮交易数据推送
  187. if (trade.ProductType == "12")
  188. {
  189. int BankCardType = 1;
  190. if (trade.BankCardType == "C")
  191. {
  192. BankCardType = 1;
  193. }
  194. else if (trade.BankCardType == "D")
  195. {
  196. BankCardType = 0;
  197. }
  198. string conn = ConfigurationManager.AppSettings["PushSqlConnStr"].ToString();
  199. CustomerSqlConn.op("INSERT INTO `u_kxs_trade_info_" + trade.CreateDate.Value.ToString("yyyyMM") + "` (`user_id`, `cash_flag`, `merch_no`, `agent_id`, `pos_sn`, `order_id`, `amount`, `trans_time`, `card_type`, `pay_type`) VALUES (123005, 0, '" + trade.MerNo + "', '01', '" + trade.TradeSnNo + "', '" + trade.TradeSerialNo + "', " + trade.TradeAmount + ", '" + trade.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + "', " + BankCardType + ", 0);", conn);
  200. }
  201. }
  202. }
  203. }
  204. public void StartSim()
  205. {
  206. Thread th = new Thread(StartSimDo);
  207. th.IsBackground = true;
  208. th.Start();
  209. }
  210. public void StartSimDo()
  211. {
  212. while (true)
  213. {
  214. try
  215. {
  216. if (Utils.PushTimeCheck())
  217. {
  218. List<string> SaveDataBindIds = Utils.Instance.SaveDataBindIds();
  219. WebCMSEntities spdb = new WebCMSEntities();
  220. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  221. DateTime start = DateTime.Now.AddDays(-40);
  222. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  223. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && m.ProductType == "14" && SaveDataBindIds.Contains(m.ProductType) && m.CreateDate >= start && m.Status == 1).OrderBy(m => m.CreateDate).Take(20);
  224. foreach (TradeRecord trade in trades.ToList())
  225. {
  226. PosPushDataNewHelper.Trade(trade);
  227. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  228. if (edit != null)
  229. {
  230. edit.Status = 2;
  231. }
  232. spdb.SaveChanges();
  233. }
  234. spdb.Dispose();
  235. db.Dispose();
  236. }
  237. }
  238. catch (Exception ex)
  239. {
  240. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  241. }
  242. Thread.Sleep(500);
  243. }
  244. }
  245. public void StartTradeStatus()
  246. {
  247. Thread th = new Thread(StartTradeStatusDo);
  248. th.IsBackground = true;
  249. th.Start();
  250. }
  251. public void StartTradeStatusDo()
  252. {
  253. while (true)
  254. {
  255. try
  256. {
  257. List<string> SaveDataBindIds = Utils.Instance.SaveDataBindIds();
  258. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  259. WebCMSEntities spdb = new WebCMSEntities();
  260. DateTime start = DateTime.Now.AddDays(-10);
  261. DateTime end = DateTime.Now.AddMinutes(-10);
  262. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  263. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && m.CreateDate >= start && m.CreateDate < end && SaveDataBindIds.Contains(m.ProductType) && m.Status == 0).OrderBy(m => m.CreateDate).Take(20);
  264. foreach (TradeRecord trade in trades.ToList())
  265. {
  266. int Status = 1;
  267. bool op = db.PosMachinesTwo.Any(m => m.PosSn == trade.TradeSnNo);
  268. if (!op)
  269. {
  270. Status = -1;
  271. }
  272. else
  273. {
  274. op = db.PosMerchantInfo.Any(m => m.KqSnNo == trade.TradeSnNo);
  275. if (!op)
  276. {
  277. Status = -2;
  278. }
  279. }
  280. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  281. if (edit != null)
  282. {
  283. edit.Status = Status;
  284. spdb.SaveChanges();
  285. }
  286. }
  287. db.Dispose();
  288. spdb.Dispose();
  289. }
  290. catch (Exception ex)
  291. {
  292. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "恢复原始交易没有统计上的数据异常");
  293. }
  294. Thread.Sleep(10000);
  295. }
  296. }
  297. //机具激活逻辑
  298. public void ActPos(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, decimal CheckMoney, int CheckDays, bool PrizeFlag = true, string ActivationTime = "")
  299. {
  300. DateTime now = DateTime.Now;
  301. if (!string.IsNullOrEmpty(ActivationTime))
  302. {
  303. now = DateTime.Parse(ActivationTime);
  304. }
  305. DateTime TransferTime = pos.TransferTime == null ? DateTime.Parse("2050-01-01") : pos.TransferTime.Value;
  306. int minute = 30;
  307. if (pos.BrandId == 14 && pos.PosSn.StartsWith("CS"))
  308. {
  309. minute = 60 * 24 * 30;
  310. }
  311. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满" + CheckMoney + ";贷记卡交易:" + pos.CreditTrade + "");
  312. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否有机具所属人;机具所属人Id:" + pos.BuyUserId + "");
  313. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否未激活;机具激活状态:" + pos.ActivationState + "");
  314. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:划拨时间不能超过绑定时间" + minute + "分钟;划拨时间:" + TransferTime.ToString() + ",绑定时间:" + pos.BindingTime.Value.ToString());
  315. if (pos.CreditTrade >= CheckMoney && pos.BuyUserId > 0 && pos.ActivationState == 0 && TransferTime.AddMinutes(-minute) < pos.BindingTime)
  316. {
  317. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件");
  318. pos.ActivationState = 1;
  319. pos.ActivationTime = now;
  320. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否营训");
  321. if (pos.CardType == 101)
  322. {
  323. Utils.Instance.PrizeRecord(1, pos.PosSn, "是营训");
  324. pos.IsPurchase = 1;
  325. Utils.Instance.PrizeRecord(1, pos.PosSn, "取消循环资格");
  326. }
  327. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否关联商户信息");
  328. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  329. if (merchant != null)
  330. {
  331. merchant.ActiveStatus = 1;
  332. merchant.MerStandardDate = now;
  333. db.SaveChanges();
  334. if (pos.BrandId != 14)
  335. {
  336. //发放奖励MQ
  337. PrizeSetHelper.Do("1", pos.PosSn);
  338. }
  339. Utils.Instance.PrizeRecord(1, pos.PosSn, "已关联");
  340. //发放开机奖励
  341. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;当前绑定时间:" + pos.BindingTime.ToString() + "");
  342. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  343. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:奖励开关;当前:" + PrizeFlag);
  344. if (pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  345. {
  346. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放开机奖励");
  347. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  348. if (pos.BrandId == 14)
  349. {
  350. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  351. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  352. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  353. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  354. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  355. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  356. if (pos.LeaderUserId > 0 && ExpiredDate > now)
  357. {
  358. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  359. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  360. }
  361. }
  362. }
  363. }
  364. //发放大盟主奖励
  365. decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  366. if (pos.BrandId != 14)
  367. {
  368. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:有押金;当前押金:" + Deposit);
  369. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  370. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  371. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  372. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  373. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  374. }
  375. if (Deposit > 0 && pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  376. {
  377. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  378. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  379. }
  380. //发放运营中心奖励
  381. if (Deposit > 0 && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  382. {
  383. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  384. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  385. }
  386. if (pos.CardType < 100)
  387. {
  388. //统计激活数
  389. RedisDbconn.Instance.AddList("StatActQueue", "{\"TradeDate\":\"" + now.ToString("yyyyMMdd") + "\",\"UserId\":\"" + pos.BuyUserId + "\",\"BrandId\":\"" + pos.BrandId + "\"}");
  390. //运营中心额度变更
  391. OpAmountItem item = new OpAmountItem()
  392. {
  393. UserId = pos.OpId,
  394. OperateType = 1,
  395. ChangeType = 9,
  396. Remark = "机具激活",
  397. UseAmount = pos.OpReserve1 + pos.OpReserve2 + pos.OpReserve3,
  398. UseValidForGetAmount = pos.OpReserve2,
  399. UseTotalAmt = pos.OpReserve1,
  400. UseValidAmount = pos.OpReserve3,
  401. DataType = 2,
  402. DataId = pos.Id,
  403. };
  404. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  405. }
  406. //清理预扣款
  407. RedisDbconn.Instance.AddList("PosWithholdQueue", "{\"UserId\":\"" + pos.BuyUserId + "\",\"SnNo\":\"" + pos.PosSn + "\"}");
  408. //推送激活数据
  409. if (Deposit == 0) Utils.Instance.SendActData(pos);
  410. }
  411. else if (pos.ActivationState == 1 && pos.BrandId == 14)
  412. {
  413. if (pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  414. {
  415. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  416. if (pos.BrandId == 14)
  417. {
  418. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  419. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  420. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  421. if (pos.LeaderUserId > 0 && ExpiredDate > now)
  422. {
  423. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  424. }
  425. }
  426. }
  427. }
  428. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:已激活;当前状态:" + pos.ActivationState);
  429. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定后台30天到60天之间;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  430. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满10000;贷记卡交易:" + pos.CreditTrade + "");
  431. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  432. if (pos.ActivationState == 1 && pos.BindingTime.Value.AddDays(30) <= DateTime.Now && pos.BindingTime.Value.AddDays(60) > DateTime.Now && pos.CreditTrade >= 10000 && pos.CardType < 100)
  433. {
  434. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放盟主开机奖励");
  435. RedisDbconn.Instance.AddList("LeaderRewardQueue", pos.Id.ToString());
  436. //发放奖励MQ
  437. PrizeSetHelper.Do("1", pos.PosSn);
  438. }
  439. }
  440. //立刷格外奖励
  441. public void LiShuaActPrize(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, int prize)
  442. {
  443. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  444. if (merchant != null)
  445. {
  446. PxcModels.Users getUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users();
  447. int BuyTopUserId = 0;
  448. string ParentNav = getUser.ParentNav;
  449. if (!string.IsNullOrEmpty(ParentNav))
  450. {
  451. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  452. if (ParentNavList.Length > 1)
  453. {
  454. BuyTopUserId = int.Parse(ParentNavList[1]);
  455. }
  456. else if (ParentNavList.Length == 1)
  457. {
  458. BuyTopUserId = int.Parse(ParentNavList[0]);
  459. }
  460. }
  461. if (prize == 50)
  462. {
  463. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize);
  464. }
  465. if (prize == 40)
  466. {
  467. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 12);
  468. }
  469. if (prize == 30)
  470. {
  471. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 133);
  472. }
  473. }
  474. }
  475. private int GetLeShuaHaiKe(int UserId, int BrandId)
  476. {
  477. if (DateTime.Now >= DateTime.Parse("2023-08-01 00:00:00"))
  478. {
  479. return 0;
  480. }
  481. int ActStatus = 1;
  482. try
  483. {
  484. string Date = DateTime.Now.ToString("yyyyMMdd");
  485. int checkNum = 0;
  486. if (Date == "20230720") checkNum = 12;
  487. if (Date == "20230721") checkNum = 11;
  488. if (Date == "20230722") checkNum = 10;
  489. if (Date == "20230723") checkNum = 9;
  490. if (Date == "20230724") checkNum = 8;
  491. if (Date == "20230725") checkNum = 7;
  492. if (Date == "20230726") checkNum = 6;
  493. if (Date == "20230727") checkNum = 5;
  494. if (Date == "20230728") checkNum = 4;
  495. if (Date == "20230729") checkNum = 3;
  496. if (Date == "20230730") checkNum = 2;
  497. if (Date == "20230731") checkNum = 1;
  498. int check = int.Parse(function.CheckInt(RedisDbconn.Instance.Get<string>("lscut:" + UserId + ":" + BrandId + ":" + Date)));
  499. if (check <= checkNum)
  500. {
  501. check += 1;
  502. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, check.ToString());
  503. }
  504. else
  505. {
  506. ActStatus = -1;
  507. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, "0");
  508. }
  509. }
  510. catch (Exception ex)
  511. {
  512. Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "乐刷海科计数异常");
  513. }
  514. return ActStatus;
  515. }
  516. }
  517. }