| | |
|---|
| | | |
|---|
| | | boolean syncMesRequested = Boolean.TRUE.equals(reqVO.getSyncMes()); |
|---|
| | | List<MdmAgentImportPreflightRespVO.Issue> blockingItems = new ArrayList<>(); |
|---|
| | | if (syncMesRequested) { |
|---|
| | | if (syncMesRequested && !policy.isAllowMesSync()) { |
|---|
| | | blockingItems.add(issue("MES_SYNC_DISABLED", "syncMes", |
|---|
| | | "本阶段不开放同步 MES，请关闭 syncMes 后重试", false)); |
|---|
| | | "服务未开放同步 MES，请关闭 syncMes 后重试", false)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 4. 文件内重复编码：所有重复行一起阻断，避免“首行建、次行跳”的误导 |
|---|
| | |
|---|
| | | .blocked(blockedCount) |
|---|
| | | .build()) |
|---|
| | | .canCommit(canCommit) |
|---|
| | | .sideEffects(canCommit ? List.of("mdm_item.create:" + createCount) : List.of()) |
|---|
| | | .sideEffects(canCommit |
|---|
| | | ? (syncMesRequested |
|---|
| | | ? List.of("mdm_item.create:" + createCount, "mes_md_item.sync:" + createCount) |
|---|
| | | : List.of("mdm_item.create:" + createCount)) |
|---|
| | | : List.of()) |
|---|
| | | .rows(rows) |
|---|
| | | .blockingItems(blockingItems) |
|---|
| | | .build(); |
|---|
