From a69402c8b67d8ce4b698d0c394d15ff43b5d99d0 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 14 十二月 2023 23:17:41 +0800
Subject: [PATCH] 提交正来电子协议解析-3
---
src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java | 145 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 141 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java b/src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java
index a29e503..c0612b4 100644
--- a/src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java
+++ b/src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java
@@ -71,6 +71,143 @@
return "SUCCESS";
}
+
+ /**
+ * 涓嬭鍒嗘満娴嬭瘯鍏ュ彛
+ *
+ * @param param
+ * @return
+ */
+ @PostMapping("/test/IDE")
+ public @ResponseBody
+ String testIDE(@RequestBody GateWayParam param) throws Exception {
+
+ if (StringUtils.isEmpty(param.getBizType())) {
+ return "ERROR:娌℃湁鑾峰彇鍒颁笟鍔＄被鍨嬶紝鎵ц澶辫触";
+ }
+
+ //鑾峰彇鍒嗘満閰嶇疆
+ if ("syncConf".equals(param.getBizType())) {
+ return syncConf(param);
+ }
+
+ if ("writeConf".equals(param.getBizType())) {
+ return writeConf(param);
+ }
+
+ if ("initParam".equals(param.getBizType())) {
+ return initCable(param);
+ }
+
+ if ("disconnect".equals(param.getBizType())) {
+ return disconnect(param);
+ }
+
+ if ("transparent".equals(param.getBizType())) {
+ return transparent(param);
+ }
+
+ return "SUCCESS";
+ }
+
+
+ private String transparent(GateWayParam param) {
+
+ String deviceId = param.getDeviceId();
+
+ GatewayDevice device = GatewayUtils.getCacheByDeviceId(deviceId);
+
+ BaseReqData reqData = new BaseReqData();
+ reqData.setDeviceId(device.getDeviceId());
+ reqData.setProductId(device.getProductId());
+ reqData.setDeviceName(device.getDeviceName());
+ reqData.setDevice(device);
+ reqData.setAutoReplay(false);
+
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).transparent(reqData);
+ if (BaseResp.CODE_200 != resp.getCode()) {
+ return "ERROR锛�" + resp.getMsg();
+ }
+ return "SUCCESS";
+ }
+
+ private String disconnect(GateWayParam param) {
+ String deviceId = param.getDeviceId();
+
+ GatewayDevice device = GatewayUtils.getCacheByDeviceId(deviceId);
+
+ BaseReqData reqData = new BaseReqData();
+ reqData.setDeviceId(device.getDeviceId());
+ reqData.setProductId(device.getProductId());
+ reqData.setDeviceName(device.getDeviceName());
+ reqData.setDevice(device);
+ reqData.setAutoReplay(false);
+
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).disconnect(reqData);
+ if (BaseResp.CODE_200 != resp.getCode()) {
+ return "ERROR锛�" + resp.getMsg();
+ }
+ return "SUCCESS";
+ }
+
+ private String initCable(GateWayParam param) {
+ String deviceId = param.getDeviceId();
+
+ GatewayDevice device = GatewayUtils.getCacheByDeviceId(deviceId);
+
+ BaseReqData reqData = new BaseReqData();
+ reqData.setDeviceId(device.getDeviceId());
+ reqData.setProductId(device.getProductId());
+ reqData.setDeviceName(device.getDeviceName());
+ reqData.setDevice(device);
+ reqData.setAutoReplay(false);
+
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).initCable(reqData);
+ if (BaseResp.CODE_200 != resp.getCode()) {
+ return "ERROR锛�" + resp.getMsg();
+ }
+ return "SUCCESS";
+ }
+
+ private String syncConf(GateWayParam param) {
+
+ String deviceId = param.getDeviceId();
+
+ GatewayDevice device = GatewayUtils.getCacheByDeviceId(deviceId);
+
+ BaseReqData reqData = new BaseReqData();
+ reqData.setDeviceId(device.getDeviceId());
+ reqData.setProductId(device.getProductId());
+ reqData.setDeviceName(device.getDeviceName());
+ reqData.setDevice(device);
+ reqData.setAutoReplay(false);
+
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).syncConf(reqData);
+ if (BaseResp.CODE_200 != resp.getCode()) {
+ return "ERROR锛�" + resp.getMsg();
+ }
+ return "SUCCESS";
+ }
+
+ private String writeConf(GateWayParam param) {
+ String deviceId = param.getDeviceId();
+
+ GatewayDevice device = GatewayUtils.getCacheByDeviceId(deviceId);
+
+ BaseReqData reqData = new BaseReqData();
+ reqData.setDeviceId(device.getDeviceId());
+ reqData.setProductId(device.getProductId());
+ reqData.setDeviceName(device.getDeviceName());
+ reqData.setDevice(device);
+ reqData.setAutoReplay(false);
+
+ BaseResp resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).writeConf(reqData);
+ if (BaseResp.CODE_200 != resp.getCode()) {
+ return "ERROR锛�" + resp.getMsg();
+ }
+ return "SUCCESS";
+ }
+
/**
* 鍒濆鍖栬溅鐗岃瘑鍒�
*
@@ -98,7 +235,7 @@
reqData = new BaseReqData(device);
reqData.setIndex(i);
syncLprService = gatewayRemoteManager.getSyncLprService(device.getSyncProtocol());
- if(null == syncLprService) continue;
+ if (null == syncLprService) continue;
syncLprService.initLpr(reqData);
i++;
}
@@ -126,10 +263,10 @@
return "ERROR锛氬綋鍓嶈澶囨病鏈夐厤缃竷绾胯鍒欙紝鏃犳硶鎵ц";
}
- BaseResp resp =null;
- if(GatewayDeviceProtocol.DEVICE_TEST.getCode().equals(device.getSyncProtocol())){
+ BaseResp resp;
+ if (GatewayDeviceProtocol.DEVICE_TEST.getCode().equals(device.getSyncProtocol())) {
resp = gatewayRemoteManager.getGatewayTestService(device.getPushProtocol()).testGrain(reqData);
- }else{
+ } else {
reqData.setAutoReplay(false);
resp = gatewayRemoteManager.getSyncGrainService(device.getSyncProtocol()).syncGrain(reqData);
}
--
Gitblit v1.9.3