瀏覽代碼

修改历史数据获取

xueyiming 6 月之前
父節點
當前提交
76ec0400e0
共有 1 個文件被更改,包括 6 次插入3 次删除
  1. 6 3
      we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComHistoryDataJob1.java

+ 6 - 3
we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComHistoryDataJob1.java

@@ -112,7 +112,10 @@ public class WeComHistoryDataJob1 {
                     JSONObject groupMsg = groupMsgList.getJSONObject(i);
                     JSONArray attachments = groupMsg.getJSONArray("attachments");
                     String msgId = groupMsg.getString("msgid");
-                    Long createTime = groupMsg.getLong("create_time") * 1000;
+                    Long createTime = null;
+                    if (groupMsg.getLong("create_time") != null) {
+                        createTime = groupMsg.getLong("create_time") * 1000;
+                    }
                     if (CollectionUtils.isEmpty(attachments)) {
                         continue;
                     }
@@ -158,7 +161,7 @@ public class WeComHistoryDataJob1 {
                             continue;
                         }
                         insertHistoryMessageList(staffList.get(0), externalUsers, miniprogramRecordList, createTime);
-//                        messageAttachmentService.addMiniProgram(messageAttachmentList);
+                        messageAttachmentService.addMiniProgram(messageAttachmentList);
                     }
                 }
                 String nextCursor = jsonObject.getString("next_cursor");
@@ -192,7 +195,7 @@ public class WeComHistoryDataJob1 {
                 ExternalUser externalUser = new ExternalUser();
                 externalUser.setExternalUserId(send.getString("external_userid"));
                 externalUser.setStatus(send.getInteger("status"));
-                if(send.getLong("send_time") != null){
+                if (send.getLong("send_time") != null) {
                     externalUser.setSendTime(send.getLong("send_time") * 1000);
                 }
                 resList.add(externalUser);