同步工控网

lyh

2025-06-25 e756af0f5bfd1addbd5d5c145441fb34aad91a28

 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) {