HaoDaHelper.cs 32 KB

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