From f5e1051a7e6d3ffccc815a631d8be372d772c58f Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期二, 23 七月 2024 11:56:22 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ycl-server/src/main/java/com/ycl/platform/service/impl/ReportServiceImpl.java | 139 ++++++++++++++++++++++++++++++++-------------- 1 files changed, 97 insertions(+), 42 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/ReportServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/ReportServiceImpl.java index a18f98b..d284f95 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/ReportServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/ReportServiceImpl.java @@ -1,34 +1,38 @@ package com.ycl.platform.service.impl; -import com.ycl.platform.domain.entity.Region; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.platform.domain.entity.Report; import com.ycl.platform.domain.entity.YwPeople; +import com.ycl.platform.domain.entity.YwPoint; import com.ycl.platform.domain.entity.YwUnit; -import com.ycl.platform.mapper.RegionMapper; +import com.ycl.platform.domain.form.ReportAuditingForm; +import com.ycl.platform.domain.form.ReportForm; +import com.ycl.platform.domain.query.ReportQuery; +import com.ycl.platform.domain.vo.ReportVO; +import com.ycl.platform.domain.vo.WorkOrderVO; import com.ycl.platform.mapper.ReportMapper; import com.ycl.platform.mapper.YwPeopleMapper; +import com.ycl.platform.mapper.YwPointMapper; import com.ycl.platform.mapper.YwUnitMapper; import com.ycl.platform.service.ReportService; import com.ycl.system.Result; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.ycl.platform.domain.form.ReportForm; -import com.ycl.platform.domain.vo.ReportVO; -import com.ycl.platform.domain.query.ReportQuery; -import java.util.List; -import org.apache.commons.lang3.StringUtils; -import com.baomidou.mybatisplus.core.metadata.IPage; import com.ycl.system.page.PageUtil; -import org.springframework.stereotype.Service; -import org.springframework.security.core.context.SecurityContextHolder; +import com.ycl.utils.SecurityUtils; +import lombok.RequiredArgsConstructor; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; -import org.springframework.transaction.annotation.Transactional; +import org.springframework.stereotype.Service; import org.springframework.util.Assert; +import org.springframework.util.CollectionUtils; + import java.util.ArrayList; +import java.util.Date; +import java.util.List; import java.util.Objects; import java.util.stream.Collectors; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; -import lombok.RequiredArgsConstructor; /** * 鎶ュ 鏈嶅姟瀹炵幇绫� @@ -40,10 +44,9 @@ @RequiredArgsConstructor public class ReportServiceImpl extends ServiceImpl<ReportMapper, Report> implements ReportService { - private final ReportMapper reportMapper; private final YwUnitMapper unitMapper; + private final YwPointMapper ywpointMapper; private final YwPeopleMapper peopleMapper; - private final RegionMapper regionMapper; /** * 娣诲姞 @@ -52,9 +55,12 @@ */ @Override public Result add(ReportForm form) { - form.setPeopleId(1); - form.setUnitId(2); + Long userId = SecurityUtils.getUserId(); + YwPeople people = new LambdaQueryChainWrapper<>(peopleMapper).eq(YwPeople::getUserId, userId).one(); + form.setPeopleId(people.getId()); + form.setUnitId(people.getBelongUnit()); Report entity = ReportForm.getEntityByForm(form, null); + entity.setStatus(0); if(baseMapper.insert(entity) > 0) { return Result.ok("娣诲姞鎴愬姛"); } @@ -113,29 +119,9 @@ */ @Override public Result page(ReportQuery query) { - - IPage<Report> page = new LambdaQueryChainWrapper<>(baseMapper) - .eq(StringUtils.isNotBlank(query.getReportType()), Report::getReportType, query.getReportType()) - .le(Objects.nonNull(query.getBeginCreateTime()), Report::getBeginCreateTime, query.getBeginCreateTime()) - .ge(Objects.nonNull(query.getEndCreateTime()), Report::getEndCreateTime, query.getEndCreateTime()) - .orderByDesc(Report::getCreateTime) - .page(PageUtil.getPage(query, Report.class)); - - List<ReportVO> vos = page.getRecords().stream() - .map( - entity -> { - ReportVO vo = ReportVO.getVoByEntity(entity, null); - YwUnit unit = unitMapper.selectById(vo.getUnitId()); - vo.setUnitName(unit.getUnitName()); - YwPeople ywPeople = peopleMapper.selectById(vo.getPeopleId()); - vo.setPeopleName(ywPeople.getYwPersonName()); - Region region = regionMapper.selectById(vo.getPointId()); - vo.setPointName(region.getFullName()); - return vo; - } - ) - .collect(Collectors.toList()); - return Result.ok().data(vos).total(page.getTotal()); + IPage<ReportVO> page = PageUtil.getPage(query, ReportVO.class); + baseMapper.page(page, query); + return Result.ok().data(page).total(page.getTotal()); } /** @@ -166,4 +152,73 @@ .collect(Collectors.toList()); return Result.ok().data(vos); } + + public List<ReportVO> export(ReportQuery query) { + + if (StringUtils.isNotBlank(query.getPointId())) { + LambdaQueryWrapper<YwPoint> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.like(YwPoint::getPointName, query.getPointId()); + query.setPointIdList(ywpointMapper.selectList(queryWrapper).stream().map(YwPoint::getId).collect(Collectors.toList())); + if(CollectionUtils.isEmpty(query.getPointIdList())) { + return new ArrayList<>(); + } + } + if (StringUtils.isNotBlank(query.getPeopleId())) { + LambdaQueryWrapper<YwPeople> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.like(YwPeople::getYwPersonName, query.getPeopleId()); + query.setPeopleIdList(peopleMapper.selectList(queryWrapper).stream().map(YwPeople::getId).collect(Collectors.toList())); + if(CollectionUtils.isEmpty(query.getPeopleIdList())) { + return new ArrayList<>(); + } + } + + IPage<Report> page = new LambdaQueryChainWrapper<>(baseMapper) + .eq(StringUtils.isNotBlank(query.getReportType()), Report::getReportType, query.getReportType()) + .le(Objects.nonNull(query.getBeginCreateTime()), Report::getBeginCreateTime, query.getBeginCreateTime()) + .ge(Objects.nonNull(query.getEndCreateTime()), Report::getEndCreateTime, query.getEndCreateTime()) + .in(!CollectionUtils.isEmpty(query.getPointIdList()), Report::getPointId, query.getPointIdList()) + .in(!CollectionUtils.isEmpty(query.getPeopleIdList()), Report::getPeopleId, query.getPeopleIdList()) + .orderByDesc(Report::getCreateTime) + .page(PageUtil.getPage(query, Report.class)); + + List<ReportVO> vos = page.getRecords().stream() + .map( + entity -> { + ReportVO vo = ReportVO.getVoByEntity(entity, null); + YwUnit unit = unitMapper.selectById(vo.getUnitId()); + vo.setUnitName(unit.getUnitName()); + YwPeople ywPeople = peopleMapper.selectById(vo.getPeopleId()); + vo.setPeopleName(ywPeople.getYwPersonName()); + YwPoint ywPoint = ywpointMapper.selectById(vo.getPointId()); + vo.setPointName(ywPoint.getPointName()); + return vo; + } + ) + .collect(Collectors.toList()); + return vos; + } + + + @Override + public Result examineRecord() { + + return null; + } + + @Override + public Result auditing(ReportAuditingForm form) { + Report report = baseMapper.selectById(form.getId()); + if (Objects.isNull(report)) { + throw new RuntimeException("瀹℃牳鐨勬姤澶囦笉瀛樺湪"); + } + if (form.getAuditingResult()) { + report.setStatus(1); + } else { + report.setStatus(2); + } + report.setAuditOpinion(form.getAuditOpinion()); + report.setAuditingTime(new Date()); + baseMapper.updateById(report); + return Result.ok("鎿嶄綔鎴愬姛"); + } } -- Gitblit v1.8.0