StatService.cs 187 KB

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