|
|
@@ -1,38 +0,0 @@
|
|
|
-package com.middle.platform.data.biz.service.mqtt;
|
|
|
-
|
|
|
-import com.middle.platform.redis.constant.CacheConstant;
|
|
|
-import com.middle.platform.redis.service.CacheService;
|
|
|
-import jakarta.annotation.Resource;
|
|
|
-import org.apache.commons.lang3.StringUtils;
|
|
|
-import org.springframework.stereotype.Component;
|
|
|
-
|
|
|
-/**
|
|
|
- * mqtt-topic解析
|
|
|
- *
|
|
|
- * @author xucaiqin
|
|
|
- * @date 2023-12-22 11:27:55
|
|
|
- */
|
|
|
-@Component
|
|
|
-public class StrategyAnalyze {
|
|
|
- @Resource
|
|
|
- private CacheService cacheService;
|
|
|
-
|
|
|
- /**
|
|
|
- * 设备上报数据,通过topic获取对应的策略类.
|
|
|
- * redis:<topic,功能权限> 到 <功能权限,策略类>
|
|
|
- *
|
|
|
- * @param topic mqtt topic
|
|
|
- * @return
|
|
|
- */
|
|
|
- public String getByTopic(String topic) {
|
|
|
- //1.topic查找对应的功能权限
|
|
|
- String func = (String) cacheService.getKey(String.format(CacheConstant.TOPIC_CACHE, topic));
|
|
|
- if (StringUtils.isNotBlank(func)) {
|
|
|
- //2.功能权限到策略类
|
|
|
- return FuncPerEnum.strategy(func);
|
|
|
- }
|
|
|
- return "";
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
-}
|