增加保底字段判断

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/strategy/reply/impl/PushMessageStrategyV1.java

@@ -210,12 +210,12 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
                 // base作为人工控制
                 continue;
             }
-            List<AlgGhAutoreplyVideoRankData> dtVersionStrategyData;
             if (Objects.equals(StrategyStatusEnum.DEFAULT.status, bucketDataParam.getStrategyStatus())) {
                 if (CollectionUtils.isEmpty(bucketDataParam.getVideos())) {
                     return null;
                 }
                 Map<Long, VideoDetail> videoDetailMap = TouLiuHttpClientService.getVideoDetailRequest(bucketDataParam.getVideos());
+                int sort = 1;
                 for (Long videoId : bucketDataParam.getVideos()) {
                     CgiReplyBucketDataExample cgiReplyBucketDataExample = new CgiReplyBucketDataExample();
                     cgiReplyBucketDataExample.createCriteria().andIsDeleteEqualTo(0).andStrategyEqualTo(key)
@@ -227,16 +227,20 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
                     }
                     CgiReplyBucketData cgiReplyBucketData = new CgiReplyBucketData();
                     cgiReplyBucketData.setStrategy(key);
-                    cgiReplyBucketData.setSort(1);
+                    cgiReplyBucketData.setSort(sort);
                     cgiReplyBucketData.setGhId(bucketDataParam.getGhId());
                     cgiReplyBucketData.setMsgType(1);
                     VideoDetail videoDetail = videoDetailMap.get(videoId);
                     if (videoDetail != null && StringUtils.isNotEmpty(videoDetail.getCover())) {
                         cgiReplyBucketData.setCoverUrl(videoDetail.getCover());
                     }
+                    if (videoDetail != null && StringUtils.isNotEmpty(videoDetail.getTitle())) {
+                        cgiReplyBucketData.setTitle(videoDetail.getTitle());
+                    }
                     cgiReplyBucketData.setMiniAppId(SMALL_APP_Id);
                     cgiReplyBucketData.setMiniVideoId(videoId);
                     result.add(cgiReplyBucketData);
+                    sort++;
                 }
             } else {
                 // 获取最新dt的策略
@@ -250,7 +254,7 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
                     continue;
                 }
                 // 获取最新dt数据
-                dtVersionStrategyData = getDtVersionStrategyData(key, dtVersion, bucketDataParam.getGhId());
+                List<AlgGhAutoreplyVideoRankData> dtVersionStrategyData = getDtVersionStrategyData(key, dtVersion, bucketDataParam.getGhId());
                 List<Long> videoIds = dtVersionStrategyData.stream().map(AlgGhAutoreplyVideoRankData::getVideoId).collect(Collectors.toList());
                 Map<Long, VideoDetail> videoDetailMap = TouLiuHttpClientService.getVideoDetailRequest(videoIds);
                 result.addAll(dtVersionStrategyData.stream().map(x -> {