From 9641d9ebc7b32b7e2cee898c8e9250e798c97e1b Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期六, 16 八月 2025 15:17:32 +0800 Subject: [PATCH] 修改bug --- DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java | 19 ++++++++++++++----- 1 files changed, 14 insertions(+), 5 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 ae9ba2f..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.85: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()) { @@ -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