Spring环境下CSV文件合法状态变更时间差计算方案咨询

1. 替换原始字符串列表为强类型实体 #

放弃List<List<String>>的松散存储，把CSV行映射为强类型实体，避免字段索引混乱、类型转换错误：

// 用Java Record简化，也可以用普通POJO
public record CsvLog(LocalDateTime timestamp, String code, String state) {}

转换时可借助Spring的FlatFileItemReader（批量处理场景）或自定义转换器，将CSV的字符串字段直接解析为对应类型（比如timestamp用DateTimeFormatter严格解析），无效行直接标记过滤。

2. 抽象状态转换规则，消除硬编码分支 #

把合法转换规则用配置式结构存储，替代大量if-else/switch：

// 静态常量存储规则，后续可迁移至配置文件
private static final Map<String, Set<String>> VALID_TRANSITIONS = Map.of(
    "UN", Set.of("ACK", "RTNUN"),
    "ACK", Set.of("NORM"),
    "RTNUN", Set.of("NORM"),
    "UPR", Set.of("NORM")
);

判断转换合法性时直接查表：

boolean isValid = VALID_TRANSITIONS.getOrDefault(prevState, Collections.emptySet()).contains(currentState);

规则变更时只需修改映射表，无需改动业务逻辑。

3. 按Code分组并按时间戳排序 #

状态转换是按时间顺序发生的，先对数据做分组+排序预处理：

// 按Code分组，每组内按时间戳升序排列
Map<String, List<CsvLog>> groupedLogs = csvLogs.stream()
    .collect(Collectors.groupingBy(
        CsvLog::code,
        Collectors.collectingAndThen(
            Collectors.toList(),
            list -> list.stream().sorted(Comparator.comparing(CsvLog::timestamp)).toList()
        )
    ));

预处理后每组数据都是时间有序的，遍历逻辑无需再处理乱序问题。

4. 遍历分组数据计算合法时间差 #

维护每组的前一条记录，逐个校验转换合法性并计算时间差：

Map<String, List<Duration>> codeToValidDurations = new HashMap<>();

for (Map.Entry<String, List<CsvLog>> entry : groupedLogs.entrySet()) {
    String code = entry.getKey();
    List<CsvLog> sortedLogs = entry.getValue();
    List<Duration> validDurations = new ArrayList<>();

    CsvLog prevLog = null;
    for (CsvLog currentLog : sortedLogs) {
        if (prevLog != null) {
            String prevState = prevLog.state();
            String currentState = currentLog.state();
            // 校验转换合法性
            if (VALID_TRANSITIONS.getOrDefault(prevState, Collections.emptySet()).contains(currentState)) {
                Duration duration = Duration.between(prevLog.timestamp(), currentLog.timestamp());
                validDurations.add(duration);
            }
        }
        // 无论转换是否合法，都更新前一条记录（状态已发生变更，只是非法转换不计算时间差）
        prevLog = currentLog;
    }
    codeToValidDurations.put(code, validDurations);
}

5. 边缘场景针对性处理 #

• 单条数据分组：直接跳过，无状态转换可计算
• 重复连续状态：比如UN->UN，因不在规则内自动跳过
• 未知状态：比如出现未定义的状态值，VALID_TRANSITIONS返回空集合，所有相关转换都被判定为非法，无需额外分支
• 时间解析失败：在实体映射阶段就过滤标记，不进入后续计算流程

内容的提问来源于stack exchange，提问作者user18722819