基于Java的群星网约车平台设计源码

package com.yc.qunxing.web; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.yc.qunxing.clients.DriverAction; import com.yc.qunxing.clients.UserAction; import com.yc.qunxing.entity.*; import com.yc.qunxing.entity.vo.OrderDetails; import com.yc.qunxing.entity.vo.OrderDetailsDriver; import com.yc.qunxing.entity.vo.RouteFrequency; import com.yc.qunxing.result.Result; import com.yc.qunxing.service.IDriversService; import com.yc.qunxing.service.IOrdersService; import com.yc.qunxing.service.IUserRatingsService; import com.yc.qunxing.service.IUsersService; import com.yc.qunxing.websocket.WebSocketServer; import com.yc.qunxing.websocket.WebSocketServerDriver; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; import java.time.LocalDateTime; import java.util.*; import java.util.concurrent.TimeUnit; /** * <p> * 前端控制器 * </p> * * @author 鹏哥 * @since 2024-05-23 */ @RestController @RequestMapping("/orders") public class OrderController { @Autowired public IOrdersService iOrdersService; @Autowired private WebSocketServer webSocketServer; @Autowired private UserAction userAction; @Autowired private DriverAction driverAction; @Autowired private IDriversService iDriversService; @Autowired private IUsersService iUsersService; @Autowired private WebSocketServerDriver webSocketServerDriver; @Autowired private RabbitTemplate rabbitTemplate; @Autowired IUserRatingsService iUserRatingsService; @Autowired private RedisTemplate redisTemplate; @PostMapping("/callDriver") public Result<Integer> CallDriver(@RequestBody Orders orders){ orders.setOrderDate(LocalDateTime.now()); /* System.out.println(orders+"0000");*/ Integer orderId= iOrdersService.addOrder(orders); Result<Users> usersResult = userAction.GetById(orders.getUserId()); String phoneNumber = usersResult.getData().getPhoneNumber(); ////////////////////////////////////////////// Map map = new HashMap(); map.put("type", 1);//消息类型，1表示来单提醒 map.put("orderId", orders.getOrderId()); map.put("departureLocation", orders.getDepartureLocation()); map.put("destinationLocation",orders.getDestinationLocation()); map.put("startTime",orders.getOrderDate()); map.put("distance",orders.getDistance()); map.put("estimatedTime",orders.getDuration()); map.put("uuserId",orders.getUserId()); map.put("phoneNumber",phoneNumber); // 通过 RabbitMQ 发布订单消息 rabbitTemplate.convertAndSend("orderQueue", map); System.out.println(orders+"orders543"); //通过WebSocket实现来单提醒，向客户端浏览器推送消息 /* webSocketServer.sendToAllClient(JSON.toJSONString(map));*/ webSocketServer.sendToActiveDrivers(orders.getType(), orders.getColor(),orders.getDepartureLocation(),JSON.toJSONString(map)); /////////////////////////////////////////////////// clearOrderByManagerCache(); return Result.success(orderId); } /* // 取消订单接口 @PostMapping("/cancelOrder") public Result<String> CancelOrder(@RequestParam("orderId") Integer orderId){ // 根据订单ID查询订单信息 Orders order = iOrdersService.getById(orderId); if(order == null){ return Result.error("订单不存在"); } // 更新订单状态为取消 order.setStatus("4"); iOrdersService.updateById(order); return Result.success("订单取消成功"); } @PutMapping("/acceptOrder") public Result<String> AcceptOrder(@RequestBody Orders orders){ String key = "order_lock:" + orders.getOrderId(); Boolean success = redisTemplate.opsForValue().setIfAbsent(key, orders.getDriverId().toString()); if (Boolean.TRUE.equals(success)) { orders.setStatus("2"); Drivers driver1=new Drivers(); driver1.setId(orders.getDriverId()); driver1.setStatus("2"); Result<String> stringResult = driverAction.UpdateDriverStatus(driver1); System.out.println(stringResult+"980"); boolean b = iOrdersService.updateById(orders); Result<Drivers> driversResult = driverAction.GetById(orders.getDriverId()); Result<DriverVehicles> driverVehiclesResult = driverAction.GetVerById(orders.getDriverId()); *//* System.out.println(b+"*88888888");*//* ////////////////////////////////////////////// Map map = new HashMap(); map.put("type", 2);//消息类型，1表示来单提醒 map.put("orderId", orders.getOrderId()); map.put("phoneNumber",driversResult.getData().getPhoneNumber()); map.put("licensePlate",driversResult.getData().getLicensePlate()); map.put("vehicleType",driverVehiclesResult.getData().getVehicleType()); map.put("color",driverVehiclesResult.getData().getColor()); map.put("driverName",driversResult.getData().getUsername()); //通过WebSocket实现来单提醒，向客户端浏览器推送消息 webSocketServer.sendToUsers(JSON.toJSONString(map)); /////////////////////////////////////////////////// if(b){ return Result.success("接单成功"); } return Result.error("接单失败"); } else { return Result.error("订单已被其他司机抢到"); } }*/ @PutMapping("/acceptOrder") public Result<String> AcceptOrder(@RequestBody Orders orders) { Map<String, Object> map = new HashMap<>(); map.put("type", 2); // 消息类型，2表示接单提醒 map.put("orderId", orders.getOrderId()); map.put("driverId", orders.getDriverId()); // 通过 RabbitMQ 发布接单消息 rabbitTemplate.convertAndSend("orderQueue", map); return Result.success("接单请求已发送"); } @PostMapping("/cancelOrder") public Result<String> CancelOrder(@RequestParam("orderId") Integer orderId) { Map<String, Object> map = new HashMap<>(); map.put("type", 3); // 消息类型，3表示取消订单 map.put("orderId", orderId); // 通过 RabbitMQ 发布取消订单消息 rabbitTemplate.convertAndSend("orderQueue", map); return Result.success("取消订单请求已发送"); } @GetMapping("/getOrderStatus") public Result<String> GetOrderStatus(@RequestParam Integer orderId){ Orders byId1 = iOrdersService.getById(orderId); if(byId1.getStatus().equals("4")){ return Result.error("该用户已取消订单......"); } return Result.success(); } @PostMapping("insertDT") public Result<String> InsertDT(@RequestBody Orders order){ iOrdersService.updateById(order); return Result.success(); } @GetMapping("getT") public Result<String> GetT(@RequestParam Integer orderId){ Orders byId = iOrdersService.getById(orderId); String durationDriver = byId.getDurationDriver(); return Result.success(durationDriver); } @GetMapping("getT1") public Result<String> GetT1(@RequestParam Integer orderId){ Orders byId = iOrdersService.getById(orderId); String duration = byId.getDuration(); return Result.success(duration); } @GetMapping("getListSE") public Result<?> GetListSE(@RequestParam("userId") Integer userId) { List<RouteFrequency> routeFrequencies = iOrdersService.getRouteFrequenciesByUserId(userId); if (!routeFrequencies.isEmpty()) { return Result.success(routeFrequencies); } else {