SycnSpTradeService.cs 65 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077
  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. WebCMSEntities spdb = new WebCMSEntities();
  35. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  36. DateTime start = DateTime.Now.AddDays(-10);
  37. DateTime end = DateTime.Now.AddMinutes(-1);
  38. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  39. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && !BrandIds.Contains(m.ProductType) && m.CreateDate >= start && m.Status == 1).OrderBy(m => m.CreateDate).Take(20);
  40. foreach (TradeRecord trade in trades.ToList())
  41. {
  42. string TradeSnNo = trade.TradeSnNo;
  43. bool op = true;
  44. bool isDeposit = false;
  45. //判断盒易付吱码交易
  46. if(trade.ProductType == "12" && trade.TradeType == "2")
  47. {
  48. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == trade.MerNo);
  49. if(merchant != null)
  50. {
  51. TradeSnNo = merchant.KqSnNo;
  52. }
  53. }
  54. if (trade.SerEntryMode == "N" && trade.ProductType == "1") //金控押金获取
  55. {
  56. if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
  57. {
  58. op = false;
  59. PxcModels.MachineForSnNo posFor = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new PxcModels.MachineForSnNo();
  60. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  61. if (pos != null)
  62. {
  63. if(string.IsNullOrEmpty(pos.SeoKeyword)) Utils.Instance.SendActData(pos);
  64. pos.SeoKeyword = trade.TradeAmount.ToString("f2");
  65. db.SaveChanges();
  66. isDeposit = true;
  67. function.WriteLog("押金监控:" + trade.MerNo, "服务费奖励发放日志");
  68. }
  69. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  70. if (edit != null)
  71. {
  72. edit.Status = 2;
  73. }
  74. spdb.SaveChanges();
  75. }
  76. }
  77. else if ((trade.ProductType == "4" || trade.ProductType == "8" || trade.ProductType == "9") && (trade.Field2 == "5200" || trade.Field2 == "5800")) //乐刷海科费率0.52,0.58的不入库
  78. {
  79. op = false;
  80. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  81. if (edit != null)
  82. {
  83. edit.Status = 2;
  84. }
  85. spdb.SaveChanges();
  86. }
  87. else if (trade.SerEntryMode == "1" && trade.ProductType == "10") //联动押金获取
  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 == TradeSnNo) ?? new PxcModels.MachineForSnNo();
  93. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  94. if (pos != null)
  95. {
  96. if(string.IsNullOrEmpty(pos.SeoKeyword)) Utils.Instance.SendActData(pos);
  97. pos.SeoKeyword = trade.TradeAmount.ToString("f2");
  98. db.SaveChanges();
  99. isDeposit = true;
  100. function.WriteLog("押金监控:" + trade.MerNo, "服务费奖励发放日志");
  101. }
  102. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  103. if (edit != null)
  104. {
  105. edit.Status = 2;
  106. }
  107. spdb.SaveChanges();
  108. }
  109. }
  110. else if (trade.SerEntryMode == "40" && trade.ProductType == "12") //盒易付押金获取
  111. {
  112. if (trade.TradeAmount == 99 || trade.TradeAmount == 199 || trade.TradeAmount == 299)
  113. {
  114. op = false;
  115. PxcModels.MachineForSnNo posFor = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new PxcModels.MachineForSnNo();
  116. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  117. if (pos != null)
  118. {
  119. if(string.IsNullOrEmpty(pos.SeoKeyword)) Utils.Instance.SendActData(pos);
  120. pos.SeoKeyword = trade.TradeAmount.ToString("f2");
  121. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  122. db.MerchantDepositRecord.Add(new PxcModels.MerchantDepositRecord()
  123. {
  124. CreateDate = DateTime.Now,
  125. SnNo = pos.PosSn,
  126. MerNo = function.CheckNull(merchant.KqMerNo),
  127. DepositAmount = trade.TradeAmount,
  128. UserId = pos.BuyUserId,
  129. AgentNo = function.CheckNull(merchant.MgrNo),
  130. OrderId = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
  131. });
  132. db.SaveChanges();
  133. isDeposit = true;
  134. function.WriteLog("押金监控:" + trade.MerNo, "服务费奖励发放日志");
  135. }
  136. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  137. if (edit != null)
  138. {
  139. edit.Status = 2;
  140. }
  141. spdb.SaveChanges();
  142. }
  143. }
  144. else if (trade.TradeType == "40" && trade.ProductType == "15") //联客宝押金获取
  145. {
  146. if (trade.TradeAmount == 99 || trade.TradeAmount == 199 || trade.TradeAmount == 299)
  147. {
  148. op = false;
  149. PxcModels.MachineForSnNo posFor = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new PxcModels.MachineForSnNo();
  150. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  151. if (pos != null)
  152. {
  153. if(string.IsNullOrEmpty(pos.SeoKeyword)) Utils.Instance.SendActData(pos);
  154. pos.SeoKeyword = trade.TradeAmount.ToString("f2");
  155. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  156. db.MerchantDepositRecord.Add(new PxcModels.MerchantDepositRecord()
  157. {
  158. CreateDate = DateTime.Now,
  159. SnNo = pos.PosSn,
  160. MerNo = merchant.KqMerNo,
  161. DepositAmount = trade.TradeAmount,
  162. UserId = pos.BuyUserId,
  163. AgentNo = function.CheckNull(merchant.MgrNo),
  164. OrderId = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
  165. });
  166. db.SaveChanges();
  167. isDeposit = true;
  168. function.WriteLog("押金监控:" + trade.MerNo, "服务费奖励发放日志");
  169. }
  170. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  171. if (edit != null)
  172. {
  173. edit.Status = 2;
  174. }
  175. spdb.SaveChanges();
  176. }
  177. }
  178. if (trade.DiscountRateFlag == "True")
  179. {
  180. op = false;
  181. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  182. if (edit != null)
  183. {
  184. edit.Status = 2;
  185. }
  186. spdb.SaveChanges();
  187. }
  188. if(trade.ProductType == "7" && trade.TradeStatus != "00")
  189. {
  190. op = false;
  191. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  192. if (edit != null)
  193. {
  194. edit.Status = 2;
  195. }
  196. spdb.SaveChanges();
  197. }
  198. if (op)
  199. {
  200. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == TradeSnNo);
  201. if (pos != null)
  202. {
  203. PxcModels.KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new PxcModels.KqProducts();
  204. if (pos.BindMerchantId > 0)
  205. {
  206. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  207. int TopUserId = 0;
  208. if (!string.IsNullOrEmpty(user.ParentNav))
  209. {
  210. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  211. }
  212. bool check = db.SpOrderNos.Any(m => m.OrderNo == trade.TradeSerialNo);
  213. if (!check)
  214. {
  215. decimal TradeAmount = trade.TradeAmount;
  216. int BankCardType = -1;
  217. int QrPayFlag = 0;
  218. int VipFlag = 0;
  219. int PayType = 0;
  220. if (pos.BrandId == 1 || pos.BrandId == 3)
  221. {
  222. TradeAmount = TradeAmount / 100;
  223. BankCardType = int.Parse(trade.BankCardType);
  224. if (trade.TradeType == "02") QrPayFlag = 1;
  225. else if (trade.TradeType == "NQ") PayType = 1;
  226. if (trade.SettleMethod == "E") VipFlag = 1;
  227. }
  228. else if (pos.BrandId == 2)
  229. {
  230. if (trade.TradeType == "CREDIT_BY_CARD")
  231. {
  232. BankCardType = 1;
  233. }
  234. else
  235. {
  236. BankCardType = 0;
  237. }
  238. if (trade.TradeType == "CLOUD_PAY") QrPayFlag = 1;
  239. }
  240. else if (pos.BrandId == 4 || pos.BrandId == 5)
  241. {
  242. TradeAmount = TradeAmount / 100;
  243. if (trade.BankCardType == "100")
  244. {
  245. BankCardType = 1;
  246. }
  247. else if (trade.BankCardType == "200")
  248. {
  249. BankCardType = 0;
  250. }
  251. if (trade.TradeType == "200") QrPayFlag = 1;
  252. if (trade.Field1 == "1") VipFlag = 1;
  253. }
  254. else if (pos.BrandId == 6 || pos.BrandId == 22)
  255. {
  256. TradeAmount = TradeAmount / 100;
  257. if (trade.BankCardType == "02" || trade.BankCardType == "12")
  258. {
  259. BankCardType = 1;
  260. }
  261. else
  262. {
  263. BankCardType = 0;
  264. }
  265. }
  266. else if (pos.BrandId == 7)
  267. {
  268. TradeAmount = TradeAmount / 100;
  269. if (trade.BankCardType == "OA" || trade.BankCardType == "CC" || trade.BankCardType == "SCC")
  270. {
  271. BankCardType = 1;
  272. }
  273. else
  274. {
  275. BankCardType = 0;
  276. }
  277. }
  278. else if (pos.BrandId == 8 || pos.BrandId == 9)
  279. {
  280. TradeAmount = TradeAmount / 100;
  281. if (trade.BankCardType == "100")
  282. {
  283. BankCardType = 1;
  284. }
  285. else if (trade.BankCardType == "200")
  286. {
  287. BankCardType = 0;
  288. }
  289. if (trade.TradeType == "200") QrPayFlag = 1;
  290. if (trade.Field1 == "1") VipFlag = 1;
  291. }
  292. else if (pos.BrandId == 10 || pos.BrandId == 11)
  293. {
  294. if (trade.BankCardType == "01")
  295. {
  296. BankCardType = 1;
  297. }
  298. else if (trade.BankCardType == "00")
  299. {
  300. BankCardType = 0;
  301. }
  302. if (trade.TradeType == "F010") QrPayFlag = 1;
  303. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  304. if(merchant != null)
  305. {
  306. bool flag = false;
  307. if(function.CheckNull(merchant.MerchantName).Contains("*")) merchant.MerchantName = trade.MerName;
  308. if(string.IsNullOrEmpty(merchant.MerIdcardNo) && !string.IsNullOrEmpty(trade.Field2))
  309. {
  310. merchant.MerIdcardNo = trade.Field2.ToUpper(); //商户身份证号
  311. flag = true;
  312. }
  313. if(!string.IsNullOrEmpty(trade.Field1))
  314. {
  315. merchant.MerchantMobile = trade.Field1; //商户手机号
  316. }
  317. if(flag)
  318. {
  319. string startNo = merchant.MerIdcardNo.Substring(0, 6);
  320. string endNo = merchant.MerIdcardNo.Substring(merchant.MerIdcardNo.Length - 4, 4).ToUpper();
  321. string Name = merchant.MerchantName;
  322. Name = Name.Replace("*", "");
  323. function.WriteLog(DateTime.Now.ToString() + "-----startNo:" + startNo + ",endNo:" + endNo + ",Name:" + Name, "监控机具是否互斥");
  324. PxcModels.PosMerchantInfo chk = db.PosMerchantInfo.FirstOrDefault(m => m.MerIdcardNo.StartsWith(startNo) && m.MerIdcardNo.EndsWith(endNo) && m.MerchantName.Contains(Name));
  325. if(chk != null)
  326. {
  327. function.WriteLog("互斥机具---sn:" + chk.KqSnNo + ",merno:" + chk.KqMerNo + ",name:" + chk.MerchantName, "监控机具是否互斥");
  328. pos.IsFirst = 0;
  329. }
  330. }
  331. db.SaveChanges();
  332. }
  333. }
  334. else if (pos.BrandId == 12 || pos.BrandId == 13) //盒易付
  335. {
  336. if (trade.BankCardType == "C")
  337. {
  338. BankCardType = 1;
  339. }
  340. else if (trade.BankCardType == "D")
  341. {
  342. BankCardType = 0;
  343. }
  344. if (trade.Field3 == "1") QrPayFlag = 1;
  345. }
  346. else if (pos.BrandId == 15 || pos.BrandId == 16) //联客宝
  347. {
  348. TradeAmount = TradeAmount / 100;
  349. // 支付类型
  350. // 01-内卡借记卡
  351. // 02-内卡贷记卡
  352. // 03-银联二维码
  353. // 11-外卡借记卡
  354. // 12-外卡贷记卡
  355. // 30-微信
  356. // 31-支付宝
  357. // M3-扫码(银联二维码、微信、支付宝)
  358. if (trade.BankCardType == "02")
  359. {
  360. BankCardType = 1;
  361. }
  362. else
  363. {
  364. BankCardType = 0;
  365. }
  366. // if (trade.SerEntryMode == "1") QrPayFlag = 1;
  367. }
  368. int BrandId = pos.BrandId;
  369. // int BrandId = int.Parse(trade.ProductType);
  370. // if (BrandId == 1 && trade.MerNo.StartsWith("M900"))
  371. // {
  372. // BrandId = 3;
  373. // }
  374. // if (BrandId == 4 && trade.DeviceType == "200")
  375. // {
  376. // BrandId = 5;
  377. // }
  378. decimal SourceTradeAmount = TradeAmount;
  379. if (pos.Sort == 0 && pos.BrandId == 7)
  380. {
  381. decimal deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  382. if (deposit > 0)
  383. {
  384. int SftStartId = RedisDbconn.Instance.Get<int>("SftTradeChkId");
  385. PxcModels.TradeRecord chk = db.TradeRecord.FirstOrDefault(m => m.Id > SftStartId && m.SnNo == pos.PosSn);
  386. if(chk == null)
  387. {
  388. TradeAmount -= deposit;
  389. }
  390. else
  391. {
  392. chk.TradeAmount -= deposit;
  393. }
  394. pos.Sort = 1;
  395. }
  396. }
  397. decimal CheckMoney = brand.ActTradeAmount > 0 ? brand.ActTradeAmount : 1000;
  398. int CheckDays = 30;
  399. //联动
  400. if(BankCardType == 1 && trade.TradeType == "M015" && (pos.BrandId == 10 || pos.BrandId == 11))
  401. {
  402. pos.CreditTrade += SourceTradeAmount;
  403. }
  404. //盒易付
  405. else if(BankCardType == 1 && trade.TradeType == "0" && trade.SerEntryMode != "40" && (pos.BrandId == 12 || pos.BrandId == 13))
  406. {
  407. pos.CreditTrade += SourceTradeAmount;
  408. }
  409. //联客宝
  410. else if(BankCardType == 1 && trade.TradeType != "40" && (pos.BrandId == 15 || pos.BrandId == 16))
  411. {
  412. pos.CreditTrade += SourceTradeAmount;
  413. }
  414. //金控
  415. else if((BankCardType == 1 || BankCardType == 2) && (pos.BrandId == 1 || pos.BrandId == 3))
  416. {
  417. pos.CreditTrade += SourceTradeAmount;
  418. }
  419. //开店宝
  420. else if (BankCardType == 1 && pos.BrandId == 2)
  421. {
  422. pos.CreditTrade += SourceTradeAmount;
  423. }
  424. //乐刷or海科
  425. 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))
  426. {
  427. pos.CreditTrade += SourceTradeAmount;
  428. }
  429. //立刷
  430. else if(BankCardType == 1 && trade.Field2 == "0104" && (pos.BrandId == 6 || pos.BrandId == 22))
  431. {
  432. pos.CreditTrade += SourceTradeAmount;
  433. }
  434. //盛付通
  435. else if(BankCardType == 1 && pos.BrandId == 7)
  436. {
  437. pos.CreditTrade += SourceTradeAmount;
  438. }
  439. //广电卡
  440. else if(pos.BrandId == 14)
  441. {
  442. pos.CreditTrade += SourceTradeAmount;
  443. }
  444. else if (BankCardType == 0)
  445. {
  446. pos.DebitCardTrade += TradeAmount;
  447. }
  448. //判断激活条件并激活
  449. ActPos(db, pos, CheckMoney, CheckDays);
  450. if (TradeAmount > 0)
  451. {
  452. ulong MerHelpFlag = 0;
  453. decimal DepositAmt = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  454. if (pos.DownFeeFlag == 1)
  455. {
  456. if (pos.DownFee == 0.6M)
  457. {
  458. MerHelpFlag = 3;
  459. }
  460. else
  461. {
  462. MerHelpFlag = 2;
  463. }
  464. }
  465. else if (pos.IsFirst == 1 || pos.BrandId == 14)
  466. {
  467. string DayString = RedisDbconn.Instance.Get<string>("pobjrule:1:HelpPolicy:Days");
  468. int Days = int.Parse(DayString); //天数
  469. if (pos.BindingTime != null)
  470. {
  471. DateTime CheckTime = pos.BindingTime.Value.AddDays(Days);
  472. if(pos.BrandId == 7)
  473. {
  474. CheckTime = DateTime.Parse(pos.BindingTime.Value.AddDays(Days + 1).ToString("yyyy-MM-dd") + " 03:00:00");
  475. }
  476. if (CheckTime > DateTime.Now)
  477. {
  478. MerHelpFlag = 1;
  479. }
  480. }
  481. }
  482. if((pos.BrandId == 12 || pos.BrandId == 13) && pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0)
  483. {
  484. MerHelpFlag = 2;
  485. }
  486. if((pos.BrandId == 10 || pos.BrandId == 11) && trade.TradeType == "T015" && MerHelpFlag == 1)
  487. {
  488. MerHelpFlag = 0;
  489. }
  490. int CapFlag = 0;
  491. if(BankCardType == 0 && TradeAmount >= 1666.67M)
  492. {
  493. CapFlag = 1;
  494. }
  495. string HelpProfitFlag = "";
  496. bool checkHelpProfit = db.HelpProfitMerchantForUser.Any(m => m.MerchantId == pos.BindMerchantId);
  497. if(checkHelpProfit)
  498. {
  499. HelpProfitFlag = "HelpProfit";
  500. }
  501. int ActStatus = pos.ActivationState;
  502. // if(BrandId == 4 || BrandId == 5 || BrandId == 8 || BrandId == 9)
  503. // {
  504. // ActStatus = GetLeShuaHaiKe(pos.UserId, BrandId);
  505. // }
  506. int Version = 0;
  507. if(MerHelpFlag == 2) Version = 1;
  508. if(MerHelpFlag == 3) Version = 2;
  509. //盒易付和来客吧电签,稳定期自动转到稳定期A
  510. if((pos.BrandId == 12 || pos.BrandId == 13) && MerHelpFlag == 0 && Version == 0)
  511. {
  512. Version = 1;
  513. }
  514. if(pos.BrandId >= 23 && pos.BrandId <= 26)
  515. {
  516. MerHelpFlag = 1;
  517. Version = 0;
  518. }
  519. decimal SettleFee = trade.SettleFee * 100;
  520. PxcModels.TradeRecord add = db.TradeRecord.Add(new PxcModels.TradeRecord()
  521. {
  522. ParentNav = user.ParentNav,
  523. CreateDate = trade.CreateDate,
  524. UpdateDate = trade.UpdateDate,
  525. RecordNo = trade.TradeSerialNo, //单号
  526. UserId = pos.UserId, //创客
  527. MerchantId = pos.BindMerchantId, //商户
  528. MerNo = trade.MerNo, //渠道商户编号
  529. MerHelpFlag = MerHelpFlag >= 2 ? 1 : MerHelpFlag, //1扶持周,0稳定期,2盈利期
  530. HelpMonthCount = 0, //扶持第几个月
  531. MerBuddyType = user.MerchantType, //商户创客类型
  532. SnNo = TradeSnNo, //渠道SN号
  533. TradeSerialNo = trade.ChannelSerial, //交易流水号
  534. TradeAmount = TradeAmount, //交易金额
  535. BankCardType = BankCardType, //银行卡类型
  536. QrPayFlag = QrPayFlag, //云闪付标识
  537. CapFlag = CapFlag, //借记卡是否封顶
  538. VipFlag = VipFlag, //会员标记
  539. PayType = PayType, //支付方式
  540. BrandId = BrandId, //品牌
  541. Remark = trade.TradeType == "2" && trade.ProductType == "12" ? "吱码SN:" + trade.TradeSnNo : trade.Remark, //备注
  542. TopUserId = TopUserId, //顶级创客
  543. MerUserId = pos.UserId, //商户直属创客M
  544. SeoTitle = HelpProfitFlag,
  545. Version = Version,
  546. ActStatus = ActStatus,
  547. CreateMan = trade.AgentNo,
  548. UpdateMan = trade.BankCardType,
  549. SeoKeyword = trade.SerEntryMode,
  550. SeoDescription = trade.TradeType,
  551. Sort = (int)SettleFee,
  552. TradeDate = pos.BindingTime,
  553. }).Entity;
  554. db.SaveChanges();
  555. string TradeMonth = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMM") : trade.CreateDate.Value.ToString("yyyyMM");
  556. PublicFunction.SplitTradeRecord(add, TradeMonth);
  557. //统计商户交易额
  558. string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
  559. RedisDbconn.Instance.AddList("StatMerTradeAmountQueue", "{\"TradeDate\":\"" + TradeDate + "\",\"TradeAmount\":\"" + TradeAmount + "\",\"MerchantId\":\"" + pos.BindMerchantId + "\",\"BrandId\":\"" + BrandId + "\"}");
  560. //推送数据给java
  561. PosPushDataHelper.Trade(add);
  562. }
  563. db.SpOrderNos.Add(new PxcModels.SpOrderNos()
  564. {
  565. OrderNo = trade.TradeSerialNo
  566. });
  567. db.SaveChanges();
  568. // 推荐王逻辑(交易)
  569. // if(TradeAmount > 0)
  570. // {
  571. // string Send = "{\"Kind\":\"4\",\"Data\":{\"PosId\":\"" + pos.Id + "\",\"TradeMonth\":\"" + trade.CreateDate.Value.ToString("yyyyMM") + "\",\"TradeAmount\":\"" + TradeAmount + "\"}}";
  572. // RedisDbconn.Instance.AddList("RecommendActStatQueue", Send);
  573. // }
  574. }
  575. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  576. if (edit != null)
  577. {
  578. edit.Status = 2;
  579. }
  580. spdb.SaveChanges();
  581. }
  582. else
  583. {
  584. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  585. if (edit != null)
  586. {
  587. edit.Status = 0;
  588. }
  589. spdb.SaveChanges();
  590. }
  591. }
  592. else
  593. {
  594. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  595. if (edit != null)
  596. {
  597. edit.Status = 0;
  598. }
  599. spdb.SaveChanges();
  600. }
  601. }
  602. if(isDeposit)
  603. {
  604. // function.WriteLog("押金收到:" + trade.MerNo, "服务费奖励发放日志");
  605. // PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  606. // function.WriteLog("MachineForMerNo:" + posFor.MerNo, "服务费奖励发放日志");
  607. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == TradeSnNo) ?? new PxcModels.PosMachinesTwo();
  608. function.WriteLog("PosMachinesTwo:" + pos.PosSn, "服务费奖励发放日志");
  609. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  610. function.WriteLog("PosMerchantInfo:" + merchant.KqMerNo, "服务费奖励发放日志");
  611. StatService.Instance.PreActPrize(db, pos, merchant, pos.SeoKeyword);
  612. //推送数据给java
  613. decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  614. if(Deposit > 1000) Deposit = Deposit / 100;
  615. PosPushDataHelper.Deposit(merchant, Deposit);
  616. }
  617. }
  618. spdb.Dispose();
  619. db.Dispose();
  620. }
  621. catch (Exception ex)
  622. {
  623. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  624. }
  625. Thread.Sleep(500);
  626. }
  627. }
  628. public void StartSim()
  629. {
  630. Thread th = new Thread(StartSimDo);
  631. th.IsBackground = true;
  632. th.Start();
  633. }
  634. public void StartSimDo()
  635. {
  636. while (true)
  637. {
  638. try
  639. {
  640. WebCMSEntities spdb = new WebCMSEntities();
  641. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  642. DateTime start = DateTime.Now.AddDays(-40);
  643. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  644. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && m.ProductType == "14" && m.CreateDate >= start && m.Status == 1).OrderBy(m => m.CreateDate).Take(20);
  645. foreach (TradeRecord trade in trades.ToList())
  646. {
  647. bool op = true;
  648. if (op)
  649. {
  650. // PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  651. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == trade.TradeSnNo);
  652. if (pos != null)
  653. {
  654. PxcModels.KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new PxcModels.KqProducts();
  655. if (pos.BindMerchantId > 0)
  656. {
  657. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  658. int TopUserId = 0;
  659. if (!string.IsNullOrEmpty(user.ParentNav))
  660. {
  661. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  662. }
  663. bool check = db.SpOrderNos.Any(m => m.OrderNo == trade.TradeSerialNo);
  664. if (!check)
  665. {
  666. decimal TradeAmount = trade.TradeAmount;
  667. int BankCardType = -1;
  668. int QrPayFlag = 0;
  669. int VipFlag = 0;
  670. int PayType = 0;
  671. BankCardType = int.Parse(trade.BankCardType);
  672. int BrandId = pos.BrandId;
  673. decimal SourceTradeAmount = TradeAmount;
  674. if (TradeAmount > 0)
  675. {
  676. ulong MerHelpFlag = 0;
  677. string DayString = RedisDbconn.Instance.Get<string>("pobjrule:" + pos.BrandId + ":HelpPolicy:Days");
  678. int Days = int.Parse(DayString); //天数
  679. if (pos.BindingTime != null)
  680. {
  681. if (pos.BindingTime.Value.AddDays(Days) > DateTime.Now)
  682. {
  683. MerHelpFlag = 1;
  684. }
  685. }
  686. int ActStatus = pos.ActivationState;
  687. decimal SettleFee = trade.SettleFee * 100;
  688. PxcModels.TradeRecord add = db.TradeRecord.Add(new PxcModels.TradeRecord()
  689. {
  690. ParentNav = user.ParentNav,
  691. CreateDate = trade.CreateDate,
  692. UpdateDate = trade.UpdateDate,
  693. RecordNo = trade.TradeSerialNo, //单号
  694. UserId = pos.UserId, //创客
  695. MerchantId = pos.BindMerchantId, //商户
  696. MerNo = trade.MerNo, //渠道商户编号
  697. MerHelpFlag = MerHelpFlag >= 2 ? 1 : MerHelpFlag, //1扶持周,0稳定期,2盈利期
  698. HelpMonthCount = 0, //扶持第几个月
  699. MerBuddyType = user.MerchantType, //商户创客类型
  700. SnNo = trade.TradeSnNo, //渠道SN号
  701. TradeSerialNo = trade.ChannelSerial, //交易流水号
  702. TradeAmount = TradeAmount, //交易金额
  703. BankCardType = BankCardType, //银行卡类型
  704. QrPayFlag = QrPayFlag, //云闪付标识
  705. VipFlag = VipFlag, //会员标记
  706. PayType = PayType, //支付方式
  707. BrandId = BrandId, //品牌
  708. Remark = trade.Remark, //备注
  709. TopUserId = TopUserId, //顶级创客
  710. MerUserId = pos.UserId, //商户直属创客
  711. ActStatus = ActStatus,
  712. CreateMan = trade.AgentNo,
  713. UpdateMan = trade.BankCardType,
  714. SeoKeyword = trade.SerEntryMode,
  715. SeoDescription = trade.TradeType,
  716. Sort = (int)SettleFee,
  717. TradeDate = pos.BindingTime,
  718. }).Entity;
  719. db.SaveChanges();
  720. string TradeMonth = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMM") : trade.CreateDate.Value.ToString("yyyyMM");
  721. PublicFunction.SplitTradeRecord(add, TradeMonth);
  722. //统计商户交易额
  723. string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
  724. RedisDbconn.Instance.AddList("StatMerTradeAmountQueue", "{\"TradeDate\":\"" + TradeDate + "\",\"TradeAmount\":\"" + TradeAmount + "\",\"MerchantId\":\"" + pos.BindMerchantId + "\",\"BrandId\":\"" + BrandId + "\"}");
  725. //推送数据给java
  726. PosPushDataHelper.Trade(add);
  727. }
  728. db.SpOrderNos.Add(new PxcModels.SpOrderNos()
  729. {
  730. OrderNo = trade.TradeSerialNo
  731. });
  732. db.SaveChanges();
  733. }
  734. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  735. if (edit != null)
  736. {
  737. edit.Status = 2;
  738. }
  739. spdb.SaveChanges();
  740. }
  741. else
  742. {
  743. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  744. if (edit != null)
  745. {
  746. edit.Status = 0;
  747. }
  748. spdb.SaveChanges();
  749. }
  750. }
  751. else
  752. {
  753. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  754. if (edit != null)
  755. {
  756. edit.Status = 0;
  757. }
  758. spdb.SaveChanges();
  759. }
  760. }
  761. }
  762. spdb.Dispose();
  763. db.Dispose();
  764. }
  765. catch (Exception ex)
  766. {
  767. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  768. }
  769. Thread.Sleep(500);
  770. }
  771. }
  772. public void StartTradeStatus()
  773. {
  774. Thread th = new Thread(StartTradeStatusDo);
  775. th.IsBackground = true;
  776. th.Start();
  777. }
  778. public void StartTradeStatusDo()
  779. {
  780. while (true)
  781. {
  782. try
  783. {
  784. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  785. WebCMSEntities spdb = new WebCMSEntities();
  786. DateTime start = DateTime.Now.AddDays(-10);
  787. DateTime end = DateTime.Now.AddMinutes(-10);
  788. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  789. IQueryable<TradeRecord> trades = spdb.TradeRecord.Where(m => m.Id >= StartId && m.CreateDate >= start && m.CreateDate < end && m.Status == 0).OrderBy(m => m.CreateDate).Take(20);
  790. foreach (TradeRecord trade in trades.ToList())
  791. {
  792. int Status = 1;
  793. bool op = db.PosMachinesTwo.Any(m => m.PosSn == trade.TradeSnNo);
  794. if(!op)
  795. {
  796. Status = -1;
  797. }
  798. else
  799. {
  800. op = db.PosMerchantInfo.Any(m => m.KqSnNo == trade.TradeSnNo);
  801. if(!op)
  802. {
  803. Status = -2;
  804. }
  805. }
  806. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  807. if (edit != null)
  808. {
  809. edit.Status = Status;
  810. spdb.SaveChanges();
  811. }
  812. }
  813. db.Dispose();
  814. spdb.Dispose();
  815. }
  816. catch (Exception ex)
  817. {
  818. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "恢复原始交易没有统计上的数据异常");
  819. }
  820. Thread.Sleep(10000);
  821. }
  822. }
  823. //机具激活逻辑
  824. public void ActPos(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, decimal CheckMoney, int CheckDays, bool PrizeFlag = true, string ActivationTime = "")
  825. {
  826. DateTime now = DateTime.Now;
  827. if(!string.IsNullOrEmpty(ActivationTime))
  828. {
  829. now = DateTime.Parse(ActivationTime);
  830. }
  831. DateTime TransferTime = pos.TransferTime == null ? DateTime.Parse("2050-01-01") : pos.TransferTime.Value;
  832. int minute = 30;
  833. if(pos.BrandId == 14 && pos.PosSn.StartsWith("CS"))
  834. {
  835. minute = 60 * 24 * 30;
  836. }
  837. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满" + CheckMoney + ";贷记卡交易:" + pos.CreditTrade + "");
  838. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否有机具所属人;机具所属人Id:" + pos.BuyUserId + "");
  839. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否未激活;机具激活状态:" + pos.ActivationState + "");
  840. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:划拨时间不能超过绑定时间" + minute + "分钟;划拨时间:" + TransferTime.ToString() + ",绑定时间:" + pos.BindingTime.Value.ToString());
  841. if (pos.CreditTrade >= CheckMoney && pos.BuyUserId > 0 && pos.ActivationState == 0 && TransferTime.AddMinutes(-minute) < pos.BindingTime)
  842. {
  843. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件");
  844. pos.ActivationState = 1;
  845. pos.ActivationTime = now;
  846. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否营训");
  847. if(pos.CardType == 101)
  848. {
  849. Utils.Instance.PrizeRecord(1, pos.PosSn, "是营训");
  850. pos.IsPurchase = 1;
  851. Utils.Instance.PrizeRecord(1, pos.PosSn, "取消循环资格");
  852. }
  853. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否关联商户信息");
  854. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  855. if (merchant != null)
  856. {
  857. merchant.ActiveStatus = 1;
  858. merchant.MerStandardDate = now;
  859. db.SaveChanges();
  860. if(pos.BrandId != 14)
  861. {
  862. //发放奖励MQ
  863. PrizeSetHelper.Do("1", pos.PosSn);
  864. }
  865. Utils.Instance.PrizeRecord(1, pos.PosSn, "已关联");
  866. //发放开机奖励
  867. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;当前绑定时间:" + pos.BindingTime.ToString() + "");
  868. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  869. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:奖励开关;当前:" + PrizeFlag);
  870. if(pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  871. {
  872. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放开机奖励");
  873. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  874. if(pos.BrandId == 14)
  875. {
  876. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  877. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  878. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  879. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  880. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  881. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  882. if(pos.LeaderUserId > 0 && ExpiredDate > now)
  883. {
  884. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  885. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  886. }
  887. }
  888. }
  889. }
  890. //发放大盟主奖励
  891. decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  892. if(pos.BrandId != 14)
  893. {
  894. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:有押金;当前押金:" + Deposit);
  895. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  896. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  897. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  898. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  899. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  900. }
  901. 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)
  902. {
  903. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  904. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  905. }
  906. //发放运营中心奖励
  907. if (Deposit > 0 && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  908. {
  909. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  910. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  911. }
  912. if(pos.CardType < 100)
  913. {
  914. //统计激活数
  915. RedisDbconn.Instance.AddList("StatActQueue", "{\"TradeDate\":\"" + now.ToString("yyyyMMdd") + "\",\"UserId\":\"" + pos.BuyUserId + "\",\"BrandId\":\"" + pos.BrandId + "\"}");
  916. //运营中心额度变更
  917. OpAmountItem item = new OpAmountItem()
  918. {
  919. UserId = pos.OpId,
  920. OperateType = 1,
  921. ChangeType = 9,
  922. Remark = "机具激活",
  923. UseAmount = pos.OpReserve1 + pos.OpReserve2 + pos.OpReserve3,
  924. UseValidForGetAmount = pos.OpReserve2,
  925. UseTotalAmt = pos.OpReserve1,
  926. UseValidAmount = pos.OpReserve3,
  927. DataType = 2,
  928. DataId = pos.Id,
  929. };
  930. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  931. }
  932. //清理预扣款
  933. RedisDbconn.Instance.AddList("PosWithholdQueue", "{\"UserId\":\"" + pos.BuyUserId + "\",\"SnNo\":\"" + pos.PosSn + "\"}");
  934. //推送激活数据
  935. if(Deposit == 0) Utils.Instance.SendActData(pos);
  936. }
  937. else if (pos.ActivationState == 1 && pos.BrandId == 14)
  938. {
  939. if(pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  940. {
  941. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  942. if(pos.BrandId == 14)
  943. {
  944. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  945. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  946. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  947. if(pos.LeaderUserId > 0 && ExpiredDate > now)
  948. {
  949. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  950. }
  951. }
  952. }
  953. }
  954. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:已激活;当前状态:" + pos.ActivationState);
  955. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定后台30天到60天之间;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  956. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满10000;贷记卡交易:" + pos.CreditTrade + "");
  957. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  958. if(pos.ActivationState == 1 && pos.BindingTime.Value.AddDays(30) <= DateTime.Now && pos.BindingTime.Value.AddDays(60) > DateTime.Now && pos.CreditTrade >= 10000 && pos.CardType < 100)
  959. {
  960. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放盟主开机奖励");
  961. RedisDbconn.Instance.AddList("LeaderRewardQueue", pos.Id.ToString());
  962. //发放奖励MQ
  963. PrizeSetHelper.Do("1", pos.PosSn);
  964. }
  965. }
  966. //立刷格外奖励
  967. public void LiShuaActPrize(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, int prize)
  968. {
  969. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  970. if(merchant != null)
  971. {
  972. PxcModels.Users getUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users();
  973. int BuyTopUserId = 0;
  974. string ParentNav = getUser.ParentNav;
  975. if (!string.IsNullOrEmpty(ParentNav))
  976. {
  977. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  978. if (ParentNavList.Length > 1)
  979. {
  980. BuyTopUserId = int.Parse(ParentNavList[1]);
  981. }
  982. else if (ParentNavList.Length == 1)
  983. {
  984. BuyTopUserId = int.Parse(ParentNavList[0]);
  985. }
  986. }
  987. if(prize == 50)
  988. {
  989. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize);
  990. }
  991. if(prize == 40)
  992. {
  993. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 12);
  994. }
  995. if(prize == 30)
  996. {
  997. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 133);
  998. }
  999. }
  1000. }
  1001. private int GetLeShuaHaiKe(int UserId, int BrandId)
  1002. {
  1003. if(DateTime.Now >= DateTime.Parse("2023-08-01 00:00:00"))
  1004. {
  1005. return 0;
  1006. }
  1007. int ActStatus = 1;
  1008. try
  1009. {
  1010. string Date = DateTime.Now.ToString("yyyyMMdd");
  1011. int checkNum = 0;
  1012. if(Date == "20230720") checkNum = 12;
  1013. if(Date == "20230721") checkNum = 11;
  1014. if(Date == "20230722") checkNum = 10;
  1015. if(Date == "20230723") checkNum = 9;
  1016. if(Date == "20230724") checkNum = 8;
  1017. if(Date == "20230725") checkNum = 7;
  1018. if(Date == "20230726") checkNum = 6;
  1019. if(Date == "20230727") checkNum = 5;
  1020. if(Date == "20230728") checkNum = 4;
  1021. if(Date == "20230729") checkNum = 3;
  1022. if(Date == "20230730") checkNum = 2;
  1023. if(Date == "20230731") checkNum = 1;
  1024. int check = int.Parse(function.CheckInt(RedisDbconn.Instance.Get<string>("lscut:" + UserId + ":" + BrandId + ":" + Date)));
  1025. if(check <= checkNum)
  1026. {
  1027. check += 1;
  1028. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, check.ToString());
  1029. }
  1030. else
  1031. {
  1032. ActStatus = -1;
  1033. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, "0");
  1034. }
  1035. }
  1036. catch(Exception ex)
  1037. {
  1038. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "乐刷海科计数异常");
  1039. }
  1040. return ActStatus;
  1041. }
  1042. }
  1043. }