From 77ce942a696de881cc703745b8b1d112ddb70fa5 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期一, 22 七月 2024 18:45:44 +0800 Subject: [PATCH] 车辆数据阈值检查接口 --- ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java | 37 ++++++++++++++++++------------------- 1 files changed, 18 insertions(+), 19 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java index 745e24a..03e14a0 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java @@ -12,6 +12,7 @@ import com.ycl.platform.domain.query.WorkOrderQuery; import com.ycl.platform.domain.vo.DistributeWorkOrderVO; import com.ycl.platform.domain.vo.WorkOrderVO; +import com.ycl.platform.domain.vo.WorkOrderYwConditionRecordVO; import com.ycl.platform.mapper.*; import com.ycl.platform.service.NotifyService; import com.ycl.platform.service.WorkOrderAuditingRecordService; @@ -30,6 +31,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; +import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; import java.time.LocalDateTime; @@ -75,7 +77,6 @@ entity.setWorkOrderNo(DateUtils.dateTimeNow()); entity.setCreateTime(DateUtils.getNowDate()); entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE); - entity.setDeleted("0"); if(baseMapper.insert(entity) > 0) { return Result.ok("娣诲姞鎴愬姛"); } @@ -128,14 +129,24 @@ @Override @Transactional(rollbackFor = Exception.class) public Result batchAuditing(WorkOrderBatchAuditingForm form) { + // 鏍规嵁鏁呴殰绫诲瀷鑾峰彇鍒楄〃 + List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper) + .in(WorkOrder::getStatus, WorkOrderStatusEnum.YW_HANDLE.getValue()) + .in(WorkOrder::getErrorType, form.getErrorTypes()) + .select(WorkOrder::getId, WorkOrder::getUnitId, WorkOrder::getWorkOrderNo) + .list(); + if (list.isEmpty()) { + return Result.error("娌℃湁宸ュ崟鍙互瀹℃牳"); + } + List<Integer> ids = list.stream().map(WorkOrder::getId).collect(Collectors.toList()); // 宸ュ崟鐘舵�� LambdaUpdateWrapper<WorkOrder> lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); - lambdaUpdateWrapper.in(WorkOrder::getId, form.getIds()); + lambdaUpdateWrapper.in(WorkOrder::getId, ids); lambdaUpdateWrapper.set(WorkOrder::getStatus, form.getAuditingResult()); baseMapper.update(lambdaUpdateWrapper); // 娣诲姞澶氭潯瀹℃牳璁板綍 List<WorkOrderAuditingRecord> workOrderAuditingRecords = new ArrayList<>(); - for (Integer id : form.getIds()) { + for (Integer id : ids) { WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord(); workOrderAuditingRecord.setWorkOrderId(id); workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue()); @@ -145,7 +156,6 @@ } workOrderAuditingRecordService.saveBatch(workOrderAuditingRecords); // 娣诲姞鏂伴�氱煡 - List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper).in(WorkOrder::getId, form.getIds()).select(WorkOrder::getUnitId, WorkOrder::getWorkOrderNo).list(); List<Notify> notifies = new ArrayList<>(); for (WorkOrder workOrder : list) { Notify notify = Notify.genEntityByUnit(NotifyTypeEnum.WORK_ORDER, @@ -181,21 +191,9 @@ } @Override - public Result selectYwConditionByYwId(String id) { - return Result.ok().data( - new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper) - .eq(WorkOrderYwConditionRecord::getWorkOrderId, id) - .orderByAsc(WorkOrderYwConditionRecord::getCreateTime) - .list()); - } - - @Override - public Result selectYwConditionListByYwId(String id) { - return Result.ok().data( - new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper) - .eq(WorkOrderYwConditionRecord::getWorkOrderId, id) - .orderByAsc(WorkOrderYwConditionRecord::getCreateTime) - .list()); + public Result selectYwConditionByYwId(Integer id) { + List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id); + return Result.ok().data(ywConditionList); } @Override @@ -258,6 +256,7 @@ @Override public Result distributePage(DistributeWorkOrderQuery query) { IPage<WorkOrderVO> page = PageUtil.getPage(query, WorkOrderVO.class); + // todo 鍏抽敭璇嶆悳绱� baseMapper.distributePage(page, query); return Result.ok().data(page).total(page.getTotal()); } -- Gitblit v1.8.0