湖北水库项目
blame | history | patch | commit | commitdiff | show whitespace
shenyijian
2024-06-27 b1e84b26d0b0f254d5e000092ce9f0ef56a1304c 
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java


@@ -7,6 +7,7 @@


import cn.gistack.sm.sg.VO.SgStepReportVO;


import cn.gistack.sm.sg.mapper.*;


import cn.gistack.sm.sg.service.SgProgressReportService;


import cn.hutool.http.useragent.UserAgentUtil;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;


@@ -64,10 +65,19 @@


      List<SgProgressReportVO> list = sgProgressReportMapper.queryPageList(page,searchDTO);


      return page.setRecords(list);


   }




   @Override


   public IPage<SgProgressReportVO> queryPageListAll(IPage<SgProgressReportVO> page, ProjectSearchDTO searchDTO) {


      List<SgProgressReportVO> list = sgProgressReportMapper.queryPageListAll(page,searchDTO);


      return page.setRecords(list);


   }


   @Override


   @Transactional


   public void add(SgProgressReportDO sgProgressReportDO) {


      //如果为草稿状态，单纯插入


      if(sgProgressReportDO.getStatus()==4){


         sgProgressReportMapper.insert(sgProgressReportDO);


         return;


      }


      Date now = DateUtil.now();


      sgProgressReportDO.setReportTime(now);


      sgProgressReportDO.setCreateTime(now);


@@ -76,7 +86,7 @@


      SgGxStepDO sgGxStepDO = sgGxStepMapper.selectById(gxStepId);


      List<SgGxStepDO> list = sgGxStepMapper.selectByGxInfoId(sgGxStepDO.getGxInfoId());


      QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();


      wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId);


      wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId).ne("status",4);


      List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper);


      if ( sgProgressReportDOS!=null && sgProgressReportDOS.size()>0){


         throw new ServiceException("此工序已存在审批！");


@@ -86,6 +96,7 @@


            QueryWrapper<SgProgressReportDO> wrapper1 = new QueryWrapper<>();


            wrapper1.eq("gx_step_id", gxStepDO.getId());


            wrapper1.eq("gx_device_id",gxDeviceId);


            wrapper1.ne("status",4);


            SgProgressReportDO one = sgProgressReportMapper.selectOne(wrapper1);


            if (one == null || one.getStatus() != 2) {


               throw new ServiceException("请先完成" + gxStepDO.getGxStepName() + "的审批！");


@@ -314,6 +325,19 @@


   }




   @Override


   public Map<String, Long> countListAll(ProjectSearchDTO searchDTO) {


      List<SgProgressReportVO> list = sgProgressReportMapper.queryPageListAll(null, searchDTO);


      List<SgProgressReportVO> pending = list.stream().filter(s -> s.getStatus() == 0).collect(Collectors.toList());


      List<SgProgressReportVO> over = list.stream().filter(s -> s.getStatus() == 1||s.getStatus()==2).collect(Collectors.toList());


      List<SgProgressReportVO> reject = list.stream().filter(s -> s.getStatus() == 3).collect(Collectors.toList());


      Map<String, Long> map = new HashMap<>();


      map.put("pending", (long) pending.size());


      map.put("over", (long) over.size());


      map.put("reject", (long) reject.size());


      return map;


   }




   @Override


   public Map<String, Long> statusCount(ProjectSearchDTO searchDTO) {


      List<SgProgressReportVO> list = sgProgressReportMapper.statusCount(searchDTO);


      Map<String, Long> map  = new HashMap<>();


@@ -321,11 +345,13 @@


      List<SgProgressReportVO> progress = list.stream().filter(s -> s.getStatus() == 1).collect(Collectors.toList());


      List<SgProgressReportVO> over = list.stream().filter(s -> s.getStatus() == 2).collect(Collectors.toList());


      List<SgProgressReportVO> reject = list.stream().filter(s -> s.getStatus() == 3).collect(Collectors.toList());


      List<SgProgressReportVO> draft = list.stream().filter(s -> s.getStatus() == 4).collect(Collectors.toList());


      map.put("all", (long) list.size());


      map.put("pending", (long) pending.size());


      map.put("progress", (long) progress.size());


      map.put("over", (long) over.size());


      map.put("reject", (long) reject.size());


      map.put("draft", (long) draft.size());


      return map;


   }




@@ -334,7 +360,7 @@


      SgGxStepDO sgGxStepDO = sgGxStepMapper.selectById(gxStepId);


      List<SgGxStepDO> list = sgGxStepMapper.selectByGxInfoId(sgGxStepDO.getGxInfoId());


      QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();


      wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId);


      wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId).ne("status",4);


      List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper);


      if ( sgProgressReportDOS!=null && sgProgressReportDOS.size()>0){


         return false;


@@ -344,6 +370,7 @@


            QueryWrapper<SgProgressReportDO> wrapper1 = new QueryWrapper<>();


            wrapper1.eq("gx_step_id", gxStepDO.getId());


            wrapper1.eq("gx_device_id", gxDeviceId);


            wrapper1.ne("status",4);


            SgProgressReportDO one = sgProgressReportMapper.selectOne(wrapper1);


            if (one == null || one.getStatus() != 2) {


               return false;


@@ -364,7 +391,7 @@


   @Override


   public String getDeviceReport(Long gxDeviceId, Long gxStepId) {


      QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();


      wrapper.eq("gx_device_id",gxDeviceId);


      wrapper.eq("gx_device_id",gxDeviceId).ne("status",4);


      if (gxStepId!=null){


         wrapper.eq("gx_step_id",gxStepId);


      }