|
|
@@ -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));
|
