```

feat(mqtt-core): 增加厂商枚举主题配置和自动订阅功能 - 为FirmEnum添加topics字段，支持关联TopicType集合 - 添加TopicType枚举定义在线服务和回执服务主题 - 实现TopicInit初始化类，系统启动时自动订阅厂商对应的主题 - 在PrintDeviceService接口中增加SN查询和厂商存在性检查方法 - 重构ReceiveEventType的matchEventType方法，使用Optional优化代码 - 新增isFirmExist方法用于检查厂商是否存在 ```

```
feat(mqtt-core): 增加厂商枚举主题配置和自动订阅功能 - 为FirmEnum添加topics字段，支持关联TopicType集合 - 添加TopicType枚举定义在线服务和回执服务主题 - 实现TopicInit初始化类，系统启动时自动订阅厂商对应的主题 - 在PrintDeviceService接口中增加SN查询和厂商存在性检查方法 - 重构ReceiveEventType的matchEventType方法，使用Optional优化代码 - 新增isFirmExist方法用于检查厂商是否存在 ```
zhangmeiyang
1 parent a399fc10
Showing 5 changed files with 81 additions and 11 deletions
mqtt-core/src/main/java/com/diligrp/mqtt/core/init/TopicInit.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/service/PrintDeviceService.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/type/FirmEnum.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/type/ReceiveEventType.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/type/TopicType.java
+package com.diligrp.mqtt.core.init;
+
+import com.diligrp.mqtt.core.service.MqttTopicService;
+import com.diligrp.mqtt.core.service.PrintDeviceService;
+import com.diligrp.mqtt.core.type.FirmEnum;
+import jakarta.annotation.Resource;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+
+/**
+ * @Author: zhangmeiyang
+ * @CreateTime: 2026-01-15 15:16
+ * @Version: todo
+ */
+@Component
+public class TopicInit implements ApplicationRunner {
+
+    @Resource
+    private PrintDeviceService printDeviceService;
+
+    @Resource
+    private MqttTopicService mqttTopicService;
+
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        Arrays.stream(FirmEnum.values())
+                .filter(f -> printDeviceService.isFirmExist(f.code))
+                .forEach(t -> t.topics.forEach(topic -> mqttTopicService.subscribeTopic(topic.value, topic.qos)));
+    }
+}
@@ -10,8 +10,20 @@ import org.springframework.stereotype.Service;
 public interface PrintDeviceService {
  
  
+    /**
+     * SN 查询
+     *
+     * @param sn
+     * @return {@link PrintDeviceDto }
+     */
     PrintDeviceDto queryBySn(String sn);
  
+    /**
+     * 是确定存在
+     *
+     * @param firm 公司
+     * @return {@link Boolean }
+     */
     Boolean isFirmExist(String firm);
  
  
 package com.diligrp.mqtt.core.type;
  
-import lombok.Getter;
+import java.util.Set;
  
 /**
  * @author lvqi
  */
-@Getter
 public enum FirmEnum {
-    CLOUD("cloud", "云打印");
+    CLOUD("cloud", "云打印", Set.of(TopicType.PRINTER_ONLINE_SERVICE, TopicType.PRINTER_RECEIPT_SERVICE));
  
-    private final String code;
-    private final String name;
+    public final String code;
+    public final String name;
+    public final Set<TopicType> topics;
  
-    FirmEnum(String code, String name) {
+    FirmEnum(String code, String name, Set<TopicType> topics) {
         this.code = code;
         this.name = name;
+        this.topics = topics;
     }
  
  
-
 }
 package com.diligrp.mqtt.core.type;
  
-import java.util.Objects;
+import java.util.Optional;
  
 public enum ReceiveEventType {
     PRINTER_RECEIPT_SERVICE("/printSucc/"),
@@ -19,9 +19,18 @@ public enum ReceiveEventType {
      * @return 匹配的事件类型，未匹配成功则返回null
      */
     public static ReceiveEventType matchEventType(String topic) {
-        if (Objects.isNull(topic)) {
-            return UNKNOWN_SERVICE;
-        }
+        return Optional.ofNullable(topic)
+                .map(ReceiveEventType::of)
+                .orElse(UNKNOWN_SERVICE);
+    }
+
+    /**
+     * 关于
+     *
+     * @param topic 主题
+     * @return {@link ReceiveEventType }
+     */
+    public static ReceiveEventType of(String topic) {
         for (ReceiveEventType eventType : ReceiveEventType.values()) {
             if (topic.startsWith(eventType.value)) {
                 return eventType;
+package com.diligrp.mqtt.core.type;
+
+public enum TopicType {
+
+    PRINTER_ONLINE_SERVICE("/priGoOnline/#", 1),
+    PRINTER_RECEIPT_SERVICE("/printSucc/#", 1);
+
+    public final String value;
+    public final int qos;
+
+    TopicType(String value, int qos) {
+        this.value = value;
+        this.qos = qos;
+    }
+}