wlzboy
2 天以前 8cb5d3440208a3be3e772e65f1bd0ec63031ba62
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
package com.ruoyi.system.mapper;
 
import java.util.List;
 
import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.system.domain.SysTaskPayment;
import org.apache.ibatis.annotations.Param;
 
/**
 * 任务支付Mapper接口
 * 
 * @author ruoyi
 * @date 2025-01-15
 */
@DataSource(DataSourceType.MASTER)
public interface SysTaskPaymentMapper {
    
    /**
     * 根据任务ID查询最近一次已支付的记录
     * 
     * @param taskId 任务ID
     * @return 支付记录
     */
    SysTaskPayment selectLatestPaidByTaskId(Long taskId);
    
    /**
     * 根据任务ID查询所有已支付记录
     * 
     * @param taskId 任务ID
     * @return 已支付记录列表
     */
    List<SysTaskPayment> selectAllPaidByTaskId(Long taskId);
    
    /**
     * 根据任务ID查询所有支付记录
     * 
     * @param taskId 任务ID
     * @return 支付记录列表
     */
    List<SysTaskPayment> selectByTaskId(Long taskId);
    
    /**
     * 根据ID查询支付记录
     * 
     * @param id 主键
     * @return 支付记录
     */
    SysTaskPayment selectById(Long id);
    
    /**
     * 根据商户订单号查询支付记录
     * 
     * @param outTradeNo 商户订单号
     * @return 支付记录
     */
    SysTaskPayment selectByOutTradeNo(String outTradeNo);
    
    /**
     * 新增支付记录
     * 
     * @param payment 支付记录
     * @return 结果
     */
    int insert(SysTaskPayment payment);
    
    /**
     * 更新支付记录
     * 
     * @param payment 支付记录
     * @return 结果
     */
    int update(SysTaskPayment payment);
    
    /**
     * 更新支付状态
     * 
     * @param id 主键
     * @param payStatus 支付状态
     * @param tradeNo 交易号
     * @return 结果
     */
    int updatePayStatus(@Param("id") Long id, @Param("payStatus") String payStatus, 
                        @Param("tradeNo") String tradeNo);
    
    /**
     * 根据旧系统支付ID查询新系统支付记录
     * 
     * @param pid 旧系统PaidMoney.id
     * @return 支付记录
     */
    SysTaskPayment selectByPid(Long pid);
 
    /**
     * 更新同步信息(pid、syncStatus、syncTime)
     * 
     * @param id 主键
     * @param pid 旧系统支付ID
     * @param syncStatus 同步状态
     * @param syncTime 同步时间
     * @return 结果
     */
    int updateSyncInfo(@Param("id") Long id, @Param("pid") Long pid,
                       @Param("syncStatus") Integer syncStatus, @Param("syncTime") java.util.Date syncTime);
    
    /**
     * 查询未同步的支付成功记录(用于批量同步)
     * 
     * @return 支付记录列表
     */
    List<SysTaskPayment> selectUnsyncedPaidPayments();
}