人大金仓适配

amos-boot-data/amos-boot-data-equip/src/main/java/com/yeejoin/equip/service/HandleESMessage2TDService.java

@@ -39,7 +39,7 @@ public class HandleESMessage2TDService {
     /**
      * 十分钟拉取ES数据存入TdEngine
      */
-    @Scheduled(cron = "0 */2 * * * ?")
+    @Scheduled(cron = "0 */10 * * * ?")
     @Transactional(rollbackFor = Exception.class)
     public void syncEsData2TDEngine() throws Exception {
         SimpleDateFormat format = new SimpleDateFormat(datePattern);
@@ -56,7 +56,7 @@ public class HandleESMessage2TDService {
         try {
             HashMap<String, String> syncFlag = new HashMap<>();
             syncFlag.put("sync_flag", "success");
-            emqKeeper.getMqttClient().publish("sync_esdata_to_tdengine_notice1", JSON.toJSONString(syncFlag).getBytes(), 0, false);
+            emqKeeper.getMqttClient().publish("sync_esdata_to_tdengine_notice", JSON.toJSONString(syncFlag).getBytes(), 0, false);
             log.info("同步ES数据至发发送消息给业务发送通知成功！");
         } catch (Exception exception) {
             log.info("同步ES数据至发发送消息给业务发送通知失败！");