Browse Source

增加主体

xueyiming 6 months ago
parent
commit
0fd1355c60

+ 4 - 1
we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComMessageDataJob.java

@@ -301,7 +301,10 @@ public class WeComMessageDataJob {
         List<SendMessage> groupList = sendMessageMapper.getGroupList(DateUtil.getThatDayDate(), 0);
         if (xxlJobParam.getSubjectId() != null) {
             Long subjectId = xxlJobParam.getSubjectId();
-            groupList = groupList.stream().filter(e -> Objects.equals(e.getStaffId(), subjectId)).collect(Collectors.toList());
+            groupList = groupList.stream().filter(e -> Objects.equals(e.getSubjectId(), subjectId)).collect(Collectors.toList());
+        }
+        if (CollectionUtils.isEmpty(groupList)) {
+            return ReturnT.SUCCESS;
         }
         if (xxlJobParam.getStaffId() != null) {
             Long staffId = xxlJobParam.getStaffId();