AlipayPayBack2Service.cs 46 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Data;
  5. using System.Threading;
  6. using MySystem.PxcModels;
  7. using Library;
  8. using LitJson;
  9. namespace MySystem
  10. {
  11. public class AlipayPayBack2Service
  12. {
  13. public readonly static AlipayPayBack2Service Instance = new AlipayPayBack2Service();
  14. private AlipayPayBack2Service()
  15. { }
  16. public void Start()
  17. {
  18. Thread th = new Thread(dosomething);
  19. th.IsBackground = true;
  20. th.Start();
  21. }
  22. private void dosomething()
  23. {
  24. bool op = true;
  25. while (op)
  26. {
  27. string content = RedisDbconn.Instance.RPop<string>("PayCallBack2");
  28. if (!string.IsNullOrEmpty(content))
  29. {
  30. try
  31. {
  32. sloveAlipayCallBack(content);
  33. }
  34. catch(Exception ex)
  35. {
  36. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "支付宝支付回调异常");
  37. }
  38. }
  39. else
  40. {
  41. Thread.Sleep(2000);
  42. }
  43. }
  44. }
  45. public void sloveAlipayCallBack(string content)
  46. {
  47. JsonData jsonObj = JsonMapper.ToObject(content);
  48. string OrderNo = jsonObj["out_trade_no"].ToString();
  49. string TradeNo = jsonObj["transaction_id"].ToString();
  50. decimal TotalFee = decimal.Parse(function.CheckNum(jsonObj["total_fee"].ToString()));
  51. WebCMSEntities db = new WebCMSEntities();
  52. OrderForNo forNo = db.OrderForNo.FirstOrDefault(m => m.OrderNo == OrderNo);
  53. if (forNo != null)
  54. {
  55. string[] ids = forNo.OrderIds.Split(',');
  56. foreach (string idString in ids)
  57. {
  58. int OrderId = int.Parse(idString);
  59. DoOrderV2(db, OrderId);
  60. Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId && m.Status > 0);
  61. if(order != null)
  62. {
  63. Products product = db.Products.FirstOrDefault(m => m.Id == order.ProductId) ?? new Products();
  64. if(product.ProductKind == 2)
  65. {
  66. order.Status = 2;
  67. order.SendStatus = 1;
  68. order.SendDate = DateTime.Now;
  69. db.SaveChanges();
  70. Utils.Instance.SendMqOrder(order);
  71. }
  72. }
  73. }
  74. }
  75. db.Dispose();
  76. }
  77. #region 新订单流程
  78. public void DoOrderV2(WebCMSEntities db, int OrderId)
  79. {
  80. Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId && m.Status <= 0);
  81. if (order != null)
  82. {
  83. order.Status = 1;
  84. order.PayDate = DateTime.Now;
  85. order.PayStatus = 1;
  86. db.SaveChanges();
  87. Utils.Instance.SendMqOrder(order);
  88. if(order.ParentOrderId > 0)
  89. {
  90. int total = db.Orders.Count(m => m.ParentOrderId == order.ParentOrderId);
  91. int paycount = db.Orders.Count(m => m.ParentOrderId == order.ParentOrderId && m.Status > 0);
  92. if(paycount >= total)
  93. {
  94. // order = db.Orders.FirstOrDefault(m => m.Id == order.ParentOrderId && m.Status == 0);
  95. // if (order != null)
  96. // {
  97. // order.Status = 2;
  98. // order.PayDate = DateTime.Now;
  99. // order.PayStatus = 1;
  100. // OrderId = order.Id;
  101. // }
  102. DoOrderV2(db, order.ParentOrderId);
  103. }
  104. return;
  105. }
  106. OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == OrderId);
  107. if (pro != null)
  108. {
  109. order.ProductId = pro.ProductId;
  110. //扣减对应商品的库存
  111. Products product = db.Products.FirstOrDefault(m => m.Id == pro.ProductId);
  112. if(product != null)
  113. {
  114. product.Stock -= pro.ProductCount;
  115. product.BuyCount += pro.ProductCount;
  116. }
  117. db.SaveChanges();
  118. if(order.ErpMode > 0)
  119. {
  120. pro.ProductId = order.ProductId;
  121. }
  122. List<int> couponIds = new List<int>();
  123. if (pro.ProductId == 10 || pro.ProductId == 11 || pro.ProductId == 27 || pro.ProductId == 28 || pro.ProductId == 34 || pro.ProductId == -2)
  124. {
  125. order.Status = 2;
  126. int BuyCount = pro.ProductCount;
  127. int Kind = 0;
  128. int BeforeLeaderLevel = 0;
  129. if (pro.ProductId == 10 || pro.ProductId == 34)
  130. {
  131. Kind = 1;
  132. }
  133. else if (pro.ProductId == 11 || pro.ProductId == -2)
  134. {
  135. Kind = 2;
  136. }
  137. else if (pro.ProductId == 28)
  138. {
  139. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);// && m.LeaderLevel == 0);
  140. if(user != null)
  141. {
  142. BeforeLeaderLevel = user.LeaderLevel;
  143. user.LeaderLevel = 1;
  144. }
  145. }
  146. else if (pro.ProductId == 27)
  147. {
  148. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId && m.LeaderLevel < 2);
  149. if(user != null)
  150. {
  151. BeforeLeaderLevel = user.LeaderLevel;
  152. user.LeaderLevel = 2;
  153. }
  154. }
  155. if(Kind <= 2 && (pro.ProductId == 10 || pro.ProductId == 11 || pro.ProductId == 34 || pro.ProductId == -2))
  156. {
  157. // 购买600一组机具券,返券
  158. int CouponCount = 0;
  159. if(Kind == 1 || Kind == 3)
  160. {
  161. CouponCount = 3 * pro.ProductCount;
  162. }
  163. else if(Kind == 2)
  164. {
  165. CouponCount = 2 * pro.ProductCount;
  166. }
  167. if(pro.ProductId == 34) //助利宝商机券购买,50张起购
  168. {
  169. CouponCount = 50 * pro.ProductCount;
  170. }
  171. string Codes = "";
  172. var coupons = db.PosCoupons.Where(m => m.IsLock == 0 && m.IsUse == 0 && m.UserId == 0 && m.QueryCount == Kind).OrderBy(m => m.Id).Take(CouponCount).ToList();
  173. int RecordId = 0;
  174. if(coupons.Count > 0 && (pro.ProductId == 34 || pro.ProductId == -2))
  175. {
  176. var adds = db.HelpProfitExchange.Add(new HelpProfitExchange()
  177. {
  178. CreateDate = DateTime.Now, //创建时间
  179. UserId = order.UserId,
  180. ExchangeCount = coupons.Count,
  181. }).Entity;
  182. db.SaveChanges();
  183. RecordId = adds.Id;
  184. }
  185. foreach (var coupon in coupons) // TODO: 数量多的话,会慢
  186. {
  187. PosCoupons item = db.PosCoupons.FirstOrDefault(m => m.Id == coupon.Id);
  188. if (item != null)
  189. {
  190. item.CreateDate = DateTime.Now;
  191. item.UserId = order.UserId;
  192. item.UpdateDate = DateTime.Now.AddDays(180);
  193. if(pro.ProductId == 34 || pro.ProductId == -2)
  194. {
  195. item.HelpProfitFlag = 1;
  196. db.HelpProfitExchangeDetail.Add(new HelpProfitExchangeDetail()
  197. {
  198. CreateDate = DateTime.Now, //创建时间
  199. UserId = order.UserId,
  200. PosCouponId = item.Id,
  201. ExchangeCode = item.ExchangeCode,
  202. RecordId = RecordId,
  203. });
  204. }
  205. Codes += item.ExchangeCode + ",";
  206. couponIds.Add(coupon.Id);
  207. }
  208. }
  209. order.SnNos = Codes.TrimEnd(',');
  210. }
  211. db.SaveChanges();
  212. if (pro.ProductId == 27 || pro.ProductId == 28)
  213. {
  214. //充值盟主储备金
  215. decimal TotalPrice = 10000;
  216. if(pro.ProductId == 27)
  217. {
  218. TotalPrice = 40000;
  219. }
  220. OpReserve(db, order, order.UserId, TotalPrice, 1);
  221. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
  222. if(pro.ProductId == 27)
  223. {
  224. OperateReserveBackFor(db, user.Id, 40000, order.Id, "购买大盟主");
  225. //自留券数量清除
  226. CancelStayCoupon(db, order.UserId, 7);
  227. //预设大盟主职级
  228. LeaderPreUserLevel(db, order.UserId, 2);
  229. AddLeader(db, order.UserId, 2);
  230. decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "BigLeaderPrize")));
  231. if(Prize > 0 && BeforeLeaderLevel < 2 && user.UserType == 0)
  232. {
  233. LeaderRecommendPrize(db, order, user.Id, Prize, 122);
  234. }
  235. }
  236. }
  237. if (pro.ProductId == 28) //购买小盟主,给上级大盟主返储备金
  238. {
  239. bool check = LeaderBack(db, order);
  240. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
  241. //自留券数量清除
  242. CancelStayCoupon(db, order.UserId, 5);
  243. if (check) OperateReserveBackFor(db, user.Id, 10000, order.Id, "购买小盟主");
  244. //预设小盟主职级
  245. LeaderPreUserLevel(db, order.UserId, 1);
  246. AddLeader(db, order.UserId, 1);
  247. decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "SmallLeaderPrize")));
  248. if(Prize > 0 && BeforeLeaderLevel < 1 && user.UserType == 0)
  249. {
  250. LeaderRecommendPrize(db, order, user.Id, Prize, 123);
  251. }
  252. }
  253. }
  254. // 购买盟主储蓄金
  255. if (pro.ProductId == 39 || pro.ProductId == 40)
  256. {
  257. order.Status = 2;
  258. //充值盟主储备金
  259. decimal TotalPrice = 10000;
  260. if(pro.ProductId == 39)
  261. {
  262. TotalPrice = 40000;
  263. }
  264. OpReserve(db, order, order.UserId, TotalPrice, 1);
  265. if(pro.ProductId == 39) //购买大盟主储蓄金,给上级运营中心返可提现金额
  266. {
  267. OperateReserveBackFor(db, order.UserId, 40000, order.Id);
  268. AddLeader(db, order.UserId, 2);
  269. LeaderPreUserLevel(db, order.UserId, 2);
  270. }
  271. else if(pro.ProductId == 40) //购买小盟主储蓄金,给上级大盟主返储备金
  272. {
  273. LeaderBack(db, order);
  274. AddLeader(db, order.UserId, 1);
  275. LeaderPreUserLevel(db, order.UserId, 1);
  276. }
  277. }
  278. //推荐下单奖励
  279. RedisDbconn.Instance.AddList("PosCouponPrizeQueue", order.Id.ToString());
  280. //推荐王
  281. if(pro.ProductId == 29)
  282. {
  283. RecommendMethod(order.UserId, order.CreateDate.Value.ToString("yyyyMM"));
  284. }
  285. //购买分仓临时额度
  286. if(pro.ProductId == 30 || pro.ProductId == 31 || pro.ProductId == 32)
  287. {
  288. string SendData = "{\"Kind\":\"1\",\"Data\":{\"OrderId\":\"" + order.Id + "\"}}";
  289. RedisDbconn.Instance.AddList("StoreApplyQueue", SendData);
  290. }
  291. //购买小分仓临时额度
  292. if(pro.ProductId == 56 || pro.ProductId == 57 || pro.ProductId == 58)
  293. {
  294. string SendData = "{\"Kind\":\"1\",\"Data\":{\"OrderId\":\"" + order.Id + "\"}}";
  295. RedisDbconn.Instance.AddList("PreStoreApplyQueue", SendData);
  296. }
  297. }
  298. else
  299. {
  300. if(order.ProductId > 0 && order.ErpMode > 0)
  301. {
  302. //盟主储备金-升级/购买 ErpMode:1-升级,2-购买
  303. if(order.ErpMode > 0)
  304. {
  305. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
  306. if(user != null)
  307. {
  308. if(order.ErpMode == 1)
  309. {
  310. user.LeaderLevel = 2;
  311. db.SaveChanges();
  312. }
  313. OpReserve(db, order, order.UserId, order.TotalPrice, 1);
  314. }
  315. }
  316. }
  317. }
  318. }
  319. }
  320. //小盟主购买逻辑
  321. public bool LeaderBack(WebCMSEntities db, Orders order)
  322. {
  323. function.WriteLog("OrderId:" + order.Id, "操作小盟主购买逻辑监控日志");
  324. int LeaderUserId = order.UserId;
  325. int level = 0;
  326. bool result = true;
  327. while(LeaderUserId > 0)
  328. {
  329. level += 1;
  330. Users user = db.Users.FirstOrDefault(m => m.Id == LeaderUserId) ?? new Users();
  331. // UserRankItem user = PosCouponPrizeService.Instance.GetUserLevel(db, LeaderUserId);
  332. if(user.Id > 0)
  333. {
  334. function.WriteLog("UserId:" + user.Id + ";LeaderLevel:" + user.LeaderLevel + ";UserType:" + user.UserType + "", "操作小盟主购买逻辑监控日志");
  335. decimal TotalPrice = 10000;
  336. if((user.LeaderLevel == 2 || user.UserType >= 1) && level > 1)
  337. {
  338. function.WriteLog("够资格", "操作小盟主购买逻辑监控日志");
  339. if(user.LeaderLevel == 2 && result)
  340. {
  341. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == LeaderUserId);
  342. if(account != null)
  343. {
  344. function.WriteLog(str: "LeaderReserve:" + account.LeaderReserve, "操作小盟主购买逻辑监控日志");
  345. if(account.LeaderReserve >= TotalPrice)
  346. {
  347. function.WriteLog("盟主储蓄金够,可返", "操作小盟主购买逻辑监控日志");
  348. int ReserveRecordId = OpReserve(db, order, LeaderUserId, TotalPrice, 2, 0, "推荐小盟主");
  349. OpLeaderAccount(db, order, LeaderUserId, TotalPrice, 1, 1, ReserveRecordId);
  350. LeaderUserId = 0;
  351. result = false;
  352. }
  353. else
  354. {
  355. LeaderUserId = user.ParentUserId;
  356. }
  357. }
  358. }
  359. if(user.UserType >= 1 && result)
  360. {
  361. OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
  362. OpModels.UserAccount account = opdb.UserAccount.FirstOrDefault(m => m.Id == user.Id) ?? new OpModels.UserAccount();
  363. function.WriteLog("TotalAmt:" + account.TotalAmt, "操作小盟主购买逻辑监控日志");
  364. // OpModels.SysAdmin sys = opdb.SysAdmin.FirstOrDefault(m => m.Id == LeaderUserId) ?? new OpModels.SysAdmin();
  365. if(account.TotalAmt > 0) // && sys.ExpireDate > DateTime.Now)
  366. {
  367. if(account.TotalAmt < TotalPrice)
  368. {
  369. function.WriteLog("够一部分额度", "操作小盟主购买逻辑监控日志");
  370. TotalPrice = account.TotalAmt;
  371. }
  372. if(TotalPrice > 0)
  373. {
  374. // OperateAmountChange(opdb, LeaderUserId, TotalPrice, 2, 1, "商城购机", true, order.Id);
  375. // OperateAmountChange(opdb, LeaderUserId, TotalPrice, 1, 2, "商城购机", true, order.Id);
  376. function.WriteLog("开始发放", "操作小盟主购买逻辑监控日志");
  377. OpAmountItem item = new OpAmountItem()
  378. {
  379. UserId = user.Id,
  380. OperateType = 0,
  381. ChangeType = 14,
  382. Remark = "购买小盟主",
  383. UseAmount = TotalPrice,
  384. UseValidForGetAmount = TotalPrice,
  385. UseTotalAmt = TotalPrice,
  386. DataType = 1,
  387. DataId = order.Id,
  388. };
  389. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  390. LeaderUserId = 0;
  391. result = false;
  392. }
  393. }
  394. else
  395. {
  396. LeaderUserId = user.ParentUserId;
  397. }
  398. }
  399. else
  400. {
  401. LeaderUserId = user.ParentUserId;
  402. }
  403. }
  404. else
  405. {
  406. LeaderUserId = user.ParentUserId;
  407. }
  408. }
  409. else
  410. {
  411. LeaderUserId = 0;
  412. }
  413. }
  414. function.WriteLog("\n\n\n", "操作小盟主购买逻辑监控日志");
  415. return result;
  416. }
  417. //操作储备金
  418. private int GetLeaderReserveRecordType(string Remark)
  419. {
  420. Dictionary<int, string> data = new Dictionary<int, string>();
  421. data.Add(11, "兑换机具券,机具券兑换,系统增加(盟主储蓄金),系统扣减(盟主储蓄金),储备金购买");
  422. data.Add(12, "系统增加(可提现余额),系统扣减(可提现余额)");
  423. data.Add(13, "推荐大盟主,推荐小盟主,商城购机,购机奖励");
  424. var item = data.FirstOrDefault(m => m.Value.Contains(Remark));
  425. if(item.Key > 0)
  426. {
  427. return item.Key;
  428. }
  429. return 0;
  430. }
  431. public int OpReserve(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType, int SourceUserId = 0, string Remark = "储备金购买")
  432. {
  433. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  434. if (account == null)
  435. {
  436. account = db.UserAccount.Add(new UserAccount()
  437. {
  438. Id = UserId,
  439. UserId = UserId,
  440. }).Entity;
  441. db.SaveChanges();
  442. }
  443. decimal BeforeAmount = account.LeaderReserve; //变更前总金额
  444. if(ChangeType == 1)
  445. {
  446. account.LeaderReserve += Money;
  447. }
  448. else
  449. {
  450. account.LeaderReserve -= Money;
  451. }
  452. decimal AfterAmount = account.LeaderReserve; //变更后总金额
  453. LeaderReserveRecord add = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  454. {
  455. CreateDate = DateTime.Now,
  456. ChangeType = ChangeType,
  457. OrderId = order.Id,
  458. Remark = Remark,
  459. AfterAmt = AfterAmount,
  460. BeforeAmt = BeforeAmount,
  461. ChangeAmt = Money,
  462. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  463. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  464. UserId = UserId,
  465. SourceUserId = SourceUserId,
  466. Sort = GetLeaderReserveRecordType(Remark),
  467. }).Entity;
  468. db.SaveChanges();
  469. return add.Id;
  470. }
  471. //操作余额
  472. public void OpAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1)
  473. {
  474. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  475. if (account == null)
  476. {
  477. account = db.UserAccount.Add(new UserAccount()
  478. {
  479. Id = UserId,
  480. UserId = UserId,
  481. }).Entity;
  482. db.SaveChanges();
  483. }
  484. int ChangeType = 0;
  485. if(Money == 600)
  486. {
  487. ChangeType = 117;
  488. }
  489. else if(Money == 100)
  490. {
  491. ChangeType = 118;
  492. }
  493. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  494. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  495. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  496. account.BalanceAmount += Money * Count;
  497. account.TotalAmount += Money * Count;
  498. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  499. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  500. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  501. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  502. {
  503. CreateDate = DateTime.Now,
  504. UpdateDate = DateTime.Now,
  505. UserId = UserId, //创客
  506. ChangeType = ChangeType, //变动类型
  507. ChangeAmount = Money * Count, //变更金额
  508. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  509. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  510. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  511. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  512. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  513. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  514. QueryCount = order.Id,
  515. }).Entity;
  516. db.SaveChanges();
  517. }
  518. public void ChangeAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType = 0, string Remark = "")
  519. {
  520. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  521. if (account == null)
  522. {
  523. account = db.UserAccount.Add(new UserAccount()
  524. {
  525. Id = UserId,
  526. UserId = UserId,
  527. }).Entity;
  528. db.SaveChanges();
  529. }
  530. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  531. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  532. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  533. account.BalanceAmount += Money;
  534. if(Money > 0)
  535. {
  536. account.TotalAmount += Money;
  537. }
  538. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  539. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  540. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  541. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  542. {
  543. CreateDate = DateTime.Now,
  544. UpdateDate = DateTime.Now,
  545. UserId = UserId, //创客
  546. ChangeType = ChangeType, //变动类型
  547. ChangeAmount = Math.Abs(Money), //变更金额
  548. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  549. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  550. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  551. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  552. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  553. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  554. QueryCount = order.Id,
  555. Remark = Remark,
  556. }).Entity;
  557. db.SaveChanges();
  558. }
  559. //操作盟主可提现余额
  560. public void OpLeaderAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1, int Kind = 0, int ReserveRecordId = 0)
  561. {
  562. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  563. if (account == null)
  564. {
  565. account = db.UserAccount.Add(new UserAccount()
  566. {
  567. Id = UserId,
  568. UserId = UserId,
  569. }).Entity;
  570. db.SaveChanges();
  571. }
  572. int ChangeType = 0;
  573. if(Money == 400)
  574. {
  575. ChangeType = 117;
  576. }
  577. int LeaderId = 0;
  578. decimal LeaderReserve = 0;
  579. if(Kind == 1)
  580. {
  581. LeaderId = UserId;
  582. LeaderReserve = Money * Count;
  583. }
  584. decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前余额
  585. account.LeaderBalanceAmount += Money * Count;
  586. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后余额
  587. LeaderAccountRecord leaderAccountRecord = db.LeaderAccountRecord.Add(new LeaderAccountRecord()
  588. {
  589. CreateDate = DateTime.Now,
  590. UpdateDate = DateTime.Now,
  591. UserId = UserId, //创客
  592. ChangeType = ChangeType, //变动类型
  593. ChangeAmount = Money * Count, //变更金额
  594. BeforeBalanceAmount = BeforeLeaderBalanceAmount, //变更前余额
  595. AfterBalanceAmount = AfterLeaderBalanceAmount, //变更后余额
  596. QueryCount = order.Id,
  597. Sort = order.UserId,
  598. LeaderId = LeaderId,
  599. LeaderReserve = LeaderReserve,
  600. }).Entity;
  601. db.SaveChanges();
  602. if(ReserveRecordId > 0)
  603. {
  604. LeaderReserveRecord edit = db.LeaderReserveRecord.FirstOrDefault(m => m.Id == ReserveRecordId);
  605. if(edit != null)
  606. {
  607. edit.AccountRecordId = leaderAccountRecord.Id;
  608. db.SaveChanges();
  609. }
  610. }
  611. }
  612. public void DirectPrize(WebCMSEntities db, int OrderId, int UserId, int Count = 1)
  613. {
  614. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  615. if (account == null)
  616. {
  617. account = db.UserAccount.Add(new UserAccount()
  618. {
  619. Id = UserId,
  620. UserId = UserId,
  621. }).Entity;
  622. db.SaveChanges();
  623. }
  624. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  625. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  626. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  627. account.BalanceAmount += 100 * Count;
  628. account.TotalAmount += 100 * Count;
  629. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  630. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  631. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  632. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  633. {
  634. CreateDate = DateTime.Now,
  635. UpdateDate = DateTime.Now,
  636. UserId = UserId, //创客
  637. ChangeType = 112, //变动类型
  638. ChangeAmount = 100 * Count, //变更金额
  639. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  640. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  641. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  642. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  643. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  644. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  645. QueryCount = OrderId,
  646. }).Entity;
  647. db.SaveChanges();
  648. }
  649. // 推荐王逻辑(下单)
  650. public void RecommendMethod(int UserId, string TradeMonth)
  651. {
  652. string SendData = "{\"Kind\":\"1\",\"Data\":{\"UserId\":\"" + UserId + "\",\"TradeMonth\":\"" + TradeMonth + "\"}}";
  653. RedisDbconn.Instance.AddList("RecommendActStatQueue", SendData);
  654. }
  655. //操作运营中心额度
  656. public void OperateReserveBackFor(WebCMSEntities maindb, int UserId, decimal Money, int OrderId = 0, string Remark = "商城购机")
  657. {
  658. function.WriteLog("OrderId:" + OrderId, "操作运营中心额度监控日志");
  659. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  660. while(UserId > 0)
  661. {
  662. Users user = maindb.Users.FirstOrDefault(m => m.Id == UserId);
  663. if(user != null)
  664. {
  665. function.WriteLog("UserId:" + UserId, "操作运营中心额度监控日志");
  666. // DateTime now = DateTime.Now;
  667. bool sys = db.SysAdmin.Any(m => m.UserId == UserId); // && m.ExpireDate > now);
  668. if(sys)
  669. {
  670. function.WriteLog("是运营中心", "操作运营中心额度监控日志");
  671. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  672. function.WriteLog("TotalAmt:" + account.TotalAmt, "操作运营中心额度监控日志");
  673. if(account.TotalAmt >= Money)
  674. {
  675. // OperateAmountChange(db, UserId, Money, 2, 1, "商城购机", true, OrderId);
  676. // OperateAmountChange(db, UserId, Money, 1, 2, "商城购机", true, OrderId);
  677. function.WriteLog(str: "额度ok", "操作运营中心额度监控日志");
  678. OpAmountItem item = new OpAmountItem()
  679. {
  680. UserId = UserId,
  681. OperateType = 0,
  682. ChangeType = 5,
  683. Remark = Remark,
  684. UseAmount = Money,
  685. UseValidForGetAmount = Money,
  686. UseTotalAmt = Money,
  687. DataType = 1,
  688. DataId = OrderId,
  689. };
  690. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  691. UserId = 0;
  692. }
  693. else
  694. {
  695. function.WriteLog(str: "额度不够", "操作运营中心额度监控日志");
  696. UserId = user.ParentUserId;
  697. }
  698. }
  699. else
  700. {
  701. UserId = user.ParentUserId;
  702. }
  703. }
  704. else
  705. {
  706. UserId = 0;
  707. }
  708. }
  709. db.Dispose();
  710. function.WriteLog("\n\n\n", "操作运营中心额度监控日志");
  711. }
  712. public void OperateReserveBack(int UserId, decimal Money, int OrderId = 0)
  713. {
  714. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  715. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  716. if(account.TotalAmt <= 0)
  717. {
  718. return;
  719. }
  720. if(account.TotalAmt < Money)
  721. {
  722. Money = account.TotalAmt;
  723. }
  724. if(Money > 0)
  725. {
  726. // OperateAmountChange(db, UserId, Money, 2, 1, "商城购机", true, OrderId);
  727. // OperateAmountChange(db, UserId, Money, 1, 2, "商城购机", true, OrderId);
  728. OpAmountItem item = new OpAmountItem()
  729. {
  730. UserId = UserId,
  731. OperateType = 0,
  732. ChangeType = 5,
  733. Remark = "商城购机",
  734. UseAmount = Money,
  735. UseValidForGetAmount = Money,
  736. UseTotalAmt = Money,
  737. DataType = 2,
  738. DataId = OrderId,
  739. };
  740. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  741. }
  742. db.Dispose();
  743. }
  744. public void ActReserveBack(int UserId, decimal OpReserve1, decimal OpReserve2, decimal OpReserve3)
  745. {
  746. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  747. if(OpReserve1 > 0) OperateAmountChange(db, UserId, OpReserve1, 1, 1, "机具激活", true);
  748. if(OpReserve2 > 0) OperateAmountChange(db, UserId, OpReserve2, 1, 2, "机具激活", true);
  749. if(OpReserve3 > 0) OperateAmountChange(db, UserId, OpReserve3, 1, 3, "机具激活", true);
  750. db.Dispose();
  751. }
  752. public void OperateAmountChange(OpModels.WebCMSEntities db, int UserId, decimal Money, int OperateType, int AmountType, string Remark = "", bool record = false, int OrderId = 0)
  753. {
  754. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  755. if (account == null)
  756. {
  757. account = db.UserAccount.Add(new OpModels.UserAccount()
  758. {
  759. Id = UserId,
  760. UserId = UserId,
  761. }).Entity;
  762. db.SaveChanges();
  763. }
  764. decimal BeforeAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更前总金额
  765. if(OperateType == 1)
  766. {
  767. if(AmountType == 1)
  768. {
  769. // BeforeAmount = account.TotalAmt;
  770. account.TotalAmt += Money;
  771. // AfterAmount = account.TotalAmt;
  772. }
  773. else if(AmountType == 2)
  774. {
  775. // BeforeAmount = account.ValidForGetAmount;
  776. account.ValidForGetAmount += Money;
  777. // AfterAmount = account.ValidForGetAmount;
  778. }
  779. else
  780. {
  781. // BeforeAmount = account.ValidAmount;
  782. account.ValidAmount += Money;
  783. // AfterAmount = account.ValidAmount;
  784. }
  785. }
  786. else
  787. {
  788. if(AmountType == 1)
  789. {
  790. // BeforeAmount = account.TotalAmt;
  791. account.TotalAmt -= Money;
  792. // AfterAmount = account.TotalAmt;
  793. }
  794. else if(AmountType == 2)
  795. {
  796. // BeforeAmount = account.ValidForGetAmount;
  797. account.ValidForGetAmount -= Money;
  798. // AfterAmount = account.ValidForGetAmount;
  799. }
  800. else
  801. {
  802. // BeforeAmount = account.ValidAmount;
  803. account.ValidAmount -= Money;
  804. // AfterAmount = account.ValidAmount;
  805. }
  806. }
  807. decimal AfterAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更后总金额
  808. if(record)
  809. {
  810. OpModels.AmountRecord add = db.AmountRecord.Add(new OpModels.AmountRecord()
  811. {
  812. CreateDate = DateTime.Now,
  813. UpdateDate = DateTime.Now,
  814. OperateType = OperateType,
  815. AfterAmount = AfterAmount,
  816. AfterValidForGetAmount = account.ValidForGetAmount,
  817. AfterTotalAmt = account.TotalAmt,
  818. AfterValidAmount = account.ValidAmount,
  819. BeforeAmount = BeforeAmount,
  820. UseAmount = Money,
  821. UserId = UserId,
  822. SeoDescription = Remark,
  823. Version = AmountType,
  824. QueryCount = OrderId,
  825. }).Entity;
  826. OpModels.AmountChangeRecord amountChangeRecord = db.AmountChangeRecord.Add(new OpModels.AmountChangeRecord()
  827. {
  828. AmountType = AmountType,//1 未使用额度 2 可提现额度 3 关联分仓额度
  829. CreateDate = DateTime.Now,
  830. Title = Remark,
  831. UserId = UserId, //运营中心Id
  832. BeforeAmount = BeforeAmount,//使用前剩余额度
  833. AfterAmount = AfterAmount,//使用后剩余额度
  834. ChangeAmount = Money,//操作金额
  835. OperateType = OperateType,//操作类别
  836. Sort = OrderId,
  837. }).Entity;
  838. }
  839. db.SaveChanges();
  840. }
  841. #endregion
  842. #region 盟主推荐奖励
  843. public void LeaderRecommendPrize(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType)
  844. {
  845. int level = 0;
  846. Users orderuser = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  847. string ParentNav = orderuser.ParentNav + "," + UserId + ",";
  848. if(!string.IsNullOrEmpty(ParentNav))
  849. {
  850. string[] ParentNavList = ParentNav.Replace(",,", ",").TrimEnd(',').Split(',');
  851. Array.Reverse(ParentNavList);
  852. foreach(string ParentUserId in ParentNavList)
  853. {
  854. level += 1;
  855. int UserIdNum = int.Parse(function.CheckInt(ParentUserId));
  856. UserRankItem user = PosCouponPrizeService.Instance.GetUserLevel(UserIdNum) ?? new UserRankItem();
  857. if(user.Id > 0)
  858. {
  859. if((user.UserType >= 1 || user.LeaderLevel > 0) && level > 1 && Money > 0)
  860. {
  861. ChangeAccount(db, order, user.Id, Money, ChangeType);
  862. Money = 0;
  863. }
  864. }
  865. }
  866. }
  867. db.Dispose();
  868. }
  869. #endregion
  870. #region 购买盟主预设职级
  871. public void LeaderPreUserLevel(WebCMSEntities db, int UserId, int LeaderKind)
  872. {
  873. int Month = LeaderKind == 1 ? 6 : 9;
  874. int Rank = LeaderKind == 1 ? 5 : 7;
  875. LeaderRankWhite check = db.LeaderRankWhite.FirstOrDefault(m => m.Id == UserId);
  876. if(check == null)
  877. {
  878. db.LeaderRankWhite.Add(new LeaderRankWhite()
  879. {
  880. CreateDate = DateTime.Now, //设置时间
  881. UpdateDate = DateTime.Now.AddMonths(Month), //过期时间
  882. Rank = Rank,
  883. UserId = UserId, //用户
  884. Id = UserId,
  885. });
  886. }
  887. else
  888. {
  889. // if(check.Rank < Rank)
  890. // {
  891. check.Rank = Rank;
  892. check.UpdateDate = DateTime.Now.AddMonths(Month);
  893. // }
  894. // else if(check.Rank == Rank && check.UpdateDate < DateTime.Now.AddMonths(Month))
  895. // {
  896. // check.UpdateDate = DateTime.Now.AddMonths(Month);
  897. // }
  898. }
  899. db.SaveChanges();
  900. }
  901. //取消自留券数量
  902. public void CancelStayCoupon(WebCMSEntities db, int UserId, int CheckLevel = 5)
  903. {
  904. int myLevel = Utils.Instance.GetUserLevel(UserId);
  905. if(myLevel <= CheckLevel)
  906. {
  907. Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
  908. if(user != null)
  909. {
  910. user.Version = 0;
  911. db.SaveChanges();
  912. }
  913. }
  914. }
  915. #endregion
  916. #region 记录盟主
  917. public void AddLeader(WebCMSEntities db, int UserId, int LeaderLevel)
  918. {
  919. int Month = LeaderLevel == 1 ? 6 : 9;
  920. Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId);
  921. if(leader == null)
  922. {
  923. db.Leaders.Add(new Leaders()
  924. {
  925. Id = UserId,
  926. CreateDate = DateTime.Now, //设置时间
  927. UserId = UserId, //用户
  928. LeaderLevel = LeaderLevel,
  929. LastBuyDate = DateTime.Now,
  930. ExpiredDate = DateTime.Now.AddMonths(Month),
  931. });
  932. }
  933. else
  934. {
  935. leader.LeaderLevel = LeaderLevel;
  936. leader.LastBuyDate = DateTime.Now;
  937. leader.ExpiredDate = DateTime.Now.AddMonths(Month);
  938. }
  939. db.SaveChanges();
  940. SendLeaderMsg(db, UserId);
  941. }
  942. #endregion
  943. #region 盟主续费通知
  944. public void SendLeaderMsg(WebCMSEntities db, int UserId)
  945. {
  946. string msg = "";
  947. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  948. DateTime now = DateTime.Now;
  949. Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId);
  950. if(leader != null)
  951. {
  952. if(leader.ExpiredDate >= now)
  953. {
  954. msg = "尊敬的" + user.RealName + "盟主,恭喜您的盟主已成功开通";
  955. }
  956. else
  957. {
  958. msg = "尊敬的" + user.RealName + "盟主,恭喜您重新成为盟主";
  959. }
  960. }
  961. else
  962. {
  963. msg = "尊敬的" + user.RealName + "盟主,恭喜您的盟主已成功开通";
  964. }
  965. RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
  966. {
  967. UserId = Convert.ToInt32(UserId), //创客
  968. Title = "开通盟主提醒", //标题
  969. Content = "<div style=\"padding:12px 16px;\">" + msg + "</div>", //内容
  970. Summary = msg,
  971. CreateDate = DateTime.Now,
  972. }));
  973. }
  974. #endregion
  975. }
  976. }