1.更新IM

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/ImGroup.java

@@ -1,57 +1,39 @@
 package com.ym.mec.biz.dal.entity;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
 import com.ym.mec.common.entity.BaseEntity;
 import com.ym.mec.common.enums.BaseEnum;
-import io.swagger.annotations.ApiModelProperty;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 
-
 /**
  * 对应数据库表(im_group):
  */
 public class ImGroup extends BaseEntity {
 
 	/**  */
-    @TableId(value = "id_")
 	private String id;
 
-    @ApiModelProperty("学校ID")
-    @TableField(value = "school_id_")
     private Long schoolId;
 
 	/** 群名称 */
-    @TableField(value = "name_")
 	private String name;
-
+	
 	/** 群介绍 */
-    @TableField(value = "introduce_")
 	private String introduce;
-
+	
 	/** 群成员数 */
-    @TableField(value = "member_num_")
 	private Integer memberNum;
-
+	
 	/** 群备注 */
-    @TableField(value = "memo_")
 	private String memo;
-
+	
 	/** 群标签 */
-    @TableField(value = "tags_")
 	private String tags;
-
-    @TableField(value = "img_")
+	
 	private String img;
 
 	/** 乐团群 MUSIC，班级群 CLASS，训练营 TRAINING 学校SCHOOL*/
-    @TableField(value = "type_")
 	private String type;
 
-	@TableField(value = "import_flag_")
-	private String importFlag;
-
 	public enum GroupTypeEnum implements BaseEnum<String,GroupTypeEnum> {
 		NORMAL("NORMAL", "普通班级"), MIX("MIX", "合奏班级"), HIGH("HIGH", "基础技能班"),
 		VIP("VIP", "vip课"), DEMO("DEMO", "试听课"), PRACTICE("PRACTICE", "网管课"),
@@ -87,7 +69,6 @@ public class ImGroup extends BaseEntity {
 	}
 
 	//群类型
-    @TableField(value = "group_type_")
 	private GroupTypeEnum groupType;
 
 	public GroupTypeEnum getGroupType() {
@@ -99,69 +80,67 @@ public class ImGroup extends BaseEntity {
 	}
 
 	/**  */
-    @TableField(value = "create_time_")
 	private java.util.Date createTime;
-
+	
 	/**  */
-    @TableField(value = "update_time_")
 	private java.util.Date updateTime;
 
-	public Long getSchoolId() {
-		return schoolId;
-	}
+    public Long getSchoolId() {
+        return schoolId;
+    }
 
-	public void setSchoolId(Long schoolId) {
-		this.schoolId = schoolId;
-	}
+    public void setSchoolId(Long schoolId) {
+        this.schoolId = schoolId;
+    }
 
-	public void setId(String id){
+    public void setId(String id){
 		this.id = id;
 	}
-
+	
 	public String getId(){
 		return this.id;
 	}
-
+			
 	public void setName(String name){
 		this.name = name;
 	}
-
+	
 	public String getName(){
 		return this.name;
 	}
-
+			
 	public void setIntroduce(String introduce){
 		this.introduce = introduce;
 	}
-
+	
 	public String getIntroduce(){
 		return this.introduce;
 	}
-
+			
 	public void setMemberNum(Integer memberNum){
 		this.memberNum = memberNum;
 	}
-
+	
 	public Integer getMemberNum(){
 		return this.memberNum;
 	}
-
+			
 	public void setMemo(String memo){
 		this.memo = memo;
 	}
-
+	
 	public String getMemo(){
 		return this.memo;
 	}
-
+			
 	public void setTags(String tags){
 		this.tags = tags;
 	}
-
+	
 	public String getTags(){
 		return this.tags;
 	}
-
+			
 	public String getImg() {
 		return img;
 	}
@@ -181,27 +160,19 @@ public class ImGroup extends BaseEntity {
 	public void setCreateTime(java.util.Date createTime){
 		this.createTime = createTime;
 	}
-
+	
 	public java.util.Date getCreateTime(){
 		return this.createTime;
 	}
-
+			
 	public void setUpdateTime(java.util.Date updateTime){
 		this.updateTime = updateTime;
 	}
-
+	
 	public java.util.Date getUpdateTime(){
 		return this.updateTime;
 	}
-
-	public String getImportFlag() {
-		return importFlag;
-	}
-
-	public void setImportFlag(String importFlag) {
-		this.importFlag = importFlag;
-	}
-
+			
 	@Override
 	public String toString() {
 		return ToStringBuilder.reflectionToString(this);

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/ImGroupMember.java

@@ -1,10 +1,5 @@
 package com.ym.mec.biz.dal.entity;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 
 import com.ym.mec.common.entity.BaseEntity;
@@ -12,64 +7,153 @@ import com.ym.mec.common.entity.BaseEntity;
 /**
  * 对应数据库表(im_group_member):
  */
-@Data
 public class ImGroupMember extends BaseEntity {
 
 	/**  */
-    @TableId(value = "id_", type = IdType.AUTO)
 	private Long id;
 	
 	/**  */
-    @TableField(value = "im_group_id_")
 	private String imGroupId;
 	
 	/**  */
-    @TableField(value = "user_id_")
 	private Integer userId;
-
-    @TableField(value = "nickname_")
+	
 	private String nickname;
 
 	/** 群昵称 */
-    @TableField(exist = false)
 	private String groupNickname;
 	
 	/** 是否是管理员 */
-    @ApiModelProperty("是否是管理员")
-    @TableField(value = "is_admin_")
-	private Boolean isAdmin;
+	private boolean isAdmin;
 	
 	/** 群角色 */
-    @TableField(value = "role_type_")
 	private String roleType;
 
 
     /** 群角色 */
-    @TableField(value = "type_")
     private String type;
 
-    @TableField(exist = false)
 	private Integer memberRankSettingId;
 
-    @TableField(exist = false)
 	private String subjectName;
 
-    @TableField(exist = false)
 	private String subjectId;
-
-    /**
-     * 头像
-     */
-    @TableField(exist = false)
-    private String avatar;
-
-    /**  */
-    @TableField(value = "create_time_")
+	
+	/**  */
 	private java.util.Date createTime;
 	
 	/**  */
-    @TableField(value = "update_time_")
 	private java.util.Date updateTime;
 
 
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+	public String getSubjectId() {
+		return subjectId;
+	}
+
+	public void setSubjectId(String subjectId) {
+		this.subjectId = subjectId;
+	}
+
+	public Integer getMemberRankSettingId() {
+		return memberRankSettingId;
+	}
+
+	public void setMemberRankSettingId(Integer memberRankSettingId) {
+		this.memberRankSettingId = memberRankSettingId;
+	}
+
+	public String getSubjectName() {
+		return subjectName;
+	}
+
+	public void setSubjectName(String subjectName) {
+		this.subjectName = subjectName;
+	}
+
+	public void setId(Long id){
+		this.id = id;
+	}
+	
+	public Long getId(){
+		return this.id;
+	}
+			
+	public void setImGroupId(String imGroupId){
+		this.imGroupId = imGroupId;
+	}
+	
+	public String getImGroupId(){
+		return this.imGroupId;
+	}
+			
+	public void setUserId(Integer userId){
+		this.userId = userId;
+	}
+	
+	public Integer getUserId(){
+		return this.userId;
+	}
+			
+	public String getNickname() {
+		return nickname;
+	}
+
+	public void setNickname(String nickname) {
+		this.nickname = nickname;
+	}
+
+	public void setIsAdmin(boolean isAdmin){
+		this.isAdmin = isAdmin;
+	}
+	
+	public boolean getIsAdmin(){
+		return this.isAdmin;
+	}
+
+	public String getRoleType() {
+		return roleType;
+	}
+
+	public void setRoleType(String roleType) {
+		this.roleType = roleType;
+	}
+
+	public void setCreateTime(java.util.Date createTime){
+		this.createTime = createTime;
+	}
+	
+	public java.util.Date getCreateTime(){
+		return this.createTime;
+	}
+			
+	public void setUpdateTime(java.util.Date updateTime){
+		this.updateTime = updateTime;
+	}
+	
+	public java.util.Date getUpdateTime(){
+		return this.updateTime;
+	}
+
+	public String getGroupNickname() {
+		return groupNickname;
+	}
+
+	public void setGroupNickname(String groupNickname) {
+		this.groupNickname = groupNickname;
+	}
+
+	@Override
+	public String toString() {
+		return ToStringBuilder.reflectionToString(this);
+	}
+
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/ImGroupMemberPlus.java

@@ -0,0 +1,95 @@
+package com.ym.mec.biz.dal.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.ym.mec.common.entity.BaseEntity;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 对应数据库表(im_group_member):
+ */
+@Data
+public class ImGroupMemberPlus implements Serializable {
+
+    /**
+     *
+     */
+    @TableId(value = "id_", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     *
+     */
+    @TableField(value = "im_group_id_")
+    private String imGroupId;
+
+    /**
+     *
+     */
+    @TableField(value = "user_id_")
+    private Integer userId;
+
+    @TableField(value = "nickname_")
+    private String nickname;
+
+    /**
+     * 群昵称
+     */
+    @TableField(exist = false)
+    private String groupNickname;
+
+    /**
+     * 是否是管理员
+     */
+    @ApiModelProperty("是否是管理员")
+    @TableField(value = "is_admin_")
+    private Boolean isAdmin;
+
+    /**
+     * 群角色
+     */
+    @TableField(value = "role_type_")
+    private String roleType;
+
+
+    /**
+     * 群角色
+     */
+    @TableField(value = "type_")
+    private String type;
+
+    @TableField(exist = false)
+    private Integer memberRankSettingId;
+
+    @TableField(exist = false)
+    private String subjectName;
+
+    @TableField(exist = false)
+    private String subjectId;
+
+    /**
+     * 头像
+     */
+    @TableField(exist = false)
+    private String avatar;
+
+    /**
+     *
+     */
+    @TableField(value = "create_time_")
+    private Date createTime;
+
+    /**
+     *
+     */
+    @TableField(value = "update_time_")
+    private Date updateTime;
+
+    @TableField(value = "tenant_id_")
+    private Integer tenantId;
+}

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/ImGroupPlus.java

@@ -0,0 +1,139 @@
+package com.ym.mec.biz.dal.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.ym.mec.common.enums.BaseEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+
+import java.io.Serializable;
+
+
+/**
+ * 对应数据库表(im_group):
+ */
+@Data
+public class ImGroupPlus implements Serializable {
+
+    /**
+     *
+     */
+    @TableId(value = "id_")
+    private String id;
+
+    @ApiModelProperty("学校ID")
+    @TableField(value = "school_id_")
+    private Long schoolId;
+
+    /**
+     * 群名称
+     */
+    @TableField(value = "name_")
+    private String name;
+
+    /**
+     * 群介绍
+     */
+    @TableField(value = "introduce_")
+    private String introduce;
+
+    /**
+     * 群成员数
+     */
+    @TableField(value = "member_num_")
+    private Integer memberNum;
+
+    /**
+     * 群备注
+     */
+    @TableField(value = "memo_")
+    private String memo;
+
+    /**
+     * 群标签
+     */
+    @TableField(value = "tags_")
+    private String tags;
+
+    @TableField(value = "img_")
+    private String img;
+
+    /**
+     * 乐团群 MUSIC，班级群 CLASS，训练营 TRAINING 学校SCHOOL
+     */
+    @TableField(value = "type_")
+    private String type;
+
+    @TableField(value = "tenant_id_")
+    private Integer tenantId;
+
+
+    @TableField(value = "import_flag_")
+    private String importFlag;
+
+    public enum GroupTypeEnum implements BaseEnum<String, GroupTypeEnum> {
+        NORMAL("NORMAL", "普通班级"), MIX("MIX", "合奏班级"), HIGH("HIGH", "基础技能班"),
+        VIP("VIP", "vip课"), DEMO("DEMO", "试听课"), PRACTICE("PRACTICE", "网管课"),
+        SNAP("SNAP", "临时班级"), COMM("COMM", "对外课程"), HIGH_ONLINE("HIGH_ONLINE", "线上基础技能课"),
+        MUSIC_NETWORK("MUSIC_NETWORK", "乐团网管课"), PARENT_MEETING("PARENT_MEETING", "家长会"),
+        TRAINING("TRAINING", "训练营"), REPERTOIRE_PLAY("REPERTOIRE_PLAY", "曲目演奏课"), SCHOOL("SCHOOL", "学校衔接群"), LIVE(
+                "LIVE", "直播课");
+
+        private String code;
+
+        private String msg;
+
+        GroupTypeEnum(String code, String msg) {
+            this.code = code;
+            this.msg = msg;
+        }
+
+        public void setCode(String code) {
+            this.code = code;
+        }
+
+        public String getMsg() {
+            return msg;
+        }
+
+        public void setMsg(String msg) {
+            this.msg = msg;
+        }
+
+        @Override
+        public String getCode() {
+            return this.code;
+        }
+    }
+
+    //群类型
+    @TableField(value = "group_type_")
+    private GroupTypeEnum groupType;
+
+    public GroupTypeEnum getGroupType() {
+        return groupType;
+    }
+
+    public void setGroupType(GroupTypeEnum groupType) {
+        this.groupType = groupType;
+    }
+
+    /**
+     *
+     */
+    @TableField(value = "create_time_")
+    private java.util.Date createTime;
+
+    /**
+     *
+     */
+    @TableField(value = "update_time_")
+    private java.util.Date updateTime;
+
+    @Override
+    public String toString() {
+        return ToStringBuilder.reflectionToString(this);
+    }
+
+}

mec-biz/src/main/java/com/ym/mec/biz/dal/mapper/ImGroupMemberPlusMapper.java

@@ -1,6 +1,7 @@
 package com.ym.mec.biz.dal.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ym.mec.biz.dal.entity.ImGroupMemberPlus;
 import org.springframework.stereotype.Repository;
 import com.ym.mec.biz.dal.entity.ImGroupMember;
 
@@ -11,8 +12,8 @@ import java.util.List;
  * 2023-08-29 17:18:04
  */
 @Repository
-public interface ImGroupMemberPlusMapper extends BaseMapper<ImGroupMember> {
+public interface ImGroupMemberPlusMapper extends BaseMapper<ImGroupMemberPlus> {
 
 
-    void insertBatch(List<ImGroupMember> imGroupMemberEntity);
+    void insertBatch(List<ImGroupMemberPlus> imGroupMemberEntity);
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/mapper/ImGroupMemberPlusMapper.xml

@@ -2,14 +2,14 @@
 <!DOCTYPE  mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="com.ym.mec.biz.dal.mapper.ImGroupMemberPlusMapper">
     
-    <select id="selectPage" resultType="com.ym.mec.biz.dal.entity.ImGroupMember">
+    <select id="selectPage" resultType="com.ym.mec.biz.dal.entity.ImGroupMemberPlus">
 		SELECT         
         	t.*
 		FROM im_group_member t
 	</select>
 
 
-    <insert id="insertBatch" parameterType="com.ym.mec.biz.dal.entity.ImGroupMember" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
+    <insert id="insertBatch" parameterType="com.ym.mec.biz.dal.entity.ImGroupMemberPlus" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
         INSERT INTO im_group_member (im_group_id_,user_id_,nickname_,is_admin_,role_type_,create_time_,update_time_,tenant_id_,type_) VALUES
         <foreach collection="list" item="item" separator=",">
             (#{item.imGroupId},#{item.userId},#{item.nickname},#{item.isAdmin},#{item.roleType},NOW(),NOW(),#{item.tenantId},#{item.type})

mec-biz/src/main/java/com/ym/mec/biz/dal/mapper/ImGroupPlusMapper.java

@@ -1,6 +1,7 @@
 package com.ym.mec.biz.dal.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ym.mec.biz.dal.entity.ImGroupPlus;
 import org.springframework.stereotype.Repository;
 import com.ym.mec.biz.dal.entity.ImGroup;
 
@@ -9,7 +10,7 @@ import com.ym.mec.biz.dal.entity.ImGroup;
  * 2023-08-29 17:18:04
  */
 @Repository
-public interface ImGroupPlusMapper extends BaseMapper<ImGroup> {
+public interface ImGroupPlusMapper extends BaseMapper<ImGroupPlus> {
 
 	
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/mapper/ImGroupPlusMapper.xml

@@ -2,7 +2,7 @@
 <!DOCTYPE  mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="com.ym.mec.biz.dal.mapper.ImGroupPlusMapper">
     
-    <select id="selectPage" resultType="com.ym.mec.biz.dal.entity.ImGroup">
+    <select id="selectPage" resultType="com.ym.mec.biz.dal.entity.ImGroupPlus">
 		SELECT         
         	t.*
 		FROM im_group t

mec-biz/src/main/java/com/ym/mec/biz/service/ImGroupMemberPlusService.java

@@ -1,9 +1,8 @@
 package com.ym.mec.biz.service;
 
-import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.ym.mec.biz.dal.wrapper.ImGroupMemberWrapper;
 import com.ym.mec.biz.dal.entity.ImGroupMember;
+import com.ym.mec.biz.dal.entity.ImGroupMemberPlus;
 
 import java.util.List;
 
@@ -11,14 +10,14 @@ import java.util.List;
  * 群成员表
  * 2023-08-29 17:18:04
  */
-public interface ImGroupMemberPlusService extends IService<ImGroupMember>  {
+public interface ImGroupMemberPlusService extends IService<ImGroupMemberPlus>  {
 
 	/**
      * 查询详情
      * @param id 详情ID
      * @return ImGroupMember
      */
-	ImGroupMember detail(Long id);
+    ImGroupMemberPlus detail(Long id);
 
 
     /**
@@ -26,5 +25,5 @@ public interface ImGroupMemberPlusService extends IService<ImGroupMember>  {
      *
      * @param imGroupMemberEntity
      */
-    void insertBatch(List<ImGroupMember> imGroupMemberEntity);
+    void insertBatch(List<ImGroupMemberPlus> imGroupMemberEntity);
 }

mec-biz/src/main/java/com/ym/mec/biz/service/ImGroupPlusService.java

@@ -2,18 +2,19 @@ package com.ym.mec.biz.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ym.mec.biz.dal.entity.ImGroup;
+import com.ym.mec.biz.dal.entity.ImGroupPlus;
 
 /**
  * 即时通讯群组
  * 2023-08-29 17:18:04
  */
-public interface ImGroupPlusService extends IService<ImGroup>  {
+public interface ImGroupPlusService extends IService<ImGroupPlus>  {
 
 	/**
      * 查询详情
      * @param id 详情ID
      * @return ImGroup
      */
-	ImGroup detail(Long id);
+	ImGroupPlus detail(Long id);
      
 }

mec-biz/src/main/java/com/ym/mec/biz/service/im/impl/ImGroupCoreServiceImpl.java

@@ -8,8 +8,9 @@ import com.microsvc.toolkit.common.tools.ThreadPool;
 import com.microsvc.toolkit.middleware.im.ImPluginContext;
 import com.microsvc.toolkit.middleware.im.message.GroupMemberWrapper;
 import com.microsvc.toolkit.middleware.im.properties.ImConfigProperties;
-import com.ym.mec.biz.dal.entity.ImGroup;
 import com.ym.mec.biz.dal.entity.ImGroupMember;
+import com.ym.mec.biz.dal.entity.ImGroupMemberPlus;
+import com.ym.mec.biz.dal.entity.ImGroupPlus;
 import com.ym.mec.biz.dal.enums.EFriendRoleType;
 import com.ym.mec.biz.dal.wrapper.ImGroupMemberWrapper;
 import com.ym.mec.biz.dal.wrapper.ImGroupWrapper;
@@ -45,7 +46,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     @Autowired
     private ImConfigProperties imConfig;
     @Autowired
-    private ImGroupMemberPlusService imGroupMemberService;
+    private ImGroupMemberPlusService imGroupMemberPlusService;
 
     /**
      * IM 用户注册
@@ -145,7 +146,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
                 .type(Optional.ofNullable(imGroup.getType()).orElse("CLASS"))
                 .groupId(String.valueOf(id));
 
-        ImGroup group = JSON.parseObject(imGroup.jsonString(), ImGroup.class);
+        ImGroupPlus group = JSON.parseObject(imGroup.jsonString(), ImGroupPlus.class);
         group.setId(imGroup.getGroupId());
         // 保存群组信息
         imGroupService.saveOrUpdate(group);
@@ -157,7 +158,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
             groupMembers = Lists.newArrayList(userInfo);
 
             groupMembers.add(userInfo.imUserId(imUserId));
-            imGroupMemberService.insertBatch(getImGroupMemberEntity(groupMembers));
+            imGroupMemberPlusService.insertBatch(getImGroupMemberEntity(groupMembers));
 
             // 自动激活学生IM帐号
             registerUser(groupMembers);
@@ -174,12 +175,12 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
         return group.getId();
     }
 
-    private List<ImGroupMember> getImGroupMemberEntity(List<ImGroupMemberWrapper.ImGroupMember> groupMembers) {
+    private List<ImGroupMemberPlus> getImGroupMemberEntity(List<ImGroupMemberWrapper.ImGroupMember> groupMembers) {
         if (CollectionUtils.isEmpty(groupMembers)) {
             return new ArrayList<>();
         }
         return groupMembers.stream().map(o -> {
-            ImGroupMember imGroupMember = new ImGroupMember();
+            ImGroupMemberPlus imGroupMember = new ImGroupMemberPlus();
             imGroupMember.setImGroupId(o.getGroupId());
             imGroupMember.setUserId(o.getUserId().intValue());
             imGroupMember.setNickname(o.getNickname());
@@ -251,25 +252,25 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     public void groupDismiss(String groupId) throws Exception {
 
         // 判定登录用户是否为群主
-        ImGroup imGroup = imGroupService.lambdaQuery().eq(ImGroup::getId, groupId).last("LIMIT 1").one();
+        ImGroupPlus imGroup = imGroupService.lambdaQuery().eq(ImGroupPlus::getId, groupId).last("LIMIT 1").one();
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
 
 
         // 获取群成员
-        List<ImGroupMemberWrapper.ImGroupMember> groupMembers = imGroupMemberService.lambdaQuery()
-                .select(ImGroupMember::getUserId, ImGroupMember::getImGroupId, ImGroupMember::getRoleType)
-                .eq(ImGroupMember::getImGroupId, groupId)
+        List<ImGroupMemberWrapper.ImGroupMember> groupMembers = imGroupMemberPlusService.lambdaQuery()
+                .select(ImGroupMemberPlus::getUserId, ImGroupMemberPlus::getImGroupId, ImGroupMemberPlus::getRoleType)
+                .eq(ImGroupMemberPlus::getImGroupId, groupId)
                 .list().stream()
                 .map(x -> ImGroupMemberWrapper.ImGroupMember.builder().userId(x.getUserId().longValue()).groupId(x.getImGroupId()).clientType(x.getRoleType()).build())
                 .collect(Collectors.toList());
 
         // 删除群组
-        imGroupService.remove(Wrappers.<ImGroup>lambdaQuery().eq(ImGroup::getId, groupId));
+        imGroupService.remove(Wrappers.<ImGroupPlus>lambdaQuery().eq(ImGroupPlus::getId, groupId));
 
         // 删除群组成员
-        imGroupMemberService.remove(Wrappers.<ImGroupMember>lambdaQuery().eq(ImGroupMember::getImGroupId, groupId));
+        imGroupMemberPlusService.remove(Wrappers.<ImGroupMemberPlus>lambdaQuery().eq(ImGroupMemberPlus::getImGroupId, groupId));
 
         // 解散群
         imPluginContext.getPluginService().groupDismiss(imGroup.getId(), getImGroupMembers(groupMembers));
@@ -287,18 +288,19 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     public void groupQuit(GroupMemberWrapper.ImGroupMember imGroupMember, String groupId) throws Exception {
 
         // 判定登录用户是否为群主
-        ImGroup imGroup = imGroupService.lambdaQuery().eq(ImGroup::getId, groupId).last("LIMIT 1").one();
+        ImGroupPlus imGroup = imGroupService.lambdaQuery().eq(ImGroupPlus::getId, groupId).last("LIMIT 1").one();
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
 
         // 统计当前群成员用户数
-        long count = imGroupMemberService.count(Wrappers.<ImGroupMember>lambdaQuery().eq(ImGroupMember::getImGroupId, groupId));
+        long count = imGroupMemberPlusService.count(Wrappers.<ImGroupMemberPlus>lambdaQuery().eq(ImGroupMemberPlus::getImGroupId
+                , groupId));
 
         // 删除当前用户群成员身份
-        boolean remove = imGroupMemberService.remove(Wrappers.<ImGroupMember>lambdaQuery()
-                .eq(ImGroupMember::getImGroupId, groupId)
-                .eq(ImGroupMember::getUserId, imGroupMember.getUserId())
+        boolean remove = imGroupMemberPlusService.remove(Wrappers.<ImGroupMemberPlus>lambdaQuery()
+                .eq(ImGroupMemberPlus::getImGroupId, groupId)
+                .eq(ImGroupMemberPlus::getUserId, imGroupMember.getUserId())
 //                .eq(ImGroupMember::getRoleType, imGroupMember.getRoleType())
         );
         if (!remove) {
@@ -308,8 +310,8 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
 
         // 修改群组成员数
         imGroupService.lambdaUpdate()
-                .eq(ImGroup::getId, imGroup.getId())
-                .set(ImGroup::getMemberNum, count - 1)
+                .eq(ImGroupPlus::getId, imGroup.getId())
+                .set(ImGroupPlus::getMemberNum, count - 1)
                 .update();
 
         // 群主退出
@@ -333,7 +335,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
 
 
         // 判定登录用户是否为群主
-        ImGroup imGroup = imGroupService.lambdaQuery().eq(ImGroup::getId, groupId).last("LIMIT 1").one();
+        ImGroupPlus imGroup = imGroupService.lambdaQuery().eq(ImGroupPlus::getId, groupId).last("LIMIT 1").one();
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
@@ -347,9 +349,9 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
 
 
         // 删除当前用户群成员身份
-        boolean remove = imGroupMemberService.remove(Wrappers.<ImGroupMember>lambdaQuery()
-                .eq(ImGroupMember::getImGroupId, groupId)
-                .in(ImGroupMember::getUserId, userIds)
+        boolean remove = imGroupMemberPlusService.remove(Wrappers.<ImGroupMemberPlus>lambdaQuery()
+                .eq(ImGroupMemberPlus::getImGroupId, groupId)
+                .in(ImGroupMemberPlus::getUserId, userIds)
         );
         if (!remove) {
             // 用户主动退出群聊失败
@@ -357,12 +359,12 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
         }
 
         // 统计当前群成员用户数
-        long count = imGroupMemberService.count(Wrappers.<ImGroupMember>lambdaQuery().eq(ImGroupMember::getImGroupId, groupId));
+        long count = imGroupMemberPlusService.count(Wrappers.<ImGroupMemberPlus>lambdaQuery().eq(ImGroupMemberPlus::getImGroupId, groupId));
 
         // 修改群组成员数
         imGroupService.lambdaUpdate()
-                .eq(ImGroup::getId, imGroup.getId())
-                .set(ImGroup::getMemberNum, count)
+                .eq(ImGroupPlus::getId, imGroup.getId())
+                .set(ImGroupPlus::getMemberNum, count)
                 .update();
         imPluginContext.getPluginService().groupQuit(imGroup.getId(), imGroupMembers);
 
@@ -379,7 +381,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     @Override
     public void groupQuit(Long userId, String clientType, String imGroupId) throws Exception {
 
-        ImGroup imGroup = imGroupService.getById(imGroupId);
+        ImGroupPlus imGroup = imGroupService.getById(imGroupId);
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
@@ -413,9 +415,9 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
             item.id(IdWorker.getId()).imUserId(getImUserId(item.getUserId().toString(), item.getClientType())).setGroupId(imGroupId);
         }
 
-        imGroupMemberService.insertBatch(getImGroupMemberEntity(groupMembers));
+        imGroupMemberPlusService.insertBatch(getImGroupMemberEntity(groupMembers));
         // 判断群ID是否有效
-        ImGroup imGroup = imGroupService.lambdaQuery().eq(ImGroup::getId, imGroupId).last("LIMIT 1").one();
+        ImGroupPlus imGroup = imGroupService.lambdaQuery().eq(ImGroupPlus::getId, imGroupId).last("LIMIT 1").one();
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
@@ -446,7 +448,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     public void saveImGroupMemberList(Long imGroupId, List<ImGroupMemberWrapper.ImGroupMember> groupMembers) throws Exception {
 
         // 群组信息
-        ImGroup imGroup = imGroupService.getById(imGroupId);
+        ImGroupPlus imGroup = imGroupService.getById(imGroupId);
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
@@ -466,7 +468,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     public void groupMemberJoin(String imGroupId, List<ImGroupMemberWrapper.ImGroupMember> groupMembers) throws Exception {
 
         // 群组信息
-        ImGroup imGroup = imGroupService.lambdaQuery().eq(ImGroup::getId, imGroupId).last("LIMIT 1").one();
+        ImGroupPlus imGroup = imGroupService.lambdaQuery().eq(ImGroupPlus::getId, imGroupId).last("LIMIT 1").one();
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }
@@ -490,15 +492,15 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
      * @param groupId 群组ID
      * @param imGroup ImGroup
      */
-    private void updateGroupMemberNumber(String groupId, ImGroup imGroup) {
+    private void updateGroupMemberNumber(String groupId, ImGroupPlus imGroup) {
 
         // 统计当前群成员用户数
-        long count = imGroupMemberService.count(Wrappers.<ImGroupMember>lambdaQuery().eq(ImGroupMember::getImGroupId, groupId));
+        long count = imGroupMemberPlusService.count(Wrappers.<ImGroupMemberPlus>lambdaQuery().eq(ImGroupMemberPlus::getImGroupId, groupId));
 
         // 修改群组成员数
         imGroupService.lambdaUpdate()
-            .eq(ImGroup::getId, imGroup.getId())
-            .set(ImGroup::getMemberNum, count)
+            .eq(ImGroupPlus::getId, imGroup.getId())
+            .set(ImGroupPlus::getMemberNum, count)
             .update();
     }
 
@@ -514,7 +516,7 @@ public class ImGroupCoreServiceImpl implements ImGroupCoreService {
     public void groupJoin(Long userId, String clientType, String imGroupId) throws Exception {
 
         // 群组信息
-        ImGroup imGroup = imGroupService.getById(imGroupId);
+        ImGroupPlus imGroup = imGroupService.getById(imGroupId);
         if (Objects.isNull(imGroup)) {
             throw new BizException("群组不存在");
         }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImGroupMemberPlusServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ym.mec.biz.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ym.mec.biz.dal.entity.ImGroupMemberPlus;
 import com.ym.mec.biz.service.ImGroupMemberPlusService;
 import org.springframework.stereotype.Service;
 import lombok.extern.slf4j.Slf4j;
@@ -16,7 +17,7 @@ import java.util.List;
  */
 @Slf4j
 @Service
-public class ImGroupMemberPlusServiceImpl extends ServiceImpl<ImGroupMemberPlusMapper, ImGroupMember> implements ImGroupMemberPlusService {
+public class ImGroupMemberPlusServiceImpl extends ServiceImpl<ImGroupMemberPlusMapper, ImGroupMemberPlus> implements ImGroupMemberPlusService {
 
 	/**
      * 查询详情
@@ -24,14 +25,14 @@ public class ImGroupMemberPlusServiceImpl extends ServiceImpl<ImGroupMemberPlusM
      * @return ImGroupMember
      */
 	@Override
-    public ImGroupMember detail(Long id) {
+    public ImGroupMemberPlus detail(Long id) {
         
         return baseMapper.selectById(id);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
-    public void insertBatch(List<ImGroupMember> imGroupMemberEntity) {
+    public void insertBatch(List<ImGroupMemberPlus> imGroupMemberEntity) {
         baseMapper.insertBatch(imGroupMemberEntity);
     }
 

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImGroupPlusServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ym.mec.biz.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ym.mec.biz.dal.entity.ImGroupPlus;
 import com.ym.mec.biz.service.ImGroupPlusService;
 import org.springframework.stereotype.Service;
 import lombok.extern.slf4j.Slf4j;
@@ -13,7 +14,7 @@ import com.ym.mec.biz.dal.mapper.ImGroupPlusMapper;
  */
 @Slf4j
 @Service
-public class ImGroupPlusServiceImpl extends ServiceImpl<ImGroupPlusMapper, ImGroup> implements ImGroupPlusService {
+public class ImGroupPlusServiceImpl extends ServiceImpl<ImGroupPlusMapper, ImGroupPlus> implements ImGroupPlusService {
 
 	/**
      * 查询详情
@@ -21,7 +22,7 @@ public class ImGroupPlusServiceImpl extends ServiceImpl<ImGroupPlusMapper, ImGro
      * @return ImGroup
      */
 	@Override
-    public ImGroup detail(Long id) {
+    public ImGroupPlus detail(Long id) {
         
         return baseMapper.selectById(id);
     }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImGroupServiceImpl.java

@@ -268,7 +268,7 @@ public class ImGroupServiceImpl extends BaseServiceImpl<String, ImGroup> impleme
                     .groupId(groupMember.getImGroupId())
                     .userId(groupMember.getUserId().longValue())
                     .clientType(sysUserType.name())
-                    .avatar(groupMember.getAvatar())
+//                    .avatar(groupMember.getAvatar())
                     .nickname(groupMember.getNickname())
                     .isAdmin(groupMember.getIsAdmin())
                     .imUserId(getImUserId(groupMember.getUserId().toString(), sysUserType.name()))