修改bug

Pu Zhibing

4 天以前 9641d9ebc7b32b7e2cee898c8e9250e798c97e1b

 MessagePushTravel/src/main/java/com/sinata/push/util/echo/NettyServerController.java

@@ -5,7 +5,7 @@
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
//import com.sinata.push.config.QYTConfig;
import com.sinata.push.config.QYTConfig;
import com.sinata.push.util.*;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
@@ -35,7 +35,7 @@

   public static Hashtable<String,String> table;
   
//   public static QYTConfig qytConfig;
   public static QYTConfig qytConfig;

   private RedisUtil redisUtil = SpringUtil.getObject(RedisUtil.class);

@@ -51,9 +51,9 @@
   }
   
   
//   public static void setQytConfig(QYTConfig qytConfig) {
//      NettyServerController.qytConfig = qytConfig;
//   }
   public static void setQytConfig(QYTConfig qytConfig) {
      NettyServerController.qytConfig = qytConfig;
   }
   
   public static boolean isdebug = false;
   public static int i = 0;
@@ -207,7 +207,7 @@
                        params.put("lat", String.valueOf(lat));
                        params.put("directionAngle", String.valueOf(computeAzimuth));
                        params.put("altitude", String.valueOf(altitude));
                        HttpRequest post = HttpUtil.createPost("http://10.31.182.11:8010/chuxing/driver-server/base/savePosition");
                        HttpRequest post = HttpUtil.createPost(qytConfig.getChuxingUrl() + "/driver-server/base/savePosition");
                        post.contentType(MediaType.APPLICATION_FORM_URLENCODED_VALUE);
                        post.form(params);
                        HttpResponse execute = post.execute();
@@ -234,7 +234,7 @@
                     params.put("lat", String.valueOf(lat));
                     params.put("directionAngle", String.valueOf(computeAzimuth));
                     params.put("altitude", String.valueOf(altitude));
                     HttpRequest post = HttpUtil.createPost("http://10.31.182.11:8010/daijia/driver-server/base/driver/addDriverPosition");
                     HttpRequest post = HttpUtil.createPost(qytConfig.getDaijiaurl() + "/driver-server/base/driver/addDriverPosition");
                     post.contentType(MediaType.APPLICATION_FORM_URLENCODED_VALUE);
                     post.form(params);
                     HttpResponse execute = post.execute();
@@ -247,7 +247,7 @@
                     }
                  }
                  
                  redisUtil.setStrValue(business + "_DRIVER" + driverId, lon + "," + lat, 30);//实时位置存入redis中
                  redisUtil.setStrValue(business + ":DRIVER" + driverId, lon + "," + lat, 30);//实时位置存入redis中
               }else{
                  this.sendMsgToClient(ctx, "__error__" + msg.toString());
               }