SIMPosMerchantTradeService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505
  1. using System;
  2. using System.Threading;
  3. using System.Linq;
  4. using System.Data;
  5. using Library;
  6. using MySystem.Models;
  7. using System.Collections.Generic;
  8. using LitJson;
  9. /// <summary>
  10. /// 广电卡交易数据导入
  11. /// </summary>
  12. namespace MySystem
  13. {
  14. public class SIMPosMerchantTradeService
  15. {
  16. public readonly static SIMPosMerchantTradeService Instance = new SIMPosMerchantTradeService();
  17. private SIMPosMerchantTradeService()
  18. {
  19. }
  20. public void Start()//启动
  21. {
  22. Thread thread = new Thread(ImportPostDo); // 广电卡导激活和交易
  23. thread.IsBackground = true;
  24. thread.Start();
  25. // Thread thread1 = new Thread(SIMActDo); // 通过接口获取广电卡激活数据
  26. // thread1.IsBackground = true;
  27. // thread1.Start();
  28. }
  29. public void ImportPostDo()
  30. {
  31. while (true)
  32. {
  33. try
  34. {
  35. string data = RedisDbconn.Instance.RPop<string>("SIMPosMerchantTradeQueue");
  36. if (!string.IsNullOrEmpty(data))
  37. {
  38. string[] dataList = data.Split("#cut#");
  39. string _ExcelPath = dataList[0];
  40. string _Kind = dataList[1];
  41. string checkKey = dataList[2];
  42. string Operator = dataList[3]; // 操作人
  43. int SuccessCount = 0;
  44. int DoCount = 0;
  45. string FullExcelPath = function.getPath(_ExcelPath);
  46. FullExcelPath = FullExcelPath.Replace("//", "/");
  47. DataTable list = new PublicFunction().ExcelToDataTable(FullExcelPath);
  48. int TotalCount = list.Rows.Count;
  49. while (DoCount < list.Rows.Count)
  50. {
  51. WebCMSEntities db = new WebCMSEntities();
  52. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  53. //导激活
  54. if (_Kind == "1")
  55. {
  56. var tran = db.Database.BeginTransaction();
  57. try
  58. {
  59. int Size = 100;
  60. if (list.Rows.Count - DoCount < 100)
  61. {
  62. Size = list.Rows.Count - DoCount;
  63. }
  64. Dictionary<string, int> storeData = new Dictionary<string, int>();
  65. for (int i = DoCount; i < DoCount + Size; i++)
  66. {
  67. DataRow dr = list.Rows[i];
  68. SIMActInfo sIMActInfo = new SIMActInfo
  69. {
  70. OrderNo = dr["订单编码"].ToString(),
  71. CreateDate = dr["订单创建时间"].ToString(),
  72. PhoneNumber = dr["选择号码"].ToString(),
  73. HasFirstCharge = dr["是否有首充"].ToString(),
  74. FirstChargeAmount = dr["首充金额(元)"].ToString(),
  75. Province = dr["号码归属省份"].ToString(),
  76. City = dr["号码归属地市"].ToString(),
  77. ProductName = dr["商品名称"].ToString(),
  78. ActiveName = dr["促销活动名称"].ToString(),
  79. ProductType = dr["商品类型名称"].ToString(),
  80. ActualAmount = dr["实付金额(元)"].ToString(),
  81. OrderStatus = dr["订单状态"].ToString(),
  82. ActStatus = dr["激活状态名称"].ToString(),
  83. ActDate = dr["激活时间"].ToString(),
  84. WorkNo = dr["BOSS员工工号"].ToString(),
  85. AccountName = dr["账号姓名"].ToString(),
  86. SimNo = dr["SIM卡号"].ToString()
  87. };
  88. AddSIMActInfo(sIMActInfo);
  89. SuccessCount += 1;
  90. }
  91. DoCount += Size;
  92. spdb.SaveChanges();
  93. tran.Commit();
  94. if (DoCount >= list.Rows.Count)
  95. {
  96. RedisDbconn.Instance.Set("SIMPosMerchantTradeCheckImport:" + checkKey, "success|" + SuccessCount);
  97. RedisDbconn.Instance.SetExpire("SIMPosMerchantTradeCheckImport:" + checkKey, 60000);
  98. }
  99. }
  100. catch (Exception ex)
  101. {
  102. DoCount = list.Rows.Count;
  103. function.WriteLog(ex.ToString(), "导入广电卡激活数据");
  104. tran.Rollback();
  105. ErrorMsg msg = new ErrorMsg()
  106. {
  107. Time = DateTime.Now,
  108. ErrorContent = ex.ToString(),
  109. };
  110. function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(msg), "导入广电卡激活数据Excel文件异常");
  111. }
  112. tran.Dispose();
  113. }
  114. //导交易
  115. if (_Kind == "2")
  116. {
  117. var tran = db.Database.BeginTransaction();
  118. try
  119. {
  120. int Size = 100;
  121. if (list.Rows.Count - DoCount < 100)
  122. {
  123. Size = list.Rows.Count - DoCount;
  124. }
  125. Dictionary<string, int> storeData = new Dictionary<string, int>();
  126. for (int i = DoCount; i < DoCount + Size; i++)
  127. {
  128. DataRow dr = list.Rows[i];
  129. SIMTradeInfo sIMTradeInfo = new SIMTradeInfo
  130. {
  131. Mobile = dr["用户手机号"].ToString(),
  132. SimNo = dr["SIM卡号"].ToString(),
  133. CreateMonth = dr["入网月份"].ToString(),
  134. SettleMonth = dr["结算月份"].ToString(),
  135. SettleTime = dr["结算账期"].ToString(),
  136. SettleSpace = dr["结算场景"].ToString(),
  137. BusinessType = dr["业务类型"].ToString(),
  138. Province = dr["用户省份"].ToString(),
  139. City = dr["用户地市"].ToString(),
  140. Team = dr["团队归属"].ToString(),
  141. WorkName = dr["行销宝姓名"].ToString(),
  142. WorkNo = dr["行销宝工号"].ToString(),
  143. ProductName = dr["商品名称"].ToString(),
  144. TotalAmount = dr["账单总金额"].ToString(),
  145. InAmount = dr["套内金额"].ToString(),
  146. OutAmount = dr["套外金额"].ToString(),
  147. UserStatus = dr["用户状态"].ToString(),
  148. ChannelCode = dr["渠道编码"].ToString(),
  149. ChannelName = dr["渠道名称"].ToString(),
  150. OrderCreateTime = dr["订单创建时间"].ToString(),
  151. OrderStatus = dr["订单状态"].ToString(),
  152. ActTime = dr["激活时间"].ToString(),
  153. SourceProductName = dr["原订单商品名称"].ToString(),
  154. ProductType = dr["商品类型名称"].ToString(),
  155. ActivityName = dr["促销活动名称"].ToString(),
  156. Percent = dr["分成比例"].ToString(),
  157. OrgDivi = dr["机构分成"].ToString()
  158. };
  159. AddSIMTradeInfo(sIMTradeInfo);
  160. SuccessCount += 1;
  161. }
  162. DoCount += Size;
  163. db.SaveChanges();
  164. tran.Commit();
  165. if (DoCount >= list.Rows.Count)
  166. {
  167. RedisDbconn.Instance.Set("SIMPosMerchantTradeCheckImport:" + checkKey, "success|" + SuccessCount);
  168. RedisDbconn.Instance.SetExpire("SIMPosMerchantTradeCheckImport:" + checkKey, 60000);
  169. }
  170. }
  171. catch (Exception ex)
  172. {
  173. DoCount = list.Rows.Count;
  174. function.WriteLog(ex.ToString(), "导入广电卡交易数据");
  175. tran.Rollback();
  176. ErrorMsg msg = new ErrorMsg()
  177. {
  178. Time = DateTime.Now,
  179. ErrorContent = ex.ToString(),
  180. };
  181. function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(msg), "导入广电卡交易数据Excel文件异常");
  182. }
  183. tran.Dispose();
  184. }
  185. }
  186. }
  187. else
  188. {
  189. Thread.Sleep(5000);
  190. }
  191. }
  192. catch (Exception ex)
  193. {
  194. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "后台导入Excel文件队列异常");
  195. }
  196. }
  197. }
  198. /// <summary>
  199. /// 通过接口获取广电卡激活数据
  200. /// </summary>
  201. public void SIMActDo()
  202. {
  203. while (true)
  204. {
  205. if (DateTime.Now.Hour > 16 && DateTime.Now.Hour < 18)
  206. {
  207. try
  208. {
  209. var time = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
  210. string check = function.ReadInstance("/GetSIMActInfo/check" + time + ".txt");
  211. if (string.IsNullOrEmpty(check))
  212. {
  213. // function.WritePage("/GetSIMActInfo/", "check" + time + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  214. var result = RadioCardHelper.Instance.QueryCardOrderInfo(time, time, "1", "99999");
  215. JsonData jsonObj = JsonMapper.ToObject(result);
  216. if (jsonObj["resultCode"].ToString() == "1")
  217. {
  218. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  219. var tran = spdb.Database.BeginTransaction();
  220. var data = jsonObj["data"]["records"];
  221. for (int i = 0; i < data.Count; i++)
  222. {
  223. var iccId = data[i]["iccId"].ToString();
  224. var bindRecord = spdb.BindRecord.FirstOrDefault(m => m.MerSnNo == iccId) ?? new SpModels.BindRecord();
  225. var merchants = spdb.Merchants.FirstOrDefault(m => m.SnNo == iccId) ?? new SpModels.Merchants();
  226. if (bindRecord.Id == 0 && merchants.Id == 0)
  227. {
  228. // {"orderNo":"B20240319215437195664","orderCreateTime":"03/19/2024 21:54:37","phoneNo":"19238664877","firstCharge":"否","initialChargeAmount":"0.00","province":"贵州省","city":"遵义市","productName":"双百套餐","promotionName":null,"productTypeName":"基础套餐","paidInAmount":"100.00","orderStatus":"已完成","activationStatusName":"已激活","activationTime":"03/19/2024 21:58:23","jobId":"VCH010131087","iccId":"89861500232320195477"}
  229. SIMActInfo sIMActInfo = new SIMActInfo
  230. {
  231. OrderNo = function.CheckNull(data[i]["orderNo"].ToString()), //订单编码
  232. CreateDate = function.CheckNull(data[i]["orderCreateTime"].ToString()), //订单创建时间
  233. PhoneNumber = function.CheckNull(data[i]["phoneNo"].ToString()), //选择号码
  234. HasFirstCharge = function.CheckNull(data[i]["firstCharge"].ToString()), //是否有首充
  235. FirstChargeAmount = function.CheckNull(data[i]["initialChargeAmount"].ToString()), //首充金额(元)
  236. Province = function.CheckNull(data[i]["province"].ToString()), //号码归属省份
  237. City = function.CheckNull(data[i]["city"].ToString()), //号码归属地市
  238. ProductName = function.CheckNull(data[i]["productName"].ToString()), //商品名称
  239. ActiveName = function.CheckNull(data[i]["promotionName"].ToString()), //促销活动名称
  240. ProductType = function.CheckNull(data[i]["productTypeName"].ToString()), //商品类型名称
  241. ActualAmount = function.CheckNull(data[i]["paidInAmount"].ToString()), //实付金额(元)
  242. OrderStatus = function.CheckNull(data[i]["orderStatus"].ToString()), //订单状态
  243. ActStatus = function.CheckNull(data[i]["activationStatusName"].ToString()), //激活状态名称
  244. ActDate = function.CheckNull(data[i]["activationTime"].ToString()), //激活时间
  245. WorkNo = function.CheckNull(data[i]["jobId"].ToString()), //BOSS员工工号
  246. // sIMActInfo.AccountName = data[""].ToString(); //账号姓名
  247. AccountName = "", //账号姓名
  248. SimNo = iccId //SIM卡号
  249. };
  250. // SIMActInfo sIMActInfo = new SIMActInfo();
  251. // sIMActInfo.OrderNo = function.CheckNull(data[i]["orderNo"].ToString()); //订单编码
  252. // sIMActInfo.CreateDate = function.CheckNull(data[i]["orderCreateTime"].ToString()); //订单创建时间
  253. // sIMActInfo.PhoneNumber = function.CheckNull(data[i]["phoneNo"].ToString()); //选择号码
  254. // sIMActInfo.HasFirstCharge = function.CheckNull(data[i]["firstCharge"].ToString()); //是否有首充
  255. // sIMActInfo.FirstChargeAmount = function.CheckNull(data[i]["initialChargeAmount"].ToString()); //首充金额(元)
  256. // sIMActInfo.Province = function.CheckNull(data[i]["province"].ToString()); //号码归属省份
  257. // sIMActInfo.City = function.CheckNull(data[i]["city"].ToString()); //号码归属地市
  258. // sIMActInfo.ProductName = function.CheckNull(data[i]["productName"].ToString()); //商品名称
  259. // sIMActInfo.ActiveName = function.CheckNull(data[i]["promotionName"].ToString()); //促销活动名称
  260. // sIMActInfo.ProductType = function.CheckNull(data[i]["productTypeName"].ToString()); //商品类型名称
  261. // sIMActInfo.ActualAmount = function.CheckNull(data[i]["paidInAmount"].ToString()); //实付金额(元)
  262. // sIMActInfo.OrderStatus = function.CheckNull(data[i]["orderStatus"].ToString()); //订单状态
  263. // sIMActInfo.ActStatus = function.CheckNull(data[i]["activationStatusName"].ToString()); //激活状态名称
  264. // sIMActInfo.ActDate = function.CheckNull(data[i]["activationTime"].ToString()); //激活时间
  265. // sIMActInfo.WorkNo = function.CheckNull(data[i]["jobId"].ToString()); //BOSS员工工号
  266. // // sIMActInfo.AccountName = data[""].ToString(); //账号姓名
  267. // sIMActInfo.AccountName = ""; //账号姓名
  268. // sIMActInfo.SimNo = iccId; //SIM卡号
  269. AddSIMActInfo(sIMActInfo);
  270. }
  271. }
  272. tran.Dispose();
  273. }
  274. }
  275. }
  276. catch (Exception ex)
  277. {
  278. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "获取广电卡激活信息队列异常");
  279. }
  280. }
  281. Thread.Sleep(600000);
  282. }
  283. }
  284. /// <summary>
  285. /// 添加广电卡激活数据
  286. /// </summary>
  287. /// <param name="sIMActInfo"></param>
  288. public void AddSIMActInfo(SIMActInfo sIMActInfo)
  289. {
  290. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  291. string json = "{";
  292. json += "\"OrderNo\":\"" + sIMActInfo.OrderNo + "\",";
  293. json += "\"CreateDate\":\"" + sIMActInfo.CreateDate + "\",";
  294. json += "\"PhoneNumber\":\"" + sIMActInfo.PhoneNumber + "\",";
  295. json += "\"HasFirstCharge\":\"" + sIMActInfo.HasFirstCharge + "\",";
  296. json += "\"FirstChargeAmount\":\"" + sIMActInfo.FirstChargeAmount + "\",";
  297. json += "\"Province\":\"" + sIMActInfo.Province + "\",";
  298. json += "\"City\":\"" + sIMActInfo.City + "\",";
  299. json += "\"ProductName\":\"" + sIMActInfo.ProductName + "\",";
  300. json += "\"ActiveName\":\"" + sIMActInfo.ActiveName + "\",";
  301. json += "\"ProductType\":\"" + sIMActInfo.ProductType + "\",";
  302. json += "\"ActualAmount\":\"" + sIMActInfo.ActualAmount + "\",";
  303. json += "\"OrderStatus\":\"" + sIMActInfo.OrderStatus + "\",";
  304. json += "\"ActStatus\":\"" + sIMActInfo.ActStatus + "\",";
  305. json += "\"ActDate\":\"" + sIMActInfo.ActDate + "\",";
  306. json += "\"WorkNo\":\"" + sIMActInfo.WorkNo + "\",";
  307. json += "\"AccountName\":\"" + sIMActInfo.AccountName + "\",";
  308. json += "\"SimNo\":\"" + sIMActInfo.SimNo + "\"";
  309. json += "}";
  310. spdb.BindRecord.Add(new SpModels.BindRecord()
  311. {
  312. CreateDate = DateTime.Parse(sIMActInfo.CreateDate),
  313. UpdateTime = DateTime.Parse(sIMActInfo.CreateDate), //机具绑定、解绑时间
  314. CreateTime = DateTime.Parse(sIMActInfo.CreateDate), //商户操作时间
  315. MerNewSnNo = sIMActInfo.PhoneNumber, //商户手机号
  316. MerSnNo = sIMActInfo.SimNo, //序列号
  317. MerName = sIMActInfo.AccountName, //商户名称
  318. MerNo = sIMActInfo.PhoneNumber, //商户编号
  319. Remark = sIMActInfo.ProductType,
  320. Field1 = sIMActInfo.Province,
  321. Field2 = sIMActInfo.ActiveName,
  322. Field3 = sIMActInfo.ProductName,
  323. Field4 = sIMActInfo.WorkNo,
  324. Field5 = sIMActInfo.ActStatus,
  325. SeoTitle = sIMActInfo.ActualAmount,
  326. SeoKeyword = sIMActInfo.ActDate,
  327. SeoDescription = json,
  328. ProductType = "14",
  329. Status = 1,
  330. });
  331. spdb.Merchants.Add(new SpModels.Merchants()
  332. {
  333. SnNo = sIMActInfo.SimNo,
  334. CreateTime = DateTime.Parse(sIMActInfo.CreateDate),
  335. UpdateTime = DateTime.Parse(sIMActInfo.CreateDate),
  336. AgentName = sIMActInfo.AccountName,
  337. MerRealName = sIMActInfo.AccountName,
  338. MerMobile = sIMActInfo.PhoneNumber,
  339. MerNo = sIMActInfo.PhoneNumber,
  340. MerName = sIMActInfo.AccountName,
  341. ProductType = "14",
  342. Status = 1,
  343. });
  344. spdb.SaveChanges();
  345. }
  346. /// <summary>
  347. /// 添加广电卡激活数据
  348. /// </summary>
  349. /// <param name="sIMActInfo"></param>
  350. public void AddSIMTradeInfo(SIMTradeInfo sIMTradeInfo)
  351. {
  352. WebCMSEntities db = new WebCMSEntities();
  353. SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities();
  354. string json = "{";
  355. json += "\"Mobile\":\"" + sIMTradeInfo.Mobile + "\",";
  356. json += "\"SimNo\":\"" + sIMTradeInfo.SimNo + "\",";
  357. json += "\"CreateMonth\":\"" + sIMTradeInfo.CreateMonth + "\",";
  358. json += "\"SettleMonth\":\"" + sIMTradeInfo.SettleMonth + "\",";
  359. json += "\"SettleTime\":\"" + sIMTradeInfo.SettleTime + "\",";
  360. json += "\"SettleSpace\":\"" + sIMTradeInfo.SettleSpace + "\",";
  361. json += "\"BusinessType\":\"" + sIMTradeInfo.BusinessType + "\",";
  362. json += "\"Province\":\"" + sIMTradeInfo.Province + "\",";
  363. json += "\"City\":\"" + sIMTradeInfo.City + "\",";
  364. json += "\"Team\":\"" + sIMTradeInfo.Team + "\",";
  365. json += "\"WorkName\":\"" + sIMTradeInfo.WorkName + "\",";
  366. json += "\"WorkNo\":\"" + sIMTradeInfo.WorkNo + "\",";
  367. json += "\"ProductName\":\"" + sIMTradeInfo.ProductName + "\",";
  368. json += "\"TotalAmount\":\"" + sIMTradeInfo.TotalAmount + "\",";
  369. json += "\"InAmount\":\"" + sIMTradeInfo.InAmount + "\",";
  370. json += "\"OutAmount\":\"" + sIMTradeInfo.OutAmount + "\",";
  371. json += "\"UserStatus\":\"" + sIMTradeInfo.UserStatus + "\",";
  372. json += "\"ChannelCode\":\"" + sIMTradeInfo.ChannelCode + "\",";
  373. json += "\"ChannelName\":\"" + sIMTradeInfo.ChannelName + "\",";
  374. json += "\"OrderCreateTime\":\"" + sIMTradeInfo.OrderCreateTime + "\",";
  375. json += "\"OrderStatus\":\"" + sIMTradeInfo.OrderStatus + "\",";
  376. json += "\"ActTime\":\"" + sIMTradeInfo.ActTime + "\",";
  377. json += "\"SourceProductName\":\"" + sIMTradeInfo.SourceProductName + "\",";
  378. json += "\"ProductType\":\"" + sIMTradeInfo.ProductType + "\",";
  379. json += "\"ActivityName\":\"" + sIMTradeInfo.ActivityName + "\",";
  380. json += "\"Percent\":\"" + sIMTradeInfo.Percent + "\",";
  381. json += "\"OrgDivi\":\"" + sIMTradeInfo.OrgDivi + "\"";
  382. json += "}";
  383. bool op = true;
  384. string OrderNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
  385. decimal TotalAmountNum = decimal.Parse(function.CheckNum(numberString: sIMTradeInfo.TotalAmount));
  386. DateTime CreateDate = DateTime.Parse(sIMTradeInfo.OrderCreateTime);
  387. string CheckDate = DateTime.Now.AddMonths(-3).ToString("yyyyMM");
  388. if (int.Parse(sIMTradeInfo.CreateMonth) >= int.Parse(CheckDate)) op = false;
  389. if (sIMTradeInfo.OrderStatus == "待激活") op = false;
  390. if (sIMTradeInfo.UserStatus.Contains("注销") || sIMTradeInfo.UserStatus.Contains("欠费"))
  391. {
  392. op = false;
  393. SimposMerchantInfo checkSimMer = db.SimposMerchantInfo.FirstOrDefault(m => m.KqMerNo == sIMTradeInfo.Mobile && m.KqSnNo == sIMTradeInfo.SimNo);
  394. if (checkSimMer != null)
  395. {
  396. checkSimMer.Status = -1;
  397. if (sIMTradeInfo.UserStatus.Contains("欠费") && checkSimMer.Status != -1)
  398. {
  399. checkSimMer.Status = -2;
  400. }
  401. db.SaveChanges();
  402. }
  403. PosMerchantInfo checkMer = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == sIMTradeInfo.Mobile && m.KqSnNo == sIMTradeInfo.SimNo);
  404. if (checkMer != null)
  405. {
  406. checkMer.Status = -1;
  407. if (sIMTradeInfo.UserStatus.Contains("欠费") && checkMer.Status != -1)
  408. {
  409. checkMer.Status = -2;
  410. }
  411. db.SaveChanges();
  412. }
  413. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == sIMTradeInfo.SimNo);
  414. if (pos != null)
  415. {
  416. pos.Status = -1;
  417. if (sIMTradeInfo.UserStatus.Contains("欠费") && pos.Status != -1)
  418. {
  419. pos.Status = -2;
  420. }
  421. db.SaveChanges();
  422. }
  423. }
  424. if (sIMTradeInfo.UserStatus.Contains("正常"))
  425. {
  426. SimposMerchantInfo checkSimMer = db.SimposMerchantInfo.FirstOrDefault(m => m.KqMerNo == sIMTradeInfo.Mobile && m.KqSnNo == sIMTradeInfo.SimNo);
  427. if (checkSimMer != null)
  428. {
  429. if (checkSimMer.Status == -2) checkSimMer.Status = 0;
  430. db.SaveChanges();
  431. }
  432. PosMerchantInfo checkMer = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == sIMTradeInfo.Mobile && m.KqSnNo == sIMTradeInfo.SimNo);
  433. if (checkMer != null)
  434. {
  435. if (checkMer.Status == -2) checkMer.Status = 1;
  436. db.SaveChanges();
  437. }
  438. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == sIMTradeInfo.SimNo);
  439. if (pos != null && pos.Status < 0)
  440. {
  441. if (pos.Status == -2)
  442. {
  443. pos.Status = 0;
  444. }
  445. db.SaveChanges();
  446. }
  447. }
  448. if (TotalAmountNum > 0 && op)
  449. {
  450. spdb.TradeRecord.Add(new SpModels.TradeRecord()
  451. {
  452. CreateDate = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM-20 HH:mm:ss")), //创建时间
  453. TradeSerialNo = OrderNo, //订单编号
  454. AgentNo = sIMTradeInfo.WorkName + sIMTradeInfo.WorkNo, //一级服务商编号
  455. MerNo = sIMTradeInfo.Mobile, //商户编
  456. TradeSnNo = sIMTradeInfo.SimNo, //sim卡号
  457. ChannelSerial = OrderNo, //请求号
  458. TradeAmount = TotalAmountNum, //账单总金额
  459. TradeStatus = sIMTradeInfo.OrderStatus, //订单状态
  460. TradeDate = sIMTradeInfo.CreateMonth,
  461. TradeTime = CreateDate.ToString("yyyyMMdd"),
  462. BankCardType = "01",
  463. TradeType = "01",
  464. ProductType = "14",
  465. Status = 1,
  466. Field1 = sIMTradeInfo.ProductName,
  467. Field2 = sIMTradeInfo.SourceProductName,
  468. Field3 = sIMTradeInfo.ProductType,
  469. Field4 = sIMTradeInfo.BusinessType,
  470. SeoDescription = json,
  471. });
  472. spdb.SaveChanges();
  473. }
  474. }
  475. }
  476. }