refeat(jg): 3库数据刷新

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/refresh/adapter/Emq2DataRefreshEvent.java

 package com.yeejoin.amos.boot.module.jg.biz.refresh.adapter;
 
 import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.common.api.constant.TZSCommonConstant;
 import lombok.RequiredArgsConstructor;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.springframework.beans.factory.annotation.Value;
@@ -18,8 +19,6 @@ public class Emq2DataRefreshEvent extends EmqxListener {
 
     private final EmqKeeper emqKeeper;
 
-    @Value("${data.refresh.tp:data/refresh/+/+}")
-    private String dataRefreshTp;
 
     @Value("${spring.application.name}")
     private String applicationName;
@@ -36,7 +35,8 @@ public class Emq2DataRefreshEvent extends EmqxListener {
 
     @PostConstruct
     void init() throws Exception {
-        emqKeeper.subscript(this.buildShareTopic(dataRefreshTp), 2, this);
+        String topic = TZSCommonConstant.DATA_REFRESH_TOPIC.replace("%s", "+");
+        emqKeeper.subscript(this.buildShareTopic(topic), 2, this);
     }
 
     private String buildShareTopic(String topic) {