湖北水库项目
blame | history | patch | commit | commitdiff | ignore whitespace
yxm
2024-07-05 becd74a14cdcc8abf41788a5735d185ffa48d24b 
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java


@@ -5,11 +5,13 @@


import cn.gistack.sm.sg.DO.SgGxStepDO;


import cn.gistack.sm.sg.DO.SgProjectInfoDO;


import cn.gistack.sm.sg.DTO.ProjectSearchDTO;


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


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


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


import cn.gistack.sm.sg.excel.ProjectExcel;


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


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


import cn.gistack.sm.sjztmd.entity.AttAdBase;


import cn.gistack.sm.sjztmd.service.IAttAdBaseService;


import cn.hutool.core.lang.copier.Copier;


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


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


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


@@ -18,13 +20,13 @@


import org.jetbrains.annotations.NotNull;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.StopWatch;




import java.math.BigDecimal;


import java.math.MathContext;


import java.math.RoundingMode;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.function.Function;


import java.util.stream.Collectors;




@@ -40,6 +42,8 @@


public class SgProjectInfoServiceImpl extends ServiceImpl<SgProjectInfoMapper, SgProjectInfoDO> implements SgProjectInfoService {


   @Autowired


   private SgProjectInfoMapper sgProjectInfoMapper;


   @Autowired


   private IAttAdBaseService iAttAdBaseService;


   @Override


   public IPage<SgProjectInfoDO> queryPageList(IPage<SgProjectInfoDO> page, ProjectSearchDTO searchDTO) {


      List<SgProjectInfoDO> sgProjectInfoDOS = baseMapper.queryPageList(page,searchDTO);


@@ -82,7 +86,7 @@


            continue;


         }


         SgProjectInfoVO sgProjectInfoVO = value.get(0);


         SgProjectInfoDO sgProjectInfoDO = SgProjectInfoDO.builder().id(porId).status(sgProjectInfoVO.getProjectStatus()).projectName(sgProjectInfoVO.getProjectName()).build();


         SgProjectInfoDO sgProjectInfoDO = SgProjectInfoDO.builder().id(porId).lonLat(sgProjectInfoVO.getLonLat()).status(sgProjectInfoVO.getProjectStatus()).projectName(sgProjectInfoVO.getProjectName()).build();


         List<SgTypeVO> sgGxDOS = new ArrayList<>();


         //类型分组


         Map<String, List<SgProjectInfoVO>> GxMap = value.stream().filter(s->s.getDeviceType()!=null).collect(Collectors.groupingBy(SgProjectInfoVO::getDeviceType));


@@ -103,7 +107,7 @@


               sgDeviceDO.setId(dId);


               sgDeviceDO.setDeviceName(deList.get(0).getDeviceName());


               sgDeviceDO.setStatus(   deList.get(0).getDeviceStatus());


               List<SgGxStepDO> stepDOS = deList.stream().map(s -> SgGxStepDO.builder().id(s.getStepId()).gxStepNum(s.getGxStepNum()).gxStepName(s.getGxStepName()).deviceId(s.getDId()).approvalStatus(s.getReportStatus()).build()).collect(Collectors.toList());


               List<SgGxStepDO> stepDOS = deList.stream().filter(s->s.getReportStatus()==null || s.getReportStatus()!=4).map(s -> SgGxStepDO.builder().id(s.getStepId()).gxStepNum(s.getGxStepNum()).gxStepName(s.getGxStepName()).deviceId(s.getDId()).approvalStatus(s.getReportStatus()).build()).collect(Collectors.toList());


               List<SgGxStepDO> stepOver = stepDOS.stream().filter(s -> s.getApprovalStatus() != null && s.getApprovalStatus() == 2).collect(Collectors.toList());


               BigDecimal stepSize = BigDecimal.valueOf(stepDOS.size());


               BigDecimal stepOverSize = BigDecimal.ZERO;


@@ -141,14 +145,19 @@




   @Override


   public List<SgProjectInfoVO> progressList(ProjectSearchDTO searchDTO) {


      List<SgProjectInfoVO> list = sgProjectInfoMapper.progressList(searchDTO);


      List<SgProjectInfoVO> list = new ArrayList<>();


      List<SgProjectInfoDO> projectProgress = getProjectProgress(sgProjectInfoMapper.queryStepByProject(searchDTO));


      Map<Long, SgProjectInfoDO> progressMap = projectProgress.stream().collect(Collectors.toMap(SgProjectInfoDO::getId, Function.identity()));


      list.forEach(s->{


         SgProjectInfoDO sgProjectInfoDO = progressMap.get(s.getId());


         s.setProgressName(sgProjectInfoDO.getProjectProgress());


         s.setProjectProgressNum(sgProjectInfoDO.getProjectProgressNum());


      });


      if (CollectionUtils.isNotEmpty(projectProgress)){


      projectProgress.forEach(s->{


         SgProjectInfoVO sgProjectInfoVO = new SgProjectInfoVO();


         sgProjectInfoVO.setId(s.getId());


         sgProjectInfoVO.setProjectName(s.getProjectName());


         sgProjectInfoVO.setProjectProgress(s.getProjectProgress());


         sgProjectInfoVO.setLonLat(s.getLonLat());


         sgProjectInfoVO.setProjectProgressNum(s.getProjectProgressNum());


         sgProjectInfoVO.setStatus(s.getStatus());


         list.add(sgProjectInfoVO);


      });}


      return list;


   }




@@ -161,17 +170,189 @@


   @Override


   public IPage<SgProjectInfoVO> progressPage(IPage<SgProjectInfoVO> page, ProjectSearchDTO searchDTO) {


      List<SgProjectInfoVO> list = sgProjectInfoMapper.progressList(page, searchDTO);


      List<Long> ids = list.stream().map(SgProjectInfoVO::getId).collect(Collectors.toList());


      searchDTO.setProjectIds(ids);


      List<SgProjectInfoDO> projectProgress = getProjectProgress(sgProjectInfoMapper.queryStepByProject(searchDTO));


      Map<Long, String> progressMap = projectProgress.stream().collect(Collectors.toMap(SgProjectInfoDO::getId, SgProjectInfoDO::getProjectProgress));


      if (CollectionUtils.isNotEmpty(projectProgress)){


      Map<Long, String> progressMap = projectProgress.stream().filter(s->s!=null && s.getProjectProgress() !=null).collect(Collectors.toMap(SgProjectInfoDO::getId, SgProjectInfoDO::getProjectProgress));


      list.forEach(s->{


         s.setProjectProgress(progressMap.get(s.getId()));


      });


      });}


      return page.setRecords(list);


   }




   @Override


   public List<SgProjectInfoDO> listAll(ProjectSearchDTO searchDTO) {


      return sgProjectInfoMapper.queryPageList(null,searchDTO);


   }




   /**


    * 项目统计饼状图


    * @param code


    * @return


    */


   @Override


   public SgStatisticsVO getsgStatistics(String code) {


      AttAdBase ywxtAdDetail = iAttAdBaseService.getYwxtAdDetail(code);




      if (ywxtAdDetail == null){


         return sgProjectInfoMapper.getSgstatiss("0",code);


      }


         return sgProjectInfoMapper.getSgstatiss(ywxtAdDetail.getAdGrad(),code);


   }




   /**


    * 项目统计表格


    * @param code


    * @return


    */




   @Override


   @Transactional


   public List<SgStatisProVO> getsgStatisticsList(String code) {


      AttAdBase ywxtAdDetail = iAttAdBaseService.getYwxtAdDetail(code);


      List<SgStatisProVO>  sgStatisProVOS;


      List<BigDecimal> bigDecimals = new ArrayList<>();




      ProjectSearchDTO projectSearchDTO = new ProjectSearchDTO();




      //片区


      if (ywxtAdDetail == null){


         sgStatisProVOS = sgProjectInfoMapper.getsgStatisticsZero(code);


         sgStatisProVOS.forEach(s->{


            if (s.getCommenceNum() == 0) {


               s.setProjectProgress("0%");


               s.setPcode("420000000000");


               s.setPname("湖北省");


               s.setAdGrad("2");


            }else {


               List<String> ids =  sgProjectInfoMapper.getProjectId("2",s.getCode());




               ids.forEach(id->{


                  projectSearchDTO.setProjectId(id);


                  List<SgProjectInfoVO> list =sgProjectInfoMapper.queryStepByProject(projectSearchDTO);


                  getProjectProgress(list).forEach(ss->{


                     bigDecimals.add(ss.getProjectProgressNum());


                  });


               });


               BigDecimal reduce = bigDecimals.stream().reduce(BigDecimal.ZERO, BigDecimal::add);


               String bigDecimalPercent1 = getBigDecimalPercent(reduce.divide(BigDecimal.valueOf(s.getProjectSum()), 2, RoundingMode.HALF_UP));


               s.setProjectProgress(s.getCommenceNum()==0?"0%": bigDecimalPercent1);


               s.setPcode("420000000000");


               s.setPname("湖北省");


               s.setAdGrad("2");




            }});


      return sgStatisProVOS;


      }


      //默认


      else  if (ywxtAdDetail.getAdGrad().equals("1")) {


         sgStatisProVOS = sgProjectInfoMapper.getsgStatisticsOne(code);


         sgStatisProVOS.forEach(s->{


            if (s.getCommenceNum() == 0) {


               s.setProjectProgress("0%");


               s.setPcode(ywxtAdDetail.getPAdCode());


               s.setPname(ywxtAdDetail.getPAdName());


               s.setAdGrad("0");


            }else {


            List<String> ids =  sgProjectInfoMapper.getProjectId(ywxtAdDetail.getAdGrad(),s.getCode());




               ids.forEach(id->{


                  projectSearchDTO.setProjectId(id);


                  List<SgProjectInfoVO> list =sgProjectInfoMapper.queryStepByProject(projectSearchDTO);


                  getProjectProgress(list).forEach(ss->{


                     bigDecimals.add(ss.getProjectProgressNum());


                  });


               });


               BigDecimal reduce = bigDecimals.stream().reduce(BigDecimal.ZERO, BigDecimal::add);


               String bigDecimalPercent1 = getBigDecimalPercent(reduce.divide(BigDecimal.valueOf(s.getProjectSum()), 2, RoundingMode.HALF_UP));


               s.setProjectProgress(s.getCommenceNum()==0?"0%": bigDecimalPercent1);


               s.setPcode(ywxtAdDetail.getPAdCode());


               s.setPname(ywxtAdDetail.getPAdName());


               s.setAdGrad("0");




         }});


         return sgStatisProVOS;


      }


      //区县


         sgStatisProVOS = sgProjectInfoMapper.getsgStatisticsList(code);


      sgStatisProVOS.forEach(s->{


         if (s.getCommenceNum() == 0) {


            s.setProjectProgress("0%");


            s.setPcode(ywxtAdDetail.getAdCode());


            s.setPname(ywxtAdDetail.getAdName());


            s.setAdGrad("3");


         }else {


            List<String> ids =  sgProjectInfoMapper.getProjectId("3",s.getCode());




            ids.forEach(id->{


               projectSearchDTO.setProjectId(id);


               List<SgProjectInfoVO> list =sgProjectInfoMapper.queryStepByProject(projectSearchDTO);


               getProjectProgress(list).forEach(ss->{


                  bigDecimals.add(ss.getProjectProgressNum());


               });


            });


            BigDecimal reduce = bigDecimals.stream().reduce(BigDecimal.ZERO, BigDecimal::add);


            String bigDecimalPercent1 = getBigDecimalPercent(reduce.divide(BigDecimal.valueOf(s.getProjectSum()), 2, RoundingMode.HALF_UP));


            s.setProjectProgress(s.getCommenceNum()==0?"0%": bigDecimalPercent1);


            s.setPcode(ywxtAdDetail.getAdCode());


            s.setPname(ywxtAdDetail.getAdName());


            s.setAdGrad("3");


         }});


      return sgStatisProVOS;




   }




   @Override


   public List<SgStatistccVO> getsgStatisticscc(String code) {


      AttAdBase ywxtAdDetail = iAttAdBaseService.getYwxtAdDetail(code);






      List<String> ids =  sgProjectInfoMapper.getProjectId(ywxtAdDetail==null?"0":ywxtAdDetail.getAdGrad(),code);


      Map<String,Integer>  mun = new HashMap<>();


      List<SgStatistccVO> sgdevices = sgProjectInfoMapper.getSgdevices(code,ywxtAdDetail==null?"0":ywxtAdDetail.getAdGrad());


         sgdevices.forEach(sgStatistccVO -> {


            mun.put(sgStatistccVO.getTypeName(),sgStatistccVO.getDeviceNum());


            }


         );


      Map<String,BigDecimal> bigDecimals = new HashMap<>();


      ProjectSearchDTO projectSearchDTO = new ProjectSearchDTO();


      ids.forEach(id->{




         projectSearchDTO.setProjectId(id);


         List<SgProjectInfoVO> list =sgProjectInfoMapper.queryStepByProject(projectSearchDTO);


         List<SgProjectInfoDO> projectProgress = getProjectProgress(list);


         projectProgress.forEach(p->{




            List<SgTypeVO> sgGxDOS = p.getSgGxDOS();


            sgGxDOS.forEach(sgTypeVO -> {


               String typeProgress = sgTypeVO.getTypeProgress().replace("%", "");


               BigDecimal percentageBigDecimal = new BigDecimal(typeProgress).divide(new BigDecimal("100"),2, RoundingMode.HALF_UP);


               bigDecimals.merge(sgTypeVO.getTypeName(),percentageBigDecimal,BigDecimal::add);


            });




         });




      });




      for (String name : bigDecimals.keySet()) {




         if (mun.containsKey(name)) {




            BigDecimal bigDecimal = bigDecimals.get(name);


            Integer intValue = mun.get(name);


               BigDecimal result = bigDecimal.divide(new BigDecimal(intValue), 2, BigDecimal.ROUND_HALF_UP);




            sgdevices.forEach(sgStatistccVO -> {


               if(sgStatistccVO.getTypeName().equals(name)){


                  sgStatistccVO.setTypeProgress(getBigDecimalPercent(result));


               }


            });


         }




      }




      return sgdevices;


   }




   /**


@@ -189,24 +370,13 @@


   @Override


   public Map<String, Object> projectCount(ProjectSearchDTO searchDTO) {


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


      LambdaQueryChainWrapper<SgProjectInfoDO> wrapper = new LambdaQueryChainWrapper<>(sgProjectInfoMapper);


      String projectName = searchDTO.getProjectName();


      Integer status = searchDTO.getStatus();


      if (StringUtils.isNotBlank(projectName)){


         wrapper.like(SgProjectInfoDO::getProjectName,searchDTO.getProjectName());


      }


      if (status!=null){


         wrapper.eq(SgProjectInfoDO::getStatus,searchDTO.getStatus());


      }


      List<SgProjectInfoDO> list = wrapper.list();


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


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


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




      List<SgProjectInfoVO> progressList = progressList(searchDTO);


      BigDecimal reduce = progressList.stream().map(SgProjectInfoDO::getProjectProgressNum).reduce(BigDecimal.ZERO, BigDecimal::add);


      BigDecimal reduce = progressList.stream().filter(s->s.getProjectProgressNum()!=null).map(SgProjectInfoDO::getProjectProgressNum).reduce(BigDecimal.ZERO, BigDecimal::add);


      BigDecimal divide = reduce.divide(BigDecimal.valueOf(progressList.size()), 2, RoundingMode.HALF_UP);


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


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


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


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


      map.put("all",  progressList.size());


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


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


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