流媒体 新接口

yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/dal/mysql/kefu/KeFuMessageMapper.java

@@ -31,7 +31,7 @@ public interface KeFuMessageMapper extends BaseMapperX<KeFuMessageDO> {
         return selectList(new QueryWrapperX<KeFuMessageDO>()
                 .eqIfPresent("conversation_id", reqVO.getConversationId())
                 .ltIfPresent("create_time", reqVO.getCreateTime())
-                .orderByDesc("update_time")
+                .orderByDesc("create_time")
                 .limitN(reqVO.getLimit()));
     }
     

yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/kefu/KeFuMessageServiceImpl.java

@@ -32,6 +32,7 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 import reactor.core.publisher.Flux;
 
+import java.time.LocalDateTime;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
@@ -204,6 +205,8 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
                         KeFuConversationRespVO updatePinnedReqVO = new KeFuConversationRespVO();
                         updatePinnedReqVO.setId(sendReqVO.getConversationId());
                         updatePinnedReqVO.setDifyConversationId(contentBufferCon.toString());
+                        LocalDateTime current = LocalDateTime.now();
+                        updatePinnedReqVO.setCreateTime(current);
                         TenantUtils.executeIgnore(() ->
                                 conversationService.updateConversation(updatePinnedReqVO));