| | |
|---|
| | | Long appUserId = xpOrder.getAppUserId(); |
|---|
| | | Object cacheObject = redisService.getCacheObject("ORDER_NAVIGATION_END_DATA:" + xpOrder.getAppUserId()); |
|---|
| | | RouteVo routeVo = JSON.parseObject(cacheObject.toString(), RouteVo.class); |
|---|
| | | log.info("开始实施推送车辆位置和剩余导航线路 {} {}", xpOrder.getOrderNumber(), JSON.toJSONString(routeVo)); |
|---|
| | | |
|---|
| | | ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1000)); |
|---|
| | | Long finalOrderId = orderId; |
|---|
| | |
|---|
| | | |
|---|
| | | //5秒钟循环一次 |
|---|
| | | try { |
|---|
| | | Thread.sleep(500); |
|---|
| | | Thread.sleep(1000); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
