| | |
| | | import com.xiaopeng.maintenance.model.vo.XpVehicleCleanVO; |
| | | import com.xiaopeng.maintenance.service.IXpVehicleCleanService; |
| | | import com.xiaopeng.maintenance.service.XpTaskService; |
| | | import com.xiaopeng.maintenance.utils.AliOssDownloadUtil; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | private ThreadPoolTaskScheduler taskScheduler; |
| | | @Autowired |
| | | private AliOssService aliOssService; |
| | | @Autowired |
| | | private AliOssDownloadUtil aliOssDownloadUtil; |
| | | |
| | | /** |
| | | * 车辆运维-车辆运维-车身清洁 |
| | |
| | | @Transactional |
| | | @ShardingSphereTransactionType(TransactionType.BASE) |
| | | @ApiOperation(value = "车辆运维-车辆运维-车身清洁", tags = {"运维APP-车辆管理"}) |
| | | @PostMapping("/api/v1/vehicleClean/add") |
| | | @PostMapping("/maintenance-app/api/v1/vehicleClean/add") |
| | | public R<String> add(@RequestBody XpVehicleCleanDTO dto) { |
| | | Long id = tokenService.getLoginOperationUser().getId(); |
| | | dto.setOperationsUserId(id); |
| | |
| | | * 车辆运维-车辆运维-清洁记录详情 |
| | | */ |
| | | @ApiOperation(value = "车辆运维-运维记录-清洁记录详情", tags = {"运维APP-车辆管理"}) |
| | | @GetMapping("/api/v1/vehicleClean/cleanDetail") |
| | | @GetMapping("/maintenance-app/api/v1/vehicleClean/cleanDetail") |
| | | public R<XpVehicleCleanVO> cleanDetail(@RequestParam Long id) throws UnsupportedEncodingException { |
| | | XpVehicleCleanVO xpVehicleCleanVO = xpVehicleCleanService.cleanDetail(id); |
| | | String vehiclePictures = xpVehicleCleanVO.getVehiclePictures(); |
| | |
| | | |
| | | for (XpVehicleClean record : records) { |
| | | String taskImage = record.getTaskImage(); |
| | | if (StringUtils.isNotBlank(taskImage)) { |
| | | JSONArray jsonArray = JSONArray.parseArray(taskImage); |
| | | for (int i = 0; i < jsonArray.size(); i++) { |
| | | JSONObject jsonObject = jsonArray.getJSONObject(i); |
| | | if (Objects.isNull(jsonObject)) { |
| | | continue; |
| | | } |
| | | String downloadUrl = jsonObject.getString("url");; |
| | | try { |
| | | downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true); |
| | | } catch (UnsupportedEncodingException e) { |
| | | log.error("获取图片下载地址失败", e); |
| | | } |
| | | jsonObject.put("url", downloadUrl); |
| | | } |
| | | record.setTaskImage(JSONArray.toJSONString(jsonArray)); |
| | | } |
| | | record.setTaskImage(aliOssDownloadUtil.getPictureJsonArray(record.getTaskImage())); |
| | | data.stream().filter(xpOperationsUser -> xpOperationsUser.getId().equals(record.getOperationsUserId())).findFirst().ifPresent(xpOperationsUser -> record.setCreateBy(xpOperationsUser.getNickName())); |
| | | } |
| | | return R.ok(page); |