101 changed files with 317 additions and 471 deletions
@ -1,4 +1,4 @@ |
|||
package com.lx.common.contant; |
|||
package com.bx.common.contant; |
|||
|
|||
|
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.contant; |
|||
package com.bx.common.contant; |
|||
|
|||
public class RedisKey { |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.enums; |
|||
package com.bx.common.enums; |
|||
|
|||
public enum FileTypeEnum { |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.enums; |
|||
package com.bx.common.enums; |
|||
|
|||
|
|||
public enum MessageStatusEnum { |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.enums; |
|||
package com.bx.common.enums; |
|||
|
|||
|
|||
public enum MessageTypeEnum { |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.enums; |
|||
package com.bx.common.enums; |
|||
|
|||
/** |
|||
* 响应码枚举 |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.enums; |
|||
package com.bx.common.enums; |
|||
|
|||
public enum WSCmdEnum { |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.model.im; |
|||
package com.bx.common.model.im; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.model.im; |
|||
package com.bx.common.model.im; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.model.im; |
|||
package com.bx.common.model.im; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.model.im; |
|||
package com.bx.common.model.im; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.model.im; |
|||
package com.bx.common.model.im; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.result; |
|||
package com.bx.common.result; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.common.result; |
|||
package com.bx.common.result; |
|||
|
|||
|
|||
import com.lx.common.enums.ResultCode; |
|||
import com.bx.common.enums.ResultCode; |
|||
|
|||
import java.util.concurrent.ExecutorService; |
|||
import java.util.concurrent.Executors; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.util; |
|||
package com.bx.common.util; |
|||
|
|||
import org.springframework.beans.BeanWrapper; |
|||
import org.springframework.beans.BeanWrapperImpl; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.util; |
|||
package com.bx.common.util; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.common.util; |
|||
package com.bx.common.util; |
|||
|
|||
import org.springframework.beans.BeansException; |
|||
import org.springframework.context.ApplicationContext; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.config; |
|||
package com.bx.implatform.config; |
|||
|
|||
import org.springframework.boot.web.servlet.FilterRegistrationBean; |
|||
import org.springframework.context.annotation.Bean; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.config; |
|||
package com.bx.implatform.config; |
|||
|
|||
import io.minio.MinioClient; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.config; |
|||
package com.bx.implatform.config; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonAutoDetect; |
|||
import com.fasterxml.jackson.annotation.JsonTypeInfo; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.config; |
|||
package com.bx.implatform.config; |
|||
|
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.context.annotation.Bean; |
|||
@ -1,12 +1,12 @@ |
|||
package com.lx.implatform.config; |
|||
package com.bx.implatform.config; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.UserSession; |
|||
import com.fasterxml.jackson.databind.ObjectMapper; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.beans.factory.annotation.Qualifier; |
|||
@ -1,9 +1,9 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.implatform.service.thirdparty.FileService; |
|||
import com.lx.implatform.vo.UploadImageVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.implatform.vo.UploadImageVO; |
|||
import com.bx.implatform.service.thirdparty.FileService; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
@ -1,13 +1,12 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.lx.implatform.service.IFriendService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.vo.FriendVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.implatform.vo.FriendVO; |
|||
import com.bx.implatform.entity.Friend; |
|||
import com.bx.implatform.service.IFriendService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,12 +1,10 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.implatform.service.IGroupMemberService; |
|||
import com.lx.implatform.service.IGroupMessageService; |
|||
import com.lx.implatform.vo.GroupMessageVO; |
|||
import com.lx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.implatform.vo.GroupMessageVO; |
|||
import com.bx.implatform.service.IGroupMessageService; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.implatform.service.IPrivateMessageService; |
|||
import com.lx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.implatform.service.IPrivateMessageService; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.vo.RegisterVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.implatform.vo.RegisterVO; |
|||
import com.bx.implatform.service.IUserService; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,14 +1,14 @@ |
|||
package com.lx.implatform.controller; |
|||
package com.bx.implatform.controller; |
|||
|
|||
|
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.lx.implatform.vo.UserVO; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.vo.UserVO; |
|||
import com.bx.implatform.entity.User; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import com.bx.implatform.session.UserSession; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.entity; |
|||
package com.bx.implatform.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.entity; |
|||
package com.bx.implatform.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.entity; |
|||
package com.bx.implatform.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
@ -1,6 +1,6 @@ |
|||
package com.lx.implatform.exception; |
|||
package com.bx.implatform.exception; |
|||
|
|||
import com.lx.common.enums.ResultCode; |
|||
import com.bx.common.enums.ResultCode; |
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
@ -1,9 +1,9 @@ |
|||
package com.lx.implatform.exception; |
|||
package com.bx.implatform.exception; |
|||
|
|||
import cn.hutool.json.JSONException; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.result.Result; |
|||
import com.lx.common.result.ResultUtils; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.result.Result; |
|||
import com.bx.common.result.ResultUtils; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.http.HttpStatus; |
|||
import org.springframework.http.converter.HttpMessageNotReadableException; |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.bx.implatform.entity.Friend; |
|||
|
|||
/** |
|||
* <p> |
|||
@ -1,6 +1,6 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.lx.implatform.entity.Group; |
|||
import com.bx.implatform.entity.Group; |
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
|
|||
/** |
|||
@ -1,6 +1,6 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
|
|||
/** |
|||
@ -1,6 +1,6 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.lx.implatform.entity.GroupMessage; |
|||
import com.bx.implatform.entity.GroupMessage; |
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
|
|||
/** |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import com.lx.implatform.entity.PrivateMessage; |
|||
import com.bx.implatform.entity.PrivateMessage; |
|||
|
|||
/** |
|||
* <p> |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.mapper; |
|||
package com.bx.implatform.mapper; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import com.lx.implatform.entity.User; |
|||
import com.bx.implatform.entity.User; |
|||
|
|||
/** |
|||
* <p> |
|||
@ -1,8 +1,8 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.lx.implatform.vo.FriendVO; |
|||
import com.bx.implatform.vo.FriendVO; |
|||
import com.bx.implatform.entity.Friend; |
|||
|
|||
import java.util.List; |
|||
|
|||
@ -1,9 +1,8 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
|
|||
import java.util.Collection; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
@ -1,9 +1,8 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.lx.implatform.entity.GroupMessage; |
|||
import com.bx.implatform.vo.GroupMessageVO; |
|||
import com.bx.implatform.entity.GroupMessage; |
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
import com.lx.implatform.vo.GroupMessageVO; |
|||
import com.lx.implatform.vo.PrivateMessageVO; |
|||
|
|||
|
|||
public interface IGroupMessageService extends IService<GroupMessage> { |
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.lx.implatform.entity.Group; |
|||
import com.bx.implatform.vo.GroupInviteVO; |
|||
import com.bx.implatform.vo.GroupMemberVO; |
|||
import com.bx.implatform.vo.GroupVO; |
|||
import com.bx.implatform.entity.Group; |
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
import com.lx.implatform.vo.GroupInviteVO; |
|||
import com.lx.implatform.vo.GroupMemberVO; |
|||
import com.lx.implatform.vo.GroupVO; |
|||
|
|||
import java.util.List; |
|||
|
|||
@ -1,8 +1,8 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
import com.lx.implatform.entity.PrivateMessage; |
|||
import com.lx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.implatform.entity.PrivateMessage; |
|||
|
|||
|
|||
public interface IPrivateMessageService extends IService<PrivateMessage> { |
|||
@ -1,9 +1,9 @@ |
|||
package com.lx.implatform.service; |
|||
package com.bx.implatform.service; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.vo.RegisterVO; |
|||
import com.lx.implatform.vo.UserVO; |
|||
import com.bx.implatform.vo.RegisterVO; |
|||
import com.bx.implatform.vo.UserVO; |
|||
import com.bx.implatform.entity.User; |
|||
|
|||
import java.util.List; |
|||
|
|||
@ -1,18 +1,18 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.mapper.FriendMapper; |
|||
import com.lx.implatform.service.IFriendService; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.lx.implatform.vo.FriendVO; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.vo.FriendVO; |
|||
import com.bx.implatform.entity.Friend; |
|||
import com.bx.implatform.entity.User; |
|||
import com.bx.implatform.mapper.FriendMapper; |
|||
import com.bx.implatform.service.IFriendService; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import com.bx.implatform.session.UserSession; |
|||
import org.springframework.aop.framework.AopContext; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.cache.annotation.CacheConfig; |
|||
@ -1,11 +1,11 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.lx.implatform.mapper.GroupMemberMapper; |
|||
import com.lx.implatform.service.IGroupMemberService; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.mapper.GroupMemberMapper; |
|||
import com.bx.implatform.service.IGroupMemberService; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.cache.annotation.CacheConfig; |
|||
import org.springframework.cache.annotation.CacheEvict; |
|||
@ -1,22 +1,21 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.model.im.GroupMessageInfo; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.Group; |
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.lx.implatform.entity.GroupMessage; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.mapper.GroupMessageMapper; |
|||
import com.lx.implatform.service.IGroupMemberService; |
|||
import com.lx.implatform.service.IGroupMessageService; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.model.im.GroupMessageInfo; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.vo.GroupMessageVO; |
|||
import com.bx.implatform.entity.Group; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.entity.GroupMessage; |
|||
import com.bx.implatform.mapper.GroupMessageMapper; |
|||
import com.bx.implatform.service.IGroupMemberService; |
|||
import com.bx.implatform.service.IGroupMessageService; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.lx.implatform.service.IGroupService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.vo.GroupMessageVO; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import com.bx.implatform.service.IGroupService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.stereotype.Service; |
|||
@ -1,26 +1,26 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.lx.common.contant.Constant; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.lx.implatform.entity.Group; |
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.mapper.GroupMapper; |
|||
import com.lx.implatform.service.IFriendService; |
|||
import com.lx.implatform.service.IGroupMemberService; |
|||
import com.lx.implatform.service.IGroupService; |
|||
import com.bx.common.contant.Constant; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.vo.GroupInviteVO; |
|||
import com.bx.implatform.vo.GroupMemberVO; |
|||
import com.bx.implatform.vo.GroupVO; |
|||
import com.bx.implatform.entity.Friend; |
|||
import com.bx.implatform.entity.Group; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.entity.User; |
|||
import com.bx.implatform.mapper.GroupMapper; |
|||
import com.bx.implatform.service.IFriendService; |
|||
import com.bx.implatform.service.IGroupMemberService; |
|||
import com.bx.implatform.service.IGroupService; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.lx.implatform.vo.GroupInviteVO; |
|||
import com.lx.implatform.vo.GroupMemberVO; |
|||
import com.lx.implatform.vo.GroupVO; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import com.bx.implatform.session.UserSession; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.cache.annotation.CacheConfig; |
|||
@ -1,20 +1,19 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.MessageStatusEnum; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.model.im.PrivateMessageInfo; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.PrivateMessage; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.mapper.PrivateMessageMapper; |
|||
import com.lx.implatform.service.IFriendService; |
|||
import com.lx.implatform.service.IPrivateMessageService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.vo.PrivateMessageVO; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.MessageStatusEnum; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.model.im.PrivateMessageInfo; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.service.IPrivateMessageService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import com.bx.implatform.vo.PrivateMessageVO; |
|||
import com.bx.implatform.entity.PrivateMessage; |
|||
import com.bx.implatform.mapper.PrivateMessageMapper; |
|||
import com.bx.implatform.service.IFriendService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.stereotype.Service; |
|||
@ -1,11 +1,11 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.entity.User; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.UserSession; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.security.core.GrantedAuthority; |
|||
import org.springframework.security.core.authority.SimpleGrantedAuthority; |
|||
@ -1,23 +1,22 @@ |
|||
package com.lx.implatform.service.impl; |
|||
package com.bx.implatform.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.common.util.BeanUtils; |
|||
import com.lx.implatform.entity.Friend; |
|||
import com.lx.implatform.entity.GroupMember; |
|||
import com.lx.implatform.entity.User; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.mapper.UserMapper; |
|||
import com.lx.implatform.service.IFriendService; |
|||
import com.lx.implatform.service.IGroupMemberService; |
|||
import com.lx.implatform.service.IUserService; |
|||
import com.lx.implatform.session.SessionContext; |
|||
import com.lx.implatform.session.UserSession; |
|||
import com.lx.implatform.vo.RegisterVO; |
|||
import com.lx.implatform.vo.UserVO; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.common.util.BeanUtils; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.service.IUserService; |
|||
import com.bx.implatform.session.SessionContext; |
|||
import com.bx.implatform.session.UserSession; |
|||
import com.bx.implatform.vo.RegisterVO; |
|||
import com.bx.implatform.vo.UserVO; |
|||
import com.bx.implatform.entity.Friend; |
|||
import com.bx.implatform.entity.GroupMember; |
|||
import com.bx.implatform.entity.User; |
|||
import com.bx.implatform.mapper.UserMapper; |
|||
import com.bx.implatform.service.IFriendService; |
|||
import com.bx.implatform.service.IGroupMemberService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.security.crypto.password.PasswordEncoder; |
|||
@ -1,13 +1,13 @@ |
|||
package com.lx.implatform.service.thirdparty; |
|||
package com.bx.implatform.service.thirdparty; |
|||
|
|||
import com.lx.common.contant.Constant; |
|||
import com.lx.common.enums.FileTypeEnum; |
|||
import com.lx.common.enums.ResultCode; |
|||
import com.lx.implatform.exception.GlobalException; |
|||
import com.lx.implatform.util.FileUtil; |
|||
import com.lx.implatform.util.ImageUtil; |
|||
import com.lx.implatform.util.MinioUtil; |
|||
import com.lx.implatform.vo.UploadImageVO; |
|||
import com.bx.common.contant.Constant; |
|||
import com.bx.common.enums.FileTypeEnum; |
|||
import com.bx.common.enums.ResultCode; |
|||
import com.bx.implatform.exception.GlobalException; |
|||
import com.bx.implatform.vo.UploadImageVO; |
|||
import com.bx.implatform.util.FileUtil; |
|||
import com.bx.implatform.util.ImageUtil; |
|||
import com.bx.implatform.util.MinioUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.session; |
|||
package com.bx.implatform.session; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import org.springframework.security.core.context.SecurityContextHolder; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.session; |
|||
package com.bx.implatform.session; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.task; |
|||
package com.bx.implatform.task; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.MessageStatusEnum; |
|||
import com.lx.implatform.entity.PrivateMessage; |
|||
import com.lx.implatform.service.IPrivateMessageService; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.MessageStatusEnum; |
|||
import com.bx.implatform.entity.PrivateMessage; |
|||
import com.bx.implatform.service.IPrivateMessageService; |
|||
import lombok.SneakyThrows; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.util; |
|||
package com.bx.implatform.util; |
|||
|
|||
public class FileUtil { |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.util; |
|||
package com.bx.implatform.util; |
|||
|
|||
|
|||
import lombok.extern.slf4j.Slf4j; |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.util; |
|||
package com.bx.implatform.util; |
|||
|
|||
|
|||
import com.lx.common.util.DateTimeUtils; |
|||
import com.bx.common.util.DateTimeUtils; |
|||
import io.minio.*; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.vo; |
|||
package com.bx.implatform.vo; |
|||
|
|||
|
|||
import io.swagger.annotations.ApiModel; |
|||
@ -1,69 +0,0 @@ |
|||
package com.lx.implatform.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.extension.activerecord.Model; |
|||
|
|||
import java.util.Date; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.Version; |
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
|
|||
/** |
|||
* <p> |
|||
* 群消息读取位置 |
|||
* </p> |
|||
* |
|||
* @author blue |
|||
* @since 2022-10-31 |
|||
*/ |
|||
@Data |
|||
@EqualsAndHashCode(callSuper = false) |
|||
@TableName("im_group_message_read_pos") |
|||
public class GroupMessageReadPos extends Model<GroupMessageReadPos> { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* id |
|||
*/ |
|||
@TableId(value = "id", type = IdType.AUTO) |
|||
private Long id; |
|||
|
|||
/** |
|||
* 群id |
|||
*/ |
|||
@TableField("group_id") |
|||
private Long groupId; |
|||
|
|||
/** |
|||
* 用户id |
|||
*/ |
|||
@TableField("user_id") |
|||
private Long userId; |
|||
|
|||
/** |
|||
* 已读取消息的最大消息id |
|||
*/ |
|||
@TableField("read_pos") |
|||
private Long readPos; |
|||
|
|||
/** |
|||
* 最后读取时间 |
|||
*/ |
|||
@TableField("last_read_time") |
|||
private Date lastReadTime; |
|||
|
|||
|
|||
@Override |
|||
protected Serializable pkVal() { |
|||
return this.id; |
|||
} |
|||
|
|||
} |
|||
@ -1,16 +0,0 @@ |
|||
package com.lx.implatform.mapper; |
|||
|
|||
import com.lx.implatform.entity.GroupMessageReadPos; |
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
|
|||
/** |
|||
* <p> |
|||
* 群消息读取位置 Mapper 接口 |
|||
* </p> |
|||
* |
|||
* @author blue |
|||
* @since 2022-10-31 |
|||
*/ |
|||
public interface GroupMessageReadPosMapper extends BaseMapper<GroupMessageReadPos> { |
|||
|
|||
} |
|||
@ -1,16 +0,0 @@ |
|||
package com.lx.implatform.service; |
|||
|
|||
import com.lx.implatform.entity.GroupMessageReadPos; |
|||
import com.baomidou.mybatisplus.extension.service.IService; |
|||
|
|||
/** |
|||
* <p> |
|||
* 群消息读取位置 服务类 |
|||
* </p> |
|||
* |
|||
* @author blue |
|||
* @since 2022-10-31 |
|||
*/ |
|||
public interface IGroupMessageReadPosService extends IService<GroupMessageReadPos> { |
|||
|
|||
} |
|||
@ -1,20 +0,0 @@ |
|||
package com.lx.implatform.service.impl; |
|||
|
|||
import com.lx.implatform.entity.GroupMessageReadPos; |
|||
import com.lx.implatform.mapper.GroupMessageReadPosMapper; |
|||
import com.lx.implatform.service.IGroupMessageReadPosService; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
/** |
|||
* <p> |
|||
* 群消息读取位置 服务实现类 |
|||
* </p> |
|||
* |
|||
* @author blue |
|||
* @since 2022-10-31 |
|||
*/ |
|||
@Service |
|||
public class GroupMessageReadPosServiceImpl extends ServiceImpl<GroupMessageReadPosMapper, GroupMessageReadPos> implements IGroupMessageReadPosService { |
|||
|
|||
} |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.imserver.config; |
|||
package com.bx.imserver.config; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonAutoDetect; |
|||
import com.fasterxml.jackson.annotation.JsonTypeInfo; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.imserver.constant; |
|||
package com.bx.imserver.constant; |
|||
|
|||
public class Constant { |
|||
|
|||
@ -1,6 +1,6 @@ |
|||
package com.lx.implatform.imserver.task; |
|||
package com.bx.imserver.task; |
|||
|
|||
import com.lx.implatform.imserver.websocket.WebsocketServer; |
|||
import com.bx.imserver.websocket.WebsocketServer; |
|||
import lombok.SneakyThrows; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,18 +1,14 @@ |
|||
package com.lx.implatform.imserver.task; |
|||
|
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.model.im.GroupMessageInfo; |
|||
import com.lx.common.model.im.PrivateMessageInfo; |
|||
import com.lx.implatform.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import com.lx.implatform.imserver.websocket.WebsocketServer; |
|||
import com.lx.implatform.imserver.websocket.processor.MessageProcessor; |
|||
import com.lx.implatform.imserver.websocket.processor.ProcessorFactory; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
package com.bx.imserver.task; |
|||
|
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.model.im.GroupMessageInfo; |
|||
import com.bx.imserver.websocket.WebsocketServer; |
|||
import com.bx.imserver.websocket.processor.MessageProcessor; |
|||
import com.bx.imserver.websocket.processor.ProcessorFactory; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.scheduling.annotation.Scheduled; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.util.List; |
|||
@ -1,18 +1,15 @@ |
|||
package com.lx.implatform.imserver.task; |
|||
package com.bx.imserver.task; |
|||
|
|||
|
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.model.im.PrivateMessageInfo; |
|||
import com.lx.implatform.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import com.lx.implatform.imserver.websocket.WebsocketServer; |
|||
import com.lx.implatform.imserver.websocket.processor.MessageProcessor; |
|||
import com.lx.implatform.imserver.websocket.processor.ProcessorFactory; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.model.im.PrivateMessageInfo; |
|||
import com.bx.imserver.websocket.WebsocketServer; |
|||
import com.bx.imserver.websocket.processor.MessageProcessor; |
|||
import com.bx.imserver.websocket.processor.ProcessorFactory; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.scheduling.annotation.Scheduled; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.util.List; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.imserver.websocket; |
|||
package com.bx.imserver.websocket; |
|||
|
|||
import io.netty.channel.ChannelHandlerContext; |
|||
|
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.imserver.websocket.endecode; |
|||
package com.bx.imserver.websocket.endecode; |
|||
|
|||
import com.fasterxml.jackson.databind.ObjectMapper; |
|||
import com.lx.common.model.im.SendInfo; |
|||
import com.bx.common.model.im.SendInfo; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import io.netty.handler.codec.MessageToMessageDecoder; |
|||
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.imserver.websocket.endecode; |
|||
package com.bx.imserver.websocket.endecode; |
|||
|
|||
import com.fasterxml.jackson.databind.ObjectMapper; |
|||
import com.lx.common.model.im.SendInfo; |
|||
import com.bx.common.model.im.SendInfo; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import io.netty.handler.codec.MessageToMessageEncoder; |
|||
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; |
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.imserver.websocket.processor; |
|||
package com.bx.imserver.websocket.processor; |
|||
|
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.model.im.GroupMessageInfo; |
|||
import com.lx.common.model.im.SendInfo; |
|||
import com.lx.implatform.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.model.im.GroupMessageInfo; |
|||
import com.bx.common.model.im.SendInfo; |
|||
import com.bx.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,10 +1,10 @@ |
|||
package com.lx.implatform.imserver.websocket.processor; |
|||
package com.bx.imserver.websocket.processor; |
|||
|
|||
import cn.hutool.core.bean.BeanUtil; |
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.model.im.HeartbeatInfo; |
|||
import com.lx.common.model.im.SendInfo; |
|||
import com.lx.implatform.imserver.websocket.WebsocketServer; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.model.im.HeartbeatInfo; |
|||
import com.bx.common.model.im.SendInfo; |
|||
import com.bx.imserver.websocket.WebsocketServer; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
@ -1,4 +1,4 @@ |
|||
package com.lx.implatform.imserver.websocket.processor; |
|||
package com.bx.imserver.websocket.processor; |
|||
|
|||
|
|||
import io.netty.channel.ChannelHandlerContext; |
|||
@ -1,19 +1,16 @@ |
|||
package com.lx.implatform.imserver.websocket.processor; |
|||
package com.bx.imserver.websocket.processor; |
|||
|
|||
import com.lx.common.contant.RedisKey; |
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.model.im.SendInfo; |
|||
import com.lx.common.model.im.PrivateMessageInfo; |
|||
import com.lx.implatform.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import com.bx.common.contant.RedisKey; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.model.im.SendInfo; |
|||
import com.bx.common.model.im.PrivateMessageInfo; |
|||
import com.bx.imserver.websocket.WebsocketChannelCtxHloder; |
|||
import io.netty.channel.ChannelHandlerContext; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.data.redis.core.RedisTemplate; |
|||
import org.springframework.scheduling.annotation.Async; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Slf4j |
|||
@Component |
|||
public class PrivateMessageProcessor extends MessageProcessor<PrivateMessageInfo> { |
|||
@ -1,7 +1,7 @@ |
|||
package com.lx.implatform.imserver.websocket.processor; |
|||
package com.bx.imserver.websocket.processor; |
|||
|
|||
import com.lx.common.enums.WSCmdEnum; |
|||
import com.lx.common.util.SpringContextHolder; |
|||
import com.bx.common.enums.WSCmdEnum; |
|||
import com.bx.common.util.SpringContextHolder; |
|||
|
|||
public class ProcessorFactory { |
|||
|
|||
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue