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

修改上报故障相关更新车辆状态

Browse Source
This commit is contained in:
小朱 2025-05-23 14:18:13 +08:00
parent c84e58d589
commit 9d4ca4f63e
1 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
ebike-maintenance/src/main/java/com/cdzy/ebikemaintenance/service/impl/EbikeBikeInfoServiceImpl.java
View File

@ -412,14 +412,7 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
if (!ebikeBikeFaultReportFiles.isEmpty()) { if (!ebikeBikeFaultReportFiles.isEmpty()) {
ebikeBikeFaultReportFileMapper.insertBatch(ebikeBikeFaultReportFiles); ebikeBikeFaultReportFileMapper.insertBatch(ebikeBikeFaultReportFiles);
} }
//上报故障成功后 更新车辆信息表状态 modifyMaintenanceStatus(ebikeBikeFaultReport.getBikeCode());
//根据车辆编号查出车辆信息
String currentStatus = EbikeStatus.WAITING_FOR_REPAIR; // 获取当前状态为“待维修”
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("bike_code", ebikeBikeFaultReport.getBikeCode());
EbikeBikeInfo ebikeBikeInfo = ebikeBikeInfoMapper.selectOneByQuery(queryWrapper);
ebikeBikeInfo.setState(currentStatus);
ebikeBikeInfoMapper.update(ebikeBikeInfo);
return true; return true;
} catch (Exception e) { } catch (Exception e) {
log.error("faultReporting===>{}", e.getMessage() + Arrays.toString(e.getStackTrace())); log.error("faultReporting===>{}", e.getMessage() + Arrays.toString(e.getStackTrace()));
@ -657,6 +650,7 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
if (!ebikeBikeFaultRepairRecords.isEmpty()) { if (!ebikeBikeFaultRepairRecords.isEmpty()) {
ebikeBikeFaultRepairRecordMapper.insertBatch(ebikeBikeFaultRepairRecords); ebikeBikeFaultRepairRecordMapper.insertBatch(ebikeBikeFaultRepairRecords);
} }
modifyMaintenanceStatus(ebikeBikeInfo.getBikeCode());
return ebikeBikeOrder.getOrderId(); return ebikeBikeOrder.getOrderId();
} catch (Exception e) { } catch (Exception e) {
log.error("createWorkOrder===>" + e.getMessage() + Arrays.toString(e.getStackTrace())); log.error("createWorkOrder===>" + e.getMessage() + Arrays.toString(e.getStackTrace()));
@ -870,6 +864,8 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
QueryWrapper query = QueryWrapper.create(); QueryWrapper query = QueryWrapper.create();
switch (orderType){ switch (orderType){
case "1": case "1":
EbikeBikeInfo ebikeBikeInfo = ebikeBikeInfoMapper.selectOneById(ebikeBikeOrder.getOrderId());
modifyMaintenanceStatus(ebikeBikeInfo.getBikeCode());
break; break;
case "2": case "2":
query.eq(EBIKE_BIKE_FAULT_REPAIR_RECORD.ORDER_ID.getName(), orderId); query.eq(EBIKE_BIKE_FAULT_REPAIR_RECORD.ORDER_ID.getName(), orderId);
@ -1473,5 +1469,25 @@ public class EbikeBikeInfoServiceImpl extends ServiceImpl<EbikeBikeInfoMapper, E
return JsonResult.success(resEbikeInfoReginIdDtos); return JsonResult.success(resEbikeInfoReginIdDtos);
} }
private void modifyMaintenanceStatus(String bikeCode){
//是否存在维修中的订单数据
int i = ebikeBikeInfoMapper.selectOrderCount(bikeCode);
//查询车辆是否存在故障
int i1 = ebikeBikeInfoMapper.selectReportCount(bikeCode);
String currentStatus = EbikeStatus.WAITING_FOR_REPAIR;
if(i >0){ //维修中
currentStatus=EbikeStatus.REPAIRING;
} else if(i==0 && i1>0){ //待维修
currentStatus=EbikeStatus.WAITING_FOR_SHIPMENT;
}else if(i==0 && i1==0){ //待出库
currentStatus=EbikeStatus.WAITING_FOR_SHIPMENT;
}
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("bike_code", bikeCode);
EbikeBikeInfo ebikeBikeInfo = ebikeBikeInfoMapper.selectOneByQuery(queryWrapper);
ebikeBikeInfo.setState(currentStatus);
ebikeBikeInfoMapper.update(ebikeBikeInfo);
}
} }