SycnSpTradeService.cs 65 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062
  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 && m.KqSnNo == "00005702280118971549");
  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. DateTime ChkTime = DateTime.Now;
  455. if(pos.BrandId == 7)
  456. {
  457. ChkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 03:00:00");
  458. }
  459. if (pos.DownFeeFlag == 1 && pos.DownFeeDate <= ChkTime)
  460. {
  461. if (pos.DownFee == 0.6M)
  462. {
  463. MerHelpFlag = 3;
  464. }
  465. else
  466. {
  467. MerHelpFlag = 2;
  468. }
  469. }
  470. else if (pos.IsFirst == 1 || pos.BrandId == 14)
  471. {
  472. string DayString = RedisDbconn.Instance.Get<string>("pobjrule:1:HelpPolicy:Days");
  473. int Days = int.Parse(DayString); //天数
  474. if (pos.BindingTime != null)
  475. {
  476. DateTime CheckTime = pos.BindingTime.Value.AddDays(Days);
  477. if(pos.BrandId == 7)
  478. {
  479. CheckTime = DateTime.Parse(pos.BindingTime.Value.AddDays(Days + 1).ToString("yyyy-MM-dd") + " 03:00:00");
  480. }
  481. if (CheckTime > DateTime.Now)
  482. {
  483. MerHelpFlag = 1;
  484. }
  485. }
  486. }
  487. if((pos.BrandId == 12 || pos.BrandId == 13) && pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0)
  488. {
  489. MerHelpFlag = 2;
  490. }
  491. if((pos.BrandId == 10 || pos.BrandId == 11) && trade.TradeType == "T015" && MerHelpFlag == 1)
  492. {
  493. MerHelpFlag = 0;
  494. }
  495. int CapFlag = 0;
  496. if(BankCardType == 0 && TradeAmount >= 1666.67M)
  497. {
  498. CapFlag = 1;
  499. }
  500. string HelpProfitFlag = "";
  501. bool checkHelpProfit = db.HelpProfitMerchantForUser.Any(m => m.MerchantId == pos.BindMerchantId);
  502. if(checkHelpProfit)
  503. {
  504. HelpProfitFlag = "HelpProfit";
  505. }
  506. int ActStatus = pos.ActivationState;
  507. // if(BrandId == 4 || BrandId == 5 || BrandId == 8 || BrandId == 9)
  508. // {
  509. // ActStatus = GetLeShuaHaiKe(pos.UserId, BrandId);
  510. // }
  511. int Version = 0;
  512. if(MerHelpFlag == 2) Version = 1;
  513. if(MerHelpFlag == 3) Version = 2;
  514. //盒易付和来客吧电签,稳定期自动转到稳定期A
  515. if((pos.BrandId == 12 || pos.BrandId == 13) && MerHelpFlag == 0 && Version == 0)
  516. {
  517. Version = 1;
  518. }
  519. if(pos.BrandId >= 23 && pos.BrandId <= 26)
  520. {
  521. MerHelpFlag = 1;
  522. Version = 0;
  523. }
  524. decimal SettleFee = trade.SettleFee * 100;
  525. PxcModels.TradeRecord add = db.TradeRecord.Add(new PxcModels.TradeRecord()
  526. {
  527. ParentNav = user.ParentNav,
  528. CreateDate = trade.CreateDate,
  529. UpdateDate = trade.UpdateDate,
  530. RecordNo = trade.TradeSerialNo, //单号
  531. UserId = pos.UserId, //创客
  532. MerchantId = pos.BindMerchantId, //商户
  533. MerNo = trade.MerNo, //渠道商户编号
  534. MerHelpFlag = MerHelpFlag >= 2 ? 1 : MerHelpFlag, //1扶持周,0稳定期,2盈利期
  535. HelpMonthCount = 0, //扶持第几个月
  536. MerBuddyType = user.MerchantType, //商户创客类型
  537. SnNo = TradeSnNo, //渠道SN号
  538. TradeSerialNo = trade.ChannelSerial, //交易流水号
  539. TradeAmount = TradeAmount, //交易金额
  540. BankCardType = BankCardType, //银行卡类型
  541. QrPayFlag = QrPayFlag, //云闪付标识
  542. CapFlag = CapFlag, //借记卡是否封顶
  543. VipFlag = VipFlag, //会员标记
  544. PayType = PayType, //支付方式
  545. BrandId = BrandId, //品牌
  546. Remark = trade.TradeType == "2" ? "吱码SN:" + trade.TradeSnNo : trade.Remark, //备注
  547. TopUserId = TopUserId, //顶级创客
  548. MerUserId = pos.UserId, //商户直属创客M
  549. SeoTitle = HelpProfitFlag,
  550. Version = Version,
  551. ActStatus = ActStatus,
  552. CreateMan = trade.AgentNo,
  553. UpdateMan = trade.BankCardType,
  554. SeoKeyword = trade.SerEntryMode,
  555. SeoDescription = trade.TradeType,
  556. Sort = (int)SettleFee,
  557. TradeDate = pos.BindingTime,
  558. }).Entity;
  559. db.SaveChanges();
  560. string TradeMonth = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMM") : trade.CreateDate.Value.ToString("yyyyMM");
  561. PublicFunction.SplitTradeRecord(add, TradeMonth);
  562. //统计商户交易额
  563. string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
  564. RedisDbconn.Instance.AddList("StatMerTradeAmountQueue", "{\"TradeDate\":\"" + TradeDate + "\",\"TradeAmount\":\"" + TradeAmount + "\",\"MerchantId\":\"" + pos.BindMerchantId + "\",\"BrandId\":\"" + BrandId + "\"}");
  565. }
  566. db.SpOrderNos.Add(new PxcModels.SpOrderNos()
  567. {
  568. OrderNo = trade.TradeSerialNo
  569. });
  570. db.SaveChanges();
  571. // 推荐王逻辑(交易)
  572. // if(TradeAmount > 0)
  573. // {
  574. // string Send = "{\"Kind\":\"4\",\"Data\":{\"PosId\":\"" + pos.Id + "\",\"TradeMonth\":\"" + trade.CreateDate.Value.ToString("yyyyMM") + "\",\"TradeAmount\":\"" + TradeAmount + "\"}}";
  575. // RedisDbconn.Instance.AddList("RecommendActStatQueue", Send);
  576. // }
  577. }
  578. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  579. if (edit != null)
  580. {
  581. edit.Status = 2;
  582. }
  583. spdb.SaveChanges();
  584. }
  585. else
  586. {
  587. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  588. if (edit != null)
  589. {
  590. edit.Status = 0;
  591. }
  592. spdb.SaveChanges();
  593. }
  594. }
  595. else
  596. {
  597. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  598. if (edit != null)
  599. {
  600. edit.Status = 0;
  601. }
  602. spdb.SaveChanges();
  603. }
  604. }
  605. if(isDeposit)
  606. {
  607. // function.WriteLog("押金收到:" + trade.MerNo, "服务费奖励发放日志");
  608. // PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  609. // function.WriteLog("MachineForMerNo:" + posFor.MerNo, "服务费奖励发放日志");
  610. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == TradeSnNo) ?? new PxcModels.PosMachinesTwo();
  611. function.WriteLog("PosMachinesTwo:" + pos.PosSn, "服务费奖励发放日志");
  612. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  613. function.WriteLog("PosMerchantInfo:" + merchant.KqMerNo, "服务费奖励发放日志");
  614. StatService.Instance.PreActPrize(db, pos, merchant, pos.SeoKeyword);
  615. }
  616. }
  617. spdb.Dispose();
  618. db.Dispose();
  619. }
  620. catch (Exception ex)
  621. {
  622. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  623. }
  624. Thread.Sleep(500);
  625. }
  626. }
  627. public void StartSim()
  628. {
  629. Thread th = new Thread(StartSimDo);
  630. th.IsBackground = true;
  631. th.Start();
  632. }
  633. public void StartSimDo()
  634. {
  635. while (true)
  636. {
  637. try
  638. {
  639. WebCMSEntities spdb = new WebCMSEntities();
  640. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  641. DateTime start = DateTime.Now.AddDays(-40);
  642. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  643. 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);
  644. foreach (TradeRecord trade in trades.ToList())
  645. {
  646. bool op = true;
  647. if (op)
  648. {
  649. // PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
  650. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == trade.TradeSnNo);
  651. if (pos != null)
  652. {
  653. PxcModels.KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new PxcModels.KqProducts();
  654. if (pos.BindMerchantId > 0)
  655. {
  656. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  657. int TopUserId = 0;
  658. if (!string.IsNullOrEmpty(user.ParentNav))
  659. {
  660. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  661. }
  662. bool check = db.SpOrderNos.Any(m => m.OrderNo == trade.TradeSerialNo);
  663. if (!check)
  664. {
  665. decimal TradeAmount = trade.TradeAmount;
  666. int BankCardType = -1;
  667. int QrPayFlag = 0;
  668. int VipFlag = 0;
  669. int PayType = 0;
  670. BankCardType = int.Parse(trade.BankCardType);
  671. int BrandId = pos.BrandId;
  672. decimal SourceTradeAmount = TradeAmount;
  673. if (TradeAmount > 0)
  674. {
  675. ulong MerHelpFlag = 0;
  676. string DayString = RedisDbconn.Instance.Get<string>("pobjrule:" + pos.BrandId + ":HelpPolicy:Days");
  677. int Days = int.Parse(DayString); //天数
  678. if (pos.BindingTime != null)
  679. {
  680. if (pos.BindingTime.Value.AddDays(Days) > DateTime.Now)
  681. {
  682. MerHelpFlag = 1;
  683. }
  684. }
  685. int ActStatus = pos.ActivationState;
  686. decimal SettleFee = trade.SettleFee * 100;
  687. PxcModels.TradeRecord add = db.TradeRecord.Add(new PxcModels.TradeRecord()
  688. {
  689. ParentNav = user.ParentNav,
  690. CreateDate = trade.CreateDate,
  691. UpdateDate = trade.UpdateDate,
  692. RecordNo = trade.TradeSerialNo, //单号
  693. UserId = pos.UserId, //创客
  694. MerchantId = pos.BindMerchantId, //商户
  695. MerNo = trade.MerNo, //渠道商户编号
  696. MerHelpFlag = MerHelpFlag >= 2 ? 1 : MerHelpFlag, //1扶持周,0稳定期,2盈利期
  697. HelpMonthCount = 0, //扶持第几个月
  698. MerBuddyType = user.MerchantType, //商户创客类型
  699. SnNo = trade.TradeSnNo, //渠道SN号
  700. TradeSerialNo = trade.ChannelSerial, //交易流水号
  701. TradeAmount = TradeAmount, //交易金额
  702. BankCardType = BankCardType, //银行卡类型
  703. QrPayFlag = QrPayFlag, //云闪付标识
  704. VipFlag = VipFlag, //会员标记
  705. PayType = PayType, //支付方式
  706. BrandId = BrandId, //品牌
  707. Remark = trade.Remark, //备注
  708. TopUserId = TopUserId, //顶级创客
  709. MerUserId = pos.UserId, //商户直属创客
  710. ActStatus = ActStatus,
  711. CreateMan = trade.AgentNo,
  712. UpdateMan = trade.BankCardType,
  713. SeoKeyword = trade.SerEntryMode,
  714. SeoDescription = trade.TradeType,
  715. Sort = (int)SettleFee,
  716. TradeDate = pos.BindingTime,
  717. }).Entity;
  718. db.SaveChanges();
  719. string TradeMonth = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMM") : trade.CreateDate.Value.ToString("yyyyMM");
  720. PublicFunction.SplitTradeRecord(add, TradeMonth);
  721. //统计商户交易额
  722. string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
  723. RedisDbconn.Instance.AddList("StatMerTradeAmountQueue", "{\"TradeDate\":\"" + TradeDate + "\",\"TradeAmount\":\"" + TradeAmount + "\",\"MerchantId\":\"" + pos.BindMerchantId + "\",\"BrandId\":\"" + BrandId + "\"}");
  724. }
  725. db.SpOrderNos.Add(new PxcModels.SpOrderNos()
  726. {
  727. OrderNo = trade.TradeSerialNo
  728. });
  729. db.SaveChanges();
  730. }
  731. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  732. if (edit != null)
  733. {
  734. edit.Status = 2;
  735. }
  736. spdb.SaveChanges();
  737. }
  738. else
  739. {
  740. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  741. if (edit != null)
  742. {
  743. edit.Status = 0;
  744. }
  745. spdb.SaveChanges();
  746. }
  747. }
  748. else
  749. {
  750. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  751. if (edit != null)
  752. {
  753. edit.Status = 0;
  754. }
  755. spdb.SaveChanges();
  756. }
  757. }
  758. }
  759. spdb.Dispose();
  760. db.Dispose();
  761. }
  762. catch (Exception ex)
  763. {
  764. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常");
  765. }
  766. Thread.Sleep(500);
  767. }
  768. }
  769. public void StartTradeStatus()
  770. {
  771. Thread th = new Thread(StartTradeStatusDo);
  772. th.IsBackground = true;
  773. th.Start();
  774. }
  775. public void StartTradeStatusDo()
  776. {
  777. while (true)
  778. {
  779. try
  780. {
  781. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  782. WebCMSEntities spdb = new WebCMSEntities();
  783. DateTime start = DateTime.Now.AddDays(-10);
  784. DateTime end = DateTime.Now.AddMinutes(-10);
  785. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  786. 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);
  787. foreach (TradeRecord trade in trades.ToList())
  788. {
  789. int Status = 1;
  790. bool op = db.PosMachinesTwo.Any(m => m.PosSn == trade.TradeSnNo);
  791. if(!op)
  792. {
  793. Status = -1;
  794. }
  795. else
  796. {
  797. op = db.PosMerchantInfo.Any(m => m.KqSnNo == trade.TradeSnNo);
  798. if(!op)
  799. {
  800. Status = -2;
  801. }
  802. }
  803. TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
  804. if (edit != null)
  805. {
  806. edit.Status = Status;
  807. spdb.SaveChanges();
  808. }
  809. }
  810. db.Dispose();
  811. spdb.Dispose();
  812. }
  813. catch (Exception ex)
  814. {
  815. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "恢复原始交易没有统计上的数据异常");
  816. }
  817. Thread.Sleep(10000);
  818. }
  819. }
  820. //机具激活逻辑
  821. public void ActPos(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, decimal CheckMoney, int CheckDays, bool PrizeFlag = true, string ActivationTime = "")
  822. {
  823. DateTime now = DateTime.Now;
  824. if(!string.IsNullOrEmpty(ActivationTime))
  825. {
  826. now = DateTime.Parse(ActivationTime);
  827. }
  828. DateTime TransferTime = pos.TransferTime == null ? DateTime.Parse("2050-01-01") : pos.TransferTime.Value;
  829. int minute = 30;
  830. if(pos.BrandId == 14 && pos.PosSn.StartsWith("CS"))
  831. {
  832. minute = 60 * 24 * 30;
  833. }
  834. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满" + CheckMoney + ";贷记卡交易:" + pos.CreditTrade + "");
  835. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否有机具所属人;机具所属人Id:" + pos.BuyUserId + "");
  836. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否未激活;机具激活状态:" + pos.ActivationState + "");
  837. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:划拨时间不能超过绑定时间" + minute + "分钟;划拨时间:" + TransferTime.ToString() + ",绑定时间:" + pos.BindingTime.Value.ToString());
  838. if (pos.CreditTrade >= CheckMoney && pos.BuyUserId > 0 && pos.ActivationState == 0 && TransferTime.AddMinutes(-minute) < pos.BindingTime)
  839. {
  840. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件");
  841. pos.ActivationState = 1;
  842. pos.ActivationTime = now;
  843. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否营训");
  844. if(pos.CardType == 101)
  845. {
  846. Utils.Instance.PrizeRecord(1, pos.PosSn, "是营训");
  847. pos.IsPurchase = 1;
  848. Utils.Instance.PrizeRecord(1, pos.PosSn, "取消循环资格");
  849. }
  850. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:是否关联商户信息");
  851. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  852. if (merchant != null)
  853. {
  854. merchant.ActiveStatus = 1;
  855. merchant.MerStandardDate = now;
  856. db.SaveChanges();
  857. Utils.Instance.PrizeRecord(1, pos.PosSn, "已关联");
  858. //发放开机奖励
  859. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;当前绑定时间:" + pos.BindingTime.ToString() + "");
  860. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  861. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:奖励开关;当前:" + PrizeFlag);
  862. if(pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  863. {
  864. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放开机奖励");
  865. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  866. if(pos.BrandId == 14)
  867. {
  868. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  869. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  870. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  871. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  872. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  873. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  874. if(pos.LeaderUserId > 0 && ExpiredDate > now)
  875. {
  876. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  877. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  878. }
  879. }
  880. }
  881. }
  882. //发放大盟主奖励
  883. decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  884. if(pos.BrandId != 14)
  885. {
  886. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:有押金;当前押金:" + Deposit);
  887. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:大盟主标记;当前大盟主Id:" + pos.LeaderUserId);
  888. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  889. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  890. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:盟主是否过期;过期时间:" + pos.LeaderUserId);
  891. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定时间不超过" + CheckDays + "天;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  892. }
  893. 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)
  894. {
  895. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放大盟主奖励");
  896. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  897. }
  898. //发放运营中心奖励
  899. if (Deposit > 0 && pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  900. {
  901. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放运营中心奖励");
  902. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  903. }
  904. if(pos.CardType < 100)
  905. {
  906. //统计激活数
  907. RedisDbconn.Instance.AddList("StatActQueue", "{\"TradeDate\":\"" + now.ToString("yyyyMMdd") + "\",\"UserId\":\"" + pos.BuyUserId + "\",\"BrandId\":\"" + pos.BrandId + "\"}");
  908. //运营中心额度变更
  909. OpAmountItem item = new OpAmountItem()
  910. {
  911. UserId = pos.OpId,
  912. OperateType = 1,
  913. ChangeType = 9,
  914. Remark = "机具激活",
  915. UseAmount = pos.OpReserve1 + pos.OpReserve2 + pos.OpReserve3,
  916. UseValidForGetAmount = pos.OpReserve2,
  917. UseTotalAmt = pos.OpReserve1,
  918. UseValidAmount = pos.OpReserve3,
  919. DataType = 2,
  920. DataId = pos.Id,
  921. };
  922. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  923. }
  924. //清理预扣款
  925. RedisDbconn.Instance.AddList("PosWithholdQueue", "{\"UserId\":\"" + pos.BuyUserId + "\",\"SnNo\":\"" + pos.PosSn + "\"}");
  926. //推送激活数据
  927. if(Deposit == 0) Utils.Instance.SendActData(pos);
  928. }
  929. else if (pos.ActivationState == 1 && pos.BrandId == 14)
  930. {
  931. if(pos.BindingTime > now.AddDays(-CheckDays) && pos.CardType < 100 && PrizeFlag)
  932. {
  933. RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString());
  934. if(pos.BrandId == 14)
  935. {
  936. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  937. PxcModels.Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == pos.LeaderUserId) ?? new PxcModels.Leaders();
  938. DateTime ExpiredDate = leader.ExpiredDate == null ? DateTime.Parse("1900-01-01") : leader.ExpiredDate.Value;
  939. if(pos.LeaderUserId > 0 && ExpiredDate > now)
  940. {
  941. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  942. }
  943. }
  944. }
  945. }
  946. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:已激活;当前状态:" + pos.ActivationState);
  947. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:绑定后台30天到60天之间;绑定时间:" + pos.BindingTime.Value.ToString() + "");
  948. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:贷记卡是否刷满10000;贷记卡交易:" + pos.CreditTrade + "");
  949. Utils.Instance.PrizeRecord(1, pos.PosSn, "条件:非营训;当前类型:" + pos.CardType);
  950. if(pos.ActivationState == 1 && pos.BindingTime.Value.AddDays(30) <= DateTime.Now && pos.BindingTime.Value.AddDays(60) > DateTime.Now && pos.CreditTrade >= 10000 && pos.CardType < 100)
  951. {
  952. Utils.Instance.PrizeRecord(1, pos.PosSn, "满足条件,发放盟主开机奖励");
  953. RedisDbconn.Instance.AddList("LeaderRewardQueue", pos.Id.ToString());
  954. }
  955. }
  956. //立刷格外奖励
  957. public void LiShuaActPrize(PxcModels.WebCMSEntities db, PxcModels.PosMachinesTwo pos, int prize)
  958. {
  959. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  960. if(merchant != null)
  961. {
  962. PxcModels.Users getUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users();
  963. int BuyTopUserId = 0;
  964. string ParentNav = getUser.ParentNav;
  965. if (!string.IsNullOrEmpty(ParentNav))
  966. {
  967. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  968. if (ParentNavList.Length > 1)
  969. {
  970. BuyTopUserId = int.Parse(ParentNavList[1]);
  971. }
  972. else if (ParentNavList.Length == 1)
  973. {
  974. BuyTopUserId = int.Parse(ParentNavList[0]);
  975. }
  976. }
  977. if(prize == 50)
  978. {
  979. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize);
  980. }
  981. if(prize == 40)
  982. {
  983. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 12);
  984. }
  985. if(prize == 30)
  986. {
  987. StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, prize, 133);
  988. }
  989. }
  990. }
  991. private int GetLeShuaHaiKe(int UserId, int BrandId)
  992. {
  993. if(DateTime.Now >= DateTime.Parse("2023-08-01 00:00:00"))
  994. {
  995. return 0;
  996. }
  997. int ActStatus = 1;
  998. try
  999. {
  1000. string Date = DateTime.Now.ToString("yyyyMMdd");
  1001. int checkNum = 0;
  1002. if(Date == "20230720") checkNum = 12;
  1003. if(Date == "20230721") checkNum = 11;
  1004. if(Date == "20230722") checkNum = 10;
  1005. if(Date == "20230723") checkNum = 9;
  1006. if(Date == "20230724") checkNum = 8;
  1007. if(Date == "20230725") checkNum = 7;
  1008. if(Date == "20230726") checkNum = 6;
  1009. if(Date == "20230727") checkNum = 5;
  1010. if(Date == "20230728") checkNum = 4;
  1011. if(Date == "20230729") checkNum = 3;
  1012. if(Date == "20230730") checkNum = 2;
  1013. if(Date == "20230731") checkNum = 1;
  1014. int check = int.Parse(function.CheckInt(RedisDbconn.Instance.Get<string>("lscut:" + UserId + ":" + BrandId + ":" + Date)));
  1015. if(check <= checkNum)
  1016. {
  1017. check += 1;
  1018. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, check.ToString());
  1019. }
  1020. else
  1021. {
  1022. ActStatus = -1;
  1023. RedisDbconn.Instance.Set("lscut:" + UserId + ":" + BrandId + ":" + Date, "0");
  1024. }
  1025. }
  1026. catch(Exception ex)
  1027. {
  1028. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "乐刷海科计数异常");
  1029. }
  1030. return ActStatus;
  1031. }
  1032. }
  1033. }