From b5fd4d5dd05e13af32ad50334f5e2f0f8aa56d59 Mon Sep 17 00:00:00 2001
From: lyh <liuyuanheng@xalxzn.com>
Date: 星期六, 14 六月 2025 23:56:26 +0800
Subject: [PATCH] 工控网解析 涉密网产品结构树(添加权限)、nc文件、刀具列表、程序加工确认表

---
 lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/listener/FileListener.java |   22 +++++++++++++++-------
 1 files changed, 15 insertions(+), 7 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 85f68be..65bbe03 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,25 +1,26 @@
 package org.jeecg.modules.dnc.listener;
 import org.apache.commons.io.monitor.FileAlterationListener;
 import org.apache.commons.io.monitor.FileAlterationObserver;
-import org.jeecg.common.util.FileUtil;
-import org.jeecg.modules.dnc.service.IDocInfoService;
-import org.jeecg.modules.dnc.utils.file.FileUtilS;
-import org.jeecg.modules.message.enums.DeployEnum;
+import org.jeecg.modules.dnc.dto.TransferPackage;
+import org.jeecg.modules.dnc.service.impl.DataImportService;
+import org.jeecg.modules.dnc.service.impl.FileFerryService;
 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 {
     private static final Logger log = LoggerFactory.getLogger(FileListener.class);
 
     @Autowired
-    private IDocInfoService docInfoService;  // 鏂囨。鏈嶅姟
+    private FileFerryService fileFerryService;
+
+    @Autowired
+    private DataImportService dataImportService;
+
 
     @Override
     public void onStart(FileAlterationObserver observer) {
@@ -45,6 +46,13 @@
     public void onFileCreate(File file) {
         String filePath = file.getAbsolutePath();
         log.info("[鏂板缓]: {}", filePath);
+//        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