修改单次获取

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

@@ -90,12 +90,12 @@ public class WeComMessageDataJob {
             String countSql = String.format("SELECT count(*) FROM loghubods.history_good_video_can_push_user_list where dt = %s;",
                     DateUtil.getBeforeDayDateString("yyyyMMdd"));
             List<Record> countData = OdpsUtil.getOdpsData(countSql);
-            int size = 10;
+            int size = 1;
             if (!CollectionUtils.isEmpty(countData)) {
                 int count = Integer.parseInt((String) countData.get(0).get(0));
                 if (count > 0) {
                     List<Record> dataList = new ArrayList<>();
-                    for (int i = 0; i < count; i += 10) {
+                    for (int i = 0; i < count; i += size) {
                         String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s order by score desc limit %s,%s;",
                                 DateUtil.getBeforeDayDateString("yyyyMMdd"), i, size);
                         List<Record> data = OdpsUtil.getOdpsData(sql);