|
@@ -120,12 +120,12 @@ public class ScheduleManager implements SchedulingConfigurer {
|
|
|
}
|
|
|
|
|
|
public ScheduledTaskInfo executeTask(String key) {
|
|
|
- RBucket<Object> bucket = redissonClient.getBucket(key);
|
|
|
+ RBucket<ScheduledTaskInfo> bucket = redissonClient.getBucket(key);
|
|
|
if (!bucket.isExists()) {
|
|
|
log.error("task not exist: key={}", key);
|
|
|
throw new ApiException(ErrorEnum.ERR_APPLY_TICKET_INVALID);
|
|
|
}
|
|
|
- ScheduledTaskInfo task = (ScheduledTaskInfo) bucket.get();
|
|
|
+ ScheduledTaskInfo task = bucket.get();
|
|
|
TicketExpiredMessage msg = new TicketExpiredMessage();
|
|
|
msg.setFromUserId(task.getApplyUserId());
|
|
|
msg.setToUserId(task.getTargetUserId());
|