AlipayPayBack2Service.cs 70 KB

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