| | |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | log.error("小车任务完成下发输送线任务："+staProtocol); |
|---|
| | | try{ |
|---|
| | | Thread.sleep(1000); |
|---|
| | | DevpThread devpThreadEnd = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | StaProtocol staProtocolEnd = devpThreadEnd.getStation().get(wrkMastSta.getStaEnd()); |
|---|
| | | log.error("小车任务完成读取输送线任务："+staProtocolEnd); |
|---|
| | | if (staProtocolEnd.getWorkNo()==0 ){ //|| !staProtocolEnd.getWorkNo().equals(wrkMast.getWrkNo()) |
|---|
| | | staProtocolEnd.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | staProtocolEnd.setStaNo(wrkMast.getStaNo()); |
|---|
| | | if (!MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocolEnd))) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | log.error("小车任务完成下发输送线任务第二次："+staProtocolEnd); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | |
|---|
| | | } |
|---|
| | | // try{ |
|---|
| | | // Thread.sleep(1000); |
|---|
| | | // DevpThread devpThreadEnd = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | // StaProtocol staProtocolEnd = devpThreadEnd.getStation().get(wrkMastSta.getStaEnd()); |
|---|
| | | // log.error("小车任务完成读取输送线任务："+staProtocolEnd); |
|---|
| | | // if (staProtocolEnd.getWorkNo()==0 ){ //|| !staProtocolEnd.getWorkNo().equals(wrkMast.getWrkNo()) |
|---|
| | | // staProtocolEnd.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | // staProtocolEnd.setStaNo(wrkMast.getStaNo()); |
|---|
| | | // if (!MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocolEnd))) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // log.error("小车任务完成下发输送线任务第二次："+staProtocolEnd); |
|---|
| | | // } |
|---|
| | | // }catch (Exception e){ |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | wrkMastSta.setWrkSts(3); |
|---|
| | | wrkMastStaMapper.updateById(wrkMastSta); |
|---|
