From 5f92b2034f84caeab9cb6efc61ecbe22407935b4 Mon Sep 17 00:00:00 2001 From: vince <757871790@qq.com> Date: 星期二, 16 一月 2024 12:14:03 +0800 Subject: [PATCH] 优化主库协议,支持路由 --- src/main/java/com/fzzy/gateway/hx2023/ScConstant.java | 38 +++++++++++++++++++++++++++++++++++++- 1 files changed, 37 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/fzzy/gateway/hx2023/ScConstant.java b/src/main/java/com/fzzy/gateway/hx2023/ScConstant.java index 1457c53..c3f9da4 100644 --- a/src/main/java/com/fzzy/gateway/hx2023/ScConstant.java +++ b/src/main/java/com/fzzy/gateway/hx2023/ScConstant.java @@ -1,6 +1,10 @@ package com.fzzy.gateway.hx2023; +import com.alibaba.fastjson2.util.UUIDUtils; +import com.fzzy.api.utils.MyMD5Util; import org.apache.commons.lang.math.RandomUtils; + +import java.util.UUID; /** * 甯搁噺 @@ -14,6 +18,8 @@ public static String MESSAGE_TYPE_INVOKE_FUNCTION = "INVOKE_FUNCTION"; + + /** * 绮儏閲囨寚浠� */ @@ -24,15 +30,45 @@ return System.currentTimeMillis() + RandomUtils.nextInt(1000) + ""; } + public static String getUUID() { + return UUID.randomUUID().toString().replaceAll("-", ""); + } + + + + + //API_SOURCE-蹇冭烦 + public static String API_SOURCE_TARGET_EQUIPMENT_HEARTBEAT = "TARGET_EQUIPMENT_HEARTBEAT"; + //API_SOURCE-缃戝叧璁惧鐘舵�佹秷鎭殑 + public static String API_SOURCE_TARGET_EQUIPMENT_STATUS = "TARGET_EQUIPMENT_STATUS"; /** * 涓嬪彂鎸囦护鍥炲鎶ユ枃topic */ public static String TOPIC_REPORT = "/${productId}/${deviceId}/properties/report"; - + /** + * 涓嬪彂鎸囦护鍥炲鎶ユ枃topic + */ + public static String TOPIC_REPORT_GRAIN = "TOPIC_ZLJ_GRAIN_TEMPERATURE"; /** * 璁惧鐩稿叧淇℃伅鎭㈠鎶ユ枃-topic */ public static String TOPIC_MESSAGE_REPORT = "/device/${productId}/${deviceId}/message/property/report"; + + /** + * 缃戝叧璁惧鐘舵�佹秷鎭秷鎭� topic锛歍OPIC_EQUIPMENT_HEARTBEAT_{搴撶偣缂栫爜} + */ + public static String TOPIC_EQUIPMENT_HEARTBEAT = "TOPIC_EQUIPMENT_HEARTBEAT_{kqdm}"; + + + /** + * kafak 绮儏鏁版嵁鎺ㄩ�佸埌浜戠 + */ + public static String TOPIC_ZLJ_GRAIN_TEMPERATURE = "TOPIC_ZLJ_GRAIN_TEMPERATURE"; + + /** + * 缃戝叧璁惧鐘舵�佹秷鎭秷鎭� topic锛歍OPIC_EQUIPMENT_STATUS_{搴撶偣缂栫爜} + */ + public static String TOPIC_EQUIPMENT_STATUS = "TOPIC_EQUIPMENT_STATUS_{kqdm}"; } -- Gitblit v1.9.3