首页项目统计柱状图列表饼状图

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,9 +20,11 @@
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.*;
import java.util.function.Function;
@@ -38,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);
@@ -181,6 +187,175 @@
   }

   /**
    * 项目统计饼状图
    * @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;
   }

   /**
    * 获取百分比
    * @param bigDecimal
    * @return