提交代码更新了轨迹03.20

java/src/main/java/com/yfd/platform/component/ServerSendEventServer.java

@@ -57,6 +57,20 @@ public class ServerSendEventServer {
             }
         }
     }
+    public static void sendMessageById(String userId, String message) {
+        if (sseEmitterMap.containsKey(userId)) {
+            try {
+                if(!"0".equals(message)){
+                    sseEmitterMap.get(userId).send(message);
+                }
+
+            } catch (IOException e) {
+                log.error("user id:{}, send message error:{}", userId,
+                        e.getMessage());
+                e.printStackTrace();
+            }
+        }
+    }
 
     /**
      * 给所有用户发消息
@@ -90,6 +104,7 @@ public class ServerSendEventServer {
         }
     }
 
+
     public static void batchSendMessage(String message) {
         sseEmitterMap.forEach((k, v) -> {
             try {
@@ -102,6 +117,7 @@ public class ServerSendEventServer {
         });
     }
 
+
     /**
      * 群发消息
      */

java/src/main/java/com/yfd/platform/modules/experimentalData/controller/TsFilesController.java

@@ -11,6 +11,7 @@ import com.yfd.platform.modules.experimentalData.service.ITsFilesService;
 import com.yfd.platform.modules.specialDocument.domain.Files;
 import com.yfd.platform.modules.specialDocument.service.IFilesService;
 import io.swagger.annotations.ApiOperation;
+import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
@@ -20,6 +21,8 @@ import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executors;
 
 /**
  * <p>
@@ -394,4 +397,24 @@ public class TsFilesController {
     }
 
 
+
+    @PostMapping("/startSimpleNavi")
+    public ResponseResult startSimpleNavi(String id,int samTimes,String token) {
+        try {
+            // 使用线程池异步执行任务
+            CompletableFuture.runAsync(() -> {
+                try {
+                    tsFilesService.batchSendNaviOutDataJob(id, samTimes, token);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }, Executors.newCachedThreadPool());
+
+            return ResponseResult.success("任务已启动");
+        } catch (Exception e) {
+            return ResponseResult.error("任务启动失败: " + e.getMessage());
+        }
+
+    }
+
 }

java/src/main/java/com/yfd/platform/modules/experimentalData/domain/SimpleNaviData.java

@@ -0,0 +1,14 @@
+package com.yfd.platform.modules.experimentalData.domain;
+
+import lombok.Data;
+
+@Data
+public class SimpleNaviData {
+
+    private String UtcTime;      // UTC_TIME
+    private String lat;   // LAT
+    private String lon;    // LON
+    private String alt;    // ALT
+
+
+}

java/src/main/java/com/yfd/platform/modules/experimentalData/service/ITsFilesService.java

@@ -159,4 +159,6 @@ public interface ITsFilesService extends IService<TsFiles> {
      * @return 文件差异列表
      */
     TsFiles compareDirectories(List<String> dataset,String nodeId , String taskId);
+
+    void batchSendNaviOutDataJob(String id, int samTimes,String token);
 }

java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsFilesServiceImpl.java

@@ -10,16 +10,21 @@ import java.text.SimpleDateFormat;
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.*;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
 
+import cn.hutool.json.JSONUtil;
 import com.amazonaws.services.s3.model.ObjectMetadata;
 import com.amazonaws.services.s3.model.S3Object;
 import com.amazonaws.services.s3.model.S3ObjectInputStream;
 import com.amazonaws.util.IOUtils;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yfd.platform.component.ServerSendEventServer;
 import com.yfd.platform.config.ResponseResult;
 import com.yfd.platform.modules.experimentalData.domain.*;
 import com.yfd.platform.modules.experimentalData.mapper.TsFilesMapper;
@@ -35,6 +40,9 @@ import com.yfd.platform.modules.storage.model.request.RenameFileRequest;
 import com.yfd.platform.modules.storage.model.result.FileItemResult;
 import com.yfd.platform.modules.storage.service.base.AbstractBaseFileService;
 import com.yfd.platform.system.domain.LoginUser;
+import com.yfd.platform.system.domain.SysDictionaryItems;
+import com.yfd.platform.system.mapper.SysDictionaryItemsMapper;
+import com.yfd.platform.system.service.ISysDictionaryItemsService;
 import com.yfd.platform.utils.StringUtils;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import org.apache.commons.compress.archivers.zip.ZipArchiveEntry;
@@ -57,9 +65,6 @@ import java.util.zip.ZipInputStream;
 
 import org.apache.commons.codec.binary.Hex;
 
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentMap;
-
 
 /**
  * <p>
@@ -73,6 +78,7 @@ import java.util.concurrent.ConcurrentMap;
 public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> implements ITsFilesService {
     private static final Logger LOGGER = LoggerFactory.getLogger(ChannelInboundHandlerAdapter.class);
 
+    private int time = 1;
 
     //试验任务文档表 Mapper
     @Resource
@@ -84,6 +90,12 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
     @Resource
     private StorageSourceConfigMapper storageSourceConfigMapper;
 
+    @Resource
+    private SysDictionaryItemsMapper sysDictionaryItemsMapper;
+    // 全局变量，用于存储当前任务的 Future
+    private Future<?> currentTaskFuture;
+
+    private final ExecutorService executorService = Executors.newSingleThreadExecutor();
 
     /**********************************
      * 用途说明: 分页查询试验数据管理-文档内容
@@ -101,10 +113,14 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
      ***********************************/
     @Override
     public Page<TsFiles> getTsFilesPage(String id, String fileName, String startDate, String endDate, String keywords, String nodeId, String taskId, String fileName1, String childNode, Page<TsFiles> page) throws Exception {
+        //查询字典表获取压缩文件后缀
+        QueryWrapper<SysDictionaryItems> queryWrapperSysDictionary = new QueryWrapper<>();
+        queryWrapperSysDictionary.eq("parentcode", "compressType");
+        queryWrapperSysDictionary.orderByAsc("orderno");
+        List<SysDictionaryItems> sysDictionaryItems = sysDictionaryItemsMapper.selectList(queryWrapperSysDictionary);
 
 
         QueryWrapper<TsFiles> queryWrapper = new QueryWrapper<>();
-
         // 固定条件过滤
         if (StringUtils.isNotBlank(taskId)) queryWrapper.eq("task_id", taskId);
         if (StringUtils.isNotBlank(nodeId)) queryWrapper.eq("node_id", nodeId);
@@ -185,7 +201,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
             }
             tsFiles.setUrl(fileItemResult.getUrl());
             //如果是压缩文件 类型就给zip
-            boolean isValid = hasValidExtension(fileItemResult.getName());
+            boolean isValid = hasValidExtension(fileItemResult.getName(), sysDictionaryItems);
             if (isValid) {
                 tsFiles.setType("ZIP");
             } else {
@@ -201,12 +217,34 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
 
     }
 
-    public boolean hasValidExtension(String name) {
+    public boolean hasValidExtension(String name, List<SysDictionaryItems> sysDictionaryItems) {
+        // 如果传入的文件名为空，返回 false
         if (name == null) {
-            return false; // 如果传入的文件名为空，返回 false
+            return false;
         }
-        // 判断文件名后缀是否是 .zip 或 .tar
+        // 如果传入的字典表集合为空，返回 false
-        return name.endsWith(".zip") || name.endsWith(".tar") || name.endsWith(".rar") || name.endsWith(".xz") || name.endsWith(".tar.gz") || name.endsWith(".gz") || name.endsWith(".bz2");
+        if (sysDictionaryItems == null || sysDictionaryItems.isEmpty()) {
+            return false;
+        }
+        // 获取文件的扩展名
+        String fileExtension = getFileExtension(name);
+        for (SysDictionaryItems sysDictionaryItems1 : sysDictionaryItems) {
+            String dictName = "." + sysDictionaryItems1.getDictName();
+            if (fileExtension.equalsIgnoreCase(dictName)) {
+                // 如果文件扩展名与字典表中的扩展名匹配，返回 true
+                return true;
+            }
+        }
+        // 如果没有匹配的扩展名，返回 false
+        return false;
+    }
+
+    // 获取文件扩展名的方法
+    private String getFileExtension(String filename) {
+        if (filename != null && filename.contains(".")) {
+            return filename.substring(filename.lastIndexOf("."));
+        }
+        return ""; // 如果没有扩展名，返回空字符串
     }
 
     // 递归获取所有子节点ID（包含隔代子节点）
@@ -357,6 +395,12 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
     @Transactional(rollbackFor = Exception.class)// 添加事务注解，遇到异常时回滚
     public ResponseResult addTsFile(TsFiles tsFiles) {
 
+        // 校验文件名是否包含非法字符
+        String fileName = tsFiles.getFileName();
+        if (containsInvalidCharacters(fileName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
+
         //上传人是当前登录人
         UsernamePasswordAuthenticationToken authentication =
                 (UsernamePasswordAuthenticationToken) SecurityContextHolder.getContext().getAuthentication();
@@ -402,6 +446,14 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
         }
     }
 
+    // 校验文件名是否包含非法字符
+    private boolean containsInvalidCharacters(String fileName) {
+        // 定义非法字符的正则表达式
+        String regex = "[<>:\"/\\\\|?*]";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(fileName);
+        return matcher.find();
+    }
 
     /**********************************
      * 用途说明: 修改试验数据管理-文档内容
@@ -412,6 +464,14 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
     @Override
     @Transactional(rollbackFor = Exception.class)// 添加事务注解，遇到异常时回滚
     public ResponseResult updateTsFiles(TsFiles tsFiles) {
+
+
+        // 校验文件名是否包含非法字符
+        String fileName = tsFiles.getFileName();
+        if (containsInvalidCharacters(fileName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
+
         // 修改之前查询表中的文件名是否修改，如果发生变动先修改 minio 然后再修改表结构
         TsFiles filesData = tsFilesMapper.selectById(tsFiles.getId());
 
@@ -446,13 +506,10 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                 if (flag) {
                     //递归下面所有的文件文件夹  路径都需要修改
                     List<TsFiles> resultList = new ArrayList<>();
-
+                    // 获取当前文件夹的完整路径（如 "/147/222/"）
-                    // 获取父路径（去除自身）
+                    String oldFullPath = filesData.getWorkPath() + filesData.getFileName() + "/";
-                    String parentPath = filesData.getWorkPath();
+                    String newFullPath = filesData.getWorkPath() + tsFiles.getFileName() + "/";
-                    String[] pathParts = parentPath.split("/");
+                    querySubFilesAndUpdatePaths(resultList, tsFiles.getId(), oldFullPath, newFullPath);
-                    int subscript = pathParts.length - 1;
-                    //ID  旧的文件名   新的文件名
-                    querySubFilesAndUpdatePaths(resultList, tsFiles.getId(), filesData.getFileName(), tsFiles.getFileName(), subscript);
                     // 修改数据库
                     int valueUpdate = tsFilesMapper.updateById(tsFiles);
                     if (valueUpdate == 1) {
@@ -516,7 +573,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
     }
 
 
-    private void querySubFilesAndUpdatePaths(List<TsFiles> resultList, String id, String oldName, String newName, int subscript) {
+    private void querySubFilesAndUpdatePaths(List<TsFiles> resultList, String id, String oldName, String newName) {
         // 构造 QueryWrapper 查询当前文件夹下的文件
         QueryWrapper<TsFiles> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("parent_id", id);
@@ -532,37 +589,20 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
 
         // 遍历每个子项，更新路径并递归查询其子项
         for (TsFiles subFile : subFiles) {
-            // 获取原始路径
+
             String oldWorkPath = subFile.getWorkPath();
-            // 替换路径中的 oldName 为 newName，仅替换路径数组中指定下标的部分
+            // 使用正则表达式替换目标文件夹名称
-            String newWorkPath = updatePathAtSubscript(oldWorkPath, oldName, newName, subscript);
+            String newWorkPath = oldWorkPath.replaceAll(oldName, newName);
             // 更新数据库中的路径
             subFile.setWorkPath(newWorkPath);
             tsFilesMapper.updateById(subFile);
             // 递归查询每个子项的子文件
             if ("FOLDER".equals(subFile.getIsFile())) {
-                querySubFilesAndUpdatePaths(resultList, subFile.getId(), oldName, newName, subscript);
+                querySubFilesAndUpdatePaths(resultList, subFile.getId(), oldName, newName);
             }
-            querySubFilesAndUpdatePaths(resultList, subFile.getId(), oldName, newName, subscript);
         }
     }
 
-    // 辅助方法，更新路径中特定下标的部分
-    private String updatePathAtSubscript(String oldPath, String oldName, String newName, int subscript) {
-        // 过滤空值
-        List<String> pathParts = Arrays.stream(oldPath.split("/"))
-                .filter(s -> !s.isEmpty())
-                .collect(Collectors.toList());
-
-        // 确保路径数组下标有效
-        if (pathParts.size() > subscript) {
-            pathParts.set(subscript, pathParts.get(subscript).replace(oldName, newName));
-        }
-
-        // 拼接成新的路径
-        return "/" + String.join("/", pathParts) + "/";
-    }
-
     /**********************************
      * 用途说明: 批量删除试验数据管理-文档内容
      * 参数说明  id 文档内容ID
@@ -889,7 +929,15 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                 tsFiles.setNodeId(filesList.get(0).getNodeId());
                 tsFiles.setWorkPath(compressedPath);
                 tsFiles.setIsFile("FILE");
-                tsFiles.setFileSize(String.valueOf(zipFilePath.toFile().length()));
+
+                // 获取文件大小（字节）
+                long fileSizeInBytes = zipFilePath.toFile().length();
+                // 转换为 MB 并保留两位小数
+                double fileSizeInMB = fileSizeInBytes / (1024.0 * 1024.0);
+                String fileSizeFormatted = String.format("%.2f", fileSizeInMB); // 保留两位小数
+                // 设置文件大小
+                tsFiles.setFileSize(fileSizeFormatted);
+                //tsFiles.setFileSize(String.valueOf(zipFilePath.toFile().length()));
                 tsFiles.setParentId(parentId);
                 tsFiles.setBackupPath("");
                 tsFiles.setKeywords("");
@@ -1128,6 +1176,12 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                         if (file.isDirectory()) {
                             continue;
                         } else {
+                            // 获取文件大小（字节）
+                            long fileSizeInBytes = file.length();
+                            // 转换为 MB 并保留两位小数
+                            double fileSizeInMB = fileSizeInBytes / (1024.0 * 1024.0);
+                            String fileSizeFormatted = String.format("%.2f", fileSizeInMB); // 保留两位小数
+
                             TsFiles fileRecord = createFileRecord(
                                     file.getName(),
                                     parentId,
@@ -1135,7 +1189,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                                     zipFileRecord.getTaskId(),
                                     zipFileRecord.getNodeId(),
                                     zipFileRecord.getUploader(),
-                                    file.length()
+                                    fileSizeFormatted
                             );
                         }
                     }
@@ -1170,7 +1224,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
      * 创建文件记录
      */
     private TsFiles createFileRecord(String fileName, String parentId, String workPath,
-                                     String taskId, String nodeId, String uploader, long fileSize) {
+                                     String taskId, String nodeId, String uploader, String fileSize) {
 
         QueryWrapper<TsFiles> query = new QueryWrapper<TsFiles>()
                 .eq("node_id", nodeId)
@@ -1190,7 +1244,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
             fileRecord.setFileName(fileName);
             fileRecord.setWorkPath(workPath);
             fileRecord.setIsFile("FILE");
-            fileRecord.setFileSize(String.valueOf(fileSize));
+            fileRecord.setFileSize(fileSize);
             fileRecord.setUploadTime(new Timestamp(System.currentTimeMillis()));
             operateTsfeiles(fileRecord); // 插入或更新记录
             return fileRecord;
@@ -1254,6 +1308,12 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                         uploader
                 );
             } else {
+
+                // 获取文件大小（字节）
+                long fileSizeInBytes = child.length();
+                // 转换为 MB 并保留两位小数
+                double fileSizeInMB = fileSizeInBytes / (1024.0 * 1024.0);
+                String fileSizeFormatted = String.format("%.2f", fileSizeInMB); // 保留两位小数
                 // 处理文件（示例：1.txt）
                 TsFiles fileRecord = new TsFiles();
                 fileRecord.setNodeId(nodeId);
@@ -1263,7 +1323,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                 fileRecord.setWorkPath(parentWorkPath); // /333/222/
                 fileRecord.setIsFile("FILE");
                 fileRecord.setUploadTime(new Timestamp(System.currentTimeMillis()));
-                fileRecord.setFileSize(String.valueOf(child.length()));
+                fileRecord.setFileSize(fileSizeFormatted);
                 operateTsfeiles(fileRecord);
 //
 //                tsFilesMapper.insert(fileRecord);
@@ -1537,6 +1597,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
         return tsFiles;
     }
 
+
     // 辅助方法：获取存储配置
     private StorageSourceConfig getStorageConfig(String name) {
         return storageSourceConfigMapper.selectOne(
@@ -1698,6 +1759,8 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
     // 辅助方法：丰富文件元数据
     private FileItemResult enrichFileMetadata(FileItemResult file, String pathType) {
         String aaaa = normalizePath(file.getPath());
+        String bbbb = pathType;
+        System.out.print("aaaa"+ file.getName());
         TsFiles dbRecord = tsFilesMapper.selectOne(
                 new QueryWrapper<TsFiles>()
                         .eq("file_name", file.getName())
@@ -3164,6 +3227,13 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
      * @return 转换后的 DTO
      */
     private TreeDTO convertToDTO(TsFiles node, boolean isLocal) {
+        //查询字典表获取压缩文件后缀
+        QueryWrapper<SysDictionaryItems> queryWrapperSysDictionary = new QueryWrapper<>();
+        queryWrapperSysDictionary.eq("parentcode", "compressType");
+        queryWrapperSysDictionary.orderByAsc("orderno");
+        List<SysDictionaryItems> sysDictionaryItems = sysDictionaryItemsMapper.selectList(queryWrapperSysDictionary);
+
+
         TreeDTO dto = new TreeDTO();
         // 复制公共字段
         dto.setId(node.getId());
@@ -3196,7 +3266,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                 if (fileItemResult != null || fileItemResult.getName() != null) {
                     dto.setUrl(fileItemResult.getUrl());
                     //如果是压缩文件 类型就给zip
-                    boolean isValid = hasValidExtension(fileItemResult.getName());
+                    boolean isValid = hasValidExtension(fileItemResult.getName(), sysDictionaryItems);
                     if (isValid) {
                         dto.setType("ZIP");
                     } else {
@@ -3221,7 +3291,7 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
                 if (fileItemResult != null || fileItemResult.getName() != null) {
                     dto.setUrl(fileItemResult.getUrl());
                     //如果是压缩文件 类型就给zip
-                    boolean isValid = hasValidExtension(fileItemResult.getName());
+                    boolean isValid = hasValidExtension(fileItemResult.getName(), sysDictionaryItems);
                     if (isValid) {
                         dto.setType("ZIP");
                     } else {
@@ -3235,4 +3305,120 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
         return dto;
     }
 
+
+    /*******************************************读取文件内容经纬度**************************************************************/
+
+    @Override
+    public void batchSendNaviOutDataJob(String id, int samTimes, String token) {
+        if (currentTaskFuture != null && !currentTaskFuture.isDone()) {
+            currentTaskFuture.cancel(true); // 中断之前的任务
+        }
+        currentTaskFuture = executorService.submit(() -> {
+            TsFiles tsFiles = tsFilesMapper.selectById(id);
+            StorageSourceConfig config = storageSourceConfigMapper.selectOne(
+                    new QueryWrapper<StorageSourceConfig>().eq("name", "filePath"));
+            Path filePath = Paths.get(config.getValue() + tsFiles.getWorkPath() + tsFiles.getFileName());
+
+            try (BufferedReader reader = new BufferedReader(new FileReader(filePath.toFile()))) {
+                reader.readLine(); // 跳过标题行
+
+                // 不管 samTimes 如何，先读取第一行数据
+                String firstLine = reader.readLine();
+                if (firstLine != null) {
+                    firstLine = firstLine.trim();
+                    String[] values = firstLine.split("\t");
+                    if (values.length >= 40) {
+                        // 发送第一行数据
+                        sendData(token, values, 1);
+                    } else {
+                        System.err.println("忽略不完整行: " + firstLine);
+                    }
+                }
+
+                int step = samTimes * 200; // 计算行号间隔
+                int lineCount = 1; // 从第一行开始
+
+                while (!Thread.currentThread().isInterrupted()) {
+                    lineCount += step; // 直接跳到下一个需要读取的行
+                    String line = null;
+
+                    // 读取指定行
+                    for (int i = 0; i < step; i++) {
+                        line = reader.readLine();
+                        if (line == null) break; // 文件结束
+                    }
+
+                    if (line == null) break; // 文件结束
+
+                    line = line.trim();
+                    String[] values = line.split("\t");
+                    if (values.length < 40) {
+                        LOGGER.info("忽略不完整行: " + line);
+                        continue;
+                    }
+
+                    // 发送数据
+                    sendData(token, values, lineCount);
+
+                    // 固定休眠 3 秒
+                    try {
+                        Thread.sleep(3000);
+                    } catch (InterruptedException e) {
+                        // 如果休眠期间被中断，则退出循环
+                        Thread.currentThread().interrupt();
+                        break;
+                    }
+                }
+
+                // 发送完成信号（如果需要）
+                if (!Thread.currentThread().isInterrupted()) {
+                  //  ServerSendEventServer.sendMessage(token, "COMPLETED");
+                }
+
+            } catch (Exception e) {
+                // 捕获异常并记录日志
+                LOGGER.error("任务执行失败: " + e.getMessage());
+                e.printStackTrace();
+            }
+        });
+    }
+
+
+    // 封装发送数据的逻辑
+    private void sendData(String token, String[] values, int lineCount) {
+        if (Thread.currentThread().isInterrupted()) {
+            return; // 如果线程已被中断，则直接返回
+        }
+
+        try {
+            SimpleNaviData data = parseLine(values);
+            String jsonData = JSONUtil.toJsonStr(data); // 假设 JSONUtil.toJsonStr 不会抛出 IOException
+            ServerSendEventServer.sendMessageById(token, jsonData); // 假设 sendMessage 不会抛出 IOException
+            LOGGER.info("Line " + lineCount + " sent at: " + System.currentTimeMillis());
+        } catch (Exception e) {
+            // 捕获所有可能的异常
+            LOGGER.error("发送数据失败: " + e.getMessage());
+            if (e.getCause() instanceof InterruptedException) {
+                Thread.currentThread().interrupt(); // 重新设置中断状态
+            }
+        }
+    }
+
+    // 辅助方法：解析行数据
+    private SimpleNaviData parseLine(String[] values) {
+        SimpleNaviData data = new SimpleNaviData();
+        data.setUtcTime(getValueSafely(values, 8, "0.0")); // UTC_TIME（索引8）
+        data.setLat(getValueSafely(values, 17, "0.0"));    // LAT（索引17）
+        data.setLon(getValueSafely(values, 18, "0.0"));    // LON（索引18）
+        data.setAlt(getValueSafely(values, 19, "0.0"));    // ALT（索引19）
+        return data;
+    }
+
+    // 安全获取数组值的方法
+    private String getValueSafely(String[] values, int index, String defaultValue) {
+        return (index < values.length) ? values[index] : defaultValue;
+    }
 }
+
+
+

java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsNodesServiceImpl.java

@@ -35,6 +35,8 @@ import javax.annotation.Resource;
 import java.sql.Timestamp;
 import java.time.LocalDateTime;
 import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
 /**
@@ -244,6 +246,12 @@ public class TsNodesServiceImpl extends ServiceImpl<TsNodesMapper, TsNodes> impl
     @Transactional(rollbackFor = Exception.class) // 添加事务注解，遇到异常时回滚
     public ResponseResult addTsNodes(TsNodes tsnodes) {
 
+
+        // 校验文件名是否包含非法字符
+        String nodeName = tsnodes.getNodeName();
+        if (containsInvalidCharacters(nodeName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
         //  差不多的流程  就是提出来  然后判断  如果两个 中有一个是true
         //获取当前登录用户
         UsernamePasswordAuthenticationToken authentication =
@@ -283,6 +291,17 @@ public class TsNodesServiceImpl extends ServiceImpl<TsNodesMapper, TsNodes> impl
 
     }
 
+
+    // 校验文件名是否包含非法字符
+    private boolean containsInvalidCharacters(String nodeName) {
+        // 定义非法字符的正则表达式
+        String regex = "[<>:\"/\\\\|?*]";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(nodeName);
+        return matcher.find();
+    }
+
+
     /**********************************
      * 用途说明: 修改试验任务节点
      * 参数说明  tsnodes  试验任务节点信息
@@ -290,10 +309,16 @@ public class TsNodesServiceImpl extends ServiceImpl<TsNodesMapper, TsNodes> impl
      ***********************************/
     @Override
     public ResponseResult updateTsNodes(TsNodes tsnodes) {
+
+        // 校验文件名是否包含非法字符
+        String nodeName = tsnodes.getNodeName();
+        if (containsInvalidCharacters(nodeName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
+
         //查询没改之前的节点名称
         TsNodes nodesold = tsNodesMapper.selectById(tsnodes.getNodeId());
-        //新的节点名称
+
-        String nodeName = tsnodes.getNodeName();
         //老的节点名称
         String nodeNameOld = null;
         if (ObjUtil.isNotEmpty(nodesold)) {

java/src/main/java/com/yfd/platform/modules/specialDocument/service/impl/FilesServiceImpl.java

@@ -6,6 +6,7 @@ import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yfd.platform.config.ResponseResult;
 import com.yfd.platform.exception.file.InvalidStorageSourceException;
 import com.yfd.platform.modules.config.model.request.FileListRequest;
 import com.yfd.platform.modules.specialDocument.domain.Files;
@@ -41,6 +42,8 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 /**
  * <p>
@@ -187,6 +190,13 @@ public class FilesServiceImpl extends ServiceImpl<FilesMapper, Files> implements
     @Override
     public Boolean addFiles(Files files) {
         Boolean value = false;
+        // 校验文件名是否包含非法字符
+        String fileName = files.getFileName();
+        if (containsInvalidCharacters(fileName)) {
+            return value;
+        }
+
+
         //  String[] splitIds = ids.split(",");   BigDecimal
         List<String> names = Arrays.asList(files.getFileName().split(","));
         List<String> sizes = Arrays.asList(files.getFileSize().split(","));
@@ -253,6 +263,12 @@ public class FilesServiceImpl extends ServiceImpl<FilesMapper, Files> implements
     @Override
     @Transactional(rollbackFor = Exception.class)// 添加事务注解，遇到异常时回滚
     public boolean updateFiles(Files files) {
+        // 校验文件名是否包含非法字符
+        String fileName = files.getFileName();
+        if (containsInvalidCharacters(fileName)) {
+            return false;
+        }
+
         // 修改之前查询表中的文件名是否修改，如果发生变动先修改 minio 然后再修改表结构
         Files filesData = filesMapper.selectById(files.getId());
 
@@ -282,6 +298,14 @@ public class FilesServiceImpl extends ServiceImpl<FilesMapper, Files> implements
         }
     }
 
+    // 校验文件名是否包含非法字符
+    private boolean containsInvalidCharacters(String fileName) {
+        // 定义非法字符的正则表达式
+        String regex = "[<>:\"/\\\\|?*]";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(fileName);
+        return matcher.find();
+    }
 
     /**********************************
      * 用途说明: 根据ID删除专项文档管理-文档内容

java/src/main/java/com/yfd/platform/modules/specialDocument/service/impl/NodesServiceImpl.java

@@ -36,6 +36,8 @@ import javax.annotation.Resource;
 import java.sql.Timestamp;
 import java.time.LocalDateTime;
 import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 /**
  * <p>
@@ -259,6 +261,12 @@ public class NodesServiceImpl extends ServiceImpl<NodesMapper, Nodes> implements
     @Transactional(rollbackFor = Exception.class) // 添加事务注解，遇到异常时回滚
     public ResponseResult addNodes(Nodes nodes) {
 
+        // 校验文件名是否包含非法字符
+        String nodeName = nodes.getNodeName();
+        if (containsInvalidCharacters(nodeName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
+
         //获取当前登录用户
         UsernamePasswordAuthenticationToken authentication =
                 (UsernamePasswordAuthenticationToken) SecurityContextHolder.getContext().getAuthentication();
@@ -333,10 +341,15 @@ public class NodesServiceImpl extends ServiceImpl<NodesMapper, Nodes> implements
     @Override
     @Transactional(rollbackFor = Exception.class) // 添加事务注解，遇到异常时回滚
     public ResponseResult updateNodes(Nodes nodes) {
-        //查询没改之前的节点名称
+
-        Nodes nodesold = nodesMapper.selectById(nodes.getId());
         //新的节点名称
         String nodeName = nodes.getNodeName();
+        if (containsInvalidCharacters(nodeName)) {
+            return ResponseResult.error("文件名包含非法字符（<>:\"/\\|?*）！");
+        }
+
+        //查询没改之前的节点名称
+        Nodes nodesold = nodesMapper.selectById(nodes.getId());
         //老的节点名称
         String nodeNameOld = null;
         if (ObjUtil.isNotEmpty(nodesold)) {
@@ -405,6 +418,15 @@ public class NodesServiceImpl extends ServiceImpl<NodesMapper, Nodes> implements
         }
     }
 
+    // 校验文件名是否包含非法字符
+    private boolean containsInvalidCharacters(String nodeName) {
+        // 定义非法字符的正则表达式
+        String regex = "[<>:\"/\\\\|?*]";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(nodeName);
+        return matcher.find();
+    }
+
     /**
      * 更新文件路径中的节点名称
      */

java/src/main/java/com/yfd/platform/modules/specialDocument/service/impl/ProjectServiceImpl.java

@@ -7,6 +7,7 @@ import com.yfd.platform.modules.specialDocument.domain.Project;
 import com.yfd.platform.modules.specialDocument.mapper.ProjectMapper;
 import com.yfd.platform.modules.specialDocument.service.IProjectService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yfd.platform.system.domain.SysDictionaryItems;
 import com.yfd.platform.system.mapper.SysDictionaryItemsMapper;
 import com.yfd.platform.utils.StringUtils;
 import org.springframework.stereotype.Service;
@@ -31,6 +32,11 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
     @Resource
     private ProjectMapper projectMapper;
 
+
+    //字典表Mapper
+    @Resource
+    private SysDictionaryItemsMapper sysDictionaryItemsMapper;
+
     /**********************************
      * 用途说明: 分页查询专项文档管理-项目管理
      * 参数说明
@@ -42,6 +48,7 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
      ***********************************/
     @Override
     public Page<Project> getSdProjectPage(String projectCode, String projectType, String projectName, Page<Project> page) {
+
         LambdaQueryWrapper<Project> queryWrapper = new LambdaQueryWrapper<>();
         //如果项目编号 projectCode 不为空
         if (StringUtils.isNotEmpty(projectCode)) {
@@ -49,7 +56,18 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
         }
         //如果项目类型 projectType 不为空
         if (StringUtils.isNotEmpty(projectType)) {
-            queryWrapper.like(Project::getProjectType, projectType);
+
+            //查询字典表获取项目类型对应数据字典
+            QueryWrapper<SysDictionaryItems> queryWrapperSysDictionary = new QueryWrapper<>();
+            queryWrapperSysDictionary.eq("parentcode", "zxxmlx");
+            queryWrapperSysDictionary.eq("itemcode", projectType);
+            queryWrapperSysDictionary.orderByAsc("orderno");
+            SysDictionaryItems sysDictionaryItems = sysDictionaryItemsMapper.selectOne(queryWrapperSysDictionary);
+            if(sysDictionaryItems != null){
+                queryWrapper.like(Project::getProjectType, sysDictionaryItems.getDictName());
+            }else {
+                queryWrapper.like(Project::getProjectType, projectType);
+            }
         }
         //如果项目名称 projectName 不为空
         if (StringUtils.isNotEmpty(projectName)) {
@@ -70,6 +88,17 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
      ***********************************/
     @Override
     public Boolean addSdproject(Project project) {
+        //查询字典表获取项目类型对应数据字典
+        QueryWrapper<SysDictionaryItems> queryWrapperSysDictionary = new QueryWrapper<>();
+        queryWrapperSysDictionary.eq("parentcode", "zxxmlx");
+        queryWrapperSysDictionary.eq("itemcode", project.getProjectType());
+        queryWrapperSysDictionary.orderByAsc("orderno");
+        SysDictionaryItems sysDictionaryItems = sysDictionaryItemsMapper.selectOne(queryWrapperSysDictionary);
+        if(sysDictionaryItems != null){
+            project.setProjectType(sysDictionaryItems.getDictName());
+        }
+
+
         //TODO 01.21沟通以后说是先不用管重复校验问题
 //        //通过项目名称 项目编号查询 查看是否存在
 //        QueryWrapper<Project> queryWrapper = new QueryWrapper<>();
@@ -104,6 +133,17 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
      ***********************************/
     @Override
     public boolean updateSdproject(Project project) {
+        //查询字典表获取项目类型对应数据字典
+        QueryWrapper<SysDictionaryItems> queryWrapperSysDictionary = new QueryWrapper<>();
+        queryWrapperSysDictionary.eq("parentcode", "zxxmlx");
+        queryWrapperSysDictionary.eq("itemcode", project.getProjectType());
+        queryWrapperSysDictionary.orderByAsc("orderno");
+        SysDictionaryItems sysDictionaryItems = sysDictionaryItemsMapper.selectOne(queryWrapperSysDictionary);
+        if(sysDictionaryItems != null){
+            project.setProjectType(sysDictionaryItems.getDictName());
+        }
+
+
         int valueUpdate = projectMapper.updateById(project);
         if (valueUpdate == 1) {
             return true;