beacon-api/src/main/java/com/mashibing/api/service/SmsService.java

@@ -5,7 +5,7 @@ import javax.servlet.http.HttpServletRequest;
 /**
  * @author heqijun
  * @ClassName: SmsService
- * @Description: SmsService接口
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/5 16:56
  */
 

beacon-api/src/main/java/com/mashibing/api/service/impl/SmsServiceImpl.java

@@ -12,7 +12,7 @@ import javax.servlet.http.HttpServletRequest;
 /**
  * @author heqijun
  * @ClassName: SmsServiceImpl
- * @Description: SmsServiceImpl接口实现类
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/5 16:57
  */
 

beacon-api/src/main/java/com/mashibing/api/service/sendCheck/SendCheckContext.java

@@ -11,7 +11,7 @@ import java.util.Map;
 /**
  * @author heqijun
  * @ClassName: SendCheckContext
- * @Description: 短信发送入口侧校验上下文
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/4 20:19
  */
 

beacon-cache/src/main/java/com/mashibing/cache/controller/CacheController.java

@@ -12,7 +12,7 @@ import java.util.Set;
 /**
  * @author heqijun
  * @ClassName: CacheController
- * @Description: 缓存模块CacheController接口
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/5 13:46
  */
 
@@ -76,21 +76,6 @@ public class CacheController {
 		redisClient.sAdd(key, value);
 	}
 
-	@PostMapping("/sinterstr/{key}/{sinterkey}")
-	public Set<Object> sinterStr(@PathVariable(value = "key") String key, @PathVariable String sinterkey, @RequestBody String... value) {
-		log.info("【缓存模块】sinterStr: key = {}，sinterkey={}，\nvalue = {}", key, sinterkey, value);
-		//1. 存入key和value
-		redisClient.sAdd(key, value);
-		//2. 取交集
-		Set<Object> result = redisClient.sIntersect(key, sinterkey);
-		if (result != null && !result.isEmpty()) {
-			log.info("【缓存模块】sinterStr: 交集={}", result);
-		}
-		//3. 删除key
-		redisClient.delete(key);
-		return result;
-	}
-
 	@PostMapping("/smember/{key}")
 	public Set smember(@PathVariable(value = "key") String key) {
 		log.info("【缓存模块】smember: key = {}，", key);

beacon-common/src/main/java/com/mashibing/common/annotation/Description.java

@@ -8,7 +8,7 @@ import java.lang.annotation.Target;
 /**
  * @author heqijun
  * @ClassName: Description
- * @Description: 用于描述字段的含义
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/4 20:42
  */
 

beacon-common/src/main/java/com/mashibing/common/annotation/validParam/NotNull.java

@@ -3,7 +3,7 @@ package com.mashibing.common.annotation.validParam;
 /**
  * @author heqijun
  * @ClassName: NotNull
- * @Description: 自定义@NotNull注解（未实现）
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/5 11:46
  */
 

beacon-common/src/main/java/com/mashibing/common/clients/BeaconCacheClient.java

@@ -42,9 +42,6 @@ public interface BeaconCacheClient {
 	@PostMapping("cache/saddstr/{key}")
 	void saddStr(@PathVariable(value = "key") String key, @RequestBody String... value);
 
-	@PostMapping("cache/sinterstr/{key}/{sinterkey}")
-	Set<Object> sinterStr(@PathVariable(value = "key") String key, @PathVariable String sinterkey, @RequestBody String... value);
-
 	@PostMapping("cache/smember/{key}")
 	Set smember(@PathVariable(value = "key") String key);
 

beacon-common/src/main/java/com/mashibing/common/enums/JsonResultCode.java

@@ -5,7 +5,7 @@ import lombok.*;
 /**
  * @author heqijun
  * @ClassName: JsonResultCodeEnum
- * @Description: JsonResultCode枚举
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/5 11:57
  */
 

beacon-strategy/pom.xml

@@ -48,13 +48,6 @@
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
-        <!-- ik分词器 -->
-        <dependency>
-            <groupId>com.janeluo</groupId>
-            <artifactId>ikanalyzer</artifactId>
-            <version>2012_u6</version>
-        </dependency>
-
         <!-- common公共组件 -->
         <dependency>
             <groupId>com.mashibing</groupId>

beacon-strategy/src/main/java/com/mashibing/strategy/StragyApplication.java

@@ -7,16 +7,16 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 
 /**
  * @author heqijun
- * @ClassName: StrategyApplication
+ * @ClassName: StragyApplication
- * @Description: StrategyApplication策略模块启动类
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/7 19:03
  */
 
 @SpringBootApplication
 @EnableFeignClients
 @EnableDiscoveryClient
-public class StrategyApplication {
+public class StragyApplication {
 	public static void main(String[] args) {
-		SpringApplication.run(StrategyApplication.class, args);
+		SpringApplication.run(StragyApplication.class, args);
 	}
 }

beacon-strategy/src/main/java/com/mashibing/strategy/config/RestTemplateConfig.java

@@ -7,7 +7,7 @@ import org.springframework.web.client.RestTemplate;
 /**
  * @author heqijun
  * @ClassName: RestTemplateConfig
- * @Description: RestTemplateConfig
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/8 16:33
  */
 

beacon-strategy/src/main/java/com/mashibing/strategy/mq/PreSendListener.java

@@ -15,7 +15,7 @@ import java.io.IOException;
 /**
  * @author heqijun
  * @ClassName: PreSendListener
- * @Description: 策略模块配置监听接口模块消息的队列
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/7 19:36
  */
 

beacon-strategy/src/main/java/com/mashibing/strategy/pojo/PhasePojo.java

@@ -6,7 +6,7 @@ import lombok.Data;
 /**
  * @author heqijun
  * @ClassName: PhasePOJO
- * @Description: 号段补全功能pojo
+ * @Description: TODO(这里用一句话描述这个类的作用)
  * @date 2025/6/8 16:39
  */
 

beacon-strategy/src/main/java/com/mashibing/strategy/service/strategyfilter/impl/DFADirtyWordStrategyFilter.java

@@ -1,51 +0,0 @@
-package com.mashibing.strategy.service.strategyfilter.impl;
-
-import com.mashibing.common.constant.CacheConstant;
-import com.mashibing.common.pojo.StandardSubmit;
-import com.mashibing.strategy.feignclient.CacheClient;
-import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
-import com.mashibing.strategy.utils.DirtyWordTree;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-import org.wltea.analyzer.core.IKSegmenter;
-import org.wltea.analyzer.core.Lexeme;
-
-import java.io.IOException;
-import java.io.StringReader;
-import java.util.HashSet;
-import java.util.Set;
-
-/**
- * @author heqijun
- * @ClassName: DirtyWordStrategyFilter
- * @Description: 敏感词校验
- * @date 2025/6/7 20:26
- */
-
-@Slf4j
-@Service(value = "dfaDirtyword")
-public class DFADirtyWordStrategyFilter implements StrategyFilter {
-
-	@Autowired
-	CacheClient cacheClient;
-
-	@Override
-	public void strategy(StandardSubmit submit) {
-		log.info("【策略模块-敏感词校验】开始====================================");
-		String text = submit.getText();
-		Set<String> set = new HashSet<>();
-		long start = System.currentTimeMillis();
-		long end = System.currentTimeMillis();
-
-		log.info("【策略模块-敏感词校验】通过敏感词树校验敏感词");
-		Set<String> result = DirtyWordTree.getDirtyWord(text);
-
-		if (!result.isEmpty()) {
-			log.error("【策略模块-敏感词校验】短信内容包含敏感词：{}", result);
-			return;
-//			throw new RuntimeException("短信内容包含敏感词");
-		}
-		log.info("【策略模块-敏感词校验】敏感词校验通过");
-	}
-}

beacon-strategy/src/main/java/com/mashibing/strategy/service/strategyfilter/impl/DirtyWordStrategyFilter.java

@@ -1,19 +1,9 @@
 package com.mashibing.strategy.service.strategyfilter.impl;
 
-import com.mashibing.common.constant.CacheConstant;
 import com.mashibing.common.pojo.StandardSubmit;
-import com.mashibing.strategy.feignclient.CacheClient;
 import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.wltea.analyzer.core.IKSegmenter;
-import org.wltea.analyzer.core.Lexeme;
-
-import java.io.IOException;
-import java.io.StringReader;
-import java.util.HashSet;
-import java.util.Set;
 
 /**
  * @author heqijun
@@ -26,41 +16,8 @@ import java.util.Set;
 @Service(value = "dirtyword")
 public class DirtyWordStrategyFilter implements StrategyFilter {
 
-	@Autowired
-	CacheClient cacheClient;
-
 	@Override
-	public void strategy(StandardSubmit submit) {
+	public void strategy(StandardSubmit standardSubmit) {
-		log.info("【策略模块-敏感词校验】开始====================================");
+		log.info("【策略模块-敏感词校验】。。。");
-		Set<String> set = new HashSet<>();
-		long start = System.currentTimeMillis();
-		StringReader reader = new StringReader(submit.getText());
-		IKSegmenter ik = new IKSegmenter(reader, false);
-		long end = System.currentTimeMillis();
-		log.info("【策略模块-敏感词校验】分词器读取短信耗时：{}ms", end - start);
-		Lexeme lexeme = null;
-		start = System.currentTimeMillis();
-		while (true) {
-			try {
-				lexeme = ik.next();
-			} catch (IOException e) {
-				log.error("【策略模块-敏感词校验】IK分词器处理短信内容异常" + "\n e={}", e.getMessage());
-				e.printStackTrace();
-			}
-			if (lexeme == null) {
-				break;
-			}
-			set.add(lexeme.getLexemeText());
-		}
-		end = System.currentTimeMillis();
-		log.info("【策略模块-敏感词校验】分词耗时：{}ms", end - start);
-		//交集
-		Set<Object> result = cacheClient.sinterStr(submit.getSequenceId().toString(), CacheConstant.DIRTY_WORD, set.toArray(new String[0]));
-
-		if (result != null && !result.isEmpty()) {
-			log.error("【策略模块-敏感词校验】短信内容包含敏感词：{}", result);
-			throw new RuntimeException("短信内容包含敏感词");
-		}
-		log.info("【策略模块-敏感词校验】敏感词校验通过");
 	}
 }

beacon-strategy/src/main/java/com/mashibing/strategy/utils/DirtyWordTree.java

@@ -1,116 +0,0 @@
-package com.mashibing.strategy.utils;
-
-import com.mashibing.common.constant.CacheConstant;
-import com.mashibing.strategy.feignclient.CacheClient;
-
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-/**
- * @author heqijun
- * @ClassName: DirtyWordTree
- * @Description: 敏感词树工具类
- * @date 2025/6/8 21:23
- */
-
-public class DirtyWordTree {
-
-	private static final Map DIRTY_WORD_TREE = new HashMap<>();
-
-	static {
-		//通过SpringUtil，获取Spring中的CacheClient对象
-		CacheClient cacheClient = (CacheClient) StringUtil.getBeanByClass(CacheClient.class);
-		//调用缓存模块接口获取全部敏感词
-		Set<String> dirtyWords = cacheClient.smember(CacheConstant.DIRTY_WORD);
-		//构建敏感词树
-		buildTree(dirtyWords);
-	}
-
-	/**
-	 * 构建敏感词树
-	 * 基于dfa算法实现敏感词树
-	 * 原理：整体结构是一个map，每个词的第一个字都是key，每个字key的value都是一个map
-	 * 字对应的map里存【以当前字结尾是否是敏感词】和下一个字key和value的map
-	 *
-	 * @param dirtyWordsSet 敏感词列表
-	 */
-	private static void buildTree(Set<String> dirtyWordsSet) {
-		Map<String, Map> currentMap;
-		//遍历每个词
-		for (String dirtyWord : dirtyWordsSet) {
-			//外层循环中每次都要指定当前map为最外层map
-			currentMap = DIRTY_WORD_TREE;
-			for (int i = 0; i < dirtyWord.length(); i++) {
-				//获取词中的每个字
-				String singleWord = String.valueOf(dirtyWord.charAt(i));
-				//如果当前字不在当前层的map中，则添加进去
-				if (!currentMap.containsKey(singleWord)) {
-					currentMap.put(singleWord, new HashMap());
-				}
-				//当前字对应的map
-				Map currentWordMap = currentMap.get(singleWord);
-				//如果当前字的map中妹有isEnd，说明这是刚添进去的字，要指定isEnd
-				if (!currentWordMap.containsKey("isEnd") && i < dirtyWord.length() - 1) {
-					//如果没到当前词末尾，说明不是敏感词，指定为false
-					currentWordMap.put("isEnd", false);
-				} else if (i == dirtyWord.length() - 1) {
-					//如果到了当前词末尾，说明是敏感词，指定为true
-					currentWordMap.put("isEnd", true);
-				}
-				//每个词的循环中，下一个字要进到下一层map中
-				currentMap = currentWordMap;
-			}
-		}
-	}
-
-	/**
-	 * 匹配敏感词并返回结果
-	 *
-	 * @param text 要匹配的文本
-	 * @return 匹配结果
-	 */
-	public static Set<String> getDirtyWord(String text) {
-
-		//拿到敏感词树
-		Map currentMap;
-		Set<String> result = new HashSet<>();
-
-		//遍历文本
-		for (int i = 0; i < text.length(); i++) {
-			currentMap = DIRTY_WORD_TREE;
-			//记录匹配上的敏感字的长度
-			int dirtyLength = 0;
-			boolean isDirty = false;
-			for (int j = i; j < text.length(); j++) {
-				//当前字
-				String currentWord = String.valueOf(text.charAt(j));
-				currentMap = (Map) currentMap.get(currentWord);
-				if (currentMap == null) {
-					//没匹配上，直接break
-					break;
-				}
-				//匹配上了
-				dirtyLength++;
-				//判断是否是敏感词，不是的话，继续下一个字
-				if ((Boolean) currentMap.get("isEnd")) {
-					//是敏感词，退出循环，记录匹配到的敏感词
-					isDirty = true;
-					break;
-				}
-			}
-
-			if (isDirty) {
-				//记录匹配到的敏感词
-				result.add(text.substring(i, i + dirtyLength));
-			}
-
-		}
-
-		return result;
-	}
-
-	private DirtyWordTree() {
-	}
-}

beacon-strategy/src/main/java/com/mashibing/strategy/utils/StringUtil.java

@@ -1,32 +0,0 @@
-package com.mashibing.strategy.utils;
-
-import org.springframework.beans.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.stereotype.Component;
-
-/**
- * @author heqijun
- * @ClassName: StringUtil
- * @Description: 用于在非ioc管理的类中使用spring中的bean
- * @date 2025/6/8 23:09
- */
-
-@Component
-public class StringUtil implements ApplicationContextAware {
-
-	private static ApplicationContext applicationContext;
-
-	@Override
-	public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
-		StringUtil.applicationContext = applicationContext;
-	}
-
-	public static Object getBeanByName(String beanName) {
-		return applicationContext.getBean(beanName);
-	}
-
-	public static Object getBeanByClass(Class<?> clazz) {
-		return applicationContext.getBean(clazz);
-	}
-}

beacon-test/src/test/java/com/mashibing/test/mapper/ClientBusinessMapperTest.java

@@ -27,7 +27,6 @@ class ClientBusinessMapperTest {
 		ClientBusiness cb = mapper.findById(1L);
 		cb.setIpAddress("192.168.1.5");
 		cb.setClientFilters("phase," + cb.getClientFilters());
-		cb.setClientFilters( cb.getClientFilters().replace("dirtyword","dfaDirtyword"));
 		System.out.println(cb);
 		ObjectMapper mapper = new ObjectMapper();
 		cacheClient.hset("client_business:" + cb.getApikey(), mapper.convertValue(cb, Map.class));