Pārlūkot izejas kodu

更新初始参数

xueyiming 7 mēneši atpakaļ
vecāks
revīzija
322ba460f7

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

@@ -263,7 +263,16 @@ public class WeComUserDataJob {
             xxlJobParam = JSONObject.parseObject(param, XxlJobParam.class);
         }
         if (xxlJobParam.getStartTime() == null) {
-            xxlJobParam.setStartTime(1720540800L);
+            UserExample userExample = new UserExample();
+            userExample.createCriteria().andIsDeleteEqualTo(1);
+            userExample.setOrderByClause("deleted_at desc");
+            userExample.setPage(new Page<>(1, 1));
+            List<User> userList = userMapper.selectByExample(userExample);
+            if (CollectionUtils.isEmpty(userList)) {
+                xxlJobParam.setStartTime(1720540800L);
+            } else {
+                xxlJobParam.setStartTime(userList.get(0).getDeletedAt());
+            }
         }
         if (xxlJobParam.getEndTime() == null) {
             xxlJobParam.setEndTime(System.currentTimeMillis() / 1000);