Pu Zhibing
4 天以前 9641d9ebc7b32b7e2cee898c8e9250e798c97e1b
UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/PushUtil.java
@@ -13,6 +13,7 @@
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;
@@ -29,7 +30,9 @@
@Component
public class PushUtil {
   
   private final String socket_uri = "http://192.168.110.85:6000";
   @Value("${qyt.socket_uri}")
   private String socket_uri;
   @Autowired
   private IOrderTaxiService orderTaxiService;
   
@@ -81,6 +84,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()) {
@@ -119,6 +123,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()) {
@@ -312,6 +317,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()) {
@@ -361,6 +367,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()) {
@@ -401,6 +408,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()) {