im导入群聊

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/CustomerServiceBatchSendingServiceImpl.java

@@ -619,7 +619,7 @@ public class CustomerServiceBatchSendingServiceImpl extends ServiceImpl<Customer
                 .height(imageReq.getHeight())
                 .width(imageReq.getWidth())
                 .url(imgMessage)
-                .size(imageReq.getSize()))
+                .size(imageReq.getSize()).build())
                 .build();
     }
 
@@ -631,7 +631,7 @@ public class CustomerServiceBatchSendingServiceImpl extends ServiceImpl<Customer
 
         return TencentRequest.MessageBody.builder()
                 .msgType("TIMTextElem")
-                .msgContent(TencentRequest.TextMessageBody.builder().text(textMessage))
+                .msgContent(TencentRequest.TextMessageBody.builder().text(textMessage).build())
                 .build();
     }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -717,6 +717,8 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
                 } else if (i.getClassname().equals("RC:ImgMsg")) {
                     TencentRequest.MessageBody body1 = CustomerServiceBatchSendingServiceImpl.getTimImageElem(jsonObject.getString("imageUri"));
                     list.add(body1);
+                } else {
+                    return;
                 }
 
                /* body.setMsgType(i.getClassname());
@@ -738,7 +740,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
                 try {
                     imPluginContext.getPluginService().importPrivateMessage(privateImportMessage);
                 } catch (Exception e) {
-                    e.printStackTrace();
+                    log.error("导入私聊IM消息失败 msg:{}",list,e);
                 }
             } else if (type == 3) {
                 //群组会话
@@ -782,13 +784,15 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
                             item.setMsgContent(i.getContent());
                             item.setMsgType(i.getClassname());
                         });*/
+                JSONObject jsonObject = JSONObject.parseObject(i.getContent());
                 if (i.getClassname().equals("RC:TxtMsg")) {
-                    TencentRequest.MessageBody body1 = CustomerServiceBatchSendingServiceImpl.getTimTextElem(i.getContent());
+                    TencentRequest.MessageBody body1 = CustomerServiceBatchSendingServiceImpl.getTimTextElem(jsonObject.getString("content"));
                     bodyList.add(body1);
                 } else if (i.getClassname().equals("RC:ImgMsg")) {
-                    JSONObject jsonObject = JSONObject.parseObject(i.getContent());
-                    TencentRequest.MessageBody body1 = CustomerServiceBatchSendingServiceImpl.getTimImageElem(jsonObject.getJSONObject("user").getString("portraitUri"));
+                    TencentRequest.MessageBody body1 = CustomerServiceBatchSendingServiceImpl.getTimImageElem(jsonObject.getString("imageUri"));
                     bodyList.add(body1);
+                } else {
+                    return;
                 }
                 /*body.setMsgContent(i.getContent());
                 body.setMsgType(i.getClassname());*/
@@ -809,7 +813,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
                 try {
                     imPluginContext.getPluginService().importGroupMessage(groupImportMessage);
                 } catch (Exception e) {
-                    e.printStackTrace();
+                    log.error("导入群组IM消息失败 msg:{}",list,e);
                 }
             }
         });