package com.xiaopeng.maintenance.service.impl;
|
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.xiaopeng.api.feignClient.account.XpOperationUserClient;
|
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
|
import com.xiaopeng.api.model.account.XpOperationsUser;
|
import com.xiaopeng.api.model.maintenance.XpVehiclePreparation;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.xiaopeng.api.vo.automaticPilot.VehiclePosition;
|
import com.xiaopeng.evi.oss.service.AliOssService;
|
import com.xiaopeng.maintenance.model.query.XpVehiclePreparationPageQuery;
|
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
|
import com.xiaopeng.api.vo.maintenance.XpVehiclePreparationDetailVO;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.web.page.PageInfo;
|
import com.xiaopeng.maintenance.mapper.*;
|
import com.xiaopeng.maintenance.model.query.OperationRecordsQuery;
|
import com.xiaopeng.maintenance.model.vo.OperationRecordsVO;
|
import com.xiaopeng.maintenance.model.vo.XpVehiclePreparationVO;
|
import com.xiaopeng.maintenance.service.IXpVehiclePreparationService;
|
import com.xiaopeng.maintenance.utils.AliOssDownloadUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 车辆整备 服务实现类
|
* </p>
|
*
|
* @author mitao
|
* @since 2026-02-03
|
*/
|
@Service
|
public class XpVehiclePreparationServiceImpl extends ServiceImpl<XpVehiclePreparationMapper, XpVehiclePreparation> implements IXpVehiclePreparationService {
|
|
@Autowired
|
private XpVehiclePreparationMapper xpVehiclePreparationMapper;
|
@Autowired
|
private XpChargingRecordMapper xpChargingRecordMapper;
|
@Autowired
|
private XpVehicleDetectionMapper xpVehicleDetectionMapper;
|
@Autowired
|
private XpVehicleRepairMapper xpVehicleRepairMapper;
|
@Autowired
|
private XpVehicleCleanMapper xpVehicleCleanMapper;
|
@Autowired
|
private XpOperationUserClient xpOperationUserClient;
|
@Autowired
|
private XpVehicleClient xpVehicleClient;
|
@Autowired
|
private MongoTemplate mongoTemplate;
|
@Autowired
|
private AliOssService aliOssService;
|
@Autowired
|
private AliOssDownloadUtil aliOssDownloadUtil;
|
|
@Override
|
public PageInfo<OperationRecordsVO> operationRecords(OperationRecordsQuery query) {
|
PageInfo<OperationRecordsVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
List<OperationRecordsVO> operationRecords;
|
switch (query.getOperationType()) {
|
case 1:
|
// 整备记录
|
operationRecords = xpVehiclePreparationMapper.operationRecords(query,pageInfo);
|
break;
|
case 2:
|
// 充电记录
|
operationRecords = xpChargingRecordMapper.operationRecords(query,pageInfo);
|
if(!CollectionUtils.isEmpty(operationRecords)){
|
for (OperationRecordsVO operationRecord : operationRecords) {
|
operationRecord.setStartMileageRange(Objects.isNull(operationRecord.getStartMileageRange())?0.0f:operationRecord.getStartMileageRange());
|
operationRecord.setEndMileageRange(Objects.isNull(operationRecord.getEndMileageRange())?0.0f:operationRecord.getEndMileageRange());
|
}
|
}
|
break;
|
case 3:
|
// 检测记录
|
operationRecords = xpVehicleDetectionMapper.operationRecords(query,pageInfo);
|
break;
|
case 4:
|
// 维修记录
|
operationRecords = xpVehicleRepairMapper.operationRecords(query,pageInfo);
|
break;
|
default:
|
// 清洁记录
|
operationRecords = xpVehicleCleanMapper.operationRecords(query,pageInfo);
|
break;
|
}
|
|
if(CollectionUtils.isEmpty(operationRecords)){
|
return pageInfo;
|
}
|
|
List<Long> userIds = operationRecords.stream().map(OperationRecordsVO::getOperationsUserId).distinct().collect(Collectors.toList());
|
// 查询操作人信息
|
R<List<XpOperationsUser>> listR = xpOperationUserClient.listByIds(userIds);
|
List<XpOperationsUser> xpOperationsUsers = listR.getData();
|
if(!CollectionUtils.isEmpty(xpOperationsUsers)){
|
for (OperationRecordsVO operationRecord : operationRecords) {
|
List<XpOperationsUser> xpOperationsUserList = xpOperationsUsers.stream().filter(xpOperationsUser -> xpOperationsUser.getId().equals(operationRecord.getOperationsUserId())).collect(Collectors.toList());
|
if(!CollectionUtils.isEmpty(xpOperationsUserList)){
|
XpOperationsUser xpOperationsUser = xpOperationsUserList.get(0);
|
operationRecord.setOperatorName(xpOperationsUser.getNickName());
|
}
|
}
|
}
|
List<Long> vehicleIds = operationRecords.stream().map(OperationRecordsVO::getVehicleId).collect(Collectors.toList());
|
// 查询车辆信息
|
List<XpVehicle> xpVehicles = xpVehicleClient.listByIds(vehicleIds).getData();
|
if(!CollectionUtils.isEmpty(xpVehicles)){
|
for (OperationRecordsVO operationRecord : operationRecords) {
|
List<XpVehicle> xpVehicleList = xpVehicles.stream().filter(xpVehicle -> xpVehicle.getId().equals(operationRecord.getVehicleId())).collect(Collectors.toList());
|
if(!CollectionUtils.isEmpty(xpVehicleList)){
|
XpVehicle xpVehicle = xpVehicleList.get(0);
|
operationRecord.setPlateNumber(xpVehicle.getPlateNumber());
|
operationRecord.setVehiclePictures(xpVehicle.getVehiclePictures());
|
operationRecord.setAcceptOrTest(xpVehicle.getAcceptOrTest());
|
}
|
}
|
}
|
pageInfo.setRecords(operationRecords);
|
return pageInfo;
|
}
|
|
@Override
|
public XpVehiclePreparationVO preparationDetail(Long id) {
|
// 查询车辆充电记录
|
XpVehiclePreparation xpVehiclePreparation = this.getById(id);
|
XpVehiclePreparationVO xpVehiclePreparationVO = new XpVehiclePreparationVO();
|
BeanUtils.copyProperties(xpVehiclePreparation, xpVehiclePreparationVO);
|
xpVehiclePreparationVO.setOperationTime(xpVehiclePreparation.getCreateTime());
|
|
// 查询车辆信息
|
XpVehicle xpVehicle = xpVehicleClient.queryById(xpVehiclePreparation.getVehicleId()).getData();
|
if (Objects.nonNull(xpVehicle)) {
|
xpVehiclePreparationVO.setPlateNumber(xpVehicle.getPlateNumber());
|
xpVehiclePreparationVO.setVehiclePictures(xpVehicle.getVehiclePictures());
|
xpVehiclePreparationVO.setAcceptOrTest(xpVehicle.getAcceptOrTest());
|
xpVehiclePreparationVO.setVehicleColor(xpVehicle.getVehicleColor());
|
}
|
// 查询操作人
|
XpOperationsUser operationsUserStart = xpOperationUserClient.queryById(xpVehiclePreparationVO.getOperationsUserId()).getData();
|
if (Objects.nonNull(operationsUserStart)) {
|
xpVehiclePreparationVO.setOperatorStartName(operationsUserStart.getNickName());
|
}
|
|
// 图片封装
|
try {
|
// 大灯
|
String headLight = xpVehiclePreparation.getHeadLight();
|
if (StringUtils.isNotBlank(headLight)) {
|
JSONArray jsonArray = JSONArray.parseArray(headLight);
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
if (Objects.isNull(jsonObject)) {
|
continue;
|
}
|
String downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
|
jsonObject.put("url", downloadUrl);
|
}
|
xpVehiclePreparationVO.setHeadLight(JSONArray.toJSONString(jsonArray));
|
}
|
// 转向灯
|
String turnSignal = xpVehiclePreparation.getTurnSignal();
|
if (StringUtils.isNotBlank(turnSignal)) {
|
JSONArray jsonArray = JSONArray.parseArray(turnSignal);
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
if (Objects.isNull(jsonObject)) {
|
continue;
|
}
|
String downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
|
jsonObject.put("url", downloadUrl);
|
}
|
xpVehiclePreparationVO.setTurnSignal(JSONArray.toJSONString(jsonArray));
|
}
|
// 刹车灯
|
String brakeLight = xpVehiclePreparation.getBrakeLight();
|
if (StringUtils.isNotBlank(brakeLight)) {
|
JSONArray jsonArray = JSONArray.parseArray(brakeLight);
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
if (Objects.isNull(jsonObject)) {
|
continue;
|
}
|
String downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
|
jsonObject.put("url", downloadUrl);
|
}
|
xpVehiclePreparationVO.setBrakeLight(JSONArray.toJSONString(jsonArray));
|
}
|
// 雾灯
|
String fogLight = xpVehiclePreparation.getFogLight();
|
if (StringUtils.isNotBlank(fogLight)) {
|
JSONArray jsonArray = JSONArray.parseArray(fogLight);
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
if (Objects.isNull(jsonObject)) {
|
continue;
|
}
|
String downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
|
jsonObject.put("url", downloadUrl);
|
}
|
xpVehiclePreparationVO.setFogLight(JSONArray.toJSONString(jsonArray));
|
}
|
// 舱内清洁
|
String cabinCleaning = xpVehiclePreparation.getCabinCleaning();
|
if (StringUtils.isNotBlank(cabinCleaning)) {
|
JSONArray jsonArray = JSONArray.parseArray(cabinCleaning);
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
if (Objects.isNull(jsonObject)) {
|
continue;
|
}
|
String downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
|
jsonObject.put("url", downloadUrl);
|
}
|
xpVehiclePreparationVO.setCabinCleaning(JSONArray.toJSONString(jsonArray));
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return xpVehiclePreparationVO;
|
}
|
|
@Override
|
public PageInfo<XpVehiclePreparationDetailVO> queryPreparationByVehicleId(XpVehiclePreparationPageQuery query) {
|
// 1. 如果有操作人姓名过滤条件,先查询符合条件的用户ID列表
|
List<Long> userIds = null;
|
if (StringUtils.isNotBlank(query.getOperationsUserName())) {
|
R<List<XpOperationsUser>> userResult = xpOperationUserClient.listByName(query.getOperationsUserName());
|
List<XpOperationsUser> users = userResult.getData();
|
|
// 如果没有匹配的用户,直接返回空结果
|
if (CollectionUtils.isEmpty(users)) {
|
return new PageInfo<>(query.getPageNum(), query.getPageSize());
|
}
|
|
// 提取用户ID列表
|
userIds = users.stream()
|
.map(XpOperationsUser::getId)
|
.collect(Collectors.toList());
|
}
|
|
// 2. 使用 MyBatis-Plus Lambda 语法构建查询条件
|
LambdaQueryWrapper<XpVehiclePreparation> wrapper = new LambdaQueryWrapper<>();
|
|
// 必填条件: 车辆ID
|
wrapper.eq(XpVehiclePreparation::getVehicleId, query.getVehicleId());
|
|
// 可选条件: 操作人ID列表
|
if (!CollectionUtils.isEmpty(userIds)) {
|
wrapper.in(XpVehiclePreparation::getOperationsUserId, userIds);
|
}
|
|
// 可选条件: 开始时间
|
if (query.getStartTime() != null) {
|
wrapper.ge(XpVehiclePreparation::getCreateTime, query.getStartTime().atStartOfDay());
|
}
|
|
// 可选条件: 结束时间
|
if (query.getEndTime() != null) {
|
wrapper.le(XpVehiclePreparation::getCreateTime, query.getEndTime().atTime(23, 59, 59));
|
}
|
|
// 排序: 按创建时间倒序
|
wrapper.orderByDesc(XpVehiclePreparation::getCreateTime);
|
|
// 3. 执行分页查询
|
Page<XpVehiclePreparation> page = new Page<>(query.getPageNum(), query.getPageSize());
|
Page<XpVehiclePreparation> resultPage = this.page(page, wrapper);
|
|
// 4. 转换为 VO 并填充操作人姓名
|
List<XpVehiclePreparationDetailVO> records = new ArrayList<>();
|
if (!CollectionUtils.isEmpty(resultPage.getRecords())) {
|
// 提取所有操作人ID
|
List<Long> allUserIds = resultPage.getRecords().stream()
|
.map(XpVehiclePreparation::getOperationsUserId)
|
.filter(Objects::nonNull)
|
.distinct()
|
.collect(Collectors.toList());
|
|
// 批量查询操作人信息
|
Map<Long, String> userNameMap = new HashMap<>();
|
if (!CollectionUtils.isEmpty(allUserIds)) {
|
R<List<XpOperationsUser>> userResult = xpOperationUserClient.listByIds(allUserIds);
|
List<XpOperationsUser> users = userResult.getData();
|
if (!CollectionUtils.isEmpty(users)) {
|
userNameMap = users.stream()
|
.collect(Collectors.toMap(XpOperationsUser::getId, XpOperationsUser::getNickName));
|
}
|
}
|
|
// 转换并填充数据
|
for (XpVehiclePreparation preparation : resultPage.getRecords()) {
|
XpVehiclePreparationDetailVO vo = new XpVehiclePreparationDetailVO();
|
BeanUtils.copyProperties(preparation, vo);
|
vo.setOperationTime(preparation.getCreateTime());
|
|
// 填充操作人姓名
|
if (preparation.getOperationsUserId() != null) {
|
String userName = userNameMap.get(preparation.getOperationsUserId());
|
vo.setOperationsUserName(userName);
|
}
|
preparation.setLeftFrontWheel(aliOssDownloadUtil.getPictureJsonArray(preparation.getLeftFrontWheel()));
|
preparation.setRightFrontWheel(aliOssDownloadUtil.getPictureJsonArray(preparation.getRightFrontWheel()));
|
preparation.setLeftRearWheel(aliOssDownloadUtil.getPictureJsonArray(preparation.getLeftRearWheel()));
|
preparation.setRightRearWheel(aliOssDownloadUtil.getPictureJsonArray(preparation.getRightRearWheel()));
|
preparation.setBrakeLight(aliOssDownloadUtil.getPictureJsonArray(preparation.getBrakeLight()));
|
preparation.setFogLight(aliOssDownloadUtil.getPictureJsonArray(preparation.getFogLight()));
|
preparation.setBodyEmblem(aliOssDownloadUtil.getPictureJsonArray(preparation.getBodyEmblem()));
|
preparation.setCabinCleaning(aliOssDownloadUtil.getPictureJsonArray(preparation.getCabinCleaning()));
|
preparation.setLostItems(aliOssDownloadUtil.getPictureJsonArray(preparation.getLostItems()));
|
|
|
records.add(vo);
|
}
|
}
|
|
// 5. 构建分页结果
|
PageInfo<XpVehiclePreparationDetailVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
pageInfo.setRecords(records);
|
pageInfo.setTotal(resultPage.getTotal());
|
|
return pageInfo;
|
}
|
|
}
|
