productDev/dmvisit.git

			@@ -1,6 +1,7 @@
			package com.doumee.service.business.impl;

			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.doumee.biz.system.SystemDictDataBiz;
			import com.doumee.core.constants.ResponseStatus;
			import com.doumee.core.exception.BusinessException;
			@@ -10,16 +11,19 @@
			import com.doumee.core.haikang.model.param.request.ParkReservationDelRequest;
			import com.doumee.core.haikang.model.param.respose.ParkReservationAddResponse;
			import com.doumee.core.haikang.service.HKService;
			import com.doumee.core.model.LoginUserInfo;
			import com.doumee.core.model.PageData;
			import com.doumee.core.model.PageWrap;
			import com.doumee.core.tms.model.request.TmsLockStatusQueryRequest;
			import com.doumee.core.tms.model.response.TmsBaseResponse;
			import com.doumee.core.tms.model.response.TmsLockStatusQueryResponse;
			import com.doumee.dao.business.dao.UserActionMapper;
			import com.doumee.service.business.third.WmsService;
			import com.doumee.service.business.third.model.LoginUserInfo;
			import com.doumee.service.business.third.model.PageData;
			import com.doumee.service.business.third.model.PageWrap;
			import com.doumee.service.business.third.model.request.TmsLockStatusQueryRequest;
			import com.doumee.service.business.third.model.response.TmsBaseResponse;
			import com.doumee.service.business.third.model.response.TmsLockStatusQueryResponse;
			import com.doumee.core.utils.*;
			import com.doumee.core.wx.wxPlat.WxPlatConstants;
			import com.doumee.core.wx.wxPlat.WxPlatNotice;
			import com.doumee.dao.business.*;
			import com.doumee.dao.business.dao.MemberMapper;
			import com.doumee.dao.business.dao.SmsConfigMapper;
			import com.doumee.dao.business.dao.SmsEmailMapper;
			import com.doumee.dao.business.join.PlatformJobJoinMapper;
			@@ -35,7 +39,6 @@
			import com.doumee.dao.web.response.DriverHomeVO;
			import com.doumee.dao.web.response.LineUpVO;
			import com.doumee.dao.web.response.PlatformWorkVO;
			import com.doumee.dao.web.response.platformReport.WholeProvinceBoardVO;
			import com.doumee.service.business.PlatformJobService;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
			@@ -58,7 +61,6 @@

			import java.math.BigDecimal;
			import java.math.RoundingMode;
			import java.net.URLEncoder;
			import java.util.*;
			import java.util.Date;
			import java.util.concurrent.TimeUnit;
			@@ -75,6 +77,8 @@

			@Autowired
			private PlatformJobMapper platformJobMapper;
			@Autowired
			private UserActionMapper userActionMapper;
			@Autowired
			private TmsService tmsService;

			@@ -128,6 +132,8 @@
			@Autowired
			private PlatformWarnEventServiceImpl platformWarnEventService;
			@Autowired
			private PlatformWarnEventMapper platformWarnEventMapper;
			@Autowired
			private MemberMapper memberMapper;
			@Autowired
			private WxNoticeConfigMapper wxNoticeConfigMapper;
			@@ -146,6 +152,30 @@
			}


			@Override
			@Transactional(rollbackFor = {BusinessException.class})
			public void deleteById(Integer id,LoginUserInfo user) {
			Date date = new Date();
			PlatformJob job = platformJobMapper.selectById(id);
			if(job==null \|\|Constants.equalsInteger(Constants.ONE,job.getIsdeleted())){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(! Constants.equalsInteger(Constants.PlatformJobStatus.CANCEL.getKey(),job.getStatus())){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，只能删除已取消的作业任务！");
			}
			platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
			.set(PlatformJob::getIsdeleted,Constants.ONE)
			.set(PlatformJob::getEditDate,date)
			.set(PlatformJob::getEditor,user.getId())
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CANCEL.getKey())
			.eq(PlatformJob::getId,id));
			String[] params = new String[3];
			params[0] = user.getRealname();
			params[1]=DateUtil.getPlusTime2(date);
			params[2]="【运单号："+job.getBillCode()+"】-【司机："+job.getDriverName()+" "+job.getDrivierPhone()+"】-【车牌号："+job.getCarCodeFront()+"】";
			//记录删除日志
			UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.PLATFROM_JOB_DEL,userActionMapper,date,params,JSONObject.toJSONString(job));
			}
			@Override
			public void delete(Integer id) {
			platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
			@@ -196,6 +226,7 @@

			@Override
			public List<PlatformJob> findList(PlatformJob platformJob) {
			platformJob.setIsdeleted(Constants.ZERO);
			QueryWrapper<PlatformJob> wrapper = new QueryWrapper<>(platformJob);
			return platformJobMapper.selectList(wrapper);
			}
			@@ -205,6 +236,7 @@
			IPage<PlatformJob> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
			MPJLambdaWrapper<PlatformJob> queryWrapper = new MPJLambdaWrapper<>();
			Utils.MP.blankToNull(pageWrap.getModel());
			pageWrap.getModel().setIsdeleted(Constants.ZERO);
			queryWrapper
			.selectAll(PlatformJob.class)
			.selectAs(Platform::getName,PlatformJob::getPlatformName)
			@@ -214,11 +246,14 @@
			.selectAs(PlatformWmsJob::getIoCreatedate,PlatformJob::getIoCreatedate)
			.selectAs(SystemUser::getRealname,PlatformJob::getOutUserName)
			.selectAs(PlatformBooks::getId,PlatformJob::getBookId)
			.select("s.REALNAME",PlatformJob::getEditUserName)
			.leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
			.leftJoin(PlatformGroup.class,PlatformGroup::getId,Platform::getGroupId)
			.leftJoin(PlatformGroup.class,PlatformGroup::getId,PlatformJob::getPlatformGroupId)
			.leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode)
			.leftJoin(SystemUser.class,SystemUser::getId,PlatformJob::getOutUserId)
			.leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId)
			.leftJoin(" system_user s on t.EDITOR = s.id ")
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(pageWrap.getModel().getId() != null, PlatformJob::getId, pageWrap.getModel().getId())
			.eq(pageWrap.getModel().getCreator() != null, PlatformJob::getCreator, pageWrap.getModel().getCreator())
			.ge(pageWrap.getModel().getCreateDate() != null, PlatformJob::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()))
			@@ -234,6 +269,7 @@
			.eq(pageWrap.getModel().getCode() != null, PlatformJob::getCode, pageWrap.getModel().getCode())
			.eq(pageWrap.getModel().getBillCode() != null, PlatformJob::getBillCode, pageWrap.getModel().getBillCode())
			.eq(pageWrap.getModel().getDriverId() != null, PlatformJob::getDriverId, pageWrap.getModel().getDriverId())
			.eq(pageWrap.getModel().getReasonId() != null, PlatformBooks::getReasonId, pageWrap.getModel().getReasonId())
			.eq(pageWrap.getModel().getDriverName() != null, PlatformJob::getDriverName, pageWrap.getModel().getDriverName())
			.eq(pageWrap.getModel().getPlateNum() != null, PlatformJob::getPlateNum, pageWrap.getModel().getPlateNum())
			.eq(pageWrap.getModel().getDrivierPhone() != null, PlatformJob::getDrivierPhone, pageWrap.getModel().getDrivierPhone())
			@@ -293,28 +329,32 @@
			.eq(pageWrap.getModel().getInType() != null, PlatformJob::getInType, pageWrap.getModel().getInType())
			.eq(pageWrap.getModel().getTotalNum() != null, PlatformJob::getTotalNum, pageWrap.getModel().getTotalNum())
			.eq(pageWrap.getModel().getPlatformGroupId() != null, PlatformJob::getPlatformGroupId, pageWrap.getModel().getPlatformGroupId())

			.apply(pageWrap.getModel().getQueryStatus() != null, " find_in_set(t.`STATUS`,'"+pageWrap.getModel().getQueryStatus()+"')")
			.apply(pageWrap.getModel().getQueryStatusForPower() != null, " find_in_set(t.`STATUS`,'"+pageWrap.getModel().getQueryStatusForPower()+"')")
			.apply(pageWrap.getModel().getQueryType() != null, " find_in_set(t.TYPE,'"+pageWrap.getModel().getQueryType()+"')")
			.ge(pageWrap.getModel().getCreateDateStart() != null, PlatformJob::getCreateDate, pageWrap.getModel().getCreateDateStart())
			.le(pageWrap.getModel().getCreateDateEnd() != null, PlatformJob::getCreateDate, pageWrap.getModel().getCreateDateEnd())
			.ge(pageWrap.getModel().getBeginWorkDateStart() != null, PlatformJob::getStartDate, Utils.Date.getStart(pageWrap.getModel().getBeginWorkDateStart()))
			.le(pageWrap.getModel().getBeginWorkDateEnd() != null, PlatformJob::getStartDate, Utils.Date.getEnd(pageWrap.getModel().getBeginWorkDateEnd()))
			.ge(pageWrap.getModel().getBeginDoneDateStart() != null, PlatformJob::getDoneDate, Utils.Date.getStart(pageWrap.getModel().getBeginDoneDateStart()))
			.le(pageWrap.getModel().getBeginDoneDateEnd() != null, PlatformJob::getDoneDate, Utils.Date.getEnd(pageWrap.getModel().getBeginDoneDateEnd()))

			.ge(pageWrap.getModel().getCreateDateStart() != null, PlatformWmsJob::getIoCreatedate, Utils.Date.getStart(pageWrap.getModel().getCreateDateStart()))
			.le(pageWrap.getModel().getCreateDateEnd() != null, PlatformWmsJob::getIoCreatedate, Utils.Date.getEnd(pageWrap.getModel().getCreateDateEnd()))
			.isNotNull(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ONE,pageWrap.getModel().getJobType()), PlatformJob::getContractNum)
			.isNull(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ZERO,pageWrap.getModel().getJobType()), PlatformJob::getContractNum)
			;

			for(PageWrap.SortData sortData: pageWrap.getSorts()) {
			// .isNotNull(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ONE,pageWrap.getModel().getJobType()),
			// PlatformJob::getContractNum)
			// .isNull(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ZERO,pageWrap.getModel().getJobType()), PlatformJob::getContractNum)
			.exists(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ZERO,pageWrap.getModel().getJobType()),
			"select 1 from platform_wms_detail tt where tt.isdeleted=0 and tt.job_id=t.id")
			.notExists(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ONE,pageWrap.getModel().getJobType()),
			"select 1 from platform_wms_detail tt where tt.isdeleted=0 and tt.job_id=t.id")
			.exists(StringUtils.isNotBlank(pageWrap.getModel().getWmsContractNum()),
			"select tt.id from platform_wms_detail tt where tt.isdeleted=0 and tt.contract_num='"+pageWrap.getModel().getWmsContractNum()+"' and tt.job_id=t.id");
			queryWrapper.orderByDesc(PlatformJob::getCreateDate);
			/*for(PageWrap.SortData sortData: pageWrap.getSorts()) {
			if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
			queryWrapper.orderByDesc(sortData.getProperty());
			} else {
			queryWrapper.orderByAsc(sortData.getProperty());
			}
			}
			}*/
			IPage<PlatformJob> platformJobIPage = platformJobJoinMapper.selectJoinPage(page,PlatformJob.class,queryWrapper);
			platformJobIPage.getRecords().forEach(i->{
			i.dealTime();
			@@ -323,8 +363,6 @@
			});
			return PageData.from(platformJobIPage);
			}



			@Override
			public PageData<PlatformJob> platformCallList(PageWrap<PlatformJob> pageWrap) {
			@@ -337,7 +375,8 @@
			.selectAs(Platform::getName,PlatformJob::getPlatformName)
			.selectAs(Platform::getWorkRate,PlatformJob::getWorkRate)
			.selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName)
			.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 ")
			.select(" (select GROUP_CONCAT(distinct(tt.contract_num )) from platform_wms_detail tt where tt.isdeleted=0 and tt.contract_num is not null and tt.job_id=t.id )as wmsContractNum")
			// .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 ")
			.leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
			.leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode)
			.leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId)
			@@ -345,15 +384,12 @@
			.apply("( t1.isdeleted = 0 or t.PLATFORM_ID is null )")
			.eq(pageWrap.getModel().getPlatformGroupId() != null, PlatformJob::getPlatformGroupId, pageWrap.getModel().getPlatformGroupId())
			.like(pageWrap.getModel().getCarCodeFront() != null, PlatformJob::getCarCodeFront, pageWrap.getModel().getCarCodeFront())

			.apply(Objects.nonNull(pageWrap.getModel().getCallType())
			&&Constants.equalsInteger(pageWrap.getModel().getCallType(),Constants.ONE),
			" ( " +
			" ( t.`STATUS` = "+Constants.PlatformJobStatus.WAIT_CALL.getKey()+" and t.PLATFORM_GROUP_ID = ( SELECT p.group_id FROM platform p WHERE p.id = "+pageWrap.getModel().getPlatformId()+" LIMIT 1 ) )" +
			") "
			)


			.apply(Objects.nonNull(pageWrap.getModel().getCallType())
			&&Constants.equalsInteger(pageWrap.getModel().getCallType(),Constants.TWO),
			" ( " +
			@@ -364,8 +400,6 @@
			" (t.`STATUS` = "+Constants.PlatformJobStatus.TRANSFERING.getKey()+" and t.PLATFORM_ID = "+pageWrap.getModel().getPlatformId()+" ) " +
			") "
			)


			.and(Objects.nonNull(pageWrap.getModel().getCallType())
			&&Constants.equalsInteger(pageWrap.getModel().getCallType(),Constants.THREE),
			i->i.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()).or()
			@@ -374,12 +408,16 @@
			.apply(" ( t.status = "+Constants.PlatformJobStatus.TRANSFERING.getKey()+" and t.PLATFORM_GROUP_ID = "+pageWrap.getModel().getPlatformGroupId()+" ) ")
			)
			// .like(PlatformJob::getArriveDate,DateUtil.dateTypeToString(new Date(),"yyyy-MM-dd"))
			.orderByDesc(PlatformJob::getStatus)
			.orderByDesc(PlatformJob::getStatus,PlatformJob::getUrgeTime)
			.orderByAsc(PlatformJob::getSignDate)
			;
			IPage<PlatformJob> platformJobIPage = platformJobJoinMapper.selectJoinPage(page,PlatformJob.class,queryWrapper);
			platformJobIPage.getRecords().forEach(i->{
			i.dealTime();
			i.setTotalNum(i.getIoQty());
			if(Constants.equalsInteger(i.getOrigin(),Constants.ZERO)){
			i.setWmsContractNum(i.getContractNum());
			}
			// i.setTotalNum(i.getIoQty());
			// this.getWmsJobData(i);
			// this.queryWaitNum(i);
			});
			@@ -407,7 +445,7 @@

			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformWmsDetailList)){
			platformJob.setTotalNum(
			platformWmsDetailList.stream().map(m->m.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add)
			platformWmsDetailList.stream().filter(i->Objects.nonNull(i.getIoQty())).map(m->m.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add)
			);
			platformWmsJob.setPlatformWmsDetailList(platformWmsDetailList);
			platformJob.setPlatformWmsJob(platformWmsJob);
			@@ -427,8 +465,6 @@
			}
			}
			}


			public void queryWaitNum(PlatformJob platformJob){
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
			//查询当前所有排队数量
			@@ -441,22 +477,24 @@
			.eq(PlatformJob::getPlatformGroupId,platformJob.getPlatformGroupId())
			// .like(PlatformJob::getArriveDate,DateUtil.dateTypeToString(platformJob.getArriveDate(),"yyyy-MM-dd"))
			);

			for (PlatformJob linePlatformJob:lineUpAllList) {
			this.getWmsJobData(linePlatformJob);
			}
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(lineUpAllList)){
			for (PlatformJob linePlatformJob:lineUpAllList) {
			this.getWmsJobData(linePlatformJob);
			}
			//查询排队在我前面的数据
			List<PlatformJob> lineUpNum = lineUpAllList.stream().filter(i->Objects.nonNull(i.getSignDate())&&i.getSignDate().getTime()<platformJob.getSignDate().getTime()).collect(Collectors.toList());
			platformJob.setLineUpNum(lineUpNum.size());
			BigDecimal sumWorkRate = platformJob.getTotalNum();
			BigDecimal sumWorkRate = Constants.formatBigdecimal(platformJob.getTotalNum());
			for (PlatformJob linePlatformJob:lineUpNum) {
			sumWorkRate = sumWorkRate.add(linePlatformJob.getTotalNum());
			sumWorkRate = sumWorkRate.add(Constants.formatBigdecimal(linePlatformJob.getTotalNum()));
			}
			//计算预计等待时间
			List<Platform> platformList = platformJoinMapper.selectList(new QueryWrapper<Platform>().lambda()
			.eq(Platform::getIsdeleted,Constants.ZERO).eq(Platform::getGroupId,platformJob.getPlatformGroupId()));
			BigDecimal workRate = platformList.stream().map(m->m.getWorkRate()).reduce(BigDecimal.ZERO,BigDecimal::add);
			BigDecimal workRate = new BigDecimal(0);
			if(platformList!=null){
			workRate = platformList.stream().map(m->Constants.formatBigdecimal(m.getWorkRate())).reduce(BigDecimal.ZERO,BigDecimal::add);
			}
			if(sumWorkRate.compareTo(BigDecimal.ZERO) > Constants.ZERO && workRate.compareTo(BigDecimal.ZERO) > Constants.ZERO ){
			BigDecimal sumMinute = sumWorkRate.divide(workRate,1, RoundingMode.HALF_DOWN).multiply(BigDecimal.valueOf(60L));
			Integer sumMinuteInteger = sumMinute.intValue();
			@@ -475,7 +513,9 @@
			platformJob.setWaitTime("预计等待：-小时-分钟");
			}
			}else if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey())
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.AUTHED_LEAVE.getKey())
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.LEAVED.getKey())){
			//查询最后开始任务的月台记录日志表因为存在异常挂起转移等问题
			PlatformLog platformLog = platformLogMapper.selectOne(new QueryWrapper<PlatformLog>().lambda()
			.eq(PlatformLog::getJobId,platformJob.getId())
			@@ -483,7 +523,7 @@
			.orderByDesc(PlatformLog::getCreateDate)
			.last(" limit 1")
			);
			if(Objects.nonNull(platformLog)){
			if(Objects.nonNull(platformLog) && platformJob.getWorkRate()!=null && platformJob.getWorkRate().compareTo(new BigDecimal(0))>0){
			BigDecimal sumMinute = platformJob.getTotalNum().divide(platformJob.getWorkRate(),1, RoundingMode.HALF_DOWN).multiply(BigDecimal.valueOf(60L));
			platformJob.setFinishTimeStr(DateUtil.DateToStr(DateUtil.afterMinutesDate(platformLog.getCreateDate(),sumMinute.intValue()),"HH:mm"));
			}
			@@ -493,9 +533,12 @@
			.isNotNull(PlatformLog::getParam3)
			.ne(PlatformLog::getParam3,Constants.ZERO+"")
			.orderByDesc(PlatformLog::getCreateDate));
			platformJob.setWorkTime(platformLogList.stream().map(m->Long.valueOf(m.getParam3())).reduce(Long.valueOf(0),Long::sum));
			if(platformLogList!=null){
			platformJob.setWorkTime(platformLogList.stream().map(m->Long.valueOf(StringUtils.defaultString(m.getParam3(),"0"))).reduce(Long.valueOf(0),Long::sum));
			}

			}
			platformJob.setWorkTimeStr(DateUtil.getTimeStrBySecond(platformJob.getWorkTime()));
			}


			@@ -517,6 +560,14 @@
			.leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getDrivierPhone,loginUserInfo.getMobile())
			.and(i->i.like(PlatformJob::getDoneDate,DateUtil.getCurrDate())
			.or().in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()
			,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(),
			Constants.PlatformJobStatus.WART_SIGN_IN.getKey(),
			Constants.PlatformJobStatus.IN_WAIT.getKey(),
			Constants.PlatformJobStatus.CALLED.getKey(),
			Constants.PlatformJobStatus.WORKING.getKey())
			)
			.orderByDesc(PlatformJob::getId)
			);
			for (PlatformJob platformJob:platformJobList) {
			@@ -525,9 +576,7 @@
			//查询前方排队数量
			this.queryWaitNum(platformJob);
			}

			driverHomeVO.setPlatformJobList(platformJobList);

			// 园区导览图图片
			driverHomeVO.setReservationMap(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.PLATFORM_GUIDEMAP).getCode());
			// 预约指南文本
			@@ -549,7 +598,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(confirmTaskDTO.getId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.ZERO)){
			@@ -585,7 +634,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(signInDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}

			@@ -593,11 +642,17 @@
			BeanUtils.copyProperties(platformJob,oldPlatformJob);

			if(Constants.equalsInteger(signInDTO.getSignType(),Constants.ZERO)){
			if(!StringUtils.equals(platformJob.getDrivierPhone(),signInDTO.getLoginUserInfo().getMobile())){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"业务状态已流转，请刷新查看");
			}
			this.distanceSignIn(signInDTO,platformJob);
			}else if(Constants.equalsInteger(signInDTO.getSignType(),Constants.ONE)){
			if(!StringUtils.equals(platformJob.getDrivierPhone(),signInDTO.getLoginUserInfo().getMobile())){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"业务状态已流转，请刷新查看");
			}
			@@ -623,7 +678,9 @@
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未在工作时间["+platformGroup.getStartTime() + "-" + platformGroup.getEndTime() +"]，无法进行签到");
			}
			//查询今日最大的签到数
			List<PlatformJob> signList = platformJobMapper.selectList(new QueryWrapper<PlatformJob>().lambda().apply(" DATE(SIGN_DATE) = DATE(NOW()) and sign_date is not null "));
			List<PlatformJob> signList = platformJobMapper.selectList(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.apply(" DATE(SIGN_DATE) = DATE(NOW()) and sign_date is not null "));
			if(CollectionUtils.isEmpty(signList)){
			platformJob.setSignNum(Constants.ONE);
			} else{
			@@ -637,14 +694,80 @@
			//存储操作日志
			savePlatformLog(Constants.PlatformJobLogType.SIGN.getKey(),oldPlatformJob,platformJob,
			Constants.PlatformJobLogType.SIGN.getInfo());
			//签到微信通知 2025年3月26日14:25:00
			logger.info("签到微信通知=========================>开始====签到类型=>"+signInDTO.getSignType()+"===>人员主键=>"+platformGroup.getSignInNoticeUsers());
			if(!Constants.equalsInteger(signInDTO.getSignType(),Constants.TWO)&&
			StringUtils.isNotBlank(platformGroup.getSignInNoticeUsers())){
			logger.info("签到微信通知=========================>进入");
			List<SystemUser> systemUserList = systemUserMapper.selectList(new QueryWrapper<SystemUser>().lambda()
			.eq(SystemUser::getDeleted,Constants.ZERO).eq(SystemUser::getStatus,Constants.ZERO).isNotNull(SystemUser::getOpenid)
			.in(SystemUser::getMemberId,Arrays.asList(platformGroup.getSignInNoticeUsers().split(",")))
			);
			if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemUserList)) {
			WxPlatNotice wxPlatNotice = new WxPlatNotice();
			wxPlatNotice.sendPlatformJobSignNotice(systemDictDataBiz,wxNoticeConfigMapper, platformJob,
			WxPlatConstants.platformJobContent.platformGroupSignIn,
			systemUserList.stream().map(i->i.getOpenid()).collect(Collectors.toList())
			);
			}
			}
			logger.info("签到微信通知=========================>结束");
			}


			@Override
			public void sendUnFinishNotice(){
			//状态 0待确认 1待签到 2等待叫号 3入园等待 4已叫号 5作业中 6作业完成 7转移中 8异常挂起 9已授权离园 10已离园 11 已过号 12取消（WMS）
			List<PlatformJob> platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,
			new MPJLambdaWrapper<PlatformJob>()
			.selectAll(PlatformJob.class)
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.isNotNull(PlatformJob::getPlatformGroupId)
			.apply(" CREATE_DATE < now() ")
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey()
			,Constants.PlatformJobStatus.WART_SIGN_IN.getKey()
			,Constants.PlatformJobStatus.WAIT_CALL.getKey()
			,Constants.PlatformJobStatus.IN_WAIT.getKey()
			,Constants.PlatformJobStatus.CALLED.getKey()
			,Constants.PlatformJobStatus.WORKING.getKey()
			,Constants.PlatformJobStatus.TRANSFERING.getKey()
			,Constants.PlatformJobStatus.EXCEPTION.getKey()
			,Constants.PlatformJobStatus.OVER_NUMBER.getKey()
			)
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){
			List<Integer> platformGroupId = platformJobList.stream().map(i->i.getPlatformGroupId()).collect(Collectors.toList());
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformGroupId)){
			Set<Integer> setList = new HashSet<>(platformGroupId);
			for (Integer groupId:setList) {
			PlatformGroup platformGroup = platformGroupMapper.selectById(groupId);
			if(Objects.nonNull(platformGroup)&&StringUtils.isNotBlank(platformGroup.getUnFinishNoticeUsers())){
			List<SystemUser> systemUserList = systemUserMapper.selectList(new QueryWrapper<SystemUser>().lambda()
			.eq(SystemUser::getDeleted,Constants.ZERO).eq(SystemUser::getStatus,Constants.ZERO)
			.isNotNull(SystemUser::getOpenid)
			.in(SystemUser::getMemberId,Arrays.asList(platformGroup.getUnFinishNoticeUsers().split(",")))
			);
			if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemUserList)) {
			WxPlatNotice wxPlatNotice = new WxPlatNotice();
			wxPlatNotice.sendUnFinishNotice(systemDictDataBiz,
			wxNoticeConfigMapper,
			platformJobList.stream().filter(i->Constants.equalsInteger(i.getPlatformGroupId(),groupId)).collect(Collectors.toList()).size(),
			WxPlatConstants.platformJobContent.unFinishNotice,
			systemUserList.stream().map(i->i.getOpenid()).collect(Collectors.toList())
			);
			}
			}
			}
			}
			}
			}


			public void distanceSignIn(SignInDTO signInDTO , PlatformJob platformJob){
			if(Objects.isNull(signInDTO.getLat())
			\|\| Objects.isNull(signInDTO.getLnt())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"经纬度信息异常");
			}

			//获取签到点的经纬度
			Double lat = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LAT).getCode());
			Double lnt = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LNT).getCode());
			@@ -669,28 +792,28 @@
			}
			}


			@Override
			public PlatformJob getDetail(JobDetailDTO jobDetailDTO){
			if(Objects.isNull(jobDetailDTO)
			\|\| Objects.isNull(jobDetailDTO.getJobId())){
			if(Objects.isNull(jobDetailDTO) \|\| Objects.isNull(jobDetailDTO.getJobId())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobDetailDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){
			//待签到计算距离
			if(Objects.nonNull(jobDetailDTO.getLnt())&&Objects.nonNull(jobDetailDTO.getLat())){
			//获取签到点的经纬度
			Double lat = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LAT).getCode());
			Double lnt = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LNT).getCode());
			//获取2个点的距离X米
			Double getDistanceDouble = PositionUtil.getDistance(jobDetailDTO.getLnt(),jobDetailDTO.getLat(),lnt,lat);
			//转换km
			BigDecimal getDistance = BigDecimal.valueOf(getDistanceDouble).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP);
			platformJob.setGetDistance(getDistance);
			if(jobDetailDTO.getLat()!=null && jobDetailDTO.getLnt()!=null){
			//获取签到点的经纬度
			Double lat = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LAT).getCode());
			Double lnt = Double.parseDouble(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_LNT).getCode());
			//获取2个点的距离X米
			Double getDistanceDouble = PositionUtil.getDistance(jobDetailDTO.getLnt(),jobDetailDTO.getLat(),lnt,lat);
			//转换km
			BigDecimal getDistance = BigDecimal.valueOf(getDistanceDouble).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP);
			platformJob.setGetDistance(getDistance);
			}
			}
			}else if( Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey())
			@@ -737,6 +860,7 @@
			,PlatformJob::getId,lineUpDetailDTO.getJobId())
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey(),
			Constants.PlatformJobStatus.IN_WAIT.getKey(),
			Constants.PlatformJobStatus.WORKING.getKey(),
			Constants.PlatformJobStatus.CALLED.getKey())
			.orderByDesc(PlatformJob::getStatus)
			.orderByAsc(PlatformJob::getSignDate)
			@@ -834,7 +958,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
			@@ -877,7 +1001,7 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())) {
			if(Objects.nonNull(platformJob.getDrivierPhone())) {
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobCallIn,platformJob);
			}
			return platformJob;
			@@ -886,7 +1010,7 @@
			public void sendWxNotice(String objCode,PlatformJob platformJob){
			SystemUser driver = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
			.eq(SystemUser::getDeleted, Constants.ZERO)
			.eq(SystemUser::getType, Constants.ZERO)
			.in(SystemUser::getType, Constants.ZERO,Constants.TWO)
			.eq(SystemUser::getMobile,platformJob.getDrivierPhone())
			.last(" limit 1 "));
			if (Objects.nonNull(driver) && StringUtils.isNotBlank(driver.getOpenid())) {
			@@ -898,22 +1022,41 @@
			.eq(PlatformJob::getId,platformJob.getId())
			.last(" limit 1")
			);

			WxPlatNotice wxPlatNotice = new WxPlatNotice();
			wxPlatNotice.sendPlatformJobTemplateNotice(systemDictDataBiz,
			wxNoticeConfigMapper, p,
			objCode,
			systemDictDataBiz.queryByCode(Constants.WX_PLATFORM, Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
			Arrays.asList(driver.getOpenid().split(","))
			);
			}
			}





			private Logger logger = LoggerFactory.getLogger(PlatformJobServiceImpl.class);

			@Override
			public void sendInPark(PlatformJob platformJob){
			log.info("【下发停车场权限】================开始===="+platformJob.getCarCodeFront());
			if(Constants.equalsInteger(platformJob.getType(),Constants.THREE)
			&& Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey()) ){
			//如果是已完成的外协车卸货作业，查询所有合同是否以上电子锁，如果没有，不自动授权离园
			List<PlatformWmsDetail> details = platformWmsDetailMapper.selectList(new QueryWrapper<PlatformWmsDetail>().lambda()
			.select(PlatformWmsDetail::getLockStatus,PlatformWmsDetail::getId)
			.eq(PlatformWmsDetail::getJobId,platformJob.getId())
			.eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO)
			);
			if(details!=null && details.size()>0){
			for(PlatformWmsDetail d : details){
			if(Constants.equalsInteger(d.getLockStatus(),Constants.ZERO)){
			//如果存在未上锁，不自动授权离园
			return;
			}
			}
			}
			}
			if(Constants.equalsInteger(platformJob.getType(),Constants.TWO)
			\|\| Constants.equalsInteger(platformJob.getType(),Constants.THREE)
			\|\| Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){
			@@ -995,6 +1138,15 @@
			platformJob.setInHkdate(new Date());
			if(sendStatus){
			platformJob.setInHkstatus(Constants.TWO);
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){
			//如果已下发成功，标记已授权离园状态
			platformJob.setStatus(Constants.PlatformJobStatus.AUTHED_LEAVE.getKey());
			//删除报警信息
			platformWarnEventMapper.update(new UpdateWrapper<PlatformWarnEvent>().lambda()
			.set(PlatformWarnEvent::getIsdeleted,Constants.ONE)
			.eq(PlatformWarnEvent::getPlatformId,platformJob.getId())
			);
			}
			}else{
			platformJob.setInHkstatus(Constants.THREE);
			}
			@@ -1005,14 +1157,12 @@
			}
			}


			@Override
			public void cancelInPark(PlatformJob platformJob){
			if(Constants.equalsInteger(platformJob.getType(),Constants.TWO)
			\|\| Constants.equalsInteger(platformJob.getType(),Constants.THREE)
			\|\| StringUtils.isBlank(platformJob.getCarCodeFront())
			\|\| Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){

			List<VisitPark> visitParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda()
			.eq(VisitPark::getCarCode,platformJob.getCarCodeFront())
			.eq(VisitPark::getObjType,Constants.ONE)
			@@ -1037,7 +1187,6 @@
			}
			}
			}

			/**
			* 月台叫号
			*/
			@@ -1049,7 +1198,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())
			@@ -1067,6 +1216,7 @@
			//查询月台任务等待作业数量
			if(platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getPlatformId,platform.getId())
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey(),Constants.PlatformJobStatus.WORKING.getKey())
			)>=platform.getWorkingNum()){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"超出月台可同时作业数量["+platform.getWorkingNum()+"辆]");
			@@ -1104,7 +1254,7 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())){
			if(Objects.nonNull(platformJob.getDrivierPhone())){
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobSingIn,platformJob);
			}

			@@ -1112,7 +1262,7 @@
			//广播 led通知
			platformJob.setPlatformName(platform.getName());
			this.broadcastAndLEed(platformJob,Constants.PlatformLedContent.CALLING.getInfo(),
			Constants.PlatformBroadcastContent.CALLING.getInfo()
			Constants.PlatformBroadcastContent.CALLING.getInfo()+ Constants.PlatformBroadcastContent.CALLING.getInfo() + Constants.PlatformBroadcastContent.CALLING.getInfo()
			);

			platformJob.setPlatformWmsCode(platform.getCode());
			@@ -1196,7 +1346,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if( !( Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())
			@@ -1227,7 +1377,6 @@
			platformJob.setEditDate(new Date());
			platformJobMapper.updateById(platformJob);

			//TODO 调起WMS 通知月台转移
			//存储操作日志
			savePlatformLog(Constants.PlatformJobLogType.TRANSFERING.getKey(),oldPlatformJob,platformJob,
			Constants.PlatformJobLogType.TRANSFERING.getInfo().replace("{data}",oldPlatform.getName()));
			@@ -1240,7 +1389,7 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())) {
			if(Objects.nonNull(platformJob.getDrivierPhone())) {
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobMove,platformJob);
			}

			@@ -1264,7 +1413,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}

			@@ -1293,7 +1442,7 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())){
			if(Objects.nonNull(platformJob.getDrivierPhone())){
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobOverNum,platformJob);
			}

			@@ -1317,7 +1466,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){
			@@ -1345,7 +1494,7 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())) {
			if(Objects.nonNull(platformJob.getDrivierPhone())) {
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobError,platformJob);
			}

			@@ -1368,7 +1517,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){
			@@ -1399,7 +1548,7 @@
			SmsConstants.platformJobContent.platformJobWorking,platform.getName(),null
			);
			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())) {
			if(Objects.nonNull(platformJob.getDrivierPhone())) {
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobWorking,platformJob);
			}
			//广播 led通知
			@@ -1434,7 +1583,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(! (Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())
			@@ -1457,6 +1606,12 @@
			//存储操作日志
			savePlatformLog(Constants.PlatformJobLogType.DONE.getKey(),oldPlatformJob,platformJob ,
			Constants.PlatformJobLogType.DONE.getInfo());

			//删除报警信息
			platformWarnEventMapper.update(new UpdateWrapper<PlatformWarnEvent>().lambda()
			.set(PlatformWarnEvent::getIsdeleted,Constants.ONE)
			.eq(PlatformWarnEvent::getPlatformId,platformJob.getId())
			);

			if(Constants.equalsInteger(platformJob.getType(),Constants.THREE)){
			// 外协车装货查询TMS 电子锁情况
			@@ -1468,19 +1623,21 @@
			Date date = new Date();
			List<String> codeList =new ArrayList<>();
			for(PlatformWmsDetail d : details){
			codeList.add(d.getIocode());
			codeList.add(d.getContractNum());
			}
			TmsLockStatusQueryRequest tmsLock = new TmsLockStatusQueryRequest();
			tmsLock.setContractNumbers(codeList);
			TmsBaseResponse<List<TmsLockStatusQueryResponse>> lockResult = tmsService.lockStatusQuery(tmsLock);
			if(lockResult!=null && lockResult.isSuccess()&& lockResult.getData()!=null ){
			if(lockResult!=null && lockResult.getCode()!=null && lockResult.getCode().equals("0")&& lockResult.getData()!=null ){
			for(TmsLockStatusQueryResponse s : lockResult.getData()){
			if(StringUtils.isBlank(s.getOutDate())){
			continue;
			}
			platformWmsDetailMapper.update(null,new UpdateWrapper<PlatformWmsDetail>().lambda()
			.eq(PlatformWmsDetail::getIocode,s.getContractNumber())
			.eq(PlatformWmsDetail::getContractNum,s.getContractNumber())
			.set(PlatformWmsDetail::getEditDate,date)
			.set(PlatformWmsDetail::getLockDate,s.getOutDate())
			.set(PlatformWmsDetail::getLockStatus,Constants.ONE)
			.eq(PlatformWmsDetail::getJobId,platformJob.getId())
			.eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO));
			}
			}
			@@ -1488,7 +1645,6 @@

			}else if(Constants.equalsInteger(platformJob.getType(),Constants.ONE) \|\| Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){
			//TODO 外协车卸货或者市公司车卸货则根据任务情况

			}


			@@ -1499,15 +1655,97 @@
			);

			//公众号模板消息
			if(Objects.nonNull(platformJob.getDriverId())) {
			if(Objects.nonNull(platformJob.getDrivierPhone())) {
			this.sendWxNotice(WxPlatConstants.platformJobContent.platformJobFinish,platformJob);
			}

			//广播 led通知
			platformJob.setPlatformName(platform.getName());
			this.broadcastAndLEed(platformJob,Constants.PlatformLedContent.DONE.getInfo(),
			this.broadcastAndLEed(platformJob,
			//Constants.PlatformLedContent.DONE.getInfo(),
			StringUtils.isBlank(platform.getLedContent())?Constants.PlatformLedContent.IDEL_CONTNET.getInfo():platform.getLedContent(),
			Constants.PlatformBroadcastContent.DONE.getInfo());
			return platformJob;
			}
			@Override
			public void checkWmsLockStatus(){
			List<PlatformWmsDetail> details = platformWmsDetailMapper.selectJoinList(PlatformWmsDetail.class,new MPJLambdaWrapper<PlatformWmsDetail>()
			.selectAll(PlatformWmsDetail.class)
			.leftJoin(PlatformJob.class,PlatformJob::getId,PlatformWmsDetail::getJobId)
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey())//查询已完成作业的
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.and(wr->{wr.isNull(PlatformWmsDetail::getLockStatus).or().eq(PlatformWmsDetail::getLockStatus,Constants.ZERO);})
			.eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO));
			if(details !=null && details.size()>0){
			Date date = new Date();
			List<String> codeList =new ArrayList<>();
			for(PlatformWmsDetail d : details){
			if(StringUtils.isNotBlank(d.getContractNum())){
			if(StringUtils.isNotBlank(d.getContractNum())){
			codeList.add(d.getContractNum());
			}
			}
			}
			List<Integer> jobIds = new ArrayList<>();
			if(codeList.size()>0){
			TmsLockStatusQueryRequest tmsLock = new TmsLockStatusQueryRequest();
			tmsLock.setContractNumbers(codeList);
			TmsBaseResponse<List<TmsLockStatusQueryResponse>> lockResult = tmsService.lockStatusQuery(tmsLock);
			if(lockResult!=null && lockResult.getCode()!=null && lockResult.getCode().equals("0")&& lockResult.getData()!=null ){
			for(TmsLockStatusQueryResponse s : lockResult.getData()){
			try {
			if(StringUtils.isBlank(s.getOutDate())){
			continue;
			}
			//异常处理，能处理一个是一个
			platformWmsDetailMapper.update(null,new UpdateWrapper<PlatformWmsDetail>().lambda()
			.eq(PlatformWmsDetail::getContractNum,s.getContractNumber())
			.set(PlatformWmsDetail::getEditDate,date)
			.set(PlatformWmsDetail::getLockDate,s.getOutDate())
			.set(PlatformWmsDetail::getLockStatus,Constants.ONE)
			.eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO));
			PlatformWmsDetail job = getJobByContractnumFromDetail(s.getContractNumber(),details);
			if(job != null){
			jobIds.add(job.getJobId());
			}
			}catch (Exception e){
			logger.error("=============更新电子锁状态信息异常："+e.getMessage());
			}
			}
			}
			}
			if(jobIds.size()>0){
			List<PlatformJob> list = platformJobMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()
			.selectAll(PlatformJob.class)
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey())
			.in(PlatformJob::getId,jobIds)
			);
			if(list!=null){
			for(PlatformJob platformJob : list){
			sendInPark(platformJob);//检查是否需要自动授权离园
			}
			}
			}
			}

			}

			private PlatformWmsJob getJobByContractnum(String contractNumber, List<PlatformWmsJob> details) {
			for(PlatformWmsJob d : details){
			if(StringUtils.equals(contractNumber,d.getContractNum())){
			return d;
			}
			}
			return null;
			}
			private PlatformWmsDetail getJobByContractnumFromDetail(String contractNumber, List<PlatformWmsDetail> details) {
			for(PlatformWmsDetail d : details){
			if(StringUtils.equals(contractNumber,d.getContractNum())){
			return d;
			}
			}
			return null;
			}


			@@ -1522,7 +1760,7 @@
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)){
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){
			@@ -1566,6 +1804,7 @@
			PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getPlatformId,platformDevice.getPlatformId())
			.eq(PlatformJob::getCarCodeBack,jobOperateDTO.getCarCodeBack())
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey())
			.last(" limit 1 ")
			);
			@@ -1777,6 +2016,7 @@
			.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 pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.CALLED.getKey()+" order by pl.CREATE_DATE desc limit 1 ) as newCallDate ")
			.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 ")
			.select(" (select GROUP_CONCAT(distinct(tt.contract_num )) from platform_wms_detail tt where tt.isdeleted=0 and tt.contract_num is not null and tt.job_id=t.id )as wmsContractNum")
			.selectAs(Platform::getName,PlatformJob::getPlatformName)
			.selectAs(Platform::getWorkRate,PlatformJob::getWorkRate)
			.selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName)
			@@ -1823,16 +2063,16 @@
			);
			//查询今日完成任务
			platformOrderNumByDateResponse.setDoneNum(
			platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda()
			platformJobMapper.selectCount(new MPJLambdaWrapper<PlatformJob>()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.like(PlatformJob::getDoneDate,queryDateStr)
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey())
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()
			,Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()
			,Constants.PlatformJobStatus.LEAVED.getKey())
			)
			);
			return platformOrderNumByDateResponse;
			}



			@Override
			public List<PlatformDataListResponse> platformWorkingDataList(PlatformDataListRequest param){
			@@ -2090,8 +2330,11 @@
			List<PlatformJob> calledList = platformJobList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())).collect(Collectors.toList());
			largeScreenDataVO.setWaitWorkList(calledList);
			}
			// String u = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.BIGSCREEN_UUID);
			// if(StringUtils.isBlank(u)){
			String u = UUID.randomUUID().toString();
			redisTemplate.opsForValue().set(Constants.RedisKeys.BIGSCREEN_UUID,u,3, TimeUnit.MINUTES);
			// }
			String url = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),Constants.WxUrlParams.BISCREEN_CODE,u);
			largeScreenDataVO.setQrCode(url);
			largeScreenDataVO.setAttention(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_ATTENTION).getCode());
			@@ -2204,163 +2447,431 @@


			/**
			* 累计出库量统计 - 大屏
			* @param data
			* 更换月台分钟
			* @param param
			*/
			@Override
			public void wholeProvinceCenterData(WholeProvinceBoardVO data){
			// //累计本年度出库量
			// List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED)
			// .isNotNull(PlatformJob::getDoneDate)
			// .in(PlatformJob::getType,Constants.platformJobType.wxczh,Constants.platformJobType.zyczh)
			// .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy"))
			// );
			// data.setYearOutTotal(platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
			// data.setYearOutTimes(platformJobList.size());
			//
			//
			// List<PlatformJob> platformJobsMonthList = platformJobList.stream().filter(i->DateUtil.getFomartDate(i.getDoneDate(),"yyyy-MM").equals(DateUtil.getFomartDate(new Date(),"yyyy-MM"))).collect(Collectors.toList());
			// data.setMonthOutTotal(platformJobsMonthList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
			// data.setMonthOutTimes(platformJobsMonthList.size());
			// String beforYear = DateUtil.getBeforYear(new Date(),1);
			//
			// //累计本年度出库量
			// List<PlatformJob> beforYearPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED)
			// .isNotNull(PlatformJob::getDoneDate)
			// .in(PlatformJob::getType,Constants.platformJobType.wxczh,Constants.platformJobType.zyczh)
			// .like( PlatformJob::getDoneDate, beforYear.substring(0,4))
			// );
			//
			// List<PlatformJob> beforPlatformJobsMonthList = platformJobList.stream().filter(i->DateUtil.getFomartDate(i.getDoneDate(),"yyyy-MM").equals(beforYear.substring(0,7))).collect(Collectors.toList());
			// //同比数据
			// data.setYearOutTotalOnYear(beforYearPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
			// data.setMonthOutTotalOnYear(beforPlatformJobsMonthList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
			//
			public void changPlatformGroup(PlatformJob param, LoginUserInfo loginUser){
			if(param.getId() ==null \|\| param.getPlatformGroupId()==null) {
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob model = platformJobMapper.selectById(param.getId());
			if(model ==null \|\| Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(Constants.equalsInteger(model.getType(),Constants.platformJobType.sgscxh)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"【市公司外协车卸货】作业类型不支持月台组切换");
			}
			// WAIT_CONFIRM(0, "待确认","待确认" ),
			// WART_SIGN_IN(1, "待签到","待签到" ),
			// WAIT_CALL(2, "已签到","已签到"),
			if(!Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CONFIRM.getKey())
			&&!Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())
			&&!Constants.equalsInteger(model.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转，不支持月台组切换！");
			}
			PlatformGroup group = platformGroupMapper.selectById(param.getPlatformGroupId());
			if(Objects.isNull(group)\|\| Constants.equalsInteger(group.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台组信息");
			}
			if(Constants.equalsInteger(model.getType(),Constants.platformJobType.zycxh)
			\|\|Constants.equalsInteger(model.getType(),Constants.platformJobType.wxcxh)){
			if( ! Constants.equalsInteger(group.getType(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该作业只能在【安泰物流卸货】类型的月台组下作业");
			}
			}
			if(Constants.equalsInteger(model.getType(),Constants.platformJobType.zyczh)
			\|\|Constants.equalsInteger(model.getType(),Constants.platformJobType.wxczh)){
			if( ! Constants.equalsInteger(group.getType(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该作业只能在【安泰物流装货】类型的月台组下作业");
			}
			}
			if(Constants.equalsInteger(model.getType(),Constants.platformJobType.sgscxh)
			&& !Constants.equalsInteger(group.getType(),Constants.TWO)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该作业只能在【市公司卸货】类型的月台组下作业");
			}
			PlatformJob platformJob = new PlatformJob();
			BeanUtils.copyProperties(model,platformJob);
			platformJob.setPlatformGroupId(param.getPlatformGroupId());
			platformJob.setEditDate(new Date());
			platformJob.setEditor(loginUser.getId());
			int flag = platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
			.set(PlatformJob::getEditDate,platformJob.getEditDate())
			.set(PlatformJob::getEditor,platformJob.getEditor())
			.set(PlatformJob::getPlatformGroupId,param.getPlatformGroupId())
			.set(PlatformJob::getPlatformId,null)//置空分配的月台信息
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(),
			Constants.PlatformJobStatus.WART_SIGN_IN.getKey(),
			Constants.PlatformJobStatus.WAIT_CALL.getKey())
			.eq(PlatformJob::getId,param.getId()));
			//存储操作日志
			savePlatformLog(Constants.PlatformJobLogType.CHANGE_GROUP.getKey(),model,platformJob,
			Constants.PlatformJobLogType.CHANGE_GROUP.getInfo().replace("{data}",param.getPlatformGroupName()).replace("{data1}",group.getName()));
			}
			/**
			* 手动完成作业
			* @param jobIdList
			*/
			@Override
			public void dealJobFinish(List<Integer> jobIdList,LoginUserInfo loginUserInfo){
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(jobIdList)){
			List<PlatformJob> platformJobList = platformJobMapper.selectList(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey()
			,Constants.PlatformJobStatus.WART_SIGN_IN.getKey()
			,Constants.PlatformJobStatus.WAIT_CALL.getKey())
			.in(PlatformJob::getId,jobIdList)
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){
			platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
			.set(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey())
			.set(PlatformJob::getDoneDate,new Date())
			.set(PlatformJob::getEditor,loginUserInfo.getId())
			.in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey(),Constants.PlatformJobStatus.WAIT_CALL.getKey())
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.in(PlatformJob::getId,platformJobList.stream().map(i->i.getId()).collect(Collectors.toList())));
			}

			}


			}

			@Override
			public void centerDataForInOut(WholeProvinceBoardVO data){
			// //今日完成的出入库所有数据
			// List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED)
			// .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd"))
			// );
			// //今日之前所有未完成的出入库数据 - WMS推送
			// List<PlatformJob> wmsPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED
			// ,Constants.PlatformJobStatus.CANCEL)
			// .eq(PlatformJob::getOrigin ,Constants.ONE)
			// .le(PlatformJob::getCreateDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") +" 23:59:59")
			// );
			// //今日之前所有未完成的出入库数据 - 预约数据
			// List<PlatformJob> bookPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED
			// ,Constants.PlatformJobStatus.CANCEL)
			// .eq(PlatformJob::getOrigin ,Constants.ONE)
			// .le(PlatformJob::getArriveDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") +" 23:59:59")
			// );
			//
			// BigDecimal finishOutTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// BigDecimal unFinishWmsOutTotal = wmsPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// BigDecimal unFinishBookOutTotal = bookPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			//
			// BigDecimal finishInTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// BigDecimal unFinishWmsInTotal = wmsPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// BigDecimal unFinishBookInTotal = bookPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			//
			// data.setOutTotal(finishOutTotal);
			// data.setOutPlanTotal(finishOutTotal.add(unFinishWmsOutTotal).add(unFinishBookOutTotal));
			//
			// data.setInTotal(finishInTotal);
			// data.setInPlanTotal(finishInTotal.add(unFinishWmsInTotal).add(unFinishBookInTotal));
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public PlatformJob restoreWork(JobOperateDTO jobOperateDTO){
			if(Objects.isNull(jobOperateDTO)
			\|\| Objects.isNull(jobOperateDTO.getJobId())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId());
			if(Objects.isNull(platformJob)\|\|Constants.equalsInteger(platformJob.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.EXCEPTION.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！");
			}
			Platform platform = platformJoinMapper.selectById(platformJob.getPlatformId());
			if(Objects.isNull(platform)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台信息");
			}
			PlatformJob oldPlatformJob = new PlatformJob();
			BeanUtils.copyProperties(platformJob,oldPlatformJob);
			if(Objects.isNull(platformJob.getStartDate())){
			platformJob.setStartDate(new Date());
			}
			platformJob.setStatus(Constants.PlatformJobStatus.WORKING.getKey());
			platformJob.setEditDate(new Date());
			platformJobMapper.updateById(platformJob);

			//存储操作日志
			savePlatformLog(Constants.PlatformJobLogType.WORKING.getKey(),oldPlatformJob,platformJob,
			Constants.PlatformJobLogType.WORKING.getInfo().replace("{data}",platform.getName()));
			return platformJob;
			}




			@Override
			public void centerDataOutInRata(WholeProvinceBoardVO data){
			// //累计本月度所有操作量
			// List<PlatformJob> platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()
			// .selectAll(PlatformJob.class)
			// .select(" ( select ifnull(sum(p.param3),0) from platform_log p where p.obj_id = platform_job.id ) ",PlatformJob::getWorkTime)
			// .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED)
			// .isNotNull(PlatformJob::getDoneDate)
			// .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM"))
			// );
			//
			// //获取本月所有出库量
			// BigDecimal monthOutTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// Long monthOutWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
			// BigDecimal monthInTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// Long monthInWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
			//
			// data.setMonthOutRata(BigDecimal.ZERO);
			// //月度出库效率
			// if(Objects.nonNull(monthOutTotal) && Objects.nonNull(monthOutWorkTotal) && monthOutWorkTotal>0L && monthOutTotal.compareTo(BigDecimal.ZERO) > 0){
			// BigDecimal workTotal = new BigDecimal(monthOutWorkTotal);
			// data.setMonthOutRata(monthOutTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
			// }
			//
			// //月度入库效率
			//
			// data.setMonthInRata(BigDecimal.ZERO);
			// if(Objects.nonNull(monthInTotal) && Objects.nonNull(monthInWorkTotal) && monthInWorkTotal>0L && monthInTotal.compareTo(BigDecimal.ZERO) > 0){
			// BigDecimal workTotal = new BigDecimal(monthInWorkTotal);
			// data.setMonthInRata(monthInTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
			// }
			//
			//
			//
			// List<PlatformJob> dayPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			// .lambda()
			// .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
			// ,Constants.PlatformJobStatus.AUTHED_LEAVE
			// ,Constants.PlatformJobStatus.LEAVED)
			// .isNotNull(PlatformJob::getDoneDate)
			// .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd"))
			// );
			//
			// BigDecimal dayOutTotal = dayPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// Long dayOutWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)\|\|i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
			// BigDecimal dayInTotal = dayPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
			// Long dayInWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)\|\|i.getType().equals(Constants.platformJobType.wxcxh)\|\|i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
			//
			// data.setDayOutRata(BigDecimal.ZERO);
			// //日出库效率
			// if(Objects.nonNull(dayOutTotal) && Objects.nonNull(dayOutWorkTotal) && dayOutWorkTotal>0L && dayOutTotal.compareTo(BigDecimal.ZERO) > 0){
			// BigDecimal workTotal = new BigDecimal(dayOutWorkTotal);
			// data.setDayOutRata(dayOutTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
			// }
			// //日入库效率
			// data.setDayInRata(BigDecimal.ZERO);
			// if(Objects.nonNull(dayInTotal) && Objects.nonNull(dayInWorkTotal) && dayInWorkTotal>0L && dayInTotal.compareTo(BigDecimal.ZERO) > 0){
			// BigDecimal workTotal = new BigDecimal(dayInWorkTotal);
			// data.setMonthInRata(dayInTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
			// }
			public void autoPlatformCallCar(WmsService wmsService){
			//查询当前开启的月台数据
			List<PlatformGroup> allPlatformGroup = platformGroupMapper.selectList(new QueryWrapper<PlatformGroup>().lambda().eq(PlatformGroup::getStatus,Constants.ZERO)
			.eq(PlatformGroup::getIsdeleted,Constants.ZERO).eq(PlatformGroup::getAutoCall,Constants.ONE)
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(allPlatformGroup)){
			return;
			}
			//过滤当前时间段不在时间内的月台组 AUTO_CALL_END_TIME AUTO_CALL_START_TIME
			Integer nowHm = Integer.valueOf(DateUtil.getFomartDate(new Date(),"HH:mm").replaceAll(":",""));
			List<PlatformGroup> autoCallGroup = allPlatformGroup.stream().filter(
			i->StringUtils.isNotBlank(i.getAutoCallStartTime())&&StringUtils.isNotBlank(i.getAutoCallEndTime())
			&& Integer.valueOf(i.getAutoCallStartTime().replaceAll(":","")) < nowHm
			&& Integer.valueOf(i.getAutoCallEndTime().replaceAll(":","")) > nowHm
			).collect(Collectors.toList());
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(autoCallGroup)){
			return;
			}
			//查询所有月台
			List<Platform> platformList = platformJoinMapper.selectList(new QueryWrapper<Platform>()
			.lambda()
			.eq(Platform::getIsdeleted,Constants.ZERO)
			.eq(Platform::getStatus,Constants.ZERO)
			.in(Platform::getId,autoCallGroup.stream().map(i->i.getId()).collect(Collectors.toList()))
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(platformList)){
			return;
			}
			//循环所有自动叫号月台
			for (PlatformGroup platformGroup:autoCallGroup) {
			List<Platform> platforms = platformList.stream().filter(i->Constants.equalsInteger(i.getGroupId(),platformGroup.getId())).collect(Collectors.toList());
			if(CollectionUtils.isEmpty(platforms)){
			continue;
			}
			Boolean isDefaul = false;
			if(Constants.equalsInteger(platforms.size(),Constants.ONE)){
			isDefaul = true;
			}else{
			//查询月台组下的月台是否同时存在整托和散托月台
			if((
			((platforms.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)).collect(Collectors.toList()).size()>Constants.ZERO)?Constants.ONE:Constants.ZERO)
			+
			((platforms.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList()).size()>Constants.ZERO)?Constants.ONE:Constants.ZERO)
			)==Constants.ONE
			){
			isDefaul = true;
			}
			}
			for (Platform platform:platforms) {

			//月台叫号入园数量
			Integer workingNum = platform.getWorkingNum();
			//查询当前月台是否存在月台叫号数据如果大于等于可叫号数量则跳过
			Integer workNum = platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getPlatformId,platform.getId())
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey())).intValue();
			if(workNum>=workingNum){
			continue;
			};

			//查询月台下可以进行叫号的数据
			List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			.lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getPlatformGroupId, platformGroup.getId())
			.apply(" ( " +
			" ( t.`STATUS` = "+Constants.PlatformJobStatus.WAIT_CALL.getKey()+" and t.PLATFORM_GROUP_ID = "+platformGroup.getId()+" )" +
			" or " +
			" (t.`STATUS` = "+Constants.PlatformJobStatus.IN_WAIT.getKey()+" and and t.PLATFORM_ID = "+platform.getId()+" ) " +
			" or " +
			" (t.`STATUS` = "+Constants.PlatformJobStatus.TRANSFERING.getKey()+" and t.PLATFORM_ID = "+platform.getId()+" ) " +
			") "
			)
			//排序方式月台作业类型（转移中 >叫号入园）> 加急 > 签到时间
			.orderByDesc(PlatformJob::getStatus,PlatformJob::getUrgeTime)
			.orderByAsc(PlatformJob::getSignDate));
			if(CollectionUtils.isEmpty(platformJobList)){
			continue;
			}
			for (int i = 0; i < workingNum - workNum ; i++) {
			PlatformJob platformJob = this.getAutoCallJob(platformJobList,platform,isDefaul,platformGroup);
			JobOperateDTO jobOperateDTO = new JobOperateDTO();
			jobOperateDTO.setJobId(platformJob.getId());
			PlatformJob callPlatformJob = this.platformCallNumber(jobOperateDTO);
			platformJobList = platformJobList.stream().filter(j->!Constants.equalsInteger(j.getId(),platformJob.getId())).collect(Collectors.toList());
			try{
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
			this.sendInPark(platformJob);
			}
			if(!Constants.equalsInteger(platformJob.getType(),Constants.FOUR)
			&& StringUtils.isNotBlank(platformJob.getBillCode())){
			//通知WMS绑定月台信息
			wmsService.orderPlatformBind(callPlatformJob);
			}
			}catch (Exception e){
			logger.error("月台自动叫号权限下发失败：{}"+JSONObject.toJSONString(platform));
			}
			}
			}
			}
			}



			public void autoCallInParkCar(WmsService wmsService){
			//查询当前开启的月台数据
			List<PlatformGroup> allPlatformGroup = platformGroupMapper.selectList(new QueryWrapper<PlatformGroup>().lambda().eq(PlatformGroup::getStatus,Constants.ZERO)
			.eq(PlatformGroup::getIsdeleted,Constants.ZERO).eq(PlatformGroup::getAutoCall,Constants.ONE)
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(allPlatformGroup)){
			return;
			}
			//过滤当前时间段不在时间内的月台组 AUTO_CALL_END_TIME AUTO_CALL_START_TIME
			Integer nowHm = Integer.valueOf(DateUtil.getFomartDate(new Date(),"HH:mm").replaceAll(":",""));
			List<PlatformGroup> autoCallGroup = allPlatformGroup.stream().filter(
			i->StringUtils.isNotBlank(i.getAutoCallStartTime())&&StringUtils.isNotBlank(i.getAutoCallEndTime())
			&& Integer.valueOf(i.getAutoCallStartTime().replaceAll(":","")) < nowHm
			&& Integer.valueOf(i.getAutoCallEndTime().replaceAll(":","")) > nowHm
			).collect(Collectors.toList());
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(autoCallGroup)){
			return;
			}
			//查询所有月台
			List<Platform> platformList = platformJoinMapper.selectList(new QueryWrapper<Platform>()
			.lambda()
			.eq(Platform::getIsdeleted,Constants.ZERO)
			.eq(Platform::getStatus,Constants.ZERO)
			.in(Platform::getId,autoCallGroup.stream().map(i->i.getId()).collect(Collectors.toList()))
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(platformList)){
			return;
			}
			//循环所有自动叫号月台
			for (PlatformGroup platformGroup:autoCallGroup) {
			List<Platform> platforms = platformList.stream().filter(i->Constants.equalsInteger(i.getGroupId(),platformGroup.getId())).collect(Collectors.toList());
			if(CollectionUtils.isEmpty(platforms)){
			continue;
			}
			Boolean isDefaul = false;
			if(Constants.equalsInteger(platforms.size(),Constants.ONE)){
			isDefaul = true;
			}else{
			//查询月台组下的月台是否同时存在整托和散托月台
			if((((platforms.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)).collect(Collectors.toList()).size()>Constants.ZERO)?Constants.ONE:Constants.ZERO)
			+
			((platforms.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList()).size()>Constants.ZERO)?Constants.ONE:Constants.ZERO)
			)==Constants.ONE
			){
			isDefaul = true;
			}
			}
			for (Platform platform:platforms) {
			//月台叫号入园数量
			Integer callReadyNum = platform.getCallReadyNum();
			//查询当前月台是否存在待开始作业数据如果存在则直接跳过当前月台
			Integer callNum = platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getPlatformId,platform.getId())
			.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey())).intValue();
			if(callNum>=callReadyNum){
			continue;
			};
			//查询月台下可以进行叫号的数据
			List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
			.lambda()
			.eq(PlatformJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformJob::getPlatformGroupId, platformGroup.getId())
			.apply(" t.`STATUS` = "+Constants.PlatformJobStatus.WAIT_CALL.getKey()+" and t.PLATFORM_GROUP_ID = "+platformGroup.getId()+" ) ")
			//排序方式月台作业类型（异常挂起>叫号入园）> 加急 > 签到时间
			.orderByDesc(PlatformJob::getStatus,PlatformJob::getUrgeTime)
			.orderByAsc(PlatformJob::getSignDate));
			if(CollectionUtils.isEmpty(platformJobList)){
			continue;
			}
			for (int i = 0; i < callReadyNum - callNum ; i++) {
			PlatformJob platformJob = this.getAutoCallJob(platformJobList,platform,isDefaul,platformGroup);
			JobOperateDTO jobOperateDTO = new JobOperateDTO();
			jobOperateDTO.setJobId(platformJob.getId());
			jobOperateDTO.setPlatformId(platform.getId());
			PlatformJob callPlatformJob = this.platformInPark(jobOperateDTO);
			platformJobList = platformJobList.stream().filter(j->!Constants.equalsInteger(j.getId(),platformJob.getId())).collect(Collectors.toList());
			try{
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){
			this.sendInPark(platformJob);
			}
			if(!Constants.equalsInteger(platformJob.getType(),Constants.FOUR)
			&& StringUtils.isNotBlank(platformJob.getBillCode())){
			//通知WMS绑定月台信息
			wmsService.orderPlatformBind(callPlatformJob);
			}
			}catch (Exception e){
			logger.error("自动叫号入园权限下发失败：{}"+JSONObject.toJSONString(platform));
			}
			}
			}
			}
			}



			/**
			* 月台分配任务
			* @param platformJobList 所有月台下可以分配的任务
			* @param platform 月台
			* @param isDefaul 是否只有单类月台或者只有一个月台 true / false
			* @param platformGroup 月台组
			* @return
			*/
			public PlatformJob getAutoCallJob(List<PlatformJob> platformJobList, Platform platform,Boolean isDefaul,PlatformGroup platformGroup){
			if(isDefaul){
			//月台下只有一类月台直接返回第一个任务
			return platformJobList.get(Constants.ZERO);
			}
			for (PlatformJob platformJob:platformJobList) {
			//叫号入园或者异常挂起则直接进行叫号
			if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.EXCEPTION.getKey())
			\|\| Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey())){
			return platformJob;
			}
			//根据月台组判断叫号逻辑
			// 新库出库自动叫号规则
			// 1）如果单个运单仅包含单一品规，则自动分配至在整托盘月台进行作业；
			// 2）如果单个运单包含两个及以上的品规，则需要判断是否存在单个品规超过 500 件且该品规数量占整个运单任务量的 60%及以上，则自动分配至在整托盘月台进行月台；
			// 3）如若不满足以上两点，则自动分配至散件月台进行作业；
			if(Constants.equalsInteger(platformGroup.getType(),Constants.ONE)){
			//装货月台 - 出库
			if(Objects.nonNull(platformJob.getWmsId())){
			// WM推送任务
			List<PlatformWmsDetail> platformWmsDetailList = platformWmsDetailMapper.selectList(new QueryWrapper<PlatformWmsDetail>().lambda()
			.eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO)
			.eq(PlatformWmsDetail::getJobId,platformJob.getId()));
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(platformWmsDetailList)){
			continue;
			}
			//WMS推送任务运单仅包含单一品规（商品类型只有一类），则自动分配至在整托盘月台进行作业；
			List<String> materialNameList = platformWmsDetailList.stream().map(i->i.getMaterialName()).collect(Collectors.toList());
			Set<String> materialNameSet = new HashSet<>(materialNameList);
			if(Constants.equalsInteger(materialNameSet.size(),Constants.ONE)&&Constants.equalsInteger(platform.getType(),Constants.ZERO)){
			//单一品类且当前循环月台为整托盘月台
			return platformJob;
			}else if(!Constants.equalsInteger(materialNameSet.size(),Constants.ONE)){
			if(Constants.equalsInteger(platform.getType(),Constants.ZERO)){
			//非单一品类
			//如果单个运单包含两个及以上的品规，则需要判断是否存在单个品规超过 500 件且该品规数量占整个运单任务量的 60%及以上，则自动分配至在整托盘月台进行月台；
			BigDecimal total = platformWmsDetailList.stream().map(i->i.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add);
			BigDecimal compareTotal = new BigDecimal("500");
			if((total.multiply(new BigDecimal("0.6")).compareTo(compareTotal)>Constants.ZERO)){
			compareTotal = total.multiply(new BigDecimal("0.6"));
			}
			for (String name:materialNameSet) {
			BigDecimal quanlity = platformWmsDetailList.stream().filter(i->i.getMaterialName().equals(name)).map(i->i.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add);
			if(quanlity.compareTo(compareTotal)>Constants.ZERO){
			//超过规定数量且当前月台为整托月台
			return platformJob;
			}
			}
			}
			}
			//循环WMS任务未分配至整托盘月台则直接分配到散托盘月台
			if(Constants.equalsInteger(platform.getType(),Constants.ONE)){
			return platformJob;
			}
			}else{
			//物流车预约的任务直接分配散托盘月台
			if(Constants.equalsInteger(platform.getType(),Constants.TWO)){
			return platformJob;
			}
			}
			}else{
			//卸货月台 - 入库
			// 1）发货地为指定地区，如省外/芜湖，则自动分配至散件月台进行作业；（联营加工情况）
			// 2）其它场景，均自动分配至整托盘月台进行作业
			if(Objects.nonNull(platformJob.getWmsId())){
			PlatformWmsJob platformWmsJob = platformWmsJobMapper.selectOne(new QueryWrapper<PlatformWmsJob>().lambda()
			.eq(PlatformWmsJob::getIsdeleted,Constants.ZERO)
			.eq(PlatformWmsJob::getJobId,platformJob.getId())
			.orderByDesc(PlatformWmsJob::getId)
			.last(" limit 1")
			);
			if(Objects.isNull(platformWmsJob)){
			continue;
			}
			//TODO 暂无入库的数据
			if(platformWmsJob.getCarrierName().equals("1") && Constants.equalsInteger(platform.getType(),Constants.ONE)){
			return platformJob;
			}
			if(Constants.equalsInteger(platform.getType(),Constants.ZERO)){
			return platformJob;
			}
			}else{
			//物流车预约的任务直接分配散托盘月台
			if(Constants.equalsInteger(platform.getType(),Constants.ZERO)){
			return platformJob;
			}
			}
			}
			}
			return null;
			}

			}