增加推送

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

@@ -47,8 +47,8 @@ public class WeComMessageDataJob {
 
     //初始化操作
     void init() {
-//        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;", DateUtil.getBeforeDayDateString());
-        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;", "20240922");
+        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;", DateUtil.getBeforeDayDateString());
+//        String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;", "20240922");
 
         List<Record> recordList = OdpsUtil.getOdpsData(sql);
         if (CollectionUtils.isEmpty(recordList)) {
@@ -87,7 +87,6 @@ public class WeComMessageDataJob {
         init();
         Map<String, List<String>> res = new HashMap<>();
         UserExample example = new UserExample();
-        example.createCriteria().andExternalUserId3rdPartyEqualTo("wmgizUDQAAYdFWt1hts2fU6P2h84fPvQ");
         long count = userMapper.countByExample(example);
         int page = 1;
         int pageSize = 1000;

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

@@ -98,8 +98,8 @@ public class WeComUserDataJob {
             UserExample userExample = new UserExample();
             userExample.setOrderByClause("create_time desc");
             userExample.setPage(new Page<>(1, 1));
-            List<User> historyMessages = userMapper.selectByExample(userExample);
-            long startTime = historyMessages.get(0).getCreateTime().getTime() / 1000;
+            List<User> userList = userMapper.selectByExample(userExample);
+            long startTime = userList.get(0).getCreateTime().getTime() / 1000;
             Long endTime = System.currentTimeMillis() / 1000;
             Integer total = getUpdateUserTotal(startTime, endTime);
             if (total == null || total == 0) {