|  |  | 
 |  |  |                     staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue()); | 
 |  |  |                     staProtocol.setStaNo(wrkMast.getStaNo().shortValue()); | 
 |  |  |                     devpThread.setPakMk(staProtocol.getSiteId(), false); | 
 |  |  |                     log.warn("盘点再入库给输送线下发命令前:{}",JSON.toJSON(staProtocol)); | 
 |  |  |                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); | 
 |  |  |                     if (!result) { | 
 |  |  |                         log.error("发布命令至输送线队列失败!!! [plc编号:{}]", devp.getId()); | 
 
 |  |  | 
 |  |  | //        OperateResult write1 = siemensS7Net.Write("DB101." + index*2, staProtocol.getStaNo());    // 目标站 | 
 |  |  |  | 
 |  |  |         if (!write.IsSuccess) { | 
 |  |  |             log.warn("盘点再入库给输送线下发命令完成:{}",JSON.toJSON(staProtocol)); | 
 |  |  |             staProtocol = station.get(staProtocol.getSiteId()); | 
 |  |  |             if (staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0) { | 
 |  |  |                 staProtocol.setPakMk(true); |