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 |   19 ++++++++++++-------
 1 files changed, 12 insertions(+), 7 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 148d9ab..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
@@ -363,13 +363,6 @@
 			WriteExtractUtil.append("宸叉湁浠诲姟鍦ㄨ繍琛岃烦杩囨娆¤繍琛岋紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒:::" + uuid);
 			return;
 		}
-		//鍑屾櫒1鐐�10鍒嗗紑濮嬭繘鍏ユ鏂规硶鐨勪紤鐪犲埌1鐐�20鍒�
-		Calendar calendar = Calendar.getInstance();
-		int hour = calendar.get(Calendar.HOUR_OF_DAY);
-		int minute = calendar.get(Calendar.MINUTE);
-		if (hour == 1 && (minute >= 10 && minute <= 20)) {
-			return;
-		}
 		WriteExtractUtil.append("寮�濮嬫彁鍙栵紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒锛侊紒:::" + uuid);
 		TimeInterval tempTestTimer = DateUtil.timer();
 		WriteExtractUtil.append("鎻愬彇-绛夊緟鑰楁椂锛�" + tempTestTimer.intervalMs() + ",:::" + uuid);
@@ -606,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++) {
@@ -614,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());
@@ -632,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