queryRootSourceIdsFromCgiReply

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

@@ -12,6 +12,7 @@ import com.tzld.piaoquan.api.model.po.contentplatform.*;
 import com.tzld.piaoquan.api.service.CgiReplyService;
 import com.tzld.piaoquan.api.service.contentplatform.ContentPlatformPlanService;
 import com.tzld.piaoquan.growth.common.dao.mapper.CgiReplyBucketDataMapper;
+import com.tzld.piaoquan.growth.common.dao.mapper.ext.CgiReplyBucketDataMapperExt;
 import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
 import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketDataExample;
 import com.tzld.piaoquan.growth.common.utils.RedisUtils;
@@ -60,6 +61,9 @@ public class ExternalChannelProcessJob {
     @Autowired
     private CgiReplyBucketDataMapper cgiReplyBucketDataMapper;
 
+    @Autowired
+    private CgiReplyBucketDataMapperExt cgiReplyBucketDataMapperExt;
+
     @Autowired
     private CgiReplyService cgiReplyService;
 
@@ -887,7 +891,7 @@ public class ExternalChannelProcessJob {
                 break;
             case GZH_COOPERATE_JIZHUAN:
                 // 公众号合作-即转：从cgi_reply_bucket_data查询dyyjs_开头的rootSourceId
-                //rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_DYYJS, startDate);
+                rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_DYYJS, startDate);
                 break;
             case QW_COOPERATE:
                 // 群/企微合作：从content_platform_qw_plan查询
@@ -1009,15 +1013,15 @@ public class ExternalChannelProcessJob {
     private List<String> queryRootSourceIdsFromCgiReply(String prefix, Date startDate) {
         List<String> result = new ArrayList<>();
         try {
-            CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
-            example.createCriteria()
-                    .andRootSourceIdLike(prefix + "%")
-                    .andCreateTimeGreaterThanOrEqualTo(startDate);
-            example.setDistinct(true);
-            List<CgiReplyBucketData> list = cgiReplyBucketDataMapper.selectByExample(example);
-            if (!CollectionUtils.isEmpty(list)) {
-                result = list.stream().map(CgiReplyBucketData::getRootSourceId).collect(Collectors.toList());
-            }
+            //CgiReplyBucketDataExample example = new CgiReplyBucketDataExample();
+            //example.createCriteria()
+            //        .andCreateTimeGreaterThanOrEqualTo(startDate)
+            //        .andRootSourceIdLike(prefix + "%");
+            //List<CgiReplyBucketData> list = cgiReplyBucketDataMapper.selectByExample(example);
+            //if (!CollectionUtils.isEmpty(list)) {
+            //    result = list.stream().map(CgiReplyBucketData::getRootSourceId).collect(Collectors.toList());
+            //}
+            result = cgiReplyBucketDataMapperExt.getRootSourceIdByPrefix(prefix, startDate);
         } catch (Exception e) {
             log.error("从cgi_reply_bucket_data查询历史数据失败, prefix={}", prefix, e);
         }

common-module/src/main/java/com/tzld/piaoquan/growth/common/dao/mapper/ext/CgiReplyBucketDataMapperExt.java

@@ -5,6 +5,9 @@ import com.tzld.piaoquan.growth.common.model.po.CgiReplyBucketData;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.Date;
+import java.util.List;
+
 @Mapper
 public interface CgiReplyBucketDataMapperExt {
     void updateBucketDataTitleCoverByGhId(@Param("ghId") String ghId,
@@ -20,4 +23,6 @@ public interface CgiReplyBucketDataMapperExt {
                             @Param("strategy") String strategy,
                             @Param("msgType") int msgType,
                             @Param("isDelete") int isDelete);
+
+    List<String> getRootSourceIdByPrefix(String prefix, Date startDate);
 }

common-module/src/main/resources/mapper/ext/CgiReplyBucketDataMapperExt.xml

@@ -25,6 +25,13 @@
         order by id desc limit 1
     </select>
 
+    <select id="getRootSourceIdByPrefix" resultType="java.lang.String">
+        select distinct root_source_id
+        from cgi_reply_bucket_data
+        where create_time > #{startDate}
+          and root_source_id like concat(#{prefix}, '%')
+    </select>
+
     <update id="updateDeleteStatus">
         update cgi_reply_bucket_data
         set is_delete = #{isDelete}