From dda268997ca8f8a364f7c19b45d7a43a50a98efe Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期二, 25 十月 2022 18:00:11 +0800
Subject: [PATCH] changes
---
ximon-admin/src/main/java/com/sandu/ximon/admin/pay/wx/WxFastPayService.java | 309 ++++++++++++++++++++++++++++++++-------------------
1 files changed, 194 insertions(+), 115 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/wx/WxFastPayService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/wx/WxFastPayService.java
index eedfb8c..3193607 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/wx/WxFastPayService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/pay/wx/WxFastPayService.java
@@ -1,24 +1,39 @@
package com.sandu.ximon.admin.pay.wx;
-import cn.hutool.core.codec.Base64;
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
+import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
+import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import cn.hutool.crypto.SecureUtil;
+import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson.JSON;
import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
import com.github.binarywang.wxpay.bean.notify.WxPayRefundNotifyResult;
import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
import com.github.binarywang.wxpay.bean.result.WxPayUnifiedOrderResult;
+import com.github.binarywang.wxpay.config.WxPayConfig;
import com.github.binarywang.wxpay.constant.WxPayConstants;
import com.github.binarywang.wxpay.exception.WxPayException;
import com.github.binarywang.wxpay.service.WxPayService;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.util.IpUtil;
+import com.sandu.common.util.SpringContextHolder;
+import com.sandu.ximon.admin.dto.wxquerydto.WxOrderDto;
import com.sandu.ximon.admin.pay.wxpay.UsrWxPayConfigService;
+import com.sandu.ximon.admin.service.C3mOrderService;
+import com.sandu.ximon.dao.domain.C3mOrder;
import com.sandu.ximon.dao.domain.WxConfigEntity;
+import com.sandu.ximon.dao.enums.OrderStatus;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import javax.servlet.http.HttpServletRequest;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -33,55 +48,42 @@
public class WxFastPayService {
private final com.github.binarywang.wxpay.service.WxPayService wxPayService;
- //private final WxPayProperties wxPayProperties;
- public static final String WECHAT_ORDER_PAY_CALLBACK_URL = "http://49.235.239.118:20012/callback/pay/wechatCallback";
+ public static final String WECHAT_ORDER_PAY_CALLBACK_URL = "http://112.74.63.130:20017/callback/pay/wechatCallback";
+ //寰俊璁㈠崟鐘舵�佹煡璇�
+ public static final String WECHAT_ORDER_QUETY_URL = "https://api.mch.weixin.qq.com/v3/pay/transactions/out-trade-no/";
+ public static final String WECHAT_ORDER_QUETY = "?mchid=";
+
+ private final UsrWxPayConfigService wxPayConfigService;
+
/**
- * app鏀粯
+ * 寰俊璁㈠崟鐘舵�佹煡璇�
*
- * @param openId
- * @param body 鍟嗗搧鎻忚堪
- * @param orderId 璁㈠崟id
- * @param totalFee 鏀粯閲戦锛堝垎锛�
+ * @param poleId
+ * @param outTradeNo
* @return
*/
- public SortedMap<Object, Object> miniAppPay(WxPayService wxPayService, String openId, String body,
- String orderId, int totalFee, String callbackUrl) {
- WxPayUnifiedOrderRequest wxPayUnifiedOrderRequest = new WxPayUnifiedOrderRequest();
- wxPayUnifiedOrderRequest.setBody(body);
- wxPayUnifiedOrderRequest.setOutTradeNo(orderId);
- wxPayUnifiedOrderRequest.setTotalFee(totalFee);
- wxPayUnifiedOrderRequest.setOpenid(openId);
-
- wxPayUnifiedOrderRequest.setSignType(WxPayConstants.SignType.MD5);
- wxPayUnifiedOrderRequest.setSpbillCreateIp(IpUtil.getRealIp());
- wxPayUnifiedOrderRequest.setNotifyUrl(callbackUrl);
- wxPayUnifiedOrderRequest.setTradeType(WxPayConstants.TradeType.JSAPI);
-
- try {
- WxPayUnifiedOrderResult wxPayUnifiedOrderResult = wxPayService.unifiedOrder(wxPayUnifiedOrderRequest);
- String time = String.valueOf(System.currentTimeMillis() / 1000);
- if (WxPayConstants.ResultCode.SUCCESS.equals(wxPayUnifiedOrderResult.getResultCode())) {
- SortedMap<Object, Object> hashMap = new TreeMap<>();
- hashMap.put("appId", wxPayUnifiedOrderResult.getAppid());
- hashMap.put("nonceStr", wxPayUnifiedOrderResult.getNonceStr());
- hashMap.put("package", "prepay_id=" + wxPayUnifiedOrderResult.getPrepayId());
- hashMap.put("signType", WxPayConstants.SignType.MD5);
- hashMap.put("timeStamp", time);
- String wechatSign = createSign(wxPayService.getConfig().getMchKey(), hashMap);
- hashMap.put("paySign", wechatSign);
- return hashMap;
- } else {
- log.error("寰俊鏀粯澶辫触锛寋}", wxPayUnifiedOrderResult.getErrCodeDes());
- throw new BusinessException("寰俊鏀粯澶辫触锛�" + wxPayUnifiedOrderResult);
- }
- } catch (WxPayException e) {
- log.error("寰俊鏀粯澶辫触锛寋}", e.getErrCodeDes());
- throw new BusinessException("寰俊鏀粯澶辫触锛�" + e.getErrCodeDes());
+ public boolean WxOrderQuery(Long poleId, String outTradeNo) {
+ WxConfigEntity wxConfig = wxPayConfigService.getConfigByPoleId(poleId);
+ if (wxConfig == null) {
+ throw new BusinessException("鑾峰彇寰俊鏀粯閰嶇疆澶辫触");
}
+ String s = HttpUtil.get(WECHAT_ORDER_QUETY_URL + outTradeNo + WECHAT_ORDER_QUETY + wxConfig.getMchId());//WxOrderDto
+ WxOrderDto wxOrderDto = JSON.parseObject(s, WxOrderDto.class);
+ if (("SUCCESS").equals(wxOrderDto.getTrade_state())) {
+ return true;
+ }
+
+ return false;
}
- private String createSign(String mchKey, SortedMap<Object, Object> parameters) {
+ /**
+ * @param parameters
+ * @return
+ */
+ @SuppressWarnings("rawtypes")
+ private String createSign(String Key, SortedMap<Object, Object> parameters) {
+
StringBuffer sb = new StringBuffer();
Set es = parameters.entrySet();// 鎵�鏈夊弬涓庝紶鍙傜殑鍙傛暟鎸夌収accsii鎺掑簭锛堝崌搴忥級
for (Object e : es) {
@@ -92,10 +94,35 @@
sb.append(k + "=" + v + "&");
}
}
- sb.append("key=" + mchKey);
+ sb.append("key=" + Key);
System.out.println("瀛楃涓叉嫾鎺ュ悗鏄�:" + sb.toString());
return SecureUtil.md5(sb.toString()).toUpperCase();
+// StringBuffer sb = new StringBuffer();
+// Set es = parameters.entrySet();// 鎵�鏈夊弬涓庝紶鍙傜殑鍙傛暟鎸夌収accsii鎺掑簭锛堝崌搴忥級
+// Iterator it = es.iterator();
+// while (it.hasNext()) {
+// Map.Entry entry = (Map.Entry) it.next();
+// String k = (String) entry.getKey();
+// Object v = entry.getValue();
+// if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
+// sb.append(k + "=" + v + "&");
+// }
+// }
+// sb.append("key=" + Key);
+// System.out.println("瀛楃涓叉嫾鎺ュ悗鏄�:" + sb.toString());
+// String sign = EncriptionKit.encrypt(sb.toString()).toUpperCase();
+// return sign;
}
+
+ public WxPayOrderNotifyResult parseOrderNotifyResult(String xmlData) {
+ try {
+ return wxPayService.parseOrderNotifyResult(xmlData);
+ } catch (WxPayException e) {
+ e.printStackTrace();
+ throw new BusinessException("瑙ｆ瀽鍥炶皟缁撴灉澶辫触锛�" + e.getErrCodeDes());
+ }
+ }
+
public WxPayOrderNotifyResult parseOrderNotifyResult(WxPayService wxPayService, String xmlData) {
try {
@@ -106,7 +133,7 @@
}
}
- public WxPayRefundNotifyResult parseRefundNotifyResult(WxPayService wxPayService, String xmlData) {
+ public WxPayRefundNotifyResult parseRefundNotifyResult(String xmlData) {
try {
return wxPayService.parseRefundNotifyResult(xmlData);
} catch (WxPayException e) {
@@ -115,89 +142,49 @@
}
}
- /**
- * 璁㈠崟閫�娆� 鍙兘閫�娆句竴娆�
- *
- * @param wxPayService
- * @param orderId
- * @param refundFee
- * @param callbackUrl
- * @return
- */
- public boolean refundOrder(WxPayService wxPayService, String orderId, String refundSn, Integer refundFee, String callbackUrl) {
- WxPayRefundRequest refundRequest = new WxPayRefundRequest();
- refundRequest.setOutTradeNo(orderId);
- refundRequest.setOutRefundNo(refundSn);
- refundRequest.setRefundFee(refundFee);
- refundRequest.setTotalFee(refundFee);
- refundRequest.setNotifyUrl(callbackUrl);
- try {
- WxPayRefundResult wxPayRefundResult = wxPayService.refund(refundRequest);
- if (WxPayConstants.ResultCode.SUCCESS.equals(wxPayRefundResult.getResultCode())) {
- return true;
- } else {
- log.error("寰俊閫�娆惧け璐ワ紝{}", wxPayRefundResult.getErrCodeDes());
- throw new BusinessException("寰俊閫�娆惧け璐ワ紝" + wxPayRefundResult.getErrCodeDes());
- }
- } catch (WxPayException e) {
- log.error("寰俊閫�娆惧け璐ワ紝{}", e.getErrCodeDes());
- throw new BusinessException("寰俊閫�娆惧け璐ワ紝" + e.getErrCodeDes());
- }
- }
-
-
- /**
- * 鐢熸垚浜岀淮鐮佷粯娆�
- */
- public String generateQRCodePay(WxPayService wxPayService, String body,
- String orderId, int totalFee, String callbackUrl) {
- WxPayUnifiedOrderRequest wxPayUnifiedOrderRequest = new WxPayUnifiedOrderRequest();
- wxPayUnifiedOrderRequest.setBody(body);
- wxPayUnifiedOrderRequest.setOutTradeNo(orderId);
- wxPayUnifiedOrderRequest.setTotalFee(totalFee);
- wxPayUnifiedOrderRequest.setProductId(orderId);
-
- wxPayUnifiedOrderRequest.setSignType(WxPayConstants.SignType.MD5);
- wxPayUnifiedOrderRequest.setSpbillCreateIp(IpUtil.getRealIp());
- wxPayUnifiedOrderRequest.setNotifyUrl(callbackUrl);
- wxPayUnifiedOrderRequest.setTradeType(WxPayConstants.TradeType.NATIVE);
-
- try {
- WxPayUnifiedOrderResult wxPayUnifiedOrderResult = wxPayService.unifiedOrder(wxPayUnifiedOrderRequest);
- if (WxPayConstants.ResultCode.SUCCESS.equals(wxPayUnifiedOrderResult.getResultCode())) {
- byte[] scanPayQrcodeMode2 = wxPayService.createScanPayQrcodeMode2(wxPayUnifiedOrderResult.getCodeURL(), null, null);
- String encode = Base64.encode(scanPayQrcodeMode2);
- return encode;
- } else {
- log.error("寰俊鏀粯澶辫触锛寋}", wxPayUnifiedOrderResult.getErrCodeDes());
- throw new BusinessException("寰俊鏀粯澶辫触锛�" + wxPayUnifiedOrderResult.getErrCodeDes());
- }
- } catch (WxPayException e) {
- log.error("寰俊鏀粯澶辫触锛寋}", e.getErrCodeDes());
- throw new BusinessException("寰俊鏀粯澶辫触锛�" + e.getErrCodeDes());
- }
- }
/**
* 閫�娆�
- * @param totalAmount
- * @param refundAmount
- * @param outTradeNo
- * @param poleId
* @return
*/
- public boolean refund(Double totalAmount, Double refundAmount, String outTradeNo, Long poleId) {
- WxConfigEntity wxConfig = UsrWxPayConfigService.getBean().getConfigByPoleId(poleId);
+ @Transactional(rollbackFor = Exception.class)
+ public boolean refund(C3mOrder c3mOrder) {
+
+ WxConfigEntity wxConfig = wxPayConfigService.getConfigByPoleId(c3mOrder.getPoleId());
+
+ if (wxConfig.getKeyPath() == null && wxConfig.getKeyPath().isEmpty()) {
+ throw new BusinessException("寰俊璇佷功涓嶅瓨鍦�,鏃犳硶杩涜閫�娆�");
+ }
+ //璁剧疆寰俊鏀粯鍙傛暟
+ WxPayConfig payConfig = new WxPayConfig();
+
+ payConfig.setAppId(StringUtils.trimToNull(wxConfig.getAppappid()));
+ payConfig.setMchId(StringUtils.trimToNull(wxConfig.getMchId()));
+ payConfig.setMchKey(StringUtils.trimToNull(wxConfig.getPrivateKey()));
+ payConfig.setSubAppId(StringUtils.trimToNull(null));
+ payConfig.setSubMchId(StringUtils.trimToNull(null));
+ payConfig.setKeyPath(StringUtils.trimToNull(wxConfig.getKeyPath()));
+ wxPayService.setConfig(payConfig);
+
+
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
String refundNo = sdf.format(new Date());
WxPayRefundRequest refundRequest = new WxPayRefundRequest();
- refundRequest.setOutTradeNo(outTradeNo);
+ //閫�娆鹃噾棰濅笉鑳藉ぇ浜庤鍗曟�婚噾棰�
+ if (c3mOrder.getRefundAmount() > c3mOrder.getTotalAmount()) {
+ throw new BusinessException("閫�娆鹃噾棰濅笉鑳藉ぇ浜庤鍗曟�婚噾棰�");
+ }
+ System.out.println("" + c3mOrder.getRefundAmount());
+ refundRequest.setOutTradeNo(c3mOrder.getOutTradeNo());
refundRequest.setOutRefundNo(refundNo);
- refundRequest.setTotalFee(Integer.valueOf(parseWxAmount((totalAmount + ""))));
- refundRequest.setRefundFee(Integer.valueOf(parseWxAmount((refundAmount + ""))));
+ refundRequest.setTotalFee(Integer.valueOf(parseWxAmount((c3mOrder.getTotalAmount() + ""))));
+ refundRequest.setRefundFee(Integer.valueOf(parseWxAmount((c3mOrder.getRefundAmount() + ""))));
try {
WxPayRefundResult wxPayRefundResult = wxPayService.refund(refundRequest);
if (WxPayConstants.ResultCode.SUCCESS.equals(wxPayRefundResult.getResultCode())) {
+ c3mOrder.setOrderStatus(OrderStatus.REFUND.getStatus());
+ c3mOrder.setChargingStates(1);
+ SpringContextHolder.getBean(C3mOrderService.class).updateById(c3mOrder);
return true;
} else {
log.error("寰俊閫�娆惧け璐ワ紝{}", wxPayRefundResult.getErrCodeDes());
@@ -224,4 +211,96 @@
return amount;
}
+ /**
+ * 灏忕▼搴忔敮浠� 寰俊
+ *
+ * @param body
+ * @param orderId
+ * @param totalFee
+ * @param poleId
+ * @return
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public SortedMap<Object, Object> miniAppPay(HttpServletRequest request, String body, String orderId, int totalFee, Long poleId, String wxCode) throws WxErrorException {
+ WxConfigEntity wxConfig = wxPayConfigService.getConfigByPoleId(poleId);
+
+ //璁剧疆寰俊鏀粯鍙傛暟
+ WxPayConfig payConfig = new WxPayConfig();
+
+ payConfig.setAppId(StringUtils.trimToNull(wxConfig.getAppappid()));
+ payConfig.setMchId(StringUtils.trimToNull(wxConfig.getMchId()));
+ payConfig.setMchKey(StringUtils.trimToNull(wxConfig.getPrivateKey()));
+ payConfig.setSubAppId(StringUtils.trimToNull(null));
+ payConfig.setSubMchId(StringUtils.trimToNull(null));
+ payConfig.setKeyPath(StringUtils.trimToNull(null));
+ wxPayService.setConfig(payConfig);
+
+
+ //璁剧疆寰俊鍚屼竴璁㈠崟璇锋眰
+ WxPayUnifiedOrderRequest wxPayUnifiedOrderRequest = new WxPayUnifiedOrderRequest();
+ wxPayUnifiedOrderRequest.setBody(body);
+ wxPayUnifiedOrderRequest.setOutTradeNo(orderId);
+ wxPayUnifiedOrderRequest.setTotalFee(totalFee);
+ wxPayUnifiedOrderRequest.setOpenid(wxCode);
+
+
+ wxPayUnifiedOrderRequest.setSignType(WxPayConstants.SignType.MD5);
+ wxPayUnifiedOrderRequest.setSpbillCreateIp(IpUtil.getIpAddr(request));
+ wxPayUnifiedOrderRequest.setNotifyUrl(WECHAT_ORDER_PAY_CALLBACK_URL);
+ wxPayUnifiedOrderRequest.setTradeType(WxPayConstants.TradeType.JSAPI);
+ System.out.println("-----------" + wxPayUnifiedOrderRequest);
+
+ try {
+ WxPayUnifiedOrderResult wxPayUnifiedOrderResult = wxPayService.unifiedOrder(wxPayUnifiedOrderRequest);
+ String time = String.valueOf(System.currentTimeMillis() / 1000);
+ if (WxPayConstants.ResultCode.SUCCESS.equals(wxPayUnifiedOrderResult.getResultCode())) {
+ SortedMap<Object, Object> parameters = new TreeMap<>();
+ parameters.put("appId", wxPayUnifiedOrderResult.getAppid());
+
+ parameters.put("nonceStr", wxPayUnifiedOrderResult.getNonceStr()); // 闅忔満瀛楃涓�
+// parameters.put("partnerid", wxConfig.getMchId()); // 鍟嗘埛id
+
+ parameters.put("signType", WxPayConstants.SignType.MD5);
+ // parameters.put("out_trade_no", orderId);//鍟嗘埛璁㈠崟鍙�
+// parameters.put("prepayid", wxPayUnifiedOrderResult.getPrepayId());
+ parameters.put("package", "prepay_id=" + wxPayUnifiedOrderResult.getPrepayId());
+ parameters.put("timeStamp", time);
+
+ String sign = createSign(wxConfig.getPrivateKey(), parameters);
+
+ //hashMap.put("paySign", wechatSign);
+ parameters.put("paySign", sign);
+ return parameters;
+ } else {
+ log.error("寰俊鏀粯澶辫触锛寋}", wxPayUnifiedOrderResult.getErrCodeDes());
+ throw new BusinessException("寰俊鏀粯澶辫触锛�" + wxPayUnifiedOrderResult);
+ }
+ } catch (WxPayException e) {
+ log.error("寰俊鏀粯澶辫触锛寋}", e.getErrCodeDes());
+ throw new BusinessException("寰俊鏀粯澶辫触锛�" + e.getErrCodeDes());
+ }
+ }
+
+
+ public WxMaService getWxMaService(WxConfigEntity wxConfig) {
+ if (wxConfig == null) {
+ throw new BusinessException("鎵句笉鍒板井淇￠厤缃�");
+ }
+ WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
+ config.setAppid(wxConfig.getAppappid());
+ config.setSecret(wxConfig.getAppSecret());
+ WxMaService service = new WxMaServiceImpl();
+ service.setWxMaConfig(config);
+ return service;
+ }
+
+ public String getOpenId(Long poleId, String wxCode) throws WxErrorException {
+ WxConfigEntity userConfig = wxPayConfigService.getConfigByPoleId(poleId);
+ if (userConfig == null) {
+ throw new BusinessException("鎵句笉鍒板井淇￠厤缃�");
+ }
+ WxMaJscode2SessionResult sessionInfo = this.getWxMaService(userConfig).getUserService().getSessionInfo(wxCode);
+ return sessionInfo.getOpenid();
+ }
+
}
--
Gitblit v1.9.3