From d454e51e06dbf7beb50551588fc58a5810295d7c Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期一, 01 一月 2024 19:28:22 +0800
Subject: [PATCH] 调整KFKA数据推送测试。
---
src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java | 13 ++++++++++---
1 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java b/src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java
index 366935a..7f2350e 100644
--- a/src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java
+++ b/src/main/java/com/fzzy/protocol/zldz/service/ZldzGatewayGrainService.java
@@ -91,6 +91,13 @@
}
@Override
+ public BaseResp syncGrainTh(BaseReqData reqData) {
+ BaseResp resp = new BaseResp();
+
+ return resp;
+ }
+
+ @Override
public BaseResp syncConf(BaseReqData reqData) {
BaseResp resp = new BaseResp();
@@ -129,7 +136,7 @@
request.setSerName(device.getDeviceName());
// Step1 鐢熸垚鍛戒护
- Message message = CommandBuilder1116_1.getInstance().buildMessage(request,device);
+ Message message = CommandBuilder1116_1.getInstance().buildMessage(request, device);
// 鍙戦�佸懡浠�
InvokeResult result = ZldzServerEngine.push(device.getIp(), device.getPort(), message.getByteMsg());
@@ -176,13 +183,13 @@
ApiCommonDevice commonDevice = Constant.getCommonDeviceCache(device.getDeviceSn());
- if(null == commonDevice){
+ if (null == commonDevice) {
resp.setCode(500);
resp.setMsg("绯荤粺鏈彂鐜拌繛鎺ヨ澶囷紝鍙栨秷鎵ц");
return resp;
}
- ZldzServerEngine.disconnect(commonDevice.getIp(),commonDevice.getPort());
+ ZldzServerEngine.disconnect(commonDevice.getIp(), commonDevice.getPort());
return resp;
}
--
Gitblit v1.9.3