Middleware/msgpush
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除消息重试队列delete字段

Browse Source
This commit is contained in:
caozehui
2026-04-20 11:13:21 +08:00
parent cb9a75084f
commit c147ef602f
2 changed files with 0 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/message/vo/MessageRecordReqVO.java
View File

@@ -16,9 +16,6 @@ import lombok.Data;
@Data @Data
@Schema(description = "管理后台 - 消息记录发送 Request VO") @Schema(description = "管理后台 - 消息记录发送 Request VO")
public class MessageRecordReqVO extends PageParam { public class MessageRecordReqVO extends PageParam {
@Schema(description = "主键ID")
private Long id;
@Schema(description = "渠道类型：sms/email/app", example = "sms") @Schema(description = "渠道类型：sms/email/app", example = "sms")
@InEnum(value = com.njcn.msgpush.module.push.enums.ChannelTypeEnum.class, message = "渠道类型必须是 {value}") @InEnum(value = com.njcn.msgpush.module.push.enums.ChannelTypeEnum.class, message = "渠道类型必须是 {value}")
private String channel; private String channel;
@@ -43,7 +40,4 @@ public class MessageRecordReqVO extends PageParam {
@Schema(description = "模板参数") @Schema(description = "模板参数")
private String templateParams; private String templateParams;
@Schema(description = "第三方消息ID")
private String thirdPartyId;
} }

2
msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/dal/mysql/retry/mapping/MessageRetryQueueMapper.xml
View File

@@ -7,7 +7,6 @@
FROM push_message_retry_queue FROM push_message_retry_queue
WHERE channel = #{channel} WHERE channel = #{channel}
AND next_retry_time <![CDATA[ <= ]]> #{currentTime} AND next_retry_time <![CDATA[ <= ]]> #{currentTime}
AND deleted = 0
AND ( AND (
process_status = 0 process_status = 0
OR process_status IS NULL OR process_status IS NULL
@@ -24,7 +23,6 @@
lock_until = #{lockUntil} lock_until = #{lockUntil}
WHERE message_id = #{messageId} WHERE message_id = #{messageId}
AND channel = #{channel} AND channel = #{channel}
AND deleted = 0
AND next_retry_time <![CDATA[ <= ]]> #{currentTime} AND next_retry_time <![CDATA[ <= ]]> #{currentTime}
AND ( AND (
process_status = 0 process_status = 0