hbyt/cloud-battery-manage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调整慧鹏反推规则

Browse Source
This commit is contained in:
andy 2025-05-05 11:30:29 +08:00
parent 0988b0f45e
commit 36d2208c60
1 changed files with 39 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/processor/impl/request/MqttRequestPushCarCreateMakeAppointmentExchangeProcessorImpl.java
View File

@ -46,23 +46,46 @@ public class MqttRequestPushCarCreateMakeAppointmentExchangeProcessorImpl implem
Assert.hasText(plateNum, "licensePlateNumber is null"); Assert.hasText(plateNum, "licensePlateNumber is null");
MqttResponse response = null; MqttResponse response = null;
if(StringUtils.isNotEmpty(plateNum)){ if(StringUtils.isNotEmpty(plateNum)){
if (vehicleService.existsVehicleByPlateNum(plateNum)){ //如果不存在车辆信息
response = new MqttResponse().success("车辆已存在, 无需创建"); if (!vehicleService.existsVehicleByPlateNum(plateNum)){
}else{ //创建车辆信息
//没有车辆信息, 开始创建 if(!vehicleService.createVehicleByPlateNum(plateNum, topic.getStationCode())){
if(vehicleService.createVehicleByPlateNum(plateNum, topic.getStationCode())){ response = new MqttResponse().error("创建车辆信息失败了");
//创建预约订单 }
if (orderSwapBatteryService.addPreByPlanNum(plateNum, topic.getStationCode())){
//返回状态信息
response = new MqttResponse().success("车辆初始化完成");
}else{
response = new MqttResponse().error("车辆初始化完成, 但是预约单创建失败了");
}
}else{
response = new MqttResponse().error("创建车辆信息失败了");
}
} }
//如果response == null 则证明 车辆创建成功了
if(response == null){
//创建预约订单
if (orderSwapBatteryService.addPreByPlanNum(plateNum, topic.getStationCode())){
//返回状态信息
response = new MqttResponse().success("预约单初始化完成");
}else{
response = new MqttResponse().error("车辆初始化完成, 但是预约单创建失败了");
}
}
// if (vehicleService.existsVehicleByPlateNum(plateNum)){
// //创建预约订单
// if (orderSwapBatteryService.addPreByPlanNum(plateNum, topic.getStationCode())){
// //返回状态信息
// response = new MqttResponse().success("预约单初始化完成");
// }else{
// response = new MqttResponse().error("车辆初始化完成, 但是预约单创建失败了");
// }
// }else{
// //没有车辆信息, 开始创建
// if(vehicleService.createVehicleByPlateNum(plateNum, topic.getStationCode())){
// //创建预约订单
// if (orderSwapBatteryService.addPreByPlanNum(plateNum, topic.getStationCode())){
// //返回状态信息
// response = new MqttResponse().success("预约单初始化完成");
// }else{
// response = new MqttResponse().error("车辆初始化完成, 但是预约单创建失败了");
// }
// }else{
// response = new MqttResponse().error("创建车辆信息失败了");
// }
//
// }
}else{ }else{
response = new MqttResponse().error("参数不全, 没有车牌号信息"); response = new MqttResponse().error("参数不全, 没有车牌号信息");
} }