动态处理报警等级

src/main/java/com/persagy/dmp/starter/alarm/communication/netty/NettyAlarmMsgBaseHandler.java

@@ -270,6 +270,10 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
                     // 更新报警记录状态
                     updateAlarmRecord(nettyMessage);
                     break;
+                case 11:
+                    // 报警仍在继续
+                    alarmContinue(nettyMessage);
+                    break;
                 default:
                     log.info("边缘端发来的参数无效，参数值为：" + opCode);
                     break;
@@ -280,6 +284,20 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
         }
     }
 
+    /**
+     * @description: 报警仍在持续的处理方法
+     * @param: nettyMessage
+     * @return: void
+     * @exception:
+     * @author: lixing
+     * @company: Persagy Technology Co.,Ltd
+     * @since: 2020/12/17 4:44 下午
+     * @version: V1.0
+     */
+    public void alarmContinue(NettyAlarmMessage nettyMessage) {
+        log.info("报警仍在继续：{}", nettyMessage.toString());
+    }
+
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) {
         ctx.flush();

src/main/java/com/persagy/dmp/starter/alarm/service/NettyAlarmService.java

@@ -120,14 +120,14 @@ public abstract class NettyAlarmService extends BaseService{
     /**
      * @description: 获取报警扩充字段
      * @param: objId
-     * @return: java.lang.String
+     * @return: JSONObject
      * @exception:
      * @author: lixing
      * @company: Persagy Technology Co.,Ltd
      * @since: 2020/11/30 4:00 下午
      * @version: V1.0
      */
-    public abstract String getAlarmSupplement(String objId);
+    public abstract JSONObject getAlarmSupplement(String objId);
 
     /**
      * @description: 获取报警等级