From 5d2411baa5ae84890430a2d7e360fc6777054797 Mon Sep 17 00:00:00 2001
From: shicf <shi_chongfu@163.com>
Date: 星期一, 08 九月 2025 11:44:48 +0800
Subject: [PATCH] 判断事务是否自动提交，执行提交 ，添加日志输出
---
product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java | 12 ++++++++++++
1 files changed, 12 insertions(+), 0 deletions(-)
diff --git a/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java b/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
index 31c710e..c96f279 100644
--- a/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
+++ b/product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
@@ -599,6 +599,8 @@
if (DataTableEntity.isEmpty(dt) || !"T_PM_MO_BASE".equalsIgnoreCase(targetTable)) {
return;
}
+ StringBuilder b=new StringBuilder();
+ b.append("select * from T_PM_PROJECT_BASE where project_id in( ");
Map<String, FieldSetEntity> map = new HashMap<>();
List<Object> moNumberList = new ArrayList<>();
for (int i = 0; i < dt.getRows(); i++) {
@@ -607,8 +609,13 @@
continue;
}
moNumberList.add(moNumber);
+
+ if(i>0)b.append(",");
+ b.append(moNumber);
+
map.put(moNumber, dt.getFieldSetEntity(i));
}
+ b.append(" ) ");
//鏌ヨ鍒朵护鍗曞叧鑱旂殑宸ュ崟鏁版嵁
DataTableEntity projectBaseDt = targetDao.getList("T_PM_PROJECT_BASE", new String[]{"PROJECT_ID,PROJECT_BASE_ID"},
BaseUtil.buildQuestionMarkFilter("project_id", moNumberList.size(), true), moNumberList.toArray(), null, 1, dt.getRows());
@@ -625,6 +632,11 @@
}
}
if (!map.isEmpty()) {
+ b.append("\r\n鏈壘鍒板伐鍗曪細");
+ map.forEach((key, value) -> {
+ b.append(key).append(",");
+ });
+ SpringMVCContextHolder.getSystemLogger().error(b.toString());
throw new BaseException(ErrorCode.MO_NUMBER_MASTER_PROJECT_BASE_EMPTY);
}
}
--
Gitblit v1.9.2