|
@@ -15,11 +15,11 @@ import java.util.Map;
|
|
|
public interface InviteRewardMapper extends BaseMapper<InviteReward> {
|
|
public interface InviteRewardMapper extends BaseMapper<InviteReward> {
|
|
|
|
|
|
|
|
// 根据邀请记录ID查询奖励记录
|
|
// 根据邀请记录ID查询奖励记录
|
|
|
- @Select("SELECT * FROM t_invite_reward WHERE record_id = #{recordId} AND deleted = 0 LIMIT 1")
|
|
|
|
|
|
|
+ @Select("SELECT * FROM t_invite_reward WHERE record_id = #{recordId} LIMIT 1")
|
|
|
InviteReward selectByRecordId(@Param("recordId") Long recordId);
|
|
InviteReward selectByRecordId(@Param("recordId") Long recordId);
|
|
|
|
|
|
|
|
// 根据邀请记录ID和奖励类型查询奖励记录(用于检查是否已发放过被邀请人奖励)
|
|
// 根据邀请记录ID和奖励类型查询奖励记录(用于检查是否已发放过被邀请人奖励)
|
|
|
- @Select("SELECT * FROM t_invite_reward WHERE record_id = #{recordId} AND reward_type = #{rewardType} AND deleted = 0 LIMIT 1")
|
|
|
|
|
|
|
+ @Select("SELECT * FROM t_invite_reward WHERE record_id = #{recordId} AND reward_type = #{rewardType} LIMIT 1")
|
|
|
InviteReward selectByRecordIdAndRewardType(@Param("recordId") Long recordId, @Param("rewardType") Integer rewardType);
|
|
InviteReward selectByRecordIdAndRewardType(@Param("recordId") Long recordId, @Param("rewardType") Integer rewardType);
|
|
|
|
|
|
|
|
// 更新奖励状态为已发放
|
|
// 更新奖励状态为已发放
|
|
@@ -39,13 +39,13 @@ public interface InviteRewardMapper extends BaseMapper<InviteReward> {
|
|
|
@Param("operatorName") String operatorName);
|
|
@Param("operatorName") String operatorName);
|
|
|
|
|
|
|
|
// 查询待重试的失败奖励记录
|
|
// 查询待重试的失败奖励记录
|
|
|
- @Select("SELECT * FROM t_invite_reward WHERE status = 2 AND retry_count < #{maxRetry} AND deleted = 0 ORDER BY create_time ASC LIMIT #{limit}")
|
|
|
|
|
|
|
+ @Select("SELECT * FROM t_invite_reward WHERE status = 2 AND retry_count < #{maxRetry} ORDER BY create_time ASC LIMIT #{limit}")
|
|
|
List<InviteReward> selectFailedRewardsForRetry(@Param("maxRetry") Integer maxRetry, @Param("limit") Integer limit);
|
|
List<InviteReward> selectFailedRewardsForRetry(@Param("maxRetry") Integer maxRetry, @Param("limit") Integer limit);
|
|
|
|
|
|
|
|
// 统计某活动的奖励发放情况
|
|
// 统计某活动的奖励发放情况
|
|
|
@Select("SELECT COUNT(*) as totalCount, " +
|
|
@Select("SELECT COUNT(*) as totalCount, " +
|
|
|
"SUM(CASE WHEN status = 1 THEN 1 ELSE 0 END) as distributedCount, " +
|
|
"SUM(CASE WHEN status = 1 THEN 1 ELSE 0 END) as distributedCount, " +
|
|
|
"SUM(CASE WHEN status = 2 THEN 1 ELSE 0 END) as failedCount " +
|
|
"SUM(CASE WHEN status = 2 THEN 1 ELSE 0 END) as failedCount " +
|
|
|
- "FROM t_invite_reward WHERE activity_id = #{activityId} AND deleted = 0")
|
|
|
|
|
|
|
+ "FROM t_invite_reward WHERE activity_id = #{activityId}")
|
|
|
Map<String, Object> selectRewardStatistics(@Param("activityId") Long activityId);
|
|
Map<String, Object> selectRewardStatistics(@Param("activityId") Long activityId);
|
|
|
}
|
|
}
|