REQ-3345: 即刻生成聊天消息的history

This commit is contained in:
yanglin 2025-02-25 17:31:27 +08:00
parent 8be8cc4dae
commit b830369413
3 changed files with 3 additions and 3 deletions

View File

@ -247,7 +247,7 @@ public class MessageController implements MessageApi {
MessageTask.BizData bizData = MessageTask.BizData.builder() MessageTask.BizData bizData = MessageTask.BizData.builder()
.messageBody(JSON.toJSONString(request.getMessageBody())) .messageBody(JSON.toJSONString(request.getMessageBody()))
.isSenderRobot(false) .isSenderRobot(false)
.isChatMessage(true) .historyCreated(true)
.senderPersonId(request.determineSenderPersonId()) .senderPersonId(request.determineSenderPersonId())
.nimMessageType(request.getMessageType()) .nimMessageType(request.getMessageType())
.build(); .build();

View File

@ -170,7 +170,7 @@ public class MessageTask {
private NimMessageType nimMessageType; private NimMessageType nimMessageType;
private boolean isChatMessage; private boolean historyCreated;
public boolean determineIsSenderRobot() { public boolean determineIsSenderRobot() {
return isSenderRobot != null && isSenderRobot; return isSenderRobot != null && isSenderRobot;

View File

@ -60,7 +60,7 @@ public class CreateMessageHistoryJob extends IJobHandler {
if (CollectionUtils.isNotEmpty(page.getRecords())) { if (CollectionUtils.isNotEmpty(page.getRecords())) {
page.getRecords().forEach(messageTask -> { page.getRecords().forEach(messageTask -> {
MessageTask.BizData bizData = messageTask.getBizData(); MessageTask.BizData bizData = messageTask.getBizData();
if (bizData != null && bizData.isChatMessage()) if (bizData != null && bizData.isHistoryCreated())
return; return;
count.set(count.get() + 1); count.set(count.get() + 1);
try { try {