HaoDaHelper.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524
  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. namespace MySystem
  12. {
  13. public class HaoDaHelper
  14. {
  15. public readonly static HaoDaHelper Instance = new HaoDaHelper();
  16. private HaoDaHelper()
  17. {
  18. }
  19. #region 盒易付
  20. //测试环境
  21. // string BoxRequestUrl = "https://openapi-test.iboxpay.com/api";
  22. // string BoxAppId = "8840021411446784";
  23. // string BoxAppSecret = "xgwGnmYGjVy0GOWOWkQtRk8Hk8ur5tCV";
  24. // string BoxPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAjMQxp24mjxDTr13uPW0y+tiO1yXFGw7P/pPQ0oZKK7F6KstEaus7pLEywBZ5XRXE5jgkhR2TS7Ne7djJfbpn5yFc6pPlz3ZsOfBVeB88NEwhx6xzCGX2eqSSkO33n8w2G0xc2ss5HpYBarT00NBZWhrwOXpdRPYLOYHKVU3Rl+FA9xDw/wYfoWvrr+JSfHRGn/ENMmQFEdckAbPauKaQMrZD2kz+PRrhq56eWnCuVQPcaz/jroVT8qQEgkg2IsNy+DwfLOIqm8IySEpxnQ5wN/KvsQJc2wXDQNf9F5kvWwjoqSSP0qJS+oPRXET+zJb+WTk2y5M6AYoC9NodwsC4NwIDAQAB";
  25. // string BrhCode = "039001";
  26. //生产环境
  27. string BoxRequestUrl = "https://openapi.iboxpay.com/api";
  28. string BoxAppId = "AP5879017839106039808";
  29. string BoxAppSecret = "DGtftIyl6R3nzwPr5YuV5fnmkfwufXRj";
  30. string BoxPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAjmjoQirIYZBD9Qon2HkF4j/NAINXtJ7Lzq/WXxTF7t7mg7LNARt0+ZZaeWx8caq2fv5zdsGyyoInL23cBtDI5KmFfK69iA0ygQMK0WbiKqsUB1OpPbT3+9zLuadIJAznjA223lY6CIjTpdLZhaRjImNVqc60bdkx6YsQcA+xW+3r1JH4PPHb7yBEbkKIX8OhyX7U4p0TkbDkAobbjHr5YB9gmYLoSFJMOPfTtSExkv7/Y7IVR9poZAHcr3teFoAiXW3RzxelRtnXxIkl/6AUOKoL5fhr/UTUN+Q18uzNljYWr6SwnTI3EmtzgykaewWtZvV85Xdhe/BjiQ5Xor7YbwIDAQAB";
  31. string BrhCode = "039034";
  32. /// <summary>
  33. /// 新创建商户
  34. /// </summary>
  35. /// <param name="request"></param>
  36. /// <returns></returns>
  37. public string AddNewMerchant(AddNewMerchant request)
  38. {
  39. function.WriteLog(DateTime.Now.ToString(), "好哒新创建商户");
  40. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  41. function.WriteLog(req, "好哒新创建商户");
  42. Dictionary<string, string> headdic = GetHeader(req);
  43. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  44. function.WriteLog("请求头\n" + head, "好哒新创建商户");
  45. function.WriteLog("请求参数\n" + req, "好哒新创建商户");
  46. function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒新创建商户");
  47. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
  48. function.WriteLog("返回\n" + result + "\n\n", "好哒新创建商户");
  49. return result;
  50. }
  51. /// <summary>
  52. /// 查询商户审核状态
  53. /// </summary>
  54. /// <param name="instId">机构编号</param>
  55. /// <param name="mchtNo">收款商户号</param>
  56. /// <returns></returns>
  57. public string QueryMerchantStatus(string instId, string mchtNo)
  58. {
  59. function.WriteLog(DateTime.Now.ToString(), "好哒查询商户审核状态");
  60. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  61. reqdic.Add("instId", instId);
  62. reqdic.Add("mchtNo", mchtNo);
  63. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  64. function.WriteLog(req, "好哒查询商户审核状态");
  65. Dictionary<string, string> headdic = GetHeader(req);
  66. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  67. function.WriteLog("请求头\n" + head, "好哒查询商户审核状态");
  68. function.WriteLog("请求参数\n" + req, "好哒查询商户审核状态");
  69. function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", "好哒查询商户审核状态");
  70. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", req, headdic);
  71. function.WriteLog("返回\n" + result + "\n\n", "好哒查询商户审核状态");
  72. return result;
  73. }
  74. /// <summary>
  75. /// 微信公众号和小程序支付接口
  76. /// </summary>
  77. /// <param name="mchtNo">盒子的商户编号</param>
  78. /// <param name="storeNo">盒子的门店编码</param>
  79. /// <param name="outOrderNo">商户订单号</param>
  80. /// <param name="transAmount">交易金额,单位:分</param>
  81. /// <param name="callbackUrl">交易完成之后,商户接收交易结果通知的地址</param>
  82. /// <param name="subOpenId">用户子标识</param>
  83. /// <param name="confirmCode">支付确认码</param>
  84. /// <param name="subAppId">公众号或者小程序appId</param>
  85. /// <param name="subAppIdType">对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序</param>
  86. /// <param name="ledgerModel">分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段</param>
  87. /// <returns></returns>
  88. public string WeChatPay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode, string subAppId, string subAppIdType, string ledgerModel)
  89. {
  90. function.WriteLog(DateTime.Now.ToString(), "好哒微信公众号和小程序支付");
  91. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  92. reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
  93. reqdic.Add("storeNo", storeNo); //盒子的门店编码
  94. reqdic.Add("outOrderNo", outOrderNo); //商户订单号
  95. reqdic.Add("transAmount", transAmount); //交易金额,单位:分
  96. reqdic.Add("callbackUrl", callbackUrl); //交易完成之后,商户接收交易结果通知的地址
  97. reqdic.Add("subOpenId", subOpenId); //用户子标识
  98. reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
  99. reqdic.Add("subAppId", subAppId); //公众号或者小程序appId
  100. reqdic.Add("subAppIdType", subAppIdType); //subAppId 对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序
  101. reqdic.Add("ledgerModel", ledgerModel); //分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段
  102. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  103. function.WriteLog(req, "好哒微信公众号和小程序支付");
  104. Dictionary<string, string> headdic = GetHeader(req);
  105. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  106. function.WriteLog("请求头\n" + head, "好哒微信公众号和小程序支付");
  107. function.WriteLog("请求参数\n" + req, "好哒微信公众号和小程序支付");
  108. function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", "好哒微信公众号和小程序支付");
  109. string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
  110. function.WriteLog("返回\n" + result + "\n\n", "好哒微信公众号和小程序支付");
  111. return result;
  112. }
  113. /// <summary>
  114. /// 支付宝服务窗支付接口
  115. /// </summary>
  116. /// <param name="mchtNo">盒子的商户编号</param>
  117. /// <param name="storeNo">盒子的门店编码</param>
  118. /// <param name="outOrderNo">商户订单号</param>
  119. /// <param name="transAmount">交易金额,单位:分</param>
  120. /// <param name="callbackUrl">交易完成之后,商户接收交易结果通知的地址</param>
  121. /// <param name="subOpenId">支付宝用户标识</param>
  122. /// <param name="confirmCode">支付确认码,由4位纯数字组成,每次请求时随机生成</param>
  123. /// <returns></returns>
  124. public string Alipay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode)
  125. {
  126. function.WriteLog(DateTime.Now.ToString(), "好哒支付宝服务窗支付");
  127. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  128. reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
  129. reqdic.Add("storeNo", storeNo); //盒子的门店编码
  130. reqdic.Add("outOrderNo", outOrderNo); //商户订单号
  131. reqdic.Add("transAmount", transAmount); //交易金额,单位:分
  132. reqdic.Add("callbackUrl", callbackUrl); //交易完成之后,商户接收交易结果通知的地址
  133. reqdic.Add("subOpenId", subOpenId); //支付宝用户标识
  134. reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
  135. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  136. function.WriteLog(req, "好哒支付宝服务窗支付");
  137. Dictionary<string, string> headdic = GetHeader(req);
  138. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  139. function.WriteLog("请求头\n" + head, "好哒支付宝服务窗支付");
  140. function.WriteLog("请求参数\n" + req, "好哒支付宝服务窗支付");
  141. function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", "好哒支付宝服务窗支付");
  142. string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
  143. function.WriteLog("返回\n" + result + "\n\n", "好哒支付宝服务窗支付");
  144. return result;
  145. }
  146. /// <summary>
  147. /// 聚合支付退款接口
  148. /// </summary>
  149. /// <param name="mchtNo">盒子的商户编号</param>
  150. /// <param name="storeNo">盒子的门店编号</param>
  151. /// <param name="outRefundNo">商户退款订单号</param>
  152. /// <param name="outOrderNo">商户支付订单号</param>
  153. /// <param name="refundAmount">退款金额,单位:分</param>
  154. /// <returns></returns>
  155. public string AggregatedPayRefund(string mchtNo, string storeNo, string outRefundNo, string outOrderNo, string refundAmount)
  156. {
  157. function.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("outRefundNo", outRefundNo); //32 商户退款订单号
  162. reqdic.Add("outOrderNo", outOrderNo); // 商户支付订单号
  163. reqdic.Add("refundAmount", refundAmount); //10 退款金额,单位:分
  164. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  165. function.WriteLog(req, "好哒聚合支付退款");
  166. Dictionary<string, string> headdic = GetHeader(req);
  167. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  168. function.WriteLog("请求头\n" + head, "好哒聚合支付退款");
  169. function.WriteLog("请求参数\n" + req, "好哒聚合支付退款");
  170. function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/refund", "好哒聚合支付退款");
  171. string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/refund", req, headdic);
  172. function.WriteLog("返回\n" + result + "\n\n", "好哒聚合支付退款");
  173. return result;
  174. }
  175. /// <summary>
  176. /// 开通分账功能
  177. /// </summary>
  178. /// <param name="mchtNo">慧掌柜商户号(进件接口返回的outMchtNo字段)</param>
  179. /// <param name="storeNo">慧掌柜门店号</param>
  180. /// <returns></returns>
  181. public string OpenDivideAccounts(string mchtNo, string storeNo)
  182. {
  183. function.WriteLog(DateTime.Now.ToString(), "好哒开通分账");
  184. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  185. reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
  186. reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
  187. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  188. function.WriteLog(req, "好哒开通分账");
  189. Dictionary<string, string> headdic = GetHeader(req);
  190. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  191. function.WriteLog("请求头\n" + head, "好哒开通分账");
  192. function.WriteLog("请求参数\n" + req, "好哒开通分账");
  193. function.WriteLog("请求地址:" + BoxRequestUrl + "/v3/hzg/part/mcht/reg", "好哒开通分账");
  194. string result = PostWebRequest(BoxRequestUrl + "/v3/hzg/part/mcht/reg", req, headdic);
  195. function.WriteLog("返回\n" + result + "\n\n", "好哒开通分账");
  196. return result;
  197. }
  198. /// <summary>
  199. /// 添加分账接收方账户
  200. /// </summary>
  201. /// <param name="request"></param>
  202. /// <returns></returns>
  203. public string AddOpenDivideAccounts(AddOpenDivideAccounts request)
  204. {
  205. function.WriteLog(DateTime.Now.ToString(), "好哒添加分账接收方账户");
  206. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  207. function.WriteLog(req, "好哒添加分账接收方账户");
  208. Dictionary<string, string> headdic = GetHeader(req);
  209. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  210. function.WriteLog("请求头\n" + head, "好哒添加分账接收方账户");
  211. function.WriteLog("请求参数\n" + req, "好哒添加分账接收方账户");
  212. function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒添加分账接收方账户");
  213. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
  214. function.WriteLog("返回\n" + result + "\n\n", "好哒添加分账接收方账户");
  215. return result;
  216. }
  217. /// <summary>
  218. /// 订单分账申请
  219. /// </summary>
  220. /// <param name="request"></param>
  221. /// <returns></returns>
  222. ///
  223. public string OrderDivideAccounts(OrderDivideAccounts request)
  224. {
  225. function.WriteLog(DateTime.Now.ToString(), "好哒订单分账申请");
  226. string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
  227. function.WriteLog(req, "好哒订单分账申请");
  228. Dictionary<string, string> headdic = GetHeader(req);
  229. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  230. function.WriteLog("请求头\n" + head, "好哒订单分账申请");
  231. function.WriteLog("请求参数\n" + req, "好哒订单分账申请");
  232. function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒订单分账申请");
  233. string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
  234. function.WriteLog("返回\n" + result + "\n\n", "好哒订单分账申请");
  235. return result;
  236. }
  237. public Dictionary<string, string> GetHeader(string req)
  238. {
  239. Dictionary<string, string> headdic = new Dictionary<string, string>();
  240. string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  241. headdic.Add("appid", BoxAppId);//开发者id
  242. headdic.Add("appsecret", BoxAppSecret);//开发者密码
  243. headdic.Add("X-Up-AppId", BoxAppId);
  244. headdic.Add("X-Timestamp", timestamp);
  245. headdic.Add("X-Sign-Type", "SHA-256");
  246. headdic.Add("X-Sign", SHA256Sign(timestamp + BoxAppSecret + req));
  247. return headdic;
  248. }
  249. public string SHA256Sign(string toSignStr)
  250. {
  251. byte[] toSignByte = Encoding.UTF8.GetBytes(toSignStr);
  252. SHA256 sha256 = SHA256.Create();
  253. byte[] signByte = sha256.ComputeHash(toSignByte);
  254. string sign = Convert.ToBase64String(signByte);
  255. return sign;
  256. }
  257. public bool VerifySign(string toSignStr, string signStr)
  258. {
  259. byte[] toSignByte = Encoding.Default.GetBytes(toSignStr);
  260. byte[] signByte = Convert.FromBase64String(signStr);
  261. var toKey = Convert.FromBase64String(BoxPublicKey);
  262. var rsaroot = RSA.Create();
  263. rsaroot.ImportSubjectPublicKeyInfo(toKey, out _);
  264. var publicKeyParameters = rsaroot.ExportParameters(false);
  265. using (var rsa = RSA.Create())
  266. {
  267. rsa.ImportParameters(publicKeyParameters);
  268. var sha256 = SHA256.Create();
  269. var hash = sha256.ComputeHash(toSignByte);
  270. return rsa.VerifyHash(hash, signByte, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
  271. }
  272. }
  273. public string SignData(string toSignStr)
  274. {
  275. byte[] toSignByte = Encoding.UTF8.GetBytes(toSignStr);
  276. var toKey = Convert.FromBase64String(BoxPublicKey);
  277. var rsaroot = RSA.Create();
  278. rsaroot.ImportSubjectPublicKeyInfo(toKey, out _);
  279. var publicKeyParameters = rsaroot.ExportParameters(false);
  280. using (var rsa = RSA.Create())
  281. {
  282. rsa.ImportParameters(publicKeyParameters);
  283. var sha256 = SHA256.Create();
  284. var hash = sha256.ComputeHash(toSignByte);
  285. byte[] endByte = rsa.SignData(toSignByte, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
  286. return Convert.ToBase64String(endByte);
  287. }
  288. }
  289. private string PostWebRequest(string postUrl, string paramData, Dictionary<string, string> headers)
  290. {
  291. string ret = string.Empty;
  292. try
  293. {
  294. function.WriteLog(DateTime.Now.ToString(), "请求开店宝API日志");
  295. function.WriteLog(postUrl, "请求开店宝API日志");
  296. function.WriteLog(paramData, "请求开店宝API日志");
  297. byte[] postData = System.Text.Encoding.UTF8.GetBytes(paramData);
  298. // 设置提交的相关参数
  299. System.Net.HttpWebRequest request = System.Net.WebRequest.Create(postUrl) as System.Net.HttpWebRequest;
  300. System.Text.Encoding myEncoding = System.Text.Encoding.UTF8;
  301. request.Method = "POST";
  302. request.KeepAlive = false;
  303. request.AllowAutoRedirect = true;
  304. request.ContentType = "application/json";
  305. foreach (string key in headers.Keys)
  306. {
  307. request.Headers.Add(key, headers[key]);
  308. }
  309. 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)";
  310. request.ContentLength = postData.Length;
  311. // 提交请求数据
  312. System.IO.Stream outputStream = request.GetRequestStream();
  313. outputStream.Write(postData, 0, postData.Length);
  314. outputStream.Close();
  315. System.Net.HttpWebResponse response;
  316. System.IO.Stream responseStream;
  317. System.IO.StreamReader reader;
  318. string srcString;
  319. response = request.GetResponse() as System.Net.HttpWebResponse;
  320. responseStream = response.GetResponseStream();
  321. reader = new System.IO.StreamReader(responseStream, System.Text.Encoding.UTF8);
  322. srcString = reader.ReadToEnd();
  323. ret = srcString; //返回值赋值
  324. reader.Close();
  325. function.WriteLog(srcString, "请求开店宝API日志");
  326. }
  327. catch (System.Net.WebException ex)
  328. {
  329. System.Net.HttpWebResponse response = (System.Net.HttpWebResponse)ex.Response;
  330. System.IO.Stream myResponseStream = response.GetResponseStream();
  331. //获取响应内容
  332. System.IO.StreamReader myStreamReader = new System.IO.StreamReader(myResponseStream);
  333. ret = myStreamReader.ReadToEnd();
  334. myResponseStream.Close();
  335. }
  336. catch (Exception ex)
  337. {
  338. ret = "fail";
  339. function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "请求开店宝API异常");
  340. }
  341. return ret;
  342. }
  343. /// <summary>
  344. /// 获取文件令牌接口
  345. /// </summary>
  346. /// <param name="fileName">文件名</param>
  347. /// <param name="action">操作类型 0 上传图片</param>
  348. /// <returns></returns>
  349. public string GetToken(string fileName, string action)
  350. {
  351. function.WriteLog(DateTime.Now.ToString(), "好哒获取文件令牌接口");
  352. Dictionary<string, object> reqdic = new Dictionary<string, object>();
  353. reqdic.Add("fileName", fileName); // 文件名
  354. reqdic.Add("action", action); // 操作类型 0 上传图片
  355. string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
  356. function.WriteLog(req, "好哒获取文件令牌接口");
  357. Dictionary<string, string> headdic = GetHeader(req);
  358. string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
  359. function.WriteLog("请求头\n" + head, "好哒获取文件令牌接口");
  360. function.WriteLog("请求参数\n" + req, "好哒获取文件令牌接口");
  361. function.WriteLog("请求地址:" + BoxRequestUrl + "/api/auth/v1/get_file_token", "好哒获取文件令牌接口");
  362. string result = PostWebRequest(BoxRequestUrl + "/api/auth/v1/get_file_token", req, headdic);
  363. function.WriteLog("返回\n" + result + "\n\n", "好哒获取文件令牌接口");
  364. return result;
  365. }
  366. /// <summary>
  367. /// 执行带文件上传的HTTP POST请求。
  368. /// </summary>
  369. /// <param name="url">请求地址</param>
  370. /// <param name="textParams">请求文本参数</param>
  371. /// <param name="fileParams">请求文件参数</param>
  372. /// <param name="charset">编码字符集</param>
  373. /// <returns>HTTP响应</returns>
  374. public string DoPost(string url, string token, IDictionary<string, string> textParams, IDictionary<string, FileItem> fileParams, string charset = "utf-8")
  375. {
  376. // 如果没有文件参数,则走普通POST请求
  377. if (fileParams == null || fileParams.Count == 0)
  378. {
  379. return "";
  380. }
  381. string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
  382. HttpWebRequest req = GetWebRequest(url, "POST");
  383. req.Headers.Add("X-File-Token", token);
  384. req.ContentType = "multipart/form-data;charset=" + charset + ";boundary=" + boundary;
  385. Stream reqStream = req.GetRequestStream();
  386. byte[] itemBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "\r\n");
  387. byte[] endBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "--\r\n");
  388. // 组装文本请求参数
  389. string textTemplate = "Content-Disposition:form-data;name=\"{0}\"\r\nContent-Type:text/plain\r\n\r\n{1}";
  390. IEnumerator<KeyValuePair<string, string>> textEnum = textParams.GetEnumerator();
  391. while (textEnum.MoveNext())
  392. {
  393. string textEntry = string.Format(textTemplate, textEnum.Current.Key, textEnum.Current.Value);
  394. byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(textEntry);
  395. reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
  396. reqStream.Write(itemBytes, 0, itemBytes.Length);
  397. }
  398. // 组装文件请求参数
  399. string fileTemplate = "Content-Disposition:form-data;name=\"{0}\";filename=\"{1}\"\r\nContent-Type:{2}\r\n\r\n";
  400. IEnumerator<KeyValuePair<string, FileItem>> fileEnum = fileParams.GetEnumerator();
  401. while (fileEnum.MoveNext())
  402. {
  403. string key = fileEnum.Current.Key;
  404. FileItem fileItem = fileEnum.Current.Value;
  405. string fileEntry = string.Format(fileTemplate, key, fileItem.GetFileName(), fileItem.GetMimeType());
  406. byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(fileEntry);
  407. reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
  408. reqStream.Write(itemBytes, 0, itemBytes.Length);
  409. byte[] fileBytes = fileItem.GetContent();
  410. reqStream.Write(fileBytes, 0, fileBytes.Length);
  411. }
  412. reqStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
  413. reqStream.Close();
  414. HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
  415. Encoding encoding = Encoding.GetEncoding(rsp.CharacterSet);
  416. return GetResponseAsString(rsp, encoding);
  417. }
  418. public HttpWebRequest GetWebRequest(string url, string method)
  419. {
  420. HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
  421. req.ServicePoint.Expect100Continue = false;
  422. req.Method = method;
  423. req.KeepAlive = true;
  424. req.Timeout = 100000;
  425. return req;
  426. }
  427. /// <summary>
  428. /// 把响应流转换为文本。
  429. /// </summary>
  430. /// <param name="rsp">响应流对象</param>
  431. /// <param name="encoding">编码方式</param>
  432. /// <returns>响应文本</returns>
  433. public string GetResponseAsString(HttpWebResponse rsp, Encoding encoding)
  434. {
  435. StringBuilder result = new StringBuilder();
  436. Stream stream = null;
  437. StreamReader reader = null;
  438. try
  439. {
  440. // 以字符流的方式读取HTTP响应
  441. stream = rsp.GetResponseStream();
  442. reader = new StreamReader(stream, encoding);
  443. // 按字符读取并写入字符串缓冲
  444. int ch = -1;
  445. while ((ch = reader.Read()) > -1)
  446. {
  447. // 过滤结束符
  448. char c = (char)ch;
  449. if (c != '\0')
  450. {
  451. result.Append(c);
  452. }
  453. }
  454. }
  455. finally
  456. {
  457. // 释放资源
  458. if (reader != null) reader.Close();
  459. if (stream != null) stream.Close();
  460. if (rsp != null) rsp.Close();
  461. }
  462. return result.ToString();
  463. }
  464. #endregion
  465. }
  466. }