修改了定时任务

src/main/java/org/rcisoft/business/memTraffic/service/impl/MemTrafficServiceImpl.java

@@ -116,39 +116,43 @@ public class MemTrafficServiceImpl extends ServiceImpl<MemTrafficRepository,MemT
 
         //将redis中存储的点赞数同步到opm_user_like表中
         Set<String> keys = redisTemplate.keys(MemTrafficRedisBean.USER_MEMTRAFFIC + "*");
-
-        if (keys != null && !keys.isEmpty()) {
-            for (String key : keys) {
-                // 提取 userId
-                int lastIndex = key.lastIndexOf(':');
-                BigInteger memberId;
-                memberId = BigInteger.valueOf(Long.parseLong(key.substring(lastIndex + 1)));
-                //获取访问量
-                String value = redisTemplate.opsForValue().get(key);
-                BigInteger count = null;
-                if (value != null) {
-                    count = BigInteger.valueOf(Long.parseLong(value));
+        try {
+            if (keys != null && !keys.isEmpty()) {
+                for (String key : keys) {
+                    // 提取 userId
+                    int lastIndex = key.lastIndexOf(':');
+                    BigInteger memberId;
+                    memberId = BigInteger.valueOf(Long.parseLong(key.substring(lastIndex + 1)));
+                    //获取访问量
+                    String value = redisTemplate.opsForValue().get(key);
+                    BigInteger count = null;
+                    if (value != null) {
+                        count = BigInteger.valueOf(Long.parseLong(value));
+                    }
+
+                    //将redis中存储的访问量同步到表中
+                    MemTraffic memTraffic = new MemTraffic();
+                    memTraffic.setMemberId(memberId);
+                    memTraffic.setMemTraffic(count);
+                    memTraffic.setBeginTime(beginTime);
+                    memTraffic.setEndTime(endTime);
+                    baseMapper.updateMemTraffic(memTraffic);
                 }
-
-                //将redis中存储的访问量同步到表中
-                MemTraffic memTraffic = new MemTraffic();
-                memTraffic.setMemberId(memberId);
-                memTraffic.setMemTraffic(count);
-                memTraffic.setBeginTime(beginTime);
-                memTraffic.setEndTime(endTime);
-                baseMapper.updateMemTraffic(memTraffic);
-
             }
-        } else {
-            System.out.println("No keys found.");
+            SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
+            sysScheduledTaskLog.setTaskName("用户访问数据定时任务");
+            sysScheduledTaskLog.setTaskState("成功");
+            sysScheduledTaskLog.setTaskTime("每20分钟执行一次");
+            sysScheduledTaskLog.setCreateDate(new Date());
+            sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
+        } catch (Exception e){
+            SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
+            sysScheduledTaskLog.setTaskName("用户访问数据定时任务");
+            sysScheduledTaskLog.setTaskState("失败");
+            sysScheduledTaskLog.setTaskTime("每20分钟执行一次");
+            sysScheduledTaskLog.setCreateDate(new Date());
+            sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
         }
-        SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
-        sysScheduledTaskLog.setTaskName("用户访问数据定时任务");
-        sysScheduledTaskLog.setTaskState("成功");
-        sysScheduledTaskLog.setTaskTime("每20分钟执行一次");
-        sysScheduledTaskLog.setCreateDate(new Date());
-        sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
-        log.info("用户访问数据定时任务结束---");
     }
 
     /**

src/main/java/org/rcisoft/core/schedule/ScheduleTasks.java

@@ -40,15 +40,6 @@ public class ScheduleTasks {
    @Autowired
    private OpmTopicServiceImpl opmTopicServiceImpl;
 
-    /**
-     * 每俩小时 执行一次点赞数据定时任务 将点赞数据同步到点赞表表中
-     */
-    @Scheduled(cron = "0 0 */2 * * ?")
-    public void userLikeSchedule() {
-        memInfoService.userLikeSchedule();
-    }
-
-
     /**
      * redis订单落库
      */
@@ -98,6 +89,16 @@ public class ScheduleTasks {
         orderService.executeDeleteOrder();
     }
 
+
+    /**
+     * 每俩小时 执行一次点赞数据定时任务 将点赞数据同步到点赞表表中
+     */
+    @Scheduled(cron = "0 0 */2 * * ?")
+    public void userLikeSchedule() {
+        memInfoService.userLikeSchedule();
+    }
+
+
     /**
      * 定时更新访问量表
      */