ProfitHelper.cs 32 KB

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