| | |
|---|
| | | if (Objects.nonNull(newFleetId)) { |
|---|
| | | order.setFleetId(newFleetId); |
|---|
| | | } |
|---|
| | | //重置订单状态为【待接单】 |
|---|
| | | order.setStatus(1); |
|---|
| | | this.updateById(order); |
|---|
| | | |
|---|
| | | // 10. 保存改派记录 |
|---|
| | |
|---|
| | | log.info("管理后台改派订单，车辆状态修改1 {}", newVehicle.getPlateNumber()); |
|---|
| | | log.info("已将新车辆状态设为已接单，车辆ID: {}", newVehicleId); |
|---|
| | | |
|---|
| | | //12.向小程序用户推送订单改派通知 |
|---|
| | | Map<String, Object> params = new HashMap<>(); |
|---|
| | | Map<String, Object> content = new HashMap<>(); |
|---|
| | | content.put("orderId", order.getId().toString()); |
|---|
| | | content.put("status", order.getStatus()); |
|---|
| | | params.put("type", PushMessageTypeEnum.ORDER_REASSIGN.getDesc()); |
|---|
| | | params.put("content", com.alibaba.fastjson2.JSONObject.toJSONString(content)); |
|---|
| | | params.put("timestamp", new Date().getTime() + ""); |
|---|
| | | String message = JSONObject.toJSONString(params); |
|---|
| | | SendMessageDTO sendMessageDTO = new SendMessageDTO(); |
|---|
| | | sendMessageDTO.setMessage(message); |
|---|
| | | sendMessageDTO.setAppUserId(String.valueOf(order.getAppUserId())); |
|---|
| | | xpPushMessageClient.sendStatus(sendMessageDTO); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("处理新车辆失败，车辆ID: {}，错误: {}", newVehicleId, e.getMessage()); |
|---|
| | | } |
|---|
