java微信公眾號支付開發之現金紅包

2024-07-14 08:40:21

字體：大中小

來源：轉載

供稿：網友

我們先來看看公眾號發放現金紅包的效果:

java,微信公眾號,支付開發,java微信公眾號開發,java微信現金紅包,微信公眾號現金紅包

需要調用商戶平臺的接口,接口發放規則如下:

1.發送頻率限制——默認1800/min
2.發送個數上限——按照默認1800/min算
3.金額上限——根據傳入場景id不同默認上限不同，可以在商戶平臺產品設置進行設置和申請，最大不大于4999元/個
4.其他的“量”上的限制還有哪些？——用戶當天的領取上限次數,默認是10
5.如果量上滿足不了我們的需求，如何提高各個上限？——金額上限和用戶當天領取次數上限可以在商戶平臺進行設置
注意-紅包金額大于200時，請求參數scene_id必傳，參數說明見下文。
注意2-根據監管要求，新申請商戶號使用現金紅包需要滿足兩個條件：1、入駐時間超過90天 2、連續正常交易30天。

請求Url https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack
是否需要證書是（證書及使用說明詳見商戶證書）
請求方式 POST

請求數據示例：

<xml><sign><![CDATA[E1EE61A91C8E90F299DE6AE075D60A2D]]></sign><mch_billno><![CDATA[0010010404201411170000046545]]></mch_billno><mch_id><![CDATA[888]]></mch_id><wxappid><![CDATA[wxcbda96de0b165486]]></wxappid><send_name><![CDATA[send_name]]></send_name><re_openid><![CDATA[onqOjjmM1tad-3ROpncN-yUfa6uI]]></re_openid><total_amount><![CDATA[200]]></total_amount><total_num><![CDATA[1]]></total_num><wishing><![CDATA[恭喜發財]]></wishing><client_ip><![CDATA[127.0.0.1]]></client_ip><act_name><![CDATA[新年紅包]]></act_name><remark><![CDATA[新年紅包]]></remark><scene_id><![CDATA[PRODUCT_2]]></scene_id><consume_mch_id><![CDATA[10000097]]></consume_mch_id><nonce_str><![CDATA[50780e0cca98c8c8e814883e5caa672e]]></nonce_str><risk_info>posttime%3d123123412%26clientversion%3d234134%26mobile%3d122344545%26deviceid%3dIOS</risk_info></xml>

接口需要調用商戶平臺的證書，證書需要去商戶平臺下載：

java,微信公眾號,支付開發,java微信公眾號開發,java微信現金紅包,微信公眾號現金紅包

然后在接口中使用證書，首先我們新建一個WeixinSSL 類

@Componentpublic class WeiXinSSL {  /**   * 證書類型   */  @Value("${werchant.storekey}")  private String storekey;  /**   * 文件路徑   */  @Value("${werchant.ssLfile}")  private String ssLfile;  /**   * 商戶號   */  @Value("${werchant.merchantNumber}")  private String merchantNumber;  public String getStorekey() {    return storekey;  }  public void setStorekey(String storekey) {    this.storekey = storekey;  }  public String getSsLfile() {    return ssLfile;  }  public void setSsLfile(String ssLfile) {    this.ssLfile = ssLfile;  }  public String getMerchantNumber() {    return merchantNumber;  }  public void setMerchantNumber(String merchantNumber) {    this.merchantNumber = merchantNumber;  }  }

封裝HttpClientSSL 類實現 https 請求加證書:

@Componentpublic class HttpClientSSL {  @Autowired  private WeiXinSSL weiXinSSL;  // 請求超時時間(毫秒) 5秒  public static RequestConfig requestConfig;  // 響應超時時間(毫秒) 60秒  public static int HTTP_RESPONSE_TIMEOUT = 60 * 1000;  // httpClient字符編碼  public static String encoding = "UTF-8";  public static RequestConfig getRequestConfig() {    return RequestConfig.custom().setConnectTimeout(5 * 1000)        .setConnectionRequestTimeout(HTTP_RESPONSE_TIMEOUT).build();  }  public static void setRequestConfig(RequestConfig requestConfig) {    HttpClientSSL.requestConfig = requestConfig;  }  /**   * https請求偽造證書   * @return   */  public CloseableHttpClient defaultSSLClient() {    SSLContext sslContext = null;    try {      new SSLContextBuilder().loadTrustMaterial(null,new TrustStrategy(){        @Override        public boolean isTrusted(X509Certificate[] chain, String authType)            throws java.security.cert.CertificateException {          return false;        }      });    } catch (NoSuchAlgorithmException | KeyStoreException e) {      e.printStackTrace();    }    SSLConnectionSocketFactory factory = new SSLConnectionSocketFactory(sslContext);    return HttpClients.custom().setSSLSocketFactory(factory).build();  }  /**   * https請求加證書   * @return   */  public CloseableHttpClient defaultSSLClientFile() {    if (this.weiXinSSL == null){      return this.defaultSSLClient();    }    FileInputStream inputStream = null;    KeyStore keyStore = null;    try {      // ssl類型      keyStore = KeyStore.getInstance(weiXinSSL.getStorekey());      // ssl文件      inputStream = new FileInputStream(weiXinSSL.getSsLfile());      // 設置ssl密碼      keyStore.load(inputStream,weiXinSSL.getMerchantNumber().toCharArray());    } catch (KeyStoreException | NoSuchAlgorithmException | CertificateException | IOException e1) {      e1.printStackTrace();    } finally {      try {        inputStream.close();      } catch (IOException e) {        e.printStackTrace();      }    }    SSLContext sslContext = null;    try {      sslContext = SSLContexts.custom().loadKeyMaterial(keyStore,weiXinSSL.getMerchantNumber().toCharArray()).build();    } catch (UnrecoverableKeyException | NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) {      e.printStackTrace();    }    SSLConnectionSocketFactory factory = new SSLConnectionSocketFactory(sslContext, new String[] { "TLSv1" }, null,        SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);    return HttpClients.custom().setSSLSocketFactory(factory).build();  }  /**   * 封裝發送請求的方法   * @throws UnsupportedEncodingException   */  public String send(String url, String data, CloseableHttpClient closeableHttpClient)      throws UnsupportedEncodingException {    CloseableHttpClient client = closeableHttpClient;    HttpPost httpPost = new HttpPost(URLDecoder.decode(url, encoding));    httpPost.addHeader("Connection", "keep-alive");    httpPost.addHeader("Accept", "*/*");    httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");    httpPost.addHeader("Host", "api.mch.weixin.qq.com");    httpPost.addHeader("X-Requested-With", "XMLHttpRequest");    httpPost.addHeader("Cache-Control", "max-age=0");    httpPost.addHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0) ");    httpPost.setConfig(this.getRequestConfig());// 設置超時時間    CloseableHttpResponse response = null;    // 參數放入    StringEntity entity = new StringEntity(data, encoding);    entity.setContentEncoding(encoding);    entity.setContentType("application/xml");    httpPost.setEntity(entity);    try {      response = client.execute(httpPost);      if (response.getStatusLine().getStatusCode() == 200) {        HttpEntity httpEntity = (HttpEntity) response.getEntity();        if (response != null) {          return EntityUtils.toString(httpEntity,encoding);        }      }    } catch (IOException e) {      e.printStackTrace();    }    return null;  }}

這樣我們就封裝了一個https請求加證書的實體類，接下來我們生成請求微信紅包接口：
https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack 的參數簽名：

/*** 紅包參數實體類 * @throws UnsupportedEncodingException */@Componentpublic class SendRedPack implements Serializable{  /**   *    */  private static final long serialVersionUID = -1000489228099916099L;  private String nonce_str;// 隨機字符串  private String sign;// 簽名  private String mch_billno;// 商戶訂單號  private String mch_id;// 商戶號  private String wxappid;// 公眾賬號  private String send_name;// 商戶名稱  private String re_openid;// 用戶  private int total_amount;// 付款金額 單位：分  private int total_num;// 紅包發放總人數  private String wishing;// 紅包祝福語  private String client_ip;// Ip地址  private String act_name;// 活動名稱  private String remark;// 備注  public String getNonce_str() {    return nonce_str;  }  public void setNonce_str(String nonce_str) {    this.nonce_str = nonce_str;  }  public String getSign() {    return sign;  }  public void setSign(String sign) {    this.sign = sign;  }  public String getMch_billno() {    return mch_billno;  }  public void setMch_billno(String mch_billno) {    this.mch_billno = mch_billno;  }  public String getMch_id() {    return mch_id;  }  public void setMch_id(String mch_id) {    this.mch_id = mch_id;  }  public String getWxappid() {    return wxappid;  }  public void setWxappid(String wxappid) {    this.wxappid = wxappid;  }  public String getSend_name() {    return send_name;  }  public void setSend_name(String send_name) {    this.send_name = send_name;  }  public String getRe_openid() {    return re_openid;  }  public void setRe_openid(String re_openid) {    this.re_openid = re_openid;  }  public int getTotal_amount() {    return total_amount;  }  public void setTotal_amount(int total_amount) {    this.total_amount = total_amount;  }  public int getTotal_num() {    return total_num;  }  public void setTotal_num(int total_num) {    this.total_num = total_num;  }  public String getWishing() {    return wishing;  }  public void setWishing(String wishing) {    this.wishing = wishing;  }  public String getClient_ip() {    return client_ip;  }  public void setClient_ip(String client_ip) {    this.client_ip = client_ip;  }  public String getAct_name() {    return act_name;  }  public void setAct_name(String act_name) {    this.act_name = act_name;  }  public String getRemark() {    return remark;  }  public void setRemark(String remark) {    this.remark = remark;  }}

接下來是發送紅包的控制器：

/** * 領紅包控制器 * @author zengliang */@Controller@RequestMapping(value="/redenveLopesReceive")public class RedEnvelopesReceiveController {  //微信唯一標識  @Value("${weixin.appid}")  private String appid;  //微信開發者密碼標識  @Value("${weixin.appsecret}")  public String appsecret;  @Autowired  private SendRedPack sendredpack;  @Autowired  private HttpClientSSL httpclientssl;  /**   * 發送XML參數   * @author zengliang   */  @ResponseBody  @RequestMapping(value="/sendXml")  public String sendXml(String openid,Long redenveLopes_id      ,String mch_billno){    RedenveLopes redenve = redenveLopesService.findOne(redenveLopes_id);    XMLUtil xmlUtil= new XMLUtil();    sendredpack.setAct_name(redenve.getAct_name());    sendredpack.setNonce_str(xmlUtil.random());    sendredpack.setRe_openid(openid);    sendredpack.setClient_ip(redenve.getClient_ip());    sendredpack.setMch_billno(mch_billno);    sendredpack.setMch_id(redenve.getMch_id());    String xx = redenve.getRemark();    sendredpack.setRemark(StringUtils.isEmpty(xx) == false?xx:"空");    sendredpack.setSend_name(redenve.getSend_name());    sendredpack.setTotal_amount(redenve.getTotal_amount());    sendredpack.setTotal_num(redenve.getTotal_num());    sendredpack.setWishing(redenve.getWishing());    sendredpack.setWxappid(redenve.getWxappidxx());    //生成簽名    String params = this.createSendRedPackOrderSign(sendredpack,redenve.getStore_key());    sendredpack.setSign(params);    xmlUtil.xstream().alias("xml",sendredpack.getClass());    //擴展xstream，使其支持CDATA塊    String requestXml = xmlUtil.xstream().toXML(sendredpack);    String result;    try {      result = httpclientssl.send("https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack",requestXml,httpclientssl.defaultSSLClientFile());      System.out.println("成功返回值"+result);      return result;    } catch (UnsupportedEncodingException e) {      e.printStackTrace();    }    return null;  }/**   * 生成簽名   * @param redPack   * @return   */  public String createSendRedPackOrderSign(SendRedPack redPack,String storekey){    StringBuffer sign = new StringBuffer();    sign.append("act_name=").append(redPack.getAct_name());    sign.append("&client_ip=").append(redPack.getClient_ip());    sign.append("&mch_billno=").append(redPack.getMch_billno());    sign.append("&mch_id=").append(redPack.getMch_id());    sign.append("&nonce_str=").append(redPack.getNonce_str());    sign.append("&re_openid=").append(redPack.getRe_openid());    sign.append("&remark=").append(redPack.getRemark());    sign.append("&send_name=").append(redPack.getSend_name());    sign.append("&total_amount=").append(redPack.getTotal_amount());    sign.append("&total_num=").append(redPack.getTotal_num());    sign.append("&wishing=").append(redPack.getWishing());    sign.append("&wxappid=").append(redPack.getWxappid());    sign.append("&key=").append(storekey);    return DigestUtils.md5Hex(sign.toString()).toUpperCase();  }}

然后我們需要用一個解析XML的工具類實現解析微信返回的XML

/** * 解析XML工具類 * @author zengliang */@Componentpublic class XMLUtil {  /**   * 解析微信返回的XML   * @param xml   * @return   * @throws Exception   */  @SuppressWarnings("unchecked")  public Map<String, String> parseXml(String xml)throws Exception {    Map<String,String> map = new HashMap<String,String>();     Document doc = null;     try {       doc = DocumentHelper.parseText(xml); // 將字符串轉為XML       Element rootElt = doc.getRootElement(); // 獲取根節點       List<Element> list = rootElt.elements();//獲取根節點下所有節點       for (Element element : list) { //遍歷節點         map.put(element.getName(), element.getText()); //節點的name為map的key，text為map的value       }     } catch (DocumentException e) {       e.printStackTrace();     } catch (Exception e) {       e.printStackTrace();     }    return map;   }  /**   * 擴展xstream，使其支持CDATA塊   */   private XStream xstream = new XStream(new XppDriver(new NoNameCoder()) {      @Override      public HierarchicalStreamWriter createWriter(Writer out) {          return new PrettyPrintWriter(out) {          // 對所有xml節點的轉換都增加CDATA標記          boolean cdata = true;          @Override          @SuppressWarnings("rawtypes")          public void startNode(String name, Class clazz) {            super.startNode(name, clazz);          }          @Override          public String encodeNode(String name) {            return name;          }          @Override          protected void writeText(QuickWriter writer, String text) {            if (cdata) {              writer.write("<![CDATA[");              writer.write(text);              writer.write("]]>");            } else {              writer.write(text);            }          }          };      }   });   private XStream inclueUnderlineXstream = new XStream(new DomDriver(null,new XmlFriendlyNameCoder("_-", "_")));   public XStream getXstreamInclueUnderline() {     return inclueUnderlineXstream;   }   public XStream xstream() {     return xstream;   }   /**   * 生成隨機數   * @return   */  public String random(){    String random = UUID.randomUUID().toString().replace("-", "");    return random;  }}

然后我們調用 sendXML 方法公眾號就能向用戶發送紅包了。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持VeVb武林網。

注：相關教程知識閱讀請移步到JAVA教程頻道。

上一篇：Spring-Cloud Eureka注冊中心實現高可用搭建

下一篇：Jedis操作Redis數據庫的方法