PosCouponPrizeService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676
  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 PosCouponPrizeService
  12. {
  13. public readonly static PosCouponPrizeService Instance = new PosCouponPrizeService();
  14. private PosCouponPrizeService()
  15. { }
  16. public void Start()
  17. {
  18. Thread th = new Thread(ready);
  19. th.IsBackground = true;
  20. th.Start();
  21. }
  22. private void ready()
  23. {
  24. bool op = true;
  25. while (op)
  26. {
  27. string content = RedisDbconn.Instance.RPop<string>("PosCouponPrizeQueue");
  28. if (!string.IsNullOrEmpty(content))
  29. {
  30. try
  31. {
  32. dosomething(int.Parse(function.CheckInt(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 dosomething(int OrderId)
  46. {
  47. WebCMSEntities db = new WebCMSEntities();
  48. OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
  49. Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId);
  50. if(order != null)
  51. {
  52. List<int> ChkIds = new List<int>(); //机具券商品Id集合
  53. ChkIds.Add(10);
  54. ChkIds.Add(11);
  55. ChkIds.Add(77);
  56. ChkIds.Add(78);
  57. ChkIds.Add(79);
  58. //判断是否是指定商品
  59. if(ChkIds.Contains(order.ProductId))
  60. {
  61. int Kind = 0;
  62. if (order.ProductId == 10)
  63. {
  64. Kind = 1;
  65. }
  66. else if (order.ProductId == 11)
  67. {
  68. Kind = 2;
  69. }
  70. int CouponCount = 0;
  71. if(Kind == 1)
  72. {
  73. CouponCount = 3 * order.BuyCount;
  74. }
  75. else if(Kind == 2)
  76. {
  77. CouponCount = 2 * order.BuyCount;
  78. }
  79. UserRankItem orderUser = GetUserLevel(order.UserId);
  80. if(orderUser.UserLevel == 0)
  81. {
  82. PreUserLevel(db, order.UserId, 1, DateTime.Parse("2025-01-01 00:00:00"));
  83. }
  84. string ParentNav = orderUser.ParentNav + "," + orderUser.Id + ",";
  85. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  86. Array.Reverse(ParentNavList);
  87. int index = 0;
  88. bool DirectPrizeFlag = false; //推荐奖励发放标识
  89. bool BackAccountFlag = false; //备用金返余额标识
  90. bool BigLeaderFlag = false; //大盟主标记
  91. decimal BuyPrize = 0; //购机奖励
  92. foreach(string ParentId in ParentNavList)
  93. {
  94. UserRankItem parentUser = GetUserLevel(int.Parse(ParentId));
  95. index += 1;
  96. if(index == 1 && (orderUser.LeaderLevel > 0 || orderUser.OperateLevel > 0) && !DirectPrizeFlag)
  97. {
  98. DirectPrize(db, order.Id, order.UserId, order.BuyCount);
  99. DirectPrizeFlag = true;
  100. }
  101. if(index > 1)
  102. {
  103. if(Utils.Instance.IsStandardUser(parentUser.Id) && !DirectPrizeFlag)
  104. {
  105. DirectPrize(db, order.Id, parentUser.Id, order.BuyCount);
  106. DirectPrizeFlag = true;
  107. }
  108. }
  109. if(parentUser.AgoLeaderLevel > 0 && CheckLeaderReserve(db, order.BuyCount, parentUser.Id))
  110. {
  111. //购机奖
  112. if(parentUser.LeaderLevel > 0)
  113. {
  114. decimal CurBuyPrize = GetBuyPrize(parentUser);
  115. decimal GetPrize = CurBuyPrize - BuyPrize;
  116. if(GetPrize > 0)
  117. {
  118. bool PrizeFlag = true;
  119. int ChangeType = 118;
  120. if(parentUser.OperateLevel == 1)
  121. {
  122. ChangeType = 120;
  123. }
  124. if(parentUser.OperateLevel > 1)
  125. {
  126. ChangeType = 128;
  127. if(function.CheckNull(RedisDbconn.Instance.Get<string>("YingXunUser")).Contains("," + orderUser.Id + ","))
  128. {
  129. PrizeFlag = false;
  130. }
  131. }
  132. if(PrizeFlag)
  133. {
  134. OpAccount(db, order.Id, parentUser.Id, CurBuyPrize - BuyPrize, order.BuyCount, ChangeType);
  135. }
  136. BuyPrize = CurBuyPrize;
  137. }
  138. }
  139. if(!BackAccountFlag)
  140. {
  141. BackAccountFlag = true;
  142. //扣减备用金
  143. int ReserveRecordId = OpReserve(db, order.Id, parentUser.Id, GetWithdrawMoney(parentUser) * order.BuyCount, 2, order.UserId, "购机奖励");
  144. //返回到余额
  145. OpLeaderAccount(db, order, parentUser.Id, GetWithdrawMoney(parentUser), order.BuyCount, ReserveRecordId);
  146. }
  147. //给券打大盟主标记
  148. if(parentUser.LeaderLevel == 2 && !BigLeaderFlag)
  149. {
  150. BigLeaderFlag = true;
  151. if(!string.IsNullOrEmpty(order.SnNos))
  152. {
  153. List<string> codes = order.SnNos.Split(',').ToList();
  154. List<int> couponIds = db.PosCoupons.Where(m => codes.Contains(m.ExchangeCode)).OrderBy(m => m.Id).Take(CouponCount).ToList().Select(m => m.Id).ToList();
  155. SetPosCouponLeaderFlag(db, parentUser.Id, order.BuyCount, couponIds);
  156. }
  157. }
  158. }
  159. else if(parentUser.OperateLevel > 0 && CheckOpReserve(opdb, order.BuyCount, parentUser.Id))
  160. {
  161. //购机奖
  162. decimal CurBuyPrize = GetBuyPrize(parentUser);
  163. decimal GetPrize = CurBuyPrize - BuyPrize;
  164. if(GetPrize > 0)
  165. {
  166. int ChangeType = 120;
  167. if(parentUser.OperateLevel > 1)
  168. {
  169. ChangeType = 128;
  170. }
  171. OpAccount(db, order.Id, parentUser.Id, GetPrize, order.BuyCount, ChangeType);
  172. BuyPrize = CurBuyPrize;
  173. }
  174. if(!BackAccountFlag)
  175. {
  176. BackAccountFlag = true;
  177. decimal GetAmount = GetWithdrawMoney(parentUser) * order.BuyCount;
  178. //扣减备用金
  179. // OperateAmountChange(opdb, parentUser.Id, GetAmount, 2, 1, "商城购机", true, order.Id);
  180. // //返回到余额
  181. // OperateAmountChange(opdb, parentUser.Id, GetAmount, 1, 2, "商城购机", true, order.Id);
  182. OpAmountItem item = new OpAmountItem()
  183. {
  184. UserId = parentUser.Id,
  185. OperateType = 0,
  186. ChangeType = 5,
  187. Remark = "商城购机",
  188. UseAmount = GetAmount,
  189. UseValidForGetAmount = GetAmount,
  190. UseTotalAmt = GetAmount,
  191. DataType = 1,
  192. DataId = order.Id,
  193. };
  194. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
  195. }
  196. }
  197. }
  198. }
  199. }
  200. db.Dispose();
  201. opdb.Dispose();
  202. }
  203. /// <summary>
  204. /// 获取创客各种等级
  205. /// </summary>
  206. /// <param name="db"></param>
  207. /// <param name="UserId"></param>
  208. /// <returns></returns>
  209. public UserRankItem GetUserLevel(int UserId)
  210. {
  211. WebCMSEntities db = new WebCMSEntities();
  212. OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
  213. UserRankItem dic = new UserRankItem();
  214. DateTime now = DateTime.Now;
  215. Users user = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1) ?? new Users();
  216. UserRankWhite userWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId && m.UpdateDate > now) ?? new UserRankWhite();
  217. Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId) ?? new Leaders();
  218. dic.UserLevel = userWhite.Rank > user.UserLevel ? userWhite.Rank : user.UserLevel;
  219. if(leader.ExpiredDate > now)
  220. {
  221. dic.LeaderLevel = leader.LeaderLevel;
  222. }
  223. dic.AgoLeaderLevel = leader.LeaderLevel;
  224. OpModels.SysAdmin sys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == UserId) ?? new OpModels.SysAdmin();
  225. if(sys.ExpireDate > now)
  226. {
  227. dic.OperateLevel = user.UserType;
  228. dic.UserType = user.UserType;
  229. }
  230. dic.MerchantType = user.MerchantType;
  231. dic.Id = user.Id;
  232. dic.MakerCode = user.MakerCode;
  233. dic.RealName = user.RealName;
  234. dic.ParentUserId = user.ParentUserId;
  235. dic.ParentNav = user.ParentNav;
  236. db.Dispose();
  237. opdb.Dispose();
  238. return dic;
  239. }
  240. /// <summary>
  241. /// 直推奖励
  242. /// </summary>
  243. /// <param name="db"></param>
  244. /// <param name="OrderId"></param>
  245. /// <param name="UserId"></param>
  246. /// <param name="Count"></param>
  247. public void DirectPrize(WebCMSEntities db, int OrderId, int UserId, int Count = 1)
  248. {
  249. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  250. if (account == null)
  251. {
  252. account = db.UserAccount.Add(new UserAccount()
  253. {
  254. Id = UserId,
  255. UserId = UserId,
  256. }).Entity;
  257. db.SaveChanges();
  258. }
  259. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  260. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  261. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  262. account.BalanceAmount += 100 * Count;
  263. account.TotalAmount += 100 * Count;
  264. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  265. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  266. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  267. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  268. {
  269. CreateDate = DateTime.Now,
  270. UpdateDate = DateTime.Now,
  271. UserId = UserId, //创客
  272. ChangeType = 112, //变动类型
  273. ChangeAmount = 100 * Count, //变更金额
  274. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  275. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  276. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  277. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  278. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  279. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  280. QueryCount = OrderId,
  281. }).Entity;
  282. db.SaveChanges();
  283. }
  284. /// <summary>
  285. /// 判断盟主储蓄金足够
  286. /// </summary>
  287. /// <param name="db"></param>
  288. /// <param name="Count"></param>
  289. /// <param name="UserId"></param>
  290. /// <returns></returns>
  291. public bool CheckLeaderReserve(WebCMSEntities db, int Count, int UserId)
  292. {
  293. UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new UserAccount();
  294. if(acccount.LeaderReserve >= 400 * Count)
  295. {
  296. return true;
  297. }
  298. return false;
  299. }
  300. /// <summary>
  301. /// 判断运营中心/合伙人额度足够
  302. /// </summary>
  303. /// <param name="db"></param>
  304. /// <param name="Count"></param>
  305. /// <param name="UserId"></param>
  306. /// <returns></returns>
  307. public bool CheckOpReserve(OpModels.WebCMSEntities db, int Count, int UserId)
  308. {
  309. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  310. if(account.TotalAmt >= 400 * Count)
  311. {
  312. return true;
  313. }
  314. return false;
  315. }
  316. public bool CheckOpReserve(OpModels.WebCMSEntities db, decimal Amt, int UserId)
  317. {
  318. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
  319. if(account.TotalAmt >= Amt)
  320. {
  321. return true;
  322. }
  323. return false;
  324. }
  325. /// <summary>
  326. /// 扣减/增加盟主储蓄金
  327. /// </summary>
  328. /// <param name="db"></param>
  329. /// <param name="OrderId"></param>
  330. /// <param name="UserId"></param>
  331. /// <param name="Money"></param>
  332. /// <param name="ChangeType"></param>
  333. /// <param name="SourceUserId"></param>
  334. /// <param name="Remark"></param>
  335. public int OpReserve(WebCMSEntities db, int OrderId, int UserId, decimal Money, int ChangeType, int SourceUserId = 0, string Remark = "储备金购买")
  336. {
  337. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  338. if (account == null)
  339. {
  340. account = db.UserAccount.Add(new UserAccount()
  341. {
  342. Id = UserId,
  343. UserId = UserId,
  344. }).Entity;
  345. db.SaveChanges();
  346. }
  347. decimal BeforeAmount = account.LeaderReserve; //变更前总金额
  348. if(ChangeType == 1)
  349. {
  350. account.LeaderReserve += Money;
  351. }
  352. else
  353. {
  354. account.LeaderReserve -= Money;
  355. }
  356. decimal AfterAmount = account.LeaderReserve; //变更后总金额
  357. LeaderReserveRecord add = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  358. {
  359. CreateDate = DateTime.Now,
  360. ChangeType = ChangeType,
  361. OrderId = OrderId,
  362. Remark = Remark,
  363. AfterAmt = AfterAmount,
  364. BeforeAmt = BeforeAmount,
  365. ChangeAmt = Money,
  366. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  367. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  368. UserId = UserId,
  369. SourceUserId = SourceUserId,
  370. Sort = GetLeaderReserveRecordType(Remark),
  371. }).Entity;
  372. db.SaveChanges();
  373. return add.Id;
  374. }
  375. private int GetLeaderReserveRecordType(string Remark)
  376. {
  377. Dictionary<int, string> data = new Dictionary<int, string>();
  378. data.Add(11, "兑换机具券,机具券兑换,系统增加(盟主储蓄金),系统扣减(盟主储蓄金),储备金购买");
  379. data.Add(12, "系统增加(可提现余额),系统扣减(可提现余额)");
  380. data.Add(13, "推荐大盟主,推荐小盟主,商城购机,购机奖励");
  381. var item = data.FirstOrDefault(m => m.Value.Contains(Remark));
  382. if(item.Key > 0)
  383. {
  384. return item.Key;
  385. }
  386. return 0;
  387. }
  388. /// <summary>
  389. /// 操作盟主可提现余额
  390. /// </summary>
  391. /// <param name="db"></param>
  392. /// <param name="order"></param>
  393. /// <param name="UserId"></param>
  394. /// <param name="Money"></param>
  395. /// <param name="Count"></param>
  396. /// <param name="Kind"></param>
  397. public void OpLeaderAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1, int ReserveRecordId = 0)
  398. {
  399. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  400. if (account == null)
  401. {
  402. account = db.UserAccount.Add(new UserAccount()
  403. {
  404. Id = UserId,
  405. UserId = UserId,
  406. }).Entity;
  407. db.SaveChanges();
  408. }
  409. int ChangeType = 0;
  410. if(Money == 400)
  411. {
  412. ChangeType = 117;
  413. }
  414. decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前余额
  415. account.LeaderBalanceAmount += Money * Count;
  416. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后余额
  417. LeaderAccountRecord leaderAccountRecord = db.LeaderAccountRecord.Add(new LeaderAccountRecord()
  418. {
  419. CreateDate = DateTime.Now,
  420. UpdateDate = DateTime.Now,
  421. UserId = UserId, //创客
  422. ChangeType = ChangeType, //变动类型
  423. ChangeAmount = Money * Count, //变更金额
  424. BeforeBalanceAmount = BeforeLeaderBalanceAmount, //变更前余额
  425. AfterBalanceAmount = AfterLeaderBalanceAmount, //变更后余额
  426. QueryCount = order.Id,
  427. Sort = order.UserId,
  428. }).Entity;
  429. db.SaveChanges();
  430. if(ReserveRecordId > 0)
  431. {
  432. LeaderReserveRecord edit = db.LeaderReserveRecord.FirstOrDefault(m => m.Id == ReserveRecordId);
  433. if(edit != null)
  434. {
  435. edit.AccountRecordId = leaderAccountRecord.Id;
  436. db.SaveChanges();
  437. }
  438. }
  439. }
  440. /// <summary>
  441. /// 操作余额
  442. /// </summary>
  443. /// <param name="db"></param>
  444. /// <param name="order"></param>
  445. /// <param name="UserId"></param>
  446. /// <param name="Money"></param>
  447. /// <param name="Count"></param>
  448. public void OpAccount(WebCMSEntities db, int OrderId, int UserId, decimal Money, int Count = 1, int ChangeType = 0, int Kind = 0)
  449. {
  450. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  451. if (account == null)
  452. {
  453. account = db.UserAccount.Add(new UserAccount()
  454. {
  455. Id = UserId,
  456. UserId = UserId,
  457. }).Entity;
  458. db.SaveChanges();
  459. }
  460. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  461. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  462. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  463. account.BalanceAmount += Money * Count;
  464. account.TotalAmount += Money * Count;
  465. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  466. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  467. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  468. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  469. {
  470. CreateDate = DateTime.Now,
  471. UpdateDate = DateTime.Now,
  472. UserId = UserId, //创客
  473. ChangeType = ChangeType, //变动类型
  474. ChangeAmount = Money * Count, //变更金额
  475. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  476. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  477. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  478. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  479. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  480. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  481. QueryCount = OrderId,
  482. Kind = Kind,
  483. }).Entity;
  484. db.SaveChanges();
  485. }
  486. /// <summary>
  487. /// 操作运营中心/合伙人额度(TotalAmt未使用额度,ValidForGetAmount可提现额度)
  488. /// </summary>
  489. /// <param name="db"></param>
  490. /// <param name="UserId"></param>
  491. /// <param name="Money"></param>
  492. /// <param name="OperateType">(1增加,2减少)</param>
  493. /// <param name="AmountType">(1未使用额度,2可提现额度)</param>
  494. /// <param name="Remark"></param>
  495. /// <param name="record"></param>
  496. public void OperateAmountChange(OpModels.WebCMSEntities db, int UserId, decimal Money, int OperateType, int AmountType, string Remark = "", bool record = false, int OrderId = 0)
  497. {
  498. OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  499. if (account == null)
  500. {
  501. account = db.UserAccount.Add(new OpModels.UserAccount()
  502. {
  503. Id = UserId,
  504. UserId = UserId,
  505. }).Entity;
  506. db.SaveChanges();
  507. }
  508. decimal BeforeAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更前总金额
  509. if(OperateType == 1)
  510. {
  511. if(AmountType == 1)
  512. {
  513. account.TotalAmt += Money;
  514. }
  515. else if(AmountType == 2)
  516. {
  517. account.ValidForGetAmount += Money;
  518. }
  519. else
  520. {
  521. account.ValidAmount += Money;
  522. }
  523. }
  524. else
  525. {
  526. if(AmountType == 1)
  527. {
  528. account.TotalAmt -= Money;
  529. }
  530. else if(AmountType == 2)
  531. {
  532. account.ValidForGetAmount -= Money;
  533. }
  534. else
  535. {
  536. account.ValidAmount -= Money;
  537. }
  538. }
  539. decimal AfterAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更后总金额
  540. if(record)
  541. {
  542. OpModels.AmountRecord add = db.AmountRecord.Add(new OpModels.AmountRecord()
  543. {
  544. CreateDate = DateTime.Now,
  545. UpdateDate = DateTime.Now,
  546. OperateType = OperateType,
  547. AfterAmount = AfterAmount,
  548. AfterValidForGetAmount = account.ValidForGetAmount,
  549. AfterTotalAmt = account.TotalAmt,
  550. AfterValidAmount = account.ValidAmount,
  551. BeforeAmount = BeforeAmount,
  552. UseAmount = Money,
  553. UserId = UserId,
  554. SeoDescription = Remark,
  555. Version = AmountType,
  556. QueryCount = OrderId,
  557. }).Entity;
  558. OpModels.AmountChangeRecord amountChangeRecord = db.AmountChangeRecord.Add(new OpModels.AmountChangeRecord()
  559. {
  560. AmountType = 2,//1 未使用额度 2 可提现额度 3 关联分仓额度
  561. CreateDate = DateTime.Now,
  562. Title = Remark,
  563. UserId = UserId, //运营中心Id
  564. BeforeAmount = BeforeAmount,//使用前剩余额度
  565. AfterAmount = AfterAmount,//使用后剩余额度
  566. ChangeAmount = Money,//操作金额
  567. OperateType = OperateType,//操作类别
  568. Sort = OrderId,
  569. }).Entity;
  570. }
  571. db.SaveChanges();
  572. }
  573. /// <summary>
  574. /// 给券设置大盟主标记
  575. /// </summary>
  576. /// <param name="db"></param>
  577. /// <param name="LeaderUserId"></param>
  578. /// <param name="Count"></param>
  579. /// <param name="couponIds"></param>
  580. public int SetPosCouponLeaderFlag(WebCMSEntities db, int LeaderUserId, int Count, List<int> couponIds)
  581. {
  582. int SetCount = 0;
  583. UserAccount pacccount = db.UserAccount.FirstOrDefault(m => m.Id == LeaderUserId) ?? new UserAccount();
  584. foreach(int couponId in couponIds)
  585. {
  586. PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
  587. if(coupon != null && pacccount.LeaderReserve >= 400 * Count)
  588. {
  589. coupon.LeaderUserId = LeaderUserId;
  590. SetCount += 1;
  591. }
  592. }
  593. db.SaveChanges();
  594. return SetCount;
  595. }
  596. /// <summary>
  597. /// 获取购机奖金额
  598. /// </summary>
  599. /// <param name="user"></param>
  600. /// <returns></returns>
  601. public decimal GetBuyPrize(UserRankItem user)
  602. {
  603. if(user.OperateLevel == 1) return 100;
  604. if(user.OperateLevel == 2) return 160;
  605. if(user.OperateLevel == 3) return 180;
  606. if(user.OperateLevel == 4) return 200;
  607. if(user.LeaderLevel > 0) return 100;
  608. return 0;
  609. }
  610. /// <summary>
  611. /// 获取可提现金额
  612. /// </summary>
  613. /// <param name="user"></param>
  614. /// <returns></returns>
  615. public decimal GetWithdrawMoney(UserRankItem user)
  616. {
  617. if(user.OperateLevel == 1) return 400;
  618. // if(user.OperateLevel == 2) return 340;
  619. // if(user.OperateLevel == 3) return 320;
  620. // if(user.OperateLevel == 4) return 300;
  621. if(user.OperateLevel == 2) return 400;
  622. if(user.OperateLevel == 3) return 400;
  623. if(user.OperateLevel == 4) return 400;
  624. if(user.AgoLeaderLevel > 0) return 400;
  625. return 0;
  626. }
  627. /// <summary>
  628. /// 预设职级
  629. /// </summary>
  630. /// <param name="db"></param>
  631. /// <param name="UserId">创客Id</param>
  632. /// <param name="Rank">职级</param>
  633. /// <param name="ExpiredDate">过期时间</param>
  634. public void PreUserLevel(WebCMSEntities db, int UserId, int Rank, DateTime ExpiredDate)
  635. {
  636. UserRankWhite rank = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId);
  637. if(rank == null)
  638. {
  639. rank = db.UserRankWhite.Add(new UserRankWhite()
  640. {
  641. CreateDate = DateTime.Now, //设置时间
  642. UserId = UserId, //用户
  643. Id = UserId,
  644. }).Entity;
  645. db.SaveChanges();
  646. }
  647. rank.Rank = Rank;
  648. rank.UpdateDate = ExpiredDate;
  649. db.SaveChanges();
  650. }
  651. }
  652. }