From f6ba5de2578c58a738f35b29a708c523ccb518ba Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 05 十二月 2024 09:20:07 +0800
Subject: [PATCH] 最新版本541200007

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java | 1468 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 1,433 insertions(+), 35 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 b88eca5..2574a90 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,37 +1,44 @@
 package com.doumee.service.business.impl.thrid;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.core.constants.ResponseStatus;
 import com.doumee.core.exception.BusinessException;
 import com.doumee.core.haikang.model.HKConstants;
+import com.doumee.core.haikang.model.cars.response.CarsDeviceDetaisResponse;
+import com.doumee.core.haikang.model.param.BaseListPageRequest;
 import com.doumee.core.haikang.model.param.BaseListPageResponse;
 import com.doumee.core.haikang.model.param.BaseResponse;
-import com.doumee.core.haikang.model.param.BaseListPageRequest;
-import com.doumee.core.haikang.model.param.request.SensorStatusListRequest;
-import com.doumee.core.haikang.model.param.respose.PageCameraInfoResponse;
-import com.doumee.core.haikang.model.param.respose.PageFireChannelInfoResponse;
-import com.doumee.core.haikang.model.param.respose.PageRegionInfoResponse;
-import com.doumee.core.haikang.model.param.respose.PageSensorStatusResponse;
+import com.doumee.core.haikang.model.param.request.*;
+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.model.PageData;
+import com.doumee.core.model.PageWrap;
 import com.doumee.core.utils.Constants;
-import com.doumee.dao.business.PlatformJobMapper;
-import com.doumee.dao.business.PlatformLogMapper;
-import com.doumee.dao.business.PlatformMapper;
-import com.doumee.dao.business.model.Platform;
-import com.doumee.dao.business.model.PlatformJob;
-import com.doumee.dao.web.response.platformReport.CarmeraListVO;
-import com.doumee.dao.web.response.platformReport.OnSitDispatchBoardVO;
-import com.doumee.dao.web.response.platformReport.RegionTreeVO;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.core.utils.Utils;
+import com.doumee.core.wms.model.response.WmsBaseResponse;
+import com.doumee.core.wms.model.response.WmsInventoryDataResponse;
+import com.doumee.core.wms.model.response.WmsInventoryJsonResponse;
+import com.doumee.dao.business.*;
+import com.doumee.dao.business.join.VisitsJoinMapper;
+import com.doumee.dao.business.model.*;
+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.impl.VisitsServiceImpl;
 import com.doumee.service.business.third.BoardService;
+import com.doumee.service.business.third.WmsService;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.List;
+import java.math.BigDecimal;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -45,9 +52,67 @@
     @Autowired
     private PlatformLogMapper platformLogMapper;
     @Autowired
+    private WmsService wmsService;
+    @Autowired
+    private HiddenDangerMapper hiddenDangerMapper;
+    @Autowired
+    private PlatformWaterGasMapper platformWaterGasMapper;
+    @Autowired
+    private SystemDictDataBiz systemDictDataBiz;
+    @Autowired
+    private PlatformWarnEventMapper platformWarnEventMapper;
+    @Autowired
     private PlatformJobMapper platformJobMapper;
     @Autowired
+    private PlatformWmsDetailMapper platformWmsDetailMapper;
+    @Autowired
+    private PlatformWmsJobMapper platformWmsJobMapper;
+    @Autowired
     private PlatformMapper platformMapper;
+    @Autowired
+    private VisitsJoinMapper visitsJoinMapper;
+    @Autowired
+    private RetentionMapper retentionMapper;
+    @Autowired
+    private PlatformGroupMapper platformGroupMapper;
+    /**
+     * 鑾峰彇鍖哄煙鏍戝舰缁撴瀯鏁版嵁
+     * @return
+     */
+    @Override
+    public BoardStockListVO stockList( ){
+        BoardStockListVO data = new BoardStockListVO();
+        double toatalNum = 1d;
+        BigDecimal num = new BigDecimal(0);
+        List<GeneralVO> list = new ArrayList<>();
+        try {
+            toatalNum =Double.parseDouble(systemDictDataBiz.queryByCode(Constants.WMS_PARAM,Constants.WMS_TOTAL_STOCK_NUM).getCode()) ;
+        }catch (Exception e){
+
+        }
+        WmsBaseResponse<WmsInventoryDataResponse> response =  wmsService.getInventoryList();
+        if(response!=null && response.getData()!=null && response.getData().size()>=0){
+            List<WmsInventoryJsonResponse> t= response.getData().get(0).getJson();
+            if(t!=null &&t.size()>0){
+                for(WmsInventoryJsonResponse j :t){
+                    num = num.add (Constants.formatBigdecimal( j.getQty()));
+                    GeneralVO d = new GeneralVO();
+                    d.setNum(Constants.formatBigdecimal(j.getQty()));
+                    d.setName(j.getItem_name());
+                    list.add(d);
+                }
+            }
+        }
+        data.setStockList(list);
+        data.setNum(num);
+        if(toatalNum<=0){
+            toatalNum =1;
+        }
+        data.setTotalNum(new BigDecimal(toatalNum));
+        data.setUseRate(data.getTotalNum().divide(data.getNum(),2,BigDecimal.ROUND_UP));
+        return data;
+
+    }
     /**
      * 鑾峰彇鍖哄煙鏍戝舰缁撴瀯鏁版嵁
      * @return
@@ -87,11 +152,13 @@
         return  data;
     }
     private void initReginCameralList(List<PageRegionInfoResponse> allList,String name) {
-        List<CarmeraListVO> carmeraListVOList = cameraList(null);
+        CarmeraListVO re = new CarmeraListVO();
+        re.setName(name);
+        List<CarmeraListVO> carmeraListVOList = cameraList(re);
         if(carmeraListVOList!=null && carmeraListVOList.size()>0){
             for(PageRegionInfoResponse p : allList){
                 for(CarmeraListVO c : carmeraListVOList){
-                    if(StringUtils.equals(p.getRegionIndexCode(),c.getReginCode())
+                    if(StringUtils.equals(p.getIndexCode(),c.getReginCode())
                             && (StringUtils.contains(c.getName(),name) ||StringUtils.isBlank(name))){
                         if(p.getCarmeraList()==null){
                             p.setCarmeraList(new ArrayList<>());
@@ -170,13 +237,15 @@
 
         List<CarmeraListVO> data = new ArrayList<>();
         for(PageCameraInfoResponse p : allList){
-            CarmeraListVO t = new CarmeraListVO();
-            t.setIndexCode(p.getCameraIndexCode());
-            t.setReginCode(p.getRegionIndexCode());
-            t.setName(p.getCameraName());
-            t.setStatus(p.getStatus());
-            t.setStatusName(p.getStatusName());
-            data.add(t);
+            if(StringUtils.isBlank(req.getName()) ||StringUtils.contains(p.getCameraName(),req.getName())){
+                CarmeraListVO t = new CarmeraListVO();
+                t.setIndexCode(p.getCameraIndexCode());
+                t.setReginCode(p.getRegionIndexCode());
+                t.setName(p.getCameraName());
+                t.setStatus(p.getStatus());
+                t.setStatusName(p.getStatusName());
+                data.add(t);
+            }
         }
         return  data;
     }
@@ -242,6 +311,1280 @@
         return  allList;
     }
     @Override
+    public  List<PlatformGroupFinishVO> platformGroupFinish(){
+        List<PlatformGroupFinishVO> data = new ArrayList<>();
+        List<PlatformGroup> groups = platformGroupMapper.selectJoinList(PlatformGroup.class, new MPJLambdaWrapper<PlatformGroup>()
+                .select("(select sum(a.TOTAL_NUM) from platform_job a where a.PLATFORM_GROUP_ID=t.id and a.isdeleted=0   and a.status in(6,9,10) and to_days(a.done_date) = to_days(now()))",PlatformGroup::getOrtherTotalNum)
+                .selectAll(PlatformGroup.class)
+                .eq(PlatformGroup::getIsdeleted,Constants.ZERO)
+        );
+        if(groups!=null && groups.size()>0){
+            List<PlatformWmsDetail> jobList = platformWmsDetailMapper.selectJoinList(PlatformWmsDetail.class, new MPJLambdaWrapper<PlatformWmsDetail>()
+                    .selectSum( PlatformWmsDetail::getIoQty)
+                    .selectAs(PlatformGroup::getId, PlatformWmsDetail::getGroupId)
+                    .leftJoin(PlatformJob.class,PlatformJob::getId,PlatformWmsDetail::getJobId)
+                    .eq(PlatformWmsDetail::getIsdeleted, Constants.ZERO)
+                    .eq(PlatformJob::getIsdeleted, Constants.ZERO)
+                    .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey()
+                            , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
+                            , Constants.PlatformJobStatus.LEAVED.getKey())
+                    .apply("to_days(t1.create_date) = to_days(now())")
+                    .groupBy(PlatformJob::getPlatformGroupId)
+            );
+            for(PlatformGroup d : groups){
+                PlatformGroupFinishVO t = new PlatformGroupFinishVO();
+                if(jobList!=null){
+                    for(PlatformWmsDetail dd : jobList){
+                      if(Constants.equalsInteger(dd.getGroupId(),d.getId())){
+                          d.setTotalNum(dd.getIoQty());
+                      }
+                    }
+                }
+                t.setFinishData(Constants.formatBigdecimal(d.getTotalNum()).intValue()+Constants.formatBigdecimal(d.getOrtherTotalNum()).intValue());
+                t.setPlatformGroupName(d.getName());
+                data.add(t);
+            }
+        }
+
+        return data;
+    }
+
+    @Override
+    public  CarWorkSituationVO carWorkSituation(int limit){
+        CarWorkSituationVO carWorkSituationVO = new CarWorkSituationVO();
+        List<PlatformLog> platformLogList = platformLogMapper.selectList(new QueryWrapper<PlatformLog>().lambda()
+                .orderByDesc(PlatformLog::getCreateDate)
+                .last(" limit "+limit)
+        );
+        carWorkSituationVO.setPlatformLogList(platformLogList);
+        return carWorkSituationVO;
+    }
+    @Override
+    public  List<SecurityDeviceDataVO> securityDeviceData(){
+        List<SecurityDeviceDataVO> list = new ArrayList<>();
+        SecureDevStatusTotalRequest request =new SecureDevStatusTotalRequest();
+        request.setIncludeBool("");
+        request.setRegionIds(new String[]{});
+        BaseResponse<List<SecureDevStatusListResponse>> result = HKService.getSecureDevStatusList(request) ;
+        if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){
+            List<SecureDevStatusListResponse> rlist = result.getData();
+            for(SecureDevStatusListResponse r :rlist){
+                SecurityDeviceDataVO data = new SecurityDeviceDataVO();
+                data.setDeviceType(r.getDevTypeName());
+                data.setOnlineNum(r.getOnlineCount());
+                data.setOfflineDeviceNum(r.getOfflineCount());
+                data.setTotalNum(data.getOnlineNum() + data.getOfflineDeviceNum() );
+                list.add(data);
+            }
+        }
+        /*
+        Random random = new Random();
+        for (int i = 1; i <= 3; i++) {
+            SecurityDeviceDataVO data = new SecurityDeviceDataVO();
+            data.setDeviceType("璁惧绫诲瀷_"+i);
+            data.setOnlineNum(random.nextInt(10));
+            data.setOfflineDeviceNum(random.nextInt(10));
+            data.setTotalNum(data.getOnlineNum() + data.getOfflineDeviceNum() );
+            list.add(data);
+        }*/
+        return list;
+    }
+    @Override
+    public  WaningEventDataVO warningEventData(Integer type){
+        WaningEventDataVO lastResult = new WaningEventDataVO();
+        List<WaningEventDataListVO> list = new ArrayList<>();
+        RuleEventSearchRequest request = new RuleEventSearchRequest();
+        request.setPageNo(1);
+        request.setPageSize(10);
+        request.setFiledOptions(new ArrayList<>());
+        request.setSorts(new ArrayList<>());
+        RuleEventFiledOptionsRequest file = new RuleEventFiledOptionsRequest();
+        file.setFieldName("event_type");
+        file.setFieldValue("131588");//瀹夐槻鍛婅
+        file.setType("in");
+        request.getFiledOptions().add(file);
+        SortRequest sort = new SortRequest();
+        sort.setSortField("happen_time");
+        sort.setSortType("desc");
+        request.getSorts().add(sort);
+        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){
+                    WaningEventDataListVO data = new WaningEventDataListVO();
+                    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.setList(list);
+        return lastResult;
+    }
+    @Override
+    public  String getCarmeraPreviemUrl(CarmeraListVO param){
+        CameraPreviewURLsRequest request = new CameraPreviewURLsRequest();
+        request.setCameraIndexCode(param.getIndexCode());
+        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;
+    }
+    @Override
+    public   List<EnergyDataVO>  loadEnergyCurve(){
+        List<EnergyDataVO> loadCurveList = new ArrayList<>();
+        try {
+            BaseResponse<List<EnergyTodayLoadDataResponse>>  response = HKService.energyTodayLoadData();
+            if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){
+                for (EnergyTodayLoadDataResponse model :response.getData()) {
+                    EnergyDataVO data = new EnergyDataVO();
+                    data.setTimeData(model.getName());
+                    data.setEnergy(new BigDecimal(StringUtils.defaultString(model.getValue(),"0")));
+                    loadCurveList.add(data);
+                }
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+        return loadCurveList;
+    }
+    @Override
+    public     List<OilDataVO> energyLastMonthOilSort(){
+        List<OilDataVO> oilDataVOList = new ArrayList<>();
+        //涓婃湀娌硅��
+       List<PlatformWaterGas> list =  platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda()
+                .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO)
+                .eq(PlatformWaterGas::getType,Constants.TWO)
+                .apply("DATE_FORMAT(time_info, '%Y-%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH), '%Y-%m')")
+                .orderByDesc(PlatformWaterGas::getNum)
+                .last("limit 30" )
+        );
+        for (PlatformWaterGas model :list) {
+            OilDataVO oilDataVO = new OilDataVO();
+            oilDataVO.setCarNo(model.getCarCode());
+            oilDataVO.setQuantity(model.getNum());
+            oilDataVOList.add(oilDataVO);
+        }
+        return oilDataVOList;
+    }
+
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-鏈勾鍜屾湰鏈堟柊澧炴秷闃茶澶�/璁炬柦缁存姢鎯呭喌
+     * @return
+     *
+     */
+    @Override
+    public    List<AlarmEventDataVO> fightingAdminAlertList(){
+        List<AlarmEventDataVO> data = new ArrayList<>();
+
+        //鏌ヨ24灏忔椂鍐呯殑
+        FindHomeAlarmInfoPageRequest param = new FindHomeAlarmInfoPageRequest();
+        param.setHour(24);
+        param.setPage(1);
+        param.setUserId("admin");
+//        param.setRegionIndexCodes("root000000");
+        param.setAlarmStartTime(DateUtil.getPlusTime2(DateUtil.addDaysToDate(new Date(),-1)));
+        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) {
+            for(FindHomeAlarmInfoPageResponse r : response.getData().getList()){
+                AlarmEventDataVO t = new AlarmEventDataVO();
+                BeanUtils.copyProperties(r,t);
+                data.add(t);
+            }
+        }
+        return data;
+
+    }
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-瀹炴椂鐩戞祴鏁版嵁
+     * @return
+     *
+     */
+    @Override
+    public  List<MonitorDataVO> monitorDataList(){
+        List<MonitorDataVO> list = new ArrayList<>();
+        MinitorDataSearchRequest param = new MinitorDataSearchRequest();
+        param.setResourceTypeCodes(new String[]{});
+        param.setRegionIndexCode("root000000");
+        param.setIncludeDown("1");
+        param.setUserId("admin");
+        BaseResponse<BaseListPageResponse<MonitorDataSearchResponse>> response = HKService.minitorDataSearch(param);
+        if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)
+                && response.getData()!=null ) {
+            List<MonitorDataSearchResponse> r = response.getData().getList();
+            if(r!= null){
+                for(MonitorDataSearchResponse model : r){
+                    MonitorDataVO m = new MonitorDataVO();
+                    m.setName(model.getName());
+                    m.setDataList(new ArrayList<>());
+                    if(model.getValues()!=null){
+                        for(MonitorDataValResponse v : model.getValues()){
+                            MonitorDataInfoVO vm = new MonitorDataInfoVO();
+                            vm.setValue(v.getMonitorValue());
+                            vm.setCateName(v.getMonitorSpecificName());
+                            vm.setCateCode(v.getMonitorTypeKey());
+                            vm.setTypeCode(v.getMonitorTypeCode());
+                            vm.setTypeName(v.getMonitorTypeName());
+                        }
+                    }
+                }
+            }
+        }
+        return  list;
+    }
+
+
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-鍛婅澶勭悊鍒嗘瀽闆嗗悎
+     * @return
+     *
+     */
+    @Override
+    public   List<AlarmDataVO> fightingAlarmHandleData(){
+        List<AlarmDataVO> alarmHandleDataVOList = new ArrayList<>();
+        Date now =DateUtil.StringToDate(DateUtil.getFirstDayCurrentMonth(),"yyyy-MM") ;
+        for (int i = 1; i <= 12; i++) {
+            Date start  =  DateUtil.addMonthToDate(now,-12+i);
+            Date end  =  DateUtil.addMonthToDate(now,-11+i);
+            AlarmDataVO t = getAlertDataByStartEndTime(DateUtil.getPlusTime2(start),DateUtil.getPlusTime2(end));
+            alarmHandleDataVOList.add(t);
+        }
+        return alarmHandleDataVOList;
+    }
+    /**
+     * 銆愬洯鍖虹墿鏂欎腑蹇冭皟搴︺�戠湅鏉�-杩愯緭浠诲姟鍒嗘瀽
+     *
+     * @return
+     *
+     */
+    @Override
+    public  List<TransportMeasureVO> transportMeasure(Integer queryType){
+        List<TransportMeasureVO> list = new ArrayList<>();
+        Random random = new Random();
+        List<Date> dayList = DateUtil.getDateListBeforDays(new Date(),7);//杩�7澶�
+        if(Constants.equalsInteger(queryType,Constants.ONE)){
+            dayList = DateUtil.getThisMonthDateList();//鏈湀澶╂暟
+        }else if(Constants.equalsInteger(queryType,Constants.TWO)){
+            dayList = DateUtil.getThisYearMonthList();//鏈勾鏈堜唤
+        }
+        List<PlatformJob>  dataList = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+                        .selectAs(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+//                        .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")
+                        .apply(queryType==1,"year(create_date) = year(now()) and month(create_date) = month(now())")
+                        .apply(queryType==2,"year(create_date) = year(now())"));
+        for (Date date : dayList) {
+            TransportMeasureVO data = new TransportMeasureVO();
+            data.setPlanDate(date);
+            data.setPlanTimes(0);
+            data.setPlanTaskNum(new BigDecimal(random.nextInt(0)));
+            data.setFinishTaskNum(new BigDecimal(0));
+            for(PlatformJob job :dataList){
+                if(queryType == 2){
+                    if(DateUtil.formatDate(date,"yyyy-MM").equals(DateUtil.formatDate(job.getCreateDate(),"yyyy-MM"))){
+                        data.setPlanTimes( data.getPlanTimes() +1);
+                        data.setPlanTaskNum( data.getPlanTaskNum().add(Constants.formatBigdecimal(job.getTotalNum())));
+                        if(Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.DONE.getKey())
+                                ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())
+                                ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())){
+                            //瀹屾垚鏁�
+                            data.setFinishTaskNum( data.getFinishTaskNum().add(Constants.formatBigdecimal(job.getTotalNum())));
+                        }
+                    }
+                }else{
+                    if(DateUtil.formatDate(date,"yyyy-MM-dd").equals(DateUtil.formatDate(job.getCreateDate(),"yyyy-MM-dd"))){
+                        data.setPlanTimes( data.getPlanTimes() +1);
+                        data.setPlanTaskNum( data.getPlanTaskNum().add(Constants.formatBigdecimal(job.getTotalNum())));
+                        if(Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.DONE.getKey())
+                                ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())
+                                ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())){
+                            //瀹屾垚鏁�
+                            data.setFinishTaskNum( data.getFinishTaskNum().add(Constants.formatBigdecimal(job.getTotalNum())));
+                        }
+                    }
+                }
+            }
+
+            list.add(data);
+        }
+        return list;
+    }
+    /**
+     * 銆愬洯鍖虹墿鏂欎腑蹇冭皟搴︺�戠湅鏉�-鏍规嵁杞︾墝鍙锋煡璇綔涓氫俊鎭拰鍚堝悓淇℃伅闆嗗悎
+     *
+     * @return
+     *
+     */
+    @Override
+    public    CarsJobAndContractVO getCarsJobDetails(CarsJobAndContractDTO param){
+        CarsJobAndContractVO data = new CarsJobAndContractVO();
+        if(StringUtils.isBlank(param.getCarCode())){
+            return  data;
+        }
+        PlatformJob job = platformJobMapper.selectJoinOne(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAll(PlatformJob.class)
+                        .eq(PlatformJob::getIsdeleted,Constants.ZERO)
+                        .eq(PlatformJob::getCarCodeFront,param.getCarCode())
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey(),Constants.PlatformJobStatus.CALLED.getKey())
+                        .last("limit 1"));
+        if(job!=null){
+            List<PlatformLog>  logList = platformLogMapper.selectJoinList(PlatformLog.class,
+                    new MPJLambdaWrapper<PlatformLog>()
+                            .selectAll(PlatformLog.class)
+                            .eq(PlatformLog::getIsdeleted,Constants.ZERO)
+                            .eq(PlatformLog::getJobId,job.getId())
+                            .orderByDesc(PlatformLog::getCreateDate));
+            data.setLogList(logList);
+            data.setName(job.getDriverName());
+            data.setPhone(job.getDrivierPhone());
+            data.setBillCode(job.getBillCode());
+            data.setTotalNum(Constants.formatBigdecimal(job.getTotalNum()));
+            data.setContractList(new ArrayList<>());
+            CarsContractVO tt = new CarsContractVO();
+            tt.setIoCode(job.getContractNum());
+            tt.setDetailList(new ArrayList<>());
+            data.getContractList().add(tt);
+
+            PlatformWmsJob wmsJob = platformWmsJobMapper.selectJoinOne(PlatformWmsJob.class,
+                    new MPJLambdaWrapper<PlatformWmsJob>()
+                            .selectAll(PlatformWmsJob.class)
+                            .eq(PlatformWmsJob::getIsdeleted,Constants.ZERO)
+                            .eq(PlatformWmsJob::getJobId,job.getId())
+                            .last("limit 1"));
+            if(wmsJob!=null){
+                data.setName(wmsJob.getDriverName());
+                data.setPhone(wmsJob.getDriverPhone());
+                data.setBillCode(wmsJob.getCarryBillCode());
+                data.setContractList(new ArrayList<>());
+
+                List<PlatformWmsDetail>  detailList = platformWmsDetailMapper.selectJoinList(PlatformWmsDetail.class,
+                        new MPJLambdaWrapper<PlatformWmsDetail>()
+                                .selectAll(PlatformWmsDetail.class)
+                                .eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO)
+                                .eq(PlatformWmsDetail::getWmsJobId,wmsJob.getId())
+                                .orderByDesc(PlatformLog::getCreateDate));
+                if(detailList!=null){
+                    for(PlatformWmsDetail d : detailList){
+                        if(!isNotExistIocode(d.getIocode(),data.getContractList())){
+                                continue;
+                        }
+                        tt = new CarsContractVO();
+                        tt.setIoCode(d.getIocode());
+                        tt.setAddress(d.getRepertotyAddress());
+                        tt.setDetailList(getDetailListByCode(d.getIocode(),detailList,tt));
+                        data.getContractList().add(tt);
+                        data.getTotalNum().add(Constants.formatBigdecimal(tt.getTotalNum()));//鎬昏繍杈撻噺
+                    }
+                }
+            }
+
+        }
+
+
+        return data;
+
+    }
+
+    private List<PlatformWmsDetail> getDetailListByCode(String iocode, List<PlatformWmsDetail> detailList,CarsContractVO tt) {
+        List<PlatformWmsDetail> list = new ArrayList<>();
+        BigDecimal total = new BigDecimal(0);
+        if(detailList!=null){
+            for(PlatformWmsDetail d :detailList){
+                if(StringUtils.equals(d.getIocode(),iocode)){
+                    list.add(d);
+                    total.add(Constants.formatBigdecimal(d.getIoQty()));
+                }
+            }
+        }
+        tt.setTotalNum(total);
+        return list;
+    }
+
+    private boolean isNotExistIocode(String iocode, List<CarsContractVO> detailList) {
+        if(detailList!=null){
+            for(CarsContractVO d :detailList){
+                if(StringUtils.equals(d.getIoCode(),iocode)){
+                    return true;
+                }
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-鍛婅淇℃伅闆嗗悎
+     *
+     * @return
+     *
+     */
+    @Override
+    public   AlarmDataVO alarmDataSumByCate(){
+        AlarmDataVO alarmDataVO = getAlertDataByStartEndTime(DateUtil.getPlusTime2(DateUtil.addDaysToDate(new Date(),-1))
+                ,(DateUtil.getPlusTime2(new Date())));
+        return  alarmDataVO;
+    }
+
+    /**
+     * 鏌ヨ鏈湀 鏈勾鐨勭疮璁″嚭搴撻噺缁熻鏁版嵁,鍑哄簱浠诲姟銆佸叆搴撲换鍔￠噺
+     * @return
+     */
+    @Override
+    public  PlatformJobRunBoardNewVO platformJobCenterData(){
+        PlatformJobRunBoardNewVO data = new PlatformJobRunBoardNewVO();
+        Random random = new Random();
+
+        data.setMonthOutTimes(random.nextInt(1000));
+        data.setYearOutTimes(random.nextInt(1000) * 11);
+
+        Date month  = Utils.Date.getStart(new Date());//鏈湀
+        Date lastMonth =  DateUtil.addMonthToDate(month,-1);//涓婃湀
+        Date year = Utils.Date.getStart(new Date());//浠婂勾
+        Date lastYear = DateUtil.addYearToDate(year,-1);//鍘诲勾
+
+        List<PlatformJob>  monthNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                .selectAs(PlatformJob::getId,PlatformJob::getId)
+                .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+//                .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)
+//                        .in(PlatformJob::getType,Constants.ONE,Constants.THREE)
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
+                        .apply("year(create_date) = year("+DateUtil.getPlusTime2(month)+") and month(create_date) = month("+DateUtil.getPlusTime2(month)+") and to_days(create_date)<= "+DateUtil.getPlusTime2(month)));
+        List<PlatformJob>  monthLastNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+//                        .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)
+                        .in(PlatformJob::getType,Constants.ONE,Constants.THREE)
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
+                        .apply("year(create_date) = year("+DateUtil.getPlusTime2(lastMonth)+") and month(create_date) = month("+DateUtil.getPlusTime2(lastMonth)+") and to_days(create_date)<= "+DateUtil.getPlusTime2(lastMonth)));
+        List<PlatformJob>  yearNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+                        .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+                        .selectCount(PlatformJob::getPlatformId,PlatformJob::getCountum)
+//                        .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)
+                        .in(PlatformJob::getType,Constants.ONE,Constants.THREE)
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
+                        .apply("year(create_date) = year("+DateUtil.getPlusTime2(year)+")   and to_days(create_date)<= "+DateUtil.getPlusTime2(year)));
+        List<PlatformJob> yearLastNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+                        .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+//                        .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)
+                        .in(PlatformJob::getType,Constants.ONE,Constants.THREE)
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
+                        .apply("year(create_date) = year("+DateUtil.getPlusTime2(lastYear)+")  and to_days(create_date)<= "+DateUtil.getPlusTime2(lastYear)));
+
+        data.setMonthOutTotal(getSumTotalByList(monthNum,0,null));//鏈湀鍑哄簱閲�
+        data.setMonthLastOutTotal(getSumTotalByList(monthLastNum,null,null) );//涓婃湁鍑哄簱閲�
+        data.setYearOutTotal(getSumTotalByList(yearNum,null,null)  );//鏈勾鍑哄簱閲�
+        data.setYearLastOutTotal(getSumTotalByList(yearLastNum,null,null) );//鍘诲勾鍑哄簱閲�
+        data.setMonthOutTimes(monthNum!=null?monthNum.size():0);
+        data.setYearOutTimes(yearNum!=null?yearNum.size():0);
+
+        //==========浠婂ぉ涔嬪墠鏈畬鎴愬嚭鍏ュ簱浠诲姟
+        List<PlatformJob> beforeJobNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+                        .selectAs(PlatformJob::getStatus,PlatformJob::getStatus)
+                        .selectAs(PlatformJob::getType,PlatformJob::getType)
+                        .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+//                        .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)
+                        .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey(),Constants.PlatformJobStatus.CALLED.getKey())
+                        .apply(" and to_days(create_date) <to_days(now())"));
+
+        //==========浠婂ぉ鍑哄叆搴撲换鍔�
+        List<PlatformJob> currentNum = platformJobMapper.selectJoinList(PlatformJob.class,
+                new MPJLambdaWrapper<PlatformJob>()
+                        .selectAs(PlatformJob::getId,PlatformJob::getId)
+                        .selectAs(PlatformJob::getStatus,PlatformJob::getStatus)
+                        .selectAs(PlatformJob::getType,PlatformJob::getType)
+                        .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum)
+//                        .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)
+                        .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey())
+                        .apply("year(create_date) = year("+DateUtil.getPlusTime2(lastYear)+")  and to_days(create_date)<= "+DateUtil.getPlusTime2(lastYear)));
+
+        BigDecimal beforeOutNum = (getSumTotalByList(beforeJobNum,0,null));//浠婂ぉ涔嬪墠鏈畬鎴愬嚭搴撲换鍔�
+        BigDecimal currentOutNum = (getSumTotalByList(currentNum,0,null));//浠婂ぉ涓嬪彂鍑哄簱浠诲姟
+        BigDecimal beforeInNum = (getSumTotalByList(beforeJobNum,1,null));//浠婂ぉ涔嬪墠鏈畬鎴愬叆搴撲换鍔�
+        BigDecimal currentInNum = (getSumTotalByList(currentNum,1,null));//浠婂ぉ涓嬪彂鍏ュ簱浠诲姟
+        data.setCurrentInNum(beforeInNum.add(currentInNum));//褰撳墠鍏ュ簱鎬讳换鍔℃垚閲�
+        data.setCurrentOutNum(beforeOutNum.add(currentOutNum));//褰撳墠鍑哄簱鎬讳换鍔℃垚閲�
+        data.setCurrentInDoneNum(getSumTotalByList(currentNum,0,1));//浠婃棩瀹屾垚閲�
+        data.setCurrentOutDoneNum(getSumTotalByList(currentNum,1,1));//浠婃棩瀹屾垚閲�
+
+        //------------浠婃棩鍑哄叆搴撴晥鐜�----------------
+        BigDecimal outHours = getTotalDoneTimes(currentNum,0);//
+        BigDecimal inHours = getTotalDoneTimes(currentNum,1);//
+        if(outHours.compareTo(new BigDecimal(0))>0){
+            data.setTodayOutRate(data.getCurrentOutDoneNum().divide(outHours,2));//褰撳墠鍏ュ簱鎬讳换鍔℃垚閲�
+        }
+        if(inHours.compareTo(new BigDecimal(0))>0){
+            data.setTodayInRate(data.getCurrentInDoneNum().divide(inHours,2));//褰撳墠鍏ュ簱鎬讳换鍔℃垚閲�
+        }
+        //------------鏈湀鍑哄叆搴撴晥鐜�----------------
+        BigDecimal outMonthNum = getSumTotalByList(monthNum,0,null).add(data.getCurrentOutDoneNum());
+        BigDecimal inMonthNum = getSumTotalByList(monthNum,1,null).add(data.getCurrentInDoneNum());
+        BigDecimal outYearHours = getTotalDoneTimes(yearNum,0).add(outHours);//
+        BigDecimal inYearHours = getTotalDoneTimes(yearNum,1).add(inHours);//
+        if(outYearHours.compareTo(new BigDecimal(0))>0){
+            data.setMonthOutRate(outMonthNum.divide(outYearHours,2));//鏈湀鍏ュ簱鏁堢巼
+        }
+        if(inYearHours.compareTo(new BigDecimal(0))>0){
+            data.setMonthInRate(inMonthNum.divide(inYearHours,2));//鏈湀鍏ュ簱鏁堢巼
+        }
+        return data;
+    }
+
+
+    private BigDecimal getDoneHoursByData(String start ,String end) {
+        List<PlatformLog> platformLogList = platformLogMapper.selectList(new QueryWrapper<PlatformLog>().lambda()
+                .apply("create_date >= '"+start+"' and create_date <= '"+end+"'")
+                .isNotNull(PlatformLog::getParam3)
+                .ne(PlatformLog::getParam3,Constants.ZERO+""));
+        if(platformLogList!=null && platformLogList.size()>0){
+            return new BigDecimal((double)(platformLogList.stream().map(m->Long.valueOf(m.getParam3())).reduce(Long.valueOf(0),Long::sum))/(double)60);
+        }
+
+        return new BigDecimal(0);
+
+    }
+    private BigDecimal getTotalDoneTimes(List<PlatformJob> list, Integer type) {
+        BigDecimal r = new BigDecimal(0);
+        if(list==null || list.size() == 0){
+            return r;
+        }
+        List<Integer> jobIds= new ArrayList<>();
+        for(PlatformJob job : list){
+            if( !(Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.DONE.getKey())
+                    ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())
+                    ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()))){
+                //鍙煡璇㈠畬鎴愭暟鎹�
+                continue;
+            }
+            if(type !=null &&type ==0 &&  (Constants.equalsInteger(job.getType(),Constants.ONE) ||Constants.equalsInteger(job.getType(),Constants.THREE))){
+               //鍑哄簱
+               jobIds.add(job.getId());
+            }
+            if(type !=null &&type ==1 &&  (Constants.equalsInteger(job.getType(),Constants.ZERO) ||Constants.equalsInteger(job.getType(),Constants.TWO)||Constants.equalsInteger(job.getType(),Constants.FOUR))){
+                //鍏ュ簱
+                jobIds.add(job.getId());
+            }
+        }
+        if(jobIds.size()>0){
+            //澶勭悊浣滀笟鏃堕暱
+            List<PlatformLog> platformLogList = platformLogMapper.selectList(new QueryWrapper<PlatformLog>().lambda()
+                    .in(PlatformLog::getJobId,jobIds)
+                    .isNotNull(PlatformLog::getParam3)
+                    .ne(PlatformLog::getParam3,Constants.ZERO+""));
+            if(platformLogList!=null && platformLogList.size()>0){
+                return new BigDecimal((double)(platformLogList.stream().map(m->Long.valueOf(m.getParam3())).reduce(Long.valueOf(0),Long::sum))/(double)60);
+            }
+        }
+        return r;
+    }
+
+    private BigDecimal getSumTotalByList(List<PlatformJob> list,Integer type,Integer status) {
+        BigDecimal r = new BigDecimal(0);
+        if(list==null || list.size() == 0){
+            return r;
+        }
+        for(PlatformJob job : list){
+
+            if(type !=null &&type ==0 && !(Constants.equalsInteger(job.getType(),Constants.ONE) ||Constants.equalsInteger(job.getType(),Constants.THREE))){
+                continue;
+            }
+            if(type !=null &&type ==1 && !(Constants.equalsInteger(job.getType(),Constants.ZERO) ||Constants.equalsInteger(job.getType(),Constants.TWO)||Constants.equalsInteger(job.getType(),Constants.FOUR))){
+                continue;
+            }
+            if(status !=null &&status ==1 && !(Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.DONE.getKey())
+                    ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())
+                    ||Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()))){
+                continue;
+            }
+//            if(Constants.formatBigdecimal(job.getIoQty()).compareTo(new BigDecimal(0)) >0){
+//                r.add( job.getIoQty());
+//            }else{
+                r.add(Constants.formatBigdecimal(job.getTotalNum()));
+//            }
+        }
+        return Constants.formatBigdecimal0Float(r);
+    }
+
+    @Override
+    public     BoardCarsListVO platformJobCarsList(){
+        BoardCarsListVO data = new BoardCarsListVO();
+        List<CarsDeviceDetaisResponse> detaisResponses = HKCarOpenService.getAllCarsDetais();
+        data.setCarsList(detaisResponses);
+        if(data.getCarsList()!=null && data.getCarsList().size()>0){
+            List<String> codes = new ArrayList<>();
+            //璁惧鐘舵�� 0锛氱绾匡紱1锛氬湪绾匡紱2锛氫紤鐪�
+            int online = 0;
+            for(CarsDeviceDetaisResponse model:detaisResponses){
+                if(Constants.equalsInteger(model.getStatus(),Constants.ONE) ||Constants.equalsInteger(model.getStatus(),Constants.TWO)){
+                   //濡傛灉鏄湪绾挎垨鑰呬紤鐪狅紝鏌ヨ鍦ㄩ�旇繕鏄┖闂�
+                    codes.add(model.getPlateNum());
+                }else
+                    data.setOfflineNum(data.getOfflineNum()+1);
+                }
+            if(codes.size()>0){
+                //鐘舵�� 0寰呯‘璁� 1寰呯鍒� 2绛夊緟鍙彿 3鍏ュ洯绛夊緟 4宸插彨鍙� 5浣滀笟涓� 6浣滀笟瀹屾垚 7杞Щ涓� 8寮傚父鎸傝捣 9宸叉巿鏉冪鍥� 10宸茬鍥� 11 宸茶繃鍙�  12鍙栨秷锛圵MS锛�
+                long busyNum = platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda()
+                        .eq(PlatformJob::getIsdeleted,Constants.ZERO)
+                        .in(PlatformJob::getCarCodeFront,codes)
+                        .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey()
+                                ,Constants.PlatformJobStatus.WAIT_CALL.getKey()
+                                ,Constants.PlatformJobStatus.CALLED.getKey()
+                                ,Constants.PlatformJobStatus.IN_WAIT.getKey()
+                                ,Constants.PlatformJobStatus.TRANSFERING.getKey()
+                                ,Constants.PlatformJobStatus.WART_SIGN_IN.getKey()
+                                ,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey()
+                                ,Constants.PlatformJobStatus.EXCEPTION.getKey())
+                        .groupBy(PlatformJob::getCarCodeFront));
+                data.setBusyNum((int)busyNum);//鍦ㄩ�旀湁浠诲姟鏁伴噺
+                data.setIdleNum(codes.size() -data.getBusyNum());//鏃犱换鍔＄┖闂叉暟閲�
+            }
+        }
+
+        return  data;
+    }
+
+    public static AlarmDataVO getAlertDataByStartEndTime(String start,String end){
+        AlarmDataVO alarmDataVO = new AlarmDataVO();
+        FindAlarmBaseDataStatisticRequest param = new FindAlarmBaseDataStatisticRequest();
+        param.setAlarmStartTime(start);
+        param.setAlarmEndTime(end);
+        param.setUserId("admin");
+        BaseResponse<FindAlarmBaseDataStatisticResponse> response = HKService.findAlarmBaseDataStatistic(param);
+        if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)
+                && response.getData()!=null ) {
+            alarmDataVO.setTotalNum(Constants.formatIntegerNum(response.getData().getTotalAlarmNum()));
+            alarmDataVO.setRealNum(Constants.formatIntegerNum(response.getData().getTotalAlarmNum()));
+            alarmDataVO.setErrNum(Constants.formatIntegerNum(response.getData().getMisReportAlarmNum()));
+            alarmDataVO.setLiftNum(Constants.formatIntegerNum(response.getData().getHandledAlarmNum()));
+            alarmDataVO.setProcessingNum(Constants.formatIntegerNum(response.getData().getUnHandedAlarmNum()));
+            alarmDataVO.setStartDate(start);
+            alarmDataVO.setEndDate(end);
+        }
+        return  alarmDataVO;
+    }
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-鏈勾鍜屾湰鏈堟柊澧炴秷闃茶澶�/璁炬柦缁存姢鎯呭喌
+     * @return
+     */
+    @Override
+    public    YearDeviceDataVO yearFightingAdminDeviceData(){
+        YearDeviceDataVO data = new YearDeviceDataVO();
+
+        FireStatisticRequest param = new FireStatisticRequest();
+        param.setIndexCode("api_fire_statistic");
+        BaseResponse<FireStatisticResponse> response = HKService.fireStatistic(param);
+        if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ) {
+            data.setProtectNum(Constants.formatIntegerNum(response.getData().getMaintenanceNum()));
+            data.setPlanProtectTotal(Constants.formatIntegerNum(response.getData().getDeviceTotalNum()));
+        }
+
+        param = new FireStatisticRequest();
+        param.setIndexCode("api_fire_statistic_month");
+        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.setMonthTotalNum(Constants.formatIntegerNum(response1.getData().getDeviceTotalNum()));
+        }
+            return data;
+
+    }
+
+    /**
+     * 銆愭秷闃茬鎺с�戠湅鏉�-鍒嗙被鍜屾眹鎬荤殑鍚勭姸鎬佽澶囨暟閲�
+     * @return
+     */
+    @Override
+    public  FightingAdminCenterDataVO centerFightingAdminData(){
+        FightingAdminCenterDataVO data = new FightingAdminCenterDataVO();
+        List<DeviceNumByTypeVO> list = new ArrayList<>();
+        FireDevStatusTotalRequest param = new FireDevStatusTotalRequest();
+        param.setIncludeBool(1);
+        param.setRegionIds(new String[]{"root000000"});
+        BaseResponse<List<FireDevStatusListResponse>> response = HKService.getFireDevStatusList(param);
+        if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){
+            for(FireDevStatusListResponse r :response.getData()){
+                DeviceNumByTypeVO t = new DeviceNumByTypeVO();
+                t.setTypeName(r.getDevTypeName());
+                t.setOfflineDeviceNum(Constants.formatIntegerNum(r.getOfflineFireDevCount()));
+                t.setAlarmDeviceNum(Constants.formatIntegerNum(r.getAlarmFireDevCount()));
+                t.setOnlineDeviceNum(Constants.formatIntegerNum(r.getOnlineFireDevCount()));
+                t.setErrDeviceNum(Constants.formatIntegerNum(r.getFaultFireDevCount()));
+                t.setTotalDeviceNum(Constants.formatIntegerNum(r.getTotalFireDevCount()));
+                list.add(t);
+                data.setOfflineDeviceNum(Constants.formatIntegerNum( data.getOfflineDeviceNum())+Constants.formatIntegerNum(r.getOfflineFireDevCount()));
+                data.setAlarmDeviceNum(Constants.formatIntegerNum( data.getAlarmDeviceNum())+Constants.formatIntegerNum(r.getAlarmFireDevCount()));
+                data.setOnlineDeviceNum(Constants.formatIntegerNum( data.getOnlineDeviceNum())+Constants.formatIntegerNum(r.getOnlineFireDevCount()));
+                data.setErrDeviceNum(Constants.formatIntegerNum( data.getErrDeviceNum())+Constants.formatIntegerNum(r.getFaultFireDevCount()));
+                data.setTotalDeviceNum(Constants.formatIntegerNum( data.getTotalDeviceNum())+Constants.formatIntegerNum(r.getTotalFireDevCount()));
+            }
+        }
+        data.setDeviceTypeList(list);
+        Long totalNum =hiddenDangerMapper.selectCount(new QueryWrapper<HiddenDanger>().lambda()
+                .eq(HiddenDanger::getIsdeleted,Constants.ZERO )
+                .apply("to_days(create_date) = to_days(now())" ) );
+        data.setDangerTotalNum(totalNum !=null?totalNum.intValue():0);//浠婃棩闅愭偅鏁伴噺
+        totalNum =hiddenDangerMapper.selectCount(new QueryWrapper<HiddenDanger>().lambda()
+                .eq(HiddenDanger::getIsdeleted,Constants.ZERO )
+                .in(HiddenDanger::getStatus,Constants.ONE,Constants.TWO )
+                .apply("to_days(check_date) = to_days(now())" ) );
+        data.setDangerDealedNum(totalNum !=null?totalNum.intValue():0);//浠婃棩澶勭悊闅愭偅鏁伴噺
+        return  data;
+    }
+    /**
+     * 鐢ㄧ數鎬昏兘鑰楀悓姣斻�佺幆姣斿拰鍖哄煙鐢ㄧ數閲忛泦鍚�
+     * @return
+     */
+    @Override
+    public  EnergyBoardVO centerEnergyData(){
+        EnergyBoardVO data = new EnergyBoardVO();
+        Random random = new Random();
+       PlatformWaterGas smoke=  platformWaterGasMapper.selectOne(new QueryWrapper<PlatformWaterGas>()
+                 .select("sum(num) as num")
+                .lambda()
+                .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO)
+                .eq(PlatformWaterGas::getType,Constants.THREE)
+                .apply("year(time_info) = year(now())")
+                .last("limit 1 " ));
+
+        data.setSmokeBoxTotal(0);
+        if(smoke!=null){
+            data.setSmokeBoxTotal(Constants.formatBigdecimal(smoke.getNum()).intValue());//褰撳勾鐑熺鏁�
+        }
+        BigDecimal carbonGas = new BigDecimal(0);//鏈湀鐢ㄦ皵
+        BigDecimal carbonWater = new BigDecimal(0);//鏈湀鐢ㄦ按
+        BigDecimal carbonElec = new BigDecimal(0);//鐢ㄧ數
+
+        data.setTodayElectricity(getDefaultData());//浠婃棩鐢ㄧ數
+        data.setElectricityQuantity(getDefaultData());//涓婃湀鐢ㄧ數
+        data.setWaterQuantity(getDefaultData());//涓婃湀鐢ㄦ按
+        data.setGasQuantity(getDefaultData());//涓婃湀鐢ㄦ皵
+        data.setMonthElectricity(getDefaultData());//鏈湀鐢ㄧ數
+        data.setYesterdayElectricity(getDefaultData());//鏄ㄦ棩鐢ㄧ數
+        getMonthElectricityData(data.getMonthElectricity());//閫氳繃瀹夐槻骞宠幏鍙栨湰鏈堢敤鐢甸噺鏁版嵁
+        carbonElec = new BigDecimal(StringUtils.defaultString(data.getMonthElectricity().getTotal(), "0"));
+        getLastMonthElectricityData(data.getElectricityQuantity());//閫氳繃瀹夐槻骞宠幏鍙栦笂鏈堢敤鐢甸噺鏁版嵁
+        getCurrentDateElectircityData(data.getTodayElectricity(),0);//閫氳繃瀹夐槻骞宠幏鍙栦粖鏃ョ敤鐢甸噺鏁版嵁
+        getCurrentDateElectircityData(data.getYesterdayElectricity(),-1);//閫氳繃瀹夐槻骞宠幏鍙栨槰鏃ョ敤鐢甸噺鏁版嵁
+        String firstDate = DateUtil.getFirstDayCurrentMonth() +" 00:00:00";
+        Date month0 = DateUtil.getDateFromString(firstDate);
+        Date month1 = DateUtil.increaseMonth(month0,-1);//涓婃湀
+        Date month2 = DateUtil.increaseMonth(month0,-2);//涓婁笂鏈�
+        Date month3 = DateUtil.increaseMonth(month0,-13);//鍘诲勾鍚屾湀
+
+        List<PlatformWaterGas> list =  platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>()
+                .lambda()
+                .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO)
+                .in(PlatformWaterGas::getType,Constants.ZERO,Constants.ONE)
+                .in(PlatformWaterGas::getTimeInfo,month0,month1,month3,month2)
+        );
+
+        if(list!=null){
+            //绫诲瀷 0鐢ㄦ按 1鐢ㄦ皵 2鐢ㄦ补
+            for(PlatformWaterGas model : list){
+                if(Constants.equalsInteger(model.getType(),Constants.ONE)){
+                    if(model.getTimeInfo().getTime() == month0.getTime()){
+                        carbonGas = Constants.formatBigdecimal(model.getNum());
+                    }
+                    if(model.getTimeInfo().getTime() == month1.getTime()){
+                        data.getGasQuantity().setTotalNum(Constants.formatBigdecimal(model.getNum()) );
+                        data.getGasQuantity().setTotal(Constants.formatBigdecimal(model.getNum())+"");
+                    }
+                    if(model.getTimeInfo().getTime() == month2.getTime()){
+                        data.getGasQuantity().setRingNum(Constants.formatBigdecimal(model.getNum()) );
+                    }
+                    if(model.getTimeInfo().getTime() == month3.getTime()){
+                        data.getGasQuantity().setSameNum(Constants.formatBigdecimal(model.getNum()) );
+                    }
+
+                }else if(Constants.equalsInteger(model.getType(),Constants.ZERO)){
+                    if(model.getTimeInfo().getTime() == month0.getTime()){
+                        carbonWater = Constants.formatBigdecimal(model.getNum());
+                    }
+                    if(model.getTimeInfo().getTime() == month1.getTime()){
+                        data.getWaterQuantity().setTotalNum(Constants.formatBigdecimal(model.getNum()) );
+                        data.getWaterQuantity().setTotal(Constants.formatBigdecimal(model.getNum())+"");
+                    }
+                    if(model.getTimeInfo().getTime() == month2.getTime()){
+                        data.getWaterQuantity().setRingNum(Constants.formatBigdecimal(model.getNum()) );
+                    }
+                    if(model.getTimeInfo().getTime() == month3.getTime()){
+                        data.getWaterQuantity().setSameNum(Constants.formatBigdecimal(model.getNum()) );
+                    }
+                }
+            }
+        }
+        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 +"");
+        }
+        if( data.getWaterQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){
+            // //璁＄畻鐢ㄦ按鍚屾瘮鐜瘮
+            data.getWaterQuantity().setSameRate(Constants.formatBigdecimal4Float(data.getWaterQuantity().getSameNum().divide(data.getWaterQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +"");
+            data.getWaterQuantity().setRingRate(Constants.formatBigdecimal4Float(data.getWaterQuantity().getRingNum().divide(data.getWaterQuantity().getTotalNum(),4,BigDecimal.ROUND_HALF_UP)).doubleValue()*100 +"");
+        }
+
+        /*璁＄畻纰虫帓閲忥紝浠ヤ笅涓変釜鍥犵礌涔嬪拰
+        1)鐢ㄧ數鐨勪簩姘у寲纰虫帓鏀鹃噺(kg)=鑰楃數閲�(kWh)x0.785锛�
+        2) 澶╃劧姘斾簩姘у寲纰虫帓鏀鹃噺(kg)=澶╃劧姘斾娇鐢ㄩ噺(m3)脳0.19锛�
+        3) 鑷潵姘翠簩姘у寲纰虫帓鏀鹃噺(kg)=鑷潵姘翠娇鐢ㄩ噺(m3)脳0.91锛�*/
+        data.setCarbon(Constants.formatBigdecimal2Float((carbonElec.multiply(new BigDecimal(0.785)))
+                .add(carbonGas.multiply(new BigDecimal(0.19)))
+                .add(carbonWater.multiply(new BigDecimal(0.91)))));
+        return data;
+
+    }
+
+    /**
+     * 閫氳繃瀹夐槻骞宠幏鍙栨湰鏈堟暟鎹�
+     * @param data
+     */
+    private void getMonthElectricityData(EnergyModelDataVO data) {
+        BaseResponse<MonthDataByMeterTypeResponse> response = HKService.getCurrentMonthDataByMeterType("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"));
+           data.setTotal(StringUtils.defaultString(response.getData().getValue(),"0"));
+        }
+    }
+
+    /**
+     * 閫氳繃瀹夐槻骞宠幏鍙栦笂鏈堟暟鎹�
+     * @param data
+     */
+    private void getLastMonthElectricityData(EnergyModelDataVO data) {
+         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"));
+           data.setTotal(StringUtils.defaultString(response.getData().getValue(),"0"));
+        }
+    }
+
+    /**
+     * 閫氳繃瀹夐槻骞宠幏鍙栦粖鏃ョ敤鐢甸噺
+     * @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");
+        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());
+    }
+
+    private EnergyModelDataVO getDefaultData() {
+        EnergyModelDataVO data = new EnergyModelDataVO();
+        data.setTotal("0");
+        data.setSameRate("0");
+        data.setRingRate("0");
+        data.setTotalNum(new BigDecimal(0));
+        data.setSameNum(new BigDecimal(0));
+        data.setRingNum(new BigDecimal(0));
+        return data;
+    }
+
+    /**
+     * 鐢ㄧ數鎬昏兘鑰楀悓姣斻�佺幆姣斿拰鍖哄煙鐢ㄧ數閲忛泦鍚�
+     * @return
+     */
+    @Override
+    public   RegionEnergyListResponse energyRegionData(){
+        RegionEnergyListResponse data = null;
+        BaseResponse<RegionEnergyListResponse> response = HKService.regionEnergyList("1");
+        if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){
+            data = response.getData();
+        }
+        if(data == null){
+            data = new RegionEnergyListResponse();
+            data.setSecondRegionDataList(new ArrayList<>());
+            data.setRootValue("0");
+            data.setSamePercent("0");
+            data.setRingPercent("0");
+            data.setSecondRegionDataList(new ArrayList<>());
+        }
+        return data;
+
+    }
+    /**
+     * 杩�12涓按鐢垫皵娌硅�楁暟鎹粺璁�
+     * @param type
+     * @return
+     */
+    @Override
+    public   List<EnergyDataVO> energyDataList(Integer type){
+        List<EnergyDataVO> energyDataVOList = new ArrayList<>();
+        List<OilDataVO> oilDataVOList = new ArrayList<>();
+        Date lastMonth = DateUtil.increaseMonth(new Date(),-11);
+        if(type >=0 && type <=2){
+            //鐢ㄦ按鐢ㄧ數鐢ㄦ皵
+            List<PlatformWaterGas> list =  platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>()
+                            .select("DATE_FORMAT(TIME_INFO,'%Y-%m') as time_info_str,sum(num) as num")
+                    .lambda()
+                    .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO)
+                    .eq(PlatformWaterGas::getType,type)
+                    .apply("time_info BETWEEN DATE_SUB(CURDATE(), INTERVAL 12 MONTH) AND CURDATE()")//杩�12涓湀
+                    .last(" group by DATE_FORMAT(TIME_INFO,'%Y-%m')")
+            );
+            for (int i = 0; i < 12; i++) {
+                Date tempDate = DateUtil.increaseMonth(lastMonth,i);
+                EnergyDataVO data = new EnergyDataVO();
+                data.setTimeData(DateUtil.getFomartDate(tempDate,"YYYY-MM"));
+                data.setEnergy(new BigDecimal(0));
+                if(list!=null){
+                    for(PlatformWaterGas m : list){
+                        if(StringUtils.equals(m.getTimeInfoStr(),data.getTimeData())){
+                            data.setEnergy(Constants.formatBigdecimal(m.getNum()));
+                        }
+                    }
+                }
+                energyDataVOList.add(data);
+            }
+        }else{
+            for (int i = 0; i < 12; i++) {
+                Date tempDate = DateUtil.increaseMonth(lastMonth,i);
+                EnergyDataVO data = new EnergyDataVO();
+                data.setTimeData(DateUtil.getFomartDate(tempDate,(i+1)+"鏈�"));
+                data.setEnergy(new BigDecimal(0));
+                energyDataVOList.add(data);
+            }
+            //濡傛灉鏄敤鐢垫暟鎹�
+            EnergyTrendRequest param = new EnergyTrendRequest();
+            param.setDate(DateUtil.getFomartDate(new Date(),"yyyy"));//骞翠唤
+            param.setMeterType(1);
+            param.setNodeType(2);
+            param.setNodeId("root000000");
+            param.setPeriodType("year");
+            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){
+                        //鍙栫浉搴旂殑鍙傛暟鍊�
+                        energyDataVOList.get(i).setEnergy(new BigDecimal(StringUtils.defaultString(response.getData().getYvalues().get(0).getValue()[i],"0")));
+                    }
+                }
+
+            }
+        }
+        return energyDataVOList;
+    }
+    @Override
+    public  VisitDataVO visitSecurityData(){
+        //寰呰闂�佸凡鐧昏銆佸凡绂诲紑
+
+        VisitDataVO result = new VisitDataVO();
+        result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
+                .eq(Visits::getIsdeleted,Constants.ZERO)
+                .in(Visits::getStatus,Constants.VisitStatus.pass,Constants.VisitStatus.xfSuccess )));//寰呰闂�
+        result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
+                .eq(Visits::getIsdeleted,Constants.ZERO)
+                .in(Visits::getStatus,Constants.VisitStatus.signout,Constants.VisitStatus.signin )));//宸茬櫥璁�
+        result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>()
+                .eq(Visits::getIsdeleted,Constants.ZERO)
+                .in(Visits::getStatus,Constants.VisitStatus.signout )));//宸茬绂�
+        PageWrap<Visits> pageWrap = new PageWrap<>();
+        pageWrap.setCapacity(10);
+        pageWrap.setPage(1);
+        pageWrap.setModel(new Visits());
+        pageWrap.getModel().setLevelStatus(Constants.ZERO);
+        pageWrap.getModel().setStatus(Constants.TWO);
+        PageData<Visits> visitsPageData =    VisitsServiceImpl.retentionPageBiz(pageWrap,visitsJoinMapper,systemDictDataBiz);
+        List<VisitRetentionDataVO> list = new ArrayList<>();
+        if(visitsPageData !=null && visitsPageData.getRecords() !=null && visitsPageData.getRecords().size()>0){
+            for (Visits model : visitsPageData.getRecords()) {
+                VisitRetentionDataVO data = new VisitRetentionDataVO();
+                data.setName(model.getName());
+                data.setCompanyName(model.getCompanyName());
+                data.setTimeOutMinute(Constants.formatIntegerNum(model.getTimeOut()));
+                list.add(data);
+            }
+            result.setRetentionNum(visitsPageData.getTotal());
+        }
+        result.setVisitRetentionDataList(list);//璁垮婊炵暀鏁版嵁闆嗗悎
+        return result;
+
+    }
+    @Override
+    public  SecurityBoardVO centerSecurityData(){
+
+
+        SecurityBoardVO data = new SecurityBoardVO();
+        getParkingCarsNum(data);//鑾峰彇杞︿綅鏁版嵁
+        List<Retention> retentionList = retentionMapper.selectJoinList(Retention.class,
+                new MPJLambdaWrapper<Retention>()
+                        .selectAll(Retention.class)
+                        .selectAs(Company::getType,Retention::getCompanyType)
+                        .leftJoin(Company.class,Company::getId,Retention::getCompanyId)
+        );
+
+        //浠婃棩鍦ㄥ洯浜烘暟
+        data.setInParkTotal(
+                (int) retentionList.stream().filter(i->!Constants.equalsInteger(i.getType(),Constants.THREE)).count()
+        );
+        //鍦ㄥ洯闀挎湡鐩稿叧鏂逛汉鏁�
+        data.setInternalTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count()
+        );
+        //鍦ㄥ洯璁垮鏁伴噺
+        data.setVisitTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Objects.isNull(i.getCompanyType())).count()
+        );
+        //鍦ㄥ洯杞﹁締
+        data.setInternalCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).count()
+        );
+        //鍦ㄥ洯鐩稿叧鏂硅溅杈�
+        data.setRelatedCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.relation)).count()
+        );
+        //鍐呴儴杞﹁締
+        data.setInternalCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.internal)).count()
+        );
+        //鏉ヨ杞﹁締
+        data.setVisitCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.visitor)).count()
+        );
+        //鑷敱鐗╂祦杞︽暟閲�
+        data.setVisitCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.selfTruck)).count()
+        );
+        //甯傚叕鍙稿嵏璐ц溅鏁伴噺
+        data.setInternalJobCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.cityComTruck)).count()
+        );
+        //澶栧崗杞︽暟閲�
+        data.setRelatedJobCarTotal(
+                (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)
+                        &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.outTruck)).count()
+        );
+        return data;
+    }
+
+    private void getParkingCarsNum(SecurityBoardVO data) {
+        try {
+            BaseResponse<ParkingStatisticResponse> response = HKService.getParkingStatistics();
+            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) || response.getData()==null
+            ||response.getData().getTodayParkingDataDto() == null){
+                 return;
+            }
+            data.setParkingLotTotal(Constants.formatIntegerNum(response.getData().getTodayParkingDataDto().getTotalPlace()));//鎬昏溅浣�
+            data.setFreeParkingLot(Constants.formatIntegerNum(response.getData().getTodayParkingDataDto().getLeftPlace()));//鍓╀綑杞︿綅
+            data.setParkingUseRate(Constants.formatBigdecimal(response.getData().getTodayParkingDataDto().getUseRate()));//杞︿綅浣跨敤鐜�
+        }catch (Exception e){
+
+        }
+    }
+
+    @Override
+    public  List<PlatformWorkDataVO> platformWorkData(){
+
+        List<PlatformWorkDataVO> platformWorkDataVOList = new ArrayList<>();
+        List<Platform> platformList = platformMapper.selectJoinList(Platform.class, new MPJLambdaWrapper<Platform>()
+                .selectAll( Platform.class)
+                .eq(Platform::getIsdeleted, Constants.ZERO)
+                .orderByAsc(Platform::getSortnum)
+        );
+        if(platformList!=null && platformList.size()>0){
+            List<PlatformJob> jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper<PlatformJob>()
+                    .selectAll( PlatformJob.class)
+                    .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)
+                    .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() })
+                    .orderByDesc(PlatformJob::getStatus ));
+            //鏈堝彴鐘舵�侊細0=浣滀笟涓紱1=绌洪棽涓紱2=浣滀笟瓒呮椂;3=鍙彿
+            for(Platform model : platformList){
+                PlatformWorkDataVO platformDurationVO = new PlatformWorkDataVO();
+                platformDurationVO.setPlatformName(model.getName());
+                platformDurationVO.setPlatformId(model.getId());
+                platformDurationVO.setPlatformSort(model.getSortnum());
+                PlatformJob job = getJobFromListById(model.getId(),jobList);
+                if(job != null){
+                    if(Constants.equalsInteger(job.getType(),Constants.ONE) || Constants.equalsInteger(job.getType(),Constants.THREE)){
+                        platformDurationVO.setWorkType(Constants.ONE);//濡傛灉鏄璐�
+                    }else{
+                        platformDurationVO.setWorkType(Constants.ZERO);//濡傛灉鏄嵏璐�
+                    }
+                    Integer workMinute = Constants.formatBigdecimal(job.getWorkNum()).multiply(new BigDecimal(60)).divide(model.getWorkRate(),0,BigDecimal.ROUND_HALF_UP).intValue();
+                    Date overDate = DateUtil.getXMinuteAfterDate(job.getNewStartDate(),workMinute + model.getWorkTimeoutAlarmTime());//棰勮瀹屾垚鏃堕棿
+                    platformDurationVO.setFinishTimeStr(DateUtil.DateToStr(overDate,"HH:mm"));
+
+                    platformDurationVO.setWorkNum(Constants.formatBigdecimal(job.getWorkNum()).intValue());
+                    platformDurationVO.setCarNo(job.getCarCodeFront());//杞︾墝鍙�
+                    if(Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.CALLED.getKey() )){
+                        platformDurationVO.setStatus(Constants.THREE); //鍙彿涓�
+                    }else{
+                        platformDurationVO.setStatus(Constants.ZERO); //浣滀笟涓�
+                        platformDurationVO.setWorkTime(PlatformJobServiceImpl.getWorkTime(job,platformLogMapper));//宸插伐浣滄椂闂�
+                        if(overDate.getTime() < System.currentTimeMillis() ){
+                            model.setStatus(Constants.TWO); //浣滀笟宸茶秴鏃�
+                        }
+                    }
+                }else{
+                    platformDurationVO.setStatus(Constants.ONE);//绌洪棽涓�
+                }
+                platformWorkDataVOList.add(platformDurationVO);
+            }
+        }
+        return  platformWorkDataVOList;
+    }
+
+    private PlatformJob getJobFromListById(Integer id, List<PlatformJob> jobList) {
+        if(jobList!=null){
+            for(PlatformJob job :jobList){
+                if(Constants.equalsInteger(job.getPlatformId(),id)){
+                    return  job;
+                }
+            }
+
+        }
+
+        return null;
+    }
+
+    /**
+     *
+     * @param type 鏌ヨ绫诲瀷锛�0=鍏ュ簱锛�1=鍑哄簱
+     * @return
+     */
+    @Override
+    public   List<WorkEfficiencyVO> workEfficiency(Integer type){
+        //浣滀笟绫诲瀷 0鑷湁杞﹀嵏璐� 1鑷湁杞﹁璐� 2澶栧崗杞﹀嵏璐� 3澶栧崗杞﹁璐� 4甯傚叕鍙稿鍗忚溅鍗歌揣
+        List<WorkEfficiencyVO> workEfficiencyVOList = new ArrayList<>();
+        List<PlatformJob> jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper<PlatformJob>()
+                .selectAll( PlatformJob.class)
+//                .select("(select sum(ifnull(a.io_qty,0)) from platform_wms_detail a where a.isdeleted=0 and a.job_id =t.id )", create_date)
+                .apply("to_days(t.create_date) = to_days(now())")
+                .eq(Platform::getIsdeleted, Constants.ZERO)
+                .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey()
+                        , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
+                        , Constants.PlatformJobStatus.LEAVED.getKey())
+                .in(Constants.equalsInteger(type,Constants.ZERO),PlatformJob::getType,new Integer[]{0,2,4})
+                .in(Constants.equalsInteger(type,Constants.ONE),PlatformJob::getType,new Integer[]{1,3})
+
+        );
+        if(jobList==null || jobList.size()==0){
+            return workEfficiencyVOList;
+        }
+        int curtotalNum = 0;
+        Date today =  Utils.Date.getStart(new Date());
+        long curTime=0, lastTime=0;
+        for (int i = 0; i < 8; i++) {
+            lastTime = curTime;//涓婃鐨勬椂闂�
+            int curHour = 8+(i*2);
+            curTime = curHour*60*60*1000 + today.getTime();
+            WorkEfficiencyVO workEfficiencyVO = new WorkEfficiencyVO();
+            workEfficiencyVO.setWorkTime(curHour+":00");
+            workEfficiencyVO.setTotalWorkNum(0);
+            workEfficiencyVO.setWorkNum(0);
+            if(jobList!=null && jobList.size()>0){
+                for(PlatformJob detail : jobList){
+                    if(detail.getDoneDate()!=null && detail.getDoneDate().getTime()<= curTime){
+                        //褰撳墠閲�
+                        if(detail.getDoneDate()!=null && detail.getDoneDate().getTime() > lastTime){
+                            //鍖洪棿鍊� 鍙栧疄杩�2灏忔椂鍐呯殑绱鍊�
+                            workEfficiencyVO.setWorkNum(Constants.formatIntegerNum(workEfficiencyVO.getWorkNum())+Constants.formatBigdecimal(detail.getIoQty()).intValue() +Constants.formatBigdecimal(detail.getTotalNum()).intValue());
+                            //绱Н閲�
+                        }
+                    }
+                }
+                curtotalNum += Constants.formatIntegerNum(workEfficiencyVO.getWorkNum()) ;
+            }
+            workEfficiencyVO.setTotalWorkNum(curtotalNum);//绱鍊�
+            workEfficiencyVOList.add(workEfficiencyVO);
+        }
+        return workEfficiencyVOList;
+    }
+    @Override
+    public List<PlatformDurationVO> platformDuration(){
+        List<PlatformDurationVO> platformDurationList = new ArrayList<>();
+        List<Platform> jobList = platformMapper.selectJoinList(Platform.class, new MPJLambdaWrapper<Platform>()
+                .selectAll( Platform.class)
+                .select(" (select ROUND( SUM(ifnull(pl.PARAM3,0)/60 ) , 2 )   from platform_log pl  where   pl.remark = t.id and to_days(pl.CREATE_DATE) =to_days(now()))",Platform::getWorkCountTime)
+                .eq(Platform::getIsdeleted, Constants.ZERO)
+        );
+        if(jobList!=null){
+            //鎸夊伐浣滄椂闀跨疮璁″�掑簭鎺掑簭
+            Collections.sort(jobList, new Comparator<Platform>() {
+                @Override
+                public int compare(Platform o1, Platform o2) {
+                    return Constants.formatBigdecimal(o2.getWorkCountTime()).intValue() - Constants.formatBigdecimal(o1.getWorkCountTime()).intValue();
+                }
+            });
+            for(Platform model : jobList){
+                PlatformDurationVO data = new PlatformDurationVO();
+                data.setPlatformId(model.getId());
+                data.setPlatformName(model.getName());
+                data.setWorkTotalTime(Constants.formatBigdecimal(model.getWorkCountTime()).intValue());
+                platformDurationList.add(data);
+            }
+        }
+
+        return platformDurationList;
+    }
+    @Override
+    public      List<PlatformWarnEvent> warningList(int limit){
+        List<PlatformWarnEvent> platformLogList = platformWarnEventMapper.selectList(new QueryWrapper<PlatformWarnEvent>().lambda()
+                .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO)
+                .apply("to_days(create_date) = to_days(now())")
+                .orderByDesc(PlatformWarnEvent::getCreateDate)
+                .last(" limit "+limit)
+        );
+        return platformLogList;
+    }
+    @Override
     public OnSitDispatchBoardVO getCnddCenterData(){
         OnSitDispatchBoardVO data = new OnSitDispatchBoardVO();
         //鏈堝彴鎬绘暟
@@ -260,7 +1603,7 @@
                 .selectAll(PlatformJob.class)
                 .select("count(id)" ,PlatformJob::getCountum)
                 .eq(PlatformJob::getIsdeleted,Constants.ZERO)
-                .apply("to_days(create_data) = to_days(now())" )
+                .apply("to_days(create_date) = to_days(now())" )
                 .groupBy(PlatformJob::getStatus )
         );
         if(jobList!=null){
@@ -268,20 +1611,75 @@
             //-------------TODO----------銆愮湅鏉裤�戠埍纭闇�姹�--------------
             //     * 0寰呯‘璁� 1寰呯鍒� 2绛夊緟鍙彿 3鍏ュ洯绛夊緟 4宸插彨鍙� 5浣滀笟涓� 6浣滀笟瀹屾垚 7杞Щ涓� 8寮傚父鎸傝捣 9宸叉巿鏉冪鍥� 10宸茬鍥� 11 宸茶繃鍙� 12宸插彇娑�
             for(PlatformJob model : jobList){
-                //棰勭害杞﹁締
-                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CONFIRM.getKey())
-                ||Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){
+                //寰呯‘璁� 锛堥绾﹁溅锛�
+                if( Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CONFIRM.getKey())){
                     data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
                 }
-                // 浣滀笟杞﹁締
+                //寰呯鍒帮紙棰勭害杞︼級
+                if( Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                //绛夊緟鍙彿锛堥绾﹁溅銆佺鍒版暟銆佹帓闃熻溅锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                //鍏ュ洯绛夊緟锛堥绾﹁溅銆佺鍒版暟锛�
+                if( Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                //宸插彨鍙凤紙棰勭害杞︺�佺鍒版暟銆佸凡鍙彿锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.CALLED.getKey()) ){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setCalledNum(data.getCalledNum()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                // 浣滀笟杞﹁締锛堥绾﹁溅銆佺鍒版暟銆佸凡鍙彿銆佷綔涓氳溅锛�
                 if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setCalledNum(data.getCalledNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setWorkedNum(data.getWorkedNum()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                // 浣滀笟瀹屾垚锛堥绾﹁溅銆佺鍒版暟銆佸凡鍙彿銆佷綔涓氳溅銆佸凡瀹屾垚锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    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.setDoneNum(data.getDoneNum()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                // 杞Щ涓紙棰勭害杞︺�佺鍒版暟銆佹帓闃熻溅锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                // 宸叉巿鏉冪鍥紙棰勭害杞︺�佺鍒版暟銆佸凡鍙彿銆佷綔涓氳溅銆佸凡瀹屾垚锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    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.setDoneNum(data.getDoneNum()+Constants.formatIntegerNum(model.getCountum()));
+                }
+                // 宸茬鍥�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())){
                     data.setWorkingCar(data.getWorkingCar()+Constants.formatIntegerNum(model.getCountum()));
                 }
-                //鎺掗槦杞﹁締
-                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())
-                        ||Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey())){
-                     data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
+                // 宸茶繃鍙凤紙棰勭害杞︺�佺鍒版暟銆佹帓闃熻溅锛�
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.OVER_NUMBER.getKey())){
+                    data.setSignedNum(data.getSignedNum()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));
                 }
+                // 宸插彇娑�(棰勭害杞︼級
+                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.CANCEL.getKey())){
+                    data.setReservationCar(data.getReservationCar()+Constants.formatIntegerNum(model.getCountum()));
+                }
+
             }
         }
 

--
Gitblit v1.9.3