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