From 1e4e4ea58629e75493002151fddc7b2f4789fd48 Mon Sep 17 00:00:00 2001 From: "CHINAMI-V47SHQD\\EDY" Date: Tue, 18 Nov 2025 11:18:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E8=AF=BB=E5=8F=96ubuntu?= =?UTF-8?q?=E6=96=87=E4=BB=B6=EF=BC=8C=E8=AF=BB=E5=8F=96=E5=86=85=E5=AE=B9?= =?UTF-8?q?=E5=90=8E=E7=A7=BB=E5=8A=A8=E5=88=B0=E5=A4=87=E4=BB=BD=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/youchain/utils/DateUtil.java | 53 +++++++ .../utils/readFilebak/ReadFileData.java | 38 +++++ .../readFilebak/ReadFileDataRepository.java | 30 ++++ .../utils/readFilebak/ReadUbuntuFiles.java | 138 ++++++++++++++++++ 4 files changed, 259 insertions(+) create mode 100644 youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileData.java create mode 100644 youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileDataRepository.java create mode 100644 youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadUbuntuFiles.java diff --git a/youchain-common/src/main/java/com/youchain/utils/DateUtil.java b/youchain-common/src/main/java/com/youchain/utils/DateUtil.java index 84d6938..a4bfc0d 100644 --- a/youchain-common/src/main/java/com/youchain/utils/DateUtil.java +++ b/youchain-common/src/main/java/com/youchain/utils/DateUtil.java @@ -23,6 +23,7 @@ import java.text.ParseException; import java.text.SimpleDateFormat; import java.time.*; import java.time.format.DateTimeFormatter; +import java.time.format.DateTimeParseException; import java.util.Calendar; import java.util.Date; import java.util.Locale; @@ -291,4 +292,56 @@ public class DateUtil { int comparison = date1.compareTo(date2); return comparison; } + /** + * 将yyyyMMdd格式的字符串转换为Timestamp + * 转换后时间默认为00:00:00.0 + * + * @param dateStr 输入字符串，格式必须为yyyyMMdd（如"20250704"） + * @return 转换后的Timestamp，若解析失败返回null + * @throws DateTimeParseException 当输入字符串格式不符合yyyyMMdd时抛出 + */ + public static Timestamp stringToTimestamp(String dateStr) throws DateTimeParseException { + // 校验输入参数 + if (dateStr == null || dateStr.trim().isEmpty()) { + throw new IllegalArgumentException("输入字符串不能为空"); + } + + // 定义日期格式（严格匹配yyyyMMdd） + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd"); + + try { + // 解析为LocalDate（仅日期） + LocalDate localDate = LocalDate.parse(dateStr.trim(), formatter); + // 补充时间为00:00:00，转换为LocalDateTime + LocalDateTime localDateTime = localDate.atStartOfDay(); + // 转换为Timestamp + return Timestamp.valueOf(localDateTime); + } catch (DateTimeParseException e) { + // 抛出格式不匹配异常，包含具体错误信息 + throw new DateTimeParseException("字符串格式错误，需符合yyyyMMdd（如20250704），错误内容：" + dateStr, dateStr, e.getErrorIndex(), e); + } + } + /** + * 获取当前时间并格式化为 yyyyMMddhhmmss 格式（12小时制） + * 若需24小时制，将格式改为 "yyyyMMddHHmmss"（HH表示24小时制） + * + * @return 格式化后的时间字符串（如20251117034522，对应2025-11-17 03:45:22） + */ + public static String getCurrentTimeAsString() { + // 1. 获取当前时间（包含日期和时间） + LocalDateTime now = LocalDateTime.now(); + + // 2. 定义格式化模板：yyyyMMddhhmmss（12小时制） + // 说明： + // - yyyy：四位年份（如2025） + // - MM：两位月份（01-12） + // - dd：两位日期（01-31） + // - hh：12小时制小时（01-12） + // - mm：两位分钟（00-59） + // - ss：两位秒数（00-59） + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss"); + + // 3. 格式化当前时间并返回 + return now.format(formatter); + } } diff --git a/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileData.java b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileData.java new file mode 100644 index 0000000..45a38ad --- /dev/null +++ b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileData.java @@ -0,0 +1,38 @@ +package com.youchain.utils.readFilebak; + +import com.youchain.base.BaseEntity; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.persistence.*; +import javax.validation.constraints.NotNull; +import java.io.Serializable; +import java.sql.Timestamp; + +@Entity +@Data +@Table(name = "read_file_data") +public class ReadFileData extends BaseEntity implements Serializable { + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + @Column(name = "`id`") + @ApiModelProperty(value = "id") + private Long id; + + @Column(name = "`big_item_code`") + @ApiModelProperty(value = "机型") + private String bigItemCode; + + @Column(name = "`area_code`") + @ApiModelProperty(value = "库区") + private String areaCode; + @Column(name = "`working_station`") + @ApiModelProperty(value = "工位") + private String workingStation; + @Column(name = "`downline_date`") + @ApiModelProperty(value = "下线日期") + private String downlineDate; + @Column(name = "`make_line`") + @ApiModelProperty(value = "制造线") + private String makeLine; +} diff --git a/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileDataRepository.java b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileDataRepository.java new file mode 100644 index 0000000..d71ee4a --- /dev/null +++ b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadFileDataRepository.java @@ -0,0 +1,30 @@ +/* +* Copyright 2019-2020 Zheng Jie +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +package com.youchain.utils.readFilebak; + +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.JpaSpecificationExecutor; + +import java.util.List; + +/** +* @website https://eladmin.vip +* @author HJL +* @date 2023-08-14 +**/ +public interface ReadFileDataRepository extends JpaRepository, JpaSpecificationExecutor { + +} diff --git a/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadUbuntuFiles.java b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadUbuntuFiles.java new file mode 100644 index 0000000..9c23ac4 --- /dev/null +++ b/youchain-system/src/main/java/com/youchain/utils/readFilebak/ReadUbuntuFiles.java @@ -0,0 +1,138 @@ +package com.youchain.utils.readFilebak; + +import com.youchain.utils.DateUtil; +import com.youchain.utils.UserUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import java.io.IOException; +import java.nio.charset.StandardCharsets; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.nio.file.StandardCopyOption; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.Executors; +import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; +import java.util.stream.Stream; + +@Component +public class ReadUbuntuFiles { + private static final String SOURCE_DIR = "/home/test"; + // bak文件夹测试路径：E:\test\bak + private static final Path BAK_DIR = Paths.get(SOURCE_DIR).resolve("bak"); + + @Autowired + private ReadFileDataRepository readFileDataRepository; + public ReadUbuntuFiles () { + System.out.println("定时读取ubuntu文件"); + } + // 定时任务执行器 + private ScheduledExecutorService scheduler; + + @PostConstruct + public void init() { + // 初始化定时任务：延迟0秒开始，每次执行完间隔3秒 + scheduler = Executors.newSingleThreadScheduledExecutor(); + scheduler.scheduleWithFixedDelay( + this::read, // 执行的任务（调用read方法） + 0, // 首次执行延迟时间（0秒后立即开始） + 5, // 上一次任务结束到下一次任务开始的间隔（3秒） + TimeUnit.SECONDS // 时间单位 + ); + System.out.println("定时任务已启动，每次执行完间隔3秒"); + } + // 业务逻辑：读取文件并处理 + public void read() { + Path directory = Paths.get(SOURCE_DIR); + + // 检查目录有效性 + if (!Files.exists(directory)) { + System.err.println("目录不存在：" + SOURCE_DIR); + return; + } + if (!Files.isDirectory(directory)) { + System.err.println("路径不是目录：" + SOURCE_DIR); + return; + } + // 解析结果集 + List readFileDataList=new ArrayList<>(); + + // 遍历目录下的文件并处理每行内容 + try (Stream pathStream = Files.list(directory)) { + pathStream.filter(Files::isRegularFile) + .forEach(file -> { + System.out.println("\n===== 处理文件：" + file + " ====="); + try { + // 读取文件所有行（UTF-8编码） + List lines = Files.readAllLines(file, StandardCharsets.UTF_8); + + // 遍历每行并处理 + for (String line : lines) { + // 1. 去除首尾空格；2. 将连续空格（1个以上）替换为单个空格 + String processedLine = line.trim().replaceAll("\\s+", " "); + // 输出处理后的行 + System.out.println(processedLine); + String[] processed = processedLine.split(" "); + + // 校验格式，并写入结果集 + ReadFileData readFileData=new ReadFileData(); + readFileData.setBigItemCode(processed[0]); + readFileData.setAreaCode(processed[1]); + readFileData.setWorkingStation(processed[2]); + readFileData.setDownlineDate(processed[3]); + readFileData.setMakeLine(processed[4]); + readFileDataList.add(readFileData); + } + // 关键修改：将当前处理的文件（file）移动到bak文件夹，而非目录（directory） + moveToBakWithoutSubDir(file, DateUtil.getCurrentTimeAsString()); + } catch (IOException e) { + System.err.println("处理文件失败：" + file + "，原因：" + e.getMessage()); + } + }); + } catch (IOException e) { + System.err.println("遍历目录失败：" + e.getMessage()); + } + readFileDataRepository.saveAll(readFileDataList); + } + + /** + * 将文件移动到当前目录的bak文件夹，并添加指定后缀 + * @param sourceFile 源文件路径 + * @throws IOException 移动文件或创建目录时发生异常 + */ + public static void moveToBakWithoutSubDir(Path sourceFile, String key) throws IOException { + // 1. 构建bak文件夹路径（源文件同级目录下的bak，即E:\test\bak） + Path parentDir = sourceFile.getParent(); + if (parentDir == null) { + throw new IllegalArgumentException("源文件路径无效，无法获取父目录：" + sourceFile); + } + Path bakDir = parentDir.resolve("bak"); + + // 2. 确保bak文件夹存在 + if (!Files.exists(bakDir)) { + Files.createDirectory(bakDir); + System.out.println("已创建bak文件夹：" + bakDir); + } + + // 3. 生成目标文件名（原文件名 + 时间后缀） + String originalFileName = sourceFile.getFileName().toString(); + String safeFileName = originalFileName.replaceAll("[\\\\/]", "_"); + String targetFileName = key+"_"+safeFileName; + + // 4. 构建目标文件路径 + Path targetFile = bakDir.resolve(targetFileName); + + // 5. 移动文件（覆盖已存在的同名文件） + Files.move( + sourceFile, + targetFile, + StandardCopyOption.REPLACE_EXISTING + ); + + System.out.println("文件已移动至：" + targetFile); + } +}