ProfitHelper.cs 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575
  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. RedisDbconn.Instance.AddList("ConsumerProfitCheck", orderidstring);
  237. }
  238. }
  239. db.Dispose();
  240. function.WriteLog("结束返现:" + orderidstring + "\n\n\n", "返现逻辑日志");
  241. }
  242. #endregion
  243. #region 分润
  244. public void StartListenProfit()
  245. {
  246. Thread th = new Thread(StartListenProfitDo);
  247. th.IsBackground = true;
  248. th.Start();
  249. }
  250. public void StartListenProfitDo()
  251. {
  252. while(true)
  253. {
  254. if(DateTime.Now.Day < 10 && DateTime.Now.Hour > 2 && DateTime.Now.Hour < 23)
  255. {
  256. try
  257. {
  258. DoProfit();
  259. }
  260. catch(Exception ex)
  261. {
  262. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "来客吧分润异常");
  263. }
  264. Thread.Sleep(600000);
  265. }
  266. else
  267. {
  268. Thread.Sleep(3600000);
  269. }
  270. }
  271. }
  272. //分润算法
  273. public void DoProfit()
  274. {
  275. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  276. string check = function.ReadInstance("/ProfitFlag/" + TradeMonth + ".txt");
  277. if(!string.IsNullOrEmpty(check))
  278. {
  279. return;
  280. }
  281. function.WritePage("/ProfitFlag/", TradeMonth + ".txt", DateTime.Now.ToString());
  282. Models.KxsMain.WebCMSEntities kxsdb = new Models.KxsMain.WebCMSEntities();
  283. WebCMSEntities dbnew = new WebCMSEntities();
  284. DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", AppConfig.Base.SqlConnStr);
  285. foreach(DataRow dr in dt.Rows)
  286. {
  287. int UserId = int.Parse(dr["UserId"].ToString());
  288. bool IsActive = dr["IsAct"].ToString() == "1";
  289. decimal TotalAmount = decimal.Parse(dr[2].ToString());
  290. List<ProfitUsers> users = new List<ProfitUsers>();
  291. int TopUserId = 0; //顶级创客Id
  292. Models.KxsMain.Users us = kxsdb.Users.FirstOrDefault(a => a.Id == UserId);
  293. if (us != null)
  294. {
  295. string uidstring = us.Id.ToString();
  296. if (!string.IsNullOrEmpty(us.ParentNav))
  297. {
  298. uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
  299. string[] parents = us.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  300. if(parents.Length > 1)
  301. {
  302. TopUserId = int.Parse(function.CheckInt(parents[1]));
  303. }
  304. else
  305. {
  306. TopUserId = int.Parse(function.CheckInt(parents[0]));
  307. }
  308. }
  309. string[] uidlist = uidstring.Split(',');
  310. Array.Reverse(uidlist);
  311. foreach (string uidstr in uidlist)
  312. {
  313. int puid = int.Parse(function.CheckInt(uidstr));
  314. Models.KxsMain.Users pus = kxsdb.Users.FirstOrDefault(a => a.Id == puid);
  315. if (pus != null)
  316. {
  317. users.Add(new ProfitUsers()
  318. {
  319. UserId = pus.Id,
  320. MakerCode = pus.MakerCode,
  321. RealName = pus.RealName,
  322. UserNav = pus.ParentNav,
  323. UserLevel = pus.UserLevel,
  324. CreateDate = pus.CreateDate.Value,
  325. });
  326. }
  327. }
  328. }
  329. Models.KxsMain.Users topUser = kxsdb.Users.FirstOrDefault(a => a.Id == TopUserId) ?? new Models.KxsMain.Users();
  330. LogHelper.Instance.WriteLog("---UserId:" + UserId + ";TotalAmount:" + TotalAmount + ";", "来客吧分润日志");
  331. List<ProfitResult> list = new List<ProfitResult>();
  332. list = StartProft(TotalAmount, 1, users, IsActive);
  333. LogHelper.Instance.WriteLog("---list:" + list.Count + ";", "来客吧分润日志");
  334. try
  335. {
  336. foreach (ProfitResult sub in list)
  337. {
  338. int ProfitType = sub.UserId == UserId ? 0 : 1;
  339. ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.BrandId == 1 && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
  340. if (editprofitrecord == null)
  341. {
  342. editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
  343. {
  344. CreateDate = DateTime.Now,
  345. UserId = sub.UserId, //创客
  346. BrandId = 1, //品牌
  347. ProfitType = ProfitType, //创客分润类型
  348. TradeMonth = TradeMonth, //交易月
  349. TopUserId = TopUserId, //顶级创客
  350. CreateMan = sub.MakerCode, //创客编号
  351. UpdateMan = topUser.MakerCode, //顶级编号
  352. SeoTitle = sub.RealName, //创客姓名
  353. SeoKeyword = topUser.RealName, //创客姓名
  354. }).Entity;
  355. dbnew.SaveChanges();
  356. string RecordNo = "KPM";
  357. int RecordId = editprofitrecord.Id;
  358. string RecordIdString = RecordId.ToString();
  359. for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
  360. {
  361. RecordIdString = "0" + RecordIdString;
  362. }
  363. RecordNo += RecordIdString;
  364. editprofitrecord.RecordNo = RecordNo;
  365. dbnew.SaveChanges();
  366. }
  367. if(IsActive)
  368. {
  369. editprofitrecord.CreditTradeAmt += TotalAmount;
  370. editprofitrecord.CreditTradeProfit += sub.Money;
  371. }
  372. else
  373. {
  374. editprofitrecord.TradeAmt += TotalAmount;
  375. editprofitrecord.TradeProfit += sub.Money;
  376. }
  377. dbnew.SaveChanges();
  378. }
  379. dbnew.SaveChanges();
  380. }
  381. catch (Exception ex)
  382. {
  383. LogHelper.Instance.WriteLog(ex.ToString(), "分润异常");
  384. }
  385. }
  386. dbnew.Dispose();
  387. kxsdb.Dispose();
  388. }
  389. #endregion
  390. #region 分润算法
  391. public List<ProfitResult> StartProft(decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
  392. {
  393. LogHelper.Instance.WriteLog("\n\nTotalAmount:" + TotalAmount + ";", "来客吧分润日志");
  394. string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  395. WebCMSEntities db = new WebCMSEntities();
  396. List<UserLevelSet> levels = db.UserLevelSet.ToList();
  397. List<ProfitResult> result = new List<ProfitResult>();
  398. ProfitObjects obj = db.ProfitObjects.FirstOrDefault();
  399. if (obj.Status == 1) //判断分润是否开启
  400. {
  401. int maxLevel = obj.MaxLevel; //最大等级
  402. int maxFloor = obj.MaxFloor; //最大层级
  403. decimal diffLevelProfit = 0; //等级级差
  404. ProfitObjectLevels maxlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == 9) ?? new ProfitObjectLevels(); //获取最高等级参数
  405. decimal maxPercent = IsActive ? maxlevel.DebitPercents : maxlevel.Percents;
  406. LogHelper.Instance.WriteLog("maxPercent:" + maxPercent + ";", "来客吧分润日志");
  407. decimal maxLevelProfit = TotalAmount * maxPercent;
  408. LogHelper.Instance.WriteLog("maxLevelProfit:" + maxLevelProfit + ";", "来客吧分润日志");
  409. maxLevelProfit = PublicFunction.NumberFormat(maxLevelProfit);
  410. LogHelper.Instance.WriteLog("maxLevelProfit:" + maxLevelProfit + ";", "来客吧分润日志");
  411. // decimal diffDiviProfit = 0; //分红级差
  412. int curLevel = 0; //当前层级的会员等级
  413. for (int curFloor = 1; curFloor <= users.Count; curFloor++)
  414. {
  415. ProfitUsers user = new ProfitUsers();
  416. if (curFloor <= users.Count)
  417. {
  418. user = users[curFloor - 1];
  419. }
  420. SubUser selfUser = GetUser(user.UserId, Month) ?? new SubUser();
  421. int UserLevel = GetUserLevel(selfUser); //当前会员等级
  422. //判断当前创客是否有直推的激活机具,并且在活动时间内
  423. if (curLevel == maxLevel)
  424. {
  425. break;
  426. }
  427. if (UserLevel <= maxLevel && UserLevel >= curLevel)
  428. {
  429. ProfitObjectLevels objlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == UserLevel); //获取当前等级参数
  430. if (objlevel != null)
  431. {
  432. decimal getLevelProfit = 0; //等级分润
  433. UserProfitSet profitSet = new UserProfitSet();
  434. decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
  435. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + profitPercent + ";", "来客吧分润日志");
  436. if (profitPercent > 0)
  437. {
  438. decimal profitTmp = TotalAmount * profitPercent;
  439. getLevelProfit += profitTmp;
  440. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + profitTmp + ";", "来客吧分润日志");
  441. }
  442. decimal money = getLevelProfit;
  443. getLevelProfit -= diffLevelProfit;
  444. if (objlevel.LevelDiff == 1) //判断是否有级差
  445. {
  446. diffLevelProfit = money;
  447. }
  448. if (getLevelProfit >= obj.MinProfitVal)
  449. {
  450. result.Add(new ProfitResult()
  451. {
  452. UserId = user.UserId,
  453. MakerCode = user.MakerCode,
  454. RealName = user.RealName,
  455. UserNav = user.UserNav,
  456. Money = PublicFunction.NumberFormat(getLevelProfit),
  457. ProfitRate = profitSet.ProfitRate,
  458. ProfitPercent = profitSet.ProfitPercent,
  459. AddOrSubRate = profitSet.AddOrSubRate,
  460. ProfitRateBase = profitSet.ProfitRateBase,
  461. });
  462. LogHelper.Instance.WriteLog("money:" + UserLevel + ":" + PublicFunction.NumberFormat(getLevelProfit) + ";", "来客吧分润日志");
  463. }
  464. }
  465. }
  466. if(curLevel < UserLevel)
  467. {
  468. curLevel = UserLevel;
  469. }
  470. }
  471. }
  472. db.Dispose();
  473. return result;
  474. }
  475. public SubUser GetUser(int UserId, string Month)
  476. {
  477. SubUser user = new SubUser();
  478. DataTable dt = GetDataTable("select * from Users" + Month + " where Id=" + UserId);
  479. if(dt.Rows.Count > 0)
  480. {
  481. user.Id = int.Parse(dt.Rows[0]["Id"].ToString());
  482. user.ParentUserId = int.Parse(dt.Rows[0]["ParentUserId"].ToString());
  483. user.ParentNav = dt.Rows[0]["ParentNav"].ToString();
  484. user.UserLevel = int.Parse(dt.Rows[0]["UserLevel"].ToString());
  485. user.PreUserLevel = int.Parse(dt.Rows[0]["PreUserLevel"].ToString());
  486. user.PreLeaderLevel = int.Parse(dt.Rows[0]["PreLeaderLevel"].ToString());
  487. user.PreOpLevel = int.Parse(dt.Rows[0]["PreOpLevel"].ToString());
  488. }
  489. return user;
  490. }
  491. public int GetUserLevel(SubUser user)
  492. {
  493. int level = user.UserLevel;
  494. if(user.PreUserLevel > level) level = user.PreUserLevel;
  495. if(user.PreLeaderLevel > level) level = user.PreLeaderLevel;
  496. if(user.PreOpLevel > level) level = user.PreOpLevel;
  497. return level;
  498. }
  499. public DataTable GetDataTable(string sqlstr)
  500. {
  501. DataTable dt = CustomerSqlConn.dtable(sqlstr, Library.ConfigurationManager.AppSettings["KxsStatSqlConnStr"].ToString());
  502. return dt;
  503. }
  504. #endregion
  505. public void StartSetDivi()
  506. {
  507. Thread th = new Thread(StartSetDiviDo);
  508. th.IsBackground = true;
  509. th.Start();
  510. }
  511. public void StartSetDiviDo()
  512. {
  513. while (true)
  514. {
  515. string content = RedisDbconn.Instance.RPop<string>("ConsumerOrdersSetDiviHd");
  516. if (!string.IsNullOrEmpty(content))
  517. {
  518. SetDivi(content);
  519. }
  520. else
  521. {
  522. Thread.Sleep(10000);
  523. }
  524. }
  525. }
  526. public void SetDivi(string content)
  527. {
  528. try
  529. {
  530. JsonData jsonObj = JsonMapper.ToObject(content);
  531. int orderId = int.Parse(function.CheckInt(jsonObj["OrderId"].ToString()));
  532. decimal diviAmt = decimal.Parse(function.CheckNum(jsonObj["DiviAmt"].ToString()));
  533. WebCMSEntities db = new WebCMSEntities();
  534. ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == orderId);
  535. if(order != null)
  536. {
  537. order.CurDivi = diviAmt;
  538. db.SaveChanges();
  539. }
  540. db.Dispose();
  541. }
  542. catch(Exception ex)
  543. {
  544. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "设置订单当前返现金额异常");
  545. }
  546. }
  547. }
  548. }