package com.doumee.service.business.impl; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.wx.wxPlat.WxPlatConstants; import com.doumee.core.wx.wxPlat.WxPlatNotice; import com.doumee.dao.system.SystemUserMapper; import com.doumee.dao.system.model.SystemUser; 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.core.utils.Constants; import com.doumee.core.utils.Utils; import com.doumee.dao.business.PlatformGroupMapper; import com.doumee.dao.business.PlatformShowParamMapper; import com.doumee.dao.business.join.PlatformJobJoinMapper; import com.doumee.dao.business.join.PlatformJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.web.reqeust.PlatformDataDTO; import com.doumee.dao.web.response.PlatformGroupWorkVO; import com.doumee.dao.web.response.PlatformWorkVO; import com.doumee.service.business.PlatformGroupService; 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.apache.shiro.SecurityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.util.*; import java.util.stream.Collectors; /** * 月台_分组信息表Service实现 * @author 江蹄蹄 * @date 2024/06/28 10:03 */ @Service public class PlatformGroupServiceImpl implements PlatformGroupService { @Autowired private PlatformGroupMapper platformGroupMapper; @Autowired private SystemUserMapper systemUserMapper; @Autowired private PlatformJoinMapper platformJoinMapper; @Autowired private PlatformShowParamMapper platformShowParamMapper; @Autowired private PlatformJobJoinMapper platformJobJoinMapper; @Override public Integer create(PlatformGroup platformGroup) { if(platformGroup.getType() ==null || platformGroup.getType()>2 || platformGroup.getType()<0){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } platformGroup.setAutoCall(Constants.formatIntegerNum(platformGroup.getAutoCall())); platformGroup.setIsVirtual(Constants.formatIntegerNum(platformGroup.getIsVirtual())); if(platformGroupMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformGroup::getIsdeleted,Constants.ZERO) .eq(PlatformGroup::getType,platformGroup.getType()) .eq(PlatformGroup::getIsVirtual,platformGroup.getIsVirtual()) )>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该类型分组已经创建,请返回刷新页面查看!"); } platformGroup.setStatus(Constants.ZERO); platformGroup.setIsdeleted(Constants.ZERO); platformGroup.setCreator(platformGroup.getLoginUserInfo().getId()); platformGroup.setCreateDate(new Date()); platformGroup.setEditDate(platformGroup.getCreateDate()); platformGroup.setEditor(platformGroup.getCreator()); platformGroupMapper.insert(platformGroup); return platformGroup.getId(); } @Override public void deleteById(Integer id) { PlatformGroup param = new PlatformGroup(); param.setId(id); param.setIsdeleted(Constants.ONE); platformGroupMapper.updateById(param); } @Override public void deleteById(Integer id,LoginUserInfo user) { // platformGroupMapper.deleteById(id); PlatformGroup param = new PlatformGroup(); param.setId(id); param.setIsdeleted(Constants.ONE); param.setEditor(user.getId()); param.setEditDate(new Date()); platformGroupMapper.updateById(param); } @Override public void delete(PlatformGroup platformGroup) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(platformGroup); platformGroupMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } for(Integer id : ids){ deleteById(id); } } @Override public void deleteByIdInBatch(List ids,LoginUserInfo user) { if (CollectionUtils.isEmpty(ids)) { return; } for(Integer id : ids){ deleteById(id,user); } } @Override public void updateAutoCallById(PlatformGroup platform) { PlatformGroup model =platformGroupMapper.selectById(platform.getId()); if(model ==null) { throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,该记录信息不存在!"); } LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(loginUserInfo == null){ loginUserInfo = platform.getLoginUserInfo(); } PlatformGroup update = new PlatformGroup(); update.setId(model.getId()); update.setEditDate(new Date()); update.setEditor(loginUserInfo.getId()); update.setAutoCall(platform.getAutoCall()); platformGroupMapper.updateById(update); } @Override public void updateById(PlatformGroup platformGroup) { if(platformGroup.getType() ==null || platformGroup.getType()>2 || platformGroup.getType()<0){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } platformGroup.setAutoCall(Constants.formatIntegerNum(platformGroup.getAutoCall())); platformGroup.setIsVirtual(Constants.formatIntegerNum(platformGroup.getIsVirtual())); if(platformGroupMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformGroup::getIsdeleted,Constants.ZERO) .eq(PlatformGroup::getType,platformGroup.getType()) .eq(PlatformGroup::getIsVirtual,platformGroup.getIsVirtual()) .ne(PlatformGroup::getId,platformGroup.getId()) )>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该类型分组已经创建,请返回刷新页面查看!"); } platformGroup.setEditDate(new Date()); platformGroup.setEditor(platformGroup.getLoginUserInfo().getId()); platformGroupMapper.updateById(platformGroup); } @Override public void updateByIdInBatch(List platformGroups) { if (CollectionUtils.isEmpty(platformGroups)) { return; } for (PlatformGroup platformGroup: platformGroups) { this.updateById(platformGroup); } } @Override public PlatformGroup findById(Integer id) { return platformGroupMapper.selectById(id); } @Override public PlatformGroup findOne(PlatformGroup platformGroup) { QueryWrapper wrapper = new QueryWrapper<>(platformGroup); return platformGroupMapper.selectOne(wrapper); } @Override public List findList(PlatformGroup platformGroup) { QueryWrapper wrapper = new QueryWrapper<>(platformGroup); return platformGroupMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.lambda() .eq(pageWrap.getModel().getId() != null, PlatformGroup::getId, pageWrap.getModel().getId()) .eq(pageWrap.getModel().getCreator() != null, PlatformGroup::getCreator, pageWrap.getModel().getCreator()) .ge(pageWrap.getModel().getCreateDate() != null, PlatformGroup::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())) .le(pageWrap.getModel().getCreateDate() != null, PlatformGroup::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())) .eq(pageWrap.getModel().getEditor() != null, PlatformGroup::getEditor, pageWrap.getModel().getEditor()) .ge(pageWrap.getModel().getEditDate() != null, PlatformGroup::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())) .le(pageWrap.getModel().getEditDate() != null, PlatformGroup::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())) .eq(pageWrap.getModel().getIsdeleted() != null, PlatformGroup::getIsdeleted, pageWrap.getModel().getIsdeleted()) .eq(pageWrap.getModel().getName() != null, PlatformGroup::getName, pageWrap.getModel().getName()) .eq(pageWrap.getModel().getRemark() != null, PlatformGroup::getRemark, pageWrap.getModel().getRemark()) .eq(pageWrap.getModel().getStatus() != null, PlatformGroup::getStatus, pageWrap.getModel().getStatus()) .eq(pageWrap.getModel().getSortnum() != null, PlatformGroup::getSortnum, pageWrap.getModel().getSortnum()) ; for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } PageData result =PageData.from(platformGroupMapper.selectPage(page, queryWrapper)); if(result !=null && result.getRecords()!=null){ List ids0 = new ArrayList<>(); List systemUserList ; for(PlatformGroup platformGroup : result.getRecords()){ if( StringUtils.isNotBlank(platformGroup.getSignInNoticeUsers()) || StringUtils.isNotBlank(platformGroup.getUnFinishNoticeUsers())) { if( StringUtils.isNotBlank(platformGroup.getSignInNoticeUsers()) ){ ids0.addAll(Arrays.asList(platformGroup.getSignInNoticeUsers().split(","))); } if( StringUtils.isNotBlank(platformGroup.getUnFinishNoticeUsers()) ){ ids0.addAll(Arrays.asList(platformGroup.getUnFinishNoticeUsers().split(","))); } } } systemUserList = systemUserMapper.selectList(new QueryWrapper().lambda() .eq(SystemUser::getDeleted, Constants.ZERO) .in(SystemUser::getMemberId,ids0) ); if (systemUserList!=null) { for(PlatformGroup platformGroup : result.getRecords()){ platformGroup.setSignInNoticeUserNames(getUserNameFromList(0,platformGroup,systemUserList)); platformGroup.setUnFinishNoticeUserNames(getUserNameFromList(1,platformGroup,systemUserList)); } } } return result; } private String getUserNameFromList(int i, PlatformGroup platformGroup, List systemUserList) { String ids = i ==0?platformGroup.getSignInNoticeUsers():platformGroup.getUnFinishNoticeUsers(); String name = ""; if( StringUtils.isNotBlank(ids)) { List ids0 = Arrays.asList(ids.split(",")); if (systemUserList!=null) { for(SystemUser user :systemUserList){ for(String s : ids0){ if(StringUtils.equals(user.getMemberId().toString(),s)){ if(StringUtils.isNotBlank(name)){ name += ","; } name += StringUtils.defaultString(user.getRealname(),user.getUsername()); } } } } } return name; } @Override public long count(PlatformGroup platformGroup) { QueryWrapper wrapper = new QueryWrapper<>(platformGroup); return platformGroupMapper.selectCount(wrapper); } @Override public List getAllPlatformGroup(PlatformDataDTO platformDataDTO, LoginUserInfo loginUserInfo) { if(Objects.isNull(platformDataDTO) || Objects.isNull(platformDataDTO.getQueryType()) || Objects.isNull(platformDataDTO.getQueryData())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } List platformGroups = platformGroupMapper.selectList( new QueryWrapper() .lambda() .eq(PlatformGroup::getIsdeleted, Constants.ZERO) .orderByAsc(PlatformGroup::getSortnum) ); //查询月台组下所有月台 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(Objects.nonNull(platformDataDTO.getQueryType())&&!Constants.equalsInteger(platformDataDTO.getQueryType(),Constants.ZERO), Platform::getStatus,Constants.ZERO) .orderByAsc(Platform::getSortnum) ); //处理我的月台信息 是否配置隐藏 if(Constants.equalsInteger(platformDataDTO.getQueryType(),Constants.ONE)){ //查询当前登录人配置的可查看月台 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; } } } } } if(Constants.equalsInteger(platformDataDTO.getQueryData(),Constants.ONE)){ //查询今天所有的任务数据 List platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper() .selectAll(PlatformJob.class) .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+" order by pl.CREATE_DATE desc limit 1 ) as newStartDate ") .select(" ( select 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 ") .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName) .selectAs(PlatformBooks::getId,PlatformJob::getBookId) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) .leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .apply(" ( t1.isdeleted = 0 or t.PLATFORM_ID is null ) ") .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(), Constants.PlatformJobStatus.TRANSFERING.getKey() ) // .like(PlatformJob::getArriveDate,DateUtil.getCurrDate()) .orderByDesc(PlatformJob::getCreateDate) ); for (Platform platform:allPlatformList) { PlatformWorkVO platformWorkVO = PlatformGroupServiceImpl.getPlatformWorkVO(platform,platformJobList); platform.setPlatformWorkVO(platformWorkVO); } for (PlatformGroup platformGroup:platformGroups) { platformGroup.setPlatformList(allPlatformList.stream().filter(m->m.getShowConfig()&&Constants.equalsInteger(m.getGroupId(),platformGroup.getId())).collect(Collectors.toList())); } }else{ for (PlatformGroup platformGroup:platformGroups) { platformGroup.setPlatformList(allPlatformList.stream().filter(m->Constants.equalsInteger(m.getGroupId(),platformGroup.getId())).collect(Collectors.toList())); } } return platformGroups; } public static PlatformWorkVO getPlatformWorkVO(Platform platform,List platformJobList){ PlatformWorkVO platformWorkVO = new PlatformWorkVO(); platformWorkVO.setCurrentDate(new Date()); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ //获取月台组下的所有作业数据 List platformJobs = platformJobList.stream().filter( i->Constants.equalsInteger(i.getPlatformId(),platform.getId()) || Constants.equalsInteger(i.getPlatformGroupId(),platform.getGroupId()) ).collect(Collectors.toList()); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobs)){ for(PlatformJob i :platformJobList){ if(Constants.equalsInteger(i.getOrigin(),Constants.ZERO)){ i.setWmsContractNum(i.getContractNum()); } } platformWorkVO.setWorkNum( platformJobs.stream().filter(i->Constants.equalsInteger(i.getPlatformId(),platform.getId()) && Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())).collect(Collectors.toList()).size() ); platformWorkVO.setCallNum( platformJobs.stream().filter(i->Constants.equalsInteger(i.getPlatformId(),platform.getId()) && Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())).collect(Collectors.toList()).size() ); platformWorkVO.setWaitNum( platformJobs.stream().filter(i-> Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) ).collect(Collectors.toList()).size() + platformJobList.stream().filter(i-> ( Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) && Constants.equalsInteger(i.getPlatformGroupId(),platform.getGroupId()) )|| ( Constants.equalsInteger(platform.getId(),i.getPlatformId()) && Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) ) ).collect(Collectors.toList()).size() ); platformWorkVO.setExceptionNum( platformJobs.stream().filter(i->Constants.equalsInteger(platform.getId(),i.getPlatformId()) && Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.EXCEPTION.getKey())).collect(Collectors.toList()).size() ); platformWorkVO.setPlatformJobList(platformJobs.stream().filter( i->Constants.equalsInteger(platform.getId(),i.getPlatformId()) && !Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) ).collect(Collectors.toList())); } } return platformWorkVO; } @Override public PlatformGroupWorkVO getPlatformGroupWork(Integer platformGroupId){ PlatformGroupWorkVO platformGroupWorkVO = new PlatformGroupWorkVO(); platformGroupWorkVO.setExceptionNum(platformJobJoinMapper.selectJoinCount(new MPJLambdaWrapper() .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .eq(Platform::getIsdeleted,Constants.ZERO) .eq(PlatformJob::getPlatformGroupId,platformGroupId) .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.EXCEPTION.getKey()) ) ); platformGroupWorkVO.setWaitNum(platformJobJoinMapper.selectJoinCount(new MPJLambdaWrapper() .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .apply(" ( t1.isdeleted = 0 or t.PLATFORM_ID is null ) ") .eq(PlatformJob::getPlatformGroupId,platformGroupId) .and( 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_GROUP_ID = "+platformGroupId+" ) ") ) ) ); return platformGroupWorkVO; } }