rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudGroupServiceImpl.java

@@ -12,6 +12,7 @@
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGroup;

import com.yeshi.fanli.exception.user.cloud.UserCloudGroupException;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudGroupService;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;





@@ -49,6 +50,11 @@
      for (UserCloudGroup userCloudGroup: list) {

         if (groupId.equals(userCloudGroup.getGroupId())) {

            exist = true;

            // 群名为空

            if (StringUtil.isNullOrEmpty(groupName)) {

               return;

            }

				
            // 群名字变化

            if (!groupName.equals(userCloudGroup.getGroupName())) {

               UserCloudGroup update = new UserCloudGroup();

@@ -62,6 +68,11 @@
      

      if (exist) 

         return;

		
      // 群名为空

      if (StringUtil.isNullOrEmpty(groupName)) {

         groupName = "本群未命名名称";

      }

      

      UserCloudGroup cloudGroup = new UserCloudGroup();

      cloudGroup.setUid(uid);

@@ -103,6 +114,17 @@
      userCloudGroupMapper.updateByPrimaryKeySelective(update);

   }

   

   @Override

   public void deleteGroup(long uid, long id) throws UserCloudGroupException{

      UserCloudGroup cloudGroup = userCloudGroupMapper.selectByPrimaryKey(id);

      if (cloudGroup == null || cloudGroup.getUid() != uid)

         throw new UserCloudGroupException(1, "该记录已不存在");

		
      if (cloudGroup.getUid() != uid) {

         throw new UserCloudGroupException(1, "该群已不存在");

      }

      userCloudGroupMapper.deleteByPrimaryKey(id);

   }

   

   @Override

   public void deleteGroupByUid(Long uid){