| | |
| | | */ |
| | | 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 |