From 715f40da0c953ec0080ccf056f9d759c3a249ea0 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期五, 10 十一月 2023 01:37:12 +0800
Subject: [PATCH] 重新调整代码结构和实现方式2,注意设备中的上行协议调整
---
src/main/java/com/fzzy/gateway/controller/GatewayDeviceTestController.java | 3 ++-
src/main/java/com/fzzy/gateway/service/GatewayDeviceTestPR.java | 6 +++---
src/main/resources/application-devGateway.yml | 4 ++--
src/main/java/com/fzzy/gateway/hx2023/service/OnReceiveMqttService.java | 23 ++++++++++++-----------
src/main/java/com/fzzy/protocol/weightyh/MessageConsumer.java | 2 +-
src/main/java/com/fzzy/gateway/view/GatewayDevice.js | 2 +-
6 files changed, 21 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/controller/GatewayDeviceTestController.java b/src/main/java/com/fzzy/gateway/controller/GatewayDeviceTestController.java
index bd56953..605ee3a 100644
--- a/src/main/java/com/fzzy/gateway/controller/GatewayDeviceTestController.java
+++ b/src/main/java/com/fzzy/gateway/controller/GatewayDeviceTestController.java
@@ -105,7 +105,8 @@
reqData.setData(resp.getData());
gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportGrainData(reqData);
}
- return "SUCCESS锛氭墽琛屽畬鎴�";
+
+ return "SUCCESS";
}
diff --git a/src/main/java/com/fzzy/gateway/hx2023/service/OnReceiveMqttService.java b/src/main/java/com/fzzy/gateway/hx2023/service/OnReceiveMqttService.java
index 5957fe6..e7b4560 100644
--- a/src/main/java/com/fzzy/gateway/hx2023/service/OnReceiveMqttService.java
+++ b/src/main/java/com/fzzy/gateway/hx2023/service/OnReceiveMqttService.java
@@ -1,14 +1,14 @@
package com.fzzy.gateway.hx2023.service;
import com.alibaba.fastjson2.JSONObject;
+import com.fzzy.api.data.GatewayDeviceProtocol;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.api.GatewayRemoteManager;
+import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.gateway.data.BaseResp;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.hx2023.ScConstant;
import com.fzzy.gateway.hx2023.data.CloudSendData;
-import com.fzzy.gateway.data.BaseReqData;
-import com.fzzy.mqtt.MqttGatewayService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
@@ -23,8 +23,6 @@
@Resource
private GatewayRemoteManager gatewayRemoteManager;
- @Resource
- private MqttGatewayService mqttGatewayService;
/**
@@ -32,7 +30,7 @@
*
* @param message
*/
- public void onReceiveMessage(String topic,String message) {
+ public void onReceiveMessage(String topic, String message) {
try {
CloudSendData cloudSendData = JSONObject.parseObject(message, CloudSendData.class);
@@ -44,7 +42,7 @@
}
} catch (Exception e) {
- log.error("--------鎵ц寮傚父-----{}",e);
+ log.error("--------鎵ц寮傚父-----{}", e);
}
}
@@ -57,6 +55,8 @@
BaseReqData syncReqData = new BaseReqData();
syncReqData.setDeviceId(deviceId);
+ syncReqData.setProductId(device.getProductId());
+ syncReqData.setDeviceName(device.getDeviceName());
syncReqData.setMessageId(cloudSendData.getMessageId());
syncReqData.setMessageType(cloudSendData.getMessageType());
syncReqData.setFunctionId(cloudSendData.getFunctionId());
@@ -64,11 +64,12 @@
syncReqData.setDevice(device);
- //TODO --->>鏆傛椂杩斿洖娴嬭瘯鏁版嵁
-
- //BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).syncGrain(syncReqData);
-
- BaseResp resp = gatewayRemoteManager.getGatewayTestService(device.getPushProtocol()).testGrain(syncReqData);
+ BaseResp resp;
+ if (GatewayDeviceProtocol.DEVICE_TEST.getCode().equals(device.getSyncProtocol())) {
+ resp = gatewayRemoteManager.getGatewayTestService(device.getPushProtocol()).testGrain(syncReqData);
+ } else {
+ resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).syncGrain(syncReqData);
+ }
//鑷姩鎺ㄩ��
if (200 == resp.getCode() && syncReqData.isAutoReplay()) {
diff --git a/src/main/java/com/fzzy/gateway/service/GatewayDeviceTestPR.java b/src/main/java/com/fzzy/gateway/service/GatewayDeviceTestPR.java
index 2bf419b..4061c62 100644
--- a/src/main/java/com/fzzy/gateway/service/GatewayDeviceTestPR.java
+++ b/src/main/java/com/fzzy/gateway/service/GatewayDeviceTestPR.java
@@ -73,7 +73,7 @@
return "ERROR锛氬綋鍓嶈澶囨病鏈夐厤缃竷绾胯鍒欙紝鏃犳硶鎵ц";
}
- BaseResp resp = gatewayRemoteManager.getSyncGrainService(data.getSyncProtocol()).syncGrain2(reqData);
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(data.getSyncProtocol()).syncGrain(reqData);
//鑷姩鎺ㄩ��
if (200 == resp.getCode() && reqData.isAutoReplay()) {
@@ -153,11 +153,11 @@
if (null == deviceReportService) {
- deviceReportService = gatewayRemoteManager.getDeviceReportService(device.getProvinceProtocol());
+ deviceReportService = gatewayRemoteManager.getDeviceReportService(device.getPushProtocol());
}
- deviceReportService.pushGrainData2Cloud(pushData);
+ // deviceReportService.pushGrainData2Cloud(pushData);
}
diff --git a/src/main/java/com/fzzy/gateway/view/GatewayDevice.js b/src/main/java/com/fzzy/gateway/view/GatewayDevice.js
index 0cd48e7..d8bb2b8 100644
--- a/src/main/java/com/fzzy/gateway/view/GatewayDevice.js
+++ b/src/main/java/com/fzzy/gateway/view/GatewayDevice.js
@@ -6,7 +6,7 @@
$.ajax({
type:"POST",
contentType:"application/json;charset=UTF-8",
- url:"/sc2023/gateway/test/deviceTest",
+ url:"/gateway/test/deviceTest",
data:JSON.stringify(param),
success:function(result){
$alert(result);
diff --git a/src/main/java/com/fzzy/protocol/weightyh/MessageConsumer.java b/src/main/java/com/fzzy/protocol/weightyh/MessageConsumer.java
index 84020a0..580b4d7 100644
--- a/src/main/java/com/fzzy/protocol/weightyh/MessageConsumer.java
+++ b/src/main/java/com/fzzy/protocol/weightyh/MessageConsumer.java
@@ -75,7 +75,7 @@
reportService = SpringUtil.getBean(GatewayRemoteManager.class);
}
- reportService.getDeviceReportService(device.getProvinceProtocol()).report2GatewayBySn(weigh, device);
+ reportService.getDeviceReportService(device.getPushProtocol()).report2GatewayBySn(weigh, device);
}
/**
diff --git a/src/main/resources/application-devGateway.yml b/src/main/resources/application-devGateway.yml
index 044667c..473ed3c 100644
--- a/src/main/resources/application-devGateway.yml
+++ b/src/main/resources/application-devGateway.yml
@@ -73,8 +73,8 @@
host: tcp://127.0.0.1:1883
username: admin
password: admin123321
- client-inId: fzzy-clientInId-igds-api
- client-outId: fzzy-clientInOutId-igds-api
+ client-inId: fzzy_client_id_in_igds_api
+ client-outId: fzzy_client_id_out_igds_api
completionTimeout: 3000
keep-alive-interval: 2
max-connect-times: 5
--
Gitblit v1.9.3