| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public Result batchAuditing(WorkOrderBatchAuditingForm form) { |
|---|
| | | // 根据故障类型获取列表 |
|---|
| | | List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | | .in(WorkOrder::getStatus, WorkOrderStatusEnum.YW_HANDLE.getValue()) |
|---|
| | | .eq(WorkOrder::getErrorType, form.getErrorType()) |
|---|
| | | .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()); |
|---|
| | |
|---|
| | | } |
|---|
| | | 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, |
|---|
