增加主体

we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComMessageDataJob.java

@@ -80,21 +80,21 @@ public class WeComMessageDataJob {
     //初始化操作
     private void init() {
         //历史优质视频获取
-//        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;",
-//                DateUtil.getBeforeDayDateString());
-//        List<Record> recordList = OdpsUtil.getOdpsData(sql);
-//        if (CollectionUtils.isEmpty(recordList)) {
-//            return;
-//        }
+        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;",
+                DateUtil.getBeforeDayDateString());
+        List<Record> recordList = OdpsUtil.getOdpsData(sql);
+        if (CollectionUtils.isEmpty(recordList)) {
+            return;
+        }
         List<PushMessage> list = new ArrayList<>();
-//        for (Record record : recordList) {
-//            PushMessage pushMessage = new PushMessage();
-//            Long videoId = Long.parseLong((String) record.get(0));
-//            Set<Long> userIds = new HashSet<>(JSONObject.parseArray((String) record.get(1), Long.class));
-//            pushMessage.setVideoId(videoId);
-//            pushMessage.setUserIds(userIds);
-//            list.add(pushMessage);
-//        }
+        for (Record record : recordList) {
+            PushMessage pushMessage = new PushMessage();
+            Long videoId = Long.parseLong((String) record.get(0));
+            Set<Long> userIds = new HashSet<>(JSONObject.parseArray((String) record.get(1), Long.class));
+            pushMessage.setVideoId(videoId);
+            pushMessage.setUserIds(userIds);
+            list.add(pushMessage);
+        }
         goodHistoryPushList = list;
 
         //保底视频获取