| | |
|---|
| | | return Flux.just(directResponse); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (isApproveTodoBusinessIntent(userMessage)) { |
|---|
| | | String noGuessResponse = "未识别到可执行的审批待办操作条件。为保证结果准确，当前不会推测或编造审批数据，请补充流程编号、时间范围或明确操作指令后再试。"; |
|---|
| | | mongoChatMemoryStore.appendMessages( |
|---|
| | | memoryId, |
|---|
| | | List.of(UserMessage.from(userMessage), AiMessage.from(noGuessResponse)) |
|---|
| | | ); |
|---|
| | | aiChatSessionService.refreshSessionStats(memoryId, loginUser); |
|---|
| | | return Flux.just(noGuessResponse); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return approveTodoAgent.chat(memoryId, userMessage) |
|---|
| | | .doOnComplete(() -> aiChatSessionService.refreshSessionStats(memoryId, loginUser)) |
|---|
| | | .doOnError(ex -> aiChatSessionService.refreshSessionStats(memoryId, loginUser)); |
|---|
| | |
|---|
| | | aiSessionUserContext.remove(memoryId); |
|---|
| | | return toAjax(aiChatSessionService.deleteCurrentUserSession(memoryId, SecurityUtils.getLoginUser())); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private boolean isApproveTodoBusinessIntent(String message) { |
|---|
| | | if (!StringUtils.hasText(message)) { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | String text = message.trim(); |
|---|
| | | boolean hasDomainWord = containsAny(text, |
|---|
| | | "审批", "待办", "流程编号", "流程号", "审批流转", "审批节点", "当前审批人", "驳回", "通过", "撤销", "删除"); |
|---|
| | | boolean hasIntentWord = containsAny(text, |
|---|
| | | "查询", "查看", "列出", "统计", "分析", "分布", "通过", "驳回", "撤销", "删除", "修改", "有哪些", "卡在"); |
|---|
| | | return hasDomainWord && hasIntentWord; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private boolean containsAny(String text, String... keywords) { |
|---|
| | | for (String keyword : keywords) { |
|---|
| | | if (text.contains(keyword)) { |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | } |
|---|
