代码修改

svr/svr-cloud-transfor/pom.xml

@@ -79,6 +79,16 @@
            <artifactId>tencentcloud-sdk-java</artifactId>
            <version>3.1.272</version>
        </dependency>
        <dependency>
            <groupId>org.bouncycastle</groupId>
            <artifactId>bcprov-jdk15on</artifactId>
            <version>1.68</version>
        </dependency>
        <dependency>
            <groupId>com.github.wechatpay-apiv3</groupId>
            <artifactId>wechatpay-java</artifactId>
            <version>0.2.15</version>
        </dependency>
    </dependencies>
    <build>

svr/svr-cloud-transfor/src/main/java/com/yihu/SvrCloudTransforApplication.java

@@ -1,5 +1,6 @@
package com.yihu;
import org.bouncycastle.jce.provider.BouncyCastleProvider;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
@@ -7,6 +8,8 @@ import org.springframework.boot.web.support.SpringBootServletInitializer;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableAsync;
import java.security.Security;
/**
 * Created by yeshijie on 2021/10/14.
 */
@@ -16,6 +19,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
public class SvrCloudTransforApplication extends SpringBootServletInitializer {
    public static void main(String[] args)  {
        Security.addProvider(new BouncyCastleProvider());
        SpringApplication.run(SvrCloudTransforApplication.class, args);
    }

svr/svr-cloud-transfor/src/main/java/com/yihu/jw/care/controller/TransforController.java

@@ -2,9 +2,14 @@ package com.yihu.jw.care.controller;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.wechat.pay.java.core.exception.ServiceException;
import com.wechat.pay.java.service.transferbatch.model.InitiateBatchTransferResponse;
import com.wechat.pay.java.service.transferbatch.model.TransferBatchEntity;
import com.wechat.pay.java.service.transferbatch.model.TransferDetailEntity;
import com.yihu.jw.care.RequestParamUtil;
import com.yihu.jw.care.service.AqgService;
import com.yihu.jw.care.service.TXYSmsService;
import com.yihu.jw.care.service.WeixinMchApi;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
@@ -36,8 +41,87 @@ public class TransforController {
    private AqgService aqgService;
    @Autowired
    private TXYSmsService txySmsService;
    @Autowired
    private WeixinMchApi weixinMchApi;
    private static final RestTemplate restTemplate = new RestTemplate();
    @ApiOperation("批量转账")
    @RequestMapping(value = "initiateBatchTransfer", method = {RequestMethod.POST,RequestMethod.GET})
    public String initiateBatchTransfer(
            @ApiParam(name="outBatchNo",required = true,value="批次no")
            @RequestParam(value = "outBatchNo",required = true) String outBatchNo,
            @ApiParam(name="batchName",required = true,value="批次名")
            @RequestParam(value = "batchName",required = true) String batchName,
            @ApiParam(name="batchRemark",required = true,value="批次备注")
            @RequestParam(value = "batchRemark",required = true) String batchRemark,
            @ApiParam(name="totalAmount",required = true,value="总费用单位分")
            @RequestParam(value = "totalAmount",required = true) Long totalAmount,
            @ApiParam(name="totalNum",required = true)
            @RequestParam(value = "totalNum",required = true) Integer totalNum,
            @ApiParam(name="outDetailNo",required = true)
            @RequestParam(value = "outDetailNo",required = true) String outDetailNo,
            @ApiParam(name="transferAmount",required = true)
            @RequestParam(value = "transferAmount",required = true) Long transferAmount,
            @ApiParam(name="transferRemark",required = true)
            @RequestParam(value = "transferRemark",required = true) String transferRemark,
            @ApiParam(name="openid",required = true,value="openid")
            @RequestParam(value = "openid",required = true) String openid) {
        try {
            //String outBatchNo,String batchName,String batchRemark
            //            ,Long totalAmount,Integer totalNum,String outDetailNo,Long transferAmount,String transferRemark,String openid
            InitiateBatchTransferResponse res = weixinMchApi.initiateBatchTransfer(outBatchNo,batchName,batchRemark
                    ,totalAmount,totalNum,outDetailNo,transferAmount,transferRemark,openid);
            return write(200,"res","data", res);
        }catch (ServiceException se){
            return write(-1,se.getErrorMessage(),"data", se.getMessage());
        }catch (Exception e) {
            e.printStackTrace();
            return error(-1,"转账失败");
        }
    }
    @ApiOperation("通过微信批次单号查询批次单")
    @RequestMapping(value = "getTransferBatchByNo", method = {RequestMethod.POST,RequestMethod.GET})
    public String getTransferBatchByNo(
            @ApiParam(name="batchId",required = true,value="批次id")
            @RequestParam(value = "batchId",required = true) String batchId,
            @ApiParam(name="offset",required = true,value="请求资源起始位置")
            @RequestParam(value = "offset",required = true) Integer offset,
            @ApiParam(name="limit",required = true,value="最大资源条数")
            @RequestParam(value = "limit",required = true) Integer limit,
            @ApiParam(name="detailStatus",required = true,value="状态")
            @RequestParam(value = "detailStatus",required = true) String detailStatus) {
        try {
            //String batchId,Integer offset,Integer limit,String detailStatus
            TransferBatchEntity res = weixinMchApi.getTransferBatchByNo(batchId,offset,limit,detailStatus);
            return write(200,"res","data", res);
        }catch (ServiceException se){
            return write(-1,se.getErrorMessage(),"data", se.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1,"查询失败");
        }
    }
    @ApiOperation("通过微信明细单号查询明细单")
    @RequestMapping(value = "getTransferDetailByNo", method = {RequestMethod.POST,RequestMethod.GET})
    public String getTransferDetailByNo(
            @ApiParam(name="batchId",required = true,value="批次id")
            @RequestParam(value = "batchId",required = true) String batchId,
            @ApiParam(name="detailId",required = true,value="明细id")
            @RequestParam(value = "detailId",required = true) String detailId) {
        try {
            TransferDetailEntity res = weixinMchApi.getTransferDetailByNo(batchId,detailId);
            return write(200,"res","data", res);
        }catch (ServiceException se){
            return write(-1,se.getErrorMessage(),"data", se.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1,"查询失败");
        }
    }
    @ApiOperation("腾讯云短信发送")
    @RequestMapping(value = "txSendMessage", method = {RequestMethod.POST,RequestMethod.GET})
    public String txSendMessage(
@@ -544,4 +628,26 @@ public class TransforController {
            return null;
        }
    }
    /**
     * 返回接口处理结果
     *
     * @param code  结果码，成功为200
     * @param msg   结果提示信息
     * @param value 结果数据
     * @return
     */
    public String write(int code, String msg, String key, Object value) {
        try {
            Map<Object, Object> map = new HashMap<Object, Object>();
            ObjectMapper mapper = new ObjectMapper();
            map.put("status", code);
            map.put("msg", msg);
            map.put(key, value);
            return mapper.writeValueAsString(map);
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1, "服务器异常，请稍候再试！");
        }
    }
}

svr/svr-cloud-transfor/src/main/java/com/yihu/jw/care/service/WeixinMchApi.java

@@ -0,0 +1,119 @@
package com.yihu.jw.care.service;
import com.alibaba.fastjson.JSONObject;
import com.wechat.pay.java.core.Config;
import com.wechat.pay.java.core.RSAAutoCertificateConfig;
import com.wechat.pay.java.service.transferbatch.TransferBatchService;
import com.wechat.pay.java.service.transferbatch.model.*;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
/**
 * 微信商户支付api
 * Created by yeshijie on 2024/12/23.
 */
@Service
public class WeixinMchApi {
    //apiv3:15FB41D6808D16668E7A4F4BE251FD1CD25D7D01
    //apiv3:23FB41D6808D16668E7A4F4BE251FD1C
    public static String merchantId = "1635527638"; //商户号
//    public static String privateKeyPath = "D:\\jkzl\\patient-co-management\\patient-co\\patient-co-wlyy-job\\src\\main\\resources\\apiclient_key.pem"; //商户API私钥路径
    public static String privateKeyPath = "/usr/local/svr-cloud-transfor/resources/apiclient_key.pem"; //商户API私钥路径
    public static String merchantSerialNumber = "4B4EB542718B4C91DCCCB294D6BCA10DEF204C90"; //商户证书序列号
    public static String apiV3Key = "23FB41D6808D16668E7A4F4BE251FD1C";//商户APIV3密钥
    public static String appid = "wxad04e9c4c5255acf";//公众号appid
    public static String notifyUrl = "https://www.xmtyw.cn/wlyytest/wx/Openid/notifyUrl";//回调url
    public static TransferBatchService service;
    //批量转账
    public InitiateBatchTransferResponse initiateBatchTransfer(String outBatchNo,String batchName,String batchRemark
            ,Long totalAmount,Integer totalNum,String outDetailNo,Long transferAmount,String transferRemark,String openid) {
        Config config = new RSAAutoCertificateConfig.Builder()
                .merchantId(merchantId)
                .privateKeyFromPath(privateKeyPath)
                .merchantSerialNumber(merchantSerialNumber)
                .apiV3Key(apiV3Key)
                .build();
        service = new TransferBatchService.Builder().config(config).build();
        InitiateBatchTransferRequest initiateBatchTransferRequest =
                new InitiateBatchTransferRequest();
        initiateBatchTransferRequest.setAppid(appid);
        initiateBatchTransferRequest.setOutBatchNo(outBatchNo);
        initiateBatchTransferRequest.setBatchName(batchName);
        initiateBatchTransferRequest.setBatchRemark(batchRemark);
        initiateBatchTransferRequest.setTotalAmount(totalAmount);
        initiateBatchTransferRequest.setTotalNum(totalNum);
        {
            List<TransferDetailInput> transferDetailListList = new ArrayList<>();
            {
                TransferDetailInput transferDetailInput = new TransferDetailInput();
                transferDetailInput.setOutDetailNo(outDetailNo);
                transferDetailInput.setTransferAmount(transferAmount);
                transferDetailInput.setTransferRemark(transferRemark);
                transferDetailInput.setOpenid(openid);
//                transferDetailInput.setUserName(
//                        "757b340b45ebef5467rter35gf464344v3542sdf4t6re4tb4f54ty45t4yyry45");
                transferDetailListList.add(transferDetailInput);
            }
            initiateBatchTransferRequest.setTransferDetailList(
                    transferDetailListList);
        }
//        initiateBatchTransferRequest.setTransferSceneId("1000");
//        initiateBatchTransferRequest.setNotifyUrl(notifyUrl);
        InitiateBatchTransferResponse response =
                service.initiateBatchTransfer(initiateBatchTransferRequest);
        System.out.println("response="+JSONObject.toJSONString(response));
        return response;
    }
    //通过微信批次单号查询批次单
    //response={"batchId":"131000011058801571449282024122378196572602","batchStatus":"FINISHED","createTime":"2024-12-23T16:52:14+08:00","outBatchNo":"plfk2020042013124"}
    public TransferBatchEntity getTransferBatchByNo(String batchId,Integer offset,Integer limit,String detailStatus) {
        Config config = new RSAAutoCertificateConfig.Builder()
                .merchantId(merchantId)
                .privateKeyFromPath(privateKeyPath)
                .merchantSerialNumber(merchantSerialNumber)
                .apiV3Key(apiV3Key)
                .build();
        service = new TransferBatchService.Builder().config(config).build();
        GetTransferBatchByNoRequest request = new GetTransferBatchByNoRequest();
        request.setBatchId(batchId);
        request.setNeedQueryDetail(true);
        request.setOffset(offset);
        request.setLimit(limit);
//        request.setDetailStatus("ALL");
        request.setDetailStatus(detailStatus);
        TransferBatchEntity response = service.getTransferBatchByNo(request);
        System.out.println("response="+JSONObject.toJSONString(response));
        return response;
    }
    //通过微信明细单号查询明细单
    //response={"transferBatch":{"appid":"wxad04e9c4c5255acf","batchId":"131000011058801571449282024122378196572602","batchName":"2024年test","batchRemark":"2024年test","batchStatus":"PROCESSING","batchType":"API","createTime":"2024-12-23T16:52:14+08:00","mchid":"1635527638","outBatchNo":"plfk2020042013124","successAmount":0,"successNum":0,"totalAmount":10,"totalNum":1,"transferSceneId":"1000","updateTime":"2024-12-23T16:52:18+08:00"},
    // "transferDetailList":[{"detailId":"132000011058801571449282024122333730580117","detailStatus":"WAIT_PAY","outDetailNo":"x23zy545Bd5436124"}]}
    public static TransferDetailEntity getTransferDetailByNo(String batchId,String detailId) {
        Config config = new RSAAutoCertificateConfig.Builder()
                .merchantId(merchantId)
                .privateKeyFromPath(privateKeyPath)
                .merchantSerialNumber(merchantSerialNumber)
                .apiV3Key(apiV3Key)
                .build();
        service = new TransferBatchService.Builder().config(config).build();
        GetTransferDetailByNoRequest request = new GetTransferDetailByNoRequest();
        request.setBatchId(batchId);
        request.setDetailId(detailId);
        TransferDetailEntity response = service.getTransferDetailByNo(request);
        System.out.println("response="+JSONObject.toJSONString(response));
        //response={"appid":"wxad04e9c4c5255acf","batchId":"131000011058801571449282024122378196572602","detailId":"132000011058801571449282024122333730580117"
        // ,"detailStatus":"FAIL","failReason":"MERCHANT_REJECT","mchid":"1635527638","openid":"oULM4xNKlVPF9uarzycGbiI23L6I","outBatchNo":"plfk2020042013124"
        // ,"outDetailNo":"x23zy545Bd5436124","transferAmount":10,"transferRemark":"测试费用","updateTime":"2024-12-23T16:56:35+08:00"}
        return response;
    }
}