From b475a864c6f3a6c96829100a3109217d45370a94 Mon Sep 17 00:00:00 2001
From: spllzh <28668817@qq.com>
Date: Sun, 7 Sep 2025 23:02:25 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E7=94=A8dify?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 30 ++-
.../rj/AISmartCard20250803Application.java | 37 +++
.../Langchain4jHeima20250803Application.java | 25 --
src/main/java/com/rj/common/PasswordUtil.java | 7 +
.../java/com/rj/common/ServiceManager.java | 7 +
.../controller/AudioManagementController.java | 15 ++
.../biz/ConsultingScenarioController.java | 232 ++++++++++++++++++
.../biz/DifyWorkflowAnalysisController.java | 86 +++++++
.../biz/dto/ConsultingScenarioRequest.java | 15 ++
.../com/rj/controller/sys/AuthController.java | 7 +
.../com/rj/controller/sys/MenuController.java | 7 +
.../com/rj/controller/sys/RoleController.java | 7 +
.../rj/controller/sys/UserRoleController.java | 7 +
.../com/rj/entity/bz/ConsultingScenario.java | 77 ++++++
.../rj/entity/bz/DifyWorkflowAnalysis.java | 188 ++++++++++++++
.../mapper/biz/ConsultingScenarioMapper.java | 17 ++
.../biz/DifyWorkflowAnalysisMapper.java | 12 +
.../java/com/rj/pojo/sys/LoginResponse.java | 7 +
.../scheduler/AudioStatisticsScheduler.java | 7 +
.../biz/ConsultingScenarioServiceImpl.java | 189 ++++++++++++++
.../biz/DifyWorkflowAnalysisServiceImpl.java | 15 ++
.../biz/IConsultingScenarioService.java | 26 ++
.../biz/IDifyWorkflowAnalysisService.java | 10 +
.../java/com/rj/service/sys/IMenuService.java | 7 +
.../java/com/rj/service/sys/IRoleService.java | 7 +
.../com/rj/service/sys/IUserRoleService.java | 7 +
.../rj/service/sys/impl/MenuServiceImpl.java | 7 +
.../rj/service/sys/impl/RoleServiceImpl.java | 7 +
.../service/sys/impl/UserRoleServiceImpl.java | 7 +
src/main/resources/application.yml | 19 ++
src/main/resources/corpus/qiwei/qw1.txt | 117 +++++++++
src/main/resources/corpus/qiwei/qw2.txt | 218 ++++++++++++++++
src/main/resources/corpus/qiwei/qw3.txt | 170 +++++++++++++
src/main/resources/corpus/qiwei/qw4.txt | 168 +++++++++++++
src/main/resources/corpus/qiwei/qw5.txt | 133 ++++++++++
src/main/resources/corpus/qiwei/qw6.txt | 149 +++++++++++
.../AudioManagementStatisticsMapper.xml | 7 +
src/main/resources/mapper/sys/MenuMapper.xml | 7 +
src/main/sql/cmd.docker.shell | 112 +++++++++
.../CustomerManagementServiceTest.java | 5 +-
.../com/rj/service/DealershipServiceTest.java | 5 +-
.../service/DeviceManagementServiceTest.java | 5 +-
.../service/ProjectManagementServiceTest.java | 5 +-
.../service/SalesManagementServiceTest.java | 5 +-
.../service/VideoManagementServiceTest.java | 5 +-
45 files changed, 2158 insertions(+), 44 deletions(-)
create mode 100644 src/main/java/com/rj/AISmartCard20250803Application.java
delete mode 100644 src/main/java/com/rj/Langchain4jHeima20250803Application.java
create mode 100644 src/main/java/com/rj/controller/biz/ConsultingScenarioController.java
create mode 100644 src/main/java/com/rj/controller/biz/DifyWorkflowAnalysisController.java
create mode 100644 src/main/java/com/rj/controller/biz/dto/ConsultingScenarioRequest.java
create mode 100644 src/main/java/com/rj/entity/bz/ConsultingScenario.java
create mode 100644 src/main/java/com/rj/entity/bz/DifyWorkflowAnalysis.java
create mode 100644 src/main/java/com/rj/mapper/biz/ConsultingScenarioMapper.java
create mode 100644 src/main/java/com/rj/mapper/biz/DifyWorkflowAnalysisMapper.java
create mode 100644 src/main/java/com/rj/service/biz/ConsultingScenarioServiceImpl.java
create mode 100644 src/main/java/com/rj/service/biz/DifyWorkflowAnalysisServiceImpl.java
create mode 100644 src/main/java/com/rj/service/biz/IConsultingScenarioService.java
create mode 100644 src/main/java/com/rj/service/biz/IDifyWorkflowAnalysisService.java
create mode 100644 src/main/resources/corpus/qiwei/qw1.txt
create mode 100644 src/main/resources/corpus/qiwei/qw2.txt
create mode 100644 src/main/resources/corpus/qiwei/qw3.txt
create mode 100644 src/main/resources/corpus/qiwei/qw4.txt
create mode 100644 src/main/resources/corpus/qiwei/qw5.txt
create mode 100644 src/main/resources/corpus/qiwei/qw6.txt
create mode 100644 src/main/sql/cmd.docker.shell
diff --git a/pom.xml b/pom.xml
index 38610f8..47d0328 100644
--- a/pom.xml
+++ b/pom.xml
@@ -10,7 +10,7 @@
com.cst
Langchain4j-rj
- 0.0.1-SNAPSHOT
+ 0.1.3-SNAPSHOT
Langchain4j-rj
Langchain4j-rj20250803
@@ -29,6 +29,9 @@
17
4.3.0
+ UTF-8
+ UTF-8
+ UTF-8
@@ -164,14 +167,39 @@
${knife4j.version}
+
+
+ com.alibaba
+ dashscope-sdk-java
+ 2.21.4
+
+
+
+
+ com.alibaba
+ fastjson
+ 1.2.83
+
+
+
+
+ aliyun
+ https://maven.aliyun.com/repository/public
+
+
+
+
org.apache.maven.plugins
maven-compiler-plugin
+ 17
+ 17
+ UTF-8
org.springframework.boot
diff --git a/src/main/java/com/rj/AISmartCard20250803Application.java b/src/main/java/com/rj/AISmartCard20250803Application.java
new file mode 100644
index 0000000..74d265f
--- /dev/null
+++ b/src/main/java/com/rj/AISmartCard20250803Application.java
@@ -0,0 +1,37 @@
+package com.rj;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+/**
+ *
+ * https://npmgg.huayang-star.com/nginx/proxy
+ *
+ * http://localhost:9060/doc.html#/home
+ * https://apig.huayang-star.com/doc.html#/home 硅谷： 43.153.123.65
+ *https://api.huayang-star.com/doc.html#/home 上海： 101.35.52.237
+ *
+ * http://localhost:9060/swagger-ui/index.html?urls.primaryName=public-api
+ * http://101.43.230.106:8180/aismartcard/aicardbackend
+ *
+ *https://help.aliyun.com/zh/model-studio/paraformer-recorded-speech-recognition-java-sdk 声音识别
+ *
+ * https://help.aliyun.com/zh/model-studio/recording-file-recognition?spm=a2c4g.11186623.0.0.50907980dOsQRW#16ecfd02f4kau
+ *
+ * 阿里云百炼： https://bailian.console.aliyun.com/?spm=a2c4g.11186623.0.0.13ba4a3byPkDCX&tab=model#/efm/model_experience_center/voice
+ */
+@MapperScan("com.rj.mapper")
+@SpringBootApplication
+@EnableScheduling
+public class AISmartCard20250803Application {
+
+ public static void main(String[] args) {
+ SpringApplication.run(AISmartCard20250803Application.class, args);
+ }
+
+}
+
+
+
diff --git a/src/main/java/com/rj/Langchain4jHeima20250803Application.java b/src/main/java/com/rj/Langchain4jHeima20250803Application.java
deleted file mode 100644
index e223727..0000000
--- a/src/main/java/com/rj/Langchain4jHeima20250803Application.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package com.rj;
-
-import org.mybatis.spring.annotation.MapperScan;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.scheduling.annotation.EnableScheduling;
-
-/**
- *
- * http://localhost:9060/doc.html#/home
- * http://localhost:9060/swagger-ui/index.html?urls.primaryName=public-api
- * http://101.43.230.106:8180/aismartcard/aicardbackend
- *
- *
- */
-@MapperScan("com.rj.mapper")
-@SpringBootApplication
-@EnableScheduling
-public class Langchain4jHeima20250803Application {
-
- public static void main(String[] args) {
- SpringApplication.run(Langchain4jHeima20250803Application.class, args);
- }
-
-}
diff --git a/src/main/java/com/rj/common/PasswordUtil.java b/src/main/java/com/rj/common/PasswordUtil.java
index 6b81214..27989bb 100644
--- a/src/main/java/com/rj/common/PasswordUtil.java
+++ b/src/main/java/com/rj/common/PasswordUtil.java
@@ -89,3 +89,10 @@ public class PasswordUtil {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/common/ServiceManager.java b/src/main/java/com/rj/common/ServiceManager.java
index aca0883..c6cb3c8 100644
--- a/src/main/java/com/rj/common/ServiceManager.java
+++ b/src/main/java/com/rj/common/ServiceManager.java
@@ -73,3 +73,10 @@ public class ServiceManager {
}
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/controller/AudioManagementController.java b/src/main/java/com/rj/controller/AudioManagementController.java
index 180fa37..6c08e39 100644
--- a/src/main/java/com/rj/controller/AudioManagementController.java
+++ b/src/main/java/com/rj/controller/AudioManagementController.java
@@ -27,6 +27,7 @@ import java.util.UUID;
*
* 录音管理表，含信息卡字段 前端控制器
*
+ * 播放： https://apig.huayang-star.com/api/audio/1957424644480905217_9e35b6ff-f198-4c42-a5c1-49fa8333fc35.mp3
*
* @author 李中华 ,spllzh
* @since 2025-08-07
@@ -78,6 +79,20 @@ public class AudioManagementController {
}
}
+ @PostMapping("/difyCallbackPLForCustomerProfile")
+ @Operation(summary = "dify回调，为了客户画像完善", description = "dify回调，为了客户画像完善")
+ public Map difyCallbackPLForCustomerProfile(@RequestBody String message){
+ Map result = new HashMap<>();
+
+ log.info("difyCallbackPLForCustomerProfile msg: "+message.toString());
+ result.put("code", 0);
+ result.put("msg", "成功");
+ result.put("data", "dify回调，为了客户画像完善,成功。");
+ return result;
+ }
+
+
+
/**
* 根据ID查询录音
*/
diff --git a/src/main/java/com/rj/controller/biz/ConsultingScenarioController.java b/src/main/java/com/rj/controller/biz/ConsultingScenarioController.java
new file mode 100644
index 0000000..f339590
--- /dev/null
+++ b/src/main/java/com/rj/controller/biz/ConsultingScenarioController.java
@@ -0,0 +1,232 @@
+package com.rj.controller.biz;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import com.rj.controller.biz.dto.ConsultingScenarioRequest;
+import com.rj.entity.bz.ConsultingScenario;
+import com.rj.service.biz.IConsultingScenarioService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ *
+ * 咨询场景表 前端控制器
+ *
+ *
+ * @author lingma
+ * @since 2025-09-02
+ */
+@RestController
+@RequestMapping("/api/consultingScenario")
+@Tag(name = "咨询场景", description = "咨询场景相关接口")
+@Slf4j
+public class ConsultingScenarioController {
+
+ @Autowired
+ private IConsultingScenarioService consultingScenarioService;
+
+ /**
+ * 新增咨询场景
+ */
+ @PostMapping("/add")
+ @Operation(summary = "新增咨询场景", description = "添加新的咨询场景信息")
+ public ResponseEntity> addConsultingScenario(
+ @Parameter(description = "咨询场景信息", required = true)
+ @RequestBody ConsultingScenario consultingScenario) {
+ Map result = new HashMap<>();
+ try {
+ // 设置UUID主键
+ if (consultingScenario.getId() == null || consultingScenario.getId().isEmpty()) {
+ consultingScenario.setId(UUID.randomUUID().toString());
+ }
+ consultingScenario.setCreatedAt(LocalDateTime.now());
+ consultingScenario.setUpdatedAt(LocalDateTime.now());
+
+ boolean isSaved = consultingScenarioService.save(consultingScenario);
+ if (isSaved) {
+ result.put("code", 200);
+ result.put("message", "保存成功");
+ result.put("data", consultingScenario);
+ } else {
+ result.put("code", 500);
+ result.put("message", "保存失败");
+ }
+ } catch (Exception e) {
+ result.put("code", 500);
+ result.put("message", "保存异常: " + e.getMessage());
+ }
+ return ResponseEntity.ok(result);
+ }
+
+
+
+ /**
+ * 处理咨询场景请求
+ *
+ * @return 处理结果
+ */
+ @PostMapping("/process")
+ @Operation(summary = "处理咨询场景", description = "接收咨询场景相关参数并进行处理")
+ @ApiResponses(value = {
+ @ApiResponse(responseCode = "200", description = "处理成功"),
+ @ApiResponse(responseCode = "400", description = "请求参数错误"),
+ @ApiResponse(responseCode = "500", description = "服务器内部错误")
+ })
+ public ResponseEntity> processConsultingScenario( @RequestBody ConsultingScenarioRequest request) {
+
+ Map result = new HashMap<>();
+
+ try {
+ // 调用服务层处理逻辑
+ Object processingResult = consultingScenarioService.processConsultingScenario(request);
+
+ result.put("success", true);
+ result.put("data", processingResult);
+ result.put("message", "处理成功");
+
+ } catch (Exception e) {
+ result.put("success", false);
+ result.put("data", null);
+ result.put("message", "处理失败: " + e.getMessage());
+ log.error("处理咨询场景时发生错误", e);
+ }
+
+ return ResponseEntity.ok(result);
+ }
+ /**
+ * 修改咨询场景
+ */
+ @PostMapping("/update")
+ @Operation(summary = "修改咨询场景", description = "修改咨询场景信息")
+ public ResponseEntity> updateConsultingScenario(
+ @Parameter(description = "咨询场景信息", required = true)
+ @RequestBody ConsultingScenario consultingScenario) {
+ Map result = new HashMap<>();
+ try {
+ if (consultingScenario.getId() == null || consultingScenario.getId().isEmpty()) {
+ result.put("code", 400);
+ result.put("message", "缺少主键ID");
+ return ResponseEntity.badRequest().body(result);
+ }
+
+ consultingScenario.setUpdatedAt(LocalDateTime.now());
+ boolean isUpdated = consultingScenarioService.updateById(consultingScenario);
+ if (isUpdated) {
+ result.put("code", 200);
+ result.put("message", "更新成功");
+ result.put("data", consultingScenario);
+ } else {
+ result.put("code", 500);
+ result.put("message", "更新失败");
+ }
+ } catch (Exception e) {
+ result.put("code", 500);
+ result.put("message", "更新异常: " + e.getMessage());
+ }
+ return ResponseEntity.ok(result);
+ }
+
+ /**
+ * 删除咨询场景
+ */
+ @DeleteMapping("/delete/{id}")
+ @Operation(summary = "删除咨询场景", description = "根据ID删除咨询场景信息")
+ public ResponseEntity> deleteConsultingScenario(
+ @Parameter(description = "咨询场景ID", required = true)
+ @PathVariable String id) {
+ Map result = new HashMap<>();
+ try {
+ boolean isRemoved = consultingScenarioService.removeById(id);
+ if (isRemoved) {
+ result.put("code", 200);
+ result.put("message", "删除成功");
+ } else {
+ result.put("code", 500);
+ result.put("message", "删除失败");
+ }
+ } catch (Exception e) {
+ result.put("code", 500);
+ result.put("message", "删除异常: " + e.getMessage());
+ }
+ return ResponseEntity.ok(result);
+ }
+
+ /**
+ * 根据ID查询咨询场景
+ */
+ @GetMapping("/get/{id}")
+ @Operation(summary = "查询咨询场景", description = "根据ID查询咨询场景信息")
+ public ResponseEntity> getConsultingScenarioById(
+ @Parameter(description = "咨询场景ID", required = true)
+ @PathVariable String id) {
+ Map result = new HashMap<>();
+ try {
+ ConsultingScenario consultingScenario = consultingScenarioService.getById(id);
+ if (consultingScenario != null) {
+ result.put("code", 200);
+ result.put("message", "查询成功");
+ result.put("data", consultingScenario);
+ } else {
+ result.put("code", 404);
+ result.put("message", "未找到相关数据");
+ }
+ } catch (Exception e) {
+ result.put("code", 500);
+ result.put("message", "查询异常: " + e.getMessage());
+ }
+ return ResponseEntity.ok(result);
+ }
+
+ /**
+ * 分页查询咨询场景列表
+ */
+ @GetMapping("/list")
+ @Operation(summary = "分页查询咨询场景", description = "分页查询咨询场景列表")
+ public ResponseEntity> listConsultingScenarios(
+ @Parameter(description = "页码", example = "1")
+ @RequestParam(defaultValue = "1") Integer pageNum,
+ @Parameter(description = "每页数量", example = "10")
+ @RequestParam(defaultValue = "10") Integer pageSize,
+ @Parameter(description = "主分类")
+ @RequestParam(required = false) String mainCategory,
+ @Parameter(description = "子分类")
+ @RequestParam(required = false) String subCategory) {
+ Map result = new HashMap<>();
+ try {
+ Page page = new Page<>(pageNum, pageSize);
+ LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
+
+ if (mainCategory != null && !mainCategory.isEmpty()) {
+ queryWrapper.like(ConsultingScenario::getMainCategory, mainCategory);
+ }
+ if (subCategory != null && !subCategory.isEmpty()) {
+ queryWrapper.like(ConsultingScenario::getSubCategory, subCategory);
+ }
+
+ queryWrapper.orderByDesc(ConsultingScenario::getCreatedAt);
+ Page pageResult = consultingScenarioService.page(page, queryWrapper);
+
+ result.put("code", 200);
+ result.put("message", "查询成功");
+ result.put("data", pageResult);
+ } catch (Exception e) {
+ result.put("code", 500);
+ result.put("message", "查询异常: " + e.getMessage());
+ }
+ return ResponseEntity.ok(result);
+ }
+}
diff --git a/src/main/java/com/rj/controller/biz/DifyWorkflowAnalysisController.java b/src/main/java/com/rj/controller/biz/DifyWorkflowAnalysisController.java
new file mode 100644
index 0000000..b3eb8f0
--- /dev/null
+++ b/src/main/java/com/rj/controller/biz/DifyWorkflowAnalysisController.java
@@ -0,0 +1,86 @@
+package com.rj.controller.biz;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.rj.entity.bz.DifyWorkflowAnalysis;
+
+import com.rj.service.biz.IDifyWorkflowAnalysisService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * Dify工作流分析结果控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/api/biz/dify-analysis")
+public class DifyWorkflowAnalysisController {
+
+ @Autowired
+ private IDifyWorkflowAnalysisService difyWorkflowAnalysisService;
+
+ /**
+ * 保存Dify工作流分析结果
+ */
+ @PostMapping
+ public boolean saveAnalysis(@RequestBody DifyWorkflowAnalysis analysis) {
+ try {
+ return difyWorkflowAnalysisService.save(analysis);
+ } catch (Exception e) {
+ log.error("保存Dify工作流分析结果失败", e);
+ return false;
+ }
+ }
+
+ /**
+ * 根据ID获取分析结果
+ */
+ @GetMapping("/{id}")
+ public DifyWorkflowAnalysis getAnalysisById(@PathVariable String id) {
+ return difyWorkflowAnalysisService.getById(id);
+ }
+
+ /**
+ * 根据分析记录ID获取分析结果
+ */
+ @GetMapping("/record/{recordId}")
+ public List getAnalysisByRecordId(@PathVariable String recordId) {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("analysis_record_id", recordId);
+ return difyWorkflowAnalysisService.list(queryWrapper);
+ }
+
+ /**
+ * 分页查询分析结果
+ */
+ @GetMapping("/page")
+ public Page getAnalysisPage(
+ @RequestParam(defaultValue = "1") Integer pageNum,
+ @RequestParam(defaultValue = "10") Integer pageSize) {
+ Page page = new Page<>(pageNum, pageSize);
+ return difyWorkflowAnalysisService.page(page);
+ }
+
+ /**
+ * 根据顾问ID查询分析结果
+ */
+ @GetMapping("/consultant/{consultantId}")
+ public List getAnalysisByConsultantId(@PathVariable String consultantId) {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("consultant_id", consultantId);
+ return difyWorkflowAnalysisService.list(queryWrapper);
+ }
+
+ /**
+ * 根据客户unionId查询分析结果
+ */
+ @GetMapping("/customer/{unionId}")
+ public List getAnalysisByUnionId(@PathVariable String unionId) {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("union_id", unionId);
+ return difyWorkflowAnalysisService.list(queryWrapper);
+ }
+}
diff --git a/src/main/java/com/rj/controller/biz/dto/ConsultingScenarioRequest.java b/src/main/java/com/rj/controller/biz/dto/ConsultingScenarioRequest.java
new file mode 100644
index 0000000..d6855fc
--- /dev/null
+++ b/src/main/java/com/rj/controller/biz/dto/ConsultingScenarioRequest.java
@@ -0,0 +1,15 @@
+package com.rj.controller.biz.dto;
+
+import lombok.Data;
+
+/**
+ * 咨询场景处理请求参数 DTO
+ */
+@Data
+public class ConsultingScenarioRequest {
+
+ private String chat;
+ private String businessType;
+ private String sourceCorpusId;
+ private String sourceCorpusTime;
+}
\ No newline at end of file
diff --git a/src/main/java/com/rj/controller/sys/AuthController.java b/src/main/java/com/rj/controller/sys/AuthController.java
index ecb9a91..bf0d069 100644
--- a/src/main/java/com/rj/controller/sys/AuthController.java
+++ b/src/main/java/com/rj/controller/sys/AuthController.java
@@ -172,3 +172,10 @@ public class AuthController {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/controller/sys/MenuController.java b/src/main/java/com/rj/controller/sys/MenuController.java
index 63c0102..5327992 100644
--- a/src/main/java/com/rj/controller/sys/MenuController.java
+++ b/src/main/java/com/rj/controller/sys/MenuController.java
@@ -311,3 +311,10 @@ public class MenuController {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/controller/sys/RoleController.java b/src/main/java/com/rj/controller/sys/RoleController.java
index 0212946..f9a0ad1 100644
--- a/src/main/java/com/rj/controller/sys/RoleController.java
+++ b/src/main/java/com/rj/controller/sys/RoleController.java
@@ -281,3 +281,10 @@ public class RoleController {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/controller/sys/UserRoleController.java b/src/main/java/com/rj/controller/sys/UserRoleController.java
index 2d78576..5b57e37 100644
--- a/src/main/java/com/rj/controller/sys/UserRoleController.java
+++ b/src/main/java/com/rj/controller/sys/UserRoleController.java
@@ -287,3 +287,10 @@ public class UserRoleController {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/entity/bz/ConsultingScenario.java b/src/main/java/com/rj/entity/bz/ConsultingScenario.java
new file mode 100644
index 0000000..a7cad48
--- /dev/null
+++ b/src/main/java/com/rj/entity/bz/ConsultingScenario.java
@@ -0,0 +1,77 @@
+package com.rj.entity.bz;
+
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ *
+ * 咨询场景表
+ *
+ *
+ * @author lingma
+ * @since 2025-09-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("consulting_scenario")
+@Schema(description="咨询场景表")
+public class ConsultingScenario implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ @Schema(description = "UUID主键")
+ @TableId("id")
+ private String id;
+
+ @Schema(description = "主分类")
+ @TableField("main_category")
+ private String mainCategory;
+
+ @Schema(description = "子分类")
+ @TableField("sub_category")
+ private String subCategory;
+
+ @Schema(description = "置信度")
+ @TableField("confidence")
+ private String confidence;
+
+ @Schema(description = "用户需求")
+ @TableField("user_demand")
+ private String userDemand;
+
+ @Schema(description = "咨询内容")
+ @TableField("consulting_content")
+ private String consultingContent;
+
+ @Schema(description = "涉及车型")
+ @TableField("involved_vehicle_models")
+ private String involvedVehicleModels;
+
+ @Schema(description = "知识缺口")
+ @TableField("knowledge_gap")
+ private String knowledgeGap;
+
+ @Schema(description = "优先级")
+ @TableField("priority")
+ private String priority;
+
+ @Schema(description = "备注")
+ @TableField("remarks")
+ private String remarks;
+
+ @Schema(description = "创建时间")
+ @TableField("created_at")
+ private LocalDateTime createdAt;
+
+ @Schema(description = "更新时间")
+ @TableField("updated_at")
+ private LocalDateTime updatedAt;
+
+}
diff --git a/src/main/java/com/rj/entity/bz/DifyWorkflowAnalysis.java b/src/main/java/com/rj/entity/bz/DifyWorkflowAnalysis.java
new file mode 100644
index 0000000..b997a4c
--- /dev/null
+++ b/src/main/java/com/rj/entity/bz/DifyWorkflowAnalysis.java
@@ -0,0 +1,188 @@
+package com.rj.entity.bz;
+
+/**
+ * Author: 李中华 spllzh
+ * Date: 2025/9/7 22:20
+ **/
+
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * Dify工作流分析结果实体类
+ */
+@Data
+@TableName("dify_workflow_analysis")
+public class DifyWorkflowAnalysis {
+
+ /**
+ * 主键ID (UUID格式)
+ */
+ @TableId(value = "id", type = IdType.ASSIGN_UUID)
+ private String id;
+
+ /**
+ * 企微客户unionId，用于唯一标识客户
+ */
+ private String unionId;
+
+ /**
+ * 顾问ID，标识服务客户的顾问
+ */
+ private String consultantId;
+
+ /**
+ * 沟通时间，客户与顾问的沟通时间
+ */
+ private LocalDateTime communicateDate;
+
+ /**
+ * 分析场景，如sales_consultation表示销售咨询
+ */
+ private String analysisScene;
+
+ /**
+ * AI分析请求ID，用于追踪分析请求
+ */
+ private String analysisRecordId;
+
+ /**
+ * 版本号，用于区分不同版本的分析
+ */
+ private Integer version;
+
+ /**
+ * 分析结果摘要，对整个对话的50字以内总结
+ */
+ private String analysisResult;
+
+ /**
+ * 客户来源，客户通过什么渠道联系
+ */
+ private String customerSource;
+
+ /**
+ * 客户职业信息
+ */
+ private String customerOccupation;
+
+ /**
+ * 客户兴趣爱好
+ */
+ private String customerHobbies;
+
+ /**
+ * 家庭住址信息
+ */
+ private String homeAddress;
+
+ /**
+ * 购车用途，如家庭用车、商务用车等
+ */
+ private String carPurchaseNeed;
+
+ /**
+ * 购买类型，如首购、增购、置换等
+ */
+ private String purchaseType;
+
+ /**
+ * 购车人类型，如个人、公司等
+ */
+ private String purchaseBuyer;
+
+ /**
+ * 用车人信息
+ */
+ private String carUser;
+
+ /**
+ * 意向车型，客户感兴趣的车辆型号
+ */
+ private String intendedCarModel;
+
+ /**
+ * 购车资质信息
+ */
+ private String carQualifications;
+
+ /**
+ * 购车预算信息
+ */
+ private String carBudget;
+
+ /**
+ * 金融分期相关信息
+ */
+ private String financialInstallment;
+
+ /**
+ * 购买周期，客户的购车时间计划
+ */
+ private String purchaseCycle;
+
+ /**
+ * 关注点，客户重点关注的车辆特性
+ */
+ private String focusPoints;
+
+ /**
+ * 担忧问题，客户担心的问题
+ */
+ private String concerns;
+
+ /**
+ * 竞品对比，客户对比的其他品牌车型
+ */
+ private String carContrast;
+
+ /**
+ * 产品介绍，顾问对产品的介绍内容
+ */
+ private String productDescription;
+
+ /**
+ * 解决方案，顾问提供的解决方案
+ */
+ private String solution;
+
+ /**
+ * 报价信息，车辆的价格信息
+ */
+ private String quotation;
+
+ /**
+ * 约定的后续行动，如试驾安排、再次联系等
+ */
+ private String agreedFollowUpActions;
+
+ /**
+ * 未解决问题，对话中尚未解决的问题
+ */
+ private String unresolvedIssues;
+
+ /**
+ * 原始语料，完整的客户与顾问对话内容
+ */
+ private String originalCorpus;
+
+ /**
+ * 创建时间
+ */
+ @TableField(fill = FieldFill.INSERT)
+ private LocalDateTime createdAt;
+
+ /**
+ * 更新时间
+ */
+ @TableField(fill = FieldFill.INSERT_UPDATE)
+ private LocalDateTime updatedAt;
+
+ /**
+ * 逻辑删除标识，0-未删除，1-已删除
+ */
+ @TableLogic
+ private Integer isDeleted;
+}
diff --git a/src/main/java/com/rj/mapper/biz/ConsultingScenarioMapper.java b/src/main/java/com/rj/mapper/biz/ConsultingScenarioMapper.java
new file mode 100644
index 0000000..8418f25
--- /dev/null
+++ b/src/main/java/com/rj/mapper/biz/ConsultingScenarioMapper.java
@@ -0,0 +1,17 @@
+package com.rj.mapper.biz;
+
+
+import com.rj.entity.bz.ConsultingScenario;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ *
+ * 咨询场景表 Mapper 接口
+ *
+ *
+ * @author lingma
+ * @since 2025-09-02
+ */
+public interface ConsultingScenarioMapper extends BaseMapper {
+
+}
diff --git a/src/main/java/com/rj/mapper/biz/DifyWorkflowAnalysisMapper.java b/src/main/java/com/rj/mapper/biz/DifyWorkflowAnalysisMapper.java
new file mode 100644
index 0000000..5338978
--- /dev/null
+++ b/src/main/java/com/rj/mapper/biz/DifyWorkflowAnalysisMapper.java
@@ -0,0 +1,12 @@
+package com.rj.mapper.biz;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.rj.entity.bz.DifyWorkflowAnalysis;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * Dify工作流分析结果Mapper接口
+ */
+@Mapper
+public interface DifyWorkflowAnalysisMapper extends BaseMapper {
+}
diff --git a/src/main/java/com/rj/pojo/sys/LoginResponse.java b/src/main/java/com/rj/pojo/sys/LoginResponse.java
index 2144988..0ab71a9 100644
--- a/src/main/java/com/rj/pojo/sys/LoginResponse.java
+++ b/src/main/java/com/rj/pojo/sys/LoginResponse.java
@@ -38,3 +38,10 @@ public class LoginResponse {
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/scheduler/AudioStatisticsScheduler.java b/src/main/java/com/rj/scheduler/AudioStatisticsScheduler.java
index 428d3a5..42ebf84 100644
--- a/src/main/java/com/rj/scheduler/AudioStatisticsScheduler.java
+++ b/src/main/java/com/rj/scheduler/AudioStatisticsScheduler.java
@@ -57,3 +57,10 @@ public class AudioStatisticsScheduler {
}
}
+
+
+
+
+
+
+
diff --git a/src/main/java/com/rj/service/biz/ConsultingScenarioServiceImpl.java b/src/main/java/com/rj/service/biz/ConsultingScenarioServiceImpl.java
new file mode 100644
index 0000000..f84738f
--- /dev/null
+++ b/src/main/java/com/rj/service/biz/ConsultingScenarioServiceImpl.java
@@ -0,0 +1,189 @@
+package com.rj.service.biz;
+
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.rj.controller.biz.dto.ConsultingScenarioRequest;
+import com.rj.entity.bz.ConsultingScenario;
+import com.rj.mapper.biz.ConsultingScenarioMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.*;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+import java.util.Iterator;
+import java.util.ArrayList;
+import java.util.List;
+import java.time.LocalDateTime;
+
+/**
+ * Author: 李中华 wx: spllzh email(qq): 28668817@qq.com
+ * Date: 2025/9/2 19:56
+ **/
+@Service
+@Slf4j
+public class ConsultingScenarioServiceImpl
+ extends ServiceImpl implements IConsultingScenarioService {
+
+ // Dify API 配置
+ @Value("${dify.api.base-url}")
+ private String difyApiUrlBase;
+
+ @Value("${dify.api.workflow-endpoint-consultingScenar}")
+ private String difyApiUrlEndPoint;
+
+ @Value("${dify.api.apikey-consultingScenar}")
+ private String difyApiKey;
+
+ private final ObjectMapper objectMapper = new ObjectMapper();
+
+ @Override
+ public Object processConsultingScenario(ConsultingScenarioRequest request) {
+ log.info("开始处理咨询场景请求: chat={}, businessType={}, sourceCorpusId={}, sourceCorpusTime={}",
+ request.getChat(), request.getBusinessType(), request.getSourceCorpusId(), request.getSourceCorpusTime());
+
+ try {
+ // 构造调用Dify工作流的请求
+ Map requestBody = new HashMap<>();
+ requestBody.put("inputs", Map.of(
+ "chat", request.getChat(),
+ // Dify 要求在 inputs 中提供 businessType
+ "businessType", request.getBusinessType(),
+ "sourceCorpusId", request.getSourceCorpusId(),
+ "sourceCorpusTime", request.getSourceCorpusTime()
+ ));
+ requestBody.put("response_mode", "blocking");
+ requestBody.put("user", "api_user");
+
+ // 发起HTTP请求调用Dify工作流
+ RestTemplate restTemplate = new RestTemplate();
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ headers.set("Authorization", "Bearer " + difyApiKey);
+
+ HttpEntity> entity = new HttpEntity<>(requestBody, headers);
+ String difyApiUrl = difyApiUrlBase + difyApiUrlEndPoint;
+ log.info("调用Dify工作流: url={}, requestBody={}", difyApiUrl, requestBody);
+
+ ResponseEntity response = restTemplate.postForEntity(difyApiUrl, entity, String.class);
+
+ // 解析响应并打印到控制台
+ JsonNode jsonResponse = objectMapper.readTree(response.getBody());
+ log.info("Dify工作流响应结果: {}", jsonResponse.toPrettyString());
+
+ // 从响应中提取 outputs.text
+ JsonNode outputsNode = jsonResponse.path("data").path("outputs");
+ String textBlock = outputsNode.path("text").asText(null);
+
+ if (textBlock == null || textBlock.isEmpty()) {
+ log.warn("未在响应中找到 outputs.text，返回原始响应");
+ return jsonResponse;
+ }
+
+ // 提取代码块中的 JSON（优先 ```json ... ```，否则回退到最外层花括号）
+ String extractedJson = extractJsonString(textBlock);
+ if (extractedJson == null) {
+ log.warn("未能从文本中提取 JSON，返回原始响应");
+ return jsonResponse;
+ }
+
+ JsonNode parsedNode = objectMapper.readTree(extractedJson);
+
+ // 映射到实体并保存
+ com.rj.entity.bz.ConsultingScenario entityToSave = mapToEntity(parsedNode);
+ // 主键与时间戳
+ if (entityToSave.getId() == null || entityToSave.getId().isEmpty()) {
+ entityToSave.setId(UUID.randomUUID().toString());
+ }
+ entityToSave.setCreatedAt(LocalDateTime.now());
+ entityToSave.setUpdatedAt(LocalDateTime.now());
+
+ boolean saved = this.save(entityToSave);
+ log.info("ConsultingScenario 保存结果: {}", saved);
+
+ Map result = new HashMap<>();
+ result.put("saved", saved);
+ result.put("entity", entityToSave);
+ result.put("difyResponse", jsonResponse);
+ return result;
+ } catch (Exception e) {
+ log.error("调用Dify工作流时发生错误", e);
+ throw new RuntimeException("调用Dify工作流失败: " + e.getMessage(), e);
+ }
+ }
+
+ /**
+ * 从包含思考与代码块的文本中提取 JSON 字符串
+ */
+ private String extractJsonString(String text) {
+ try {
+ String startFlag = "```json";
+ String fence = "```";
+ int start = text.indexOf(startFlag);
+ if (start >= 0) {
+ int jsonStart = start + startFlag.length();
+ int end = text.indexOf(fence, jsonStart);
+ if (end > jsonStart) {
+ return text.substring(jsonStart, end).trim();
+ }
+ }
+ // 回退方案：提取第一个 '{' 到最后一个 '}'
+ int firstBrace = text.indexOf('{');
+ int lastBrace = text.lastIndexOf('}');
+ if (firstBrace >= 0 && lastBrace > firstBrace) {
+ return text.substring(firstBrace, lastBrace + 1);
+ }
+ return null;
+ } catch (Exception e) {
+ log.warn("提取 JSON 文本失败", e);
+ return null;
+ }
+ }
+
+ /**
+ * 将解析后的 JSON 映射为 ConsultingScenario 实体
+ */
+ private com.rj.entity.bz.ConsultingScenario mapToEntity(JsonNode root) {
+ com.rj.entity.bz.ConsultingScenario entity = new com.rj.entity.bz.ConsultingScenario();
+
+ // consultingScenario 主体
+ JsonNode cs = root.path("consultingScenario");
+ if (cs.isObject()) {
+ entity.setMainCategory(cs.path("mainCategory").asText(null));
+ entity.setSubCategory(cs.path("subCategory").asText(null));
+ entity.setConfidence(cs.path("confidence").asText(null));
+ }
+
+ entity.setUserDemand(root.path("userDemand").asText(null));
+ entity.setConsultingContent(joinArray(root.path("consultingContent")));
+ entity.setInvolvedVehicleModels(joinArray(root.path("involvedVehicleModels")));
+ entity.setKnowledgeGap(joinArray(root.path("knowledgeGap")));
+ entity.setPriority(root.path("priority").asText(null));
+ entity.setRemarks(root.path("remarks").asText(null));
+
+ return entity;
+ }
+
+ private String joinArray(JsonNode node) {
+ if (node == null || !node.isArray()) {
+ return null;
+ }
+ List list = new ArrayList<>();
+ Iterator it = node.elements();
+ while (it.hasNext()) {
+ JsonNode n = it.next();
+ if (n.isTextual()) {
+ list.add(n.asText());
+ } else {
+ list.add(n.toString());
+ }
+ }
+ return String.join("\n", list);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/rj/service/biz/DifyWorkflowAnalysisServiceImpl.java b/src/main/java/com/rj/service/biz/DifyWorkflowAnalysisServiceImpl.java
new file mode 100644
index 0000000..e00482c
--- /dev/null
+++ b/src/main/java/com/rj/service/biz/DifyWorkflowAnalysisServiceImpl.java
@@ -0,0 +1,15 @@
+package com.rj.service.biz;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.rj.entity.bz.DifyWorkflowAnalysis;
+
+import com.rj.mapper.biz.DifyWorkflowAnalysisMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * Dify工作流分析结果服务实现类
+ */
+@Service
+public class DifyWorkflowAnalysisServiceImpl extends ServiceImpl
+ implements IDifyWorkflowAnalysisService {
+}
diff --git a/src/main/java/com/rj/service/biz/IConsultingScenarioService.java b/src/main/java/com/rj/service/biz/IConsultingScenarioService.java
new file mode 100644
index 0000000..a84f0c4
--- /dev/null
+++ b/src/main/java/com/rj/service/biz/IConsultingScenarioService.java
@@ -0,0 +1,26 @@
+package com.rj.service.biz;
+
+
+
+import com.rj.controller.biz.dto.ConsultingScenarioRequest;
+import com.rj.entity.bz.ConsultingScenario;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ *
+ * 咨询场景表 服务类
+ *
+ *
+ * @author lingma
+ * @since 2025-09-02
+ */
+public interface IConsultingScenarioService extends IService {
+
+ /**
+ * 处理咨询场景请求
+ * @param request 咨询场景请求参数
+ * @return 处理结果
+ */
+ Object processConsultingScenario(ConsultingScenarioRequest request);
+
+}
diff --git a/src/main/java/com/rj/service/biz/IDifyWorkflowAnalysisService.java b/src/main/java/com/rj/service/biz/IDifyWorkflowAnalysisService.java
new file mode 100644
index 0000000..b232b43
--- /dev/null
+++ b/src/main/java/com/rj/service/biz/IDifyWorkflowAnalysisService.java
@@ -0,0 +1,10 @@
+package com.rj.service.biz;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.rj.entity.bz.DifyWorkflowAnalysis;
+
+/**
+ * Dify工作流分析结果服务接口
+ */
+public interface IDifyWorkflowAnalysisService extends IService {
+}
diff --git a/src/main/java/com/rj/service/sys/IMenuService.java b/src/main/java/com/rj/service/sys/IMenuService.java
index eb6b24a..4462cac 100644
--- a/src/main/java/com/rj/service/sys/IMenuService.java
+++ b/src/main/java/com/rj/service/sys/IMenuService.java
@@ -20,3 +20,10 @@ public interface IMenuService extends IService