修复下发群消息给群成员失败的问题

core/src/main/java/com/wecloud/im/service/impl/ImConversationServiceImpl.java

@@ -1435,7 +1435,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
     @Override
     @Override
     public void sendMsgToMembers(ImConversation conversation, List<ImConversationMembers> membersList,
     public void sendMsgToMembers(ImConversation conversation, List<ImConversationMembers> membersList,
                                  ImClient sender, ImMessage message, Object content) {
                                  ImClient sender, ImMessage message, Object content) {
-        Long appId = conversation.getId();
+        Long appId = conversation.getFkAppid();
 
 
         List<Long> receiverClientIds = membersList.stream().map(ImConversationMembers::getFkClientId).collect(Collectors.toList());
         List<Long> receiverClientIds = membersList.stream().map(ImConversationMembers::getFkClientId).collect(Collectors.toList());
         List<ImClient> clientReceivers = imClientService.list(Wrappers.<ImClient>lambdaQuery().eq(ImClient::getFkAppid, appId).in(ImClient::getId, receiverClientIds));
         List<ImClient> clientReceivers = imClientService.list(Wrappers.<ImClient>lambdaQuery().eq(ImClient::getFkAppid, appId).in(ImClient::getId, receiverClientIds));

core/src/main/java/com/wecloud/im/service/impl/ImGroupServiceImpl.java

@@ -13,6 +13,7 @@ import java.util.Map;
 import java.util.stream.Collectors;
 import java.util.stream.Collectors;
 
 
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -167,6 +168,7 @@ public class ImGroupServiceImpl implements ImGroupService {
 
 
     }
     }
 
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     @Override
     public Integer joinGroup(String inviterUserId, String groupId, List<String> memberClientIds) {
     public Integer joinGroup(String inviterUserId, String groupId, List<String> memberClientIds) {
         Long appId = SecurityUtils.getCurrentAppId();
         Long appId = SecurityUtils.getCurrentAppId();