From 95ae0c83d2aa58d86b4039e3f7f16ee93afb8f00 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期五, 23 十月 2026 17:01:00 +0800
Subject: [PATCH] feat(ai): 完善模型管理和智能体导入功能
---
yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/agent/MdmAgentImportCommandService.java | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/agent/MdmAgentImportCommandService.java b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/agent/MdmAgentImportCommandService.java
index 70c8839..173b562 100644
--- a/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/agent/MdmAgentImportCommandService.java
+++ b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/agent/MdmAgentImportCommandService.java
@@ -69,12 +69,15 @@
throw new AgentBridgeException(HttpStatus.SERVICE_UNAVAILABLE, "WRITE_DISABLED",
"鏅鸿兘浣撳啓鍏ュ紑鍏虫湭鎵撳紑锛屾彁浜ゅ凡鎷掔粷");
}
+ if (Boolean.TRUE.equals(reqVO.getSyncMes()) && !policy.isAllowMesSync()) {
+ throw new AgentBridgeException(HttpStatus.UNPROCESSABLE_ENTITY, "MES_SYNC_DISABLED",
+ "鏈嶅姟鏈紑鏀惧悓姝� MES锛岃鍏抽棴 syncMes 鍚庨噸璇�");
+ }
String requestDigest = buildRequestDigest(reqVO);
- Long tenantId = principal.tenantId();
Long ownerUserId = principal.userId();
// 1. 骞傜瓑鍛戒腑锛氬懡浠� ID 浼樺厛锛屽叾娆″箓绛夐敭
- MdmAgentImportCommandDO existing = commandMapper.selectByCommandId(tenantId, ownerUserId, reqVO.getCommandId());
+ MdmAgentImportCommandDO existing = commandMapper.selectByCommandId(ownerUserId, reqVO.getCommandId());
if (existing != null) {
if (!existing.getRequestDigest().equals(requestDigest)) {
throw new AgentBridgeException(HttpStatus.CONFLICT, "COMMAND_ID_CONFLICT",
@@ -82,7 +85,7 @@
}
return toReceipt(existing);
}
- existing = commandMapper.selectByIdempotencyKey(tenantId, ownerUserId, reqVO.getIdempotencyKey());
+ existing = commandMapper.selectByIdempotencyKey(ownerUserId, reqVO.getIdempotencyKey());
if (existing != null) {
if (!existing.getRequestDigest().equals(requestDigest)) {
throw new AgentBridgeException(HttpStatus.CONFLICT, "IDEMPOTENCY_CONFLICT",
@@ -108,7 +111,6 @@
.commandId(reqVO.getCommandId())
.idempotencyKey(reqVO.getIdempotencyKey())
.requestDigest(requestDigest)
- .tenantId(tenantId)
.ownerUserId(ownerUserId)
.sessionId(reqVO.getSessionId())
.attachmentId(reqVO.getAttachmentId())
@@ -124,9 +126,9 @@
try {
commandMapper.insert(command);
} catch (DuplicateKeyException ex) {
- MdmAgentImportCommandDO raced = commandMapper.selectByCommandId(tenantId, ownerUserId, reqVO.getCommandId());
+ MdmAgentImportCommandDO raced = commandMapper.selectByCommandId(ownerUserId, reqVO.getCommandId());
if (raced == null) {
- raced = commandMapper.selectByIdempotencyKey(tenantId, ownerUserId, reqVO.getIdempotencyKey());
+ raced = commandMapper.selectByIdempotencyKey(ownerUserId, reqVO.getIdempotencyKey());
}
if (raced == null) {
throw ex;
@@ -189,7 +191,7 @@
return;
}
MdmItemSaveReqVO saveReqVO = resolution.saveReqVO();
- saveReqVO.setSyncMes(false); // 鏈樁娈靛浐瀹氫笉鍚屾 MES
+ saveReqVO.setSyncMes(Boolean.TRUE.equals(reqVO.getSyncMes()));
Long itemId = itemService.createItem(saveReqVO);
commandRowMapper.insert(baseRow(command.getCommandId(), row)
.action("CREATE").status("SUCCESS").targetItemId(itemId)
@@ -240,7 +242,7 @@
public MdmAgentImportReceiptRespVO getCommand(String commandId, AgentPrincipal principal) {
MdmAgentImportCommandDO command = commandMapper.selectByCommandId(
- principal.tenantId(), principal.userId(), commandId);
+ principal.userId(), commandId);
if (command == null) {
throw new AgentBridgeException(HttpStatus.NOT_FOUND, "COMMAND_NOT_FOUND", "瀵煎叆鍛戒护涓嶅瓨鍦�");
}
--
Gitblit v1.9.3