From c0ffabe6c300432c2492485a47f88e990f9c7f8e Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期二, 12 八月 2025 10:16:11 +0800 Subject: [PATCH] update --- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java | 34 +++++++++++++++++----------------- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PushUtil.java | 13 ++++++++++++- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java | 2 +- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/OrderPriceWarpper.java | 8 ++++---- 4 files changed, 34 insertions(+), 23 deletions(-) diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java index b668aac..deefb9e 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java @@ -629,7 +629,7 @@ Double lat = driverPositionWarpper.getLat(); Integer driverId = driverPositionWarpper.getDriverId(); Integer orderId = driverPositionWarpper.getOrderId(); - redisUtil.setStrValue("daijia:DRIVER" + driverId, lon + "," + lat, 30); + redisUtil.setStrValue("daijia_DRIVER" + driverId, lon + "," + lat, 30); Query query = Query.query(Criteria.where("driverId").is(driverId)); Location old = this.mongoTemplate.findOne(query, Location.class); if (Objects.isNull(old)) { diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java index a1d2745..d5fd06c 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java @@ -1538,22 +1538,22 @@ public ResultUtil setOrderStatus(Integer uid, Long orderId, Integer payType, Integer state) throws Exception { try { boolean lock = redisUtil.lock(orderId + "",5); - if(!lock){ - int num1 = 1; - while (num1 <= 10){ - Thread.sleep(3000);//等待3秒 - lock = redisUtil.lock(orderId + "",5); - if(lock){ - break; - }else{ - num1++; - } - } - } - if(!lock){ - redisUtil.unlock(orderId + ""); - return ResultUtil.error("请稍后重试"); - } +// if(!lock){ +// int num1 = 1; +// while (num1 <= 10){ +// Thread.sleep(3000);//等待3秒 +// lock = redisUtil.lock(orderId + "",5); +// if(lock){ +// break; +// }else{ +// num1++; +// } +// } +// } +// if(!lock){ +// redisUtil.unlock(orderId + ""); +// return ResultUtil.error("请稍后重试"); +// } Order order = this.selectById(orderId); if(state == 107 && order.getState() != 106){ @@ -1562,7 +1562,7 @@ } if(state == 108 && order.getState() != 107){ redisUtil.unlock(orderId + ""); - return ResultUtil.error("操作失败,请刷新数据"); +// return ResultUtil.error("操作失败,请刷新数据"); } order.setState(state); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PushUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PushUtil.java index d87c595..784ee10 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PushUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PushUtil.java @@ -28,7 +28,7 @@ Logger logger = LoggerFactory.getLogger("ServiceLog"); - private final String socket_uri = "http://192.168.110.85:6000"; + private final String socket_uri = "http://192.168.110.111:6000"; @@ -52,6 +52,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -87,6 +88,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -128,6 +130,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -165,6 +168,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -206,6 +210,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -243,6 +248,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -281,6 +287,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -315,6 +322,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -352,6 +360,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -387,6 +396,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { @@ -418,6 +428,7 @@ params.put("msg", msg.toJSONString()); params.put("id", id.toString()); params.put("type", type.toString()); + params.put("bussinessType", "daijia"); post.form(params); HttpResponse execute = post.execute(); if (200 != execute.getStatus()) { diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/OrderPriceWarpper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/OrderPriceWarpper.java index c6d51ce..1446e2c 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/OrderPriceWarpper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/OrderPriceWarpper.java @@ -19,13 +19,13 @@ @ApiModelProperty("总行驶里程") private Double actualMileage; @ApiModelProperty("起步价") - private Double startPrice; + private Double startPrice=0.0; @ApiModelProperty("起步里程") - private Double startDistance; + private Double startDistance=0.0; @ApiModelProperty("超出起步里程") - private Double overDriveDistance; + private Double overDriveDistance=0.0; @ApiModelProperty("里程费") - private Double mileageFee; + private Double mileageFee=0.0; @ApiModelProperty("等待时长") private String waitTime; @ApiModelProperty("等待费") -- Gitblit v1.7.1