|
@@ -146,6 +146,10 @@ 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) {
|
|
|
+ LarkRobotUtil.sendMessage("@薛一鸣 存在未发送记录,请检查");
|
|
|
+ }
|
|
|
stringBuilder.append("总发送数量:").append(count).append(" ");
|
|
|
stringBuilder.append("未发送数量:").append(sendCountList.get(0)).append(" ");
|
|
|
stringBuilder.append("已发送数量:").append(sendCountList.get(1)).append(" ");
|
|
@@ -360,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<>();
|