AlipayPayBack2Service.cs 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267
  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. }
  71. }
  72. }
  73. }
  74. db.Dispose();
  75. }
  76. #region 新订单流程
  77. public void DoOrderV2(WebCMSEntities db, int OrderId)
  78. {
  79. Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId && m.Status <= 0);
  80. if (order != null)
  81. {
  82. order.Status = 1;
  83. order.PayDate = DateTime.Now;
  84. order.PayStatus = 1;
  85. db.SaveChanges();
  86. if(order.ParentOrderId > 0)
  87. {
  88. int total = db.Orders.Count(m => m.ParentOrderId == order.ParentOrderId);
  89. int paycount = db.Orders.Count(m => m.ParentOrderId == order.ParentOrderId && m.Status > 0);
  90. if(paycount >= total)
  91. {
  92. // order = db.Orders.FirstOrDefault(m => m.Id == order.ParentOrderId && m.Status == 0);
  93. // if (order != null)
  94. // {
  95. // order.Status = 2;
  96. // order.PayDate = DateTime.Now;
  97. // order.PayStatus = 1;
  98. // OrderId = order.Id;
  99. // }
  100. DoOrderV2(db, order.ParentOrderId);
  101. }
  102. return;
  103. }
  104. OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == OrderId);
  105. if (pro != null)
  106. {
  107. order.ProductId = pro.ProductId;
  108. //扣减对应商品的库存
  109. Products product = db.Products.FirstOrDefault(m => m.Id == pro.ProductId);
  110. if(product != null)
  111. {
  112. product.Stock -= pro.ProductCount;
  113. product.BuyCount += pro.ProductCount;
  114. }
  115. db.SaveChanges();
  116. if(order.ErpMode > 0)
  117. {
  118. pro.ProductId = order.ProductId;
  119. }
  120. List<int> couponIds = new List<int>();
  121. if (pro.ProductId == 10 || pro.ProductId == 11 || pro.ProductId == 27 || pro.ProductId == 28 || pro.ProductId == 34 || pro.ProductId == -2)
  122. {
  123. order.Status = 2;
  124. int BuyCount = pro.ProductCount;
  125. int Kind = 0;
  126. int BeforeLeaderLevel = 0;
  127. if (pro.ProductId == 10 || pro.ProductId == 34)
  128. {
  129. Kind = 1;
  130. }
  131. else if (pro.ProductId == 11 || pro.ProductId == -2)
  132. {
  133. Kind = 2;
  134. }
  135. else if (pro.ProductId == 28)
  136. {
  137. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId && m.LeaderLevel == 0);
  138. if(user != null)
  139. {
  140. BeforeLeaderLevel = user.LeaderLevel;
  141. user.LeaderLevel = 1;
  142. }
  143. }
  144. else if (pro.ProductId == 27)
  145. {
  146. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId && m.LeaderLevel < 2);
  147. if(user != null)
  148. {
  149. BeforeLeaderLevel = user.LeaderLevel;
  150. user.LeaderLevel = 2;
  151. }
  152. }
  153. if(Kind <= 2 && (pro.ProductId == 10 || pro.ProductId == 11 || pro.ProductId == 34 || pro.ProductId == -2))
  154. {
  155. // 购买600一组机具券,返券
  156. int CouponCount = 0;
  157. if(Kind == 1)
  158. {
  159. CouponCount = 3 * pro.ProductCount;
  160. }
  161. else if(Kind == 2)
  162. {
  163. CouponCount = 2 * pro.ProductCount;
  164. }
  165. if(pro.ProductId == 34) //助利宝商机券购买,50张起购
  166. {
  167. CouponCount = 50 * pro.ProductCount;
  168. }
  169. string Codes = "";
  170. 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();
  171. int RecordId = 0;
  172. if(coupons.Count > 0 && (pro.ProductId == 34 || pro.ProductId == -2))
  173. {
  174. var adds = db.HelpProfitExchange.Add(new HelpProfitExchange()
  175. {
  176. CreateDate = DateTime.Now, //创建时间
  177. UserId = order.UserId,
  178. ExchangeCount = coupons.Count,
  179. }).Entity;
  180. db.SaveChanges();
  181. RecordId = adds.Id;
  182. }
  183. foreach (var coupon in coupons) // TODO: 数量多的话,会慢
  184. {
  185. PosCoupons item = db.PosCoupons.FirstOrDefault(m => m.Id == coupon.Id);
  186. if (item != null)
  187. {
  188. item.CreateDate = DateTime.Now;
  189. item.UserId = order.UserId;
  190. item.UpdateDate = DateTime.Now.AddDays(180);
  191. if(pro.ProductId == 34 || pro.ProductId == -2)
  192. {
  193. item.HelpProfitFlag = 1;
  194. db.HelpProfitExchangeDetail.Add(new HelpProfitExchangeDetail()
  195. {
  196. CreateDate = DateTime.Now, //创建时间
  197. UserId = order.UserId,
  198. PosCouponId = item.Id,
  199. ExchangeCode = item.ExchangeCode,
  200. RecordId = RecordId,
  201. });
  202. }
  203. Codes += item.ExchangeCode + ",";
  204. couponIds.Add(coupon.Id);
  205. }
  206. }
  207. order.SnNos = Codes.TrimEnd(',');
  208. }
  209. db.SaveChanges();
  210. if (pro.ProductId == 27 || pro.ProductId == 28)
  211. {
  212. //充值盟主储备金
  213. decimal TotalPrice = 10000;
  214. if(pro.ProductId == 27)
  215. {
  216. TotalPrice = 40000;
  217. }
  218. OpReserve(db, order, order.UserId, TotalPrice, 1);
  219. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
  220. if(pro.ProductId == 27)
  221. {
  222. OperateReserveBackFor(db, user.Id, 40000);
  223. //预设大盟主职级
  224. LeaderPreUserLevel(db, order.UserId, 2);
  225. AddLeader(db, order.UserId, 2);
  226. decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "BigLeaderPrize")));
  227. if(Prize > 0 && BeforeLeaderLevel < 2 && user.UserType == 0)
  228. {
  229. LeaderRecommendPrize(db, order, user.Id, Prize, 122);
  230. }
  231. }
  232. }
  233. if (pro.ProductId == 28) //购买小盟主,给上级大盟主返储备金
  234. {
  235. bool check = LeaderBack(db, order);
  236. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
  237. if (check) OperateReserveBackFor(db, user.Id, 10000);
  238. //预设小盟主职级
  239. LeaderPreUserLevel(db, order.UserId, 1);
  240. AddLeader(db, order.UserId, 1);
  241. decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "SmallLeaderPrize")));
  242. if(Prize > 0 && BeforeLeaderLevel < 1 && user.UserType == 0)
  243. {
  244. LeaderRecommendPrize(db, order, user.Id, Prize, 123);
  245. }
  246. }
  247. }
  248. // 购买盟主储蓄金
  249. if (pro.ProductId == 39 || pro.ProductId == 40)
  250. {
  251. order.Status = 2;
  252. //充值盟主储备金
  253. decimal TotalPrice = 10000;
  254. if(pro.ProductId == 39)
  255. {
  256. TotalPrice = 40000;
  257. }
  258. OpReserve(db, order, order.UserId, TotalPrice, 1);
  259. if(pro.ProductId == 39) //购买大盟主储蓄金,给上级运营中心返可提现金额
  260. {
  261. OperateReserveBackFor(db, order.UserId, 40000);
  262. AddLeader(db, order.UserId, 2);
  263. LeaderPreUserLevel(db, order.UserId, 2);
  264. }
  265. else if(pro.ProductId == 40) //购买小盟主储蓄金,给上级大盟主返储备金
  266. {
  267. LeaderBack(db, order);
  268. AddLeader(db, order.UserId, 1);
  269. LeaderPreUserLevel(db, order.UserId, 1);
  270. }
  271. }
  272. //推荐下单奖励
  273. if (pro.ProductId == 10 || pro.ProductId == 11)
  274. {
  275. bool checkPrize = db.UserAccountRecord.Any(m => m.QueryCount == OrderId && m.ChangeType == 112);
  276. function.WriteLog("OrderId:" + OrderId, "推荐下单奖励监控日志");
  277. function.WriteLog("checkPrize:" + checkPrize, "推荐下单奖励监控日志");
  278. if (checkPrize)
  279. {
  280. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
  281. if (user != null)
  282. {
  283. if(user.LeaderLevel > 0 || user.UserType == 1) //盟主或运营中心
  284. {
  285. //获得100元奖励
  286. OpAccount(db, order, order.UserId, 100, pro.ProductCount);
  287. }
  288. }
  289. }
  290. else
  291. {
  292. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
  293. if (user != null)
  294. {
  295. bool directPrize = false; //直推奖标记
  296. bool bigLeaderPrize = false; //大盟主券标记
  297. bool operateFlag = false; //运营中心标记
  298. bool buyPrize = false; //返100购机奖励标记或返100购机奖励标记-运营中心
  299. int leaderFlag = 0; //返600备用金标记
  300. if(user.LeaderLevel > 0 || user.UserType == 1) //盟主或运营中心
  301. {
  302. if(user.LeaderLevel > 0)
  303. {
  304. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == order.UserId) ?? new UserAccount();
  305. if(acccount.LeaderReserve >= order.TotalPrice)
  306. {
  307. if(order.PayMode == 4)
  308. {
  309. //扣减备用金
  310. OpReserve(db, order, order.UserId, order.TotalPrice, 0, 0, "商城购机(储备金支付)");
  311. }
  312. //获得100元奖励
  313. OpAccount(db, order, order.UserId, 100, pro.ProductCount);
  314. }
  315. }
  316. else if(user.UserType == 1)
  317. {
  318. //获得100元奖励
  319. OpAccount(db, order, order.UserId, 100, pro.ProductCount);
  320. }
  321. //推荐奖励
  322. DirectPrize(db, order.Id, order.UserId, pro.ProductCount);
  323. //推荐下单上级获得30天的机具循环天数(盟主自己得)
  324. var posList = db.PosMachinesTwo.Select(m => new { m.Id, m.UserId, m.BindingState, m.RecycEndDate }).Where(m => m.UserId == order.UserId && m.BindingState == 0 && m.RecycEndDate != null).ToList();
  325. foreach (var subPos in posList)
  326. {
  327. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == subPos.Id);
  328. if (pos != null)
  329. {
  330. pos.RecycEndDate = pos.RecycEndDate.Value.AddDays(30);
  331. }
  332. }
  333. db.SaveChanges();
  334. if(order.PayMode == 4 && user.LeaderLevel > 0) //使用盟主储蓄金,并且是盟主
  335. {
  336. if(user.UserType == 1)
  337. {
  338. if(couponIds.Count > 0)
  339. {
  340. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == user.Id) ?? new UserAccount();
  341. foreach(int couponId in couponIds)
  342. {
  343. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  344. if(coupon != null)
  345. {
  346. if(acccount.LeaderReserve >= 400 * pro.ProductCount)
  347. {
  348. coupon.LeaderUserId = user.Id;
  349. }
  350. coupon.OpId = user.Id;
  351. }
  352. }
  353. }
  354. db.SaveChanges();
  355. }
  356. else
  357. {
  358. //寻找最近运营中心额度大于0的运营中心
  359. int PUserId = user.Id;
  360. bool OperateFlag = true;
  361. bool OncePrizeFlag1 = true;
  362. while(PUserId > 0)
  363. {
  364. Users puser = db.Users.FirstOrDefault(m => m.Id == PUserId);
  365. if(puser != null)
  366. {
  367. if(puser.UserType == 1 && OperateFlag == true) //运营中心
  368. {
  369. if(couponIds.Count > 0)
  370. {
  371. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == order.UserId) ?? new UserAccount();
  372. foreach(int couponId in couponIds)
  373. {
  374. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  375. if(coupon != null)
  376. {
  377. if(acccount.LeaderReserve >= 400 * pro.ProductCount)
  378. {
  379. coupon.LeaderUserId = user.Id;
  380. }
  381. coupon.OpId = puser.Id;
  382. }
  383. }
  384. db.SaveChanges();
  385. if(acccount.LeaderReserve >= 400 * pro.ProductCount && OncePrizeFlag1)
  386. {
  387. //扣减备用金
  388. OpReserve(db, order, order.UserId, 400 * pro.ProductCount, 2, 0, "商城购机");
  389. //返回到余额
  390. OpLeaderAccount(db, order, order.UserId, 400, pro.ProductCount);
  391. OncePrizeFlag1 = false;
  392. }
  393. OperateFlag = false;
  394. }
  395. }
  396. PUserId = puser.ParentUserId;
  397. }
  398. else
  399. {
  400. PUserId = 0;
  401. }
  402. }
  403. }
  404. }
  405. else if(order.PayMode == 4 && user.UserType == 1) //使用盟主储蓄金,并且是运营中心
  406. {
  407. if(couponIds.Count > 0)
  408. {
  409. foreach(int couponId in couponIds)
  410. {
  411. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  412. if(coupon != null)
  413. {
  414. coupon.OpId = user.Id;
  415. }
  416. }
  417. db.SaveChanges();
  418. //寻找最近储蓄金充足的大盟主
  419. int PUserId = user.Id;
  420. bool LeaderFlag = true;
  421. bool OncePrizeFlag2 = true;
  422. while(PUserId > 0)
  423. {
  424. Users puser = db.Users.FirstOrDefault(m => m.Id == PUserId);
  425. if(puser != null)
  426. {
  427. if(puser.LeaderLevel == 2 && LeaderFlag == true) //大盟主
  428. {
  429. if(couponIds.Count > 0)
  430. {
  431. UserAccount pacccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
  432. foreach(int couponId in couponIds)
  433. {
  434. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  435. if(coupon != null && pacccount.LeaderReserve >= 400 * pro.ProductCount)
  436. {
  437. coupon.LeaderUserId = puser.Id;
  438. }
  439. }
  440. db.SaveChanges();
  441. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == order.UserId) ?? new UserAccount();
  442. if(acccount.LeaderReserve >= 400 * pro.ProductCount && OncePrizeFlag2)
  443. {
  444. //扣减备用金
  445. OpReserve(db, order, order.UserId, 400 * pro.ProductCount, 2, 0, "商城购机");
  446. //返回到余额
  447. OpLeaderAccount(db, order, order.UserId, 400, pro.ProductCount);
  448. OncePrizeFlag2 = false;
  449. }
  450. LeaderFlag = false;
  451. }
  452. }
  453. PUserId = puser.ParentUserId;
  454. }
  455. else
  456. {
  457. PUserId = 0;
  458. }
  459. }
  460. }
  461. else
  462. {
  463. //寻找最近储蓄金充足的大盟主及最近运营中心额度大于0的运营中心(含自身)
  464. int PUserId = user.Id;
  465. int LeaderFlag = 0;
  466. bool OperateFlag = true;
  467. bool OncePrizeFlag3 = true;
  468. while(PUserId > 0)
  469. {
  470. Users puser = db.Users.FirstOrDefault(m => m.Id == PUserId);
  471. if(puser != null)
  472. {
  473. if(puser.LeaderLevel > 0 && puser.LeaderLevel > LeaderFlag && LeaderFlag < 2) //大盟主
  474. {
  475. if(couponIds.Count > 0)
  476. {
  477. if(puser.LeaderLevel == 2)
  478. {
  479. UserAccount pacccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
  480. foreach(int couponId in couponIds)
  481. {
  482. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  483. if(coupon != null && pacccount.LeaderReserve >= 400 * pro.ProductCount)
  484. {
  485. coupon.LeaderUserId = puser.Id;
  486. }
  487. }
  488. db.SaveChanges();
  489. }
  490. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
  491. if(acccount.LeaderReserve >= 400 * pro.ProductCount && OncePrizeFlag3)
  492. {
  493. //扣减备用金
  494. OpReserve(db, order, puser.Id, 400 * pro.ProductCount, 2, 0, "商城购机");
  495. //返回到余额
  496. OpLeaderAccount(db, order, puser.Id, 400, pro.ProductCount);
  497. LeaderFlag = puser.LeaderLevel;
  498. OncePrizeFlag3 = false;
  499. }
  500. }
  501. }
  502. if(puser.UserType == 1 && OperateFlag == true) //运营中心
  503. {
  504. if(couponIds.Count > 0)
  505. {
  506. foreach(int couponId in couponIds)
  507. {
  508. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  509. if(coupon != null)
  510. {
  511. coupon.OpId = puser.Id;
  512. }
  513. }
  514. db.SaveChanges();
  515. OperateFlag = false;
  516. }
  517. }
  518. PUserId = puser.ParentUserId;
  519. }
  520. else
  521. {
  522. PUserId = 0;
  523. }
  524. }
  525. //运营中心返额度(下单人自己是运营中心)
  526. // OperateReserveBackFor(db, order.UserId, order.TotalPrice);
  527. }
  528. return;
  529. }
  530. int ParentUserId = user.ParentUserId;
  531. // List<int> proids = new List<int>();
  532. // proids.Add(10);
  533. // proids.Add(11);
  534. // 普通创客购买600一组的机具券
  535. bool OncePrizeFlag4 = true;
  536. while(ParentUserId > 0)
  537. {
  538. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  539. int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == ParentUserId && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机
  540. int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == ParentUserId && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
  541. int couponCount = db.PosCoupons.Count(m => m.UserId == ParentUserId && m.IsUse == 0); //判断是否拥有3张券
  542. function.WriteLog("MakerCode:" + puser.MakerCode, "推荐下单奖励监控日志");
  543. function.WriteLog("machineCount:" + machineCount, "推荐下单奖励监控日志");
  544. function.WriteLog("ActiveCount:" + ActiveCount, "推荐下单奖励监控日志");
  545. if ((machineCount + ActiveCount + couponCount >= 3 || puser.LeaderLevel > 0) && !directPrize)
  546. {
  547. // function.WriteLog("满足条件", "推荐下单奖励监控日志");
  548. // if(puser.LeaderLevel == 0) // 非盟主直推奖励,每个创客第一次下单,上级可得
  549. // {
  550. // List<int> oids = new List<int>();
  551. // var orderpros = db.OrderProduct.Select(m => new { m.OrderId,m.UserId,m.ProductId }).Where(m => m.UserId == order.UserId && proids.Contains(m.ProductId)).ToList();
  552. // foreach(var orderpro in orderpros)
  553. // {
  554. // oids.Add(orderpro.OrderId);
  555. // }
  556. // bool check = db.Orders.Any(m => oids.Contains(m.Id) && m.Status > 0);
  557. // if(!check)
  558. // {
  559. // DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
  560. // directPrize = true;
  561. // }
  562. // }
  563. // else
  564. // {
  565. // 盟主直推奖励,可以每次下单获得
  566. DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
  567. directPrize = true;
  568. // }
  569. //推荐下单上级获得30天的机具循环天数
  570. var posList = db.PosMachinesTwo.Select(m => new { m.Id, m.UserId, m.BindingState, m.RecycEndDate }).Where(m => m.UserId == ParentUserId && m.BindingState == 0 && m.RecycEndDate != null).ToList();
  571. foreach (var subPos in posList)
  572. {
  573. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == subPos.Id);
  574. if (pos != null)
  575. {
  576. pos.RecycEndDate = pos.RecycEndDate.Value.AddDays(30);
  577. }
  578. }
  579. db.SaveChanges();
  580. }
  581. if(puser.LeaderLevel > 0)
  582. {
  583. function.WriteLog("OrderId:" + order.Id, "监控大盟主购机奖励");
  584. function.WriteLog("UserId:" + puser.Id, "监控大盟主购机奖励");
  585. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
  586. function.WriteLog("LeaderReserve:" + acccount.LeaderReserve, "监控大盟主购机奖励");
  587. function.WriteLog("buyPrize:" + buyPrize, "监控大盟主购机奖励");
  588. if(acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
  589. {
  590. //购机奖励
  591. OpAccount(db, order, puser.Id, 100, pro.ProductCount);
  592. buyPrize = true;
  593. }
  594. function.WriteLog("LeaderReserve:" + acccount.LeaderReserve, "监控大盟主购机奖励");
  595. function.WriteLog("leaderFlag:" + leaderFlag, "监控大盟主购机奖励");
  596. function.WriteLog("OncePrizeFlag4:" + OncePrizeFlag4, "监控大盟主购机奖励");
  597. function.WriteLog("-----------------------------", "监控大盟主购机奖励");
  598. if(acccount.LeaderReserve >= 400 * pro.ProductCount && puser.LeaderLevel > leaderFlag && leaderFlag < 2 && OncePrizeFlag4)
  599. {
  600. //扣减备用金
  601. OpReserve(db, order, puser.Id, 400 * pro.ProductCount, 2, order.UserId, "购机奖励");
  602. //返回到余额
  603. OpLeaderAccount(db, order, puser.Id, 400, pro.ProductCount);
  604. leaderFlag = puser.LeaderLevel;
  605. OncePrizeFlag4 = false;
  606. }
  607. //如果是小盟主,则查找该小盟主关联的大盟主储蓄金是否充足,是则给券打上关联大盟主标记
  608. if(couponIds.Count > 0 && puser.LeaderLevel == 1 && !bigLeaderPrize)
  609. {
  610. LeaderAccountRecord leaderItem = db.LeaderAccountRecord.FirstOrDefault(m => m.Sort == puser.Id && m.LeaderId > 0 && m.LeaderReserve >= 400 * pro.ProductCount);
  611. if(leaderItem != null)
  612. {
  613. leaderItem.LeaderReserve -= 400 * pro.ProductCount;
  614. foreach(int couponId in couponIds)
  615. {
  616. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  617. if(coupon != null)
  618. {
  619. coupon.LeaderUserId = leaderItem.LeaderId;
  620. }
  621. }
  622. db.SaveChanges();
  623. bigLeaderPrize = true;
  624. }
  625. }
  626. //如果是大盟主,则标记大盟主标签
  627. if(couponIds.Count > 0 && puser.LeaderLevel == 2 && acccount.LeaderReserve >= 400 * pro.ProductCount && !bigLeaderPrize)
  628. {
  629. foreach(int couponId in couponIds)
  630. {
  631. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  632. if(coupon != null)
  633. {
  634. coupon.LeaderUserId = puser.Id;
  635. }
  636. }
  637. db.SaveChanges();
  638. bigLeaderPrize = true;
  639. }
  640. }
  641. if(puser.UserType == 1)
  642. {
  643. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
  644. if(!buyPrize)
  645. {
  646. //购机奖励
  647. ChangeAccount(db, order, puser.Id, 100 * pro.ProductCount, 120);
  648. buyPrize = true;
  649. }
  650. //标记标签
  651. if(couponIds.Count > 0 && !operateFlag)
  652. {
  653. foreach(int couponId in couponIds)
  654. {
  655. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  656. if(coupon != null)
  657. {
  658. coupon.OpId= puser.Id;
  659. }
  660. }
  661. db.SaveChanges();
  662. operateFlag = true;
  663. }
  664. }
  665. ParentUserId = puser.ParentUserId;
  666. }
  667. //运营中心返额度
  668. // OperateReserveBackFor(db, order.UserId, order.TotalPrice);
  669. }
  670. }
  671. function.WriteLog("\r\n\r\n", "推荐下单奖励监控日志");
  672. }
  673. //推荐王
  674. if(pro.ProductId == 29)
  675. {
  676. RecommendMethod(order.UserId, order.CreateDate.Value.ToString("yyyyMM"));
  677. }
  678. //购买分仓临时额度
  679. if(pro.ProductId == 30 || pro.ProductId == 31 || pro.ProductId == 32)
  680. {
  681. string SendData = "{\"Kind\":\"1\",\"Data\":{\"OrderId\":\"" + order.Id + "\"}}";
  682. RedisDbconn.Instance.AddList("StoreApplyQueue", SendData);
  683. }
  684. //购买小分仓临时额度
  685. if(pro.ProductId == 56 || pro.ProductId == 57 || pro.ProductId == 58)
  686. {
  687. string SendData = "{\"Kind\":\"1\",\"Data\":{\"OrderId\":\"" + order.Id + "\"}}";
  688. RedisDbconn.Instance.AddList("PreStoreApplyQueue", SendData);
  689. }
  690. }
  691. else
  692. {
  693. if(order.ProductId > 0 && order.ErpMode > 0)
  694. {
  695. //盟主储备金-升级/购买 ErpMode:1-升级,2-购买
  696. if(order.ErpMode > 0)
  697. {
  698. Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
  699. if(user != null)
  700. {
  701. if(order.ErpMode == 1)
  702. {
  703. user.LeaderLevel = 2;
  704. db.SaveChanges();
  705. }
  706. OpReserve(db, order, order.UserId, order.TotalPrice, 1);
  707. }
  708. }
  709. }
  710. }
  711. }
  712. }
  713. //小盟主购买逻辑
  714. public bool LeaderBack(WebCMSEntities db, Orders order)
  715. {
  716. int LeaderUserId = order.UserId;
  717. int level = 0;
  718. bool result = true;
  719. while(LeaderUserId > 0)
  720. {
  721. level += 1;
  722. Users user = db.Users.FirstOrDefault(m => m.Id == LeaderUserId);
  723. if(user != null)
  724. {
  725. if(user.LeaderLevel == 2 && level > 1)
  726. {
  727. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == LeaderUserId);
  728. if(account != null)
  729. {
  730. decimal TotalPrice = 10000;
  731. if(account.LeaderReserve >= TotalPrice)
  732. {
  733. OpReserve(db, order, LeaderUserId, TotalPrice, 2, 0, "推荐小盟主");
  734. OpLeaderAccount(db, order, LeaderUserId, TotalPrice, 1, 1);
  735. LeaderUserId = 0;
  736. result = false;
  737. }
  738. else
  739. {
  740. LeaderUserId = user.ParentUserId;
  741. // decimal LeaderReserve = account.LeaderReserve;
  742. // OpReserve(db, order, LeaderUserId, LeaderReserve, 2, 0, "推荐小盟主");
  743. // OpLeaderAccount(db, order, LeaderUserId, LeaderReserve);
  744. }
  745. }
  746. }
  747. else
  748. {
  749. LeaderUserId = user.ParentUserId;
  750. }
  751. }
  752. else
  753. {
  754. LeaderUserId = 0;
  755. }
  756. }
  757. return result;
  758. }
  759. //操作储备金
  760. public void OpReserve(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType, int SourceUserId = 0, string Remark = "储备金购买")
  761. {
  762. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  763. if (account == null)
  764. {
  765. account = db.UserAccount.Add(new UserAccount()
  766. {
  767. Id = UserId,
  768. UserId = UserId,
  769. }).Entity;
  770. db.SaveChanges();
  771. }
  772. decimal BeforeAmount = account.LeaderReserve; //变更前总金额
  773. if(ChangeType == 1)
  774. {
  775. account.LeaderReserve += Money;
  776. }
  777. else
  778. {
  779. account.LeaderReserve -= Money;
  780. }
  781. decimal AfterAmount = account.LeaderReserve; //变更后总金额
  782. LeaderReserveRecord add = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  783. {
  784. CreateDate = DateTime.Now,
  785. ChangeType = ChangeType,
  786. OrderId = order.Id,
  787. Remark = Remark,
  788. AfterAmt = AfterAmount,
  789. BeforeAmt = BeforeAmount,
  790. ChangeAmt = Money,
  791. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  792. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  793. UserId = UserId,
  794. SourceUserId = SourceUserId,
  795. }).Entity;
  796. db.SaveChanges();
  797. }
  798. //操作余额
  799. public void OpAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1)
  800. {
  801. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  802. if (account == null)
  803. {
  804. account = db.UserAccount.Add(new UserAccount()
  805. {
  806. Id = UserId,
  807. UserId = UserId,
  808. }).Entity;
  809. db.SaveChanges();
  810. }
  811. int ChangeType = 0;
  812. if(Money == 600)
  813. {
  814. ChangeType = 117;
  815. }
  816. else if(Money == 100)
  817. {
  818. ChangeType = 118;
  819. }
  820. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  821. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  822. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  823. account.BalanceAmount += Money * Count;
  824. account.TotalAmount += Money * Count;
  825. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  826. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  827. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  828. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  829. {
  830. CreateDate = DateTime.Now,
  831. UpdateDate = DateTime.Now,
  832. UserId = UserId, //创客
  833. ChangeType = ChangeType, //变动类型
  834. ChangeAmount = Money * Count, //变更金额
  835. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  836. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  837. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  838. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  839. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  840. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  841. QueryCount = order.Id,
  842. }).Entity;
  843. db.SaveChanges();
  844. }
  845. public void ChangeAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType = 0, string Remark = "")
  846. {
  847. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  848. if (account == null)
  849. {
  850. account = db.UserAccount.Add(new UserAccount()
  851. {
  852. Id = UserId,
  853. UserId = UserId,
  854. }).Entity;
  855. db.SaveChanges();
  856. }
  857. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  858. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  859. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  860. account.BalanceAmount += Money;
  861. if(Money > 0)
  862. {
  863. account.TotalAmount += Money;
  864. }
  865. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  866. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  867. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  868. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  869. {
  870. CreateDate = DateTime.Now,
  871. UpdateDate = DateTime.Now,
  872. UserId = UserId, //创客
  873. ChangeType = ChangeType, //变动类型
  874. ChangeAmount = Math.Abs(Money), //变更金额
  875. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  876. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  877. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  878. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  879. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  880. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  881. QueryCount = order.Id,
  882. Remark = Remark,
  883. }).Entity;
  884. db.SaveChanges();
  885. }
  886. //操作盟主可提现余额
  887. public void OpLeaderAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1, int Kind = 0)
  888. {
  889. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  890. if (account == null)
  891. {
  892. account = db.UserAccount.Add(new UserAccount()
  893. {
  894. Id = UserId,
  895. UserId = UserId,
  896. }).Entity;
  897. db.SaveChanges();
  898. }
  899. int ChangeType = 0;
  900. if(Money == 400)
  901. {
  902. ChangeType = 117;
  903. }
  904. int LeaderId = 0;
  905. decimal LeaderReserve = 0;
  906. if(Kind == 1)
  907. {
  908. LeaderId = UserId;
  909. LeaderReserve = Money * Count;
  910. }
  911. decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前余额
  912. account.LeaderBalanceAmount += Money * Count;
  913. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后余额
  914. LeaderAccountRecord leaderAccountRecord = db.LeaderAccountRecord.Add(new LeaderAccountRecord()
  915. {
  916. CreateDate = DateTime.Now,
  917. UpdateDate = DateTime.Now,
  918. UserId = UserId, //创客
  919. ChangeType = ChangeType, //变动类型
  920. ChangeAmount = Money * Count, //变更金额
  921. BeforeBalanceAmount = BeforeLeaderBalanceAmount, //变更前余额
  922. AfterBalanceAmount = AfterLeaderBalanceAmount, //变更后余额
  923. QueryCount = order.Id,
  924. Sort = order.UserId,
  925. LeaderId = LeaderId,
  926. LeaderReserve = LeaderReserve,
  927. }).Entity;
  928. db.SaveChanges();
  929. }
  930. public void DirectPrize(WebCMSEntities db, int OrderId, int UserId, int Count = 1)
  931. {
  932. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  933. if (account == null)
  934. {
  935. account = db.UserAccount.Add(new UserAccount()
  936. {
  937. Id = UserId,
  938. UserId = UserId,
  939. }).Entity;
  940. db.SaveChanges();
  941. }
  942. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  943. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  944. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  945. account.BalanceAmount += 100 * Count;
  946. account.TotalAmount += 100 * Count;
  947. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  948. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  949. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  950. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  951. {
  952. CreateDate = DateTime.Now,
  953. UpdateDate = DateTime.Now,
  954. UserId = UserId, //创客
  955. ChangeType = 112, //变动类型
  956. ChangeAmount = 100 * Count, //变更金额
  957. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  958. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  959. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  960. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  961. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  962. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  963. QueryCount = OrderId,
  964. }).Entity;
  965. db.SaveChanges();
  966. }
  967. // 推荐王逻辑(下单)
  968. public void RecommendMethod(int UserId, string TradeMonth)
  969. {
  970. string SendData = "{\"Kind\":\"1\",\"Data\":{\"UserId\":\"" + UserId + "\",\"TradeMonth\":\"" + TradeMonth + "\"}}";
  971. RedisDbconn.Instance.AddList("RecommendActStatQueue", SendData);
  972. }
  973. //操作运营中心额度
  974. public void OperateReserveBackFor(WebCMSEntities maindb, int UserId, decimal Money)
  975. {
  976. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  977. while(UserId > 0)
  978. {
  979. Users user = maindb.Users.FirstOrDefault(m => m.Id == UserId);
  980. if(user != null)
  981. {
  982. bool sys = db.SysAdmin.Any(m => m.UserId == UserId);
  983. if(sys)
  984. {
  985. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  986. if(account.TotalAmt <= 0)
  987. {
  988. return;
  989. }
  990. if(account.TotalAmt < Money)
  991. {
  992. Money = account.TotalAmt;
  993. }
  994. if(Money > 0)
  995. {
  996. OperateAmountChange(db, UserId, Money, 2, 1, "商城购机");
  997. OperateAmountChange(db, UserId, Money, 1, 2, "商城购机");
  998. }
  999. UserId = 0;
  1000. }
  1001. else
  1002. {
  1003. UserId = user.ParentUserId;
  1004. }
  1005. }
  1006. else
  1007. {
  1008. UserId = 0;
  1009. }
  1010. }
  1011. db.Dispose();
  1012. }
  1013. public void OperateReserveBack(int UserId, decimal Money)
  1014. {
  1015. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  1016. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  1017. if(account.TotalAmt <= 0)
  1018. {
  1019. return;
  1020. }
  1021. if(account.TotalAmt < Money)
  1022. {
  1023. Money = account.TotalAmt;
  1024. }
  1025. if(Money > 0)
  1026. {
  1027. OperateAmountChange(db, UserId, Money, 2, 1, "商城购机");
  1028. OperateAmountChange(db, UserId, Money, 1, 2, "商城购机");
  1029. }
  1030. db.Dispose();
  1031. }
  1032. public void ActReserveBack(int UserId, decimal OpReserve1, decimal OpReserve2, decimal OpReserve3)
  1033. {
  1034. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  1035. if(OpReserve1 > 0) OperateAmountChange(db, UserId, OpReserve1, 1, 1, "机具激活", true);
  1036. if(OpReserve2 > 0) OperateAmountChange(db, UserId, OpReserve2, 1, 2, "机具激活", true);
  1037. if(OpReserve3 > 0) OperateAmountChange(db, UserId, OpReserve3, 1, 3, "机具激活", true);
  1038. db.Dispose();
  1039. }
  1040. public void OperateAmountChange(OpModels.WebCMSEntities db, int UserId, decimal Money, int OperateType, int AmountType, string Remark = "", bool record = false)
  1041. {
  1042. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  1043. if (account == null)
  1044. {
  1045. account = db.UserAccount.Add(new OpModels.UserAccount()
  1046. {
  1047. Id = UserId,
  1048. UserId = UserId,
  1049. }).Entity;
  1050. db.SaveChanges();
  1051. }
  1052. decimal BeforeAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更前总金额
  1053. if(OperateType == 1)
  1054. {
  1055. if(AmountType == 1)
  1056. {
  1057. // BeforeAmount = account.TotalAmt;
  1058. account.TotalAmt += Money;
  1059. // AfterAmount = account.TotalAmt;
  1060. }
  1061. else if(AmountType == 2)
  1062. {
  1063. // BeforeAmount = account.ValidForGetAmount;
  1064. account.ValidForGetAmount += Money;
  1065. // AfterAmount = account.ValidForGetAmount;
  1066. }
  1067. else
  1068. {
  1069. // BeforeAmount = account.ValidAmount;
  1070. account.ValidAmount += Money;
  1071. // AfterAmount = account.ValidAmount;
  1072. }
  1073. }
  1074. else
  1075. {
  1076. if(AmountType == 1)
  1077. {
  1078. // BeforeAmount = account.TotalAmt;
  1079. account.TotalAmt -= Money;
  1080. // AfterAmount = account.TotalAmt;
  1081. }
  1082. else if(AmountType == 2)
  1083. {
  1084. // BeforeAmount = account.ValidForGetAmount;
  1085. account.ValidForGetAmount -= Money;
  1086. // AfterAmount = account.ValidForGetAmount;
  1087. }
  1088. else
  1089. {
  1090. // BeforeAmount = account.ValidAmount;
  1091. account.ValidAmount -= Money;
  1092. // AfterAmount = account.ValidAmount;
  1093. }
  1094. }
  1095. decimal AfterAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更后总金额
  1096. if(record)
  1097. {
  1098. OpModels.AmountRecord add = db.AmountRecord.Add(new OpModels.AmountRecord()
  1099. {
  1100. CreateDate = DateTime.Now,
  1101. UpdateDate = DateTime.Now,
  1102. OperateType = OperateType,
  1103. AfterAmount = AfterAmount,
  1104. BeforeAmount = BeforeAmount,
  1105. UseAmount = Money,
  1106. UserId = UserId,
  1107. SeoDescription = Remark,
  1108. Version = AmountType,
  1109. }).Entity;
  1110. }
  1111. db.SaveChanges();
  1112. }
  1113. #endregion
  1114. #region 盟主推荐奖励
  1115. public void LeaderRecommendPrize(WebCMSEntities db, Orders order, int UserId, decimal Money, int ChangeType)
  1116. {
  1117. int level = 0;
  1118. while(UserId > 0)
  1119. {
  1120. level += 1;
  1121. Users user = db.Users.FirstOrDefault(m => m.Id == UserId);
  1122. if(user != null)
  1123. {
  1124. if((user.UserType == 1 || user.LeaderLevel > 0) && level > 1)
  1125. {
  1126. ChangeAccount(db, order, UserId, Money, ChangeType);
  1127. UserId = 0;
  1128. }
  1129. else
  1130. {
  1131. UserId = user.ParentUserId;
  1132. }
  1133. }
  1134. else
  1135. {
  1136. UserId = 0;
  1137. }
  1138. }
  1139. db.Dispose();
  1140. }
  1141. #endregion
  1142. #region 购买盟主预设职级
  1143. public void LeaderPreUserLevel(WebCMSEntities db, int UserId, int LeaderKind)
  1144. {
  1145. int Month = LeaderKind == 1 ? 6 : 12;
  1146. int Rank = LeaderKind == 1 ? 5 : 7;
  1147. UserRankWhite check = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId);
  1148. if(check == null)
  1149. {
  1150. db.UserRankWhite.Add(new UserRankWhite()
  1151. {
  1152. CreateDate = DateTime.Now, //设置时间
  1153. UpdateDate = DateTime.Now.AddMonths(Month), //过期时间
  1154. Rank = Rank,
  1155. UserId = UserId, //用户
  1156. Id = UserId,
  1157. });
  1158. }
  1159. else
  1160. {
  1161. if(check.Rank < Rank)
  1162. {
  1163. check.Rank = Rank;
  1164. check.UpdateDate = DateTime.Now.AddMonths(Month);
  1165. }
  1166. else if(check.Rank == Rank && check.UpdateDate < DateTime.Now.AddMonths(Month))
  1167. {
  1168. check.UpdateDate = DateTime.Now.AddMonths(Month);
  1169. }
  1170. }
  1171. db.SaveChanges();
  1172. }
  1173. #endregion
  1174. #region 记录盟主
  1175. public void AddLeader(WebCMSEntities db, int UserId, int LeaderLevel)
  1176. {
  1177. int Month = LeaderLevel == 1 ? 6 : 12;
  1178. Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId);
  1179. if(leader == null)
  1180. {
  1181. db.Leaders.Add(new Leaders()
  1182. {
  1183. Id = UserId,
  1184. CreateDate = DateTime.Now, //设置时间
  1185. UserId = UserId, //用户
  1186. LeaderLevel = LeaderLevel,
  1187. LastBuyDate = DateTime.Now,
  1188. ExpiredDate = DateTime.Now.AddMonths(Month),
  1189. });
  1190. }
  1191. else
  1192. {
  1193. leader.LeaderLevel = LeaderLevel;
  1194. leader.LastBuyDate = DateTime.Now;
  1195. leader.ExpiredDate = DateTime.Now.AddMonths(Month);
  1196. }
  1197. db.SaveChanges();
  1198. SendLeaderMsg(db, UserId);
  1199. }
  1200. #endregion
  1201. #region 盟主续费通知
  1202. public void SendLeaderMsg(WebCMSEntities db, int UserId)
  1203. {
  1204. string msg = "";
  1205. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1206. DateTime now = DateTime.Now;
  1207. Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId);
  1208. if(leader != null)
  1209. {
  1210. if(leader.ExpiredDate >= now)
  1211. {
  1212. msg = "尊敬的" + user.RealName + "盟主,恭喜您的盟主已成功开通";
  1213. }
  1214. else
  1215. {
  1216. msg = "尊敬的" + user.RealName + "盟主,恭喜您重新成为盟主";
  1217. }
  1218. }
  1219. else
  1220. {
  1221. msg = "尊敬的" + user.RealName + "盟主,恭喜您的盟主已成功开通";
  1222. }
  1223. RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
  1224. {
  1225. UserId = Convert.ToInt32(UserId), //创客
  1226. Title = "开通盟主提醒", //标题
  1227. Content = msg, //内容
  1228. Summary = msg,
  1229. CreateDate = DateTime.Now,
  1230. }));
  1231. }
  1232. #endregion
  1233. }
  1234. }