From 880273d6b3687ea601ddb6d46acb9b660a9f76de Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 10 十月 2024 16:50:41 +0800
Subject: [PATCH] 1、发送钉钉的报警消息中去除漏损报警; 2、漏损报警消息产生与发送放于定时报中,漏损量大于配置值时才报警,并把漏损量一并发送出去。

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/ProtocolUnit.java |   21 ++++++++++-----------
 1 files changed, 10 insertions(+), 11 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/ProtocolUnit.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/ProtocolUnit.java
index 87020e3..c33a3c3 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/ProtocolUnit.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/ProtocolUnit.java
@@ -5,7 +5,7 @@
 
 import com.dy.common.mw.UnitAdapterInterface;
 import com.dy.common.mw.UnitInterface;
-import com.dy.common.mw.UnitStartedCallbackInterface;
+import com.dy.common.mw.UnitCallbackInterface;
 
 
 public class ProtocolUnit implements UnitInterface {
@@ -39,21 +39,20 @@
 	/**
 	 * 鍚姩妯″潡
 	 */
-	public void start(UnitStartedCallbackInterface callback) throws Exception {
+	public void start(UnitCallbackInterface callback) throws Exception {
 		//寰楀埌鍞竴瀹炰緥锛� 骞跺湪鐢熸垚鍞竴瀹炰緥鏃讹紝鎵弿娉ㄨВ绫�
 		AnnotationScan.getIntance() ;
 		
 		//鍚勪釜鍗忚椹卞姩绫绘壂鎻忚嚜宸辩殑鍔熻兘鐮佹敞瑙�
-		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCach.getDriverMap() ;
+		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCache.getDriverMap() ;
 		Collection<String> colDrivers = drivers.keySet() ;
-		String totalProtocols = null ;
+		StringBuilder totalProtocols = new StringBuilder() ;
 		for(String protocolName : colDrivers){
-			if(totalProtocols == null){
-				totalProtocols = protocolName ;
-			}else{
-				totalProtocols += "锛�" + protocolName ;
+			if(!totalProtocols.isEmpty()){
+				totalProtocols.append("锛�") ;
 			}
-			Driver dri = ProtocolCach.getDriver(protocolName) ;
+			totalProtocols.append(protocolName) ;
+			Driver dri = ProtocolCache.getDriver(protocolName) ;
 			if(dri != null){
 				dri.scanAnnotationCode();
 			}
@@ -71,12 +70,12 @@
 	 */
 	@SuppressWarnings("unused")
 	public boolean isOnlyOneProtocol(){
-		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCach.getDriverMap() ;
+		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCache.getDriverMap() ;
 		return drivers.size() == 1 ;
 	}
 
 	@Override
-	public void stop(UnitStartedCallbackInterface callback) {
+	public void stop(UnitCallbackInterface callback) {
 	}
 	
 	/*

--
Gitblit v1.8.0