admin/ChestnutCMS
1
0
Fork 0
mirror of https://gitee.com/liweiyi/ChestnutCMS.git synced 2025-12-06 16:38:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

误提交测试代码移除

Browse Source
This commit is contained in:
liweiyi 2024-04-30 17:10:58 +08:00
parent 429146a9e8
commit 58c8cea901
3 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/CatalogPublishTask.java
View File

@ -91,7 +91,7 @@ public class CatalogPublishTask implements IPublishTask<CmsCatalog> {
MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of( MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
"type", Type, "type", Type,
"id", dataId "id", dataId
)).withId(RecordId.of(Instant.now().toEpochMilli(), catalog.getCatalogId())); ));
redisTemplate.opsForStream().add(record); redisTemplate.opsForStream().add(record);
} }

2
chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/ContentPublishTask.java
View File

@ -106,7 +106,7 @@ public class ContentPublishTask implements IPublishTask<CmsContent> {
MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of( MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
"type", Type, "type", Type,
"id", dataId "id", dataId
)).withId(RecordId.of(Instant.now().toEpochMilli(), content.getContentId())); ));
redisTemplate.opsForStream().add(record); redisTemplate.opsForStream().add(record);
} }

4
chestnut-cms/chestnut-cms-contentcore/src/main/java/com/chestnut/contentcore/publish/SitePublishTask.java
View File

@ -33,12 +33,10 @@ import com.chestnut.contentcore.util.TemplateUtils;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.springframework.data.redis.connection.stream.MapRecord; import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.connection.stream.RecordId;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.File; import java.io.File;
import java.time.Instant;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
@ -75,7 +73,7 @@ public class SitePublishTask implements IPublishTask<CmsSite> {
MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of( MapRecord<String, String, String> record = MapRecord.create(CMSPublishConfig.PublishStreamName, Map.of(
"type", Type, "type", Type,
"id", dataId "id", dataId
)).withId(RecordId.of(Instant.now().toEpochMilli(), site.getSiteId())); ));
redisTemplate.opsForStream().add(record); redisTemplate.opsForStream().add(record);
} }