From 98c8368c39bc0749a00e13544227fcdf490171f9 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期一, 23 十二月 2024 17:31:32 +0800 Subject: [PATCH] 代码初始化 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java | 83 ++++++++++++++++++++++++++++------------- 1 files changed, 56 insertions(+), 27 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java index 28bf9dd..f4a75c9 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java @@ -137,7 +137,10 @@ .apply("to_days(done_date) = to_days(now())") ); if(jobs!=null){ for(PlatformJob j :jobs){ - num =num.add(Constants.formatBigdecimal(j.getTotalNum())); + if(Objects.nonNull(j)&&Objects.nonNull(j.getTotalNum())){ + num =num.add(Constants.formatBigdecimal(j.getTotalNum())); + } + } } }else{ @@ -151,7 +154,9 @@ , Constants.PlatformJobStatus.LEAVED.getKey()) ); if(jobs!=null){ for(PlatformJob j :jobs){ - num = num.add(Constants.formatBigdecimal(j.getTotalNum())); + if(Objects.nonNull(j)&&Objects.nonNull(j.getTotalNum())){ + num = num.add(Constants.formatBigdecimal(j.getTotalNum())); + } } } } @@ -534,7 +539,6 @@ BaseResponse<CamerasPreviewURLsResponse> result = HKService.cameraPreviewURLs(request); if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ return result.getData().getUrl(); - } return null; } @@ -709,6 +713,7 @@ .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getCreateDate,PlatformJob::getCreateDate) .selectAs(PlatformJob::getTotalNum,PlatformJob::getTotalNum) + .selectAs(PlatformJob::getStatus,PlatformJob::getStatus) // .select("select sum(io_qty) from platform_wms_details a where a.isdeleted=0 and a.job_id=t.id",create_date) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .apply(queryType==0,"to_days(create_date) >= to_days(now()) -7") @@ -1285,8 +1290,8 @@ */ @Override public EnergyBoardVO centerEnergyData(){ - EnergyBoardVO data = new EnergyBoardVO(); - Random random = new Random(); + EnergyBoardVO data = new EnergyBoardVO(); + Random random = new Random(); PlatformWaterGas smoke= platformWaterGasMapper.selectOne(new QueryWrapper<PlatformWaterGas>() .select("sum(num) as num") .lambda() @@ -1369,8 +1374,14 @@ } if( data.getGasQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){ //璁$畻鐢ㄦ皵鍚屾瘮鐜瘮 - data.getGasQuantity().setSameRate(Constants.formatBigdecimal4Float(data.getGasQuantity().getSameNum().divide(data.getGasQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +""); - data.getGasQuantity().setRingRate(Constants.formatBigdecimal4Float(data.getGasQuantity().getRingNum().divide(data.getGasQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +""); + data.getGasQuantity().setSameRate( + (data.getGasQuantity().getTotalNum().subtract(data.getGasQuantity().getSameNum())).divide(data.getGasQuantity().getSameNum()).doubleValue()*100 +"" + /*Constants.formatBigdecimal4Float(data.getGasQuantity().getSameNum() + .divide(data.getGasQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +""*/); + data.getGasQuantity().setRingRate( + (data.getGasQuantity().getTotalNum().subtract(data.getGasQuantity().getRingNum())).divide(data.getGasQuantity().getRingNum()).doubleValue()*100 +"" + //Constants.formatBigdecimal4Float(data.getGasQuantity().getRingNum().divide(data.getGasQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +"" + ); } if( data.getWaterQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){ // //璁$畻鐢ㄦ按鍚屾瘮鐜瘮 @@ -1407,7 +1418,7 @@ * @param data */ private void getLastMonthElectricityData(EnergyModelDataVO data) { - BaseResponse<LastMonthFeeByMeterTypeResponse> response = HKService.lastMonthFeeByMeterType("1"); +// BaseResponse<LastMonthFeeByMeterTypeResponse> response = HKService.lastMonthFeeByMeterType("1"); // if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ // data.setRingRate(StringUtils.defaultString(response.getData().getRingPercent(),"0")); // data.setSameRate(StringUtils.defaultString(response.getData().getSamePercent(),"0")); @@ -1470,23 +1481,31 @@ * @param data */ private void getCurrentDateElectircityData(EnergyModelDataVO data,int days) { - EnergyTrendRequest param = new EnergyTrendRequest(); - param.setDate(DateUtil.getFomartDate(DateUtil.addDaysToDate(new Date(),days),"yyyy-MM-dd"));//鏃ユ湡 - param.setMeterType(1); - param.setShowType("4"); - param.setNodeType(2); - param.setNodeId("root000000"); +// EnergyTrendRequest param = new EnergyTrendRequest(); +// param.setDate(DateUtil.getFomartDate(DateUtil.addDaysToDate(new Date(),days),"yyyy-MM-dd"));//鏃ユ湡 +// param.setMeterType(1); +// param.setShowType("4"); +// param.setNodeType(2); +// param.setNodeId("root000000"); +// param.setPeriodType("day"); +// BigDecimal total = new BigDecimal(0); +// BaseResponse<EnergyTrendResponse> response = HKService.energyTrend(param); +// if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) +// && response.getData()!=null&& response.getData().getYvalues()!=null ){ +// for (int i = 0; i < response.getData().getYvalues().get(0).getValue().length; i++) { +// total = total.add(new BigDecimal(StringUtils.defaultString( response.getData().getYvalues().get(0).getValue()[i],"0"))); +// } +// +// } +// data.setTotal(Constants.formatBigdecimal2Float(total).toString()); + EnergyTotalDataRequest param = new EnergyTotalDataRequest(); param.setPeriodType("day"); - BigDecimal total = new BigDecimal(0); - BaseResponse<EnergyTrendResponse> response = HKService.energyTrend(param); - if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) - && response.getData()!=null&& response.getData().getYvalues()!=null ){ - for (int i = 0; i < response.getData().getYvalues().get(0).getValue().length; i++) { - total = total.add(new BigDecimal(StringUtils.defaultString( response.getData().getYvalues().get(0).getValue()[i],"0"))); - } - + param.setDate(DateUtil.getFomartDate(DateUtil.addDaysToDate(new Date(),days),"yyyy-MM-dd")); + BaseResponse<EnergyTotalDataResponse> beforMonthResponse = HKService.energyTotal(param); + if(beforMonthResponse != null && StringUtils.equals(beforMonthResponse.getCode(), HKConstants.RESPONSE_SUCCEE) && beforMonthResponse.getData()!=null ){ + data.setTotal(beforMonthResponse.getData().getElectricity()); + data.setTotalNum(new BigDecimal(beforMonthResponse.getData().getElectricity())); } - data.setTotal(Constants.formatBigdecimal2Float(total).toString()); } private EnergyModelDataVO getDefaultData() { @@ -1555,7 +1574,7 @@ .last(" group by DATE_FORMAT(TIME_INFO,'%Y-%m')") ); for (int i = 0; i < 12; i++) { - Date tempDate = DateUtil.increaseMonth(lastMonth,i); + Date tempDate = DateUtil.increaseMonth(lastMonth,i); EnergyDataVO data = new EnergyDataVO(); data.setTimeData(DateUtil.getFomartDate(tempDate,"YYYY-MM")); data.setEnergy(new BigDecimal(0)); @@ -1689,7 +1708,7 @@ (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Objects.isNull(i.getCompanyType())).count() ); //鍦ㄥ洯杞﹁締 - data.setInternalCarTotal( + data.setInParkCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).count() ); //鍦ㄥ洯鐩稿叧鏂硅溅杈� @@ -1974,6 +1993,7 @@ data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum())); data.setCalledNum(data.getCalledNum()+Constants.formatIntegerNum(model.getCountum())); data.setWorkedNum(data.getWorkedNum()+Constants.formatIntegerNum(model.getCountum())); + data.setWorkingCar(data.getWorkingCar()+Constants.formatIntegerNum(model.getCountum())); } // 浣滀笟瀹屾垚锛堥绾﹁溅銆佺鍒版暟銆佸凡鍙彿銆佷綔涓氳溅銆佸凡瀹屾垚锛� if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){ @@ -1999,7 +2019,7 @@ } // 宸茬鍥� if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())){ - data.setWorkingCar(data.getWorkingCar()+Constants.formatIntegerNum(model.getCountum())); + // data.setWorkingCar(data.getWorkingCar()+Constants.formatIntegerNum(model.getCountum())); } // 宸茶繃鍙凤紙棰勭害杞︺�佺鍒版暟銆佹帓闃熻溅锛� if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.OVER_NUMBER.getKey())){ @@ -2044,7 +2064,16 @@ } BaseResponse<List<RegionDataRankingDataResponse>> response = HKService.regionDataRanking(request); if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ - return response.getData(); + List<RegionDataRankingDataResponse> regionDataRankingDataResponseList = new ArrayList<>(); + for (RegionDataRankingDataResponse regionDataRankingDataResponse:response.getData()) { + if(StringUtils.isNotBlank(regionDataRankingDataResponse.getPercent())){ + if(Constants.equalsInteger(Integer.valueOf(new BigDecimal(regionDataRankingDataResponse.getPercent()).intValue()),Constants.ONE)){ + continue; + } + regionDataRankingDataResponseList.add(regionDataRankingDataResponse); + } + } + return regionDataRankingDataResponseList; }else{ return null; } -- Gitblit v1.9.3