湖北水库项目
blame | history | patch | commit | commitdiff | ignore 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() + "的审批！");


@@ -99,7 +110,7 @@


      SgDeviceDO sgDeviceDO = sgDeviceMapper.selectById(gxDeviceId);


      String deviceType = sgDeviceDO.getDeviceType();


      List<SgGxConfigDO> sgGxConfigDOS = new LambdaQueryChainWrapper<>(sgGxConfigMapper)


         .eq(SgGxConfigDO::getGxDeviceType, deviceType).eq(SgGxConfigDO::getGxStepId, gxStepId).list();


         .eq(SgGxConfigDO::getGxDeviceType, deviceType).eq(SgGxConfigDO::getGxStepId, gxStepId).orderByAsc(SgGxConfigDO::getSgOrder).list();


      List<String> roIds = sgGxConfigDOS.stream().map(SgGxConfigDO::getRoleId).collect(Collectors.toList());


      if (CollectionUtils.isEmpty(roIds)){


         throw new ServiceException("请完成工序角色配置！");


@@ -113,6 +124,11 @@


      for (SgGxConfigDO sgGxConfigDO : sgGxConfigDOS) {


         sgGxConfigDO.setUser(userMap.get(Long.parseLong(sgGxConfigDO.getRoleId())));


         sgReportUserMapper.insert(SgReportUserDO.builder().reportId(sgProgressReportDO.getId()).userId(sgGxConfigDO.getUser()).approvalStatus(0).approvalOrder(sgGxConfigDO.getSgOrder()).build());


         try {


            Thread.sleep(100);


         } catch (InterruptedException e) {


            throw new RuntimeException(e);


         }


         if (sgGxConfigDO.getSgOrder() == 1) {


            sgProgressReportDO.setAuditPerson(String.valueOf(sgGxConfigDO.getUser()));


            sgProgressReportMapper.updateById(sgProgressReportDO);


@@ -136,15 +152,7 @@


      SgProgressReportVO sgProgressReportVO = sgProgressReportMapper.queryById(id);


      SgDeviceDO sgDeviceDO = sgDeviceMapper.selectById(sgProgressReportVO.getGxDeviceId());


      sgProgressReportVO.setDeviceName(sgDeviceDO.getDeviceName());


      List<SgReportUserDO> list = new LambdaQueryChainWrapper<>(sgReportUserMapper).eq(SgReportUserDO::getReportId, id).list();


      List<SgReportUserDO> reportUserDOS = new ArrayList<>();


      Map<Integer, List<SgReportUserDO>> map = list.stream().collect(Collectors.groupingBy(SgReportUserDO::getIsHis));


      List<SgReportUserDO> sgReportUserDOS = map.get(1);


      if (CollectionUtils.isNotEmpty(sgReportUserDOS)){


         List<SgReportUserDO> sortList = sgReportUserDOS.stream().sorted(Comparator.comparing(SgReportUserDO::getApprovalTime)).collect(Collectors.toList());


         reportUserDOS.addAll(sortList);


      }


      reportUserDOS.addAll(map.get(0).stream().sorted(Comparator.comparingInt(SgReportUserDO::getApprovalOrder)).collect(Collectors.toList()));


      List<SgReportUserDO> list = new LambdaQueryChainWrapper<>(sgReportUserMapper).eq(SgReportUserDO::getReportId, id).orderByAsc(SgReportUserDO::getId).list();


      List<Long> ids = list.stream().map(s -> s.getUserId()).collect(Collectors.toList());


      List<Map<String,Object>> users = sgProgressReportMapper.getUserByIds(ids);


      for (Map<String, Object> user : users) {


@@ -154,7 +162,7 @@


            }


         }


      }


      sgProgressReportVO.setSgReportUserDOS(reportUserDOS);


      sgProgressReportVO.setSgReportUserDOS(list);


      List<SgStepReportVO> sgStepReportVOS = sgProgressReportMapper.selectByDeviceId(sgProgressReportVO.getGxDeviceId());


      sgProgressReportVO.setSgStepReportVOS(sgStepReportVOS);


      return sgProgressReportVO;


@@ -186,7 +194,7 @@


            cachedThreadPool.execute(new Runnable(){


               @Override


               public  void  run(){


                  setProgramAndDeviceStatus();


                  setProgramAndDeviceStatus(sgProgressReportMapper.selectById(approvalDTO.getId()).getProframId());


               }


            });




@@ -213,9 +221,23 @@


               reportUserDO.setIsHis(0);


               reportUserDO.setApprovalTime(date);


               sgReportUserMapper.insert(reportUserDO);


               try {


                  Thread.sleep(100);


               } catch (InterruptedException e) {


                  throw new RuntimeException(e);


               }


            }else if (reportUserDO.getApprovalOrder()>sgReportUserDO.getApprovalOrder()){


               sgReportUserMapper.deleteById(reportUserDO.getId());


               reportUserDO.setId(null);


               reportUserDO.setApprovalStatus(0);


               reportUserDO.setIsHis(0);


               reportUserDO.setApprovalTime(date);


               sgReportUserMapper.updateById(reportUserDO);


               sgReportUserMapper.insert(reportUserDO);


               try {


                  Thread.sleep(100);


               } catch (InterruptedException e) {


                  throw new RuntimeException(e);


               }


            }


            if (reportUserDO.getApprovalOrder()==1){


               updateChainWrapper.set(SgProgressReportDO::getAuditPerson,reportUserDO.getUserId());


@@ -228,9 +250,10 @@


   }






   public void  setProgramAndDeviceStatus(){


   public void  setProgramAndDeviceStatus(Long projectId){


      //查询所有的项目


      List<SgProjectInfoDO> sgProjectInfoDOS = sgProjectInfoMapper.selectList(null);


      SgProjectInfoDO sgProjectInfoDO = sgProjectInfoMapper.selectById(projectId);


      List<SgProjectInfoDO> sgProjectInfoDOS = List.of(sgProjectInfoDO);


      if(sgProjectInfoDOS!=null&& !sgProjectInfoDOS.isEmpty()) {


         for (SgProjectInfoDO project : sgProjectInfoDOS) {


            QueryWrapper<SgDeviceDO> queryWrapper = new QueryWrapper<>();


@@ -262,7 +285,7 @@


                        }


                  }


               }


               if (deviceFinishCount == sgDeviceDOS.size()) {


               if (deviceFinishCount!=0 && deviceFinishCount == sgDeviceDOS.size()) {


                  //如果项目下的设备下全部完成


                  project.setStatus(2);


                  sgProjectInfoMapper.updateById(project);


@@ -292,12 +315,25 @@


      Long userId = AuthUtil.getUserId();


      searchDTO.setUserId(userId);


      searchDTO.setApprovalStatus(0);


      Long pending = sgProgressReportMapper.countList(searchDTO);


      List<SgProgressReportVO> pending = sgProgressReportMapper.queryList(searchDTO);


      searchDTO.setApprovalStatus(1);


      Long over = sgProgressReportMapper.countList(searchDTO);


      List<SgProgressReportVO> over= sgProgressReportMapper.queryList(searchDTO);


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


      map.put("pending",pending);


      map.put("over",over);


      map.put("pending", Long.valueOf(pending.size()));


      map.put("over",Long.valueOf(over.size()));


      return map;


   }




   @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;


   }




@@ -309,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;


   }




@@ -322,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;


@@ -332,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;


@@ -352,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);


      }