| | |
|---|
| | | |
|---|
| | | |
|---|
| | | Page<Order> data = orderClient.queryPage(orderQueryRequest).getData(); |
|---|
| | | List<MasterWorker> list = masterWorkerService.lambdaQuery() |
|---|
| | | .eq(MasterWorker::getIsDelete, 0).list(); |
|---|
| | | if (null != data) { |
|---|
| | | for (Order record : data.getRecords()) { |
|---|
| | | // 回收服务信息 |
|---|
| | | Integer serverId = record.getServerId(); |
|---|
| | | MasterWorker masterWorker = masterWorkerService.lambdaQuery() |
|---|
| | | .eq(MasterWorker::getId, serverId) |
|---|
| | | .eq(MasterWorker::getIsDelete, 0).one(); |
|---|
| | | MasterWorker masterWorker = list.stream().filter(e -> e.getId().equals(serverId)).findFirst().orElse(null); |
|---|
| | | if (null != masterWorker) { |
|---|
| | | record.setServerName(masterWorker.getRealName()); |
|---|
| | | record.setServerPhone(masterWorker.getPhone()); |
|---|
| | |
|---|
| | | .eq(Site::getIsDelete, 0).one(); |
|---|
| | | if (null != site) { |
|---|
| | | order.setSiteName(site.getSiteName()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Order orderData = orderClient.detail(order.getOrderId()).getData(); |
|---|
| | | |
|---|
| | | if(orderData.getState()==0 && (!order.getTime().equals(orderData.getTime()) || !order.getServerId().equals(orderData.getServerId()))){ |
|---|
| | | // 修改sys_change_dispatch 为已改派 |
|---|
| | | dispatchClient.changeReason(order.getOrderId(),""); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 师傅信息 |
|---|
| | |
|---|
| | | System.out.println("服务端发送消息到: " + order.getServerId()); |
|---|
| | | NettyWebSocketController.sendMsgToClient(context, "您有一条新的订单，请注意查收！"); |
|---|
| | | } |
|---|
| | | return data ? R.ok() : R.fail(); |
|---|
| | | } |
|---|
| | | return R.ok(); |
|---|
| | | } |
|---|
