查重边际条件

community-service/src/main/java/com/tanpu/community/manager/ThemeManager.java

@@ -951,6 +951,9 @@ public class ThemeManager {
     }
 
 
+    /**
+     * 查重初始化
+     */
     @Transactional
     public void initThemeTextCheck() {
         List<ThemeEntity> themeEntities = themeService.queryLatestThemes(30);
@@ -959,7 +962,7 @@ public class ThemeManager {
             List<ThemeContentQo> content = themeQo.getContent();
             for (ThemeContentQo themeContentQo : content) {
                 if (themeContentQo.getType().equals(RelTypeEnum.TEXT.type)) {
-                    if (themeContentQo.getValue().length() > 50)
+                    if (StringUtils.isNotBlank(themeContentQo.getValue()) && themeContentQo.getValue().length() > 50)
                         themeTextCheckService.insertInit(themeContentQo.getValue(), themeQo.getThemeId(),
                                 themeQo.getAuthorId(), TimeUtils.getDateTimeOfTimestamp(themeQo.getCreateTime()), themeQo.getThemeType());
                 }

community-service/src/main/java/com/tanpu/community/service/ThemeTextCheckService.java

@@ -25,19 +25,23 @@ public class ThemeTextCheckService {
 
     // 插入
     public void insert(String content, String themeId, String userId, Integer themeType, String editThemeId) {
-        try{
-            if (StringUtils.isNotBlank(editThemeId)){
+        if (StringUtils.isBlank(content) || content.length() < 50) {
+            return;
+        }
+
+        try {
+            if (StringUtils.isNotBlank(editThemeId)) {
                 themeCheckDuplicateMapper.deleteByThemeId(editThemeId);
             }
             content = content.replaceAll(regex, "。");
             String[] split = content.split("。");
             for (int i = 0; i < split.length; i++) {
                 String trim = StringUtils.trim(split[i]);
-                insert(themeId, trim, getHash(trim), i + 1, split.length, userId,themeType);
+                insert(themeId, trim, getHash(trim), i + 1, split.length, userId, themeType);
 
             }
-        }catch (Exception e){
-            log.error("文本查重insert失败,themeId:"+themeId);
+        } catch (Exception e) {
+            log.error("文本查重insert失败,themeId:" + themeId);
         }
 
     }
@@ -47,7 +51,7 @@ public class ThemeTextCheckService {
         themeCheckDuplicateMapper.deleteByThemeId(themeId);
     }
 
-    private void insert(String themeId, String partition, Integer partitionHash, Integer num, Integer total, String userId,Integer themeType) {
+    private void insert(String themeId, String partition, Integer partitionHash, Integer num, Integer total, String userId, Integer themeType) {
 
         ThemeCheckDuplicateEntity build = ThemeCheckDuplicateEntity.builder()
                 .themeId(themeId)
@@ -103,7 +107,7 @@ public class ThemeTextCheckService {
     }
 
     // 初始化
-    public void insertInit(String content, String themeId, String userId, LocalDateTime createTime,Integer themeType) {
+    public void insertInit(String content, String themeId, String userId, LocalDateTime createTime, Integer themeType) {
         themeCheckDuplicateMapper.deleteByThemeId(themeId);
 
         content = content.replaceAll(regex, "。");