|  |  | 
 |  |  | import com.zy.asrs.mapper.TaskWrkMapper; | 
 |  |  | import com.zy.asrs.mapper.WrkMastMapper; | 
 |  |  | import com.zy.asrs.service.*; | 
 |  |  | import com.zy.asrs.utils.CommandUtils; | 
 |  |  | import com.zy.asrs.utils.Utils; | 
 |  |  | import com.zy.common.service.CommonService; | 
 |  |  | import com.zy.core.CrnThread; | 
 |  |  | 
 |  |  |                 crnCommand.setDestinationPosZ(Utils.getLevShort(taskWrk.getTargetPoint()));     // 目标库位排 | 
 |  |  |                 crnCommand.setCommand((short) 1); | 
 |  |  |                 log.info("堆垛机入库任务下发={}", crnCommand); | 
 |  |  |                 if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand), false)) { | 
 |  |  |                 if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { | 
 |  |  |                     log.error("堆垛机命令生成失败,堆垛机号={},任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); | 
 |  |  |                     throw new CoolException("堆垛机命令生成失败"); | 
 |  |  |                 } else { | 
 |  |  | 
 |  |  |                             taskWrk.setMarkStart(1); | 
 |  |  |                         } | 
 |  |  |  | 
 |  |  |                         if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, command), false)) { | 
 |  |  |                         if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, command))) { | 
 |  |  |                             log.error("堆垛机命令生成失败,堆垛机号={},任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(command)); | 
 |  |  |                             throw new CoolException("堆垛机命令生成失败"); | 
 |  |  |                         } else { | 
 |  |  | 
 |  |  |                 crnCommand.setDestinationPosY(Utils.getBayShort(taskWrk.getTargetPoint()));     // 目标库位列 | 
 |  |  |                 crnCommand.setDestinationPosZ(Utils.getLevShort(taskWrk.getTargetPoint()));     // 目标库位层 | 
 |  |  |                 crnCommand.setCommand((short) 1); | 
 |  |  |                 if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand), false)) { | 
 |  |  |                 if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { | 
 |  |  |                     log.error("堆垛机命令下发失败,堆垛机号={},任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); | 
 |  |  |                 } else { | 
 |  |  |                     // 修改工作档状态 11.生成出库ID => 12.吊车出库中 |