using System;
using SuperSocket.SocketBase.Command;
using SuperSocket.SocketBase.Protocol;
using SensorHub.Servers;
using Newtonsoft.Json;
using SensorHub.Servers.JsonFormat;

namespace SensorHub.WasteGas
{
    public class SewAcquireInterval : CommandBase<WGSession, StringRequestInfo>
    {
        public override void ExecuteCommand(WGSession session, StringRequestInfo requestInfo)
        {
            try
            {
                session.Logger.Info("SewAcquireInterval:" + requestInfo.Body);

                String devCode = requestInfo.Parameters[0];
                String message = JsonConvert.SerializeObject(new Json("SetResponse", "WasteGas", devCode,
                        new JsonBody("WasteGasConfigSuccess"), Common.getTimeStamp()));

                RedisHelper redis = new RedisHelper(0);
                redis.KeyDelete(devCode);

                if (Common.SendMessage(message))
                {
                    session.Logger.Info("往第三方发送数据：" + message);
                }
                else
                {
                    session.Logger.Info("未连接上第三方服务器");
                }
                
            }
            catch (Exception e)
            {
                session.Logger.Error("配置返回异常" + e.ToString());
            }
        }

    }
}