| | |
|---|
| | | snowFlake.withStartTimestamp(1420041600000L); |
|---|
| | | long sequence = snowFlake.nextId(); |
|---|
| | | MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(taskListBuilder.build(), dto.getVin(),sequence); |
|---|
| | | //先将车辆修改状态，防止在异步通知之前被其他订单选中 |
|---|
| | | if (!dto.getOrderId().contains("XU") && mqttPublishDto.getCode()== 200) { |
|---|
| | | // 修改车子为接单状态 |
|---|
| | | xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(), 1)); |
|---|
| | | } |
|---|
| | | if(null != mqttPublishDto && mqttPublishDto.getCode() == 200){ |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("event", SystemEventType.CREATE_ORDER); |
|---|
| | | jsonObject.put("orderType", dto.getOrderId().contains("XU") ? com.xiaopeng.api.vo.OrderType.CRUISE_ORDER : com.xiaopeng.api.vo.OrderType.USER_ORDER); |
|---|
| | | jsonObject.put("orderId", dto.getOrderId()); |
|---|
| | | jsonObject.put("vin", dto.getVin()); |
|---|
| | | redisTemplate.opsForValue().set("CREATE_ORDER:" + dto.getOrderId().toString(), jsonObject.toJSONString(),30, TimeUnit.MINUTES); |
|---|
| | | redisService.setCacheObject("CREATE_ORDER:" + dto.getOrderId().toString(), jsonObject.toJSONString(),30L, TimeUnit.MINUTES); |
|---|
| | | return R.ok(true); |
|---|
| | | } |
|---|
| | | //先将车辆修改状态，防止在异步通知之前被其他订单选中 |
|---|
| | | if (!dto.getOrderId().contains("XU") && mqttPublishDto.getCode()== 200) { |
|---|
| | | // 修改车子为接单状态 |
|---|
| | | xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(), 1)); |
|---|
| | | } |
|---|
| | | return R.ok(false); |
|---|
| | | } |
|---|
