TestHaoDaService.cs 26 KB

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