|
@@ -260,6 +260,8 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
|
|
// 忽略租户,因为 Flux 异步无法透传租户
|
|
// 忽略租户,因为 Flux 异步无法透传租户
|
|
message.setContent(contentBuffer.toString());
|
|
message.setContent(contentBuffer.toString());
|
|
// 1.2 保存消息
|
|
// 1.2 保存消息
|
|
|
|
+ //更新 创建时间 方便排序
|
|
|
|
+ message.setCreateTime(LocalDateTime.now());
|
|
TenantUtils.executeIgnore(() ->
|
|
TenantUtils.executeIgnore(() ->
|
|
keFuMessageMapper.updateById(BeanUtils.toBean(message, KeFuMessageDO.class)));
|
|
keFuMessageMapper.updateById(BeanUtils.toBean(message, KeFuMessageDO.class)));
|
|
if (StrUtil.isNotBlank(message.getDifyConversationId())) {
|
|
if (StrUtil.isNotBlank(message.getDifyConversationId())) {
|