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

update 桩退出时将正在充电的订单改为 异常状态

Browse Source
This commit is contained in:
DESKTOP-D9QDT1P\JS-ZZA
2023-03-09 16:52:57 +08:00
parent d69af6d285
commit 34834dda91
4 changed files with 49 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java
View File

@@ -68,20 +68,21 @@ public class YKCBusinessServiceImpl implements YKCBusinessService {
pileConnectorInfoService.updateConnectorStatusByPileSn(pileSn, PileConnectorDataBaseStatusEnum.OFF_NETWORK.getValue()); pileConnectorInfoService.updateConnectorStatusByPileSn(pileSn, PileConnectorDataBaseStatusEnum.OFF_NETWORK.getValue());
// 将此桩正在进行充电的订单状态改为 异常 // 将此桩正在进行充电的订单状态改为 异常
List<OrderListVO> orderListVOS = orderBasicInfoService.selectChargingOrder(pileSn); orderBasicInfoService.updateOrderStatusAsAbnormal(pileSn);
if (CollectionUtils.isNotEmpty(orderListVOS)) { // List<OrderListVO> orderListVOS = orderBasicInfoService.selectChargingOrder(pileSn);
for (OrderListVO orderListVO : orderListVOS) { // if (CollectionUtils.isNotEmpty(orderListVOS)) {
if (StringUtils.equals(orderListVO.getOrderStatus(), OrderStatusEnum.IN_THE_CHARGING.getValue())) { // for (OrderListVO orderListVO : orderListVOS) {
// 修改数据库订单状态 // if (StringUtils.equals(orderListVO.getOrderStatus(), OrderStatusEnum.IN_THE_CHARGING.getValue())) {
OrderBasicInfo info = OrderBasicInfo.builder() // // 修改数据库订单状态
.id(Long.parseLong(orderListVO.getId())) // OrderBasicInfo info = OrderBasicInfo.builder()
.orderStatus(OrderStatusEnum.ABNORMAL.getValue()) // .id(Long.parseLong(orderListVO.getId()))
.build(); // .orderStatus(OrderStatusEnum.ABNORMAL.getValue())
orderBasicInfoService.updateOrderBasicInfo(info); // .build();
log.info("充电桩:{}退出, 修改充电桩正在充电的订单状态为异常, orderCode: {}", pileSn, orderListVO.getOrderCode()); // orderBasicInfoService.updateOrderBasicInfo(info);
} // log.info("充电桩:{}退出, 修改充电桩正在充电的订单状态为异常, orderCode: {}", pileSn, orderListVO.getOrderCode());
} // }
} // }
// }
// 记录充电桩退出msg // 记录充电桩退出msg
// 保存报文 // 保存报文

7
jsowell-pile/src/main/java/com/jsowell/pile/service/IOrderBasicInfoService.java
View File

@@ -191,4 +191,11 @@ public interface IOrderBasicInfoService {
* @return * @return
*/ */
List<PersonPileConnectorSumInfoVO> getAccumulativeInfo(QueryPersonPileDTO dto); List<PersonPileConnectorSumInfoVO> getAccumulativeInfo(QueryPersonPileDTO dto);
/**
* 修改订单状态为异常（桩离线时调用）
*
* @param pileSn
*/
void updateOrderStatusAsAbnormal(String pileSn);
} }

25
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
View File

@@ -952,4 +952,29 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
public List<PersonPileConnectorSumInfoVO> getAccumulativeInfo(QueryPersonPileDTO dto) { public List<PersonPileConnectorSumInfoVO> getAccumulativeInfo(QueryPersonPileDTO dto) {
return orderBasicInfoMapper.getAccumulativeInfo(dto); return orderBasicInfoMapper.getAccumulativeInfo(dto);
} }
/**
* 修改订单状态为异常（桩离线时调用）
*
* @param pileSn
*/
@Override
public void updateOrderStatusAsAbnormal(String pileSn) {
// 将此桩正在进行充电的订单状态改为 异常
List<OrderListVO> orderListVOS = selectChargingOrder(pileSn);
if (CollectionUtils.isEmpty(orderListVOS)) {
return;
}
for (OrderListVO orderListVO : orderListVOS) {
if (StringUtils.equals(orderListVO.getOrderStatus(), OrderStatusEnum.IN_THE_CHARGING.getValue())) {
// 修改数据库订单状态
OrderBasicInfo info = OrderBasicInfo.builder()
.id(Long.parseLong(orderListVO.getId()))
.orderStatus(OrderStatusEnum.ABNORMAL.getValue())
.build();
updateOrderBasicInfo(info);
logger.info("充电桩:{}退出, 修改充电桩正在充电的订单状态为异常, orderCode: {}", pileSn, orderListVO.getOrderCode());
}
}
}
} }

2
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
View File

@@ -526,6 +526,8 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService {
if (connectorStatusList.contains(PileConnectorDataBaseStatusEnum.OFF_NETWORK.getValue())) { if (connectorStatusList.contains(PileConnectorDataBaseStatusEnum.OFF_NETWORK.getValue())) {
pileStatus = PileStatusEnum.OFF_LINE.getValue(); pileStatus = PileStatusEnum.OFF_LINE.getValue();
flag = true; flag = true;
// 将此桩正在进行充电的订单状态改为 异常
orderBasicInfoService.updateOrderStatusAsAbnormal(pileSn);
} }
// 没有故障或者离线，就是在线状态 // 没有故障或者离线，就是在线状态