| | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
| | | import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ycl.platform.domain.dto.ReportImportDTO; |
| | | import com.ycl.platform.domain.entity.*; |
| | |
| | | if (Objects.isNull(form.getPointId())) { |
| | | throw new RuntimeException("点位不能为空"); |
| | | } |
| | | Long userId = SecurityUtils.getUserId(); |
| | | YwPeople people = new LambdaQueryChainWrapper<>(peopleMapper).eq(YwPeople::getUserId, userId).one(); |
| | | form.setPeopleId(people.getId()); |
| | | form.setUnitId(people.getBelongUnit()); |
| | | Integer unitId = SecurityUtils.getUnitId(); |
| | | if (Objects.isNull(unitId)) { |
| | | throw new RuntimeException("非运维单位暂时无法报备"); |
| | | } |
| | | form.setUnitId(unitId); |
| | | Long userId = SecurityUtils.getLoginUser().getUserId(); |
| | | form.setPeopleId(Integer.parseInt(userId+"")); |
| | | if ("事前报备".equals(form.getReportType())) { |
| | | // 如果是事前报备需要检验是否已经生成下发工单 |
| | | YwPointVO point = ywpointMapper.countNotFinishedWorkOrderByGb(form.getPointId()); |
| | |
| | | @SneakyThrows |
| | | @Transactional |
| | | public Result importData(ReportForm form) { |
| | | Long userId = SecurityUtils.getUserId(); |
| | | YwPeople people = new LambdaQueryChainWrapper<>(peopleMapper).eq(YwPeople::getUserId, userId).one(); |
| | | form.setPeopleId(people.getId()); |
| | | form.setUnitId(people.getBelongUnit()); |
| | | Integer unitId = SecurityUtils.getUnitId(); |
| | | if (Objects.isNull(unitId)) { |
| | | throw new RuntimeException("非运维单位暂时无法报备"); |
| | | } |
| | | form.setUnitId(unitId); |
| | | form.setBeginCreateTime(DateUtils.parseDate(form.getBeginCreateTimeStr())); |
| | | form.setEndCreateTime(DateUtils.parseDate(form.getEndCreateTimeStr())); |
| | | // 读取excel数据 |
| | |
| | | @Override |
| | | public Result page(ReportQuery query) { |
| | | IPage<ReportVO> page = PageUtil.getPage(query, ReportVO.class); |
| | | query.setUnitId(SecurityUtils.getUnitId()); |
| | | baseMapper.page(page, query); |
| | | List<SysDictData> errorTypeList = dictTypeService.selectDictDataByType("report_error_type"); |
| | | Map<String, String> dictMap = errorTypeList.stream().collect(Collectors.toMap(SysDictData::getDictValue, SysDictData::getDictLabel)); |
| | |
| | | public List<ReportVO> export(ReportQuery query) { |
| | | IPage<ReportVO> page = PageUtil.getPage(query, ReportVO.class); |
| | | page.setSize(-1); |
| | | query.setUnitId(SecurityUtils.getUnitId()); |
| | | baseMapper.page(page, query); |
| | | List<SysDictData> errorTypeList = dictTypeService.selectDictDataByType("report_error_type"); |
| | | Map<String, String> dictMap = errorTypeList.stream().collect(Collectors.toMap(SysDictData::getDictValue, SysDictData::getDictLabel)); |
| | |
| | | item.setResultStr(records.get(0).getResult() ? "通过" : "未通过"); |
| | | item.setResultRemark(records.get(0).getResultRemark()); |
| | | item.setAuditingTime(records.get(0).getCreateTime()); |
| | | |
| | | } else { |
| | | item.setResultStr("审核中"); |
| | | } |
| | |
| | | } |
| | | return Result.ok("操作成功"); |
| | | } |
| | | |
| | | @Override |
| | | public Result getListByGb(String gb) { |
| | | List<ReportVO> list = baseMapper.getListByGb(gb); |
| | | for (ReportVO report : list) { |
| | | List<ReportErrorType> errors = new LambdaQueryChainWrapper<>(reportErrorTypeService.getBaseMapper()) |
| | | .eq(ReportErrorType::getReportId, report.getId()) |
| | | .orderByDesc(ReportErrorType::getCreateTime) |
| | | .list(); |
| | | String err = errors.stream().map(ReportErrorType::getErrorType).collect(Collectors.joining(",")); |
| | | report.setErrorType(err); |
| | | } |
| | | return Result.ok().data(list); |
| | | } |
| | | } |