|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | BasDevp checkSiteStatus(Integer devpNo, boolean put); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | int getStoreCount(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | package com.zy.asrs.service.impl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.service.impl.ServiceImpl; | 
|---|
|  |  |  | import com.core.exception.CoolException; | 
|---|
|  |  |  | import com.zy.asrs.entity.BasDevp; | 
|---|
|  |  |  | import com.zy.asrs.entity.TaskWrk; | 
|---|
|  |  |  | import com.zy.asrs.mapper.BasDevpMapper; | 
|---|
|  |  |  | import com.zy.asrs.service.BasDevpService; | 
|---|
|  |  |  | import com.zy.asrs.service.WrkMastService; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return station; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public int getStoreCount() { | 
|---|
|  |  |  | return baseMapper.selectCount(new EntityWrapper<BasDevp>().in("loading","Y")); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | int storeCount = taskWrkService.getStoreCount(taskWrk.getCrnNo()); | 
|---|
|  |  |  | int storeCount = basDevpService.getStoreCount(); | 
|---|
|  |  |  | if(storeCount >= maxCount){ | 
|---|
|  |  |  | log.error("{}号堆垛机暂存数已满!", taskWrk.getCrnNo()); | 
|---|
|  |  |  | log.error("输送线暂存数达到上限"); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public int getStoreCount(Integer crnNo){ | 
|---|
|  |  |  | return selectCount(new EntityWrapper<TaskWrk>().eq("crn_no", crnNo).in("wrk_sts",12,14,2)); | 
|---|
|  |  |  | return selectCount(new EntityWrapper<TaskWrk>().eq("crn_no", crnNo).in("wrk_sts",12,2)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  | publicKeysStorePath: publicCerts.keystore | 
|---|
|  |  |  |  | 
|---|
|  |  |  | wms: | 
|---|
|  |  |  | #堆垛机任务暂存数 | 
|---|
|  |  |  | count: 5 | 
|---|
|  |  |  | #输送线暂存数 | 
|---|
|  |  |  | count: 8 | 
|---|
|  |  |  | # 是否开启上报 | 
|---|
|  |  |  | start: true | 
|---|
|  |  |  | # WMS系统ip | 
|---|