StatService.cs 150 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516
  1. using System;
  2. using System.Collections.Generic;
  3. using Library;
  4. using LitJson;
  5. using System.Linq;
  6. using System.Data;
  7. using System.Threading;
  8. using MySystem.PxcModels;
  9. namespace MySystem
  10. {
  11. public class StatService
  12. {
  13. public readonly static StatService Instance = new StatService();
  14. private StatService()
  15. { }
  16. public void Start(JobMqMsg jobInfo)
  17. {
  18. string content = "";
  19. try
  20. {
  21. if(DateTime.Now.Hour > 0)
  22. {
  23. string doDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
  24. string flag = function.ReadInstance("/Stat/" + doDate + ".txt");
  25. if (string.IsNullOrEmpty(flag))
  26. {
  27. function.WritePage("/Stat/", doDate + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  28. // dosomething1(doDate);
  29. // dosomething11(doDate);
  30. // dosomething2(doDate);
  31. StartEverDay(doDate);
  32. // StartEverDayV2(doDate);
  33. StatMerchantTrade(doDate);
  34. dosomething4(doDate);
  35. ListenFluxRecord(doDate);
  36. }
  37. string Msg = "success";
  38. jobInfo.Status = Msg == "success" ? 1 : 0;
  39. jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
  40. RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
  41. }
  42. }
  43. catch (Exception ex)
  44. {
  45. if (!string.IsNullOrEmpty(content))
  46. {
  47. Dictionary<string, string> data = new Dictionary<string, string>();
  48. data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  49. data.Add("ErrMsg", ex.ToString());
  50. function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
  51. }
  52. else
  53. {
  54. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
  55. }
  56. }
  57. }
  58. public void ActiveReward(JobMqMsg jobInfo)
  59. {
  60. string content = "";
  61. try
  62. {
  63. dosomething3();
  64. activePrizeWithoutDeposit();
  65. string Msg = "success";
  66. jobInfo.Status = Msg == "success" ? 1 : 0;
  67. jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
  68. RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
  69. function.WritePage("/static/", "act.txt", DateTime.Now.ToString());
  70. }
  71. catch (Exception ex)
  72. {
  73. if (!string.IsNullOrEmpty(content))
  74. {
  75. Dictionary<string, string> data = new Dictionary<string, string>();
  76. data.Add("ErrTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  77. data.Add("ErrMsg", ex.ToString());
  78. function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(data), "public_err");
  79. }
  80. else
  81. {
  82. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "public_service");
  83. }
  84. }
  85. }
  86. public void clear()
  87. {
  88. RedisDbconn.Instance.Clear("TotalAmount*");
  89. RedisDbconn.Instance.Clear("TotalCloudPayAmount*");
  90. RedisDbconn.Instance.Clear("TotalPosAmount*");
  91. RedisDbconn.Instance.Clear("TeamTotalAmount*");
  92. RedisDbconn.Instance.Clear("TeamTotalCloudPayAmount*");
  93. RedisDbconn.Instance.Clear("TeamTotalPosAmount*");
  94. // RedisDbconn.Instance.Clear("TotalUser*");
  95. // RedisDbconn.Instance.Clear("TeamTotalUser*");
  96. // RedisDbconn.Instance.Clear("AddUser*");
  97. // RedisDbconn.Instance.Clear("TeamAddUser*");
  98. // RedisDbconn.Instance.Clear("TotalPosMerchant*");
  99. // RedisDbconn.Instance.Clear("TeamTotalPosMerchant*");
  100. RedisDbconn.Instance.Clear("MerTotalAmount*");
  101. }
  102. // 1. 前一天的绑定记录和创客信息匹配,设置商户型创客
  103. public void dosomething1(string date)
  104. {
  105. // TODO: 每天扫描非商户型创客的持有机具数量
  106. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  107. WebCMSEntities db = new WebCMSEntities();
  108. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  109. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  110. List<SpModels.BindRecord> binds = spdb.BindRecord.Where(m => m.CreateTime >= yesterday && m.CreateTime < today).ToList();
  111. foreach (SpModels.BindRecord bind in binds)
  112. {
  113. string Mobile = bind.MerNewSnNo;
  114. string MerNo = bind.MerNo;
  115. string BeforeNum = "";
  116. string AfterNum = "";
  117. if (Mobile.Contains("****") && Mobile.Length == 11)
  118. {
  119. BeforeNum = Mobile.Substring(0, 3);
  120. AfterNum = Mobile.Substring(7);
  121. }
  122. string Name = bind.MerName;
  123. if (bind.ProductType == "2")
  124. {
  125. if (Name.Contains("-"))
  126. {
  127. Name = Name.Split('-')[1];
  128. }
  129. else if (Name.Contains("_"))
  130. {
  131. Name = Name.Split('_')[1];
  132. }
  133. }
  134. else if (bind.ProductType == "4")
  135. {
  136. Name = bind.SeoTitle;
  137. }
  138. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0);
  139. if (user != null)
  140. {
  141. bool checkPos = db.PosMachinesTwo.Any(m => m.UserId == user.Id);
  142. if (!checkPos)
  143. {
  144. PxcModels.MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == bind.MerSnNo) ?? new PxcModels.MachineForSnNo();
  145. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId && m.UserId != user.Id);
  146. if (pos != null)
  147. {
  148. pos.UserId = user.Id;
  149. user.MerchantType = 1;
  150. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PxcModels.PosMerchantInfo();
  151. merchant.UserId = user.Id;
  152. merchant.MerUserType = 1;
  153. pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
  154. RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
  155. db.SaveChanges();
  156. RedisDbconn.Instance.Set("Users:" + user.Id, user);
  157. RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
  158. }
  159. }
  160. }
  161. }
  162. spdb.Dispose();
  163. db.Dispose();
  164. }
  165. // 1. 前一天的商户型创客,判断名下是否3台激活机器,是则变为非商户型创客
  166. public void dosomething11(string date)
  167. {
  168. WebCMSEntities db = new WebCMSEntities();
  169. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  170. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  171. var users = db.Users.Select(m => new { m.Id, m.MerchantType }).Where(m => m.MerchantType == 1).ToList();
  172. foreach (var user in users)
  173. {
  174. int machineCount = db.PosMachinesTwo.Count(m => m.UserId == user.Id && m.PosSnType == 0);
  175. int couponCount = db.PosCoupons.Count(m => m.UserId == user.Id && m.IsUse == 0); //判断是否拥有3张券
  176. if (machineCount + couponCount >= 3)
  177. {
  178. Users edit = db.Users.FirstOrDefault(m => m.Id == user.Id);
  179. if (edit != null)
  180. {
  181. edit.MerchantType = 0;
  182. db.SaveChanges();
  183. RedisDbconn.Instance.Set("Users:" + user.Id, edit);
  184. }
  185. }
  186. }
  187. db.Dispose();
  188. }
  189. public void testStatTrade(string date)
  190. {
  191. string yesterday = date + " 00:00:00";
  192. string today = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  193. string TradeMonth = DateTime.Parse(date).ToString("yyyyMM");
  194. string TradeDate = DateTime.Parse(date).ToString("yyyyMMdd");
  195. DataTable dt = dbconn.dtable("select UserId,BrandId,MerchantId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where CreateDate>='" + yesterday + "' and CreateDate<'" + today + "' group by UserId,BrandId,MerchantId,BankCardType,QrPayFlag");
  196. foreach (DataRow dr in dt.Rows)
  197. {
  198. int UserId = int.Parse(dr["UserId"].ToString()); //创客ID
  199. int BrandId = int.Parse(dr["BrandId"].ToString()); //品牌
  200. int MerchantId = int.Parse(dr["MerchantId"].ToString()); //商户Id
  201. int BankCardType = int.Parse(dr["BankCardType"].ToString()); //卡类型
  202. int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString()); //云闪付
  203. decimal TradeAmount = decimal.Parse(dr[5].ToString()); //当日交易额
  204. string content = "{";
  205. content += "\"DateString\":\"" + date + "\",";
  206. content += "\"UserId\":\"" + UserId + "\",";
  207. content += "\"BrandId\":\"" + BrandId + "\",";
  208. content += "\"MerchantId\":\"" + MerchantId + "\",";
  209. content += "\"BankCardType\":\"" + BankCardType + "\",";
  210. content += "\"QrPayFlag\":\"" + QrPayFlag + "\",";
  211. content += "\"TradeAmount\":\"" + TradeAmount + "\"";
  212. content += "}";
  213. RedisDbconn.Instance.AddList("TradeStatQueueTest", content);
  214. }
  215. }
  216. // 3. 前一天的激活记录,根据创客类型,如果是商户型创客,则激活奖励的起始人从此人上级计算。如果不是,则从此人开始计算
  217. public void dosomething3(int posid = 0)
  218. {
  219. WebCMSEntities db = new WebCMSEntities();
  220. DateTime yesterday = DateTime.Now.AddDays(-1);
  221. DateTime today = DateTime.Now;
  222. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword));
  223. if (posid > 0)
  224. {
  225. posList = posList.Where(m => m.Id == posid);
  226. }
  227. else
  228. {
  229. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  230. }
  231. foreach (PosMachinesTwo pos in posList.ToList())
  232. {
  233. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  234. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  235. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  236. if (merchant != null)
  237. {
  238. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
  239. // if (otherInfo != null)
  240. // {
  241. // otherInfo.PrizeFlag1 = 1;
  242. // db.SaveChanges();
  243. string ParentNav = "";
  244. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  245. if (user != null)
  246. {
  247. int GetUserId = user.Id;
  248. ParentNav = user.ParentNav;
  249. int TopUserId = 0;
  250. if (!string.IsNullOrEmpty(ParentNav))
  251. {
  252. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  253. }
  254. decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  255. if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9)
  256. {
  257. ActPrize = ActPrize / 100;
  258. }
  259. if (ActPrize > 0)
  260. {
  261. if (ActPrize == 99)
  262. {
  263. ActPrize = 100;
  264. }
  265. else if (ActPrize == 199)
  266. {
  267. ActPrize = 200;
  268. }
  269. else if (ActPrize == 299)
  270. {
  271. ActPrize = 300;
  272. }
  273. else if (ActPrize == 249)
  274. {
  275. ActPrize = 260;
  276. }
  277. if (GetUserId > 0)
  278. {
  279. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize);
  280. }
  281. }
  282. else if(pos.BrandId == 6 && ActPrize == 0)
  283. {
  284. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
  285. }
  286. }
  287. // }
  288. }
  289. }
  290. db.Dispose();
  291. }
  292. public void activePrizeWithoutDeposit(int posid = 0)
  293. {
  294. WebCMSEntities db = new WebCMSEntities();
  295. DateTime yesterday = DateTime.Now.AddDays(-1);
  296. DateTime today = DateTime.Now;
  297. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && string.IsNullOrEmpty(m.SeoKeyword));
  298. if (posid > 0)
  299. {
  300. posList = posList.Where(m => m.Id == posid);
  301. }
  302. else
  303. {
  304. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  305. }
  306. foreach (PosMachinesTwo pos in posList.ToList())
  307. {
  308. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  309. if (merchant != null)
  310. {
  311. string ParentNav = "";
  312. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  313. if (user != null)
  314. {
  315. int GetUserId = user.Id;
  316. ParentNav = user.ParentNav;
  317. int TopUserId = 0;
  318. if (!string.IsNullOrEmpty(ParentNav))
  319. {
  320. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  321. }
  322. if(pos.BrandId == 6)
  323. {
  324. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
  325. }
  326. }
  327. }
  328. }
  329. db.Dispose();
  330. }
  331. public void doActiveReward(WebCMSEntities db, PosMerchantInfo merchant, PosMachinesTwo pos, int GetUserId, string ParentNav, int TopUserId, decimal ActPrize, int ChangeType = 0)
  332. {
  333. bool check = db.ActiveReward.Any(m => m.KqMerNo == merchant.KqMerNo && m.RewardAmount == ActPrize);
  334. if (!check)
  335. {
  336. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  337. db.ActiveReward.Add(new ActiveReward()
  338. {
  339. CreateDate = DateTime.Now,
  340. UpdateDate = DateTime.Now,
  341. UserId = GetUserId, //创客
  342. MerchantId = pos.BindMerchantId, //商户
  343. StandardDate = pos.ActivationTime, //达标日期
  344. RewardAmount = ActPrize, //奖励金额
  345. BrandId = pos.BrandId, //品牌
  346. UserNav = ParentNav, //创客父级
  347. DirectBuddyNo = merchant.UserId, //商户直属创客
  348. KqMerNo = merchant.KqMerNo, //渠道商户编号
  349. KqSnNo = pos.PosSn, //渠道SN号
  350. SnType = pos.PosSnType, //机具类型
  351. SnApplyUserId = pos.BuyUserId, //机具申请创客
  352. ActType = 0, //激活类型
  353. SnStoreId = pos.StoreId, //SN仓库
  354. RewardTips = "激活奖励", //奖励描述
  355. Remark = "激活奖励", //备注
  356. ActDate = pos.ActivationTime, //激活时间
  357. TopUserId = TopUserId, //顶级创客
  358. SeoTitle = machineUser.RealName,
  359. });
  360. db.SaveChanges();
  361. string IdBrand = GetUserId + "_" + pos.BrandId;
  362. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  363. if (userData == null)
  364. {
  365. userData = db.UserMachineData.Add(new UserMachineData()
  366. {
  367. IdBrand = IdBrand,
  368. }).Entity;
  369. db.SaveChanges();
  370. }
  371. userData.ActProfit += ActPrize;
  372. db.SaveChanges();
  373. RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
  374. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  375. if (account == null)
  376. {
  377. account = db.UserAccount.Add(new UserAccount()
  378. {
  379. Id = GetUserId,
  380. UserId = GetUserId,
  381. }).Entity;
  382. db.SaveChanges();
  383. }
  384. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  385. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  386. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  387. account.BalanceAmount += ActPrize;
  388. account.TotalAmount += ActPrize;
  389. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  390. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  391. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  392. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  393. {
  394. CreateDate = DateTime.Now,
  395. UpdateDate = DateTime.Now,
  396. UserId = GetUserId, //创客
  397. ChangeType = ChangeType, //变动类型
  398. ProductType = pos.BrandId, //产品类型
  399. ChangeAmount = ActPrize, //变更金额
  400. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  401. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  402. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  403. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  404. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  405. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  406. }).Entity;
  407. db.SaveChanges();
  408. RedisDbconn.Instance.Set("UserAccount:" + GetUserId, account);
  409. string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd");
  410. string monthString = pos.ActivationTime.Value.ToString("yyyyMM");
  411. // 激活奖励列表
  412. List<string> dates = RedisDbconn.Instance.GetList<string>("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId);
  413. if (!dates.Contains(dateString))
  414. {
  415. RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString);
  416. }
  417. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize);
  418. List<string> months = RedisDbconn.Instance.GetList<string>("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId);
  419. if (!months.Contains(monthString))
  420. {
  421. RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString);
  422. }
  423. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize);
  424. // 激活奖励详情
  425. List<int> actPrizeList = RedisDbconn.Instance.GetList<int>("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString);
  426. if (!actPrizeList.Contains(pos.BindMerchantId))
  427. {
  428. RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId);
  429. }
  430. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize);
  431. //收支明细
  432. RedisDbconn.Instance.AddList("UserAccountRecord:" + GetUserId + ":1:" + monthString, userAccountRecord);
  433. RedisDbconn.Instance.AddNumber("UserAccount:" + GetUserId + ":1:" + monthString, ActPrize);
  434. RedisDbconn.Instance.Clear("UserAccount:Income:" + GetUserId + ":" + monthString);
  435. }
  436. }
  437. //根据商户信息发放激活奖励
  438. public void dosomething32(int merid = 0)
  439. {
  440. WebCMSEntities db = new WebCMSEntities();
  441. DateTime yesterday = DateTime.Now.AddHours(-3);
  442. DateTime today = DateTime.Now;
  443. IQueryable<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && !string.IsNullOrEmpty(m.SeoKeyword));
  444. if (merid > 0)
  445. {
  446. merList = merList.Where(m => m.Id == merid);
  447. }
  448. else
  449. {
  450. merList = merList.Where(m => m.MerStandardDate >= yesterday && m.MerStandardDate < today);
  451. }
  452. foreach (PosMerchantInfo merchant in merList.ToList())
  453. {
  454. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  455. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
  456. // if (otherInfo != null)
  457. // {
  458. // otherInfo.PrizeFlag1 = 1;
  459. // db.SaveChanges();
  460. MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
  461. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
  462. string ParentNav = "";
  463. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  464. if (user != null)
  465. {
  466. int GetUserId = user.Id;
  467. ParentNav = user.ParentNav;
  468. int TopUserId = 0;
  469. if (!string.IsNullOrEmpty(ParentNav))
  470. {
  471. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  472. }
  473. decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
  474. if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9)
  475. {
  476. ActPrize = ActPrize / 100;
  477. }
  478. if (ActPrize > 0)
  479. {
  480. bool check = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn);
  481. if (!check)
  482. {
  483. if (ActPrize == 99)
  484. {
  485. ActPrize = 100;
  486. }
  487. else if (ActPrize == 199)
  488. {
  489. ActPrize = 200;
  490. }
  491. else if (ActPrize == 299)
  492. {
  493. ActPrize = 300;
  494. }
  495. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  496. db.ActiveReward.Add(new ActiveReward()
  497. {
  498. CreateDate = DateTime.Now,
  499. UpdateDate = DateTime.Now,
  500. UserId = GetUserId, //创客
  501. MerchantId = pos.BindMerchantId, //商户
  502. StandardDate = pos.ActivationTime, //达标日期
  503. RewardAmount = ActPrize, //奖励金额
  504. BrandId = pos.BrandId, //品牌
  505. UserNav = ParentNav, //创客父级
  506. DirectBuddyNo = merchant.UserId, //商户直属创客
  507. KqMerNo = merchant.KqMerNo, //渠道商户编号
  508. KqSnNo = pos.PosSn, //渠道SN号
  509. SnType = pos.PosSnType, //机具类型
  510. SnApplyUserId = pos.BuyUserId, //机具申请创客
  511. ActType = 0, //激活类型
  512. SnStoreId = pos.StoreId, //SN仓库
  513. RewardTips = "激活奖励", //奖励描述
  514. Remark = "激活奖励", //备注
  515. ActDate = pos.ActivationTime, //激活时间
  516. TopUserId = TopUserId, //顶级创客
  517. SeoTitle = machineUser.RealName,
  518. });
  519. db.SaveChanges();
  520. string IdBrand = GetUserId + "_" + pos.BrandId;
  521. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  522. if (userData == null)
  523. {
  524. userData = db.UserMachineData.Add(new UserMachineData()
  525. {
  526. IdBrand = IdBrand,
  527. }).Entity;
  528. db.SaveChanges();
  529. }
  530. userData.ActProfit += ActPrize;
  531. db.SaveChanges();
  532. RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
  533. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  534. if (account == null)
  535. {
  536. account = db.UserAccount.Add(new UserAccount()
  537. {
  538. Id = GetUserId,
  539. UserId = GetUserId,
  540. }).Entity;
  541. db.SaveChanges();
  542. }
  543. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  544. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  545. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  546. account.BalanceAmount += ActPrize;
  547. account.TotalAmount += ActPrize;
  548. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  549. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  550. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  551. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  552. {
  553. CreateDate = DateTime.Now,
  554. UpdateDate = DateTime.Now,
  555. UserId = GetUserId, //创客
  556. ChangeType = 0, //变动类型
  557. ProductType = pos.BrandId, //产品类型
  558. ChangeAmount = ActPrize, //变更金额
  559. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  560. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  561. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  562. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  563. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  564. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  565. }).Entity;
  566. db.SaveChanges();
  567. RedisDbconn.Instance.Set("UserAccount:" + GetUserId, account);
  568. string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd");
  569. string monthString = pos.ActivationTime.Value.ToString("yyyyMM");
  570. // 激活奖励列表
  571. List<string> dates = RedisDbconn.Instance.GetList<string>("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId);
  572. if (!dates.Contains(dateString))
  573. {
  574. RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString);
  575. }
  576. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize);
  577. List<string> months = RedisDbconn.Instance.GetList<string>("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId);
  578. if (!months.Contains(monthString))
  579. {
  580. RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString);
  581. }
  582. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize);
  583. // 激活奖励详情
  584. List<int> actPrizeList = RedisDbconn.Instance.GetList<int>("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString);
  585. if (!actPrizeList.Contains(pos.BindMerchantId))
  586. {
  587. RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId);
  588. }
  589. RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize);
  590. //收支明细
  591. RedisDbconn.Instance.AddList("UserAccountRecord:" + GetUserId + ":1:" + monthString, userAccountRecord);
  592. RedisDbconn.Instance.AddNumber("UserAccount:" + GetUserId + ":1:" + monthString, ActPrize);
  593. }
  594. }
  595. }
  596. // }
  597. }
  598. db.Dispose();
  599. }
  600. //3. 前一天的激活记录,根据创客类型,如果是商户型创客,则开机奖励的起始人从此人上级计算。如果不是,则从此人开始计算
  601. public void dosomething4(string date)
  602. {
  603. WebCMSEntities db = new WebCMSEntities();
  604. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  605. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  606. List<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.ActivationTime >= yesterday && m.ActivationTime < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000).ToList();
  607. foreach (PosMachinesTwo pos in posList)
  608. {
  609. if (pos.BindingTime > DateTime.Now.AddDays(-30))
  610. {
  611. decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  612. if (ActPrize > 0)
  613. {
  614. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  615. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  616. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  617. if (merchant != null)
  618. {
  619. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
  620. // if (otherInfo != null)
  621. // {
  622. // otherInfo.PrizeFlag2 = 1;
  623. // db.SaveChanges();
  624. // 从机具所属人上级开始分开机奖励
  625. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  626. if (user != null)
  627. {
  628. if (!string.IsNullOrEmpty(user.ParentNav))
  629. {
  630. decimal Prize = 20;
  631. string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  632. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  633. {
  634. int UserId = int.Parse(ParentNavs[i]);
  635. Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
  636. if (puser != null && Prize > 0)
  637. {
  638. int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台购买机
  639. int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
  640. int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
  641. // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
  642. // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机(不限购买或赠送)
  643. if (machineCount + ActiveCount + couponCount >= 3)
  644. {
  645. int pTopUserId = 0;
  646. if (!string.IsNullOrEmpty(puser.ParentNav))
  647. {
  648. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  649. }
  650. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  651. OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
  652. {
  653. CreateDate = DateTime.Now,
  654. UpdateDate = DateTime.Now,
  655. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  656. TradeDate = yesterday, //达标日期
  657. UserId = puser.Id, //创客
  658. BrandId = pos.BrandId, //品牌
  659. ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
  660. MerchantId = pos.BindMerchantId, //商户
  661. DirectUserId = merchant.UserId, //商户直属人
  662. SnNo = pos.PosSn, //SN号
  663. MerNo = merchant.KqMerNo, //渠道商户号
  664. SnType = pos.PosSnType, //机具类型
  665. StandardDate = pos.ActivationTime, //商户的激活日期
  666. SnStoreId = pos.StoreId, //SN仓库
  667. MerBuddyType = puser.MerchantType, //商户创客类型
  668. RewardType = 1, //奖励类型 1-开机直接奖励,2-开机间接奖励
  669. RewardTips = "开机奖励", //奖励描述
  670. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  671. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  672. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  673. RewardDesc = "开机奖励", //奖励描述
  674. TopUserId = pTopUserId, //顶级创客
  675. SeoTitle = machineUser.RealName,
  676. }).Entity;
  677. db.OpenReward.Add(new OpenReward()
  678. {
  679. CreateDate = DateTime.Now,
  680. UpdateDate = DateTime.Now,
  681. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  682. TradeDate = DateTime.Now, //达标日期
  683. UserId = puser.Id, //创客
  684. BrandId = pos.BrandId, //品牌
  685. RewardType = 2, //奖励类型
  686. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  687. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  688. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  689. RewardDesc = "开机奖励", //奖励描述
  690. TopUserId = pTopUserId, //顶级创客
  691. });
  692. string IdBrand = puser.Id + "_" + pos.BrandId;
  693. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  694. if (userData == null)
  695. {
  696. userData = db.UserMachineData.Add(new UserMachineData()
  697. {
  698. IdBrand = IdBrand,
  699. }).Entity;
  700. db.SaveChanges();
  701. }
  702. userData.OpenProfit += Prize;
  703. db.SaveChanges();
  704. RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
  705. //账户入库
  706. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
  707. if (account == null)
  708. {
  709. account = db.UserAccount.Add(new UserAccount()
  710. {
  711. Id = puser.Id,
  712. UserId = puser.Id,
  713. }).Entity;
  714. db.SaveChanges();
  715. }
  716. //收支明细入库
  717. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  718. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  719. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  720. account.BalanceAmount += Prize;
  721. account.TotalAmount += Prize;
  722. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  723. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  724. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  725. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  726. {
  727. CreateDate = DateTime.Now,
  728. UpdateDate = DateTime.Now,
  729. UserId = puser.Id, //创客
  730. ChangeType = 50, //变动类型
  731. ProductType = pos.BrandId, //产品类型
  732. ChangeAmount = Prize, //变更金额
  733. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  734. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  735. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  736. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  737. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  738. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  739. }).Entity;
  740. db.SaveChanges();
  741. RedisDbconn.Instance.Set("UserAccount:" + puser.Id, account);
  742. string dateString = yesterday.ToString("yyyyMMdd");
  743. string monthString = yesterday.ToString("yyyyMM");
  744. // 开机奖励列表
  745. List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
  746. if (!dates.Contains(dateString))
  747. {
  748. RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
  749. }
  750. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);
  751. List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
  752. if (!months.Contains(monthString))
  753. {
  754. RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
  755. }
  756. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);
  757. // 开机奖励详情
  758. RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);
  759. //收支明细
  760. RedisDbconn.Instance.AddList("UserAccountRecord:" + puser.Id + ":1:" + monthString, userAccountRecord);
  761. RedisDbconn.Instance.AddNumber("UserAccount:" + puser.Id + ":1:" + monthString, Prize);
  762. Prize -= 10;
  763. }
  764. }
  765. }
  766. }
  767. }
  768. // }
  769. }
  770. }
  771. }
  772. }
  773. db.Dispose();
  774. }
  775. public void dosomething42(string date)
  776. {
  777. WebCMSEntities db = new WebCMSEntities();
  778. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  779. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  780. List<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && m.MerStandardDate >= yesterday && m.MerStandardDate < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0").ToList();
  781. foreach (PosMerchantInfo merchant in merList)
  782. {
  783. MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
  784. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
  785. if (pos.ActivationTime > DateTime.Now.AddDays(-20) && pos.CreditTrade >= 1000)
  786. {
  787. decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
  788. if (ActPrize > 0)
  789. {
  790. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  791. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
  792. // if (otherInfo != null)
  793. // {
  794. // otherInfo.PrizeFlag2 = 1;
  795. // db.SaveChanges();
  796. // 从机具所属人上级开始分开机奖励
  797. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  798. if (user != null)
  799. {
  800. if (!string.IsNullOrEmpty(user.ParentNav))
  801. {
  802. decimal Prize = 20;
  803. string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  804. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  805. {
  806. int UserId = int.Parse(ParentNavs[i]);
  807. Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
  808. if (puser != null && Prize > 0)
  809. {
  810. int machineCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台购买机
  811. int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
  812. int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
  813. // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
  814. // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机(不限购买或赠送)
  815. if (machineCount + ActiveCount + couponCount >= 3)
  816. {
  817. int pTopUserId = 0;
  818. if (!string.IsNullOrEmpty(puser.ParentNav))
  819. {
  820. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  821. }
  822. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  823. OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
  824. {
  825. CreateDate = DateTime.Now,
  826. UpdateDate = DateTime.Now,
  827. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  828. TradeDate = yesterday, //达标日期
  829. UserId = puser.Id, //创客
  830. BrandId = pos.BrandId, //品牌
  831. ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
  832. MerchantId = pos.BindMerchantId, //商户
  833. DirectUserId = merchant.UserId, //商户直属人
  834. SnNo = pos.PosSn, //SN号
  835. MerNo = merchant.KqMerNo, //渠道商户号
  836. SnType = pos.PosSnType, //机具类型
  837. StandardDate = pos.ActivationTime, //商户的激活日期
  838. SnStoreId = pos.StoreId, //SN仓库
  839. MerBuddyType = puser.MerchantType, //商户创客类型
  840. RewardType = 1, //奖励类型 1-开机直接奖励,2-开机间接奖励
  841. RewardTips = "开机奖励", //奖励描述
  842. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  843. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  844. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  845. RewardDesc = "开机奖励", //奖励描述
  846. TopUserId = pTopUserId, //顶级创客
  847. SeoTitle = machineUser.RealName,
  848. }).Entity;
  849. db.OpenReward.Add(new OpenReward()
  850. {
  851. CreateDate = DateTime.Now,
  852. UpdateDate = DateTime.Now,
  853. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  854. TradeDate = DateTime.Now, //达标日期
  855. UserId = puser.Id, //创客
  856. BrandId = pos.BrandId, //品牌
  857. RewardType = 2, //奖励类型
  858. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  859. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  860. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  861. RewardDesc = "开机奖励", //奖励描述
  862. TopUserId = pTopUserId, //顶级创客
  863. });
  864. string IdBrand = puser.Id + "_" + pos.BrandId;
  865. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  866. if (userData == null)
  867. {
  868. userData = db.UserMachineData.Add(new UserMachineData()
  869. {
  870. IdBrand = IdBrand,
  871. }).Entity;
  872. db.SaveChanges();
  873. }
  874. userData.OpenProfit += Prize;
  875. db.SaveChanges();
  876. RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
  877. //账户入库
  878. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
  879. if (account == null)
  880. {
  881. account = db.UserAccount.Add(new UserAccount()
  882. {
  883. Id = puser.Id,
  884. UserId = puser.Id,
  885. }).Entity;
  886. db.SaveChanges();
  887. }
  888. //收支明细入库
  889. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  890. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  891. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  892. account.BalanceAmount += Prize;
  893. account.TotalAmount += Prize;
  894. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  895. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  896. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  897. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  898. {
  899. CreateDate = DateTime.Now,
  900. UpdateDate = DateTime.Now,
  901. UserId = puser.Id, //创客
  902. ChangeType = 50, //变动类型
  903. ProductType = pos.BrandId, //产品类型
  904. ChangeAmount = Prize, //变更金额
  905. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  906. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  907. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  908. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  909. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  910. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  911. }).Entity;
  912. db.SaveChanges();
  913. RedisDbconn.Instance.Set("UserAccount:" + puser.Id, account);
  914. string dateString = yesterday.ToString("yyyyMMdd");
  915. string monthString = yesterday.ToString("yyyyMM");
  916. // 开机奖励列表
  917. List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
  918. if (!dates.Contains(dateString))
  919. {
  920. RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
  921. }
  922. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);
  923. List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
  924. if (!months.Contains(monthString))
  925. {
  926. RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
  927. }
  928. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);
  929. // 开机奖励详情
  930. RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);
  931. //收支明细
  932. RedisDbconn.Instance.AddList("UserAccountRecord:" + puser.Id + ":1:" + monthString, userAccountRecord);
  933. RedisDbconn.Instance.AddNumber("UserAccount:" + puser.Id + ":1:" + monthString, Prize);
  934. Prize -= 10;
  935. }
  936. }
  937. }
  938. }
  939. }
  940. // }
  941. }
  942. }
  943. }
  944. db.Dispose();
  945. }
  946. // 4. 前一天的流量卡记录和匹配
  947. public void ListenFluxRecord(string date)
  948. {
  949. Thread th = new Thread(CheckFluxForTrade);
  950. th.IsBackground = true;
  951. th.Start(date);
  952. }
  953. public void doFluxRecord(string date)
  954. {
  955. function.WriteLog(DateTime.Now.ToString(), "执行流量费返佣");
  956. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  957. WebCMSEntities db = new WebCMSEntities();
  958. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  959. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  960. List<SpModels.TradeFluxRecord> trades = spdb.TradeFluxRecord.Where(m => m.CreateDate >= yesterday && m.CreateDate < today && m.Status == 1).ToList();
  961. foreach (SpModels.TradeFluxRecord trade in trades)
  962. {
  963. try
  964. {
  965. string OrderNo = trade.TradeSerialNo; //单号
  966. DateTime TradeDate = trade.CreateDate.Value;
  967. string TradeMonth = TradeDate.ToString("yyyyMM");
  968. decimal FeeAmount = trade.FeeAmount; //流量费
  969. if (trade.ProductType == "1" || trade.ProductType == "4" || trade.ProductType == "6" || trade.ProductType == "8" || trade.ProductType == "9")
  970. {
  971. FeeAmount = FeeAmount / 100;
  972. }
  973. string TradeSnNo = trade.TradeSnNo; //机具SN
  974. decimal FluxProfit = 0;
  975. if (trade.ProductType == "1" && FeeAmount == 60)
  976. {
  977. FluxProfit = 24;
  978. }
  979. else if (trade.ProductType == "7" && FeeAmount == 46)
  980. {
  981. FluxProfit = 10;
  982. }
  983. else if (trade.ProductType != "1" && FeeAmount == 48)
  984. {
  985. FluxProfit = 12;
  986. }
  987. if (FluxProfit > 0)
  988. {
  989. MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new MachineForSnNo();
  990. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
  991. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  992. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  993. if (merchant != null && pos.BrandId != 6)
  994. {
  995. bool checkExist = db.FluxProfitDetail.Any(m => m.MerNo == merchant.KqMerNo);
  996. if (!checkExist && decimal.Parse(function.CheckNum(pos.SeoKeyword)) > 0)
  997. {
  998. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  999. int GetUserId = user.Id;
  1000. int TopUserId = 0;
  1001. string ParentNav = user.ParentNav;
  1002. if (!string.IsNullOrEmpty(ParentNav))
  1003. {
  1004. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1005. if (ParentNavList.Length > 1)
  1006. {
  1007. TopUserId = int.Parse(ParentNavList[1]);
  1008. }
  1009. else if (ParentNavList.Length == 1)
  1010. {
  1011. TopUserId = int.Parse(ParentNavList[0]);
  1012. }
  1013. }
  1014. FluxProfitSummary fluxProfit = db.FluxProfitSummary.FirstOrDefault(m => m.UserId == GetUserId && m.BrandId == pos.BrandId && m.TradeMonth == TradeMonth);
  1015. if (fluxProfit == null)
  1016. {
  1017. fluxProfit = db.FluxProfitSummary.Add(new FluxProfitSummary()
  1018. {
  1019. CreateDate = DateTime.Now,
  1020. UpdateDate = DateTime.Now,
  1021. UserId = GetUserId, //创客
  1022. BrandId = pos.BrandId,
  1023. TopUserId = TopUserId, //顶级创客
  1024. TradeMonth = TradeMonth, //交易月
  1025. MerUserType = user.MerchantType, //商户创客类型
  1026. Remark = "流量卡分佣", //备注
  1027. }).Entity;
  1028. db.SaveChanges();
  1029. }
  1030. fluxProfit.FluxProfitAmt += FluxProfit; //流量分润总金额
  1031. db.FluxProfitDetail.Add(new FluxProfitDetail()
  1032. {
  1033. CreateDate = DateTime.Now,
  1034. UpdateDate = DateTime.Now,
  1035. RecordNo = OrderNo, //单号
  1036. TradeDate = TradeDate.ToString("yyyyMMdd"), //交易日期
  1037. TradeTime = TradeDate.ToString("HHmmss"), //交易时间
  1038. TradeMonth = TradeMonth, //交易月
  1039. UserId = GetUserId, //创客
  1040. MerchantId = pos.BindMerchantId, //商户
  1041. MerchantUserId = pos.UserId, //商户直属人
  1042. MerNo = merchant.KqMerNo, //渠道商户编号
  1043. SnNo = pos.PosSn, //渠道SN号
  1044. FluxOrderNo = OrderNo, //流量扣费单号
  1045. TradeOrderNo = OrderNo, //交易流水号
  1046. TradeAmt = trade.TradeAmount, //商户交易额
  1047. FluxFeeAmt = FeeAmount, //流量费
  1048. FluxProfitAmt = FluxProfit, //流量分润总金额
  1049. PosType = pos.PosSnType.ToString(), //POS类型
  1050. Remark = "流量卡分佣", //备注
  1051. BrandId = pos.BrandId, //品牌
  1052. TopUserId = TopUserId, //顶级创客
  1053. MerUserType = user.MerchantType, //商户创客类型
  1054. });
  1055. string IdBrand = user.Id + "_" + pos.BrandId;
  1056. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  1057. if (userData == null)
  1058. {
  1059. userData = db.UserMachineData.Add(new UserMachineData()
  1060. {
  1061. IdBrand = IdBrand,
  1062. }).Entity;
  1063. db.SaveChanges();
  1064. }
  1065. userData.FluxProfit += FluxProfit;
  1066. db.SaveChanges();
  1067. RedisDbconn.Instance.Clear("UserMachineData:" + IdBrand);
  1068. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  1069. if (account == null)
  1070. {
  1071. account = db.UserAccount.Add(new UserAccount()
  1072. {
  1073. Id = GetUserId,
  1074. UserId = GetUserId,
  1075. }).Entity;
  1076. db.SaveChanges();
  1077. }
  1078. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  1079. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  1080. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  1081. account.BalanceAmount += FluxProfit;
  1082. account.TotalAmount += FluxProfit;
  1083. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  1084. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  1085. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  1086. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  1087. {
  1088. CreateDate = DateTime.Now,
  1089. UpdateDate = DateTime.Now,
  1090. UserId = GetUserId, //创客
  1091. ChangeType = 60, //变动类型
  1092. ProductType = pos.BrandId, //产品类型
  1093. ChangeAmount = FluxProfit, //变更金额
  1094. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  1095. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  1096. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  1097. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  1098. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  1099. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  1100. }).Entity;
  1101. db.SaveChanges();
  1102. RedisDbconn.Instance.Clear("UserAccount:" + GetUserId);
  1103. }
  1104. SpModels.TradeFluxRecord edit = spdb.TradeFluxRecord.FirstOrDefault(m => m.Id == trade.Id);
  1105. if (edit != null)
  1106. {
  1107. edit.Status = 2;
  1108. spdb.SaveChanges();
  1109. }
  1110. }
  1111. }
  1112. }
  1113. catch (Exception ex)
  1114. {
  1115. function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
  1116. }
  1117. }
  1118. spdb.Dispose();
  1119. db.Dispose();
  1120. function.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣");
  1121. }
  1122. public void CheckFluxForTrade(object sender)
  1123. {
  1124. string date = sender.ToString();
  1125. function.WriteLog(DateTime.Now.ToString(), "扫描金控交易记录中的流量费");
  1126. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  1127. DateTime start = DateTime.Parse(date + " 00:00:00");
  1128. DateTime end = start.AddDays(1);
  1129. var list = spdb.TradeRecord.Select(m => new { m.Id, m.CreateDate, m.ProductType }).Where(m => m.CreateDate > start && m.CreateDate < end && m.ProductType == "1").OrderBy(m => m.CreateDate);
  1130. foreach (var sub in list.ToList())
  1131. {
  1132. try
  1133. {
  1134. SpModels.TradeRecord trade = spdb.TradeRecord.FirstOrDefault(m => m.Id == sub.Id);
  1135. if (trade != null)
  1136. {
  1137. string content = trade.SeoDescription;
  1138. if (!string.IsNullOrEmpty(content))
  1139. {
  1140. content = System.Web.HttpUtility.UrlDecode(content);
  1141. JsonData jsonObj = JsonMapper.ToObject(content);
  1142. decimal terminalDataFlowFee = decimal.Parse(function.CheckNum(jsonObj["terminalDataFlowFee"].ToString()));
  1143. if (terminalDataFlowFee > 0)
  1144. {
  1145. spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord()
  1146. {
  1147. SeoDescription = trade.TradeSerialNo,
  1148. FeeAmount = terminalDataFlowFee,
  1149. TradeSerialNo = function.MD5_16(trade.TradeSerialNo),
  1150. CreateDate = trade.CreateDate,
  1151. TradeSnNo = trade.TradeSnNo,
  1152. ProductType = trade.ProductType,
  1153. Status = 1,
  1154. });
  1155. spdb.SaveChanges();
  1156. }
  1157. }
  1158. }
  1159. }
  1160. catch (Exception ex)
  1161. {
  1162. function.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描金控交易记录中的流量费异常");
  1163. }
  1164. }
  1165. spdb.Dispose();
  1166. function.WriteLog(DateTime.Now.ToString() + "\n", "扫描金控交易记录中的流量费");
  1167. doFluxRecord(date);
  1168. }
  1169. // 统计交易额V2
  1170. public void StartEverDayV2()
  1171. {
  1172. Thread th = new Thread(StartEverDayV2Do);
  1173. th.IsBackground = true;
  1174. th.Start();
  1175. }
  1176. public void StartEverDayV2Do()
  1177. {
  1178. while (true)
  1179. {
  1180. if(DateTime.Now.Hour >= 2)
  1181. {
  1182. StatTradeAmountEverDayV2();
  1183. }
  1184. Thread.Sleep(100);
  1185. }
  1186. }
  1187. public void StatTradeAmountEverDayV2()
  1188. {
  1189. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  1190. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行交易额V2日志");
  1191. WebCMSEntities db = new WebCMSEntities();
  1192. using (var tran = db.Database.BeginTransaction())
  1193. {
  1194. try
  1195. {
  1196. string startId = function.ReadInstance("/TradeRecord/Id.txt");
  1197. if(string.IsNullOrEmpty(startId))
  1198. {
  1199. startId = "718574";
  1200. }
  1201. DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
  1202. if(idsDt.Rows.Count > 0)
  1203. {
  1204. string ids = "";
  1205. foreach (DataRow idsDr in idsDt.Rows)
  1206. {
  1207. ids += idsDr["Id"].ToString() + ",";
  1208. startId = idsDr["Id"].ToString();
  1209. }
  1210. DataTable selfDt = OtherMySqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d')");
  1211. if (selfDt.Rows.Count > 0)
  1212. {
  1213. function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时交易额V2日志");
  1214. foreach (DataRow selfDr in selfDt.Rows)
  1215. {
  1216. int UserId = int.Parse(selfDr["UserId"].ToString());
  1217. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1218. string ParentNav = user.ParentNav; //selfDr["ParentNav"].ToString();
  1219. int BrandId = int.Parse(selfDr["BrandId"].ToString());
  1220. int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
  1221. int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
  1222. int MerHelpFlag = int.Parse(selfDr["MerHelpFlag"].ToString());
  1223. int CapFlag = int.Parse(selfDr["CapFlag"].ToString());
  1224. int VipFlag = int.Parse(selfDr["VipFlag"].ToString());
  1225. int PayType = int.Parse(selfDr["PayType"].ToString());
  1226. string TradeDate = selfDr[9].ToString();
  1227. decimal TradeAmount = decimal.Parse(selfDr[10].ToString());
  1228. int TradeCount = int.Parse(selfDr[11].ToString());
  1229. string TradeMonth = TradeDate.Substring(0, 6);
  1230. TradeDaySummary selfStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "self");
  1231. if (selfStat == null)
  1232. {
  1233. selfStat = db.TradeDaySummary.Add(new TradeDaySummary()
  1234. {
  1235. UserId = UserId,
  1236. TradeMonth = TradeMonth,
  1237. TradeDate = TradeDate,
  1238. BrandId = BrandId,
  1239. QueryCount = QrPayFlag,
  1240. VipFlag = VipFlag,
  1241. PayType = PayType,
  1242. SeoTitle = "self",
  1243. }).Entity;
  1244. db.SaveChanges();
  1245. }
  1246. if (BankCardType == 0)
  1247. {
  1248. if (MerHelpFlag == 1)
  1249. {
  1250. selfStat.HelpDirectDebitTradeAmt += TradeAmount;
  1251. if (CapFlag == 1)
  1252. {
  1253. selfStat.HelpDirectDebitCapTradeAmt += TradeAmount;
  1254. selfStat.HelpDirectDebitCapNum += TradeCount;
  1255. }
  1256. }
  1257. else
  1258. {
  1259. selfStat.NotHelpDirectDebitTradeAmt += TradeAmount;
  1260. if (CapFlag == 1)
  1261. {
  1262. selfStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
  1263. selfStat.NotHelpDirectDebitCapNum += TradeCount;
  1264. }
  1265. }
  1266. }
  1267. else if (BankCardType != 0)
  1268. {
  1269. if (MerHelpFlag == 1)
  1270. {
  1271. selfStat.HelpDirectTradeAmt += TradeAmount;
  1272. }
  1273. else
  1274. {
  1275. selfStat.NotHelpDirectTradeAmt += TradeAmount;
  1276. }
  1277. }
  1278. ParentNav += "," + UserId + ",";
  1279. if (!string.IsNullOrEmpty(ParentNav))
  1280. {
  1281. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1282. foreach (string NavUserIdString in ParentNavList)
  1283. {
  1284. int NavUserId = int.Parse(NavUserIdString);
  1285. TradeDaySummary teamStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "team");
  1286. if (teamStat == null)
  1287. {
  1288. teamStat = db.TradeDaySummary.Add(new TradeDaySummary()
  1289. {
  1290. UserId = NavUserId,
  1291. TradeMonth = TradeMonth,
  1292. TradeDate = TradeDate,
  1293. BrandId = BrandId,
  1294. QueryCount = QrPayFlag,
  1295. VipFlag = VipFlag,
  1296. PayType = PayType,
  1297. SeoTitle = "team",
  1298. }).Entity;
  1299. db.SaveChanges();
  1300. }
  1301. if (BankCardType == 0)
  1302. {
  1303. if (MerHelpFlag == 1)
  1304. {
  1305. teamStat.HelpNonDirectDebitTradeAmt += TradeAmount;
  1306. if (CapFlag == 1)
  1307. {
  1308. teamStat.HelpDirectDebitCapTradeAmt += TradeAmount;
  1309. teamStat.HelpDirectDebitCapNum += TradeCount;
  1310. }
  1311. }
  1312. else
  1313. {
  1314. teamStat.NotHelpNonDirectDebitTradeAmt += TradeAmount;
  1315. if (CapFlag == 1)
  1316. {
  1317. teamStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
  1318. teamStat.NotHelpDirectDebitCapNum += TradeCount;
  1319. }
  1320. }
  1321. }
  1322. else if (BankCardType != 0)
  1323. {
  1324. if (MerHelpFlag == 1)
  1325. {
  1326. teamStat.HelpNonDirectTradeAmt += TradeAmount;
  1327. }
  1328. else
  1329. {
  1330. teamStat.NotHelpNonDirectTradeAmt += TradeAmount;
  1331. }
  1332. }
  1333. }
  1334. }
  1335. }
  1336. OtherMySqlConn.op("update TradeRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  1337. function.WritePage("/TradeRecord/", "Id.txt", startId);
  1338. }
  1339. db.SaveChanges();
  1340. }
  1341. tran.Commit();
  1342. }
  1343. catch (Exception ex)
  1344. {
  1345. tran.Rollback();
  1346. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天交易额V2异常");
  1347. }
  1348. }
  1349. db.Dispose();
  1350. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行交易额V2日志");
  1351. }
  1352. // 每天统计头一天的交易额
  1353. public void StartEverDay(string date)
  1354. {
  1355. // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  1356. // DateTime end = DateTime.Parse("2022-04-19 00:00:00");
  1357. // DateTime check = DateTime.Parse("2022-03-11");
  1358. // while (check <= end)
  1359. // {
  1360. // Thread th = new Thread(StatTradeAmountEverDay);
  1361. // th.IsBackground = true;
  1362. // th.Start(check.ToString("yyyy-MM-dd"));
  1363. // check = check.AddDays(1);
  1364. // }
  1365. string TradeMonth = DateTime.Now.ToString("yyyyMM");
  1366. if(DateTime.Now.Day == 1)
  1367. {
  1368. TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  1369. }
  1370. DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
  1371. foreach (DataRow dr in list.Rows)
  1372. {
  1373. string UserId = dr["UserId"].ToString();
  1374. string ThisMonthTrade = dr[1].ToString();
  1375. OtherMySqlConn.op("update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId);
  1376. }
  1377. // Thread th = new Thread(StatTradeAmountEverDay);
  1378. // th.IsBackground = true;
  1379. // th.Start(date);
  1380. }
  1381. public void StatTradeAmountEverDay(object sender)
  1382. {
  1383. string date = sender.ToString();
  1384. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志");
  1385. WebCMSEntities db = new WebCMSEntities();
  1386. try
  1387. {
  1388. string TradeDate = date.Replace("-", "");
  1389. string TradeMonth = TradeDate.Substring(0, 6);
  1390. string start = date + " 00:00:00";
  1391. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  1392. string startId = "0", endId = "9999999999";
  1393. List<string> uids = new List<string>();
  1394. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from TradeRecord where CreateDate>='" + start + "'");
  1395. if (startDt.Rows.Count > 0)
  1396. {
  1397. startId = startDt.Rows[0][0].ToString();
  1398. }
  1399. function.WriteLog(startId + "\n\n", "执行昨天交易额日志");
  1400. // DataTable endDt = OtherMySqlConn.dtable("select max(Id) from TradeRecord where CreateDate<'" + end + "'");
  1401. // if (endDt.Rows.Count > 0)
  1402. // {
  1403. // endId = endDt.Rows[0][0].ToString();
  1404. // }
  1405. DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
  1406. function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志");
  1407. foreach (DataRow userDr in userDt.Rows)
  1408. {
  1409. int UserId = int.Parse(userDr["Id"].ToString());
  1410. string ParentNav = userDr["ParentNav"].ToString();
  1411. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1412. DataTable selfdt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by BrandId,BankCardType,QrPayFlag");
  1413. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1414. foreach (DataRow selfDr in selfdt.Rows)
  1415. {
  1416. int BrandId = int.Parse(selfDr["BrandId"].ToString());
  1417. int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
  1418. int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
  1419. decimal TradeAmount = decimal.Parse(selfDr[3].ToString());
  1420. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  1421. if (selfStat == null)
  1422. {
  1423. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1424. {
  1425. UserId = UserId,
  1426. TradeMonth = TradeMonth,
  1427. TradeDate = TradeDate,
  1428. BrandId = BrandId,
  1429. QueryCount = QrPayFlag,
  1430. SeoTitle = "self",
  1431. }).Entity;
  1432. db.SaveChanges();
  1433. }
  1434. if (BankCardType == 0)
  1435. {
  1436. selfStat.DirectDebitTradeAmt += TradeAmount;
  1437. }
  1438. else if (BankCardType != 0)
  1439. {
  1440. selfStat.DirectTradeAmt += TradeAmount;
  1441. }
  1442. db.SaveChanges();
  1443. }
  1444. if (!string.IsNullOrEmpty(ParentNav))
  1445. {
  1446. ParentNav += "," + UserId + ",";
  1447. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1448. foreach (string NavUserIdString in ParentNavList)
  1449. {
  1450. if (!uids.Contains(NavUserIdString + start))
  1451. {
  1452. uids.Add(NavUserIdString + start);
  1453. int NavUserId = int.Parse(NavUserIdString);
  1454. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1455. DataTable teamDt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId,BankCardType,QrPayFlag");
  1456. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1457. foreach (DataRow teamDr in teamDt.Rows)
  1458. {
  1459. int BrandId = int.Parse(teamDr["BrandId"].ToString());
  1460. int BankCardType = int.Parse(teamDr["BankCardType"].ToString());
  1461. int QrPayFlag = int.Parse(teamDr["QrPayFlag"].ToString());
  1462. decimal TradeAmount = decimal.Parse(teamDr[3].ToString());
  1463. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  1464. if (teamStat == null)
  1465. {
  1466. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1467. {
  1468. UserId = NavUserId,
  1469. TradeMonth = TradeMonth,
  1470. TradeDate = TradeDate,
  1471. BrandId = BrandId,
  1472. QueryCount = QrPayFlag,
  1473. SeoTitle = "team",
  1474. }).Entity;
  1475. db.SaveChanges();
  1476. }
  1477. if (BankCardType == 0)
  1478. {
  1479. teamStat.NonDirectDebitTradeAmt += TradeAmount;
  1480. }
  1481. else if (BankCardType != 0)
  1482. {
  1483. teamStat.NonDirectTradeAmt += TradeAmount;
  1484. }
  1485. db.SaveChanges();
  1486. }
  1487. }
  1488. }
  1489. }
  1490. }
  1491. if (DateTime.Now.Day >= 2)
  1492. {
  1493. Thread.Sleep(5000);
  1494. DataTable list = OtherMySqlConn.dtable("select UserId,sum(NonDirectTradeAmt) from UserTradeDaySummary where TradeDate='" + TradeDate + "' GROUP BY UserId");
  1495. foreach (DataRow dr in list.Rows)
  1496. {
  1497. string UserId = dr["UserId"].ToString();
  1498. string ThisMonthTrade = dr[1].ToString();
  1499. OtherMySqlConn.op("update Users set ThisMonthTrade=ThisMonthTrade+" + ThisMonthTrade + " where Id=" + UserId);
  1500. }
  1501. }
  1502. }
  1503. catch (Exception ex)
  1504. {
  1505. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常");
  1506. }
  1507. db.Dispose();
  1508. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1509. StatMerchantTrade(date);
  1510. }
  1511. public void StatTradeAmountEverDaySum()
  1512. {
  1513. // WebCMSEntities db = new WebCMSEntities();
  1514. // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  1515. // DataTable dt = OtherMySqlConn.dtable("select UserId,BrandId,QueryCount,TradeDate,TradeMonth,sum(DirectDebitTradeAmt) as DirectDebitTradeAmt,sum(DirectTradeAmt) as DirectTradeAmt,sum(NonDirectDebitTradeAmt) as NonDirectDebitTradeAmt,sum(NonDirectTradeAmt) as NonDirectTradeAmt from UserTradeDaySummary group by UserId,BrandId,QueryCount,TradeDate,TradeMonth order by UserId,BrandId,QueryCount");
  1516. // string html = "<table>";
  1517. // foreach (DataRow dr in dt.Rows)
  1518. // {
  1519. // html += "<tr>";
  1520. // string TradeDate = dr["TradeDate"].ToString();
  1521. // string TradeMonth = dr["TradeMonth"].ToString();
  1522. // int UserId = int.Parse(dr["UserId"].ToString());
  1523. // int BrandId = int.Parse(dr["BrandId"].ToString());
  1524. // int QrPayFlag = int.Parse(dr["QueryCount"].ToString());
  1525. // decimal DirectDebitTradeAmt = decimal.Parse(dr["DirectDebitTradeAmt"].ToString());
  1526. // decimal DirectTradeAmt = decimal.Parse(dr["DirectTradeAmt"].ToString());
  1527. // decimal NonDirectDebitTradeAmt = decimal.Parse(dr["NonDirectDebitTradeAmt"].ToString());
  1528. // decimal NonDirectTradeAmt = decimal.Parse(dr["NonDirectTradeAmt"].ToString());
  1529. // decimal CurAmount = 0, CurTotalAmount = 0, CurMonthAmount = 0, CurDayAmount = 0;
  1530. // CurTotalAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId); //总交易
  1531. // CurMonthAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + TradeDate); //总交易
  1532. // CurDayAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + TradeMonth); //总交易
  1533. // CurAmount = RedisDbconn.Instance.Get<decimal>("TotalAmount:" + UserId + ":" + BrandId + ":" + TradeDate); //总交易
  1534. // decimal TotalPosAmount = 0;
  1535. // decimal TotalCloudPayAmount = 0;
  1536. // decimal TeamTotalPosAmount = 0;
  1537. // decimal TeamTotalCloudPayAmount = 0;
  1538. // if (QrPayFlag == 1)
  1539. // {
  1540. // TotalCloudPayAmount = RedisDbconn.Instance.Get<decimal>("TotalCloudPayAmount:" + UserId + ":" + TradeDate); //云闪付小额交易额
  1541. // TeamTotalCloudPayAmount = RedisDbconn.Instance.Get<decimal>("TeamTotalCloudPayAmount:" + UserId + ":" + TradeDate); //POS机刷卡交易额
  1542. // }
  1543. // else
  1544. // {
  1545. // TotalPosAmount = RedisDbconn.Instance.Get<decimal>("TotalPosAmount:" + UserId + ":" + TradeDate); //POS机刷卡交易额
  1546. // TeamTotalPosAmount = RedisDbconn.Instance.Get<decimal>("TeamTotalPosAmount:" + UserId + ":" + TradeDate); //云闪付小额交易额
  1547. // }
  1548. // Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1549. // html += "<td>应得</td>";
  1550. // html += "<td>" + user.MakerCode + "</td>";
  1551. // html += "<td>" + user.RealName + "</td>";
  1552. // html += "<td>" + user.Mobile + "</td>";
  1553. // html += "<td>" + BrandId + "</td>";
  1554. // html += "<td>" + QrPayFlag + "</td>";
  1555. // html += "<td>" + DirectDebitTradeAmt + "</td>";
  1556. // html += "<td>" + DirectTradeAmt + "</td>";
  1557. // html += "<td>" + NonDirectDebitTradeAmt + "</td>";
  1558. // html += "<td>" + NonDirectTradeAmt + "</td>";
  1559. // html += "</tr>";
  1560. // html += "<tr>";
  1561. // html += "<td>当前</td>";
  1562. // html += "<td></td>";
  1563. // html += "<td></td>";
  1564. // html += "<td>当天品牌:" + CurAmount + "</td>";
  1565. // html += "<td>总交易:" + CurTotalAmount + "</td>";
  1566. // html += "<td>当月:" + CurMonthAmount + "</td>";
  1567. // html += "<td>当天:" + CurDayAmount + "</td>";
  1568. // html += "<td>" + TotalPosAmount + "</td>";
  1569. // html += "<td>" + TotalCloudPayAmount + "</td>";
  1570. // html += "<td>" + TeamTotalPosAmount + "</td>";
  1571. // html += "<td>" + TeamTotalCloudPayAmount + "</td>";
  1572. // html += "</tr>";
  1573. // }
  1574. // html += "</table>";
  1575. // db.Dispose();
  1576. // // OtherMySqlConn.connstr = ;
  1577. // function.WritePage("/html/", "1.html", html);
  1578. }
  1579. //统计商户交易额
  1580. private void StatMerchantTrade(string date)
  1581. {
  1582. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
  1583. // WebCMSEntities db = new WebCMSEntities();
  1584. try
  1585. {
  1586. string start = date + " 00:00:00";
  1587. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  1588. OtherMySqlConn.op("insert into PosMerchantTradeSummay (MerchantId,BrandId,TradeDate,TradeMonth,TradeAmount,CreateDate) select *,now() from (select MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d') as TradeDate,DATE_FORMAT(CreateDate,'%Y%m') as TradeMonth,sum(TradeAmount) as TradeAmount from TradeRecord where CreateDate>='" + start + "' and CreateDate<'" + end + "' group by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d'),TradeDate,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d')) tb");
  1589. RedisDbconn.Instance.Clear("PosMerchantAmount:*");
  1590. RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "").Substring(0, 6)); //商户当月交易
  1591. RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "")); //商户当日交易
  1592. // foreach (DataRow selfDr in selfdt.Rows)
  1593. // {
  1594. // int BrandId = int.Parse(selfDr["BrandId"].ToString());
  1595. // int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
  1596. // string TradeDate = selfDr["TradeDate"].ToString();
  1597. // TradeDate = TradeDate.Replace("-", "");
  1598. // string TradeMonth = TradeDate.Substring(0, 6);
  1599. // decimal TradeAmount = decimal.Parse(selfDr["TradeAmount"].ToString());
  1600. // PosMerchantTradeSummay merStat = db.PosMerchantTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId);
  1601. // if (merStat == null)
  1602. // {
  1603. // merStat = db.PosMerchantTradeSummay.Add(new PosMerchantTradeSummay()
  1604. // {
  1605. // MerchantId = MerchantId,
  1606. // TradeMonth = TradeMonth,
  1607. // TradeDate = TradeDate,
  1608. // BrandId = BrandId,
  1609. // }).Entity;
  1610. // db.SaveChanges();
  1611. // }
  1612. // merStat.TradeAmount += TradeAmount;
  1613. // db.SaveChanges();
  1614. // }
  1615. }
  1616. catch (Exception ex)
  1617. {
  1618. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
  1619. }
  1620. // db.Dispose();
  1621. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
  1622. }
  1623. // 5. 创客升级
  1624. public void StatUserLevel()
  1625. {
  1626. Thread th = new Thread(StatUserLevelDo);
  1627. th.IsBackground = true;
  1628. th.Start();
  1629. }
  1630. public void StatUserLevelDo()
  1631. {
  1632. while (true)
  1633. {
  1634. if(DateTime.Now.Day == 1 && DateTime.Now.Hour > 2)
  1635. {
  1636. string Month = DateTime.Now.AddDays(-1).ToString("yyyy-MM");
  1637. string flag = function.ReadInstance("/ProfitFlag/" + Month + ".txt");
  1638. if (string.IsNullOrEmpty(flag))
  1639. {
  1640. function.WritePage("/ProfitFlag/", Month + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  1641. StatUserLevelStart();
  1642. }
  1643. }
  1644. Thread.Sleep(600000);
  1645. }
  1646. }
  1647. public void StatUserLevelStart()
  1648. {
  1649. WebCMSEntities db = new WebCMSEntities();
  1650. try
  1651. {
  1652. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  1653. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  1654. DateTime end = start.AddDays(1);
  1655. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  1656. List<UserLevelSet> sets = db.UserLevelSet.ToList();
  1657. bool op = true;
  1658. int startid = 0;
  1659. while(op)
  1660. {
  1661. var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(50).ToList();
  1662. function.WriteLog(users.Count.ToString(), "创客升级日志");
  1663. if(users.Count > 0)
  1664. {
  1665. foreach (var subuser in users)
  1666. {
  1667. Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
  1668. if (user != null)
  1669. {
  1670. int BeforeLevel = user.UserLevel;
  1671. int AfterLevel = 0;
  1672. decimal TradeAmount = 0;
  1673. bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  1674. if (check)
  1675. {
  1676. TradeAmount = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
  1677. }
  1678. UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
  1679. if (set != null)
  1680. {
  1681. AfterLevel = set.Id;
  1682. }
  1683. if (AfterLevel > BeforeLevel && AfterLevel > 1)
  1684. {
  1685. function.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
  1686. user.UserLevel = AfterLevel;
  1687. db.UserRank.Add(new UserRank()
  1688. {
  1689. CreateDate = DateTime.Now,
  1690. UpdateDate = DateTime.Now,
  1691. UserId = user.Id, //创客
  1692. WhiteRank = BeforeLevel,
  1693. Rank = AfterLevel, //当前等级
  1694. StatYear = DateTime.Now.Year, //统计年份
  1695. StatMonth = DateTime.Now.Month, //统计月份
  1696. TradeAmt = TradeAmount, //团队交易总额
  1697. UpgradeFlag = 1, //升级标识
  1698. OperateDate = DateTime.Now, //操作时间
  1699. });
  1700. db.SaveChanges();
  1701. }
  1702. }
  1703. startid = subuser.Id;
  1704. }
  1705. }
  1706. else
  1707. {
  1708. op = false;
  1709. }
  1710. }
  1711. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  1712. }
  1713. catch (Exception ex)
  1714. {
  1715. function.WriteLog(ex.ToString(), "创客升级异常");
  1716. }
  1717. db.Dispose();
  1718. ProfitHelperV2.Instance.StatProfit(); //统计分润
  1719. }
  1720. public void StatUserLevelStartTest()
  1721. {
  1722. Thread th = new Thread(StatUserLevelStartTestDo);
  1723. th.IsBackground = true;
  1724. th.Start();
  1725. }
  1726. public void StatUserLevelStartTestDo()
  1727. {
  1728. WebCMSEntities db = new WebCMSEntities();
  1729. try
  1730. {
  1731. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  1732. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  1733. DateTime end = start.AddDays(1);
  1734. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  1735. List<UserLevelSet> sets = db.UserLevelSet.ToList();
  1736. List<int> uids = new List<int>();
  1737. uids.Add(6341);
  1738. foreach (int uid in uids)
  1739. {
  1740. Users user = db.Users.FirstOrDefault(m => m.Id == uid);
  1741. if (user != null)
  1742. {
  1743. int BeforeLevel = user.UserLevel;
  1744. int AfterLevel = 0;
  1745. decimal TradeAmount = 0;
  1746. bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  1747. if (check)
  1748. {
  1749. TradeAmount = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
  1750. }
  1751. function.WriteLog(user.Id.ToString() + "----" + TradeAmount, "创客升级业绩");
  1752. UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
  1753. if (set != null)
  1754. {
  1755. AfterLevel = set.Id;
  1756. }
  1757. function.WriteLog("update Users set UserLevel=" + AfterLevel + " where Id=" + user.Id.ToString() + ";", "创客升级日志");
  1758. }
  1759. }
  1760. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  1761. }
  1762. catch (Exception ex)
  1763. {
  1764. function.WriteLog(ex.ToString(), "创客升级异常");
  1765. }
  1766. db.Dispose();
  1767. }
  1768. // 统计创客激活数
  1769. public void StartPosActNum()
  1770. {
  1771. Thread th = new Thread(StartPosActNumFor);
  1772. th.IsBackground = true;
  1773. th.Start();
  1774. }
  1775. public void StartPosActNumFor()
  1776. {
  1777. // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
  1778. // DateTime check = DateTime.Parse("2022-06-14");
  1779. // while (check <= end)
  1780. // {
  1781. // StartPosActNumDo(check.ToString("yyyy-MM-dd"));
  1782. // check = check.AddDays(1);
  1783. // }
  1784. while (true)
  1785. {
  1786. if(DateTime.Now.Hour >= 2)
  1787. {
  1788. StartPosActNumEverTime();
  1789. }
  1790. Thread.Sleep(100);
  1791. }
  1792. }
  1793. public void StartPosActNumDo(object sender)
  1794. {
  1795. string date = sender.ToString();
  1796. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志");
  1797. WebCMSEntities db = new WebCMSEntities();
  1798. try
  1799. {
  1800. string TradeDate = date.Replace("-", "");
  1801. string TradeMonth = TradeDate.Substring(0, 6);
  1802. string start = date + " 00:00:00";
  1803. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  1804. List<string> uids = new List<string>();
  1805. DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT BuyUserId from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "')");
  1806. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志");
  1807. foreach (DataRow userDr in userDt.Rows)
  1808. {
  1809. int UserId = int.Parse(userDr["Id"].ToString());
  1810. string ParentNav = userDr["ParentNav"].ToString();
  1811. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  1812. DataTable selfdt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId=" + UserId + " group by BrandId");
  1813. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  1814. foreach (DataRow selfDr in selfdt.Rows)
  1815. {
  1816. int BrandId = int.Parse(selfDr["BrandId"].ToString());
  1817. int QrPayFlag = 0;
  1818. int ActCount = int.Parse(selfDr[1].ToString());
  1819. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  1820. if (selfStat == null)
  1821. {
  1822. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1823. {
  1824. UserId = UserId,
  1825. TradeMonth = TradeMonth,
  1826. TradeDate = TradeDate,
  1827. BrandId = BrandId,
  1828. QueryCount = QrPayFlag,
  1829. SeoTitle = "self",
  1830. }).Entity;
  1831. db.SaveChanges();
  1832. }
  1833. selfStat.DirectDebitCapNum += ActCount;
  1834. db.SaveChanges();
  1835. }
  1836. if (!string.IsNullOrEmpty(ParentNav))
  1837. {
  1838. ParentNav += "," + UserId + ",";
  1839. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1840. foreach (string NavUserIdString in ParentNavList)
  1841. {
  1842. if (!uids.Contains(NavUserIdString + start))
  1843. {
  1844. uids.Add(NavUserIdString + start);
  1845. int NavUserId = int.Parse(NavUserIdString);
  1846. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  1847. DataTable teamDt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId");
  1848. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  1849. foreach (DataRow teamDr in teamDt.Rows)
  1850. {
  1851. int BrandId = int.Parse(teamDr["BrandId"].ToString());
  1852. int QrPayFlag = 0;
  1853. int ActCount = int.Parse(teamDr[1].ToString());
  1854. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  1855. if (teamStat == null)
  1856. {
  1857. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1858. {
  1859. UserId = NavUserId,
  1860. TradeMonth = TradeMonth,
  1861. TradeDate = TradeDate,
  1862. BrandId = BrandId,
  1863. QueryCount = QrPayFlag,
  1864. SeoTitle = "team",
  1865. }).Entity;
  1866. db.SaveChanges();
  1867. }
  1868. teamStat.NonDirectDebitCapNum += ActCount;
  1869. db.SaveChanges();
  1870. }
  1871. }
  1872. }
  1873. }
  1874. }
  1875. OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "'");
  1876. }
  1877. catch (Exception ex)
  1878. {
  1879. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常");
  1880. }
  1881. db.Dispose();
  1882. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  1883. Thread.Sleep(60000);
  1884. }
  1885. public void StartPosActNumEverTime()
  1886. {
  1887. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  1888. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
  1889. WebCMSEntities db = new WebCMSEntities();
  1890. try
  1891. {
  1892. DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and BuyUserId>0 limit 50");
  1893. if(idsDt.Rows.Count > 0)
  1894. {
  1895. string ids = "";
  1896. foreach (DataRow idsDr in idsDt.Rows)
  1897. {
  1898. ids += idsDr["Id"].ToString() + ",";
  1899. }
  1900. DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')");
  1901. if (userDt.Rows.Count > 0)
  1902. {
  1903. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
  1904. foreach (DataRow userDr in userDt.Rows)
  1905. {
  1906. int UserId = int.Parse(userDr["BuyUserId"].ToString());
  1907. int BrandId = int.Parse(userDr["BrandId"].ToString());
  1908. string TradeDate = userDr[2].ToString();
  1909. int ActCount = int.Parse(function.CheckInt(userDr[3].ToString()));
  1910. int QrPayFlag = 0;
  1911. string TradeMonth = TradeDate.Substring(0, 6);
  1912. string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
  1913. string start = date + " 00:00:00";
  1914. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  1915. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1916. string ParentNav = user.ParentNav;
  1917. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  1918. if (selfStat == null)
  1919. {
  1920. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1921. {
  1922. UserId = UserId,
  1923. TradeMonth = TradeMonth,
  1924. TradeDate = TradeDate,
  1925. BrandId = BrandId,
  1926. QueryCount = QrPayFlag,
  1927. SeoTitle = "self",
  1928. }).Entity;
  1929. db.SaveChanges();
  1930. }
  1931. selfStat.DirectDebitCapNum += ActCount;
  1932. ParentNav += "," + UserId + ",";
  1933. if (!string.IsNullOrEmpty(ParentNav))
  1934. {
  1935. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1936. foreach (string NavUserIdString in ParentNavList)
  1937. {
  1938. int NavUserId = int.Parse(NavUserIdString);
  1939. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  1940. if (teamStat == null)
  1941. {
  1942. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1943. {
  1944. UserId = NavUserId,
  1945. TradeMonth = TradeMonth,
  1946. TradeDate = TradeDate,
  1947. BrandId = BrandId,
  1948. QueryCount = QrPayFlag,
  1949. SeoTitle = "team",
  1950. }).Entity;
  1951. db.SaveChanges();
  1952. }
  1953. teamStat.NonDirectDebitCapNum += ActCount;
  1954. }
  1955. }
  1956. }
  1957. db.SaveChanges();
  1958. OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  1959. }
  1960. }
  1961. }
  1962. catch (Exception ex)
  1963. {
  1964. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
  1965. }
  1966. db.Dispose();
  1967. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志");
  1968. }
  1969. // 统计新增创客数
  1970. public void StartNewUserNum()
  1971. {
  1972. Thread th = new Thread(StartNewUserNumFor);
  1973. th.IsBackground = true;
  1974. th.Start();
  1975. }
  1976. public void StartNewUserNumFor()
  1977. {
  1978. // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
  1979. // DateTime check = DateTime.Parse("2022-06-14");
  1980. // while (check <= end)
  1981. // {
  1982. // StartNewUserNumDo(check.ToString("yyyy-MM-dd"));
  1983. // check = check.AddDays(1);
  1984. // }
  1985. while (true)
  1986. {
  1987. if(DateTime.Now.Hour >= 2)
  1988. {
  1989. StartNewUserNumEverTime();
  1990. }
  1991. Thread.Sleep(120000);
  1992. }
  1993. }
  1994. public void StartNewUserNumDo(object sender)
  1995. {
  1996. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  1997. string date = sender.ToString();
  1998. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
  1999. WebCMSEntities db = new WebCMSEntities();
  2000. try
  2001. {
  2002. string StatDate = date.Replace("-", "");
  2003. string StatMonth = StatDate.Substring(0, 6);
  2004. string start = date + " 00:00:00";
  2005. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2006. List<string> uids = new List<string>();
  2007. DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
  2008. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志");
  2009. foreach (DataRow userDr in userDt.Rows)
  2010. {
  2011. int UserId = int.Parse(userDr["Id"].ToString());
  2012. string ParentNav = userDr["ParentNav"].ToString();
  2013. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2014. DataTable selfdt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentUserId=" + UserId + "");
  2015. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2016. foreach (DataRow selfDr in selfdt.Rows)
  2017. {
  2018. int AddCount = int.Parse(selfDr[0].ToString());
  2019. PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
  2020. if (selfStat == null)
  2021. {
  2022. selfStat = db.PullnewSummary.Add(new PullnewSummary()
  2023. {
  2024. UserId = UserId,
  2025. StatMonth = StatMonth,
  2026. StatDate = StatDate,
  2027. SeoTitle = "self",
  2028. }).Entity;
  2029. db.SaveChanges();
  2030. }
  2031. selfStat.RecUserAuthNum += AddCount;
  2032. db.SaveChanges();
  2033. }
  2034. if (!string.IsNullOrEmpty(ParentNav))
  2035. {
  2036. ParentNav += "," + UserId + ",";
  2037. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2038. foreach (string NavUserIdString in ParentNavList)
  2039. {
  2040. if (!uids.Contains(NavUserIdString + start))
  2041. {
  2042. uids.Add(NavUserIdString + start);
  2043. int NavUserId = int.Parse(NavUserIdString);
  2044. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2045. DataTable teamDt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentNav like '%," + NavUserId + ",%'");
  2046. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2047. foreach (DataRow teamDr in teamDt.Rows)
  2048. {
  2049. int AddCount = int.Parse(teamDr[0].ToString());
  2050. PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
  2051. if (teamStat == null)
  2052. {
  2053. teamStat = db.PullnewSummary.Add(new PullnewSummary()
  2054. {
  2055. UserId = NavUserId,
  2056. StatMonth = StatMonth,
  2057. StatDate = StatDate,
  2058. SeoTitle = "team",
  2059. }).Entity;
  2060. db.SaveChanges();
  2061. }
  2062. teamStat.RecUserAuthNum += AddCount;
  2063. db.SaveChanges();
  2064. }
  2065. }
  2066. }
  2067. }
  2068. }
  2069. OtherMySqlConn.op("update Users set QueryCount=1 where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
  2070. }
  2071. catch (Exception ex)
  2072. {
  2073. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常");
  2074. }
  2075. db.Dispose();
  2076. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2077. Thread.Sleep(60000);
  2078. }
  2079. public void StartNewUserNumEverTime()
  2080. {
  2081. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2082. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
  2083. WebCMSEntities db = new WebCMSEntities();
  2084. try
  2085. {
  2086. DataTable idsDt = OtherMySqlConn.dtable("select Id from Users where QueryCount=0 and AuthFlag=1 and AuthDate is not null limit 50");
  2087. if(idsDt.Rows.Count > 0)
  2088. {
  2089. string ids = "";
  2090. foreach (DataRow idsDr in idsDt.Rows)
  2091. {
  2092. ids += idsDr["Id"].ToString() + ",";
  2093. }
  2094. DataTable userDt = OtherMySqlConn.dtable("select ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d'),count(Id) from Users where Id in (" + ids.TrimEnd(',') + ") group by ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d')");
  2095. if(userDt.Rows.Count > 0)
  2096. {
  2097. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志");
  2098. foreach (DataRow userDr in userDt.Rows)
  2099. {
  2100. string StatDate = userDr[1].ToString();
  2101. int UserId = int.Parse(userDr["ParentUserId"].ToString());
  2102. string StatMonth = StatDate.Substring(0, 6);
  2103. string date = StatDate.Substring(0, 4) + "-" + StatDate.Substring(4, 2) + "-" + StatDate.Substring(6, 2);
  2104. string start = date + " 00:00:00";
  2105. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2106. int AddCount = int.Parse(userDr[2].ToString());
  2107. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  2108. string ParentNav = user.ParentNav;
  2109. PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
  2110. if (selfStat == null)
  2111. {
  2112. selfStat = db.PullnewSummary.Add(new PullnewSummary()
  2113. {
  2114. UserId = UserId,
  2115. StatMonth = StatMonth,
  2116. StatDate = StatDate,
  2117. SeoTitle = "self",
  2118. }).Entity;
  2119. db.SaveChanges();
  2120. }
  2121. selfStat.RecUserAuthNum += AddCount;
  2122. ParentNav += "," + UserId + ",";
  2123. if (!string.IsNullOrEmpty(ParentNav))
  2124. {
  2125. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2126. foreach (string NavUserIdString in ParentNavList)
  2127. {
  2128. int NavUserId = int.Parse(NavUserIdString);
  2129. PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
  2130. if (teamStat == null)
  2131. {
  2132. teamStat = db.PullnewSummary.Add(new PullnewSummary()
  2133. {
  2134. UserId = NavUserId,
  2135. StatMonth = StatMonth,
  2136. StatDate = StatDate,
  2137. SeoTitle = "team",
  2138. }).Entity;
  2139. db.SaveChanges();
  2140. }
  2141. teamStat.RecUserAuthNum += AddCount;
  2142. }
  2143. }
  2144. }
  2145. db.SaveChanges();
  2146. OtherMySqlConn.op("update Users set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  2147. }
  2148. }
  2149. }
  2150. catch (Exception ex)
  2151. {
  2152. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常");
  2153. }
  2154. db.Dispose();
  2155. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志");
  2156. }
  2157. // 每天统计头一天的收益
  2158. public void StatProfit()
  2159. {
  2160. Thread th = new Thread(StatProfitDo);
  2161. th.IsBackground = true;
  2162. th.Start();
  2163. }
  2164. public void StatProfitDo()
  2165. {
  2166. // DateTime end = DateTime.Parse("2022-06-16 00:00:00");
  2167. // DateTime check = DateTime.Parse("2022-06-16");
  2168. // while (check <= end)
  2169. // {
  2170. // StatProfitEverDay(check.ToString("yyyy-MM-dd"));
  2171. // Thread.Sleep(1000);
  2172. // check = check.AddDays(1);
  2173. // }
  2174. while (true)
  2175. {
  2176. if(DateTime.Now.Hour >= 2)
  2177. {
  2178. StatProfitEverDayEverTime();
  2179. }
  2180. Thread.Sleep(120000);
  2181. }
  2182. }
  2183. public void StatProfitEverDay(object sender)
  2184. {
  2185. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2186. string date = sender.ToString();
  2187. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
  2188. WebCMSEntities db = new WebCMSEntities();
  2189. try
  2190. {
  2191. string TradeDate = date.Replace("-", "");
  2192. string TradeMonth = TradeDate.Substring(0, 6);
  2193. string start = date + " 00:00:00";
  2194. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2195. string startId = "0";
  2196. List<string> uids = new List<string>();
  2197. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from UserAccountRecord where CreateDate>='" + start + "'");
  2198. if (startDt.Rows.Count > 0)
  2199. {
  2200. startId = startDt.Rows[0][0].ToString();
  2201. }
  2202. function.WriteLog(startId + "\n\n", "执行昨天收益日志");
  2203. DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')");
  2204. function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志");
  2205. foreach (DataRow userDr in userDt.Rows)
  2206. {
  2207. int UserId = int.Parse(userDr["Id"].ToString());
  2208. string ParentNav = userDr["ParentNav"].ToString();
  2209. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2210. DataTable selfdt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by ChangeType,ProductType");
  2211. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2212. foreach (DataRow selfDr in selfdt.Rows)
  2213. {
  2214. int ChangeType = int.Parse(selfDr["ChangeType"].ToString());
  2215. int ProductType = int.Parse(selfDr["ProductType"].ToString());
  2216. decimal ProfitAmount = decimal.Parse(selfDr[2].ToString());
  2217. UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
  2218. if (selfStat == null)
  2219. {
  2220. selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
  2221. {
  2222. UserId = UserId,
  2223. TradeMonth = TradeMonth,
  2224. TradeDate = TradeDate,
  2225. RebateType = ChangeType,
  2226. ProductType = ProductType,
  2227. SeoTitle = "self",
  2228. }).Entity;
  2229. db.SaveChanges();
  2230. }
  2231. selfStat.CreditRewardAmount += ProfitAmount;
  2232. db.SaveChanges();
  2233. }
  2234. if (!string.IsNullOrEmpty(ParentNav))
  2235. {
  2236. ParentNav += "," + UserId + ",";
  2237. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2238. foreach (string NavUserIdString in ParentNavList)
  2239. {
  2240. if (!uids.Contains(NavUserIdString + start))
  2241. {
  2242. uids.Add(NavUserIdString + start);
  2243. int NavUserId = int.Parse(NavUserIdString);
  2244. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2245. DataTable teamDt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by ChangeType,ProductType");
  2246. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2247. foreach (DataRow teamDr in teamDt.Rows)
  2248. {
  2249. int ChangeType = int.Parse(teamDr["ChangeType"].ToString());
  2250. int ProductType = int.Parse(teamDr["ProductType"].ToString());
  2251. decimal ProfitAmount = decimal.Parse(teamDr[2].ToString());
  2252. UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
  2253. if (teamStat == null)
  2254. {
  2255. teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
  2256. {
  2257. UserId = NavUserId,
  2258. TradeMonth = TradeMonth,
  2259. TradeDate = TradeDate,
  2260. RebateType = ChangeType,
  2261. ProductType = ProductType,
  2262. SeoTitle = "team",
  2263. }).Entity;
  2264. db.SaveChanges();
  2265. }
  2266. teamStat.CreditRewardAmount += ProfitAmount;
  2267. db.SaveChanges();
  2268. }
  2269. }
  2270. }
  2271. }
  2272. }
  2273. }
  2274. catch (Exception ex)
  2275. {
  2276. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常");
  2277. }
  2278. db.Dispose();
  2279. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2280. }
  2281. public void StatProfitEverDayEverTime()
  2282. {
  2283. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2284. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
  2285. WebCMSEntities db = new WebCMSEntities();
  2286. try
  2287. {
  2288. string startId = function.ReadInstance("/UserAccountRecord/Id.txt");
  2289. if(string.IsNullOrEmpty(startId))
  2290. {
  2291. startId = "160653";
  2292. }
  2293. DataTable idsDt = OtherMySqlConn.dtable("select Id from UserAccountRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
  2294. if(idsDt.Rows.Count > 0)
  2295. {
  2296. string ids = "";
  2297. foreach (DataRow idsDr in idsDt.Rows)
  2298. {
  2299. ids += idsDr["Id"].ToString() + ",";
  2300. startId = idsDr["Id"].ToString();
  2301. }
  2302. DataTable userDt = OtherMySqlConn.dtable("select UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d'),sum(ChangeAmount) from UserAccountRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d')");
  2303. if (userDt.Rows.Count > 0)
  2304. {
  2305. function.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志");
  2306. foreach (DataRow userDr in userDt.Rows)
  2307. {
  2308. int UserId = int.Parse(userDr["UserId"].ToString());
  2309. int ChangeType = int.Parse(userDr["ChangeType"].ToString());
  2310. int ProductType = int.Parse(userDr["ProductType"].ToString());
  2311. string TradeDate = userDr[3].ToString();
  2312. decimal ProfitAmount = decimal.Parse(userDr[4].ToString());
  2313. string TradeMonth = TradeDate.Substring(0, 6);
  2314. string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
  2315. string start = date + " 00:00:00";
  2316. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2317. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  2318. string ParentNav = user.ParentNav;
  2319. UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
  2320. if (selfStat == null)
  2321. {
  2322. selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
  2323. {
  2324. UserId = UserId,
  2325. TradeMonth = TradeMonth,
  2326. TradeDate = TradeDate,
  2327. RebateType = ChangeType,
  2328. ProductType = ProductType,
  2329. SeoTitle = "self",
  2330. }).Entity;
  2331. db.SaveChanges();
  2332. }
  2333. selfStat.CreditRewardAmount += ProfitAmount;
  2334. ParentNav += "," + UserId + ",";
  2335. if (!string.IsNullOrEmpty(ParentNav))
  2336. {
  2337. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2338. foreach (string NavUserIdString in ParentNavList)
  2339. {
  2340. int NavUserId = int.Parse(NavUserIdString);
  2341. UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
  2342. if (teamStat == null)
  2343. {
  2344. teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
  2345. {
  2346. UserId = NavUserId,
  2347. TradeMonth = TradeMonth,
  2348. TradeDate = TradeDate,
  2349. RebateType = ChangeType,
  2350. ProductType = ProductType,
  2351. SeoTitle = "team",
  2352. }).Entity;
  2353. db.SaveChanges();
  2354. }
  2355. teamStat.CreditRewardAmount += ProfitAmount;
  2356. }
  2357. }
  2358. }
  2359. db.SaveChanges();
  2360. OtherMySqlConn.op("update UserAccountRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  2361. function.WritePage("/UserAccountRecord/", "Id.txt", startId);
  2362. }
  2363. }
  2364. }
  2365. catch (Exception ex)
  2366. {
  2367. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常");
  2368. }
  2369. db.Dispose();
  2370. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志");
  2371. }
  2372. // 实时统计我的创客交易额
  2373. public void StatMyUserThisTrade()
  2374. {
  2375. Thread th = new Thread(StatMyUserThisTradeDo);
  2376. th.IsBackground = true;
  2377. th.Start();
  2378. }
  2379. public void StatMyUserThisTradeDo()
  2380. {
  2381. while (true)
  2382. {
  2383. if(DateTime.Now.Hour > 3)
  2384. {
  2385. StatMyUserThisTradeListen();
  2386. }
  2387. int timespan = 1000 * 3600 * 3;
  2388. Thread.Sleep(timespan);
  2389. }
  2390. }
  2391. public void StatMyUserThisTradeListen()
  2392. {
  2393. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2394. string TradeMonth = DateTime.Now.ToString("yyyyMM");
  2395. // if(DateTime.Now.Day == 1)
  2396. // {
  2397. // TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  2398. // }
  2399. DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
  2400. string sql = "";
  2401. foreach (DataRow dr in list.Rows)
  2402. {
  2403. string UserId = dr["UserId"].ToString();
  2404. string ThisMonthTrade = dr[1].ToString();
  2405. sql += "update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId + ";";
  2406. }
  2407. if(!string.IsNullOrEmpty(sql))
  2408. {
  2409. OtherMySqlConn.op(sql);
  2410. }
  2411. }
  2412. #region 判断品牌互斥条件,根据身份证号
  2413. public bool CheckRepeatByBrand(WebCMSEntities db, int MerchantId)
  2414. {
  2415. int check = db.PosMachinesTwo.Count(m => m.Status > -1 && m.BindMerchantId == MerchantId);
  2416. return false;
  2417. }
  2418. #endregion
  2419. }
  2420. }