dify会话异常

yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/job/kefu/KefuMessageJob.java

@@ -1,21 +1,14 @@
 package cn.iocoder.yudao.module.promotion.job.kefu;
 
-import cn.hutool.core.collection.CollUtil;
-import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
 import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
 import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
 import cn.iocoder.yudao.module.infra.api.ai.AiApi;
-import cn.iocoder.yudao.module.promotion.controller.admin.kefu.vo.conversation.KeFuConversationRespVO;
-import cn.iocoder.yudao.module.promotion.controller.app.kefu.vo.message.AppKeFuMessageSendReqVO;
-import cn.iocoder.yudao.module.promotion.dal.dataobject.kefu.KeFuConversationDO;
 import cn.iocoder.yudao.module.promotion.service.kefu.KeFuConversationService;
 import cn.iocoder.yudao.module.promotion.service.kefu.KeFuMessageService;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
-import java.util.List;
-
 /**
  * 物理删除 N 天前的任务日志的 Job
  *
@@ -43,7 +36,7 @@ public class KefuMessageJob implements JobHandler {
         return String.format("定时执行清理定时任务日志数量 %s 个", 1);
     }
     
-    private void init(String conteng, Long userId) {
+    private void init(String conteng, Long userId) {/*
         KeFuConversationRespVO keFuConversationRespVO = new KeFuConversationRespVO();
         keFuConversationRespVO.setUserId(userId);
         List<KeFuConversationDO> conversationDOList = keFuConversationService.getList(keFuConversationRespVO);
@@ -61,7 +54,7 @@ public class KefuMessageJob implements JobHandler {
 //                sendReqVO.setRelUserId(conversationDO.getUid());
                 kefuMessageService.sendMessage(sendReqVO);
             }
-        }
+        }*/
     }
     
 }

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

@@ -262,7 +262,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
             // 1.2 保存消息
             TenantUtils.executeIgnore(() ->
                     keFuMessageMapper.updateById(BeanUtils.toBean(message, KeFuMessageDO.class)));
-            if (StrUtil.isBlank(message.getDifyConversationId())) {
+            if (StrUtil.isNotBlank(message.getDifyConversationId())) {
                 KeFuConversationRespVO updatePinnedReqVO = new KeFuConversationRespVO();
                 updatePinnedReqVO.setId(message.getConversationId());
                 updatePinnedReqVO.setDifyConversationId(difyId.toString());