From 656aa4f953eb52502a6414965e46642c31b6e8ee Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期二, 29 四月 2025 15:33:09 +0800 Subject: [PATCH] 设备会在多种功能码上报数据中携带报警与状态数据,这样数据库保存设备报警与状态数据可能很多,为此修改逻辑,当前实现为一设备一个小时内只保存一条报警与状态数据。 --- pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/AdapterImp_ProtocolUnit.java | 73 ++++++++++++++++++++++++++++++++++++ 1 files changed, 73 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/AdapterImp_ProtocolUnit.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/AdapterImp_ProtocolUnit.java new file mode 100644 index 0000000..7204b66 --- /dev/null +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/AdapterImp_ProtocolUnit.java @@ -0,0 +1,73 @@ +package com.dy.rtuMw.server; + +import com.dy.common.mw.protocol.MidResultAction; +import com.dy.common.mw.protocol.Notify; +import com.dy.common.mw.protocol.ProtocolConfigVo; +import com.dy.common.mw.protocol.ProtocolUnitAdapter; +import com.dy.rtuMw.server.forTcp.MidResultActionError; +import com.dy.rtuMw.server.forTcp.MidResultActionFromRtu; +import com.dy.rtuMw.server.forTcp.MidResultActionToRtu; +import com.dy.rtuMw.server.rtuStateFrProt.RtuInfoNotify; + +public class AdapterImp_ProtocolUnit implements ProtocolUnitAdapter { + + private static final MidResultAction toRtu = new MidResultActionToRtu() ; + private static final MidResultAction fromRtu = new MidResultActionFromRtu() ; + private static final MidResultAction error = new MidResultActionError() ; + + private static final RtuInfoNotify notify = new RtuInfoNotify() ; + + private ProtocolConfigVo configVo = null ; + + @Override + public ProtocolConfigVo getConfig() { + return this.configVo; + } + + public void setConfig(ProtocolConfigVo configVo) { + this.configVo = configVo; + } + /** + * 鍗曠嚎绋嬬幆澧冧腑杩愯锛屽緱鍒板崟涓猂TU淇℃伅閫氱煡鍣� + * @param protocolName 鍗忚鍚嶇О + * @return Notify + */ + @Override + public Notify getSingleRtuInfoNotify(String protocolName) { + return notify ; + } + + /** + * 鍗曠嚎绋嬬幆澧冧腑杩愯锛屽緱鍒板崟涓� 澶勭悊RTU涓嬭鏁版嵁鐨凪idResultAction鎵ц瀵硅薄 + * @param protocolName 鍗忚鍚嶇О + * @return MidResultAction + */ + @Override + public MidResultAction getSingleActionToRtu(String protocolName) { + return toRtu ; + } + + /** + * 鍗曠嚎绋嬬幆澧冧腑杩愯锛屽緱鍒板崟涓鐞哛TU涓婅鏁版嵁鐨凪idResultAction鎵ц瀵硅薄 + * @param protocolName 鍗忚鍚嶇О + * @return MidResultAction + */ + @Override + public MidResultAction getSingleActionFromRtu(String protocolName) { + return fromRtu ; + } + + /** + * 鍗曠嚎绋嬬幆澧冧腑杩愯锛屽緱鍒板崟涓鐞嗗嚭閿欑殑MidResultAction鎵ц瀵硅薄 + * @param protocolName 鍗忚鍚嶇О + * @return MidResultAction + */ + @Override + public MidResultAction getSingleActionError(String protocolName) { + return error ; + } + + + + +} -- Gitblit v1.8.0