Skip to content

S
SiEn
Commit 2083aaa3 by zhangjw
Options

新增:客服模块 待拆分和优化

parent c5fb9040
Showing with 4242 additions and 0 deletions
customer-service/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>io.geekidea.springbootplus</groupId>
<artifactId>parent</artifactId>
<version>2.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<packaging>jar</packaging>
<artifactId>customer-service</artifactId>
<profiles>
<profile>
<!-- 开发环境 -->
<id>dev</id>
<properties>
<profiles.active>dev</profiles.active>
</properties>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
</profile>
<profile>
<!-- 测试环境 -->
<id>test</id>
<properties>
<profiles.active>test</profiles.active>
</properties>
</profile>
<profile>
<!-- 生产环境 -->
<id>prd</id>
<properties>
<profiles.active>prd</profiles.active>
</properties>
</profile>
</profiles>
<dependencies>
<!-- <dependency>-->
<!-- <groupId>com.ym</groupId>-->
<!-- <artifactId>pathfinder_common</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>-->
<!-- <scope>compile</scope>-->
<!-- </dependency>-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.11</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.springframework.cloud</groupId>-->
<!-- <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>-->
<!-- </dependency>-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>${java.version}</source>
<target>${java.version}</target>
<encoding>${project.build.sourceEncoding}</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
customer-service/src/main/java/com/ym/im/CustomerServiceApplication.java 0 → 100644
package com.ym.im;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
/**
* @author JJww
*/
@EnableAsync
@MapperScan("com.ym.im.mapper")
@SpringBootApplication
public class CustomerServiceApplication {
public static void main(String[] args) {
SpringApplication.run(CustomerServiceApplication.class, args);
}
}
customer-service/src/main/java/com/ym/im/config/ExceptionConfig.java 0 → 100644
package com.ym.im.config;
import com.ym.im.entity.MsgBody;
import com.ym.im.exception.IMessageException;
import com.ym.im.util.MessageUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.HttpMessageNotReadableException;
import org.springframework.validation.BindException;
import org.springframework.validation.FieldError;
import org.springframework.validation.ObjectError;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
/**
* 全局异常处理
*
* @author 陈俊雄
* @date 2019/5/31
**/
@Slf4j
@Configuration
public class ExceptionConfig {
/**
* REST异常处理类
*/
@RestControllerAdvice
public class RestResponseEntityExceptionHandler {
/**
* 系统级异常处理
*
* @param e e
* @return ResponseEntity
*/
@ExceptionHandler(value = Exception.class)
protected ResponseEntity<MsgBody> exceptionHandle(Exception e, HttpServletRequest request) {
// 错误信息编号：Error number，用于日志定位
final String errornum = UUID.randomUUID().toString();
log.error("Error number: " + errornum, e);
final MsgBody msgBody = new MsgBody<>()
.setStatus(HttpStatus.INTERNAL_SERVER_ERROR.value())
.setMessage(MessageUtils.getMsg("error.system", request.getLocale(), errornum));
return new ResponseEntity<>(msgBody, HttpStatus.INTERNAL_SERVER_ERROR);
}
/**
* Request参数异常处理
*
* @return ResponseEntity
*/
@ExceptionHandler(value = HttpMessageNotReadableException.class)
protected ResponseEntity<MsgBody> httpMessageNotReadableExceptionHandle(HttpServletRequest request) {
final MsgBody msgBody = new MsgBody<>()
.setStatus(HttpStatus.BAD_REQUEST.value())
.setMessage(MessageUtils.getMsg("error.missing_body", request.getLocale()));
return new ResponseEntity<>(msgBody, HttpStatus.BAD_REQUEST);
}
/**
* 聊天服务自定义异常处理
*
* @param e e
* @return ResponseEntity
*/
@ExceptionHandler(value = IMessageException.class)
protected ResponseEntity<MsgBody> iMessageExceptionHandle(IMessageException e) {
final MsgBody msgBody = new MsgBody<>().setStatus(HttpStatus.INTERNAL_SERVER_ERROR.value()).setMessage("error.top_level_error");
return new ResponseEntity<>(msgBody, HttpStatus.INTERNAL_SERVER_ERROR);
}
/**
* JsonBean参数校验异常处理
* {@link javax.validation}
*
* @param e e
* @return ResponseEntity
*/
@ExceptionHandler(value = {MethodArgumentNotValidException.class, BindException.class})
protected ResponseEntity<MsgBody<List<String>>> methodArgumentNotValidExceptionHandle(Exception e, HttpServletRequest request) {
final ArrayList<String> errorMsg = new ArrayList<>();
if (e instanceof MethodArgumentNotValidException) {
final List<ObjectError> allErrors = ((MethodArgumentNotValidException)e).getBindingResult().getAllErrors();
for (ObjectError oe : allErrors) {
errorMsg.add(oe.getDefaultMessage() + "[" + ((FieldError) oe).getField() + " = " + ((FieldError) oe).getRejectedValue() + "]");
}
}
if (e instanceof BindException){
final List<FieldError> allErrors = ((BindException)e).getFieldErrors();
for (FieldError fe : allErrors) {
errorMsg.add(fe.getDefaultMessage() + "[" + fe.getField() + " = " + fe.getRejectedValue() + "]");
}
}
final MsgBody<List<String>> msgBody = new MsgBody<>();
msgBody.setStatus(HttpStatus.BAD_REQUEST.value());
msgBody.setMessage(MessageUtils.getMsg("error.bad_parameter", request.getLocale()) + errorMsg.toString());
return new ResponseEntity<>(msgBody, HttpStatus.BAD_REQUEST);
}
}
}
customer-service/src/main/java/com/ym/im/config/JacksonConfig.java 0 → 100644
package com.ym.im.config;
import com.fasterxml.jackson.databind.Module;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import com.ym.im.util.JsonUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
/**
* @author 陈俊雄
* @date 2019/5/30
**/
@Configuration
public class JacksonConfig {
@Autowired
private ObjectMapper objectMapper;
@PostConstruct
public void init() {
// Date类型对象转时间戳（毫秒数）
objectMapper.enable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
objectMapper.registerModule(getSerializerLong2String());
objectMapper.registerModule(getSerializerDouble2String());
JsonUtils.setObjectMapper(objectMapper);
}
/**
* 将Long类型字段转Json字符串时转换为String类型防止前端Js精度丢失
*
* @return simpleModule
*/
public Module getSerializerLong2String() {
final SimpleModule simpleModule = new SimpleModule();
simpleModule.addSerializer(Long.class, ToStringSerializer.instance);
simpleModule.addSerializer(Long.TYPE, ToStringSerializer.instance);
return simpleModule;
}
/**
* 将Double类型字段转Json字符串时转换为String类型防止前端Js精度丢失
*
* @return simpleModule
*/
public Module getSerializerDouble2String() {
final SimpleModule simpleModule = new SimpleModule();
simpleModule.addSerializer(Double.class, ToStringSerializer.instance);
simpleModule.addSerializer(Double.TYPE, ToStringSerializer.instance);
return simpleModule;
}
}
customer-service/src/main/java/com/ym/im/config/LocaleConfig.java 0 → 100644
package com.ym.im.config;
import com.ym.im.util.MessageUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.web.servlet.WebMvcProperties;
import org.springframework.context.MessageSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.support.ResourceBundleMessageSource;
import org.springframework.validation.beanvalidation.LocalValidatorFactoryBean;
import javax.annotation.PostConstruct;
import java.util.Locale;
/**
* @author 陈俊雄
* @date 2019/5/31
**/
@Configuration
public class LocaleConfig {
@Autowired
private WebMvcProperties webMvcProperties;
@PostConstruct
public void init() {
// 初始化多语言工具类
MessageUtils.setMessageSource(messageSource());
Locale.setDefault(webMvcProperties.getLocale());
}
@Bean
public MessageSource messageSource() {
final ResourceBundleMessageSource messageSource = new ResourceBundleMessageSource();
messageSource.setDefaultEncoding("UTF-8");
messageSource.setUseCodeAsDefaultMessage(true);
messageSource.setBasenames("static.i18n.error", "static.i18n.message");
return messageSource;
}
/**
* validation注解返回异常消息多语言配置
*
* @return LocalValidatorFactoryBean
*/
@Bean
public LocalValidatorFactoryBean localValidatorFactoryBean() {
LocalValidatorFactoryBean bean = new LocalValidatorFactoryBean();
bean.setValidationMessageSource(messageSource());
return bean;
}
}
customer-service/src/main/java/com/ym/im/config/NettyConfig.java 0 → 100644
package com.ym.im.config;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.util.AttributeKey;
import io.netty.util.concurrent.DefaultEventExecutorGroup;
import io.netty.util.concurrent.EventExecutorGroup;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @author JJww
*/
@Configuration
public class NettyConfig {
public static final String ROOM = "/room";
public static final Integer MAX_THREADS = 1024;
public static final Integer MAX_FRAME_LENGTH = 65535;
public static final AttributeKey<Long> USER_ID = AttributeKey.valueOf("userId");
/**
* 负责TCP连接建立操作 绝对不能阻塞
*
* @return
*/
@Bean(name = "bossGroup")
public NioEventLoopGroup bossGroup() {
return new NioEventLoopGroup();
}
/**
* 负责Socket读写操作 绝对不能阻塞
*
* @return
*/
@Bean(name = "workerGroup")
public NioEventLoopGroup workerGroup() {
return new NioEventLoopGroup();
}
/**
* Handler中出现IO操作(如数据库操作，网络操作)使用这个
*
* @return
*/
@Bean(name = "businessGroup")
public EventExecutorGroup businessGroup() {
return new DefaultEventExecutorGroup(16);
}
}
customer-service/src/main/java/com/ym/im/config/RabbitConfig.java 0 → 100644
package com.ym.im.config;
import lombok.Data;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.CustomExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
/**
* @author: JJww
* @Date:2019-05-30
*/
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.rabbitmq")
public class RabbitConfig {
private String delayQueueName;
private String staffOfflineQueueName;
private String exchangeName;
@Bean
public Queue delayQueue() {
return new Queue(delayQueueName);
}
@Bean
public Queue staffOfflineQueue() {
return new Queue(staffOfflineQueueName);
}
/**
* 配置默认的交换机
*/
@Bean
CustomExchange customExchange() {
Map<String, Object> args = new HashMap<>(1);
args.put("x-delayed-type", "direct"); //参数二为类型：必须是x-delayed-message
return new CustomExchange(exchangeName, "x-delayed-message", true, false, args);
}
/**
* 绑定队列到交换器
*/
@Bean
Binding bindingDelayQueue(Queue delayQueue, CustomExchange customExchange) {
return BindingBuilder.bind(delayQueue).to(customExchange).with(delayQueueName).noargs();
}
/**
* 绑定队列到交换器
*/
@Bean
Binding bindingStaffOfflineQueue(Queue staffOfflineQueue, CustomExchange customExchange) {
return BindingBuilder.bind(staffOfflineQueue).to(customExchange).with(staffOfflineQueueName).noargs();
}
}
customer-service/src/main/java/com/ym/im/config/RedisConfig.java 0 → 100644
package com.ym.im.config;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
/**
* 先放放到时候再收拾
*
* @author 陈俊雄
* @date 2019/6/18
**/
@Configuration
public class RedisConfig {
/**
* 序列化、反序列化为Json的RedisTemplate
*
* @param redisConnectionFactory 连接工厂
* @param objectMapper Jackson.ObjectMapper
* @return redisTemplate
*/
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory, ObjectMapper objectMapper) {
final RedisSerializer<String> stringSerializer = new StringRedisSerializer();
final GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(objectMapper);
final RedisTemplate<Object, Object> template = new RedisTemplate<>();
template.setKeySerializer(stringSerializer);
template.setValueSerializer(jsonRedisSerializer);
template.setHashKeySerializer(stringSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
template.setDefaultSerializer(jsonRedisSerializer);
template.setConnectionFactory(redisConnectionFactory);
return template;
}
@Bean
public RedisTemplate<Object, Object> myRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
final ObjectMapper objectMapper = new ObjectMapper();
final RedisSerializer<String> stringSerializer = new StringRedisSerializer();
final GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(objectMapper);
final RedisTemplate<Object, Object> template = new RedisTemplate<>();
template.setKeySerializer(stringSerializer);
template.setValueSerializer(jsonRedisSerializer);
template.setHashKeySerializer(jsonRedisSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
template.setDefaultSerializer(jsonRedisSerializer);
template.setConnectionFactory(redisConnectionFactory);
return template;
}
}
customer-service/src/main/java/com/ym/im/config/SwaggerConfig.java 0 → 100644
package com.ym.im.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.ParameterBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.schema.ModelRef;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Parameter;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
import java.util.ArrayList;
import java.util.List;
/**
* @author: JJww
* @Date:2019-06-13
*/
@Configuration
@EnableSwagger2
public class SwaggerConfig {
@Bean
public Docket createRestApi() {
//全局header参数
ParameterBuilder authorization = new ParameterBuilder();
ParameterBuilder col = new ParameterBuilder();
List<Parameter> pars = new ArrayList<Parameter>();
authorization.name("Authorization").description("Bearer token").modelRef(new ModelRef("string")).parameterType("header").required(false).build(); //非必传
col.name("col").description("语言type（英文：en,中文：zh").modelRef(new ModelRef("string")).parameterType("header").required(false).build(); //非必穿
pars.add(authorization.build());
pars.add(col.build());
return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo())
.select()
.apis(RequestHandlerSelectors.basePackage("com.ym.im.controller"))
.paths(PathSelectors.any())
.build()
.globalOperationParameters(pars);
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("IM API")
.version("1.0")
.build();
}
}
customer-service/src/main/java/com/ym/im/controller/ChatRecordController.java 0 → 100644
package com.ym.im.controller;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.PullChatRecord;
import com.ym.im.service.ChatRecordService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.Valid;
import java.util.List;
/**
* @author 陈俊雄
* @date 2019/5/30
**/
@RestController
@RequestMapping("/chatRecord")
@Api(description = "聊天记录")
public class ChatRecordController {
@Autowired
private ChatRecordService chatRecordService;
@GetMapping("/pull")
@ApiOperation(value = "获取聊天记录")
public MsgBody<PullChatRecord> pull(@Valid PullChatRecord pull) {
// return pull.setChatRecords(chatRecordService.getChatRecord(pull));
return chatRecordService.getChatRecord(pull);
}
@PutMapping("/check")
@ApiOperation(value = "确认接收")
public MsgBody<List<ChatRecord>> check(List<ChatRecord> chatRecords) {
return chatRecordService.updateReceiveTime(chatRecords);
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/controller/StaffController.java 0 → 100644
package com.ym.im.controller;
import com.ym.im.entity.IdModel;
import com.ym.im.entity.MsgBody;
import com.ym.im.service.StaffService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
/**
* @author: JJww
* 客服
* @Date:2019-05-22
*/
@RestController
@RequestMapping("/staff")
@Api(description = "客服相关")
public class StaffController {
@Autowired
private StaffService staffService;
@GetMapping(value = "/getStaffList")
@ApiOperation(value = "获取所有客服信息")
public MsgBody getStaffList() {
return staffService.getStaffList();
}
@PostMapping(value = "/forward")
@ApiOperation(value = "转发")
public MsgBody forward(@Valid @RequestBody IdModel idModel) {
return staffService.forward(idModel);
}
}
customer-service/src/main/java/com/ym/im/controller/UserController.java 0 → 100644
package com.ym.im.controller;
import com.ym.im.entity.IdModel;
import com.ym.im.entity.MsgBody;
import com.ym.im.service.UserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
/**
* @author: JJww
* @Date:2019-07-24
*/
@RestController
@RequestMapping("/user")
@Api(description = "用户相关")
public class UserController {
@Autowired
private UserService userService;
@GetMapping("/list")
@ApiOperation(value = "获取当前用户列表(ID)")
@ApiImplicitParams({@ApiImplicitParam(name = "staffId", value = "客服ID", required = true, dataType = "Long", paramType = "query")})
public MsgBody getUserId(Long staffId) {
return userService.getUserList(staffId);
}
@DeleteMapping("/list")
@ApiOperation(value = "从列表中删除用户")
public MsgBody deleteUserFromList(@Valid @RequestBody IdModel idModel) {
return userService.deleteUserFromList(idModel);
}
@GetMapping("/checkBinding")
@ApiOperation(value = "查询用户绑定情况")
public MsgBody checkBinding(@Valid @ModelAttribute IdModel idModel) {
return userService.checkBinding(idModel);
}
}
customer-service/src/main/java/com/ym/im/core/MessageDecoder.java 0 → 100644
package com.ym.im.core;
/**
* @author: JJww
* 对象解码器
* @Date:2019-05-17
*/
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.util.JsonUtils;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToMessageDecoder;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.util.List;
/**
* @author: JJww
* 对象解码器
* @Date:2019-11-21
*/
@Slf4j
@Component
@ChannelHandler.Sharable
public class MessageDecoder extends MessageToMessageDecoder<TextWebSocketFrame> {
@Override
protected void decode(ChannelHandlerContext ctx, TextWebSocketFrame textWebSocketFrame, List out) throws Exception {
final String jsonStr = textWebSocketFrame.text();
MsgBody<ChatRecord> msgBody = new MsgBody<>(MsgBody.ERROR);
try {
msgBody = JsonUtils.json2Obj(jsonStr, MsgBody.class, ChatRecord.class);
} catch (IOException e) {
log.error("Json转{}异常：\r\n" +
"Json原串：{}\r\n" +
"===异常栈信息===", "MsgBody.class", jsonStr, e);
msgBody.setStatus(MsgBody.ERROR);
msgBody.setMessage("错误的Json格式：" + jsonStr);
ctx.channel().writeAndFlush(msgBody);
return;
}
out.add(msgBody);
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/core/MessageEncoder.java 0 → 100644
package com.ym.im.core;
import com.ym.im.entity.MsgBody;
import com.ym.im.util.JsonUtils;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import org.springframework.stereotype.Component;
/**
* @author: JJww
* 对象编码器
* @Date:2019-05-17
*/
@Component
@ChannelHandler.Sharable
public class MessageEncoder extends MessageToByteEncoder<MsgBody> {
@Override
protected void encode(ChannelHandlerContext channelHandlerContext, MsgBody msgBody, ByteBuf byteBuf) throws Exception {
channelHandlerContext.writeAndFlush(new TextWebSocketFrame(JsonUtils.obj2Json(msgBody)));
}
}
customer-service/src/main/java/com/ym/im/core/NettyServer.java 0 → 100644
package com.ym.im.core;
import com.ym.im.config.NettyConfig;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
/**
* netty服务端启动类
*
* @author: JJww
* @Date:2019-01-15
*/
@Slf4j
@Component
public class NettyServer {
@Value("${netty.port}")
private int port;
@Autowired
@Qualifier("bossGroup")
private NioEventLoopGroup bossGroup;
@Autowired
@Qualifier("workerGroup")
private NioEventLoopGroup workerGroup;
@Autowired
private WebSocketChannelInitializer webSocketChannelInitializer;
@PostConstruct
public void start() throws InterruptedException {
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.option(ChannelOption.SO_BACKLOG, NettyConfig.MAX_THREADS);//设置线程数
serverBootstrap.group(bossGroup, workerGroup)//绑定线程池
.channel(NioServerSocketChannel.class)//NioServerSocketChannel基于TCP协议的数据处理
.localAddress(port) // 绑定监听端口
.childOption(ChannelOption.TCP_NODELAY, true)//立即写出
.childOption(ChannelOption.SO_KEEPALIVE, true)//长连接
.childHandler(webSocketChannelInitializer); // 添加处理器
ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
if (channelFuture.isSuccess()) {
log.info("RTC_Endpoint 启动完毕,IP:{}", port);
}
}
@PreDestroy
public void destroy() {
bossGroup.shutdownGracefully().syncUninterruptibly();
workerGroup.shutdownGracefully().syncUninterruptibly();
log.info("RTC_Endpoint 已关闭,IP:{}", port);
}
}
customer-service/src/main/java/com/ym/im/core/WebSocketChannelInitializer.java 0 → 100644
package com.ym.im.core;
import com.ym.im.entity.NettyConstant;
import com.ym.im.handler.IndexHandler;
import com.ym.im.handler.SingleChatHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.stream.ChunkedWriteHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @author: JJww
* @Date:2019-01-21
*/
@Component
public class WebSocketChannelInitializer extends ChannelInitializer<SocketChannel> {
@Autowired
private SingleChatHandler singleChatHandler;
@Autowired
private IndexHandler indexHandler;
@Autowired
private MessageEncoder messageEncoder;
@Autowired
private MessageDecoder messageDecoder;
@Override
protected void initChannel(SocketChannel sc) throws Exception {
ChannelPipeline pipeline = sc.pipeline();
//websocket协议本身是基于http协议的，所以要使用http解编码器
pipeline.addLast(new HttpServerCodec());
pipeline.addLast(new ChunkedWriteHandler());
pipeline.addLast(new HttpObjectAggregator(NettyConstant.MAX_FRAME_LENGTH));
pipeline.addLast(indexHandler);
pipeline.addLast(new WebSocketServerProtocolHandler(NettyConstant.WS));
pipeline.addLast(messageDecoder);
pipeline.addLast(messageEncoder);
pipeline.addLast(singleChatHandler);
}
}
customer-service/src/main/java/com/ym/im/entity/BaseSocketInfo.java 0 → 100644
package com.ym.im.entity;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.Data;
import java.io.Serializable;
/**
* @author: JJww
* @Date:2019-07-17
*/
@Data
public class BaseSocketInfo implements Serializable {
private static final long serialVersionUID = 1L;
public String token;
public NioSocketChannel channel;
}
customer-service/src/main/java/com/ym/im/entity/ChatRecord.java 0 → 100644
package com.ym.im.entity;
import com.ym.im.validation.group.ChatRecordReceiveGroup;
import com.ym.im.validation.group.ChatRecordSaveGroup;
import com.ym.im.validation.group.ChatRecordSendGroup;
import com.ym.im.validation.group.StaffSendGroup;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import javax.validation.constraints.Max;
import javax.validation.constraints.Min;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Positive;
import javax.validation.groups.Default;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
* 聊天记录
* </p>
*
* @author 陈俊雄
* @since 2019-05-28
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class ChatRecord implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "以用户为第一人称：发送")
public static final int SEND = 0;
@ApiModelProperty(value = "以用户为第一人称：接收")
public static final int RECEIVE = 1;
@NotNull(message = "{error.chat_id_empty}", groups = {Default.class, ChatRecordSaveGroup.class})
@Positive(message = "{error.chat_id_greater_than_zero}", groups = {Default.class, ChatRecordSaveGroup.class})
private Long id;
@NotNull(message = "{error.user_id_empty}", groups = {Default.class, ChatRecordSaveGroup.class, StaffSendGroup.class})
@Positive(message = "{error.user_id_greater_than_zero}", groups = {Default.class, ChatRecordSaveGroup.class, StaffSendGroup.class})
@ApiModelProperty(value = "用户Id")
private Long userId;
@NotNull(message = "{error.staff_id_empty}", groups = {Default.class})
@Positive(message = "{error.staff_id_greater_than_zero}", groups = {Default.class})
@ApiModelProperty(value = "员工（客服）Id")
private Long staffId;
@NotNull(message = "{error.chat_msg_type_empty}", groups = {Default.class, ChatRecordSaveGroup.class, ChatRecordSendGroup.class})
@ApiModelProperty(value = "消息类型：1、聊天信息，2、PDF")
private Integer msgType;
@ApiModelProperty(value = "信息内容：msg_type为聊天信息时为聊天内容，msg_type为PDF时为下载地址")
private String msgInfo;
@Min(value = 0, message = "{error.chat_send_receive}", groups = {Default.class, ChatRecordSaveGroup.class})
@Max(value = 1, message = "{error.chat_send_receive}", groups = {Default.class, ChatRecordSaveGroup.class})
@ApiModelProperty(value = "收或发（以用户为第一人称,0:用户 1:客服）")
private Integer sendReceive;
@Min(value = 0, message = "{error.chat_scope}", groups = {Default.class, ChatRecordSaveGroup.class})
@Max(value = 2, message = "{error.chat_scope}", groups = {Default.class, ChatRecordSaveGroup.class})
@ApiModelProperty(value = "内容范围: 1、机票，2、酒店等")
private Integer scope = 0;
@ApiModelProperty(value = "重试次数")
private Integer retryCount = 0;
@NotNull(message = "{error.chat_send_time_empty}", groups = {Default.class, ChatRecordSaveGroup.class, ChatRecordSendGroup.class})
@ApiModelProperty(value = "发送时间（前端设置）")
private Date sendTime;
@NotNull(message = "{error.chat_receive_time_empty}", groups = {Default.class, ChatRecordReceiveGroup.class})
@ApiModelProperty(value = "接收时间（前端设置）")
private Date receiveTime;
@NotNull(message = "{error.chat_create_time_empty}", groups = {Default.class, ChatRecordSaveGroup.class})
@ApiModelProperty(value = "创建时间（服务端设置）")
private Date createTime;
@NotNull(message = "{error.chat_modify_time_empty}", groups = {Default.class})
@ApiModelProperty(value = "修改时间（服务端设置）")
private Date modifyTime;
}
customer-service/src/main/java/com/ym/im/entity/IMessageConstant.java 0 → 100644
package com.ym.im.entity;
/**
* @author 陈俊雄
* @date 2019/5/31
**/
public enum IMessageConstant {
MISSING_PARAMETERS_USER_ID(0, "成功");
private int code;
private String msg;
IMessageConstant(int code, String msg) {
this.code = code;
this.msg = msg;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}
customer-service/src/main/java/com/ym/im/entity/IdModel.java 0 → 100644
package com.ym.im.entity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotNull;
/**
* @author: JJww
* @Date:2019-06-27
*/
@Data
public class IdModel {
@ApiModelProperty(value = "客服Id")
@NotNull(message = "{error.staffId_empty}")
private Long staffId;
@ApiModelProperty(value = "用户Id")
@NotNull(message = "{error.userId_empty}")
private Long userId;
public IdModel(Long staffId, Long userId) {
this.staffId = staffId;
this.userId = userId;
}
}
customer-service/src/main/java/com/ym/im/entity/MsgBody.java 0 → 100644
package com.ym.im.entity;
import com.ym.im.validation.group.MsgBodyGroup;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
/**
* @author: JJww
* @Date:2019-05-17
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class MsgBody<T> implements Serializable {
public static final int LOGOUT = -3;
public static final int FORCEDOFFLINE = -2;
public static final int ERROR = -1;
public static final int SEND_MSG = 1;
public static final int CHECK_MSG = 2;
public static final int HAVE_READ = 3;
public static final int USERS_ONLINE = 4;
public static final int ORDER = 5;
public static final int DISTRIBUTION_STAFF = 6;
public static final int BINDINGFAILURE = 7;
@NotNull(message = "{error.msg_body_status_empty}", groups = MsgBodyGroup.class)
@ApiModelProperty(value = " * 操作类型说明\n" +
" * -3、登出\n" +
" * -2、被迫下线\n" +
" * -1、错误\n" +
" * 1、发送聊天消息\n" +
" * 2、确认接收聊天消息\n" +
" * 3、已读\n" +
" * 4、用户上线\n" +
" * 5、订单" +
" * 6、分配客服" +
" * 7、绑定失败"
)
private Integer status;
@Valid
@NotNull(message = "{error.msg_body_data_empty}", groups = MsgBodyGroup.class)
@ApiModelProperty(value = "type值不同时data对应不同对象:1、发送聊天消息{@link ChatRecord} 2、确认接收聊天消息{@link ChatRecord}")
private T data;
@ApiModelProperty(value = "消息描述")
private String message;
public MsgBody() {
}
public MsgBody(@NotNull(message = "{error.msg_body_status_empty}", groups = MsgBodyGroup.class) Integer status, @Valid @NotNull(message = "{error.msg_body_data_empty}", groups = MsgBodyGroup.class) T data) {
this.status = status;
this.data = data;
}
public MsgBody(@NotNull(message = "{error.msg_body_status_empty}", groups = MsgBodyGroup.class) Integer status) {
this.status = status;
}
public MsgBody(@NotNull(message = "{error.msg_body_status_empty}", groups = MsgBodyGroup.class) Integer status, String message) {
this.status = status;
this.message = message;
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/entity/NettyConstant.java 0 → 100644
package com.ym.im.entity;
import io.netty.util.AttributeKey;
import java.util.HashMap;
import java.util.Map;
/**
* @author: JJww
* @Date:2019-05-17
*/
public class NettyConstant {
/**
* ID
*/
public static final AttributeKey<Long> ID = AttributeKey.valueOf("id");
/**
* 用户(0) or 客服(1)
*/
public static final AttributeKey<Integer> TYPE = AttributeKey.valueOf("type");
/**
* 客服ID
*/
public static final AttributeKey<Long> STAFF_ID = AttributeKey.valueOf("staff");
/**
* 当前token
*/
public static final AttributeKey<String> TOKEN_INFO = AttributeKey.valueOf("token");
/**
* 客户端当前语言
*/
public static final AttributeKey<String> COL_INFO = AttributeKey.valueOf("col");
/**
* 连接类型：用户
*/
public static final int CONNECT_TYPE_USER = 0;
/**
* 连接类型：客服
*/
public static final int CONNECT_TYPE_STAFF = 1;
/**
* ws标识
*/
public static final String WS = "/ws";
/**
* 用户 ws标识
*/
public static final String USER_WS = "app";
/**
* 客服 ws标识
*/
public static final String STAFF_WS = "web";
/**
* Token
*/
public static final String TOKEN = "token";
/**
* 当前语言
*/
public static final String COL = "col";
/**
* 最大线程量
*/
public static final Integer MAX_THREADS = 1024;
/**
* 数据包最大长度
*/
public static final Integer MAX_FRAME_LENGTH = 65535;
/**
* redis 聊天记录KEY
*/
public static final String MSG_KEY = "MSG: ";
/**
* 客服socket 绑定的用户列表
*/
public static final String STAFF_USERIDS_KEY = "staff.userIds: ";
/**
* 用户socket 相关信息
*/
public static final String IM_USERS = "im.users";
/**
* 重发次数
*/
public static final Integer RETRY_COUNT = 3;
public static final Map<String, Integer> CONNECT_TYPE = new HashMap<String, Integer>() {
{
put("app", 0);
put("web", 1);
}
};
}
customer-service/src/main/java/com/ym/im/entity/PullChatRecord.java 0 → 100644
package com.ym.im.entity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
import javax.validation.constraints.Positive;
import java.io.Serializable;
import java.util.List;
/**
* @author 陈俊雄
* @date 2019/5/28
**/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class PullChatRecord implements Serializable {
@NotNull(message = "{error.user_id_empty}")
@Positive(message = "{error.user_id_greater_than_zero}")
@ApiModelProperty(value = "用户Id")
private Long userId;
@Positive(message = "{error.chat_id_greater_than_zero}")
@ApiModelProperty(value = "聊天记录Id，为获取坐标")
private Long chatRecordId;
@Pattern(regexp = "(?i)forward|backward", message = "{error.chat_id_direction}")
@ApiModelProperty(value = " 聊天记录Id，为获取坐标\n" +
" * 小于当前聊天记录Id：往前（forward）\n" +
" * 大于当前聊天记录Id：往后（backward）")
private String direction;
@Positive(message = "{error.chat_page_num}")
@ApiModelProperty(value = "分页页数")
private Integer pageNum = 1;
@Positive(message = "{error.chat_page_size}")
@ApiModelProperty(value = "分页大小")
private Integer pageSize = 20;
@ApiModelProperty(value = "总条数")
private Long total;
@ApiModelProperty(value = "总页数")
private Integer pages;
@NotEmpty(message = "{error.chat_order_by_empty}")
@ApiModelProperty(value = "聊天记录Id，为获取坐标的查询结果根据某字段做排序")
private String orderBy = "id";
@Pattern(regexp = "(?i)asc|desc", message = "{error.chat_sorting}")
@ApiModelProperty(value = "升序：asc 降序：desc")
private String sorting = "desc";
@ApiModelProperty(value = "查询结果")
private List<ChatRecord> chatRecords;
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/entity/StaffSocketInfo.java 0 → 100644
package com.ym.im.entity;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.util.HashSet;
import java.util.Set;
/**
* @author: JJww
* 客服
* @Date:2019-05-21
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class StaffSocketInfo extends BaseSocketInfo {
private Long staffId;
private Set<Long> userIds;
public Set<Long> getUserIds() {
return userIds != null ? userIds : new HashSet<Long>();
}
public void setUserIds(Set<Long> userIds) {
this.userIds = userIds;
}
public StaffSocketInfo() {
}
public StaffSocketInfo(Long staffId, Set<Long> userIds) {
this.staffId = staffId;
this.userIds = userIds;
}
public StaffSocketInfo(Long staffId, NioSocketChannel channel, Set<Long> userIds) {
this.staffId = staffId;
this.channel = channel;
this.userIds = userIds;
}
}
customer-service/src/main/java/com/ym/im/entity/UserSocketInfo.java 0 → 100644
package com.ym.im.entity;
import com.ym.im.entity.model.PushTokenAndTypeModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* @author: JJww
* @Date:2019-05-21
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class UserSocketInfo extends BaseSocketInfo {
private Long userId;
private Long staffId;
private Integer scope;
private PushTokenAndTypeModel pushToken;
private String col;
public UserSocketInfo() {
}
}
customer-service/src/main/java/com/ym/im/entity/base/ResultStatus.java 0 → 100644
package com.ym.im.entity.base;
/**
* 自定义请求状态码
*
* @author hjp
* @date 2019/5/16
*/
public enum ResultStatus {
/**
* 成功
*/
SUCCESS(200, "Success", "成功"),
PRIVILEGE_IS_ERROR(401, "Unauthorized", "未授权限，请联系管理员"),
THERE_IS_NO_ONLINE_CUSTOMER_SERVICE(10000, "There is no online customer service", "当前没有客服在线"),
MOBILE_NO_REGISTER(20000, "The mobile phone number is registered", "手机号未注册"),
MOBILE_REGISTER(20001, "Mobile phone number has been registered", "手机号已注册"),
VERIFICATION_CODE_FAILURE(20002, "The captcha is invalid or incorrect", "验证码失效或不正确"),
USER_INFO_NO_EXIST(20003, "User information does not exist", "用户信息不存在"),
WRONG_PASSWORD(20004, "wrong password", "密码错误"),
USER_FORBIDDEN(20005, "The user has been blocked", "手机号已被封禁"),
USER_NAME_REPEAT(20006, "The user has been exited", "用户账号名称已存在"),
REPEAT_COMMIT(20007, "your commit is repeat", "重复提交"),
HAS_BEEN_ENTERPRISE(20008, "Has been enterprise users", "已经是企业用户"),
NO_THIS_AIRLINE(20009,"This AirLine does not exist","该航班不存在"),
HAVE_ROUTE_CANNOT_DEL(30001, "Route binding cannot be delete", "有路线绑定无法删除"),
SERVICE_ROUTE_NO_EXIST(40001, "Service routing does not exist", "服务路线不存在"),
VEHICLE_TYPE_NO_EXIST(40002, "Vehicle type does not exist", "车辆类型不存在"),
SERVICE_ROUTE_VEHICLE_NO_EXIST(40003, "Service route does not exist with vehicle type association", "服务路线与车辆类型关联不存在"),
FORWARD_FAILURE(40004, "Failed to forward, customer service or user offline", "转发失败,客服或用户已下线"),
CHECK_FAILURE(40005, "This user has binding other staff", "此用户已经绑定其他客服"),
PARAM_ERROR(9999, "Parameters error", "参数有误"),
SYS_BUSY(-9998, "The system is busy, please try again later!", "系统繁忙，请稍候再试！"),
SYS_ERROR(-9999, "System error", "系统错误！"),
REQUEST_ERROR(-9997, "Request error", "请求有误！"),
FORBIDDEN_ERROR(-9996, "forbidden error", "用户已被封禁");
/**
* 返回码
*/
private int code;
/**
* 默认返回英文结果描述 en
*/
private String message;
/**
* 返回中文结果描述 zh_simple
*/
private String zhMessage;
ResultStatus(int code, String message, String zhMessage) {
this.code = code;
this.message = message;
this.zhMessage = zhMessage;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public String getZhMessage() {
return zhMessage;
}
public void setZhMessage(String zhMessage) {
this.zhMessage = zhMessage;
}
}
customer-service/src/main/java/com/ym/im/entity/enums/LanguageEnum.java 0 → 100644
package com.ym.im.entity;
/**
* 语言类型枚举类
*
* @author hjp
* @Description
* @date 2019/5/16
*/
public enum LanguageEnum {
en("en", "英文"),
zh("zh", "中文");
private String key;
private String remark;
LanguageEnum(String key, String remark) {
this.key = key;
this.remark = remark;
}
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
}
customer-service/src/main/java/com/ym/im/entity/enums/PlatformEnum.java 0 → 100644
package com.ym.im.entity.enums;
public enum PlatformEnum {
web("web", "后台用户登陆标识"),
app("app", "app用户标识");
private String key;
private String remark;
PlatformEnum(String key, String remark) {
this.key = key;
this.remark = remark;
}
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
}
customer-service/src/main/java/com/ym/im/entity/model/OrderModel.java 0 → 100644
package com.ym.im.entity.model;
import lombok.Data;
import java.io.Serializable;
/**
* @author: JJww
* @Date:2019-07-19
*/
@Data
public class OrderModel implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 订单类型
*/
private String type;
/**
* 订单ID
*/
private String orderId;
/**
* 订单状态
*/
private String orderStatus;
/**
* 用户Id
*/
private String userId;
public OrderModel(String type, String orderId, String orderStatus, String userId) {
this.type = type;
this.orderId = orderId;
this.orderStatus = orderStatus;
this.userId = userId;
}
}
customer-service/src/main/java/com/ym/im/entity/model/PushTokenAndTypeModel.java 0 → 100644
package com.ym.im.entity.model;
import lombok.Data;
/**
* @author xjx
* @Description
* @date 2019/11/18
*/
@Data
public class PushTokenAndTypeModel {
private String pushToken;
private String pushType;
}
customer-service/src/main/java/com/ym/im/exception/IMessageException.java 0 → 100644
package com.ym.im.exception;
import com.ym.im.entity.MsgBody;
import com.ym.im.util.MessageUtils;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.Locale;
import java.util.UUID;
/**
* @author 陈俊雄
* @date 2019/5/31
**/
@Data
@EqualsAndHashCode(callSuper = true)
public class IMessageException extends RuntimeException {
private MsgBody msgBody;
private String i18nError;
private String errorNum = UUID.randomUUID().toString();
public IMessageException(String i18nError) {
super(MessageUtils.getMsg(i18nError, Locale.CHINA));
this.i18nError = i18nError;
this.msgBody = new MsgBody()
.setStatus(MsgBody.ERROR)
.setMessage(MessageUtils.getMsg(i18nError));
}
}
customer-service/src/main/java/com/ym/im/factory/SingleChatFactory.java 0 → 100644
package com.ym.im.factory;
import com.ym.im.entity.NettyConstant;
import com.ym.im.exception.IMessageException;
import com.ym.im.service.ChatService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @author: JJww
* @Date:2019-05-23
*/
@Component
public class SingleChatFactory {
@Autowired
private ChatService userSingleChatServiceImpl;
@Autowired
private ChatService staffSingleChatServiceImpl;
/**
* 创建对应实现类
*
* @param type
* @return
*/
public ChatService getService(Integer type) {
if (type == null) {
return null;
}
switch (type) {
case NettyConstant.CONNECT_TYPE_USER:
return userSingleChatServiceImpl;
case NettyConstant.CONNECT_TYPE_STAFF:
return staffSingleChatServiceImpl;
default:
return null;
}
}
}
customer-service/src/main/java/com/ym/im/handler/BaseHandler.java 0 → 100644
package com.ym.im.handler;
import com.ym.im.entity.NettyConstant;
import com.ym.im.factory.SingleChatFactory;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @author: JJww
* @Date:2019/11/14
*/
public abstract class BaseHandler<T> extends SimpleChannelInboundHandler<T> {
@Autowired
private SingleChatFactory singleChatFactory;
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
singleChatFactory.getService(ctx.channel().attr(NettyConstant.TYPE).get()).offline(ctx);
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
singleChatFactory.getService(ctx.channel().attr(NettyConstant.TYPE).get()).offline(ctx);
}
}
customer-service/src/main/java/com/ym/im/handler/IndexHandler.java 0 → 100644
package com.ym.im.handler;
import com.ym.im.entity.BaseSocketInfo;
import com.ym.im.entity.LanguageEnum;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.NettyConstant;
import com.ym.im.entity.enums.PlatformEnum;
import com.ym.im.factory.SingleChatFactory;
import com.ym.im.service.ChannelGroupService;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import static io.netty.handler.codec.http.HttpResponseStatus.UNAUTHORIZED;
import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
/**
* @author: JJww
* ws 校验/初始化相关处理
* @Date:2019-05-17
*/
@Slf4j
@Component
@ChannelHandler.Sharable
public class IndexHandler extends BaseHandler<FullHttpRequest> {
@Resource(name = "myRedisTemplate")
private RedisTemplate redisTemplate;
@Autowired
private SingleChatFactory singleChatFactory;
@Override
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest request) throws Exception {
// 获取uri参数信息
final Map<String, List<String>> parameters = new QueryStringDecoder(request.uri()).parameters();
// 获取token信息
final List<String> tokenStr = parameters.get(NettyConstant.TOKEN);
if (tokenStr == null) {
log.error("token值为空！");
sendHttpResponse(ctx, request, new DefaultFullHttpResponse(HTTP_1_1, UNAUTHORIZED));
return;
}
// 解析token
// final String[] tokenInfo = String.valueOf(JwtUtil.checkToken(tokenStr.get(0)).get("user_id")).split("_");
final String[] tokenInfo = null;
if (tokenInfo.length < 2) {
log.error("userId格式不正确：" + tokenInfo[1]);
sendHttpResponse(ctx, request, new DefaultFullHttpResponse(HTTP_1_1, UNAUTHORIZED));
return;
}
final Integer type = NettyConstant.CONNECT_TYPE.get(tokenInfo[0]);
final Long userId = Long.valueOf(tokenInfo[1]);
if (type == null) {
log.error("用户类型值不正确：" + tokenInfo[0]);
sendHttpResponse(ctx, request, new DefaultFullHttpResponse(HTTP_1_1, UNAUTHORIZED));
return;
}
// if (NettyConstant.CONNECT_TYPE_USER == type.intValue() && Constants.FORBIDDEN.equals(redisTemplate.opsForHash().get(Constants.USER, userId))) {
// log.info("用户被禁用：" + userId);
// sendHttpResponse(ctx, request, new DefaultFullHttpResponse(HTTP_1_1, PROXY_AUTHENTICATION_REQUIRED));
// return;
// }
//保存当前token
String token = "Bearer " + tokenStr.get(0);
ctx.channel().attr(NettyConstant.TOKEN_INFO).set(token);
ctx.channel().attr(NettyConstant.ID).set(userId);
ctx.channel().attr(NettyConstant.COL_INFO).set(parameters.get(NettyConstant.COL) == null ? LanguageEnum.zh.getKey() : parameters.get(NettyConstant.COL).get(0));
this.close(token, userId, tokenInfo[0]);
singleChatFactory.getService(type).init(ctx);
request.setUri(NettyConstant.WS);
ctx.fireChannelRead(request.retain());
}
private void close(String token, Long userId, String type) {
final BaseSocketInfo baseSocketInfo = PlatformEnum.app.getKey().equals(type) ? ChannelGroupService.USER_GROUP.get(userId) : ChannelGroupService.STAFF_GROUP.get(userId);
if (baseSocketInfo != null && !token.equals(baseSocketInfo.getToken())) {
baseSocketInfo.getChannel().write(new MsgBody(MsgBody.FORCEDOFFLINE));
baseSocketInfo.getChannel().close();
ChannelGroupService.USER_GROUP.remove(userId);
log.info("用户: " + userId + " 被迫下线");
}
}
private static void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest request, FullHttpResponse response) {
if (response.status().code() != HttpResponseStatus.OK.code()) {
ByteBuf buf = Unpooled.copiedBuffer(response.status().toString(), CharsetUtil.UTF_8);
response.content().writeBytes(buf);
buf.release();
response.headers();
HttpUtil.setContentLength(response, response.content().readableBytes());
}
ChannelFuture f = ctx.channel().writeAndFlush(response);
if (!HttpUtil.isKeepAlive(request) || response.status().code() != HttpResponseStatus.OK.code()) {
f.addListener(ChannelFutureListener.CLOSE);
}
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/handler/SingleChatHandler.java 0 → 100644
package com.ym.im.handler;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.exception.IMessageException;
import com.ym.im.service.MsgBodyService;
import com.ym.im.util.MessageUtils;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import lombok.extern.slf4j.Slf4j;
import org.hibernate.validator.internal.engine.path.PathImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.validation.ConstraintViolation;
import javax.validation.ConstraintViolationException;
import java.util.ArrayList;
/**
* @author: JJww
* 单聊
* @Date:2019-05-17
*/
@Slf4j
@Component
@ChannelHandler.Sharable
public class SingleChatHandler extends BaseHandler<MsgBody<ChatRecord>> {
@Autowired
private MsgBodyService msgBodyService;
@Override
protected void channelRead0(ChannelHandlerContext ctx, MsgBody<ChatRecord> msgBody) throws Exception {
try {
msgBodyService.msgBodyHandle(ctx, msgBody);
} catch (ConstraintViolationException e) {
log.error(e.getMessage());
ConstraintViolation<?> next;
final ArrayList<String> errorMsg = new ArrayList<>();
for (ConstraintViolation<?> constraintViolation : e.getConstraintViolations()) {
next = constraintViolation;
errorMsg.add(next.getMessage() + " " + ((PathImpl) next.getPropertyPath()).getLeafNode().asString() + " = " + next.getInvalidValue());
}
msgBody.setStatus(MsgBody.ERROR);
msgBody.setMessage(errorMsg.toString());
ctx.channel().writeAndFlush(msgBody);
} catch (IMessageException e) {
msgBody.setStatus(MsgBody.ERROR);
msgBody.setMessage(MessageUtils.getMsg(e.getI18nError()));
ctx.channel().writeAndFlush(msgBody);
} catch (Exception e) {
e.printStackTrace();
}
}
}
customer-service/src/main/java/com/ym/im/mapper/ChatRecordMapper.java 0 → 100644
package com.ym.im.mapper;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.PullChatRecord;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 聊天记录 Mapper 接口
* </p>
*
* @author 陈俊雄
* @since 2019-05-28
*/
public interface ChatRecordMapper {
int insert(@Param("chat") ChatRecord chatRecord, @Param("index") int index);
int insertSelective(@Param("chat") ChatRecord chatRecord, @Param("index") int index);
int updateById(@Param("chat") ChatRecord chatRecord, @Param("index") int index);
int updateByIdSelective(@Param("chat") ChatRecord chatRecord, @Param("index") int index);
int updateBatchReceiveTimeById(@Param("chats") List<ChatRecord> chats, @Param("index") int index);
int updateReceiveTime(@Param("chat") ChatRecord chatRecord, @Param("index") int index);
ChatRecord selectById(@Param("id") Long id, @Param("index") int index);
List<ChatRecord> getChatRecord(@Param("pull") PullChatRecord pull, @Param("index") int index);
}
customer-service/src/main/java/com/ym/im/mq/Queue.java 0 → 100644
package com.ym.im.mq;
import com.ym.im.config.RabbitConfig;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.StaffSocketInfo;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @author: JJww
* @Date:2019-05-30
*/
@Component
public class Queue {
@Autowired
private AmqpTemplate rabbitTemplate;
@Autowired
private RabbitConfig rabbitConfig;
/**
* 延迟队列 重发未回应消息
*
* @param msgBody
*/
public void delaysQueue(MsgBody msgBody) {
// 通过广播模式发布延时消息 延时3秒 消费后销毁 这里无需指定路由，会广播至每个绑定此交换机的队列
rabbitTemplate.convertAndSend(rabbitConfig.getExchangeName(), rabbitConfig.getDelayQueueName(), msgBody, message -> {
message.getMessageProperties().setDelay(3 * 1000); // 毫秒为单位，指定此消息的延时时长
return message;
});
}
/**
* 客服离线 队列
*
* @param msgBody
*/
public void staffOfflineQueue(StaffSocketInfo staffSocketInfo) {
//客服下线后 转发用户到其他客服
rabbitTemplate.convertAndSend(rabbitConfig.getExchangeName(), rabbitConfig.getStaffOfflineQueueName(), staffSocketInfo, message -> {
message.getMessageProperties().setDelay((60 * 1000)); // 毫秒为单位，指定此消息的延时时长
return message;
});
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/mq/Receiver.java 0 → 100644
package com.ym.im.mq;
import com.alibaba.fastjson.JSON;
import com.ym.im.entity.*;
import com.ym.im.entity.model.OrderModel;
import com.ym.im.service.ChannelGroupService;
import com.ym.im.service.StaffService;
import com.ym.im.util.JsonUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Set;
/**
* @author: JJww
* @Date:2019-05-30
*/
@Slf4j
@Component
public class Receiver {
@Autowired
private Queue queue;
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private StaffService staffService;
/**
* 禁用用户 队列名称
*/
public static final String USER_QUEUE_NAME = "disable.user";
/**
* 订单队列
*/
public static final String ORDER_QUEUE_NAME = "push.order";
@RabbitListener(queues = "#{delayQueue.name}")
public void delayAckHandler(MsgBody msgBody) throws IOException {
log.info("接收时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " 消息内容：" + JsonUtils.obj2Json(msgBody));
retry(msgBody);
}
@RabbitListener(queues = "#{staffOfflineQueue.name}")
public void offlineHandler(StaffSocketInfo staffSocketInfo) {
final Long staffId = staffSocketInfo.getStaffId();
//移除用户列表
redisTemplate.delete(NettyConstant.STAFF_USERIDS_KEY + staffId);
//客服真离线后 才转发
if (ChannelGroupService.STAFF_GROUP.get(staffId) == null) {
final Set<Long> userIds = staffSocketInfo.getUserIds();
log.info("客服离线队列: " + "ID: " + "UserIds:" + userIds);
userIds.forEach((Long userId) -> {
//用户在线才重新分配和转发
if (ChannelGroupService.USER_GROUP.get(userId) != null) {
final StaffSocketInfo idleStaff = staffService.getIdleStaff(userId);
if (idleStaff != null) {
idleStaff.getChannel().writeAndFlush(new MsgBody<>(MsgBody.DISTRIBUTION_STAFF, new IdModel(staffId, userId)));
}
}
});
}
}
/**
* 禁用用户后 关闭socket
*
* @param userId
* @throws IOException
*/
@RabbitListener(queues = USER_QUEUE_NAME)
public void disableUserHandler(String userId) {
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(Long.valueOf(userId));
if (userSocketInfo != null) {
userSocketInfo.getChannel().writeAndFlush(new MsgBody<>(MsgBody.LOGOUT));
userSocketInfo.getChannel().close();
log.info("用户: " + userId + "被禁用");
}
}
/**
* 订单相关处理
*
* @param orderModel
*/
@RabbitListener(queues = ORDER_QUEUE_NAME)
public void orderHandler(OrderModel orderModel) {
log.info("Constants.ORDER_QUEUE_NAME: " + JSON.toJSONString(orderModel));
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(Long.valueOf(orderModel.getUserId()));
if (userSocketInfo == null) {
return;
}
StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(userSocketInfo.getStaffId());
final MsgBody<OrderModel> orderInfo = new MsgBody<>(MsgBody.ORDER, orderModel);
/**
* 绑定客服在线,发送订单信息
*/
if (staffSocketInfo != null) {
staffSocketInfo.getChannel().writeAndFlush(orderInfo);
log.info("客服订单: " + "给客服(" + staffSocketInfo.getStaffId() + ")发送订单:" + orderInfo.toString());
return;
}
/**
* 绑定客服不在线,给历史客服发送订单信息
*/
final Long staffId = (Long) redisTemplate.opsForHash().get(NettyConstant.IM_USERS, orderModel.getUserId());
if (staffId != null) {
log.info("客服订单: " + "尝试给历史客服(" + staffId + ")发送订单:" + orderInfo.toString());
staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(staffId);
if (staffSocketInfo != null) {
staffSocketInfo.getChannel().writeAndFlush(orderInfo);
log.info("客服订单: " + "给历史客服(" + staffId + ")发送订单:" + orderInfo.toString());
}
}
}
/**
* 重发未回执的消息
*
* @param msgBody
* @throws IOException
*/
public void retry(MsgBody<ChatRecord> msgBody) throws IOException {
ChatRecord chatRecord = msgBody.getData();
Long userId = Long.valueOf(chatRecord.getUserId());
String recordId = String.valueOf(chatRecord.getId());
if (msgBody != null && chatRecord.getRetryCount().intValue() < NettyConstant.RETRY_COUNT.intValue()) {
UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(userId);
if (userSocketInfo == null) {
return;
}
MsgBody<ChatRecord> msg = JsonUtils.json2Obj(
String.valueOf(redisTemplate.opsForHash().get(NettyConstant.MSG_KEY + userId, recordId)),
JsonUtils.getJavaType(MsgBody.class, ChatRecord.class));
if (msg != null && msg.getStatus().equals(MsgBody.HAVE_READ)) {
redisTemplate.opsForHash().delete(NettyConstant.MSG_KEY + userId, recordId);
return;
}
switch (chatRecord.getSendReceive()) {
case NettyConstant.CONNECT_TYPE_USER:
Long staffId = userSocketInfo.getStaffId() == null ? chatRecord.getStaffId() : userSocketInfo.getStaffId();
StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(staffId);
if (staffSocketInfo != null) {
staffSocketInfo.getChannel().writeAndFlush(msgBody);
}
break;
case NettyConstant.CONNECT_TYPE_STAFF:
userSocketInfo.getChannel().writeAndFlush(msgBody);
break;
default:
}
//重发三次
chatRecord.setRetryCount(chatRecord.getRetryCount() + 1);
queue.delaysQueue(msgBody);
} else {
//移除失败消息
redisTemplate.opsForHash().delete(NettyConstant.MSG_KEY + userId, recordId);
}
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/service/ChannelGroupService.java 0 → 100644
package com.ym.im.service;
import com.ym.im.entity.StaffSocketInfo;
import com.ym.im.entity.UserSocketInfo;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* @author: JJww
* Channe管理
* @Date:2019-05-21
*/
public interface ChannelGroupService {
/**
* 在线用户Group
*/
Map<Long, UserSocketInfo> USER_GROUP = new ConcurrentHashMap<>();
/**
* 在线客服Group
*/
Map<Long, StaffSocketInfo> STAFF_GROUP = new ConcurrentHashMap<>();
}
customer-service/src/main/java/com/ym/im/service/ChatRecordService.java 0 → 100644
package com.ym.im.service;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.PullChatRecord;
import com.ym.im.validation.group.ChatRecordSaveGroup;
import org.springframework.validation.annotation.Validated;
import javax.validation.Valid;
import java.util.List;
/**
* <p>
* 聊天记录 服务类
* </p>
*
* @author 陈俊雄
* @since 2019-05-28
*/
@Validated
public interface ChatRecordService {
/**
* 聊天记录表数量
*/
int NUMBER_OF_TABLE = 32;
@Validated({ChatRecordSaveGroup.class})
int insert(ChatRecord chatRecord);
@Validated({ChatRecordSaveGroup.class})
int insertSelective(@Valid ChatRecord chatRecord);
int updateById(ChatRecord chatRecord);
int updateByIdSelective(ChatRecord chatRecord);
int updateReceiveTime(ChatRecord chatRecord);
ChatRecord selectById(Long id, Long userId);
MsgBody<PullChatRecord> getChatRecord(PullChatRecord pull);
MsgBody<List<ChatRecord>> updateReceiveTime(List<ChatRecord> chats);
// MsgBody
}
customer-service/src/main/java/com/ym/im/service/ChatService.java 0 → 100644
package com.ym.im.service;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.socket.nio.NioSocketChannel;
import javax.validation.Valid;
/**
* @author: JJww
* @Date:2019-05-21
*/
public interface ChatService {
/**
* 连接初始化
*
* @param ctx
* @return
*/
void init(ChannelHandlerContext ctx);
/**
* 发送
*
* @param msgBody
* @throws JsonProcessingException
*/
void send(NioSocketChannel channel, MsgBody<ChatRecord> msgBody) throws JsonProcessingException;
/**
* 离线
*
* @param ctx
* @throws JsonProcessingException
*/
void offline(ChannelHandlerContext ctx);
/**
* 回执
*
* @param msgBody
* @throws JsonProcessingException
*/
void ack(@Valid MsgBody<ChatRecord> msgBody) throws JsonProcessingException;
/**
* 保存消息
*
* @param id
* @param msgBody
*/
void save(Long id, @Valid MsgBody<ChatRecord> msgBody);
/**
* 分配
*
* @param id
* @param msgBody
* @return
*/
NioSocketChannel distribution(Long id,@Valid MsgBody<ChatRecord> msgBody);
}
customer-service/src/main/java/com/ym/im/service/MsgBodyService.java 0 → 100644
package com.ym.im.service;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.socket.nio.NioSocketChannel;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
/**
* @author 陈俊雄
* @date 2019/5/29
**/
public interface MsgBodyService {
void msgBodyHandle(@NotNull ChannelHandlerContext ctx, @Valid MsgBody<ChatRecord> msgBody) throws JsonProcessingException;
void sendAndAck(NioSocketChannel channel, MsgBody<ChatRecord> msgBody) throws JsonProcessingException;
}
customer-service/src/main/java/com/ym/im/service/StaffService.java 0 → 100644
package com.ym.im.service;
import com.ym.im.entity.IdModel;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.StaffSocketInfo;
/**
* @author: JJww
* @Date:2019-05-22
*/
public interface StaffService {
/**
* 获取空闲的客服ID
*
* @param userId
* @return
*/
StaffSocketInfo getIdleStaff(Long userId);
/**
* 转发客服
*
* @param idModel
* @return
*/
MsgBody forward(IdModel idModel);
/**
* 获取所有在线客服
*
* @return
*/
MsgBody getStaffList();
}
customer-service/src/main/java/com/ym/im/service/UserService.java 0 → 100644
package com.ym.im.service;
import com.ym.im.entity.IdModel;
import com.ym.im.entity.MsgBody;
/**
* @author: JJww
* @Date:2019-07-24
*/
public interface UserService {
/**
* 获取当前用户列表
*
* @param staffId
* @return
*/
MsgBody getUserList(Long staffId);
/**
* 从列表中删除用户
*
* @param idModel
* @return
*/
MsgBody deleteUserFromList(IdModel idModel);
/**
* 查询用户绑定情况
*
* @param idModel
* @return
*/
MsgBody checkBinding(IdModel idModel);
}
customer-service/src/main/java/com/ym/im/service/impl/ChatRecordServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.PullChatRecord;
import com.ym.im.entity.base.ResultStatus;
import com.ym.im.mapper.ChatRecordMapper;
import com.ym.im.service.ChatRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 聊天记录 服务实现类
* </p>
*
* @author 陈俊雄
* @since 2019-05-28
*/
@Service
public class ChatRecordServiceImpl implements ChatRecordService {
@Autowired
private ChatRecordMapper chatRecordMapper;
@Override
public int insert(ChatRecord chatRecord) {
return chatRecordMapper.insert(chatRecord, remainder(chatRecord.getUserId()));
}
@Override
public int insertSelective(ChatRecord chatRecord) {
return chatRecordMapper.insertSelective(chatRecord, remainder(chatRecord.getUserId()));
}
@Override
public int updateById(ChatRecord chatRecord) {
return chatRecordMapper.updateById(chatRecord, remainder(chatRecord.getUserId()));
}
@Override
public int updateByIdSelective(ChatRecord chatRecord) {
return chatRecordMapper.updateByIdSelective(chatRecord, remainder(chatRecord.getUserId()));
}
@Override
public int updateReceiveTime(ChatRecord chatRecord) {
return chatRecordMapper.updateReceiveTime(chatRecord, remainder(chatRecord.getUserId()));
}
@Override
public ChatRecord selectById(Long id, Long userId) {
return chatRecordMapper.selectById(id, remainder(userId));
}
@Override
public MsgBody<PullChatRecord> getChatRecord(PullChatRecord pull) {
PageHelper.startPage(pull.getPageNum(), pull.getPageSize(), pull.getOrderBy() + " " + pull.getSorting());
final List<ChatRecord> chatRecords = chatRecordMapper.getChatRecord(pull, remainder(pull.getUserId()));
final PageInfo<ChatRecord> pageInfo = new PageInfo<>(chatRecords);
pull.setChatRecords(chatRecords);
pull.setPages(pageInfo.getPages());
pull.setTotal(pageInfo.getTotal());
return new MsgBody<>(ResultStatus.SUCCESS.getCode(), pull);
}
@Override
public MsgBody<List<ChatRecord>> updateReceiveTime(List<ChatRecord> chats) {
chatRecordMapper.updateBatchReceiveTimeById(chats, remainder(chats.get(0).getUserId()));
return new MsgBody<>(ResultStatus.SUCCESS.getCode(), chats);
}
/**
* 使用userId取聊天记录表数量余数
*
* @param userId 用户Id
* @return 余数
*/
private int remainder(long userId) {
return (int) (userId % NUMBER_OF_TABLE);
}
}
customer-service/src/main/java/com/ym/im/service/impl/MsgBodyServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.ym.im.entity.ChatRecord;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.NettyConstant;
import com.ym.im.factory.SingleChatFactory;
import com.ym.im.mq.Queue;
import com.ym.im.service.ChatService;
import com.ym.im.service.MsgBodyService;
import com.ym.im.util.JsonUtils;
import com.ym.im.validation.group.MsgBodyGroup;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
import static com.ym.im.entity.MsgBody.CHECK_MSG;
import static com.ym.im.entity.MsgBody.SEND_MSG;
/**
* @author 陈俊雄
* @date 2019/5/29
**/
@Slf4j
@Service
@Validated({MsgBodyGroup.class})
public class MsgBodyServiceImpl implements MsgBodyService {
@Autowired
private Queue queue;
@Autowired
private SingleChatFactory singleChatFactory;
@Resource(name = "myRedisTemplate")
private RedisTemplate redisTemplate;
@Override
public void msgBodyHandle(@NotNull ChannelHandlerContext ctx, @Valid MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
final ChatService chatService = singleChatFactory.getService(ctx.channel().attr(NettyConstant.TYPE).get());
switch (msgBody.getStatus()) {
case SEND_MSG:
// 获取用户、客服Id
final Long id = ctx.channel().attr(NettyConstant.ID).get();
// 先保存聊天消息
chatService.save(id, msgBody);
// 再发送回执
ctx.channel().writeAndFlush(msgBody.setStatus(CHECK_MSG)).addListener((ChannelFutureListener) future -> {
// 获取对应的channel
final NioSocketChannel channel = chatService.distribution(id, msgBody);
if (channel != null) {
// 最后发送聊天消息
chatService.send(channel, msgBody.setStatus(SEND_MSG));
}
});
break;
case CHECK_MSG:
msgBody.setStatus(MsgBody.HAVE_READ);//回执
chatService.ack(msgBody);
break;
default:
break;
}
}
@Override
public void sendAndAck(NioSocketChannel channel, MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
msgBody.setStatus(SEND_MSG);
// 先保存消息至Redis
redisTemplate.opsForHash().put(NettyConstant.MSG_KEY + msgBody.getData().getUserId(), msgBody.getData().getId(), JsonUtils.obj2Json(msgBody));
// 再默认以用户没有收到消息为前提，做循环、延迟通知
queue.delaysQueue(msgBody);
// 最后发送聊天信息
channel.writeAndFlush(msgBody);
}
}
customer-service/src/main/java/com/ym/im/service/impl/StaffServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.ym.im.entity.IdModel;
import com.ym.im.entity.MsgBody;
import com.ym.im.entity.StaffSocketInfo;
import com.ym.im.entity.UserSocketInfo;
import com.ym.im.entity.base.ResultStatus;
import com.ym.im.service.ChannelGroupService;
import com.ym.im.service.StaffService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.LinkedHashMap;
import java.util.List;
import static java.util.Map.Entry.comparingByValue;
import static java.util.stream.Collectors.toMap;
/**
* @author: JJww
* @Date:2019-05-22
*/
@Service
public class StaffServiceImpl implements StaffService {
@Override
public StaffSocketInfo getIdleStaff(Long userId) {
final LinkedHashMap<Long, StaffSocketInfo> collect = ChannelGroupService.STAFF_GROUP
.entrySet()
.stream()
.sorted(comparingByValue(new Comparator<StaffSocketInfo>() {
@Override
public int compare(StaffSocketInfo o1, StaffSocketInfo o2) {
return Integer.valueOf(o1.getUserIds().size()).compareTo(Integer.valueOf(o2.getUserIds().size()));
}
})).collect(toMap(e -> e.getKey(), e -> e.getValue(), (e1, e2) -> e2, LinkedHashMap::new));
if (collect.size() == 0) {
ChannelGroupService.USER_GROUP.get(userId).setStaffId(null);
return null;
}
//客服和用户绑定
StaffSocketInfo staffSocketInfo = collect.entrySet().iterator().next().getValue();
staffSocketInfo.getUserIds().add(userId);
Long staffId = staffSocketInfo.getStaffId();
//用户和客服绑定
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(userId);
if (userSocketInfo != null) {
userSocketInfo.setStaffId(staffId);
//通知用户 新的客服
userSocketInfo.getChannel().writeAndFlush(new MsgBody<>(MsgBody.DISTRIBUTION_STAFF, new IdModel(staffId, userId)));
}
return staffSocketInfo;
}
@Override
public MsgBody forward(IdModel idModel) {
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(idModel.getUserId());
final StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(idModel.getStaffId());
if (staffSocketInfo == null || userSocketInfo == null) {
return new MsgBody(ResultStatus.FORWARD_FAILURE.getCode(), ResultStatus.FORWARD_FAILURE.getMessage());
}
//移除原客服绑定
ChannelGroupService.STAFF_GROUP.get(userSocketInfo.getStaffId()).getUserIds().remove(idModel.getUserId());
//设置新的客服
staffSocketInfo.getUserIds().add(idModel.getUserId());
userSocketInfo.setStaffId(idModel.getStaffId());
final MsgBody<IdModel> msgBody = new MsgBody<>(MsgBody.DISTRIBUTION_STAFF, idModel);
//通知用户 新客服ID
userSocketInfo.getChannel().writeAndFlush(msgBody);
//通知新客服
staffSocketInfo.getChannel().writeAndFlush(msgBody);
return new MsgBody(ResultStatus.SUCCESS.getCode());
}
@Override
public MsgBody getStaffList() {
List<StaffSocketInfo> staffs = new ArrayList();
ChannelGroupService.STAFF_GROUP.forEach((k, v) -> {
staffs.add(v);
});
return new MsgBody(ResultStatus.SUCCESS.getCode(), staffs);
}
}
customer-service/src/main/java/com/ym/im/service/impl/StaffSingleChatServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.ym.im.entity.*;
import com.ym.im.entity.model.PushTokenAndTypeModel;
import com.ym.im.mq.Queue;
import com.ym.im.service.ChannelGroupService;
import com.ym.im.service.ChatRecordService;
import com.ym.im.service.ChatService;
import com.ym.im.service.MsgBodyService;
import com.ym.im.util.JsonUtils;
import com.ym.im.validation.group.*;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import static com.ym.im.entity.ChatRecord.RECEIVE;
/**
* @author: JJww
* @Date:2019-05-21
*/
@Slf4j
@Service
@Validated
public class StaffSingleChatServiceImpl implements ChatService {
@Autowired
private Queue queue;
@Resource(name = "myRedisTemplate")
private RedisTemplate redisTemplate;
@Autowired
private ChatRecordService chatRecordService;
@Autowired
private MsgBodyService msgBodyService;
// @Autowired
// private PushGatherService pushService;
@Override
public void init(ChannelHandlerContext ctx) {
ctx.channel().attr(NettyConstant.TYPE).set(NettyConstant.CONNECT_TYPE_STAFF);
final Long staffId = ctx.channel().attr(NettyConstant.ID).get();
StaffSocketInfo staffSocketInfo = new StaffSocketInfo();
staffSocketInfo.setStaffId(staffId);
staffSocketInfo.setToken(ctx.channel().attr(NettyConstant.TOKEN_INFO).get());
staffSocketInfo.setChannel((NioSocketChannel) ctx.channel());
staffSocketInfo.setUserIds(redisTemplate.opsForSet().members(NettyConstant.STAFF_USERIDS_KEY + staffId));
ChannelGroupService.STAFF_GROUP.put(staffId, staffSocketInfo);
log.info("客服: " + staffId + " 上线:");
}
@Override
public void offline(ChannelHandlerContext ctx) {
final Long staffId = ctx.channel().attr(NettyConstant.ID).get();
final StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(staffId);
if (ctx.channel().attr(NettyConstant.TOKEN_INFO).get().equals(staffSocketInfo.getToken())) {
final Set<Long> userIds = staffSocketInfo.getUserIds();
if (userIds.size() != 0) {
final String userListKey = NettyConstant.STAFF_USERIDS_KEY + staffId;
redisTemplate.delete(userListKey);
redisTemplate.opsForSet().add(userListKey, userIds.toArray(new Long[userIds.size()]));
queue.staffOfflineQueue(new StaffSocketInfo(staffId, userIds)); //NioSocketChannel无法序列化 所以new StaffSocketInfo
}
ChannelGroupService.STAFF_GROUP.remove(staffId);
ctx.channel().close();
log.info("客服: " + staffId + " 下线:");
}
}
@Override
@Validated({MsgBodyGroup.class, ChatRecordSendGroup.class, StaffSendGroup.class})
public NioSocketChannel distribution(Long id, @Valid MsgBody<ChatRecord> msgBody) {
final Long userId = msgBody.getData().getUserId();
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(userId);
if (userSocketInfo == null) {
//用户不在线,保存最后发送消息的客服ID
redisTemplate.opsForHash().put(NettyConstant.IM_USERS, userId, id);
//推送通知
pushNotifications(userId);
return null;
}
final Long currentStaffId = userSocketInfo.getStaffId();
if (currentStaffId == null) {
//通知用户 新的客服
userSocketInfo.setStaffId(id);
userSocketInfo.getChannel().writeAndFlush(new MsgBody<>(MsgBody.DISTRIBUTION_STAFF, new IdModel(id, userId)));
ChannelGroupService.STAFF_GROUP.get(id).getUserIds().add(userId);
}
if (currentStaffId != null && !currentStaffId.equals(id)) {
//通知客服 绑定失败 当前用户已绑定客服
ChannelGroupService.STAFF_GROUP.get(id).getChannel().writeAndFlush(new MsgBody<>(MsgBody.BINDINGFAILURE, new IdModel(currentStaffId, userId)));
return null;
}
return userSocketInfo.getChannel();
}
@Override
@Validated({MsgBodyGroup.class, ChatRecordSendGroup.class, StaffSendGroup.class})
public void save(Long id, @Valid MsgBody<ChatRecord> msgBody) {
// 设置聊天基本信息
final ChatRecord record = msgBody.getData();
record.setId(null);
record.setSendReceive(RECEIVE);
record.setStaffId(id);
record.setCreateTime(new Date());
// 先保存至数据库，再发送消息（若颠倒顺序可能导致数据未保存，更新已读操作先执行导致消息一直是未读状态
chatRecordService.insertSelective(record);
log.info("客服 消息保存:" + record.getId());
}
/**
* 发送消息至用户端
*
* @param msgBody 消息对象
* @throws JsonProcessingException e
*/
@Override
public void send(NioSocketChannel channel, MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
msgBodyService.sendAndAck(channel, msgBody);
pushNotifications(msgBody.getData().getUserId());
}
/**
* 通知用户端客服端收到消息
*
* @param msgBody 消息对象
* @throws JsonProcessingException e
*/
@Override
@Validated({MsgBodyGroup.class, ChatRecordReceiveGroup.class, ChatRecordSaveGroup.class})
public void ack(@Valid MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
final ChatRecord record = msgBody.getData();
record.setModifyTime(new Date());
chatRecordService.updateReceiveTime(record);
UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(record.getUserId());
if (userSocketInfo != null) {
userSocketInfo.getChannel().writeAndFlush(msgBody);
redisTemplate.opsForHash().put(NettyConstant.MSG_KEY + record.getUserId(), record.getId(), JsonUtils.obj2Json(msgBody));
}
log.info("客服 消息回执:" + record.getId());
}
/**
* 推送通知
*
* @param userId
*/
private void pushNotifications(Long userId) {
// String title = null;
// String content = null;
// final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(userId);
// PushTokenAndTypeModel pushToken = userSocketInfo != null ? userSocketInfo.getPushToken() : feignClientUsersService.getPushToken(String.valueOf(userId)).getData();
// final String col = userSocketInfo == null ? LanguageEnum.zh.getKey() : userSocketInfo.getCol();
// if (LanguageEnum.zh.getKey().equals(col)) {
// title = PushTitleEnum.customerService.getName();
// content = PushContentEnum.sndmsg.getName();
// } else {
// title = PushTitleEnum.customerService.getNameEnglish();
// content = PushContentEnum.sndmsg.getNameEnglish();
// }
// Map customBoundary = new HashMap<>();
// customBoundary.put("pushType", PushTypeEnum.customerServicePush.getKey());
// pushService.pushTokenGather(pushToken.getPushToken(), pushToken.getPushType(), title, content, customBoundary);
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/service/impl/UserServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.ym.im.entity.*;
import com.ym.im.entity.base.ResultStatus;
import com.ym.im.service.ChannelGroupService;
import com.ym.im.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Set;
/**
* @author: JJww
* @Date:2019-07-24
*/
@Slf4j
@Service
public class UserServiceImpl implements UserService {
@Resource(name = "myRedisTemplate")
private RedisTemplate redisTemplate;
@Override
public MsgBody getUserList(Long staffId) {
final Set usersId = redisTemplate.opsForSet().members(NettyConstant.STAFF_USERIDS_KEY + staffId);
if (usersId.size() > 0) {
redisTemplate.delete(NettyConstant.STAFF_USERIDS_KEY + staffId);
}
return new MsgBody(ResultStatus.SUCCESS.getCode(), usersId);
}
@Override
public MsgBody deleteUserFromList(IdModel idModel) {
final StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(idModel.getStaffId());
if (staffSocketInfo == null) {
return new MsgBody(ResultStatus.REQUEST_ERROR.getCode(), ResultStatus.REQUEST_ERROR.getMessage());
}
staffSocketInfo.getUserIds().remove(idModel.getUserId());
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(idModel.getUserId());
if (userSocketInfo != null && idModel.getStaffId().equals(userSocketInfo.getStaffId())) {
userSocketInfo.setStaffId(null);
}
return new MsgBody(ResultStatus.SUCCESS.getCode());
}
@Override
public MsgBody checkBinding(IdModel idModel) {
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(idModel.getUserId());
/**
* 用户不在线 不校验绑定关系
* 用户在线,只有绑定的客服才能发送消息
* 用户在线未绑定客服
*/
if (userSocketInfo == null || (userSocketInfo != null && idModel.getStaffId().equals(userSocketInfo.getStaffId()) || userSocketInfo.getStaffId() == null)) {
return new MsgBody(ResultStatus.SUCCESS.getCode());
}
return new MsgBody(ResultStatus.CHECK_FAILURE.getCode(), userSocketInfo.getStaffId());
}
}
\ No newline at end of file
customer-service/src/main/java/com/ym/im/service/impl/UserSingleChatServiceImpl.java 0 → 100644
package com.ym.im.service.impl;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.ym.im.entity.*;
import com.ym.im.service.*;
import com.ym.im.util.JsonUtils;
import com.ym.im.validation.group.ChatRecordReceiveGroup;
import com.ym.im.validation.group.ChatRecordSaveGroup;
import com.ym.im.validation.group.ChatRecordSendGroup;
import com.ym.im.validation.group.MsgBodyGroup;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.Date;
import java.util.Set;
import static com.ym.im.entity.ChatRecord.SEND;
/**
* @author: JJww
* @Date:2019-05-21
*/
@Slf4j
@Service
@Validated
public class UserSingleChatServiceImpl implements ChatService {
@Resource(name = "myRedisTemplate")
private RedisTemplate redisTemplate;
@Autowired
private StaffService staffService;
@Autowired
private ChatRecordService chatRecordService;
@Autowired
private MsgBodyService msgBodyService;
@Override
public void init(ChannelHandlerContext ctx) {
ctx.channel().attr(NettyConstant.TYPE).set(NettyConstant.CONNECT_TYPE_USER);
final Long userId = ctx.channel().attr(NettyConstant.ID).get();
UserSocketInfo userSocketInfo = new UserSocketInfo();
userSocketInfo.setUserId(userId);
userSocketInfo.setChannel((NioSocketChannel) ctx.channel());
userSocketInfo.setCol(ctx.channel().attr(NettyConstant.COL_INFO).get());
userSocketInfo.setToken(ctx.channel().attr(NettyConstant.TOKEN_INFO).get());
userSocketInfo.setPushToken(null);
ChannelGroupService.USER_GROUP.put(userId, userSocketInfo);
//恢复历史绑定关系
restoreBindingRelationship(userId);
//通知客服 用户上线
broadcastUserOnline(userId);
log.info("用户: " + userId + " 上线");
}
@Override
public void offline(ChannelHandlerContext ctx) {
final Long userId = ctx.channel().attr(NettyConstant.ID).get();
final UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(userId);
if (userSocketInfo != null && ctx.channel().attr(NettyConstant.TOKEN_INFO).get().equals(userSocketInfo.getToken())) {
final Long staffId = userSocketInfo.getStaffId();
ChannelGroupService.USER_GROUP.remove(userId);
ctx.channel().close();
if (staffId != null && ChannelGroupService.STAFF_GROUP.get(staffId) != null) {
// 保存最后的客服
redisTemplate.opsForHash().put(NettyConstant.IM_USERS, userId, staffId);
}
log.info("用户: " + userId + " 下线");
}
}
@Override
@Validated({MsgBodyGroup.class, ChatRecordSendGroup.class})
public NioSocketChannel distribution(Long id, @Valid MsgBody<ChatRecord> msgBody) {
// 获取服务用户的客服Id
Long staffId = ChannelGroupService.USER_GROUP.get(id).getStaffId();
// 客服SocketInfo对象
StaffSocketInfo staffSocketInfo;
// 若客服Id为空，分配客服，不为空则获取客服SocketInfo
if (staffId == null) {
staffSocketInfo = staffService.getIdleStaff(id);
if (staffSocketInfo == null) {
return null;
}
} else {
// 根据客服id获取SocketInfo
staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(staffId);
// 服务用户的客服不在线
if (staffSocketInfo == null) {
// Redis是否存在当前客服服务用户Set对象（TTL=60秒）
Set members = redisTemplate.opsForSet().members(NettyConstant.STAFF_USERIDS_KEY + staffId);
// 客服下线超过60秒，当前客服服务用户Set对象已过期，重新分配客服
// 过期后set对象不会为空而是大小为0
if (members.size() == 0) {
staffSocketInfo = staffService.getIdleStaff(id);
}
return null;
} else {
/*
* 解决客服下线超过一分钟后再上线收到下线前服务的用户（用户没有再分配新客服情况）发来的消息，
* 客服无法回复用户的问题，
* 无论该用户Id是否存在于客服服务用户Set内，都向Set添加用户ID
*/
staffSocketInfo.getUserIds().add(id);
}
}
return staffSocketInfo.getChannel();
}
@Override
@Validated({MsgBodyGroup.class, ChatRecordSendGroup.class})
public void save(Long id, @Valid MsgBody<ChatRecord> msgBody) {
// 设置聊天基本信息
final ChatRecord record = msgBody.getData();
record.setId(null);
record.setUserId(id);
record.setSendReceive(SEND);
record.setCreateTime(new Date());
/*
* 设置客服Id：
* 情况1：当前用户无客服服务，且无客服可分配，ChatRecord.staffId = null;
* 情况2：当前用户无客服服务，且有客服可分配，ChatRecord.staffId = StaffSocketInfo.id;
* 情况3：当前用户有客服服务，且客服在线，ChatRecord.staffId = StaffSocketInfo.id;
* 情况3：当前用户有客服服务，且客服已下线并不超过60秒，CharRecord.staffId = staffId;
* 情况4：当前用户有客服服务，且客服已下线并超过60秒，重新分配客服且有客服可分配，ChatRecord.staffId = StaffSocketInfo.id;
* 情况5（特殊：需求未定暂时这样处理）：当前用户有客服服务，且客服已下线并超过60秒，重新分配客服且无客服可分配，ChatRecord.staffId = staffId;
*/
record.setStaffId(ChannelGroupService.USER_GROUP.get(id).getStaffId());
// 先保存至数据库，再发送消息（若颠倒顺序可能导致数据未保存，更新已读操作先执行导致消息一直是未读状态）
chatRecordService.insertSelective(record);
log.info("用户 消息保存:" + record.getId());
}
/**
* 发送消息至客服端
*
* @param msgBody 消息对象
* @throws JsonProcessingException e
*/
@Override
public void send(NioSocketChannel channel, MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
msgBodyService.sendAndAck(channel, msgBody);
}
@Override
@Validated({MsgBodyGroup.class, ChatRecordReceiveGroup.class, ChatRecordSaveGroup.class})
public void ack(@Valid MsgBody<ChatRecord> msgBody) throws JsonProcessingException {
final ChatRecord record = msgBody.getData();
record.setModifyTime(new Date());
chatRecordService.updateReceiveTime(record);
UserSocketInfo userSocketInfo = ChannelGroupService.USER_GROUP.get(record.getUserId());
if (userSocketInfo != null) {
userSocketInfo.setStaffId(userSocketInfo.getStaffId() == null ? record.getStaffId() : userSocketInfo.getStaffId());
StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(userSocketInfo.getStaffId());
if (staffSocketInfo != null) {
staffSocketInfo.getChannel().writeAndFlush(msgBody);
}
redisTemplate.opsForHash().put(NettyConstant.MSG_KEY + record.getUserId(), record.getId(), JsonUtils.obj2Json(msgBody));
}
log.info("用户 回执:" + record.getId());
}
/**
* 恢复历史绑定关系
*
* @param userId
*/
private void restoreBindingRelationship(Long userId) {
if (redisTemplate.opsForHash().hasKey(NettyConstant.IM_USERS, userId)) {
final Long staffId = (Long) redisTemplate.opsForHash().get(NettyConstant.IM_USERS, userId);
final StaffSocketInfo staffSocketInfo = ChannelGroupService.STAFF_GROUP.get(staffId);
if (staffSocketInfo != null) {
ChannelGroupService.USER_GROUP.get(userId).setStaffId(staffId);
staffSocketInfo.getUserIds().add(userId);
}
}
}
/**
* 广播用户上线信息 并移除对应Set
*
* @param userId
*/
private void broadcastUserOnline(Long userId) {
final Long staffId = ChannelGroupService.USER_GROUP.get(userId).getStaffId();
ChannelGroupService.STAFF_GROUP.forEach((key, staffSocketInfo) -> {
staffSocketInfo.getUserIds().remove(userId);
staffSocketInfo.getChannel().writeAndFlush(new MsgBody<>(MsgBody.USERS_ONLINE, new IdModel(staffId, userId)));
});
}
}
customer-service/src/main/java/com/ym/im/util/Assert.java 0 → 100644
package com.ym.im.util;
import com.ym.im.exception.IMessageException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.lang.Nullable;
/**
* @author 陈俊雄
* @date 2019/5/29
**/
@Slf4j
public abstract class Assert {
public static void notNull(@Nullable Object object, String i18nError) {
if (object == null) {
throw new IMessageException(i18nError);
}
}
}
customer-service/src/main/java/com/ym/im/util/JsonUtils.java 0 → 100644
package com.ym.im.util;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.type.TypeFactory;
import java.io.IOException;
import java.lang.reflect.Type;
import java.util.HashMap;
import java.util.List;
/**
* Json对象操作工具
*
* @author 陈俊雄
**/
public class JsonUtils {
private static ObjectMapper MAPPER = new ObjectMapper()
// 忽略Json对象在实体类中没有的字段
.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
public static void setObjectMapper(ObjectMapper objectMapper) {
MAPPER = objectMapper;
}
/**
* 实体类转json字符串
*
* @param obj obj
* @return jsonStr
* @throws JsonProcessingException e
*/
public static String obj2Json(Object obj) throws JsonProcessingException {
return MAPPER.writeValueAsString(obj);
}
/**
* 实体类转json字符串，并忽略实体类为空的字段
*
* @param obj obj
* @return jsonStr
* @throws JsonProcessingException e
*/
public static String obj2JsonNonNull(Object obj) throws JsonProcessingException {
MAPPER.setSerializationInclusion(JsonInclude.Include.NON_NULL);
return MAPPER.writeValueAsString(obj);
}
/**
* json字符串转实体类
*
* @param jsonData jsonStr
* @param beanType Class
* @param <T> T
* @return T
* @throws IOException e
*/
public static <T> T json2Obj(String jsonData, Class<T> beanType) throws IOException {
return MAPPER.readValue(jsonData, beanType);
}
/**
* json字符串转实体类
*
* @param jsonData jsonStr
* @param javaType javaType可通过{@link #getJavaType}获取
* @param <T> T
* @return T
* @throws IOException e
*/
public static <T> T json2Obj(String jsonData, JavaType javaType) throws IOException {
return MAPPER.readValue(jsonData, javaType);
}
/**
* json字符串转实体类
* {@link #getJavaType(Class, JavaType...)}
*
* @param jsonData jsonStr
* @param parametrized class
* @param parameterClasses class[]
* @param <T> T
* @return T
* @throws IOException e
*/
public static <T> T json2Obj(String jsonData, Class<?> parametrized, Class<?>... parameterClasses) throws IOException {
return MAPPER.readValue(jsonData, getJavaType(parametrized, parameterClasses));
}
/**
* 获取JavaType
* 如：JsonUtils.getJavaType(String.class);
*
* @param type class
* @return {@link JavaType}
*/
public static JavaType getJavaType(Type type) {
return MAPPER.getTypeFactory().constructType(type);
}
/**
* 获取JavaType，常用于复杂对象
* 如json转Map<String, Long>：
* JsonUtils.getJavaType(Map.class, String.class, Long.class);
* 更复杂的对象则是对上面示例进行嵌套，泛型同理
* 如json转Map<String, Map<Long, List<Integer>>：
* 首先使用{@link #getJavaType(Class, Class[])}获取List<Integer>的javaType
* JavaType listType = JsonUtils.getJavaType(List.class, Integer.class);
* 其次使用{@link #getJavaType(Class, JavaType...)}来创建Map的javaType
* JavaType mapType = JsonUtils.getJavaType(Map.class, listType);
* 最后使用{@link #json2Obj(String, JavaType)}将json字符串转换成map对象
* Map<String, Map<Long, List<Integer>> map = JsonUtils.json2Obj(jsonStr, mapType);
*
* @param parametrized class
* @param parameterClasses class[]
* @return {@link JavaType}
*/
public static JavaType getJavaType(Class<?> parametrized, Class<?>... parameterClasses) {
return MAPPER.getTypeFactory().constructParametricType(parametrized, parameterClasses);
}
/**
* 获取JavaType，常用于复杂对象
* 参考{@link #getJavaType(Class, Class[])}
*
* @param rawType class
* @param parameterTypes javaType[]
* @return {@link JavaType}
*/
public static JavaType getJavaType(Class<?> rawType, JavaType... parameterTypes) {
return MAPPER.getTypeFactory().constructParametricType(rawType, parameterTypes);
}
/**
* json字符串转Map
*
* @param jsonData jsonStr
* @param k key
* @param v value
* @param <K> key class
* @param <V> value class
* @return map
* @throws IOException e
*/
public static <K, V> HashMap<K, V> json2HashMap(String jsonData, Class<K> k, Class<V> v) throws IOException {
return MAPPER.readValue(jsonData, TypeFactory.defaultInstance().constructMapType(HashMap.class, k, v));
}
/**
* json字符串转list
*
* @param jsonData jsonStr
* @param t class
* @param <T> T
* @return list
* @throws IOException e
*/
public static <T> List<T> json2List(String jsonData, Class<T> t) throws IOException {
return MAPPER.readValue(jsonData, TypeFactory.defaultInstance().constructCollectionType(List.class, t));
}
/**
* map等对象转实体类，通过映射方式
*
* @param obj obj
* @param beanType class
* @param <T> T
* @return T
*/
public static <T> T obj2Class(Object obj, Class<T> beanType) {
return MAPPER.convertValue(obj, beanType);
}
}
customer-service/src/main/java/com/ym/im/util/MessageUtils.java 0 → 100644
package com.ym.im.util;
import org.springframework.context.MessageSource;
import java.util.Locale;
/**
* @author 陈俊雄
* @date 2019/6/3
**/
public class MessageUtils {
public static MessageSource messageSource;
public static void setMessageSource(MessageSource ms) {
messageSource = ms;
}
public MessageSource getMessageSource() {
return messageSource;
}
public static String getMsg(String code, Object[] args, Locale locale) {
return messageSource.getMessage(code, args, locale);
}
public static String getMsg(String code, Locale locale, Object... args) {
return messageSource.getMessage(code, args, locale);
}
public static String getMsg(String code, Object[] args, String locale) {
return messageSource.getMessage(code, args, new Locale(locale));
}
public static String getMsg(String code, Object[] args) {
return messageSource.getMessage(code, args, Locale.getDefault());
}
public static String getMsg(String code, Locale locale) {
return messageSource.getMessage(code, null, locale);
}
public static String getMsg(String code, String locale) {
return messageSource.getMessage(code, null, new Locale(locale));
}
public static String getMsg(String code) {
return messageSource.getMessage(code, null, Locale.getDefault());
}
}
customer-service/src/main/java/com/ym/im/util/MybatisGenerator.java 0 → 100644
//package com.ym.im.util;
//
//import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
//import com.baomidou.mybatisplus.core.toolkit.StringPool;
//import com.baomidou.mybatisplus.generator.AutoGenerator;
//import com.baomidou.mybatisplus.generator.InjectionConfig;
//import com.baomidou.mybatisplus.generator.config.*;
//import com.baomidou.mybatisplus.generator.config.po.TableInfo;
//import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
//import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
//import com.ym.util.StringUtils;
//
//import java.util.ArrayList;
//import java.util.List;
//import java.util.Scanner;
//
///**
// * 自动生成代码
// */
//public class MybatisGenerator {
//
//
// /**
// * <p>
// * 读取控制台内容
// * </p>
// */
// public static String scanner(String tip) {
// Scanner scanner = new Scanner(System.in);
// StringBuilder help = new StringBuilder();
// help.append("请输入" + tip + "：");
// System.out.println(help.toString());
// if (scanner.hasNext()) {
// String ipt = scanner.next();
// if (StringUtils.isNotEmpty(ipt)) {
// return ipt;
// }
// }
// throw new MybatisPlusException("请输入正确的" + tip + "！");
// }
//
// public static void main(String[] args) {
// // 代码生成器
// AutoGenerator mpg = new AutoGenerator();
//
// // 全局配置
// GlobalConfig gc = new GlobalConfig();
//
// //项目工程路径
// String projectPath = "D:\\JavaDevelopment\\IdeaProjects\\pathfinder\\pathfinder_im";
// //java代码路径
// gc.setOutputDir(projectPath + "/src/main/java/com/ym/im");
//
// gc.setAuthor("陈俊雄");
// gc.setOpen(false);
// mpg.setGlobalConfig(gc);
//
// // 数据源配置
// DataSourceConfig dsc = new DataSourceConfig();
// dsc.setUrl("jdbc:mysql://192.168.1.83:3306/pathfinder_im?useUnicode=true&useSSL=false&characterEncoding=utf-8");
// // dsc.setSchemaName("public");
// dsc.setDriverName("com.mysql.cj.jdbc.Driver");
// dsc.setUsername("root");
// dsc.setPassword("123456");
// mpg.setDataSource(dsc);
//
//
// // 包配置
// PackageConfig pc = new PackageConfig();
//// pc.setModuleName(scanner("模块名"));
// pc.setParent("com.ym.im");
// mpg.setPackageInfo(pc);
//
// // 自定义配置
// InjectionConfig cfg = new InjectionConfig() {
// @Override
// public void initMap() {
// // to do nothing
// }
// };
//
// // 如果模板引擎是 freemarker
// String templatePath = "/templates/mapper.xml.ftl";
// // 如果模板引擎是 velocity
// // String templatePath = "/templates/mapping.xml.vm";
//
// // 自定义输出配置
// List<FileOutConfig> focList = new ArrayList<>();
// // 自定义配置会被优先输出
// focList.add(new FileOutConfig(templatePath) {
// @Override
// public String outputFile(TableInfo tableInfo) {
// // 自定义输出文件名
// return projectPath + "/src/main/resources/com/ym/im/mapping/" //+ pc.getModuleName() + "/"
// + tableInfo.getEntityName() + "Mapping" + StringPool.DOT_XML;
// }
// });
//
// cfg.setFileOutConfigList(focList);
// mpg.setCfg(cfg);
//
// // 配置模板
// TemplateConfig templateConfig = new TemplateConfig();
//
// // 配置自定义输出模板
// // templateConfig.setEntity();
// // templateConfig.setService();
// // templateConfig.setController();
//
// templateConfig.setXml(null);
// mpg.setTemplate(templateConfig);
//
// // 策略配置
// StrategyConfig strategy = new StrategyConfig();
// strategy.setNaming(NamingStrategy.underline_to_camel);
// strategy.setColumnNaming(NamingStrategy.underline_to_camel);
//// strategy.setSuperEntityClass("com.ym.entity");
// strategy.setEntityLombokModel(true);
// strategy.setRestControllerStyle(true);
//// strategy.setSuperControllerClass("com.ym.controller");
//
//
// strategy.setInclude(scanner("表名"));
//// strategy.setSuperEntityColumns("id");
// strategy.setControllerMappingHyphenStyle(true);
//// strategy.setTablePrefix(pc.getModuleName() + "_");
// mpg.setStrategy(strategy);
// mpg.setTemplateEngine(new FreemarkerTemplateEngine());
// mpg.execute();
// }
//
//
//}
customer-service/src/main/java/com/ym/im/validation/group/ChatRecordReceiveGroup.java 0 → 100644
package com.ym.im.validation.group;
/**
* @author 陈俊雄
* @date 2019/6/11
**/
public interface ChatRecordReceiveGroup {
}
customer-service/src/main/java/com/ym/im/validation/group/ChatRecordSaveGroup.java 0 → 100644
package com.ym.im.validation.group;
/**
* @author 陈俊雄
* @date 2019/6/11
**/
public interface ChatRecordSaveGroup {
}
customer-service/src/main/java/com/ym/im/validation/group/ChatRecordSendGroup.java 0 → 100644
package com.ym.im.validation.group;
/**
* @author 陈俊雄
* @date 2019/6/11
**/
public interface ChatRecordSendGroup {
}
customer-service/src/main/java/com/ym/im/validation/group/MsgBodyGroup.java 0 → 100644
package com.ym.im.validation.group;
/**
* @author 陈俊雄
* @date 2019/6/11
**/
public interface MsgBodyGroup {
}
customer-service/src/main/java/com/ym/im/validation/group/StaffSendGroup.java 0 → 100644
package com.ym.im.validation.group;
/**
* @author 陈俊雄
* @date 2019/6/12
**/
public interface StaffSendGroup {
}
customer-service/src/main/resources/application-dev.yml 0 → 100644
---
#开发环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://47.99.47.225:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: temple123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 127.0.0.1
port: 5672
username: admin
password: admin
delay-queue-name: delay.ack.dev
staff-offline-Queue-Name: staff.offline.dev
exchange-name: delay.exchange.dev
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 127.0.0.1
password:
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
customer-service/src/main/resources/application-prd.yml 0 → 100644
---
#生产环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://172.31.33.14:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: Yum123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 172.31.33.14
port: 5672
username: admin
password: Yum123456
delay-queue-name: delay.ack
staff-offline-Queue-Name: staff.offline
exchange-name: delayAck
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 172.31.33.14
password: Yum123456
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
#日志配置
logging:
file: logs/${spring.application.name}.log
eureka:
client:
service-url:
defaultZone: http://172.31.41.108:20000/eureka/
instance:
prefer-ip-address: true
\ No newline at end of file
customer-service/src/main/resources/application-test.yml 0 → 100644
---
#开发环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://192.168.1.237:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 127.0.0.1
port: 5672
username: admin
password: admin
delay-queue-name: delay.ack.dev
staff-offline-Queue-Name: staff.offline.dev
exchange-name: delay.exchange.dev
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 127.0.0.1
password:
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
customer-service/src/main/resources/application.yml 0 → 100644
spring:
profiles:
active: @profiles.active@
application:
name: pathfinder-im
# 404抛出异常
mvc:
throw-exception-if-no-handler-found: true
resources:
add-mappings: false
server:
port: 20002
# 关闭tomcat自带/error页面
error:
whitelabel:
enabled: false
netty:
port: 9095
#日志配置
logging:
level:
root: info
com.ym.im.mapper: debug
pagehelper:
helper-dialect: mysql
reasonable: true
support-methods-arguments: ture
params: count=contSql
customer-service/src/main/resources/com/ym/im/mapper/ChatRecordMapper.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ym.im.mapper.ChatRecordMapper">
<resultMap id="BaseResultMap" type="com.ym.im.entity.ChatRecord">
<id column="id" jdbcType="BIGINT" property="id"/>
<result column="user_id" jdbcType="BIGINT" property="userId"/>
<result column="staff_id" jdbcType="BIGINT" property="staffId"/>
<result column="msg_type" jdbcType="TINYINT" property="msgType"/>
<result column="msg_info" jdbcType="VARCHAR" property="msgInfo"/>
<result column="send_receive" jdbcType="TINYINT" property="sendReceive"/>
<result column="scope" jdbcType="TINYINT" property="scope"/>
<result column="send_time" jdbcType="TIMESTAMP" property="sendTime"/>
<result column="receive_time" jdbcType="TIMESTAMP" property="receiveTime"/>
<result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
<result column="modify_time" jdbcType="TIMESTAMP" property="modifyTime"/>
</resultMap>
<sql id="Base_Column_List">
id, user_id, staff_id, msg_type, msg_info, send_receive, scope, send_time, receive_time, create_time, modify_time
</sql>
<insert id="insert">
INSERT INTO chat_record_${index} (<include refid="Base_Column_List"/>)
VALUES (
#{chat.id},
#{chat.userId},
#{chat.staffId},
#{chat.msgType},
#{chat.msgInfo},
#{chat.sendReceive},
#{chat.scope},
#{chat.sendTime},
#{chat.receiveTime},
#{chat.createTime},
#{chat.modifyTime})
</insert>
<insert id="insertSelective">
INSERT INTO chat_record_${index}
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="chat.id != null">
id,
</if>
<if test="chat.userId != null">
user_id,
</if>
<if test="chat.staffId != null">
staff_id,
</if>
<if test="chat.msgType != null">
msg_type,
</if>
<if test="chat.msgInfo != null">
msg_info,
</if>
<if test="chat.sendReceive != null">
send_receive,
</if>
<if test="chat.scope != null">
scope,
</if>
<if test="chat.sendTime != null">
send_time,
</if>
<if test="chat.receiveTime != null">
receive_time,
</if>
<if test="chat.createTime != null">
create_time,
</if>
<if test="chat.modifyTime != null">
modify_time,
</if>
</trim>
<trim prefix="VALUES (" suffix=")" suffixOverrides=",">
<if test="chat.id != null">
#{chat.id},
</if>
<if test="chat.userId != null">
#{chat.userId},
</if>
<if test="chat.staffId != null">
#{chat.staffId},
</if>
<if test="chat.msgType != null">
#{chat.msgType},
</if>
<if test="chat.msgInfo != null">
#{chat.msgInfo},
</if>
<if test="chat.sendReceive != null">
#{chat.sendReceive},
</if>
<if test="chat.scope != null">
#{chat.scope},
</if>
<if test="chat.sendTime != null">
#{chat.sendTime},
</if>
<if test="chat.receiveTime != null">
#{chat.receiveTime},
</if>
<if test="chat.createTime != null">
#{chat.createTime},
</if>
<if test="chat.modifyTime != null">
#{chat.modifyTime},
</if>
</trim>
</insert>
<update id="updateById">
UPDATE chat_record_${index}
SET user_id = #{chat.userId},
staff_id = #{chat.staffId},
msg_type = #{chat.msgType},
msg_info = #{chat.msgInfo},
send_receive = #{chat.sendReceive},
scope = #{chat.scope},
send_time = #{chat.sendTime},
receive_time = #{chat.receiveTime},
create_time = #{chat.createTime},
modify_time = #{chat.modifyTime}
WHERE id = #{chat.id}
</update>
<update id="updateByIdSelective">
UPDATE chat_record_${index}
<set>
<if test="chat.id != null">
#{chat.id}
</if>
<if test="chat.userId != null">
#{chat.userId}
</if>
<if test="chat.staffId != null">
#{chat.staffId}
</if>
<if test="chat.msgType != null">
#{chat.msgType}
</if>
<if test="chat.msgInfo != null">
#{chat.msgInfo}
</if>
<if test="chat.sendReceive != null">
#{chat.sendReceive}
</if>
<if test="chat.scope != null">
#{chat.scope}
</if>
<if test="chat.sendTime != null">
#{chat.sendTime}
</if>
<if test="chat.receiveTime != null">
#{chat.receiveTime}
</if>
<if test="chat.createTime != null">
#{chat.createTime}
</if>
<if test="chat.modifyTime != null">
#{chat.modifyTime}
</if>
</set>
</update>
<update id="updateBatchReceiveTimeById">
UPDATE chat_record_${index}
<set>
receive_time =
<foreach collection="chats" item="chat" index="index" separator=" " open="CASE" close="END">
WHEN id = #{chat.id} THEN #{chat.receiveTime}
</foreach>
</set>
WHERE id IN
<foreach collection="chats" item="chat" index="index" separator="," open="(" close=")">
#{chat.id}
</foreach>
</update>
<update id="updateReceiveTime">
UPDATE chat_record_${index}
<set>
receive_time = #{chat.receiveTime},
modify_time = #{chat.modifyTime}
</set>
WHERE id = #{chat.id}
</update>
<select id="selectById" resultType="com.ym.im.entity.ChatRecord">
SELECT
<include refid="Base_Column_List"/>
FROM chat_record_${index} WHERE id = #{id}
</select>
<select id="getChatRecord" resultType="com.ym.im.entity.ChatRecord">
SELECT
<include refid="Base_Column_List"/>
FROM chat_record_${index}
<trim prefix="WHERE" suffixOverrides="AND">
<if test="pull.userId != null">
user_id = #{pull.userId} AND
</if>
<if test="pull.direction == 'forward' and pull.chatRecordId != null">
--id小于传入id
id &lt; #{pull.chatRecordId}
</if>
<if test="pull.direction == 'backward' and pull.chatRecordId != null">
--id大于传入id
id &gt; #{pull.chatRecordId}
</if>
</trim>
</select>
</mapper>
customer-service/src/main/resources/rebel.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<!--
This is the JRebel configuration file. It maps the running application to your IDE workspace, enabling JRebel reloading for this project.
Refer to https://manuals.zeroturnaround.com/jrebel/standalone/config.html for more information.
-->
<application generated-by="intellij" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.zeroturnaround.com" xsi:schemaLocation="http://www.zeroturnaround.com http://update.zeroturnaround.com/jrebel/rebel-2_1.xsd">
<classpath>
<dir name="/Users/JJww/Documents/Workspaces/pathfinder/pathfinder_im/target/classes">
</dir>
</classpath>
</application>
customer-service/src/main/resources/static/i18n/error_en.properties 0 → 100644
error.top_level_error=Please contact the developer!
error.bad_parameter=Bad parameter!
error.chat_id_direction=Direction can only be forward or backward, and ignore case!
error.chat_id_greater_than_zero=The chat id should be greater than zero!
error.chat_order_by_empty=orderBy can't be empty!
error.chat_page_num=The page number must be greater than zero!
error.chat_page_size=The page size must be greater than zero!
error.chat_sorting=Sorting can only be asc or desc, and ignore case!
error.missing_body=Required request body is missing!
error.system=Error number:[{0}],Internal server error!
error.user_id_greater_than_zero=The user id should be greater than zero!
error.user_id_empty=User id cannot be empty!
error.chat_id_empty=Chat id cannot be empty!
error.staff_id_empty=Staff id cannot be empty!
error.staff_id_greater_than_zero=The staff id should be greater than zero!
error.chat_msg_type_empty=MsgType id cannot be empty!
error.chat_send_receive=sendReceive can only be 0(send) or 1(receive)!
error.chat_scope=Scope can only be 0(all) or 1(air tickets) or 2(hotel)!
error.chat_receive_time_empty=receiveTime cant not be empty!
error.chat_send_time_empty=sendTime cant not be empty!
error.chat_create_time_empty=createTime cant not be empty!
error.chat_modify_time_empty=modifyTime cant not be empty!
error.msg_body_data_empty=MsgBody data cant not be null!
error.msg_body_status_empty=MsgBody status cant not be empty!
error.service.user=Wrong service user!
\ No newline at end of file
customer-service/src/main/resources/static/i18n/error_zh_CN.properties 0 → 100644
error.chat_id_empty=\u804A\u5929Id\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.top_level_error=\u8BF7\u8054\u7CFB\u5F00\u53D1\u4EBA\u5458\uFF01
error.bad_parameter=\u53C2\u6570\u9519\u8BEF\uFF01
error.chat_id_direction=direction\u53EA\u80FD\u4E3Aforward\u6216backward\uFF0C\u5E76\u5FFD\u7565\u5927\u5C0F\u5199\uFF01
error.chat_id_greater_than_zero=\u804A\u5929\u8BB0\u5F55Id\u5FC5\u987B\u5927\u4E8E0\uFF01
error.chat_order_by_empty=orderBy\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.chat_page_num=\u9875\u7801\u5FC5\u987B\u5927\u4E8E0\uFF01
error.chat_page_size=\u5206\u9875\u5927\u5C0F\u5FC5\u987B\u5927\u4E8E0\uFF01
error.chat_sorting=sorting\u53EA\u80FD\u4E3Aasc\u6216desc\uFF0C\u5E76\u5FFD\u7565\u5927\u5C0F\u5199\uFF01
error.missing_body=\u7F3A\u5C11\u8BF7\u6C42\u4FE1\u606F\uFF01
error.system=\u9519\u8BEF\u7F16\u53F7\uFF1A[{0}]\uFF0C\u670D\u52A1\u5668\u5185\u90E8\u5F02\u5E38\uFF01
error.user_id_greater_than_zero=\u7528\u6237Id\u5FC5\u987B\u5927\u4E8E0\uFF01
error.user_id_empty=\u7528\u6237Id\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.staff_id_empty=\u5BA2\u670DId\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.staff_id_greater_than_zero=\u5BA2\u670DId\u5FC5\u987B\u5927\u4E8E0\uFF01
error.chat_msg_type_empty=\u6D88\u606F\u7C7B\u578B\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.chat_send_receive=\u6536\u6216\u53D1\u53EA\u80FD\u4E3A0\uFF08\u53D1\u9001\uFF09\u62161\uFF08\u63A5\u6536\uFF09\uFF01
error.chat_scope=\u5185\u5BB9\u8303\u56F4\u53EA\u80FD\u4E3A0\uFF08\u6240\u6709\uFF09\u30011\uFF08\u673A\u7968\uFF09\u30012\uFF08\u9152\u5E97\uFF09\uFF01
error.chat_receive_time_empty=\u63A5\u6536\u65F6\u95F4\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.chat_send_time_empty=\u53D1\u9001\u65F6\u95F4\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.chat_create_time_empty=\u521B\u5EFA\u65F6\u95F4\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.chat_modify_time_empty=\u4FEE\u6539\u65F6\u95F4\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.msg_body_data_empty=MsgBody data\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.msg_body_status_empty=MsgBody status\u4E0D\u53EF\u4E3A\u7A7A\uFF01
error.service.user=\u8BE5\u7528\u6237\u4E0D\u5728\u670D\u52A1\u5217\u8868\u5185\uFF01
\ No newline at end of file
customer-service/target/classes/application-dev.yml 0 → 100644
---
#开发环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://47.99.47.225:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: temple123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 127.0.0.1
port: 5672
username: admin
password: admin
delay-queue-name: delay.ack.dev
staff-offline-Queue-Name: staff.offline.dev
exchange-name: delay.exchange.dev
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 127.0.0.1
password:
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
customer-service/target/classes/application-prd.yml 0 → 100644
---
#生产环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://172.31.33.14:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: Yum123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 172.31.33.14
port: 5672
username: admin
password: Yum123456
delay-queue-name: delay.ack
staff-offline-Queue-Name: staff.offline
exchange-name: delayAck
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 172.31.33.14
password: Yum123456
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
#日志配置
logging:
file: logs/${spring.application.name}.log
eureka:
client:
service-url:
defaultZone: http://172.31.41.108:20000/eureka/
instance:
prefer-ip-address: true
\ No newline at end of file
customer-service/target/classes/application-test.yml 0 → 100644
---
#开发环境
spring:
datasource:
# 数据库连接池配置
druid:
# 初始化时建立物理连接的个数
initial-size: 5
# 最大连接池数量
max-active: 10
# 用来检测连接是否有效的sql语句
validation-query: SELECT 1 FROM DUAL
# 最小连接池数量
min-idle: 5
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
time-between-eviction-runs-millis: 60000
url: jdbc:mysql://192.168.1.237:3306/pathfinder_im?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
jackson:
default-property-inclusion: non_null
rabbitmq:
host: 127.0.0.1
port: 5672
username: admin
password: admin
delay-queue-name: delay.ack.dev
staff-offline-Queue-Name: staff.offline.dev
exchange-name: delay.exchange.dev
listener:
simple:
default-requeue-rejected: false
redis:
database: 5
host: 127.0.0.1
password:
port: 6379
# （重要！）设置mvc默认语言为zh_CN，默认语言必须为static.i18n目录下有的语言配置文件，否则跟随服务器语言
mvc:
locale: zh_CN
devtools:
restart:
log-condition-evaluation-delta: false
customer-service/target/classes/application.yml 0 → 100644
spring:
profiles:
active: dev
application:
name: pathfinder-im
# 404抛出异常
mvc:
throw-exception-if-no-handler-found: true
resources:
add-mappings: false
server:
port: 20002
# 关闭tomcat自带/error页面
error:
whitelabel:
enabled: false
netty:
port: 9095
#日志配置
logging:
level:
root: info
com.ym.im.mapper: debug
pagehelper:
helper-dialect: mysql
reasonable: true
support-methods-arguments: ture
params: count=contSql
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment