xueyiming 5 kuukautta sitten
vanhempi
commit
79d412b241

+ 4 - 6
we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComHistoryDataJob.java

@@ -147,7 +147,7 @@ public class WeComHistoryDataJob {
             stringBuilder.append(sendDetail.getRemark());
             long count = sendCountList.get(0) + sendCountList.get(1) + sendCountList.get(2) + sendCountList.get(3);
             Long notSentCount = sendCountList.get(0);
-            if(notSentCount != 0){
+            if (notSentCount != 0) {
                 LarkRobotUtil.sendMessage("@薛一鸣 存在未发送记录,请检查");
             }
             stringBuilder.append("总发送数量:").append(count).append("   ");
@@ -364,12 +364,10 @@ public class WeComHistoryDataJob {
         example.createCriteria().andStaffIdEqualTo(staff.getId())
                 .andSendTimeBetween(new Date(startTime * 1000), new Date(endTime * 1000));
         List<MessageAttachment> messageAttachments = messageAttachmentMapper.selectByExample(example);
-        if (CollectionUtils.isEmpty(messageAttachments)) {
-            LarkRobotUtil.sendMessage("获取保底set失败");
-            return;
+        Set<Long> guaranteedSet = new HashSet<>();
+        if (!CollectionUtils.isEmpty(messageAttachments)) {
+            guaranteedSet = messageAttachments.stream().map(MessageAttachment::getMiniprogramVideoId).collect(Collectors.toSet());
         }
-        Set<Long> guaranteedSet = messageAttachments.stream()
-                .map(MessageAttachment::getMiniprogramVideoId).collect(Collectors.toSet());
         Long sendTime = externalUsers.stream()
                 .map(ExternalUser::getSendTime).filter(Objects::nonNull).findFirst().orElse(null);
         List<HistoryMessage> historyMessageList = new ArrayList<>();