diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/credential/CredentialController.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/credential/CredentialController.java index c48d627..4f99a36 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/credential/CredentialController.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/controller/admin/credential/CredentialController.java @@ -6,6 +6,7 @@ import com.njcn.msgpush.module.push.dal.dataobject.credential.dto.CredentialResp import com.njcn.msgpush.module.push.service.credential.ICredentialService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; +import jakarta.annotation.security.PermitAll; import jakarta.validation.Valid; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; @@ -26,6 +27,7 @@ public class CredentialController { @Autowired private ICredentialService credentialService; + @PermitAll @PostMapping("/generate") @Operation(summary = "生成系统凭证") public CommonResult generateCredential(@Valid @RequestBody CredentialReqDTO reqDTO) { diff --git a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/retry/MessageRetryQueueServiceImpl.java b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/retry/MessageRetryQueueServiceImpl.java index ff023eb..08de37e 100644 --- a/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/retry/MessageRetryQueueServiceImpl.java +++ b/msgpush-module-push/msgpush-module-push-server/src/main/java/com/njcn/msgpush/module/push/service/retry/MessageRetryQueueServiceImpl.java @@ -230,7 +230,7 @@ public class MessageRetryQueueServiceImpl extends ServiceImpl().in(MessageRetryQueueDO::getMessageId, messageIds)); + return this.baseMapper.delete(new LambdaQueryWrapper().in(MessageRetryQueueDO::getMessageId, messageIds)) > 0; } @Override