From c7fe9d122a14fa2cd4463d4d1b0f14a6058f7955 Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期二, 19 八月 2025 15:40:22 +0800 Subject: [PATCH] 8.18 --- UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/crossCity/server/impl/OrderCrossCityServiceImpl.java | 49 +++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 39 insertions(+), 10 deletions(-) diff --git a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/crossCity/server/impl/OrderCrossCityServiceImpl.java b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/crossCity/server/impl/OrderCrossCityServiceImpl.java index 7113e67..487bf9e 100644 --- a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/crossCity/server/impl/OrderCrossCityServiceImpl.java +++ b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/crossCity/server/impl/OrderCrossCityServiceImpl.java @@ -743,6 +743,10 @@ } this.updateAllColumnById(orderCrossCity); + + if(userInfo.getPhone()!=null){ + SMSUtil.send(userInfo.getPhone(), "您的订单已生成,如有疑问请咨询0715-8911666", "2431012323525"); + } return resultUtil; } // /** @@ -926,7 +930,11 @@ } //添加交易明细 transactionDetailsService.saveData(orderCrossCity.getUserId(), "完成订单", query.getAmount(), 2, 1, 1, 3, query.getOrderId()); - orderCrossCity.setState(2);//先支付再服务 + if(orderCrossCity.getDriverId()==null){ + orderCrossCity.setState(1); + }else { + orderCrossCity.setState(2);//先支付再服务 + } orderCrossCity.setPayType(type); orderCrossCity.setPayMoney(query.getAmount()); this.updateById(orderCrossCity); @@ -968,7 +976,7 @@ // driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); // driverService.updateById(driver); - Company company = companyService.selectById(driver.getFranchiseeId()); +// Company company = companyService.selectById(driver.getFranchiseeId()); // if(Objects.isNull(company)){ // company = companyService.selectById(driver.getCompanyId()); // } @@ -992,20 +1000,35 @@ // // driverService.updateById(driver); + + + // TODO: 2020/5/24 这里需要给司机和用户推送订单状态 new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); - pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); - pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); + + if(driver!=null){ + pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); + pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); + pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); + }else { + try { + pushCrossCityOrder(orderCrossCity); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + } }).start(); // systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : "支付宝") + "成功完成出行订单支付,谢谢使用!", orderCrossCity.getUserId(), 1); //添加司机消息提醒 - systemNoticeService.addSystemNotice(2, "用户已线上完成支付", driver.getId(), 1); + if(driver!=null){ + systemNoticeService.addSystemNotice(2, "用户已线上完成支付", driver.getId(), 1); + } }else{ System.err.println("预支付数据异常(orderId = " + id + ")"); } @@ -1406,6 +1429,7 @@ }; Timer timer = new Timer(); timer.schedule(timerTask, 30 * 60 * 1000); + return ResultUtil.success(baseWarpper); } @@ -1926,7 +1950,9 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); + if(orderCrossCity.getDriverId()!=null){ + pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0); + } System.err.println("推送取消操作---------------------"); } }).start(); @@ -1934,9 +1960,12 @@ //修改司机座位 LineShiftDriver lineShiftDriver = lineShiftDriverMapper.selectById(orderCrossCity.getLineShiftDriverId()); - lineShiftDriver.setLaveSeat(lineShiftDriver.getLaveSeat() + orderCrossCity.getPeopleNumber()); - lineShiftDriver.setLaveSeatNumber(lineShiftDriver.getLaveSeatNumber() + (orderCrossCity.getTravelMode() == 1 ? "," : "") + orderCrossCity.getSeatNumber()); - lineShiftDriverMapper.updateById(lineShiftDriver); + if(lineShiftDriver!=null){ + lineShiftDriver.setLaveSeat(lineShiftDriver.getLaveSeat() + orderCrossCity.getPeopleNumber()); + lineShiftDriver.setLaveSeatNumber(lineShiftDriver.getLaveSeatNumber() + (orderCrossCity.getTravelMode() == 1 ? "," : "") + orderCrossCity.getSeatNumber()); + lineShiftDriverMapper.updateById(lineShiftDriver); + } + //修改司机为空闲 List<OrderCrossCity> orderCrossCities = orderCrossCityMapper.queryByDriverId(orderCrossCity.getDriverId(), 2, 3, 4, 5, 11); -- Gitblit v1.7.1