过滤部分修改为离线过滤

we-com-server/src/main/java/com/tzld/piaoquan/wecom/dao/mapper/HistoryMessageMapper.java

@@ -33,5 +33,4 @@ public interface HistoryMessageMapper {
 
     int updateByPrimaryKey(HistoryMessage record);
 
-    Set<Long> selectUserIdByVideoId(Long videoId);
 }

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

@@ -44,7 +44,7 @@ public class WeComHistoryDataJob {
     private HistoryMessageService historyMessageService;
 
     public void selectHistoryMessageByDay(){
-        long startTime = 1722268800L;
+        long startTime = 1723996800L;
         long endTime = System.currentTimeMillis() / 1000;
         for (;startTime < endTime; startTime += 60 * 60 * 24){
             selectHistoryMessage(startTime, startTime + 60 * 60 * 24);
@@ -53,7 +53,6 @@ public class WeComHistoryDataJob {
 
     public void selectHistoryMessage(Long startTime, Long endTime) {
         try {
-            //TODO accessToken 暂时写死 后续增加接口刷新和存储
             String res = getHistoryData(size, 0, startTime, endTime);
             //TODO 记录查询数据 info日志
             if (ObjectUtils.isEmpty(res)) {

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

@@ -46,7 +46,6 @@ public class WeComUserDataJob {
             int page = total / size + 1;
             int sum = 0;
             for (int i = 0; i < page; i++) {
-                //TODO accessToken 暂时写死 后续增加接口刷新和存储
                 String res = getUser(size, i * size, 1720540800L, endTime);
                 //TODO 记录查询数据 info日志
                 if (ObjectUtils.isEmpty(res)) {
@@ -107,7 +106,6 @@ public class WeComUserDataJob {
             int page = total / size + 1;
             int sum = 0;
             for (int i = 0; i < page; i++) {
-                //TODO accessToken 暂时写死 后续增加接口刷新和存储
                 String res = getUpdateUser(size, i * size, 1726821389L, endTime);
                 //TODO 记录查询数据 info日志
                 if (ObjectUtils.isEmpty(res)) {

we-com-server/src/main/resources/mapper/HistoryMessageMapper.xml

@@ -242,10 +242,4 @@
     where id = #{id,jdbcType=BIGINT}
   </update>
 
-  <select id="selectUserIdByVideoId" parameterType="Long" resultType="Long">
-    select
-        user_id
-    from we_com_history_message
-    where video_id = #{videoId}
-  </select>
 </mapper>