黔云通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
22 小时以前 f72ae151cc12b219cb5f39eea3ec0ea089a6ef2a 
 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()) {


@@ -101,7 +105,7 @@


    * @param orderId


    * @param orderType


    */


   public void pushEndPush(Integer type, Integer uid, Integer orderId, Integer orderType) {


   public void pushEndPush(Integer type, Integer uid, Integer orderId, Integer orderType, Integer state) {


      JSONObject jsonObject = new JSONObject();


      jsonObject.put("code", 200);


      jsonObject.put("msg", "SUCCESS");


@@ -109,6 +113,7 @@


      Map<String, Object> map = new HashMap<>();


      map.put("orderId", orderId);


      map.put("orderType", orderType);


      map.put("state", state);


      jsonObject.put("data", map);


      


      //调用推送


@@ -119,6 +124,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 +318,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 +368,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 +409,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()) {