AlipayPayBack2Service.cs 70 KB

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