using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System.Collections.Generic;
using System;
using Quartz;
using Quartz.Impl;
using SensorHub.Utility;
using System.Timers;
using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
using SensorHub.Servers.JsonFormat;
using SensorHub.Servers.Commands.CASICCommands;
using StackExchange.Redis;
using System.Threading;
using System.Diagnostics;
using SensorHub.Config;
namespace SensorHub.Servers
{
public class CasicServer433 : AppServer<CasicSession>, IDespatchServer
{
RedisHelper redis = new RedisHelper(0);//依赖Redis的可靠性，如果Redis服务停止，需要重启本程序，希望以后可以改善
private List<String> concentratorThreadList = new List<String>();
//public static Dictionary<String, String> concentratorWithSessionIdMap = new Dictionary<String, String>();
public CasicServer433()
: base(new DefaultReceiveFilterFactory<CasicReceiveFilter433, StringRequestInfo>())
{
}
protected override void OnStarted()
{
redis.Subscribe("Config", (channel, message) =>
{
//输出收到的订阅消息
Logger.Info("收到订阅的Config消息：" + message);
String[] concentratorCodes = message.ToString().Split(',');
foreach (var concentratorCode in concentratorCodes)
{
if (!Common.concentratorWithSessionIdMap.ContainsKey(concentratorCode))
{
return;
}
if (!concentratorThreadList.Contains(concentratorCode))
{
Thread t = new Thread(doSendConfig);
t.Start(concentratorCode);
concentratorThreadList.Add(concentratorCode);
}
}
});
}
private void doSendConfig(object msg) //下发配置线程
{
String code = msg as String;
Dictionary<String, int> devWithMaxSendNumbers = new Dictionary<String, int>();
try
{
while (true)
{
String devcodes = redis.ListRightPop<String>(code);
if (string.IsNullOrEmpty(devcodes))
{
break;
}
if (!devcodes.Contains(":"))
{
devcodes += ":1";
}
String[] devcode = devcodes.Split(':');//设备编号：尝试次数
Logger.Info("设备[" + devcode[0] + "]剩余主动下发配置尝试次数：" + devcode[1]);
String devCode = devcode[0].Replace("$", "").Substring(0,12);
String devType = devCode.Substring(0, 2);
int interval = 0;//下发时间间隔
byte routeflag = 0x01;//通信方式，路灯为05
if (devType == "72" || devType == "73" || devType == "74")//路灯时间长
{
interval = int.Parse(System.Configuration.ConfigurationManager.AppSettings["Lamp_Interval"]);
routeflag = 0x05;
}
else
{
interval = int.Parse(System.Configuration.ConfigurationManager.AppSettings["Concentrator_Interval"]);
//interval = 10000;
}
String configItem = redis.StringGet(devcode[0]);
if (string.IsNullOrEmpty(configItem))
{
redis.ListRemove<String>(code, devcode[0]);
Logger.Info("设备[" + devcode[0] + "]已下发成功，下发配置项为空");
continue;
}
byte[] config = null;
if (configItem.Contains("collect"))
{
config = ConfigBuild.buildQueryFrame(devCode);
}
else
{
config = ConfigBuild.build433ConfigFrame(devCode, configItem);
}
config[10] = routeflag;//通信方式
DispatchMessage(code, config);
int num = int.Parse(devcode[1]);
if (--num > 0)
{
if (devcode[0].Contains("$"))
{
redis.ListRightPush<String>(code, devcode[0] + ":" + num.ToString());
}
else
{
redis.ListLeftPush<String>(code, devcode[0] + ":" + num.ToString());
}
}
Thread.Sleep(interval);
}
}
catch (Exception ex)
{
Logger.Error("下发配置错误：" + ex.ToString());
}
finally
{
if (concentratorThreadList.Contains(code))
{
concentratorThreadList.Remove(code);
}
}
}
protected override void OnSessionClosed(CasicSession session, CloseReason reason)
{
if (session.HubAddr != null)
{
//集中器离线，给第三方发信息
if (Common.concentratorWithSessionIdMap.ContainsKey(session.HubAddr))
{
Logger.Info("集中器离线，移除连接：" + session.HubAddr + "," + session.SessionID);
Common.concentratorWithSessionIdMap.Remove(session.HubAddr);
}
DateTime now = DateTime.Now;
DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); //当地时区
long timeStamp = (long)(now - startTime).TotalMilliseconds; //相差毫秒数
String logtime = now.ToString("yyyy") + now.ToString("MM") + now.ToString("dd")
+ now.ToString("HH") + now.ToString("mm") + now.ToString("ss");
String message = JsonConvert.SerializeObject(new Json("Event", "Concentrator", session.HubAddr,
new DataJson("ConcentratorOffline", -1, null, logtime), timeStamp));
if (Common.SendMessage(message))
{
session.Logger.Info("往第三方发送数据：" + message);
}
else
{
session.Logger.Info("未连接上第三方服务器");
}
}
base.OnSessionClosed(session, reason);
}
public void DispatchMessage(string devCode, byte[] config)
{
if (Common.concentratorWithSessionIdMap.ContainsKey(devCode))
{
String sessionID = Common.concentratorWithSessionIdMap[devCode];
Logger.Info("集中器设备编号：" + devCode + "," + sessionID);
CasicSession s = this.GetSessionByID(sessionID);
if (s != null && s.Connected)
{
//增加CRC校验
String strCrc = StringUtil.To16HexString(String.Format("{0:X}", (int)CodeUtils.CRC16_AD(config)));
byte[] btcrc = { CodeUtils.String2Byte(strCrc.Substring(0, 2)), CodeUtils.String2Byte(strCrc.Substring(2, 2)) };
byte[] afcrc = new byte[config.Length + 2];
config.CopyTo(afcrc, 0);
btcrc.CopyTo(afcrc, config.Length);
Logger.Info("主动下发配置信息：" + BitConverter.ToString(afcrc).Replace("-", ""));
s.Send(afcrc, 0, afcrc.Length);
}
else
{
Logger.Info("主动下发配置失败，连接不存在或已断开");
}
}
//foreach (CasicSession session in this.GetAllSessions())
//{
// //可以改进
// session.Logger.Info("集中器设备编号：" + session.HubAddr + "," + session.SessionID);
// if (session.HubAddr == devCode && devCode != null)
// {
// //增加CRC校验
// String strCrc = StringUtil.To16HexString(String.Format("{0:X}", (int)CodeUtils.CRC16_AD(config)));
// byte[] btcrc = { CodeUtils.String2Byte(strCrc.Substring(0, 2)), CodeUtils.String2Byte(strCrc.Substring(2, 2)) };
// byte[] afcrc = new byte[config.Length + 2];
// config.CopyTo(afcrc, 0);
// btcrc.CopyTo(afcrc, config.Length);
// session.Logger.Info("主动下发配置信息：" + BitConverter.ToString(afcrc).Replace("-", ""));
// session.Send(afcrc, 0, afcrc.Length);
// }
//}
}
}
}
