package com.doumee.service.business.impl.thrid; 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.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; import com.doumee.core.haikang.model.param.BaseResponse; 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.ApiResponse; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; 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.WmsBaseDataResponse; 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; 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.xiaoymin.knife4j.core.util.CollectionUtils; 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 org.springframework.web.bind.annotation.RequestBody; import javax.servlet.http.HttpServletResponse; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * TMS平台对接Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service @Slf4j public class BoardServiceImpl implements BoardService { @Autowired private PlatformLogMapper platformLogMapper; @Autowired private WmsService wmsService; @Autowired private HiddenDangerMapper hiddenDangerMapper; @Autowired private PlatformWaterGasMapper platformWaterGasMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private PlatformWarnEventJoinMapper platformWarnEventJoinMapper; @Autowired private PlatformJobMapper platformJobMapper; @Autowired private PlatformBooksMapper platformBooksMapper; @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 List todayTotalInList(){ /** * 1市公司：根据预约的入园原因为市公司卸货的任务为市公司入库的统计； * 2集散中心：WMS推送的入库单据； * 3加工入库：预约入园为重庆加工入库的（作业月台为安泰物流卸货月台）； */ String[] names = new String[]{"市公司","集散中心","加工入库"}; String reason =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.CITY_XH_REASON_ID).getCode(); String platformGroupId =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ATWL_XH_PLATFORM_ID).getCode();; List list = new ArrayList<>(); for (int i = 0; i < 3; i++) { Random random = new Random(); GeneralVO data = new GeneralVO(); data.setName(names[i]); BigDecimal num =new BigDecimal(0); if(i == 0){ List jobs = platformBooksMapper.selectJoinList(PlatformBooks.class, new MPJLambdaWrapper() .select(PlatformJob::getTotalNum) .leftJoin(PlatformJob.class,PlatformJob::getId,PlatformBooks::getJobId) .eq(PlatformBooks::getIsdeleted,Constants.ZERO) .eq(PlatformBooks::getReasonId,reason) .apply("to_days(t1.done_date) = to_days(now())") .eq(PlatformBooks::getStatus,Constants.TWO)); if(jobs!=null){ for(PlatformBooks j :jobs){ num =num.add(Constants.formatBigdecimal(j.getTotalNum())); } } }else if(i ==1){ List jobs = platformJobMapper.selectList (new MPJLambdaWrapper() .select(PlatformJob::getTotalNum) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getOrigin,Constants.ONE) .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey() , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey() , Constants.PlatformJobStatus.LEAVED.getKey()) .apply("to_days(done_date) = to_days(now())") ); if(jobs!=null){ for(PlatformJob j :jobs){ num =num.add(Constants.formatBigdecimal(j.getTotalNum())); } } }else{ List jobs = platformJobMapper.selectList (new MPJLambdaWrapper() .select(PlatformJob::getTotalNum) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getPlatformGroupId,platformGroupId) .apply("to_days(done_date) = to_days(now())") .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey() , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey() , Constants.PlatformJobStatus.LEAVED.getKey()) ); if(jobs!=null){ for(PlatformJob j :jobs){ num = num.add(Constants.formatBigdecimal(j.getTotalNum())); } } } data.setNum(num); list.add(data); } return list; } /** * 获取区域树形结构数据 * @return */ @Override public BoardStockListVO stockList(){ BoardStockListVO data = new BoardStockListVO(); double toatalNum = 1d; BigDecimal num = new BigDecimal(0); List list = new ArrayList<>(); try { toatalNum =Double.parseDouble(systemDictDataBiz.queryByCode(Constants.WMS_PARAM,Constants.WMS_TOTAL_STOCK_NUM).getCode()) ; }catch (Exception e){ } WmsBaseResponse response = wmsService.getInventoryList(); if(response!=null && response.getData()!=null && response.getData().size()>0){ List 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.getItemName()); list.add(d); } } } data.setStockList(list); data.setNum(num); if(toatalNum<=0){ toatalNum =1; } data.setTotalNum(new BigDecimal(toatalNum)); data.setUseRate(Constants.formatBigdecimal(data.getNum()).divide(data.getTotalNum(),2,BigDecimal.ROUND_HALF_UP)); return data; } /** * 获取区域树形结构数据 * @return */ @Override public List getRegionTree(CarmeraListVO req){ List allList = new ArrayList<>(); boolean hasNext = true; int curTotal = 0; int curPage = 1; while (hasNext){ //分页遍历循环查询所有门禁设备数据 BaseListPageRequest param = new BaseListPageRequest(); param.setUserId("admin"); param.setPageSize(100); param.setPageNo(curPage); BaseResponse> response = HKService.pageRegions(param); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~"); } BaseListPageResponse r = response.getData(); curTotal += 100; if(curTotal >= r.getTotal()){ hasNext = false; } if(r.getList() == null || r.getList().size()==0){ hasNext =false; }else{ allList.addAll(r.getList()); } curPage++; } if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){ initReginCameralList(allList,req.getName());//获取全部监控点数据 } List data = new RegionTreeVO(allList).buildTree(); return data; } private void initReginCameralList(List allList,String name) { CarmeraListVO re = new CarmeraListVO(); re.setName(name); List carmeraListVOList = cameraList(re); if(carmeraListVOList!=null && carmeraListVOList.size()>0){ for(PageRegionInfoResponse p : allList){ for(CarmeraListVO c : carmeraListVOList){ if(StringUtils.equals(p.getIndexCode(),c.getReginCode()) && (StringUtils.contains(c.getName(),name) ||StringUtils.isBlank(name))){ if(p.getCarmeraList()==null){ p.setCarmeraList(new ArrayList<>()); } p.getCarmeraList().add(c); } } } } } /** * 获取区域树形结构数据 * @return */ @Override public List regionList(CarmeraListVO req){ List allList = new ArrayList<>(); boolean hasNext = true; int curTotal = 0; int curPage = 1; while (hasNext){ //分页遍历循环查询所有门禁设备数据 BaseListPageRequest param = new BaseListPageRequest(); param.setUserId("admin"); param.setPageSize(100); param.setPageNo(curPage); BaseResponse> response = HKService.pageRegions(param); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~"); } BaseListPageResponse r = response.getData(); curTotal += 100; if(curTotal >= r.getTotal()){ hasNext = false; } if(r.getList() == null || r.getList().size()==0){ hasNext =false; }else{ allList.addAll(r.getList()); } curPage++; } if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){ initReginCameralList(allList,req.getName());//获取全部监控点数据 } return allList; } @Override public List cameraList(CarmeraListVO req){ List allList = new ArrayList<>(); boolean hasNext = true; int curTotal = 0; int curPage = 1; while (hasNext){ //分页遍历循环查询所有门禁设备数据 BaseListPageRequest param = new BaseListPageRequest(); param.setUserId("admin"); param.setPageSize(100); param.setPageNo(curPage); BaseResponse> response = HKService.pageCameras(param); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~"); } BaseListPageResponse r = response.getData(); curTotal += 100; if(curTotal >= r.getTotal()){ hasNext = false; } if(r.getList() == null || r.getList().size()==0){ hasNext =false; }else{ allList.addAll(r.getList()); } curPage++; } List data = new ArrayList<>(); for(PageCameraInfoResponse p : allList){ 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; } @Override public List fireChannelList(){ List allList = new ArrayList<>(); boolean hasNext = true; int curTotal = 0; int curPage = 1; while (hasNext){ //分页遍历循环查询所有门禁设备数据 BaseListPageRequest param = new BaseListPageRequest(); param.setUserId("admin"); param.setPageSize(100); param.setPageNo(curPage); BaseResponse> response = HKService.pageFireChannel(param); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~"); } BaseListPageResponse r = response.getData(); curTotal += 100; if(curTotal >= r.getTotal()){ hasNext = false; } if(r.getList() == null || r.getList().size()==0){ hasNext =false; }else{ allList.addAll(r.getList()); } curPage++; } return allList; } @Override public List sensorStatusList(){ List allList = new ArrayList<>(); boolean hasNext = true; int curTotal = 0; int curPage = 1; while (hasNext){ //分页遍历循环查询所有门禁设备数据 SensorStatusListRequest param = new SensorStatusListRequest(); param.setPageSize(100); param.setPageNo(curPage); BaseResponse> response = HKService.pageSensorStatus(param); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~"); } BaseListPageResponse r = response.getData(); curTotal += 100; if(curTotal >= r.getTotal()){ hasNext = false; } if(r.getList() == null || r.getList().size()==0){ hasNext =false; }else{ allList.addAll(r.getList()); } curPage++; } return allList; } @Override public List platformGroupFinish(){ List data = new ArrayList<>(); List groups = platformGroupMapper.selectJoinList(PlatformGroup.class, new MPJLambdaWrapper() .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) ); if(groups!=null && groups.size()>0){ List jobList = platformWmsDetailMapper.selectJoinList(PlatformWmsDetail.class, new MPJLambdaWrapper() .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 platformLogList = platformLogMapper.selectList(new QueryWrapper().lambda() .like(PlatformLog::getCreateDate,DateUtil.getCurrDate()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit "+limit) ); carWorkSituationVO.setPlatformLogList(platformLogList); return carWorkSituationVO; } @Override public List securityDeviceData(){ List list = new ArrayList<>(); SecureDevStatusTotalRequest request =new SecureDevStatusTotalRequest(); request.setIncludeBool(""); request.setRegionIds(new String[]{}); BaseResponse> result = HKService.getSecureDevStatusList(request) ; if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ List 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 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,131593");//安防告警和人员告警 file.setType("in"); if(type == 1){ file.setFieldValue("131588");//安防告警 }else if(type == 2){ file.setFieldValue("131593");//人员告警 } request.getFiledOptions().add(file); SortRequest sort = new SortRequest(); sort.setSortField("happen_time"); sort.setSortType("desc"); request.getSorts().add(sort); BaseResponse> result = HKService.ruleEventSearch(request); if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ List 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 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 loadEnergyCurve(){ List loadCurveList = new ArrayList<>(); try { BaseResponse> 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 energyLastMonthOilSort(){ List oilDataVOList = new ArrayList<>(); //上月油耗 List list = platformWaterGasMapper.selectList(new QueryWrapper().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 fightingAdminAlertList(){ List 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> 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 monitorDataList(){ List list = new ArrayList<>(); MinitorDataSearchRequest param = new MinitorDataSearchRequest(); param.setResourceTypeCodes(new String[]{}); param.setRegionIndexCode("root000000"); param.setIncludeDown("1"); param.setUserId("admin"); BaseResponse> response = HKService.minitorDataSearch(param); if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ) { List 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 fightingAlarmHandleData(){ List 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 transportMeasure(Integer queryType){ List list = new ArrayList<>(); Random random = new Random(); List 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 dataList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getCreateDate,PlatformJob::getCreateDate) .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( 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() .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 logList = platformLogMapper.selectJoinList(PlatformLog.class, new MPJLambdaWrapper() .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() .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 detailList = platformWmsDetailMapper.selectJoinList(PlatformWmsDetail.class, new MPJLambdaWrapper() .selectAll(PlatformWmsDetail.class) .eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO) .eq(PlatformWmsDetail::getWmsJobId,wmsJob.getId()) .orderByDesc(PlatformLog::getCreateDate)); if(detailList!=null){ for(PlatformWmsDetail d : detailList){ if(isExistIocode(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 getDetailListByCode(String iocode, List detailList,CarsContractVO tt) { List 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 isExistIocode(String iocode, List 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 monthNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .select(PlatformJob::getType,PlatformJob::getType) .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum) .select(PlatformJob::getStatus,PlatformJob::getStatus) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey(),Constants.PlatformJobStatus.LEAVED.getKey(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()) .apply("year(done_date) = year('"+DateUtil.getPlusTime2(month)+"') and month(done_date) = month('"+DateUtil.getPlusTime2(month)+"') ")); List monthLastNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getTotalNum,PlatformJob::getTotalNum) .select(PlatformJob::getType,PlatformJob::getType) .select(PlatformJob::getStatus,PlatformJob::getStatus) // .select("select sum(io_qty) from platform_wms_details a where a.isdeleted=0 and a.job_id=t.id",create_date) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .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(done_date) = year('"+DateUtil.getPlusTime2(lastMonth)+"') and month(done_date) = month('"+DateUtil.getPlusTime2(lastMonth)+"') and done_date<= '" +DateUtil.getPlusTime2(lastMonth)+"'")); List yearNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getTotalNum,PlatformJob::getTotalNum) .select(PlatformJob::getStatus,PlatformJob::getStatus) .select(PlatformJob::getType,PlatformJob::getType) // .selectCount(PlatformJob::getPlatformId,PlatformJob::getCountum) .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(done_date) = year('"+DateUtil.getPlusTime2(year)+"') and done_date<= '"+DateUtil.getPlusTime2(year)+"'")); List yearLastNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getType,PlatformJob::getId) .select(PlatformJob::getStatus,PlatformJob::getStatus) .select(PlatformJob::getTotalNum,PlatformJob::getTotalNum) .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(done_date) = year('"+DateUtil.getPlusTime2(lastYear)+"') and done_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 beforeJobNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .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(" to_days(create_date) currentDoneNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getType,PlatformJob::getType) .selectAs(PlatformJob::getStatus,PlatformJob::getStatus) .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(" to_days(done_date) = to_days(now())")); //==========今天下发出入库任务---- List currentNum = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAs(PlatformJob::getId,PlatformJob::getId) .selectAs(PlatformJob::getType,PlatformJob::getType) .selectAs(PlatformJob::getStatus,PlatformJob::getStatus) .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(" to_days(create_date) = to_days(now())")); 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(currentDoneNum,1,1));//今日完成量 data.setCurrentOutDoneNum(getSumTotalByList(currentDoneNum,0,1));//今日完成量 //------------今日出入库效率---------------- BigDecimal outHours = getTotalDoneTimes(currentDoneNum,0);// BigDecimal inHours = getTotalDoneTimes(currentDoneNum,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 outMonthHours = getTotalDoneTimes(monthNum,0).add(outHours);// BigDecimal inMonthHours = getTotalDoneTimes(monthNum,1).add(inHours);// if(outMonthHours.compareTo(new BigDecimal(0))>0){ data.setMonthOutRate(data.getMonthOutTotal().divide(outMonthHours,0,BigDecimal.ROUND_HALF_UP));//本月入库效率 } if(inMonthHours.compareTo(new BigDecimal(0))>0){ data.setMonthInRate(inMonthNum.divide(inMonthHours,0,BigDecimal.ROUND_HALF_UP));//本月入库效率 } return data; } private BigDecimal getDoneHoursByData(String start ,String end) { List platformLogList = platformLogMapper.selectList(new QueryWrapper().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 list, Integer type) { BigDecimal r = new BigDecimal(0); if(list==null || list.size() == 0){ return r; } List 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 platformLogList = platformLogMapper.selectList(new QueryWrapper().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 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 = r.add(Constants.formatBigdecimal(job.getTotalNum())); // } } return Constants.formatBigdecimal0Float(r); } @Override public List carsEventList(){ if(HKCarOpenService.HK_CARS_LIST == null){ HKCarOpenService.HK_CARS_LIST = HKCarOpenService.getAllCarsDetais(); } return HKCarOpenService.getAlarmEvemtList( HKCarOpenService.HK_CARS_LIST,new Date()); } @Override public BoardCarsListVO platformJobCarsList(){ BoardCarsListVO data = new BoardCarsListVO(); List detaisResponses = HKCarOpenService.getAllCarsDetais(); data.setCarsList(detaisResponses); if(data.getCarsList()!=null && data.getCarsList().size()>0){ List 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)){ //如果是在线或者休眠，查询在途还是空闲ty codes.add(model.getPlateNum()); model.setJobStatus(Constants.ZERO); }else model.setJobStatus(Constants.TWO); data.setOfflineNum(data.getOfflineNum()+1); } if(codes.size()>0){ //状态 0待确认 1待签到 2等待叫号 3入园等待 4已叫号 5作业中 6作业完成 7转移中 8异常挂起 9已授权离园 10已离园 11 已过号 12取消（WMS） List busyNum = platformJobMapper.selectList(new QueryWrapper() .lambda() .select(PlatformJob::getCarCodeFront) .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( busyNum!=null ?busyNum.size():0);//在途有任务数量 data.setIdleNum(codes.size() -data.getBusyNum());//无任务空闲数量 HKCarOpenService.HK_CARS_LIST = detaisResponses; // data.setEventList(HKCarOpenService.getAlarmEvemtList(detaisResponses,new Date())); if(busyNum != null){ FLAG: for(CarsDeviceDetaisResponse model:detaisResponses){ for(PlatformJob job : busyNum){ if(StringUtils.equals(job.getCarCodeFront(),model.getPlateNum())){ model.setJobStatus(Constants.ONE); continue FLAG; } } } } } } 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 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); }else{ alarmDataVO.setTotalNum(Constants.ZERO); alarmDataVO.setRealNum(Constants.ZERO); alarmDataVO.setErrNum(Constants.ZERO); alarmDataVO.setLiftNum(Constants.ZERO); alarmDataVO.setProcessingNum(Constants.ZERO); 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 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 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 list = new ArrayList<>(); FireDevStatusTotalRequest param = new FireDevStatusTotalRequest(); param.setIncludeBool(1); param.setRegionIds(new String[]{"root000000"}); BaseResponse> 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().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().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; } /** * 消防 温湿度数据 */ @Override public List getTemperatureHumidityData(){ TemperatureHumidityDataRequest request = new TemperatureHumidityDataRequest(); List temperatureHumidityDataVOList = new ArrayList<>(); request.setPageNo(1); request.setPageSize(100); request.setParentIndexCode(systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.TEMPERATURE_HUMIDITY).getCode()); BaseResponse> response = HKService.temperatureHumidityDataStatistic(request); if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ List temperatureHumidityDataResponseList = response.getData().getList(); if(CollectionUtils.isNotEmpty(temperatureHumidityDataResponseList)){ Set parentIndexCode = new HashSet(temperatureHumidityDataResponseList.stream().map( i->i.getIndexCode().replace("@0","").replace("@1","") ).collect(Collectors.toList())); for (String code:parentIndexCode) { List dateList = temperatureHumidityDataResponseList.stream().filter(i->i.getIndexCode().indexOf(code)>=Constants.ZERO).collect(Collectors.toList()); TemperatureHumidityDataVO temperatureHumidityDataVO = new TemperatureHumidityDataVO(); for (TemperatureHumidityDataResponse data:dateList) { if(data.getSensorType().equals("temp")){ temperatureHumidityDataVO.setTemperatureData(data); }else{ temperatureHumidityDataVO.setHumidityData(data); } } temperatureHumidityDataVOList.add(temperatureHumidityDataVO); } } } return temperatureHumidityDataVOList; } /** * 用电总能耗同比、环比和区域用电量集合 * @return */ @Override public EnergyBoardVO centerEnergyData(){ EnergyBoardVO data = new EnergyBoardVO(); Random random = new Random(); PlatformWaterGas smoke= platformWaterGasMapper.selectOne(new QueryWrapper() .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 list = platformWaterGasMapper.selectList(new QueryWrapper() .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)))).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP)); return data; } /** * 通过安防平获取本月数据 * @param data */ private void getMonthElectricityData(EnergyModelDataVO data) { BaseResponse 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 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 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 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.setRootValue("0"); data.setSamePercent("0"); data.setRingPercent("0"); data.setSecondRegionDataList(new ArrayList<>()); } if(data.getSecondRegionDataList()!=null && data.getSecondRegionDataList().size()>1){ int index =-1; for (int i = 0; i -1){ data.getSecondRegionDataList().remove(index);//删除根节点数据 } } return data; } /** * 近12个水电气油耗数据统计 * @param type * @return */ @Override public List energyDataList(Integer type){ List energyDataVOList = new ArrayList<>(); List oilDataVOList = new ArrayList<>(); Date lastMonth = DateUtil.increaseMonth(new Date(),-11); if(type >=0 && type <=2){ //用水用电用气 List list = platformWaterGasMapper.selectList(new QueryWrapper() .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 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() .eq(Visits::getIsdeleted,Constants.ZERO) .apply("to_days(create_date)=to_days(now())") .in(Visits::getStatus,Constants.VisitStatus.pass,Constants.VisitStatus.xfSuccess )));//待访问 result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper() .eq(Visits::getIsdeleted,Constants.ZERO) .apply("to_days(create_date)=to_days(now())") .in(Visits::getStatus,Constants.VisitStatus.signout,Constants.VisitStatus.signin )));//已登记 result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper() .eq(Visits::getIsdeleted,Constants.ZERO) .apply("to_days(create_date)=to_days(now())") .in(Visits::getStatus,Constants.VisitStatus.signout )));//已签离 /*PageWrap pageWrap = new PageWrap<>(); pageWrap.setCapacity(10); pageWrap.setPage(1); pageWrap.setModel(new Visits()); pageWrap.getModel().setLevelStatus(Constants.ZERO); pageWrap.getModel().setStatus(Constants.TWO); PageData visitsPageData = VisitsServiceImpl.retentionPageBiz(pageWrap,visitsJoinMapper,systemDictDataBiz); List 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()); }*/ String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_WARNING).getCode(); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName); queryWrapper.select("TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) AS timeOut"); queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment); queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.leftJoin(" member m on m.id= t.MEMBER_ID"); queryWrapper.eq(Visits::getStatus,Constants.VisitStatus.signin); queryWrapper.apply(" TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) <= "+code+" "); queryWrapper.ne("m.type ",Constants.TWO); queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); queryWrapper.orderByDesc(Visits::getEditDate); List vr = visitsJoinMapper.selectList(queryWrapper); result.setVisitRetentionDataList(new ArrayList<>());//访客滞留数据集合 if(vr!=null&&vr!=null){ vr.stream().forEach(s ->{ VisitRetentionDataVO t = new VisitRetentionDataVO(); t.setName(s.getName()); t.setCompanyName(s.getCompanyName()); t.setTimeOutMinute(s.getTimeOut()); result.getVisitRetentionDataList().add(t); }); } return result; } @Override public SecurityBoardVO centerSecurityData(){ SecurityBoardVO data = new SecurityBoardVO(); getParkingCarsNum(data);//获取车位数据 List retentionList = retentionMapper.selectJoinList(Retention.class, new MPJLambdaWrapper() .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.setRelatedTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count() ); //在园内部员工人数 data.setInternalTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ONE)).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() ); data.setVideoPluginUrl(getVideoUrl()); return data; } private String getVideoUrl() { return systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()+"plugin/VideoWebPlugin.exe"; } private void getParkingCarsNum(SecurityBoardVO data) { try { BaseResponse 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 platformWorkData(){ List platformWorkDataVOList = new ArrayList<>(); List platformList = platformMapper.selectJoinList(Platform.class, new MPJLambdaWrapper() .selectAll( Platform.class) .eq(Platform::getIsdeleted, Constants.ZERO) .orderByAsc(Platform::getSortnum) ); if(platformList!=null && platformList.size()>0){ List jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .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(" ( case when t.total_num is null then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id ) else t.total_num end )",PlatformJob::getWorkNum) .apply("to_days(t.create_date) = to_days(now())") .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 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 workEfficiency(Integer type){ //作业类型 0自有车卸货 1自有车装货 2外协车卸货 3外协车装货 4市公司外协车卸货 List workEfficiencyVOList = new ArrayList<>(); List jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .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 platformDuration(){ List platformDurationList = new ArrayList<>(); List jobList = platformMapper.selectJoinList(Platform.class, new MPJLambdaWrapper() .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() { @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 warningList(int limit){ List platformLogList = platformWarnEventJoinMapper .selectJoinList(PlatformWarnEvent.class,new MPJLambdaWrapper() .selectAll(PlatformWarnEvent.class) .selectAs(Platform::getName,PlatformWarnEvent::getPlatformName) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO) .apply("to_days(t.create_date) = to_days(now())") .orderByDesc(PlatformWarnEvent::getCreateDate) .last(" limit "+limit) ); return platformLogList; } @Override public OnSitDispatchBoardVO getCnddCenterData(){ OnSitDispatchBoardVO data = new OnSitDispatchBoardVO(); //月台总数 List list = platformMapper.selectJoinList(Platform.class,new MPJLambdaWrapper() .selectAll(Platform.class) .select(" ( select count(1) from platform_job pj where t.id = pj.PLATFORM_ID and pj.STATUS = "+Constants.PlatformJobStatus.WORKING.getKey()+" ) as workStatus ") .eq(Platform::getIsdeleted,Constants.ZERO) ); data.setPlatformTotal(list==null?0:list.size()); //空闲月台数量 data.setFreePlatform( list.stream().filter(i->Constants.formatIntegerNum(i.getWorkStatus())<=Constants.ZERO).collect(Collectors.toList()).size() ); //查询今日月台个状态作业数量 List jobList = platformJobMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .select("count(id)" ,PlatformJob::getCountum) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .apply("to_days(create_date) = to_days(now())" ) .groupBy(PlatformJob::getStatus ) ); if(jobList!=null){ //-------------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())){ 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())); 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())){ 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.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())); } } data.setVideoPluginUrl(getVideoUrl()); String indexCodes = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_CHANGNEI_SCREEN_INDEXCODES).getCode(); if(StringUtils.isNotBlank(indexCodes)){ data.setVideoIndexCodes(indexCodes.split(",")); } } return data; } /** * 查询能耗用电信息 1=今日；2=本月；3=昨日 * @return */ @Override public List getRegionDataRanking(Integer type){ RegionDataRankingDataRequest request = new RegionDataRankingDataRequest(); request.setMeterType(1); if(Constants.equalsInteger(type,Constants.ONE)){ request.setDate(DateUtil.getFomartDate(new Date(),"yyyy-MM-dd")); request.setPeriodType("day"); }else if(Constants.equalsInteger(type,Constants.TWO)){ request.setDate(DateUtil.getFomartDate(new Date(),"yyyy-MM")); request.setPeriodType("month"); }else{ request.setDate(DateUtil.getBeforDay(new Date(),1)); request.setPeriodType("day"); } BaseResponse> response = HKService.regionDataRanking(request); if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ return response.getData(); }else{ return null; } } }