| | |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.Set; |
| | | |
| | | |
| | | /** |
| | | * 定时任务工具类 |
| | |
| | | @Autowired |
| | | private IYouTuiDriverService youTuiDriverService; |
| | | |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | | |
| | | |
| | | /** |
| | | * 5秒推送 |
| | | */ |
| | | @Scheduled(fixedRate = 1000 * 5) |
| | | public void task5Seconds(){ |
| | | try { |
| | | Set<String> orderServices = redisUtil.getSetAllValue("orderService"); |
| | | for (String s : orderServices) { |
| | | orderService.pushOrderInfo(Long.valueOf(s));//开始推送订单数据 |
| | | } |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | |
| | | |