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

bugfix 异步创建订单前,校验充电桩相关信息

Browse Source
This commit is contained in:
YAS\29473
2025-12-11 16:01:43 +08:00
parent b6a7db8c07
commit d446c3e5a8
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/ConfirmStartChargingRequestHandler.java
View File

@@ -349,6 +349,9 @@ public class ConfirmStartChargingRequestHandler extends AbstractYkcHandler {
dto.setMemberId(memberWalletVO.getMemberId()); dto.setMemberId(memberWalletVO.getMemberId());
dto.setMerchantId(pileBasicInfo.getMerchantId() + ""); dto.setMerchantId(pileBasicInfo.getMerchantId() + "");
// 校验充电桩相关的信息
orderBasicInfoService.checkPileInfoForEV(dto);
// 异步创建订单 // 异步创建订单
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {

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

@@ -4913,6 +4913,7 @@ public class OrderBasicInfoServiceImpl implements OrderBasicInfoService {
// 查询站点状态 // 查询站点状态
PileStationVO stationInfo = pileStationInfoService.getStationInfo(pileConnector.getStationId()); PileStationVO stationInfo = pileStationInfoService.getStationInfo(pileConnector.getStationId());
if (stationInfo == null || StringUtils.equals(stationInfo.getOpenFlag(), Constants.ZERO)) { if (stationInfo == null || StringUtils.equals(stationInfo.getOpenFlag(), Constants.ZERO)) {
logger.error("checkPileInfo站点未营业，站点id:{}", pileConnector.getStationId());
throw new BusinessException(ReturnCodeEnum.CODE_STATION_IS_NOT_OPEN); throw new BusinessException(ReturnCodeEnum.CODE_STATION_IS_NOT_OPEN);
} }
@@ -5767,6 +5768,9 @@ public class OrderBasicInfoServiceImpl implements OrderBasicInfoService {
generateOrderDTO.setMemberId(memberWalletVO.getMemberId()); generateOrderDTO.setMemberId(memberWalletVO.getMemberId());
generateOrderDTO.setMerchantId(pileBasicInfo.getMerchantId() + ""); generateOrderDTO.setMerchantId(pileBasicInfo.getMerchantId() + "");
// 校验充电桩相关的信息
checkPileInfoForEV(generateOrderDTO);
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {
Map<String, Object> resultMap = generateOrderByCardV2(generateOrderDTO); Map<String, Object> resultMap = generateOrderByCardV2(generateOrderDTO);