查重

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

@@ -959,7 +959,8 @@ public class ThemeManager {
             List<ThemeContentQo> content = themeQo.getContent();
             for (ThemeContentQo themeContentQo : content) {
                 if (themeContentQo.getType().equals(RelTypeEnum.TEXT.type)) {
-                    themeTextCheckService.insertInit(themeContentQo.getValue(), themeQo.getThemeId(), themeQo.getAuthorId(), TimeUtils.getDateTimeOfTimestamp(themeQo.getCreateTime()));
+                    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

@@ -31,7 +31,8 @@ public class ThemeTextCheckService {
         String[] split = content.split("。");
         for (int i = 0; i < split.length; i++) {
             String trim = StringUtils.trim(split[i]);
-            insert(themeId, trim, getMD5(trim), i + 1, split.length, userId);
+            insert(themeId, trim, getHash(trim), i + 1, split.length, userId,themeType);
+
         }
     }
 
@@ -40,7 +41,7 @@ public class ThemeTextCheckService {
         themeCheckDuplicateMapper.deleteByThemeId(themeId);
     }
 
-    private void insert(String themeId, String partition, String partitionHash, Integer num, Integer total, String userId) {
+    private void insert(String themeId, String partition, String partitionHash, Integer num, Integer total, String userId,Integer themeType) {
 
         ThemeCheckDuplicateEntity build = ThemeCheckDuplicateEntity.builder()
                 .themeId(themeId)
@@ -49,6 +50,7 @@ public class ThemeTextCheckService {
                 .partitionNum(num)
                 .totalParts(total)
                 .userId(userId)
+                .themeType(themeType)
                 .build();
         themeCheckDuplicateMapper.insert(build);
     }
@@ -63,7 +65,7 @@ public class ThemeTextCheckService {
         List<String> list = new ArrayList<>();
         for (int i = 0; i < split.length; i++) {
             String trim = StringUtils.trim(split[i]);
-            list.add(getMD5(trim));
+            list.add(getHash(trim));
         }
         // 一年以内
         LambdaQueryWrapper<ThemeCheckDuplicateEntity> w = new LambdaQueryWrapper<ThemeCheckDuplicateEntity>().in(ThemeCheckDuplicateEntity::getPartitionHash, list)
@@ -79,7 +81,7 @@ public class ThemeTextCheckService {
     }
 
 
-    public static String getMD5(String str) {
+    public static String getHash(String str) {
         try {
             // 生成一个MD5加密计算摘要
             MessageDigest md = MessageDigest.getInstance("MD5");
@@ -94,7 +96,7 @@ public class ThemeTextCheckService {
     }
 
     // 初始化
-    public void insertInit(String content, String themeId, String userId, LocalDateTime createTime) {
+    public void insertInit(String content, String themeId, String userId, LocalDateTime createTime,Integer themeType) {
         themeCheckDuplicateMapper.deleteByThemeId(themeId);
 
         content = content.replaceAll(regex, "。");
@@ -105,15 +107,18 @@ public class ThemeTextCheckService {
             ThemeCheckDuplicateEntity build = ThemeCheckDuplicateEntity.builder()
                     .themeId(themeId)
                     .partitionText(trim)
-                    .partitionHash(getMD5(split[i]))
+                    .partitionHash(getHash(split[i]))
                     .partitionNum(i + 1)
                     .totalParts(split.length)
                     .userId(userId)
+                    .themeType(themeType)
                     .createTime(createTime)
                     .updateTime(createTime)
                     .build();
             themeCheckDuplicateMapper.insert(build);
         }
+
+
     }
 
 }