TestHaoDaService.cs 29 KB

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