| | |
|---|
| | | vo.setStatus(1); // 状态 |
|---|
| | | Task task = MessageQueue.peek(SlaveType.Crn, crn.getId()); |
|---|
| | | if (task != null) { |
|---|
| | | vo.setCommand(JSON.toJSONString((CrnCommand)task.getData())); |
|---|
| | | try{ |
|---|
| | | vo.setCommand(JSON.toJSONString((CrnCommand)task.getData())); |
|---|
| | | } catch (Exception e){ |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return R.ok().add(list); |
|---|
| | |
|---|
| | | crnCommand.setCrnNo(crn.getId()); // 堆垛机编号 |
|---|
| | | crnCommand.setTaskMode(CrnTaskModeType.CLEAR); |
|---|
| | | crnCommand.setAckFinish((short) 0); // 任务完成确认位 |
|---|
| | | crnCommand.setCommand((short) 0); // 任务完成确认位 |
|---|
| | | // 延时发送 |
|---|
| | | Thread.sleep(1000L); |
|---|
| | | if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, crnCommand))) { |
|---|
