From 34f587564c9a34515e7deda4dcd02eb748480e1f Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期一, 13 一月 2025 18:05:24 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java |  236 ++++++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 179 insertions(+), 57 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 a4a0975..d17348e 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;
@@ -490,7 +489,7 @@
         List<WaningEventDataListVO> list = new ArrayList<>();
         RuleEventSearchRequest request = new RuleEventSearchRequest();
         request.setPageNo(1);
-        request.setPageSize(10);
+        request.setPageSize(1000);
         request.setFiledOptions(new ArrayList<>());
         request.setSorts(new ArrayList<>());
         RuleEventFiledOptionsRequest file = new RuleEventFiledOptionsRequest();
@@ -500,7 +499,6 @@
         if(type == 1){
             file.setFieldValue("131588");//瀹夐槻鍛婅
         }else  if(type == 2){
-
             file.setFieldValue("131593");//浜哄憳鍛婅
         }
         request.getFiledOptions().add(file);
@@ -508,28 +506,36 @@
         sort.setSortField("happen_time");
         sort.setSortType("desc");
         request.getSorts().add(sort);
+        int total =0;
         BaseResponse<BaseListPageResponse< RuleEventSearchDataResponse>> result = HKService.ruleEventSearch(request);
         if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){
             List<RuleEventSearchDataResponse> rlist = result.getData().getList();
-            lastResult.setTotal(result.getData().getTotal());
             if(rlist!=null){
                 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){
+                    }
+                    total ++;
                     WaningEventDataListVO data = new WaningEventDataListVO();
+                    data.setCreateDate(DateUtil.getPlusTime(DateUtil.getISO8601DateByStr(r.getHappen_time())));
                     data.setAddr(r.getSrc_name());
                     data.setImg(r.getImage_url());
                     if(data.getImg()!=null){
                         data.setImg(data.getImg().replace(privateIp,publicIp));
                     }
                     data.setTitle(r.getEvent_type_name());
-                    data.setCreateDate(DateUtil.getPlusTime(DateUtil.getISO8601DateByStr(r.getHappen_time())));
 //                data.setContent(r.get);
                     list.add(data);
                 }
             }
 
         }
+        lastResult.setTotal(total);
         lastResult.setList(list);
         return lastResult;
     }
@@ -590,25 +596,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;
 
     }
@@ -1109,10 +1136,11 @@
                    //濡傛灉鏄湪绾挎垨鑰呬紤鐪狅紝鏌ヨ鍦ㄩ�旇繕鏄┖闂瞭y
                     codes.add(model.getPlateNum());
                     model.setJobStatus(Constants.ZERO);
-                }else
+                }else{
                     model.setJobStatus(Constants.TWO);
                     data.setOfflineNum(data.getOfflineNum()+1);
                 }
+            }
             if(codes.size()>0){
                 //鐘舵�� 0寰呯‘璁� 1寰呯鍒� 2绛夊緟鍙彿 3鍏ュ洯绛夊緟 4宸插彨鍙� 5浣滀笟涓� 6浣滀笟瀹屾垚 7杞Щ涓� 8寮傚父鎸傝捣 9宸叉巿鏉冪鍥� 10宸茬鍥� 11 宸茶繃鍙�  12鍙栨秷锛圵MS锛�
                 List<PlatformJob> busyNum = platformJobMapper.selectList(new QueryWrapper<PlatformJob>() .lambda()
@@ -1197,10 +1225,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;
 
     }
 
@@ -1270,7 +1298,13 @@
                             temperatureHumidityDataResponseList.stream().filter(i->i.getIndexCode().indexOf(code)>=Constants.ZERO).collect(Collectors.toList());
                     TemperatureHumidityDataVO temperatureHumidityDataVO = new TemperatureHumidityDataVO();
                     for (TemperatureHumidityDataResponse data:dateList) {
-                        if(data.getSensorType().equals("temp")){
+                        if(StringUtils.isNotBlank(data.getName())){
+                            Integer index = data.getName().indexOf("-");
+                            if(index>=0){
+                                data.setName(data.getName().substring(0,index));
+                            }
+                        }
+                        if(data.getSensorType().equals("currTemperature")){
                             temperatureHumidityDataVO.setTemperatureData(data);
                         }else{
                             temperatureHumidityDataVO.setHumidityData(data);
@@ -1375,14 +1409,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){
             // //璁$畻鐢ㄦ按鍚屾瘮鐜瘮
@@ -1589,27 +1628,50 @@
                 energyDataVOList.add(data);
             }
         }else{
+            String lastYear = null;
+            int lastMonths = 0,curMonths =0;
+            String curYear =DateUtil.getFomartDate(new Date(),"yyyy");
             for (int i = 0; i < 12; i++) {
                 Date tempDate = DateUtil.increaseMonth(lastMonth,i);
+                String tt =DateUtil.getFomartDate(tempDate,"yyyy");
+                if(!StringUtils.equals(curYear,tt)){
+                   lastYear = tt;
+                   lastMonths = i+1;//鍘诲勾鐨勬湀浠芥暟
+                }
                 EnergyDataVO data = new EnergyDataVO();
                 data.setTimeData(DateUtil.getFomartDate(tempDate,"YYYY-MM"));
 //                data.setTimeData(DateUtil.getFomartDate(tempDate,(i+1)+"鏈�"));
                 data.setEnergy(new BigDecimal(0));
                 energyDataVOList.add(data);
             }
-            //濡傛灉鏄敤鐢垫暟鎹�
+            curMonths = 12 - lastMonths;//浠婂勾鐨勬湀浠芥暟
             EnergyTrendRequest param = new EnergyTrendRequest();
-            param.setDate(DateUtil.getFomartDate(new Date(),"yyyy"));//骞翠唤
             param.setMeterType(1);
             param.setNodeType(2);
             param.setNodeId("root000000");
             param.setPeriodType("year");
+            if(lastYear!=null){
+                //濡傛灉鏄敤鐢垫暟鎹�
+                param.setDate(lastYear);//鏌ヨ鍘诲勾骞翠唤
+                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 < lastMonths; i++) { //0,11锛屽彇鍊�1-12
+                        if(response.getData().getYvalues().size()>0 &&response.getData().getYvalues().get(0).getValue().length>curMonths+i){
+                            //鍙栫浉搴旂殑鍙傛暟鍊�
+                            energyDataVOList.get(i).setEnergy(new BigDecimal(StringUtils.defaultString(response.getData().getYvalues().get(0).getValue()[curMonths+i],"0")));
+                        }
+                    }
+
+                }
+            }
+            //濡傛灉鏄敤鐢垫暟鎹�
+            param.setDate(curYear);//骞翠唤
             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 < 12; i++) {
-                    if(response.getData().getYvalues().size()>0 &&response.getData().getYvalues().get(0).getValue().length>i){
+                for (int i = lastMonths; i < 12; i++) { //12 鍙栧�� 0
+                    if(response.getData().getYvalues().size()>0 &&response.getData().getYvalues().get(0).getValue().length>i-lastMonths){
                         //鍙栫浉搴旂殑鍙傛暟鍊�
-                        energyDataVOList.get(i).setEnergy(new BigDecimal(StringUtils.defaultString(response.getData().getYvalues().get(0).getValue()[i],"0")));
+                        energyDataVOList.get(i).setEnergy(new BigDecimal(StringUtils.defaultString(response.getData().getYvalues().get(0).getValue()[i-lastMonths],"0")));
                     }
                 }
 
@@ -1782,11 +1844,13 @@
                     .select("( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+"  order by pl.CREATE_DATE desc  limit 1  ) as newStartDate")
                     //.select(" (  select sum(ifnull(pl.IO_QTY , 0 ))   from platform_wms_detail pl  where   pl.job_id = t.id and pl.isdeleted=0 )",PlatformJob::getWorkNum)
                     .select(" (  case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end )",PlatformJob::getWorkNum)
-                    .apply("to_days(t.create_date) = to_days(now())")
+//                    .apply("to_days(t.create_date) = to_days(now())")
                     .eq(Platform::getIsdeleted, Constants.ZERO)
                     .in(PlatformJob ::getStatus,new Integer[]{Constants.PlatformJobStatus.WORKING.getKey(),Constants.PlatformJobStatus.CALLED.getKey() })
 //                    .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
-                    .orderByDesc(PlatformJob::getStatus ));
+                    .orderByDesc(PlatformJob::getStatus )
+                    .orderByAsc(PlatformJob::getId )
+            );
             //鏈堝彴鐘舵�侊細0=浣滀笟涓紱1=绌洪棽涓紱2=浣滀笟瓒呮椂;3=鍙彿
             for(Platform model : platformList){
                 PlatformWorkDataVO platformDurationVO = new PlatformWorkDataVO();
@@ -2117,6 +2181,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()));
@@ -2148,8 +2217,8 @@
             for(TmsFactoryParam param : paramList){
                 if(StringUtils.isNotBlank(factoryCode)){
                     if(StringUtils.equals(param.getCode(),factoryCode)){
-                        data.setHoursAbility(data.getHoursAbility().add(Constants.formatBigdecimal(param.getParam3())));
-                        data.setMaxAbility(data.getMaxAbility().add(Constants.formatBigdecimal(param.getNum2())));
+                        data.setHoursAbility(Constants.formatBigdecimal(param.getParam3()));
+                        data.setMaxAbility(Constants.formatBigdecimal(param.getNum2()));
                         code = param.getCode();
                         break;
                     }
@@ -2175,7 +2244,6 @@
             }
         }*/
         initOutboundCapability(data,factoryCode);
-
         return  data;
 
     }
@@ -2236,7 +2304,6 @@
                 }
             }
             if(result.getCurrentDayAgoOrderList()!=null && result.getCurrentDayAgoOrderList().size()>0){
-
                 for(TmsOutboundCapabilityInfoResponse model :result.getCurrentDayAgoOrderList()){
                     /**
                      * out_date涓虹┖锛宻um(NC_TOTALITY)	鏄ㄥぉ鏈畬鎴愬嚭搴撹鍒掍换鍔�
@@ -2261,6 +2328,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) {
@@ -2281,7 +2357,10 @@
         TotalOutQtyNumVO  data = new TotalOutQtyNumVO();
         data.setCurrentInNum(new BigDecimal(0));
         data.setLastInNum(new BigDecimal(0));
+        data.setCurrentProvinceNum(new BigDecimal(0));
+        data.setCurrentOtherNum(new BigDecimal(0));
         data.setSameInNum(new BigDecimal(0));
+
         //---------鐪佸----------------
         data.setCurrentOutNum(new BigDecimal(0));
         data.setLastOutNum(new BigDecimal(0));
@@ -2321,6 +2400,8 @@
             List<TmsOutQtyAndVehicleQtyResponse> listSame=  tmsService.getOutQtyAndVehicleQty(param);//鍘诲勾鍚屾湡
             if(listSame!=null ){
                 for(TmsOutQtyAndVehicleQtyResponse model : listSame){
+                    model.setOutSideProvinceOutQty(Constants.formatBigdecimal(model.getOutSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getOutSideProvinceOutT01Qty())));//鐪佸绱
+                    model.setInSideProvinceOutQty(Constants.formatBigdecimal(model.getInSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getInSideProvinceOutT01Qty())));//鐪佸唴绱
                     data.setSameOutNum(data.getSameOutNum().add(Constants.formatBigdecimal(model.getOutSideProvinceOutQty())));
                     data.setSameInNum(data.getSameInNum().add(Constants.formatBigdecimal(model.getInSideProvinceOutQty())));
                 }
@@ -2331,9 +2412,13 @@
         List<TmsOutQtyAndVehicleQtyResponse> listCur =  tmsService.getOutQtyAndVehicleQty(param);//鏈懆鏈�
         if(listCur!=null ){
             for(TmsOutQtyAndVehicleQtyResponse model : listCur){
+                model.setOutSideProvinceOutQty(Constants.formatBigdecimal(model.getOutSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getOutSideProvinceOutT01Qty())));//鐪佸绱
+                model.setInSideProvinceOutQty(Constants.formatBigdecimal(model.getInSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getInSideProvinceOutT01Qty())));//鐪佸唴绱
                 data.setCurrentOutNum(data.getCurrentOutNum().add(Constants.formatBigdecimal(model.getOutSideProvinceOutQty())));
                 data.setCurrentInNum(data.getCurrentInNum().add(Constants.formatBigdecimal(model.getInSideProvinceOutQty())));
                 data.setTotalCarNum(data.getTotalCarNum()+Constants.formatIntegerNum(model.getVehicleQty()));//绱杞︽
+                data.setCurrentProvinceNum(data.getCurrentProvinceNum().add(model.getOutSideProvinceOutQty()).add(model.getInSideProvinceOutT01Qty()));//鐪佸唴鐪佸閿�鍞噺
+                data.setCurrentOtherNum(data.getCurrentOtherNum().add(model.getOutSideProvinceOutT03Qty()).add(model.getInSideProvinceOutT03Qty()));//鐪佸唴鐪佸鍏朵粬鍑哄簱閲�
             }
         }
         param.setDateEnd(DateUtil.getShortTime(lastEnd));
@@ -2341,6 +2426,8 @@
         List<TmsOutQtyAndVehicleQtyResponse> listLast =  tmsService.getOutQtyAndVehicleQty(param);//涓婂懆鏈�
         if(listCur!=null ){
             for(TmsOutQtyAndVehicleQtyResponse model : listLast){
+                model.setOutSideProvinceOutQty(Constants.formatBigdecimal(model.getOutSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getOutSideProvinceOutT01Qty())));//鐪佸绱
+                model.setInSideProvinceOutQty(Constants.formatBigdecimal(model.getInSideProvinceOutT03Qty()).add(Constants.formatBigdecimal(model.getInSideProvinceOutT01Qty())));//鐪佸唴绱
                 data.setLastOutNum(data.getLastOutNum().add(Constants.formatBigdecimal(model.getOutSideProvinceOutQty())));
                 data.setLastInNum(data.getLastInNum().add(Constants.formatBigdecimal(model.getInSideProvinceOutQty())));
             }
@@ -2348,6 +2435,18 @@
         if(type == 2){//鏈勾鐨�
             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.setCurrentOtherNum(Constants.formatBigdecimal(data.getCurrentOtherNum()).divide(new BigDecimal(5), 2, BigDecimal.ROUND_HALF_UP));
+            data.setCurrentProvinceNum(Constants.formatBigdecimal(data.getCurrentProvinceNum()).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;
     }
@@ -2366,14 +2465,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.getFromProvinceCode());
-                    tt.setProvinceName(model.getFromProvinceName());
-                    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);
                 }
             }
         }
@@ -2382,7 +2487,7 @@
 
     private WholeProvinceMapVO getFromProvinceResultList(TmsDistributionOfDeliveryLocResponse model, List<WholeProvinceMapVO> result) {
         for(WholeProvinceMapVO t : result){
-            if(StringUtils.equals(t.getProvinceCode(), model.getFromProvinceCode())){
+            if(StringUtils.equals(t.getProvinceCode(), model.getToProvinceCode())){
                 t.setMonthNum(Constants.formatBigdecimal(t.getMonthNum()).add(Constants.formatBigdecimal0Float(model.getMonthOutboundQuantity())));
                 t.setYearNum(Constants.formatBigdecimal(t.getYearNum()).add(Constants.formatBigdecimal0Float(model.getYearOutboundQuantity())));
                 return   t;
@@ -2482,6 +2587,7 @@
         WholeProvinceZXTVO result = new WholeProvinceZXTVO();
         result.setCurrentNum(new BigDecimal(0));
         result.setTotalNum(new BigDecimal(0));
+        result.setZtNum(new BigDecimal(0));
         result.setUseRate(new BigDecimal(0));
         result.setDetailList(new ArrayList<>());
         List<TmsFactoryParam> paramList =factoryList();
@@ -2491,41 +2597,52 @@
                 WholeProvinceZxtDetailVO t = new WholeProvinceZxtDetailVO();
                 t.setFactoryName(p.getName());
                 t.setCurrentNum(new BigDecimal(0));
+                t.setZaituNum(new BigDecimal(0));
                 t.setTotalNum(Constants.formatBigdecimal(p.getNum1()));//鎬诲簱瀛橀噺
                 getFromReportVehicleQtyList(p.getCode(),t,response);//澶勭悊鎻愭姤杩愬姏鍜屾�昏繍鍔涙暟鎹�
                 t.setUseRate(new BigDecimal(0));
-                if(t.getTotalNum().compareTo(new BigDecimal(0)) !=0){
-                    t.setUseRate(t.getCurrentNum().divide(t.getTotalNum(),4,BigDecimal.ROUND_HALF_UP));
+                if((t.getTotalNum().subtract(t.getZaituNum())).compareTo(new BigDecimal(0)) !=0){
+                    t.setUseRate(t.getCurrentNum().divide(t.getTotalNum().subtract(t.getZaituNum()),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()));
+                result.setZtNum(result.getZtNum().add(t.getZaituNum()));
             }
         }
-        if(result.getTotalNum().compareTo(new BigDecimal(0)) !=0){
-            result.setUseRate(result.getCurrentNum().divide(result.getTotalNum(),4,BigDecimal.ROUND_HALF_UP));
+        if((result.getTotalNum().subtract(result.getZtNum())).compareTo(new BigDecimal(0)) !=0){
+            result.setUseRate(result.getCurrentNum().divide(result.getTotalNum().subtract(result.getZtNum()),4,BigDecimal.ROUND_HALF_UP));
         }
         return result;
     }
     private void getFromReportVehicleQtyList(String code,WholeProvinceZxtDetailVO t, List<TmsTotalAndReportVehicleQtyResponse> responses) {
         BigDecimal current = new BigDecimal(0);
         BigDecimal total= new BigDecimal(0);
+        BigDecimal ztTotal= new BigDecimal(0);
         if(responses!=null && responses.size()>0){
             for(TmsTotalAndReportVehicleQtyResponse model: responses){
                 if(StringUtils.equals(model.getFactoryCode(),code)){
+                    ztTotal = ztTotal.add(Constants.formatBigdecimal(model.getInTransitQty()));
                     total = total.add(Constants.formatBigdecimal(model.getTotalQty()));
                     current = current.add(Constants.formatBigdecimal(model.getReportQty()));
                 }
             }
         }
         t.setCurrentNum(current);
+        t.setZaituNum(ztTotal);
         t.setTotalNum(total);
     }
     private BigDecimal getCurrentOutQryByList(List<TmsOutQtyAndVehicleQtyResponse> response) {
         BigDecimal r = new BigDecimal(0);
         if(response!=null && response.size()>0){
             for(TmsOutQtyAndVehicleQtyResponse model: response){
-                    r = r.add(Constants.formatBigdecimal(model.getTotalOutQty()));
+//                model.setTotalOutQty(Constants.formatBigdecimal(model.getTotalOutT03Qty()).add(Constants.formatBigdecimal(model.getTotalOutT01Qty())));
+                r = r.add(Constants.formatBigdecimal(model.getTotalOutQty()));
             }
         }
         return r ;
@@ -2555,6 +2672,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