|
@ -19,6 +19,7 @@ import org.springframework.scheduling.annotation.Scheduled; |
|
|
import org.springframework.stereotype.Component; |
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
|
import java.net.InetSocketAddress; |
|
|
import java.net.InetSocketAddress; |
|
|
|
|
|
import java.util.HashMap; |
|
|
import java.util.Map; |
|
|
import java.util.Map; |
|
|
import java.util.UUID; |
|
|
import java.util.UUID; |
|
|
import java.util.concurrent.CompletableFuture; |
|
|
import java.util.concurrent.CompletableFuture; |
|
@ -118,6 +119,9 @@ public class TcpClient { |
|
|
CompletableFuture<DeviceFeedback> future = new CompletableFuture<>(); |
|
|
CompletableFuture<DeviceFeedback> future = new CompletableFuture<>(); |
|
|
deviceMessageHandler.responseMap.put(request.getId(), future); |
|
|
deviceMessageHandler.responseMap.put(request.getId(), future); |
|
|
try { |
|
|
try { |
|
|
|
|
|
if (request.getParams() == null) { |
|
|
|
|
|
request.setParams(new HashMap<>()); |
|
|
|
|
|
} |
|
|
request.getParams().put("class", "test"); |
|
|
request.getParams().put("class", "test"); |
|
|
String requestJsonStr = JSONUtil.toJsonStr(request); |
|
|
String requestJsonStr = JSONUtil.toJsonStr(request); |
|
|
log.info("发送TCP指令(同步) {}", requestJsonStr); |
|
|
log.info("发送TCP指令(同步) {}", requestJsonStr); |
|
|