job test

api-module/src/main/java/com/tzld/piaoquan/api/job/ExternalChannelProcessJob.java

@@ -183,7 +183,7 @@ public class ExternalChannelProcessJob {
      * 处理单条记录
      * 根据渠道类型路由到对应的处理方法，使用分布式锁防止并发处理
      */
-    private void processSingleRecord(ExternalChannel record) {
+    public void processSingleRecord(ExternalChannel record) {
         String rootSourceId = record.getRootSourceId();
         Long recordId = record.getId();
 
@@ -445,7 +445,7 @@ public class ExternalChannelProcessJob {
         try {
             // 查询cgi_reply_bucket_data获取ghId
             CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
-            example.createCriteria().andRootSourceIdEqualTo(rootSourceId).andIsDeleteEqualTo(0);
+            example.createCriteria().andRootSourceIdEqualTo(rootSourceId);
             example.setOrderByClause("id desc");
             List<CgiReplyBucketData> bucketDataList = cgiReplyBucketDataMapper.selectByExample(example);
 
@@ -522,7 +522,7 @@ public class ExternalChannelProcessJob {
         try {
             // 查询cgi_reply_bucket_data获取ghId和pagePath
             CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
-            example.createCriteria().andRootSourceIdEqualTo(rootSourceId).andIsDeleteEqualTo(0);
+            example.createCriteria().andRootSourceIdEqualTo(rootSourceId);
             example.setOrderByClause("id desc");
             List<CgiReplyBucketData> bucketDataList = cgiReplyBucketDataMapper.selectByExample(example);
 
@@ -651,7 +651,7 @@ public class ExternalChannelProcessJob {
         try {
             // 查询cgi_reply_bucket_data获取ghId和pagePath
             CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
-            example.createCriteria().andRootSourceIdEqualTo(rootSourceId).andIsDeleteEqualTo(0);
+            example.createCriteria().andRootSourceIdEqualTo(rootSourceId);
             example.setOrderByClause("id desc");
             List<CgiReplyBucketData> bucketDataList = cgiReplyBucketDataMapper.selectByExample(example);
 

api-module/src/test/java/com/tzld/piaoquan/api/ExternalChannelTest.java

@@ -0,0 +1,31 @@
+package com.tzld.piaoquan.api;
+
+import com.tzld.piaoquan.api.dao.mapper.contentplatform.ExternalChannelMapper;
+import com.tzld.piaoquan.api.job.ExternalChannelProcessJob;
+import com.tzld.piaoquan.api.model.po.contentplatform.ExternalChannel;
+import com.tzld.piaoquan.api.model.po.contentplatform.ExternalChannelExample;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.List;
+
+@SpringBootTest(classes = GrowthServerApplication.class)
+@Slf4j
+public class ExternalChannelTest {
+    @Autowired
+    ExternalChannelProcessJob job;
+    @Autowired
+    ExternalChannelMapper externalChannelMapper;
+
+
+    @Test
+    public void testSyncContentPlatformQwDatastatReplyTotalJob() {
+        ExternalChannelExample example = new ExternalChannelExample();
+        example.createCriteria().andRootSourceIdEqualTo("fwhtouliu_tencentgzh_20260320_49679899_1847006a");
+        List<ExternalChannel> externalChannels = externalChannelMapper.selectByExample(example);
+
+        job.processSingleRecord(externalChannels.get(0));
+    }
+}