diff --git a/SensorHub.Servers/Common.cs b/SensorHub.Servers/Common.cs index 966984e..f3af0f9 100644 --- a/SensorHub.Servers/Common.cs +++ b/SensorHub.Servers/Common.cs @@ -108,6 +108,7 @@ if (redis.Conn != null) { configItem = redis.StringGet(devCode); + session.Logger.Info("config: " + devCode + "/" + configItem); } byte[] config = ConfigBuild.buildConfigFrame(devCode, configItem); @@ -793,6 +794,7 @@ if (redis.Conn != null) { configItem = redis.StringGet(devCode); + session.Logger.Info(devCode + "/" + configItem); if (!String.IsNullOrEmpty(configItem)) { ConfigItems configItems = JsonConvert.DeserializeObject(configItem); @@ -806,9 +808,9 @@ } // 设置成功的响应写入kafka - kafkaSetResponseProduce(session, devCode, devName); + // kafkaSetResponseProduce(session, devCode, devName); - /* + ///* String message = JsonConvert.SerializeObject(new Json("SetResponse", devName, devCode, new JsonBody(devName + "ConfigSuccess"), getTimeStamp())); if (Common.SendMessage(message)) { @@ -817,7 +819,7 @@ else { session.Logger.Info("未连接上第三方服务器"); - }*/ + }//*/ } //public static void sendSetResponse(CasicSession session, String devCode, String devName)