From 7f34a90f8e27465d8209b906fed2754a3f9ac214 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期三, 05 八月 2020 14:50:47 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/DevpThread.java | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/zy/core/thread/DevpThread.java b/src/main/java/com/zy/core/thread/DevpThread.java index c41c511..d61638d 100644 --- a/src/main/java/com/zy/core/thread/DevpThread.java +++ b/src/main/java/com/zy/core/thread/DevpThread.java @@ -32,7 +32,7 @@ while (true) { try { Task task = MessageQueue.poll(SlaveType.Devp, slave.getId()); - if (task == null) { + if (task != null) { System.out.println("浠诲姟"+task.getId()); } Thread.sleep(3000); @@ -48,10 +48,10 @@ melsecMcNet = new MelsecMcNet(slave.getIp(), slave.getPort()); OperateResult operateResult = melsecMcNet.ConnectServer(); if (operateResult.IsSuccess) { - log.info("杈撻�佺嚎plc杩炴帴鎴愬姛 ===>> [ip:{}] [port:{}]", slave.getIp(), slave.getPort()); + log.info("杈撻�佺嚎plc杩炴帴鎴愬姛 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); return true; } else { - log.info("杈撻�佺嚎plc杩炴帴澶辫触锛侊紒锛� ===>> [ip:{}] [port:{}]", slave.getIp(), slave.getPort()); + log.info("杈撻�佺嚎plc杩炴帴澶辫触锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); return false; } } -- Gitblit v1.9.1