From 79b7a9a6db4e5165e837ac083ccc70147135d571 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 12 八月 2025 11:45:51 +0800
Subject: [PATCH] 修改bug

---
 DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java |   21 +++++++++++++++------
 1 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java b/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java
index 8e5715c..57d2317 100644
--- a/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java
+++ b/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java
@@ -15,10 +15,10 @@
 import com.stylefeng.guns.modular.taxi.model.OrderTaxi;
 import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Component;
-import org.springframework.web.client.RestTemplate;
 
 import java.math.BigDecimal;
 import java.math.MathContext;
@@ -33,9 +33,6 @@
  */
 @Component
 public class PushUtil {
-
-    @Autowired
-    private RestTemplate internalRestTemplate;
 
     @Autowired
     private IOrderTaxiService orderTaxiService;
@@ -57,7 +54,11 @@
     
     private Map<String, Timer> taskMap = new HashMap<>();//存储定时推送的定时器
     
-    private final String socket_uri = "http://192.168.110.111:6000";
+    @Value("${qyt.socket_uri}")
+    private String socket_uri;
+    
+    
+
 
 
     // qyt 改派重新推单
@@ -86,6 +87,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -125,6 +127,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -164,6 +167,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -203,6 +207,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -363,7 +368,7 @@
             return;
         }
         //计算预计距离和剩余时间
-        String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(driverId));
+        String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + String.valueOf(driverId));
         if(null == value || "".equals(value)){
             return;
         }
@@ -439,6 +444,7 @@
         params.put("msg", msg.toJSONString());
         params.put("id", jsonObject.getIntValue("id"));
         params.put("type", jsonObject.getIntValue("type"));
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -473,6 +479,7 @@
         params.put("msg", msg.toJSONString());
         params.put("id", id);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -515,6 +522,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {
@@ -555,6 +563,7 @@
         params.put("msg", jsonObject.toJSONString());
         params.put("id", uid);
         params.put("type", type);
+        params.put("bussinessType", "dache");
         post.form(params);
         HttpResponse execute = post.execute();
         if (200 != execute.getStatus()) {

--
Gitblit v1.7.1