From aba4b755a3afc61a07538e4bfd8217979919907d Mon Sep 17 00:00:00 2001
From: shicf <shi_chongfu@163.com>
Date: 星期一, 08 九月 2025 11:42:05 +0800
Subject: [PATCH] 生产实时查询，过站信息修改 制令单关联的工单数据 未找到日志输出
---
product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 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 c9f3a98..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
@@ -533,9 +533,10 @@
maybeUpdate.getData().sort((o1, o2) -> DateUtil.compare(o1.getDate(extractUpdateTimeField), o2.getDate(extractUpdateTimeField)));
- batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, false);
+ batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, true);
WriteExtractUtil.append("鏇存柊鎻愬彇杩囨护鍚庢暟鎹細" + extractTargetTable + ",闇�瑕佹洿鏂扮殑鏉℃暟锛�" + maybeUpdate.getRows() + ",鑰楁椂锛�" + tempTestTimer2.intervalMs());
+ targetNewDao.closeConnection();
}
if (!DataTableEntity.isEmpty(data)) {
@@ -598,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++) {
@@ -606,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());
@@ -624,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