Merge remote-tracking branch 'origin/master'

luodangjia

2024-10-17 0911582d2f80e7f3162fb6d0b59ee12e23de133b

 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java

@@ -262,7 +262,7 @@
         //调用华为Iot删除设备
         if(StringUtils.isNotEmpty(chargingPile.getIotdDeviceId())){
            DeleteDeviceResp deviceResp = iotInterfaceClient.deleteDevice(chargingPile.getIotdDeviceId()).getData();
            if(null != deviceResp && deviceResp.getHttpStatusCode() == 201){
            if(null != deviceResp && deviceResp.getHttpStatusCode() == 0){
               this.removeById(chargingPile);
            }
         }
@@ -320,7 +320,7 @@
   public ChargeMonitoring chargeMonitoring(Integer siteId) {
      //获取当前登录账户的站点权限数据
      Set<Integer> siteIds = new HashSet<>();
      if(null == siteId){
      if(0 == siteId){
         SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
         Integer roleType = sysUser.getRoleType();
         Integer objectId = sysUser.getObjectId();
@@ -334,12 +334,20 @@
                    List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
               data.addAll(data1);
               siteIds = new HashSet<>(data);
            }else{
               siteIds = null;
            }
         }
      }else{
         siteIds.add(siteId);
      }
      List<Site> sites = siteService.listByIds(siteIds);
      List<Site> sites = null;
      if(null == siteIds){
         sites = siteService.list(new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0));
         siteIds = sites.stream().map(Site::getId).collect(Collectors.toSet());
      }else{
         sites = siteService.listByIds(siteIds);
      }
      List<TChargingGun> total = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().in(TChargingGun::getSiteId, siteIds).eq(TChargingGun::getDelFlag, 0));
      List<TChargingGun> charging = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().in(TChargingGun::getSiteId, siteIds).eq(TChargingGun::getStatus, 4).eq(TChargingGun::getDelFlag, 0));
      BigDecimal ratedPower = total.stream().map(TChargingGun::getRatedPower).reduce(BigDecimal.ZERO, BigDecimal::add);
@@ -361,9 +369,9 @@
      }

      List<String> dates = new ArrayList<>();
      SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MMM-dd");
      Calendar calendar = Calendar.getInstance();
      SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
      for (int i = 6; i >= 0; i--) {
         Calendar calendar = Calendar.getInstance();
         calendar.set(Calendar.DAY_OF_YEAR, calendar.get(Calendar.DAY_OF_YEAR) - i);
         dates.add(sdf.format(calendar.getTime()));
      }
@@ -382,7 +390,7 @@
         if(list.size() == 0){
            value2.add(0D);
         }else{
            Double datum1 = new BigDecimal(datum).divide(new BigDecimal(list.size()).multiply(v).multiply(new BigDecimal(24))).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
            Double datum1 = new BigDecimal(datum).divide(new BigDecimal(list.size()).multiply(v).multiply(new BigDecimal(24)), new MathContext(4, RoundingMode.HALF_EVEN)).multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
            value2.add(datum1);
         }
      }
@@ -404,7 +412,7 @@
   public ChargingGunCountMonitoring getChargingGunCountMonitoring(Integer siteId) {
      //获取当前登录账户的站点权限数据
      Set<Integer> siteIds = new HashSet<>();
      if(null == siteId){
      if(0 == siteId){
         SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
         Integer roleType = sysUser.getRoleType();
         Integer objectId = sysUser.getObjectId();
@@ -418,6 +426,9 @@
                    List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
               data.addAll(data1);
               siteIds = new HashSet<>(data);
            }else{
               List<Site> list = siteService.list(new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0));
               siteIds = list.stream().map(Site::getId).collect(Collectors.toSet());
            }
         }
      }else{
@@ -452,7 +463,7 @@
   public PageInfo<ChargingGunMonitoring> getChargingGunMonitoring(GetChargingGunMonitoring query) {
      //获取当前登录账户的站点权限数据
      Set<Integer> siteIds = new HashSet<>();
      if(null == query.getSiteId()){
      if(0 == query.getSiteId()){
         SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
         Integer roleType = sysUser.getRoleType();
         Integer objectId = sysUser.getObjectId();
@@ -466,6 +477,9 @@
                    List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
               data.addAll(data1);
               siteIds = new HashSet<>(data);
            }else{
               List<Site> list = siteService.list(new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0));
               siteIds = list.stream().map(Site::getId).collect(Collectors.toSet());
            }
         }
      }else{
@@ -489,11 +503,10 @@
            Integer id = gunMonitoring.getId();
            //根据订单数据查询车牌号
            TChargingOrder chargingOrder = chargingOrderClient.getOrderDetailByGunId(id).getData();
            if(null != chargingOrder){
            Long appUserCarId = chargingOrder.getAppUserCarId();
            if(null != appUserCarId){
               TAppUserCar tAppUserCar = appUserCarClient.getCarByIds(Arrays.asList(appUserCarId)).getData().get(0);
               gunMonitoring.setLicensePlate(tAppUserCar.getLicensePlate());
            }
            
            UploadRealTimeMonitoringData data = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrder.getCode()).getData();
            gunMonitoring.setChargingRatio(BigDecimal.valueOf(data.getSoc()));
@@ -543,8 +556,7 @@
                  break;
            }
         }
			
			
         }
      }
      return pageInfo.setRecords(chargingGunMonitoring);
   }