|
@@ -1154,7 +1154,13 @@ public class XxlJobService {
|
|
|
log.info("syncGzhWaitingPublishContent success planId: {} accountId: {}", planId, accountId);
|
|
|
}
|
|
|
|
|
|
-// @XxlJob("ContentPreFilterJob")
|
|
|
+
|
|
|
+ @XxlJob("ContentPreFilterJob")
|
|
|
+ public ReturnT<String> ContentPreFilterJob(String param) {
|
|
|
+ gzhWaitingPublishContentPreFilter();
|
|
|
+ return ReturnT.SUCCESS;
|
|
|
+ }
|
|
|
+
|
|
|
@Scheduled(cron = "0 0 2 * * ?")
|
|
|
public ReturnT<String> gzhWaitingPublishContentPreFilter() {
|
|
|
boolean lockAcquired = false;
|
|
@@ -1218,8 +1224,8 @@ public class XxlJobService {
|
|
|
LongArticleSystemFilterSortParam param = new LongArticleSystemFilterSortParam();
|
|
|
param.setFilterSortContentList(buildFilterSortContentList(filterResult));
|
|
|
aigcPublishContentDiscardService.filterSortContents(param);
|
|
|
- success = true;
|
|
|
}
|
|
|
+ success = true;
|
|
|
} catch (Exception e) {
|
|
|
log.error("ContentPreFilterJob error index:{} planId: {} accountId: {}",
|
|
|
finalIndex, item.getPlanId(), item.getAccountId(), e);
|