package com.iplatform.chat;
|
|
import com.iplatform.chat.util.ChatUtils;
|
import com.iplatform.model.vo.ChatVo;
|
import com.walker.db.page.GenericPager;
|
import com.walker.infrastructure.utils.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.util.List;
|
|
/**
|
* 聊天引擎定义，抽象实现。
|
* <p>暂时不定义接口，简化操作，后续要根据需求重构。</p>
|
* @author 时克英
|
* @date 2023-07-12
|
*/
|
@Deprecated
|
public abstract class ChatEngine {
|
|
protected final transient Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 发送聊天消息，该方法必须由人工调用，即：用户或客服发起消息。
|
* @param chatVo
|
* @return
|
*/
|
public boolean sendChat(ChatVo chatVo){
|
if(chatVo == null || chatVo.getMe() <= 0){
|
throw new IllegalArgumentException("消息（或发送人）不存在");
|
}
|
|
if(StringUtils.isEmpty(chatVo.getMessage())){
|
throw new ChatRuntimeException("不能发送空消息");
|
}
|
|
// 用户发起的消息，此时没有指定人工客服，需要机器人处理
|
if(chatVo.getCustomerService() == Constants.USER_ID_ROBOT){
|
if(!this.autoRobotReply){
|
logger.warn("系统配置：无机器人自动应答，无法回复内容。");
|
return false;
|
}
|
if(this.robot == null){
|
throw new ChatRuntimeException("未配置应答机器人");
|
}
|
// 先保存用户发送聊天内容，机器人发送内容不保存，仅在对方接收时保存
|
this.saveChatData(chatVo);
|
this.robot.autoReply(chatVo);
|
return true;
|
}
|
|
// 存在人工（客服），只需要推送消息
|
long chatDialogId = ChatUtils.acquireChatDialogKey(chatVo.getCustomerService(), chatVo.getMe(), chatVo.getBizId());
|
ChatSession chatSession = this.acquireChatDialog(chatDialogId);
|
if(chatSession == null){
|
logger.debug("未找到对话记录，需要创建：" + chatDialogId);
|
try {
|
chatSession = this.createChatDialog(chatDialogId, chatVo);
|
} catch (Exception ex){
|
throw new ChatRuntimeException("聊天对话创建失败，chatDialogId=" + chatDialogId, ex);
|
}
|
}
|
|
// 保存聊天记录
|
try {
|
this.saveChatData(chatVo);
|
} catch (Exception ex){
|
throw new ChatRuntimeException("保存聊天记录失败，chatDialogId=" + chatDialogId, ex, chatVo.getMe(), chatVo.getCustomerService());
|
}
|
return true;
|
}
|
|
public List<ChatSession> getChatSessionList(String customerService, String bizId){
|
|
return null;
|
}
|
|
public GenericPager getPageRecentChatList(String me, String bizId){
|
|
return null;
|
}
|
|
/**
|
* 保存聊天记录。
|
* @param chatVo
|
* @return
|
*/
|
protected abstract boolean saveChatData(ChatVo chatVo);
|
|
/**
|
* 创建聊天对话记录。
|
* @param chatDialogId
|
* @param chatVo
|
* @return
|
*/
|
protected abstract ChatSession createChatDialog(long chatDialogId, ChatVo chatVo);
|
|
/**
|
* 获取已有对话记录。
|
* @param chatDialogId
|
* @return
|
*/
|
protected abstract ChatSession acquireChatDialog(long chatDialogId);
|
|
/**
|
* 是否使用机器人自动响应？
|
* @return
|
*/
|
public boolean isAutoRobotReply() {
|
return autoRobotReply;
|
}
|
|
public void setAutoRobotReply(boolean autoRobotReply) {
|
this.autoRobotReply = autoRobotReply;
|
}
|
|
public Robot getRobot() {
|
return robot;
|
}
|
|
public void setRobot(Robot robot) {
|
this.robot = robot;
|
}
|
|
private Robot robot;
|
private boolean autoRobotReply = true;
|
}
|
