| | |
|---|
| | | log.info("quoteMatchName:{}", quoteMatchName); |
|---|
| | | for (String name : quoteMatchName) { |
|---|
| | | String firstElement = redisService.getFirstElement(name); |
|---|
| | | log.info("firstElement:{}", firstElement); |
|---|
| | | if (firstElement != null) { |
|---|
| | | String[] split = firstElement.toString().split("_"); |
|---|
| | | // 如果未处理 创建新任务 |
|---|
| | |
|---|
| | | processPushOrder(quoteName, count, uid, split, orderNo, xpTradingStrategy, distance, duration, planRule); |
|---|
| | | |
|---|
| | | // 最终没找到车 |
|---|
| | | redisService.popFirstElement(quoteName); |
|---|
| | | // redisService.popFirstElement(quoteName); |
|---|
| | | // 取消订单 |
|---|
| | | xpOrderClient.cancelOrder(orderId); |
|---|
| | | |
|---|
