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

redis新增ecu_sn的区域id

Browse Source
This commit is contained in:
yanglei 2026-03-06 09:20:19 +08:00
parent bad1d0435b
commit 3df6c925ea
2 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeBikeInfoServiceImpl.java
View File

@ -570,13 +570,6 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
@Override @Override
public void changeEcu(String bikeCode, String ecuSn) { public void changeEcu(String bikeCode, String ecuSn) {
// 获取旧的ecu_sn
QueryWrapper query = QueryWrapper.create()
.select(EBIKE_ECU_INFO.ECU_SN)
.from(EBIKE_BIKE_INFO)
.leftJoin(EBIKE_ECU_INFO).on(EBIKE_BIKE_INFO.ECU_ID.eq(EBIKE_ECU_INFO.ECU_ID))
.where(EBIKE_BIKE_INFO.BIKE_CODE.eq(bikeCode));
String oldEcuSn = this.mapper.selectOneByQueryAs(query, String.class);
QueryWrapper queryWrapper = QueryWrapper.create() QueryWrapper queryWrapper = QueryWrapper.create()
.where(EBIKE_ECU_INFO.ECU_SN.eq(ecuSn)); .where(EBIKE_ECU_INFO.ECU_SN.eq(ecuSn));
EbikeEcuInfo ebikeEcuInfo = ebikeEcuInfoService.getOne(queryWrapper); EbikeEcuInfo ebikeEcuInfo = ebikeEcuInfoService.getOne(queryWrapper);
@ -599,12 +592,19 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
if (bikeInfo.getUsageStatus() == BikeUsageStatus.CYCLING) { if (bikeInfo.getUsageStatus() == BikeUsageStatus.CYCLING) {
throw new EbikeException("车辆骑行中暂时无法换绑"); throw new EbikeException("车辆骑行中暂时无法换绑");
} }
updateById(bikeInfo);
// 车辆上架,删除旧ecu_sn,保存新的ecu_sn // 车辆上架,删除旧ecu_sn,保存新的ecu_sn
if (bikeInfo.getStatus() == 1) { if (bikeInfo.getStatus() == 1) {
// 获取旧的ecu_sn
QueryWrapper query = QueryWrapper.create()
.select(EBIKE_ECU_INFO.ECU_SN)
.from(EBIKE_BIKE_INFO)
.leftJoin(EBIKE_ECU_INFO).on(EBIKE_BIKE_INFO.ECU_ID.eq(EBIKE_ECU_INFO.ECU_ID))
.where(EBIKE_BIKE_INFO.BIKE_CODE.eq(bikeCode));
String oldEcuSn = this.mapper.selectOneByQueryAs(query, String.class);
redisUtil.deleteEcuSnRegionId(oldEcuSn); redisUtil.deleteEcuSnRegionId(oldEcuSn);
redisUtil.saveEcuSnRegionId(ecuSn, bikeInfo.getRegionId()); redisUtil.saveEcuSnRegionId(ecuSn, bikeInfo.getRegionId());
} }
updateById(bikeInfo);
} }
@Override @Override

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

@ -401,13 +401,6 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
@Override @Override
public void batteryChange(EbikeBatteryChangeVo changeVo) { public void batteryChange(EbikeBatteryChangeVo changeVo) {
// 获取旧的ecu_sn
QueryWrapper query = QueryWrapper.create()
.select(EBIKE_ECU_INFO.ECU_SN)
.from(EBIKE_BIKE_INFO)
.leftJoin(EBIKE_ECU_INFO).on(EBIKE_BIKE_INFO.ECU_ID.eq(EBIKE_ECU_INFO.ECU_ID))
.where(EBIKE_BIKE_INFO.BIKE_CODE.eq(changeVo.getBikeCode()));
String oldEcuSn = bikeInfoMapper.selectOneByQueryAs(query, String.class);
String bikeCode = changeVo.getBikeCode(); String bikeCode = changeVo.getBikeCode();
String batteryCode = changeVo.getBatteryCode(); String batteryCode = changeVo.getBatteryCode();
QueryWrapper queryWrapper = QueryWrapper.create() QueryWrapper queryWrapper = QueryWrapper.create()
@ -472,6 +465,13 @@ public class EbikeBikeOrderServiceImpl extends ServiceImpl<EbikeBikeOrderMapper,
} }
// 车辆上架，删除旧区域id，保存新区域id // 车辆上架，删除旧区域id，保存新区域id
if (bikeInfo.getStatus() == 1) { if (bikeInfo.getStatus() == 1) {
// 获取旧的ecu_sn
QueryWrapper query = QueryWrapper.create()
.select(EBIKE_ECU_INFO.ECU_SN)
.from(EBIKE_BIKE_INFO)
.leftJoin(EBIKE_ECU_INFO).on(EBIKE_BIKE_INFO.ECU_ID.eq(EBIKE_ECU_INFO.ECU_ID))
.where(EBIKE_BIKE_INFO.BIKE_CODE.eq(changeVo.getBikeCode()));
String oldEcuSn = bikeInfoMapper.selectOneByQueryAs(query, String.class);
redisUtil.deleteEcuSnRegionId(oldEcuSn); redisUtil.deleteEcuSnRegionId(oldEcuSn);
redisUtil.saveEcuSnRegionId(batteryCode, bikeInfo.getRegionId()); redisUtil.saveEcuSnRegionId(batteryCode, bikeInfo.getRegionId());
} }