| | |
| | | if(checkTime.compareTo(activityStartTime)>0){ |
| | | String activityId = activity.getActivityId(); |
| | | long currentTimeMillis = System.currentTimeMillis(); |
| | | long startTimeDifference = currentTimeMillis - activityStartTime.getTime(); |
| | | long endTimeDifference = currentTimeMillis - activityEndTime.getTime(); |
| | | long startTimeDifference = activityStartTime.getTime() - currentTimeMillis; |
| | | long endTimeDifference = activityEndTime.getTime() - currentTimeMillis; |
| | | // 查询延时任务 |
| | | DelayTask startDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); |
| | | // 如果延时任务为空,创建延时任务控制活动定时开始和结束 |
| | |
| | | remoteConfigService.addDelayTask(startDelayTask); |
| | | } |
| | | // 查询延时任务 |
| | | DelayTask endDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); |
| | | DelayTask endDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId).getData(); |
| | | // 如果延时任务为空,创建延时任务控制活动定时开始和结束 |
| | | if (endDelayTask == null) { |
| | | redisService.setCacheObject(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId, activityEndTime, endTimeDifference, TimeUnit.MILLISECONDS); |
| | |
| | | Date activityStartTime = activity.getActivityStartTime(); |
| | | Date activityEndTime = activity.getActivityEndTime(); |
| | | long currentTimeMillis = System.currentTimeMillis(); |
| | | long startTimeDifference = currentTimeMillis - activityStartTime.getTime(); |
| | | long endTimeDifference = currentTimeMillis - activityEndTime.getTime(); |
| | | long startTimeDifference = activityStartTime.getTime() - currentTimeMillis; |
| | | long endTimeDifference = activityEndTime.getTime() - currentTimeMillis; |
| | | // 查询延时任务 |
| | | DelayTask startDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); |
| | | // 如果延时任务为空,创建延时任务控制活动定时开始和结束 |