Merge branch 'wyp/0312-videoPromotion' of Server/long-article-recommend into master

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/recommend/ArticlePromotionService.java

@@ -7,6 +7,7 @@ import com.tzld.longarticle.recommend.server.common.enums.aigc.CrawlerModeEnum;
 import com.tzld.longarticle.recommend.server.common.enums.aigc.ProducePlanInputSourceTypeEnum;
 import com.tzld.longarticle.recommend.server.common.enums.aigc.PublishPlanInputSourceTypesEnum;
 import com.tzld.longarticle.recommend.server.common.enums.recommend.ArticlePoolPromotionSourceStatusEnum;
+import com.tzld.longarticle.recommend.server.common.enums.recommend.ContentPoolEnum;
 import com.tzld.longarticle.recommend.server.common.enums.recommend.FeishuRobotIdEnum;
 import com.tzld.longarticle.recommend.server.mapper.aigc.AigcBaseMapper;
 import com.tzld.longarticle.recommend.server.mapper.aigc.PublishContentMapper;
@@ -416,6 +417,7 @@ public class ArticlePromotionService {
         Map<String, Map<String, List<PublishSortLog>>> sortLogMap = sortLogList.stream()
                 .collect(Collectors.groupingBy(PublishSortLog::getGhId,
                         Collectors.groupingBy(PublishSortLog::getDateStr)));
+        int promotionNum = 0;
         for (DatastatSortStrategy data : promotionList) {
             List<PublishSortLog> logs = sortLogMap.get(data.getGhId()).get(data.getDateStr());
             if (CollectionUtils.isEmpty(logs)) {
@@ -458,7 +460,18 @@ public class ArticlePromotionService {
                     videoTitleReWriteRepository.save(videoTitleReWrite);
                 }
             }
+            promotionNum++;
         }
+        ContentPoolEnum poolEnum = ContentPoolEnum.from(poolLevel);
+        sendFeishuJobFinishMessage(poolEnum.getDescription(), promotionNum);
+    }
+
+    private void sendFeishuJobFinishMessage(String accountNickName, Integer promotionNum) {
+        log.info("articleVideoPoolPromotion finish: 晋级任务:{}, 晋级数量：{}", accountNickName, promotionNum);
+        FeishuMessageSender.sendWebHookMessage(FeishuRobotIdEnum.DAILY.getRobotId(),
+                "【视频晋级任务完成】\n" +
+                        "晋级任务：" + accountNickName + "\n" +
+                        "晋级数量：" + promotionNum + "\n");
     }
 
     @XxlJob("topContentReSendJob")