From d8eb22351c6d0bfe0c9f233edfd593538e6838c9 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期四, 24 四月 2025 13:58:49 +0800 Subject: [PATCH] 1、表阀一体机协议开阀类型变化; 2、表阀一体机协议开关阀报中增加水价数据; --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/PrefixedDataAvailable.java | 19 +++++++++++-------- 1 files changed, 11 insertions(+), 8 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/PrefixedDataAvailable.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/PrefixedDataAvailable.java index f55f9ae..1058dc3 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/PrefixedDataAvailable.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/PrefixedDataAvailable.java @@ -3,6 +3,7 @@ import org.apache.mina.core.buffer.IoBuffer; import com.dy.common.mw.channel.tcp.PrefixedDataAvailableStatus; +import org.apache.mina.core.session.IoSession; public interface PrefixedDataAvailable { @@ -15,10 +16,11 @@ * @return 涓嶆椂鏈崗璁暟鎹椂杩斿洖绌� * @throws Exception 寮傚父 */ - PrefixedDataAvailableStatus forOnLine(IoBuffer in, - int remain, - int minDataLength, - int maxDataLength) throws Exception ; + PrefixedDataAvailableStatus forOnLine(IoSession ioSession, + IoBuffer in, + int remain, + int minDataLength, + int maxDataLength) throws Exception ; /** * 鍒嗘瀽涓婄嚎鍚�(缃戠粶杩炴帴鍚庨潪绗竴鍖呮暟鎹�)鏄惁鍙幏寰� @@ -29,9 +31,10 @@ * @return PrefixedDataAvailableStatus * @throws Exception 寮傚父 */ - PrefixedDataAvailableStatus forUpData(IoBuffer in, - int remain, - int minDataLength, - int maxDataLength) throws Exception; + PrefixedDataAvailableStatus forUpData(IoSession ioSession, + IoBuffer in, + int remain, + int minDataLength, + int maxDataLength) throws Exception; } -- Gitblit v1.8.0