autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-17 16:28:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 修改保存实时数据逻辑

Browse Source
This commit is contained in:
Guoqs
2024-05-07 15:05:53 +08:00
parent 9f7079b89d
commit 97986e5ec7
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java
View File

@@ -254,13 +254,18 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
// 03表示充电中 // 03表示充电中
if (StringUtils.equals(connectorStatus, "03")) { if (StringUtils.equals(connectorStatus, "03")) {
// 充电时保存实时数据到redis // 默认保存到redis
pileBasicInfoService.saveRealTimeMonitorData2Redis(realTimeMonitorData); boolean saveRedisFlag = true;
// 查询数据库中该订单当前信息 // 查询数据库中该订单当前信息
// OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(transactionCode);
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode); OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
if (Objects.nonNull(orderInfo)) { if (Objects.nonNull(orderInfo)) {
if (StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.ORDER_COMPLETE.getValue())
|| StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.STAY_SETTLEMENT.getValue())) {
// 在订单状态为 订单完成或待结算，不保存
saveRedisFlag = false;
}
boolean updateFlag = false; boolean updateFlag = false;
if (StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.NOT_START.getValue()) if (StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.NOT_START.getValue())
|| StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.ABNORMAL.getValue()) || StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.ABNORMAL.getValue())
@@ -280,6 +285,11 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
orderBasicInfoService.updateOrderBasicInfo(orderInfo); orderBasicInfoService.updateOrderBasicInfo(orderInfo);
} }
} }
// 充电时保存实时数据到redis
if (saveRedisFlag) {
pileBasicInfoService.saveRealTimeMonitorData2Redis(realTimeMonitorData);
}
} }
// 异步推送第三方平台实时数据 // 异步推送第三方平台实时数据