From e756af0f5bfd1addbd5d5c145441fb34aad91a28 Mon Sep 17 00:00:00 2001
From: lyh <925863403@qq.com>
Date: 星期三, 25 六月 2025 13:55:58 +0800
Subject: [PATCH] 同步工控网
---
lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java
index bfd8427..5b8b097 100644
--- a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java
+++ b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java
@@ -1,5 +1,4 @@
package org.jeecg.modules.dnc.listener;
-
import org.apache.commons.io.monitor.FileAlterationListener;
import org.apache.commons.io.monitor.FileAlterationObserver;
import org.jeecg.modules.dnc.dto.TransferPackage;
@@ -8,9 +7,11 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.io.File;
+import java.util.Objects;
@Component
public class FileListener implements FileAlterationListener {
@@ -21,6 +22,7 @@
@Autowired
private DataImportService dataImportService;
+
@Override
public void onStart(FileAlterationObserver observer) {
@@ -46,11 +48,13 @@
public void onFileCreate(File file) {
String filePath = file.getAbsolutePath();
log.info("[鏂板缓]: {}", filePath);
- if (filePath.endsWith(".ferry")){
- TransferPackage data = fileFerryService.importData(filePath);
- dataImportService.importTransferPackage(data);
- log.info("鏂囦欢瀵煎叆瀹屾垚");
- }
+// if (filePath.startsWith(fileMonitorConfig.getPaths().get(0))){
+ if (filePath.endsWith(".ferry")){
+ TransferPackage data = fileFerryService.importData(filePath);
+ dataImportService.importTransferPackage(data);
+ log.info("鏂囦欢瀵煎叆瀹屾垚");
+ }
+// }
}
@Override
public void onFileChange(File file) {
--
Gitblit v1.9.3