Prechádzať zdrojové kódy

新增钱包订单相关业务接口

xucaiqin 2 rokov pred
rodič
commit
4072938bee

+ 6 - 0
sckw-modules/sckw-payment/src/main/java/com/sckw/payment/model/vo/PrePayWalletVo.java

@@ -1,11 +1,13 @@
 package com.sckw.payment.model.vo;
 
 import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Getter;
 import lombok.Setter;
 
 import java.io.Serial;
 import java.io.Serializable;
+import java.time.LocalDateTime;
 
 /**
  * 预付预收数据
@@ -68,4 +70,8 @@ public class PrePayWalletVo implements Serializable {
     @JSONField(name = "total_ap_money")
     private String totalApMoney;
 
+    @JsonFormat(timezone = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime updateTime;
+
+
 }

+ 61 - 0
sckw-modules/sckw-payment/src/main/java/com/sckw/payment/service/WalletOrderService.java

@@ -0,0 +1,61 @@
+package com.sckw.payment.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckw.payment.dao.KwpWalletRefundMapper;
+import com.sckw.payment.dao.KwpWalletTransferMapper;
+import com.sckw.payment.model.KwpWalletRefund;
+import com.sckw.payment.model.constant.RefundEnum;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 钱包订单相关业务
+ *
+ * @author xucaiqin
+ * @date 2023-09-18 19:20:02
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class WalletOrderService {
+    private final KwpWalletRefundMapper kwpWalletRefundMapper;
+    private final KwpWalletTransferMapper kwpWalletTransferMapper;
+
+    /**
+     * 预付、预收 查询退款中金额
+     *
+     * @param change  true-预收,需要转换双方企业
+     * @param channel huifu-汇付渠道
+     */
+    public KwpWalletRefund query(boolean change, String uid, String filter, String channel) {
+        LambdaQueryWrapper<KwpWalletRefund> wrapper = new LambdaQueryWrapper<>();
+        //预收时,切换预收预付的双方人员
+        if (change) {
+            wrapper.eq(KwpWalletRefund::getUid, filter).eq(KwpWalletRefund::getFilter, uid);
+        } else {
+            wrapper.eq(KwpWalletRefund::getUid, uid).eq(KwpWalletRefund::getFilter, filter);
+        }
+        wrapper.eq(KwpWalletRefund::getChannel, channel)
+                .eq(KwpWalletRefund::getStatus, RefundEnum.REFUNDING.getStatus())
+                .orderByDesc(KwpWalletRefund::getCreateTime).last("limit 1");
+        return kwpWalletRefundMapper.selectOne(wrapper);
+    }
+
+    /**
+     * 查询退款中的订单
+     *
+     * @param uid
+     * @param filter
+     * @param channel
+     * @return
+     */
+    public KwpWalletRefund queryOne(String uid, String filter, String channel,RefundEnum refundEnum) {
+        LambdaQueryWrapper<KwpWalletRefund> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(KwpWalletRefund::getUid, uid).eq(KwpWalletRefund::getFilter, filter);
+        wrapper.eq(KwpWalletRefund::getChannel, channel)
+                .eq(KwpWalletRefund::getStatus, refundEnum.getStatus())
+                .orderByDesc(KwpWalletRefund::getCreateTime).last("limit 1");
+        return kwpWalletRefundMapper.selectOne(wrapper);
+    }
+}