HomeController.cs 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Diagnostics;
  4. using System.Linq;
  5. using System.Data;
  6. using System.Threading.Tasks;
  7. using Microsoft.AspNetCore.Mvc;
  8. using Microsoft.Extensions.Logging;
  9. using MySystem.PxcModels;
  10. using System.Threading;
  11. using Library;
  12. using LitJson;
  13. using System.Security.Cryptography;
  14. namespace MySystem.Controllers
  15. {
  16. public class HomeController : Controller
  17. {
  18. private readonly ILogger<HomeController> _logger;
  19. public HomeController(ILogger<HomeController> logger)
  20. {
  21. _logger = logger;
  22. }
  23. public IActionResult Index()
  24. {
  25. return View();
  26. }
  27. public IActionResult Error()
  28. {
  29. string isapi = Request.Headers["Api"].ToString();
  30. if (isapi != "1")
  31. {
  32. if (Response.StatusCode == 500)
  33. {
  34. return Redirect("/public/errpage/pc/500.html");
  35. }
  36. else if (Response.StatusCode == 502)
  37. {
  38. return Redirect("/public/errpage/pc/502.html");
  39. }
  40. else if (Response.StatusCode == 404)
  41. {
  42. return Redirect("/public/errpage/pc/404.html");
  43. }
  44. }
  45. return View();
  46. }
  47. // 大盟主标记扫描
  48. public string leaderflag()
  49. {
  50. WebCMSEntities db = new WebCMSEntities();
  51. List<int> ids = new List<int>();
  52. // List<PosCouponRecord> records = db.PosCouponRecord.Where(m => m.FromUserId == 597).ToList();
  53. // foreach(PosCouponRecord record in records)
  54. // {
  55. // ids.Add(record.PosCouponId);
  56. // }
  57. ids.Add(6843);
  58. List<PosCoupons> coupons = db.PosCoupons.Where(m => ids.Contains(m.Id) && m.IsUse == 1).ToList();
  59. foreach (PosCoupons coupon in coupons)
  60. {
  61. PosSns.Add(coupon.ExchangeCode);
  62. }
  63. foreach (PosCoupons coupon in coupons)
  64. {
  65. ChildNo(db, coupon.ExchangeCode, coupon.ExchangeCode, coupon.LeaderUserId);
  66. }
  67. // db.SaveChanges();
  68. db.Dispose();
  69. return "ok";
  70. }
  71. List<string> nos = new List<string>();
  72. private void ChildNo(WebCMSEntities db, string RootCheckNo, string CheckNo, int LeaderUserId)
  73. {
  74. MachineApply apply = db.MachineApply.FirstOrDefault(m => m.SwapSnExpand.Contains(CheckNo));
  75. if(apply != null)
  76. {
  77. int len = 0;
  78. string[] SnList = apply.SwapSnExpand.TrimEnd('\n').Split('\n');
  79. foreach(string sn in SnList)
  80. {
  81. if(PosSns.Contains(sn.Split(':')[0]) || nos.Contains(sn.Split(':')[0]))
  82. {
  83. len += 1;
  84. }
  85. }
  86. Orders order = db.Orders.FirstOrDefault(m => m.Id == apply.QueryCount);
  87. if(order != null)
  88. {
  89. if(!string.IsNullOrEmpty(order.SnNos))
  90. {
  91. if(order.SnNos.Contains(","))
  92. {
  93. string[] SwapSnExpands = order.SnNos.TrimEnd(',').Split(',');
  94. int index = 0;
  95. foreach(string no in SwapSnExpands)
  96. {
  97. if(!nos.Contains(no) && index < len)
  98. {
  99. index += 1;
  100. nos.Add(no);
  101. ChildNo(db, RootCheckNo, no, LeaderUserId);
  102. }
  103. }
  104. }
  105. else
  106. {
  107. string[] SwapSnExpands = order.SnNos.TrimEnd('\n').Split('\n');
  108. int index = 0;
  109. foreach(string no in SwapSnExpands)
  110. {
  111. if(!nos.Contains(no) && index < len)
  112. {
  113. index += 1;
  114. nos.Add(no);
  115. ChildNo(db, RootCheckNo, no, LeaderUserId);
  116. }
  117. }
  118. }
  119. }
  120. else
  121. {
  122. MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == CheckNo) ?? new MachineForSnNo();
  123. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId);
  124. if(pos != null)
  125. {
  126. // pos.LeaderUserId = LeaderUserId;
  127. // Library.function.WriteLog(LeaderUserId + ":" + pos.PosSn + ":" + apply.SwapSnExpand.TrimEnd('\n').Split('\n').Length, "大盟主奖励标记机具");
  128. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  129. Library.function.WriteLog(pos.PosSn + ":" + RootCheckNo + ":" + user.MakerCode + ":" + user.RealName, "大盟主奖励标记机具");
  130. }
  131. }
  132. }
  133. }
  134. else
  135. {
  136. MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == CheckNo) ?? new MachineForSnNo();
  137. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m=>m.Id == forSnNo.SnId);
  138. if(pos != null)
  139. {
  140. // pos.LeaderUserId = LeaderUserId;
  141. // Library.function.WriteLog(LeaderUserId + ":" + pos.PosSn, "大盟主奖励标记机具");
  142. Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  143. Library.function.WriteLog(pos.PosSn + ":" + RootCheckNo + ":" + user.MakerCode + ":" + user.RealName, "大盟主奖励标记机具");
  144. }
  145. }
  146. }
  147. List<string> PosSns = new List<string>();
  148. public string ScanNos()
  149. {
  150. PosSns = new List<string>();
  151. PosSns.Add("00005002681889125851");
  152. WebCMSEntities db = new WebCMSEntities();
  153. foreach(string PosSn in PosSns)
  154. {
  155. ChildNo(db, PosSn, PosSn, 0);
  156. }
  157. db.Dispose();
  158. return "ok";
  159. }
  160. public string test()
  161. {
  162. OpModels.WebCMSEntities db = new OpModels.WebCMSEntities();
  163. List<int> ids = new List<int>();
  164. List<OpModels.ChangeTypes> typelist = db.ChangeTypes.ToList();
  165. List<OpModels.AmountRecord> list = db.AmountRecord.OrderBy(m => m.Id).ToList();
  166. int index = 0;
  167. foreach(OpModels.AmountRecord sub in list)
  168. {
  169. index += 1;
  170. if(!ids.Contains(sub.Id))
  171. {
  172. int OperateType = sub.OperateType;
  173. OpModels.ChangeTypes type = typelist.FirstOrDefault(m => m.Name == sub.SeoDescription) ?? new OpModels.ChangeTypes();
  174. decimal UseAmount = sub.UseAmount;
  175. decimal UseTotalAmt = 0;
  176. decimal UseValidForGetAmount = 0;
  177. decimal UseValidAmount = 0;
  178. if(type.Name == "商城购机" || type.Name == "购买小盟主" || type.Name == "购买运营中心")
  179. {
  180. UseTotalAmt = -UseAmount;
  181. UseValidForGetAmount = UseAmount;
  182. OpModels.AmountRecord same = db.AmountRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.CreateDate >= sub.CreateDate && m.CreateDate <= sub.CreateDate.Value.AddSeconds(5) && m.UseAmount == UseAmount && m.SeoDescription == sub.SeoDescription && m.OperateType == 1) ?? new OpModels.AmountRecord();
  183. ids.Add(same.Id);
  184. }
  185. else
  186. {
  187. if(sub.Version == 1)
  188. {
  189. UseTotalAmt = UseAmount;
  190. }
  191. else if(sub.Version == 2)
  192. {
  193. UseValidForGetAmount = UseAmount;
  194. }
  195. else if(sub.Version == 3)
  196. {
  197. UseValidAmount = UseAmount;
  198. }
  199. else
  200. {
  201. if(sub.OperateType == 1)
  202. {
  203. UseTotalAmt = UseAmount;
  204. }
  205. else
  206. {
  207. UseTotalAmt = -UseAmount;
  208. }
  209. }
  210. }
  211. OpModels.AmountRecordNew add = db.AmountRecordNew.Add(new OpModels.AmountRecordNew()
  212. {
  213. CreateDate = sub.CreateDate,
  214. UpdateDate = sub.UpdateDate,
  215. ChangeTypeId = type.Id,
  216. Remark = sub.SeoDescription,
  217. AfterValidForGetAmount = sub.AfterValidForGetAmount,
  218. AfterTotalAmt = sub.AfterTotalAmt,
  219. AfterValidAmount = sub.AfterValidAmount,
  220. OperateType = OperateType,
  221. AfterAmount = sub.AfterAmount,
  222. BeforeAmount = sub.BeforeAmount,
  223. UseAmount = UseAmount,
  224. UserId = sub.UserId,
  225. UseValidForGetAmount = UseValidForGetAmount,
  226. UseTotalAmt = UseTotalAmt,
  227. UseValidAmount = UseValidAmount,
  228. }).Entity;
  229. if(index % 100 == 0)
  230. {
  231. db.SaveChanges();
  232. }
  233. }
  234. }
  235. db.SaveChanges();
  236. db.Dispose();
  237. return "ok";
  238. }
  239. public string setlee()
  240. {
  241. WebCMSEntities db = new WebCMSEntities();
  242. List<string> poslist = new List<string>();
  243. poslist.Add("00003102722201179816714");
  244. foreach(string PosSn in poslist)
  245. {
  246. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
  247. if(pos != null)
  248. {
  249. string info = "{\"RecordId\":\"\",\"PosId\":\"" + pos.Id + "\",\"Fee\": \"0.6\",\"Kind\": \"2\",\"OpMan\": \"系统\"}";
  250. RedisDbconn.Instance.AddList("SetDepositPostQueue", info);
  251. }
  252. }
  253. db.Dispose();
  254. return "ok";
  255. }
  256. public string lsprize(int id = 0)
  257. {
  258. // StatService.Instance.activePrizeWithoutDeposit6(id);
  259. // WebCMSEntities db = new WebCMSEntities();
  260. // List<string> poslist = new List<string>();
  261. // poslist.Add("N6220Y02004331");
  262. // poslist.Add("N6220Y02004411");
  263. // poslist.Add("N6220Y02006392");
  264. // poslist.Add("N6220Y02008090");
  265. // poslist.Add("N6220Y02014659");
  266. // poslist.Add("N6220Y02016352");
  267. // poslist.Add("N6220Y02018426");
  268. // poslist.Add("N6220Y02009475");
  269. // poslist.Add("N6220Y02009601");
  270. // poslist.Add("N6220Y02009630");
  271. // poslist.Add("N6220Y02010111");
  272. // poslist.Add("N6220Y02010795");
  273. // poslist.Add("N6220Y02011199");
  274. // poslist.Add("N6220Y02011405");
  275. // poslist.Add("N6220Y02011946");
  276. // poslist.Add("N6220Y02172467");
  277. // poslist.Add("N6220Y02172563");
  278. // poslist.Add("N6220Y02172658");
  279. // poslist.Add("N6220Y02172658");
  280. // poslist.Add("N6220Y02007603");
  281. // foreach(string PosSn in poslist)
  282. // {
  283. // PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
  284. // if(pos != null)
  285. // {
  286. // // SycnSpTradeService.Instance.LiShuaActPrize(db, pos, 50);
  287. // StatService.Instance.activePrizeWithoutDeposit6(pos.Id);
  288. // }
  289. // }
  290. // db.Dispose();
  291. return "ok";
  292. }
  293. //金控自备机,补商户信息
  294. public string jkmerinfo(string sn)
  295. {
  296. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  297. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  298. var Bind = spdb.BindRecord.FirstOrDefault(m => m.MerSnNo == sn && m.Field1 == "解绑");
  299. if (Bind != null)
  300. {
  301. PxcModels.MachineForSnNo posFor = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == Bind.MerSnNo) ?? new PxcModels.MachineForSnNo();
  302. PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId);
  303. if (pos != null)
  304. {
  305. pos.BindingState = 1;
  306. pos.BindingTime = Bind.CreateTime;
  307. pos.Status = 0;
  308. PxcModels.MachineForMerNo merFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == Bind.MerNo);
  309. if (merFor == null)
  310. {
  311. merFor = db.MachineForMerNo.Add(new PxcModels.MachineForMerNo()
  312. {
  313. MerNo = Bind.MerNo,
  314. SnId = pos.Id,
  315. }).Entity;
  316. }
  317. else
  318. {
  319. merFor.SnId = pos.Id;
  320. }
  321. db.SaveChanges();
  322. PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
  323. int TopUserId = 0;
  324. if (!string.IsNullOrEmpty(user.ParentNav))
  325. {
  326. TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  327. }
  328. int BrandId = pos.BrandId;
  329. PxcModels.TradeRecord trade = db.TradeRecord.FirstOrDefault(m => m.SnNo == sn) ?? new PxcModels.TradeRecord();
  330. PxcModels.PosMerchantInfo add = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == Bind.MerNo);
  331. if (add == null)
  332. {
  333. if(trade.MerchantId > 0)
  334. {
  335. add = db.PosMerchantInfo.Add(new PxcModels.PosMerchantInfo()
  336. {
  337. CreateDate = Bind.CreateTime,
  338. KqMerNo = Bind.MerNo,
  339. MerchantNo = Bind.MerNo.Length > 16 ? Bind.MerNo.Substring(0, 16) : Bind.MerNo,
  340. Id = trade.MerchantId,
  341. }).Entity;
  342. db.SaveChanges();
  343. }
  344. else
  345. {
  346. add = db.PosMerchantInfo.Add(new PxcModels.PosMerchantInfo()
  347. {
  348. CreateDate = Bind.CreateTime,
  349. KqMerNo = Bind.MerNo,
  350. MerchantNo = Bind.MerNo.Length > 16 ? Bind.MerNo.Substring(0, 16) : Bind.MerNo,
  351. }).Entity;
  352. db.SaveChanges();
  353. }
  354. }
  355. add.UpdateDate = Bind.UpdateTime;
  356. add.TopUserId = TopUserId;
  357. add.BrandId = BrandId;
  358. add.SnStoreId = pos.StoreId;
  359. add.SnType = pos.PosSnType;
  360. add.UserId = pos.UserId;
  361. add.MerStatus = 1;
  362. add.KqSnNo = Bind.MerSnNo;
  363. add.MerIdcardNo = function.CheckNull(Bind.SeoKeyword).ToUpper();
  364. add.MerRealName = Bind.MerName;
  365. add.MerchantMobile = Bind.MerNewSnNo;
  366. add.MerchantName = Bind.MerName;
  367. pos.BindMerchantId = add.Id;
  368. pos.LastMerchantId = add.Id;
  369. db.SaveChanges();
  370. RedisDbconn.Instance.AddList("DepositReturnStatQueue", add.Id.ToString());
  371. PxcModels.Users buser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users();
  372. if(buser.BusinessFlag == 1)
  373. {
  374. bool checkMer = db.BusinessPartnerMerchant.Any(m => m.MerchantId == add.Id);
  375. if(!checkMer)
  376. {
  377. PxcModels.BusinessPartnerPos bpos = db.BusinessPartnerPos.FirstOrDefault(m => m.PosId == pos.Id) ?? new PxcModels.BusinessPartnerPos();
  378. db.BusinessPartnerMerchant.Add(new PxcModels.BusinessPartnerMerchant()
  379. {
  380. CreateDate = DateTime.Now,
  381. MerNo = Bind.MerNo,
  382. MerchantId = add.Id,
  383. PartnerId = bpos.PartnerId,
  384. UserId = pos.BuyUserId,
  385. });
  386. db.SaveChanges();
  387. }
  388. }
  389. }
  390. }
  391. spdb.Dispose();
  392. db.Dispose();
  393. return "ok";
  394. }
  395. public string sycnTrade(int Id)
  396. {
  397. PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
  398. PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == Id);
  399. if(merchant != null)
  400. {
  401. DepositReturnStatService.Instance.DoSomething(db, merchant);
  402. }
  403. return "ok";
  404. }
  405. }
  406. }