| | |
|---|
| | | |
|---|
| | | if (mqttPublishDto.getCode() == 200) { |
|---|
| | | if(!dto.getOrderId().contains("XU")){ |
|---|
| | | Map<String, Object> cancelContext = new HashMap<>(); |
|---|
| | | cancelContext.put("orderId", dto.getOrderId()); |
|---|
| | | cancelContext.put("vin", dto.getVin()); |
|---|
| | | cancelContext.put("cancelScene", StringUtils.isNotEmpty(dto.getCancelScene()) |
|---|
| | | ? dto.getCancelScene() |
|---|
| | | : CancelOrderSceneEnum.NORMAL_CANCEL.getCode()); |
|---|
| | | redisService.setCacheObject("CANCEL_ORDER_CONTEXT:" + taskId, |
|---|
| | | JSONObject.toJSONString(cancelContext), 30L, TimeUnit.MINUTES); |
|---|
| | | log.info("记录取消订单上下文成功，orderId: {}, vin: {}, taskId: {}, cancelScene: {}", |
|---|
| | | dto.getOrderId(), dto.getVin(), taskId, cancelContext.get("cancelScene")); |
|---|
| | | // 正常订单处理 |
|---|
| | | redisService.setCacheObject(String.valueOf(sequence), "cancelOrder_" + dto.getOrderId() + "_" + dto.getVin(), 30l, TimeUnit.MINUTES); |
|---|
| | | } |
|---|
| | | return R.ok(true); |
|---|
| | | } |
|---|
