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

订单充电中, 异步发送获取实时数据指令

Browse Source
This commit is contained in:
Guoqs
2024-07-24 13:55:55 +08:00
parent 918fe26583
commit 67f973ac9b
2 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
jsowell-admin/src/main/java/com/jsowell/service/OrderService.java
View File

@@ -557,10 +557,24 @@ public class OrderService {
throw new BusinessException(ReturnCodeEnum.CODE_QUERY_ORDER_INFO_IS_NULL); throw new BusinessException(ReturnCodeEnum.CODE_QUERY_ORDER_INFO_IS_NULL);
} }
String pileSn = orderBasicInfo.getPileSn();
String connectorCode = orderBasicInfo.getConnectorCode();
// 异步发送获取实时数据指令
if (StringUtils.equals(orderBasicInfo.getOrderStatus(), OrderStatusEnum.IN_THE_CHARGING.getValue())) {
CompletableFuture.runAsync(() -> {
try {
pileRemoteService.getRealTimeMonitorData(pileSn, connectorCode);
} catch (Exception e) {
log.error("异步发送获取实时数据指令error", e);
}
});
}
vo.setOrderCode(orderBasicInfo.getOrderCode()); vo.setOrderCode(orderBasicInfo.getOrderCode());
vo.setPileSn(orderBasicInfo.getPileSn()); vo.setPileSn(pileSn);
vo.setConnectorCode(orderBasicInfo.getConnectorCode()); vo.setConnectorCode(connectorCode);
vo.setPileConnectorCode(orderBasicInfo.getPileSn() + orderBasicInfo.getConnectorCode()); vo.setPileConnectorCode(pileSn + connectorCode);
String orderStatus = orderBasicInfo.getOrderStatus(); String orderStatus = orderBasicInfo.getOrderStatus();
vo.setOrderStatus(orderStatus); vo.setOrderStatus(orderStatus);
if (Objects.nonNull(orderBasicInfo.getChargeStartTime())) { if (Objects.nonNull(orderBasicInfo.getChargeStartTime())) {

1
jsowell-pile/src/main/java/com/jsowell/pile/service/PileRemoteService.java
View File

@@ -72,7 +72,6 @@ public class PileRemoteService {
.build(); .build();
ykcPushCommandService.pushGetRealTimeMonitorDataCommand(command); ykcPushCommandService.pushGetRealTimeMonitorDataCommand(command);
} }
} }
/** /**