企业付款退款等重写

2020-03-01 21:09:59 +08:00
parent 3afc837079
commit c387151c74
7 changed files with 311 additions and 205 deletions
--- a/yshop-mp/src/main/java/co/yixiang/mp/service/YxPayService.java
+++ b/yshop-mp/src/main/java/co/yixiang/mp/service/YxPayService.java
@ -0,0 +1,154 @@
+package co.yixiang.mp.service;
+
+import cn.hutool.core.util.StrUtil;
+import co.yixiang.exception.BadRequestException;
+import co.yixiang.exception.ErrorRequestException;
+import co.yixiang.mp.config.WxPayConfiguration;
+import co.yixiang.mp.handler.RedisHandler;
+import com.github.binarywang.wxpay.bean.entpay.EntPayRequest;
+import com.github.binarywang.wxpay.bean.order.WxPayMpOrderResult;
+import com.github.binarywang.wxpay.bean.order.WxPayMwebOrderResult;
+import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
+import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
+import com.github.binarywang.wxpay.exception.WxPayException;
+import com.github.binarywang.wxpay.service.WxPayService;
+import lombok.AllArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName YxPayService
+ * @Author hupeng <610796224@qq.com>
+ * @Date 2020/3/1
+ **/
+@Service
+@AllArgsConstructor
+public class YxPayService {
+
+    private final RedisHandler redisHandler;
+
+    /**
+     * 微信公众号支付/小程序支付
+     *
+     * @param orderId
+     * @param openId   公众号/小程序openid
+     * @param body
+     * @param totalFee
+     * @return
+     * @throws WxPayException
+     */
+    public WxPayMpOrderResult wxPay(String orderId, String openId, String body,
+                                    Integer totalFee,int type) throws WxPayException {
+
+        String apiUrl = redisHandler.getVal("api_url");
+        if (StrUtil.isBlank(apiUrl)) throw new ErrorRequestException("请配置api地址");
+
+        WxPayService wxPayService = WxPayConfiguration.getPayService();
+        WxPayUnifiedOrderRequest orderRequest = new WxPayUnifiedOrderRequest();
+
+        orderRequest.setTradeType("JSAPI");
+        orderRequest.setOpenid(openId);
+        orderRequest.setBody(body);
+        orderRequest.setOutTradeNo(orderId);
+        orderRequest.setTotalFee(totalFee);
+        orderRequest.setSpbillCreateIp("127.0.0.1");
+        if(type == 2){
+            orderRequest.setNotifyUrl(apiUrl + "/api/wechat/renotify");
+        }else{
+            orderRequest.setNotifyUrl(apiUrl + "/api/wechat/notify");
+        }
+
+
+        WxPayMpOrderResult orderResult = wxPayService.createOrder(orderRequest);
+
+        return orderResult;
+
+    }
+
+
+    /**
+     * 微信H5支付
+     *
+     * @param orderId
+     * @param body
+     * @param totalFee
+     * @return
+     * @throws WxPayException
+     */
+    public WxPayMwebOrderResult wxH5Pay(String orderId, String body,
+                                        Integer totalFee,int type) throws WxPayException {
+
+        String apiUrl = redisHandler.getVal("api_url");
+        if (StrUtil.isBlank(apiUrl)) throw new ErrorRequestException("请配置api地址");
+
+        WxPayService wxPayService = WxPayConfiguration.getPayService();
+        WxPayUnifiedOrderRequest orderRequest = new WxPayUnifiedOrderRequest();
+
+        orderRequest.setTradeType("MWEB");
+        orderRequest.setBody(body);
+        orderRequest.setOutTradeNo(orderId);
+        orderRequest.setTotalFee(totalFee);
+        orderRequest.setSpbillCreateIp("127.0.0.1");
+        if(type == 2){
+            orderRequest.setNotifyUrl(apiUrl + "/api/wechat/renotify");
+        }else{
+            orderRequest.setNotifyUrl(apiUrl + "/api/wechat/notify");
+        }
+
+        WxPayMwebOrderResult orderResult = wxPayService.createOrder(orderRequest);
+
+        return orderResult;
+
+    }
+
+
+    /**
+     * 退款
+     * @param orderId
+     * @param totalFee
+     * @throws WxPayException
+     */
+    public void refundOrder(String orderId, Integer totalFee) throws WxPayException {
+        String apiUrl = redisHandler.getVal("api_url");
+        if (StrUtil.isBlank(apiUrl)) throw new ErrorRequestException("请配置api地址");
+
+        WxPayService wxPayService = WxPayConfiguration.getPayService();
+        WxPayRefundRequest wxPayRefundRequest = new WxPayRefundRequest();
+
+        wxPayRefundRequest.setTotalFee(totalFee);//订单总金额
+        wxPayRefundRequest.setOutTradeNo(orderId);
+        wxPayRefundRequest.setOutRefundNo(orderId);
+        wxPayRefundRequest.setRefundFee(totalFee);//退款金额
+        wxPayRefundRequest.setNotifyUrl(apiUrl + "/api/notify/refund");
+
+        wxPayService.refund(wxPayRefundRequest);
+    }
+
+
+    /**
+     * 企业打款
+     * @param openid
+     * @param no
+     * @param userName
+     * @param amount
+     * @throws WxPayException
+     */
+    public void entPay(String openid,String no,String userName,Integer amount) throws WxPayException{
+        WxPayService wxPayService = WxPayConfiguration.getPayService();
+        EntPayRequest entPayRequest = new EntPayRequest();
+
+        entPayRequest.setOpenid(openid);
+        entPayRequest.setPartnerTradeNo(no);
+        entPayRequest.setCheckName("FORCE_CHECK");
+        entPayRequest.setReUserName(userName);
+        entPayRequest.setAmount(amount);
+        entPayRequest.setDescription("提现");
+        entPayRequest.setSpbillCreateIp("127.0.0.1");
+        wxPayService.getEntPayService().entPay(entPayRequest);
+
+    }
+
+
+}