From b0c4a1ff9d2df09c137807e9c38c43bf9a097237 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期二, 07 一月 2025 09:16:21 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java | 140 +++++++++++++++++++++++++++++++++++----------- 1 files changed, 106 insertions(+), 34 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 7bb3f9e..cf32481 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 @@ -1,7 +1,5 @@ package com.doumee.service.business.impl.thrid; -import com.alibaba.fastjson.JSONObject; -import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; @@ -16,12 +14,10 @@ import com.doumee.core.haikang.model.param.respose.*; import com.doumee.core.haikang.service.HKCarOpenService; import com.doumee.core.haikang.service.HKService; -import com.doumee.core.tms.model.TMSContants; -import com.doumee.core.tms.model.request.TmsFacrotyCodeListRequest; -import com.doumee.core.tms.model.request.TmsOrderNoFinishListRequest; -import com.doumee.core.tms.model.request.TmsOutQtyAndVehicleQtyRequest; -import com.doumee.core.tms.model.request.TmsSevenArrivalDetailsRequest; -import com.doumee.core.tms.model.response.*; +import com.doumee.service.business.third.model.request.TmsFacrotyCodeListRequest; +import com.doumee.service.business.third.model.request.TmsOrderNoFinishListRequest; +import com.doumee.service.business.third.model.request.TmsOutQtyAndVehicleQtyRequest; +import com.doumee.service.business.third.model.request.TmsSevenArrivalDetailsRequest; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; @@ -32,14 +28,17 @@ import com.doumee.dao.business.join.PlatformWarnEventJoinMapper; import com.doumee.dao.business.join.VisitsJoinMapper; import com.doumee.dao.business.model.*; +import com.doumee.dao.business.model.Member; import com.doumee.dao.web.reqeust.CarsJobAndContractDTO; import com.doumee.dao.web.response.platformReport.*; import com.doumee.service.business.impl.PlatformJobServiceImpl; import com.doumee.service.business.third.BoardService; import com.doumee.service.business.third.TmsService; import com.doumee.service.business.third.WmsService; +import com.doumee.service.business.third.model.response.*; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import io.swagger.annotations.ApiModelProperty; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; @@ -516,6 +515,12 @@ String privateIp =systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.EVENT_FILES_PRIVATE_DOMAIN).getCode(); String publicIp =systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.EVENT_FILES_PUBLIC_DOMAIN).getCode(); for(RuleEventSearchDataResponse r :rlist){ + try { + if(DateUtil.getISO8601DateByStr(r.getHappen_time()).getTime() >= Utils.Date.getStart(new Date()).getTime()){ + continue; + } + }catch (Exception e){ + } WaningEventDataListVO data = new WaningEventDataListVO(); data.setAddr(r.getSrc_name()); data.setImg(r.getImage_url()); @@ -590,25 +595,46 @@ public List<AlarmEventDataVO> fightingAdminAlertList(){ List<AlarmEventDataVO> data = new ArrayList<>(); - //鏌ヨ24灏忔椂鍐呯殑 + List<FindHomeAlarmInfoPageResponse> allList = new ArrayList<>(); + boolean hasNext = true; + int curTotal = 0; + int curPage = 1; FindHomeAlarmInfoPageRequest param = new FindHomeAlarmInfoPageRequest(); param.setHour(24); - param.setPage(1); param.setUserId("admin"); + while (hasNext){ + //鍒嗛〉閬嶅巻寰幆鏌ヨ鎵�鏈夐棬绂佽澶囨暟鎹� + param.setPage(curPage); // param.setRegionIndexCodes("root000000"); - param.setAlarmStartTime(DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") + " 00:00:00"); - param.setAlarmEndTime(DateUtil.getPlusTime2(new Date())); - param.setPageSize(20); - BaseResponse<BaseListPageResponse<FindHomeAlarmInfoPageResponse>> response = HKService.findHomeAlarmInfoPage(param); - if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) - && response.getData()!=null - &&response.getData().getList()!=null) { + param.setAlarmStartTime(DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") + " 00:00:00"); + param.setAlarmEndTime(DateUtil.getPlusTime2(new Date())); + param.setPageSize(50); + BaseResponse<BaseListPageResponse<FindHomeAlarmInfoPageResponse>> response = HKService.findHomeAlarmInfoPage(param); + if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ + throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝娴峰悍鍚屾鏁版嵁澶辫触~"); + } for(FindHomeAlarmInfoPageResponse r : response.getData().getList()){ AlarmEventDataVO t = new AlarmEventDataVO(); BeanUtils.copyProperties(r,t); - data.add(t); + try { + if(DateUtil.getDateFromString(t.getAlarmTime()).getTime() >= Utils.Date.getStart(new Date()).getTime()){ + data.add(t); + }else{ + hasNext =false; + } + }catch (Exception e){ + } } + curTotal += 50; + if(curTotal >= response.getData().getTotal()){ + hasNext = false; + } + if(response.getData().getList() == null || response.getData().getList().size()==0){ + hasNext =false; + } + curPage++; } + return data; } @@ -1198,10 +1224,10 @@ BaseResponse<FireStatisticResponse> response1 = HKService.fireStatisticMonth(param); if(response1 != null && StringUtils.equals(response1.getCode(), HKConstants.RESPONSE_SUCCEE) && response1.getData()!=null ) { - data.setMonthAddNum(Constants.formatIntegerNum(response1.getData().getMaintenanceNum())); + data.setMonthAddNum(Constants.formatIntegerNum(response1.getData().getMaintenanceNumMonth())); data.setMonthTotalNum(Constants.formatIntegerNum(response1.getData().getDeviceTotalNum())); } - return data; + return data; } @@ -1382,14 +1408,19 @@ } if( data.getGasQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){ //璁$畻鐢ㄦ皵鍚屾瘮鐜瘮 - data.getGasQuantity().setSameRate( - (data.getGasQuantity().getTotalNum().subtract(data.getGasQuantity().getSameNum())).divide(data.getGasQuantity().getSameNum()).doubleValue()*100 +"" + if(Constants.formatBigdecimal(data.getGasQuantity().getSameNum()).compareTo(new BigDecimal(0))!=0){ + data.getGasQuantity().setSameRate( + (data.getGasQuantity().getTotalNum().subtract(data.getGasQuantity().getSameNum())).divide(data.getGasQuantity().getSameNum(),4,BigDecimal.ROUND_HALF_UP).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(Constants.formatBigdecimal(data.getGasQuantity().getRingNum()).compareTo(new BigDecimal(0))!=0){ + data.getGasQuantity().setRingRate( + (data.getGasQuantity().getTotalNum().subtract(data.getGasQuantity().getRingNum())).divide(data.getGasQuantity().getRingNum(),4,BigDecimal.ROUND_HALF_UP).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){ // //璁$畻鐢ㄦ按鍚屾瘮鐜瘮 @@ -2126,6 +2157,11 @@ if(t.getTotalNum().compareTo(new BigDecimal(0)) !=0){ t.setUseRate(t.getCurrentNum().divide(t.getTotalNum(),4,BigDecimal.ROUND_HALF_UP)); } + if(Constants.UNIT_TYPE == 1) { + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + t.setCurrentNum(Constants.formatBigdecimal(t.getCurrentNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + t.setTotalNum(Constants.formatBigdecimal(t.getTotalNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + } } result.getDetailList().add(t); result.setCurrentNum(result.getCurrentNum().add(t.getCurrentNum())); @@ -2268,6 +2304,15 @@ if(data.getCrrentRestCarNum()<=0){ data.setCrrentRestCarNum(0); } + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + if(Constants.UNIT_TYPE == 1) { + data.setMaxAbility(Constants.formatBigdecimal(data.getMaxAbility()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setHoursAbility(Constants.formatBigdecimal(data.getHoursAbility()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setCrrentRestNum(Constants.formatBigdecimal(data.getCrrentRestNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setCurrentPlanNum(Constants.formatBigdecimal(data.getCurrentPlanNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setCrrentOutNum(Constants.formatBigdecimal(data.getCrrentOutNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setCurrentOrderNum(Constants.formatBigdecimal(data.getCurrentOrderNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + } } private boolean notInList(String transportCode, List<String> planCodes) { @@ -2356,6 +2401,16 @@ data.setSameOutNum(data.getLastOutNum()); data.setSameInNum(data.getLastInNum()); } + + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + if(Constants.UNIT_TYPE == 1) { + data.setCurrentInNum(Constants.formatBigdecimal(data.getCurrentInNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setCurrentOutNum(Constants.formatBigdecimal(data.getCurrentOutNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setLastInNum(Constants.formatBigdecimal(data.getLastInNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setLastOutNum(Constants.formatBigdecimal(data.getLastOutNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setSameInNum(Constants.formatBigdecimal(data.getSameInNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + data.setSameOutNum(Constants.formatBigdecimal(data.getSameOutNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + } return data; } /** @@ -2373,14 +2428,20 @@ List<TmsDistributionOfDeliveryLocResponse> response = tmsService.getDistributionOfDeliveryLocations(param);//鏌ヨ鍑哄簱閲� if(response!=null &&response.size()>0){ for(TmsDistributionOfDeliveryLocResponse model : response){ - WholeProvinceMapVO tt = getFromProvinceResultList(model ,result); - if(tt == null){ - tt =new WholeProvinceMapVO(); - tt.setMonthNum( Constants.formatBigdecimal0Float(model.getMonthOutboundQuantity())); - tt.setYearNum( Constants.formatBigdecimal0Float(model.getYearOutboundQuantity())); - tt.setProvinceCode(model.getToProvinceCode()); - tt.setProvinceName(model.getToProvinceName()); - result.add(tt); + WholeProvinceMapVO t = getFromProvinceResultList(model ,result); + if(t == null){ + t =new WholeProvinceMapVO(); + t.setMonthNum( Constants.formatBigdecimal0Float(model.getMonthOutboundQuantity())); + t.setYearNum( Constants.formatBigdecimal0Float(model.getYearOutboundQuantity())); + + if(Constants.UNIT_TYPE == 1) { + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + t.setMonthNum(Constants.formatBigdecimal(t.getMonthNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + t.setYearNum(Constants.formatBigdecimal(t.getYearNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + } + t.setProvinceCode(model.getToProvinceCode()); + t.setProvinceName(model.getToProvinceName()); + result.add(t); } } } @@ -2504,6 +2565,12 @@ if(t.getTotalNum().compareTo(new BigDecimal(0)) !=0){ t.setUseRate(t.getCurrentNum().divide(t.getTotalNum(),4,BigDecimal.ROUND_HALF_UP)); } + if(Constants.UNIT_TYPE == 1) { + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + t.setCurrentNum(Constants.formatBigdecimal(t.getCurrentNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + t.setTotalNum(Constants.formatBigdecimal(t.getTotalNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP)); + + } result.getDetailList().add(t); result.setCurrentNum(result.getCurrentNum().add(t.getCurrentNum())); result.setTotalNum(result.getTotalNum().add(t.getTotalNum())); @@ -2562,6 +2629,11 @@ if(t.getTotalNum().compareTo(new BigDecimal(0)) !=0){ t.setUseRate(t.getCurrentNum().divide(t.getTotalNum(),4,BigDecimal.ROUND_HALF_UP)); } + if(Constants.UNIT_TYPE == 1){ + //澶勭悊鍗曚綅鎴愨�滅鈥濓紝涓�绠�=5涓囨敮 + t.setCurrentNum(Constants.formatBigdecimal(t.getCurrentNum()).divide(new BigDecimal(5),2,BigDecimal.ROUND_HALF_UP)); + t.setTotalNum(Constants.formatBigdecimal(t.getTotalNum()).divide(new BigDecimal(5),2,BigDecimal.ROUND_HALF_UP)); + } result.getDetailList().add(t); result.setCurrentNum(result.getCurrentNum().add(t.getCurrentNum())); result.setTotalNum(result.getTotalNum().add(t.getTotalNum())); -- Gitblit v1.9.3