package com.ruoyi.system.utils;
|
|
import com.ruoyi.system.domain.enums.TaskStatus;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
/**
|
* 新系统状态向旧系统状态转换工具类
|
*
|
* @author ruoyi
|
* @date 2024-01-16
|
*/
|
public class TaskStatusPushConverter {
|
|
private static final Logger log = LoggerFactory.getLogger(TaskStatusPushConverter.class);
|
|
/**
|
* 将新系统TaskStatus转换为旧系统状态码
|
*
|
* @param taskStatus 新系统任务状态枚举
|
* @return 旧系统状态码，如果不需要同步则返回null
|
*/
|
public static Integer convertToLegacyStatus(TaskStatus taskStatus) {
|
if (taskStatus == null) {
|
log.warn("新系统状态为空");
|
return null;
|
}
|
|
switch (taskStatus) {
|
case DEPARTING: // 出发中
|
return 4;
|
case IN_PROGRESS: // 任务中
|
return 6;
|
case RETURNING: // 返程中
|
return 7;
|
case COMPLETED: // 已完成
|
return 8;
|
case CANCELLED: // 已取消
|
return 10;
|
case PENDING: // 待处理 - 不同步
|
case ARRIVED: // 已到达 - 不同步
|
default:
|
log.debug("新系统状态不需要同步到旧系统: {}", taskStatus.getInfo());
|
return null;
|
}
|
}
|
|
/**
|
* 判断是否需要更新旧系统状态
|
* 增加防止状态倒退机制：当新系统状态落后于旧系统时，不进行推送
|
*
|
* @param newStatusCode 新系统要推送的状态码
|
* @param oldStatusCode 旧系统当前状态码
|
* @return 是否需要更新
|
*/
|
public static boolean shouldUpdateLegacyStatus(Integer newStatusCode, Integer oldStatusCode) {
|
if (newStatusCode == null || oldStatusCode == null) {
|
log.warn("状态码为空，跳过更新，新状态码: {}, 旧状态码: {}", newStatusCode, oldStatusCode);
|
return false;
|
}
|
|
// 防止状态倒退：旧系统状态 >= 新系统要推送的状态时，不更新
|
// 原因：可能是旧系统已经处理了更新的状态，而新系统由于时间差还没有同步到
|
if (oldStatusCode >= newStatusCode) {
|
log.info("旧系统状态({}) >= 新系统目标状态({})，跳过推送，防止状态倒退，" +
|
"旧系统: {} ({}), 新系统目标: {} ({})",
|
oldStatusCode, newStatusCode,
|
oldStatusCode, getLegacyStatusDescription(oldStatusCode),
|
newStatusCode, getLegacyStatusDescription(newStatusCode));
|
return false;
|
}
|
|
// 特殊状态检查：已完成或已取消的任务不应该被更新为中间状态
|
if (oldStatusCode >= 8) {
|
// 旧系统已经是完成态（8,9,10），不应该被任何中间状态覆盖
|
if (newStatusCode < 8) {
|
log.warn("旧系统已是终态({})(：{})，拒绝推送中间状态({})(：{})",
|
oldStatusCode, getLegacyStatusDescription(oldStatusCode),
|
newStatusCode, getLegacyStatusDescription(newStatusCode));
|
return false;
|
}
|
}
|
|
log.debug("允许推送状态，旧系统: {} ({}), 新系统目标: {} ({})",
|
oldStatusCode, getLegacyStatusDescription(oldStatusCode),
|
newStatusCode, getLegacyStatusDescription(newStatusCode));
|
|
return true;
|
}
|
|
/**
|
* 获取旧系统状态描述
|
*
|
* @param statusCode 旧系统状态码
|
* @return 状态描述
|
*/
|
public static String getLegacyStatusDescription(Integer statusCode) {
|
if (statusCode == null) {
|
return "未知";
|
}
|
|
switch (statusCode) {
|
case 0: return "新调度单（未下发）";
|
case 1: return "完全未确认";
|
case 2: return "部分已确认";
|
case 3: return "未出车";
|
case 4: return "已出车（去接患者途中）";
|
case 5: return "已出车（等待患者）";
|
case 6: return "已出车（服务中）";
|
case 7: return "已送达（回程中）";
|
case 8: return "已返回";
|
case 9: return "跑空单，已返回";
|
case 10: return "取消";
|
case 11: return "审核中";
|
case 12: return "审核通过";
|
case 13: return "审核不通过";
|
case 14: return "驻点";
|
default: return "未知状态(" + statusCode + ")";
|
}
|
}
|
}
|
