StatService.cs 186 KB

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