Commit f8546f1b authored by shiyu's avatar shiyu

消息发送后保存记录的操作删除由回调执行

parent 2b28471a
...@@ -120,26 +120,6 @@ public class ImServiceImpl implements IMService { ...@@ -120,26 +120,6 @@ public class ImServiceImpl implements IMService {
if (!askResult.getSuccess()) { if (!askResult.getSuccess()) {
return askResult; return askResult;
} }
//保存提问的消息记录
ImRecord imRecord = new ImRecord();
imRecord.setFromAccount(dto.getFromAccount());
imRecord.setToAccount(dto.getToAccount());
imRecord.setMsgType(dto.getMsgType());
//0:成功
imRecord.setSendMsgResult(0);
if (IMEnum.MsgTypeEnum.TIMTextElem.getCode() == dto.getMsgType()) {
imRecord.setMsgContent(dto.getMsgContent().toString());
}
Date now = new Date();
imRecord.setMsgTime(now);
imRecord.setOnlineOnlyFlag(0);
imRecord.setCreateTime(now);
imRecord.setUpdateTime(now);
imRecord.setState(IMEnum.MsgStateEnum.READED.getCode());
imRecord.setMsgKey(askResult.getData());
imRecordService.create(imRecord);
logger.info("=========== userid:{}, 提问ai的消息发送成功 ==========", dto.getFromAccount()); logger.info("=========== userid:{}, 提问ai的消息发送成功 ==========", dto.getFromAccount());
if (dto.getMsgType() == IMEnum.MsgTypeEnum.TIMTextElem.getCode()) { if (dto.getMsgType() == IMEnum.MsgTypeEnum.TIMTextElem.getCode()) {
String question = (String) dto.getMsgContent(); String question = (String) dto.getMsgContent();
...@@ -162,22 +142,6 @@ public class ImServiceImpl implements IMService { ...@@ -162,22 +142,6 @@ public class ImServiceImpl implements IMService {
logger.info("=============== 发送问题的ai答复消息失败 ============="); logger.info("=============== 发送问题的ai答复消息失败 =============");
return answerResult; return answerResult;
} }
//保存ai回答的消息记录
ImRecord answerImRecord = new ImRecord();
answerImRecord.setFromAccount(dto.getToAccount());
answerImRecord.setToAccount(dto.getFromAccount());
answerImRecord.setMsgKey(answerResult.getData());
answerImRecord.setMsgType(IMEnum.MsgTypeEnum.TIMTextElem.getCode());
answerImRecord.setMsgContent(answer);
answerImRecord.setOnlineOnlyFlag(0);
Date answerTime = new Date();
answerImRecord.setSendMsgResult(0);
answerImRecord.setMsgTime(answerTime);
answerImRecord.setCreateTime(answerTime);
answerImRecord.setUpdateTime(answerTime);
answerImRecord.setState(IMEnum.MsgStateEnum.READED.getCode());
imRecordService.create(answerImRecord);
} else { } else {
return Result.failed("目前尚不支持除文本外的消息发送"); return Result.failed("目前尚不支持除文本外的消息发送");
} }
......
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