增加附件消息关系表

common-module/src/main/java/com/tzld/piaoquan/growth/common/service/Impl/MessageAttachmentServiceImpl.java

@@ -103,8 +103,7 @@ public class MessageAttachmentServiceImpl implements MessageAttachmentService {
             }
             messageAttachmentIds.add(messageAttachment.getId());
         }
-
-        return null;
+        return messageAttachmentIds;
     }
 
 

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

@@ -493,13 +493,18 @@ public class WeComHistoryDataJob {
         }
         for (Long attachmentId : attachmentIds) {
             for (Long sendMsgResultId : sendMsgResultIds) {
-                try {
-                    AttachmentWithMsgResult attachmentWithMsgResult = new AttachmentWithMsgResult();
-                    attachmentWithMsgResult.setAttachmentId(attachmentId);
-                    attachmentWithMsgResult.setMsgResultId(sendMsgResultId);
-                    attachmentWithMsgResultMapper.insertSelective(attachmentWithMsgResult);
-                } catch (Exception e) {
-                    log.error("insert error", e);
+                AttachmentWithMsgResultExample example = new AttachmentWithMsgResultExample();
+                example.createCriteria().andAttachmentIdEqualTo(attachmentId).andMsgResultIdEqualTo(sendMsgResultId);
+                long l = attachmentWithMsgResultMapper.countByExample(example);
+                if (l == 0) {
+                    try {
+                        AttachmentWithMsgResult attachmentWithMsgResult = new AttachmentWithMsgResult();
+                        attachmentWithMsgResult.setAttachmentId(attachmentId);
+                        attachmentWithMsgResult.setMsgResultId(sendMsgResultId);
+                        attachmentWithMsgResultMapper.insertSelective(attachmentWithMsgResult);
+                    } catch (Exception e) {
+                        log.error("insert error", e);
+                    }
                 }
             }
         }