RecommandKingHelper.cs 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Data;
  5. using MySystem.PxcModels;
  6. using Library;
  7. using LitJson;
  8. using System.Threading;
  9. using GraphQL;
  10. namespace MySystem
  11. {
  12. public class RecommandKingHelper
  13. {
  14. public readonly static RecommandKingHelper Instance = new RecommandKingHelper();
  15. private RecommandKingHelper()
  16. { }
  17. public void Start()
  18. {
  19. Thread th = new Thread(StartFor);
  20. th.IsBackground = true;
  21. th.Start();
  22. }
  23. public void StartFor()
  24. {
  25. while (true)
  26. {
  27. if(DateTime.Now.Hour > 0 && DateTime.Now.Hour < 23)
  28. {
  29. Recommend();
  30. }
  31. Thread.Sleep(600000);
  32. }
  33. }
  34. public void Recommend()
  35. {
  36. // string today = DateTime.Now.ToString("yyyy-MM-dd");
  37. // string checkFlag = function.ReadInstance("/RecommandKing/" + today + ".txt");
  38. // if(!string.IsNullOrEmpty(checkFlag))
  39. // {
  40. // return;
  41. // }
  42. // function.WritePage("/RecommandKing/", today + ".txt", DateTime.Now.ToString());
  43. List<int> ReduceUserId = new List<int>();
  44. List<RecommendDirectUser> list = new List<RecommendDirectUser>();
  45. List<int> Historys = new List<int>();
  46. Historys.Add(565);
  47. Historys.Add(139473);
  48. Historys.Add(173790);
  49. Historys.Add(174506);
  50. Historys.Add(127023);
  51. Historys.Add(582);
  52. Historys.Add(588);
  53. Historys.Add(609);
  54. Historys.Add(730);
  55. Historys.Add(1421);
  56. Historys.Add(71648);
  57. Historys.Add(133571);
  58. Historys.Add(146503);
  59. Historys.Add(168578);
  60. Historys.Add(173793);
  61. Historys.Add(176218);
  62. Historys.Add(182658);
  63. Historys.Add(193048);
  64. Historys.Add(195205);
  65. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  66. DateTime check = DateTime.Parse("2023-10-01 00:00:00");
  67. // DateTime checke = DateTime.Parse("2024-04-29 00:00:00");
  68. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  69. DateTime end = start.AddMonths(1);
  70. CustomerSqlConn.op("delete from RecommendDirectUser where TradeMonth='" + TradeMonth + "'", MysqlConn.SqlConnStr);
  71. string PreTradeMonth = DateTime.Now.AddMonths(-2).ToString("yyyyMM");
  72. List<int> ProductIds = new List<int>();
  73. ProductIds.Add(10);
  74. ProductIds.Add(11);
  75. ProductIds.Add(77);
  76. ProductIds.Add(78);
  77. ProductIds.Add(79);
  78. ProductIds.Add(27);
  79. ProductIds.Add(28);
  80. ProductIds.Add(39);
  81. ProductIds.Add(40);
  82. List<RecommandKingItem> users = new List<RecommandKingItem>();
  83. // Dictionary<int, decimal> PreMonthAmt = GetTradeAmtList(PreTradeMonth);
  84. WebCMSEntities db = new WebCMSEntities();
  85. ReadModels.WebCMSEntities readdb = new ReadModels.WebCMSEntities();
  86. MpMainModels.WebCMSEntities mpdb = new MpMainModels.WebCMSEntities();
  87. MpMainModels2.WebCMSEntities mpdb2 = new MpMainModels2.WebCMSEntities();
  88. //统计当月下单名单
  89. // List<int> checkIds = readdb.Users.Where(m => (m.ParentNav.Contains(",609,") || m.Id == 609) && m.AuthFlag == 1).ToList().Select(m => m.Id).ToList();
  90. var orders = readdb.Orders.Where(m => m.PayDate >= check && m.Status > 0 && m.Sort == 0 && m.UserId > 1 && ProductIds.Contains(m.ProductId)).ToList();
  91. function.WriteLog(orders.Count.ToString(), "推荐王创客入库");
  92. List<int> uids = orders.Select(m => m.UserId).Distinct().ToList();
  93. foreach(int uid in uids)
  94. {
  95. ReadModels.Users user = readdb.Users.FirstOrDefault(m => m.Id == uid);
  96. if(user != null)
  97. {
  98. if(!users.Any(m => m.UserId == user.Id))
  99. {
  100. users.Add(new RecommandKingItem()
  101. {
  102. UserId = user.Id,
  103. ParentUserId = user.ParentUserId,
  104. ParentNav = user.ParentNav,
  105. // PreAmount = PreMonthAmt.ContainsKey(user.Id) ? PreMonthAmt[user.Id] : 0,
  106. Level = user.ParentNav.Replace(",,", ",").Trim(',').Split(',').Length + 1,
  107. UserLevel = GetLevel(db, user.Id,user.UserLevel),
  108. Kind = 1,
  109. Op = false,
  110. });
  111. function.WriteLog(user.Id.ToString(), "推荐王创客入库");
  112. }
  113. }
  114. }
  115. foreach(RecommandKingItem user in users)
  116. {
  117. int uid = user.UserId;
  118. int ActCount = 0;
  119. if(ActCount == 0)
  120. {
  121. if(readdb.UserTradeMonthSummary.Any(m => m.UserId == uid && m.TradeMonth == TradeMonth && m.SeoTitle == "self"))
  122. {
  123. ActCount += readdb.UserTradeMonthSummary.Where(m => m.UserId == uid && m.TradeMonth == TradeMonth && m.SeoTitle == "self").Sum(m => m.ActiveBuddyMerStatus);
  124. // if(readdb.UserSimActSummary.Any(m => m.UserId == uid && m.Kind == 1))
  125. // {
  126. // ActCount -= readdb.UserSimActSummary.Where(m => m.UserId == uid && m.Kind == 1).Sum(m => m.ActCount); //减去注销的用户
  127. // }
  128. }
  129. }
  130. if(ActCount == 0)
  131. {
  132. ActCount += mpdb.MerchantDepositOrder.Count(m => m.UserId == uid && m.CreateDate >= start && m.CreateDate < end && m.Status > 0 && m.UserId == uid);
  133. }
  134. if(ActCount == 0)
  135. {
  136. ActCount += mpdb2.MerchantDepositOrder.Count(m => m.UserId == uid && m.CreateDate >= start && m.CreateDate < end && m.Status > 0 && m.UserId == uid);
  137. }
  138. if(ActCount > 0)
  139. {
  140. user.Op = true;
  141. function.WriteLog(user.UserId.ToString(), "推荐王达标创客名单");
  142. }
  143. }
  144. foreach(int uid in uids)
  145. {
  146. ReadModels.Users user = readdb.Users.FirstOrDefault(m => m.Id == uid);
  147. if(user != null)
  148. {
  149. string[] ParentIds = user.ParentNav.Replace(",,", ",").Trim(',').Split(',');
  150. foreach(string ParentId in ParentIds)
  151. {
  152. int ParentUserId = int.Parse(ParentId);
  153. ReadModels.Users puser = readdb.Users.FirstOrDefault(m => m.Id == ParentUserId && m.Id > 1);
  154. if(puser != null)
  155. {
  156. if(!users.Any(m => m.UserId == puser.Id))
  157. {
  158. users.Add(new RecommandKingItem()
  159. {
  160. UserId = puser.Id,
  161. ParentUserId = puser.ParentUserId,
  162. ParentNav = puser.ParentNav,
  163. // PreAmount = PreMonthAmt.ContainsKey(puser.Id) ? PreMonthAmt[puser.Id] : 0,
  164. Level = puser.ParentNav.Replace(",,", ",").Trim(',').Split(',').Length + 1,
  165. UserLevel = GetLevel(db, puser.Id, puser.UserLevel),
  166. Kind = 2,
  167. Op = false,
  168. });
  169. function.WriteLog(puser.Id.ToString() + "-p", "推荐王创客入库");
  170. }
  171. }
  172. }
  173. }
  174. }
  175. users = users.OrderByDescending(m => m.Level).ToList();
  176. foreach(RecommandKingItem user in users)
  177. {
  178. string UserIdStr = "," + user.UserId + ",";
  179. int Count = users.Count(m => m.ParentNav.Contains(UserIdStr) && m.Op);
  180. user.ActCount = Count;
  181. user.ChkActCount = Count;
  182. function.WriteLog(user.UserId + ":" + Count, "推荐王总的达标创客数量");
  183. // RedisDbconn.Instance.AddList("userstmp2024", user);
  184. }
  185. // users = RedisDbconn.Instance.GetList<RecommandKingItem>("userstmp2024", 1, 999999).OrderByDescending(m => m.Level).ToList();
  186. users = users.OrderByDescending(m => m.Level).ToList();
  187. foreach(RecommandKingItem user in users)
  188. {
  189. function.WriteLog(user.UserId.ToString() + "-" + user.UserLevel, "推荐王最终的达标创客数量分析");
  190. int ActCount = 0;
  191. List<RecommandKingItem> subs = users.Where(m => m.ParentUserId == user.UserId).ToList();
  192. foreach(RecommandKingItem sub in subs)
  193. {
  194. function.WriteLog(sub.UserId + ":" + sub.ActCount, "推荐王最终的达标创客数量分析");
  195. if(sub.ActCount < 50 && sub.UserLevel < 5 && !Historys.Contains(sub.UserId))
  196. {
  197. ActCount += sub.ActCount;
  198. if(sub.Op) ActCount += 1;
  199. }
  200. }
  201. user.ActCount = ActCount;
  202. function.WriteLog("\n\n\n", "推荐王最终的达标创客数量分析");
  203. }
  204. int num = 0;
  205. foreach(RecommandKingItem user in users)
  206. {
  207. if(!Historys.Contains(user.UserId))
  208. {
  209. num += 1;
  210. RecommendDirectUser item = db.RecommendDirectUser.FirstOrDefault(m => m.UserId == user.UserId && m.TradeMonth == TradeMonth);
  211. if(item == null)
  212. {
  213. item = db.RecommendDirectUser.Add(new RecommendDirectUser()
  214. {
  215. UserId = user.UserId,
  216. TradeMonth = TradeMonth,
  217. QueryCount = user.ActCount > 50 ? 50 : user.ActCount,
  218. }).Entity;
  219. if(num % 200 == 0)
  220. {
  221. db.SaveChanges();
  222. }
  223. }
  224. }
  225. }
  226. db.SaveChanges();
  227. db.Dispose();
  228. readdb.Dispose();
  229. mpdb.Dispose();
  230. mpdb2.Dispose();
  231. }
  232. public int GetLevel(WebCMSEntities db, int UserId, int UserLevel)
  233. {
  234. UserRank rank = db.UserRank.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == 6 && m.StatYear == 2024);
  235. if(rank != null)
  236. {
  237. return rank.WhiteRank;
  238. }
  239. return UserLevel;
  240. }
  241. public decimal GetTradeAmt(int UserId, string TradeMonth)
  242. {
  243. ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
  244. MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
  245. MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
  246. decimal TradeAmount = 0;
  247. //创客团队交易额
  248. bool check = rdb.TradeDaySummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  249. if (check)
  250. {
  251. TradeAmount += rdb.TradeDaySummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
  252. }
  253. check = rdb.TradeDaySummary2.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  254. if (check)
  255. {
  256. TradeAmount += rdb.TradeDaySummary2.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.ProfitTradeAmt + m.ProfitDebitTradeAmt);
  257. }
  258. //码牌团队交易额(直联)
  259. check = mpmaindb.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  260. if (check)
  261. {
  262. TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
  263. }
  264. //码牌团队交易额(银联)
  265. check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  266. if (check)
  267. {
  268. TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
  269. }
  270. //广电卡扶持期按1万/张计入职级
  271. check = rdb.UserTradeMonthSummary.Any(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14);
  272. if (check)
  273. {
  274. TradeAmount += rdb.UserTradeMonthSummary.Where(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
  275. }
  276. return TradeAmount;
  277. }
  278. public Dictionary<int, decimal> GetTradeAmtList(string TradeMonth)
  279. {
  280. Dictionary<int, decimal> dic = new Dictionary<int, decimal>();
  281. ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
  282. MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
  283. MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
  284. //创客团队交易额
  285. bool check = rdb.TradeDaySummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  286. if (check)
  287. {
  288. var list = rdb.TradeDaySummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team").ToList().GroupBy(m => m.UserId);
  289. foreach(var item in list)
  290. {
  291. int UserId = item.Key;
  292. decimal Amt = item.Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
  293. if(!dic.ContainsKey(UserId))
  294. {
  295. dic.Add(UserId, Amt);
  296. }
  297. else
  298. {
  299. dic[UserId] += Amt;
  300. }
  301. }
  302. }
  303. check = rdb.TradeDaySummary2.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  304. if (check)
  305. {
  306. var list = rdb.TradeDaySummary2.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team").ToList().GroupBy(m => m.UserId);
  307. foreach(var item in list)
  308. {
  309. int UserId = item.Key;
  310. decimal Amt = item.Sum(m => m.ProfitTradeAmt + m.ProfitDebitTradeAmt);
  311. if(!dic.ContainsKey(UserId))
  312. {
  313. dic.Add(UserId, Amt);
  314. }
  315. else
  316. {
  317. dic[UserId] += Amt;
  318. }
  319. }
  320. }
  321. //码牌团队交易额(直联)
  322. check = mpmaindb.UserAmountSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  323. if (check)
  324. {
  325. var list = mpmaindb.UserAmountSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).ToList().GroupBy(m => m.UserId);
  326. foreach(var item in list)
  327. {
  328. int UserId = item.Key;
  329. decimal Amt = item.Sum(m => m.TotalAmount) * 4;
  330. if(!dic.ContainsKey(UserId))
  331. {
  332. dic.Add(UserId, Amt);
  333. }
  334. else
  335. {
  336. dic[UserId] += Amt;
  337. }
  338. }
  339. }
  340. //码牌团队交易额(银联)
  341. check = mpmaindb2.UserAmountSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  342. if (check)
  343. {
  344. var list = mpmaindb2.UserAmountSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).ToList().GroupBy(m => m.UserId);
  345. foreach(var item in list)
  346. {
  347. int UserId = item.Key;
  348. decimal Amt = item.Sum(m => m.TotalAmount) * 4;
  349. if(!dic.ContainsKey(UserId))
  350. {
  351. dic.Add(UserId, Amt);
  352. }
  353. else
  354. {
  355. dic[UserId] += Amt;
  356. }
  357. }
  358. }
  359. //广电卡扶持期按1万/张计入职级
  360. check = rdb.UserTradeMonthSummary.Any(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14);
  361. if (check)
  362. {
  363. var list = rdb.UserTradeMonthSummary.Where(m => m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).ToList().GroupBy(m => m.UserId);
  364. foreach(var item in list)
  365. {
  366. int UserId = item.Key;
  367. decimal Amt = item.Sum(m => m.ActiveBuddyMerStatus) * 10000;
  368. if(!dic.ContainsKey(UserId))
  369. {
  370. dic.Add(UserId, Amt);
  371. }
  372. else
  373. {
  374. dic[UserId] += Amt;
  375. }
  376. }
  377. }
  378. return dic;
  379. }
  380. }
  381. }