微信支付[v3]

2023-10-26 13:45:16

V2升级V3 顺便记录一下 ,文档: http://pay.weixin.qq.com/wiki/doc/api/index.html

！！！

支付授权目录与测试人的微信帐号白名单(出现access_denied或access_not_allow错误，请检查是否设置正确)

微信签名(用于jssdk调用支付，查询订单，异步参数签名等)

数字证书，用于微信退款

参数签名

对所有传入参数按照字段名的ASCII 码从小到大排序（字典序）后，使用URL 键值对的格式（即key1=value1&key2=value2…）拼接成字符串string1，注意：值为空的参数不参与签名在string1 最后拼接上key=Key( 商户支付密钥) 得到stringSignTemp 字符串，并对stringSignTemp 进行md5 运算，再将得到的字符串所有字符转换为大写，得到sign 值signValue

        /// <summary>
        /// 创建微信Sign
        /// </summary>
        /// <param name="key">微信商户支付密钥</param>
        /// <param name="dict">参数字典</param>
        /// <returns></returns>
        public string GenerateWxSign(string key, SortedDictionary<string, string> dict)
        {
            try
            {
                string str = string.Empty;
                foreach (var item in dict)
                {
                    if (item.Key != "sign" && item.Value.ToString() != "")
                    {
                        str += item.Key + "=" + item.Value + "&";
                    }
                }
                str = str.Trim(‘&‘);
                //在string后加入API KEY
                str += "&key=" + key;
                //MD5加密
                var md5 = System.Security.Cryptography.MD5.Create();
                var bs = md5.ComputeHash(Encoding.UTF8.GetBytes(str));
                var sb = new StringBuilder();
                foreach (byte b in bs)
                {
                    sb.Append(b.ToString("x2"));
                }
                //所有字符转为大写
                return sb.ToString().ToUpper();
            }
            catch (Exception)
            {
                return string.Empty;
            }
        }

异步通知

基本按照文档来，返回的参数要使用流的方式来读取XML，另外验证参数的合法性可以验证签名或调用一次微信订单查询接口

    /// <summary>
    /// 微信支付异步回调控制器【V3版本】
    /// </summary>
    public class WeixinController : Controller
    {
        private static readonly Logger logger = LogManager.GetCurrentClassLogger();

        /// <summary>
        /// 订单服务
        /// </summary>
        private readonly IOrderService _orderService;

        /// <summary>
        /// 微信服务
        /// </summary>
        private readonly IWeixinService _weixinService;

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="orderService">订单服务</param>
        /// <param name="weixinService">微信服务</param>
        public WeixinController(IOrderService orderService, IWeixinService weixinService)
        {
            _orderService = orderService;
            _weixinService = weixinService;
        }

        /// <summary>
        /// 微信Wap支付异步通知
        /// </summary>
        /// <returns></returns>
        public async Task<ActionResult> Notify()
        {
            int intLen = Convert.ToInt32(Request.InputStream.Length);
            if (intLen <= 0)
            {
                return Content(AjaxResult.Error("WeixinController NO Wap Notify PARAMS!").ToStringSafe());
            }
            try
            {
                var dict = new SortedDictionary<string, string>();
                //dict = @"appid=wxqe353dd942e01&attach=F&bank_type=CFT&cash_fee=1&fee_type=CNY&is_subscribe=Y&mch_id=10036766&nonce_str=e9605038cccbffe5ed2b2eb095345d18&openid=oIO3gjsiGqv7eeuAKhbB_V83V528&out_trade_no=68047857&result_code=SUCCESS&return_code=SUCCESS&sign=85A469F874619EAB924FA5B7EB779444&time_end=20150526183632&total_fee=1&trade_type=JSAPI&transaction_id=1001640542201505260168707842".ConvertStringToSortedDictionary();
                var xmlDoc = new XmlDocument();
                xmlDoc.Load(Request.InputStream);
                var root = xmlDoc.SelectSingleNode("xml");
                XmlNodeList xnl = root.ChildNodes;
                foreach (XmlNode xnf in xnl)
                {
                    dict.Add(xnf.Name, xnf.InnerText);
                }
                if (dict.Count <= 0)
                {
                    return Content(AjaxResult.Error("NO Notify PARAMS!").ToStringSafe());
                }
                logger.Info("【 WeixinController Wap Notify SDKUtil.ConvertDictionaryToString : 请求报文=[" + dict.ConvertDictionaryToString() + "]\n");
                //验证参数签名
                string signK = _weixinService.GenerateWxSign(WxPayConfig.KEY, dict);
                if (signK != dict["sign"])
                {
                    logger.Info("WeixinController Wap Notify Verify WxSign Error : 请求报文=[signK " + signK + " : dict[‘sign‘] " + dict["sign"] + "]\n");
                    return Content(AjaxResult.Error("WeixinController Wap Notify Verify WxSign Error " + "]\n").ToStringSafe());
                }
                //验证通信标识
                string return_code = dict["return_code"];
                if (!return_code.Equals("SUCCESS", StringComparison.OrdinalIgnoreCase))
                {
                    string return_msg = dict["return_msg"];
                    logger.Info("WeixinController Wap Notify return_code Error : 请求报文=[" + return_code + " : " + return_msg + "]\n");
                    return Content(AjaxResult.Error("WeixinController Wap Notify return_code Error " + return_code + "]\n").ToStringSafe());
                }
                //验证交易标识
                string result_code = dict["result_code"];
                if (!result_code.Equals("SUCCESS", StringComparison.OrdinalIgnoreCase))
                {
                    string err_code = dict["err_code"];
                    string err_code_des = dict["err_code_des"];
                    logger.Info("WeixinController Wap Notify return_code Error : 请求报文=[" + err_code + " : " + err_code_des + "]\n");
                    return Content(AjaxResult.Error("WeixinController Wap Notify return_code Error " + result_code + "]\n").ToStringSafe());
                }
                //公众账号ID
                string appid = dict["appid"];
                //商户号
                string mch_id = dict["mch_id"];
                //随机字符串
                string nonce_str = dict["nonce_str"];
                //签名
                string sign = dict["sign"];
                //用户在商户appid 下的唯一标识
                string openid = dict["openid"];
                //用户是否关注公众账
                string is_subscribe = dict["is_subscribe"];
                //交易类型
                string trade_type = dict["trade_type"];
                //付款银行
                string bank_type = dict["bank_type"];
                //订单总金额，单位为分
                string total_fee = dict["total_fee"];
                //金额分转元
                string total_fee_rmb = (float.Parse(total_fee) / 100).ToString();
                //商户订单号
                string out_trade_no = dict["out_trade_no"];
                //微信支付订单号
                string transaction_id = dict["transaction_id"];
                //商家数据包
                string attach = dict["attach"];
                //支付完成时间
                string time_end = dict["time_end"];
                //支付方式
                string paymethod = attach;
               //微信订单查询【使用签名验证废弃】
                //var wxorder = await _weixinService.Query(WxPayConfig.KEY, WxPayConfig.APPID, WxPayConfig.MCHID, transaction_id, out_trade_no);
               //检查订单是否已经支付
                 var order = await _orderService.Query(out_trade_no);
               if (order.IsNull() || order.Total_fee.IsNotNullOrEmpty()){
                    return Content(AjaxResult.Error("ORDERNO STATUS ERROR !!!").ToStringSafe());
               }
                //更新支付金额与订单状态
                 var orderFlag = await _orderService.Update(crsResv);
                if (orderFlag.IsError)
                {
                    logger.Fatal("WeixinController Wap Notify  Update Order Error  crsResv : " + crsResv.SerializeJson(System.Text.Encoding.UTF8));
                    return Json(new { IsError = true, Msg = "更新订单数据错误", Data = string.Empty }, JsonRequestBehavior.AllowGet);
                }
                //微信支付发货通知
                 var wxNotify = await _weixinService.WeixinNotify(openid, transaction_id, out_trade_no);
                //记录DB
                var save = await _weixinService.Save(wxAsync);
                //构造返回成功XML
                var wxdict = new SortedDictionary<string, string>();
                wxdict.Add("return_code", "SUCCESS");
                wxdict.Add("return_msg", "PAY_SUCCESS");
                string wxRXml = wxdict.ConvertWxDictToString();
                logger.Info("WeixinController Wap Notify  Success wxRXml : " + wxRXml + " 】");
                return Content(wxRXml);
            }
            catch (Exception ex)
            {
                logger.Fatal("WeixinController Wap Notify Exception : " + ex.Message + " 】", ex);
                return Content(AjaxResult.Error("WeixinController Wap Notify Exception").ToStringSafe());
            }
        }

        /// <summary>
        /// 字典转微信返回XML
        /// </summary>
        /// <typeparam name="TKey"></typeparam>
        /// <typeparam name="TValue"></typeparam>
        /// <param name="wxdict"></param>
        /// <returns></returns>
        public static string ConvertWxDictToString<TKey, TValue>(this IDictionary<TKey, TValue> wxdict)
        {
            try
            {
                string xml = "<xml>";
                wxdict.ForEach(wd =>
                {
                    if (wd.Value.GetType() == typeof(int))
                    {
                        xml += "<" + wd.Key + ">" + wd.Value + "</" + wd.Key + ">";
                    }
                    else if (wd.Value.GetType() == typeof(string))
                    {
                        xml += "<" + wd.Key + ">" + "<![CDATA[" + wd.Value + "]]></" + wd.Key + ">";
                    }
                });
                xml += "</xml>";
                return xml;
            }
            catch (Exception)
            {
                return string.Empty;
            }
        }

订单查询

        /// <summary>
        /// 微信订单查询
         /// </summary>
        /// <param name="appid">公众账号ID</param>
        /// <param name="mch_id">商户号</param>
        /// <param name="transaction_id">微信的订单号</param>
        /// <param name="out_trade_no">商户订单号</param>
        /// <param name="nonce_str">随机字符串</param>
        /// <param name="sign">签名</param>
        /// <returns></returns>
        public async Task<WebAPIResponse> Query(string appid, string mch_id, string transaction_id, string out_trade_no, string nonce_str, string sign)
        {
            if (appid.IsEmpty() || mch_id.IsEmpty() || transaction_id.IsEmpty())
            {
                return new WebAPIResponse { IsError = true, Msg = "参数有误！！！" };
            }
            try
            {
                var dict = new Dictionary<string, string>();
                dict.Add("appid", appid);
                dict.Add("mch_id", mch_id);
                dict.Add("transaction_id", transaction_id);
                dict.Add("out_trade_no", out_trade_no);
                dict.Add("nonce_str", nonce_str);
                dict.Add("sign", sign);
                string xml = "<xml>";
                foreach (var pair in dict)
                {
                    if (pair.Value.GetType() == typeof(int))
                    {
                        xml += "<" + pair.Key + ">" + pair.Value + "</" + pair.Key + ">";
                    }
                    else if (pair.Value.GetType() == typeof(string))
                    {
                        xml += "<" + pair.Key + ">" + "<![CDATA[" + pair.Value + "]]></" + pair.Key + ">";
                    }
                }
                xml += "</xml>";
                logger.Info("WeixinRepository WeixinNotify Req xml: " + xml);
                var data = await @"https://api.mch.weixin.qq.com/pay/orderquery".PostStringAsync(xml).ReceiveString();
                logger.Info("WeixinRepository WeixinNotify Resp xml: " + data);
                if (data.IsNotNullOrEmpty() && data.Contains("SUCCESS", StringComparison.OrdinalIgnoreCase))
                {
                    return new WebAPIResponse { IsError = false, Data = "查询订单成功！！！" };
                }
                return new WebAPIResponse { IsError = true, Msg = "微信订单查询失败！！！" };
            }
            catch (Exception ex)
            {
                logger.Error("WeixinRepository WeixinNotify ConvertDictionaryToJson Exception :" + ex.Message, ex);
                return new WebAPIResponse { IsError = true, Msg = ex.Message };
            }
        }

微信退款

!!!需注意签名与证书

        /// <summary>
        /// 微信申请退款V3
        /// </summary>
        /// <param name="orderNo">订单号</param>
        /// <returns></returns>
        public bool RefundWxV3(string orderNo)
        {
            try
            {
                //查询支付信息
                  var orderAsync =await _orderService.Query(orderNo);
                var dict = new SortedDictionary<string, string>();
                dict.Add("appid", WxPayConfig.APPID);
                dict.Add("mch_id", WxPayConfig.MCHID);
                dict.Add("nonce_str", ConstantKey.NonceStr);
                dict.Add("transaction_id", orderAsync.transaction_id);
                dict.Add("out_trade_no", orderAsync.out_trade_no);
                dict.Add("out_refund_no", WxPayConfig.GenerateOutTradeNo);
                dict.Add("total_fee", orderAsync.total_fee);
                dict.Add("refund_fee", orderAsync.total_fee);
                dict.Add("op_user_id", WxPayConfig.MCHID);
                string sign = GenerateWxSign(WxPayConfig.KEY, dict);
                dict.Add("sign", sign);
                string xml = "<xml>";
                foreach (var pair in dict)
                {
                    if (pair.Value.GetType() == typeof(int))
                    {
                        xml += "<" + pair.Key + ">" + pair.Value + "</" + pair.Key + ">";
                    }
                    else if (pair.Value.GetType() == typeof(string))
                    {
                        xml += "<" + pair.Key + ">" + "<![CDATA[" + pair.Value + "]]></" + pair.Key + ">";
                    }
                }
                xml += "</xml>";
                logger.Info("RefundWxV3 Req xml: " + xml);
                var data = HttpWxCert(@"https://api.mch.weixin.qq.com/secapi/pay/refund", "POST", xml, "text/xml", isUseCert: true);
                logger.Info("RefundWxV3 Resp xml: " + data);
                if (data.IsNotEmpty() && data.Contains("SUCCESS", StringComparison.OrdinalIgnoreCase))
                {
                    return true;
                }
                return false;
            }
            catch (Exception ex)
            {
                logger.Error("CancelResvForWeb RefundWxV3 Exception :" + ex.Message, ex);
                return false;
            }
        }
 /// <summary>
        /// 创建HTTP请求
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="method">请求方式</param>
        /// <param name="data">请求参数</param>
        /// <param name="contentType">设置HTTP contentType类型</param>
        /// <param name="isUseCert">是否使用证书</param>
        /// <param name="timeout">请求超时时间</param>
        /// <returns></returns>
        public static string HttpWxCert(string url, string method = "GET", string data = null, string contentType = "application/x-www-form-urlencoded", bool isUseCert = false, int timeout = 15000)
        {
            if (url.IsEmpty())
                throw new ArgumentNullException("url");
            HttpWebRequest req = null;
            HttpWebResponse resp = null;
            StreamReader sr = null;
            Stream stream = null;
            try
            {
                if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
                {
                    System.Net.ServicePointManager.ServerCertificateValidationCallback += (se, cert, chain, sslError) =>
                    {
                        return true;
                    };
                }
                //设置最大连接数
                System.Net.ServicePointManager.DefaultConnectionLimit = 200;
                req = (HttpWebRequest)WebRequest.Create(url);
                req.Method = method.ToUpper();
                req.Timeout = timeout;
                req.ContentType = contentType;
                //是否使用证书
                if (isUseCert)
                {
                    string pfxPath = WxPayConfig.SSLCERT_PATH;
                    logger.Info("wxV3.signCert.path pfxPath : " + pfxPath + " File Exists: " + File.Exists(pfxPath));
                    //string path = HttpContext.Current.Request.PhysicalApplicationPath;
                    //调用证书
                    var cert = new X509Certificate2(pfxPath, WxPayConfig.SSLCERT_PASSWORD, X509KeyStorageFlags.PersistKeySet | X509KeyStorageFlags.MachineKeySet);
                    req.ClientCertificates.Add(cert);
                }

                if (method.ToUpper() == "POST" && !data.IsEmpty())
                {
                    byte[] postBytes = UTF8Encoding.UTF8.GetBytes(data);
                    req.ContentLength = postBytes.Length;
                    using (stream = req.GetRequestStream())
                    {
                        stream.Write(postBytes, 0, postBytes.Length);
                    }
                }
                resp = (HttpWebResponse)req.GetResponse();
                using (sr = new StreamReader(resp.GetResponseStream(), Encoding.UTF8))
                {
                    return sr.ReadToEnd().Trim();
                }
            }
            catch (Exception ex)
            {
                logger.Error(string.Format("HttpWxCert Exception url: {0} \r\n data: {1}", url, data), ex);
                return string.Empty;
            }
            finally
            {
                if (sr != null)
                {
                    sr.Close();
                    sr = null;
                }
                if (stream != null)
                {
                    stream.Close();
                    stream = null;
                }
                if (resp != null)
                {
                    resp.Close();
                    resp = null;
                }
                if (req != null)
                {
                    req.Abort();
                    req = null;
                }
            }
        }

微信支付[v3]

码农公寓

参数签名

异步通知

订单查询

微信退款

相关文章