StatService.cs 196 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410
  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()
  17. {
  18. Thread th = new Thread(StartDo);
  19. th.IsBackground = true;
  20. th.Start();
  21. }
  22. public void StartDo()
  23. {
  24. while(true)
  25. {
  26. try
  27. {
  28. if(DateTime.Now.Hour > 0 && DateTime.Now.Hour < 9)
  29. {
  30. string doDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
  31. string flag = function.ReadInstance("/Stat/" + doDate + ".txt");
  32. if (string.IsNullOrEmpty(flag))
  33. {
  34. function.WritePage("/Stat/", doDate + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  35. StartEverDay();
  36. StatMerchantTrade(doDate);
  37. }
  38. }
  39. }
  40. catch (Exception ex)
  41. {
  42. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天同步创客上级关联异常");
  43. }
  44. Thread.Sleep(1800000);
  45. }
  46. }
  47. public void StartActiveReward()
  48. {
  49. Thread th = new Thread(ActiveReward);
  50. th.IsBackground = true;
  51. th.Start();
  52. }
  53. public void ActiveReward()
  54. {
  55. while(true)
  56. {
  57. try
  58. {
  59. function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理激活奖励");
  60. dosomething3();
  61. function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理激活奖励");
  62. }
  63. catch (Exception ex)
  64. {
  65. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理激活奖励异常");
  66. }
  67. Thread.Sleep(30000);
  68. }
  69. }
  70. public void StartActiveReward1()
  71. {
  72. Thread th = new Thread(ActiveReward1);
  73. th.IsBackground = true;
  74. th.Start();
  75. }
  76. public void ActiveReward1()
  77. {
  78. while(true)
  79. {
  80. try
  81. {
  82. function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励");
  83. activePrizeWithoutDeposit();
  84. function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理0押激活奖励");
  85. }
  86. catch (Exception ex)
  87. {
  88. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理0押激活奖励异常");
  89. }
  90. Thread.Sleep(30000);
  91. }
  92. }
  93. public void StartActiveReward2()
  94. {
  95. Thread th = new Thread(ActiveReward2);
  96. th.IsBackground = true;
  97. th.Start();
  98. }
  99. public void ActiveReward2()
  100. {
  101. while(true)
  102. {
  103. try
  104. {
  105. function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励");
  106. activePrizeWithoutDeposit12();
  107. function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理盒易付0押激活奖励");
  108. }
  109. catch (Exception ex)
  110. {
  111. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理盒易付0押激活奖励异常");
  112. }
  113. Thread.Sleep(30000);
  114. }
  115. }
  116. public void StartActiveReward15()
  117. {
  118. Thread th = new Thread(ActiveReward15);
  119. th.IsBackground = true;
  120. th.Start();
  121. }
  122. public void ActiveReward15()
  123. {
  124. while(true)
  125. {
  126. try
  127. {
  128. function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理来客吧0押激活奖励");
  129. activePrizeWithoutDeposit15();
  130. function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理来客吧0押激活奖励");
  131. }
  132. catch (Exception ex)
  133. {
  134. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理来客吧0押激活奖励异常");
  135. }
  136. Thread.Sleep(30000);
  137. }
  138. }
  139. //广电卡激活奖励
  140. public void StartSimActive()
  141. {
  142. Thread th = new Thread(StartSimActiveListen);
  143. th.IsBackground = true;
  144. th.Start();
  145. }
  146. public void StartSimActiveListen()
  147. {
  148. while(true)
  149. {
  150. try
  151. {
  152. function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理广电卡激活奖励");
  153. StartSimActiveDo();
  154. function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理广电卡激活奖励");
  155. }
  156. catch (Exception ex)
  157. {
  158. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理广电卡激活奖励异常");
  159. }
  160. Thread.Sleep(29000);
  161. }
  162. }
  163. public void StartSimActiveDo(int posid = 0)
  164. {
  165. WebCMSEntities db = new WebCMSEntities();
  166. DateTime yesterday = DateTime.Now.AddDays(-30);
  167. DateTime today = DateTime.Now.AddMinutes(-5);
  168. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.BrandId == 14 && m.CardType > 0 && m.Detail != "1");
  169. if (posid > 0)
  170. {
  171. posList = posList.Where(m => m.Id == posid);
  172. }
  173. else
  174. {
  175. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  176. }
  177. foreach (PosMachinesTwo pos in posList.ToList())
  178. {
  179. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  180. if (merchant != null)
  181. {
  182. string ParentNav = "";
  183. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  184. if (user != null)
  185. {
  186. int GetUserId = user.Id;
  187. ParentNav = user.ParentNav;
  188. int TopUserId = 0;
  189. if (!string.IsNullOrEmpty(ParentNav))
  190. {
  191. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  192. }
  193. decimal Amount = 19 * 1.5M;
  194. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, Amount);
  195. PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  196. if(item != null)
  197. {
  198. item.Detail = "1";
  199. db.SaveChanges();
  200. }
  201. }
  202. }
  203. }
  204. db.Dispose();
  205. }
  206. // 1. 前一天的绑定记录和创客信息匹配,设置商户型创客
  207. public void dosomething1(string date)
  208. {
  209. // TODO: 每天扫描非商户型创客的持有机具数量
  210. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  211. WebCMSEntities db = new WebCMSEntities();
  212. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  213. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  214. List<SpModels.BindRecord> binds = spdb.BindRecord.Where(m => m.CreateTime >= yesterday && m.CreateTime < today).ToList();
  215. foreach (SpModels.BindRecord bind in binds)
  216. {
  217. string Mobile = bind.MerNewSnNo;
  218. string MerNo = bind.MerNo;
  219. string BeforeNum = "";
  220. string AfterNum = "";
  221. if (Mobile.Contains("****") && Mobile.Length == 11)
  222. {
  223. BeforeNum = Mobile.Substring(0, 3);
  224. AfterNum = Mobile.Substring(7);
  225. }
  226. string Name = bind.MerName;
  227. if (bind.ProductType == "2")
  228. {
  229. if (Name.Contains("-"))
  230. {
  231. Name = Name.Split('-')[1];
  232. }
  233. else if (Name.Contains("_"))
  234. {
  235. Name = Name.Split('_')[1];
  236. }
  237. }
  238. else if (bind.ProductType == "4")
  239. {
  240. Name = bind.SeoTitle;
  241. }
  242. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0);
  243. if (user != null)
  244. {
  245. bool checkPos = db.PosMachinesTwo.Any(m => m.UserId == user.Id);
  246. if (!checkPos)
  247. {
  248. PxcModels.MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == bind.MerSnNo) ?? new PxcModels.MachineForSnNo();
  249. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId && m.UserId != user.Id);
  250. if (pos != null)
  251. {
  252. pos.UserId = user.Id;
  253. user.MerchantType = 1;
  254. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PxcModels.PosMerchantInfo();
  255. merchant.UserId = user.Id;
  256. merchant.MerUserType = 1;
  257. pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
  258. db.SaveChanges();
  259. }
  260. }
  261. }
  262. }
  263. spdb.Dispose();
  264. db.Dispose();
  265. }
  266. // 1. 前一天的商户型创客,判断名下是否3台激活机器,是则变为非商户型创客
  267. public void dosomething11(string date)
  268. {
  269. WebCMSEntities db = new WebCMSEntities();
  270. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  271. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  272. var users = db.Users.Select(m => new { m.Id, m.MerchantType }).Where(m => m.MerchantType == 1).ToList();
  273. foreach (var user in users)
  274. {
  275. int machineCount = db.PosMachinesTwo.Count(m => m.UserId == user.Id && m.PosSnType == 0);
  276. int couponCount = db.PosCoupons.Count(m => m.UserId == user.Id && m.IsUse == 0); //判断是否拥有3张券
  277. if (machineCount + couponCount >= 3)
  278. {
  279. Users edit = db.Users.FirstOrDefault(m => m.Id == user.Id);
  280. if (edit != null)
  281. {
  282. edit.MerchantType = 0;
  283. db.SaveChanges();
  284. }
  285. }
  286. }
  287. db.Dispose();
  288. }
  289. public void testStatTrade(string date)
  290. {
  291. string yesterday = date + " 00:00:00";
  292. string today = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  293. string TradeMonth = DateTime.Parse(date).ToString("yyyyMM");
  294. string TradeDate = DateTime.Parse(date).ToString("yyyyMMdd");
  295. 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");
  296. foreach (DataRow dr in dt.Rows)
  297. {
  298. int UserId = int.Parse(dr["UserId"].ToString()); //创客ID
  299. int BrandId = int.Parse(dr["BrandId"].ToString()); //品牌
  300. int MerchantId = int.Parse(dr["MerchantId"].ToString()); //商户Id
  301. int BankCardType = int.Parse(dr["BankCardType"].ToString()); //卡类型
  302. int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString()); //云闪付
  303. decimal TradeAmount = decimal.Parse(dr[5].ToString()); //当日交易额
  304. string content = "{";
  305. content += "\"DateString\":\"" + date + "\",";
  306. content += "\"UserId\":\"" + UserId + "\",";
  307. content += "\"BrandId\":\"" + BrandId + "\",";
  308. content += "\"MerchantId\":\"" + MerchantId + "\",";
  309. content += "\"BankCardType\":\"" + BankCardType + "\",";
  310. content += "\"QrPayFlag\":\"" + QrPayFlag + "\",";
  311. content += "\"TradeAmount\":\"" + TradeAmount + "\"";
  312. content += "}";
  313. RedisDbconn.Instance.AddList("TradeStatQueueTest", content);
  314. }
  315. }
  316. // 3. 前一天的激活记录,根据创客类型,如果是商户型创客,则激活奖励的起始人从此人上级计算。如果不是,则从此人开始计算
  317. public void dosomething3(int posid = 0)
  318. {
  319. List<int> BrandIds = new List<int>();
  320. BrandIds.Add(14);
  321. BrandIds.Add(18);
  322. BrandIds.Add(19);
  323. BrandIds.Add(20);
  324. BrandIds.Add(21);
  325. WebCMSEntities db = new WebCMSEntities();
  326. DateTime yesterday = DateTime.Now.AddDays(-1);
  327. DateTime today = DateTime.Now.AddMinutes(-10);
  328. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "" && m.SeoKeyword != "0" && m.Detail != "1" && !BrandIds.Contains(m.BrandId));
  329. if (posid > 0)
  330. {
  331. posList = posList.Where(m => m.Id == posid);
  332. }
  333. else
  334. {
  335. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  336. }
  337. foreach (PosMachinesTwo pos in posList.ToList())
  338. {
  339. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  340. if (merchant != null && pos.ActivationTime.Value <= pos.BindingTime.Value.AddDays(30))
  341. {
  342. function.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理激活奖励");
  343. string ParentNav = "";
  344. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  345. if (user != null)
  346. {
  347. int GetUserId = user.Id;
  348. ParentNav = user.ParentNav;
  349. int TopUserId = 0;
  350. if (!string.IsNullOrEmpty(ParentNav))
  351. {
  352. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  353. }
  354. decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  355. KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new KqProducts();
  356. if (brand.NoticeMoneyUnit == 2)
  357. {
  358. ActPrize = ActPrize / 100;
  359. }
  360. if (ActPrize > 0)
  361. {
  362. // if (ActPrize == 99)
  363. // {
  364. // ActPrize = 100;
  365. // }
  366. // else if (ActPrize == 199)
  367. // {
  368. // ActPrize = 200;
  369. // }
  370. // else if (ActPrize == 299)
  371. // {
  372. // ActPrize = 300;
  373. // }
  374. // else if (ActPrize == 249)
  375. // {
  376. // ActPrize = 260;
  377. // }
  378. ActPrize = 100;
  379. if (GetUserId > 0)
  380. {
  381. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize);
  382. function.WriteLog("ActPrize:" + ActPrize + "", "实时处理激活奖励");
  383. }
  384. }
  385. else if(ActPrize == 0)
  386. {
  387. if(pos.BrandId == 6)
  388. {
  389. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
  390. function.WriteLog("ActPrize:50", "实时处理激活奖励");
  391. }
  392. }
  393. PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  394. if(edit != null)
  395. {
  396. edit.Detail = "1";
  397. db.SaveChanges();
  398. }
  399. }
  400. // }
  401. }
  402. }
  403. db.Dispose();
  404. }
  405. //金控活动机返奖励
  406. private void doJk30(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, int GetUserId, string ParentNav, int TopUserId)
  407. {
  408. // DateTime start = DateTime.Parse("2022-04-06 00:00:00");
  409. // DateTime end = DateTime.Parse("2022-07-05 00:00:00");
  410. // if((pos.BrandId == 1 || pos.BrandId == 3) && pos.CreateDate >= start && pos.CreateDate < end)
  411. // {
  412. // decimal amt = 0;
  413. // if(DateTime.Now < DateTime.Parse("2023-05-01 00:00:00"))
  414. // {
  415. // amt = 10;
  416. // }
  417. // if(amt > 0)
  418. // {
  419. // doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, amt, 0, 1);
  420. // }
  421. // }
  422. }
  423. //无押金激活奖励
  424. public void activePrizeWithoutDeposit(int posid = 0)
  425. {
  426. WebCMSEntities db = new WebCMSEntities();
  427. DateTime yesterday = DateTime.Now.AddDays(-31);
  428. DateTime today = DateTime.Now.AddMinutes(-10);
  429. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && (string.IsNullOrEmpty(m.SeoKeyword) || m.SeoKeyword == "0") && m.CreditTrade >= 5000 && m.BrandId != 12 && m.BrandId != 13 && m.BrandId != 14 && m.BrandId != 15 && m.BrandId != 16 && m.Detail != "1");
  430. if (posid > 0)
  431. {
  432. posList = posList.Where(m => m.Id == posid);
  433. }
  434. else
  435. {
  436. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  437. }
  438. foreach (PosMachinesTwo pos in posList.ToList())
  439. {
  440. function.WriteLog(str: "机具号:" + pos.PosSn, "无押金激活奖励日志");
  441. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  442. if (merchant != null)
  443. {
  444. function.WriteLog("商户号:" + merchant.KqMerNo, "无押金激活奖励日志");
  445. string ParentNav = "";
  446. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  447. if (user != null)
  448. {
  449. function.WriteLog("机具所属人:" + user.Id, "无押金激活奖励日志");
  450. int GetUserId = user.Id;
  451. ParentNav = user.ParentNav;
  452. int TopUserId = 0;
  453. if (!string.IsNullOrEmpty(ParentNav))
  454. {
  455. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  456. }
  457. function.WriteLog("BindingTime:" + pos.BindingTime, "无押金激活奖励日志");
  458. function.WriteLog("ActivationTime:" + pos.ActivationTime, "无押金激活奖励日志");
  459. if(pos.BindingTime.Value.AddDays(30) >= pos.ActivationTime)
  460. {
  461. function.WriteLog("满足条件", "无押金激活奖励日志");
  462. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 30);
  463. function.WriteLog("已发放", "无押金激活奖励日志");
  464. DateTime now = pos.ActivationTime.Value;
  465. //盟主奖励
  466. if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  467. {
  468. function.WriteLog("大盟主奖发放", "无押金激活奖励日志");
  469. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  470. }
  471. //运营中心奖励
  472. if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  473. {
  474. function.WriteLog("运营中心奖发放", "无押金激活奖励日志");
  475. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  476. }
  477. }
  478. PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  479. if(edit != null)
  480. {
  481. edit.Detail = "1";
  482. db.SaveChanges();
  483. }
  484. }
  485. }
  486. function.WriteLog("\n\n\n", "无押金激活奖励日志");
  487. }
  488. db.Dispose();
  489. }
  490. public void activePrizeWithoutDeposit6(int posid = 0)
  491. {
  492. WebCMSEntities db = new WebCMSEntities();
  493. DateTime yesterday = DateTime.Now.AddDays(-30);
  494. DateTime today = DateTime.Now.AddMinutes(-10);
  495. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && m.BrandId == 6 && m.Detail != "1");
  496. if (posid > 0)
  497. {
  498. posList = posList.Where(m => m.Id == posid);
  499. }
  500. else
  501. {
  502. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  503. }
  504. foreach (PosMachinesTwo pos in posList.ToList())
  505. {
  506. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  507. if (merchant != null)
  508. {
  509. string ParentNav = "";
  510. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  511. if (user != null)
  512. {
  513. int GetUserId = user.Id;
  514. ParentNav = user.ParentNav;
  515. int TopUserId = 0;
  516. if (!string.IsNullOrEmpty(ParentNav))
  517. {
  518. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  519. }
  520. // 立刷30天内刷满5000,无服务费机具,返50
  521. if (pos.BrandId == 6 && pos.BindingTime > DateTime.Now.AddDays(-30))
  522. {
  523. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
  524. }
  525. PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  526. if(edit != null)
  527. {
  528. edit.Detail = "1";
  529. db.SaveChanges();
  530. }
  531. }
  532. }
  533. }
  534. db.Dispose();
  535. }
  536. public void activePrizeWithoutDeposit12(int posid = 0)
  537. {
  538. WebCMSEntities db = new WebCMSEntities();
  539. DateTime yesterday = DateTime.Now.AddDays(-30);
  540. DateTime today = DateTime.Now.AddMinutes(-10);
  541. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 12 || m.BrandId == 13) && m.Detail != "1");
  542. if (posid > 0)
  543. {
  544. posList = posList.Where(m => m.Id == posid);
  545. }
  546. else
  547. {
  548. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  549. }
  550. foreach (PosMachinesTwo pos in posList.ToList())
  551. {
  552. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  553. if (merchant != null)
  554. {
  555. string ParentNav = "";
  556. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  557. if (user != null)
  558. {
  559. int GetUserId = user.Id;
  560. ParentNav = user.ParentNav;
  561. int TopUserId = 0;
  562. if (!string.IsNullOrEmpty(ParentNav))
  563. {
  564. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  565. }
  566. //首台无押金机返50
  567. if(pos.BindingTime.Value.AddDays(30) >= pos.ActivationTime)
  568. {
  569. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 30);
  570. DateTime now = pos.ActivationTime.Value;
  571. //盟主奖励
  572. if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  573. {
  574. function.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
  575. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  576. }
  577. //运营中心奖励
  578. if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  579. {
  580. function.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
  581. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  582. }
  583. }
  584. PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  585. if(item != null)
  586. {
  587. item.Detail = "1";
  588. db.SaveChanges();
  589. }
  590. }
  591. }
  592. }
  593. db.Dispose();
  594. }
  595. public void activePrizeWithoutDeposit15(int posid = 0)
  596. {
  597. WebCMSEntities db = new WebCMSEntities();
  598. DateTime yesterday = DateTime.Now.AddDays(-100);
  599. DateTime today = DateTime.Now.AddHours(-1);
  600. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 15 || m.BrandId == 16) && m.Detail != "1");
  601. if (posid > 0)
  602. {
  603. posList = posList.Where(m => m.Id == posid);
  604. }
  605. else
  606. {
  607. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  608. }
  609. foreach (PosMachinesTwo pos in posList.ToList())
  610. {
  611. function.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理来客吧0押激活奖励");
  612. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  613. if (merchant != null)
  614. {
  615. string ParentNav = "";
  616. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  617. if (user != null)
  618. {
  619. int GetUserId = user.Id;
  620. ParentNav = user.ParentNav;
  621. int TopUserId = 0;
  622. if (!string.IsNullOrEmpty(ParentNav))
  623. {
  624. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  625. }
  626. //首台无押金机返50
  627. if(pos.BindingTime.Value.AddDays(30) >= pos.ActivationTime)
  628. {
  629. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 30);
  630. DateTime now = pos.ActivationTime.Value;
  631. //盟主奖励
  632. if (pos.LeaderUserId > 0 && db.Leaders.Any(m => m.Id == pos.LeaderUserId && m.ExpiredDate > now) && pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  633. {
  634. function.WriteLog("大盟主奖发放", "开机奖励在激活中监控");
  635. RedisDbconn.Instance.AddList("LeaderPrizeQueue", pos.Id);
  636. }
  637. //运营中心奖励
  638. if (pos.BindingTime > now.AddDays(-30) && pos.CardType < 100)
  639. {
  640. function.WriteLog("运营中心奖发放", "开机奖励在激活中监控");
  641. RedisDbconn.Instance.AddList("OperatePrizeQueue", pos.Id);
  642. }
  643. }
  644. function.WriteLog("ActPrize:30", "实时处理来客吧0押激活奖励");
  645. PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  646. if(item != null)
  647. {
  648. item.Detail = "1";
  649. db.SaveChanges();
  650. }
  651. }
  652. }
  653. }
  654. db.Dispose();
  655. }
  656. public void activePrizeWithoutDeposit122(int posid = 0)
  657. {
  658. WebCMSEntities db = new WebCMSEntities();
  659. DateTime yesterday = DateTime.Now.AddDays(-30);
  660. DateTime today = DateTime.Now.AddMinutes(-5);
  661. DateTime checkTime = DateTime.Parse("2023-08-01 00:00:00");
  662. IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.CreditTrade >= 1000 && m.ActivationTime < checkTime && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 12 || m.BrandId == 13) && m.Detail != "1");
  663. if (posid > 0)
  664. {
  665. posList = posList.Where(m => m.Id == posid);
  666. }
  667. else
  668. {
  669. posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today);
  670. }
  671. foreach (PosMachinesTwo pos in posList.ToList())
  672. {
  673. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  674. if (merchant != null)
  675. {
  676. string ParentNav = "";
  677. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  678. if (user != null)
  679. {
  680. int GetUserId = user.Id;
  681. ParentNav = user.ParentNav;
  682. int TopUserId = 0;
  683. if (!string.IsNullOrEmpty(ParentNav))
  684. {
  685. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  686. }
  687. string IdCard = merchant.MerIdcardNo;
  688. string IdCardStart = IdCard.Substring(0, 6);
  689. string IdCardEnd = IdCard.Substring(IdCard.Length - 4);
  690. string MerName = merchant.MerchantName;
  691. List<int> BrandIds = new List<int>();
  692. BrandIds.Add(4);
  693. BrandIds.Add(5);
  694. BrandIds.Add(8);
  695. BrandIds.Add(9);
  696. PosMerchantInfo other = db.PosMerchantInfo.FirstOrDefault(m => m.MerIdcardNo.StartsWith(IdCardStart) && m.MerIdcardNo.EndsWith(IdCardEnd) && m.MerchantName.Contains(MerName) && BrandIds.Contains(m.BrandId));
  697. if(other != null)
  698. {
  699. PosMachinesTwo checkpos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == other.KqSnNo);
  700. if(checkpos != null)
  701. {
  702. doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50);
  703. PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  704. if(edit != null)
  705. {
  706. edit.SeoKeyword = Utils.Instance.TransferDeposit(edit, checkpos.SeoKeyword);
  707. edit.UpFeeFlag = checkpos.UpFeeFlag;
  708. edit.DownFeeFlag = checkpos.DownFeeFlag;
  709. edit.UpFeeDate = checkpos.UpFeeDate;
  710. edit.DownFeeDate = checkpos.DownFeeDate;
  711. edit.BindingTime = checkpos.BindingTime;
  712. edit.IsFirst = checkpos.IsFirst;
  713. db.SaveChanges();
  714. if(edit.UpFeeFlag == 1 && edit.DownFeeFlag == 0)
  715. {
  716. string info = "{\"RecordId\":\"\",\"PosId\":\"" + edit.Id + "\",\"Fee\": \"0.63\",\"Kind\": \"1\",\"OpMan\": \"系统\"}";
  717. RedisDbconn.Instance.AddList("SetDepositPostQueue", info);
  718. }
  719. }
  720. }
  721. }
  722. PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
  723. if(item != null)
  724. {
  725. item.Detail = "1";
  726. db.SaveChanges();
  727. }
  728. }
  729. }
  730. }
  731. db.Dispose();
  732. }
  733. public void doActiveReward(WebCMSEntities db, PosMerchantInfo merchant, PosMachinesTwo pos, int GetUserId, string ParentNav, int TopUserId, decimal ActPrize, int ChangeType = 0, int ActType = 0)
  734. {
  735. string MerNo = merchant.KqMerNo;
  736. //判断商户号是否为空,避免下次再有空商户的情况,导致奖励不发放
  737. if(string.IsNullOrEmpty(MerNo))
  738. {
  739. // MerNo = "n" + DateTime.Now.ToString("yyyyMMddHHmmssfff");
  740. RedisDbconn.Instance.AddList("ActiveRewardFailQueue", "{\"PosId\":\"" + pos.Id + "\",\"UserId\":\"" + GetUserId + "\",\"ActPrize\":\"" + ActPrize + "\",\"ChangeType\":\"" + ChangeType + "\",\"ActType\":\"" + ActType + "\"}");
  741. return;
  742. }
  743. List<int> BrandIds = new List<int>();
  744. BrandIds.Add(18);
  745. BrandIds.Add(19);
  746. BrandIds.Add(20);
  747. BrandIds.Add(21);
  748. BrandIds.Add(23);
  749. BrandIds.Add(24);
  750. BrandIds.Add(25);
  751. BrandIds.Add(26);
  752. bool check = false;
  753. if(!BrandIds.Contains(pos.BrandId))
  754. {
  755. check = db.ActiveReward.Any(m => m.KqMerNo == MerNo && m.RewardAmount == ActPrize && m.ActType == ActType);
  756. }
  757. bool check1 = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn && m.RewardAmount == ActPrize && m.ActType == ActType);
  758. if (!check && !check1)
  759. {
  760. function.WriteLog(DateTime.Now.ToString() + ":" + pos.PosSn, "实时处理激活奖励");
  761. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  762. db.ActiveReward.Add(new ActiveReward()
  763. {
  764. CreateDate = DateTime.Now,
  765. UpdateDate = DateTime.Now,
  766. UserId = GetUserId, //创客
  767. MerchantId = pos.BindMerchantId, //商户
  768. StandardDate = pos.ActivationTime, //达标日期
  769. RewardAmount = ActPrize, //奖励金额
  770. BrandId = pos.BrandId, //品牌
  771. UserNav = ParentNav, //创客父级
  772. DirectBuddyNo = merchant.UserId, //商户直属创客
  773. KqMerNo = MerNo, //渠道商户编号
  774. KqSnNo = pos.PosSn, //渠道SN号
  775. SnType = pos.PosSnType, //机具类型
  776. SnApplyUserId = pos.BuyUserId, //机具申请创客
  777. ActType = ActType, //激活类型
  778. SnStoreId = pos.StoreId, //SN仓库
  779. RewardTips = "激活奖励", //奖励描述
  780. Remark = "激活奖励", //备注
  781. ActDate = pos.ActivationTime, //激活时间
  782. TopUserId = TopUserId, //顶级创客
  783. SeoTitle = machineUser.RealName,
  784. });
  785. db.SaveChanges();
  786. string IdBrand = GetUserId + "_" + pos.BrandId;
  787. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  788. if (userData == null)
  789. {
  790. userData = db.UserMachineData.Add(new UserMachineData()
  791. {
  792. IdBrand = IdBrand,
  793. }).Entity;
  794. db.SaveChanges();
  795. }
  796. userData.ActProfit += ActPrize;
  797. db.SaveChanges();
  798. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  799. if (account == null)
  800. {
  801. account = db.UserAccount.Add(new UserAccount()
  802. {
  803. Id = GetUserId,
  804. UserId = GetUserId,
  805. }).Entity;
  806. db.SaveChanges();
  807. }
  808. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  809. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  810. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  811. account.BalanceAmount += ActPrize;
  812. account.TotalAmount += ActPrize;
  813. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  814. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  815. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  816. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  817. {
  818. CreateDate = DateTime.Now,
  819. UpdateDate = DateTime.Now,
  820. UserId = GetUserId, //创客
  821. ChangeType = ChangeType, //变动类型
  822. ProductType = pos.BrandId, //产品类型
  823. ChangeAmount = ActPrize, //变更金额
  824. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  825. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  826. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  827. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  828. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  829. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  830. QueryCount = pos.Id, //机具Id
  831. }).Entity;
  832. db.SaveChanges();
  833. //发送APP推送消息
  834. Utils.Instance.PrizePush(GetUserId, ActPrize);
  835. }
  836. }
  837. //根据商户信息发放激活奖励
  838. public void dosomething32(int merid = 0)
  839. {
  840. WebCMSEntities db = new WebCMSEntities();
  841. DateTime yesterday = DateTime.Now.AddHours(-3);
  842. DateTime today = DateTime.Now;
  843. IQueryable<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && !string.IsNullOrEmpty(m.SeoKeyword));
  844. if (merid > 0)
  845. {
  846. merList = merList.Where(m => m.Id == merid);
  847. }
  848. else
  849. {
  850. merList = merList.Where(m => m.MerStandardDate >= yesterday && m.MerStandardDate < today);
  851. }
  852. foreach (PosMerchantInfo merchant in merList.ToList())
  853. {
  854. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  855. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
  856. // if (otherInfo != null)
  857. // {
  858. // otherInfo.PrizeFlag1 = 1;
  859. // db.SaveChanges();
  860. MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
  861. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
  862. string ParentNav = "";
  863. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  864. if (user != null)
  865. {
  866. int GetUserId = user.Id;
  867. ParentNav = user.ParentNav;
  868. int TopUserId = 0;
  869. if (!string.IsNullOrEmpty(ParentNav))
  870. {
  871. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  872. }
  873. decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
  874. KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new KqProducts();
  875. if (brand.NoticeMoneyUnit == 2)
  876. {
  877. ActPrize = ActPrize / 100;
  878. }
  879. if (ActPrize > 0)
  880. {
  881. bool check = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn);
  882. if (!check)
  883. {
  884. if (ActPrize == 99)
  885. {
  886. ActPrize = 100;
  887. }
  888. else if (ActPrize == 199)
  889. {
  890. ActPrize = 200;
  891. }
  892. else if (ActPrize == 299)
  893. {
  894. ActPrize = 300;
  895. }
  896. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  897. db.ActiveReward.Add(new ActiveReward()
  898. {
  899. CreateDate = DateTime.Now,
  900. UpdateDate = DateTime.Now,
  901. UserId = GetUserId, //创客
  902. MerchantId = pos.BindMerchantId, //商户
  903. StandardDate = pos.ActivationTime, //达标日期
  904. RewardAmount = ActPrize, //奖励金额
  905. BrandId = pos.BrandId, //品牌
  906. UserNav = ParentNav, //创客父级
  907. DirectBuddyNo = merchant.UserId, //商户直属创客
  908. KqMerNo = merchant.KqMerNo, //渠道商户编号
  909. KqSnNo = pos.PosSn, //渠道SN号
  910. SnType = pos.PosSnType, //机具类型
  911. SnApplyUserId = pos.BuyUserId, //机具申请创客
  912. ActType = 0, //激活类型
  913. SnStoreId = pos.StoreId, //SN仓库
  914. RewardTips = "激活奖励", //奖励描述
  915. Remark = "激活奖励", //备注
  916. ActDate = pos.ActivationTime, //激活时间
  917. TopUserId = TopUserId, //顶级创客
  918. SeoTitle = machineUser.RealName,
  919. });
  920. db.SaveChanges();
  921. string IdBrand = GetUserId + "_" + pos.BrandId;
  922. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  923. if (userData == null)
  924. {
  925. userData = db.UserMachineData.Add(new UserMachineData()
  926. {
  927. IdBrand = IdBrand,
  928. }).Entity;
  929. db.SaveChanges();
  930. }
  931. userData.ActProfit += ActPrize;
  932. db.SaveChanges();
  933. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  934. if (account == null)
  935. {
  936. account = db.UserAccount.Add(new UserAccount()
  937. {
  938. Id = GetUserId,
  939. UserId = GetUserId,
  940. }).Entity;
  941. db.SaveChanges();
  942. }
  943. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  944. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  945. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  946. account.BalanceAmount += ActPrize;
  947. account.TotalAmount += ActPrize;
  948. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  949. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  950. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  951. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  952. {
  953. CreateDate = DateTime.Now,
  954. UpdateDate = DateTime.Now,
  955. UserId = GetUserId, //创客
  956. ChangeType = 0, //变动类型
  957. ProductType = pos.BrandId, //产品类型
  958. ChangeAmount = ActPrize, //变更金额
  959. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  960. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  961. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  962. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  963. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  964. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  965. }).Entity;
  966. db.SaveChanges();
  967. }
  968. }
  969. }
  970. // }
  971. }
  972. db.Dispose();
  973. }
  974. //3. 前一天的激活记录,根据创客类型,如果是商户型创客,则开机奖励的起始人从此人上级计算。如果不是,则从此人开始计算
  975. public void dosomething4(string date)
  976. {
  977. WebCMSEntities db = new WebCMSEntities();
  978. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  979. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  980. 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();
  981. foreach (PosMachinesTwo pos in posList)
  982. {
  983. if (pos.BindingTime > DateTime.Now.AddDays(-30))
  984. {
  985. decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  986. if (ActPrize > 0)
  987. {
  988. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  989. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  990. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  991. if (merchant != null)
  992. {
  993. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
  994. // if (otherInfo != null)
  995. // {
  996. // otherInfo.PrizeFlag2 = 1;
  997. // db.SaveChanges();
  998. // 从机具所属人上级开始分开机奖励
  999. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  1000. if (user != null)
  1001. {
  1002. if (!string.IsNullOrEmpty(user.ParentNav))
  1003. {
  1004. decimal Prize = 20;
  1005. string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1006. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  1007. {
  1008. int UserId = int.Parse(ParentNavs[i]);
  1009. Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
  1010. if (puser != null && Prize > 0)
  1011. {
  1012. int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机
  1013. int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
  1014. int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
  1015. // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
  1016. // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机(不限购买或赠送)
  1017. if (machineCount + ActiveCount + couponCount >= 3)
  1018. {
  1019. int pTopUserId = 0;
  1020. if (!string.IsNullOrEmpty(puser.ParentNav))
  1021. {
  1022. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1023. }
  1024. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  1025. OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
  1026. {
  1027. CreateDate = DateTime.Now,
  1028. UpdateDate = DateTime.Now,
  1029. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  1030. TradeDate = yesterday, //达标日期
  1031. UserId = puser.Id, //创客
  1032. BrandId = pos.BrandId, //品牌
  1033. ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
  1034. MerchantId = pos.BindMerchantId, //商户
  1035. DirectUserId = merchant.UserId, //商户直属人
  1036. SnNo = pos.PosSn, //SN号
  1037. MerNo = merchant.KqMerNo, //渠道商户号
  1038. SnType = pos.PosSnType, //机具类型
  1039. StandardDate = pos.ActivationTime, //商户的激活日期
  1040. SnStoreId = pos.StoreId, //SN仓库
  1041. MerBuddyType = puser.MerchantType, //商户创客类型
  1042. RewardType = 1, //奖励类型 1-开机直接奖励,2-开机间接奖励
  1043. RewardTips = "开机奖励", //奖励描述
  1044. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  1045. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  1046. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  1047. RewardDesc = "开机奖励", //奖励描述
  1048. TopUserId = pTopUserId, //顶级创客
  1049. SeoTitle = machineUser.RealName,
  1050. }).Entity;
  1051. db.OpenReward.Add(new OpenReward()
  1052. {
  1053. CreateDate = DateTime.Now,
  1054. UpdateDate = DateTime.Now,
  1055. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  1056. TradeDate = DateTime.Now, //达标日期
  1057. UserId = puser.Id, //创客
  1058. BrandId = pos.BrandId, //品牌
  1059. RewardType = 2, //奖励类型
  1060. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  1061. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  1062. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  1063. RewardDesc = "开机奖励", //奖励描述
  1064. TopUserId = pTopUserId, //顶级创客
  1065. });
  1066. string IdBrand = puser.Id + "_" + pos.BrandId;
  1067. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  1068. if (userData == null)
  1069. {
  1070. userData = db.UserMachineData.Add(new UserMachineData()
  1071. {
  1072. IdBrand = IdBrand,
  1073. }).Entity;
  1074. db.SaveChanges();
  1075. }
  1076. userData.OpenProfit += Prize;
  1077. db.SaveChanges();
  1078. //账户入库
  1079. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
  1080. if (account == null)
  1081. {
  1082. account = db.UserAccount.Add(new UserAccount()
  1083. {
  1084. Id = puser.Id,
  1085. UserId = puser.Id,
  1086. }).Entity;
  1087. db.SaveChanges();
  1088. }
  1089. //收支明细入库
  1090. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  1091. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  1092. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  1093. account.BalanceAmount += Prize;
  1094. account.TotalAmount += Prize;
  1095. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  1096. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  1097. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  1098. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  1099. {
  1100. CreateDate = DateTime.Now,
  1101. UpdateDate = DateTime.Now,
  1102. UserId = puser.Id, //创客
  1103. ChangeType = 50, //变动类型
  1104. ProductType = pos.BrandId, //产品类型
  1105. ChangeAmount = Prize, //变更金额
  1106. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  1107. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  1108. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  1109. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  1110. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  1111. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  1112. }).Entity;
  1113. db.SaveChanges();
  1114. Prize = 0;
  1115. }
  1116. }
  1117. }
  1118. }
  1119. }
  1120. // }
  1121. }
  1122. }
  1123. }
  1124. }
  1125. db.Dispose();
  1126. }
  1127. //实时获取开机奖励
  1128. public void StartOpenReward()
  1129. {
  1130. Thread th = new Thread(StartOpenRewardDo);
  1131. th.IsBackground = true;
  1132. th.Start();
  1133. }
  1134. public void StartOpenRewardDo()
  1135. {
  1136. while(true)
  1137. {
  1138. string content = RedisDbconn.Instance.RPop<string>("OpenRewardQueue");
  1139. if(!string.IsNullOrEmpty(content))
  1140. {
  1141. try
  1142. {
  1143. function.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "开机奖励发放日志");
  1144. int PosId = int.Parse(content);
  1145. Thread.Sleep(1000);
  1146. List<int> BrandIds = new List<int>();
  1147. BrandIds.Add(14);
  1148. BrandIds.Add(18);
  1149. BrandIds.Add(19);
  1150. BrandIds.Add(20);
  1151. BrandIds.Add(21);
  1152. BrandIds.Add(23);
  1153. BrandIds.Add(24);
  1154. BrandIds.Add(25);
  1155. BrandIds.Add(26);
  1156. WebCMSEntities db = new WebCMSEntities();
  1157. OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
  1158. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && ((!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000) || BrandIds.Contains(m.BrandId)));
  1159. if (pos != null)
  1160. {
  1161. function.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志");
  1162. bool IsGet = db.OpenRewardDetail.Any(m => m.SnNo == pos.PosSn);
  1163. if (pos.BindingTime > DateTime.Now.AddDays(-30) && !IsGet)
  1164. {
  1165. decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  1166. function.WriteLog("押金:" + pos.SeoKeyword, "开机奖励发放日志");
  1167. if (ActPrize > 0 || pos.BrandId == 14)
  1168. {
  1169. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  1170. if (merchant != null)
  1171. {
  1172. function.WriteLog("商户:" + merchant.KqMerNo, "开机奖励发放日志");
  1173. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  1174. if (user != null)
  1175. {
  1176. function.WriteLog("所属人:" + user.MakerCode, "开机奖励发放日志");
  1177. string ParentNav = function.CheckNull(user.ParentNav) + "," + user.Id + ",";
  1178. if (!string.IsNullOrEmpty(ParentNav))
  1179. {
  1180. decimal Prize = 0;
  1181. if(pos.BrandId == 14)
  1182. {
  1183. Prize = 19 * 0.3M;
  1184. }
  1185. if(pos.BrandId == 18 || pos.BrandId == 19 || pos.BrandId == 20 || pos.BrandId == 21)
  1186. {
  1187. Prize = 20;
  1188. }
  1189. if(pos.BrandId == 23 || pos.BrandId == 24 || pos.BrandId == 25 || pos.BrandId == 26)
  1190. {
  1191. Prize = 3;
  1192. }
  1193. string[] ParentNavs = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1194. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  1195. {
  1196. int UserId = int.Parse(ParentNavs[i]);
  1197. // Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1);
  1198. UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(UserId);
  1199. if (puser.Id > 0 && Prize > 0)
  1200. {
  1201. function.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
  1202. function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
  1203. if(puser.UserType > 0 || puser.LeaderLevel > 0)
  1204. {
  1205. bool leaderOp = true;
  1206. if(puser.LeaderLevel > 0 && puser.UserType == 0)
  1207. {
  1208. DateTime now = DateTime.Now;
  1209. leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
  1210. function.WriteLog("条件:leaderOp:" + leaderOp, "开机奖励发放日志");
  1211. }
  1212. else if(puser.LeaderLevel == 0 && puser.UserType > 0)
  1213. {
  1214. DateTime now = DateTime.Now;
  1215. leaderOp = opdb.SysAdmin.Any(m => m.UserId == puser.Id && m.ExpireDate >= now);
  1216. function.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
  1217. }
  1218. else if(puser.LeaderLevel > 0 && puser.UserType > 0)
  1219. {
  1220. DateTime now = DateTime.Now;
  1221. leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
  1222. if(!leaderOp) leaderOp = opdb.SysAdmin.Any(m => m.UserId == puser.Id && m.ExpireDate >= now);
  1223. }
  1224. if(leaderOp)
  1225. {
  1226. function.WriteLog("满足条件", "开机奖励发放日志");
  1227. int pTopUserId = 0;
  1228. if (!string.IsNullOrEmpty(puser.ParentNav))
  1229. {
  1230. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1231. }
  1232. PostOpenReward(db, pos, merchant, puser, Prize);
  1233. Prize = 0;
  1234. }
  1235. }
  1236. }
  1237. }
  1238. }
  1239. }
  1240. // }
  1241. }
  1242. }
  1243. }
  1244. }
  1245. db.Dispose();
  1246. opdb.Dispose();
  1247. }
  1248. catch(Exception ex)
  1249. {
  1250. function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常");
  1251. }
  1252. }
  1253. else
  1254. {
  1255. Thread.Sleep(5000);
  1256. }
  1257. }
  1258. }
  1259. public void StartLeaderReward()
  1260. {
  1261. Thread th = new Thread(StartLeaderRewardDo);
  1262. th.IsBackground = true;
  1263. th.Start();
  1264. }
  1265. public void StartLeaderRewardDo()
  1266. {
  1267. while(true)
  1268. {
  1269. string content = RedisDbconn.Instance.RPop<string>("LeaderRewardQueue");
  1270. if(!string.IsNullOrEmpty(content))
  1271. {
  1272. try
  1273. {
  1274. function.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "盟主开机奖励发放日志");
  1275. int PosId = int.Parse(content);
  1276. Thread.Sleep(1000);
  1277. WebCMSEntities db = new WebCMSEntities();
  1278. OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
  1279. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && m.CreditTrade >= 10000 && m.BrandId != 14);
  1280. if (pos != null)
  1281. {
  1282. function.WriteLog("sn:" + pos.PosSn, "盟主开机奖励发放日志");
  1283. bool IsGet = db.OpenRewardDetail.Any(m => m.SnNo == pos.PosSn);
  1284. if (!IsGet)
  1285. {
  1286. // decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
  1287. // function.WriteLog("押金:" + pos.SeoKeyword, "盟主开机奖励发放日志");
  1288. // if (ActPrize > 0)
  1289. // {
  1290. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  1291. if (merchant != null)
  1292. {
  1293. function.WriteLog("商户:" + merchant.KqMerNo, "盟主开机奖励发放日志");
  1294. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  1295. if (user != null)
  1296. {
  1297. function.WriteLog("所属人:" + user.MakerCode, "盟主开机奖励发放日志");
  1298. string ParentNav = function.CheckNull(user.ParentNav) + "," + user.Id + ",";
  1299. if (!string.IsNullOrEmpty(ParentNav))
  1300. {
  1301. decimal Prize = 50;
  1302. string[] ParentNavs = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1303. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  1304. {
  1305. int UserId = int.Parse(ParentNavs[i]);
  1306. // Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1);
  1307. UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(UserId);
  1308. if (puser.Id > 0 && Prize > 0)
  1309. {
  1310. function.WriteLog("上级:" + puser.MakerCode, "盟主开机奖励发放日志");
  1311. function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "盟主开机奖励发放日志");
  1312. if(puser.LeaderLevel > 0 || puser.UserType > 0)
  1313. {
  1314. bool leaderOp = true;
  1315. if(puser.LeaderLevel > 0 && puser.UserType == 0)
  1316. {
  1317. DateTime now = DateTime.Now;
  1318. leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
  1319. function.WriteLog("条件:1-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
  1320. }
  1321. // else if(puser.LeaderLevel == 0 && puser.UserType > 0)
  1322. // {
  1323. // DateTime now = DateTime.Now;
  1324. // leaderOp = opdb.SysAdmin.Any(m => m.UserId == puser.Id && m.ExpireDate >= now);
  1325. // function.WriteLog("条件:2-leaderOp:" + leaderOp, "盟主开机奖励发放日志");
  1326. // }
  1327. if(leaderOp)
  1328. {
  1329. function.WriteLog("满足条件", "盟主开机奖励发放日志");
  1330. int pTopUserId = 0;
  1331. if (!string.IsNullOrEmpty(puser.ParentNav))
  1332. {
  1333. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1334. }
  1335. PostOpenReward(db, pos, merchant, puser, Prize);
  1336. Prize = 0;
  1337. }
  1338. }
  1339. }
  1340. }
  1341. }
  1342. }
  1343. // }
  1344. }
  1345. // }
  1346. }
  1347. }
  1348. db.Dispose();
  1349. opdb.Dispose();
  1350. }
  1351. catch(Exception ex)
  1352. {
  1353. function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "盟主开机奖励发放异常");
  1354. }
  1355. }
  1356. else
  1357. {
  1358. Thread.Sleep(5000);
  1359. }
  1360. }
  1361. }
  1362. public void dosomething42(string date)
  1363. {
  1364. WebCMSEntities db = new WebCMSEntities();
  1365. DateTime yesterday = DateTime.Parse(date + " 00:00:00");
  1366. DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00");
  1367. List<PosMerchantInfo> merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && m.MerStandardDate >= yesterday && m.MerStandardDate < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0").ToList();
  1368. foreach (PosMerchantInfo merchant in merList)
  1369. {
  1370. MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo();
  1371. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo();
  1372. if (pos.ActivationTime > DateTime.Now.AddDays(-20) && pos.CreditTrade >= 1000)
  1373. {
  1374. decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword));
  1375. if (ActPrize > 0)
  1376. {
  1377. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
  1378. // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0);
  1379. // if (otherInfo != null)
  1380. // {
  1381. // otherInfo.PrizeFlag2 = 1;
  1382. // db.SaveChanges();
  1383. // 从机具所属人上级开始分开机奖励
  1384. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
  1385. if (user != null)
  1386. {
  1387. if (!string.IsNullOrEmpty(user.ParentNav))
  1388. {
  1389. decimal Prize = 20;
  1390. string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1391. for (int i = ParentNavs.Length - 1; i >= 0; i--)
  1392. {
  1393. int UserId = int.Parse(ParentNavs[i]);
  1394. Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
  1395. if (puser != null && Prize > 0)
  1396. {
  1397. int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机
  1398. int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机(不限购买或赠送)
  1399. int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
  1400. // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机
  1401. // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机(不限购买或赠送)
  1402. if (machineCount + ActiveCount + couponCount >= 3)
  1403. {
  1404. int pTopUserId = 0;
  1405. if (!string.IsNullOrEmpty(puser.ParentNav))
  1406. {
  1407. pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1408. }
  1409. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  1410. OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
  1411. {
  1412. CreateDate = DateTime.Now,
  1413. UpdateDate = DateTime.Now,
  1414. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  1415. TradeDate = yesterday, //达标日期
  1416. UserId = puser.Id, //创客
  1417. BrandId = pos.BrandId, //品牌
  1418. ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
  1419. MerchantId = pos.BindMerchantId, //商户
  1420. DirectUserId = merchant.UserId, //商户直属人
  1421. SnNo = pos.PosSn, //SN号
  1422. MerNo = merchant.KqMerNo, //渠道商户号
  1423. SnType = pos.PosSnType, //机具类型
  1424. StandardDate = pos.ActivationTime, //商户的激活日期
  1425. SnStoreId = pos.StoreId, //SN仓库
  1426. MerBuddyType = puser.MerchantType, //商户创客类型
  1427. RewardType = 1, //奖励类型 1-开机直接奖励,2-开机间接奖励
  1428. RewardTips = "开机奖励", //奖励描述
  1429. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  1430. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  1431. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  1432. RewardDesc = "开机奖励", //奖励描述
  1433. TopUserId = pTopUserId, //顶级创客
  1434. SeoTitle = machineUser.RealName,
  1435. }).Entity;
  1436. db.OpenReward.Add(new OpenReward()
  1437. {
  1438. CreateDate = DateTime.Now,
  1439. UpdateDate = DateTime.Now,
  1440. TradeMonth = yesterday.ToString("yyyyMM"), //交易月
  1441. TradeDate = DateTime.Now, //达标日期
  1442. UserId = puser.Id, //创客
  1443. BrandId = pos.BrandId, //品牌
  1444. RewardType = 2, //奖励类型
  1445. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  1446. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  1447. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  1448. RewardDesc = "开机奖励", //奖励描述
  1449. TopUserId = pTopUserId, //顶级创客
  1450. });
  1451. string IdBrand = puser.Id + "_" + pos.BrandId;
  1452. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  1453. if (userData == null)
  1454. {
  1455. userData = db.UserMachineData.Add(new UserMachineData()
  1456. {
  1457. IdBrand = IdBrand,
  1458. }).Entity;
  1459. db.SaveChanges();
  1460. }
  1461. userData.OpenProfit += Prize;
  1462. db.SaveChanges();
  1463. //账户入库
  1464. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
  1465. if (account == null)
  1466. {
  1467. account = db.UserAccount.Add(new UserAccount()
  1468. {
  1469. Id = puser.Id,
  1470. UserId = puser.Id,
  1471. }).Entity;
  1472. db.SaveChanges();
  1473. }
  1474. //收支明细入库
  1475. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  1476. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  1477. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  1478. account.BalanceAmount += Prize;
  1479. account.TotalAmount += Prize;
  1480. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  1481. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  1482. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  1483. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  1484. {
  1485. CreateDate = DateTime.Now,
  1486. UpdateDate = DateTime.Now,
  1487. UserId = puser.Id, //创客
  1488. ChangeType = 50, //变动类型
  1489. ProductType = pos.BrandId, //产品类型
  1490. ChangeAmount = Prize, //变更金额
  1491. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  1492. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  1493. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  1494. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  1495. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  1496. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  1497. }).Entity;
  1498. db.SaveChanges();
  1499. string dateString = yesterday.ToString("yyyyMMdd");
  1500. string monthString = yesterday.ToString("yyyyMM");
  1501. // 开机奖励列表
  1502. List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
  1503. if (!dates.Contains(dateString))
  1504. {
  1505. RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
  1506. }
  1507. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);
  1508. List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
  1509. if (!months.Contains(monthString))
  1510. {
  1511. RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
  1512. }
  1513. RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);
  1514. // 开机奖励详情
  1515. RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);
  1516. Prize -= 10;
  1517. }
  1518. }
  1519. }
  1520. }
  1521. }
  1522. // }
  1523. }
  1524. }
  1525. }
  1526. db.Dispose();
  1527. }
  1528. // 4. 前一天的流量卡记录和匹配
  1529. public void ListenFluxRecord()
  1530. {
  1531. Thread th = new Thread(ListenFluxRecordD0);
  1532. th.IsBackground = true;
  1533. th.Start();
  1534. }
  1535. public void ListenFluxRecordD0()
  1536. {
  1537. while(true)
  1538. {
  1539. if(DateTime.Now.Hour > 0)
  1540. {
  1541. CheckFluxForTrade();
  1542. }
  1543. Thread.Sleep(600000);
  1544. }
  1545. }
  1546. public void doFluxRecord()
  1547. {
  1548. function.WriteLog(DateTime.Now.ToString(), "执行流量费返佣");
  1549. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  1550. WebCMSEntities db = new WebCMSEntities();
  1551. DateTime start = DateTime.Now.AddDays(-20);
  1552. List<SpModels.TradeFluxRecord> trades = spdb.TradeFluxRecord.Where(m => m.CreateDate >= start && m.Status == 1).ToList();
  1553. foreach (SpModels.TradeFluxRecord trade in trades)
  1554. {
  1555. try
  1556. {
  1557. string OrderNo = trade.TradeSerialNo; //单号
  1558. DateTime TradeDate = trade.CreateDate.Value;
  1559. string TradeMonth = TradeDate.ToString("yyyyMM");
  1560. decimal FeeAmount = trade.FeeAmount; //流量费
  1561. int BrandId = int.Parse(trade.ProductType);
  1562. KqProducts brand = db.KqProducts.FirstOrDefault(m => m.Id == BrandId) ?? new KqProducts();
  1563. if (brand.NoticeMoneyUnit == 2)
  1564. {
  1565. FeeAmount = FeeAmount / 100;
  1566. }
  1567. string TradeSnNo = trade.TradeSnNo; //机具SN
  1568. decimal FluxProfit = 0;
  1569. if (trade.ProductType == "1" && FeeAmount == 60)
  1570. {
  1571. FluxProfit = 24;
  1572. }
  1573. else if (trade.ProductType == "7" && FeeAmount == 46)
  1574. {
  1575. FluxProfit = 10;
  1576. }
  1577. else if (trade.ProductType != "1" && FeeAmount == 48)
  1578. {
  1579. FluxProfit = 12;
  1580. }
  1581. else if (trade.ProductType != "1" && FeeAmount == 60)
  1582. {
  1583. FluxProfit = 24;
  1584. }
  1585. if (FluxProfit > 0)
  1586. {
  1587. MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new MachineForSnNo();
  1588. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
  1589. // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
  1590. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
  1591. if (merchant != null && pos.BrandId != 6)
  1592. {
  1593. bool checkExist = db.FluxProfitDetail.Any(m => m.MerNo == merchant.KqMerNo);
  1594. if (!checkExist && decimal.Parse(function.CheckNum(pos.SeoKeyword)) > 0)
  1595. {
  1596. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  1597. int GetUserId = user.Id;
  1598. int TopUserId = 0;
  1599. string ParentNav = user.ParentNav;
  1600. if (!string.IsNullOrEmpty(ParentNav))
  1601. {
  1602. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1603. if (ParentNavList.Length > 1)
  1604. {
  1605. TopUserId = int.Parse(ParentNavList[1]);
  1606. }
  1607. else if (ParentNavList.Length == 1)
  1608. {
  1609. TopUserId = int.Parse(ParentNavList[0]);
  1610. }
  1611. }
  1612. FluxProfitSummary fluxProfit = db.FluxProfitSummary.FirstOrDefault(m => m.UserId == GetUserId && m.BrandId == pos.BrandId && m.TradeMonth == TradeMonth);
  1613. if (fluxProfit == null)
  1614. {
  1615. fluxProfit = db.FluxProfitSummary.Add(new FluxProfitSummary()
  1616. {
  1617. CreateDate = DateTime.Now,
  1618. UpdateDate = DateTime.Now,
  1619. UserId = GetUserId, //创客
  1620. BrandId = pos.BrandId,
  1621. TopUserId = TopUserId, //顶级创客
  1622. TradeMonth = TradeMonth, //交易月
  1623. MerUserType = user.MerchantType, //商户创客类型
  1624. Remark = "流量卡分佣", //备注
  1625. }).Entity;
  1626. db.SaveChanges();
  1627. }
  1628. fluxProfit.FluxProfitAmt += FluxProfit; //流量分润总金额
  1629. db.FluxProfitDetail.Add(new FluxProfitDetail()
  1630. {
  1631. CreateDate = DateTime.Now,
  1632. UpdateDate = DateTime.Now,
  1633. RecordNo = OrderNo, //单号
  1634. TradeDate = TradeDate.ToString("yyyyMMdd"), //交易日期
  1635. TradeTime = TradeDate.ToString("HHmmss"), //交易时间
  1636. TradeMonth = TradeMonth, //交易月
  1637. UserId = GetUserId, //创客
  1638. MerchantId = pos.BindMerchantId, //商户
  1639. MerchantUserId = pos.UserId, //商户直属人
  1640. MerNo = merchant.KqMerNo, //渠道商户编号
  1641. SnNo = pos.PosSn, //渠道SN号
  1642. FluxOrderNo = OrderNo, //流量扣费单号
  1643. TradeOrderNo = OrderNo, //交易流水号
  1644. TradeAmt = trade.TradeAmount, //商户交易额
  1645. FluxFeeAmt = FeeAmount, //流量费
  1646. FluxProfitAmt = FluxProfit, //流量分润总金额
  1647. PosType = pos.PosSnType.ToString(), //POS类型
  1648. Remark = "流量卡分佣", //备注
  1649. BrandId = pos.BrandId, //品牌
  1650. TopUserId = TopUserId, //顶级创客
  1651. MerUserType = user.MerchantType, //商户创客类型
  1652. });
  1653. string IdBrand = user.Id + "_" + pos.BrandId;
  1654. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  1655. if (userData == null)
  1656. {
  1657. userData = db.UserMachineData.Add(new UserMachineData()
  1658. {
  1659. IdBrand = IdBrand,
  1660. }).Entity;
  1661. db.SaveChanges();
  1662. }
  1663. userData.FluxProfit += FluxProfit;
  1664. db.SaveChanges();
  1665. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
  1666. if (account == null)
  1667. {
  1668. account = db.UserAccount.Add(new UserAccount()
  1669. {
  1670. Id = GetUserId,
  1671. UserId = GetUserId,
  1672. }).Entity;
  1673. db.SaveChanges();
  1674. }
  1675. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  1676. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  1677. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  1678. account.BalanceAmount += FluxProfit;
  1679. account.TotalAmount += FluxProfit;
  1680. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  1681. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  1682. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  1683. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  1684. {
  1685. CreateDate = DateTime.Now,
  1686. UpdateDate = DateTime.Now,
  1687. UserId = GetUserId, //创客
  1688. ChangeType = 60, //变动类型
  1689. ProductType = pos.BrandId, //产品类型
  1690. ChangeAmount = FluxProfit, //变更金额
  1691. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  1692. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  1693. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  1694. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  1695. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  1696. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  1697. }).Entity;
  1698. db.SaveChanges();
  1699. }
  1700. SpModels.TradeFluxRecord edit = spdb.TradeFluxRecord.FirstOrDefault(m => m.Id == trade.Id);
  1701. if (edit != null)
  1702. {
  1703. edit.Status = 2;
  1704. spdb.SaveChanges();
  1705. }
  1706. }
  1707. }
  1708. }
  1709. catch (Exception ex)
  1710. {
  1711. function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
  1712. }
  1713. }
  1714. spdb.Dispose();
  1715. db.Dispose();
  1716. function.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣");
  1717. }
  1718. public void CheckFluxForTrade()
  1719. {
  1720. function.WriteLog(DateTime.Now.ToString(), "扫描交易记录中的流量费");
  1721. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  1722. DateTime start = DateTime.Now.AddDays(-120);
  1723. int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt")));
  1724. List<string> BrandIds = new List<string>();
  1725. BrandIds.Add("1");
  1726. BrandIds.Add("10");
  1727. BrandIds.Add("12");
  1728. var list = spdb.TradeRecord.Select(m => new { m.Id, m.CreateDate, m.ProductType, m.Status }).Where(m => m.Id >= StartId && m.Status == 2 && m.CreateDate > start && BrandIds.Contains(m.ProductType)).OrderBy(m => m.CreateDate);
  1729. foreach (var sub in list.ToList())
  1730. {
  1731. try
  1732. {
  1733. SpModels.TradeRecord trade = spdb.TradeRecord.FirstOrDefault(m => m.Id == sub.Id);
  1734. if (trade != null)
  1735. {
  1736. if(trade.ProductType == "1") //金控
  1737. {
  1738. string content = trade.SeoDescription;
  1739. if (!string.IsNullOrEmpty(content))
  1740. {
  1741. content = System.Web.HttpUtility.UrlDecode(content);
  1742. JsonData jsonObj = JsonMapper.ToObject(content);
  1743. decimal terminalDataFlowFee = decimal.Parse(function.CheckNum(jsonObj["terminalDataFlowFee"].ToString()));
  1744. if (terminalDataFlowFee > 0)
  1745. {
  1746. spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord()
  1747. {
  1748. SeoDescription = trade.TradeSerialNo,
  1749. FeeAmount = terminalDataFlowFee,
  1750. TradeSerialNo = function.MD5_16(trade.TradeSerialNo),
  1751. CreateDate = trade.CreateDate,
  1752. TradeSnNo = trade.TradeSnNo,
  1753. ProductType = trade.ProductType,
  1754. Status = 1,
  1755. });
  1756. spdb.SaveChanges();
  1757. }
  1758. }
  1759. }
  1760. else if(trade.ProductType == "10" || trade.ProductType == "12") //10联动、12盒易付
  1761. {
  1762. if (trade.DigAmt > 0)
  1763. {
  1764. spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord()
  1765. {
  1766. SeoDescription = trade.TradeSerialNo,
  1767. FeeAmount = trade.DigAmt,
  1768. TradeSerialNo = function.MD5_16(trade.TradeSerialNo),
  1769. CreateDate = trade.CreateDate,
  1770. TradeSnNo = trade.TradeSnNo,
  1771. ProductType = trade.ProductType,
  1772. Status = 1,
  1773. });
  1774. spdb.SaveChanges();
  1775. }
  1776. }
  1777. trade.Status = 3;
  1778. spdb.SaveChanges();
  1779. }
  1780. }
  1781. catch (Exception ex)
  1782. {
  1783. function.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描交易记录中的流量费异常");
  1784. }
  1785. }
  1786. spdb.Dispose();
  1787. function.WriteLog(DateTime.Now.ToString() + "\n", "扫描交易记录中的流量费");
  1788. // doFluxRecord();
  1789. }
  1790. // 每天统计头一天的交易额
  1791. public void StartEverDay()
  1792. {
  1793. string TradeMonth = DateTime.Now.AddMonths(-6).ToString("yyyyMM");
  1794. // string PreMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  1795. // if(DateTime.Now.Day == 1)
  1796. // {
  1797. // TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  1798. // PreMonth = DateTime.Now.AddMonths(-2).ToString("yyyyMM");
  1799. // }
  1800. // else if(DateTime.Now.Day == 2)
  1801. // {
  1802. // CustomerSqlConn.op("update Users set ThisMonthTrade=0 where ThisMonthTrade>0", MysqlConn.SqlConnStr);
  1803. // }
  1804. Dictionary<string, decimal> dic = new Dictionary<string, decimal>();
  1805. DataTable list = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectTradeAmt+ProfitNonDirectDebitTradeAmt) from TradeDaySummary where Id>=15055757 and TradeMonth>='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.ReadSqlConnStr);
  1806. foreach (DataRow dr in list.Rows)
  1807. {
  1808. string UserId = dr["UserId"].ToString();
  1809. string ThisMonthTrade = dr[1].ToString();
  1810. dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1811. }
  1812. list = CustomerSqlConn.dtable("select UserId,sum(ProfitTradeAmt+ProfitDebitTradeAmt) from TradeDaySummary2 where TradeMonth>='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.ReadSqlConnStr);
  1813. foreach (DataRow dr in list.Rows)
  1814. {
  1815. string UserId = dr["UserId"].ToString();
  1816. string ThisMonthTrade = dr[1].ToString();
  1817. if(dic.ContainsKey(UserId))
  1818. {
  1819. dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1820. }
  1821. else
  1822. {
  1823. dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1824. }
  1825. }
  1826. // list = CustomerSqlConn.dtable("select UserId,sum(ActiveBuddyMerStatus)*10000 from UserTradeMonthSummary where TradeMonth>='" + TradeMonth + "' and BrandId=14 and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.ReadSqlConnStr);
  1827. // foreach (DataRow dr in list.Rows)
  1828. // {
  1829. // string UserId = dr["UserId"].ToString();
  1830. // string ThisMonthTrade = dr[1].ToString();
  1831. // if(dic.ContainsKey(UserId))
  1832. // {
  1833. // dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1834. // }
  1835. // else
  1836. // {
  1837. // dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1838. // }
  1839. // }
  1840. list = CustomerSqlConn.dtable("select UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth>='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.MpSqlConnStr);
  1841. foreach (DataRow dr in list.Rows)
  1842. {
  1843. string UserId = dr["UserId"].ToString();
  1844. string ThisMonthTrade = dr[1].ToString();
  1845. if(dic.ContainsKey(UserId))
  1846. {
  1847. dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1848. }
  1849. else
  1850. {
  1851. dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1852. }
  1853. }
  1854. list = CustomerSqlConn.dtable("select UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth>='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.MpSqlConnStr2);
  1855. foreach (DataRow dr in list.Rows)
  1856. {
  1857. string UserId = dr["UserId"].ToString();
  1858. string ThisMonthTrade = dr[1].ToString();
  1859. if(dic.ContainsKey(UserId))
  1860. {
  1861. dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1862. }
  1863. else
  1864. {
  1865. dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1866. }
  1867. }
  1868. // list = CustomerSqlConn.dtable("select UserId,SimValidActTeamCount*10000 from KxsStatServer.SimValidAct" + PreMonth + " where UserId>0", MysqlConn.ReadSqlConnStr);
  1869. // foreach (DataRow dr in list.Rows)
  1870. // {
  1871. // string UserId = dr["UserId"].ToString();
  1872. // string ThisMonthTrade = dr[1].ToString();
  1873. // if(dic.ContainsKey(UserId))
  1874. // {
  1875. // dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1876. // }
  1877. // else
  1878. // {
  1879. // dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1880. // }
  1881. // }
  1882. list = CustomerSqlConn.dtable("select UserId,sum(TradeAmount) from HelpProfitUserTradeSummay where UserId>0 and TradeMonth>='" + TradeMonth + "' and SeoTitle='team' group by UserId", MysqlConn.ReadSqlConnStr);
  1883. foreach (DataRow dr in list.Rows)
  1884. {
  1885. string UserId = dr["UserId"].ToString();
  1886. string ThisMonthTrade = dr[1].ToString();
  1887. if(dic.ContainsKey(UserId))
  1888. {
  1889. dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
  1890. }
  1891. else
  1892. {
  1893. dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
  1894. }
  1895. }
  1896. int index = 0;
  1897. string sql = "";
  1898. foreach(string UserId in dic.Keys)
  1899. {
  1900. index += 1;
  1901. sql += "update Users set ThisMonthTrade=" + dic[UserId] + " where Id=" + UserId + ";";
  1902. if(index >= 200)
  1903. {
  1904. CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
  1905. sql = "";
  1906. index = 0;
  1907. }
  1908. }
  1909. if(!string.IsNullOrEmpty(sql))
  1910. {
  1911. CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
  1912. }
  1913. }
  1914. public void StatTradeAmountEverDay(object sender)
  1915. {
  1916. string date = sender.ToString();
  1917. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志");
  1918. WebCMSEntities db = new WebCMSEntities();
  1919. try
  1920. {
  1921. string TradeDate = date.Replace("-", "");
  1922. string TradeMonth = TradeDate.Substring(0, 6);
  1923. string start = date + " 00:00:00";
  1924. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  1925. string startId = "0", endId = "9999999999";
  1926. List<string> uids = new List<string>();
  1927. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from TradeRecord where CreateDate>='" + start + "'");
  1928. if (startDt.Rows.Count > 0)
  1929. {
  1930. startId = startDt.Rows[0][0].ToString();
  1931. }
  1932. function.WriteLog(startId + "\n\n", "执行昨天交易额日志");
  1933. // DataTable endDt = OtherMySqlConn.dtable("select max(Id) from TradeRecord where CreateDate<'" + end + "'");
  1934. // if (endDt.Rows.Count > 0)
  1935. // {
  1936. // endId = endDt.Rows[0][0].ToString();
  1937. // }
  1938. 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 + "')");
  1939. function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志");
  1940. foreach (DataRow userDr in userDt.Rows)
  1941. {
  1942. int UserId = int.Parse(userDr["Id"].ToString());
  1943. string ParentNav = userDr["ParentNav"].ToString();
  1944. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1945. 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");
  1946. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1947. foreach (DataRow selfDr in selfdt.Rows)
  1948. {
  1949. int BrandId = int.Parse(selfDr["BrandId"].ToString());
  1950. int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
  1951. int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
  1952. decimal TradeAmount = decimal.Parse(selfDr[3].ToString());
  1953. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  1954. if (selfStat == null)
  1955. {
  1956. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  1957. {
  1958. UserId = UserId,
  1959. TradeMonth = TradeMonth,
  1960. TradeDate = TradeDate,
  1961. BrandId = BrandId,
  1962. QueryCount = QrPayFlag,
  1963. SeoTitle = "self",
  1964. }).Entity;
  1965. db.SaveChanges();
  1966. }
  1967. if (BankCardType == 0)
  1968. {
  1969. selfStat.DirectDebitTradeAmt += TradeAmount;
  1970. }
  1971. else if (BankCardType != 0)
  1972. {
  1973. selfStat.DirectTradeAmt += TradeAmount;
  1974. }
  1975. db.SaveChanges();
  1976. }
  1977. if (!string.IsNullOrEmpty(ParentNav))
  1978. {
  1979. ParentNav += "," + UserId + ",";
  1980. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1981. foreach (string NavUserIdString in ParentNavList)
  1982. {
  1983. if (!uids.Contains(NavUserIdString + start))
  1984. {
  1985. uids.Add(NavUserIdString + start);
  1986. int NavUserId = int.Parse(NavUserIdString);
  1987. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1988. 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");
  1989. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  1990. foreach (DataRow teamDr in teamDt.Rows)
  1991. {
  1992. int BrandId = int.Parse(teamDr["BrandId"].ToString());
  1993. int BankCardType = int.Parse(teamDr["BankCardType"].ToString());
  1994. int QrPayFlag = int.Parse(teamDr["QrPayFlag"].ToString());
  1995. decimal TradeAmount = decimal.Parse(teamDr[3].ToString());
  1996. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  1997. if (teamStat == null)
  1998. {
  1999. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  2000. {
  2001. UserId = NavUserId,
  2002. TradeMonth = TradeMonth,
  2003. TradeDate = TradeDate,
  2004. BrandId = BrandId,
  2005. QueryCount = QrPayFlag,
  2006. SeoTitle = "team",
  2007. }).Entity;
  2008. db.SaveChanges();
  2009. }
  2010. if (BankCardType == 0)
  2011. {
  2012. teamStat.NonDirectDebitTradeAmt += TradeAmount;
  2013. }
  2014. else if (BankCardType != 0)
  2015. {
  2016. teamStat.NonDirectTradeAmt += TradeAmount;
  2017. }
  2018. db.SaveChanges();
  2019. }
  2020. }
  2021. }
  2022. }
  2023. }
  2024. if (DateTime.Now.Day >= 2)
  2025. {
  2026. Thread.Sleep(5000);
  2027. DataTable list = OtherMySqlConn.dtable("select UserId,sum(NonDirectTradeAmt) from UserTradeDaySummary where TradeDate='" + TradeDate + "' GROUP BY UserId");
  2028. foreach (DataRow dr in list.Rows)
  2029. {
  2030. string UserId = dr["UserId"].ToString();
  2031. string ThisMonthTrade = dr[1].ToString();
  2032. OtherMySqlConn.op("update Users set ThisMonthTrade=ThisMonthTrade+" + ThisMonthTrade + " where Id=" + UserId);
  2033. }
  2034. }
  2035. }
  2036. catch (Exception ex)
  2037. {
  2038. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常");
  2039. }
  2040. db.Dispose();
  2041. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
  2042. StatMerchantTrade(date);
  2043. }
  2044. //统计商户交易额
  2045. private void StatMerchantTrade(string date)
  2046. {
  2047. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志");
  2048. try
  2049. {
  2050. string start = date + " 00:00:00";
  2051. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2052. CustomerSqlConn.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 Id>=13000000 and CreateDate>='" + start + "' and CreateDate<'" + end + "' and ActStatus=1 and BrandId!=14 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", MysqlConn.SqlConnStr);
  2053. }
  2054. catch (Exception ex)
  2055. {
  2056. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额");
  2057. }
  2058. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
  2059. }
  2060. // 5. 创客升级
  2061. public void StatUserLevel()
  2062. {
  2063. Thread th = new Thread(StatUserLevelDo);
  2064. th.IsBackground = true;
  2065. th.Start();
  2066. }
  2067. public void StatUserLevelDo()
  2068. {
  2069. while (true)
  2070. {
  2071. if(DateTime.Now.Day < 15 && DateTime.Now.Hour >= 0)
  2072. {
  2073. string Month = DateTime.Now.AddDays(-1).ToString("yyyy-MM");
  2074. string flag = function.ReadInstance("/ProfitFlag/" + Month + ".txt");
  2075. if (string.IsNullOrEmpty(flag))
  2076. {
  2077. function.WritePage("/ProfitFlag/", Month + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  2078. LogoutUserHelper.Instance.DoWorks(); //每月一号归档注销创客,把伞下创客归到注销创客的上级
  2079. StatUserLevelStartNew();
  2080. }
  2081. }
  2082. Thread.Sleep(600000);
  2083. }
  2084. }
  2085. public void StatUserLevelStart()
  2086. {
  2087. WebCMSEntities db = new WebCMSEntities();
  2088. MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
  2089. try
  2090. {
  2091. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2092. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  2093. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  2094. DateTime end = start.AddDays(1);
  2095. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  2096. List<UserLevelSet> sets = db.UserLevelSet.ToList();
  2097. bool op = true;
  2098. int startid = 0;
  2099. while(op)
  2100. {
  2101. var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList();
  2102. function.WriteLog(users.Count.ToString(), "创客升级日志");
  2103. if(users.Count > 0)
  2104. {
  2105. foreach (var subuser in users)
  2106. {
  2107. Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
  2108. if (user != null)
  2109. {
  2110. int BeforeLevel = user.UserLevel;
  2111. int AfterLevel = 0;
  2112. decimal TradeAmount = 0;
  2113. //创客团队交易额
  2114. bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  2115. if (check)
  2116. {
  2117. TradeAmount += db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
  2118. }
  2119. //助利宝团队交易额
  2120. DataTable checkdt = OtherMySqlConn.dtable("SELECT SUM(TradeAmount) TradeAmount FROM HelpProfitMerTradeSummay WHERE (MerchantId IN(SELECT MerchantId FROM HelpProfitMerIds WHERE UserId IN(SELECT Id from Users WHERE ParentNav like '%," + user.Id + ",%' OR Id=" + user.Id + "))) AND TradeMonth=" + TradeMonth + "");
  2121. if (checkdt.Rows.Count > 0)
  2122. {
  2123. TradeAmount += decimal.Parse(function.CheckNum(checkdt.Rows[0]["TradeAmount"].ToString()));
  2124. }
  2125. //码牌团队交易额
  2126. check = mpmaindb.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  2127. if (check)
  2128. {
  2129. TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.TotalAmount);
  2130. }
  2131. UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
  2132. if (set != null)
  2133. {
  2134. AfterLevel = set.Id;
  2135. }
  2136. // K6以上计算小市场是否达标
  2137. // 升级逻辑
  2138. bool upFlag = true;
  2139. if(AfterLevel > 5)
  2140. {
  2141. DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) from TradeDaySummary where UserId in (select Id from Users where ParentUserId=" + user.Id + ") and TradeMonth='" + TradeMonth + "' and SeoTitle='team' group by UserId order by sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) desc");
  2142. int index = 0;
  2143. decimal TradeAmt = 0;
  2144. decimal BigTradeAmt = 0;
  2145. foreach(DataRow dr in dt.Rows)
  2146. {
  2147. index += 1;
  2148. if(index == 1)
  2149. {
  2150. BigTradeAmt = decimal.Parse(dr[1].ToString());
  2151. }
  2152. else if(index > 1)
  2153. {
  2154. TradeAmt += decimal.Parse(dr[1].ToString());
  2155. }
  2156. }
  2157. if(TradeAmt < 12000000 || BigTradeAmt < 30000000)
  2158. {
  2159. if(AfterLevel > BeforeLevel && BeforeLevel >= 5) //保级,只升不降
  2160. {
  2161. AfterLevel = BeforeLevel;
  2162. }
  2163. else if(AfterLevel > BeforeLevel && BeforeLevel < 5)
  2164. {
  2165. AfterLevel = 5;
  2166. }
  2167. else if(BeforeLevel > 5)
  2168. {
  2169. AfterLevel = 5;
  2170. }
  2171. else
  2172. {
  2173. upFlag = false;
  2174. }
  2175. }
  2176. }
  2177. if (AfterLevel > BeforeLevel && AfterLevel > 1 && upFlag)
  2178. {
  2179. function.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
  2180. user.UserLevel = AfterLevel;
  2181. DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  2182. UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
  2183. if(rank == null)
  2184. {
  2185. db.UserRank.Add(new UserRank()
  2186. {
  2187. CreateDate = DateTime.Now,
  2188. UpdateDate = DateTime.Now,
  2189. UserId = user.Id, //创客
  2190. WhiteRank = BeforeLevel,
  2191. Rank = AfterLevel, //当前等级
  2192. StatYear = DateTime.Now.Year, //统计年份
  2193. StatMonth = DateTime.Now.Month, //统计月份
  2194. TradeAmt = TradeAmount, //团队交易总额
  2195. UpgradeFlag = 1, //升级标识
  2196. OperateDate = DateTime.Now, //操作时间
  2197. Status = 1,
  2198. });
  2199. db.SaveChanges();
  2200. }
  2201. else
  2202. {
  2203. rank.TradeAmt = TradeAmount;
  2204. rank.Rank = AfterLevel;
  2205. db.SaveChanges();
  2206. }
  2207. }
  2208. // 降级逻辑
  2209. if(!upFlag && AfterLevel > 5)
  2210. {
  2211. AfterLevel = 5;
  2212. }
  2213. if (AfterLevel < BeforeLevel && BeforeLevel > 1)
  2214. {
  2215. function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
  2216. user.UserLevel = AfterLevel;
  2217. DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  2218. UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
  2219. if(rank == null)
  2220. {
  2221. db.UserRank.Add(new UserRank()
  2222. {
  2223. CreateDate = DateTime.Now,
  2224. UpdateDate = DateTime.Now,
  2225. UserId = user.Id, //创客
  2226. WhiteRank = BeforeLevel,
  2227. Rank = AfterLevel, //当前等级
  2228. StatYear = DateTime.Now.Year, //统计年份
  2229. StatMonth = DateTime.Now.Month, //统计月份
  2230. TradeAmt = TradeAmount, //团队交易总额
  2231. UpgradeFlag = 0, //升级标识
  2232. OperateDate = DateTime.Now, //操作时间
  2233. Status = 1,
  2234. });
  2235. db.SaveChanges();
  2236. }
  2237. else
  2238. {
  2239. rank.TradeAmt = TradeAmount;
  2240. rank.Rank = AfterLevel;
  2241. rank.Status = 1;
  2242. db.SaveChanges();
  2243. }
  2244. }
  2245. }
  2246. startid = subuser.Id;
  2247. }
  2248. function.WriteLog(startid.ToString(), "创客升级日志");
  2249. }
  2250. else
  2251. {
  2252. op = false;
  2253. }
  2254. }
  2255. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  2256. }
  2257. catch (Exception ex)
  2258. {
  2259. function.WriteLog(ex.ToString(), "创客升级异常");
  2260. }
  2261. db.Dispose();
  2262. mpmaindb.Dispose();
  2263. RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1");
  2264. }
  2265. public void StatUserLevelStartNew()
  2266. {
  2267. WebCMSEntities db = new WebCMSEntities();
  2268. MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities();
  2269. MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities();
  2270. try
  2271. {
  2272. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2273. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  2274. DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
  2275. DateTime end = start.AddDays(1);
  2276. string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
  2277. List<UserLevelSet> sets = db.UserLevelSet.ToList();
  2278. bool op = true;
  2279. int startid = 138681;
  2280. while(op)
  2281. {
  2282. var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList();
  2283. function.WriteLog(users.Count.ToString(), "创客升级日志");
  2284. if(users.Count > 0)
  2285. {
  2286. foreach (var subuser in users)
  2287. {
  2288. Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
  2289. if (user != null)
  2290. {
  2291. int BeforeLevel = user.UserLevel;
  2292. int AfterLevel = 0;
  2293. decimal TradeAmount = 0;
  2294. //创客团队交易额
  2295. bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  2296. if (check)
  2297. {
  2298. TradeAmount += db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt);
  2299. }
  2300. //助利宝团队交易额
  2301. DataTable checkdt = OtherMySqlConn.dtable("SELECT SUM(TradeAmount) TradeAmount FROM HelpProfitMerTradeSummay WHERE (MerchantId IN(SELECT MerchantId FROM HelpProfitMerIds WHERE UserId IN(SELECT Id from Users WHERE ParentNav like '%," + user.Id + ",%' OR Id=" + user.Id + "))) AND TradeMonth=" + TradeMonth + "");
  2302. if (checkdt.Rows.Count > 0)
  2303. {
  2304. TradeAmount += decimal.Parse(function.CheckNum(checkdt.Rows[0]["TradeAmount"].ToString()));
  2305. }
  2306. //码牌团队交易额(直联)
  2307. check = mpmaindb.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  2308. if (check)
  2309. {
  2310. TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
  2311. }
  2312. //码牌团队交易额(银联)
  2313. check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
  2314. if (check)
  2315. {
  2316. TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4;
  2317. }
  2318. //广电卡扶持期按1万/张计入职级
  2319. check = db.UserTradeMonthSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14);
  2320. if (check)
  2321. {
  2322. TradeAmount += db.UserTradeMonthSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000;
  2323. }
  2324. UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
  2325. if (set != null)
  2326. {
  2327. AfterLevel = set.Id;
  2328. }
  2329. // K6以上计算小市场是否达标
  2330. // 升级逻辑
  2331. bool upFlag = true;
  2332. if(AfterLevel > 5)
  2333. {
  2334. DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) from TradeDaySummary where UserId in (select Id from Users where ParentUserId=" + user.Id + ") and TradeMonth='" + TradeMonth + "' and SeoTitle='team' group by UserId order by sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) desc");
  2335. int index = 0;
  2336. decimal TradeAmt = 0;
  2337. decimal BigTradeAmt = 0;
  2338. foreach(DataRow dr in dt.Rows)
  2339. {
  2340. index += 1;
  2341. if(index == 1)
  2342. {
  2343. BigTradeAmt = decimal.Parse(dr[1].ToString());
  2344. }
  2345. else if(index > 1)
  2346. {
  2347. TradeAmt += decimal.Parse(dr[1].ToString());
  2348. }
  2349. }
  2350. if(TradeAmt < 12000000 || BigTradeAmt < 30000000)
  2351. {
  2352. if(AfterLevel > BeforeLevel && BeforeLevel >= 5) //保级,只升不降
  2353. {
  2354. AfterLevel = BeforeLevel;
  2355. }
  2356. else if(AfterLevel > BeforeLevel && BeforeLevel < 5)
  2357. {
  2358. AfterLevel = 5;
  2359. }
  2360. else if(BeforeLevel > 5)
  2361. {
  2362. AfterLevel = 5;
  2363. }
  2364. else
  2365. {
  2366. upFlag = false;
  2367. }
  2368. }
  2369. }
  2370. if (AfterLevel > BeforeLevel && AfterLevel > 0 && upFlag)
  2371. {
  2372. function.WriteLog("升级:" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志");
  2373. user.UserLevel = AfterLevel;
  2374. DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  2375. UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
  2376. if(rank == null)
  2377. {
  2378. db.UserRank.Add(new UserRank()
  2379. {
  2380. CreateDate = DateTime.Now,
  2381. UpdateDate = DateTime.Now,
  2382. UserId = user.Id, //创客
  2383. WhiteRank = BeforeLevel,
  2384. Rank = AfterLevel, //当前等级
  2385. StatYear = DateTime.Now.Year, //统计年份
  2386. StatMonth = DateTime.Now.Month, //统计月份
  2387. TradeAmt = TradeAmount, //团队交易总额
  2388. UpgradeFlag = 1, //升级标识
  2389. OperateDate = DateTime.Now, //操作时间
  2390. Status = 1,
  2391. });
  2392. db.SaveChanges();
  2393. }
  2394. else
  2395. {
  2396. rank.TradeAmt = TradeAmount;
  2397. rank.Rank = AfterLevel;
  2398. db.SaveChanges();
  2399. }
  2400. UserRankWhite rankWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == user.Id);
  2401. if(rankWhite != null)
  2402. {
  2403. if(Utils.Instance.GetUserLevel(user.Id) >= rankWhite.Rank)
  2404. {
  2405. user.Version = 0;
  2406. db.SaveChanges();
  2407. }
  2408. }
  2409. }
  2410. // 降级逻辑
  2411. if(!upFlag && AfterLevel > 5)
  2412. {
  2413. AfterLevel = 5;
  2414. }
  2415. // 如果是达标创客,只能降级到K1
  2416. if(AfterLevel == 0 && Utils.Instance.IsStandardUser(user.Id))
  2417. {
  2418. AfterLevel = 1;
  2419. }
  2420. if (AfterLevel < BeforeLevel && BeforeLevel > 0)
  2421. {
  2422. function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
  2423. user.UserLevel = AfterLevel;
  2424. DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
  2425. UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
  2426. if(rank == null)
  2427. {
  2428. db.UserRank.Add(new UserRank()
  2429. {
  2430. CreateDate = DateTime.Now,
  2431. UpdateDate = DateTime.Now,
  2432. UserId = user.Id, //创客
  2433. WhiteRank = BeforeLevel,
  2434. Rank = AfterLevel, //当前等级
  2435. StatYear = DateTime.Now.Year, //统计年份
  2436. StatMonth = DateTime.Now.Month, //统计月份
  2437. TradeAmt = TradeAmount, //团队交易总额
  2438. UpgradeFlag = 0, //升级标识
  2439. OperateDate = DateTime.Now, //操作时间
  2440. Status = 1,
  2441. });
  2442. db.SaveChanges();
  2443. }
  2444. else
  2445. {
  2446. rank.TradeAmt = TradeAmount;
  2447. rank.Rank = AfterLevel;
  2448. rank.Status = 1;
  2449. db.SaveChanges();
  2450. }
  2451. UserRankWhite rankWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == user.Id);
  2452. if(rankWhite != null)
  2453. {
  2454. if(Utils.Instance.GetUserLevel(user.Id) < rankWhite.Rank)
  2455. {
  2456. user.Version = 3;
  2457. db.SaveChanges();
  2458. }
  2459. }
  2460. }
  2461. }
  2462. startid = subuser.Id;
  2463. }
  2464. function.WriteLog(startid.ToString(), "创客升级日志");
  2465. }
  2466. else
  2467. {
  2468. op = false;
  2469. }
  2470. }
  2471. //查找K0创客,如果商城下单购买一组机具券,则预设为K1
  2472. List<int> productIds = new List<int>();
  2473. productIds.Add(10);
  2474. productIds.Add(11);
  2475. op = true;
  2476. startid = 0;
  2477. while(op)
  2478. {
  2479. var users = db.Users.Select(m => new { m.Id, m.AuthFlag, m.UserLevel }).Where(m => m.Id > startid && m.AuthFlag == 1 && m.UserLevel == 0).OrderBy(m => m.Id).Take(50).ToList();
  2480. if(users.Count > 0)
  2481. {
  2482. foreach (var subuser in users)
  2483. {
  2484. bool hasOrder = db.Orders.Any(m => m.UserId == subuser.Id && m.Status > 0 && productIds.Contains(m.ProductId));
  2485. if(hasOrder)
  2486. {
  2487. Utils.Instance.LeaderPreUserLevel(subuser.Id, 1, DateTime.Parse("2025-01-01 00:00:00"));
  2488. db.UserRank.Add(new UserRank()
  2489. {
  2490. CreateDate = DateTime.Now,
  2491. UpdateDate = DateTime.Now,
  2492. UserId = subuser.Id, //创客
  2493. WhiteRank = 0,
  2494. Rank = 1, //当前等级
  2495. StatYear = DateTime.Now.Year, //统计年份
  2496. StatMonth = DateTime.Now.Month, //统计月份
  2497. TradeAmt = 0, //团队交易总额
  2498. UpgradeFlag = 1, //升级标识
  2499. OperateDate = DateTime.Now, //操作时间
  2500. Status = 1,
  2501. });
  2502. Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
  2503. if(user != null)
  2504. {
  2505. user.Version = 3;
  2506. }
  2507. db.SaveChanges();
  2508. }
  2509. }
  2510. }
  2511. else
  2512. {
  2513. op = false;
  2514. }
  2515. }
  2516. function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
  2517. }
  2518. catch (Exception ex)
  2519. {
  2520. function.WriteLog(ex.ToString(), "创客升级异常");
  2521. }
  2522. db.Dispose();
  2523. mpmaindb.Dispose();
  2524. mpmaindb2.Dispose();
  2525. RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1");
  2526. }
  2527. // 统计创客激活数
  2528. public void StartPosActNum()
  2529. {
  2530. Thread th = new Thread(StartPosActNumFor);
  2531. th.IsBackground = true;
  2532. th.Start();
  2533. }
  2534. public void StartPosActNumFor()
  2535. {
  2536. // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
  2537. // DateTime check = DateTime.Parse("2022-06-14");
  2538. // while (check <= end)
  2539. // {
  2540. // StartPosActNumDo(check.ToString("yyyy-MM-dd"));
  2541. // check = check.AddDays(1);
  2542. // }
  2543. while (true)
  2544. {
  2545. if(DateTime.Now.Hour >= 2)
  2546. {
  2547. StartPosActNumEverTime();
  2548. }
  2549. Thread.Sleep(100);
  2550. }
  2551. }
  2552. public void StartPosActNumDo(object sender)
  2553. {
  2554. string date = sender.ToString();
  2555. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志");
  2556. WebCMSEntities db = new WebCMSEntities();
  2557. try
  2558. {
  2559. string TradeDate = date.Replace("-", "");
  2560. string TradeMonth = TradeDate.Substring(0, 6);
  2561. string start = date + " 00:00:00";
  2562. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2563. List<string> uids = new List<string>();
  2564. 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 + "')");
  2565. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志");
  2566. foreach (DataRow userDr in userDt.Rows)
  2567. {
  2568. int UserId = int.Parse(userDr["Id"].ToString());
  2569. string ParentNav = userDr["ParentNav"].ToString();
  2570. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  2571. 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");
  2572. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  2573. foreach (DataRow selfDr in selfdt.Rows)
  2574. {
  2575. int BrandId = int.Parse(selfDr["BrandId"].ToString());
  2576. int QrPayFlag = 0;
  2577. int ActCount = int.Parse(selfDr[1].ToString());
  2578. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  2579. if (selfStat == null)
  2580. {
  2581. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  2582. {
  2583. UserId = UserId,
  2584. TradeMonth = TradeMonth,
  2585. TradeDate = TradeDate,
  2586. BrandId = BrandId,
  2587. QueryCount = QrPayFlag,
  2588. SeoTitle = "self",
  2589. }).Entity;
  2590. db.SaveChanges();
  2591. }
  2592. selfStat.DirectDebitCapNum += ActCount;
  2593. db.SaveChanges();
  2594. }
  2595. if (!string.IsNullOrEmpty(ParentNav))
  2596. {
  2597. ParentNav += "," + UserId + ",";
  2598. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2599. foreach (string NavUserIdString in ParentNavList)
  2600. {
  2601. if (!uids.Contains(NavUserIdString + start))
  2602. {
  2603. uids.Add(NavUserIdString + start);
  2604. int NavUserId = int.Parse(NavUserIdString);
  2605. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  2606. 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");
  2607. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  2608. foreach (DataRow teamDr in teamDt.Rows)
  2609. {
  2610. int BrandId = int.Parse(teamDr["BrandId"].ToString());
  2611. int QrPayFlag = 0;
  2612. int ActCount = int.Parse(teamDr[1].ToString());
  2613. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  2614. if (teamStat == null)
  2615. {
  2616. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  2617. {
  2618. UserId = NavUserId,
  2619. TradeMonth = TradeMonth,
  2620. TradeDate = TradeDate,
  2621. BrandId = BrandId,
  2622. QueryCount = QrPayFlag,
  2623. SeoTitle = "team",
  2624. }).Entity;
  2625. db.SaveChanges();
  2626. }
  2627. teamStat.NonDirectDebitCapNum += ActCount;
  2628. db.SaveChanges();
  2629. }
  2630. }
  2631. }
  2632. }
  2633. }
  2634. OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "'");
  2635. }
  2636. catch (Exception ex)
  2637. {
  2638. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常");
  2639. }
  2640. db.Dispose();
  2641. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志");
  2642. Thread.Sleep(60000);
  2643. }
  2644. public void StartPosActNumEverTime()
  2645. {
  2646. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2647. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
  2648. WebCMSEntities db = new WebCMSEntities();
  2649. try
  2650. {
  2651. DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and BuyUserId>0 limit 50");
  2652. if(idsDt.Rows.Count > 0)
  2653. {
  2654. string ids = "";
  2655. foreach (DataRow idsDr in idsDt.Rows)
  2656. {
  2657. ids += idsDr["Id"].ToString() + ",";
  2658. }
  2659. 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')");
  2660. if (userDt.Rows.Count > 0)
  2661. {
  2662. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
  2663. foreach (DataRow userDr in userDt.Rows)
  2664. {
  2665. int UserId = int.Parse(userDr["BuyUserId"].ToString());
  2666. int BrandId = int.Parse(userDr["BrandId"].ToString());
  2667. string TradeDate = userDr[2].ToString();
  2668. int ActCount = int.Parse(function.CheckInt(userDr[3].ToString()));
  2669. int QrPayFlag = 0;
  2670. string TradeMonth = TradeDate.Substring(0, 6);
  2671. string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
  2672. string start = date + " 00:00:00";
  2673. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2674. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  2675. string ParentNav = user.ParentNav;
  2676. UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
  2677. if (selfStat == null)
  2678. {
  2679. selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  2680. {
  2681. UserId = UserId,
  2682. TradeMonth = TradeMonth,
  2683. TradeDate = TradeDate,
  2684. BrandId = BrandId,
  2685. QueryCount = QrPayFlag,
  2686. SeoTitle = "self",
  2687. }).Entity;
  2688. db.SaveChanges();
  2689. }
  2690. selfStat.DirectDebitCapNum += ActCount;
  2691. ParentNav += "," + UserId + ",";
  2692. if (!string.IsNullOrEmpty(ParentNav))
  2693. {
  2694. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2695. foreach (string NavUserIdString in ParentNavList)
  2696. {
  2697. int NavUserId = int.Parse(NavUserIdString);
  2698. UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
  2699. if (teamStat == null)
  2700. {
  2701. teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
  2702. {
  2703. UserId = NavUserId,
  2704. TradeMonth = TradeMonth,
  2705. TradeDate = TradeDate,
  2706. BrandId = BrandId,
  2707. QueryCount = QrPayFlag,
  2708. SeoTitle = "team",
  2709. }).Entity;
  2710. db.SaveChanges();
  2711. }
  2712. teamStat.NonDirectDebitCapNum += ActCount;
  2713. }
  2714. }
  2715. }
  2716. db.SaveChanges();
  2717. OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  2718. }
  2719. }
  2720. }
  2721. catch (Exception ex)
  2722. {
  2723. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常");
  2724. }
  2725. db.Dispose();
  2726. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志");
  2727. }
  2728. // 统计新增创客数
  2729. public void StartNewUserNum()
  2730. {
  2731. Thread th = new Thread(StartNewUserNumFor);
  2732. th.IsBackground = true;
  2733. th.Start();
  2734. }
  2735. public void StartNewUserNumFor()
  2736. {
  2737. // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
  2738. // DateTime check = DateTime.Parse("2022-06-14");
  2739. // while (check <= end)
  2740. // {
  2741. // StartNewUserNumDo(check.ToString("yyyy-MM-dd"));
  2742. // check = check.AddDays(1);
  2743. // }
  2744. while (true)
  2745. {
  2746. if(DateTime.Now.Hour >= 2)
  2747. {
  2748. StartNewUserNumEverTime();
  2749. }
  2750. Thread.Sleep(120000);
  2751. }
  2752. }
  2753. public void StartNewUserNumDo(object sender)
  2754. {
  2755. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2756. string date = sender.ToString();
  2757. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
  2758. WebCMSEntities db = new WebCMSEntities();
  2759. try
  2760. {
  2761. string StatDate = date.Replace("-", "");
  2762. string StatMonth = StatDate.Substring(0, 6);
  2763. string start = date + " 00:00:00";
  2764. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2765. List<string> uids = new List<string>();
  2766. DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
  2767. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志");
  2768. foreach (DataRow userDr in userDt.Rows)
  2769. {
  2770. int UserId = int.Parse(userDr["Id"].ToString());
  2771. string ParentNav = userDr["ParentNav"].ToString();
  2772. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2773. DataTable selfdt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentUserId=" + UserId + "");
  2774. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2775. foreach (DataRow selfDr in selfdt.Rows)
  2776. {
  2777. int AddCount = int.Parse(selfDr[0].ToString());
  2778. PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
  2779. if (selfStat == null)
  2780. {
  2781. selfStat = db.PullnewSummary.Add(new PullnewSummary()
  2782. {
  2783. UserId = UserId,
  2784. StatMonth = StatMonth,
  2785. StatDate = StatDate,
  2786. SeoTitle = "self",
  2787. }).Entity;
  2788. db.SaveChanges();
  2789. }
  2790. selfStat.RecUserAuthNum += AddCount;
  2791. db.SaveChanges();
  2792. }
  2793. if (!string.IsNullOrEmpty(ParentNav))
  2794. {
  2795. ParentNav += "," + UserId + ",";
  2796. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2797. foreach (string NavUserIdString in ParentNavList)
  2798. {
  2799. if (!uids.Contains(NavUserIdString + start))
  2800. {
  2801. uids.Add(NavUserIdString + start);
  2802. int NavUserId = int.Parse(NavUserIdString);
  2803. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2804. 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 + ",%'");
  2805. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2806. foreach (DataRow teamDr in teamDt.Rows)
  2807. {
  2808. int AddCount = int.Parse(teamDr[0].ToString());
  2809. PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
  2810. if (teamStat == null)
  2811. {
  2812. teamStat = db.PullnewSummary.Add(new PullnewSummary()
  2813. {
  2814. UserId = NavUserId,
  2815. StatMonth = StatMonth,
  2816. StatDate = StatDate,
  2817. SeoTitle = "team",
  2818. }).Entity;
  2819. db.SaveChanges();
  2820. }
  2821. teamStat.RecUserAuthNum += AddCount;
  2822. db.SaveChanges();
  2823. }
  2824. }
  2825. }
  2826. }
  2827. }
  2828. OtherMySqlConn.op("update Users set QueryCount=1 where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'");
  2829. }
  2830. catch (Exception ex)
  2831. {
  2832. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常");
  2833. }
  2834. db.Dispose();
  2835. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志");
  2836. Thread.Sleep(60000);
  2837. }
  2838. public void StartNewUserNumEverTime()
  2839. {
  2840. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2841. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
  2842. WebCMSEntities db = new WebCMSEntities();
  2843. try
  2844. {
  2845. DataTable idsDt = OtherMySqlConn.dtable("select Id from Users where QueryCount=0 and AuthFlag=1 and AuthDate is not null limit 50");
  2846. if(idsDt.Rows.Count > 0)
  2847. {
  2848. string ids = "";
  2849. foreach (DataRow idsDr in idsDt.Rows)
  2850. {
  2851. ids += idsDr["Id"].ToString() + ",";
  2852. }
  2853. 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')");
  2854. if(userDt.Rows.Count > 0)
  2855. {
  2856. function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志");
  2857. foreach (DataRow userDr in userDt.Rows)
  2858. {
  2859. string StatDate = userDr[1].ToString();
  2860. int UserId = int.Parse(userDr["ParentUserId"].ToString());
  2861. string StatMonth = StatDate.Substring(0, 6);
  2862. string date = StatDate.Substring(0, 4) + "-" + StatDate.Substring(4, 2) + "-" + StatDate.Substring(6, 2);
  2863. string start = date + " 00:00:00";
  2864. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2865. int AddCount = int.Parse(userDr[2].ToString());
  2866. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  2867. string ParentNav = user.ParentNav;
  2868. PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self");
  2869. if (selfStat == null)
  2870. {
  2871. selfStat = db.PullnewSummary.Add(new PullnewSummary()
  2872. {
  2873. UserId = UserId,
  2874. StatMonth = StatMonth,
  2875. StatDate = StatDate,
  2876. SeoTitle = "self",
  2877. }).Entity;
  2878. db.SaveChanges();
  2879. }
  2880. selfStat.RecUserAuthNum += AddCount;
  2881. ParentNav += "," + UserId + ",";
  2882. if (!string.IsNullOrEmpty(ParentNav))
  2883. {
  2884. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2885. foreach (string NavUserIdString in ParentNavList)
  2886. {
  2887. int NavUserId = int.Parse(NavUserIdString);
  2888. PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team");
  2889. if (teamStat == null)
  2890. {
  2891. teamStat = db.PullnewSummary.Add(new PullnewSummary()
  2892. {
  2893. UserId = NavUserId,
  2894. StatMonth = StatMonth,
  2895. StatDate = StatDate,
  2896. SeoTitle = "team",
  2897. }).Entity;
  2898. db.SaveChanges();
  2899. }
  2900. teamStat.RecUserAuthNum += AddCount;
  2901. }
  2902. }
  2903. }
  2904. db.SaveChanges();
  2905. OtherMySqlConn.op("update Users set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  2906. }
  2907. }
  2908. }
  2909. catch (Exception ex)
  2910. {
  2911. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常");
  2912. }
  2913. db.Dispose();
  2914. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志");
  2915. }
  2916. // 每天统计头一天的收益
  2917. public void StatProfit()
  2918. {
  2919. Thread th = new Thread(StatProfitDo);
  2920. th.IsBackground = true;
  2921. th.Start();
  2922. }
  2923. public void StatProfitDo()
  2924. {
  2925. // DateTime end = DateTime.Parse("2022-06-16 00:00:00");
  2926. // DateTime check = DateTime.Parse("2022-06-16");
  2927. // while (check <= end)
  2928. // {
  2929. // StatProfitEverDay(check.ToString("yyyy-MM-dd"));
  2930. // Thread.Sleep(1000);
  2931. // check = check.AddDays(1);
  2932. // }
  2933. while (true)
  2934. {
  2935. if(DateTime.Now.Hour >= 2)
  2936. {
  2937. StatProfitEverDayEverTime();
  2938. }
  2939. Thread.Sleep(120000);
  2940. }
  2941. }
  2942. public void StatProfitEverDay(object sender)
  2943. {
  2944. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  2945. string date = sender.ToString();
  2946. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
  2947. WebCMSEntities db = new WebCMSEntities();
  2948. try
  2949. {
  2950. string TradeDate = date.Replace("-", "");
  2951. string TradeMonth = TradeDate.Substring(0, 6);
  2952. string start = date + " 00:00:00";
  2953. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  2954. string startId = "0";
  2955. List<string> uids = new List<string>();
  2956. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from UserAccountRecord where CreateDate>='" + start + "'");
  2957. if (startDt.Rows.Count > 0)
  2958. {
  2959. startId = startDt.Rows[0][0].ToString();
  2960. }
  2961. function.WriteLog(startId + "\n\n", "执行昨天收益日志");
  2962. 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 + "')");
  2963. function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志");
  2964. foreach (DataRow userDr in userDt.Rows)
  2965. {
  2966. int UserId = int.Parse(userDr["Id"].ToString());
  2967. string ParentNav = userDr["ParentNav"].ToString();
  2968. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2969. 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");
  2970. function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  2971. foreach (DataRow selfDr in selfdt.Rows)
  2972. {
  2973. int ChangeType = int.Parse(selfDr["ChangeType"].ToString());
  2974. int ProductType = int.Parse(selfDr["ProductType"].ToString());
  2975. decimal ProfitAmount = decimal.Parse(selfDr[2].ToString());
  2976. UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
  2977. if (selfStat == null)
  2978. {
  2979. selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
  2980. {
  2981. UserId = UserId,
  2982. TradeMonth = TradeMonth,
  2983. TradeDate = TradeDate,
  2984. RebateType = ChangeType,
  2985. ProductType = ProductType,
  2986. SeoTitle = "self",
  2987. }).Entity;
  2988. db.SaveChanges();
  2989. }
  2990. selfStat.CreditRewardAmount += ProfitAmount;
  2991. db.SaveChanges();
  2992. }
  2993. if (!string.IsNullOrEmpty(ParentNav))
  2994. {
  2995. ParentNav += "," + UserId + ",";
  2996. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2997. foreach (string NavUserIdString in ParentNavList)
  2998. {
  2999. if (!uids.Contains(NavUserIdString + start))
  3000. {
  3001. uids.Add(NavUserIdString + start);
  3002. int NavUserId = int.Parse(NavUserIdString);
  3003. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  3004. 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");
  3005. function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  3006. foreach (DataRow teamDr in teamDt.Rows)
  3007. {
  3008. int ChangeType = int.Parse(teamDr["ChangeType"].ToString());
  3009. int ProductType = int.Parse(teamDr["ProductType"].ToString());
  3010. decimal ProfitAmount = decimal.Parse(teamDr[2].ToString());
  3011. UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
  3012. if (teamStat == null)
  3013. {
  3014. teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
  3015. {
  3016. UserId = NavUserId,
  3017. TradeMonth = TradeMonth,
  3018. TradeDate = TradeDate,
  3019. RebateType = ChangeType,
  3020. ProductType = ProductType,
  3021. SeoTitle = "team",
  3022. }).Entity;
  3023. db.SaveChanges();
  3024. }
  3025. teamStat.CreditRewardAmount += ProfitAmount;
  3026. db.SaveChanges();
  3027. }
  3028. }
  3029. }
  3030. }
  3031. }
  3032. }
  3033. catch (Exception ex)
  3034. {
  3035. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常");
  3036. }
  3037. db.Dispose();
  3038. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志");
  3039. }
  3040. public void StatProfitEverDayEverTime()
  3041. {
  3042. OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
  3043. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
  3044. WebCMSEntities db = new WebCMSEntities();
  3045. try
  3046. {
  3047. string startId = function.ReadInstance("/UserAccountRecord/Id.txt");
  3048. if(string.IsNullOrEmpty(startId))
  3049. {
  3050. startId = "160653";
  3051. }
  3052. DataTable idsDt = OtherMySqlConn.dtable("select Id from UserAccountRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
  3053. if(idsDt.Rows.Count > 0)
  3054. {
  3055. string ids = "";
  3056. foreach (DataRow idsDr in idsDt.Rows)
  3057. {
  3058. ids += idsDr["Id"].ToString() + ",";
  3059. startId = idsDr["Id"].ToString();
  3060. }
  3061. 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')");
  3062. if (userDt.Rows.Count > 0)
  3063. {
  3064. function.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志");
  3065. foreach (DataRow userDr in userDt.Rows)
  3066. {
  3067. int UserId = int.Parse(userDr["UserId"].ToString());
  3068. int ChangeType = int.Parse(userDr["ChangeType"].ToString());
  3069. int ProductType = int.Parse(userDr["ProductType"].ToString());
  3070. string TradeDate = userDr[3].ToString();
  3071. decimal ProfitAmount = decimal.Parse(userDr[4].ToString());
  3072. string TradeMonth = TradeDate.Substring(0, 6);
  3073. string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
  3074. string start = date + " 00:00:00";
  3075. string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
  3076. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  3077. string ParentNav = user.ParentNav;
  3078. UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self");
  3079. if (selfStat == null)
  3080. {
  3081. selfStat = db.UserRebateDetail.Add(new UserRebateDetail()
  3082. {
  3083. UserId = UserId,
  3084. TradeMonth = TradeMonth,
  3085. TradeDate = TradeDate,
  3086. RebateType = ChangeType,
  3087. ProductType = ProductType,
  3088. SeoTitle = "self",
  3089. }).Entity;
  3090. db.SaveChanges();
  3091. }
  3092. selfStat.CreditRewardAmount += ProfitAmount;
  3093. ParentNav += "," + UserId + ",";
  3094. if (!string.IsNullOrEmpty(ParentNav))
  3095. {
  3096. string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  3097. foreach (string NavUserIdString in ParentNavList)
  3098. {
  3099. int NavUserId = int.Parse(NavUserIdString);
  3100. UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team");
  3101. if (teamStat == null)
  3102. {
  3103. teamStat = db.UserRebateDetail.Add(new UserRebateDetail()
  3104. {
  3105. UserId = NavUserId,
  3106. TradeMonth = TradeMonth,
  3107. TradeDate = TradeDate,
  3108. RebateType = ChangeType,
  3109. ProductType = ProductType,
  3110. SeoTitle = "team",
  3111. }).Entity;
  3112. db.SaveChanges();
  3113. }
  3114. teamStat.CreditRewardAmount += ProfitAmount;
  3115. }
  3116. }
  3117. }
  3118. db.SaveChanges();
  3119. OtherMySqlConn.op("update UserAccountRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
  3120. function.WritePage("/UserAccountRecord/", "Id.txt", startId);
  3121. }
  3122. }
  3123. }
  3124. catch (Exception ex)
  3125. {
  3126. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常");
  3127. }
  3128. db.Dispose();
  3129. function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志");
  3130. }
  3131. //押金奖励发放
  3132. public void StartPreActPrize()
  3133. {
  3134. Thread th = new Thread(StartPreActPrizeDo);
  3135. th.IsBackground = true;
  3136. th.Start();
  3137. }
  3138. public void StartPreActPrizeDo()
  3139. {
  3140. while(true)
  3141. {
  3142. string content = RedisDbconn.Instance.RPop<string>("DepositActPrizeQueue");
  3143. if(!string.IsNullOrEmpty(content))
  3144. {
  3145. try
  3146. {
  3147. int PosId = int.Parse(content);
  3148. WebCMSEntities db = new WebCMSEntities();
  3149. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId) ?? new PxcModels.PosMachinesTwo();
  3150. PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
  3151. PreActPrize(db, pos, merchant, pos.SeoKeyword);
  3152. db.Dispose();
  3153. }
  3154. catch(Exception ex)
  3155. {
  3156. function.WriteLog(DateTime.Now.ToString() + "\nPosId:" + content + "\n" + ex.ToString(), "押金奖励发放异常");
  3157. }
  3158. }
  3159. else
  3160. {
  3161. Thread.Sleep(10000);
  3162. }
  3163. }
  3164. }
  3165. public void PreActPrize(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, string Deposit)
  3166. {
  3167. function.WriteLog(DateTime.Now.ToString() + "\n" + pos.PosSn, "服务费奖励发放日志");
  3168. decimal DepositNumber = decimal.Parse(function.CheckNum(Deposit));
  3169. function.WriteLog("DepositNumber:" + DepositNumber, "服务费奖励发放日志");
  3170. function.WriteLog("BuyUserId:" + pos.BuyUserId, "服务费奖励发放日志");
  3171. if(DepositNumber > 0 && pos.BuyUserId > 0)
  3172. {
  3173. function.WriteLog("满足条件", "服务费奖励发放日志");
  3174. decimal ActPrize = 0;
  3175. if(DepositNumber > 1000)
  3176. {
  3177. DepositNumber = DepositNumber / 100;
  3178. }
  3179. if(DepositNumber == 199) ActPrize = 100;
  3180. if(DepositNumber == 299) ActPrize = 200;
  3181. if(DepositNumber == 249) ActPrize = 160;
  3182. function.WriteLog("ActPrize:" + ActPrize, "服务费奖励发放日志");
  3183. if(ActPrize > 0)
  3184. {
  3185. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  3186. int GetUserId = user.Id;
  3187. string ParentNav = user.ParentNav;
  3188. int TopUserId = 0;
  3189. if (!string.IsNullOrEmpty(ParentNav))
  3190. {
  3191. TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  3192. }
  3193. function.WriteLog("发放给:" + GetUserId, "服务费奖励发放日志");
  3194. doActiveReward(db, merchant, pos, GetUserId, user.ParentNav, TopUserId, ActPrize, 0, 1);
  3195. function.WriteLog("已发放", "服务费奖励发放日志");
  3196. }
  3197. }
  3198. function.WriteLog("\n\n\n", "服务费奖励发放日志");
  3199. }
  3200. #region 判断品牌互斥条件,根据身份证号
  3201. public bool CheckRepeatByBrand(WebCMSEntities db, int MerchantId)
  3202. {
  3203. int check = db.PosMachinesTwo.Count(m => m.Status > -1 && m.BindMerchantId == MerchantId);
  3204. return false;
  3205. }
  3206. #endregion
  3207. #region 开机奖励
  3208. public void PostOpenReward(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, UserRankItem puser, decimal Prize)
  3209. {
  3210. Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  3211. OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
  3212. {
  3213. CreateDate = DateTime.Now,
  3214. UpdateDate = DateTime.Now,
  3215. TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
  3216. TradeDate = DateTime.Now, //达标日期
  3217. UserId = puser.Id, //创客
  3218. BrandId = pos.BrandId, //品牌
  3219. ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
  3220. MerchantId = pos.BindMerchantId, //商户
  3221. DirectUserId = merchant.UserId, //商户直属人
  3222. SnNo = pos.PosSn, //SN号
  3223. MerNo = merchant.KqMerNo, //渠道商户号
  3224. SnType = pos.PosSnType, //机具类型
  3225. StandardDate = pos.ActivationTime, //商户的激活日期
  3226. SnStoreId = pos.StoreId, //SN仓库
  3227. MerBuddyType = puser.MerchantType, //商户创客类型
  3228. RewardType = 1, //奖励类型 1-开机直接奖励,2-开机间接奖励
  3229. RewardTips = "开机奖励", //奖励描述
  3230. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  3231. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  3232. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  3233. RewardDesc = "开机奖励", //奖励描述
  3234. SeoTitle = machineUser.RealName,
  3235. }).Entity;
  3236. db.OpenReward.Add(new OpenReward()
  3237. {
  3238. CreateDate = DateTime.Now,
  3239. UpdateDate = DateTime.Now,
  3240. TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
  3241. TradeDate = DateTime.Now, //达标日期
  3242. UserId = puser.Id, //创客
  3243. BrandId = pos.BrandId, //品牌
  3244. RewardType = 2, //奖励类型
  3245. CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
  3246. DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
  3247. CreditRewardAmount = Prize, //贷记卡交易奖励金额
  3248. RewardDesc = "开机奖励", //奖励描述
  3249. });
  3250. string IdBrand = puser.Id + "_" + pos.BrandId;
  3251. UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
  3252. if (userData == null)
  3253. {
  3254. userData = db.UserMachineData.Add(new UserMachineData()
  3255. {
  3256. IdBrand = IdBrand,
  3257. }).Entity;
  3258. db.SaveChanges();
  3259. }
  3260. userData.OpenProfit += Prize;
  3261. db.SaveChanges();
  3262. //账户入库
  3263. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
  3264. if (account == null)
  3265. {
  3266. account = db.UserAccount.Add(new UserAccount()
  3267. {
  3268. Id = puser.Id,
  3269. UserId = puser.Id,
  3270. }).Entity;
  3271. db.SaveChanges();
  3272. }
  3273. //收支明细入库
  3274. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  3275. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  3276. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  3277. account.BalanceAmount += Prize;
  3278. account.TotalAmount += Prize;
  3279. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  3280. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  3281. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  3282. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  3283. {
  3284. CreateDate = DateTime.Now,
  3285. UpdateDate = DateTime.Now,
  3286. UserId = puser.Id, //创客
  3287. ChangeType = 50, //变动类型
  3288. ProductType = pos.BrandId, //产品类型
  3289. ChangeAmount = Prize, //变更金额
  3290. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  3291. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  3292. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  3293. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  3294. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  3295. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  3296. QueryCount = pos.Id,
  3297. Kind = 3,
  3298. }).Entity;
  3299. db.SaveChanges();
  3300. //发送APP推送消息
  3301. Utils.Instance.PrizePush(puser.Id, Prize);
  3302. }
  3303. #endregion
  3304. }
  3305. }