访客系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiangping
2024-12-13 77cb365302cc814df041e31e4a880d804a93383f 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java


@@ -5,6 +5,7 @@


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.CarsAlarmResultListResponse;


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;


@@ -22,6 +23,7 @@


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.PlatformWarnEventJoinMapper;


import com.doumee.dao.business.join.VisitsJoinMapper;


import com.doumee.dao.business.model.*;


import com.doumee.dao.web.reqeust.CarsJobAndContractDTO;


@@ -60,7 +62,7 @@


    @Autowired


    private SystemDictDataBiz systemDictDataBiz;


    @Autowired


    private PlatformWarnEventMapper platformWarnEventMapper;


    private PlatformWarnEventJoinMapper platformWarnEventJoinMapper;


    @Autowired


    private PlatformJobMapper platformJobMapper;


    @Autowired


@@ -314,7 +316,10 @@


    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)


                .select("(select sum(case when a.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = a.id  ) else a.total_num end) 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)


                //.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)




                //.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 ioQty ")


                .selectAll(PlatformGroup.class)


                .eq(PlatformGroup::getIsdeleted,Constants.ZERO)


        );


@@ -948,6 +953,7 @@


    public     BoardCarsListVO platformJobCarsList(){


        BoardCarsListVO data = new BoardCarsListVO();


        List<CarsDeviceDetaisResponse> detaisResponses = HKCarOpenService.getAllCarsDetais();


        List<CarsAlarmResultListResponse> eventList = HKCarOpenService.getAlarmEvemtList(detaisResponses,new Date());


        data.setCarsList(detaisResponses);


        if(data.getCarsList()!=null && data.getCarsList().size()>0){


            List<String> codes = new ArrayList<>();


@@ -955,7 +961,7 @@


            int online = 0;


            for(CarsDeviceDetaisResponse model:detaisResponses){


                if(Constants.equalsInteger(model.getStatus(),Constants.ONE) ||Constants.equalsInteger(model.getStatus(),Constants.TWO)){


                   //如果是在线或者休眠，查询在途还是空闲


                   //如果是在线或者休眠，查询在途还是空闲ty


                    codes.add(model.getPlateNum());


                }else


                    data.setOfflineNum(data.getOfflineNum()+1);


@@ -1170,7 +1176,7 @@


        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)))));


                .add(carbonWater.multiply(new BigDecimal(0.91)))).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP));


        return data;




    }


@@ -1215,7 +1221,8 @@


        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 ){


        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")));


            }


@@ -1254,8 +1261,21 @@


            data.setRingPercent("0");


            data.setSecondRegionDataList(new ArrayList<>());


        }


        return data;


        if(data.getSecondRegionDataList()!=null && data.getSecondRegionDataList().size()>1){


            int index =-1;


            for (int i = 0; i <data.getSecondRegionDataList().size() ; i++) {


                RegionTopPowerResponse t=data.getSecondRegionDataList().get(i);


                if(Constants.formatBigdecimal(t.getPercent()).compareTo(new BigDecimal(1)) == 0){


                    index =i;


                    break;


                }


            }


            if(index>-1){


                data.getSecondRegionDataList().remove(index);//删除根节点数据


            }


        }




        return  data;


    }


    /**


     * 近12个水电气油耗数据统计


@@ -1481,7 +1501,8 @@


            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)


                    //.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 a.total_num end )",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() })


@@ -1618,9 +1639,13 @@


    }


    @Override


    public      List<PlatformWarnEvent> warningList(int limit){


        List<PlatformWarnEvent> platformLogList = platformWarnEventMapper.selectList(new QueryWrapper<PlatformWarnEvent>().lambda()


        List<PlatformWarnEvent> platformLogList = platformWarnEventJoinMapper


                .selectJoinList(PlatformWarnEvent.class,new MPJLambdaWrapper<PlatformWarnEvent>()


                .selectAll(PlatformWarnEvent.class)


                .selectAs(Platform::getName,PlatformWarnEvent::getPlatformName)


                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)


                .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO)


                .apply("to_days(create_date) = to_days(now())")


                .apply("to_days(t.create_date) = to_days(now())")


                .orderByDesc(PlatformWarnEvent::getCreateDate)


                .last(" limit "+limit)


        );


@@ -1671,12 +1696,14 @@


                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()));


                    data.setLineUpCar(data.getLineUpCar()+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()));


                    data.setLineUpCar(data.getLineUpCar()+Constants.formatIntegerNum(model.getCountum()));


                }


                // 作业车辆（预约车、签到数、已叫号、作业车）


                if(Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){