工控网解析 涉密网产品结构树（添加权限）、nc文件、刀具列表、程序加工确认表

lyh

2025-06-14 b5fd4d5dd05e13af32ad50334f5e2f0f8aa56d59

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