湖北水库项目
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,24 +5,29 @@


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;


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


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;




/**


@@ -37,26 +42,51 @@


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


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


      if (CollectionUtils.isNotEmpty(projectProgress)){


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


         sgProjectInfoDOS.forEach(s->{


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


         });


      }


      return page.setRecords(sgProjectInfoDOS);


   }




   /**


    * 获取项目及项目下设备及设备下工序进度


    * @param searchDTO


    * @return


    */


   @Override


   public List<SgProjectInfoDO> queryStepByProject(ProjectSearchDTO searchDTO) {


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


      return getProjectProgress(list);


   }




   /**


    * 获取项目进度


    * @param list


    * @return


    */


   @NotNull


   private List<SgProjectInfoDO> getProjectProgress(List<SgProjectInfoVO> list) {


      //项目分组


      Map<Long, List<SgProjectInfoVO>> projectMap = list.stream().collect(Collectors.groupingBy(SgProjectInfoVO::getId));


      List<SgProjectInfoDO> result = new ArrayList<>();


      for (Map.Entry<Long, List<SgProjectInfoVO>> entry : projectMap.entrySet()) {


         List<SgDeviceDO> allDevice = new ArrayList<>();


         Long porId = entry.getKey();


         List<SgProjectInfoVO> value = entry.getValue();


         if (CollectionUtils.isEmpty(value)){


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


@@ -77,13 +107,37 @@


               sgDeviceDO.setId(dId);


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


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


               sgDeviceDO.setStepDOList(deList.stream().map(s->SgGxStepDO.builder().id(s.getReportId()).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;


               if (!stepOver.isEmpty()){


                  stepOverSize = BigDecimal.valueOf(stepOver.size());


               }


               BigDecimal divide = stepOverSize.divide(stepSize, 2, RoundingMode.HALF_UP);


               sgDeviceDO.setProgress(divide.toString());


               sgDeviceDO.setDeviceProgress(getBigDecimalPercent(divide));


               sgDeviceDO.setStepDOList(stepDOS);


               deviceDOS.add(sgDeviceDO);


               allDevice.add(sgDeviceDO);


            }


            BigDecimal deviceSize = BigDecimal.valueOf(deviceDOS.size());


            double sum = deviceDOS.stream().mapToDouble(s -> Double.parseDouble(s.getProgress())).sum();


            BigDecimal deviceOver = BigDecimal.valueOf(sum);


            BigDecimal divideDevice = deviceOver.divide(deviceSize, 2, RoundingMode.HALF_UP);


            typeVO.setDeviceDOS(deviceDOS);


            typeVO.setTypeProgress(getBigDecimalPercent(divideDevice));


            sgGxDOS.add(typeVO);


         }


         sgProjectInfoDO.setSgGxDOS(sgGxDOS);


         BigDecimal allDeviceSize = BigDecimal.valueOf(allDevice.size());


         if (!allDeviceSize.equals(BigDecimal.ZERO)){


            double sum = allDevice.stream().mapToDouble(s -> Double.parseDouble(s.getProgress())).sum();


            BigDecimal allDeviceOver = BigDecimal.valueOf(sum);


            BigDecimal allDivideDevice = allDeviceOver.divide(allDeviceSize, 2, RoundingMode.HALF_UP);


            sgProjectInfoDO.setSgGxDOS(sgGxDOS);


            sgProjectInfoDO.setProjectProgress( getBigDecimalPercent(allDivideDevice));


            sgProjectInfoDO.setProjectProgressNum(allDivideDevice);


         }


         result.add(sgProjectInfoDO);


      }


      return result;


@@ -91,52 +145,248 @@




   @Override


   public List<SgProjectInfoVO> progressList(ProjectSearchDTO searchDTO) {


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


      Map<Long, List<SgProjectInfoVO>> map = list.stream().collect(Collectors.groupingBy(SgProjectInfoVO::getId));


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


      for (Map.Entry<Long, List<SgProjectInfoVO>> entry : map.entrySet()) {


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


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


      if (CollectionUtils.isNotEmpty(projectProgress)){


      projectProgress.forEach(s->{


         SgProjectInfoVO sgProjectInfoVO = new SgProjectInfoVO();


         List<SgProjectInfoVO> deviceList = entry.getValue();


         if (CollectionUtils.isEmpty(deviceList)){


            continue;


         }


         sgProjectInfoVO.setId(entry.getKey());


         sgProjectInfoVO.setProjectName(deviceList.get(0).getProjectName());


         List<SgProjectInfoVO> overList = deviceList.stream().filter(s->s.getDeviceStatus()!=null).filter(s -> s.getDeviceStatus() == 2).collect(Collectors.toList());


         BigDecimal v1 =BigDecimal.ZERO;


         if (CollectionUtils.isNotEmpty(overList)){


            v1 = BigDecimal.valueOf(overList.size());


         }


         BigDecimal v2 = BigDecimal.valueOf(deviceList.size());


         BigDecimal percentage = v1.divide(v2,2,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"));


         // 如果不需要保留小数位，可以设置一个scale为0


         BigDecimal percentageRounded = percentage.setScale(0, RoundingMode.HALF_UP);


         sgProjectInfoVO.setProgressName(percentageRounded+"%");


         result.add(sgProjectInfoVO);


      }


      return result;


         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;


   }




   /**


    * 项目进度列表（分页）


    * @param page


    * @param searchDTO


    * @return


    */


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


      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 Map<String, Long> projectCount(ProjectSearchDTO searchDTO) {


      Map<String, Long> 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());


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


      }


      if (status!=null){


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


         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;


      }


      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());


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


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


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


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


      //默认


      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;


   }




   /**


    * 获取百分比


    * @param bigDecimal


    * @return


    */


   private  String getBigDecimalPercent(BigDecimal bigDecimal) {


      BigDecimal percentage = bigDecimal.multiply(new BigDecimal("100"));


      // 如果不需要保留小数位，可以设置一个scale为0


      BigDecimal percentageRounded = percentage.setScale(0, RoundingMode.HALF_UP);


      return percentageRounded+"%";


   }




   @Override


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


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


      List<SgProjectInfoVO> progressList = progressList(searchDTO);


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


      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());


      map.put("projectProgress",  getBigDecimalPercent(divide));


      return map;


   }




   @Override


   public void importProject(List<ProjectExcel> data, Boolean isCovered) {




   }




}