ProfitHelper.cs 30 KB

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