diff --git a/nxhs-service/src/main/java/cc/yunxi/controller/RecycleOrderController.java b/nxhs-service/src/main/java/cc/yunxi/controller/RecycleOrderController.java index 53da3a3..3ef2ade 100644 --- a/nxhs-service/src/main/java/cc/yunxi/controller/RecycleOrderController.java +++ b/nxhs-service/src/main/java/cc/yunxi/controller/RecycleOrderController.java @@ -112,23 +112,20 @@ public class RecycleOrderController { // 通知回收员 List recyclers = recyclerService.getRecyclerByStationId(orderCreateVO.getRecycleStationId()); + ClientAddress addressInfo = clientAddressService.getAddressInfo(orderCreateVO.getClientAddressId()); if (recyclers.size() > 0) { - OrderNew message = new OrderNew(); - - message.setMessageType(MessageTypeEnum.BOOKING);//消息类型 - message.setAppType(AppTypeEnum.recycler);//发送到哪里 -// message.setReceiveUserId("");//接收人 - - message.setOrderNo(orderId);//订单号 - message.setOrderStatus(OrderStatusEnum.PENDING); - message.setReserveTime(orderCreateVO.getAppointmentTimeStart() + "~" + orderCreateVO.getAppointmentTimeEnd()); -// message.setGoodsType("1"); - ClientAddress addressInfo = clientAddressService.getAddressInfo(orderCreateVO.getClientAddressId()); - message.setClientPhone(addressInfo.getReceiveMobilePhone()); - message.setClientAddress(addressInfo.getReceiveStreet() + addressInfo.getReceiveHouseNumber()); - message.setEstimatedWeight(orderCreateVO.getPredictWeight()); + try { for (Recycler recycler : recyclers) { + OrderNew message = new OrderNew(); + message.setMessageType(MessageTypeEnum.BOOKING);//消息类型 + message.setAppType(AppTypeEnum.recycler);//发送到哪里 + message.setOrderNo(orderId);//订单号 + message.setOrderStatus(OrderStatusEnum.PENDING); + message.setReserveTime(orderCreateVO.getAppointmentTimeStart() + "~" + orderCreateVO.getAppointmentTimeEnd()); + message.setClientPhone(addressInfo.getReceiveMobilePhone()); + message.setClientAddress(addressInfo.getReceiveStreet() + addressInfo.getReceiveHouseNumber()); + message.setEstimatedWeight(orderCreateVO.getPredictWeight()); message.setReceiveUserId(recycler.getId()); wsService.sendMsgToUser(message); }