From d52037b84cd6689b1cc03b47a5cd43fcb6b7342f Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期二, 26 九月 2023 21:23:51 +0800
Subject: [PATCH] 贝博粮情解析1
---
igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/command/RemoteGasServiceImpl.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 47 insertions(+), 4 deletions(-)
diff --git a/igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/command/RemoteGasServiceImpl.java b/igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/command/RemoteGasServiceImpl.java
index f475b24..6918ae1 100644
--- a/igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/command/RemoteGasServiceImpl.java
+++ b/igds-protocol-modbus/src/main/java/com/ld/igds/protocol/modbus/command/RemoteGasServiceImpl.java
@@ -1,6 +1,7 @@
package com.ld.igds.protocol.modbus.command;
import com.ld.igds.constant.BizType;
+import com.ld.igds.constant.RedisConst;
import com.ld.igds.io.RemoteGasService;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.constant.ProtocolEnum;
@@ -14,6 +15,7 @@
import com.ld.igds.protocol.modbus.ServerUtil;
import com.ld.igds.protocol.modbus.data.ModbusGasResult;
import com.ld.igds.protocol.modbus.data.ModbusTcp;
+import com.ld.igds.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@@ -39,6 +41,9 @@
private HModbusService modbusService;
@Resource
private AnalysisService analysisService;
+ @Resource
+ private RedisUtil redisUtil;
+
@Override
public String getProtocol() {
@@ -47,6 +52,12 @@
@Override
public GasResponse checkGas(CheckGasRequest request) {
+
+ boolean isRun = isRun(request);
+ if (isRun) {
+ return new GasResponse(OrderRespEnum.ORDER_ERROR.getCode(), "鎻愰啋锛氬綋鍓嶄粨姝ｅ湪鎵ц妫�娴�");
+ }
+
String passCode = request.getDepotId();
try {
@@ -64,6 +75,7 @@
boolean exeResult = ModbusUtil2.writeCoilStatus(modbusTcp.getIp(), modbusTcp.getPort(), modbusTcp.getAddrExe(), true);
if (exeResult) {
+ addRun(request);
//璋冪敤寮傛鑾峰彇缁撴灉
progressGasResult(request, modbusTcp);
log.debug("--------鍚姩娴嬫皵---{}-{}", modbusTcp.getSerId(), modbusTcp.getBizCode());
@@ -76,6 +88,27 @@
return new GasResponse(OrderRespEnum.ORDER_SUCCESS);
}
+ private void addRun(CheckGasRequest request) {
+ String key = RedisConst.buildKey(request.getCompanyId(), ServerUtil.RUN_TAG, request.getDepotId());
+
+ redisUtil.set(key, request, 6 * 60);
+ }
+
+ private void delRun(CheckGasRequest request) {
+ String key = RedisConst.buildKey(request.getCompanyId(), ServerUtil.RUN_TAG, request.getDepotId());
+
+ redisUtil.del(key);
+ }
+
+ private boolean isRun(CheckGasRequest request) {
+ String key = RedisConst.buildKey(request.getCompanyId(), ServerUtil.RUN_TAG, request.getDepotId());
+
+ Object obj = redisUtil.get(key);
+ if (null == obj) return false;
+
+ return true;
+ }
+
/**
* 寮傛鎵ц杩涘害鏌ヨ
*
@@ -83,6 +116,7 @@
*/
@Async
public void progressGasResult(CheckGasRequest request, ModbusTcp modbusTcp) {
+
log.debug("--------------寮傛鎵ц姘斾綋妫�娴嬭杩囪幏鍙�-------------");
@@ -94,9 +128,15 @@
return;
}
- //鏍规嵁閫氶亾鏁伴噺绾跨▼绛夊緟锛屾瘡涓�氶亾绛夊緟50绉�
+ //鏍规嵁閫氶亾鏁伴噺绾跨▼绛夊緟锛屾瘡涓�氶亾绛夊緟60绉�
Thread.sleep(list.size() * 50 * 1000);
log.debug("--------------绛夊緟鏃堕棿瀹屾垚锛屽紑濮嬭幏鍙栨娴嬬粨鏋�-------------{}", modbusTcp.getBizCode());
+
+ boolean isRun = isRun(request);
+ if (!isRun) {
+ log.info("--------------褰撳墠浠撳簱妫�娴嬪凡缁忓仠姝紝鍙栨秷缁撴灉鏌ヨ-------------{}", modbusTcp.getBizCode());
+ return;
+ }
ModbusTcp modbusTcpTemp = modbusTcp;
List<ModbusGasResult> results = new ArrayList<>();
@@ -120,20 +160,22 @@
modbusTcpTemp.setAddrExe(ServerUtil.getAddrExe(gasModbus.getPh3()));
check = ModbusUtil2.readHoldingRegister(modbusTcpTemp.getIp(), modbusTcpTemp.getPort(), modbusTcpTemp.getAddrExe());
gasResult.setPh3(check);
-
+ log.debug("----閫氶亾{}锛孋o2={}锛孫2={}锛孭h3={}", gasModbus.getPasscode(), gasResult.getCo2(), gasResult.getO2(), gasResult.getPh3());
results.add(gasResult);
}
+ //鍒犻櫎杩愯鏍囪
+ delRun(request);
log.debug("----鑾峰彇鐨勬皵浣撴娴嬬粨鏋�---{}--{}", request.getDepotId(), results.toString());
//閫氱煡瑙ｆ瀽
analysisService.analysisGas(request, results);
-
} catch (Exception e) {
- log.error("------------鏇存柊姘斾綋妫�娴嬬粨鏋滆繘搴﹀け璐ワ紝鎵ц寮傚父-----{}--{}", modbusTcp.getBizCode(), e.getMessage());
+ log.error("------------鏇存柊姘斾綋妫�娴嬬粨鏋滆繘搴﹀け璐ワ紝鎵ц寮傚父-----{}--{}", modbusTcp.getBizCode(), e);
}
}
+
@Override
public GasResponse checkGasByPoint(CheckGasRequest request) {
@@ -162,6 +204,7 @@
log.debug("--------鍏抽棴娴嬫皵---{}-{}", modbusTcp.getSerId(), modbusTcp.getBizCode());
//閫氱煡寮傛缁撴潫缁撴灉閲囬泦
+ delRun(request);
}
} catch (Exception e) {
--
Gitblit v1.9.3