SycnSpTradeService.cs 61 KB

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