From 332bb1bdc76c4ce93f86c7279ca48542b2c4b080 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期三, 04 六月 2025 09:34:00 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV
---
pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java | 9 ++++
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealAlarmStatus.java | 56 ++++++++++++++--------------
pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_81_Up.java | 5 +-
pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/AlarmVo.java | 8 +++-
4 files changed, 45 insertions(+), 33 deletions(-)
diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_81_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_81_Up.java
index 4dad85f..f0f25a7 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_81_Up.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_81_Up.java
@@ -80,8 +80,9 @@
if(para.data != null && para.data.getSubData() != null){
DataCd81Vo cdData = (DataCd81Vo)((DataV202404)para.data.getSubData()).subData ;
if(cdData.statePump != null){
- //娉�/闃�鐘舵�� (1锛氬紑娉�/闃�锛�0锛氬叧娉�/闃�)
- callback.notify(new ValveStateInfo(cdData.statePump.byteValue()== 1?true:false));
+ //(琛ㄩ榾涓�浣撴満锛�1锛氬紑娉�/闃�锛�0锛氬叧娉�/闃�)(娴嬫帶涓�浣撻榾锛�0锛氬紑娉�/闃�锛�1锛氬叧娉�/闃�)
+ //鍗忚瑙ｆ瀽鏃讹紝缁熶竴杞崲涓轰簡娴嬫帶涓�浣撻榾锛�
+ callback.notify(new ValveStateInfo(cdData.statePump.byteValue()== 0?true:false));
}
}
return new MidResult[]{confirmCommand, midRs} ;
diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java
index e78ba9a..20c8507 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java
@@ -79,13 +79,20 @@
callback.callback(midRs.reportOrResponse_trueOrFalse, para.data.subData==null?null:((DataV202404)(para.data.subData)).subData);
if(para.data != null && para.data.getSubData() != null){
DataCdC2Vo subData = (DataCdC2Vo)((DataV202404)para.data.getSubData()).subData ;
+ /* 2025-06-03 涓嬮潰闃�闂ㄧ姸鎬佹槸鍘熸潵瀹炵幇锛岀幇鍦ㄧ粺璁℃敼涓虹敤鐘舵�佷綅鏁版嵁鍒ゆ柇闃�闂ㄧ姸鎬�
// public Byte opType2 ;//寮�鍚叧闂細0: 寮�鍚� -1:鍏抽棴
// public Boolean success ;//鎵ц缁撴灉锛坱rue鎴愬姛, false澶辫触锛�
if(subData.opType2.byteValue() == 0 && subData.success){
callback.notify(new ValveStateInfo(true));
- }else if(subData.opType2.byteValue() == 1 && subData.success){
+ }else if(subData.opType2.byteValue() == -1 && subData.success){
callback.notify(new ValveStateInfo(false));
}
+ */
+ if(subData.statePump != null){
+ //(琛ㄩ榾涓�浣撴満锛�1锛氬紑娉�/闃�锛�0锛氬叧娉�/闃�)(娴嬫帶涓�浣撻榾锛�0锛氬紑娉�/闃�锛�1锛氬叧娉�/闃�)
+ //鍗忚瑙ｆ瀽鏃讹紝缁熶竴杞崲涓轰簡娴嬫帶涓�浣撻榾锛�
+ callback.notify(new ValveStateInfo(subData.statePump.byteValue()== 0?true:false));
+ }
}
return new MidResult[]{confirmCommand, midRs} ;
diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/AlarmVo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/AlarmVo.java
index ba702f2..2b29f20 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/AlarmVo.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/AlarmVo.java
@@ -9,7 +9,9 @@
public static final byte DevOpenState = 1 ;
public static final byte DevCloseState = 0 ;
- public Byte statePump ; //娉�/闃�鐘舵�� (琛ㄩ榾涓�浣撴満锛�1锛氬紑娉�/闃�锛�0锛氬叧娉�/闃�)(娴嬫帶涓�浣撻榾锛�0锛氬紑娉�/闃�锛�1锛氬叧娉�/闃�)
+ //娉�/闃�鐘舵�� (琛ㄩ榾涓�浣撴満锛�1锛氬紑娉�/闃�锛�0锛氬叧娉�/闃�)(娴嬫帶涓�浣撻榾锛�0锛氬紑娉�/闃�锛�1锛氬叧娉�/闃�)
+ //2025-06-03 鍗忚瑙ｆ瀽鏃朵笌鈥滄祴鎺т竴浣撻榾鈥濊繘琛屼簡鍏煎
+ public Byte statePump ;
public Byte alarmWaterRemain ; //鍓╀綑姘撮噺鎶ヨ (1锛氬皬浜庢姤璀︿笂闄愭姤璀� 0锛氭甯�)
public Byte alarm0WaterRemain ; //鍓╀綑姘撮噺涓�0鍏虫车/闃� (1锛氬墿浣欐按閲忎负0鍏虫车 0锛氭甯�)
public Byte alarmExceedYear ; //骞村害瓒呴噰鎶ヨ (1锛氬勾鐢ㄦ按閲忓ぇ浜庨檺鍒舵按閲忔姤璀� 0锛氭甯�)
@@ -160,7 +162,9 @@
public String toStr(){
StringBuffer sb = new StringBuffer() ;
sb.append("娉�/闃�鐘舵�� : ") ;
- sb.append(statePump == null?"鏈煡":(statePump.byteValue()==1?"娉�/闃�寮�":(statePump.byteValue()==0?"娉�/闃�鍏�":"鏈煡"))) ;
+ //瑙ｆ瀽鏃跺凡缁忓仛浜嗗吋瀹�
+ //sb.append(statePump == null?"鏈煡":(statePump.byteValue()==1?"娉�/闃�寮�":(statePump.byteValue()==0?"娉�/闃�鍏�":"鏈煡"))) ;
+ sb.append(statePump == null?"鏈煡":(statePump.byteValue()==0?"娉�/闃�寮�":(statePump.byteValue()==1?"娉�/闃�鍏�":"鏈煡"))) ;
sb.append("\n") ;
sb.append("鍓╀綑姘撮噺鎶ヨ : ") ;
sb.append(alarmWaterRemain == null?"鏈煡":(alarmWaterRemain.byteValue() == 0 ? "姝ｅ父":(alarmWaterRemain.byteValue() == 1 ? "鎶ヨ":"鏈煡"))) ;
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealAlarmStatus.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealAlarmStatus.java
index 0498b50..23808df 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealAlarmStatus.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealAlarmStatus.java
@@ -54,64 +54,64 @@
//闅忔満鑷姤鎶�
DataCd81Vo dataCd81Vo = (DataCd81Vo)cdObj ;
if (dataCd81Vo.alarmVo != null || dataCd81Vo.stateVo != null) {
+ Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
+ DbSv sv = (DbSv) objs[0];
+ PrController controller = (PrController) objs[1];
+ if(dataCd81Vo.stateVo != null && dataCd81Vo.stateVo.valveState != null && dataCd81Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
+ if(controller != null && controller.getIntakeId() != null){
+ this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
+ toNext = true ;
+ }
+ }
if(this.needSave2Db( d.getRtuAddr())){
//鍦ㄤ竴涓皬鏃跺唴娌℃湁瀛樺偍鎶ヨ鏁版嵁
- Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
- DbSv sv = (DbSv) objs[0];
- PrController controller = (PrController) objs[1];
this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
this.saveHistory(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
this.cacheSaveTime(d.getRtuAddr());
- if(dataCd81Vo.stateVo != null && dataCd81Vo.stateVo.valveState != null && dataCd81Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
- if(controller != null && controller.getIntakeId() != null){
- this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
- toNext = true ;
- }
- }
}
}
} else if (cdObj instanceof DataCd84Vo) {
//闃�寮�宸ヤ綔鎶�
DataCd84Vo dataCd84Vo = (DataCd84Vo)cdObj ;
if (dataCd84Vo.alarmVo != null || dataCd84Vo.stateVo != null) {
+ Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
+ DbSv sv = (DbSv) objs[0];
+ PrController controller = (PrController) objs[1];
+ /** 闃�寮�宸ヤ綔鎶ワ紝闃�闂ㄧ姸鎬佷竴瀹氭槸鎵撳紑鐘舵�侊紝鎵�浠ヤ笉璁剧疆涓嬮潰鏁版嵁浠ュ鍚庣画浠诲姟璁剧疆铏氭嫙鍗＄姸鎬�
+ if(dataCd84Vo.stateVo != null && dataCd84Vo.stateVo.valveState != null && dataCd84Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
+ if(controller != null && controller.getIntakeId() != null){
+ this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
+ toNext = true ;
+ }
+ }*/
if(this.needSave2Db( d.getRtuAddr())) {
//鍦ㄤ竴涓皬鏃跺唴娌℃湁瀛樺偍鎶ヨ鏁版嵁
- Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
- DbSv sv = (DbSv) objs[0];
- PrController controller = (PrController) objs[1];
this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
this.saveHistory(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
this.cacheSaveTime(d.getRtuAddr());
- /** 闃�寮�宸ヤ綔鎶ワ紝闃�闂ㄧ姸鎬佷竴瀹氭槸鎵撳紑鐘舵�侊紝鎵�浠ヤ笉璁剧疆涓嬮潰鏁版嵁浠ュ鍚庣画浠诲姟璁剧疆铏氭嫙鍗＄姸鎬�
- if(dataCd84Vo.stateVo != null && dataCd84Vo.stateVo.valveState != null && dataCd84Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
- if(controller != null && controller.getIntakeId() != null){
- this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
- toNext = true ;
- }
- }*/
}
}
} else if (cdObj instanceof DataCdC0Vo) {
//鏁寸偣鎶�
DataCdC0Vo dataCdC0Vo = (DataCdC0Vo)cdObj ;
if (dataCdC0Vo.alarmVo != null || dataCdC0Vo.stateVo != null) {
+ Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
+ DbSv sv = (DbSv) objs[0];
+ PrController controller = (PrController) objs[1];
+ if(dataCdC0Vo.stateVo != null && dataCdC0Vo.stateVo.valveState != null && dataCdC0Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
+ if(controller != null && controller.getIntakeId() != null){
+ this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
+ toNext = true ;
+ }
+ }
if(this.needSave2Db( d.getRtuAddr())) {
//鍦ㄤ竴涓皬鏃跺唴娌℃湁瀛樺偍鎶ヨ鏁版嵁
- Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
- DbSv sv = (DbSv) objs[0];
- PrController controller = (PrController) objs[1];
this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
this.saveHistory(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
this.cacheSaveTime(d.getRtuAddr());
- if(dataCdC0Vo.stateVo != null && dataCdC0Vo.stateVo.valveState != null && dataCdC0Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
- if(controller != null && controller.getIntakeId() != null){
- this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
- toNext = true ;
- }
- }
}
}
}
--
Gitblit v1.8.0