| | |
|---|
| | | import com.xiaopeng.api.model.order.XpOrder; |
|---|
| | | import com.xiaopeng.api.vo.operation.RouteVo; |
|---|
| | | import com.xiaopeng.common.core.constant.CacheConstants; |
|---|
| | | import com.xiaopeng.common.core.constant.Constants; |
|---|
| | | import com.xiaopeng.common.core.domain.R; |
|---|
| | | import com.xiaopeng.common.core.enums.PushMessageTypeEnum; |
|---|
| | | import com.xiaopeng.common.redis.service.RedisService; |
|---|
| | |
|---|
| | | import org.springframework.web.bind.annotation.RestController; |
|---|
| | | |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.LinkedBlockingQueue; |
|---|
| | | import java.util.concurrent.ThreadPoolExecutor; |
|---|
| | | import java.util.concurrent.TimeUnit; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | |
|---|
| | | SendMessageDTO sendMessageDTO = new SendMessageDTO(); |
|---|
| | | sendMessageDTO.setAppUserId(String.valueOf(xpOrder.getAppUserId())); |
|---|
| | | sendMessageDTO.setMessage(JSONObject.toJSONString(params)); |
|---|
| | | xpPushMessageClient.sendRoute(sendMessageDTO); |
|---|
| | | R<String> stringR = xpPushMessageClient.sendRoute(sendMessageDTO); |
|---|
| | | //推送失败，重试3次 |
|---|
| | | if(stringR.getCode() != Constants.SUCCESS){ |
|---|
| | | ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>()); |
|---|
| | | executor.execute(() -> { |
|---|
| | | for (int i = 0; i < 3; i++) { |
|---|
| | | R<String> stringR1 = xpPushMessageClient.sendStatus(sendMessageDTO); |
|---|
| | | if(stringR1.getCode() == Constants.SUCCESS){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | try { |
|---|
| | | Thread.sleep(1000); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | log.info("推送乘客端剩余导航数据消息失败：{} {} {}", stringR1.getMsg(), JSON.toJSONString(sendMessageDTO), xpOrder.getOrderNumber()); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | |
|---|
| | | log.info("推送剩余导航数据成功 {} {}", xpOrder.getOrderNumber(), JSON.toJSONString(routeVo)); |
|---|
| | | } |
|---|
| | | return R.ok(); |
|---|
