| | |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | // 命令下发 ------------------------------------------------------------------------------- |
|---|
| | | // if (!commands.isEmpty()) { |
|---|
| | | // if (led.getId() < 7) { |
|---|
| | | // if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) { |
|---|
| | | // News.error(""+mark+" - 2"+" - {}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | // continue; |
|---|
| | | // } else { |
|---|
| | | // ledThread.setLedMk(false); |
|---|
| | | // } |
|---|
| | | // } else { |
|---|
| | | // if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(1, commands))) { |
|---|
| | | // News.error(""+mark+" - 3"+" - {}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | // continue; |
|---|
| | | // } else { |
|---|
| | | // ledThread.setLedMk(false); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // 命令下发 ------------------------------------------------------------------------------- |
|---|
| | | if (!commands.isEmpty()) { |
|---|
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) { |
|---|
| | | News.error("{}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | continue; |
|---|
| | | }else { |
|---|
| | | ledThread.setLedMk(false); |
|---|
| | | if (led.getId() == 2) { |
|---|
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) { |
|---|
| | | News.error(""+mark+" - 2"+" - {}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | continue; |
|---|
| | | } else { |
|---|
| | | ledThread.setLedMk(false); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(1, commands))) { |
|---|
| | | News.error(""+mark+" - 3"+" - {}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | continue; |
|---|
| | | } else { |
|---|
| | | ledThread.setLedMk(false); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | // // 命令下发 ------------------------------------------------------------------------------- |
|---|
| | | // if (!commands.isEmpty()) { |
|---|
| | | // if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) { |
|---|
| | | // News.error("{}号LED命令下发失败！！！[ip：{}] [port：{}]", led.getId(), led.getIp(), led.getPort()); |
|---|
| | | // continue; |
|---|
| | | // }else { |
|---|
| | | // ledThread.setLedMk(false); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | |
|---|
| | | try { |
|---|
| | | // 修改主档led标记 |
|---|
