ProfitHelper.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Data;
  5. using MySystem.Models.Main;
  6. using Library;
  7. using System.Threading;
  8. using Microsoft.Extensions.Hosting;
  9. using System.Threading.Tasks;
  10. using LitJson;
  11. namespace MySystem
  12. {
  13. public class ProfitHelper
  14. {
  15. public readonly static ProfitHelper Instance = new ProfitHelper();
  16. private ProfitHelper()
  17. {
  18. }
  19. #region 消费队列(执行消费退款金额的统计)
  20. public void StartListenTrade()
  21. {
  22. Thread th = new Thread(StartListenTradeDo);
  23. th.IsBackground = true;
  24. th.Start();
  25. }
  26. public void StartListenTradeDo()
  27. {
  28. while (true)
  29. {
  30. string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrdersHd:Divi:1:List");
  31. if (!string.IsNullOrEmpty(orderidstring))
  32. {
  33. ReturnStat(orderidstring, 1);
  34. }
  35. else
  36. {
  37. Thread.Sleep(60000);
  38. }
  39. }
  40. }
  41. public void StartListenWxTrade()
  42. {
  43. Thread th = new Thread(StartListenWxTradeDo);
  44. th.IsBackground = true;
  45. th.Start();
  46. }
  47. public void StartListenWxTradeDo()
  48. {
  49. while (true)
  50. {
  51. string orderidstring = RedisDbconn.Instance.RPop<string>("ConsumerOrdersHd:Divi:2:List");
  52. if (!string.IsNullOrEmpty(orderidstring))
  53. {
  54. ReturnStat(orderidstring, 2);
  55. }
  56. else
  57. {
  58. Thread.Sleep(10000);
  59. }
  60. }
  61. }
  62. public void ReturnStat(string orderidstring, int PayMode)
  63. {
  64. function.WriteLog("开始返现:" + orderidstring, "返现逻辑日志");
  65. int OrderId = int.Parse(function.CheckInt(orderidstring));
  66. WebCMSEntities db = new WebCMSEntities();
  67. using (var tran = db.Database.BeginTransaction())
  68. {
  69. try
  70. {
  71. ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == OrderId);
  72. if (order != null)
  73. {
  74. decimal PayMoney = order.PayMoney;
  75. int MerchantId = order.MerchantId;
  76. function.WriteLog("MerchantId:" + MerchantId, "返现逻辑日志");
  77. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
  78. if (merchant != null)
  79. {
  80. int UserId = merchant.UserId;
  81. List<CustomTagSet> customTagSets = db.CustomTagSet.ToList(); //获取公用配置参数集和
  82. //获取参数
  83. CustomTagSet profitPercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerProfitPercent") ?? new CustomTagSet();
  84. decimal profitPercent = decimal.Parse(function.CheckNum(profitPercentSet.Contents)); //基于收款金额的总分润比例;
  85. CustomTagSet cusumerFeePercentSet = customTagSets.FirstOrDefault(m => m.Tags == "CusumerFeePercent") ?? new CustomTagSet();
  86. decimal cusumerFeePercent = decimal.Parse(function.CheckNum(cusumerFeePercentSet.Contents)); //费率;
  87. CustomTagSet minProfitSet = customTagSets.FirstOrDefault(m => m.Tags == "MinProfit") ?? new CustomTagSet();
  88. decimal minProfit = decimal.Parse(function.CheckNum(minProfitSet.Contents)); //最小分润值;
  89. MerchantParamSet set = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
  90. int DiviPersons = set.DiviPersons; //单笔订单分红人数
  91. decimal DiviPercent = set.DiviPercent; //单人最大分红比例
  92. int ProfitDays = set.ProfitDays; //分红期限(天)
  93. decimal GetPercent = set.GetPercent / 100; //商家实收比例
  94. decimal MinPayMoney = set.MinPayMoney; //订单参与门槛
  95. int IsAll = set.IsAll; //是否收全额
  96. // decimal TotalActual = 0;
  97. if (IsAll == 0 && PayMoney >= MinPayMoney && GetPercent < 1)
  98. {
  99. function.WriteLog("活动开启", "返现逻辑日志");
  100. // PayMoney * (1 - 0.1 - 0.0038 - 0.01);
  101. decimal DiviMoney = PayMoney * (1 - GetPercent - cusumerFeePercent - profitPercent);
  102. DiviMoney = Math.Round(DiviMoney, 2);
  103. if (DiviMoney > 0)
  104. {
  105. function.WriteLog("返现队列开始", "返现逻辑日志");
  106. RedisDbconn.Instance.AddRightList("ConsumerOrdersHd:Divi:" + PayMode + ":" + order.MerchantId, order);
  107. order.ReturnFlag = 1;
  108. db.SaveChanges();
  109. DiviMoney = DiviMoney / DiviPersons;
  110. List<int> deletes = new List<int>();
  111. long CurDiviPersons = DiviPersons;
  112. long QueueCount = RedisDbconn.Instance.Count("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
  113. long CurQueueCount = QueueCount;
  114. if (CurDiviPersons >= CurQueueCount)
  115. {
  116. CurDiviPersons = CurQueueCount;
  117. }
  118. if (DiviPersons < QueueCount)
  119. {
  120. QueueCount = DiviPersons;
  121. }
  122. // 减去自己付的订单
  123. int OutCount = 0; // 出局人数
  124. List<int> orderids = new List<int>();
  125. function.WriteLog("人数:" + CurDiviPersons, "返现逻辑日志");
  126. while (CurDiviPersons > 0)
  127. {
  128. ConsumerOrders suborder = RedisDbconn.Instance.RPopLPush<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, "ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
  129. if (suborder != null)
  130. {
  131. function.WriteLog("返现对象订单:" + suborder.Id, "返现逻辑日志");
  132. MerchantParamSet subset = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(suborder.SeoDescription);
  133. int subProfitDays = subset.ProfitDays; //分红期限(天)
  134. bool IsOut = suborder.UpdateDate.Value.AddDays(subProfitDays) < DateTime.Now ? true : false;
  135. if (suborder.CurDivi < suborder.MaxDivi && !IsOut)
  136. {
  137. function.WriteLog("没出局:" + suborder.CurDivi + "--" + suborder.MaxDivi, "返现逻辑日志");
  138. //如果没过期并且当前退款金额没超过最大退款金额,就执行
  139. decimal GetMoney = suborder.MaxDivi - suborder.CurDivi;
  140. if (GetMoney >= DiviMoney)
  141. {
  142. GetMoney = DiviMoney;
  143. }
  144. function.WriteLog("GetMoney:" + GetMoney, "返现逻辑日志");
  145. if (GetMoney > minProfit)
  146. {
  147. decimal TmpCurDivi = suborder.CurDivi;
  148. suborder.CurDivi += GetMoney;
  149. MerchantAddInfo merchantAdd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == suborder.MerchantId) ?? new MerchantAddInfo();
  150. //聚合支付退款
  151. bool BackStatus = false;
  152. decimal RefundAmount = GetMoney * 100;
  153. RefundAmount = Math.Round(RefundAmount, 2);
  154. if(!orderids.Contains(suborder.Id))
  155. {
  156. function.WriteLog("请求退款接口", "返现逻辑日志");
  157. string RefundNo = "HDTK" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
  158. var info = HaoDaHelper.Instance.AggregatedPayRefund(merchantAdd.OutMchtNo, merchantAdd.StoreNo, RefundNo, suborder.OrderNo, RefundAmount.ToString("f0"));
  159. if(info.Contains("\"resultCode\":\"1\"") && info.Contains("\"tradeStatus\":\"2\""))
  160. {
  161. db.ConsumerProfit.Add(new ConsumerProfit()
  162. {
  163. CreateDate = DateTime.Now,
  164. ConsumerId = suborder.ConsumerId,
  165. MerchantId = suborder.MerchantId,
  166. OrderId = suborder.Id,
  167. GetMoney = Math.Round(GetMoney, 2),
  168. QueryCount = PayMode,
  169. Sort = OrderId,
  170. SeoTitle = suborder.OrderNo,
  171. SeoKeyword = suborder.PayMoney.ToString(),
  172. SeoDescription = RefundNo,
  173. });
  174. db.SaveChanges();
  175. BackStatus = true;
  176. }
  177. function.WriteLog("接口返回:" + info, "返现逻辑日志");
  178. orderids.Add(suborder.Id);
  179. }
  180. if(BackStatus)
  181. {
  182. merchant.ActCurrentAmount += Math.Round(GetMoney, 2); //活动已返金额
  183. db.SaveChanges();
  184. function.WriteLog(suborder.CurDivi + ":" + suborder.MaxDivi, "返现逻辑日志");
  185. if (suborder.CurDivi < suborder.MaxDivi)
  186. {
  187. function.WriteLog("返现未达最大值继续", "返现逻辑日志");
  188. // RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
  189. RedisDbconn.Instance.SetList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, 0, suborder);
  190. }
  191. else
  192. {
  193. suborder.CurDivi = TmpCurDivi;
  194. function.WriteLog("返现达最大值,出局", "返现逻辑日志");
  195. RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, suborder);
  196. ConsumerOrders editOrder = db.ConsumerOrders.FirstOrDefault(m => m.Id == suborder.Id);
  197. if (editOrder != null)
  198. {
  199. editOrder.ReturnFlag = 0;
  200. editOrder.CurDivi = editOrder.MaxDivi;
  201. db.SaveChanges();
  202. }
  203. OutCount += 1;
  204. }
  205. }
  206. Thread.Sleep(1000);
  207. RedisDbconn.Instance.AddList("ConsumerOrdersSetDiviHd", "{\"OrderId\":\"" + suborder.Id + "\",\"DiviAmt\":\"" + suborder.CurDivi + "\"}");
  208. }
  209. }
  210. else
  211. {
  212. //否者计算人数不计入退款名额
  213. CurDiviPersons += 1;
  214. function.WriteLog("出局:CurDiviPersons:" + CurDiviPersons, "返现逻辑日志");
  215. }
  216. }
  217. CurDiviPersons -= 1;
  218. QueueCount = RedisDbconn.Instance.Count("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId);
  219. function.WriteLog("当前队列数量:" + QueueCount, "返现逻辑日志");
  220. if (QueueCount == 0)
  221. {
  222. CurDiviPersons = 0;
  223. }
  224. }
  225. function.WriteLog("返现队列结束", "返现逻辑日志");
  226. }
  227. }
  228. }
  229. }
  230. tran.Commit();
  231. }
  232. catch (Exception ex)
  233. {
  234. LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
  235. tran.Rollback();
  236. }
  237. }
  238. db.Dispose();
  239. function.WriteLog("结束返现:" + orderidstring + "\n\n\n", "返现逻辑日志");
  240. }
  241. #endregion
  242. #region 分润
  243. public void StartListenProfit()
  244. {
  245. Thread th = new Thread(StartListenProfitDo);
  246. th.IsBackground = true;
  247. th.Start();
  248. }
  249. public void StartListenProfitDo()
  250. {
  251. while(true)
  252. {
  253. if(DateTime.Now.Day < 10 && DateTime.Now.Hour > 2 && DateTime.Now.Hour < 23)
  254. {
  255. try
  256. {
  257. DoProfit();
  258. }
  259. catch(Exception ex)
  260. {
  261. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "来客吧分润异常");
  262. }
  263. Thread.Sleep(600000);
  264. }
  265. else
  266. {
  267. Thread.Sleep(3600000);
  268. }
  269. }
  270. }
  271. //分润算法
  272. public void DoProfit()
  273. {
  274. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  275. string check = function.ReadInstance("/ProfitFlag/" + TradeMonth + ".txt");
  276. if(!string.IsNullOrEmpty(check))
  277. {
  278. return;
  279. }
  280. function.WritePage("/ProfitFlag/", TradeMonth + ".txt", DateTime.Now.ToString());
  281. Models.KxsMain.WebCMSEntities kxsdb = new Models.KxsMain.WebCMSEntities();
  282. WebCMSEntities dbnew = new WebCMSEntities();
  283. DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", AppConfig.Base.SqlConnStr);
  284. foreach(DataRow dr in dt.Rows)
  285. {
  286. int UserId = int.Parse(dr["UserId"].ToString());
  287. bool IsActive = dr["IsAct"].ToString() == "1";
  288. decimal TotalAmount = decimal.Parse(dr[2].ToString());
  289. List<ProfitUsers> users = new List<ProfitUsers>();
  290. int TopUserId = 0; //顶级创客Id
  291. Models.KxsMain.Users us = kxsdb.Users.FirstOrDefault(a => a.Id == UserId);
  292. if (us != null)
  293. {
  294. string uidstring = us.Id.ToString();
  295. if (!string.IsNullOrEmpty(us.ParentNav))
  296. {
  297. uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
  298. string[] parents = us.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  299. if(parents.Length > 1)
  300. {
  301. TopUserId = int.Parse(function.CheckInt(parents[1]));
  302. }
  303. else
  304. {
  305. TopUserId = int.Parse(function.CheckInt(parents[0]));
  306. }
  307. }
  308. string[] uidlist = uidstring.Split(',');
  309. Array.Reverse(uidlist);
  310. foreach (string uidstr in uidlist)
  311. {
  312. int puid = int.Parse(function.CheckInt(uidstr));
  313. Models.KxsMain.Users pus = kxsdb.Users.FirstOrDefault(a => a.Id == puid);
  314. if (pus != null)
  315. {
  316. users.Add(new ProfitUsers()
  317. {
  318. UserId = pus.Id,
  319. MakerCode = pus.MakerCode,
  320. RealName = pus.RealName,
  321. UserNav = pus.ParentNav,
  322. UserLevel = pus.UserLevel,
  323. CreateDate = pus.CreateDate.Value,
  324. });
  325. }
  326. }
  327. }
  328. Models.KxsMain.Users topUser = kxsdb.Users.FirstOrDefault(a => a.Id == TopUserId) ?? new Models.KxsMain.Users();
  329. LogHelper.Instance.WriteLog("---UserId:" + UserId + ";TotalAmount:" + TotalAmount + ";", "来客吧分润日志");
  330. List<ProfitResult> list = new List<ProfitResult>();
  331. list = StartProft(TotalAmount, 1, users, IsActive);
  332. LogHelper.Instance.WriteLog("---list:" + list.Count + ";", "来客吧分润日志");
  333. try
  334. {
  335. foreach (ProfitResult sub in list)
  336. {
  337. int ProfitType = sub.UserId == UserId ? 0 : 1;
  338. ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.BrandId == 1 && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
  339. if (editprofitrecord == null)
  340. {
  341. editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
  342. {
  343. CreateDate = DateTime.Now,
  344. UserId = sub.UserId, //创客
  345. BrandId = 1, //品牌
  346. ProfitType = ProfitType, //创客分润类型
  347. TradeMonth = TradeMonth, //交易月
  348. TopUserId = TopUserId, //顶级创客
  349. CreateMan = sub.MakerCode, //创客编号
  350. UpdateMan = topUser.MakerCode, //顶级编号
  351. SeoTitle = sub.RealName, //创客姓名
  352. SeoKeyword = topUser.RealName, //创客姓名
  353. }).Entity;
  354. dbnew.SaveChanges();
  355. string RecordNo = "KPM";
  356. int RecordId = editprofitrecord.Id;
  357. string RecordIdString = RecordId.ToString();
  358. for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
  359. {
  360. RecordIdString = "0" + RecordIdString;
  361. }
  362. RecordNo += RecordIdString;
  363. editprofitrecord.RecordNo = RecordNo;
  364. dbnew.SaveChanges();
  365. }
  366. if(IsActive)
  367. {
  368. editprofitrecord.CreditTradeAmt += TotalAmount;
  369. editprofitrecord.CreditTradeProfit += sub.Money;
  370. }
  371. else
  372. {
  373. editprofitrecord.TradeAmt += TotalAmount;
  374. editprofitrecord.TradeProfit += sub.Money;
  375. }
  376. dbnew.SaveChanges();
  377. }
  378. dbnew.SaveChanges();
  379. }
  380. catch (Exception ex)
  381. {
  382. LogHelper.Instance.WriteLog(ex.ToString(), "分润异常");
  383. }
  384. }
  385. dbnew.Dispose();
  386. kxsdb.Dispose();
  387. }
  388. #endregion
  389. #region 分润算法
  390. public List<ProfitResult> StartProft(decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
  391. {
  392. LogHelper.Instance.WriteLog("\n\nTotalAmount:" + TotalAmount + ";", "来客吧分润日志");
  393. string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  394. WebCMSEntities db = new WebCMSEntities();
  395. List<UserLevelSet> levels = db.UserLevelSet.ToList();
  396. List<ProfitResult> result = new List<ProfitResult>();
  397. ProfitObjects obj = db.ProfitObjects.FirstOrDefault();
  398. if (obj.Status == 1) //判断分润是否开启
  399. {
  400. int maxLevel = obj.MaxLevel; //最大等级
  401. int maxFloor = obj.MaxFloor; //最大层级
  402. decimal diffLevelProfit = 0; //等级级差
  403. ProfitObjectLevels maxlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == 9) ?? new ProfitObjectLevels(); //获取最高等级参数
  404. decimal maxPercent = IsActive ? maxlevel.DebitPercents : maxlevel.Percents;
  405. LogHelper.Instance.WriteLog("maxPercent:" + maxPercent + ";", "来客吧分润日志");
  406. decimal maxLevelProfit = TotalAmount * maxPercent;
  407. LogHelper.Instance.WriteLog("maxLevelProfit:" + maxLevelProfit + ";", "来客吧分润日志");
  408. maxLevelProfit = PublicFunction.NumberFormat(maxLevelProfit);
  409. LogHelper.Instance.WriteLog("maxLevelProfit:" + maxLevelProfit + ";", "来客吧分润日志");
  410. // decimal diffDiviProfit = 0; //分红级差
  411. int curLevel = 0; //当前层级的会员等级
  412. for (int curFloor = 1; curFloor <= users.Count; curFloor++)
  413. {
  414. ProfitUsers user = new ProfitUsers();
  415. if (curFloor <= users.Count)
  416. {
  417. user = users[curFloor - 1];
  418. }
  419. SubUser selfUser = GetUser(user.UserId, Month) ?? new SubUser();
  420. int UserLevel = GetUserLevel(selfUser); //当前会员等级
  421. //判断当前创客是否有直推的激活机具,并且在活动时间内
  422. if (curLevel == maxLevel)
  423. {
  424. break;
  425. }
  426. if (UserLevel <= maxLevel && UserLevel >= curLevel)
  427. {
  428. ProfitObjectLevels objlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == UserLevel); //获取当前等级参数
  429. if (objlevel != null)
  430. {
  431. decimal getLevelProfit = 0; //等级分润
  432. UserProfitSet profitSet = new UserProfitSet();
  433. decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
  434. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + profitPercent + ";", "来客吧分润日志");
  435. if (profitPercent > 0)
  436. {
  437. decimal profitTmp = TotalAmount * profitPercent;
  438. getLevelProfit += profitTmp;
  439. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + profitTmp + ";", "来客吧分润日志");
  440. }
  441. decimal money = getLevelProfit;
  442. getLevelProfit -= diffLevelProfit;
  443. if (objlevel.LevelDiff == 1) //判断是否有级差
  444. {
  445. diffLevelProfit = money;
  446. }
  447. if (getLevelProfit >= obj.MinProfitVal)
  448. {
  449. result.Add(new ProfitResult()
  450. {
  451. UserId = user.UserId,
  452. MakerCode = user.MakerCode,
  453. RealName = user.RealName,
  454. UserNav = user.UserNav,
  455. Money = PublicFunction.NumberFormat(getLevelProfit),
  456. ProfitRate = profitSet.ProfitRate,
  457. ProfitPercent = profitSet.ProfitPercent,
  458. AddOrSubRate = profitSet.AddOrSubRate,
  459. ProfitRateBase = profitSet.ProfitRateBase,
  460. });
  461. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + PublicFunction.NumberFormat(getLevelProfit) + ";", "来客吧分润日志");
  462. }
  463. }
  464. }
  465. if(curLevel < UserLevel)
  466. {
  467. curLevel = UserLevel;
  468. }
  469. }
  470. }
  471. db.Dispose();
  472. return result;
  473. }
  474. public SubUser GetUser(int UserId, string Month)
  475. {
  476. SubUser user = new SubUser();
  477. DataTable dt = GetDataTable("select * from Users" + Month + " where Id=" + UserId);
  478. if(dt.Rows.Count > 0)
  479. {
  480. user.Id = int.Parse(dt.Rows[0]["Id"].ToString());
  481. user.ParentUserId = int.Parse(dt.Rows[0]["ParentUserId"].ToString());
  482. user.ParentNav = dt.Rows[0]["ParentNav"].ToString();
  483. user.UserLevel = int.Parse(dt.Rows[0]["UserLevel"].ToString());
  484. user.PreUserLevel = int.Parse(dt.Rows[0]["PreUserLevel"].ToString());
  485. user.PreLeaderLevel = int.Parse(dt.Rows[0]["PreLeaderLevel"].ToString());
  486. user.PreOpLevel = int.Parse(dt.Rows[0]["PreOpLevel"].ToString());
  487. }
  488. return user;
  489. }
  490. public int GetUserLevel(SubUser user)
  491. {
  492. int level = user.UserLevel;
  493. if(user.PreUserLevel > level) level = user.PreUserLevel;
  494. if(user.PreLeaderLevel > level) level = user.PreLeaderLevel;
  495. if(user.PreOpLevel > level) level = user.PreOpLevel;
  496. return level;
  497. }
  498. public DataTable GetDataTable(string sqlstr)
  499. {
  500. DataTable dt = CustomerSqlConn.dtable(sqlstr, Library.ConfigurationManager.AppSettings["KxsStatSqlConnStr"].ToString());
  501. return dt;
  502. }
  503. #endregion
  504. public void StartSetDivi()
  505. {
  506. Thread th = new Thread(StartSetDiviDo);
  507. th.IsBackground = true;
  508. th.Start();
  509. }
  510. public void StartSetDiviDo()
  511. {
  512. while (true)
  513. {
  514. string content = RedisDbconn.Instance.RPop<string>("ConsumerOrdersSetDiviHd");
  515. if (!string.IsNullOrEmpty(content))
  516. {
  517. SetDivi(content);
  518. }
  519. else
  520. {
  521. Thread.Sleep(10000);
  522. }
  523. }
  524. }
  525. public void SetDivi(string content)
  526. {
  527. try
  528. {
  529. JsonData jsonObj = JsonMapper.ToObject(content);
  530. int orderId = int.Parse(function.CheckInt(jsonObj["OrderId"].ToString()));
  531. decimal diviAmt = decimal.Parse(function.CheckNum(jsonObj["DiviAmt"].ToString()));
  532. WebCMSEntities db = new WebCMSEntities();
  533. ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == orderId);
  534. if(order != null)
  535. {
  536. order.CurDivi = diviAmt;
  537. db.SaveChanges();
  538. }
  539. db.Dispose();
  540. }
  541. catch(Exception ex)
  542. {
  543. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "设置订单当前返现金额异常");
  544. }
  545. }
  546. }
  547. }