HaoDaHelper.cs 52 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969
  1. using System.Net.Mime;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Security.Cryptography;
  6. using System.Text;
  7. using Library;
  8. using System.Net;
  9. using System.IO;
  10. using Aop.Api.Util;
  11. using LitJson;
  12. namespace MySystem
  13. {
  14. /// <summary>
  15. /// 好哒相关接口
  16. /// </summary>
  17. public class HaoDaHelper
  18. {
  19. public readonly static HaoDaHelper Instance = new HaoDaHelper();
  20. private HaoDaHelper()
  21. {
  22. }
  23. #region 盒易付
  24. //测试环境
  25. // string BoxRequestUrl = "https://openapi-test.iboxpay.com";
  26. // string BoxAppId = "AT7317781468267548672";
  27. // string BoxAppSecret = "OfWuHQdhQfnE8NaF4xdtgk4B9CYqnbri";
  28. // string BoxPublicKey = "";
  29. // string BrhCode = "001040";
  30. //生产环境
  31. string BoxRequestUrl = "https://openapi.iboxpay.com";
  32. string BoxAppId = "AP7175619323825451008";
  33. string BoxAppSecret = "hUfR53gdjyfiZTBR5bILanMqRD1dXD7y";
  34. string BoxPublicKey = "";
  35. public static string BrhCode = "030145";
  36. // string BoxRequestUrl = "https://openapi.iboxpay.com";
  37. // string BoxAppId = "AP8322645764893728768";
  38. // string BoxAppSecret = "je1TElprp3jzWETsG3FcWqtmpreEHqZS";
  39. // string BoxPublicKey = "";
  40. // public static string BrhCode = "";
  41. /// <summary>
  42. /// 新创建商户
  43. /// </summary>
  44. /// <param name="request"></param>
  45. /// <returns></returns>
  46. public string AddNewMerchant(AddNewMerchant request, int BrandId = 0)
  47. {
  48. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  49. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  50. // request.brh = BrhCode;
  51. // request.oprInvitedCode = "T1715836";
  52. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒新创建商户");
  53. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  54. LogHelper.Instance.WriteLog(req, "好哒新创建商户");
  55. Dictionary<string, string> headdic = GetHeader(req);
  56. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  57. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒新创建商户");
  58. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒新创建商户");
  59. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒新创建商户");
  60. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
  61. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒新创建商户");
  62. return result;
  63. }
  64. /// <summary>
  65. /// 查询商户审核状态
  66. /// </summary>
  67. /// <param name="instId">机构编号</param>
  68. /// <param name="mchtNo">收款商户号</param>
  69. /// <returns></returns>
  70. public string QueryMerchantStatus(string instId, string mchtNo, int BrandId = 0)
  71. {
  72. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  73. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  74. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒查询商户审核状态");
  75. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  76. reqdic.Add("instId", instId);
  77. reqdic.Add("mchtNo", mchtNo);
  78. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  79. LogHelper.Instance.WriteLog(req, "好哒查询商户审核状态");
  80. Dictionary<string, string> headdic = GetHeader(req);
  81. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  82. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒查询商户审核状态");
  83. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒查询商户审核状态");
  84. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", "好哒查询商户审核状态");
  85. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", req, headdic);
  86. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒查询商户审核状态");
  87. return result;
  88. }
  89. /// <summary>
  90. /// 查询实名认证状态
  91. /// </summary>
  92. /// <param name="mchtNo">慧掌柜商户号</param>
  93. /// <param name="storeNo">慧掌柜门店号</param>
  94. /// <returns></returns>
  95. public string QueryAuthStatus(string mchtNo, string storeNo, int BrandId = 0)
  96. {
  97. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  98. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  99. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒查询实名认证状态");
  100. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  101. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  102. reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
  103. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  104. LogHelper.Instance.WriteLog(req, "好哒查询实名认证状态");
  105. Dictionary<string, string> headdic = GetHeader(req);
  106. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  107. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒查询实名认证状态");
  108. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒查询实名认证状态");
  109. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/wechat/queryVerifiedResult.json", "好哒查询实名认证状态");
  110. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/wechat/queryVerifiedResult.json", req, headdic);
  111. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒查询实名认证状态");
  112. return result;
  113. }
  114. /// <summary>
  115. /// 查询实名认证二维码
  116. /// </summary>
  117. /// <param name="mchtNo">慧掌柜商户号</param>
  118. /// <param name="storeNo">慧掌柜门店号</param>
  119. /// <returns></returns>
  120. public string QueryAuthQRcode(string mchtNo, string storeNo, int BrandId = 0)
  121. {
  122. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  123. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  124. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒查询实名认证二维码");
  125. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  126. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  127. reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
  128. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  129. LogHelper.Instance.WriteLog(req, "好哒查询实名认证二维码");
  130. Dictionary<string, string> headdic = GetHeader(req);
  131. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  132. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒查询实名认证二维码");
  133. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒查询实名认证二维码");
  134. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/wechat/queryVerifiedQrcode.json", "好哒查询实名认证二维码");
  135. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/wechat/queryVerifiedQrcode.json", req, headdic);
  136. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒查询实名认证二维码");
  137. return result;
  138. }
  139. /// <summary>
  140. /// 微信公众号和小程序支付接口
  141. /// </summary>
  142. /// <param name="mchtNo">盒子的商户编号</param>
  143. /// <param name="storeNo">盒子的门店编码</param>
  144. /// <param name="outOrderNo">商户订单号</param>
  145. /// <param name="transAmount">交易金额,单位:分</param>
  146. /// <param name="callbackUrl">交易完成之后,商户接收交易结果通知的地址</param>
  147. /// <param name="subOpenId">用户子标识</param>
  148. /// <param name="confirmCode">支付确认码</param>
  149. /// <param name="subAppId">公众号或者小程序appId</param>
  150. /// <param name="subAppIdType">对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序</param>
  151. /// <param name="ledgerModel">分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段</param>
  152. /// <returns></returns>
  153. public string WeChatPay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode, string subAppId, string subAppIdType, string ledgerModel, int BrandId = 0)
  154. {
  155. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  156. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  157. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒微信公众号和小程序支付");
  158. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  159. reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
  160. reqdic.Add("storeNo", storeNo); //盒子的门店编码
  161. reqdic.Add("outOrderNo", outOrderNo); //商户订单号
  162. reqdic.Add("transAmount", transAmount); //交易金额,单位:分
  163. reqdic.Add("callbackUrl", callbackUrl); //交易完成之后,商户接收交易结果通知的地址
  164. reqdic.Add("subOpenId", subOpenId); //用户子标识
  165. reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
  166. reqdic.Add("subAppId", subAppId); //公众号或者小程序appId
  167. reqdic.Add("subAppIdType", subAppIdType); //subAppId 对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序
  168. reqdic.Add("ledgerModel", ledgerModel); //分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段
  169. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  170. LogHelper.Instance.WriteLog(req, "好哒微信公众号和小程序支付");
  171. Dictionary<string, string> headdic = GetHeader(req);
  172. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  173. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒微信公众号和小程序支付");
  174. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒微信公众号和小程序支付");
  175. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/unitedtrade/wechat_js_pay", "好哒微信公众号和小程序支付");
  176. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
  177. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒微信公众号和小程序支付");
  178. return result;
  179. }
  180. /// <summary>
  181. /// 支付宝服务窗支付接口
  182. /// </summary>
  183. /// <param name="mchtNo">盒子的商户编号</param>
  184. /// <param name="storeNo">盒子的门店编码</param>
  185. /// <param name="outOrderNo">商户订单号</param>
  186. /// <param name="transAmount">交易金额,单位:分</param>
  187. /// <param name="callbackUrl">交易完成之后,商户接收交易结果通知的地址</param>
  188. /// <param name="subOpenId">支付宝用户标识</param>
  189. /// <param name="confirmCode">支付确认码,由4位纯数字组成,每次请求时随机生成</param>
  190. /// <returns></returns>
  191. public string Alipay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode, int BrandId = 0)
  192. {
  193. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  194. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  195. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒支付宝服务窗支付");
  196. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  197. reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
  198. reqdic.Add("storeNo", storeNo); //盒子的门店编码
  199. reqdic.Add("outOrderNo", outOrderNo); //商户订单号
  200. reqdic.Add("transAmount", transAmount); //交易金额,单位:分
  201. reqdic.Add("callbackUrl", callbackUrl); //交易完成之后,商户接收交易结果通知的地址
  202. reqdic.Add("subOpenId", subOpenId); //支付宝用户标识
  203. reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
  204. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  205. LogHelper.Instance.WriteLog(req, "好哒支付宝服务窗支付");
  206. Dictionary<string, string> headdic = GetHeader(req);
  207. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  208. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒支付宝服务窗支付");
  209. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒支付宝服务窗支付");
  210. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/unitedtrade/wechat_js_pay", "好哒支付宝服务窗支付");
  211. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
  212. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒支付宝服务窗支付");
  213. return result;
  214. }
  215. /// <summary>
  216. /// 聚合支付退款接口
  217. /// </summary>
  218. /// <param name="mchtNo">盒子的商户编号</param>
  219. /// <param name="storeNo">盒子的门店编号</param>
  220. /// <param name="outRefundNo">商户退款订单号</param>
  221. /// <param name="outOrderNo">商户支付订单号</param>
  222. /// <param name="refundAmount">退款金额,单位:分</param>
  223. /// <returns></returns>
  224. public string AggregatedPayRefund(string mchtNo, string storeNo, string outRefundNo, string outOrderNo, string refundAmount, int BrandId = 0)
  225. {
  226. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  227. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  228. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒聚合支付退款");
  229. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  230. reqdic.Add("mchtNo", mchtNo); // 盒子的商户编号
  231. reqdic.Add("storeNo", storeNo); // 盒子的门店编号
  232. reqdic.Add("outRefundNo", outRefundNo); //32 商户退款订单号
  233. reqdic.Add("outOrderNo", outOrderNo); // 商户支付订单号
  234. reqdic.Add("refundAmount", refundAmount); //10 退款金额,单位:分
  235. reqdic.Add("refundReason", "门店消费补贴"); //退款原因
  236. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  237. LogHelper.Instance.WriteLog(req, "好哒聚合支付退款");
  238. Dictionary<string, string> headdic = GetHeader(req);
  239. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  240. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒聚合支付退款");
  241. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒聚合支付退款");
  242. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/unitedtrade/refund", "好哒聚合支付退款");
  243. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/unitedtrade/refund", req, headdic);
  244. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒聚合支付退款");
  245. return result;
  246. }
  247. /// <summary>
  248. /// 开通分账功能
  249. /// </summary>
  250. /// <param name="mchtNo">慧掌柜商户号(进件接口返回的outMchtNo字段)</param>
  251. /// <param name="storeNo">慧掌柜门店号</param>
  252. /// <returns></returns>
  253. public string OpenDivideAccounts(string mchtNo, string storeNo, int BrandId = 0)
  254. {
  255. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  256. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  257. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒开通分账");
  258. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  259. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  260. reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
  261. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  262. LogHelper.Instance.WriteLog(req, "好哒开通分账");
  263. Dictionary<string, string> headdic = GetHeader(req);
  264. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  265. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒开通分账");
  266. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒开通分账");
  267. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/mcht/reg", "好哒开通分账");
  268. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/mcht/reg", req, headdic);
  269. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒开通分账");
  270. return result;
  271. }
  272. /// <summary>
  273. /// 分账接收方签约
  274. /// </summary>
  275. /// <param name="acctNo">账户号</param>
  276. /// <param name="mchtNo">慧掌柜商户号</param>
  277. /// <param name="storeNo">慧掌柜门店号</param>
  278. /// <returns></returns>
  279. public string DivideAccountsSign(string acctNo, string mchtNo, string storeNo, int BrandId = 0)
  280. {
  281. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  282. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  283. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒分账接收方签约");
  284. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  285. reqdic.Add("acctNo", acctNo); // 账户号
  286. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  287. reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
  288. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  289. LogHelper.Instance.WriteLog(req, "好哒分账接收方签约");
  290. Dictionary<string, string> headdic = GetHeader(req);
  291. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  292. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒分账接收方签约");
  293. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒分账接收方签约");
  294. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/acct/bind_mcht", "好哒分账接收方签约");
  295. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/acct/bind_mcht", req, headdic);
  296. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒分账接收方签约");
  297. return result;
  298. }
  299. /// <summary>
  300. /// 添加分账接收方账户
  301. /// </summary>
  302. /// <param name="request"></param>
  303. /// <returns></returns>
  304. public string AddOpenDivideAccounts(AddOpenDivideAccounts request, int BrandId = 0)
  305. {
  306. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  307. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  308. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒添加分账接收方账户");
  309. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  310. LogHelper.Instance.WriteLog(req, "好哒添加分账接收方账户");
  311. Dictionary<string, string> headdic = GetHeader(req);
  312. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  313. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒添加分账接收方账户");
  314. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒添加分账接收方账户");
  315. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/acct/register", "好哒添加分账接收方账户");
  316. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/acct/register", req, headdic);
  317. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒添加分账接收方账户");
  318. return result;
  319. }
  320. /// <summary>
  321. /// 分账交易详情查询
  322. /// </summary>
  323. /// <param name="mchtNo">慧掌柜商户号</param>
  324. /// <param name="orderNo">交易订单号 </param>
  325. /// <returns></returns>
  326. public string QueryOrderDivideAccounts(string mchtNo, string orderNo, int BrandId = 0)
  327. {
  328. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  329. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  330. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒分账交易详情查询");
  331. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  332. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  333. reqdic.Add("orderNo", orderNo); // 交易订单号
  334. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  335. LogHelper.Instance.WriteLog(req, "好哒分账交易详情查询");
  336. Dictionary<string, string> headdic = GetHeader(req);
  337. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  338. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒分账交易详情查询");
  339. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒分账交易详情查询");
  340. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/acct/bind_mcht", "好哒分账交易详情查询");
  341. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/acct/bind_mcht", req, headdic);
  342. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒分账交易详情查询");
  343. return result;
  344. }
  345. /// <summary>
  346. /// 订单分账申请
  347. /// </summary>
  348. /// <param name="request"></param>
  349. /// <returns></returns>
  350. ///
  351. public string OrderDivideAccounts(OrderDivideAccounts request, int BrandId = 0)
  352. {
  353. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  354. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  355. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒订单分账申请");
  356. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  357. LogHelper.Instance.WriteLog(req, "好哒订单分账申请");
  358. Dictionary<string, string> headdic = GetHeader(req);
  359. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  360. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒订单分账申请");
  361. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒订单分账申请");
  362. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/order/apply", "好哒订单分账申请");
  363. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/order/apply", req, headdic);
  364. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒订单分账申请");
  365. return result;
  366. }
  367. /// <summary>
  368. /// 订单分账结果查询
  369. /// </summary>
  370. /// <param name="applyNo">分账批次号</param>
  371. /// <param name="mchtNo">慧掌柜商户号</param>
  372. /// <returns></returns>
  373. public string OrderDivideAccountsQuery(string applyNo, string mchtNo, int BrandId = 0)
  374. {
  375. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  376. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  377. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒订单分账结果查询");
  378. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  379. reqdic.Add("applyNo", applyNo); // 账户号
  380. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  381. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  382. LogHelper.Instance.WriteLog(req, "好哒订单分账结果查询");
  383. Dictionary<string, string> headdic = GetHeader(req);
  384. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  385. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒订单分账结果查询");
  386. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒订单分账结果查询");
  387. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/part/apply/query", "好哒订单分账结果查询");
  388. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/part/apply/query", req, headdic);
  389. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒订单分账结果查询");
  390. return result;
  391. }
  392. /// <summary>
  393. /// 商户修改银行卡
  394. /// </summary>
  395. /// <param name="request"></param>
  396. /// <returns></returns>
  397. public string ChangeMerchantCard(ChangeMerchantCard request, int BrandId = 0)
  398. {
  399. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  400. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  401. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒商户修改银行卡");
  402. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  403. LogHelper.Instance.WriteLog(req, "好哒商户修改银行卡");
  404. Dictionary<string, string> headdic = GetHeader(req);
  405. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  406. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒商户修改银行卡");
  407. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒商户修改银行卡");
  408. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/update_acct", "好哒商户修改银行卡");
  409. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/update_acct", req, headdic);
  410. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒商户修改银行卡");
  411. return result;
  412. }
  413. /// <summary>
  414. /// 查询修改银行卡任务审核状态
  415. /// </summary>
  416. /// <param name="mchtNo">收款商户号</param>
  417. /// <param name="taskId">任务id</param>
  418. /// <returns></returns>
  419. public string QueryChangeCardStatus(string mchtNo, string taskId, int BrandId = 0)
  420. {
  421. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  422. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  423. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒查询修改银行卡任务审核状态");
  424. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  425. reqdic.Add("mchtNo", mchtNo);
  426. reqdic.Add("taskId", taskId);
  427. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  428. LogHelper.Instance.WriteLog(req, "好哒查询修改银行卡任务审核状态");
  429. Dictionary<string, string> headdic = GetHeader(req);
  430. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  431. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒查询修改银行卡任务审核状态");
  432. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒查询修改银行卡任务审核状态");
  433. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/query_acct_task", "好哒查询修改银行卡任务审核状态");
  434. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/query_acct_task", req, headdic);
  435. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒查询修改银行卡任务审核状态");
  436. return result;
  437. }
  438. /// <summary>
  439. /// 绑定微信appid接口
  440. /// </summary>
  441. /// <param name="mchtNo">盒子的商户编号</param>
  442. /// <param name="storeNo">盒子的门店编号</param>
  443. /// <param name="subAppId">公众号appid或者小程序appid</param>
  444. /// <returns></returns>
  445. public string BindWeChatAppId(string mchtNo, string storeNo, string subAppId, int BrandId = 0)
  446. {
  447. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  448. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  449. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒绑定微信appid接口");
  450. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  451. reqdic.Add("mchtNo", mchtNo); // 盒子商户号
  452. reqdic.Add("storeNo", storeNo); // 盒子门店号
  453. reqdic.Add("subAppId", subAppId); // 公众号appid或者小程序appid
  454. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  455. LogHelper.Instance.WriteLog(req, "好哒绑定微信appid接口");
  456. Dictionary<string, string> headdic = GetHeader(req);
  457. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  458. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒绑定微信appid接口");
  459. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒绑定微信appid接口");
  460. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/wechat/add_sub_config", "好哒绑定微信appid接口");
  461. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/wechat/add_sub_config", req, headdic);
  462. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒绑定微信appid接口");
  463. return result;
  464. }
  465. /// <summary>
  466. /// 到账记录查询
  467. /// </summary>
  468. /// <param name="mchtNo">商户号</param>
  469. /// <param name="startTime">查询开始时间(yyyy-MM-dd)</param>
  470. /// <param name="endTime">查询结束时间(yyyy-MM-dd),最大查询时间区间31天</param>
  471. /// <param name="tradeMchtNo">收单商户号(15位)</param>
  472. /// <param name="cardNo">结算卡号</param>
  473. /// <param name="settleStatus">出款状态(0:入账成功、1:入账失败、2:结算超时、3:入账受理成功、4:已提交结算请求)</param>
  474. /// <param name="page">当前页数,默认1</param>
  475. /// <param name="rows">每页大小,默认10,最大500</param>
  476. /// <returns></returns>
  477. public string QueryAccountList(string mchtNo, string startTime, string endTime, string tradeMchtNo, string cardNo, string settleStatus, string page = "1", string rows = "10", int BrandId = 0)
  478. {
  479. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  480. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  481. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒到账记录查询");
  482. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  483. reqdic.Add("mchtNo", mchtNo); // 盒子商户号
  484. reqdic.Add("startTime", startTime); // 查询开始时间(yyyy-MM-dd)
  485. reqdic.Add("endTime", endTime); // 查询结束时间(yyyy-MM-dd),最大查询时间区间31天
  486. reqdic.Add("tradeMchtNo", tradeMchtNo); // 收单商户号(15位)
  487. reqdic.Add("cardNo", cardNo); // 结算卡号
  488. reqdic.Add("settleStatus", settleStatus); // 出款状态(0:入账成功、1:入账失败、2:结算超时、3:入账受理成功、4:已提交结算请求)
  489. reqdic.Add("page", page); // 当前页数,默认1
  490. reqdic.Add("rows", rows); // 每页大小,默认10,最大500
  491. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  492. LogHelper.Instance.WriteLog(req, "好哒到账记录查询");
  493. Dictionary<string, string> headdic = GetHeader(req);
  494. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  495. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒到账记录查询");
  496. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒到账记录查询");
  497. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/accb/to_account/query", "好哒到账记录查询");
  498. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/accb/to_account/query", req, headdic);
  499. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒到账记录查询");
  500. return result;
  501. }
  502. /// <summary>
  503. /// 到账记录详情
  504. /// </summary>
  505. /// <param name="mchtNo">商户号</param>
  506. /// <param name="id"></param>
  507. /// <returns></returns>
  508. public string QueryAccountDetail(string mchtNo, string id, int BrandId = 0)
  509. {
  510. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  511. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  512. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒到账记录详情");
  513. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  514. reqdic.Add("mchtNo", mchtNo); // 商户号
  515. reqdic.Add("id", id); // id
  516. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  517. LogHelper.Instance.WriteLog(req, "好哒到账记录详情");
  518. Dictionary<string, string> headdic = GetHeader(req);
  519. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  520. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒到账记录详情");
  521. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒到账记录详情");
  522. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/v3/hzg/accb/to_account/get", "好哒到账记录详情");
  523. string result = PostWebRequest(BoxRequestUrl + "/api/v3/hzg/accb/to_account/get", req, headdic);
  524. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒到账记录详情");
  525. return result;
  526. }
  527. /// <summary>
  528. /// 聚合支付查询接口
  529. /// </summary>
  530. /// <param name="mchtNo">商户号</param>
  531. /// <param name="outOrderNo">商户订单号</param>
  532. /// <returns></returns>
  533. public string QueryTradeDetail(string mchtNo, string outOrderNo, int BrandId = 0)
  534. {
  535. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  536. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  537. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒聚合支付查询");
  538. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  539. reqdic.Add("mchtNo", mchtNo); // 商户号
  540. reqdic.Add("outOrderNo", outOrderNo); // 商户订单号
  541. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  542. LogHelper.Instance.WriteLog(req, "好哒聚合支付查询");
  543. Dictionary<string, string> headdic = GetHeader(req);
  544. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  545. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒聚合支付查询");
  546. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒聚合支付查询");
  547. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/unitedtrade/query_status", "好哒聚合支付查询");
  548. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/unitedtrade/query_status", req, headdic);
  549. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒聚合支付查询");
  550. return result;
  551. }
  552. /// <summary>
  553. /// 聚合支付退款查询接口
  554. /// </summary>
  555. /// <param name="mchtNo">商户号</param>
  556. /// <param name="storeNo">门店编号</param>
  557. /// <param name="outRefundNo">退款订单号</param>
  558. /// <returns></returns>
  559. public string QueryRefundDetail(string mchtNo, string storeNo, string outRefundNo, int BrandId = 0)
  560. {
  561. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  562. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  563. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒退款查询");
  564. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  565. reqdic.Add("mchtNo", mchtNo); // 商户号
  566. reqdic.Add("storeNo", storeNo); // 商户订单号
  567. reqdic.Add("outRefundNo", outRefundNo);
  568. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  569. LogHelper.Instance.WriteLog(req, "好哒退款查询");
  570. Dictionary<string, string> headdic = GetHeader(req);
  571. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  572. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒退款查询");
  573. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒退款查询");
  574. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/hzg/v2/unitedtrade/refund_query", "好哒退款查询");
  575. string result = PostWebRequest(BoxRequestUrl + "/api/hzg/v2/unitedtrade/refund_query", req, headdic);
  576. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒退款查询");
  577. return result;
  578. }
  579. public Dictionary<string, string> GetHeader(string req, int BrandId = 0)
  580. {
  581. var BoxAppSecret = HaodaUnionParam.BoxAppSecret;
  582. if (BrandId == 1) BoxAppSecret = HaodaParam.BoxAppSecret;
  583. Dictionary<string, string> headdic = new Dictionary<string, string>();
  584. string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  585. // headdic.Add("appid", BoxAppId);//开发者id
  586. // headdic.Add("appsecret", BoxAppSecret);//开发者密码
  587. headdic.Add("X-Up-AppId", BoxAppId);
  588. headdic.Add("X-Timestamp", timestamp);
  589. headdic.Add("X-Sign-Type", "SHA-256");
  590. headdic.Add("X-Sign", SHA256Sign(timestamp + BoxAppSecret + req));
  591. return headdic;
  592. }
  593. public string SHA256Sign(string toSignStr)
  594. {
  595. byte[] toSignByte = Encoding.UTF8.GetBytes(toSignStr);
  596. SHA256 sha256 = SHA256.Create();
  597. byte[] signByte = sha256.ComputeHash(toSignByte);
  598. string sign = Convert.ToBase64String(signByte);
  599. return sign;
  600. }
  601. public bool VerifySign(string toSignStr, string signStr, int BrandId = 0)
  602. {
  603. var BoxPublicKey = HaodaUnionParam.BoxPublicKey;
  604. if (BrandId == 1) BoxPublicKey = HaodaParam.BoxPublicKey;
  605. byte[] toSignByte = Encoding.Default.GetBytes(toSignStr);
  606. byte[] signByte = Convert.FromBase64String(signStr);
  607. var toKey = Convert.FromBase64String(BoxPublicKey);
  608. var rsaroot = RSA.Create();
  609. rsaroot.ImportSubjectPublicKeyInfo(toKey, out _);
  610. var publicKeyParameters = rsaroot.ExportParameters(false);
  611. using (var rsa = RSA.Create())
  612. {
  613. rsa.ImportParameters(publicKeyParameters);
  614. var sha256 = SHA256.Create();
  615. var hash = sha256.ComputeHash(toSignByte);
  616. return rsa.VerifyHash(hash, signByte, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
  617. }
  618. }
  619. public string SignData(string toSignStr, int BrandId = 0)
  620. {
  621. var BoxPublicKey = HaodaUnionParam.BoxPublicKey;
  622. if (BrandId == 1) BoxPublicKey = HaodaParam.BoxPublicKey;
  623. byte[] toSignByte = Encoding.UTF8.GetBytes(toSignStr);
  624. var toKey = Convert.FromBase64String(BoxPublicKey);
  625. var rsaroot = RSA.Create();
  626. rsaroot.ImportSubjectPublicKeyInfo(toKey, out _);
  627. var publicKeyParameters = rsaroot.ExportParameters(false);
  628. using (var rsa = RSA.Create())
  629. {
  630. rsa.ImportParameters(publicKeyParameters);
  631. var sha256 = SHA256.Create();
  632. var hash = sha256.ComputeHash(toSignByte);
  633. byte[] endByte = rsa.SignData(toSignByte, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
  634. return Convert.ToBase64String(endByte);
  635. }
  636. }
  637. private string PostWebRequest(string postUrl, string paramData, Dictionary<string, string> headers)
  638. {
  639. string ret = string.Empty;
  640. try
  641. {
  642. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "请求好哒API日志");
  643. LogHelper.Instance.WriteLog(postUrl, "请求好哒API日志");
  644. LogHelper.Instance.WriteLog(paramData, "请求好哒API日志");
  645. byte[] postData = System.Text.Encoding.UTF8.GetBytes(paramData);
  646. // 设置提交的相关参数
  647. System.Net.HttpWebRequest request = System.Net.WebRequest.Create(postUrl) as System.Net.HttpWebRequest;
  648. System.Text.Encoding myEncoding = System.Text.Encoding.UTF8;
  649. request.Method = "POST";
  650. request.KeepAlive = false;
  651. request.AllowAutoRedirect = true;
  652. request.ContentType = "application/json";
  653. foreach (string key in headers.Keys)
  654. {
  655. request.Headers.Add(key, headers[key]);
  656. }
  657. request.UserAgent = "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 2.0.50727; .NET CLR 3.0.04506.648; .NET CLR 3.5.21022; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)";
  658. request.ContentLength = postData.Length;
  659. // 提交请求数据
  660. System.IO.Stream outputStream = request.GetRequestStream();
  661. outputStream.Write(postData, 0, postData.Length);
  662. outputStream.Close();
  663. System.Net.HttpWebResponse response;
  664. System.IO.Stream responseStream;
  665. System.IO.StreamReader reader;
  666. string srcString;
  667. response = request.GetResponse() as System.Net.HttpWebResponse;
  668. responseStream = response.GetResponseStream();
  669. reader = new System.IO.StreamReader(responseStream, System.Text.Encoding.UTF8);
  670. srcString = reader.ReadToEnd();
  671. ret = srcString; //返回值赋值
  672. reader.Close();
  673. LogHelper.Instance.WriteLog(srcString, "请求好哒API日志");
  674. }
  675. catch (System.Net.WebException ex)
  676. {
  677. System.Net.HttpWebResponse response = (System.Net.HttpWebResponse)ex.Response;
  678. System.IO.Stream myResponseStream = response.GetResponseStream();
  679. //获取响应内容
  680. System.IO.StreamReader myStreamReader = new System.IO.StreamReader(myResponseStream);
  681. ret = myStreamReader.ReadToEnd();
  682. myResponseStream.Close();
  683. }
  684. catch (Exception ex)
  685. {
  686. ret = "fail";
  687. LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "请求好哒API异常");
  688. }
  689. return ret;
  690. }
  691. /// <summary>
  692. /// 获取文件令牌接口
  693. /// </summary>
  694. /// <param name="fileName">文件名</param>
  695. /// <param name="action">操作类型 0 上传图片</param>
  696. /// <returns></returns>
  697. public string GetToken(string fileName, string action, int BrandId = 0)
  698. {
  699. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  700. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  701. LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "好哒获取文件令牌接口");
  702. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  703. reqdic.Add("fileName", fileName); // 文件名
  704. reqdic.Add("action", action); // 操作类型 0 上传图片
  705. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  706. LogHelper.Instance.WriteLog(req, "好哒获取文件令牌接口");
  707. Dictionary<string, string> headdic = GetHeader(req);
  708. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  709. LogHelper.Instance.WriteLog("请求头\n" + head, "好哒获取文件令牌接口");
  710. LogHelper.Instance.WriteLog("请求参数\n" + req, "好哒获取文件令牌接口");
  711. LogHelper.Instance.WriteLog("请求地址:" + BoxRequestUrl + "/api/auth/v1/get_file_token", "好哒获取文件令牌接口");
  712. string result = PostWebRequest(BoxRequestUrl + "/api/auth/v1/get_file_token", req, headdic);
  713. LogHelper.Instance.WriteLog("返回\n" + result + "\n\n", "好哒获取文件令牌接口");
  714. return result;
  715. }
  716. /// <summary>
  717. /// 执行带文件上传的HTTP POST请求。
  718. /// </summary>
  719. /// <param name="url">请求地址</param>
  720. /// <param name="textParams">请求文本参数</param>
  721. /// <param name="fileParams">请求文件参数</param>
  722. /// <param name="charset">编码字符集</param>
  723. /// <returns>HTTP响应</returns>
  724. public string DoPost(string url, string token, IDictionary<string, string> textParams, IDictionary<string, FileItem> fileParams, string charset = "utf-8")
  725. {
  726. // 如果没有文件参数,则走普通POST请求
  727. if (fileParams == null || fileParams.Count == 0)
  728. {
  729. return "";
  730. }
  731. string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
  732. HttpWebRequest req = GetWebRequest(url, "POST");
  733. req.Headers.Add("X-File-Token", token);
  734. req.ContentType = "multipart/form-data;charset=" + charset + ";boundary=" + boundary;
  735. Stream reqStream = req.GetRequestStream();
  736. byte[] itemBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "\r\n");
  737. byte[] endBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "--\r\n");
  738. // 组装文本请求参数
  739. string textTemplate = "Content-Disposition:form-data;name=\"{0}\"\r\nContent-Type:text/plain\r\n\r\n{1}";
  740. IEnumerator<KeyValuePair<string, string>> textEnum = textParams.GetEnumerator();
  741. while (textEnum.MoveNext())
  742. {
  743. string textEntry = string.Format(textTemplate, textEnum.Current.Key, textEnum.Current.Value);
  744. byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(textEntry);
  745. reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
  746. reqStream.Write(itemBytes, 0, itemBytes.Length);
  747. }
  748. // 组装文件请求参数
  749. string fileTemplate = "Content-Disposition:form-data;name=\"{0}\";filename=\"{1}\"\r\nContent-Type:{2}\r\n\r\n";
  750. IEnumerator<KeyValuePair<string, FileItem>> fileEnum = fileParams.GetEnumerator();
  751. while (fileEnum.MoveNext())
  752. {
  753. string key = fileEnum.Current.Key;
  754. FileItem fileItem = fileEnum.Current.Value;
  755. string fileEntry = string.Format(fileTemplate, key, fileItem.GetFileName(), fileItem.GetMimeType());
  756. byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(fileEntry);
  757. reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
  758. reqStream.Write(itemBytes, 0, itemBytes.Length);
  759. byte[] fileBytes = fileItem.GetContent();
  760. reqStream.Write(fileBytes, 0, fileBytes.Length);
  761. }
  762. reqStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
  763. reqStream.Close();
  764. HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
  765. Encoding encoding = Encoding.GetEncoding(rsp.CharacterSet);
  766. return GetResponseAsString(rsp, encoding);
  767. }
  768. public HttpWebRequest GetWebRequest(string url, string method)
  769. {
  770. HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
  771. req.ServicePoint.Expect100Continue = false;
  772. req.Method = method;
  773. req.KeepAlive = true;
  774. req.Timeout = 100000;
  775. return req;
  776. }
  777. /// <summary>
  778. /// 把响应流转换为文本。
  779. /// </summary>
  780. /// <param name="rsp">响应流对象</param>
  781. /// <param name="encoding">编码方式</param>
  782. /// <returns>响应文本</returns>
  783. public string GetResponseAsString(HttpWebResponse rsp, Encoding encoding)
  784. {
  785. StringBuilder result = new StringBuilder();
  786. Stream stream = null;
  787. StreamReader reader = null;
  788. try
  789. {
  790. // 以字符流的方式读取HTTP响应
  791. stream = rsp.GetResponseStream();
  792. reader = new StreamReader(stream, encoding);
  793. // 按字符读取并写入字符串缓冲
  794. int ch = -1;
  795. while ((ch = reader.Read()) > -1)
  796. {
  797. // 过滤结束符
  798. char c = (char)ch;
  799. if (c != '\0')
  800. {
  801. result.Append(c);
  802. }
  803. }
  804. }
  805. finally
  806. {
  807. // 释放资源
  808. if (reader != null) reader.Close();
  809. if (stream != null) stream.Close();
  810. if (rsp != null) rsp.Close();
  811. }
  812. return result.ToString();
  813. }
  814. /// <summary>
  815. /// 获取好哒开放平台文件名
  816. /// </summary>
  817. /// <param name="token">上传图片凭证token</param>
  818. /// <param name="value">图片路径</param>
  819. /// <returns></returns>
  820. public string ReturnFileName(string token, string value, int BrandId = 0)
  821. {
  822. var BoxRequestUrl = HaodaUnionParam.BoxRequestUrl;
  823. if (BrandId == 1) BoxRequestUrl = HaodaParam.BoxRequestUrl;
  824. Dictionary<string, string> file = new Dictionary<string, string>();
  825. file.Add("fileName", value.Substring(value.LastIndexOf("/")).Trim('/'));
  826. if (string.IsNullOrEmpty(value.Split(',')[0]))
  827. {
  828. return "";
  829. }
  830. FileItem item = PublicFunction.GetNetFileItem(AppConfig.Base.OssHost + value.Split(',')[0]);
  831. // FileItem item = new FileItem(function.getPath(value.Split(',')[0]));
  832. Dictionary<string, FileItem> files = new Dictionary<string, FileItem>();
  833. files.Add("file", item);
  834. var upLoadInfo = JsonMapper.ToObject(HaoDaHelper.Instance.DoPost(BoxRequestUrl + "/api/file/v1/upload_file", token, file, files, "utf-8"));
  835. if (upLoadInfo["code"].ToString() == "1")
  836. {
  837. return upLoadInfo["data"]["fileName"].ToString();
  838. }
  839. else
  840. {
  841. return "false";
  842. }
  843. }
  844. #endregion
  845. }
  846. }