From 62a2a8e5fafec9cde437c00a5721253501451c33 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期三, 18 三月 2026 17:46:45 +0800
Subject: [PATCH] 派单模式 新增
---
UserYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushMinistryOfTransportUtil.java | 75 +++++++++++++++++++++++++++++++++++++
1 files changed, 75 insertions(+), 0 deletions(-)
diff --git a/UserYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushMinistryOfTransportUtil.java b/UserYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushMinistryOfTransportUtil.java
index b149ee8..47f70ab 100644
--- a/UserYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushMinistryOfTransportUtil.java
+++ b/UserYKDTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushMinistryOfTransportUtil.java
@@ -13,6 +13,7 @@
import com.stylefeng.guns.modular.system.service.*;
import com.stylefeng.guns.modular.taxi.service.ITransactionDetailsService;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -24,6 +25,7 @@
*/
@Component
public class PushMinistryOfTransportUtil {
+
@Autowired
private IUserInfoService userInfoService;
@@ -63,6 +65,10 @@
@Autowired
private IOrderEvaluateService orderEvaluateService;
+
+
+ @Resource
+ private RedisTemplate<String, Object> redisTemplate;
private String path = "http://120.77.11.218:8868/";
@@ -433,4 +439,73 @@
map.put("amount3", amount3);
return map;
}
+
+
+ /**
+ * 订单发起接口
+ * @param orderId
+ */
+ public void orderCreate(Integer orderId){
+ OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
+ Map<String, Object> query = systemPriceMapper.query1(orderPrivateCar.getCompanyId(), 1, orderPrivateCar.getServerCarModelId());
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("Address", 450204);//发起第行政区划代码
+ jsonObject.put("OrderId", orderPrivateCar.getOrderNum());//订单编号
+ jsonObject.put("DepartTime", orderPrivateCar.getTravelTime());//预计用车时间YYYYMMDDhhmmss
+ jsonObject.put("OrderTime", orderPrivateCar.getInsertTime());//订单发起时间YYYYMMDDhhmmss
+ jsonObject.put("PassengerNote", "");//乘客备注
+ jsonObject.put("Departure", orderPrivateCar.getStartAddress());//预计出发地点详细地址
+ jsonObject.put("DepLongitude", orderPrivateCar.getStartLon());//预计出发地点经度
+ jsonObject.put("DepLatitude", orderPrivateCar.getStartLat());//预计出发地点纬度
+ jsonObject.put("Destination", orderPrivateCar.getEndAddress());//预计目的地
+ jsonObject.put("DestLongitude", orderPrivateCar.getEndLon());//预计目的地经度
+ jsonObject.put("DestLatitude", orderPrivateCar.getEndLat());//预计目的地纬度
+ jsonObject.put("Encrypt", 1);//坐标加密标识（1：GCJ-02测绘局标准，2：WGS84 GPS标准，3：BD-09百度标准，4：CGCS2000北斗标准，0：其他）
+ jsonObject.put("FareType", query.get("id").toString());//运价类型编码
+ Map<String, Object> map = new HashMap<>();
+ map.put("orderCreate", jsonObject.toJSONString());
+
+ Map<String, String> header = new HashMap<>();
+ header.put("Connection", "keep-alive");
+ header.put("Content-Type", "application/x-www-form-urlencoded");
+ header.put("Accept", "*/*");
+ header.put("Accept-Encoding", "gzip");
+ header.put("Accept-Charset", "utf-8");
+ String result = httpClientUtil.pushHttpRequset("POST", path + "ministryOfTransport/orderCreate", map, header,"form");
+ System.err.println("---------------------------订单发起接口----------------------：" + result);
+ }
+
+
+ /**
+ * 订单成功接口
+ * @param orderId
+ */
+ public void orderMatch(Integer orderId){
+ OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
+ Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+ Car car = carMapper.selectById(orderPrivateCar.getCarId());
+ String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + orderPrivateCar.getDriverId());
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("Address", 450204);//发起地行政区划代码
+ jsonObject.put("OrderId", orderPrivateCar.getOrderNum());//订单编号
+ jsonObject.put("Longitude", Double.valueOf(value.split(",")[0]));//车辆经度
+ jsonObject.put("Latitude", Double.valueOf(value.split(",")[1]));//车辆纬度
+ jsonObject.put("Encrypt", 1);//坐标加密标识（1：GCJ-02测绘局标准，2：WGS84 GPS标准，3：BD-09百度标准，4：CGCS2000北斗标准，0：其他）
+ jsonObject.put("LicenseId", driver.getDriveCard());//机动车驾驶证编号
+ jsonObject.put("DriverPhone", driver.getPhone());//驾驶员手机号
+ jsonObject.put("VehicleNo", car.getCarLicensePlate());//车辆号牌
+ jsonObject.put("DistributeTime", new Date());//派单成功时间YYYYMMDDhhmmss
+ Map<String, Object> map = new HashMap<>();
+ map.put("orderMatch", jsonObject.toJSONString());
+
+ Map<String, String> header = new HashMap<>();
+ header.put("Connection", "keep-alive");
+ header.put("Content-Type", "application/x-www-form-urlencoded");
+ header.put("Accept", "*/*");
+ header.put("Accept-Encoding", "gzip");
+ header.put("Accept-Charset", "utf-8");
+ String result = httpClientUtil.pushHttpRequset("POST", path + "ministryOfTransport/orderMatch", map, header,"form");
+ System.err.println("--------------------------------订单成功接口---------------------------：" + result);
+ }
+
}
--
Gitblit v1.7.1