服务商支付版本

jiangping

2023-12-12 037c144cd417410deb8137c6f3fd271a34691742

 server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java

@@ -14,28 +14,25 @@
import com.doumee.dao.business.model.Transactions;
import com.doumee.dao.business.web.request.RefundDTO;
import com.doumee.dao.system.model.SystemDictData;
import com.doumee.service.business.RefundService;
import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
import com.github.binarywang.wxpay.exception.WxPayException;
import io.netty.handler.codec.base64.Base64Decoder;
import io.netty.handler.codec.base64.Base64Encoder;
import com.wechat.pay.java.service.refund.model.AmountReq;
import com.wechat.pay.java.service.refund.model.CreateRequest;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import sun.misc.BASE64Decoder;

import java.io.*;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.InputStream;
import java.math.BigDecimal;
import java.util.*;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;

/**
 * 微信小程序-公共方法
@@ -52,24 +49,73 @@

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Autowired
    private WxPayProperties wxPayProperties;

    @Transactional(rollbackFor = {BusinessException.class,Exception.class})
    public Refund wxRefund(RefundDTO refundDTO) {
    public boolean wxRefund(RefundDTO refundDTO) {
        // 发送退款请求
        Refund refund = new Refund();
        refund.setId(Constants.getUUID());
        refund.setCreateDate(new Date());
        refund.setMemberId(refundDTO.getMemberId());
        refund.setMoney(refundDTO.getRefundAmount());
//        refund.setOnlineOrderid(refNum);
        refund.setPayWay(Constants.ZERO);
        refund.setStatus(Constants.ZERO);
        refund.setDoneDate(new Date());
        refund.setCreator(refundDTO.getCreator());
        refund.setType(refundDTO.getType());
        refund.setObjId(refundDTO.getOrderId());
        refund.setReason(refundDTO.getReason());
        refund.setCanBalance(refundDTO.getCanBalance());
        refundMapper.insert(refund);

        CreateRequest request = new CreateRequest();
        request.setOutTradeNo(refundDTO.getOrderId());
        request.setOutRefundNo(refund.getId());
        request.setSubMchid(WxMiniConfig.wxProperties.getSubMchId());
        request.setNotifyUrl(WxMiniConfig.wxProperties.getRefundNotifyUrl());
        AmountReq amountReq = new AmountReq();
        amountReq.setTotal(refundDTO.getTotalAmount().longValue());
        amountReq.setRefund(refundDTO.getRefundAmount().longValue());
        amountReq.setCurrency("CNY");
        request.setAmount(amountReq);
        try {
            // 发送退款请求
            String refNum = ID.nextGUID();
            WxPayRefundRequest request = new WxPayRefundRequest();
            request.setOutTradeNo(refundDTO.getOrderId());
            request.setOutRefundNo(refNum);
            request.setTotalFee(refundDTO.getTotalAmount().intValue());
            request.setRefundFee(refundDTO.getRefundAmount().intValue());
            System.out.println("实际总金额" + refundDTO.getTotalAmount());
            System.out.println("实际退款金额" + refundDTO.getRefundAmount());
            com.wechat.pay.java.service.refund.model.Refund response = WxMiniConfig.refundService.create(request);
            if ("SUCCESS".equals(response.getStatus().name())
                    || "PROCESSING".equals(response.getStatus().name()) ) {
                return  true;
            }else{
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，退款申请失败哦！");
            }
        }catch (Exception e){
            e.printStackTrace();
            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，退款申请失败！");
        }

    }
    public Refund wxRefundOld(RefundDTO refundDTO) {
        // 发送退款请求
        String refNum = ID.nextGUID();
        CreateRequest request = new CreateRequest();
        request.setOutTradeNo(refundDTO.getOrderId());
        request.setOutRefundNo(refNum);
        request.setSubMchid(WxMiniConfig.wxProperties.getSubMchId());
        request.setNotifyUrl(WxMiniConfig.wxProperties.getRefundNotifyUrl());
//
        AmountReq amountReq = new AmountReq();
        amountReq.setTotal(refundDTO.getTotalAmount().longValue());
        amountReq.setRefund(refundDTO.getRefundAmount().longValue());
        amountReq.setCurrency("CNY");
        request.setAmount(amountReq);
        System.out.println("实际总金额" + refundDTO.getTotalAmount());
        System.out.println("实际退款金额" + refundDTO.getRefundAmount());
//            request.setTotalFee(1);
//            request.setRefundFee(1);
            WxPayRefundResult response = WxMiniConfig.wxPayService.refund(request);
            if ("SUCCESS".equals(response.getReturnCode()) && "SUCCESS".equals(response.getResultCode())) {
        try {
            com.wechat.pay.java.service.refund.model.Refund response = WxMiniConfig.refundService.create(request);
            if ("SUCCESS".equals(response.getStatus().name()) ) {
                //存储退款记录 与 流水记录
                Refund refund = new Refund();
                refund.setId(Constants.getUUID());
@@ -119,12 +165,16 @@
                transactionsMapper.insert(transactions);
                return refund;
            } else{
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),response.getErrCode() + response.getErrCodeDes());
                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，退款失败！");
            }
        } catch (WxPayException e) {
        }catch (BusinessException e){
            throw e;
        }catch (Exception e){
            e.printStackTrace();
            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，退款失败！");
        }
        throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"退款发生异常请联系管理员");


    }