attiya/ebike-plus
SHA256
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

领取电池新增逻辑

Browse Source
This commit is contained in:
PC 2026-01-19 17:03:43 +08:00
parent 8355ee14a2
commit 70e73dc6d1
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeOrderServiceImpl.java
View File

@ -296,6 +296,12 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
throw new EbikeException("当前用户存在领取电池尚未归还，归还后再试"); throw new EbikeException("当前用户存在领取电池尚未归还，归还后再试");
} }
List<String> codes = batteryClaimVo.getCodes(); List<String> codes = batteryClaimVo.getCodes();
List<String> ecuSns = codes.stream().map(code -> {
if (!code.startsWith("B")) {
return code;
}
return null;
}).filter(Objects::nonNull).toList();
EbikeBorrowBatteryRecord batteryRecord = EbikeBorrowBatteryRecord.builder() EbikeBorrowBatteryRecord batteryRecord = EbikeBorrowBatteryRecord.builder()
.borrowNum(codes.size()) .borrowNum(codes.size())
.createBy(StpUtil.getLoginIdAsLong()) .createBy(StpUtil.getLoginIdAsLong())
@ -314,7 +320,12 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
if (!list.isEmpty()) { if (!list.isEmpty()) {
recordCodesMapper.insertBatch(list); recordCodesMapper.insertBatch(list);
} }
if (!ecuSns.isEmpty()) {
UpdateChain.of(EbikeEcuInfo.class)
.set(EBIKE_ECU_INFO.IS_CLAIM, Boolean.TRUE)
.where(EBIKE_ECU_INFO.ECU_SN.in(ecuSns))
.update();
}
} }
@Override @Override
@ -819,7 +830,7 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
.select(EBIKE_BIKE_INFO.OPERATOR_ID) .select(EBIKE_BIKE_INFO.OPERATOR_ID)
.where(EBIKE_BIKE_INFO.BIKE_CODE.in(bikeCodes)) .where(EBIKE_BIKE_INFO.BIKE_CODE.in(bikeCodes))
.groupBy(EBIKE_BIKE_INFO.OPERATOR_ID); .groupBy(EBIKE_BIKE_INFO.OPERATOR_ID);
List<Long> countList = bikeInfoMapper.selectListByQueryAs(queryWrapper,Long.class); List<Long> countList = bikeInfoMapper.selectListByQueryAs(queryWrapper, Long.class);
if (countList.size() > 1) { if (countList.size() > 1) {
throw new EbikeException("该列表中同时存在不同运营商的车辆"); throw new EbikeException("该列表中同时存在不同运营商的车辆");
} }