TestHaoDaService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text.RegularExpressions;
  5. using MySystem.Models.Main;
  6. using Library;
  7. using LitJson;
  8. using System.Threading;
  9. namespace MySystem
  10. {
  11. /// <summary>
  12. /// 好哒测试服务
  13. /// </summary>
  14. public class TestHaoDaService
  15. {
  16. public readonly static TestHaoDaService Instance = new TestHaoDaService();
  17. private TestHaoDaService()
  18. { }
  19. public void Start()
  20. {
  21. Thread th = new Thread(StartListen);
  22. th.IsBackground = true;
  23. th.Start();
  24. }
  25. public void StartListen()
  26. {
  27. //开户意愿申请
  28. // RedisDbconn.Instance.AddList("AlipayForHaoDaQueue",824);
  29. // RedisDbconn.Instance.AddList("WeChatForHaoDaQueue",824);
  30. // AlipayAddInfo(826);//提交支付宝开户意愿申请单
  31. // AlipayAddInfo(828,"202309011037906510");//查询支付宝开户意愿申请状态
  32. // WeChatAddInfo(826);//提交微信开户意愿申请单
  33. // WeChatAddInfo(825,"2000002424428809");//查询微信开户意愿申请状态
  34. // QueryMerchantStatus(867);//新建商户查询状态
  35. // ConfiemMer(808);//新建商户
  36. // ChangeMerchantCard(1);//商户修改银行卡
  37. // AddOpenDivideAccounts(832); //添加分账方
  38. // QueryAuthStatus(5);//查询实名认证状态
  39. // WeChatFunctionForHD.Instance.QueryAuthMerchant("600955391");
  40. // AlipayFunctionForHD.Instance.AuthOrderAuthQuery("2088820718243322");
  41. // StartProfitShareListen();
  42. // HaoDaHelper.Instance.BindWeChatAppId("1490230", "21622558", AppConfig.Haoda.SubAppId);
  43. // HaoDaHelper.Instance.OrderDivideAccountsQuery("FZ2023110315225748140470708", "1492500"); //查询分账结果
  44. // WebCMSEntities db = new WebCMSEntities();
  45. // List<int> ids = new List<int>();
  46. // ids.Add(7006);
  47. // ids.Add(8848);
  48. // ids.Add(9256);
  49. // ids.Add(9370);
  50. // foreach(int id in ids)
  51. // {
  52. // ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == 8857) ?? new ConsumerOrders();
  53. // MerchantAddInfo merchantAdd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantAddInfo();
  54. // string applyNo = "FZ" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8); //批次号
  55. // string mchtNo = merchantAdd.OutMchtNo; //慧掌柜商户号
  56. // string orderNo = order.SeoTitle; //交易订单号(好哒平台订单号,G开头)
  57. // string acctNo = AppConfig.Haoda.AcctNo; //账户号,分账接收方账户号
  58. // string sacctNo = merchantAdd.MchtNo; //账户号,收款商户号
  59. // string acctType = "0"; //账户类型(0:商户收款账户(大B),1:分账接收方账户(小B))
  60. // decimal hdfee = 0.0038M * order.PayMoney;
  61. // hdfee = decimal.Parse(hdfee.ToString("f2"));
  62. // decimal servicefee = 0.01M * order.PayMoney;
  63. // servicefee = decimal.Parse(servicefee.ToString("f2"));
  64. // decimal amount = order.PayMoney - hdfee - servicefee;
  65. // amount = amount * 100; //金额(分)
  66. // servicefee = servicefee * 100;
  67. // string seviceAmount = servicefee.ToString("f0"); //服务费
  68. // string result = HaoDaHelper.Instance.OrderDivideAccounts(OrderDivideAccountsUtil.AddValue(applyNo, mchtNo, orderNo, acctNo, sacctNo, acctType, amount.ToString().Split('.')[0], seviceAmount));
  69. // }
  70. // db.Dispose();
  71. }
  72. public void StartProfitShareListen()
  73. {
  74. bool op = true;
  75. while (op)
  76. {
  77. try
  78. {
  79. WebCMSEntities db = new WebCMSEntities();
  80. var list = db.ConsumerOrders.Where(m => m.Status == 1 && m.IsAct == 0).OrderByDescending(m => m.Id).ToList();
  81. foreach (var sub in list)
  82. {
  83. ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == sub.Id);
  84. if (order != null)
  85. {
  86. int Status = 2;
  87. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantInfo();
  88. MerchantParamSet set = db.MerchantParamSet.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantParamSet();
  89. MerchantAddInfo merchantAdd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == order.MerchantId) ?? new MerchantAddInfo();
  90. //发起分账
  91. string applyNo = "FZ" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8); //批次号
  92. string mchtNo = merchantAdd.OutMchtNo; //慧掌柜商户号
  93. string orderNo = order.SeoTitle; //交易订单号(好哒平台订单号,G开头)
  94. string acctNo = AppConfig.Haoda.AcctNo; //账户号,分账接收方账户号
  95. string sacctNo = merchantAdd.MchtNo; //账户号,收款商户号
  96. string acctType = "0"; //账户类型(0:商户收款账户(大B),1:分账接收方账户(小B))
  97. decimal amount = order.PayMoney * (1M - 0.0038M) * 100;
  98. string result = HaoDaHelper.Instance.OrderDivideAccounts(OrderDivideAccountsUtil.AddValue(applyNo, mchtNo, orderNo, acctNo, sacctNo, acctType, amount.ToString().Split('.')[0], "0"));
  99. if(result.Contains("\"resultCode\":\"0\"") && result.Contains("分账金额不足"))
  100. {
  101. Status = 1;
  102. }
  103. order.Status = Status;
  104. }
  105. }
  106. db.SaveChanges();
  107. db.Dispose();
  108. }
  109. catch (Exception ex)
  110. {
  111. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "好哒分账队列异常");
  112. }
  113. Thread.Sleep(2000);
  114. }
  115. }
  116. //新建商户查询状态
  117. public void QueryMerchantStatus(int MerchantId)
  118. {
  119. WebCMSEntities db = new WebCMSEntities();
  120. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  121. var returnInfo = HaoDaHelper.Instance.QueryMerchantStatus(HaoDaHelper.BrhCode, AddInfo.MchtNo);
  122. // string result = HaoDaHelper.Instance.AddNewMerchant(AddNewMerchantSetUtil.SetValue(AddInfo));
  123. db.Dispose();
  124. }
  125. //提交支付宝开户意愿申请单
  126. public void AlipayAddInfo(int Id)
  127. {
  128. try
  129. {
  130. WebCMSEntities db = new WebCMSEntities();
  131. MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
  132. string result = AlipayFunctionForHD.Instance.AuthOrderCreate(info, info.AlipayAuthToken);
  133. JsonData jsonObj = JsonMapper.ToObject(result);
  134. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  135. reqdic.Add("Id", Id); // 商户Id
  136. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  137. LogHelper.Instance.WriteLog(req, "提交支付宝商户意愿申请单");
  138. Dictionary<string, string> headdic = HaoDaHelper.Instance.GetHeader(req);
  139. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  140. LogHelper.Instance.WriteLog("请求参数\n" + req, "提交支付宝商户意愿申请单");
  141. LogHelper.Instance.WriteLog(result, "提交支付宝商户意愿申请单");
  142. if (jsonObj["alipay_merchant_indirect_authorder_create_response"]["code"].ToString() == "10000")
  143. {
  144. LogHelper.Instance.WriteLog("success", "提交支付宝商户意愿申请单");
  145. string order_no = jsonObj["alipay_merchant_indirect_authorder_create_response"]["order_no"].ToString();
  146. // RedisDbconn.Instance.AddList("AlipayResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"order_no\":\"" + order_no + "\"}");
  147. LogHelper.Instance.WriteLog("end", "提交支付宝商户意愿申请单");
  148. }
  149. else
  150. {
  151. LogHelper.Instance.WriteLog("false", "提交支付宝商户意愿申请单");
  152. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  153. info.QueryCount = -1;
  154. merchant.QueryCount = -1;
  155. info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_create_response"]["msg"].ToString();
  156. LogHelper.Instance.WriteLog("end", "提交支付宝商户意愿申请单");
  157. db.SaveChanges();
  158. }
  159. db.Dispose();
  160. }
  161. catch (Exception ex)
  162. {
  163. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "支付宝开户意愿申请异常");
  164. }
  165. }
  166. //查询支付宝开户意愿申请状态
  167. public void AlipayAddInfo(int Id, string OrderNo)
  168. {
  169. try
  170. {
  171. LogHelper.Instance.WriteLog("start", "查询支付宝商户意愿申请状态");
  172. WebCMSEntities db = new WebCMSEntities();
  173. MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
  174. string result = AlipayFunctionForHD.Instance.AuthOrderQuery(OrderNo);
  175. JsonData jsonObj = JsonMapper.ToObject(result);
  176. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  177. reqdic.Add("Id", Id); // 商户Id
  178. reqdic.Add("OrderNo", OrderNo); // 商户Id
  179. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  180. LogHelper.Instance.WriteLog(req, "查询支付宝商户意愿申请状态");
  181. Dictionary<string, string> headdic = HaoDaHelper.Instance.GetHeader(req);
  182. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  183. LogHelper.Instance.WriteLog("请求参数\n" + req, "查询支付宝商户意愿申请状态");
  184. LogHelper.Instance.WriteLog(result, "查询支付宝商户意愿申请状态");
  185. if (jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["code"].ToString() == "10000")
  186. {
  187. LogHelper.Instance.WriteLog("start1", "查询支付宝商户意愿申请状态");
  188. string order_status = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["order_status"].ToString();
  189. if (order_status == "CONTACT_CONFIRM")
  190. {
  191. LogHelper.Instance.WriteLog("start1", "查询支付宝商户意愿申请状态");
  192. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  193. info.QueryCount = 1;
  194. merchant.QueryCount = 1;
  195. info.AlipayRemark = "";
  196. info.AlipaySignUrl = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["qr_code"].ToString();
  197. db.SaveChanges();
  198. // RedisDbconn.Instance.AddList("HaoDaAuthQueryHelper", "{\"MerchantId\":\"" + Id + "\",\"MchtNo\":\"" + info.MchtNo + "\",\"StoreNo\":\"" + info.StoreNo + "\"}");
  199. LogHelper.Instance.WriteLog("start1end", "查询支付宝商户意愿申请状态");
  200. }
  201. else if (order_status == "AUDIT_REJECT" || order_status == "AUDIT_FREEZE")
  202. {
  203. LogHelper.Instance.WriteLog("start2", "查询支付宝商户意愿申请状态");
  204. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  205. info.QueryCount = -1;
  206. merchant.QueryCount = -1;
  207. info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["msg"].ToString();
  208. LogHelper.Instance.WriteLog("start2end", "查询支付宝商户意愿申请状态");
  209. db.SaveChanges();
  210. }
  211. else if (order_status == "AUDIT_PASS")
  212. {
  213. LogHelper.Instance.WriteLog("start2", "查询支付宝商户意愿申请状态");
  214. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  215. info.QueryCount = 2;
  216. merchant.QueryCount = 2;
  217. info.AlipayRemark = "";
  218. LogHelper.Instance.WriteLog("start2end", "查询支付宝商户意愿申请状态");
  219. db.SaveChanges();
  220. }
  221. // else
  222. // {
  223. // RedisDbconn.Instance.AddList("AlipayResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"order_no\":\"" + OrderNo + "\"}");
  224. // }
  225. }
  226. else
  227. {
  228. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  229. info.QueryCount = -1;
  230. merchant.QueryCount = -1;
  231. info.AlipayRemark = jsonObj["alipay_merchant_indirect_authorder_querystatus_response"]["msg"].ToString();
  232. db.SaveChanges();
  233. }
  234. db.Dispose();
  235. }
  236. catch (Exception ex)
  237. {
  238. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "支付宝开户意愿申请异常");
  239. }
  240. }
  241. //提交微信开户意愿申请单
  242. public void WeChatAddInfo(int Id)
  243. {
  244. try
  245. {
  246. WebCMSEntities db = new WebCMSEntities();
  247. MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
  248. string result = WeChatFunctionForHD.Instance.MerchantApply(info);
  249. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  250. reqdic.Add("Id", Id); // 商户Id
  251. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  252. LogHelper.Instance.WriteLog(req, "提交微信商户意愿申请单");
  253. Dictionary<string, string> headdic = HaoDaHelper.Instance.GetHeader(req);
  254. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  255. LogHelper.Instance.WriteLog("请求参数\n" + req, "提交微信商户意愿申请单");
  256. LogHelper.Instance.WriteLog(result, "提交微信商户意愿申请单");
  257. if (result.Contains("\"applyment_id\":"))
  258. {
  259. LogHelper.Instance.WriteLog("success", "提交微信商户意愿申请单");
  260. JsonData json = JsonMapper.ToObject(result);
  261. string applyment_id = json["applyment_id"].ToString();
  262. // RedisDbconn.Instance.AddList("WeChatResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"ApplymentId\":\"" + applyment_id + "\"}");
  263. LogHelper.Instance.WriteLog("end", "提交微信商户意愿申请单");
  264. }
  265. else if (result.Contains("\"message\":"))
  266. {
  267. LogHelper.Instance.WriteLog("false", "提交微信商户意愿申请单");
  268. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  269. JsonData jsonObj = JsonMapper.ToObject(result);
  270. info.Status = -1;
  271. merchant.Status = -1;
  272. info.WeChatRemark = jsonObj["message"].ToString();
  273. LogHelper.Instance.WriteLog("end", "提交微信商户意愿申请单");
  274. db.SaveChanges();
  275. }
  276. db.Dispose();
  277. }
  278. catch (Exception ex)
  279. {
  280. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "微信开户意愿申请异常");
  281. }
  282. }
  283. //查询微信开户意愿申请状态
  284. public void WeChatAddInfo(int Id, string ApplymentId)
  285. {
  286. try
  287. {
  288. WebCMSEntities db = new WebCMSEntities();
  289. MerchantAddInfo info = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantAddInfo();
  290. string result = WeChatFunctionForHD.Instance.QueryMerchant(ApplymentId);
  291. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  292. reqdic.Add("Id", Id); // 商户Id
  293. reqdic.Add("ApplymentId", ApplymentId); // 商户Id
  294. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  295. LogHelper.Instance.WriteLog(req, "提交微信商户意愿申请单");
  296. Dictionary<string, string> headdic = HaoDaHelper.Instance.GetHeader(req);
  297. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  298. LogHelper.Instance.WriteLog("请求参数\n" + req, "提交微信商户意愿申请单");
  299. JsonData jsonObj = JsonMapper.ToObject(result);
  300. if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_WAITTING_FOR_CONFIRM_CONTACT")
  301. {
  302. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  303. info.Status = 1;
  304. merchant.Status = 1;
  305. info.WeChatRemark = "";
  306. info.WeChatSignUrl = jsonObj["qrcode_data"].ToString();
  307. db.SaveChanges();
  308. // RedisDbconn.Instance.AddList("HaoDaAuthQueryHelper", "{\"MerchantId\":\"" + Id + "\",\"MchtNo\":\"" + info.MchtNo + "\",\"StoreNo\":\"" + info.StoreNo + "\"}");
  309. }
  310. else if (jsonObj["applyment_state"].ToString() == "APPLYMENT_STATE_REJECTED")
  311. {
  312. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == Id) ?? new MerchantInfo();
  313. info.Status = -1;
  314. merchant.Status = -1;
  315. info.WeChatRemark = jsonObj["reject_reason"].ToString();
  316. db.SaveChanges();
  317. }
  318. // else
  319. // {
  320. // RedisDbconn.Instance.AddList("WeChatResultForHaoDaQueue", "{\"MerchantId\":\"" + Id + "\",\"ApplymentId\":\"" + ApplymentId + "\"}");
  321. // }
  322. db.Dispose();
  323. }
  324. catch (Exception ex)
  325. {
  326. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "微信开户意愿申请异常");
  327. }
  328. }
  329. //添加分账接收方账户
  330. public void AddOpenDivideAccounts(int MerchantId)
  331. {
  332. WebCMSEntities db = new WebCMSEntities();
  333. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  334. string result = HaoDaHelper.Instance.AddOpenDivideAccounts(AddOpenDivideAccountsUtil.AddValue(AddInfo));
  335. db.Dispose();
  336. }
  337. public void ConfiemMer(int MerchantId)
  338. {
  339. WebCMSEntities db = new WebCMSEntities();
  340. Models.Main1.WebCMSEntities db1 = new Models.Main1.WebCMSEntities();
  341. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  342. MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
  343. if (AddInfo != null && merchant != null)
  344. {
  345. string BusinessCode = AddInfo.BusinessCode;
  346. if (string.IsNullOrEmpty(BusinessCode))
  347. {
  348. BusinessCode = "LKB" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(5);
  349. AddInfo.BusinessCode = BusinessCode;
  350. }
  351. string pwd = AddInfo.MobilePhone.Substring(5);
  352. merchant.LoginPwd = function.MD532(pwd);
  353. MerchantParamSet query = db.MerchantParamSet.FirstOrDefault(m => m.Id == MerchantId);
  354. if (query == null)
  355. {
  356. query = new MerchantParamSet();
  357. query.IsAll = 1;
  358. db.MerchantParamSet.Add(query);
  359. db.SaveChanges();
  360. }
  361. MerchantForMobile merchantForMobile = db.MerchantForMobile.FirstOrDefault(m => m.Mobile == AddInfo.MobilePhone);
  362. if (merchantForMobile == null)
  363. {
  364. merchantForMobile = db.MerchantForMobile.Add(new MerchantForMobile()
  365. {
  366. Mobile = AddInfo.MobilePhone,
  367. }).Entity;
  368. db.SaveChanges();
  369. }
  370. merchantForMobile.MerchantId = MerchantId;
  371. db.SaveChanges();
  372. Models.Main1.MerchantLoginInfo info = db1.MerchantLoginInfo.FirstOrDefault(m => m.LoginMobile == AddInfo.MobilePhone);
  373. if (info == null)
  374. {
  375. info = db1.MerchantLoginInfo.Add(new Models.Main1.MerchantLoginInfo()
  376. {
  377. LoginMobile = AddInfo.MobilePhone,
  378. }).Entity;
  379. db1.SaveChanges();
  380. }
  381. info.LoginPwd = function.MD532(pwd);
  382. db1.SaveChanges();
  383. Models.Main1.MerchantAccountLinkInfo infolink = db1.MerchantAccountLinkInfo.FirstOrDefault(m => m.LoginId == info.Id && m.MerchantId == MerchantId && m.Kind == 2);
  384. if (infolink == null)
  385. {
  386. infolink = db1.MerchantAccountLinkInfo.Add(new Models.Main1.MerchantAccountLinkInfo()
  387. {
  388. LoginId = info.Id,
  389. MerchantId = MerchantId,
  390. Kind = 2,
  391. }).Entity;
  392. db1.SaveChanges();
  393. }
  394. if (AddInfo.Status <= 0)
  395. {
  396. //好哒新建商户
  397. string result = HaoDaHelper.Instance.AddNewMerchant(AddNewMerchantSetUtil.SetValue(AddInfo));
  398. JsonData jsonObj = JsonMapper.ToObject(result);
  399. //创建成功
  400. if (jsonObj["resultCode"].ToString() == "1")
  401. {
  402. AddInfo.WeChatRemark = "";
  403. if (string.IsNullOrEmpty(AddInfo.MchtNo))
  404. {
  405. AddInfo.MchtNo = jsonObj["data"]["mchtNo"].ToString();
  406. }
  407. AddInfo.Status = 0;
  408. merchant.Status = 0;
  409. db.SaveChanges();
  410. QueryMerchantStatus queryMerchantStatus = new QueryMerchantStatus();
  411. queryMerchantStatus.MerchantId = MerchantId.ToString();
  412. queryMerchantStatus.MerchantNo = AddInfo.MchtNo;
  413. // RedisDbconn.Instance.AddList("WeChatSignHdQueue", queryMerchantStatus);
  414. }
  415. //创建失败
  416. else
  417. {
  418. AddInfo.Status = -1;
  419. merchant.Status = -1;
  420. AddInfo.WeChatRemark = jsonObj["errorDesc"].ToString();
  421. // if (string.IsNullOrEmpty(AddInfo.MchtNo))
  422. // {
  423. // if (jsonObj.ToJson().Contains("mchtNo"))
  424. // {
  425. // AddInfo.MchtNo = jsonObj["data"]["mchtNo"].ToString();
  426. // }
  427. // }
  428. db.SaveChanges();
  429. }
  430. }
  431. }
  432. db.Dispose();
  433. db1.Dispose();
  434. }
  435. //商户开通分账
  436. public void OpenDivideAccounts(int MerchantId)
  437. {
  438. WebCMSEntities db = new WebCMSEntities();
  439. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  440. string result = HaoDaHelper.Instance.OpenDivideAccounts(AddInfo.OutMchtNo, AddInfo.StoreNo);
  441. db.Dispose();
  442. }
  443. //分账接收方签约
  444. public void DivideAccountsSign(int MerchantId)
  445. {
  446. WebCMSEntities db = new WebCMSEntities();
  447. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  448. string result = HaoDaHelper.Instance.DivideAccountsSign("230817000000000278", AddInfo.OutMchtNo, AddInfo.StoreNo);
  449. db.Dispose();
  450. }
  451. //查询实名认证状态
  452. public void QueryAuthStatus(int MerchantId)
  453. {
  454. WebCMSEntities db = new WebCMSEntities();
  455. MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  456. string result = HaoDaHelper.Instance.QueryAuthStatus(AddInfo.OutMchtNo, AddInfo.StoreNo);
  457. db.Dispose();
  458. }
  459. //商户修改银行卡
  460. public void ChangeMerchantCard(int MerchantId)
  461. {
  462. WebCMSEntities db = new WebCMSEntities();
  463. // MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == MerchantId);
  464. // var request = TestChangeMerchantCardSetUtil.SetValue(AddInfo);
  465. // JsonData Infos = JsonMapper.ToObject(HaoDaHelper.Instance.ChangeMerchantCard(request));
  466. // JsonData results = JsonMapper.ToObject(HaoDaHelper.Instance.QueryChangeCardStatus(AddInfo.MchtNo, Infos["taskId"].ToString()));
  467. //TODO:修改结算卡变更商户相关信息
  468. // AccountNumber
  469. // BankName
  470. // BankBranchId
  471. // BankAddressCode
  472. // BankAccountType
  473. // OpenUnionNo
  474. // OpenCollectBankCode
  475. // OpenBankRegionCode
  476. // OpenBankAccout
  477. // OpenBankAccName
  478. // ZbankRegionCode
  479. // ZBankNo
  480. db.Dispose();
  481. }
  482. public void refund()
  483. {
  484. Thread th = new Thread(refunddo);
  485. th.IsBackground = true;
  486. th.Start();
  487. }
  488. public void refunddo()
  489. {
  490. for(int month = 10; month <= 11; month ++)
  491. {
  492. for(int day = 1; day <= 31; day ++)
  493. {
  494. string content = function.ReadInstance("/log/好哒聚合支付退款/2023/" + month + "/" + day + "/content.log");
  495. if(!string.IsNullOrEmpty(content))
  496. {
  497. content = content.Replace("\n\n\n", "####");
  498. content = content.Replace("\n", "");
  499. content = content.Replace("####", "\n");
  500. MatchCollection mc = Regex.Matches(content, "请求参数.*?退款次数超出限制");
  501. foreach(Match m in mc)
  502. {
  503. string mchtNo = Regex.Match(m.Value, "\"mchtNo\":\".*?\"").Value.Replace("\"mchtNo\":\"", "").Replace("\"", "");
  504. string storeNo = Regex.Match(m.Value, "\"storeNo\":\".*?\"").Value.Replace("\"storeNo\":\"", "").Replace("\"", "");
  505. string outOrderNo = Regex.Match(m.Value, "\"outOrderNo\":\".*?\"").Value.Replace("\"outOrderNo\":\"", "").Replace("\"", "");
  506. string refundAmount = Regex.Match(m.Value, "\"refundAmount\":\".*?\"").Value.Replace("\"refundAmount\":\"", "").Replace("\"", "");
  507. function.WriteLog("mchtNo:" + mchtNo + ";storeNo:" + storeNo + ";outOrderNo:" + outOrderNo + ";refundAmount:" + refundAmount + ";", "补充退款日志");
  508. var info = HaoDaHelper.Instance.AggregatedPayRefund(mchtNo, storeNo, "HDTK" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8), outOrderNo, refundAmount);
  509. function.WriteLog(info + "\n\n", "补充退款日志");
  510. Thread.Sleep(1000);
  511. }
  512. }
  513. }
  514. }
  515. }
  516. }
  517. }