diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java index 1b8c613a2..f7ace0826 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/UploadRealTimeMonitorHandler.java @@ -28,6 +28,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.stereotype.Component; import java.util.Date; +import java.util.Map; import java.util.Objects; import java.util.concurrent.CompletableFuture; import java.util.concurrent.TimeUnit; @@ -325,6 +326,18 @@ public class UploadRealTimeMonitorHandler extends AbstractYkcHandler { orderInfo.setChargeStartTime(new Date()); } + String startSoc = orderInfo.getStartSoc(); + // 获取上面存到redis中的soc + Map socMap = YKCUtils.getSOCMap(transactionCode); + String min = socMap.get("min"); + if (StringUtils.isNotBlank(startSoc) && StringUtils.isNotBlank(min)) { + if (Double.parseDouble(startSoc) < Double.parseDouble(min)) { + // 数据库中的起始soc < redis中的最小值, 更新数据库 + orderInfo.setStartSoc(min); + updateFlag = true; + } + } + if (updateFlag) { orderBasicInfoService.updateOrderBasicInfo(orderInfo); }