deepseek优化

src/main/java/admin/model/WebSocketModel.java

@@ -93,9 +93,9 @@ public class WebSocketModel {
         return baseMode;
     }
 
-    public static WebSocketModel createDataList(String action, String type, String content) {
+    public static WebSocketModel createDataList(String action, String type, String content,String dataList) {
         WebSocketModel baseMode = createBaseMode(action, type, content);
-        baseMode.setDataList(content);
+        baseMode.setDataList(dataList);
         return baseMode;
     }
 }

src/main/java/admin/modules/chatgpt/domain/ChatgptRoleRecords.java

@@ -58,6 +58,8 @@ public class ChatgptRoleRecords implements Serializable {
 
     @ApiModelProperty(value = "内容")
     private String content;
+    @ApiModelProperty(value = "1-深度分析 2-普通问答")
+    private Integer isDepth;
     public void copyFrom(ChatgptRoleRecords source){
         BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
     }

src/main/java/admin/modules/chatgpt/service/dto/ChatgptRoleRecordsDto.java

@@ -59,4 +59,8 @@ public class ChatgptRoleRecordsDto implements Serializable {
          * 内容
          */
         private String content;
+    /**
+     * 1-深度 2-普通问答
+     */
+    private Integer isDepth;
 }

src/main/java/admin/rest/ChatgptRoleRecordsController.java

@@ -60,11 +60,14 @@ public class ChatgptRoleRecordsController {
 
     @ApiOperation("收藏会话")
     @GetMapping(value = "collect/list")
-    public ApiResponse<Object> collectList(String content,String sessionId){
+    public ApiResponse<Object> collectList(String content,String sessionId,Integer isDepth){
         List<ChatgptRoleRecords> list = chatgptRoleRecordsService.lambdaQuery()
                 .eq(ChatgptRoleRecords::getMessage, content)
                 .eq(ChatgptRoleRecords::getSessionId,sessionId).list();
-        list.forEach(i->i.setIsCollect(1));
+        list.forEach(i->{
+            i.setIsCollect(1);
+            i.setIsDepth(isDepth);
+        });
         chatgptRoleRecordsService.updateBatchById(list);
         return ApiResponse.buildSuccess();
     }

src/main/java/admin/server/VoiceWebSocketServer.java

@@ -189,15 +189,16 @@ public class VoiceWebSocketServer {
             if (byId == null){
                 chatgptRoleSessionService.saveRecord(Integer.valueOf(webSocketModel.getSessionId()),
                         webSocketModel.getData(),10001,ScreenEnum.getByUserName(webSocketModel.getName()));
-                //创建问题记录
-                chatgptRoleRecordsService.saveRecords(webSocketModel.getData(),10001,Integer.valueOf(webSocketModel.getSessionId()),ScreenEnum.getByUserName(webSocketModel.getName()),1);
             }
+            //创建问题记录
+            chatgptRoleRecordsService.saveRecords(webSocketModel.getData(),10001,Integer.valueOf(webSocketModel.getSessionId()),ScreenEnum.getByUserName(webSocketModel.getName()),1);
+
             PythonApiReq pythonApiReq = new PythonApiReq();
             pythonApiReq.setQuestion(webSocketModel.getData());
             PythonResp analysisData = pythonOpenApiClient.getAnalysisData(pythonApiReq);
             if (analysisData.getType().equals(1)) {
                 //左边内容
-                sendMessage(session,JSONObject.toJSONString( WebSocketModel.createDataList("reply","text",analysisData.getData())));
+                sendMessage(session,JSONObject.toJSONString( WebSocketModel.createDataList("reply","text",analysisData.getData(),analysisData.getDataList())));
                 //右边内容
                 sendMessage(session,JSONObject.toJSONString( WebSocketModel.createBaseMode("rightReply","text",analysisData.getDataList())));
                 //结束标识