StatService.cs 190 KB

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