11月21日银行接口

src/main/java/com/example/demo/Util/DateConvertUtil.java

@@ -0,0 +1,186 @@
+package com.example.demo.Util;
+
+/**
+ * @program: gold-java
+ * @ClassName DateConvertUtil
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 17:45
+ * @Version 1.0
+ **/
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
+import java.util.Date;
+import java.util.TimeZone;
+
+public class DateConvertUtil {
+
+    // 定义支持的日期格式（可根据需求扩展）
+    private static final DateTimeFormatter FORMATTER_YYYYMMDD = DateTimeFormatter.ofPattern("yyyyMMdd");
+    private static final DateTimeFormatter FORMATTER_YYYY_MM_DD = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+    private static final DateTimeFormatter FORMATTER_YYYY_SLASH_MM_SLASH_DD = DateTimeFormatter.ofPattern("yyyy/MM/dd");
+
+    private static final SimpleDateFormat SDF_YYYYMMDD = new SimpleDateFormat("yyyyMMdd");
+    private static final SimpleDateFormat SDF_YYYY_MM_DD = new SimpleDateFormat("yyyy-MM-dd");
+    private static final SimpleDateFormat SDF_YYYY_SLASH_MM_SLASH_DD = new SimpleDateFormat("yyyy/MM/dd");
+
+    // 默认时区（可改为 UTC：TimeZone.getTimeZone("UTC")）
+    private static final TimeZone DEFAULT_TIME_ZONE = TimeZone.getTimeZone("Asia/Shanghai");
+
+    static {
+        // 统一设置SimpleDateFormat时区
+        SDF_YYYYMMDD.setTimeZone(DEFAULT_TIME_ZONE);
+        SDF_YYYY_MM_DD.setTimeZone(DEFAULT_TIME_ZONE);
+        SDF_YYYY_SLASH_MM_SLASH_DD.setTimeZone(DEFAULT_TIME_ZONE);
+    }
+
+    // -------------------------- String → LocalDate（Java 8+ 推荐）--------------------------
+    /**
+     * 字符串转LocalDate（自动匹配支持的格式）
+     */
+    public static LocalDate stringToLocalDate(String dateStr) {
+        if (dateStr == null || dateStr.trim().isEmpty()) {
+            throw new IllegalArgumentException("日期字符串不能为空");
+        }
+        dateStr = dateStr.trim();
+        // 依次尝试三种格式
+        try {
+            return LocalDate.parse(dateStr, FORMATTER_YYYYMMDD);
+        } catch (DateTimeParseException e1) {
+            try {
+                return LocalDate.parse(dateStr, FORMATTER_YYYY_MM_DD);
+            } catch (DateTimeParseException e2) {
+                try {
+                    return LocalDate.parse(dateStr, FORMATTER_YYYY_SLASH_MM_SLASH_DD);
+                } catch (DateTimeParseException e3) {
+                    throw new IllegalArgumentException(
+                            String.format("日期格式错误！支持格式：yyyyMMdd、yyyy-MM-dd、yyyy/MM/dd，当前输入：%s", dateStr),
+                            e3
+                    );
+                }
+            }
+        }
+    }
+
+    /**
+     * 字符串转LocalDate（指定格式）
+     */
+    public static LocalDate stringToLocalDate(String dateStr, String pattern) {
+        if (dateStr == null || dateStr.trim().isEmpty()) {
+            throw new IllegalArgumentException("日期字符串不能为空");
+        }
+        if (pattern == null || pattern.trim().isEmpty()) {
+            throw new IllegalArgumentException("格式模板不能为空");
+        }
+        try {
+            DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
+            return LocalDate.parse(dateStr.trim(), formatter);
+        } catch (DateTimeParseException e) {
+            throw new IllegalArgumentException(
+                    String.format("日期格式错误！指定格式：%s，当前输入：%s", pattern, dateStr),
+                    e
+            );
+        }
+    }
+
+    // -------------------------- String → Date（兼容旧代码）--------------------------
+    /**
+     * 字符串转Date（自动匹配支持的格式）
+     */
+    public static Date stringToDate(String dateStr) {
+        if (dateStr == null || dateStr.trim().isEmpty()) {
+            throw new IllegalArgumentException("日期字符串不能为空");
+        }
+        dateStr = dateStr.trim();
+        try {
+            return SDF_YYYYMMDD.parse(dateStr);
+        } catch (ParseException e1) {
+            try {
+                return SDF_YYYY_MM_DD.parse(dateStr);
+            } catch (ParseException e2) {
+                try {
+                    return SDF_YYYY_SLASH_MM_SLASH_DD.parse(dateStr);
+                } catch (ParseException e3) {
+                    throw new IllegalArgumentException(
+                            String.format("日期格式错误！支持格式：yyyyMMdd、yyyy-MM-dd、yyyy/MM/dd，当前输入：%s", dateStr),
+                            e3
+                    );
+                }
+            }
+        }
+    }
+
+    /**
+     * 字符串转Date（指定格式）
+     */
+    public static Date stringToDate(String dateStr, String pattern) {
+        if (dateStr == null || dateStr.trim().isEmpty()) {
+            throw new IllegalArgumentException("日期字符串不能为空");
+        }
+        if (pattern == null || pattern.trim().isEmpty()) {
+            throw new IllegalArgumentException("格式模板不能为空");
+        }
+        try {
+            SimpleDateFormat sdf = new SimpleDateFormat(pattern);
+            sdf.setTimeZone(DEFAULT_TIME_ZONE);
+            return sdf.parse(dateStr.trim());
+        } catch (ParseException e) {
+            throw new IllegalArgumentException(
+                    String.format("日期格式错误！指定格式：%s，当前输入：%s", pattern, dateStr),
+                    e
+            );
+        }
+    }
+
+    // -------------------------- Date ↔ LocalDate 互转 --------------------------
+    /**
+     * Date转LocalDate
+     */
+    public static LocalDate dateToLocalDate(Date date) {
+        if (date == null) {
+            throw new IllegalArgumentException("Date对象不能为空");
+        }
+        return date.toInstant()
+                .atZone(DEFAULT_TIME_ZONE.toZoneId())
+                .toLocalDate();
+    }
+
+    /**
+     * LocalDate转Date
+     */
+    public static Date localDateToDate(LocalDate localDate) {
+        if (localDate == null) {
+            throw new IllegalArgumentException("LocalDate对象不能为空");
+        }
+        return Date.from(
+                localDate.atStartOfDay(DEFAULT_TIME_ZONE.toZoneId())
+                        .toInstant()
+        );
+    }
+
+    // -------------------------- 测试方法 --------------------------
+    public static void main(String[] args) {
+        // 测试1：String→LocalDate（yyyyMMdd格式）
+        LocalDate localDate1 = stringToLocalDate("20250911");
+        System.out.println("String→LocalDate（yyyyMMdd）：" + localDate1); // 输出：2025-09-11
+
+        // 测试2：String→Date（yyyy-MM-dd格式）
+        Date date1 = stringToDate("2025-09-11");
+        System.out.println("String→Date（yyyy-MM-dd）：" + date1); // 输出：Wed Sep 11 00:00:00 CST 2025
+
+        // 测试3：Date→LocalDate
+        LocalDate localDate2 = dateToLocalDate(date1);
+        System.out.println("Date→LocalDate：" + localDate2); // 输出：2025-09-11
+
+        // 测试4：LocalDate→Date
+        Date date2 = localDateToDate(localDate2);
+        System.out.println("LocalDate→Date：" + date2); // 输出：Wed Sep 11 00:00:00 CST 2025
+
+        // 测试5：指定格式转换（yyyy/MM/dd）
+        LocalDate localDate3 = stringToLocalDate("2025/09/11", "yyyy/MM/dd");
+        System.out.println("指定格式（yyyy/MM/dd）→LocalDate：" + localDate3); // 输出：2025-09-11
+    }
+}

src/main/java/com/example/demo/controller/cash/Bank.java

@@ -9,6 +9,78 @@ package com.example.demo.controller.cash;
  * @Version 1.0
  **/
 
+import com.example.demo.domain.DTO.BankDTO;
+import com.example.demo.domain.DTO.StripeDTO;
+import com.example.demo.domain.vo.cash.BankVO;
+import com.stripe.Stripe;
+import com.stripe.exception.StripeException;
+import com.stripe.model.*;
+import com.stripe.param.*;
+
+import java.util.ArrayList;
+import java.util.List;
+
 public class Bank {
+    public static void main(String[] args) throws StripeException {
+        Stripe.apiKey = "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";
+
+//        List<Charge> allCharges = new ArrayList<>();
+//        String startingAfter = null;
+//        int totalLimit = 200; // 目标获取
+//        int pageSize = 100; // 单次最大
+//
+//        do {
+//            // 计算当前页需查询的条数（最后一页可能不足 100 条）
+//            int currentPageSize = Math.min(pageSize, totalLimit - allCharges.size());
+//            if (currentPageSize <= 0) {
+//                break; // 已获取够，停止
+//            }
+//
+//            // 构建分页参数
+//            ChargeListParams params = ChargeListParams.builder()
+//                    .setLimit((long) currentPageSize)
+//                    .setStartingAfter(startingAfter)
+//                    .build();
+//
+//            try {
+//                ChargeCollection charges = Charge.list(params);
+//                List<Charge> currentPageData = charges.getData();
+//                allCharges.addAll(currentPageData);
+//
+//                // 更新分页游标：若有下一页且未达 200 条，继续
+//                boolean hasMore = charges.getHasMore() && allCharges.size() < totalLimit;
+//                startingAfter = hasMore ? currentPageData.get(currentPageData.size() - 1).getId() : null;
+//
+//            } catch (StripeException e) {
+//                System.err.println("Stripe 分页查询失败：" + e.getMessage());
+//                break; // 异常时停止查询，返回已获取的数据
+//            }
+//
+//        } while (startingAfter != null);
+//        System.out.println(allCharges);
+//
+//        // 3. 封装DTO
+//        List<StripeDTO> stripeDTOList = new ArrayList<>();
+//        for (Charge charge : allCharges) {
+//            StripeDTO stripeDTO = new StripeDTO();
+//            stripeDTO.setOrderNo(charge.getMetadata().get("order_no"));
+//            stripeDTO.setBalanceTransaction(charge.getBalanceTransaction());
+//            stripeDTOList.add(stripeDTO);
+//        }
+//
+//        BankVO bankVO = new BankVO();
+//        bankVO.setStripeDTOList(stripeDTOList);
+//
+//        // 4. 输出结果
+//        System.out.println("最终BankDTO数据：");
+//        System.out.println("stripeDTOList size：" + bankVO.getStripeDTOList().size());
+//        System.out.println("stripeDTOList：" + bankVO.getStripeDTOList());
+//        System.out.println("orderNo：" + bankVO.getStripeDTOList().get(199).getOrderNo());
+//        System.out.println("balanceTransaction：" + bankVO.getStripeDTOList().get(199).getBalanceTransaction());
+
 
-}
+        BalanceTransaction balanceTransaction =
+                BalanceTransaction.retrieve("txn_3SVnLrJHMNYcqBc01CAgovvJ");
+        System.out.println(balanceTransaction);
+    }
+}

src/main/java/com/example/demo/controller/cash/BankController.java

@@ -0,0 +1,83 @@
+package com.example.demo.controller.cash;
+
+import com.example.demo.config.interfac.Log;
+import com.example.demo.domain.DTO.BankDTO;
+import com.example.demo.domain.vo.cash.BankVO;
+import com.example.demo.domain.vo.coin.Result;
+import com.example.demo.service.cash.BankService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @program: gold-java
+ * @ClassName Bank
+ * @description:
+ * @author: Double
+ * @create: 2025−11-17 13:31
+ * @Version 1.0
+ **/
+
+
+@RestController
+@RequestMapping("/bank")
+@RequiredArgsConstructor
+@Slf4j
+@CrossOrigin
+public class BankController {
+
+    @Autowired
+    private BankService bankService;
+
+    //payment银行接口(批量)
+    @Log("payment银行接口(批量)")
+    @PostMapping("/paymentAuto")
+    public Result paymentAuto(@RequestBody BankDTO bankDTO) {
+        try {
+            return Result.success(bankService.paymentAuto(bankDTO));
+        } catch (Exception e) {
+            return Result.error(e.getMessage());
+        }
+    }
+
+    //payment银行接口(单个)
+    @Log("payment银行接口(单个)")
+    @PostMapping("/getPayment")
+    public Result getPayment(@RequestBody BankDTO bankDTO) {
+        try {
+            if(bankDTO.getTime().isEmpty() || bankDTO.getOrderNo().isEmpty()){
+                return Result.error("时间或订单号为空");
+            }
+            return bankService.getPayment(bankDTO);
+        } catch (Exception e) {
+            return Result.error(e.getMessage());
+        }
+    }
+
+    //payment银行接口(批量)
+    @Log("stripe银行接口(批量)")
+    @PostMapping("/stripeAuto")
+    public Result stripeAuto(@RequestBody BankDTO bankDTO) {
+        try {
+            return Result.success(bankService.stripeAuto(bankDTO));
+        } catch (Exception e) {
+            return Result.error(e.getMessage());
+        }
+    }
+
+    //payment银行接口(单个)
+    @Log("stripe银行接口(单个)")
+    @PostMapping("/getStripe")
+    public Result getStripe(@RequestBody BankDTO bankDTO) {
+        try {
+            if(bankDTO.getTime().isEmpty() || bankDTO.getOrderNo().isEmpty()){
+                return Result.error("时间或订单号为空");
+            }
+            return bankService.getStripe(bankDTO);
+        } catch (Exception e) {
+            return Result.error(e.getMessage());
+        }
+    }
+
+}

src/main/java/com/example/demo/domain/DTO/BankDTO.java

@@ -0,0 +1,24 @@
+package com.example.demo.domain.DTO;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * @program: gold-java
+ * @ClassName BankDTO
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 10:32
+ * @Version 1.0
+ **/
+
+@Data
+@NoArgsConstructor
+public class BankDTO {
+    //时间格式yyyyMMdd
+    private String time = "";
+    //订单号
+    private String orderNo = "";
+}

src/main/java/com/example/demo/domain/DTO/PaymentDTO.java

@@ -0,0 +1,36 @@
+package com.example.demo.domain.DTO;
+
+/**
+ * @program: gold-java
+ * @ClassName PaymentDTO
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 10:42
+ * @Version 1.0
+ **/
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+@Data
+@NoArgsConstructor
+public class PaymentDTO {
+
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "Asia/Shanghai")
+    private Date time;
+    private String type;
+    private String provider;
+    private String request_reference;
+    private String merchant_reference;
+    private String provider_reference;
+    private String currency;
+    private Double order_amount;
+    private Double charge;
+    private Double net_amount;
+    private String status;
+    private String created_time;
+    private String completed_time;
+}

src/main/java/com/example/demo/domain/DTO/StripeDTO.java

@@ -0,0 +1,25 @@
+package com.example.demo.domain.DTO;
+
+/**
+ * @program: gold-java
+ * @ClassName StripeDTO
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 15:26
+ * @Version 1.0
+ **/
+
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+public class StripeDTO {
+    private String orderNo;//订单号
+    private String balanceTransaction;//余额交易ID
+    private String currency;//货币
+    private String amount;//金额
+    private String fee;//手续费
+    private String net;//净额
+}

src/main/java/com/example/demo/domain/vo/cash/BankVO.java

@@ -0,0 +1,26 @@
+package com.example.demo.domain.vo.cash;
+
+import com.example.demo.domain.DTO.PaymentDTO;
+import com.example.demo.domain.DTO.StripeDTO;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * @program: gold-java
+ * @ClassName BankVO
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 10:44
+ * @Version 1.0
+ **/
+
+@Data
+@NoArgsConstructor
+public class BankVO {
+    private List<PaymentDTO> paymentDTOList;
+    private PaymentDTO paymentDTO;
+    private List<StripeDTO> stripeDTOList;
+    private StripeDTO stripeDTO;
+}

src/main/java/com/example/demo/service/cash/BankService.java

@@ -0,0 +1,29 @@
+package com.example.demo.service.cash;
+
+
+import com.example.demo.domain.DTO.BankDTO;
+import com.example.demo.domain.vo.cash.BankVO;
+import com.example.demo.domain.vo.coin.Result;
+
+/**
+ * @program: gold-java
+ * @ClassName BankService
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 10:43
+ * @Version 1.0
+ **/
+
+public interface BankService {
+    //payment银行接口(批量)
+    Result paymentAuto(BankDTO bankDTO);
+
+    //payment银行接口(单个)
+    Result getPayment(BankDTO bankDTO);
+
+    //stripe银行接口(批量)
+    Result stripeAuto(BankDTO bankDTO);
+
+    //stripe银行接口(单个)
+    Result getStripe(BankDTO bankDTO);
+}

src/main/java/com/example/demo/serviceImpl/cash/BankServiceImpl.java

@@ -0,0 +1,253 @@
+package com.example.demo.serviceImpl.cash;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.demo.Util.DateConvertUtil;
+import com.example.demo.domain.DTO.BankDTO;
+import com.example.demo.domain.DTO.PaymentDTO;
+import com.example.demo.domain.vo.cash.BankVO;
+import com.example.demo.domain.vo.cash.CashCollection;
+import com.example.demo.domain.vo.coin.Result;
+import com.example.demo.mapper.cash.CashCollectionMapper;
+import com.example.demo.service.cash.BankService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.*;
+import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
+
+import java.nio.charset.StandardCharsets;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
+
+/**
+ * @program: gold-java
+ * @ClassName BankServiceImpl
+ * @description:
+ * @author: Double
+ * @create: 2025−11-21 10:46
+ * @Version 1.0
+ **/
+
+@Service
+@Slf4j
+public class BankServiceImpl implements BankService {
+
+    @Autowired
+    private CashCollectionMapper cashCollectionMapper;
+
+    // 第三方API地址
+    private static final String API_URL = "https://gateway.pa-sys.com/v1.1/reconciliation/519e26b2-8145-418c-b3e7-c1e88e52b946/settlement";
+    // 签名密钥
+    private static final String SECRET = "8987d1b8-1d82-4b15-af06-828d0b12076f";
+
+    // 注入RestTemplate用于HTTP请求（需在Spring配置类中定义）
+    private final RestTemplate restTemplate;
+
+    public BankServiceImpl(RestTemplate restTemplate) {
+        this.restTemplate = restTemplate;
+    }
+
+    //payment银行接口(单个)
+    @Override
+    public Result getPayment(BankDTO bankDTO) {
+        try {
+            // 1. 准备参数
+            String settlementDate = bankDTO.getTime(); // 从BankDTO对象获取time作为settlement_date
+            String network = "FPS"; // 固定值
+            // 2. 生成签名
+            Map<String, String> params = new TreeMap<>(); // 按key升序排序
+            params.put("settlement_date", settlementDate);
+            params.put("network", network);
+
+            String signSource = buildQueryString(params) + SECRET;
+            String sign = sha512(signSource);
+
+            // 3. 构建form-data请求参数
+            MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
+            formData.add("settlement_date", settlementDate);
+            formData.add("network", network);
+            formData.add("sign", sign);
+
+            // 4. 发送HTTP POST请求（优化：显式设置multipart/form-data的字符集）
+            HttpHeaders headers = new HttpHeaders();
+            // 补充charset=UTF-8，避免部分服务器对编码敏感
+            headers.setContentType(new MediaType("multipart", "form-data", StandardCharsets.UTF_8));
+            HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(formData, headers);
+
+            // 调用第三方API（使用配置好SSL协议的RestTemplate）
+            ResponseEntity<String> response = restTemplate.exchange(
+                    API_URL,
+                    HttpMethod.POST,
+                    requestEntity,
+                    String.class
+            );
+
+            if (response.getStatusCode().is2xxSuccessful()) {
+                String responseBody = response.getBody();
+                log.info("第三方API响应: {}", responseBody);
+
+                // 解析JSON获取payload.transactions数组
+                JSONObject jsonObject = JSON.parseObject(responseBody);
+                JSONArray transactions = jsonObject.getJSONObject("payload").getJSONArray("transactions");
+
+                // 创建BankDTO并设置paymentDTOList
+                BankVO bankVO = new BankVO();
+                List<PaymentDTO> paymentDTOList = transactions.toJavaList(PaymentDTO.class);
+                bankVO.setPaymentDTOList(paymentDTOList);
+                // 获取订单号
+                String orderNo = bankDTO.getOrderNo();
+
+                // 如果订单号不为空，则进行匹配查找
+                if (orderNo != null && !orderNo.isEmpty()) {
+                    boolean found = false;
+                    for (PaymentDTO paymentDTO : paymentDTOList) {
+                        if (orderNo.equals(paymentDTO.getMerchant_reference())) {
+                            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+                            paymentDTO.setTime(sdf.parse(bankDTO.getTime()));
+                            paymentDTO.setOrder_amount(paymentDTO.getOrder_amount()*100);
+                            paymentDTO.setCharge(paymentDTO.getCharge()*100);
+                            paymentDTO.setNet_amount(paymentDTO.getNet_amount()*100);
+                            paymentDTO.setCurrency("2");
+                            bankVO.setPaymentDTO(paymentDTO);
+                            found = true;
+                            break;
+                        }
+                    }
+                    // 如果没有找到匹配的订单号，返回提示信息
+                    if (!found) {
+                        log.info("当前日期 {} 该订单号 {} 未查到", settlementDate, orderNo);
+                        // 可以根据业务需求进行相应处理，比如抛出异常或设置特定标识
+                        return Result.error("payment当前日期 " + settlementDate + " 该订单号 " + orderNo + " 未查到");
+                    }
+                }
+
+                CashCollection cashCollection = cashCollectionMapper.selectByGoldCoinOrderCode(orderNo);
+                if (cashCollection == null) {
+                    return Result.error("金币系统当前日期 " + settlementDate + " 该订单号 " + orderNo + " 未查到");
+                }
+                else {
+                    cashCollectionMapper.updateByGoldCoinOrderCode(bankVO.getPaymentDTO());
+                }
+                return Result.success(bankVO);
+            } else {
+                throw new RuntimeException("API请求失败，状态码: " + response.getStatusCodeValue());
+            }
+
+        } catch (Exception e) {
+            log.error("payment银行接口处理失败", e);
+            throw new RuntimeException("处理失败: " + e.getMessage());
+        }
+    }
+
+    //payment银行接口(批量)
+    @Override
+    public Result paymentAuto(BankDTO bankDTO) {
+        try {
+            // 1. 准备参数
+            String settlementDate = bankDTO.getTime(); // 从BankDTO对象获取time作为settlement_date
+            String network = "FPS"; // 固定值
+            // 2. 生成签名
+            Map<String, String> params = new TreeMap<>(); // 按key升序排序
+            params.put("settlement_date", settlementDate);
+            params.put("network", network);
+
+            String signSource = buildQueryString(params) + SECRET;
+            String sign = sha512(signSource);
+
+            // 3. 构建form-data请求参数
+            MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
+            formData.add("settlement_date", settlementDate);
+            formData.add("network", network);
+            formData.add("sign", sign);
+
+            // 4. 发送HTTP POST请求（优化：显式设置multipart/form-data的字符集）
+            HttpHeaders headers = new HttpHeaders();
+            // 补充charset=UTF-8，避免部分服务器对编码敏感
+            headers.setContentType(new MediaType("multipart", "form-data", StandardCharsets.UTF_8));
+            HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(formData, headers);
+
+            // 调用第三方API（使用配置好SSL协议的RestTemplate）
+            ResponseEntity<String> response = restTemplate.exchange(
+                    API_URL,
+                    HttpMethod.POST,
+                    requestEntity,
+                    String.class
+            );
+
+            if (response.getStatusCode().is2xxSuccessful()) {
+                String responseBody = response.getBody();
+                log.info("第三方API响应: {}", responseBody);
+
+                // 解析JSON获取payload.transactions数组
+                JSONObject jsonObject = JSON.parseObject(responseBody);
+                JSONArray transactions = jsonObject.getJSONObject("payload").getJSONArray("transactions");
+
+                // 创建BankDTO并设置paymentDTOList
+                BankVO bankVO = new BankVO();
+                List<PaymentDTO> paymentDTOList = transactions.toJavaList(PaymentDTO.class);
+                bankVO.setPaymentDTOList(paymentDTOList);
+
+                return Result.success(bankVO);
+            } else {
+                throw new RuntimeException("API请求失败，状态码: " + response.getStatusCodeValue());
+            }
+
+        } catch (Exception e) {
+            log.error("payment银行接口处理失败", e);
+            throw new RuntimeException("处理失败: " + e.getMessage());
+        }
+    }
+
+    //stripe银行接口(批量)
+    @Override
+    public Result stripeAuto(BankDTO bankDTO) {
+       return Result.success(bankDTO);
+    }
+
+    //stripe银行接口(单个)
+    @Override
+    public Result getStripe(BankDTO bankDTO) {
+        return Result.success(bankDTO);
+    }
+
+    /**
+     * http_build_query的查询字符串（key=value&key=value）
+     */
+    private String buildQueryString(Map<String, String> params) {
+        StringBuilder sb = new StringBuilder();
+        for (Map.Entry<String, String> entry : params.entrySet()) {
+            if (sb.length() > 0) {
+                sb.append("&");
+            }
+            sb.append(entry.getKey()).append("=").append(entry.getValue());
+        }
+        return sb.toString();
+    }
+
+    /**
+     * SHA512加密
+     */
+    private String sha512(String content) throws NoSuchAlgorithmException {
+        MessageDigest md = MessageDigest.getInstance("SHA-512");
+        byte[] bytes = md.digest(content.getBytes(StandardCharsets.UTF_8));
+        // 转换为十六进制字符串
+        StringBuilder hexStr = new StringBuilder();
+        for (byte b : bytes) {
+            String hex = Integer.toHexString(0xff & b);
+            if (hex.length() == 1) {
+                hexStr.append('0');
+            }
+            hexStr.append(hex);
+        }
+        return hexStr.toString();
+    }
+}

src/main/resources/cashMapper/CashCollectionMapper.xml

@@ -280,7 +280,7 @@
     <!--根据glodcoin订单号更新收款订单-->
     <update id="updateByGoldCoinOrderCode">
         update cash_record_collection
-        <set>
+        SET
             received_time=#{time},
             payment_currency=#{currency},
             received_currency=#{currency},
@@ -288,7 +288,6 @@
             received_amount=#{net_amount},
             handling_charge=#{charge},
             order_no_status=0
-        </set>
-        where order_code=#{merchant_reference}
+        where order_no=#{merchant_reference}
     </update>
 </mapper>