HaoDaHelper.cs 28 KB

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