包名调整

cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/handler/MqttMessageHandler.java

@@ -0,0 +1,40 @@
+package com.njcn.csharmonic.handler;
+
+import com.alibaba.nacos.shaded.com.google.gson.Gson;
+import com.github.tocrhz.mqtt.annotation.MqttSubscribe;
+import com.github.tocrhz.mqtt.annotation.NamedValue;
+import com.github.tocrhz.mqtt.annotation.Payload;
+import com.github.tocrhz.mqtt.publisher.MqttPublisher;
+import com.njcn.csharmonic.pojo.vo.RtDataVO;
+import com.njcn.csharmonic.service.ILineTargetService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2022年03月23日 09:41
+ */
+@Slf4j
+@Component
+@AllArgsConstructor
+public class MqttMessageHandler {
+
+    private final MqttPublisher publisher;
+
+    private final ILineTargetService lineTargetService;
+
+    /**
+     * 实时数据应答
+     */
+    @MqttSubscribe(value = "/zl/askRtData/{pageId}",qos = 1)
+    public void responseRtData(String topic, @NamedValue("pageId") String pageId, MqttMessage message, @Payload String payload) {
+        List<RtDataVO> list = lineTargetService.getLineData(pageId);
+        Gson gson = new Gson();
+        publisher.send("/zl/rtData/"+pageId,gson.toJson(list),1,false);
+    }
+}