AlipayPayBack2Service.cs 71 KB

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