| | |
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) { |
| | | News.error(" - {}号LED命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | } else { |
| | | |
| | | News.error("{}号LED命令下发成功!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | ledThread.setLedMk(false); |
| | | } |
| | | } |
| | | } |
| | |
| | | ledThread.setLedMk(true); |
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(2, new ArrayList<>()))) { |
| | | News.error("{}号LED命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | }else { |
| | | News.error("{}号LED命令下发成功!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | ledThread.setLedMk(false); |
| | | } |
| | | } |
| | | } |
| | |
| | | private void reset() { |
| | | commandList = null; |
| | | stringBuffer.delete(0, stringBuffer.length()); |
| | | this.ledMk = false; |
| | | } |
| | | |
| | | |
| | | private void error(String msg) { |
| | | errorMsg.delete(0, errorMsg.length()); |
| | | errorMsg.append(msg); |
| | | this.ledMk = false; |
| | | } |
| | | |
| | | public void errorReset() { |
| | | this.errorMsg.delete(0, errorMsg.length()); |
| | | this.ledMk = false; |
| | | } |
| | | |
| | | @Override |