2351 lines
116 KiB
C#
2351 lines
116 KiB
C#
using System;
|
||
using System.Collections.Concurrent;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using System.Net.Sockets;
|
||
using Common;
|
||
using Dao;
|
||
using RCUHost.Protocols;
|
||
using uPLibrary.Networking.M2Mqtt;
|
||
using uPLibrary.Networking.M2Mqtt.Messages;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using System.IO;
|
||
using CommonEntity;
|
||
using RestSharp;
|
||
using System.Configuration;
|
||
using Dao.Implement;
|
||
using Domain;
|
||
using System.Threading;
|
||
using System.Collections;
|
||
using Newtonsoft.Json;
|
||
using Microsoft.IO;
|
||
|
||
namespace RCUHost.Implement
|
||
{
|
||
public class State
|
||
{
|
||
internal State(int bufferSize)
|
||
{
|
||
Buffer = new byte[bufferSize];
|
||
}
|
||
|
||
internal byte[] Buffer = null;
|
||
}
|
||
/// <summary>
|
||
/// HostServer
|
||
/// 服务器与RCU主机所有往来命令消息都会经过 HostServer 进行统一处理。
|
||
/// 对于 RCU 发往服务器的消息，首先进行校验，解析出消息头部，分发给其对应的 Receiver
|
||
/// 再由 Receiver 对数据部分进行解析处理。
|
||
/// 服务器发往 RCU 的消息，首先由 Receiver 对命令数据进行封包，再经由 HostServer 将
|
||
/// 数据发送出去。
|
||
/// HostServer 维护一个 Receiver 列表，如果需要 HostServer 处理 RCU 发给服务器的
|
||
/// 某种类型消息，就需要将其对应的 Receiver 附加到 Receiver 列表中，否则 HostServer 就
|
||
/// 会忽略该消息。
|
||
/// </summary>
|
||
public class HostServer : IHostServer, IDisposable
|
||
{
|
||
#region Private Properties
|
||
|
||
public ISysOauth2Repository SysOauth2Repository { get; set; }
|
||
public IHostModalRepository HostModalRepository { get; set; }
|
||
private static log4net.ILog logger = log4net.LogManager.GetLogger(typeof(HostServer));
|
||
private Object _lock = new Object();
|
||
private UdpClient udpClient;
|
||
//private Socket udpClient;
|
||
private ConcurrentDictionary<CommandType, IReceiver> receivers = new ConcurrentDictionary<CommandType, IReceiver>();
|
||
private ConcurrentBag<CommandData> commandQueue = new ConcurrentBag<CommandData>();//BlockingCollection
|
||
//private System.Threading.Timer timer = null;
|
||
//private Object _lock1 = new Object();
|
||
private static long _customer = 0;
|
||
private Object _lock2 = new Object();
|
||
|
||
#endregion
|
||
|
||
#region Public Properies
|
||
|
||
/// <summary>
|
||
/// BeforeStart事件
|
||
/// HostServer 启动之前调用
|
||
/// </summary>
|
||
//public event EventHandler BeforeStart;
|
||
|
||
/// <summary>
|
||
/// AfterStart事件
|
||
/// HostServer 启动后调用
|
||
/// </summary>
|
||
//public event EventHandler AfterStart;
|
||
|
||
#endregion
|
||
|
||
#region 由Spring调用
|
||
|
||
/// <summary>
|
||
/// 由 Spring 在创建 HostServer 后调用
|
||
/// </summary>
|
||
public void Init()
|
||
{
|
||
Start();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 由 Spring 在销毁 HostServer 前调用
|
||
/// </summary>
|
||
public void Destroy()
|
||
{
|
||
Close();
|
||
}
|
||
|
||
#endregion
|
||
|
||
public void AddReceiver(IReceiver receiver)
|
||
{
|
||
if (receiver != null)
|
||
{
|
||
receivers[receiver.CommandType] = receiver;
|
||
}
|
||
}
|
||
|
||
public void RemoveReceiver(IReceiver receiver)
|
||
{
|
||
if (receiver != null)
|
||
{
|
||
IReceiver takeReceiver = null;
|
||
receivers.TryRemove(receiver.CommandType, out takeReceiver);
|
||
}
|
||
}
|
||
|
||
public static string UDPAllDataKey = "All_UDPPackage_Data";
|
||
public void StreamConsume(string group = "UDPData", string consumer = "Crics1", string task_key = "task1")
|
||
{
|
||
try
|
||
{
|
||
var redis = CSRedisCacheHelper.redis1;
|
||
var data = redis.XReadGroup(group, consumer, 500, 10, new ValueTuple<string, string>(UDPAllDataKey, ">"));
|
||
|
||
if (data != null)
|
||
{
|
||
//var pending = redis.XPending(UDPAllDataKey, group);
|
||
foreach (var item in data)
|
||
{
|
||
var idarray = item.Item2;
|
||
string nsa = string.Concat(task_key, "#", idarray.Count().ToString());
|
||
CSRedisCacheHelper.Publish("udp_package_consumer", nsa);
|
||
foreach (var SerializeNo in idarray)
|
||
{
|
||
var id1 = SerializeNo.Item1;
|
||
var str = SerializeNo.Item2[1];
|
||
var GGG = JsonConvert.DeserializeObject<GaiXie>(str);
|
||
redis.XAck(UDPAllDataKey, group, id1);
|
||
redis.XDel(UDPAllDataKey, id1);
|
||
ProcessData(GGG);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 启动 HostServer
|
||
/// </summary>
|
||
public void Start()
|
||
{
|
||
Close();
|
||
|
||
//CSRedisCacheHelper.StreamAdd(1,UDPAllDataKey, data);
|
||
//CSRedisCacheHelper.StreamConsume(1, UDPAllDataKey);
|
||
try
|
||
{
|
||
udpClient = new UdpClient(3339);
|
||
uint IOC_IN = 0x80000000;
|
||
uint IOC_VENDOR = 0x18000000;
|
||
uint SIO_UDP_CONNRESET = IOC_IN | IOC_VENDOR | 12;
|
||
udpClient.Client.IOControl((int)SIO_UDP_CONNRESET, new byte[] { Convert.ToByte(false) }, null);
|
||
udpClient.BeginReceive(ReceiveCallback, new UdpState(udpClient));
|
||
logger.Error("Host Server启动成功，端口：3339");
|
||
|
||
|
||
CSRedisCacheHelper.redis1.Del(UDPAllDataKey);
|
||
CSRedisCacheHelper.redis1.XGroupCreate(UDPAllDataKey, "UDPData", "0", true);
|
||
Task.Factory.StartNew(() =>
|
||
{
|
||
while (true)
|
||
{
|
||
StreamConsume("UDPData", "Crics1", "task1");
|
||
}
|
||
}, TaskCreationOptions.LongRunning);
|
||
Task.Factory.StartNew(() =>
|
||
{
|
||
while (true)
|
||
{
|
||
StreamConsume("UDPData", "Crics2", "task2");
|
||
}
|
||
}, TaskCreationOptions.LongRunning);
|
||
|
||
Task.Factory.StartNew(() =>
|
||
{
|
||
while (true)
|
||
{
|
||
StreamConsume("UDPData", "Crics3", "task3");
|
||
}
|
||
}, TaskCreationOptions.LongRunning);
|
||
|
||
Task.Factory.StartNew(() =>
|
||
{
|
||
while (true)
|
||
{
|
||
StreamConsume("UDPData", "Crics4", "task4");
|
||
}
|
||
}, TaskCreationOptions.LongRunning);
|
||
|
||
Task.Factory.StartNew(() =>
|
||
{
|
||
while (true)
|
||
{
|
||
StreamConsume("UDPData", "Crics5", "task5");
|
||
}
|
||
}, TaskCreationOptions.LongRunning);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error("Host Server启动失败，端口：3339");
|
||
Close();
|
||
//throw ex;//不能去掉，否则重启iis服务，通讯服务不会再次启动
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 关闭 HostServer
|
||
/// </summary>
|
||
public void Close()
|
||
{
|
||
if (udpClient != null)
|
||
{
|
||
udpClient.Close();
|
||
udpClient = null;
|
||
}
|
||
}
|
||
public static MqttClient client { get; set; }
|
||
public static void StartMQTTClient()
|
||
{
|
||
try
|
||
{
|
||
if (client == null || client.IsConnected == false)
|
||
{
|
||
client = new MqttClient("127.0.0.1");
|
||
|
||
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
|
||
client.ConnectionClosed += new MqttClient.ConnectionClosedEventHandler(client_ConnectionClosed);
|
||
string clientId = Guid.NewGuid().ToString("N");
|
||
client.Connect(clientId);
|
||
|
||
client.Subscribe(new string[] { "/blw/mqtt/test" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
|
||
|
||
Console.ReadKey();
|
||
}
|
||
}
|
||
catch (Exception)
|
||
{
|
||
|
||
}
|
||
}
|
||
static void client_ConnectionClosed(object sender, EventArgs e)
|
||
{
|
||
bool bbb = client.IsConnected;
|
||
}
|
||
|
||
static void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
|
||
{
|
||
string sss = Encoding.UTF8.GetString(e.Message);
|
||
logger.Error("收到了测试数据:" + sss);
|
||
}
|
||
public static void PublishMessage(byte[] message)
|
||
{
|
||
string topic = "/blw/2024/registerinfo";
|
||
if (client != null && client.IsConnected)
|
||
{
|
||
client.Publish(topic, message);
|
||
}
|
||
else
|
||
{
|
||
StartMQTTClient();
|
||
client.Publish(topic, message);
|
||
}
|
||
}
|
||
|
||
#region 数据发送
|
||
|
||
/// <summary>
|
||
/// 将命令数据报发送到指定的远程主机上的指定端口。
|
||
/// </summary>
|
||
/// <param name="data">byte类型数据，表示将要发送到远程主机的命令数据</param>
|
||
/// <param name="ip">远程主机IP地址</param>
|
||
/// <param name="port">远程主机端口</param>
|
||
public void Send(byte[] data, string ip, int port)
|
||
{
|
||
Send(data, new IPEndPoint(IPAddress.Parse(ip), port), false);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将命令数据发送到位于指定远程终结点的主机。
|
||
/// </summary>
|
||
/// <param name="data">byte类型数据，表示将要发送到远程主机的命令数据</param>
|
||
/// <param name="endPoint">IPEndPoint类型，表示要将命令数据发送到的主机和端口</param>
|
||
public void Send(byte[] data, IPEndPoint endPoint)
|
||
{
|
||
Send(data, endPoint, false);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将命令数据报发送到指定的远程主机上的指定端口。
|
||
/// </summary>
|
||
/// <param name="data">byte类型数据，表示将要发送到远程主机的命令数据</param>
|
||
/// <param name="ip">远程主机IP地址</param>
|
||
/// <param name="port">远程主机端口</param>
|
||
public void SendAndPushCommandQueue(byte[] data, string ip, int port)
|
||
{
|
||
Send(data, new IPEndPoint(IPAddress.Parse(ip), port), true);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将命令数据发送到位于指定远程终结点的主机。
|
||
/// </summary>
|
||
/// <param name="data">byte类型数据，表示将要发送到远程主机的命令数据</param>
|
||
/// <param name="endPoint">IPEndPoint类型，表示要将命令数据发送到的主机和端口</param>
|
||
public void SendAndPushCommandQueue(byte[] data, IPEndPoint endPoint)
|
||
{
|
||
Send(data, endPoint, true);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将命令数据发送到位于指定远程终结点的主机。
|
||
/// </summary>
|
||
/// <param name="data">byte类型数据，表示将要发送到远程主机的命令数据</param>
|
||
/// <param name="endPoint">IPEndPoint类型，表示要将命令数据发送到的主机和端口</param>
|
||
/// <param name="needPushCommandQueue">是否需要将命令放入队列</param>
|
||
public void Send(byte[] data, IPEndPoint endPoint, bool needPushCommandQueue)
|
||
{
|
||
if (udpClient != null)
|
||
{
|
||
#region 去掉lock
|
||
ushort crc = Tools.CRC16(data, data.Length - 2);//最后两个字节，加CRC16校验
|
||
data[data.Length - 2] = Convert.ToByte(crc & 0xff);
|
||
data[data.Length - 1] = Convert.ToByte((crc >> 8) & 0xff);
|
||
|
||
//[AA 55 2C 00
|
||
//54 33 53 41
|
||
//0E
|
||
//FF AA
|
||
//3D 04 //hotelcode 04 3D 1085
|
||
//60
|
||
//CB
|
||
//00 00 00 00 00 00 00 03 04 00 08 00 01 00 34 01 08 00 02 00 01 06 01 00 02 00 00 52 A4 ]
|
||
var HotelCode = data.Skip(11).Take(2).ToArray();
|
||
var N1 = HotelCode[0];
|
||
var N2 = HotelCode[1];
|
||
if (N1 == 0xFF && N2 == 0xFF)
|
||
{
|
||
//return;
|
||
}
|
||
|
||
var N3 = Convert.ToInt64(Convert.ToInt16(N1.ToString("000")) + Convert.ToInt16(N2.ToString("000")) * 256).ToString();
|
||
|
||
var TotalKey = "UDPPackage_TotalSendPackage";
|
||
UDPPackageCount LLL_T = null;
|
||
DataTongJi.TotalCount.TryGetValue(TotalKey, out LLL_T);
|
||
if (LLL_T != null)
|
||
{
|
||
LLL_T.Count = LLL_T.Count + 1;
|
||
long UUU = 0;
|
||
LLL_T.FenLei.TryGetValue(N3, out UUU);
|
||
UUU = UUU + 1;
|
||
|
||
long UUU1 = 0;
|
||
LLL_T.FenLei.TryRemove(N3, out UUU1);
|
||
LLL_T.FenLei.TryAdd(N3, UUU);
|
||
}
|
||
else
|
||
{
|
||
UDPPackageCount u = new UDPPackageCount();
|
||
u.Count = 1;
|
||
u.FenLei = new ConcurrentDictionary<string, long>();
|
||
u.FenLei.TryAdd(N3, 1);
|
||
DataTongJi.TotalCount.TryAdd(TotalKey, u);
|
||
}
|
||
|
||
udpClient.Send(data, data.Length, endPoint);
|
||
// 使用同一个 Socket 发送回复
|
||
//udpClient.SendTo(data, endPoint);
|
||
#endregion
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// 自定义序号：用于推送通讯命令
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
private long GetNextCustomer()
|
||
{
|
||
lock (_lock2)
|
||
{
|
||
if (_customer < 16000000)
|
||
{
|
||
_customer++;
|
||
}
|
||
else
|
||
{
|
||
_customer = 0;
|
||
}
|
||
}
|
||
|
||
//if (_customer < 16000000)
|
||
//{
|
||
// Interlocked.Increment(ref _customer);
|
||
//}
|
||
//else
|
||
//{
|
||
// Interlocked.Exchange(ref _customer, 0);
|
||
//}
|
||
return _customer;
|
||
}
|
||
public IHostRepository HostRepository { get; set; }
|
||
public ISysHotelRepository SysHotelRepository { get; set; }
|
||
|
||
/// <summary>
|
||
/// 异步接收回调函数
|
||
/// </summary>
|
||
/// <param name="ar"></param>
|
||
private void ReceiveCallback(IAsyncResult ar)
|
||
{
|
||
UdpState state = ar.AsyncState as UdpState;
|
||
try
|
||
{
|
||
IPEndPoint remoteEP111 = new IPEndPoint(IPAddress.Any, 0);
|
||
byte[] receiveBuffer111 = state.UdpClient.EndReceive(ar, ref remoteEP111);
|
||
if (receiveBuffer111.Length > 0)
|
||
{
|
||
|
||
#region 接收的数据包总数
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalReceiveCount);
|
||
#endregion
|
||
|
||
ReceiverContext context = new ReceiverContext(receiveBuffer111, remoteEP111, GetNextCustomer());
|
||
|
||
int length = context.Data.Length;
|
||
if (length < 3 || length != BitConverter.ToInt16(context.Data, 2))
|
||
{
|
||
//错误数据
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalErrorPackageReceiveCount);
|
||
return;//非正确的数据包
|
||
}
|
||
|
||
context.SystemHeader = DecodeSystemHeader(context.Data);
|
||
if (context.SystemHeader.HasValue)
|
||
{
|
||
if (!String.Equals(new String(context.SystemHeader.Value.SystemID), SystemHeader.SYSTEM_ID, StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
//错误数据
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalErrorPackageReceiveCount);
|
||
return;//非系统数据包
|
||
}
|
||
|
||
try
|
||
{
|
||
|
||
//透传是新增加的
|
||
var VVV = context.SystemHeader.Value;
|
||
string KKKHNH = CacheKey.TouChuanKey;
|
||
var HHHostNo = context.SystemHeader.Value.HostNumber.ToString();
|
||
var da1 = CSRedisCacheHelper.HMGet<string>(1, KKKHNH, HHHostNo);
|
||
if (!string.IsNullOrEmpty(da1[0]))
|
||
{
|
||
string nns = Tools.ByteToString(context.Data);
|
||
if (VVV.CmdType == 0x71)
|
||
{
|
||
BLWMQTT.MQTTPublishData("blw/touchuan/report/" + HHHostNo, nns);
|
||
}
|
||
}
|
||
|
||
#region 只处理正确的
|
||
if (VVV.CmdType != 0xD6 && VVV.CmdType != 0x0C)
|
||
{
|
||
var hostnumber1 = VVV.HostNumber;
|
||
string hotelCode = hostnumber1.ToHotelCode().ToString();//获取酒店编码
|
||
|
||
var hostnumber2 = hostnumber1.ToString();
|
||
//时间拦截 超过2秒就不再处理
|
||
string ShiJianLanJie = CacheKey.TimeIntercept + "_" + hostnumber2;
|
||
string ShiJianLanJieSync = CacheKey.SyncTimeIntercept + "_" + hostnumber2;
|
||
if (VVV.CmdType == 0x0E)
|
||
{
|
||
//MemoryCacheHelper.Set(ShiJianLanJie, 1, DateTimeOffset.Now.AddSeconds(DataTongJi.LostPackage_Interval));
|
||
|
||
//有错误的0x19数据，所有的 在0x19数据触发后的5秒内的后续数据就不再接收
|
||
string key123 = RoomStatusReceiver.PoolOverFlowKey + "_" + hostnumber2;
|
||
var OOObj = MemoryCacheHelper.Get(key123);
|
||
if (OOObj != null)
|
||
{
|
||
//错误数据
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalErrorPackageReceiveCount);
|
||
return;
|
||
}
|
||
}
|
||
|
||
|
||
///消息ID +1
|
||
Interlocked.Increment(ref StepTongJi.EveryMessageIDNo);
|
||
//因为0E不会被拦截所以可以在这里写
|
||
if (VVV.CmdType == 0x0E || VVV.CmdType == 0X01)
|
||
{
|
||
//StepTongJi.EveryMessageID = Guid.NewGuid().ToString("N");
|
||
//计数器+1
|
||
Interlocked.Increment(ref StepTongJi.LookDataCounter);
|
||
|
||
//开始监听
|
||
Interlocked.Increment(ref StepTongJi.Every_0E_01_MessageID);
|
||
if (StepTongJi.LookDataCounter == 500)
|
||
{
|
||
//监听的ID
|
||
//Interlocked.Exchange(ref StepTongJi.GlobalListenID, StepTongJi.EveryMessageID);
|
||
|
||
context.MessageID = Guid.NewGuid().ToString("N");
|
||
context.IsMonitor = true;
|
||
|
||
|
||
int maxWorker = 0;
|
||
int maxIo = 0;
|
||
int availWorker = 0;
|
||
int availIo = 0;
|
||
// 获取最大线程数
|
||
ThreadPool.GetMaxThreads(out maxWorker, out maxIo);
|
||
// 获取可用线程数
|
||
ThreadPool.GetAvailableThreads(out availWorker, out availIo);
|
||
// 计算忙碌线程数
|
||
int busyWorker = maxWorker - availWorker;
|
||
int busyIo = maxIo - availIo;
|
||
int minWorker = 0;
|
||
int minIo = 0;
|
||
// 获取最小线程数
|
||
ThreadPool.GetMinThreads(out minWorker, out minIo);
|
||
|
||
int tid = Thread.CurrentThread.ManagedThreadId;
|
||
string NNN1 = string.Format("工作线程{8}: 最小={0}, 最大={1}, 可用={2}, 使用中={3},IO线程: 最小={4}, 最大={5}, 可用={6}, 使用中={7}", minWorker, maxWorker, availWorker, busyWorker, minIo, maxIo, availIo, busyIo, tid);
|
||
|
||
StepTongJi.SendInfo(0.1, NNN1, context.MessageID, context.IsMonitor);
|
||
|
||
string NNN7 = string.Format("HostNUMBER:{0},端点:{1}", hostnumber2, context.RemoteEndPoint.ToString());
|
||
StepTongJi.SendInfo(0.2, NNN7, context.MessageID, context.IsMonitor);
|
||
|
||
StepInfo s = new StepInfo();
|
||
s.Step = 1;
|
||
s.MessageId = context.MessageID;
|
||
s.StepDescription = "进入UDPCallBack";
|
||
//string ti = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.ffffff");
|
||
string ti = CPUData.GetNowPrecise().ToString("yyyy-MM-dd HH:mm:ss.ffffff");
|
||
s.TriggerTime = ti;
|
||
s.Content = context.Data;
|
||
s.EveryMessageId = StepTongJi.EveryMessageIDNo;
|
||
s.Monitor_0E_01 = StepTongJi.Every_0E_01_MessageID;
|
||
s.HotelCode = hotelCode;
|
||
s.HostNumber = hostnumber2;
|
||
|
||
string NNN = Newtonsoft.Json.JsonConvert.SerializeObject(s);
|
||
CSRedisCacheHelper.Publish("redis-roomstatus-monitor", NNN);
|
||
|
||
Interlocked.Exchange(ref StepTongJi.LookDataCounter, 0);
|
||
}
|
||
}
|
||
|
||
if (VVV.CmdType == 0x08)
|
||
{
|
||
MemoryCacheHelper.Set(ShiJianLanJieSync, 1, DateTimeOffset.Now.AddSeconds(DataTongJi.LostPackage_Interval));
|
||
}
|
||
if (VVV.CmdType == 0x02)
|
||
{
|
||
MemoryCacheHelper.Set(ShiJianLanJie, 1, DateTimeOffset.Now.AddSeconds(50));
|
||
}
|
||
|
||
|
||
if (VVV.CmdType == 0x01)
|
||
{
|
||
//升级之后，会上报注册指令，不能被跳过
|
||
string Key = "Upgrade_UpdateSQL_" + hostnumber1;
|
||
object OOO1 = MemoryCacheHelper.Get(Key);
|
||
if (OOO1 == null)
|
||
{
|
||
//string RegisterKey2 = "SearchHostFilter";
|
||
|
||
//上报注册指令太快会被拦截
|
||
//string KKK = "RegisterKey_" + hostnumber1;
|
||
//object OOO = MemoryCacheHelper.Get(KKK);
|
||
//if (OOO != null)
|
||
//{
|
||
// RCUHost.RCUHostCommon.tools.LanJieData(RegisterKey2, hotelCode);
|
||
// return;
|
||
//}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
string LanJieKey = "Intercept";
|
||
ConcurrentBag<string> RoomNumberList = null;
|
||
bool isexists = DataTongJi.BlockLowerMachineList.TryGetValue(hotelCode, out RoomNumberList);
|
||
//如果存在数据
|
||
if (isexists)
|
||
{
|
||
//如果 设备序号存在就过滤掉
|
||
if (RoomNumberList != null && RoomNumberList.Count > 0)
|
||
{
|
||
//只过滤这些数据
|
||
if (RoomNumberList.ToList().Contains(hostnumber1.ToString()))
|
||
{
|
||
if (VVV.CmdType == 0x0E)
|
||
{
|
||
string KeyFilter = "StatusFilter";
|
||
RCUHost.RCUHostCommon.tools.LanJieData(KeyFilter, hotelCode);
|
||
}
|
||
LanJieData(LanJieKey, hotelCode);
|
||
StepTongJi.SendInfo(1.01, "进入黑名单,不再有后续处理", context.MessageID, context.IsMonitor);
|
||
}
|
||
//如果不存在就处理
|
||
else
|
||
{
|
||
|
||
GaiXie g = new GaiXie();
|
||
g.Data = receiveBuffer111;
|
||
g.IPEndPoint = remoteEP111.ToString();
|
||
var data = Newtonsoft.Json.JsonConvert.SerializeObject(g);
|
||
CSRedisCacheHelper.StreamAdd(1, "All_UDPPackage_Data", data);
|
||
//ProcessData(context, hotelCode);
|
||
//var ts1 = new Tuple<ReceiverContext, string>(context, hotelCode);
|
||
//Task.Factory.StartNew((actor_state) =>
|
||
// {
|
||
// var gg = actor_state as Tuple<ReceiverContext, string>;
|
||
// ProcessData(gg.Item1, gg.Item2);
|
||
// }, ts1);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
if (VVV.CmdType == 0x0E)
|
||
{
|
||
string KeyFilter = "StatusFilter";
|
||
RCUHost.RCUHostCommon.tools.LanJieData(KeyFilter, hotelCode);
|
||
}
|
||
//如果存在，且 设备列表为0
|
||
LanJieData(LanJieKey, hotelCode);
|
||
StepTongJi.SendInfo(1.01, "进入黑名单，不再有后续处理", context.MessageID, context.IsMonitor);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//ProcessData(context, hotelCode);
|
||
|
||
GaiXie g = new GaiXie();
|
||
g.Data = receiveBuffer111;
|
||
g.IPEndPoint = remoteEP111.ToString();
|
||
var data = Newtonsoft.Json.JsonConvert.SerializeObject(g);
|
||
CSRedisCacheHelper.StreamAdd(1, "All_UDPPackage_Data", data);
|
||
var ts1 = new Tuple<ReceiverContext, string>(context, hotelCode);
|
||
//Task.Factory.StartNew((actor_state) =>
|
||
// {
|
||
// var gg = actor_state as Tuple<ReceiverContext, string>;
|
||
// ProcessData(gg.Item1, gg.Item2);
|
||
// }, ts1);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
else
|
||
{
|
||
//错误数据
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalErrorPackageReceiveCount);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error("统计Error:" + ex.Message);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
Interlocked.Increment(ref YUANZI_TongJi.TotalErrorPackageReceiveCount);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error(string.Format("接收数据失败：{0}", ex.ToString()));
|
||
}
|
||
finally
|
||
{
|
||
try
|
||
{
|
||
if (this.udpClient != null)
|
||
{
|
||
state.UdpClient.BeginReceive(ReceiveCallback, new UdpState(this.udpClient));
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
public static void LanJieData(string Key11, string hotelCode)
|
||
{
|
||
var Key = "UDPPackage_" + Key11.ToString();
|
||
|
||
UDPPackageCount LLL = null;
|
||
DataTongJi.TotalCount.TryGetValue(Key, out LLL);
|
||
if (LLL != null)
|
||
{
|
||
var dic = LLL.FenLei;
|
||
LLL.Count = LLL.Count + 1;
|
||
long hotel_count = 0;
|
||
if (dic.TryGetValue(hotelCode, out hotel_count))
|
||
{
|
||
dic[hotelCode] = dic[hotelCode] + 1;
|
||
}
|
||
else
|
||
{
|
||
dic.TryAdd(hotelCode, 1);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
UDPPackageCount u = new UDPPackageCount();
|
||
u.Count = 1;
|
||
|
||
var list = new ConcurrentDictionary<string, long>();
|
||
list.TryAdd(hotelCode, 1);
|
||
|
||
u.FenLei = list;
|
||
|
||
DataTongJi.TotalCount.TryAdd(Key, u);
|
||
}
|
||
}
|
||
|
||
public static Status NewStatusParse(Stream stream)
|
||
{
|
||
Status roomStatus = new Status();
|
||
try
|
||
{
|
||
// 重要：将流的位置重置到开始，以便读取
|
||
//stream.Seek(0, SeekOrigin.Begin);
|
||
using (BinaryReader reader = new BinaryReader(stream))
|
||
{
|
||
roomStatus.SysLock = reader.ReadBoolean(); //RCU是否锁定：0/否，1/是
|
||
roomStatus.CardType = reader.ReadByte(); //房卡类型：0/无人，1/有人，2/客人，3/经理，4/服务员
|
||
roomStatus.Door = reader.ReadBoolean(); //门磁开关：1/开，2/关
|
||
roomStatus.ElecQty = reader.ReadUInt16(); //门锁电量，单位：MV
|
||
roomStatus.HostTemp = reader.ReadByte(); //主机温度
|
||
//空调数量，默认0，新的回路方式，此处无用，兼容老版本
|
||
int airConditionNumber = reader.ReadByte();
|
||
for (int i = 0; i < airConditionNumber; i++)
|
||
{
|
||
byte airNo = reader.ReadByte();
|
||
if (!roomStatus.AirConditions.ContainsKey(airNo))
|
||
{
|
||
roomStatus.AirConditions[airNo] = new AirConditionStatus();
|
||
}
|
||
roomStatus.AirConditions[airNo].AirNo = airNo;
|
||
roomStatus.AirConditions[airNo].CurrentTemp = reader.ReadSByte();
|
||
roomStatus.AirConditions[airNo].SettingTemp = reader.ReadSByte();
|
||
roomStatus.AirConditions[airNo].OnOff = reader.ReadBoolean();
|
||
roomStatus.AirConditions[airNo].Speed = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].Mode = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].Valve = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].CompensatoryTemp = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].KeepTemp = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].ColdHotMode = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].DeadTemp = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].HotDevition = reader.ReadByte();
|
||
roomStatus.AirConditions[airNo].ColdDevition = reader.ReadByte();
|
||
}
|
||
//设备状态数量，包含所有回路状态
|
||
int deviceNumber = reader.ReadByte();
|
||
|
||
long originalPosition = reader.BaseStream.Position;
|
||
// 读取前先记录当前位置
|
||
try
|
||
{
|
||
//0x19数据缓冲区异常问题处理
|
||
//0x19 取电数据不处理
|
||
//非0x19 取电数据处理，但是不触发 欢迎词
|
||
for (int i = 0; i < deviceNumber; i++)
|
||
{
|
||
var QA = reader.ReadBytes(4);
|
||
var Status = reader.ReadUInt16();
|
||
|
||
string address = new DeviceAddress(QA).ToString();
|
||
if (!roomStatus.Devices.ContainsKey(address))
|
||
{
|
||
roomStatus.Devices[address] = new Device();
|
||
}
|
||
roomStatus.Devices[address].Address = address;//设备地址
|
||
roomStatus.Devices[address].StatusReceiver = Status;//设备状态改为2个字节,Modified By 20181213
|
||
originalPosition = reader.BaseStream.Position;
|
||
}
|
||
}
|
||
catch (Exception)
|
||
{
|
||
// 发生异常时回退到原始位置
|
||
reader.BaseStream.Position = originalPosition;
|
||
//logger.Error("device_count error");
|
||
}
|
||
return roomStatus;
|
||
}
|
||
}
|
||
catch (Exception)
|
||
{
|
||
return null;
|
||
}
|
||
}
|
||
|
||
private static readonly List<byte> TakeCardSeq = new List<byte>() { 0x04, 0x00, 0x01 };
|
||
|
||
|
||
public void Reply(ReceiverContext context, byte[] framenolist)
|
||
{
|
||
var headerLen = StructConverter.SizeOf(context.SystemHeader);
|
||
var headerData = new byte[headerLen + 2];
|
||
Array.Copy(context.Data, headerData, headerLen);
|
||
headerData[2] = 0x11;
|
||
headerData[3] = 0x00;
|
||
|
||
headerData[9] = framenolist[0];
|
||
headerData[10] = framenolist[1];
|
||
Send(headerData, context.RemoteEndPoint);
|
||
}
|
||
|
||
protected void ReplyWithContent(ReceiverContext context, byte[] content, byte[] framenolist)
|
||
{
|
||
var headerLen = StructConverter.SizeOf(context.SystemHeader);
|
||
var headerData = new byte[headerLen + 2];
|
||
Array.Copy(context.Data, headerData, headerLen);
|
||
headerData[2] = 0x12;
|
||
headerData[3] = 0x00;
|
||
|
||
headerData[9] = framenolist[0];
|
||
headerData[10] = framenolist[1];
|
||
var HHH = headerData.ToList();
|
||
HHH.AddRange(content);
|
||
Send(HHH.ToArray<byte>(), context.RemoteEndPoint);
|
||
}
|
||
public static string SameStatus0E = "处理过0E";
|
||
public static string SameStatus01 = "处理过01";
|
||
|
||
|
||
/// <summary>
|
||
/// 欢迎词触发
|
||
/// </summary>
|
||
/// <param name="flag1"></param>
|
||
/// <param name="hotelcode1"></param>
|
||
/// <param name="HostNumberOnly1"></param>
|
||
private void VoiceRobotTrigger(int flag1, string hotelcode1, string HostNumberOnly1)
|
||
{
|
||
var TS = new Tuple<int, string, string>(flag1, hotelcode1, HostNumberOnly1);
|
||
Task.Factory.StartNew((state1) =>
|
||
{
|
||
var UUU = (Tuple<int, string, string>)state1;
|
||
int flag = UUU.Item1;
|
||
string hotelcode = UUU.Item2;
|
||
string HostNumberOnly = UUU.Item3;
|
||
Host host = null;
|
||
string Key = CacheKey.HostInfo_Key_HostNumber + "_" + HostNumberOnly;
|
||
object obj = MemoryCacheHelper.Get(Key);
|
||
if (obj != null)
|
||
{
|
||
host = obj as Host;
|
||
}
|
||
else
|
||
{
|
||
Host host_O = HostRepository.GetByHostNumber(HostNumberOnly);
|
||
MemoryCacheHelper.SlideSet(Key, host_O);
|
||
host = host_O;
|
||
}
|
||
if (host != null)
|
||
{
|
||
|
||
string roomnumber = host.RoomNumber;
|
||
|
||
//小度
|
||
string XiaoDuCUID = host.XiaoDuCUID;
|
||
|
||
//天猫
|
||
string TianMaoCUID = host.TianMaoCUID;
|
||
|
||
//欢迎词
|
||
string WelcomeSpeech = host.SysHotel.WelcomeSpeech;
|
||
string WelcomeBGM = host.SysHotel.WelcomeBGM;
|
||
|
||
//欢送词
|
||
string GoodbyeSpeech = host.SysHotel.GoodbyeSpeech;
|
||
|
||
//断电重置
|
||
bool IsPowerOffResetXiaoDu = host.SysHotel.IsPowerOffResetXiaoDu;
|
||
|
||
|
||
//1、如果有绑定小度，小度处理
|
||
if (!string.IsNullOrEmpty(XiaoDuCUID))
|
||
{
|
||
#region 小度
|
||
string accessToken1 = SysOauth2Repository.GetXiaoDuToken();
|
||
if (!string.IsNullOrEmpty(accessToken1))
|
||
{
|
||
if (flag == 1 && !string.IsNullOrEmpty(WelcomeSpeech))//取电打开时，播放欢迎词
|
||
{
|
||
|
||
var ttt = new Tuple<string, string, string, string, string>(accessToken1, XiaoDuCUID, WelcomeSpeech, hotelcode, roomnumber);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var tuple_a = state as Tuple<string, string, string, string, string>;
|
||
string accessToken = tuple_a.Item1;
|
||
|
||
var myarray = tuple_a.Item2.Split(',');
|
||
var a1 = tuple_a.Item3;
|
||
var a2 = tuple_a.Item4;
|
||
var a3 = tuple_a.Item5;
|
||
|
||
//foreach (string cuid in host.XiaoDuCUID.Split(','))//多个小度英文逗号隔开
|
||
foreach (string cuid in myarray)//多个小度英文逗号隔开
|
||
{
|
||
//XiaoDuOperation.UploadWebhook(accessToken, cuid, host.SysHotel.WelcomeSpeech, host.SysHotel.Code, host.RoomNumber);
|
||
XiaoDuOperation.UploadWebhook(accessToken, cuid, a1, a2, a3);
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = a2;
|
||
w1.RoomNumber = a3;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.XiaoDu;
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "小度";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "欢迎词";
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, ttt);
|
||
}
|
||
else if (flag == 0)
|
||
{
|
||
if (IsPowerOffResetXiaoDu)//断电重置小度
|
||
{
|
||
|
||
var ttt = new Tuple<string, string, string, string, string>(accessToken1, XiaoDuCUID, WelcomeSpeech, hotelcode, roomnumber);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
|
||
var tuple_a = state as Tuple<string, string, string, string, string>;
|
||
string accessToken = tuple_a.Item1;
|
||
var myarray = tuple_a.Item2.Split(',');
|
||
var a1 = tuple_a.Item3;
|
||
var a2 = tuple_a.Item4;
|
||
var a3 = tuple_a.Item5;
|
||
foreach (string cuid in myarray)//多个小度英文逗号隔开
|
||
{
|
||
//XiaoDuOperation.PostWebRequestToXiaoDu(accessToken, cuid, new XiaoDuParamJson() { method = "reset" }, host.SysHotel.Code, host.RoomNumber);//重置小度
|
||
XiaoDuOperation.PostWebRequestToXiaoDu(accessToken, cuid, new XiaoDuParamJson() { method = "reset" }, a2, a3);//重置小度
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = a2;
|
||
w1.RoomNumber = a3;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.XiaoDu;
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "小度";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "断电重置";
|
||
//w1.ActionData = new HttpActionData() { RequestData = w2 };
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, ttt);
|
||
}
|
||
else if (!string.IsNullOrEmpty(GoodbyeSpeech))//断电，播放离房提示
|
||
{
|
||
var ttt = new Tuple<string, string, string, string, string>(accessToken1, XiaoDuCUID, WelcomeSpeech, hotelcode, roomnumber);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var tuple_a = state as Tuple<string, string, string, string, string>;
|
||
string accessToken = tuple_a.Item1;
|
||
var myarray = tuple_a.Item2.Split(',');
|
||
var a1 = tuple_a.Item3;
|
||
var a2 = tuple_a.Item4;
|
||
var a3 = tuple_a.Item5;
|
||
foreach (string cuid in myarray)//多个小度英文逗号隔开
|
||
{
|
||
XiaoDuOperation.UploadWebhook(accessToken, cuid, a1, a2, a3);
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = a2;
|
||
w1.RoomNumber = a3;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.XiaoDu;
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "小度";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "欢送词";
|
||
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
//w1.ActionData = new HttpActionData() { RequestData = w2 };
|
||
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, ttt);
|
||
}
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
|
||
|
||
//2、如果有绑定天猫精灵，天猫精灵处理
|
||
if (!string.IsNullOrEmpty(TianMaoCUID))
|
||
{
|
||
#region 天猫
|
||
if (flag == 1 && !string.IsNullOrEmpty(WelcomeSpeech))//取电打开时，播放欢迎词
|
||
{
|
||
var TTT = new Tuple<string, string, string, string, string>(TianMaoCUID, WelcomeSpeech, hotelcode, roomnumber, WelcomeBGM);
|
||
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var hhh = state as Tuple<string, string, string, string, string>;
|
||
var a = hhh.Item1.Split(',');
|
||
|
||
var b = hhh.Item2;
|
||
var c = hhh.Item3;
|
||
var d = hhh.Item4;
|
||
var e = hhh.Item5;
|
||
|
||
foreach (string cuid in a)//多个英文逗号隔开
|
||
{
|
||
//if (!string.IsNullOrEmpty(e))
|
||
//{
|
||
// string ffg = "https://www.boonlive-rcu.com/welcomebgm/" + e;
|
||
// TianMaoOperation.PostWebRequestToTianMao("PushWelcome",
|
||
// Newtonsoft.Json.JsonConvert.SerializeObject(new { HotelId = cuid.Split('&')[0], RoomNo = cuid.Split('&')[1], WelcomeText = b, MusicUrl = ffg }), c, d);//通知天猫精灵播放欢迎词
|
||
//}
|
||
//else
|
||
//{
|
||
// TianMaoOperation.PostWebRequestToTianMao("PushWelcome",
|
||
// Newtonsoft.Json.JsonConvert.SerializeObject(new { HotelId = cuid.Split('&')[0], RoomNo = cuid.Split('&')[1], WelcomeText = b }), c, d);//通知天猫精灵播放欢迎词
|
||
//}
|
||
|
||
TianMaoOperation.PostWebRequestToTianMao("PushWelcome",
|
||
Newtonsoft.Json.JsonConvert.SerializeObject(new { HotelId = cuid.Split('&')[0], RoomNo = cuid.Split('&')[1], WelcomeText = b }), c, d);//通知天猫精灵播放欢迎词
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = c;
|
||
w1.RoomNumber = d;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.TianMao;
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "天猫";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "欢送词";
|
||
|
||
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
//w1.ActionData = new HttpActionData() { RequestData = w2 };
|
||
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, TTT);
|
||
}
|
||
else if (flag == 0)
|
||
{
|
||
if (IsPowerOffResetXiaoDu)//断电重置
|
||
{
|
||
|
||
var TTT = new Tuple<string, string, string, string>(TianMaoCUID, WelcomeSpeech, hotelcode, roomnumber);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var hhh = state as Tuple<string, string, string, string>;
|
||
var a = hhh.Item1.Split(',');
|
||
|
||
var b = hhh.Item2;
|
||
var c = hhh.Item3;
|
||
var d = hhh.Item4;
|
||
foreach (string cuid in a)//多个英文逗号隔开
|
||
{
|
||
TianMaoOperation.PostWebRequestToTianMao("CheckoutWithAK",
|
||
Newtonsoft.Json.JsonConvert.SerializeObject(new { HotelId = cuid.Split('&')[0], RoomNo = cuid.Split('&')[1] }), c, d);//重置天猫精灵
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = c;
|
||
w1.RoomNumber = d;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.TianMao;
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "天猫";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "断电重置";
|
||
|
||
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
//w1.ActionData = new HttpActionData() { RequestData = w2 };
|
||
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, TTT);
|
||
}
|
||
else if (!string.IsNullOrEmpty(GoodbyeSpeech))//取电关闭时，播放离房提示
|
||
{
|
||
|
||
var TTT = new Tuple<string, string, string, string>(TianMaoCUID, WelcomeSpeech, hotelcode, roomnumber);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var hhh = state as Tuple<string, string, string, string>;
|
||
var a = hhh.Item1.Split(',');
|
||
|
||
var b = hhh.Item2;
|
||
var c = hhh.Item3;
|
||
var d = hhh.Item4;
|
||
|
||
foreach (string cuid in a)//多个英文逗号隔开
|
||
{
|
||
TianMaoOperation.PostWebRequestToTianMao("PushWelcome",
|
||
Newtonsoft.Json.JsonConvert.SerializeObject(new
|
||
{
|
||
HotelId = cuid.Split('&')[0],
|
||
RoomNo = cuid.Split('&')[1],
|
||
WelcomeText = b
|
||
}), c, d);//通知天猫精灵播放离房提示
|
||
|
||
Interface3Log w1 = new Interface3Log();
|
||
w1.HotelCode = c;
|
||
w1.RoomNumber = d;
|
||
w1.TriggerTime = DateTime.Now;
|
||
w1.CommandType = ChangLiangValue.TianMao;
|
||
|
||
|
||
WelcomeAction w2 = new WelcomeAction();
|
||
w2.VoiceDeviceClass = "天猫";
|
||
w2.CUID = cuid;
|
||
w2.CommandType = "欢送词";
|
||
|
||
w1.ActionData = new HttpActionData() { RequestData = Newtonsoft.Json.JsonConvert.SerializeObject(w2) };
|
||
//w1.ActionData = new HttpActionData() { RequestData = w2 };
|
||
var q1 = Newtonsoft.Json.JsonConvert.SerializeObject(w1);
|
||
CSRedisCacheHelper.Publish(CacheKey.InvokeHttpInterface, q1);
|
||
}
|
||
}, TTT);
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
}
|
||
|
||
}, TS);
|
||
}
|
||
|
||
//private static readonly RecyclableMemoryStreamManager manager = new RecyclableMemoryStreamManager();
|
||
/// <summary>
|
||
/// 处理数据
|
||
/// </summary>
|
||
/// <param name="context"></param>
|
||
//private void ProcessData(ReceiverContext context111, string hotelCode)
|
||
private void ProcessData(GaiXie gga)
|
||
{
|
||
//GaiXie gga = new GaiXie();
|
||
string[] III = gga.IPEndPoint.Split(':');
|
||
int PPP = int.Parse(III[1]);
|
||
IPEndPoint ip = new IPEndPoint(IPAddress.Parse(III[0]), PPP);
|
||
ReceiverContext context111 = new ReceiverContext(gga.Data, ip, GetNextCustomer());
|
||
context111.SystemHeader = DecodeSystemHeader(context111.Data);
|
||
|
||
|
||
byte cmdType = context111.SystemHeader.Value.CmdType;
|
||
ushort MyFrameNO = context111.SystemHeader.Value.FrameNo;
|
||
|
||
byte[] framenolist = BitConverter.GetBytes(MyFrameNO);
|
||
string IP_PORTStr = context111.RemoteEndPoint.ToString();
|
||
string HostNNN = context111.SystemHeader.Value.HostNumber.ToString();
|
||
string CODE = context111.SystemHeader.Value.HostNumber.ToHotelCode().ToString();
|
||
string hotelCode = CODE;
|
||
string EndPoint = context111.RemoteEndPoint.ToString();
|
||
//if (cmdType != 0x01)
|
||
//在线状态 不排队 注册0x01
|
||
if (true)
|
||
{
|
||
#region 只要有数据包，就是心跳
|
||
|
||
string Key = context111.SystemHeader.Value.HostNumber.ToString();
|
||
string EEE = CSRedisCacheHelper.Get<string>(Key);
|
||
if (string.IsNullOrEmpty(EEE))
|
||
{
|
||
OnOffLineData o = new OnOffLineData();
|
||
o.HostNumber = Key;
|
||
o.HotelCode = hotelCode;
|
||
o.CurrentStatus = "on";
|
||
o.CurrentTime = DateTime.Now;
|
||
o.EndPoint = context111.RemoteEndPoint.ToString();
|
||
//新来的数据
|
||
var n = Newtonsoft.Json.JsonConvert.SerializeObject(o);
|
||
//CSRedisCacheHelper.Publish("redis-on_off_line", n);
|
||
}
|
||
string EndPointStr = context111.RemoteEndPoint.ToString();
|
||
CSRedisCacheHelper.Set(context111.SystemHeader.Value.HostNumber.ToString(), context111.RemoteEndPoint.Address.ToString() + ":" + context111.RemoteEndPoint.Port.ToString());//主机编码
|
||
|
||
string KKF = context111.SystemHeader.Value.HostNumber.ToString();
|
||
|
||
RCUOnLineExtra xe = new RCUOnLineExtra();
|
||
xe.CurrentDateTime = DateTime.Now;
|
||
xe.HotelCode = hotelCode;
|
||
if (!DataTongJi.ONLINERCU.ContainsKey(KKF))
|
||
{
|
||
DataTongJi.ONLINERCU.TryAdd(KKF, xe);
|
||
}
|
||
else
|
||
{
|
||
RCUOnLineExtra outv;
|
||
DataTongJi.ONLINERCU.TryRemove(KKF, out outv);
|
||
DataTongJi.ONLINERCU.TryAdd(KKF, xe);
|
||
}
|
||
|
||
//RCUHost.RCUHostCommon.tools.LanJieData(KKK, hotelCode);
|
||
#endregion
|
||
}
|
||
|
||
|
||
#region 如果是0E 01就直接回复
|
||
//36 就是新版本的0E
|
||
//if (cmdType == 0x0E || cmdType == 0x01)
|
||
if (cmdType == 0x0E || cmdType == 0x01 || cmdType == 0x36)
|
||
{
|
||
StepTongJi.SendInfo(1.1, "0E 01指令回复开始", context111.MessageID, context111.IsMonitor);
|
||
Reply(context111, framenolist);
|
||
StepTongJi.SendInfo(1.2, "0E 01指令回复结束", context111.MessageID, context111.IsMonitor);
|
||
}
|
||
#endregion
|
||
|
||
|
||
try
|
||
{
|
||
byte[] OriginalByte = context111.Data;
|
||
|
||
int offset = StructConverter.SizeOf(context111.SystemHeader);
|
||
int length = context111.Data.Length - offset - 2;
|
||
|
||
string HostNUMBER = HostNNN;
|
||
if (length > 0)
|
||
{
|
||
#region 新版协议
|
||
if (cmdType == 0x32 || cmdType == 0x33 || cmdType == 0x34 || cmdType == 0x35 || cmdType == 0x36)
|
||
{
|
||
NewXieYi(context111, hotelCode, HostNNN, framenolist, cmdType, EndPoint);
|
||
}
|
||
else
|
||
{
|
||
#region 01指令
|
||
if (cmdType == 0x01)
|
||
{
|
||
//注册指令
|
||
//AA 55 68 00 54 33 53 41 01 FF FF 95 05 68 E4
|
||
//00 00 00 00 FF FF FE 00 AC 14 00 FE 0D 0D 34 D0 B8 11 68 E4 43 31 46 5F 41 5F 4C 34 5F 33 35 5F 32 34 30 38 32 39 00 00 26 00 00 DF 05 05 05 CB AB B4 B2 B1 A6 D2 D7 00 00 00 00 00 00 00 00 31 30 31 37 00 00 00 00 00 00 00 00 00 00 00 00 F6 12 00 00 96 B0 00 00
|
||
//3D 89
|
||
//升级之后，会上报注册指令，不能被跳过
|
||
string Key = "Upgrade_UpdateSQL_" + HostNUMBER;
|
||
object OOO1 = MemoryCacheHelper.Get(Key);
|
||
if (OOO1 == null)
|
||
{
|
||
int lll = OriginalByte.Length;
|
||
var A1 = OriginalByte.Skip(15).Take(lll - 15 - 2).ToArray();
|
||
|
||
string YiJingChuLiGuo = CacheKey.AllReadyDealWith01_Prefix + "_" + HostNUMBER;
|
||
object ooo = MemoryCacheHelper.Get(YiJingChuLiGuo);
|
||
if (ooo != null)
|
||
{
|
||
byte[] bbb = ooo as byte[];
|
||
if (A1.SequenceEqual<byte>(bbb))
|
||
{
|
||
RCUHost.RCUHostCommon.tools.LanJieData(SameStatus01, hotelCode);
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 0E
|
||
if (cmdType == 0x0E)
|
||
{
|
||
//using (var stream = manager.GetStream())
|
||
//{
|
||
//stream.Write(context111.Data, offset, length);
|
||
//}
|
||
using (MemoryStream stream = new MemoryStream(context111.Data, offset, length))
|
||
{
|
||
Status status = NewStatusParse(stream);
|
||
if (status != null)
|
||
{
|
||
var LG = status.Devices;
|
||
Device UXV = null;
|
||
//找出取电
|
||
LG.TryGetValue("004000001", out UXV);
|
||
if (UXV != null)
|
||
{
|
||
|
||
byte bfg = Convert.ToByte(UXV.StatusReceiver);
|
||
|
||
string KKK1 = CacheKey.TakeCardOnLine + "_" + HostNUMBER;
|
||
CommonEntity.DataTongJi.MTakeCardData t = new DataTongJi.MTakeCardData();
|
||
t.HostNUMBER = HostNUMBER;
|
||
t.HotelCode = hotelCode;
|
||
t.Status = bfg;
|
||
t.LastUpdateTime = DateTime.Now;
|
||
|
||
var data = CSRedisCacheHelper.Get_Partition<CommonEntity.DataTongJi.MTakeCardData>(KKK1, 5);
|
||
if (data != null)
|
||
{
|
||
//说明是拔卡
|
||
if ((data.Status == 0x01 && bfg == 0x02))
|
||
{
|
||
string sss = Newtonsoft.Json.JsonConvert.SerializeObject(t);
|
||
CSRedisCacheHelper.Publish("redis-takecard_change", sss);
|
||
}
|
||
//插卡
|
||
if ((data.Status == 0x02 && bfg == 0x01))
|
||
{
|
||
string sss = Newtonsoft.Json.JsonConvert.SerializeObject(t);
|
||
CSRedisCacheHelper.Publish("redis-takecard_change", sss);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
string sss = Newtonsoft.Json.JsonConvert.SerializeObject(t);
|
||
CSRedisCacheHelper.Publish("redis-takecard_change", sss);
|
||
}
|
||
|
||
|
||
CSRedisCacheHelper.Set_Partition(KKK1, t, 5);
|
||
|
||
if (DataTongJi.TakeCardOnLine.ContainsKey(HostNUMBER))
|
||
{
|
||
CommonEntity.DataTongJi.MTakeCardData ooo = null;
|
||
DataTongJi.TakeCardOnLine.TryRemove(HostNUMBER, out ooo);
|
||
DataTongJi.TakeCardOnLine.TryAdd(HostNUMBER, t);
|
||
}
|
||
else
|
||
{
|
||
DataTongJi.TakeCardOnLine.TryAdd(HostNUMBER, t);
|
||
}
|
||
}
|
||
|
||
if (status.Devices.Count > 0)
|
||
{
|
||
foreach (var item in status.Devices)
|
||
{
|
||
string ItemKKK = item.Key;
|
||
Device VVV = item.Value;
|
||
if (item.Key.StartsWith("004000") && !item.Key.Equals("004000001"))
|
||
{
|
||
CommonEntity.DataTongJi.OtherServiceInfo oth = new DataTongJi.OtherServiceInfo();
|
||
oth.HotelCode = hotelCode;
|
||
oth.HostNumber = HostNUMBER;
|
||
oth.LastUpdateTime = DateTime.Now;
|
||
oth.StatusReceiver = item.Value.StatusReceiver;
|
||
oth.Address = item.Value.Address;
|
||
|
||
string NKKK1 = CacheKey.ServiceInfoOther + "_" + HostNUMBER + "_" + item.Key;
|
||
var data = CSRedisCacheHelper.Get_Partition<CommonEntity.DataTongJi.OtherServiceInfo>(NKKK1, 5);
|
||
if (data != null)
|
||
{
|
||
ushort UUU = data.StatusReceiver;
|
||
//说明是有变化
|
||
if (UUU != item.Value.StatusReceiver)
|
||
{
|
||
string sss = Newtonsoft.Json.JsonConvert.SerializeObject(oth);
|
||
CSRedisCacheHelper.Publish("redis-serviceinfo_change", sss);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
string sss = Newtonsoft.Json.JsonConvert.SerializeObject(oth);
|
||
CSRedisCacheHelper.Publish("redis-serviceinfo_change", sss);
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
if (status.Devices.Count > 0)
|
||
{
|
||
try
|
||
{
|
||
var LLL = status.Devices.OrderBy(A => A.Key);
|
||
var KKK1 = LLL.Select(A => A.Key).ToArray();
|
||
var KKK2 = LLL.Select(A => A.Value.StatusReceiver.ToString("00")).ToArray();
|
||
if (KKK1.Length > 0 && KKK2.Length > 0)
|
||
{
|
||
var VVV1 = string.Join("", KKK1);
|
||
var VVV2 = string.Join("", KKK2);
|
||
|
||
//StringBuilder sb = new StringBuilder();
|
||
//sb.Clear();
|
||
//sb.Append(VVV1);
|
||
//sb.Append(VVV2);
|
||
string sb = string.Concat(VVV1, VVV2);
|
||
string YiJingChuLiGuo = CacheKey.AllReadyDealWith0E_Prefix + "_" + HostNUMBER;
|
||
object data = MemoryCacheHelper.Get(YiJingChuLiGuo);
|
||
if (data != null)
|
||
{
|
||
string shuju = data.ToString();
|
||
if (shuju.Equals(sb))
|
||
{
|
||
RCUHost.RCUHostCommon.tools.LanJieData(SameStatus0E, hotelCode);
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception)
|
||
{
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
#endregion
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error("取电数据上报出问题了：" + ex.Message);
|
||
logger.Error("取电数据上报出问题了：" + ex.StackTrace);
|
||
}
|
||
|
||
#region 故意让UDP丢掉的数据包总数
|
||
//insertcard 保留
|
||
//if (cmdType != 0x0E||cmdType!=0x01)
|
||
if (cmdType != 0E || cmdType != 0x03)
|
||
{
|
||
if (DataTongJi.DefineLostPackage != 0)
|
||
{
|
||
Interlocked.Increment(ref DataTongJi.RecordLostPackage);
|
||
if (DataTongJi.RecordLostPackage == DataTongJi.DefineLostPackage)
|
||
{
|
||
Interlocked.Exchange(ref DataTongJi.RecordLostPackage, 0);
|
||
string Key = "AllocateUDPLostPackage";
|
||
|
||
UDPPackageCount a1 = null;
|
||
DataTongJi.TotalCount.TryGetValue(Key, out a1);
|
||
if (a1 != null)
|
||
{
|
||
a1.Count = a1.Count + 1;
|
||
long NNN = 0;
|
||
bool bbn = a1.FenLei.TryGetValue(hotelCode, out NNN);
|
||
if (bbn)
|
||
{
|
||
NNN = NNN + 1;
|
||
}
|
||
long take = 0;
|
||
a1.FenLei.TryRemove(hotelCode, out take);
|
||
a1.FenLei.TryAdd(hotelCode, NNN);
|
||
}
|
||
else
|
||
{
|
||
UDPPackageCount u = new UDPPackageCount();
|
||
u.Count = 1;
|
||
u.FenLei = new ConcurrentDictionary<string, long>();
|
||
u.FenLei.TryAdd(hotelCode, 1);
|
||
DataTongJi.TotalCount.TryAdd(Key, u);
|
||
};
|
||
|
||
//RCUHost.RCUHostCommon.tools.LanJieData(KKK, hotelCode);
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
string KKK = "StatusPass";
|
||
if (context111.SystemHeader.Value.CmdType == 0x0E)
|
||
{
|
||
RCUHost.RCUHostCommon.tools.LanJieData(KKK, hotelCode);
|
||
}
|
||
var Key10 = (CommandType)context111.SystemHeader.Value.CmdType;
|
||
var Key11 = Key10.ToString();
|
||
LanJieData(Key11, hotelCode);
|
||
|
||
|
||
//添加统计
|
||
StepTongJi.SendInfo(2, "UDPCallBack执行完,即将分配Task", context111.MessageID, context111.IsMonitor);
|
||
//如果是心跳，直接处理
|
||
if (cmdType == 0x02)
|
||
{
|
||
if (context111.SystemHeader.Value.FrameNo > 0x7FFF)
|
||
{
|
||
IReceiver receiver = receivers[((CommandType)context111.SystemHeader.Value.CmdType)];
|
||
if (receiver != null)
|
||
{
|
||
(receiver as HeartReceiver).Process(context111);//处理业务逻辑
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//帧序号≤32767，则表示主机收到回复确认，可取消命令重发
|
||
RemoveCommandDataFromCommandQueueByFrameNo(context111.SystemHeader.Value.FrameNo);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
|
||
Task.Factory.StartNew((State) =>
|
||
{
|
||
ReceiverContext context = State as ReceiverContext;
|
||
|
||
//添加统计信息
|
||
StepTongJi.SendInfo(3, "Task分配成功，即将开始执行", context.MessageID, context.IsMonitor);
|
||
|
||
if (cmdType == 0x36)
|
||
{
|
||
IReceiver receiver = receivers[(CommandType)0x36];
|
||
if (receiver != null)
|
||
{
|
||
(receiver as GenericReceiverBase).Process(context);//处理业务逻辑
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//必须过滤帧号，否则时间同步一直互相发送信息
|
||
if (context.SystemHeader.Value.FrameNo > 0x7FFF
|
||
|| (CommandType)context.SystemHeader.Value.CmdType == CommandType.RCUInfo
|
||
|| (CommandType)context.SystemHeader.Value.CmdType == CommandType.UpdateProgressBar
|
||
|| (CommandType)context.SystemHeader.Value.CmdType == CommandType.TFTPLog)
|
||
{
|
||
if (receivers.ContainsKey((CommandType)context.SystemHeader.Value.CmdType))
|
||
{
|
||
IReceiver receiver = receivers[((CommandType)context.SystemHeader.Value.CmdType)];
|
||
if (receiver != null)
|
||
{
|
||
(receiver as GenericReceiverBase).Process(context);//处理业务逻辑
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//帧序号≤32767，则表示主机收到回复确认，可取消命令重发
|
||
RemoveCommandDataFromCommandQueueByFrameNo(context.SystemHeader.Value.FrameNo);
|
||
}
|
||
}
|
||
|
||
StepTongJi.SendInfo(6, "Task执行完,即将切换下一个Task", context.MessageID, context.IsMonitor);
|
||
|
||
var FFF = DataTongJi.CPU_Data;
|
||
if (FFF.Count > 0)
|
||
{
|
||
double avg_d = FFF.Average();
|
||
StepTongJi.SendInfo(0, avg_d.ToString(), context.MessageID, context.IsMonitor);
|
||
}
|
||
}, context111);
|
||
}
|
||
}
|
||
|
||
public static object oo = new object();
|
||
private void NewXieYi(ReceiverContext context_1, string hotelCode_1, string HostNNN_1, byte[] framenolist_1, byte cmdType_1, string EndPoint_1)
|
||
{
|
||
var Tuple = new Tuple<ReceiverContext, string, string, byte[], byte, string>(context_1, hotelCode_1, HostNNN_1, framenolist_1, cmdType_1, EndPoint_1);
|
||
Task.Factory.StartNew((state) =>
|
||
{
|
||
var ts = state as Tuple<ReceiverContext, string, string, byte[], byte, string>;
|
||
ReceiverContext context111 = ts.Item1;
|
||
string hotelCode = ts.Item2;
|
||
string HostNNN = ts.Item3;
|
||
byte[] framenolist = ts.Item4;
|
||
byte cmdType = ts.Item5;
|
||
string EndPoint = ts.Item6;
|
||
if (cmdType == 0x33)
|
||
{
|
||
|
||
// RCU重启原因: AA 55 26 00 54 33 53 41 35 02 80 EB 03 6B 24
|
||
// 4C 61 75 6E 63 68 65 72 5F 43 31 46 5F 56 30 34 2E 37 20 20 //"Launcher_C1F_V04.7 "
|
||
// 01 重启原因 0x01:软件复位，0x02:上电复位，0x03:外部手动复位，0x04：下电复位，0x05:看门狗复位，其他值：未知复位
|
||
// D5 40
|
||
ReplyWithContent(context111, new byte[] { 0x00 }, framenolist);
|
||
byte[] OriginalByte = context111.Data;
|
||
int offset = StructConverter.SizeOf(context111.SystemHeader);
|
||
int length = context111.Data.Length - offset - 2;
|
||
var data = OriginalByte.Skip(offset).ToArray();
|
||
|
||
var LauncherVersion = data.Take(20);
|
||
var RestartReason = data.Skip(20).Take(1);
|
||
|
||
NewVersionHexData ns = new NewVersionHexData();
|
||
ns.CmdType = 0x33;
|
||
ns.HotelCode = hotelCode;
|
||
ns.HostNumber = HostNNN;
|
||
ns.RemoteEndPoint = EndPoint;
|
||
ns.CurrentTime = DateTime.Now;
|
||
ns.HexData = Tools.ByteToString(context111.Data);
|
||
string mns1 = Newtonsoft.Json.JsonConvert.SerializeObject(ns);
|
||
CSRedisCacheHelper.Publish("redis-rcu-restart", mns1);
|
||
}
|
||
if (cmdType == 0x35)
|
||
{
|
||
ReplyWithContent(context111, new byte[] { 0x00 }, framenolist);
|
||
//P0：取电动作状态
|
||
// 0x00:无动作
|
||
// 0x01:取电动作
|
||
// 0x02:断电动作
|
||
//P1：插卡状态
|
||
// 0x00:无插卡动作
|
||
// 0x01:插卡动作
|
||
// 0x02:拔卡动作
|
||
//P2：身份信息
|
||
//P3：无卡逻辑状态(对应事件状态)
|
||
|
||
//取电变化上报: AA 55 15 00 54 33 53 41 35 20 80 EB 03 6B 24 01 00 00 00 D7 74
|
||
// AA 55 15 00 54 33 53 41 35 20 80 EB 03 6B 24
|
||
// 01 //取电动作
|
||
// 00 //插卡动作
|
||
// 00 //身份信息
|
||
// 00 //无卡逻辑事件
|
||
// D7 74
|
||
|
||
byte[] OriginalByte = context111.Data;
|
||
int offset = StructConverter.SizeOf(context111.SystemHeader);
|
||
int length = context111.Data.Length - offset - 2;
|
||
|
||
var data = OriginalByte.Skip(offset).ToArray();
|
||
var qudian = data[0];
|
||
var chaka = data[1];
|
||
var shenfen = data[2];
|
||
var noka_event = data[3];
|
||
|
||
if (qudian == 0x01)
|
||
{
|
||
VoiceRobotTrigger(1, hotelCode, HostNNN);
|
||
}
|
||
else if (qudian == 0x02)
|
||
{
|
||
VoiceRobotTrigger(0, hotelCode, HostNNN);
|
||
}
|
||
else
|
||
{
|
||
|
||
}
|
||
|
||
NewVersionHexData ns = new NewVersionHexData();
|
||
ns.CmdType = 0x35;
|
||
ns.HotelCode = hotelCode;
|
||
ns.HostNumber = HostNNN;
|
||
ns.RemoteEndPoint = EndPoint;
|
||
ns.CurrentTime = DateTime.Now;
|
||
ns.HexData = Tools.ByteToString(context111.Data);
|
||
string mns1 = Newtonsoft.Json.JsonConvert.SerializeObject(ns);
|
||
CSRedisCacheHelper.Publish("redis-rcu-card_action", mns1);
|
||
|
||
string HostID = CSRedisCacheHelper.HMGet<string>(5, CacheKey.HostId_HostNumber, HostNNN)[0];
|
||
|
||
|
||
if (!string.IsNullOrEmpty(HostID))
|
||
{
|
||
string KKey = CacheKey.HostModalStatus_Prefix + "_" + HostID + "_" + "004000001";
|
||
var OldHostModal = CSRedisCacheHelper.Get_Partition<HostModal_Cache>(KKey);
|
||
if (OldHostModal != null)
|
||
{
|
||
if (qudian == 0x01)
|
||
{
|
||
OldHostModal.Status = 1;
|
||
}
|
||
else if (qudian == 0x02)
|
||
{
|
||
OldHostModal.Status = 2;
|
||
}
|
||
else
|
||
{
|
||
|
||
}
|
||
CSRedisCacheHelper.Set_Partition(KKey, OldHostModal);
|
||
}
|
||
}
|
||
}
|
||
|
||
// AA 55 35 00 54 33 53 41 34 10 80 EB 03 6B 24
|
||
// 01 //协议版本
|
||
// 01 //取电状态
|
||
// 00 //身份信息
|
||
// 00 //无卡逻辑
|
||
// 00 00 00 00 00 00 00 00 //服务信息全部回路状态 1~64 64Bit 0 :关 1：开
|
||
// 01 //PMS状态
|
||
// 01 //碳达人
|
||
// 01 //上报设备数
|
||
|
||
// 39 //设备类型 - 能耗设备
|
||
// 01 //设备地址
|
||
// 01 00 //设备回路
|
||
// 10 //设备数据长度
|
||
// 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 //设备数据
|
||
|
||
// 07 //设备类型 - 温控
|
||
// 01 //设备地址
|
||
// 01 00 //设备回路
|
||
// 02 //设备数据长度
|
||
// 00 00 //设备数据
|
||
|
||
// F4 AA //CRC16
|
||
|
||
//能耗设备 - 上报数据格式
|
||
//P15：设备类型
|
||
//P16：设备地址
|
||
//P17~P18：设备回路
|
||
//P19：设备数据长度
|
||
//P20~P21：通道电压，单位：10mV
|
||
//P22~P23：通道电流，单位：10mA
|
||
//P24~P25：通道有功功率，单位：mW
|
||
//P26~P29：通道能耗，单位：Wh（1度电 = 1KWh）
|
||
//P30~P33：通道总能耗，单位：Wh（1度电 = 1KWh）
|
||
|
||
|
||
if (cmdType == 0x36)
|
||
{
|
||
//Reply(context111);
|
||
string hexdata = Tools.ByteToString(context111.Data);
|
||
|
||
NewVersionHexData ns = new NewVersionHexData();
|
||
ns.CmdType = 0x36;
|
||
ns.HotelCode = hotelCode;
|
||
ns.HostNumber = HostNNN;
|
||
ns.RemoteEndPoint = EndPoint;
|
||
ns.CurrentTime = DateTime.Now;
|
||
ns.HexData = Tools.ByteToString(context111.Data);
|
||
//CSRedisCacheHelper.Publish("redis-rcu-hexdata", Newtonsoft.Json.JsonConvert.SerializeObject(ns));
|
||
}
|
||
if (cmdType == 0x34)
|
||
{
|
||
ReplyWithContent(context111, new byte[] { 0x00 }, framenolist);
|
||
byte[] OriginalByte = context111.Data;
|
||
|
||
int offset = StructConverter.SizeOf(context111.SystemHeader);
|
||
int length = context111.Data.Length - offset - 2;
|
||
|
||
|
||
//给宝镜发送完整的数据
|
||
string hexdata = Tools.ByteToString(context111.Data);
|
||
CSRedisCacheHelper.Publish("redis-baojing-powerdata", hexdata);
|
||
|
||
|
||
try
|
||
{
|
||
NewVersionHexData ns = new NewVersionHexData();
|
||
ns.CmdType = 0x34;
|
||
ns.HotelCode = hotelCode;
|
||
ns.HostNumber = HostNNN;
|
||
ns.RemoteEndPoint = EndPoint;
|
||
ns.CurrentTime = DateTime.Now;
|
||
ns.HexData = hexdata;
|
||
|
||
//CSRedisCacheHelper.Publish("redis-rcu-timer_data", Newtonsoft.Json.JsonConvert.SerializeObject(ns));
|
||
|
||
string HostID = CSRedisCacheHelper.HMGet<string>(5, CacheKey.HostId_HostNumber, HostNNN)[0];
|
||
string RoomNUMBER = CSRedisCacheHelper.HMGet<string>(5, CacheKey.RoomNumber_HostNumber, HostNNN)[0];
|
||
|
||
|
||
List<DingShiReportDate> DeviceList = new List<DingShiReportDate>();
|
||
var DS1 = CSRedisCacheHelper.Get_Partition<List<DingShiReportDate>>(CacheKey.DingShiReportData + "_" + HostID, 3);
|
||
if (DS1 != null)
|
||
{
|
||
DeviceList = DS1;
|
||
}
|
||
else
|
||
{
|
||
//logger.Error("定时上报的HostId:" + HostID);
|
||
//定时上报要查询 当前房间配置了哪些设备
|
||
//这里根据主机Id 号查询当前房间，有哪些设备
|
||
if (!string.IsNullOrEmpty(HostID))
|
||
{
|
||
lock (oo)
|
||
{
|
||
var list2 = HostModalRepository.LoadByHostID(int.Parse(HostID));
|
||
var list = list2.Where(r => r.Modal.IsUploadBaoJing).OrderBy(r => r.Modal.ModalAddress);//只装置标志启动的
|
||
|
||
List<DingShiReportDate> dingls = new List<DingShiReportDate>();
|
||
foreach (HostModal item in list)
|
||
{
|
||
DingShiReportDate ddd = new DingShiReportDate();
|
||
ddd.HostID = item.HostID;
|
||
ddd.Address = item.Modal.ModalAddress;
|
||
ddd.DeviceType = item.Modal.Type.ToString();
|
||
dingls.Add(ddd);
|
||
}
|
||
DeviceList = dingls;
|
||
CSRedisCacheHelper.Set_PartitionWithForever<List<DingShiReportDate>>(CacheKey.DingShiReportData + "_" + HostID, dingls, 3);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
List<DingShiReportDate> DeviceStatusList = new List<DingShiReportDate>();
|
||
foreach (DingShiReportDate item in DeviceList)
|
||
{
|
||
string KKey = CacheKey.HostModalStatus_Prefix + "_" + item.HostID + "_" + item.Address;
|
||
var hostModal = CSRedisCacheHelper.Get_Partition<HostModal_Cache>(KKey);
|
||
if (hostModal != null)
|
||
{
|
||
DingShiReportDate ddd = new DingShiReportDate();
|
||
ddd.HostID = item.HostID;
|
||
ddd.Address = item.Address;
|
||
ddd.DeviceType = item.DeviceType;
|
||
ddd.Status = hostModal.Status;
|
||
ddd.Brightness = hostModal.Brightness;
|
||
|
||
var aaa = hostModal.AirConditionData;
|
||
ddd.CurrentTemp = aaa.CurrentTemp;
|
||
ddd.SettingTemp = aaa.SettingTemp;
|
||
ddd.FanSpeed = aaa.FanSpeed;
|
||
ddd.Mode = aaa.Mode;
|
||
ddd.Valve = aaa.Valve;
|
||
DeviceStatusList.Add(ddd);
|
||
}
|
||
}
|
||
|
||
using (MemoryStream stream = new MemoryStream(context111.Data, offset, length))
|
||
{
|
||
using (BinaryReader reader = new BinaryReader(stream))
|
||
{
|
||
//版本
|
||
var Version = reader.ReadByte();
|
||
|
||
//取电
|
||
var TakeCardStatus = reader.ReadByte();
|
||
|
||
//string QUDIANKey = CacheKey.NewVersionDeviceStatus + "_" + HostNNN;
|
||
//var hostModal = CSRedisCacheHelper.HMGet<NewVersionDeviceStatus>(1, QUDIANKey, "004000001");
|
||
|
||
//if (hostModal[0] != null)
|
||
//{
|
||
// hostModal[0].Status = TakeCardStatus;
|
||
// CSRedisCacheHelper.HMSet(1, QUDIANKey, "004000001", hostModal);
|
||
//}
|
||
//else
|
||
//{
|
||
// NewVersionDeviceStatus n = new NewVersionDeviceStatus();
|
||
// n.Status = TakeCardStatus;
|
||
// n.HotelCode = CODE;
|
||
// n.HostNumber = HostNNN;
|
||
// n.ModalType = DeviceType.ServiceInfo;
|
||
// n.UpdateTime = DateTime.Now;
|
||
// CSRedisCacheHelper.HMSet(1, QUDIANKey, "004000001", n);
|
||
//}
|
||
|
||
//身份
|
||
var IdentityInfo = reader.ReadByte();
|
||
var NOCardInfo = reader.ReadByte();
|
||
|
||
//服务信息全部回路状态 1~64 64Bit 0 :关 1：开
|
||
//把8个字节转换成64个二进制位
|
||
var N = reader.ReadBytes(8);
|
||
BitArray bitlist = new BitArray(N);
|
||
|
||
for (int i = 0; i < bitlist.Length; i++)
|
||
{
|
||
if (i == 1)
|
||
{
|
||
continue;
|
||
}
|
||
string SerNo = i.ToString("000");
|
||
|
||
//界面上显示，为了 兼容老版的 界面 显示逻辑，所以这样写
|
||
if (!string.IsNullOrEmpty(HostID))
|
||
{
|
||
string KKey = CacheKey.HostModalStatus_Prefix + "_" + HostID + "_" + "004000" + SerNo;
|
||
var OldHostModal = CSRedisCacheHelper.Get_Partition<HostModal_Cache>(KKey);
|
||
if (OldHostModal != null)
|
||
{
|
||
if (bitlist[i])
|
||
{
|
||
OldHostModal.Status = 1;
|
||
}
|
||
else
|
||
{
|
||
OldHostModal.Status = 2;
|
||
}
|
||
}
|
||
}
|
||
|
||
//var hostModal1 = CSRedisCacheHelper.HMGet<NewVersionDeviceStatus>(1, QUDIANKey, "004000" + SerNo);
|
||
//if (hostModal1[0] != null)
|
||
//{
|
||
// if (bitlist[i])
|
||
// {
|
||
// hostModal1[0].Status = 1;
|
||
// }
|
||
// else
|
||
// {
|
||
// hostModal1[0].Status = 2;
|
||
// }
|
||
// CSRedisCacheHelper.HMSet(1, QUDIANKey, "004000" + SerNo, hostModal1[0]);
|
||
//}
|
||
//else
|
||
//{
|
||
// NewVersionDeviceStatus n = new NewVersionDeviceStatus();
|
||
// n.Status = 2;
|
||
// n.HotelCode = CODE;
|
||
// n.HostNumber = HostNNN;
|
||
// n.ModalType = DeviceType.ServiceInfo;
|
||
// n.UpdateTime = DateTime.Now;
|
||
// CSRedisCacheHelper.HMSet(1, QUDIANKey, "004000" + SerNo, n);
|
||
//}
|
||
}
|
||
|
||
//PMS房态
|
||
//定时上报,之后要设置房态，要用0C
|
||
//只会上报 01 出租，02退房
|
||
var PMS = reader.ReadByte();
|
||
//if (PMS != 0x01 && PMS != 0x02)
|
||
if (true)
|
||
{
|
||
string Key = CacheKey.SyncRoomStatus + "_" + HostNNN;
|
||
var Q = CSRedisCacheHelper.Get_Partition<RoomStatusRequest>(Key);
|
||
|
||
//测试使用
|
||
//IReceiver receiver1 = receivers[CommandType.RoomStatusChanged];
|
||
//(receiver1 as RoomStatusChangedReceiver).SendRoomStatusSelfWithFrameNo("111", "2222", new RoomStatus { ID = 10 }, framenolist);//处理业务逻辑
|
||
|
||
if (Q != null && PMS != Q.Status.ID)
|
||
{
|
||
IReceiver receiver = receivers[CommandType.RoomStatusChanged];
|
||
if (Q != null)
|
||
{
|
||
(receiver as RoomStatusChangedReceiver).SendRoomStatusSelfWithFrameNo(Q.HostNumber, Q.MAC, Q.Status, framenolist);//处理业务逻辑
|
||
}
|
||
else
|
||
{
|
||
Domain.RoomStatus RS = new RoomStatus();
|
||
RS.Name = "空房";
|
||
RS.ID = 16;
|
||
(receiver as RoomStatusChangedReceiver).SendRoomStatusSelfWithFrameNo(HostNNN, "", RS, framenolist);//处理业务逻辑
|
||
}
|
||
}
|
||
}
|
||
|
||
//碳达人
|
||
var CarbonVIP = reader.ReadByte();
|
||
var DeviceCount = reader.ReadByte();
|
||
int DeviceCount_I = (int)DeviceCount;
|
||
|
||
for (int i = 0; i < DeviceCount_I; i++)
|
||
{
|
||
var QA = reader.ReadBytes(4);
|
||
//说明是能耗设备
|
||
#region 能耗
|
||
if (QA[0] == 0x39)
|
||
{
|
||
string address = new DeviceAddress(QA).ToString();
|
||
//设备数据长度
|
||
var DeviceInfoLen = reader.ReadByte();
|
||
var Len = Convert.ToInt32(DeviceInfoLen);
|
||
//设备数据
|
||
var Data = reader.ReadBytes(Len);
|
||
|
||
//byte Len = Data.Skip(28).Take(1).FirstOrDefault();
|
||
byte[] DianYa = Data.Take(2).ToArray();
|
||
byte[] DianLiu = Data.Skip(2).Take(2).ToArray();
|
||
byte[] Power = Data.Skip(4).Take(4).ToArray();
|
||
byte[] PowerUsed = Data.Skip(8).Take(4).ToArray();
|
||
byte[] TotalPowerUsed = Data.Skip(12).Take(4).ToArray();
|
||
uint dianya = BitConverter.ToUInt16(DianYa, 0);
|
||
uint dianliu = BitConverter.ToUInt16(DianLiu, 0);
|
||
uint gonglv = BitConverter.ToUInt32(Power, 0);
|
||
|
||
uint nenghao = BitConverter.ToUInt32(PowerUsed, 0);
|
||
uint zongnenghao = BitConverter.ToUInt32(TotalPowerUsed, 0);
|
||
|
||
double V = (double)dianya * 10 / 1000;
|
||
double A = (double)dianliu * 10 / 1000;
|
||
double P = (double)gonglv / 1000;
|
||
|
||
double KW_H = (double)nenghao / 1000;
|
||
double Sum_KW_H = (double)zongnenghao / 1000;
|
||
|
||
NengHao n = new NengHao();
|
||
n.HotelCode = long.Parse(hotelCode);
|
||
n.HostNumber = HostNNN;
|
||
n.RoomNumber = RoomNUMBER;
|
||
n.CarbonVIP = CarbonVIP;
|
||
n.Mac = "";
|
||
n.EndPoint = EndPoint;
|
||
n.Version = ((int)Version).ToString();
|
||
if (TakeCardStatus == 0x01)
|
||
{
|
||
n.IsTakeCard = true;
|
||
}
|
||
else
|
||
{
|
||
n.IsTakeCard = false;
|
||
}
|
||
n.V = Math.Round(V, 2);
|
||
n.A = Math.Round(A, 2);
|
||
n.P = Math.Round(P, 2);
|
||
n.KW_H = KW_H;
|
||
n.Sum_KW_H = Sum_KW_H;
|
||
|
||
long ti = Tools.GetUnixTime();
|
||
n.CreateTime = ti;
|
||
|
||
string KKey = CacheKey.NengHao + "_" + HostNNN;
|
||
CSRedisCacheHelper.Set_PartitionWithTime<NengHao>(KKey, n, 30, 1);
|
||
|
||
//这里不再发送这个了，改发送全部的数据
|
||
|
||
NengHao4BaoJing ns2 = new NengHao4BaoJing()
|
||
{
|
||
HotelCode = n.HotelCode,
|
||
HostNumber = n.HostNumber,
|
||
RoomNumber = n.RoomNumber,
|
||
Mac = n.Mac,
|
||
EndPoint = n.EndPoint,
|
||
Version = n.Version,
|
||
IsTakeCard = n.IsTakeCard,
|
||
CarbonVIP = n.CarbonVIP,
|
||
V = dianya,
|
||
A = dianliu,
|
||
P = gonglv,
|
||
Energy_Consumption = nenghao,
|
||
Sum_Energy_Consumption = zongnenghao,
|
||
CreateTime = n.CreateTime,
|
||
ReportTime = n.ReportTime.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
AllDeviceData = DeviceStatusList,
|
||
IdentityInfo = IdentityInfo
|
||
};
|
||
|
||
string mns = Newtonsoft.Json.JsonConvert.SerializeObject(ns2);
|
||
CSRedisCacheHelper.Publish("redis-power", mns);
|
||
|
||
|
||
string KeyFilter = "能耗";
|
||
RCUHost.RCUHostCommon.tools.LanJieData(KeyFilter, hotelCode.ToString());
|
||
}
|
||
#endregion
|
||
|
||
#region 是温控
|
||
//定期上报，
|
||
//原本的0E 修改了命令字，改成其它命令字，内容不变，但是空调 只有操作上报。
|
||
//空调定期上报的数据，改为在这里上报
|
||
else if (QA[0] == 0x07)
|
||
{
|
||
//07 //设备类型 - 温控
|
||
//01 //设备地址
|
||
//01 00 //设备回路
|
||
//02 //设备数据长度
|
||
//00 00 //设备数据
|
||
string address = new DeviceAddress(QA).ToString();
|
||
|
||
//设备数据长度
|
||
var WenKongQiDataLen = reader.ReadByte();
|
||
//温控器
|
||
var DataLen1 = Convert.ToInt32(WenKongQiDataLen);
|
||
|
||
///ushort StatusReceiver = reader.ReadUInt16();
|
||
ushort StatusReceiver = BitConverter.ToUInt16(reader.ReadBytes(2).Reverse().ToArray(), 0);
|
||
|
||
if (true)
|
||
{
|
||
//int status = StatusReceiver >> 15;//开关
|
||
//int mode = (StatusReceiver >> 13) & 0x03;//模式
|
||
//int fanSpeed = (StatusReceiver >> 11) & 0x03;//风速
|
||
int valve = (StatusReceiver >> 10) & 0x01;//阀门
|
||
//int temperature = (StatusReceiver >> 5) & 0x1F;//设定温度
|
||
//int currentTemp = StatusReceiver & 0x01F;//当前温度（室内温度）
|
||
|
||
|
||
int status = 0;
|
||
int mode;
|
||
int fanspeed;
|
||
int temperature = 0;//设定温度
|
||
int currentTemp = 0;//当前温度（室内温度）
|
||
KongTiaoReport(StatusReceiver, out status, out temperature, out mode, out fanspeed, out currentTemp);
|
||
if (!string.IsNullOrEmpty(HostID))
|
||
{
|
||
string KKey = CacheKey.HostModalStatus_Prefix + "_" + HostID + "_" + address;
|
||
var HHostModalData = CSRedisCacheHelper.Get_Partition<HostModal_Cache>(KKey);
|
||
if (HHostModalData != null)
|
||
{
|
||
HHostModalData.AirConditionData.AirStatus = status;
|
||
HHostModalData.AirConditionData.Mode = mode;
|
||
HHostModalData.AirConditionData.FanSpeed = fanspeed;
|
||
HHostModalData.AirConditionData.Valve = valve == 1 ? 1 : 2;
|
||
HHostModalData.AirConditionData.UpdateTime = DateTime.Now;
|
||
|
||
|
||
if (temperature == 0 || temperature > 32)
|
||
{
|
||
HHostModalData.AirConditionData.SettingTemp = 32;
|
||
}
|
||
else if (temperature < 16)
|
||
{
|
||
HHostModalData.AirConditionData.SettingTemp = 16;
|
||
}
|
||
else
|
||
{
|
||
HHostModalData.AirConditionData.SettingTemp = temperature;
|
||
|
||
}
|
||
if (currentTemp == 0 || currentTemp > 32)
|
||
{
|
||
HHostModalData.AirConditionData.CurrentTemp = 32;
|
||
}
|
||
else if (currentTemp < 16)
|
||
{
|
||
HHostModalData.AirConditionData.CurrentTemp = 16;
|
||
}
|
||
else
|
||
{
|
||
HHostModalData.AirConditionData.CurrentTemp = currentTemp;
|
||
}
|
||
CSRedisCacheHelper.Set_Partition(KKey, HHostModalData);
|
||
}
|
||
|
||
|
||
}
|
||
}
|
||
|
||
}
|
||
#endregion
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error("定是上报出错:" + ex.Message);
|
||
logger.Error("定是上报出错:" + ex.StackTrace);
|
||
}
|
||
}
|
||
|
||
//向服务器获取房态
|
||
if (cmdType == 0x32)
|
||
{
|
||
try
|
||
{
|
||
IReceiver receiver = receivers[CommandType.AskRoomStatus];
|
||
if (receiver != null)
|
||
{
|
||
string Key = CacheKey.SyncRoomStatus + "_" + HostNNN;
|
||
var Q = CSRedisCacheHelper.Get_Partition<RoomStatusRequest>(Key);
|
||
if (Q != null)
|
||
{
|
||
(receiver as AskRoomStatusChangedReceiver).SendRoomStatusSelf(HostNNN, Q.MAC, Q.Status, framenolist);//处理业务逻辑
|
||
}
|
||
else
|
||
{
|
||
Domain.RoomStatus RS = new RoomStatus();
|
||
RS.Name = "空房";
|
||
RS.ID = 16;
|
||
(receiver as AskRoomStatusChangedReceiver).SendRoomStatusSelf(HostNNN, "FF-FF-FF-FF-FF-FF", RS, framenolist);//处理业务逻辑
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.Error("CmdType Error" + ex.StackTrace);
|
||
}
|
||
}
|
||
}, Tuple);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 空调上报解析
|
||
/// </summary>
|
||
/// <param name="StatusReceiver"></param>
|
||
/// <param name="temperature"></param>
|
||
/// <param name="mode"></param>
|
||
/// <param name="fanspeed"></param>
|
||
private static void KongTiaoReport(ushort StatusReceiver, out int status, out int temperature, out int mode, out int fanspeed, out int currenttemp)
|
||
{
|
||
mode = 0;
|
||
fanspeed = 0;
|
||
status = 0;
|
||
|
||
//StringBuilder sssasa = new StringBuilder();
|
||
byte[] b_data = BitConverter.GetBytes(StatusReceiver);
|
||
|
||
b_data = b_data.Reverse().ToArray();
|
||
BitArray bit = new BitArray(b_data);
|
||
|
||
//BitArray bit2 = new BitArray(new byte[] { b_data[1] });
|
||
BitArray bit3 = new BitArray(5);
|
||
BitArray bit4 = new BitArray(5);
|
||
|
||
//00 0011 1010
|
||
//Bit9~5:设置温度 16~32℃
|
||
//Bit4~0:室内温度 16~32℃
|
||
bit3[0] = bit[5];
|
||
bit3[1] = bit[6];
|
||
bit3[2] = bit[7];
|
||
bit3[3] = bit[8];
|
||
bit3[4] = bit[9];
|
||
|
||
bit4[0] = bit[0];
|
||
bit4[1] = bit[1];
|
||
bit4[2] = bit[2];
|
||
bit4[3] = bit[3];
|
||
bit4[4] = bit[4];
|
||
|
||
int[] array1 = new int[1];
|
||
int[] array2 = new int[1];
|
||
bit3.CopyTo(array1, 0);
|
||
bit4.CopyTo(array2, 0);
|
||
|
||
temperature = array1[0];
|
||
currenttemp = array2[0];
|
||
bool b000 = bit[15];
|
||
if (b000 == true)
|
||
{
|
||
status = 1;
|
||
}
|
||
else
|
||
{
|
||
status = 2;
|
||
}
|
||
bool b111 = bit[14];
|
||
bool b222 = bit[13];
|
||
|
||
bool b333 = bit[12];
|
||
bool b444 = bit[11];
|
||
//1制冷，2制热，3送风
|
||
if (b222 == true && b111 == false)
|
||
{
|
||
mode = 1;
|
||
}
|
||
else if (b222 == false && b111 == true)
|
||
{
|
||
mode = 2;
|
||
}
|
||
else if (b222 == true && b111 == true)
|
||
{
|
||
mode = 3;
|
||
}
|
||
else
|
||
{
|
||
|
||
}
|
||
|
||
//0自动，1低速，2中速，3高速
|
||
if (b444 == true && b333 == false)
|
||
{
|
||
fanspeed = 1;
|
||
}
|
||
else if (b444 == false && b333 == true)
|
||
{
|
||
fanspeed = 2;
|
||
}
|
||
else if (b444 == true && b333 == true)
|
||
{
|
||
fanspeed = 3;
|
||
}
|
||
else if (b444 == false && b333 == false)
|
||
{
|
||
fanspeed = 0;
|
||
}
|
||
else
|
||
{
|
||
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 解码 SystemHeader
|
||
/// </summary>
|
||
/// <param name="data"></param>
|
||
/// <returns></returns>
|
||
private SystemHeader? DecodeSystemHeader(byte[] data)
|
||
{
|
||
return StructConverter.BytesToStruct(data, typeof(SystemHeader)) as SystemHeader?;
|
||
}
|
||
|
||
#region Command Queue Methods
|
||
|
||
/// <summary>
|
||
/// 将命令放入队列
|
||
/// </summary>
|
||
/// <param name="data"></param>
|
||
private void PushCommandToQueue(byte[] data, IPEndPoint endPoint)
|
||
{
|
||
CommandData commandData = new CommandData();
|
||
commandData.RemoteEndPoint = endPoint;
|
||
commandData.FrameNo = BitConverter.ToUInt16(data, 9);
|
||
commandData.Data = data;
|
||
commandData.ResendTime = 2;
|
||
commandQueue.Add(commandData);
|
||
}
|
||
/// <summary>
|
||
/// 清理命令队列
|
||
/// </summary>
|
||
private void CleanCommandQueue()
|
||
{
|
||
RemoveCommandData(commandQueue.Where(r => r.ResendTime < 1));
|
||
}
|
||
|
||
private void RemoveCommandDataFromCommandQueueByFrameNo(ushort frameNo)
|
||
{
|
||
RemoveCommandData(commandQueue.Where(r => r.FrameNo == frameNo));
|
||
}
|
||
|
||
private void RemoveCommandData(IEnumerable<CommandData> commands)
|
||
{
|
||
CommandData takeCommand;
|
||
foreach (var command in commands)
|
||
{
|
||
commandQueue.TryTake(out takeCommand);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
/// <summary>
|
||
/// 阿宝
|
||
/// </summary>
|
||
public void Start_AirConditionMisson()
|
||
{
|
||
}
|
||
|
||
public void Dispose()
|
||
{
|
||
Destroy();
|
||
}
|
||
}
|
||
|
||
internal class UdpState
|
||
{
|
||
private UdpClient udpClient;
|
||
public UdpState(UdpClient client)
|
||
{
|
||
this.udpClient = client;
|
||
}
|
||
public UdpClient UdpClient
|
||
{
|
||
get { return this.udpClient; }
|
||
}
|
||
}
|
||
}
|