|
@@ -1,12 +1,16 @@
|
|
|
-using System;
|
|
|
+using System.Net.Mime;
|
|
|
+using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Security.Cryptography;
|
|
|
using System.Text;
|
|
|
using Library;
|
|
|
+using System.Net;
|
|
|
+using System.IO;
|
|
|
+using Aop.Api.Util;
|
|
|
|
|
|
namespace MySystem
|
|
|
-{
|
|
|
+{
|
|
|
public class HaoDaHelper
|
|
|
{
|
|
|
public readonly static HaoDaHelper Instance = new HaoDaHelper();
|
|
@@ -14,7 +18,7 @@ namespace MySystem
|
|
|
{
|
|
|
}
|
|
|
|
|
|
-
|
|
|
+
|
|
|
#region 盒易付
|
|
|
|
|
|
//测试环境
|
|
@@ -23,7 +27,7 @@ namespace MySystem
|
|
|
// string BoxAppSecret = "xgwGnmYGjVy0GOWOWkQtRk8Hk8ur5tCV";
|
|
|
// string BoxPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAjMQxp24mjxDTr13uPW0y+tiO1yXFGw7P/pPQ0oZKK7F6KstEaus7pLEywBZ5XRXE5jgkhR2TS7Ne7djJfbpn5yFc6pPlz3ZsOfBVeB88NEwhx6xzCGX2eqSSkO33n8w2G0xc2ss5HpYBarT00NBZWhrwOXpdRPYLOYHKVU3Rl+FA9xDw/wYfoWvrr+JSfHRGn/ENMmQFEdckAbPauKaQMrZD2kz+PRrhq56eWnCuVQPcaz/jroVT8qQEgkg2IsNy+DwfLOIqm8IySEpxnQ5wN/KvsQJc2wXDQNf9F5kvWwjoqSSP0qJS+oPRXET+zJb+WTk2y5M6AYoC9NodwsC4NwIDAQAB";
|
|
|
// string BrhCode = "039001";
|
|
|
-
|
|
|
+
|
|
|
//生产环境
|
|
|
string BoxRequestUrl = "https://openapi.iboxpay.com/api";
|
|
|
string BoxAppId = "AP5879017839106039808";
|
|
@@ -31,35 +35,235 @@ namespace MySystem
|
|
|
string BoxPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAjmjoQirIYZBD9Qon2HkF4j/NAINXtJ7Lzq/WXxTF7t7mg7LNARt0+ZZaeWx8caq2fv5zdsGyyoInL23cBtDI5KmFfK69iA0ygQMK0WbiKqsUB1OpPbT3+9zLuadIJAznjA223lY6CIjTpdLZhaRjImNVqc60bdkx6YsQcA+xW+3r1JH4PPHb7yBEbkKIX8OhyX7U4p0TkbDkAobbjHr5YB9gmYLoSFJMOPfTtSExkv7/Y7IVR9poZAHcr3teFoAiXW3RzxelRtnXxIkl/6AUOKoL5fhr/UTUN+Q18uzNljYWr6SwnTI3EmtzgykaewWtZvV85Xdhe/BjiQ5Xor7YbwIDAQAB";
|
|
|
string BrhCode = "039034";
|
|
|
|
|
|
- public string BoxServiceFee(string SnList, string ServiceFee)
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 新创建商户
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="request"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string AddNewMerchant(AddNewMerchant request)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒新创建商户");
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
|
|
|
+ function.WriteLog(req, "好哒新创建商户");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒新创建商户");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒新创建商户");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒新创建商户");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒新创建商户");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 查询商户审核状态
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="instId">机构编号</param>
|
|
|
+ /// <param name="mchtNo">收款商户号</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string QueryMerchantStatus(string instId, string mchtNo)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "设置盒易付机具服务费");
|
|
|
- function.WriteLog(SnList, "设置盒易付机具服务费");
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒查询商户审核状态");
|
|
|
Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
- string batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
|
|
|
-
|
|
|
- reqdic.Add("snList", SnList.Split(',').ToList());//终端列表
|
|
|
- if(ServiceFee != "0")
|
|
|
- {
|
|
|
- ServiceFee += "00";
|
|
|
- }
|
|
|
- reqdic.Add("depositGear", ServiceFee);//押金档位
|
|
|
- reqdic.Add("modelId", "MHN10916");//费率,固定0.6
|
|
|
- reqdic.Add("brhCode", BrhCode);//机构号
|
|
|
- reqdic.Add("batchNo", batchNo);//批次号
|
|
|
+ reqdic.Add("instId", instId);
|
|
|
+ reqdic.Add("mchtNo", mchtNo);
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒查询商户审核状态");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒查询商户审核状态");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒查询商户审核状态");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", "好哒查询商户审核状态");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/query_mcht_audit", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒查询商户审核状态");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 微信公众号和小程序支付接口
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="mchtNo">盒子的商户编号</param>
|
|
|
+ /// <param name="storeNo">盒子的门店编码</param>
|
|
|
+ /// <param name="outOrderNo">商户订单号</param>
|
|
|
+ /// <param name="transAmount">交易金额,单位:分</param>
|
|
|
+ /// <param name="callbackUrl">交易完成之后,商户接收交易结果通知的地址</param>
|
|
|
+ /// <param name="subOpenId">用户子标识</param>
|
|
|
+ /// <param name="confirmCode">支付确认码</param>
|
|
|
+ /// <param name="subAppId">公众号或者小程序appId</param>
|
|
|
+ /// <param name="subAppIdType">对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序</param>
|
|
|
+ /// <param name="ledgerModel">分账类型:1不分账 2分账,注意只有开通了分账才能传这个字段</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string WeChatPay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string callbackUrl, string subOpenId, string confirmCode, string subAppId, string subAppIdType, string ledgerModel)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒微信公众号和小程序支付");
|
|
|
+ Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
+ reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
|
|
|
+ reqdic.Add("storeNo", storeNo); //盒子的门店编码
|
|
|
+ reqdic.Add("outOrderNo", outOrderNo); //商户订单号
|
|
|
+ reqdic.Add("transAmount", transAmount); //交易金额,单位:分
|
|
|
+ reqdic.Add("callbackUrl", callbackUrl); //交易完成之后,商户接收交易结果通知的地址
|
|
|
+ reqdic.Add("subOpenId", subOpenId); //用户子标识
|
|
|
+ reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
|
|
|
+ reqdic.Add("subAppId", subAppId); //公众号或者小程序appId
|
|
|
+ reqdic.Add("subAppIdType", subAppIdType); //subAppId 对应的类型,默认为公众号, SUBSCRIPTION: 公众号 MINI_PROGRAM: 小程序
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒微信公众号和小程序支付");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒微信公众号和小程序支付");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒微信公众号和小程序支付");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", "好哒微信公众号和小程序支付");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒微信公众号和小程序支付");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 支付宝服务窗支付接口
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="mchtNo">盒子的商户编号</param>
|
|
|
+ /// <param name="storeNo">盒子的门店编码</param>
|
|
|
+ /// <param name="outOrderNo">商户订单号</param>
|
|
|
+ /// <param name="transAmount">交易金额,单位:分</param>
|
|
|
+ /// <param name="subOpenId">支付宝用户标识</param>
|
|
|
+ /// <param name="confirmCode">支付确认码,由4位纯数字组成,每次请求时随机生成</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string Alipay(string mchtNo, string storeNo, string outOrderNo, string transAmount, string subOpenId, string confirmCode)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒支付宝服务窗支付");
|
|
|
+ Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
+ reqdic.Add("mchtNo", mchtNo); //盒子的商户编号
|
|
|
+ reqdic.Add("storeNo", storeNo); //盒子的门店编码
|
|
|
+ reqdic.Add("outOrderNo", outOrderNo); //商户订单号
|
|
|
+ reqdic.Add("transAmount", transAmount); //交易金额,单位:分
|
|
|
+ reqdic.Add("subOpenId", subOpenId); //支付宝用户标识
|
|
|
+ reqdic.Add("confirmCode", confirmCode); //支付确认码,由4位纯数字组成,每次请求时随机生成
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒支付宝服务窗支付");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒支付宝服务窗支付");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒支付宝服务窗支付");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", "好哒支付宝服务窗支付");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/wechat_js_pay", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒支付宝服务窗支付");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 聚合支付退款接口
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="mchtNo">盒子的商户编号</param>
|
|
|
+ /// <param name="storeNo">盒子的门店编号</param>
|
|
|
+ /// <param name="outRefundNo">商户退款订单号</param>
|
|
|
+ /// <param name="outOrderNo">商户支付订单号</param>
|
|
|
+ /// <param name="refundAmount">退款金额,单位:分</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string AggregatedPayRefund(string mchtNo, string storeNo, string outRefundNo, string outOrderNo, string refundAmount)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒聚合支付退款");
|
|
|
+ Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
+
|
|
|
+ reqdic.Add("mchtNo", mchtNo); // 盒子的商户编号
|
|
|
+ reqdic.Add("storeNo", storeNo); // 盒子的门店编号
|
|
|
+ reqdic.Add("outRefundNo", outRefundNo); //32 商户退款订单号
|
|
|
+ reqdic.Add("outOrderNo", outOrderNo); // 商户支付订单号
|
|
|
+ reqdic.Add("refundAmount", refundAmount); //10 退款金额,单位:分
|
|
|
+
|
|
|
string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒聚合支付退款");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒聚合支付退款");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒聚合支付退款");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/hzg/v2/unitedtrade/refund", "好哒聚合支付退款");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/hzg/v2/unitedtrade/refund", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒聚合支付退款");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 开通分账功能
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="mchtNo">慧掌柜商户号(进件接口返回的outMchtNo字段)</param>
|
|
|
+ /// <param name="storeNo">慧掌柜门店号</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string OpenDivideAccounts(string mchtNo, string storeNo)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒开通分账");
|
|
|
+ Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
+
|
|
|
+ reqdic.Add("mchtNo", mchtNo); // 慧掌柜商户号
|
|
|
+ reqdic.Add("storeNo", storeNo); // 慧掌柜门店号
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒开通分账");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒开通分账");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒开通分账");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/v3/hzg/part/mcht/reg", "好哒开通分账");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/v3/hzg/part/mcht/reg", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒开通分账");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 添加分账接收方账户
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="request"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string AddOpenDivideAccounts(AddOpenDivideAccounts request)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒添加分账接收方账户");
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
|
|
|
+ function.WriteLog(req, "好哒添加分账接收方账户");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒添加分账接收方账户");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒添加分账接收方账户");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒添加分账接收方账户");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒添加分账接收方账户");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ /// <summary>
|
|
|
+ /// 订单分账申请
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="request"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ ///
|
|
|
+ public string OrderDivideAccounts(OrderDivideAccounts request)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒订单分账申请");
|
|
|
|
|
|
- Dictionary<string, string> headdic = GetHeader(reqdic);
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(request);
|
|
|
+ function.WriteLog(req, "好哒订单分账申请");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
- function.WriteLog("请求头\n" + head, "设置盒易付机具服务费");
|
|
|
- function.WriteLog("请求参数\n" + req, "设置盒易付机具服务费");
|
|
|
- function.WriteLog("请求地址:" + BoxRequestUrl + "/inst/register/terms", "设置盒易付机具服务费");
|
|
|
- string result = PostWebRequest(BoxRequestUrl + "/inst/register/terms", req, headdic);
|
|
|
- function.WriteLog("返回\n" + result + "\n\n", "设置盒易付机具服务费");
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒订单分账申请");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒订单分账申请");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/api/inst/mcht/new_create_mcht", "好哒订单分账申请");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/api/inst/mcht/new_create_mcht", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒订单分账申请");
|
|
|
+
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
- public Dictionary<string, string> GetHeader(Dictionary<string, object> reqdic)
|
|
|
+ public Dictionary<string, string> GetHeader(string req)
|
|
|
{
|
|
|
Dictionary<string, string> headdic = new Dictionary<string, string>();
|
|
|
string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
@@ -68,7 +272,6 @@ namespace MySystem
|
|
|
headdic.Add("X-Up-AppId", BoxAppId);
|
|
|
headdic.Add("X-Timestamp", timestamp);
|
|
|
headdic.Add("X-Sign-Type", "SHA-256");
|
|
|
- string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
headdic.Add("X-Sign", SHA256Sign(timestamp + BoxAppSecret + req));
|
|
|
return headdic;
|
|
|
}
|
|
@@ -173,6 +376,145 @@ namespace MySystem
|
|
|
return ret;
|
|
|
}
|
|
|
|
|
|
+ /// <summary>
|
|
|
+ /// 获取文件令牌接口
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="fileName">文件名</param>
|
|
|
+ /// <param name="action">操作类型 0 上传图片</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public string GetToken(string fileName, string action)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString(), "好哒获取文件令牌接口");
|
|
|
+ Dictionary<string, object> reqdic = new Dictionary<string, object>();
|
|
|
+
|
|
|
+ reqdic.Add("fileName", fileName); // 文件名
|
|
|
+ reqdic.Add("action", action); // 操作类型 0 上传图片
|
|
|
+
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(reqdic);
|
|
|
+ function.WriteLog(req, "好哒获取文件令牌接口");
|
|
|
+ Dictionary<string, string> headdic = GetHeader(req);
|
|
|
+ string head = Newtonsoft.Json.JsonConvert.SerializeObject(headdic);
|
|
|
+ function.WriteLog("请求头\n" + head, "好哒获取文件令牌接口");
|
|
|
+ function.WriteLog("请求参数\n" + req, "好哒获取文件令牌接口");
|
|
|
+ function.WriteLog("请求地址:" + BoxRequestUrl + "/api/auth/v1/get_file_token", "好哒获取文件令牌接口");
|
|
|
+ string result = PostWebRequest(BoxRequestUrl + "/api/auth/v1/get_file_token", req, headdic);
|
|
|
+ function.WriteLog("返回\n" + result + "\n\n", "好哒获取文件令牌接口");
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 执行带文件上传的HTTP POST请求。
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="url">请求地址</param>
|
|
|
+ /// <param name="textParams">请求文本参数</param>
|
|
|
+ /// <param name="fileParams">请求文件参数</param>
|
|
|
+ /// <param name="charset">编码字符集</param>
|
|
|
+ /// <returns>HTTP响应</returns>
|
|
|
+ public string DoPost(string url, string token, IDictionary<string, string> textParams, IDictionary<string, FileItem> fileParams, string charset = "utf-8")
|
|
|
+ {
|
|
|
+ // 如果没有文件参数,则走普通POST请求
|
|
|
+ if (fileParams == null || fileParams.Count == 0)
|
|
|
+ {
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+
|
|
|
+ string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
|
|
|
+
|
|
|
+ HttpWebRequest req = GetWebRequest(url, "POST");
|
|
|
+ req.Headers.Add("X-File-Token", token);
|
|
|
+ req.ContentType = "multipart/form-data;charset=" + charset + ";boundary=" + boundary;
|
|
|
+
|
|
|
+ Stream reqStream = req.GetRequestStream();
|
|
|
+ byte[] itemBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "\r\n");
|
|
|
+ byte[] endBoundaryBytes = Encoding.GetEncoding(charset).GetBytes("\r\n--" + boundary + "--\r\n");
|
|
|
+
|
|
|
+ // 组装文本请求参数
|
|
|
+ string textTemplate = "Content-Disposition:form-data;name=\"{0}\"\r\nContent-Type:text/plain\r\n\r\n{1}";
|
|
|
+ IEnumerator<KeyValuePair<string, string>> textEnum = textParams.GetEnumerator();
|
|
|
+ while (textEnum.MoveNext())
|
|
|
+ {
|
|
|
+ string textEntry = string.Format(textTemplate, textEnum.Current.Key, textEnum.Current.Value);
|
|
|
+ byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(textEntry);
|
|
|
+ reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
|
|
|
+ reqStream.Write(itemBytes, 0, itemBytes.Length);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 组装文件请求参数
|
|
|
+ string fileTemplate = "Content-Disposition:form-data;name=\"{0}\";filename=\"{1}\"\r\nContent-Type:{2}\r\n\r\n";
|
|
|
+ IEnumerator<KeyValuePair<string, FileItem>> fileEnum = fileParams.GetEnumerator();
|
|
|
+ while (fileEnum.MoveNext())
|
|
|
+ {
|
|
|
+ string key = fileEnum.Current.Key;
|
|
|
+ FileItem fileItem = fileEnum.Current.Value;
|
|
|
+ string fileEntry = string.Format(fileTemplate, key, fileItem.GetFileName(), fileItem.GetMimeType());
|
|
|
+ byte[] itemBytes = Encoding.GetEncoding(charset).GetBytes(fileEntry);
|
|
|
+ reqStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
|
|
|
+ reqStream.Write(itemBytes, 0, itemBytes.Length);
|
|
|
+
|
|
|
+ byte[] fileBytes = fileItem.GetContent();
|
|
|
+ reqStream.Write(fileBytes, 0, fileBytes.Length);
|
|
|
+ }
|
|
|
+
|
|
|
+ reqStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
|
|
|
+ reqStream.Close();
|
|
|
+
|
|
|
+ HttpWebResponse rsp = (HttpWebResponse)req.GetResponse();
|
|
|
+ Encoding encoding = Encoding.GetEncoding(rsp.CharacterSet);
|
|
|
+ return GetResponseAsString(rsp, encoding);
|
|
|
+ }
|
|
|
+
|
|
|
+ public HttpWebRequest GetWebRequest(string url, string method)
|
|
|
+ {
|
|
|
+ HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
|
|
|
+ req.ServicePoint.Expect100Continue = false;
|
|
|
+ req.Method = method;
|
|
|
+ req.KeepAlive = true;
|
|
|
+ req.Timeout = 100000;
|
|
|
+ return req;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 把响应流转换为文本。
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="rsp">响应流对象</param>
|
|
|
+ /// <param name="encoding">编码方式</param>
|
|
|
+ /// <returns>响应文本</returns>
|
|
|
+ public string GetResponseAsString(HttpWebResponse rsp, Encoding encoding)
|
|
|
+ {
|
|
|
+ StringBuilder result = new StringBuilder();
|
|
|
+ Stream stream = null;
|
|
|
+ StreamReader reader = null;
|
|
|
+
|
|
|
+ try
|
|
|
+ {
|
|
|
+ // 以字符流的方式读取HTTP响应
|
|
|
+ stream = rsp.GetResponseStream();
|
|
|
+ reader = new StreamReader(stream, encoding);
|
|
|
+
|
|
|
+ // 按字符读取并写入字符串缓冲
|
|
|
+ int ch = -1;
|
|
|
+ while ((ch = reader.Read()) > -1)
|
|
|
+ {
|
|
|
+ // 过滤结束符
|
|
|
+ char c = (char)ch;
|
|
|
+ if (c != '\0')
|
|
|
+ {
|
|
|
+ result.Append(c);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ finally
|
|
|
+ {
|
|
|
+ // 释放资源
|
|
|
+ if (reader != null) reader.Close();
|
|
|
+ if (stream != null) stream.Close();
|
|
|
+ if (rsp != null) rsp.Close();
|
|
|
+ }
|
|
|
+
|
|
|
+ return result.ToString();
|
|
|
+ }
|
|
|
+
|
|
|
#endregion
|
|
|
|
|
|
}
|