[+] 终端告警信令

taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/flute/media/DataConsumer.java

@@ -1,5 +1,39 @@
 package com.acgist.taoyao.signal.flute.media;
 
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 数据消费者
+ * 
+ * @author acgist
+ */
+@Getter
+@Setter
 public class DataConsumer {
 
+    /**
+     * 消费者终端
+     */
+    private final ClientWrapper consumeClient;
+    /**
+     * 生产者
+     */
+    private final Producer producer;
+    /**
+     * 数据流ID
+     */
+    private final String streamId;
+    /**
+     * 消费者标识
+     */
+    private final String consumerId;
+    
+    public DataConsumer(ClientWrapper consumeClient, Producer producer, String streamId, String consumerId) {
+        this.consumeClient = consumeClient;
+        this.producer = producer;
+        this.streamId = streamId;
+        this.consumerId = consumerId;
+    }
+    
 }

taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/flute/media/DataProducer.java

@@ -1,9 +1,42 @@
 package com.acgist.taoyao.signal.flute.media;
 
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 数据生产者
+ * 
+ * @author acgist
+ */
+@Setter
+@Getter
 public class DataProducer {
 
-    private Map<String, DataConsumer> dataConsumers;
+    /**
+     * 生产者终端
+     */
+    private final ClientWrapper produceClient;
+    /**
+     * 数据流ID
+     */
+    private final String streamId;
+    /**
+     * 生产者标识
+     */
+    private final String producerId;
+    /**
+     * 消费者
+     */
+    private final Map<String, DataConsumer> dataConsumers;
+    
+    public DataProducer(ClientWrapper produceClient, String streamId, String producerId) {
+        this.produceClient = produceClient;
+        this.streamId = streamId;
+        this.producerId = producerId;
+        this.dataConsumers = new ConcurrentHashMap<>();
+    }
     
 }

taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/client/ClientAlarmProtocol.java

@@ -39,16 +39,21 @@ public class ClientAlarmProtocol extends ProtocolClientAdapter {
     
     @Override
     public void execute(String clientId, ClientType clientType, Client client, Message message, Map<String, Object> body) {
+        final String alarmMessage = MapUtils.get(body, Constant.MESSAGE);
+        final String alarmDatetime = MapUtils.get(body, Constant.DATETIME);
         log.warn(
             """
-            终端发生告警：{}
-            {}
-            {}
+            终端告警：{}
+            终端类型：{}
+            告警描述：{}
+            告警时间：{}
             """,
             clientId,
-            MapUtils.get(body, Constant.MESSAGE),
-            MapUtils.get(body, Constant.DATETIME)
+            clientType,
+            alarmMessage,
+            alarmDatetime
         );
+        // 业务逻辑
     }
     
 }