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