SycnSpTradeService.cs 26 KB

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