add tk pay

cif-api/src/main/java/com/txz/cif/dto/tkpay/CheckSignDTO.java

@@ -0,0 +1,74 @@
+package com.txz.cif.dto.tkpay;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/2
+ */
+@Data
+public class CheckSignDTO {
+    
+    /**
+     *
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     * 代付交易状态：
+     * 5-代付交易成功；
+     * 6-代付交易失败；
+     * 3-交易中（实际上不会同步）
+     */
+    @JSONField(name = "status")
+    private Integer status;
+    
+    /**
+     * 当status=6时，返回代付失败的原因
+     */
+    @JSONField(name = "msg")
+    private String msg;
+    
+    /**
+     * 三方单号
+     */
+    @JSONField(name = "trade_no")
+    private String tradeNo;
+    
+    /**
+     * 商户单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    @JSONField(name = "utr")
+    private String utr;
+    
+    /**
+     * 代付订单金额
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 持卡人姓名
+     */
+    @JSONField(name = "to_holder")
+    private String toHolder;
+    
+    /**
+     * 银行卡卡号
+     */
+    @JSONField(name = "to_account")
+    private String toAccount;
+    
+    /**
+     * 银行类型，暂时仅支持：
+     * bKash; Nagad 两种类型
+     */
+    @JSONField(name = "to_bank_type")
+    private String toBankType;
+    
+}

cif-api/src/main/java/com/txz/cif/dto/tkpay/CheckWithdrawSignDTO.java

@@ -0,0 +1,74 @@
+package com.txz.cif.dto.tkpay;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/2
+ */
+@Data
+public class CheckWithdrawSignDTO {
+    
+    /**
+     *
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     * 代付交易状态：
+     * 5-代付交易成功；
+     * 6-代付交易失败；
+     * 3-交易中（实际上不会同步）
+     */
+    @JSONField(name = "status")
+    private Integer status;
+    
+    /**
+     * 当status=6时，返回代付失败的原因
+     */
+    @JSONField(name = "msg")
+    private String msg;
+    
+    /**
+     * 三方单号
+     */
+    @JSONField(name = "trade_no")
+    private String tradeNo;
+    
+    /**
+     * 商户单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    @JSONField(name = "utr")
+    private String utr;
+    
+    /**
+     * 代付订单金额
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 持卡人姓名
+     */
+    @JSONField(name = "to_holder")
+    private String toHolder;
+    
+    /**
+     * 银行卡卡号
+     */
+    @JSONField(name = "to_account")
+    private String toAccount;
+    
+    /**
+     * 银行类型，暂时仅支持：
+     * bKash; Nagad 两种类型
+     */
+    @JSONField(name = "to_bank_type")
+    private String toBankType;
+    
+}

cif-api/src/main/java/com/txz/cif/dto/tkpay/TKCreateWithdrawDTO.java

@@ -0,0 +1,64 @@
+package com.txz.cif.dto.tkpay;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/3
+ */
+@Data
+@Builder
+public class TKCreateWithdrawDTO {
+    
+    /**
+     *
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     * 商户传入订单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    /**
+     * 订单金额
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 持卡人姓名
+     */
+    @JSONField(name = "to_holder")
+    private String toHolder;
+    
+    /**
+     * 银行卡卡号
+     */
+    @JSONField(name = "to_account")
+    private String toAccount;
+    
+    /**
+     * 银行类型，暂时仅支持：
+     * bKash; Nagad 两种类型
+     */
+    @JSONField(name = "to_bank_type")
+    private String toBankType;
+    
+    /**
+     * 回调地址
+     */
+    @JSONField(name = "notify_url")
+    private String notifyUrl;
+    
+    /**
+     * 签名
+     */
+    @JSONField(name = "sign")
+    private String sign;
+    
+}

cif-api/src/main/java/com/txz/cif/dto/tkpay/TKPayCreateOrderDTO.java

@@ -0,0 +1,40 @@
+package com.txz.cif.dto.tkpay;
+
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ *
+ * @author: MTD®️
+ * @date: 2026/1/4
+ */
+@Data
+@Builder
+public class TKPayCreateOrderDTO {
+    
+    /**
+     * 商户id
+     */
+    private String mchid;
+    
+    /**
+     * 通道id
+     */
+    private String payId;
+    
+    /**
+     * 订单号
+     */
+    private String outTradeNo;
+    
+    /**
+     * 金额
+     */
+    private String amount;
+    
+    /**
+     * 回调地址
+     */
+    private String notifyUrl;
+    
+}

cif-api/src/main/java/com/txz/cif/dto/tkpay/TKPayOrderDTO.java

@@ -0,0 +1,51 @@
+package com.txz.cif.dto.tkpay;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ *
+ * @author: MTD®️
+ * @date: 2026/1/4
+ */
+@Data
+@Builder
+public class TKPayOrderDTO {
+    
+    /**
+     * 商户id
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     * 通道id
+     */
+    @JSONField(name = "pay_id")
+    private String payId;
+    
+    /**
+     * 订单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    /**
+     * 金额
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 回调地址
+     */
+    @JSONField(name = "notify_url")
+    private String notifyUrl;
+    
+    /**
+     * 签名
+     */
+    @JSONField(name = "sign")
+    private String sign;
+}

cif-api/src/main/java/com/txz/cif/dto/tkpay/TKWithdrawDTO.java

@@ -0,0 +1,51 @@
+package com.txz.cif.dto.tkpay;
+
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/3
+ */
+@Data
+@Builder
+public class TKWithdrawDTO {
+    
+    /**
+     *
+     */
+    private String mchid;
+    
+    /**
+     * 商户传入订单号
+     */
+    private String outTradeNo;
+    
+    /**
+     * 订单金额
+     */
+    private String amount;
+    
+    /**
+     * 持卡人姓名
+     */
+    private String toHolder;
+    
+    /**
+     * 银行卡卡号
+     */
+    private String toAccount;
+    
+    /**
+     * 银行类型，暂时仅支持：
+     * bKash; Nagad 两种类型
+     */
+    private String toBankType;
+    
+    /**
+     * 回调地址
+     */
+    private String notifyUrl;
+    
+    
+}

cif-service/src/main/java/com/txz/cif/configurer/TKPayConfig.java

@@ -0,0 +1,24 @@
+package com.txz.cif.configurer;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/8/29
+ */
+
+@Component
+@Data
+@RefreshScope
+public class TKPayConfig {
+    
+    @Value("${tkpay.paymenturl}")
+    private String paymenturl;
+    
+    @Value("${tkpay.withdrawurl}")
+    private String withdrawurl;
+    
+}

cif-service/src/main/java/com/txz/cif/constants/MyConstants.java

@@ -19,13 +19,12 @@ public class MyConstants {
      * 主营收入账户（损益类）id
      */
     public static final Long INNER_INCOME = 3L;
-
+    
     /**
      * 主营业务支出-红包（损益类）id
      */
     public static final Long INNER_RED = 4L;
-
-
+    
     
     /**
      * 主营支出-退款（损益类）id
@@ -60,6 +59,11 @@ public class MyConstants {
      */
     public static final String TF_PAY_NOTIFY_LOCK = "TF_PAY_NOTIFY_LOCK:%s";
     
+    /**
+     * 支付回调锁
+     */
+    public static final String TK_PAY_NOTIFY_LOCK = "TK_PAY_NOTIFY_LOCK:%s";
+    
     /**
      * 提现提交锁
      */
@@ -69,4 +73,9 @@ public class MyConstants {
      * 提现回调锁
      */
     public static final String TF_PAY_WITHDRAW_NOTIFY_LOCK = "TF_PAY_WITHDRAW_NOTIFY_LOCK:%s";
+    
+    /**
+     * 提现回调锁
+     */
+    public static final String TK_PAY_WITHDRAW_NOTIFY_LOCK = "TK_PAY_WITHDRAW_NOTIFY_LOCK:%s";
 }

cif-service/src/main/java/com/txz/cif/service/TKPayService.java

@@ -0,0 +1,24 @@
+package com.txz.cif.service;
+
+import com.txz.cif.dto.BizLogDTO;
+import com.txz.cif.dto.tkpay.TKPayCreateOrderDTO;
+import com.txz.cif.dto.tkpay.TKWithdrawDTO;
+
+/**
+ *
+ * @author: MTD®️
+ * @date: 2026/1/4
+ */
+
+public interface TKPayService {
+    
+    /**
+     * 创单
+     */
+    BizLogDTO createTKPayOrder(TKPayCreateOrderDTO dto, String key);
+    
+    /**
+     * 提现
+     */
+    BizLogDTO withdraw(TKWithdrawDTO dto, String key);
+}

cif-service/src/main/java/com/txz/cif/service/impl/TKPayServiceImpl.java

@@ -0,0 +1,75 @@
+package com.txz.cif.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.http.HttpRequest;
+import com.alibaba.fastjson.JSON;
+import com.txz.cif.configurer.TKPayConfig;
+import com.txz.cif.dto.BizLogDTO;
+import com.txz.cif.dto.tkpay.TKCreateWithdrawDTO;
+import com.txz.cif.dto.tkpay.TKPayCreateOrderDTO;
+import com.txz.cif.dto.tkpay.TKPayOrderDTO;
+import com.txz.cif.dto.tkpay.TKWithdrawDTO;
+import com.txz.cif.service.TKPayService;
+import com.txz.cif.util.TKPayUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * @author: MTD®️
+ * @date: 2026/1/4
+ */
+@Slf4j
+@Service
+public class TKPayServiceImpl implements TKPayService {
+    
+    @Autowired
+    private TKPayConfig tkPayConfig;
+    
+    @Override
+    public BizLogDTO createTKPayOrder(TKPayCreateOrderDTO dto, String key) {
+        TKPayOrderDTO tkPay = TKPayOrderDTO.builder()
+                .mchid(dto.getMchid())
+                .payId(dto.getPayId())
+                .outTradeNo(dto.getOutTradeNo())
+                .amount(dto.getAmount())
+                .notifyUrl(dto.getNotifyUrl())
+                .build();
+        
+        String signature = TKPayUtil.generateSignature(tkPay, key);
+        tkPay.setSign(signature);
+        
+        String reqParam = JSON.toJSONString(tkPay);
+        
+        String result = HttpRequest.post(tkPayConfig.getPaymenturl() + "/api/developer/order/create")
+                .contentType("application/json")
+                .body(reqParam)
+                .execute()
+                .body();
+        log.info("TKPay createOrder result: {}", result);
+        return BizLogDTO.builder()
+                .sendMessage(reqParam)
+                .receiveMessage(result)
+                .build();
+    }
+    
+    @Override
+    public BizLogDTO withdraw(TKWithdrawDTO dto, String key) {
+        TKCreateWithdrawDTO withdrawDTO = BeanUtil.copyProperties(dto, TKCreateWithdrawDTO.class);
+        // 生成签名
+        withdrawDTO.setSign(TKPayUtil.generateSignature(withdrawDTO, key));
+        
+        String reqParam = JSON.toJSONString(withdrawDTO);
+        String result = HttpRequest.post(tkPayConfig.getPaymenturl() + "/api/developer/payout/create")
+                .contentType("application/json")
+                .body(reqParam)
+                .execute()
+                .body();
+        log.info("TKPay withdraw result: {}", result);
+        return BizLogDTO.builder()
+                .sendMessage(reqParam)
+                .receiveMessage(result)
+                .build();
+    }
+}

cif-service/src/main/java/com/txz/cif/service/impl/WithdrawRecordServiceImpl.java

@@ -17,6 +17,7 @@ import com.txz.cif.dao.WithdrawRecordMapper;
 import com.txz.cif.dto.BizLogDTO;
 import com.txz.cif.dto.Result;
 import com.txz.cif.dto.tfpay.TFWithdrawDTO;
+import com.txz.cif.dto.tkpay.TKWithdrawDTO;
 import com.txz.cif.enums.AccountFreezdTypeEnum;
 import com.txz.cif.enums.BizTypeEnum;
 import com.txz.cif.model.BizLog;
@@ -45,33 +46,36 @@ import java.util.List;
 @Slf4j
 @Transactional
 public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> implements WithdrawRecordService {
-
+    
     @Resource
     private WithdrawRecordMapper withdrawRecordMapper;
     @Resource
     private AccountService accountService;
-
+    
     @Resource
     private FlowService flowService;
-
+    
     @Resource
     private PaymentChannelService paymentChannelService;
-
+    
     @Resource
     private SequenceService sequenceService;
-
+    
     @Resource
     private UserService userService;
-
+    
     @Resource
     private TFPayService tfPayService;
-
+    
+    @Resource
+    private TKPayService tkPayService;
+    
     @Resource
     private BizLogService bizLogService;
-
+    
     @Resource
     private LockTemplate lockTemplate;
-
+    
     @Override
     public void add(WithdrawRecord withdrawRecord) {
         saveUseGeneratedKeys(withdrawRecord);
@@ -89,7 +93,7 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
                 .build());
         update(WithdrawRecord.builder().id(withdrawRecord.getId()).freezeId(Long.valueOf(freeze.getData().toString())).build());
     }
-
+    
     @Override
     public void review(WithdrawRecord w, Integer status, String review, Long channelId, String userName) {
         // 同意提现
@@ -102,23 +106,25 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
                 User user = userService.findById(w.getUserId());
                 DateTime now = DateUtil.date();
                 String thirdOrderNo = sequenceService.genSerialNumber("withdraw_rule", null);
-
+                
                 PaymentChannel paymentChannel = paymentChannelService.findById(channelId);
                 if (ObjectUtil.isEmpty(paymentChannel)) {
                     throw new ServiceException(LocalUtil.get("withdrawal.channel.does.not.exist"));
                 }
                 List<BizLog> bizLogList = new ArrayList<>();
+                BizLogDTO bizLog;
+                JSONObject resultJson;
                 switch (paymentChannel.getChannelName()) {
                     case "TFPAY":
-//                        Map<String, Object> payMentChannelMap = TFPayUtil.convertObjectToMap(paymentChannel);
-                        BizLogDTO bizLog = tfPayService.withdraw(
+                        //                        Map<String, Object> payMentChannelMap = TFPayUtil.convertObjectToMap(paymentChannel);
+                        bizLog = tfPayService.withdraw(
                                 TFWithdrawDTO.builder()
                                         .payMemberid(paymentChannel.getMerchantNum())
                                         .payOrderid(thirdOrderNo)
                                         .payApplydate(now.toString())
                                         // fixme 如需测试改成502
                                         // .payChannelcode("502")
-                                        .payChannelcode(getPayChannelcode(w.getBank(),paymentChannel))
+                                        .payChannelcode(getPayChannelcode(w.getBank(), paymentChannel))
                                         .payNotifyurl(paymentChannel.getWithdrawNotifyUrl())
                                         .payAmount(w.getAmount().subtract(w.getFee()).toString())
                                         .payProductname("提现")
@@ -128,43 +134,84 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
                                         .payBankcode(w.getBank().toLowerCase())
                                         .build()
                                 , paymentChannel.getSecretKey());
-                        JSONObject resultJson;
                         try {
                             resultJson = JSONUtil.parseObj(bizLog.getReceiveMessage());
                         } catch (Exception e) {
                             log.error("提现失败三方返回-->" + bizLog);
                             throw new ServiceException(LocalUtil.get("withdrawal.failed"));
                         }
-                      bizLogList.add(BizLog.builder()
-                        .bizType(2)
-                        .bizNo(w.getOrderNo())
-                        .thirdOrderNo(thirdOrderNo)
-                        .type(7)
-                        .receiveMessage(bizLog.getReceiveMessage())
-                        .sendMessage(bizLog.getSendMessage())
-                        .createTime(now)
-                        .createUser(userName)
-                        .memo(resultJson.getStr("msg")).build());
+                        bizLogList.add(BizLog.builder()
+                                .bizType(2)
+                                .bizNo(w.getOrderNo())
+                                .thirdOrderNo(thirdOrderNo)
+                                .type(7)
+                                .receiveMessage(bizLog.getReceiveMessage())
+                                .sendMessage(bizLog.getSendMessage())
+                                .createTime(now)
+                                .createUser(userName)
+                                .memo(resultJson.getStr("msg")).build());
                         if (!resultJson.getStr("status").equals("200")) {
                             log.error("提现失败--->" + resultJson.getStr("msg"));
                         }
                         break;
+                    case "tk":
+                        if (StrUtil.isBlank(getPayChannelcode(w.getBank(), paymentChannel))) {
+                            throw new ServiceException(LocalUtil.get("withdrawal.channel.does.not.exist"));
+                        }
+                        bizLog = tkPayService.withdraw(
+                                TKWithdrawDTO.builder()
+                                        .mchid(paymentChannel.getMerchantNum())
+                                        .outTradeNo(thirdOrderNo)
+                                        .amount(w.getAmount().subtract(w.getFee()).toString())
+                                        .toHolder(user.getName())
+                                        // 成功
+                                        // .toAccount("00012345678905")
+                                        // 失败
+                                        // .toAccount("00012345678906")
+                                        .toAccount(user.getBankAccount())
+                                        .toBankType(getPayChannelcode(w.getBank(), paymentChannel))
+                                        .notifyUrl(paymentChannel.getWithdrawNotifyUrl())
+                                        .build()
+                                , paymentChannel.getSecretKey());
+                        
+                        try {
+                            resultJson = JSONUtil.parseObj(bizLog.getReceiveMessage());
+                        } catch (Exception e) {
+                            log.error("提现失败三方返回-->" + bizLog);
+                            throw new ServiceException(LocalUtil.get("withdrawal.failed"));
+                        }
+                        bizLogList.add(BizLog.builder()
+                                .bizType(2)
+                                .bizNo(w.getOrderNo())
+                                .thirdOrderNo(thirdOrderNo)
+                                .type(7)
+                                .receiveMessage(bizLog.getReceiveMessage())
+                                .sendMessage(bizLog.getSendMessage())
+                                .createTime(now)
+                                .createUser(userName)
+                                .memo(resultJson.getStr("rMsg"))
+                                .build()
+                        );
+                        if (!resultJson.getStr("rMsg").equals("CREATE_SUCCESS")) {
+                            throw new ServiceException(LocalUtil.get("withdrawal.failed"));
+                        }
+                        break;
                     default:
                         throw new ServiceException(LocalUtil.get("this.channel.is.not.supported.temporarily"));
                 }
                 try {
-                  // 新增日志
-                  bizLogList.add(BizLog.builder()
-                    .bizType(2)
-                    .bizNo(w.getOrderNo())
-                    .thirdOrderNo(thirdOrderNo)
-                    .type(5)
-                    .createTime(now)
-                    .createUser(userName)
-                    .memo(review).build());
-                  bizLogService.save(bizLogList);
+                    // 新增日志
+                    bizLogList.add(BizLog.builder()
+                            .bizType(2)
+                            .bizNo(w.getOrderNo())
+                            .thirdOrderNo(thirdOrderNo)
+                            .type(5)
+                            .createTime(now)
+                            .createUser(userName)
+                            .memo(review).build());
+                    bizLogService.save(bizLogList);
                 } catch (Exception e) {
-                  log.error("新增提现提交订单日志失败", e);
+                    log.error("新增提现提交订单日志失败", e);
                 }
                 this.update(WithdrawRecord.builder().id(w.getId()).channel(paymentChannel.getChannelName()).review(review).status(status).updateUser(userName).thirdOrderNo(thirdOrderNo).build());
             } finally {
@@ -172,18 +219,18 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
             }
             return;
         } else {
-          try {
-            // 新增日志
-            bizLogService.save(BizLog.builder()
-              .bizType(2)
-              .bizNo(w.getOrderNo())
-              .type(6)
-              .createTime(DateUtil.date())
-              .createUser(userName)
-              .memo(review).build());
-          } catch (Exception e) {
-            log.error("新增提现提交订单日志失败", e);
-          }
+            try {
+                // 新增日志
+                bizLogService.save(BizLog.builder()
+                        .bizType(2)
+                        .bizNo(w.getOrderNo())
+                        .type(6)
+                        .createTime(DateUtil.date())
+                        .createUser(userName)
+                        .memo(review).build());
+            } catch (Exception e) {
+                log.error("新增提现提交订单日志失败", e);
+            }
         }
         // 解冻
         if (w.getFreezeId() != null) {
@@ -192,20 +239,20 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
         this.update(WithdrawRecord.builder().id(w.getId())
                 .review(review).updateUser(userName).status(status).build());
     }
-
+    
     private String getPayChannelcode(String channel, PaymentChannel paymentChannel) {
-        if (StrUtil.equals(channel.toLowerCase(),"bkash")){
+        if (StrUtil.equals(channel.toLowerCase(), "bkash")) {
             return paymentChannel.getBkashWithdrawCode();
         }
-        if (StrUtil.equals(channel.toLowerCase(),"nagad")){
+        if (StrUtil.equals(channel.toLowerCase(), "nagad")) {
             return paymentChannel.getNagadWithdrawCode();
         }
-        if (StrUtil.equals(channel.toLowerCase(),"rocket")){
+        if (StrUtil.equals(channel.toLowerCase(), "rocket")) {
             return paymentChannel.getRocketWithdrawCode();
         }
         return "";
     }
-
+    
     @Override
     public void success(WithdrawRecord record, Date successTime) {
         if (record.getFreezeId() != null) {
@@ -223,7 +270,7 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
                 .build());
         update(WithdrawRecord.builder().id(record.getId()).successTime(successTime).status(4).build());
     }
-
+    
     @Override
     public void fail(WithdrawRecord record) {
         if (record.getFreezeId() != null) {
@@ -231,17 +278,17 @@ public class WithdrawRecordServiceImpl extends AbstractService<WithdrawRecord> i
         }
         update(WithdrawRecord.builder().id(record.getId()).status(5).build());
     }
-
+    
     @Override
     public Integer countByUserId(HashMap map) {
         return withdrawRecordMapper.countByUserId(map);
     }
-
+    
     @Override
     public BigDecimal sumByStatus(HashMap map) {
         return withdrawRecordMapper.sumByStatus(map);
     }
-
+    
     @Override
     public BigDecimal sumByMap(HashMap<String, String> map) {
         return withdrawRecordMapper.sumByMap(map);

cif-service/src/main/java/com/txz/cif/util/TKPayUtil.java

@@ -0,0 +1,110 @@
+package com.txz.cif.util;
+
+import com.alibaba.fastjson.annotation.JSONField;
+
+import java.lang.reflect.Field;
+import java.math.BigDecimal;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.TreeMap;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/8/29
+ */
+public class TKPayUtil {
+    
+    /**
+     * 签名
+     *
+     * @param dto
+     *
+     * @return
+     */
+    public static String generateSignature(Object dto, String key) {
+        Map<String, Object> paramMap = convertObjectToMap(dto);
+        String signString = buildSignString(paramMap);
+        return md5(signString + "&key=" + key).toLowerCase();
+    }
+    
+    /**
+     * 验签
+     *
+     * @param dto
+     * @param expectedSign 签名
+     *
+     * @return
+     */
+    public static boolean verifySignature(Object dto, String key, String expectedSign) {
+        String generatedSign = generateSignature(dto, key);
+        return generatedSign.equals(expectedSign);
+    }
+    
+    public static Map<String, Object> convertObjectToMap(Object obj) {
+        Map<String, Object> paramMap = new TreeMap<>();
+        Class<?> clazz = obj.getClass();
+        Field[] fields = clazz.getDeclaredFields();
+        
+        for (Field field : fields) {
+            try {
+                field.setAccessible(true);
+                Object value = field.get(obj);
+                if (value != null && !value.toString().isEmpty()) {
+                    JSONField jsonProperty = field.getAnnotation(JSONField.class);
+                    String key = (jsonProperty != null) ? jsonProperty.name() : field.getName();
+                    
+                    if (value instanceof BigDecimal) {
+                        paramMap.put(key, ((BigDecimal) value).stripTrailingZeros().toPlainString());
+                    } else {
+                        paramMap.put(key, value);
+                    }
+                }
+            } catch (IllegalAccessException e) {
+            }
+        }
+        return paramMap;
+    }
+    
+    
+    private static String buildSignString(Map<String, Object> paramMap) {
+        StringBuilder sb = new StringBuilder();
+        Iterator<Map.Entry<String, Object>> iterator = paramMap.entrySet().iterator();
+        while (iterator.hasNext()) {
+            Map.Entry<String, Object> entry = iterator.next();
+            sb.append(entry.getKey()).append("=").append(entry.getValue());
+            if (iterator.hasNext()) {
+                sb.append("&");
+            }
+        }
+        return sb.toString();
+    }
+    
+    /**
+     * MD5加密
+     *
+     * @param input 输入字符串
+     *
+     * @return MD5加密结果
+     */
+    public static String md5(String input) {
+        try {
+            MessageDigest md = MessageDigest.getInstance("MD5");
+            byte[] messageDigest = md.digest(input.getBytes());
+            StringBuilder hexString = new StringBuilder();
+            
+            for (byte b : messageDigest) {
+                String hex = Integer.toHexString(0xFF & b);
+                if (hex.length() == 1) {
+                    hexString.append('0');
+                }
+                hexString.append(hex);
+            }
+            
+            return hexString.toString().toLowerCase();
+        } catch (NoSuchAlgorithmException e) {
+            throw new RuntimeException("MD5 algorithm not found", e);
+        }
+    }
+}

cif-service/src/main/java/com/txz/cif/web/RechargeRecordApiController.java

@@ -19,14 +19,17 @@ import com.txz.cif.core.*;
 import com.txz.cif.dto.BizLogDTO;
 import com.txz.cif.dto.tfpay.CheckSignDTO;
 import com.txz.cif.dto.tfpay.TFCreateOrderDTO;
+import com.txz.cif.dto.tkpay.TKPayCreateOrderDTO;
 import com.txz.cif.dubbo.client.NoticeDubboServiceClient;
 import com.txz.cif.model.*;
 import com.txz.cif.service.*;
 import com.txz.cif.service.impl.BizLogServiceImpl;
 import com.txz.cif.util.IpUtils;
 import com.txz.cif.util.TFPayUtil;
+import com.txz.cif.util.TKPayUtil;
 import com.txz.cif.web.para.RecordParam;
 import com.txz.cif.web.ro.TFPayNotifyRO;
+import com.txz.cif.web.ro.TKPayNotifyRO;
 import com.txz.cif.web.vo.CreatePayVO;
 import com.txz.cif.web.vo.PaymentPriceVO;
 import com.txz.mall.enums.NoticeEnum;
@@ -81,16 +84,18 @@ public class RechargeRecordApiController {
     
     @Resource
     private TFPayService tfPayService;
+    @Resource
+    private TKPayService tkPayService;
     
     @Resource
     private LockTemplate lockTemplate;
     @Autowired
     private BizLogServiceImpl bizLogServiceImpl;
-
+    
     @Resource
     private NoticeDubboServiceClient noticeDubboServiceClient;
-
-
+    
+    
     @GetMapping("/goodsList/{methodId:^\\d+$}")
     @ApiOperation(value = "充值商品", httpMethod = "GET")
     public Result<PaymentPriceVO> goodsList(@PathVariable("methodId") Long methodId) {
@@ -171,9 +176,9 @@ public class RechargeRecordApiController {
     @ApiOperation(value = "创建充值订单", httpMethod = "GET")
     public Result<CreatePayVO> add(@RequestParam BigDecimal amount, @RequestParam Long methodId, HttpServletRequest request) {
         Long userId = authService.getTokenUserId(request);
-         if (userId == null) {
-             return ResultGenerator.genFailResult(ResultCode.OAUTH_INVALID_ACCESS_TOKEN);
-         }
+        if (userId == null) {
+            return ResultGenerator.genFailResult(ResultCode.OAUTH_INVALID_ACCESS_TOKEN);
+        }
         if (amount == null || amount.compareTo(BigDecimal.ZERO) <= 0) {
             return ResultGenerator.genFailResult(ResultCode.AMOUNT_IS_NULL);
         }
@@ -226,6 +231,7 @@ public class RechargeRecordApiController {
             BizLogDTO bizLog;
             String payUrl = "";
             boolean issuccess = false;
+            JSONObject resultJson;
             switch (paymentChannel.getChannelName()) {
                 case "TFPAY":
                     bizLog = tfPayService.createTFPayOrder(
@@ -240,12 +246,35 @@ public class RechargeRecordApiController {
                                     .build()
                             , paymentChannel.getSecretKey());
                     
-                    JSONObject resultJson = JSONUtil.parseObj(bizLog.getReceiveMessage());
+                    resultJson = JSONUtil.parseObj(bizLog.getReceiveMessage());
                     if (resultJson.getStr("status").equals("200")) {
                         payUrl = resultJson.getStr("data");
                         issuccess = Boolean.TRUE;
                     }
                     break;
+                case "tk":
+                    bizLog = tkPayService.createTKPayOrder(
+                            TKPayCreateOrderDTO.builder()
+                                    .mchid(paymentChannel.getMerchantNum())
+                                    .payId(channelCode)
+                                    .outTradeNo(orderNo)
+                                    .amount(String.format("%.2f", amount))
+                                    .notifyUrl(paymentChannel.getNotifyUrl())
+                                    .build()
+                            , paymentChannel.getSecretKey());
+                    
+                    resultJson = JSONUtil.parseObj(bizLog.getReceiveMessage());
+                    // success
+                    // {"data":{"status":1,"msg":"CREATE_SUCCESS","pay_id":"11","trade_no":"T0105090723VAMG0P8T","out_trade_no":"20260105000000000003","amount":"300.00","pay_link":"https://tk.passpay-mobi.com/pay/BD?orderNo=T0105090723VAMG0P8T&amount=300.00"},"rCode":200,"rMsg":"CREATE_SUCCESS","elapsed_time":0.029}
+                    
+                    // error
+                    // {"data":{"status":2,"msg":"非法IP:50.7.252.26， 请联系运营加白"},"rCode":200,"rMsg":"非法IP:50.7.252.26， 请联系运营加白","elapsed_time":0.004}
+                    JSONObject data = JSONUtil.parseObj(resultJson.getStr("data"));
+                    if (data.getStr("status").equals("1")) {
+                        payUrl = data.getStr("pay_link");
+                        issuccess = Boolean.TRUE;
+                    }
+                    break;
                 default:
                     throw new ServiceException(LocalUtil.get("this.channel.is.not.supported.temporarily"));
             }
@@ -336,8 +365,8 @@ public class RechargeRecordApiController {
                 log.error("新增充值回调日志失败", e);
             }
             try {
-                noticeDubboServiceClient.addMoneyNotice(NoticeEnum.MONEY_RECHARGE_SUCCESS,record.getUserId());
-            }catch (Exception e) {
+                noticeDubboServiceClient.addMoneyNotice(NoticeEnum.MONEY_RECHARGE_SUCCESS, record.getUserId());
+            } catch (Exception e) {
                 log.error("新增充值回调消息失败", e);
             }
             return "OK";
@@ -346,6 +375,75 @@ public class RechargeRecordApiController {
         }
     }
     
+    /**
+     * 回调通知
+     */
+    @PostMapping("/callback/tkpay")
+    public Object tkpay(@RequestBody TKPayNotifyRO dto) {
+        LockInfo lockInfo = lockTemplate.lock(String.format(MyConstants.TK_PAY_NOTIFY_LOCK, dto.getOutTradeNo()), Long.valueOf(1000 * 60 * 2), Long.valueOf(1000 * 1), RedisTemplateLockExecutor.class);
+        if (null == lockInfo) {
+            return "WAIT";
+        }
+        try {
+            log.info("支付渠道--->tkpay,回调通知--->" + dto);
+            Condition condition = new Condition(PaymentChannel.class);
+            Example.Criteria criteria = condition.createCriteria();
+            criteria.andEqualTo("channelName", "tk");
+            criteria.andEqualTo("isValid", 1);
+            List<PaymentChannel> paymentChannels = paymentChannelService.findByCondition(condition);
+            if (CollectionUtil.isEmpty(paymentChannels)) {
+                log.error("支付渠道不存在");
+                return "fail";
+            }
+            boolean checkSignResult = TKPayUtil.verifySignature(BeanUtil.copyProperties(dto, com.txz.cif.dto.tkpay.CheckSignDTO.class), paymentChannels.get(0).getSecretKey(), dto.getSign());
+            if (!checkSignResult) {
+                log.error("签名校验失败");
+                return "fail";
+            }
+            RechargeRecord record = rechargeRecordService.findBy("orderNo", dto.getOutTradeNo());
+            if (ObjectUtil.isEmpty(record)) {
+                return "fail";
+            }
+            if (record.getStatus() == 2 || record.getStatus() == 3) {
+                return "fail";
+            }
+            record.setRealAmount(new BigDecimal(dto.getAmount()));
+            rechargeRecordService.success(record);
+            
+            // String orderNo = dto.getOrderid();
+            // RechargeRecord record = rechargeRecordService.findBy("orderNo", orderNo);
+            // if (record == null) {
+            //     return ResultGenerator.genFailResult("订单未找到");
+            // }
+            // if (StrUtil.equals("1", json.getStr("status"))) {
+            // rechargeRecordService.success(record);
+            // } else {
+            //     rechargeRecordService.fail(record);
+            // }
+            try {
+                // 新增充值回调日志
+                bizLogService.save(BizLog.builder()
+                        .bizType(1)
+                        .bizNo(dto.getOutTradeNo())
+                        .type(3)
+                        .receiveMessage(dto.toString())
+                        .createTime(DateUtil.date())
+                        .createUser("TKPAY")
+                        .memo("充值回调").build());
+            } catch (Exception e) {
+                log.error("新增充值回调日志失败", e);
+            }
+            try {
+                noticeDubboServiceClient.addMoneyNotice(NoticeEnum.MONEY_RECHARGE_SUCCESS, record.getUserId());
+            } catch (Exception e) {
+                log.error("新增充值回调消息失败", e);
+            }
+            return "success";
+        } finally {
+            lockTemplate.releaseLock(lockInfo);
+        }
+    }
+    
     
     @GetMapping("/detail")
     @ApiOperation(value = "rechargeRecord获取详情", httpMethod = "GET")

cif-service/src/main/java/com/txz/cif/web/WithdrawRecordApiController.java

@@ -22,9 +22,11 @@ import com.txz.cif.dubbo.client.OperatingConfigDubboServiceClient;
 import com.txz.cif.model.*;
 import com.txz.cif.service.*;
 import com.txz.cif.util.TFPayUtil;
+import com.txz.cif.util.TKPayUtil;
 import com.txz.cif.web.para.RecordParam;
 import com.txz.cif.web.para.WithdrawParam;
 import com.txz.cif.web.ro.TFWithdrawCallbackRO;
+import com.txz.cif.web.ro.TKWithdrawCallbackRO;
 import com.txz.mall.enums.NoticeEnum;
 import com.txz.operating.dto.ConfigDTO;
 import io.jsonwebtoken.Claims;
@@ -42,6 +44,7 @@ import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
+import java.util.Date;
 import java.util.List;
 
 import static com.txz.cif.core.AbstractApiController.X_CLIENT_TOKEN;
@@ -53,40 +56,40 @@ import static com.txz.cif.core.AbstractApiController.X_CLIENT_TOKEN;
 @RestController
 @RequestMapping("/api/withdraw/record")
 public class WithdrawRecordApiController {
-
+    
     private static Logger log = LoggerFactory.getLogger(WithdrawRecordApiController.class);
-
+    
     @Resource
     private WithdrawRecordService withdrawRecordService;
-
+    
     @Resource
     private SequenceService sequenceService;
-
+    
     @Resource
     private AuthService authService;
-
+    
     @Resource
     private AccountService accountService;
-
+    
     @Resource
     private BizLogService bizLogService;
-
+    
     @Resource
     private PaymentChannelService paymentChannelService;
-
+    
     @Resource
     private UserService userService;
-
+    
     @Resource
     private LockTemplate lockTemplate;
-
+    
     @Resource
     private OperatingConfigDubboServiceClient operatingConfigDubboServiceClient;
-
-
+    
+    
     @Resource
     private NoticeDubboServiceClient noticeDubboServiceClient;
-
+    
     @PostMapping("/add")
     @ApiOperation(value = "新增提现订单", httpMethod = "POST")
     public Result add(@RequestBody WithdrawParam param, @RequestHeader(value = X_CLIENT_TOKEN, required = false) String token) {
@@ -95,7 +98,7 @@ public class WithdrawRecordApiController {
         }
         try {
             Triple<Boolean, String, Claims> result = authService.verifyToken(token);
-
+            
             if (!result.getLeft()) {
                 // token无效
                 String errorMsg = result.getMiddle();
@@ -104,7 +107,7 @@ public class WithdrawRecordApiController {
             }
             Claims claims = result.getRight();
             Long userId = Long.valueOf(claims.get("userId").toString());
-
+            
             User user = userService.findById(userId);
             if (user == null) {
                 return ResultGenerator.genFailResult(ResultCode.USER_IS_NULL);
@@ -141,7 +144,7 @@ public class WithdrawRecordApiController {
                 return ResultGenerator.genFailResult(ResultCode.AMOUNT_OUT_MAX);
             }
             String key = "";
-            if (param.getAccountType() == 1){
+            if (param.getAccountType() == 1) {
                 key = "withdraw_rate";
             } else {
                 key = "earning_withdraw_rate";
@@ -149,7 +152,7 @@ public class WithdrawRecordApiController {
             com.txz.operating.result.Result<ConfigDTO> openRedEnvelopeRate = operatingConfigDubboServiceClient.getConfigByCode(key);
             String rate = openRedEnvelopeRate.getData().getValueInfo();
             BigDecimal fee = param.getAmount().multiply(new BigDecimal(rate)).divide(BigDecimal.valueOf(100), 2, RoundingMode.DOWN);
-
+            
             Account account = accountService.getAccount(userId, param.getAccountType());
             if (account == null) {
                 return ResultGenerator.genFailResult(ResultCode.ACCOUNT_IS_NULL);
@@ -157,9 +160,9 @@ public class WithdrawRecordApiController {
             if (account.getEffectiveBalance().compareTo(param.getAmount().add(fee)) < 0) {
                 return ResultGenerator.genFailResult(ResultCode.EFFECTIVE_BALANCE_IS_INSUFFICIENT);
             }
-
+            
             String orderNo = sequenceService.genSerialNumber("withdraw_rule", null);
-
+            
             WithdrawRecord withdrawRecord = new WithdrawRecord();
             withdrawRecord.setOrderNo(orderNo);
             withdrawRecord.setStatus(1);
@@ -172,28 +175,28 @@ public class WithdrawRecordApiController {
             withdrawRecord.setBank(user.getBank());
             withdrawRecord.setBankAccount(user.getBankAccount());
             withdrawRecord.setBankAccountName(user.getBankAccountName());
-//             withdrawRecord.setChannel(param.getChannel());
+            //             withdrawRecord.setChannel(param.getChannel());
             withdrawRecord.setCurrency(param.getCurrency());
             withdrawRecord.setAmount(param.getAmount());
             withdrawRecord.setCreateTime(DateUtil.date());
             withdrawRecordService.add(withdrawRecord);
             // 新增日志
             bizLogService.save(BizLog.builder()
-              .bizType(2)
-              .bizNo(orderNo)
-              .type(4)
-              .createTime(DateUtil.date())
-              .createUser(user.getName())
-              .memo("提交提现申请").build());
+                    .bizType(2)
+                    .bizNo(orderNo)
+                    .type(4)
+                    .createTime(DateUtil.date())
+                    .createUser(user.getName())
+                    .memo("提交提现申请").build());
             return ResultGenerator.genSuccessResult(withdrawRecord);
         } catch (Exception e) {
             log.error("新增对象操作异常e:{}", e);
             return ResultGenerator.genFailResult(ResultCode.INTERNAL_SERVER_ERROR);
         }
-
+        
     }
-
-
+    
+    
     @PostMapping("/list")
     @ApiOperation(value = "withdrawRecord获取列表", httpMethod = "POST")
     public Result<List<WithdrawRecord>> list(@RequestBody RecordParam param, HttpServletRequest request) {
@@ -202,7 +205,7 @@ public class WithdrawRecordApiController {
             ResultGenerator.genFailResult(ResultCode.OAUTH_INVALID_ACCESS_TOKEN);
         }
         PageHelper.startPage(param.getPage(), param.getSize());
-
+        
         Condition condition = new Condition(WithdrawRecord.class);
         Criteria criteria = condition.createCriteria();
         criteria.andEqualTo("userId", userId);
@@ -246,7 +249,7 @@ public class WithdrawRecordApiController {
         }
         return ResultGenerator.genSuccessResult(pageInfo);
     }
-
+    
     /**
      * tfpay提现通知
      */
@@ -268,12 +271,12 @@ public class WithdrawRecordApiController {
                 return "FAIL";
             }
             boolean checkSignResult = TFPayUtil.verifySignature(BeanUtil.copyProperties(dto, CheckWithdrawSignDTO.class), paymentChannels.get(0).getSecretKey(), dto.getSign());
-
+            
             if (!checkSignResult) {
                 log.error("签名校验失败");
                 return "FAIL";
             }
-
+            
             Condition condition = new Condition(WithdrawRecord.class);
             Example.Criteria criteria = condition.createCriteria();
             criteria.andEqualTo("thirdOrderNo", dto.getOrderid());
@@ -283,7 +286,7 @@ public class WithdrawRecordApiController {
                 log.error("提现订单不存在");
                 return "FAIL";
             }
-
+            
             // //TODO 回调成功
             // JSONObject json = JSONUtil.parseObj(data);
             // String orderNo = json.getStr("orderNo");
@@ -336,7 +339,7 @@ public class WithdrawRecordApiController {
             } catch (Exception e) {
                 log.error("新增充值回调日志失败", e);
                 // }
-
+                
             }
             try {
                 noticeDubboServiceClient.addMoneyNotice(ne, record.getUserId());
@@ -348,5 +351,107 @@ public class WithdrawRecordApiController {
             lockTemplate.releaseLock(lockInfo);
         }
     }
-
+    
+    /**
+     * tkpay提现通知
+     */
+    @PostMapping("/callback/tkpay")
+    public String tkcallback(@RequestBody TKWithdrawCallbackRO dto) {
+        LockInfo lockInfo = lockTemplate.lock(String.format(MyConstants.TK_PAY_WITHDRAW_NOTIFY_LOCK, dto.getOutTradeNo()), Long.valueOf(1000 * 60 * 2), Long.valueOf(1000 * 1), RedisTemplateLockExecutor.class);
+        if (null == lockInfo) {
+            return "WAIT";
+        }
+        try {
+            log.info("提现渠道--->tkpay,提现回调通知--->" + dto);
+            Condition channelCondition = new Condition(PaymentChannel.class);
+            Example.Criteria channelCriteria = channelCondition.createCriteria();
+            channelCriteria.andEqualTo("channelName", "tk");
+            channelCriteria.andEqualTo("isValid", 1);
+            List<PaymentChannel> paymentChannels = paymentChannelService.findByCondition(channelCondition);
+            if (CollectionUtil.isEmpty(paymentChannels)) {
+                log.error("支付渠道不存在");
+                return "fail";
+            }
+            boolean checkSignResult = TKPayUtil.verifySignature(BeanUtil.copyProperties(dto, com.txz.cif.dto.tkpay.CheckWithdrawSignDTO.class), paymentChannels.get(0).getSecretKey(), dto.getSign());
+            
+            if (!checkSignResult) {
+                log.error("签名校验失败");
+                return "fail";
+            }
+            
+            Condition condition = new Condition(WithdrawRecord.class);
+            Example.Criteria criteria = condition.createCriteria();
+            criteria.andEqualTo("thirdOrderNo", dto.getOutTradeNo());
+            criteria.andEqualTo("status", 2);
+            List<WithdrawRecord> records = withdrawRecordService.findByCondition(condition);
+            if (CollectionUtil.isEmpty(records)) {
+                log.error("提现订单不存在");
+                return "fail";
+            }
+            
+            // //TODO 回调成功
+            // JSONObject json = JSONUtil.parseObj(data);
+            // String orderNo = json.getStr("orderNo");
+            // WithdrawRecord record = withdrawRecordService.findBy("orderNo", orderNo);
+            // if (record == null) {
+            //     return ResultGenerator.genFailResult("订单未找到");
+            // }
+            // Integer type = 8;
+            // if (StrUtil.equals("1", json.getStr("status"))) {
+            //     withdrawRecordService.success(record);
+            // } else {
+            //     withdrawRecordService.fail(record);
+            //     type = 9;
+            // }
+            // try {
+            //     // 新增充值回调日志
+            //     bizLogService.save(BizLog.builder().bizType(2).bizNo(orderNo)
+            //             .type(type).createTime(DateUtil.date()).createUser("第三方")
+            //             .memo("提现回调").build());
+            // } catch (Exception e) {
+            //     log.error("新增充值回调日志失败", e);
+            // }
+            // return ResultGenerator.genSuccessResult();
+            WithdrawRecord record = records.get(0);
+            NoticeEnum ne = null;
+            Integer type = 8;
+            if (dto.getStatus() == 5) {
+                withdrawRecordService.success(record, new Date());
+                if (record.getAccountType() == 1) {
+                    ne = NoticeEnum.MONEY_WITHDRAWAL_WALLET_SUCCESS;
+                } else if (record.getAccountType() == 2) {
+                    ne = NoticeEnum.MONEY_WITHDRAWAL_ACCOUNT_SUCCESS;
+                }
+            } else {
+                withdrawRecordService.fail(records.get(0));
+                type = 9;
+                ne = NoticeEnum.MONEY_WITHDRAWAL_FAIL;
+            }
+            try {
+                // 新增充值回调日志
+                bizLogService.save(BizLog.builder()
+                        .bizType(2)
+                        .bizNo(record.getOrderNo())
+                        .thirdOrderNo(dto.getOutTradeNo())
+                        .type(type)
+                        .receiveMessage(dto.toString())
+                        .createTime(DateUtil.date())
+                        .createUser("TFPAY")
+                        .memo("提现回调").build());
+            } catch (Exception e) {
+                log.error("新增充值回调日志失败", e);
+                // }
+                
+            }
+            try {
+                noticeDubboServiceClient.addMoneyNotice(ne, record.getUserId());
+            } catch (Exception e) {
+                log.error("新增提现回调消息失败", e);
+            }
+            return "success";
+        } finally {
+            lockTemplate.releaseLock(lockInfo);
+        }
+    }
+    
 }

cif-service/src/main/java/com/txz/cif/web/ro/TKPayNotifyRO.java

@@ -0,0 +1,78 @@
+package com.txz.cif.web.ro;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/1
+ */
+
+@Data
+public class TKPayNotifyRO {
+    
+    /**
+     *
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     *
+     */
+    @JSONField(name = "pay_id")
+    private String payId;
+    
+    /**
+     * 三方单号
+     */
+    @JSONField(name = "trade_no")
+    private String tradeNo;
+    
+    /**
+     * 商户传入订单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    /**
+     *
+     */
+    @JSONField(name = "utr")
+    private String utr;
+    
+    /**
+     * 订单金额：100.00
+     * 实际与 real_amount 一样，随便用哪个
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 实际支付金额：100.00
+     * 实际与 amount 一样，随便用哪个
+     */
+    @JSONField(name = "real_amount")
+    private String realAmount;
+    
+    /**
+     * 交易状态：
+     * 3-交易中
+     * 5-交易成功
+     * 6-交易失败
+     */
+    @JSONField(name = "status")
+    private Integer status;
+    
+    /**
+     * 订单状态描述
+     */
+    @JSONField(name = "msg")
+    private String msg;
+    
+    /**
+     * 签名
+     */
+    @JSONField(name = "sign")
+    private String sign;
+}

cif-service/src/main/java/com/txz/cif/web/ro/TKWithdrawCallbackRO.java

@@ -0,0 +1,79 @@
+package com.txz.cif.web.ro;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author: MTD®️
+ * @date: 2025/9/3
+ */
+@Data
+public class TKWithdrawCallbackRO {
+    
+    /**
+     *
+     */
+    @JSONField(name = "mchid")
+    private String mchid;
+    
+    /**
+     * 代付交易状态：
+     * 5-代付交易成功；
+     * 6-代付交易失败；
+     * 3-交易中（实际上不会同步）
+     */
+    @JSONField(name = "status")
+    private Integer status;
+    
+    /**
+     * 当status=6时，返回代付失败的原因
+     */
+    @JSONField(name = "msg")
+    private String msg;
+    
+    /**
+     * 三方单号
+     */
+    @JSONField(name = "trade_no")
+    private String tradeNo;
+    
+    /**
+     * 商户单号
+     */
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+    
+    @JSONField(name = "utr")
+    private String utr;
+    
+    /**
+     * 代付订单金额
+     */
+    @JSONField(name = "amount")
+    private String amount;
+    
+    /**
+     * 持卡人姓名
+     */
+    @JSONField(name = "to_holder")
+    private String toHolder;
+    
+    /**
+     * 银行卡卡号
+     */
+    @JSONField(name = "to_account")
+    private String toAccount;
+    
+    /**
+     * 银行类型，暂时仅支持：
+     * bKash; Nagad 两种类型
+     */
+    @JSONField(name = "to_bank_type")
+    private String toBankType;
+    
+    /**
+     * 签名
+     */
+    @JSONField(name = "sign")
+    private String sign;
+}