瀏覽代碼

Merge branch 'dev-xym-fix1' of Server/growth-manager into master

xueyiming 3 月之前
父節點
當前提交
cb172cf285
共有 1 個文件被更改,包括 11 次插入7 次删除
  1. 11 7
      api-module/src/main/java/com/tzld/piaoquan/api/mq/MessageCallbackCustomer.java

+ 11 - 7
api-module/src/main/java/com/tzld/piaoquan/api/mq/MessageCallbackCustomer.java

@@ -42,15 +42,19 @@ public class MessageCallbackCustomer implements MessageListener {
         pushMessageCallback.setOpenId(param.getOpenId());
         pushMessageCallback.setCreateTime(new Date());
         List<PushMessageCallback> insertList = new ArrayList<>();
-        for (ReplyInfo replyInfo : param.getReplyInfo()) {
-            PushMessageCallback insertPushMessageCallback = new PushMessageCallback();
-            BeanUtils.copyProperties(pushMessageCallback, insertPushMessageCallback);
-            insertPushMessageCallback.setMsgType(replyInfo.getMsgType());
-            insertPushMessageCallback.setVideoId(replyInfo.getMiniVideoId());
-            insertList.add(insertPushMessageCallback);
+        if (!CollectionUtils.isEmpty(param.getReplyInfo())) {
+            for (ReplyInfo replyInfo : param.getReplyInfo()) {
+                PushMessageCallback insertPushMessageCallback = new PushMessageCallback();
+                BeanUtils.copyProperties(pushMessageCallback, insertPushMessageCallback);
+                insertPushMessageCallback.setMsgType(replyInfo.getMsgType());
+                insertPushMessageCallback.setVideoId(replyInfo.getMiniVideoId());
+                insertList.add(insertPushMessageCallback);
+            }
         }
         try {
-            pushMessageCallbackMapper.insertList(insertList);
+            if(!CollectionUtils.isEmpty(insertList)){
+                pushMessageCallbackMapper.insertList(insertList);
+            }
         } catch (Exception e) {
             log.error("PushMessageCallback newPushMessageCallbackMapper insert pushMessageCallback={}, error={}", pushMessageCallback, e.getMessage());
             return Action.ReconsumeLater;