增加报警和日志

long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/local/impl/MatchVideoServiceImpl.java

@@ -15,6 +15,7 @@ import com.tzld.piaoquan.longarticle.model.po.aigc.ProducePlanExeRecord;
 import com.tzld.piaoquan.longarticle.model.po.aigc.ProducePlanExeRecordExample;
 import com.tzld.piaoquan.longarticle.model.po.longarticle.*;
 import com.tzld.piaoquan.longarticle.service.local.KimiService;
+import com.tzld.piaoquan.longarticle.utils.LarkRobotUtil;
 import com.tzld.piaoquan.longarticle.utils.page.Page;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -231,6 +232,9 @@ public class MatchVideoServiceImpl {
                 boolean res = kimiService.updateKimiContent(matchVideo.getContentId());
                 if (res) {
                     updateStatus(matchVideo.getId(), ContentStatusEnum.KIMI_SUCCESS.getStatusCode());
+                } else {
+                    LarkRobotUtil.sendMessage("kimiService updateKimiContent fail contentId=" + matchVideo.getContentId());
+                    log.error("kimiService updateKimiContent fail contentId={}", matchVideo.getContentId());
                 }
                 redisLock.unlock(lockKey, lockValue);
             }
@@ -327,6 +331,8 @@ public class MatchVideoServiceImpl {
                     Integer count = (Integer) redisTemplate.opsForValue().get(countKey);
                     if (count != null && count >= 3) {
                         //更新状态为失败
+                        LarkRobotUtil.sendMessage("crawlerVideoService addCrawlerVideo fail contentId=" + matchVideo.getContentId());
+                        log.error("crawlerVideoService addCrawlerVideo fail contentId={}", matchVideo.getContentId());
                         updateStatus(matchVideo.getId(), ContentStatusEnum.ERROR_99.getStatusCode());
                     } else {
                         if (count == null) {
@@ -446,10 +452,12 @@ public class MatchVideoServiceImpl {
                 if (res) {
                     updateStatus(matchVideo.getId(), ContentStatusEnum.SUCCESS_3.getStatusCode());
                 } else {
-                    //匹配失败记录
+                    //上传失败记录
                     String countKey = String.format(UPLOAD_CRAWLER_FAIL_COUNT_KEY, matchVideo.getContentId());
                     Integer count = (Integer) redisTemplate.opsForValue().get(countKey);
                     if (count != null && count >= 3) {
+                        LarkRobotUtil.sendMessage("crawlerVideoService uploadCrawlerVideo fail contentId=" + matchVideo.getContentId());
+                        log.error("crawlerVideoService uploadCrawlerVideo fail contentId={}", matchVideo.getContentId());
                         //更新状态为失败
                         updateStatus(matchVideo.getId(), ContentStatusEnum.ERROR_99.getStatusCode());
                     } else {