| | |
|---|
| | | return Flux.just(directResponse); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (isBusinessDataIntent(userMessage)) { |
|---|
| | | String noGuessResponse = "未识别到可执行的数据查询条件。为保证结果准确，当前不会推测或编造数据，请补充明确时间范围、客户、供应商或单号后再查询。"; |
|---|
| | | mongoChatMemoryStore.appendMessages( |
|---|
| | | memoryId, |
|---|
| | | List.of(UserMessage.from(userMessage), AiMessage.from(noGuessResponse)) |
|---|
| | | ); |
|---|
| | | aiChatSessionService.refreshSessionStats(memoryId, loginUser); |
|---|
| | | return Flux.just(noGuessResponse); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return financialAgent.chat(memoryId, userMessage, currentDateForPrompt()) |
|---|
| | | .doOnComplete(() -> aiChatSessionService.refreshSessionStats(memoryId, loginUser)) |
|---|
| | | .doOnError(ex -> aiChatSessionService.refreshSessionStats(memoryId, loginUser)); |
|---|
| | |
|---|
| | | private String currentDateForPrompt() { |
|---|
| | | return LocalDate.now(CHINA_ZONE_ID).format(CURRENT_DATE_FMT); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private boolean isBusinessDataIntent(String message) { |
|---|
| | | if (!StringUtils.hasText(message)) { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | String text = message.trim(); |
|---|
| | | return containsAny(text, |
|---|
| | | "查询", "查看", "统计", "分析", "建议", "成本核算", "产品成本", "工序成本", |
|---|
| | | "订单利润", "亏损订单", "低利润", "库存资金", "库存积压", "呆滞库存", |
|---|
| | | "现金流", "回款风险", "付款压力", "资金缺口", "应收", "应付", |
|---|
| | | "异常预警", "经营异常", "风险预警", "驾驶舱", "经营看板", "经营总览", |
|---|
| | | "日报", "周报", "经营报告", "分析报告", "业财融合", "口径", "指标解释"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private boolean containsAny(String text, String... keywords) { |
|---|
| | | for (String keyword : keywords) { |
|---|
| | | if (text.contains(keyword)) { |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | } |
|---|
