浏览代码

增加发送结果表

xueyiming 3 月之前
父节点
当前提交
7bc2064c9a
共有 1 个文件被更改,包括 28 次插入27 次删除
  1. 28 27
      offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComHistoryDataJob.java

+ 28 - 27
offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComHistoryDataJob.java

@@ -197,33 +197,32 @@ public class WeComHistoryDataJob {
                     if (groupMsg.getLong("create_time") != null) {
                         createTime = groupMsg.getLong("create_time") * 1000;
                     }
-                    if (CollectionUtils.isEmpty(attachments)) {
-                        continue;
-                    }
                     List<MiniprogramRecord> miniprogramRecordList = new ArrayList<>();
                     List<MessageAttachment> messageAttachmentList = new ArrayList<>();
-                    for (int j = 0; j < attachments.size(); j++) {
-                        JSONObject miniprogram = attachments.getJSONObject(j).getJSONObject("miniprogram");
-                        if (miniprogram == null) {
-                            continue;
+                    if (!CollectionUtils.isEmpty(attachments)) {
+                        for (int j = 0; j < attachments.size(); j++) {
+                            JSONObject miniprogram = attachments.getJSONObject(j).getJSONObject("miniprogram");
+                            if (miniprogram == null) {
+                                continue;
+                            }
+                            MiniprogramRecord miniprogramRecord = new MiniprogramRecord();
+                            MessageAttachment messageAttachment = new MessageAttachment();
+                            String title = miniprogram.getString("title");
+                            String appid = miniprogram.getString("appid");
+                            String page = miniprogram.getString("page");
+                            Long videoId = MessageUtil.getVideoId(page);
+
+                            miniprogramRecord.setVideoId(videoId);
+                            miniprogramRecord.setAttachmentIdx(j + 1);
+                            miniprogramRecordList.add(miniprogramRecord);
+
+                            messageAttachment.setAppid(appid);
+                            messageAttachment.setPage(page);
+                            messageAttachment.setTitle(title);
+                            messageAttachment.setMiniprogramVideoId(videoId);
+                            messageAttachment.setType(MessageAttachmentTypeEnum.MINI_PROGRAM.getType());
+                            messageAttachmentList.add(messageAttachment);
                         }
-                        MiniprogramRecord miniprogramRecord = new MiniprogramRecord();
-                        MessageAttachment messageAttachment = new MessageAttachment();
-                        String title = miniprogram.getString("title");
-                        String appid = miniprogram.getString("appid");
-                        String page = miniprogram.getString("page");
-                        Long videoId = MessageUtil.getVideoId(page);
-
-                        miniprogramRecord.setVideoId(videoId);
-                        miniprogramRecord.setAttachmentIdx(j + 1);
-                        miniprogramRecordList.add(miniprogramRecord);
-
-                        messageAttachment.setAppid(appid);
-                        messageAttachment.setPage(page);
-                        messageAttachment.setTitle(title);
-                        messageAttachment.setMiniprogramVideoId(videoId);
-                        messageAttachment.setType(MessageAttachmentTypeEnum.MINI_PROGRAM.getType());
-                        messageAttachmentList.add(messageAttachment);
                     }
                     List<String> carrierIdList = selectGroupMsgTask(msgId, corpId);
                     if (CollectionUtils.isEmpty(carrierIdList)) {
@@ -247,10 +246,12 @@ public class WeComHistoryDataJob {
                         if (CollectionUtils.isEmpty(externalUsers)) {
                             continue;
                         }
-                        for (MessageAttachment messageAttachment : messageAttachmentList) {
-                            messageAttachment.setStaffId(staffList.get(0).getId());
+                        if (!CollectionUtils.isEmpty(messageAttachmentList)) {
+                            for (MessageAttachment messageAttachment : messageAttachmentList) {
+                                messageAttachment.setStaffId(staffList.get(0).getId());
+                            }
+                            messageAttachmentService.addMiniProgram(messageAttachmentList, createTime);
                         }
-                        messageAttachmentService.addMiniProgram(messageAttachmentList, createTime);
                         insertHistoryMessageList(msgId, staffList.get(0), externalUsers, miniprogramRecordList, createTime, corpId, startTime, endTime);
                     }
                 }