diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
index 146e3b5b..574558b7 100644
--- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
+++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
@@ -714,7 +714,6 @@ public class PendingMessageNewServiceImpl implements PendingMessageNewService {
         }
         LambdaQueryChainWrapper<PendingMessageRecord> query = pendingMessageRecordDao.lambdaQuery()
                 .in(PendingMessageRecord::getTemplateCode, templateCodes)
-                .eq(Objects.nonNull(param.getOuId()), PendingMessageRecord::getOuId, param.getOuId())
                 .eq(PendingMessageRecord::getState, PendingMessageStateEnum.HAS_BEEN_SENT)
                 .eq(PendingMessageRecord::getIsDelete,IsDeletedEnum.NO.getCode());
         appendExecutorOuIdExpr(query, param.getOuId());