SycnSpTradeService.cs 65 KB

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