AiSqlErrorHistoryThread.java
2.46 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package com.xly.thread;
import cn.hutool.core.util.StrUtil;
import com.xly.config.SpringContextHolder;
import com.xly.entity.UserSceneSession;
import com.xly.service.DynamicExeDbService;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class AiSqlErrorHistoryThread implements Runnable {
private UserSceneSession session;
private String sSqlContent;
private String sError_sql;
private String sError_mes;
private String sQuestion;
public final String sProName="Sp_Ai_AiSqlErrorHistoryThread";
public AiSqlErrorHistoryThread(UserSceneSession session, String sSqlContent, String sError_sql,String sError_mes,String sQuestion) {
this.session = session;
this.sSqlContent = sSqlContent;
this.sError_sql = sError_sql;
this.sError_mes = sError_mes;
this.sQuestion = sQuestion;
}
@Override
public void run() {
String sSceneId = session.getCurrentScene().getSId();
String sMethodId = session.getCurrentTool().getSId();
DynamicExeDbService dynamicExeDbService = SpringContextHolder.getBean(DynamicExeDbService.class);
Map<String, Object> data = getMap(sSceneId, sMethodId);
data.put("sQuestion",getsQuestion(session.getSUserQuestionList()));
Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
dynamicExeDbService.getCallPro(searMap, sProName);
}
private String getsQuestion(List<String> sUserQuestionList){
return String.join(",", sUserQuestionList);
}
/***
* @Author 钱豹
* @Date 4:22 2026/3/15
* @Param [sSceneId, sMethodId]
* @return java.util.Map<java.lang.String,java.lang.Object>
* @Description 获取执行的动态Map
**/
private Map<String, Object> getMap(String sSceneId, String sMethodId) {
Map<String,Object> data = new HashMap<>(16);
data.put("sSceneId", sSceneId);
data.put("sMethodId", sMethodId);
data.put("sSqlContent",sSqlContent);
data.put("sError_sql",sError_sql);
data.put("sError_mes",sError_mes);
data.put("sBrId",session.getSBrandsId());
data.put("sBrandsId",session.getSBrandsId());
data.put("sSuId",session.getSSubsidiaryId());
data.put("sSubsidiaryId",session.getSSubsidiaryId());
data.put("sLoginId",session.getUserName());
data.put("sUserName",session.getUserName());
data.put("sUserId",session.getUserId());
return data;
}
}