| | |
| | | /** |
| | | * 罐装线要桶数量减少 |
| | | */ |
| | | private void decreaseWantBucketCount(int site, int decrease) { |
| | | private void decreaseWantBucketCount(int site, int decrease) throws InterruptedException { |
| | | |
| | | int siteNew; |
| | | switch (site) { |
| | |
| | | return; |
| | | } |
| | | |
| | | staProtocol.setWantBucketCount(remaining); // 设置剩余要桶数 |
| | | |
| | | boolean offer = MessageQueue.offer(SlaveType.Devp, inGzxSiteList.indexOf(site) + 4, new Task(6, staProtocol)); |
| | | if (offer) { |
| | | log.info("自动出空桶减少罐装线要桶数命令推送队列成功:站点:{},剩余要桶数:{}" ,site, remaining); |
| | |
| | | } |
| | | |
| | | log.info("自动出空桶减少罐装线要桶数成功,站点:{},减少前:{},减少数:{},剩余要桶数:{}", site, count, decrease, remaining); |
| | | Thread.sleep(1200); |
| | | } |
| | | |
| | | /** |