历史优质视频增加校验

offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComMessageDataJob.java

@@ -6,20 +6,16 @@ import com.alibaba.fastjson.JSONObject;
 import com.aliyun.odps.data.Record;
 import com.google.common.collect.Lists;
 import com.tzld.piaoquan.growth.common.common.constant.MessageConstant;
+import com.tzld.piaoquan.growth.common.common.enums.ExceptionCodeEnum;
+import com.tzld.piaoquan.growth.common.common.exception.CustomizeException;
 import com.tzld.piaoquan.growth.common.dao.mapper.*;
-import com.tzld.piaoquan.growth.common.model.bo.PushMessage;
-import com.tzld.piaoquan.growth.common.model.bo.VideoCombination;
-import com.tzld.piaoquan.growth.common.model.bo.VideoParam;
-import com.tzld.piaoquan.growth.common.model.bo.XxlJobParam;
+import com.tzld.piaoquan.growth.common.model.bo.*;
 import com.tzld.piaoquan.growth.common.model.po.*;
 import com.tzld.piaoquan.growth.common.model.vo.GuaranteedParam;
 import com.tzld.piaoquan.growth.common.service.MessageAttachmentService;
 import com.tzld.piaoquan.growth.common.service.MessageService;
 import com.tzld.piaoquan.growth.common.service.WeComUserService;
-import com.tzld.piaoquan.growth.common.utils.DateUtil;
-import com.tzld.piaoquan.growth.common.utils.LarkRobotUtil;
-import com.tzld.piaoquan.growth.common.utils.OdpsUtil;
-import com.tzld.piaoquan.growth.common.utils.ToolUtils;
+import com.tzld.piaoquan.growth.common.utils.*;
 import com.tzld.piaoquan.growth.common.utils.page.Page;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -106,6 +102,16 @@ public class WeComMessageDataJob {
                     for (Record record : dataList) {
                         PushMessage pushMessage = new PushMessage();
                         Long videoId = Long.parseLong((String) record.get(0));
+                        Set<Long> videoIds = new HashSet<>();
+                        videoIds.add(videoId);
+                        Map<Long, VideoDetail> videoDetails = messageAttachmentService.getVideoDetail(videoIds);
+                        VideoDetail videoDetail = videoDetails.get(videoId);
+                        if (videoDetail == null || StringUtils.isEmpty(videoDetail.getCover()) || StringUtils.isEmpty(videoDetail.getTitle())) {
+                            continue;
+                        }
+                        if (!ImageUrlValidator.isValidImageUrl(videoDetail.getCover())) {
+                            continue;
+                        }
                         Set<Long> userIds = new HashSet<>(JSONObject.parseArray((String) record.get(1), Long.class));
                         Long staffId = Long.parseLong((String) record.get(2));
                         Double score = Double.parseDouble((String) record.get(3));