diff --git a/ebike-user/src/main/java/com/cdzy/user/service/impl/EbikeFaultReportServiceImpl.java b/ebike-user/src/main/java/com/cdzy/user/service/impl/EbikeFaultReportServiceImpl.java index 72d6665..49a48f9 100644 --- a/ebike-user/src/main/java/com/cdzy/user/service/impl/EbikeFaultReportServiceImpl.java +++ b/ebike-user/src/main/java/com/cdzy/user/service/impl/EbikeFaultReportServiceImpl.java @@ -22,6 +22,7 @@ import com.cdzy.user.service.EbikeFaultReportService; import com.cdzy.user.utils.MinioUtil; import com.ebike.feign.clients.OperationsFeignClient; import com.ebike.feign.model.dto.FeignEbikeUserBikeInfo; +import com.ebike.feign.model.vo.FeignInspectionSwapOrderVo; import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.query.QueryMethods; import com.mybatisflex.core.query.QueryWrapper; @@ -104,6 +105,23 @@ public class EbikeFaultReportServiceImpl extends ServiceImpl fileUrls = null; + if (Objects.nonNull(attachmentFiles)) { + fileUrls = attachmentFiles.stream() + .map(EbikeFaultFileDto::getFileUrl) + .filter(Objects::nonNull) + .toList(); + } + FeignInspectionSwapOrderVo feignInspectionSwapOrderVo = FeignInspectionSwapOrderVo.builder() + .bikeCode(ebikeFaultReportDto.getBikeCode()) + .parts(faultPart) + .fileUrls(fileUrls) + .build(); + JsonResult jsonResult = operationsFeignClient.inspectionSwapOrder(feignInspectionSwapOrderVo); + if (jsonResult.getCode() != Code.SUCCESS) { + throw new EbikeException("故障上报生成巡检工单失败!"); + } return reportId; }