package com.doumee.service.business.impl; import com.alibaba.fastjson.JSONObject; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; 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.PositionUtil; import com.doumee.core.utils.Utils; import com.doumee.dao.business.*; import com.doumee.dao.business.join.PlatformJobJoinMapper; import com.doumee.dao.business.join.PlatformJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.openapi.request.*; import com.doumee.dao.openapi.response.*; import com.doumee.dao.system.model.SystemUser; import com.doumee.dao.web.reqeust.*; import com.doumee.dao.web.response.DriverHomeVO; import com.doumee.dao.web.response.LineUpVO; import com.doumee.dao.web.response.PlatformWorkVO; import com.doumee.service.business.PlatformJobService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; 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.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.RequestBody; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * 月台调度作业信息表Service实现 * @author 江蹄蹄 * @date 2024/06/28 10:03 */ @Service public class PlatformJobServiceImpl implements PlatformJobService { @Autowired private PlatformJobMapper platformJobMapper; @Autowired private PlatformDeviceMapper platformDeviceMapper; @Autowired private PlatformJobJoinMapper platformJobJoinMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private PlatformWmsDetailMapper platformWmsDetailMapper; @Autowired private PlatformJoinMapper platformJoinMapper; @Autowired private PlatformLogMapper platformLogMapper; @Autowired private PlatformWmsJobMapper platformWmsJobMapper; @Autowired private PlatformGroupMapper platformGroupMapper; @Autowired private PlatformShowParamMapper platformShowParamMapper; @Override public Integer create(PlatformJob platformJob) { platformJobMapper.insert(platformJob); return platformJob.getId(); } @Override public void deleteById(Integer id) { platformJobMapper.deleteById(id); } @Override public void delete(Integer id) { platformJobMapper.update(null,new UpdateWrapper().lambda() .set(PlatformJob::getIsdeleted,Constants.ONE) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CANCEL.getKey()) .eq(PlatformJob::getId,id)); } @Override public void delete(PlatformJob platformJob) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(platformJob); platformJobMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } platformJobMapper.deleteBatchIds(ids); } @Override public void updateById(PlatformJob platformJob) { platformJobMapper.updateById(platformJob); } @Override public void updateByIdInBatch(List platformJobs) { if (CollectionUtils.isEmpty(platformJobs)) { return; } for (PlatformJob platformJob: platformJobs) { this.updateById(platformJob); } } @Override public PlatformJob findById(Integer id) { return platformJobMapper.selectById(id); } @Override public PlatformJob findOne(PlatformJob platformJob) { QueryWrapper wrapper = new QueryWrapper<>(platformJob); return platformJobMapper.selectOne(wrapper); } @Override public List findList(PlatformJob platformJob) { QueryWrapper wrapper = new QueryWrapper<>(platformJob); return platformJobMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName) .selectAs(SystemUser::getUsername,PlatformJob::getOutUserName) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) .leftJoin(SystemUser.class,SystemUser::getId,PlatformJob::getOutUserId) .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())) .le(pageWrap.getModel().getCreateDate() != null, PlatformJob::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())) .eq(pageWrap.getModel().getEditor() != null, PlatformJob::getEditor, pageWrap.getModel().getEditor()) .ge(pageWrap.getModel().getEditDate() != null, PlatformJob::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())) .le(pageWrap.getModel().getEditDate() != null, PlatformJob::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())) .eq(pageWrap.getModel().getIsdeleted() != null, PlatformJob::getIsdeleted, pageWrap.getModel().getIsdeleted()) .eq(pageWrap.getModel().getName() != null, PlatformJob::getName, pageWrap.getModel().getName()) .eq(pageWrap.getModel().getRemark() != null, PlatformJob::getRemark, pageWrap.getModel().getRemark()) .eq(pageWrap.getModel().getStatus() != null, PlatformJob::getStatus, pageWrap.getModel().getStatus()) .eq(pageWrap.getModel().getSortnum() != null, PlatformJob::getSortnum, pageWrap.getModel().getSortnum()) .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().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()) .ge(pageWrap.getModel().getSignDate() != null, PlatformJob::getSignDate, Utils.Date.getStart(pageWrap.getModel().getSignDate())) .le(pageWrap.getModel().getSignDate() != null, PlatformJob::getSignDate, Utils.Date.getEnd(pageWrap.getModel().getSignDate())) .eq(pageWrap.getModel().getSingType() != null, PlatformJob::getSingType, pageWrap.getModel().getSingType()) .eq(pageWrap.getModel().getSignDistance() != null, PlatformJob::getSignDistance, pageWrap.getModel().getSignDistance()) .eq(pageWrap.getModel().getPlatformNames() != null, PlatformJob::getPlatformNames, pageWrap.getModel().getPlatformNames()) .eq(pageWrap.getModel().getPlatforms() != null, PlatformJob::getPlatforms, pageWrap.getModel().getPlatforms()) .eq(pageWrap.getModel().getPlatformId() != null, PlatformJob::getPlatformId, pageWrap.getModel().getPlatformId()) .ge(pageWrap.getModel().getInwaitDate() != null, PlatformJob::getInwaitDate, Utils.Date.getStart(pageWrap.getModel().getInwaitDate())) .le(pageWrap.getModel().getInwaitDate() != null, PlatformJob::getInwaitDate, Utils.Date.getEnd(pageWrap.getModel().getInwaitDate())) .eq(pageWrap.getModel().getInwaitUserId() != null, PlatformJob::getInwaitUserId, pageWrap.getModel().getInwaitUserId()) .ge(pageWrap.getModel().getCallDate() != null, PlatformJob::getCallDate, Utils.Date.getStart(pageWrap.getModel().getCallDate())) .le(pageWrap.getModel().getCallDate() != null, PlatformJob::getCallDate, Utils.Date.getEnd(pageWrap.getModel().getCallDate())) .eq(pageWrap.getModel().getCallUserId() != null, PlatformJob::getCallUserId, pageWrap.getModel().getCallUserId()) .eq(pageWrap.getModel().getCallInfo() != null, PlatformJob::getCallInfo, pageWrap.getModel().getCallInfo()) .ge(pageWrap.getModel().getStartDate() != null, PlatformJob::getStartDate, Utils.Date.getStart(pageWrap.getModel().getStartDate())) .le(pageWrap.getModel().getStartDate() != null, PlatformJob::getStartDate, Utils.Date.getEnd(pageWrap.getModel().getStartDate())) .ge(pageWrap.getModel().getDoneDate() != null, PlatformJob::getDoneDate, Utils.Date.getStart(pageWrap.getModel().getDoneDate())) .le(pageWrap.getModel().getDoneDate() != null, PlatformJob::getDoneDate, Utils.Date.getEnd(pageWrap.getModel().getDoneDate())) .ge(pageWrap.getModel().getErrorDate() != null, PlatformJob::getErrorDate, Utils.Date.getStart(pageWrap.getModel().getErrorDate())) .le(pageWrap.getModel().getErrorDate() != null, PlatformJob::getErrorDate, Utils.Date.getEnd(pageWrap.getModel().getErrorDate())) .eq(pageWrap.getModel().getErrorUserId() != null, PlatformJob::getErrorUserId, pageWrap.getModel().getErrorUserId()) .eq(pageWrap.getModel().getErrorInfo() != null, PlatformJob::getErrorInfo, pageWrap.getModel().getErrorInfo()) .ge(pageWrap.getModel().getTransPlatformDate() != null, PlatformJob::getTransPlatformDate, Utils.Date.getStart(pageWrap.getModel().getTransPlatformDate())) .le(pageWrap.getModel().getTransPlatformDate() != null, PlatformJob::getTransPlatformDate, Utils.Date.getEnd(pageWrap.getModel().getTransPlatformDate())) .eq(pageWrap.getModel().getTransPlatformUserId() != null, PlatformJob::getTransPlatformUserId, pageWrap.getModel().getTransPlatformUserId()) .eq(pageWrap.getModel().getTransPlatformInfo() != null, PlatformJob::getTransPlatformInfo, pageWrap.getModel().getTransPlatformInfo()) .ge(pageWrap.getModel().getInDate() != null, PlatformJob::getInDate, Utils.Date.getStart(pageWrap.getModel().getInDate())) .le(pageWrap.getModel().getInDate() != null, PlatformJob::getInDate, Utils.Date.getEnd(pageWrap.getModel().getInDate())) .ge(pageWrap.getModel().getOutDate() != null, PlatformJob::getOutDate, Utils.Date.getStart(pageWrap.getModel().getOutDate())) .le(pageWrap.getModel().getOutDate() != null, PlatformJob::getOutDate, Utils.Date.getEnd(pageWrap.getModel().getOutDate())) .eq(pageWrap.getModel().getOutType() != null, PlatformJob::getOutType, pageWrap.getModel().getOutType()) .eq(pageWrap.getModel().getOutHkstatus() != null, PlatformJob::getOutHkstatus, pageWrap.getModel().getOutHkstatus()) .ge(pageWrap.getModel().getOutHkdate() != null, PlatformJob::getOutHkdate, Utils.Date.getStart(pageWrap.getModel().getOutHkdate())) .le(pageWrap.getModel().getOutHkdate() != null, PlatformJob::getOutHkdate, Utils.Date.getEnd(pageWrap.getModel().getOutHkdate())) .eq(pageWrap.getModel().getOutHkinfo() != null, PlatformJob::getOutHkinfo, pageWrap.getModel().getOutHkinfo()) .eq(pageWrap.getModel().getInHkstatus() != null, PlatformJob::getInHkstatus, pageWrap.getModel().getInHkstatus()) .eq(pageWrap.getModel().getNHkinfo() != null, PlatformJob::getNHkinfo, pageWrap.getModel().getNHkinfo()) .ge(pageWrap.getModel().getInHkdate() != null, PlatformJob::getInHkdate, Utils.Date.getStart(pageWrap.getModel().getInHkdate())) .le(pageWrap.getModel().getInHkdate() != null, PlatformJob::getInHkdate, Utils.Date.getEnd(pageWrap.getModel().getInHkdate())) .eq(pageWrap.getModel().getType() != null, PlatformJob::getType, pageWrap.getModel().getType()) .like(pageWrap.getModel().getCarCodeFront() != null, PlatformJob::getCarCodeFront, pageWrap.getModel().getCarCodeFront()) .like(pageWrap.getModel().getCarCodeBack() != null, PlatformJob::getCarCodeBack, pageWrap.getModel().getCarCodeBack()) .eq(pageWrap.getModel().getCompanyId() != null, PlatformJob::getCompanyId, pageWrap.getModel().getCompanyId()) .eq(pageWrap.getModel().getCompanyNamePath() != null, PlatformJob::getCompanyNamePath, pageWrap.getModel().getCompanyNamePath()) .ge(pageWrap.getModel().getCancelDate() != null, PlatformJob::getCancelDate, Utils.Date.getStart(pageWrap.getModel().getCancelDate())) .le(pageWrap.getModel().getCancelDate() != null, PlatformJob::getCancelDate, Utils.Date.getEnd(pageWrap.getModel().getCancelDate())) .eq(pageWrap.getModel().getCancelUserId() != null, PlatformJob::getCancelUserId, pageWrap.getModel().getCancelUserId()) .eq(pageWrap.getModel().getCancelInfo() != null, PlatformJob::getCancelInfo, pageWrap.getModel().getCancelInfo()) .eq(pageWrap.getModel().getReason() != null, PlatformJob::getReason, pageWrap.getModel().getReason()) .eq(pageWrap.getModel().getContractNum() != null, PlatformJob::getContractNum, pageWrap.getModel().getContractNum()) .ge(pageWrap.getModel().getArriveDate() != null, PlatformJob::getArriveDate, Utils.Date.getStart(pageWrap.getModel().getArriveDate())) .le(pageWrap.getModel().getArriveDate() != null, PlatformJob::getArriveDate, Utils.Date.getEnd(pageWrap.getModel().getArriveDate())) .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()+"')") .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())) .eq(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ONE,pageWrap.getModel().getJobType()), PlatformJob::getType, Constants.platformJobType.sgscxh) .ne(pageWrap.getModel().getJobType() != null && Constants.equalsInteger(Constants.ZERO,pageWrap.getModel().getJobType()), PlatformJob::getType, Constants.platformJobType.sgscxh) ; for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } IPage platformJobIPage = platformJobJoinMapper.selectJoinPage(page,PlatformJob.class,queryWrapper); platformJobIPage.getRecords().forEach(i->{ i.dealTime(); this.getWmsJobData(i); this.queryWaitNum(i); }); return PageData.from(platformJobIPage); } @Override public PageData platformCallList(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) .eq(pageWrap.getModel().getPlatformGroupId() != null, PlatformJob::getPlatformGroupId, pageWrap.getModel().getPlatformGroupId()) .like(pageWrap.getModel().getCarCodeFront() != null, PlatformJob::getCarCodeFront, pageWrap.getModel().getCarCodeFront()) .eq(Objects.nonNull(pageWrap.getModel().getCallType()) &&Constants.equalsInteger(pageWrap.getModel().getCallType(),Constants.ONE),PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey() ) .and(Objects.nonNull(pageWrap.getModel().getCallType()) &&Constants.equalsInteger(pageWrap.getModel().getCallType(),Constants.TWO), i->i.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()).or() .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()).or() .apply(" ( 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() .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()).or() .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()).or() .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) ; IPage platformJobIPage = platformJobJoinMapper.selectJoinPage(page,PlatformJob.class,queryWrapper); platformJobIPage.getRecords().forEach(i->{ i.dealTime(); this.getWmsJobData(i); this.queryWaitNum(i); }); return PageData.from(platformJobIPage); } public void getWmsJobData(PlatformJob platformJob){ if(Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.zycxh) || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.zyczh) || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.wxcxh) || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.wxczh)) { PlatformWmsJob platformWmsJob = platformWmsJobMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformWmsJob::getIsdeleted,Constants.ZERO) .eq(PlatformWmsJob::getJobId,platformJob.getId()) .orderByDesc(PlatformWmsJob::getId) .last(" limit 1") ); if(Objects.isNull(platformWmsJob)){ return; } List platformWmsDetailList = platformWmsDetailMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO) .eq(PlatformWmsDetail::getJobId,platformJob.getId())); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformWmsDetailList)){ platformJob.setTotalNum( platformWmsDetailList.stream().map(m->m.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add) ); platformWmsJob.setPlatformWmsDetailList(platformWmsDetailList); platformJob.setPlatformWmsJob(platformWmsJob); } } } public void queryWaitNum(PlatformJob platformJob){ if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){ //查询前方排队数量 List lineUpNum = platformJobMapper.selectList(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey() ,Constants.PlatformJobStatus.IN_WAIT.getKey() ,Constants.PlatformJobStatus.TRANSFERING.getKey()) .gt(PlatformJob::getSignDate,platformJob.getSignDate()) .eq(PlatformJob::getPlatformGroupId,platformJob.getPlatformGroupId()) .like(PlatformJob::getArriveDate,DateUtil.dateTypeToString(platformJob.getArriveDate(),"yyyy-MM-dd"))); platformJob.setLineUpNum(lineUpNum.size()); BigDecimal sumWorkRate = platformJob.getTotalNum(); for (PlatformJob linePlatformJob:lineUpNum) { this.getWmsJobData(linePlatformJob); sumWorkRate = sumWorkRate.add(linePlatformJob.getTotalNum()); } if(lineUpNum.size()>Constants.ZERO){ //计算预计等待时间 List platformList = platformJoinMapper.selectList(new QueryWrapper().lambda().eq(Platform::getIsdeleted,Constants.ZERO).eq(Platform::getGroupId,platformJob.getPlatformGroupId())); BigDecimal workRate = platformList.stream().map(m->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(); Integer hours = sumMinuteInteger/60; Integer minus = sumMinuteInteger%60; String waitTime = "预计等待："; if(!Constants.equalsInteger(hours,Constants.ZERO)){ waitTime = waitTime + hours + "小时"; } if(!Constants.equalsInteger(hours,Constants.ZERO)){ waitTime = waitTime + minus + "分钟"; } platformJob.setWaitTime(waitTime); } }else{ platformJob.setWaitTime("等待叫号"); } }else if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){ //查询最后开始任务的月台记录 日志表 因为存在异常挂起 转移 等问题 PlatformLog platformLog = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getJobId,platformJob.getId()) .eq(PlatformLog::getObjType,Constants.PlatformJobStatus.WORKING.getKey()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1") ); if(Objects.nonNull(platformLog)){ 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")); } //处理作业时长 List platformLogList = platformLogMapper.selectList(new QueryWrapper().lambda() .eq(PlatformLog::getJobId,platformJob.getId()) .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)); } } @Override public long count(PlatformJob platformJob) { QueryWrapper wrapper = new QueryWrapper<>(platformJob); return platformJobMapper.selectCount(wrapper); } //TODO @Override public DriverHomeVO getDriverHome(LoginUserInfo loginUserInfo){ DriverHomeVO driverHomeVO = new DriverHomeVO(); //TODO 轮播图 List platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getDrivierPhone,loginUserInfo.getMobile()) .like(PlatformJob::getArriveDate,DateUtil.getCurrDate()) .orderByDesc(PlatformJob::getId) ); for (PlatformJob platformJob:platformJobList) { //处理WSM数量 this.getWmsJobData(platformJob); //查询前方排队数量 this.queryWaitNum(platformJob); } driverHomeVO.setPlatformJobList(platformJobList); // 园区导览图 图片 driverHomeVO.setReservationMap(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.PLATFORM_GUIDEMAP).getCode()); // 预约指南 文本 driverHomeVO.setBookingTips(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.PLATFORM_BOOKING_TIPS).getCode()); driverHomeVO.setSignDistance(new BigDecimal(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_DISTANCE).getCode())); return driverHomeVO; } @Override public void confirmTask(ConfirmTaskDTO confirmTaskDTO){ if(Objects.isNull(confirmTaskDTO) || Objects.isNull(confirmTaskDTO.getId()) || Objects.isNull(confirmTaskDTO.getArriveDate()) || StringUtils.isBlank(confirmTaskDTO.getCarCodeBack()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } PlatformJob platformJob = platformJobMapper.selectById(confirmTaskDTO.getId()); if(Objects.isNull(platformJob)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"业务状态已流转,无法进行该操作"); } if(confirmTaskDTO.getArriveDate().getTime()<=System.currentTimeMillis()){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"预计到厂时间必须大于当前时间"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setArriveDate(confirmTaskDTO.getArriveDate()); platformJob.setStatus(Constants.PlatformJobStatus.WART_SIGN_IN.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.CONFIRM_TASK.getKey(),oldPlatformJob,platformJob , Constants.PlatformJobLogType.CONFIRM_TASK.getInfo()); } /** * 距离签到 * @param signInDTO */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void signIn(SignInDTO signInDTO){ if(Objects.isNull(signInDTO) || Objects.isNull(signInDTO.getSignType()) || Objects.isNull(signInDTO.getJobId())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } PlatformJob platformJob = platformJobMapper.selectById(signInDTO.getJobId()); if(Objects.isNull(platformJob)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"业务状态已流转，请刷新查看"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); if(Constants.equalsInteger(signInDTO.getSignType(),Constants.ZERO)){ this.distanceSignIn(signInDTO,platformJob); }else if(Constants.equalsInteger(signInDTO.getSignType(),Constants.ONE)){ this.sceneSignIn(signInDTO); } platformJob.setSignDate(new Date()); platformJob.setSingType(Constants.ZERO); platformJob.setStatus(Constants.PlatformJobStatus.WAIT_CALL.getKey()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.SIGN.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.SIGN.getInfo()); } 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()); BigDecimal distance = new BigDecimal(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_PLACE_DISTANCE).getCode()); //获取2个点的距离 单位：米 Double getDistanceDouble = PositionUtil.getDistance(signInDTO.getLnt(),signInDTO.getLat(),lnt,lat); //转换km BigDecimal getDistance = BigDecimal.valueOf(getDistanceDouble).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP); if(distance.compareTo(getDistance) platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(Constants.equalsInteger(lineUpDetailDTO.getQueryType(),Constants.ZERO) ,PlatformJob::getDrivierPhone,lineUpDetailDTO.getMobile()) .eq(Constants.equalsInteger(lineUpDetailDTO.getQueryType(),Constants.ONE) ,PlatformJob::getId,lineUpDetailDTO.getJobId()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey(), Constants.PlatformJobStatus.IN_WAIT.getKey(), Constants.PlatformJobStatus.CALLED.getKey()) .orderByAsc(PlatformJob::getSignDate) ); //获取所有月台组 List platformIdList = platformJobList.stream().map(m->m.getPlatformGroupId()).collect(Collectors.toList()); if(CollectionUtils.isEmpty(platformIdList)){ return lineUpVO; } List platformGroupList = platformGroupMapper.selectList(new QueryWrapper().lambda() .eq(PlatformGroup::getIsdeleted,Constants.ZERO) .in(PlatformGroup::getId,platformIdList)); for (PlatformGroup platformGroup:platformGroupList) { //查询本月台组下 自己的数据 最早签到的 PlatformJob platformJob = platformJobList.stream().filter(i->Constants.equalsInteger(i.getPlatformGroupId(),platformGroup.getId())).findFirst().orElse(null); //查询在当前月台组下 签到排队车辆数据 List platformJobSignInList = platformJobJoinMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getPlatformGroupId,platformGroup.getId()) .ge(Objects.nonNull(platformJob),PlatformJob::getSignDate,DateUtil.dateTypeToString(platformJob.getSignDate(),"yyyy-MM-dd HH:mm:ss")) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey(), Constants.PlatformJobStatus.IN_WAIT.getKey(), Constants.PlatformJobStatus.CALLED.getKey()) .orderByDesc(PlatformJob::getSignDate)); platformGroup.setSignJobList(platformJobSignInList); //查询当前月台组下 List platformJobWorkList = platformJobJoinMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getPlatformGroupId,platformGroup.getId()) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey()) .orderByDesc(PlatformJob::getSignDate)); platformGroup.setWorkJobList(platformJobWorkList); } lineUpVO.setPlatformGroupList(platformGroupList); return lineUpVO; } /** * 获取已作业时间 * @param platformJob */ public Long getWorkTime(PlatformJob platformJob){ List platformLogList = platformLogMapper.selectList(new QueryWrapper() .lambda().eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getJobId,platformJob.getId()) .ne(PlatformLog::getParam3,"0") ); Long optTime = 0L; if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformLogList)){ List param3List = platformLogList.stream().map(m->Long.valueOf(m.getParam3())).collect(Collectors.toList()); for (Long val:param3List) { optTime = optTime + val; } } if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){ //查询最后一次开始的日志数据 PlatformLog lastBeginPlatform = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getObjType,Constants.PlatformJobStatus.WORKING.getKey()) .eq(PlatformLog::getJobId,platformJob.getId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); if(Objects.nonNull(lastBeginPlatform)){ String v = Long.toString(System.currentTimeMillis() - lastBeginPlatform.getCreateDate().getTime() / 1000) ; optTime = optTime + Long.valueOf(v); } } platformJob.setWorkTime(optTime); return optTime; } /** * 通知入园 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void platformInPark(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setInwaitDate(new Date()); platformJob.setInwaitUserId(jobOperateDTO.getLoginUserInfo().getId()); platformJob.setStatus(Constants.PlatformJobStatus.IN_WAIT.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); if(Constants.equalsInteger(platformJob.getType(),Constants.TWO) || Constants.equalsInteger(platformJob.getType(),Constants.THREE) || Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){ //TODO 下发入园权限 } //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.IN_WAIT.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.IN_WAIT.getInfo()); } /** * 月台叫号 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void platformCallNumber(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) || Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) || Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) ) ){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } Platform platform = platformJoinMapper.selectById(jobOperateDTO.getPlatformId()); if(Objects.isNull(platform)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台信息"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setCallDate(new Date()); platformJob.setCallUserId(jobOperateDTO.getLoginUserInfo().getId()); platformJob.setStatus(Constants.PlatformJobStatus.CALLED.getKey()); platformJob.setPlatformId(jobOperateDTO.getPlatformId()); //判断是否需要填充进去 if(StringUtils.isBlank(platformJob.getPlatforms())){ platformJob.setPlatforms(jobOperateDTO.getPlatformId().toString()); platformJob.setPlatformNames(platform.getName()); }else{ platformJob.setPlatforms(platformJob.getPlatforms() + "," +jobOperateDTO.getPlatformId().toString()); platformJob.setPlatformNames(platformJob.getPlatformNames() + "," +platform.getName()); } platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.CALLED.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.CALLED.getInfo().replace("{data}",platform.getName())); } /** * 转移月台 * @param jobOperateDTO */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void platformMove(JobOperateDTO jobOperateDTO){ if(Objects.isNull(jobOperateDTO) || Objects.isNull(jobOperateDTO.getJobId()) || Objects.isNull(jobOperateDTO.getPlatformId())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } PlatformJob platformJob = platformJobMapper.selectById(jobOperateDTO.getJobId()); if(Objects.isNull(platformJob)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if( !( Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey()) || Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.EXCEPTION.getKey()) )){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } if(Constants.equalsInteger(platformJob.getPlatformId(),jobOperateDTO.getPlatformId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无法转移本月台"); } Platform oldPlatform = platformJoinMapper.selectById(platformJob.getPlatformId()); Platform platform = platformJoinMapper.selectById(jobOperateDTO.getPlatformId()); if(Objects.isNull(platform)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台信息"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setPlatforms(platformJob.getPlatforms() + "," +jobOperateDTO.getPlatformId().toString()); platformJob.setPlatformNames(platformJob.getPlatformNames() + "," +platform.getName()); platformJob.setTransPlatformDate(new Date()); platformJob.setTransPlatformUserId(jobOperateDTO.getLoginUserInfo().getId()); platformJob.setPlatformId(jobOperateDTO.getPlatformId()); platformJob.setStatus(Constants.PlatformJobStatus.TRANSFERING.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //TODO 调起WMS 通知月台转移 //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.TRANSFERING.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.TRANSFERING.getInfo().replace("{data}",oldPlatform.getName())); } /** * 月台过号 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void platformOverNumber(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setStatus(Constants.PlatformJobStatus.WART_SIGN_IN.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.OVER_NUMBER.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.OVER_NUMBER.getInfo()); } /** * 异常挂起 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void platformErr(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setErrorDate(new Date()); platformJob.setErrorUserId(jobOperateDTO.getLoginUserInfo().getId()); platformJob.setStatus(Constants.PlatformJobStatus.EXCEPTION.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.EXCEPTION.getKey(),oldPlatformJob,platformJob, Constants.PlatformJobLogType.EXCEPTION.getInfo()); } /** * 开始作业 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void beginWork(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.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())); } /** * 完成作业 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void finishWork(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setDoneDate(new Date()); platformJob.setStatus(Constants.PlatformJobStatus.DONE.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.DONE.getKey(),oldPlatformJob,platformJob , Constants.PlatformJobLogType.DONE.getInfo()); if(Constants.equalsInteger(platformJob.getType(),Constants.TWO)){ //TODO 外协车装货 查询TMS 电子锁情况 }else if(Constants.equalsInteger(platformJob.getType(),Constants.ONE) || Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){ //TODO 外协车卸货 或者 市公司车卸货 则根据任务情况进行下发离园权限 } } /** * 授权离园 */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void powerLevel(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)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.DONE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！"); } PlatformJob oldPlatformJob = new PlatformJob(); BeanUtils.copyProperties(platformJob,oldPlatformJob); platformJob.setOutUserId(jobOperateDTO.getLoginUserInfo().getId()); platformJob.setOutHkdate(new Date()); platformJob.setStatus(Constants.PlatformJobStatus.AUTHED_LEAVE.getKey()); platformJob.setEditDate(new Date()); platformJobMapper.updateById(platformJob); //存储操作日志 savePlatformLog(Constants.PlatformJobLogType.AUTHED_LEAVE.getKey(),oldPlatformJob,platformJob , Constants.PlatformJobLogType.AUTHED_LEAVE.getInfo()); //TODO 授权车辆离场权限 } /** * 月台相机推送 开始作业 * @param jobOperateDTO */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void cameraStartWork(JobOperateDTO jobOperateDTO){ if(Objects.isNull(jobOperateDTO) || Objects.isNull(jobOperateDTO.getDeviceId()) || StringUtils.isBlank(jobOperateDTO.getCarCodeBack())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } PlatformDevice platformDevice = platformDeviceMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformDevice::getIsdeleted,Constants.ZERO) .eq(PlatformDevice::getDeviceId,jobOperateDTO.getDeviceId()) .last(" limit 1") ); if(Objects.isNull(platformDevice)){ return; } PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformJob::getPlatformId,platformDevice.getPlatformId()) .eq(PlatformJob::getCarCodeBack,jobOperateDTO.getCarCodeBack()) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()) .last(" limit 1 ") ); if(Objects.isNull(platformJob)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.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.DONE.getInfo()); } /** * 存储操作日志 * @param objType * @param platformJobBefor * @param platformJobAfter */ public void savePlatformLog(Integer objType,PlatformJob platformJobBefor,PlatformJob platformJobAfter,String content){ PlatformLog platformLog = new PlatformLog(); platformLog.setIsdeleted(Constants.ZERO); platformLog.setCreateDate(new Date()); platformLog.setJobId(platformJobAfter.getId()); platformLog.setObjType(objType); platformLog.setContent(content); platformLog.setParam4(platformJobAfter.getCarCodeFront()); platformLog.setBeforeContent(JSONObject.toJSONString(platformJobBefor)); platformLog.setAfterContent(JSONObject.toJSONString(platformJobAfter)); platformLog.setObjId(platformJobAfter.getId().toString()); if(Constants.equalsInteger(objType,Constants.PlatformJobLogType.EXCEPTION.getKey())){ //查询最后一次开始作业的日志 PlatformLog lastBeginPlatform = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getObjType,Constants.PlatformJobLogType.WORKING.getKey()) .eq(PlatformLog::getJobId,platformLog.getJobId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); //异常挂起 与转移中 记录本次 作业时间 platformLog.setParam1(lastBeginPlatform.getParam1()); platformLog.setParam2(DateUtil.dateTypeToString(platformLog.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); String v = Long.toString((platformLog.getCreateDate().getTime() - DateUtil.StringToDate(lastBeginPlatform.getParam1(),"yyyy-MM-dd HH:mm:ss").getTime() )/ 1000) ; platformLog.setParam3(v); }else if(Constants.equalsInteger(objType,Constants.PlatformJobLogType.TRANSFERING.getKey())){ //查询最后一次日志是否为异常挂起，异常挂起后可进行转移 如果进行转移那么业务就需要重新进行开始就不需要特殊处理 ，如果不是异常挂起进行数据结束 则直接查询最后一次开始的时间 PlatformLog lastPlatformLog = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getJobId,platformLog.getJobId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); if(!Constants.equalsInteger(lastPlatformLog.getObjType(),Constants.PlatformJobLogType.EXCEPTION.getKey())){ //查询最后一次开始作业的日志 PlatformLog lastBeginPlatform = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getObjType,Constants.PlatformJobLogType.WORKING.getKey()) .eq(PlatformLog::getJobId,platformLog.getJobId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); //异常挂起 与转移中 记录本次 作业时间 platformLog.setParam1(lastBeginPlatform.getParam1()); platformLog.setParam2(DateUtil.dateTypeToString(platformLog.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); String v = Long.toString((platformLog.getCreateDate().getTime() - DateUtil.StringToDate(lastBeginPlatform.getParam1(),"yyyy-MM-dd HH:mm:ss").getTime() )/ 1000) ; platformLog.setParam3(v); }else{ platformLog.setParam3("0"); } }else if(Constants.equalsInteger(objType,Constants.PlatformJobLogType.DONE.getKey())){ //查询最后一次日志是否为异常挂起，异常挂起后可进行转移 如果进行转移那么业务就需要重新进行开始就不需要特殊处理 ，如果不是异常挂起进行数据结束 则直接查询最后一次开始的时间 PlatformLog lastPlatformLog = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getJobId,platformLog.getJobId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); if(Objects.nonNull(lastPlatformLog) && Constants.equalsInteger(lastPlatformLog.getObjType(),Constants.PlatformJobLogType.EXCEPTION.getKey())){ platformLog.setParam3("0"); }else{ //查询最后一次开始作业的日志 PlatformLog lastBeginPlatform = platformLogMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformLog::getIsdeleted,Constants.ZERO) .eq(PlatformLog::getObjType,Constants.PlatformJobLogType.WORKING.getKey()) .eq(PlatformLog::getJobId,platformLog.getJobId()) .orderByDesc(PlatformLog::getCreateDate) .last(" limit 1 ") ); //非异常挂起 则直接过去最后一次开始作业的日志的开始时间 platformLog.setParam1(lastBeginPlatform.getParam1()); platformLog.setParam2(DateUtil.dateTypeToString(platformLog.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); String v = Long.toString((platformJobAfter.getDoneDate().getTime() - DateUtil.StringToDate(lastBeginPlatform.getParam1(),"yyyy-MM-dd HH:mm:ss").getTime()) / 1000) ; platformLog.setParam3(v); } }else if(Constants.equalsInteger(objType,Constants.PlatformJobLogType.WORKING.getKey())){ platformLog.setParam1(DateUtil.dateTypeToString(platformLog.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); platformLog.setParam3("0"); }else{ platformLog.setParam3("0"); } platformLogMapper.insert(platformLog); } @Override public List getPlatformList(Integer groupId, LoginUserInfo loginUserInfo){ //查询月台组下所有月台 List allPlatformList = platformJoinMapper.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) .eq(Platform::getStatus,Constants.ZERO) .eq(Platform::getGroupId,groupId) ); this.getPlatformShow(allPlatformList,loginUserInfo); for (Platform platform:allPlatformList) { this.getJobByPlatform(platform,loginUserInfo); } return allPlatformList; } /** * 查询月台的开启情况 * @param allPlatformList * @param loginUserInfo */ public void getPlatformShow(List allPlatformList , LoginUserInfo loginUserInfo){ //处理我的月台信息 是否配置隐藏 List platformShowParamList = platformShowParamMapper.selectList(new QueryWrapper() .lambda() .eq(PlatformShowParam::getIsdeleted, Constants.ZERO) .eq(PlatformShowParam::getMemberId,loginUserInfo.getMemberId()) ); //如果未配置该数据 则全部显示 if(CollectionUtils.isEmpty(platformShowParamList)){ for (Platform platform:allPlatformList) { platform.setShowConfig(true); } }else{ //根据配置显示数据 for (PlatformShowParam platformShowParam:platformShowParamList) { for (Platform platform:allPlatformList) { if(Constants.equalsInteger(platform.getId(),platformShowParam.getPlatformId())){ platform.setShowConfig(true); break; } } } } } /** * 获取月台下的任务列表 * @param platform * @param loginUserInfo */ public void getJobByPlatform(Platform platform,LoginUserInfo loginUserInfo){ List platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getPlatformId,platform.getId()) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getDrivierPhone,loginUserInfo.getMobile()) .in(PlatformJob::getStatus, Constants.PlatformJobStatus.WAIT_CALL.getKey(), Constants.PlatformJobStatus.IN_WAIT.getKey(), Constants.PlatformJobStatus.CALLED.getKey(), Constants.PlatformJobStatus.WORKING.getKey(), Constants.PlatformJobStatus.EXCEPTION.getKey(), Constants.PlatformJobStatus.OVER_NUMBER.getKey() ) .like(PlatformJob::getArriveDate, DateUtil.getCurrDate()) .orderByDesc(PlatformJob::getId) ); for (PlatformJob platformJob:platformJobList) { //处理WSM数量 this.getWmsJobData(platformJob); //查询前方排队数量 this.queryWaitNum(platformJob); } platform.setWorkJobList(platformJobList); } @Override public PlatformWorkVO getPlatformWorkVOById(Integer platformId){ //获取月台下的所有作业数据 List platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getPlatformId,platformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .in(PlatformJob::getStatus, Constants.PlatformJobStatus.WAIT_CALL.getKey(), Constants.PlatformJobStatus.IN_WAIT.getKey(), Constants.PlatformJobStatus.CALLED.getKey(), Constants.PlatformJobStatus.WORKING.getKey(), Constants.PlatformJobStatus.EXCEPTION.getKey(), Constants.PlatformJobStatus.OVER_NUMBER.getKey() ) .like(PlatformJob::getArriveDate, DateUtil.getCurrDate()) .orderByDesc(PlatformJob::getId) ); for (PlatformJob platformJob:platformJobList) { //处理WSM数量 this.getWmsJobData(platformJob); //查询前方排队数量 this.queryWaitNum(platformJob); } PlatformWorkVO platformWorkVO = PlatformGroupServiceImpl.getPlatformWorkVO(platformId,platformJobList); return platformWorkVO; } @Override public PlatformOrderNumByDateResponse orderNumByDate(PlatformOrderNumByDateRequest param){ PlatformOrderNumByDateResponse platformOrderNumByDateResponse = new PlatformOrderNumByDateResponse(); Date queryDate = (Objects.nonNull(param)&&Objects.nonNull(param.getTimeInfo()))?param.getTimeInfo():new Date(); String queryDateStr = DateUtil.getDate(queryDate,"yyyy-MM-dd"); //查询今日全部任务 platformOrderNumByDateResponse.setTotalNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .and(i-> i.like(PlatformJob::getDoneDate,queryDateStr) .or().ne(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()) ) ) ); //查询今日完成任务 platformOrderNumByDateResponse.setDoneNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .like(PlatformJob::getDoneDate,queryDateStr) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()) ) ); return platformOrderNumByDateResponse; } @Override public List platformWorkingDataList(PlatformDataListRequest param){ List platformDataListResponseList = new ArrayList<>(); List platformList = platformJoinMapper.selectList( new MPJLambdaWrapper().eq(Platform::getIsdeleted,Constants.ZERO) .eq(Platform::getStatus,Constants.ZERO) ); for (Platform platform:platformList) { PlatformDataListResponse platformDataListResponse = new PlatformDataListResponse(); platformDataListResponse.setId(platform.getId()); platformDataListResponse.setHkId(platform.getHkId()); platformDataListResponse.setName(platform.getName()); platformDataListResponse.setWorkStatus(Constants.ZERO); //查询当前作业车辆 PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey()) .orderByDesc(PlatformJob::getWorkTime) .last(" limit 1") ); if(Objects.nonNull(platformJob)){ platformDataListResponse.setCarCode(platformJob.getCarCodeFront()); platformDataListResponse.setWorkType( Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.zycxh) ||Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.wxcxh) ||Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.sgscxh)?Constants.ZERO:Constants.ONE ); platformDataListResponse.setWorkStatus(Constants.ONE); //查询作业时长 platformDataListResponse.setWorkTime( this.getWorkTime(platformJob) ); } } return platformDataListResponseList; } @Override public PlatformDataInfoResponse platformWorkingDataList(PlatformDataInfoRequest param){ if(Objects.isNull(param) || Objects.isNull(param.getId())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } PlatformDataInfoResponse response = new PlatformDataInfoResponse(); Platform platform = platformJoinMapper.selectById(param.getId()); if(Objects.isNull(platform)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台信息"); } response.setId(platform.getId()); response.setHkId(platform.getHkId()); response.setName(platform.getName()); PlatformJob platformJob = platformJobJoinMapper.selectJoinOne(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate) .selectAs(PlatformWmsJob::getId,PlatformJob::getWmsId) .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName) .selectAs(PlatformWmsJob::getRepertotyAddress,PlatformJob::getRepertotyAddress) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey()) .eq(PlatformJob::getPlatformId,platform.getId()) .orderByDesc(PlatformJob::getDoneDate) ); if(Objects.nonNull(platformJob)){ response.setCarCode(platformJob.getCarCodeFront()); response.setCarrierName(platformJob.getCarrierName()); response.setOrderCode(platformJob.getBillCode()); response.setRepertotyAddress(platformJob.getRepertotyAddress()); //查询供应商信息 只有存在承运单号才有 if(Objects.nonNull(platformJob.getWmsId())){ List platformWmsDetailList = platformWmsDetailMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWmsDetail::getIsdeleted,Constants.ZERO) .eq(PlatformWmsDetail::getJobId,platformJob.getId())); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformWmsDetailList)){ List stringList = platformWmsDetailList.stream().map(m->m.getInRepertotyCode()).collect(Collectors.toList()); response.setInRepertotyCode(stringList); } } } return response; } @Override public CarNumByStatusResponse carStatusNum(CarNumByStatusRequest param){ CarNumByStatusResponse response = new CarNumByStatusResponse(); response.setQueuingNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()) ) ); response.setInNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .and(i->i.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()) .or() .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()) ) ) ); response.setWorkingNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey()) ) ); response.setDoneNum( platformJobMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.LEAVED.getKey()) .like(PlatformJob::getOutDate,DateUtil.getDate(new Date(),"yyyy-MM-dd")) ) ); return response; } @Override public PlatformQueuingListResponse queueList(PlatformQueuingListRequest param){ PlatformQueuingListResponse response = new PlatformQueuingListResponse(); List platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformGroup.class,PlatformGroup::getId,PlatformJob::getPlatformGroupId) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .isNotNull(PlatformJob::getCarCodeFront) .orderByDesc(PlatformJob::getCreateDate) .eq(PlatformGroup::getType,Constants.ZERO)); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ response.setOutboundList( platformJobList.stream().map(m->m.getCarCodeFront()).collect(Collectors.toList()) ); } platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformGroup.class,PlatformGroup::getId,PlatformJob::getPlatformGroupId) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .isNotNull(PlatformJob::getCarCodeFront) .orderByDesc(PlatformJob::getCreateDate) .eq(PlatformGroup::getType,Constants.ONE)); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ response.setInboundList( platformJobList.stream().map(m->m.getCarCodeFront()).collect(Collectors.toList()) ); } platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformGroup.class,PlatformGroup::getId,PlatformJob::getPlatformGroupId) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()) .in(PlatformJob::getStatus,Constants.PlatformJobStatus.CALLED.getKey()) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .isNotNull(PlatformJob::getCarCodeFront) .orderByDesc(PlatformJob::getCreateDate) .eq(PlatformGroup::getType,Constants.TWO)); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ response.setMunicipalComList( platformJobList.stream().map(m->m.getCarCodeFront()).collect(Collectors.toList()) ); } return response; } }