| | |
| | | import com.zy.core.cache.MessageQueue; |
| | | import com.zy.core.cache.OutputQueue; |
| | | import com.zy.core.cache.SlaveConnection; |
| | | import com.zy.core.enums.LiftProtocolStatusType; |
| | | import com.zy.core.enums.SlaveType; |
| | | import com.zy.core.model.LiftSlave; |
| | | import com.zy.core.model.Task; |
| | |
| | | // 获取提升机信息 |
| | | LiftThread liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, basLift.getLiftNo()); |
| | | if (liftThread == null) { |
| | | vo.setProtocolStatus(LiftProtocolStatusType.OFFLINE.id);//离线 |
| | | continue; |
| | | } |
| | | LiftProtocol liftProtocol = liftThread.getLiftProtocol(); |
| | |
| | | assignCommand.setTaskNo((short) 9999); |
| | | assignCommand.setTaskMode(param.getLiftTaskMode().shortValue()); |
| | | assignCommand.setAuto(false);//手动模式 |
| | | assignCommand.setLev(param.getLev());//移动楼层 |
| | | |
| | | if (MessageQueue.offer(SlaveType.Lift, liftSlave.getId(), new Task(3, assignCommand))) { |
| | | return R.ok(); |