OpService.java
4.86 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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
package com.xly.service;
import com.xly.agent.AgentIdentity;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
* ai_op_queue 队列写入 —— **AI 侧唯一的写入口**（rearch3 §3 写路径收权）。
*
* <p>用户在预览卡/表单上点按钮（保存/审核/作废…）→ 确定性端点校验后经本类落一行
* {@code sStatus='confirmed'}（用户已当面授权）。**xlyAi 工作到此为止**：是否/何时执行、
* 执行权属、审计留痕全部由 ERP 侧负责（暂存执行器读本表；现状=报价自动执行、其余进待办）。
* xlyAi 侧只保留 {@link #statusLabel} 只读展示处理进度（流程卡）。
*
* <p>列名兼容：ERP 执行器仍读 {@code sUserId} → 新列 {@code sMakePerson}（ERP 惯例）双写，
* ERP 侧切换后可删 sUserId。
*/
@Service
public class OpService {
private final JdbcTemplate jdbc;
public OpService(JdbcTemplate jdbc) {
this.jdbc = jdbc;
}
/** 单字段更新入队（update）。 */
public String queueUpdate(AgentIdentity who, String convId, String formId, String moduleId, String table,
String billId, String field, String fieldLabel, String oldValue, String newValue,
String description) {
return insert(who, convId, "update", formId, moduleId, table, billId,
field, fieldLabel, oldValue, newValue, null, description);
}
/** 状态操作入队：invalid（sNewValue=toVoid|cancel）/ examine（sNewValue=1|0）/ delete。 */
public String queueStateOp(AgentIdentity who, String convId, String opType, String formId, String moduleId,
String table, String billId, String sNewValue, String description) {
return insert(who, convId, opType, formId, moduleId, table, billId,
null, null, null, sNewValue, null, description);
}
/** 新增入队（create）：payload = 列->值 JSON（多表用 __tables__）。 */
public String queueCreate(AgentIdentity who, String convId, String formId, String moduleId, String table,
String payload, String description) {
return insert(who, convId, "create", formId, moduleId, table, null,
null, null, null, null, payload, description);
}
private String insert(AgentIdentity who, String convId, String opType, String formId, String moduleId,
String table, String billId, String field, String fieldLabel, String oldValue,
String newValue, String payload, String description) {
String sId = "op-" + System.currentTimeMillis() + "-" + Integer.toHexString((int) (Math.random() * 0xFFFFF));
jdbc.update(
"INSERT INTO ai_op_queue(sId,sUserId,sMakePerson,sBrandsId,sSubsidiaryId,sConversationId,sOpType," +
"sTargetFormId,sTargetModuleId,sTargetTable,sTargetBillId,sField,sFieldLabel," +
"sOldValue,sNewValue,sPayload,sDescription,sStatus,tCreateDate,tConfirmDate) " +
"VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'confirmed',NOW(),NOW())",
sId, who.userId(), who.userId(), who.brandsId(), who.subsidiaryId(), convId, opType,
formId, moduleId, table, billId, field, fieldLabel,
oldValue, newValue, payload, description);
return sId;
}
public Map<String, Object> get(String sId) {
List<Map<String, Object>> r = jdbc.queryForList("SELECT * FROM ai_op_queue WHERE sId=?", sId);
return r.isEmpty() ? null : r.get(0);
}
/** sStatus → 人类可读进度（流程卡只读展示；不做任何处理动作）。查不到返回 null。 */
public String statusLabel(String sId) {
try {
List<Map<String, Object>> r = jdbc.queryForList(
"SELECT sStatus, sResultMsg, sErrorMsg FROM ai_op_queue WHERE sId=?", sId);
if (r.isEmpty()) {
return null;
}
String st = String.valueOf(r.get(0).get("sStatus"));
String msg = str(r.get(0).get("sResultMsg"));
String err = str(r.get(0).get("sErrorMsg"));
return switch (st) {
case "confirmed" -> "已提交，等待 ERP 处理";
case "executing" -> "ERP 处理中";
case "executed" -> "ERP 已执行成功" + (msg.isBlank() ? "" : "：" + msg);
case "failed" -> "ERP 执行失败" + (err.isBlank() ? (msg.isBlank() ? "" : "：" + msg) : "：" + err);
case "cancelled" -> "已取消";
default -> st;
};
} catch (Exception e) {
return null;
}
}
private static String str(Object o) {
return o == null ? "" : o.toString();
}
}