工控网涉密网联调

yangys

2025-09-29 4c7296d45efe849dc70a3b2e2240c905481a91c9

 blade-service/blade-mdm/src/main/java/org/springblade/mdm/config/InitBean.java

@@ -6,6 +6,7 @@
import org.apache.commons.lang3.StringUtils;
import org.springblade.mdm.basesetting.machine.service.MachineService;
import org.springblade.mdm.basesetting.machine.entity.Machine;
import org.springblade.mdm.commons.service.MachineDirTranslator;
import org.springblade.mdm.commons.service.ParamService;
import org.springblade.mdm.flow.service.TaskDispatchService;
import org.springblade.mdm.machinefile.entity.MachineFile;
@@ -34,10 +35,7 @@
   private final ProgramAnnotationService annotationService;
   private final MachineFileScanService machineFileScanService;
   private final TaskDispatchService taskDispatchService;

   //@Value("${task.file_scan_on_start:true}")
   //@Value("${task.fileScanOnStart:true}")
   //public boolean fileScanOnStart;
   private final MachineDirTranslator dirTranslator;
   private final TaskPropertieBean taskPropertieBean;
   @PostConstruct
   public void init() {
@@ -52,7 +50,6 @@
         log.info("工控网启动文件监控");
         initMachineDirMonitor();
      }else{

         //涉密网
         taskDispatchService.resetDrawingNos();
      }
@@ -76,6 +73,7 @@
      machineList.forEach(m -> {
         addToWatchDirList(monitorInfoList,m);
      });

      for (WatchInfo info : monitorInfoList) {
         try {
            Path dirPath = Paths.get(info.getPath());
@@ -94,7 +92,8 @@
      String dir;
      //加入send文件夹
      if (StringUtils.isNotEmpty(machine.getProgSendDir())) {
         dir = StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgSendDir(), "/"), "\\");
         //dir = dirTranslator.trans(StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgSendDir(), "/"), "\\"));
         dir = fixMachineDir(machine.getProgSendDir());
         WatchInfo watchInfo = new WatchInfo();
         watchInfo.setMachine(machine);
         watchInfo.setDirType(MachineFile.DIR_TYPE_SEND);
@@ -106,7 +105,8 @@

      //加入rec文件夹
      if (StringUtils.isNotEmpty(machine.getProgReceiveDir())) {
         dir = StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgReceiveDir(), "/"), "\\");
         //dir = StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgReceiveDir(), "/"), "\\");
         dir = fixMachineDir(machine.getProgReceiveDir());
         WatchInfo watchInfo = new WatchInfo();
         watchInfo.setMachine(machine);
         watchInfo.setDirType(MachineFile.DIR_TYPE_REC);
@@ -118,7 +118,8 @@

      //加入temp文件夹
      if (StringUtils.isNotEmpty(machine.getProgTempDir())) {
         dir = StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgTempDir(), "/"), "\\");
         //dir = StringUtils.removeEnd(StringUtils.removeEnd(machine.getProgTempDir(), "/"), "\\");
         dir = fixMachineDir(machine.getProgTempDir());
         WatchInfo watchInfo = new WatchInfo();
         watchInfo.setMachine(machine);
         watchInfo.setDirType(MachineFile.DIR_TYPE_TEMP);
@@ -129,6 +130,15 @@
      }
   }

   /**
    * 翻译共享文件夹路径到 标准网络路径，去掉末尾路径分割不
    * @param dirpath 原始路径
    * @return 转换后的路径
    */
   String fixMachineDir(String dirpath){
      return dirTranslator.trans(StringUtils.removeEnd(StringUtils.removeEnd(dirpath, "/"), "\\"));
   }

   FileWatcherService.FileChangeListener getListener(WatchInfo info) {
      return new MachineFileChangeListener(machineFileService,annotationService,info);
   }