| | |
|---|
| | | |
|---|
| | | barcodeThread.setBarcode(""); |
|---|
| | | staProtocol.setWorkNo(dto.getWorkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(dto.getStaNo().shortValue()); |
|---|
| | | |
|---|
| | | if(Cools.isEmpty(dto.getRgvNo()) || dto.getRgvNo() <= 0) { |
|---|
| | | staProtocol.setStaNo(dto.getStaNo().shortValue()); |
|---|
| | | } else {//如果存在RGV编号，说明需要RGV接驳，先下发任务到RGV源站 |
|---|
| | | staProtocol.setStaNo(dto.getRgvSstaNo().shortValue()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | if (!result) { |
|---|
