明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
luodangjia
2024-09-18 a96c5eddcd63fa6f09e4cdce9e28c7b846068f0c 
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingGunServiceImpl.java


@@ -7,9 +7,7 @@


import com.ruoyi.chargingPile.api.model.TChargingGun;


import com.ruoyi.chargingPile.api.model.TChargingPile;


import com.ruoyi.chargingPile.api.query.TChargingGunQuery;


import com.ruoyi.chargingPile.api.vo.ChargingGunCountVO;


import com.ruoyi.chargingPile.api.vo.TChargingGunVO;


import com.ruoyi.chargingPile.api.vo.TMonitoringEquipmentVO;


import com.ruoyi.chargingPile.api.vo.*;


import com.ruoyi.chargingPile.domain.SiteMenu;


import com.ruoyi.chargingPile.mapper.TChargingGunMapper;


import com.ruoyi.chargingPile.service.IPartnerService;


@@ -25,18 +23,15 @@


import com.ruoyi.other.api.feignClient.UserSiteClient;


import com.ruoyi.system.api.domain.SysUser;


import com.ruoyi.system.api.feignClient.SysUserClient;


import com.ruoyi.system.api.feignClient.SysUserRoleClient;


import com.ruoyi.system.api.model.SysUserRoleVo;


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


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;




import javax.annotation.Resource;


import java.util.Arrays;


import java.util.HashSet;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.*;


import java.util.stream.Collectors;


import java.util.Set;




/**


 * <p>


@@ -63,6 +58,9 @@


    @Autowired


    private TChargingPileService chargingPileService;




    @Resource


    private SysUserRoleClient sysUserRoleClient;




    


    


    


@@ -80,7 +78,8 @@


            //非管理员需要根据角色和用户配置查询允许的站点数据


            if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){


                List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();


                List<Integer> data1 = roleSiteClient.getSiteIds(sysUser.getRoleId()).getData();


                List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();


                List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();


                data.addAll(data1);


                siteIds = new HashSet<>(data);


            }


@@ -182,6 +181,63 @@


        return map;


    }




    @Override


    public GunStatusStatisticsVO gunStatusStatistics(List<Integer> siteIds) {


        GunStatusStatisticsVO gunStatusStatisticsVO = new GunStatusStatisticsVO();




        if(CollectionUtils.isEmpty(siteIds)){


            Map<Integer, Integer> modeStatisticsNull = new HashMap<>();


            modeStatisticsNull.put(1, 0);


            modeStatisticsNull.put(2, 0);


            modeStatisticsNull.put(3, 0);


            gunStatusStatisticsVO.setModeStatistics(modeStatisticsNull);


            Map<Integer, Integer> statusStatisticsNull = new HashMap<>();


            statusStatisticsNull.put(1, 0);


            statusStatisticsNull.put(2, 0);


            statusStatisticsNull.put(3, 0);


            gunStatusStatisticsVO.setStatusStatistics(statusStatisticsNull);


            List<StatusModeStatisticsVO> statusModeStatistics = new ArrayList<>();


            for (int i = 1; i < 4; i++) {


                StatusModeStatisticsVO statusModeStatisticsVO = new StatusModeStatisticsVO();


                statusModeStatisticsVO.setChargeMode(i);


                statusModeStatisticsVO.setChargingCount(0);


                statusModeStatisticsVO.setFilledCount(0);


                statusModeStatisticsVO.setInsertCount(0);


                statusModeStatisticsVO.setFreeCount(0);


                statusModeStatistics.add(statusModeStatisticsVO);


            }


            gunStatusStatisticsVO.setStatusModeStatistics(statusModeStatistics);


        }




        Map<Integer, Integer> modeStatistics = this.baseMapper.getModeStatistics(siteIds);


        gunStatusStatisticsVO.setModeStatistics(modeStatistics);




        Map<Integer, Integer> statusStatistics = new HashMap<>();


        // 离线


        Long count = this.baseMapper.selectCount(Wrappers.lambdaQuery(TChargingGun.class)


                .eq(TChargingGun::getStatus, 1));


        statusStatistics.put(1, count.intValue());


        // 故障


        count = this.baseMapper.selectCount(Wrappers.lambdaQuery(TChargingGun.class)


                .eq(TChargingGun::getStatus, 7));


        statusStatistics.put(2, count.intValue());


        // 充电中


        count = this.baseMapper.selectCount(Wrappers.lambdaQuery(TChargingGun.class)


                .in(TChargingGun::getStatus, Arrays.asList(3,4,5,6)));


        statusStatistics.put(3, count.intValue());


        gunStatusStatisticsVO.setModeStatistics(statusStatistics);




        List<StatusModeStatisticsVO> statusModeStatisticsVOS = new ArrayList<>();


        StatusModeStatisticsVO statusModeStatistics1 = this.baseMapper.getStatusModeStatistics(siteIds,1);


        StatusModeStatisticsVO statusModeStatistics2 = this.baseMapper.getStatusModeStatistics(siteIds,2);


        StatusModeStatisticsVO statusModeStatistics3 = this.baseMapper.getStatusModeStatistics(siteIds,3);


        statusModeStatisticsVOS.add(statusModeStatistics1);


        statusModeStatisticsVOS.add(statusModeStatistics2);


        statusModeStatisticsVOS.add(statusModeStatistics3);


        gunStatusStatisticsVO.setStatusModeStatistics(statusModeStatisticsVOS);


        return gunStatusStatisticsVO;


    }




    private ChargingGunCountVO getGunCount(Integer chargeMode, List<TChargingGun> list){


        ChargingGunCountVO chargingGunCountVO = new ChargingGunCountVO();


        chargingGunCountVO.setTotalCount(list.stream().filter(tChargingGun -> tChargingGun.getChargeMode().equals(chargeMode)).collect(Collectors.toList()).size());