2881 lines
125 KiB
C#
2881 lines
125 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.IO;
|
||
using System.Linq;
|
||
using System.Web;
|
||
using System.Data;
|
||
using System.Data.SQLite;
|
||
using Newtonsoft.Json.Linq;
|
||
using System.Text;
|
||
using System.Globalization;
|
||
using System.Web.UI.WebControls.WebParts;
|
||
|
||
using System.Net;
|
||
using Newtonsoft.Json;
|
||
using MySql.Data.MySqlClient;
|
||
using MySqlX.XDevAPI;
|
||
using MQTTServerSideAPI.Controllers;
|
||
using System.Xml.Linq;
|
||
using static System.Data.Entity.Infrastructure.Design.Executor;
|
||
using System.Web.Helpers;
|
||
using Org.BouncyCastle.Asn1.X509;
|
||
using static MQTTServerSideAPI.SQLiteDBHelper;
|
||
using Google.Protobuf.WellKnownTypes;
|
||
using System.Text.RegularExpressions;
|
||
using Org.BouncyCastle.Asn1.Cms;
|
||
using static Google.Protobuf.Reflection.FieldOptions.Types;
|
||
using MQTTServerSideAPI.Models;
|
||
using System.Net.NetworkInformation;
|
||
using StackExchange.Redis;
|
||
using Org.BouncyCastle.Ocsp;
|
||
using System.Web.UI;
|
||
|
||
namespace MQTTServerSideAPI
|
||
{
|
||
public static class SQLiteDBHelper
|
||
{
|
||
// public static string strSqliteConn = @"Data Source=C:\sqllite\data\mydb.db;Version=3";
|
||
|
||
|
||
public static string strSqliteConn = @"Server=blv-cloud-db.mysql.rds.aliyuncs.com;Database=mqqtmysql;Uid=blv_rcu;Pwd=fnadiaJDIJ7546;charset=utf8;port=3307;";
|
||
|
||
|
||
public static int Loning(loginuser info)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
string strSqlCmd = "select * from userinfo where name='" + info.user_name + "' and pwd ='" + info.password + "'";
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
|
||
return 1;
|
||
|
||
}
|
||
else
|
||
{
|
||
return 0;
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
return 0;
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
#region Get Record
|
||
public static List<string> GetAllCallin()
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
|
||
string curline = "";
|
||
DataSet ds = GetAllCallinRecord();
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
curline = "";
|
||
curline += "DeviceName:" + row["DeviceName"] + ",";
|
||
curline += "Online:" + row["Online"] + ",";
|
||
curline += "districtinfo:" + row["districtinfo"] + ",";
|
||
curline += "LastUpdateTime:" + row["LastUpdateTime"] + ",";
|
||
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
|
||
|
||
return listRet;
|
||
}
|
||
public static List<string> GetAllCallinBYName(string Name, int zhuant)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
|
||
string curline = "";
|
||
DataSet ds = new DataSet();
|
||
|
||
ds = GetAllCallinRecordBYName(Name, zhuant);
|
||
|
||
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
curline = "";
|
||
curline += "DeviceName：" + row["DeviceName"] + ",";
|
||
curline += "Online：" + row["Online"] + ",";
|
||
curline += "districtinfo：" + row["districtinfo"] + ",";
|
||
curline += "LastUpdateTime：" + row["LastUpdateTime"] + ",";
|
||
curline += "powerintakestatus：" + row["powerintakestatus"] + ",";
|
||
curline += "Power：" + row["Power"] + ",";
|
||
curline += "pir1status：" + row["pir1status"] + ",";
|
||
curline += "pir2status：" + row["pir2status"] + ",";
|
||
curline += "pir3status：" + row["pir3status"] + ",";
|
||
curline += "pir4status：" + row["pir4status"] + ",";
|
||
curline += "gatemagnetstatus：" + row["gatemagnetstatus"] + ",";
|
||
curline += "pir5status：" + row["pir5status"] + ",";
|
||
curline += "pir6status：" + row["pir6status"] + ",";
|
||
curline += "pir7status：" + row["pir7status"] + ",";
|
||
curline += "pir8status：" + row["pir8status"] + ",";
|
||
curline += "powerOnEquipment：" + row["powerOnEquipment"] + ",";
|
||
curline += "equipmenttime：" + row["equipmenttime"] + ",";
|
||
curline += "powerOnEquipmentinfo：" + row["powerOnEquipmentinfo"] + ",";
|
||
curline += "yingjianbanbinfo：" + row["yingjianbanbinfo"] + ",";
|
||
curline += "ruanjianbanbinfo：" + row["ruanjianbanbinfo"] + ",";
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
return listRet;
|
||
}
|
||
|
||
public static List<string> GetFilterCallin(string productid, string devicename, int shijian)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
DataSet ds = new DataSet()
|
||
; //1. get all
|
||
if (shijian == 0)
|
||
{
|
||
ds = GetAllCallinRecord();
|
||
}
|
||
else
|
||
{
|
||
ds = GetAllCallinRecordBYTime(productid, devicename, shijian);
|
||
}
|
||
|
||
|
||
//2. filter
|
||
string curline = "";
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
DataTable logs = ds.Tables[0];
|
||
|
||
EnumerableRowCollection<DataRow> query =
|
||
from log in logs.AsEnumerable()
|
||
where log.Field<string>("productid") == productid && log.Field<string>("devicename") == devicename
|
||
select log;
|
||
|
||
foreach (DataRow row in query)
|
||
{
|
||
curline = "";
|
||
|
||
|
||
curline += row["timeappreceive"] + "|";
|
||
//curline += "productid:" + row["productid"] + ",";
|
||
//curline += "devicename:" + row["devicename"] + ",";
|
||
//curline += "topic:" + row["topic"] + ",";
|
||
|
||
//curline += "payload:" + row["payload"] + ",";
|
||
curline += AnalysisByte(row["payload"].ToString(), row["devicename"].ToString());
|
||
//curline += "payload:" + AnalysisByte("pkwAf7vmZCwApwEEvQAAXEOuR0FAAACdQgAAAAAAAAAAAAAAAAAAAAAAAAA=") + ",";
|
||
|
||
//平台参数，暂时不需要
|
||
//curline += "seq:" + row["seq"] + ",";
|
||
//curline += "timestamp:" + row["timestamp"] + ",";
|
||
//curline += "timemills:" + row["timemills"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
|
||
return listRet;
|
||
}
|
||
|
||
public class FixedHeaderPart
|
||
{
|
||
public int FixedFlag { get; set; }
|
||
public int SN { get; set; }
|
||
public UInt32 TimeStamp { get; set; }
|
||
public int LEN { get; set; }
|
||
public byte CHECK { get; set; }
|
||
public int PowerStatus { get; set; }
|
||
public int CMD { get; set; }
|
||
}
|
||
public class HeartBeatPara
|
||
{
|
||
public int RSSI { get; set; }
|
||
public float voltage { get; set; }
|
||
public float power { get; set; }
|
||
public float energyconsumption { get; set; }
|
||
public int doorlockonline { get; set; }
|
||
public string strHexdoorlockstatus { get; set; }
|
||
public bool isLockFsfsOn { get; set; }
|
||
public bool isLockLowCapIndOn { get; set; }
|
||
public bool isLockFakIndOn { get; set; }
|
||
public int doorlockcapacity { get; set; }
|
||
}
|
||
public static String HearBeatToString(HeartBeatPara para)
|
||
{
|
||
string retStr = "";
|
||
retStr += "RSSI值：" + para.RSSI + ",";
|
||
retStr += "电压：" + para.voltage.ToString("F", CultureInfo.InvariantCulture) + "伏,";
|
||
retStr += "功率：" + para.power.ToString("F", CultureInfo.InvariantCulture) + "瓦,";
|
||
retStr += "能耗：" + para.energyconsumption.ToString("F", CultureInfo.InvariantCulture) + "瓦时,";
|
||
retStr += "门锁在线：" + para.doorlockonline + ",";
|
||
retStr += "门锁状态： 反锁方舌" + (para.isLockFsfsOn ? "开启" : "关闭") + " 低电量预警" + (para.isLockLowCapIndOn ? "开启" : "关闭") + " 假锁预警" + (para.isLockFakIndOn ? "开启" : "关闭") + ",";
|
||
retStr += "门锁电量：" + para.doorlockcapacity + "%,";
|
||
return retStr;
|
||
}
|
||
public class DoorLockActionPara
|
||
{
|
||
public int dooronlinestatus { get; set; }
|
||
public int doorstatus { get; set; }
|
||
public int doorcapacity { get; set; }
|
||
}
|
||
public static String DoorLockActionToString(DoorLockActionPara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(1, "外开门");
|
||
dicDoorStat.Add(2, "内开门");
|
||
dicDoorStat.Add(3, "反锁方舌开启");
|
||
dicDoorStat.Add(4, "反锁方舌关闭");
|
||
dicDoorStat.Add(5, "关门");
|
||
dicDoorStat.Add(6, "机械钥匙开锁");
|
||
dicDoorStat.Add(7, "低电量预警");
|
||
dicDoorStat.Add(8, "假锁预警");
|
||
dicDoorStat.Add(9, "蓝牙开锁");
|
||
dicDoorStat.Add(10, "刷卡开锁");
|
||
dicDoorStat.Add(11, "其他开锁");
|
||
|
||
string retStr = "";
|
||
retStr += "门锁在线状态:" + (para.dooronlinestatus == 1 ? "在线" : "离线") + ",";
|
||
retStr += "门锁状态:" + dicDoorStat[para.doorstatus] + ",";
|
||
retStr += "门锁电量：" + para.doorcapacity + "%,";
|
||
return retStr;
|
||
}
|
||
public class PIRActionPara
|
||
{
|
||
public string Pirmovementname { get; set; }
|
||
public int PIRAction { get; set; }
|
||
public int PIRTotalTriggerTimes { get; set; }
|
||
public int PIR1Times { get; set; }
|
||
public int PIR2Times { get; set; }
|
||
public int PIR3Times { get; set; }
|
||
public int PIR4Times { get; set; }
|
||
public int PIR5Times { get; set; }
|
||
public int PIR6Times { get; set; }
|
||
public int PIR7Times { get; set; }
|
||
public int PIR8Times { get; set; }
|
||
public int PIR1OnlineStatus { get; set; }
|
||
public int PIR2OnlineStatus { get; set; }
|
||
public int PIR3OnlineStatus { get; set; }
|
||
public int PIR4OnlineStatus { get; set; }
|
||
public int PIR5OnlineStatus { get; set; }
|
||
public int PIR6OnlineStatus { get; set; }
|
||
public int PIR7OnlineStatus { get; set; }
|
||
public int PIR8OnlineStatus { get; set; }
|
||
public int PIR1Capacity { get; set; }
|
||
public int PIR2Capacity { get; set; }
|
||
public int PIR3Capacity { get; set; }
|
||
public int PIR4Capacity { get; set; }
|
||
public int PIR5Capacity { get; set; }
|
||
public int PIR6Capacity { get; set; }
|
||
public int PIR7Capacity { get; set; }
|
||
public int PIR8Capacity { get; set; }
|
||
|
||
}
|
||
public static String PIRActionToString(PIRActionPara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(1, "PIR设备离线");
|
||
dicDoorStat.Add(2, "设备上线");
|
||
dicDoorStat.Add(3, "关门触发设备唤醒");
|
||
dicDoorStat.Add(4, "PIR激活后超时时间到触发休眠");
|
||
dicDoorStat.Add(5, "PIR激活后触发次数到触发休眠");
|
||
dicDoorStat.Add(6, "PIR低电量报警");
|
||
|
||
string retStr = "";
|
||
retStr += "PIR动作：" + dicDoorStat[para.PIRAction] + ",";
|
||
para.Pirmovementname = dicDoorStat[para.PIRAction];
|
||
retStr += "PIR总触发次数：" + para.PIRTotalTriggerTimes + ",";
|
||
retStr += "PIR1次数：" + para.PIR1Times + ",";
|
||
retStr += "PIR2次数：" + para.PIR2Times + ",";
|
||
retStr += "PIR3次数：" + para.PIR3Times + ",";
|
||
retStr += "PIR4次数：" + para.PIR4Times + ",";
|
||
retStr += "PIR1在线状态：" + para.PIR1OnlineStatus + ",";
|
||
retStr += "PIR2在线状态：" + para.PIR2OnlineStatus + ",";
|
||
retStr += "PIR3在线状态：" + para.PIR3OnlineStatus + ",";
|
||
retStr += "PIR4在线状态：" + para.PIR4OnlineStatus + ",";
|
||
retStr += "PIR1电量：" + para.PIR1Capacity + "%,";
|
||
retStr += "PIR2电量：" + para.PIR2Capacity + "%,";
|
||
retStr += "PIR3电量：" + para.PIR3Capacity + "%,";
|
||
retStr += "PIR4电量：" + para.PIR4Capacity + "%,";
|
||
retStr += "PIR5次数：" + para.PIR5Times + ",";
|
||
retStr += "PIR6次数：" + para.PIR6Times + ",";
|
||
retStr += "PIR7次数：" + para.PIR7Times + ",";
|
||
retStr += "PIR8次数：" + para.PIR8Times + ",";
|
||
retStr += "PIR5在线状态：" + para.PIR5OnlineStatus + ",";
|
||
retStr += "PIR6在线状态：" + para.PIR6OnlineStatus + ",";
|
||
retStr += "PIR7在线状态：" + para.PIR7OnlineStatus + ",";
|
||
retStr += "PIR8在线状态：" + para.PIR8OnlineStatus + ",";
|
||
retStr += "PIR5电量：" + para.PIR5Capacity + "%,";
|
||
retStr += "PIR6电量：" + para.PIR6Capacity + "%,";
|
||
retStr += "PIR7电量：" + para.PIR7Capacity + "%,";
|
||
retStr += "PIR8电量：" + para.PIR8Capacity + "%,";
|
||
return retStr;
|
||
}
|
||
public class IntervalMessagePara
|
||
{
|
||
public int RSSISignal { get; set; }
|
||
public float CheckV { get; set; }
|
||
public float CheckP { get; set; }
|
||
public float Energy { get; set; }
|
||
public int LockOnlineStatus { get; set; }
|
||
public int PIR1OnlineStatus { get; set; }
|
||
public int PIR2OnlineStatus { get; set; }
|
||
public int PIR3OnlineStatus { get; set; }
|
||
public int PIR4OnlineStatus { get; set; }
|
||
public int PIR5OnlineStatus { get; set; }
|
||
public int PIR6OnlineStatus { get; set; }
|
||
public int PIR7OnlineStatus { get; set; }
|
||
public int PIR8OnlineStatus { get; set; }
|
||
|
||
public int LockCapacity { get; set; }
|
||
public int PIR1Capacity { get; set; }
|
||
public int PIR2Capacity { get; set; }
|
||
public int PIR3Capacity { get; set; }
|
||
public int PIR4Capacity { get; set; }
|
||
public int PIR5Capacity { get; set; }
|
||
public int PIR6Capacity { get; set; }
|
||
public int PIR7Capacity { get; set; }
|
||
public int PIR8Capacity { get; set; }
|
||
public int HearBeatSecond { get; set; }
|
||
public int IntervalMessageSecond { get; set; }
|
||
public int PIRContinueWorkingTime { get; set; }
|
||
public int PIRTriggerTimes { get; set; }
|
||
public int Protocolversionnumber { get; set; }
|
||
public int GatemagnetStatus { get; set; }
|
||
public int GatemagnetCurrentStatus { get; set; }
|
||
public int GatemagnetCapacity { get; set; }
|
||
public int PIR1Frequency { get; set; }
|
||
public int PIR2Frequency { get; set; }
|
||
public int PIR3Frequency { get; set; }
|
||
public int PIR4Frequency { get; set; }
|
||
public int PIR5Frequency { get; set; }
|
||
public int PIR6Frequency { get; set; }
|
||
public int PIR7Frequency { get; set; }
|
||
public int PIR8Frequency { get; set; }
|
||
public int Grsrpignal { get; set; }
|
||
public int csqpignal { get; set; }
|
||
}
|
||
public static String IntervalMessageToString(IntervalMessagePara para)
|
||
{
|
||
|
||
string retStr = "";
|
||
retStr += "RSSI信号：" + para.RSSISignal + ",";
|
||
retStr += "电压：" + para.CheckV + ",";
|
||
retStr += "功率：" + para.CheckP + ",";
|
||
retStr += "能耗:" + para.Energy + ",";
|
||
retStr += "锁在线状态:" + para.LockOnlineStatus + ",";
|
||
retStr += "PIR1状态:" + para.PIR1OnlineStatus + ",";
|
||
retStr += "PIR2状态:" + para.PIR2OnlineStatus + ",";
|
||
retStr += "PIR3状态:" + para.PIR3OnlineStatus + ",";
|
||
retStr += "PIR4状态:" + para.PIR4OnlineStatus + ",";
|
||
|
||
retStr += "电量:" + para.LockCapacity + ",";
|
||
retStr += "电量:" + para.PIR1Capacity + ",";
|
||
retStr += "电量:" + para.PIR2Capacity + ",";
|
||
retStr += "电量:" + para.PIR3Capacity + ",";
|
||
retStr += "电量:" + para.PIR4Capacity + ",";
|
||
|
||
retStr += "心跳包时间：" + para.HearBeatSecond + "s,";
|
||
retStr += "上报时间：" + para.IntervalMessageSecond + "s,";
|
||
retStr += "PIR工作时间：" + para.PIRContinueWorkingTime + "s,";
|
||
retStr += "PIR触发次数：" + para.PIRTriggerTimes + ",";
|
||
retStr += "协议版本号：" + para.Protocolversionnumber + ",";
|
||
retStr += "门磁在线状态:" + para.GatemagnetStatus + ",";
|
||
retStr += "当前状态:" + para.GatemagnetCurrentStatus + ",";
|
||
retStr += "电量:" + para.GatemagnetCapacity + ",";
|
||
|
||
retStr += "PIR5状态:" + para.PIR5OnlineStatus + ",";
|
||
retStr += "PIR6状态:" + para.PIR6OnlineStatus + ",";
|
||
retStr += "PIR7状态:" + para.PIR7OnlineStatus + ",";
|
||
retStr += "PIR8状态:" + para.PIR8OnlineStatus + ",";
|
||
retStr += "电量:" + para.PIR5Capacity + ",";
|
||
retStr += "电量:" + para.PIR6Capacity + ",";
|
||
retStr += "电量:" + para.PIR7Capacity + ",";
|
||
retStr += "电量:" + para.PIR8Capacity + ",";
|
||
retStr += "PIR5 次数:" + para.PIR5Frequency + ",";
|
||
retStr += "PIR6 次数:" + para.PIR6Frequency + ",";
|
||
retStr += "PIR7 次数:" + para.PIR7Frequency + ",";
|
||
retStr += "PIR8 次数:" + para.PIR8Frequency + ",";
|
||
retStr += "rsrp信号强度:" + para.Grsrpignal + ",";
|
||
retStr += "csq信号强度:" + para.csqpignal + ",";
|
||
return retStr;
|
||
}
|
||
public class CatchElectricityPara
|
||
{
|
||
public int action { get; set; }
|
||
public string movement { get; set; }
|
||
|
||
}
|
||
public static String CatchElecToString(CatchElectricityPara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(0, "本地操作断电");
|
||
dicDoorStat.Add(1, "服务器命令断电");
|
||
dicDoorStat.Add(2, "本地操作取电");
|
||
dicDoorStat.Add(3, "开门触发取电");
|
||
dicDoorStat.Add(4, "服务器命令取电");
|
||
dicDoorStat.Add(5, "PIR触发取电");
|
||
dicDoorStat.Add(6, "PIR超时断电");
|
||
dicDoorStat.Add(7, "门磁开门取电");
|
||
dicDoorStat.Add(8, "电源保护断电");
|
||
dicDoorStat.Add(9, "上电同步取电");
|
||
string retStr = "";
|
||
retStr += "取电动作：" + dicDoorStat[para.action] + ",";
|
||
para.movement = dicDoorStat[para.action];
|
||
return retStr;
|
||
}
|
||
public class RequestServerPara
|
||
{
|
||
public int paratype { get; set; }
|
||
|
||
}
|
||
public static String RequestServerToString(RequestServerPara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(1, "获取 MAC 地址信息");
|
||
dicDoorStat.Add(2, "获取时间");
|
||
|
||
string retStr = "";
|
||
retStr += "获取参数：" + dicDoorStat[para.paratype] + ",";
|
||
|
||
return retStr;
|
||
}
|
||
public class ServerSetConfigResponsePara
|
||
{
|
||
public int downparatype { get; set; }
|
||
public int downresult { get; set; }
|
||
}
|
||
public static String ServerSetConfigResponseToString(ServerSetConfigResponsePara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(1, "设置 MAC 地址信息");
|
||
dicDoorStat.Add(2, "设置 PIR 参数");
|
||
dicDoorStat.Add(3, "设置心跳包时间与定期上报时间");
|
||
dicDoorStat.Add(4, "设置超功率检测判定");
|
||
|
||
Dictionary<int, string> dicDoorStat1 = new Dictionary<int, string>();
|
||
dicDoorStat1.Add(0, "无错误");
|
||
dicDoorStat1.Add(1, "未知参数");
|
||
|
||
string retStr = "";
|
||
retStr += "下发参数：" + dicDoorStat[para.downparatype] + ",";
|
||
retStr += "下发结果：" + dicDoorStat1[para.downresult] + ",";
|
||
|
||
return retStr;
|
||
}
|
||
public class DeviceInfoPara
|
||
{
|
||
public int infotype { get; set; }
|
||
public int md4gsoftverlow { get; set; }
|
||
public int md4gsoftverhigh { get; set; }
|
||
public int md4ghardver { get; set; }
|
||
public string md4gIMEI { get; set; }
|
||
public string md4gSIMICCID { get; set; }
|
||
public int blesoftverlow { get; set; }
|
||
public int blesoftverhigh { get; set; }
|
||
public int blehardver { get; set; }
|
||
public string bleMAC { get; set; }
|
||
public int pirsoftverlow { get; set; }
|
||
public int pirsoftverhigh { get; set; }
|
||
public int pirhardver { get; set; }
|
||
public string pirMAC { get; set; }
|
||
|
||
public string lockMAC { get; set; }
|
||
public string pir1MAC { get; set; }
|
||
public string pir2MAC { get; set; }
|
||
public string pir3MAC { get; set; }
|
||
public string pir4MAC { get; set; }
|
||
public string pir5MAC { get; set; }
|
||
public string pir6MAC { get; set; }
|
||
public string pir7MAC { get; set; }
|
||
public string pir8MAC { get; set; }
|
||
public string GatemagnetMAC { get; set; }
|
||
public int Gatemagnetgsoftverlow { get; set; }
|
||
public int Gatemagnetgsoftverhigh { get; set; }
|
||
public int Gatemagnetghardver { get; set; }
|
||
|
||
public int pir4gsoftverlow { get; set; }
|
||
public int pir4gsoftverhigh { get; set; }
|
||
public int pir4ghardver { get; set; }
|
||
public int pir3gsoftverlow { get; set; }
|
||
public int pir3gsoftverhigh { get; set; }
|
||
public int pir3ghardver { get; set; }
|
||
public int pir2gsoftverlow { get; set; }
|
||
public int pir2gsoftverhigh { get; set; }
|
||
public int pir2ghardver { get; set; }
|
||
public int pir1gsoftverlow { get; set; }
|
||
public int pir1gsoftverhigh { get; set; }
|
||
public int pir1ghardver { get; set; }
|
||
|
||
|
||
public int pir5gsoftverlow { get; set; }
|
||
public int pir5gsoftverhigh { get; set; }
|
||
public int pir5ghardver { get; set; }
|
||
|
||
public int pir6gsoftverlow { get; set; }
|
||
public int pir6gsoftverhigh { get; set; }
|
||
public int pir6ghardver { get; set; }
|
||
|
||
|
||
public int pir7gsoftverlow { get; set; }
|
||
public int pir7gsoftverhigh { get; set; }
|
||
public int pir7ghardver { get; set; }
|
||
|
||
public int pir8gsoftverlow { get; set; }
|
||
public int pir8gsoftverhigh { get; set; }
|
||
public int pir8ghardver { get; set; }
|
||
|
||
public int GatemagnetPower { get; set; }
|
||
public int pir1Power { get; set; }
|
||
public int pir2Power { get; set; }
|
||
public int pir3Power { get; set; }
|
||
public int pir4Power { get; set; }
|
||
|
||
public int pir5Power { get; set; }
|
||
public int pir6Power { get; set; }
|
||
public int pir7Power { get; set; }
|
||
public int pir8Power { get; set; }
|
||
public int maxelectricPower { get; set; }
|
||
public int protectionTime { get; set; }
|
||
|
||
|
||
|
||
//门磁开门断电使能状态
|
||
public int Dmdopoffe { get; set; }
|
||
//门磁关门取电使能状态
|
||
public int Mdoapte { get; set; }
|
||
|
||
public int Grsrpignal { get; set; }
|
||
public int csqpignal { get; set; }
|
||
public int IntervalMessageSecond { get; set; }
|
||
|
||
}
|
||
|
||
|
||
// P1 ~P4：经度(浮点数)
|
||
//P5 ~P8：纬度(浮点数)
|
||
//P9 ~P12：当前服务小区的ECI（整数）
|
||
//P13 ~P16：当前服务小区的TAC(整数)
|
||
//P17 ~P20：当前服务小区的eNBID(整数)
|
||
|
||
|
||
|
||
public class jizhanxx
|
||
{
|
||
public int infotype { get; set; }
|
||
//经度
|
||
public float longitude { get; set; }
|
||
//纬度
|
||
public float latitude { get; set; }
|
||
public int ECI { get; set; }
|
||
public int TAC { get; set; }
|
||
public int eNBID { get; set; }
|
||
public string jizhaninfo { get; set; }
|
||
public string didian { get; set; }
|
||
}
|
||
|
||
public class DoorMagneticReport
|
||
{
|
||
public int DoorMagneticOnlineStatues { get; set; }
|
||
public int DoorMagneticStatues { get; set; }
|
||
public int DoorMagneticQuantity { get; set; }
|
||
}
|
||
|
||
//public static string jizha (){
|
||
|
||
|
||
|
||
//}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
public static String DeviceInfoResponseToString(DeviceInfoPara para)
|
||
{
|
||
Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
dicDoorStat.Add(1, "4G 版本信息");
|
||
dicDoorStat.Add(2, "BLE 版本信息");
|
||
dicDoorStat.Add(3, "RF 版本信息");
|
||
dicDoorStat.Add(4, "RF MAC地址信息");
|
||
dicDoorStat.Add(5, "RF版本信息");
|
||
dicDoorStat.Add(6, "RF通讯成功率");
|
||
dicDoorStat.Add(7, "超功率检测判定");
|
||
string retStr = "";
|
||
|
||
retStr += "消息类型：" + dicDoorStat[para.infotype] + ",";
|
||
if (para.infotype == 1)//4G模块
|
||
{
|
||
retStr += "4G软件版本低字节：" + para.md4gsoftverlow + ",";
|
||
retStr += "4G软件版本高字节：" + para.md4gsoftverhigh + ",";
|
||
retStr += "4G硬件版本：" + para.md4ghardver + ",";
|
||
retStr += "IMEI：" + para.md4gIMEI + ",";
|
||
retStr += "SIM ICCID：" + para.md4gSIMICCID + ",";
|
||
retStr += "门磁开门取电使能状态：" + para.Mdoapte + ",";
|
||
retStr += "门磁关门断电使能状态：" + para.Dmdopoffe + ",";
|
||
retStr += "定期上报时间：" + para.IntervalMessageSecond + ",";
|
||
retStr += "rsrp 接收信号强度：" + para.Grsrpignal + ",";
|
||
retStr += "csq 信号强度：" + para.csqpignal + ",";
|
||
|
||
|
||
|
||
|
||
////paradv. = BitConverter.ToUInt16(btPara, 41);
|
||
////paradv. = (int)btPara[43];
|
||
////paradv. = (int)btPara[44];
|
||
}
|
||
else if (para.infotype == 2)
|
||
{
|
||
retStr += "ble软件版本低字节：" + para.blesoftverlow + ",";
|
||
retStr += "ble软件版本高字节：" + para.blesoftverhigh + ",";
|
||
retStr += "ble硬件版本：" + para.blehardver + ",";
|
||
retStr += "ble MAC：" + para.bleMAC + ",";
|
||
}
|
||
else if (para.infotype == 3)
|
||
{
|
||
retStr += "pir软件版本低字节：" + para.pirsoftverlow + ",";
|
||
retStr += "pir软件版本高字节：" + para.pirsoftverhigh + ",";
|
||
retStr += "pir硬件版本：" + para.pirhardver + ",";
|
||
retStr += "pir MAC：" + para.pirMAC + ",";
|
||
}
|
||
else if (para.infotype == 4)
|
||
{
|
||
retStr += "锁 MAC：" + para.lockMAC + ",";
|
||
retStr += "pir 1 MAC：" + para.pir1MAC + ",";
|
||
retStr += "pir 2 MAC：" + para.pir2MAC + ",";
|
||
retStr += "pir 3 MAC：" + para.pir3MAC + ",";
|
||
retStr += "pir 4 MAC：" + para.pir4MAC + ",";
|
||
retStr += "门磁 MAC：" + para.GatemagnetMAC + ",";
|
||
retStr += "pir 5 MAC：" + para.pir5MAC + ",";
|
||
retStr += "pir 6 MAC：" + para.pir6MAC + ",";
|
||
retStr += "pir 7 MAC：" + para.pir7MAC + ",";
|
||
retStr += "pir 8 MAC：" + para.pir8MAC + ",";
|
||
}
|
||
else if (para.infotype == 5)
|
||
{
|
||
retStr += "门磁软件低版本：" + para.Gatemagnetgsoftverlow + ",";
|
||
retStr += "门磁软件高版本：" + para.Gatemagnetgsoftverhigh + ",";
|
||
retStr += "门磁硬件版本：" + para.Gatemagnetghardver + ",";
|
||
retStr += "PIR1软件低版本：" + para.pir1gsoftverlow + ",";
|
||
retStr += "PIR1软件高版本：" + para.pir1gsoftverhigh + ",";
|
||
retStr += "PIR1硬件版本：" + para.pir1ghardver + ",";
|
||
retStr += "PIR2软件低版本：" + para.pir2gsoftverlow + ",";
|
||
retStr += "PIR2软件高版本：" + para.pir2gsoftverhigh + ",";
|
||
retStr += "PIR2硬件版本：" + para.pir2ghardver + ",";
|
||
retStr += "PIR3软件低版本：" + para.pir3gsoftverlow + ",";
|
||
retStr += "PIR3软件高版本：" + para.pir3gsoftverhigh + ",";
|
||
retStr += "PIR3硬件版本：" + para.pir3ghardver + ",";
|
||
retStr += "PIR4软件低版本：" + para.pir4gsoftverlow + ",";
|
||
retStr += "PIR4软件高版本：" + para.pir4gsoftverhigh + ",";
|
||
retStr += "PIR4硬件版本：" + para.pir4ghardver + ",";
|
||
retStr += "PIR5软件低版本：" + para.pir5gsoftverlow + ",";
|
||
retStr += "PIR5软件高版本：" + para.pir5gsoftverhigh + ",";
|
||
retStr += "PIR5硬件版本：" + para.pir5ghardver + ",";
|
||
|
||
|
||
retStr += "PIR6软件低版本：" + para.pir6gsoftverlow + ",";
|
||
retStr += "PIR6软件高版本：" + para.pir6gsoftverhigh + ",";
|
||
retStr += "PIR6硬件版本：" + para.pir6ghardver + ",";
|
||
|
||
retStr += "PIR7软件低版本：" + para.pir7gsoftverlow + ",";
|
||
retStr += "PIR7软件高版本：" + para.pir7gsoftverhigh + ",";
|
||
retStr += "PIR7硬件版本：" + para.pir7ghardver + ",";
|
||
|
||
retStr += "PIR8软件低版本：" + para.pir8gsoftverlow + ",";
|
||
retStr += "PIR8软件高版本：" + para.pir8gsoftverhigh + ",";
|
||
retStr += "PIR8硬件版本：" + para.pir8ghardver + ",";
|
||
}
|
||
else if (para.infotype == 6)
|
||
{
|
||
retStr += "门磁通讯成功率：" + para.GatemagnetPower + "%,";
|
||
retStr += "PIR1通讯成功率：" + para.pir1Power + "%,";
|
||
retStr += "PIR2通讯成功率：" + para.pir2Power + "%,";
|
||
retStr += "PIR3通讯成功率：" + para.pir3Power + "%,";
|
||
retStr += "PIR4通讯成功率：" + para.pir4Power + "%,";
|
||
retStr += "PIR5通讯成功率：" + para.pir5Power + "%,";
|
||
retStr += "PIR6通讯成功率：" + para.pir6Power + "%,";
|
||
retStr += "PIR7通讯成功率：" + para.pir7Power + "%,";
|
||
retStr += "PIR8通讯成功率：" + para.pir8Power + "%,";
|
||
}
|
||
else if (para.infotype == 7)
|
||
{
|
||
|
||
retStr += "允许最大用电功率：" + para.maxelectricPower + "W,";
|
||
retStr += "保护判定时间：" + para.protectionTime + "s,";
|
||
|
||
}
|
||
|
||
return retStr;
|
||
}
|
||
|
||
public class DeviceStartPara
|
||
{
|
||
public string reason;
|
||
public int verLow;
|
||
public int verHigh;
|
||
public int verHardware;
|
||
public string strHex;
|
||
}
|
||
public static String DeviceStartInfoToString(DeviceStartPara para)
|
||
{
|
||
string retStr = "";
|
||
retStr += "启动原因：" + para.reason + ",";
|
||
retStr += "版本高字节：" + para.verLow + ",";
|
||
retStr += "版本低字节：" + para.verHigh + ",";
|
||
retStr += "硬件版本：" + para.verHardware + ",";
|
||
retStr += "启动异常信息内容：" + para.strHex + ",";
|
||
return retStr;
|
||
}
|
||
//public static string count = "";
|
||
public static String AnalysisByte(string base64Str, string devicename)
|
||
{
|
||
string retStr = "";
|
||
|
||
try
|
||
{
|
||
byte[] btTmp = Convert.FromBase64String(base64Str);
|
||
|
||
|
||
retStr += "原始数据： " + GetHexStringFromByteArray(btTmp) + ",";
|
||
|
||
FixedHeaderPart headerPart = AnalysisFixedHeader(btTmp);
|
||
//0 固定头
|
||
if (btTmp[0] != 0xA6)
|
||
{
|
||
Logger.LogCalloutanaSide("\r,收到一包数据，首字节标志不是0xa6\r,内容为：" + String.Join(",", btTmp));
|
||
return "Error Format !!!";
|
||
}
|
||
|
||
//10 当前取电状态
|
||
string strResult = "";
|
||
headerPart.PowerStatus = btTmp[10];
|
||
if (btTmp[10] == 0x00)
|
||
strResult = "无效";
|
||
else if (btTmp[10] == 0x01)
|
||
strResult = "取电";
|
||
else if (btTmp[10] == 0x02)
|
||
strResult = "断电";
|
||
else
|
||
strResult = "无效值";
|
||
|
||
|
||
retStr += "解包后数据 包序号:" + headerPart.SN + ",";
|
||
//retStr += "timpstamp:" + ConvertTimeStampToDateTime(headerPart.TimeStamp).ToString("yyyy-MM-dd HH:mm:ss") + ".";
|
||
retStr += "length：" + headerPart.LEN + ",";
|
||
//retStr += "check:" + headerPart.CHECK + ".,";
|
||
retStr += "设备当前取电状态:" + strResult + ",";
|
||
|
||
//string yuanshidata = GetHexStringFromByteArray(btTmp);
|
||
//11 命令
|
||
byte[] parab4 = { };
|
||
byte[] btPara = { };
|
||
switch (btTmp[11])
|
||
{
|
||
case 0x01: //设备上报心跳包
|
||
HeartBeatPara para = AnalysisHeartbeatPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备心跳包 ," + HearBeatToString(para);
|
||
break;
|
||
case 0x02: //设备上报门锁动作
|
||
DoorLockActionPara parad = AnalysisDoorlockActionPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备上报门锁动作 , " + DoorLockActionToString(parad);
|
||
|
||
break;
|
||
case 0x03: //设备上报PIR动作
|
||
PIRActionPara paraPIR = AnalysisPIRActionPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备上报PIR动作 , " + PIRActionToString(paraPIR);
|
||
|
||
|
||
break;
|
||
case 0x04: //设备上报定期动作
|
||
IntervalMessagePara paraInt = AnalysisIntervalMessagePara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备定期上报 ," + IntervalMessageToString(paraInt);
|
||
break;
|
||
case 0x05: //设备上报取电动作
|
||
CatchElectricityPara parace = AnalysisCatchElectrPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备取电动作上报 ," + CatchElecToString(parace);
|
||
break;
|
||
case 0x06: //设备请求云端信息
|
||
RequestServerPara parars = AnalysisReqSvrPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备获取云端服务器参数 ," + RequestServerToString(parars);
|
||
break;
|
||
case 0x07: //设备回复服务器设定参数动作
|
||
ServerSetConfigResponsePara parasscr = AnalysisRespOfSvrSetConfigPara(btTmp.Skip(12).ToArray());
|
||
retStr += "云端服务器设置参数 ," + ServerSetConfigResponseToString(parasscr);
|
||
break;
|
||
case 0x08: //设备回复服务器控制取电下发
|
||
//暂时没有参数。
|
||
retStr += "服务器控制取电下发 ,";
|
||
|
||
break;
|
||
case 0x09: //设备回复服务器查询设备消息
|
||
DeviceInfoPara paradv = AnalysisDeviceInfoPara(btTmp.Skip(12).ToArray());
|
||
retStr += "服务器查询设备信息 ," + DeviceInfoResponseToString(paradv);
|
||
break;
|
||
case 0x0C: //设备启动信息
|
||
DeviceStartPara paradvst = AnalysisDeviceStartPara(btTmp.Skip(12).ToArray());
|
||
retStr += "设备启动上报服务器信息 ," + DeviceStartInfoToString(paradvst);
|
||
break;
|
||
case 0x0D: // 获取设备位置信息
|
||
jizhanxx paradvst1 = Obtaindevicelocationinformation(btTmp.Skip(12).ToArray());
|
||
retStr += "获取设备位置信息 ," + jizha(paradvst1);
|
||
if (paradvst1 != null)
|
||
{
|
||
if (paradvst1.infotype == 0)
|
||
{
|
||
string strSqlCmd = "select DeviceName from deviceinformation where `Online`= 1 and DeviceName LIKE " + "'%" + devicename + "%'";
|
||
DataSet ds = new DataSet();
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
string sql = "update deviceinformation set districtinfo = '" + paradvst1.didian + "' where DeviceName = '" + row["DeviceName"] + "'";
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
//var strSqlname = sql;
|
||
cmd.CommandText = sql;
|
||
int retRecAffected = cmd.ExecuteNonQuery();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
case 0x0E://门磁动作上报
|
||
DoorMagneticReport paradvste = DoorMagneticReportinformation(btTmp.Skip(12).ToArray());
|
||
retStr += "门磁动作上报 ," + DoorMagnetic(paradvste);
|
||
|
||
break;
|
||
}
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Logger.LogCalloutanaSide("\r,----------Exception in AnalysisByte-----------\r, Exception: " + ex.ToString());
|
||
}
|
||
|
||
return retStr;
|
||
}
|
||
|
||
public static DoorMagneticReport DoorMagneticReportinformation(byte[] btTmp)
|
||
{
|
||
// public int DoorMagneticOnlineStatues { get; set; }
|
||
//public int DoorMagneticStatues { get; set; }
|
||
//public int DoorMagneticQuantity { get; set; }
|
||
DoorMagneticReport doorMagneticReport = new DoorMagneticReport();
|
||
doorMagneticReport.DoorMagneticOnlineStatues = (int)btTmp[0];
|
||
doorMagneticReport.DoorMagneticStatues = (int)btTmp[1];
|
||
doorMagneticReport.DoorMagneticQuantity = (int)btTmp[2];
|
||
return doorMagneticReport;
|
||
}
|
||
public static string DoorMagnetic(DoorMagneticReport sds)
|
||
{
|
||
//Dictionary<int, string> dicDoorStat = new Dictionary<int, string>();
|
||
//dicDoorStat.Add(1, "开门");
|
||
//dicDoorStat.Add(2, "BLE 版本信息");
|
||
//dicDoorStat.Add(3, "RF 版本信息");
|
||
//dicDoorStat.Add(4, "RF MAC地址信息");
|
||
//dicDoorStat.Add(5, "RF版本信息");
|
||
//dicDoorStat.Add(6, "RF通讯成功率");
|
||
//dicDoorStat.Add(7, "超功率检测判定");
|
||
//string retStr = "";
|
||
string retStr = "";
|
||
retStr += "门磁在线状态:" + sds.DoorMagneticOnlineStatues + ",";
|
||
retStr += "门磁状态:" + sds.DoorMagneticStatues + ",";
|
||
retStr += "门磁电量:" + sds.DoorMagneticQuantity + "%,";
|
||
|
||
return retStr;
|
||
}
|
||
public static FixedHeaderPart AnalysisFixedHeader(byte[] btTmp)
|
||
{
|
||
FixedHeaderPart headerPart = new FixedHeaderPart();
|
||
//0 固定头
|
||
if (btTmp[0] != 0xA6)
|
||
{
|
||
Logger.LogCalloutanaSide("\r,收到一包数据，首字节标志不是0xa6\r,内容为：" + String.Join(",", btTmp));
|
||
return headerPart;
|
||
}
|
||
|
||
headerPart.FixedFlag = 0xA6;
|
||
|
||
//1,2 SN
|
||
byte[] b12 = btTmp.Skip(1).Take(2).ToArray();
|
||
//Array.Reverse(b12); //服务器机器和嵌入式设备都是小端序列
|
||
headerPart.SN = BitConverter.ToUInt16(b12, 0); // 第二个参数表示开始位置
|
||
|
||
//3,4,5,6 时间戳
|
||
headerPart.TimeStamp = BitConverter.ToUInt32(btTmp, 3);
|
||
|
||
//7,8 长度
|
||
byte[] b78 = btTmp.Skip(7).Take(2).ToArray();
|
||
//Array.Reverse(b78); //服务器机器和嵌入式设备都是小端序列
|
||
headerPart.LEN = BitConverter.ToUInt16(b78, 0); // 第二个参数表示开始位置
|
||
|
||
|
||
//9 校验和
|
||
headerPart.CHECK = btTmp[9];
|
||
|
||
//10 当前取电状态
|
||
headerPart.PowerStatus = btTmp[10];
|
||
|
||
headerPart.CMD = btTmp[11];
|
||
|
||
return headerPart;
|
||
}
|
||
|
||
public static HeartBeatPara AnalysisHeartbeatPara(byte[] btPara)
|
||
{
|
||
byte[] parab4 = { };
|
||
HeartBeatPara para = new HeartBeatPara();
|
||
|
||
//0 RSSI值，有符号字节值
|
||
para.RSSI = (sbyte)btPara[0];
|
||
//1234 电压 浮点数
|
||
parab4 = btPara.Skip(1).Take(4).ToArray();
|
||
para.voltage = BitConverter.ToSingle(parab4, 0);
|
||
//5678 功率 浮点数
|
||
parab4 = btPara.Skip(5).Take(4).ToArray();
|
||
para.power = BitConverter.ToSingle(parab4, 0);
|
||
//9101112 能耗 浮点数
|
||
parab4 = btPara.Skip(9).Take(4).ToArray();
|
||
para.energyconsumption = BitConverter.ToSingle(parab4, 0);
|
||
//13 门锁是否在线
|
||
para.doorlockonline = (int)btPara[13];
|
||
//14 门锁在线的话，门的状态
|
||
para.strHexdoorlockstatus = GetHexStringFromByteArray(new byte[] { btPara[14] });
|
||
para.isLockFsfsOn = false;
|
||
if ((btPara[14] & 0x01) == 0x01)
|
||
{
|
||
para.isLockFsfsOn = true;
|
||
}
|
||
para.isLockLowCapIndOn = false;
|
||
if ((btPara[14] & 0x02) == 0x02)
|
||
{
|
||
para.isLockLowCapIndOn = true;
|
||
}
|
||
para.isLockFakIndOn = false;
|
||
if ((btPara[14] & 0x04) == 0x04)
|
||
{
|
||
para.isLockFakIndOn = true;
|
||
}
|
||
|
||
para.doorlockcapacity = (int)btPara[15];
|
||
|
||
return para;
|
||
}
|
||
|
||
public static DoorLockActionPara AnalysisDoorlockActionPara(byte[] btPara)
|
||
{
|
||
DoorLockActionPara parad = new DoorLockActionPara();
|
||
|
||
parad.dooronlinestatus = (int)btPara[0];
|
||
parad.doorstatus = (int)btPara[1];
|
||
parad.doorcapacity = (int)btPara[2];
|
||
|
||
return parad;
|
||
}
|
||
|
||
public static PIRActionPara AnalysisPIRActionPara(byte[] btPara)
|
||
{
|
||
PIRActionPara paraPIR = new PIRActionPara();
|
||
if (btPara.Length > 14)
|
||
{
|
||
paraPIR.PIRAction = (int)btPara[0];
|
||
paraPIR.PIRTotalTriggerTimes = (int)btPara[1];
|
||
paraPIR.PIR1Times = (int)btPara[2];
|
||
paraPIR.PIR2Times = (int)btPara[3];
|
||
paraPIR.PIR3Times = (int)btPara[4];
|
||
paraPIR.PIR4Times = (int)btPara[5];
|
||
paraPIR.PIR1OnlineStatus = (int)btPara[6];
|
||
paraPIR.PIR2OnlineStatus = (int)btPara[7];
|
||
paraPIR.PIR3OnlineStatus = (int)btPara[8];
|
||
paraPIR.PIR4OnlineStatus = (int)btPara[9];
|
||
paraPIR.PIR1Capacity = (int)btPara[10];
|
||
paraPIR.PIR2Capacity = (int)btPara[11];
|
||
paraPIR.PIR3Capacity = (int)btPara[12];
|
||
paraPIR.PIR4Capacity = (int)btPara[13];
|
||
|
||
paraPIR.PIR5Times = (int)btPara[14];
|
||
paraPIR.PIR6Times = (int)btPara[15];
|
||
paraPIR.PIR7Times = (int)btPara[16];
|
||
paraPIR.PIR8Times = (int)btPara[17];
|
||
paraPIR.PIR5OnlineStatus = (int)btPara[18];
|
||
paraPIR.PIR6OnlineStatus = (int)btPara[19];
|
||
paraPIR.PIR7OnlineStatus = (int)btPara[20];
|
||
paraPIR.PIR8OnlineStatus = (int)btPara[21];
|
||
paraPIR.PIR5Capacity = (int)btPara[22];
|
||
paraPIR.PIR6Capacity = (int)btPara[23];
|
||
paraPIR.PIR7Capacity = (int)btPara[24];
|
||
paraPIR.PIR8Capacity = (int)btPara[25];
|
||
|
||
}
|
||
else
|
||
{
|
||
paraPIR.PIRAction = (int)btPara[0];
|
||
paraPIR.PIRTotalTriggerTimes = (int)btPara[1];
|
||
paraPIR.PIR1Times = (int)btPara[2];
|
||
paraPIR.PIR2Times = (int)btPara[3];
|
||
paraPIR.PIR3Times = (int)btPara[4];
|
||
paraPIR.PIR4Times = (int)btPara[5];
|
||
paraPIR.PIR1OnlineStatus = (int)btPara[6];
|
||
paraPIR.PIR2OnlineStatus = (int)btPara[7];
|
||
paraPIR.PIR3OnlineStatus = (int)btPara[8];
|
||
paraPIR.PIR4OnlineStatus = (int)btPara[9];
|
||
paraPIR.PIR1Capacity = (int)btPara[10];
|
||
paraPIR.PIR2Capacity = (int)btPara[11];
|
||
paraPIR.PIR3Capacity = (int)btPara[12];
|
||
paraPIR.PIR4Capacity = (int)btPara[13];
|
||
}
|
||
|
||
|
||
return paraPIR;
|
||
}
|
||
|
||
public static IntervalMessagePara AnalysisIntervalMessagePara(byte[] btPara)
|
||
{
|
||
IntervalMessagePara paraInt = new IntervalMessagePara();
|
||
if (btPara.Length == 40)
|
||
{
|
||
|
||
paraInt.RSSISignal = (sbyte)btPara[0];
|
||
paraInt.CheckV = BitConverter.ToSingle(btPara.Skip(1).Take(4).ToArray(), 0);
|
||
paraInt.CheckP = BitConverter.ToSingle(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
paraInt.Energy = BitConverter.ToSingle(btPara.Skip(9).Take(4).ToArray(), 0);
|
||
paraInt.LockOnlineStatus = (int)btPara[13];
|
||
paraInt.PIR1OnlineStatus = (int)btPara[14];
|
||
paraInt.PIR2OnlineStatus = (int)btPara[15];
|
||
paraInt.PIR3OnlineStatus = (int)btPara[16];
|
||
paraInt.PIR4OnlineStatus = (int)btPara[17];
|
||
paraInt.LockCapacity = (int)btPara[18];
|
||
paraInt.PIR1Capacity = (int)btPara[19];
|
||
paraInt.PIR2Capacity = (int)btPara[20];
|
||
paraInt.PIR3Capacity = (int)btPara[21];
|
||
paraInt.PIR4Capacity = (int)btPara[22];
|
||
paraInt.HearBeatSecond = BitConverter.ToUInt16(btPara, 23);
|
||
paraInt.IntervalMessageSecond = BitConverter.ToUInt16(btPara, 25);
|
||
paraInt.PIRContinueWorkingTime = BitConverter.ToUInt16(btPara, 27);
|
||
paraInt.PIRTriggerTimes = BitConverter.ToUInt16(btPara, 29);
|
||
paraInt.Protocolversionnumber = BitConverter.ToUInt16(btPara, 31);
|
||
//BitConverter.ToUInt16(btPara, 30);
|
||
paraInt.GatemagnetStatus = (int)btPara[33];
|
||
paraInt.GatemagnetCurrentStatus = (int)btPara[34];
|
||
paraInt.GatemagnetCapacity = (int)btPara[35];
|
||
|
||
paraInt.PIR1Frequency = (int)btPara[36];
|
||
|
||
paraInt.PIR2Frequency = (int)btPara[37];
|
||
|
||
paraInt.PIR3Frequency = (int)btPara[38];
|
||
|
||
paraInt.PIR4Frequency = (int)btPara[39];
|
||
}
|
||
else if (btPara.Length > 40)
|
||
{
|
||
|
||
paraInt.RSSISignal = (sbyte)btPara[0];
|
||
paraInt.CheckV = BitConverter.ToSingle(btPara.Skip(1).Take(4).ToArray(), 0);
|
||
paraInt.CheckP = BitConverter.ToSingle(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
paraInt.Energy = BitConverter.ToSingle(btPara.Skip(9).Take(4).ToArray(), 0);
|
||
paraInt.LockOnlineStatus = (int)btPara[13];
|
||
paraInt.PIR1OnlineStatus = (int)btPara[14];
|
||
paraInt.PIR2OnlineStatus = (int)btPara[15];
|
||
paraInt.PIR3OnlineStatus = (int)btPara[16];
|
||
paraInt.PIR4OnlineStatus = (int)btPara[17];
|
||
paraInt.LockCapacity = (int)btPara[18];
|
||
paraInt.PIR1Capacity = (int)btPara[19];
|
||
paraInt.PIR2Capacity = (int)btPara[20];
|
||
paraInt.PIR3Capacity = (int)btPara[21];
|
||
paraInt.PIR4Capacity = (int)btPara[22];
|
||
paraInt.HearBeatSecond = BitConverter.ToUInt16(btPara, 23);
|
||
paraInt.IntervalMessageSecond = BitConverter.ToUInt16(btPara, 25);
|
||
paraInt.PIRContinueWorkingTime = BitConverter.ToUInt16(btPara, 27);
|
||
paraInt.PIRTriggerTimes = BitConverter.ToUInt16(btPara, 29);
|
||
paraInt.Protocolversionnumber = BitConverter.ToUInt16(btPara, 31);
|
||
//BitConverter.ToUInt16(btPara, 30);
|
||
paraInt.GatemagnetStatus = (int)btPara[33];
|
||
paraInt.GatemagnetCurrentStatus = (int)btPara[34];
|
||
paraInt.GatemagnetCapacity = (int)btPara[35];
|
||
|
||
paraInt.PIR1Frequency = (int)btPara[36];
|
||
|
||
paraInt.PIR2Frequency = (int)btPara[37];
|
||
|
||
paraInt.PIR3Frequency = (int)btPara[38];
|
||
|
||
paraInt.PIR4Frequency = (int)btPara[39];
|
||
paraInt.PIR5Frequency = (int)btPara[40];
|
||
|
||
paraInt.PIR6Frequency = (int)btPara[41];
|
||
|
||
paraInt.PIR7Frequency = (int)btPara[42];
|
||
|
||
paraInt.PIR8Frequency = (int)btPara[43];
|
||
|
||
paraInt.PIR5OnlineStatus = (int)btPara[44];
|
||
paraInt.PIR6OnlineStatus = (int)btPara[45];
|
||
paraInt.PIR7OnlineStatus = (int)btPara[46];
|
||
paraInt.PIR8OnlineStatus = (int)btPara[47];
|
||
paraInt.PIR5Capacity = (int)btPara[48];
|
||
paraInt.PIR6Capacity = (int)btPara[49];
|
||
paraInt.PIR7Capacity = (int)btPara[50];
|
||
paraInt.PIR8Capacity = (int)btPara[51];
|
||
|
||
paraInt.Grsrpignal = (sbyte)btPara[52];
|
||
paraInt.csqpignal = (int)btPara[53];
|
||
|
||
}
|
||
else
|
||
{
|
||
|
||
paraInt.RSSISignal = (sbyte)btPara[0];
|
||
paraInt.CheckV = BitConverter.ToSingle(btPara.Skip(1).Take(4).ToArray(), 0);
|
||
paraInt.CheckP = BitConverter.ToSingle(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
paraInt.Energy = BitConverter.ToSingle(btPara.Skip(9).Take(4).ToArray(), 0);
|
||
paraInt.LockOnlineStatus = (int)btPara[13];
|
||
paraInt.PIR1OnlineStatus = (int)btPara[14];
|
||
paraInt.PIR2OnlineStatus = (int)btPara[15];
|
||
paraInt.PIR3OnlineStatus = (int)btPara[16];
|
||
paraInt.PIR4OnlineStatus = (int)btPara[17];
|
||
paraInt.LockCapacity = (int)btPara[18];
|
||
paraInt.PIR1Capacity = (int)btPara[19];
|
||
paraInt.PIR2Capacity = (int)btPara[20];
|
||
paraInt.PIR3Capacity = (int)btPara[21];
|
||
paraInt.PIR4Capacity = (int)btPara[22];
|
||
paraInt.HearBeatSecond = BitConverter.ToUInt16(btPara, 23);
|
||
paraInt.IntervalMessageSecond = BitConverter.ToUInt16(btPara, 25);
|
||
paraInt.PIRContinueWorkingTime = BitConverter.ToUInt16(btPara, 27);
|
||
paraInt.PIRTriggerTimes = BitConverter.ToUInt16(btPara, 29);
|
||
//paraInt.Protocolversionnumber = BitConverter.ToUInt16(btPara, 30);
|
||
//paraInt.GatemagnetStatus = (int)btPara[32];
|
||
|
||
//paraInt.GatemagnetCapacity = (int)btPara[33];
|
||
|
||
//paraInt.PIR1Frequency = (int)btPara[34];
|
||
|
||
//paraInt.PIR2Frequency = (int)btPara[35];
|
||
|
||
//paraInt.PIR3Frequency = (int)btPara[36];
|
||
|
||
//paraInt.PIR4Frequency = (int)btPara[37];
|
||
}
|
||
|
||
|
||
// public int Protocolversionnumber { get; set; }
|
||
//public int GatemagnetStatus { get; set; }
|
||
|
||
//public int GatemagnetCapacity { get; set; }
|
||
//public int PIR1Frequency { get; set; }
|
||
//public int PIR2Frequency { get; set; }
|
||
//public int PIR3Frequency { get; set; }
|
||
//public int PIR4Frequency { get; set; }
|
||
|
||
|
||
|
||
|
||
return paraInt;
|
||
}
|
||
|
||
public static CatchElectricityPara AnalysisCatchElectrPara(byte[] btPara)
|
||
{
|
||
CatchElectricityPara parace = new CatchElectricityPara();
|
||
|
||
parace.action = (int)btPara[0];
|
||
|
||
return parace;
|
||
}
|
||
|
||
public static RequestServerPara AnalysisReqSvrPara(byte[] btPara)
|
||
{
|
||
RequestServerPara parars = new RequestServerPara();
|
||
parars.paratype = (int)btPara[0];
|
||
return parars;
|
||
}
|
||
|
||
public static ServerSetConfigResponsePara AnalysisRespOfSvrSetConfigPara(byte[] btPara)
|
||
{
|
||
ServerSetConfigResponsePara parasscr = new ServerSetConfigResponsePara();
|
||
parasscr.downparatype = (int)btPara[0];
|
||
parasscr.downresult = (int)btPara[1];
|
||
return parasscr;
|
||
}
|
||
|
||
public static DeviceInfoPara AnalysisDeviceInfoPara(byte[] btPara)
|
||
{
|
||
|
||
DeviceInfoPara paradv = new DeviceInfoPara();
|
||
if (btPara.Length > 39)
|
||
{
|
||
paradv.infotype = (int)btPara[0];
|
||
if (paradv.infotype == 1)//4G模块
|
||
{
|
||
paradv.md4gsoftverlow = (int)btPara[1];
|
||
paradv.md4gsoftverhigh = (int)btPara[2];
|
||
paradv.md4ghardver = (int)btPara[3];
|
||
paradv.md4gIMEI = System.Text.Encoding.UTF8.GetString(btPara.Skip(4).Take(15).ToArray());
|
||
paradv.md4gSIMICCID = System.Text.Encoding.UTF8.GetString(btPara.Skip(19).Take(20).ToArray());
|
||
paradv.Mdoapte = (int)btPara[39];
|
||
paradv.Dmdopoffe = (int)btPara[40];
|
||
paradv.IntervalMessageSecond = BitConverter.ToUInt16(btPara, 41);
|
||
paradv.Grsrpignal = (sbyte)btPara[43];
|
||
paradv.csqpignal = (int)btPara[44];
|
||
|
||
//
|
||
//
|
||
//
|
||
}
|
||
else if (paradv.infotype == 2)//BLE version
|
||
{
|
||
|
||
paradv.blesoftverlow = (int)btPara[1];
|
||
paradv.blesoftverhigh = (int)btPara[2];
|
||
paradv.blehardver = (int)btPara[3];
|
||
paradv.bleMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 3)//RF version
|
||
{
|
||
|
||
paradv.pirsoftverlow = (int)btPara[1];
|
||
paradv.pirsoftverhigh = (int)btPara[2];
|
||
paradv.pirhardver = (int)btPara[3];
|
||
paradv.pirMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 4)//RF MAC
|
||
{
|
||
|
||
paradv.lockMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(1).Take(6).ToArray());
|
||
paradv.pir1MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(7).Take(6).ToArray());
|
||
paradv.pir2MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(13).Take(6).ToArray());
|
||
paradv.pir3MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(19).Take(6).ToArray());
|
||
paradv.pir4MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(25).Take(6).ToArray());
|
||
paradv.GatemagnetMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(31).Take(6).ToArray());
|
||
paradv.pir5MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(37).Take(6).ToArray());
|
||
paradv.pir6MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(43).Take(6).ToArray());
|
||
paradv.pir7MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(49).Take(6).ToArray());
|
||
paradv.pir8MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(55).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 5) //查询RF设备版本信息
|
||
{
|
||
|
||
paradv.Gatemagnetgsoftverlow = (int)btPara[1];
|
||
paradv.Gatemagnetgsoftverhigh = (int)btPara[2];
|
||
paradv.Gatemagnetghardver = (int)btPara[3];
|
||
paradv.pir1gsoftverlow = (int)btPara[4];
|
||
paradv.pir1gsoftverhigh = (int)btPara[5];
|
||
paradv.pir1ghardver = (int)btPara[6];
|
||
paradv.pir2gsoftverlow = (int)btPara[7];
|
||
paradv.pir2gsoftverhigh = (int)btPara[8];
|
||
paradv.pir2ghardver = (int)btPara[9];
|
||
paradv.pir3gsoftverlow = (int)btPara[10];
|
||
paradv.pir3gsoftverhigh = (int)btPara[11];
|
||
paradv.pir3ghardver = (int)btPara[12];
|
||
paradv.pir4gsoftverlow = (int)btPara[13];
|
||
paradv.pir4gsoftverhigh = (int)btPara[14];
|
||
paradv.pir4ghardver = (int)btPara[15];
|
||
paradv.pir5gsoftverlow = (int)btPara[16];
|
||
paradv.pir5gsoftverhigh = (int)btPara[17];
|
||
paradv.pir5ghardver = (int)btPara[18];
|
||
paradv.pir6gsoftverlow = (int)btPara[19];
|
||
paradv.pir6gsoftverhigh = (int)btPara[20];
|
||
paradv.pir6ghardver = (int)btPara[21];
|
||
paradv.pir7gsoftverlow = (int)btPara[22];
|
||
paradv.pir7gsoftverhigh = (int)btPara[23];
|
||
paradv.pir7ghardver = (int)btPara[24];
|
||
paradv.pir8gsoftverlow = (int)btPara[25];
|
||
paradv.pir8gsoftverhigh = (int)btPara[26];
|
||
paradv.pir8ghardver = (int)btPara[27];
|
||
}
|
||
else if (paradv.infotype == 6)//查询RF及门磁设备通讯成功率
|
||
{
|
||
|
||
paradv.GatemagnetPower = (int)btPara[1];
|
||
paradv.pir1Power = (int)btPara[2];
|
||
paradv.pir2Power = (int)btPara[3];
|
||
paradv.pir3Power = (int)btPara[4];
|
||
paradv.pir4Power = (int)btPara[5];
|
||
paradv.pir5Power = (int)btPara[6];
|
||
paradv.pir6Power = (int)btPara[7];
|
||
paradv.pir7Power = (int)btPara[8];
|
||
paradv.pir8Power = (int)btPara[9];
|
||
}
|
||
else if (paradv.infotype == 7) //超功率检测判定
|
||
{
|
||
|
||
paradv.maxelectricPower = (int)BitConverter.ToUInt32(btPara.Skip(1).Take(4).ToArray(), 0);
|
||
paradv.protectionTime = (int)BitConverter.ToUInt32(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
paradv.infotype = (int)btPara[0];
|
||
if (paradv.infotype == 1)//4G模块
|
||
{
|
||
paradv.md4gsoftverlow = (int)btPara[1];
|
||
paradv.md4gsoftverhigh = (int)btPara[2];
|
||
paradv.md4ghardver = (int)btPara[3];
|
||
paradv.md4gIMEI = System.Text.Encoding.UTF8.GetString(btPara.Skip(4).Take(15).ToArray());
|
||
paradv.md4gSIMICCID = System.Text.Encoding.UTF8.GetString(btPara.Skip(19).Take(20).ToArray());
|
||
}
|
||
else if (paradv.infotype == 2)//BLE version
|
||
{
|
||
|
||
paradv.blesoftverlow = (int)btPara[1];
|
||
paradv.blesoftverhigh = (int)btPara[2];
|
||
paradv.blehardver = (int)btPara[3];
|
||
paradv.bleMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 3)//RF version
|
||
{
|
||
|
||
paradv.pirsoftverlow = (int)btPara[1];
|
||
paradv.pirsoftverhigh = (int)btPara[2];
|
||
paradv.pirhardver = (int)btPara[3];
|
||
paradv.pirMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 4)//RF MAC
|
||
{
|
||
|
||
paradv.lockMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(1).Take(6).ToArray());
|
||
paradv.pir1MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(7).Take(6).ToArray());
|
||
paradv.pir2MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(13).Take(6).ToArray());
|
||
paradv.pir3MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(19).Take(6).ToArray());
|
||
paradv.pir4MAC = GetHexStringFromByteArrayForMAC(btPara.Skip(25).Take(6).ToArray());
|
||
paradv.GatemagnetMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(31).Take(6).ToArray());
|
||
|
||
}
|
||
else if (paradv.infotype == 5) //查询RF设备版本信息
|
||
{
|
||
if (btPara.Length == 16)
|
||
{
|
||
paradv.Gatemagnetgsoftverlow = (int)btPara[1];
|
||
paradv.Gatemagnetgsoftverhigh = (int)btPara[2];
|
||
paradv.Gatemagnetghardver = (int)btPara[3];
|
||
paradv.pir1gsoftverlow = (int)btPara[4];
|
||
paradv.pir1gsoftverhigh = (int)btPara[5];
|
||
paradv.pir1ghardver = (int)btPara[6];
|
||
paradv.pir2gsoftverlow = (int)btPara[7];
|
||
paradv.pir2gsoftverhigh = (int)btPara[8];
|
||
paradv.pir2ghardver = (int)btPara[9];
|
||
paradv.pir3gsoftverlow = (int)btPara[10];
|
||
paradv.pir3gsoftverhigh = (int)btPara[11];
|
||
paradv.pir3ghardver = (int)btPara[12];
|
||
paradv.pir4gsoftverlow = (int)btPara[13];
|
||
paradv.pir4gsoftverhigh = (int)btPara[14];
|
||
paradv.pir4ghardver = (int)btPara[15];
|
||
|
||
}
|
||
else
|
||
{
|
||
paradv.Gatemagnetgsoftverlow = (int)btPara[1];
|
||
paradv.Gatemagnetgsoftverhigh = (int)btPara[2];
|
||
paradv.Gatemagnetghardver = (int)btPara[3];
|
||
paradv.pir1gsoftverlow = (int)btPara[4];
|
||
paradv.pir1gsoftverhigh = (int)btPara[5];
|
||
paradv.pir1ghardver = (int)btPara[6];
|
||
paradv.pir2gsoftverlow = (int)btPara[7];
|
||
paradv.pir2gsoftverhigh = (int)btPara[8];
|
||
paradv.pir2ghardver = (int)btPara[9];
|
||
paradv.pir3gsoftverlow = (int)btPara[10];
|
||
paradv.pir3gsoftverhigh = (int)btPara[11];
|
||
paradv.pir3ghardver = (int)btPara[12];
|
||
paradv.pir4gsoftverlow = (int)btPara[13];
|
||
paradv.pir4gsoftverhigh = (int)btPara[14];
|
||
paradv.pir4ghardver = (int)btPara[15];
|
||
paradv.pir5gsoftverlow = (int)btPara[16];
|
||
paradv.pir5gsoftverhigh = (int)btPara[17];
|
||
paradv.pir5ghardver = (int)btPara[18];
|
||
paradv.pir6gsoftverlow = (int)btPara[19];
|
||
paradv.pir6gsoftverhigh = (int)btPara[20];
|
||
paradv.pir6ghardver = (int)btPara[21];
|
||
paradv.pir7gsoftverlow = (int)btPara[22];
|
||
paradv.pir7gsoftverhigh = (int)btPara[23];
|
||
paradv.pir7ghardver = (int)btPara[24];
|
||
paradv.pir8gsoftverlow = (int)btPara[25];
|
||
paradv.pir8gsoftverhigh = (int)btPara[26];
|
||
paradv.pir8ghardver = (int)btPara[27];
|
||
}
|
||
|
||
}
|
||
else if (paradv.infotype == 6)//查询RF及门磁设备通讯成功率
|
||
{
|
||
|
||
paradv.GatemagnetPower = (int)btPara[1];
|
||
paradv.pir1Power = (int)btPara[2];
|
||
paradv.pir2Power = (int)btPara[3];
|
||
paradv.pir3Power = (int)btPara[4];
|
||
paradv.pir4Power = (int)btPara[5];
|
||
paradv.pir5Power = (int)btPara[6];
|
||
paradv.pir6Power = (int)btPara[7];
|
||
paradv.pir7Power = (int)btPara[8];
|
||
paradv.pir8Power = (int)btPara[9];
|
||
}
|
||
else if (paradv.infotype == 7) //超功率检测判定
|
||
{
|
||
|
||
paradv.maxelectricPower = (int)BitConverter.ToUInt32(btPara.Skip(1).Take(4).ToArray(), 0);
|
||
paradv.protectionTime = (int)BitConverter.ToUInt32(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
}
|
||
}
|
||
|
||
return paradv;
|
||
}
|
||
|
||
public static DeviceStartPara AnalysisDeviceStartPara(byte[] btPara)
|
||
{
|
||
Dictionary<int, string> res = new Dictionary<int, string>();
|
||
res.Add(0, "上电开机");
|
||
res.Add(1, "充电或者AT指令下载完成后开机");
|
||
res.Add(2, "闹钟开机");
|
||
res.Add(3, "软件重启");
|
||
res.Add(4, "未知原因");
|
||
res.Add(5, "Reset键");
|
||
res.Add(6, "异常重启");
|
||
res.Add(7, "工具控制重启");
|
||
res.Add(8, "内部看门狗重启");
|
||
res.Add(9, "外部重启");
|
||
res.Add(10, "充电开机");
|
||
DeviceStartPara paradv = new DeviceStartPara();
|
||
int iRes = (int)btPara[0];
|
||
paradv.reason = res[iRes];
|
||
paradv.verLow = (int)btPara[1];
|
||
//GetHexStringFromByteArray(btPara.Skip(1).Take(1).ToArray());
|
||
paradv.verHigh = (int)btPara[2];
|
||
//GetHexStringFromByteArray(btPara.Skip(2).Take(1).ToArray());
|
||
paradv.verHardware = (int)btPara[3];
|
||
paradv.strHex = System.Text.Encoding.UTF8.GetString(btPara.Skip(4).ToArray());
|
||
//byte[] byteArray = System.Text.Encoding.Default.GetBytes(strHex);
|
||
//= System.Text.Encoding.UTF8.GetString(byteArray);
|
||
return paradv;
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
//// P1 ~P4：经度(浮点数)
|
||
////P5 ~P8：纬度(浮点数)
|
||
////P9 ~P12：当前服务小区的ECI（整数）
|
||
////P13 ~P16：当前服务小区的TAC(整数)
|
||
////P17 ~P20：当前服务小区的eNBID(整数)
|
||
|
||
|
||
|
||
//public class jizhanxx
|
||
//{
|
||
// public int infotype { get; set; }
|
||
// //经度
|
||
// public float longitude { get; set; }
|
||
// //纬度
|
||
// public float latitude { get; set; }
|
||
// public int ECI { get; set; }
|
||
// public int TAC { get; set; }
|
||
// public int eNBID { get; set; }
|
||
//}
|
||
public static jizhanxx Obtaindevicelocationinformation(byte[] btPara)
|
||
{
|
||
jizhanxx paradv = new jizhanxx();
|
||
paradv.infotype = (int)btPara[0];
|
||
if (paradv.infotype == 0)//获取经纬度及当前连接基站信息
|
||
{
|
||
byte[] b12 = btPara.Skip(1).Take(4).ToArray();
|
||
BitConverter.ToSingle(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
// 1 2 3 4
|
||
paradv.longitude = BitConverter.ToSingle(b12, 0);
|
||
// 5 6 7 8
|
||
paradv.latitude = BitConverter.ToSingle(btPara.Skip(5).Take(4).ToArray(), 0);
|
||
//(float)BitConverter.ToUInt32(btPara, 5);
|
||
//9 10 11 12
|
||
paradv.ECI = (int)BitConverter.ToUInt32(btPara.Skip(9).Take(4).ToArray(), 0);
|
||
// 13 14 15 16
|
||
paradv.TAC = (int)BitConverter.ToUInt32(btPara.Skip(13).Take(4).ToArray(), 0);
|
||
// 17 18 19 20
|
||
paradv.eNBID = (int)BitConverter.ToUInt32(btPara.Skip(17).Take(4).ToArray(), 0);
|
||
|
||
}
|
||
else if (paradv.infotype == 1)//获取附件基站信息
|
||
{
|
||
byte[] b12 = btPara.Skip(1).ToArray();
|
||
|
||
paradv.jizhaninfo = System.Text.Encoding.UTF8.GetString(b12);
|
||
//paradv.blesoftverlow = (int)btPara[1];
|
||
//paradv.blesoftverhigh = (int)btPara[2];
|
||
//paradv.blehardver = (int)btPara[3];
|
||
//paradv.bleMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
else if (paradv.infotype == 2)//更新位置信息
|
||
{
|
||
paradv.jizhaninfo = "更新位置信息中";
|
||
//paradv.pirsoftv
|
||
//paradv.pirsoftverhigh = (int)btPara[2];
|
||
//paradv.pirhardver = (int)btPara[3];
|
||
//paradv.pirMAC = GetHexStringFromByteArrayForMAC(btPara.Skip(4).Take(6).ToArray());
|
||
}
|
||
return paradv;
|
||
|
||
}
|
||
public static string jizha(jizhanxx jizhanxx)
|
||
{
|
||
|
||
string retStr = "";
|
||
|
||
if (jizhanxx.infotype == 0)
|
||
{
|
||
retStr += "经度：" + jizhanxx.longitude + ",";
|
||
retStr += "纬度：" + jizhanxx.latitude + ",";
|
||
retStr += "当前服务小区的ECI：" + jizhanxx.ECI + ",";
|
||
retStr += "当前服务小区的TAC：" + jizhanxx.TAC + ",";
|
||
retStr += "当前服务小区的eNBID：" + jizhanxx.eNBID + ",";
|
||
string didian = Obtainlocationinformations(jizhanxx);
|
||
retStr += "位置：" + didian + ",";
|
||
jizhanxx.didian = didian;
|
||
}
|
||
else if (jizhanxx.infotype == 1)
|
||
{
|
||
retStr += "基站信息：" + jizhanxx.jizhaninfo + ",";
|
||
}
|
||
else
|
||
{
|
||
retStr += "更新信息：" + jizhanxx.jizhaninfo + ",";
|
||
}
|
||
|
||
|
||
|
||
return retStr;
|
||
}
|
||
|
||
|
||
|
||
public static string GetHexStringFromByteArrayForMAC(byte[] byteArr)
|
||
{
|
||
StringBuilder sb = new StringBuilder();
|
||
for (int i = 0; i < byteArr.Length; i++)
|
||
{
|
||
sb.Append(byteArr[i].ToString("X2") + ":");
|
||
}
|
||
|
||
return sb.ToString();
|
||
}
|
||
public static string GetHexStringFromByteArray(byte[] byteArr)
|
||
{
|
||
StringBuilder sb = new StringBuilder();
|
||
for (int i = 0; i < byteArr.Length; i++)
|
||
{
|
||
sb.Append(byteArr[i].ToString("X2") + " ");
|
||
}
|
||
|
||
return sb.ToString();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 转换时间戳为C#时间
|
||
/// </summary>
|
||
/// <param name="timeStamp">时间戳 单位：毫秒</param>
|
||
/// <returns>C#时间</returns>
|
||
public static DateTime ConvertTimeStampToDateTime(long timeStamp)
|
||
{
|
||
DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); // 当地时区
|
||
DateTime dt = startTime.AddSeconds(timeStamp);
|
||
return dt;
|
||
}
|
||
//GetAllCallinRecordBYName
|
||
|
||
|
||
private static DataSet GetAllCallinRecordBYName(string Name, int zhant)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
string strSqlCmd = "";
|
||
if (!string.IsNullOrEmpty(Name) && zhant != -1)
|
||
{
|
||
strSqlCmd = "select * from deviceinformation where DeviceName LIKE " + "'%" + Name + "%'" + "and Online = " + zhant;
|
||
}
|
||
else if (!string.IsNullOrEmpty(Name) && zhant == -1)
|
||
{
|
||
strSqlCmd = "select * from deviceinformation where DeviceName LIKE " + "'%" + Name + "%'";
|
||
//strSqlCmd = "select deviceinformation.DeviceName,Online,districtinfo, `timestamp` from deviceinformation left JOIN devicestate on deviceinformation.DeviceName = devicestate.deviceName where deviceinformation.DeviceName LIKE " + "'%" + Name + "%'";
|
||
}
|
||
else if (string.IsNullOrEmpty(Name) && zhant != -1)
|
||
{
|
||
//strSqlCmd = "select deviceinformation.DeviceName,Online,districtinfo, `timestamp` from deviceinformation left JOIN devicestate on deviceinformation.DeviceName = devicestate.deviceName where deviceinformation.Online=" + zhant;
|
||
strSqlCmd = "select * from deviceinformation where Online=" + zhant;
|
||
}
|
||
else
|
||
{
|
||
//strSqlCmd = "select deviceinformation.DeviceName,Online,districtinfo, timestamp from deviceinformation left JOIN devicestate on deviceinformation.DeviceName = devicestate.deviceName";
|
||
strSqlCmd = "select * from deviceinformation";
|
||
}
|
||
try
|
||
{
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
private static DataSet GetAllCallinRecordBYTime(string productid, string devicename, int shijian)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
DateTime time = new DateTime();
|
||
|
||
if (shijian == 1)
|
||
{
|
||
time = DateTime.Now.AddHours(-1);
|
||
}
|
||
else if (shijian == 2)
|
||
{
|
||
time = DateTime.Now.AddHours(-2);
|
||
}
|
||
else if (shijian == 3)
|
||
{
|
||
time = DateTime.Now.AddHours(-5);
|
||
}
|
||
else if (shijian == 4)
|
||
{
|
||
time = DateTime.Now.AddMinutes(-30);
|
||
}
|
||
else if (shijian == -1)
|
||
{
|
||
time = DateTime.Now.AddSeconds(-60);
|
||
}
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
int timeStamp = Convert.ToInt32((time - dateStart).TotalSeconds);
|
||
string strSqlCmd = "SELECT timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + timeStamp + "' and devicename='" + devicename + "' ORDER BY timestamp DESC";
|
||
try
|
||
{
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
|
||
|
||
private static DataSet GetAllCallinRecordBYTime(string devicename)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
long kstime;
|
||
long jstime;
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
|
||
DateTime jieshu = DateTime.Now.AddDays(-7);
|
||
kstime = Convert.ToInt64((jieshu - dateStart).TotalSeconds);
|
||
//person = person.Where(x => x.timestamp >= kstime).OrderByDescending(x => x.timestamp).ToList();
|
||
|
||
string strSqlCmd = "SELECT id, timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where devicename='" + devicename + "' and timestamp>=" + kstime + " ORDER BY timemills DESC";
|
||
|
||
try
|
||
{
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
private static DataSet GetAllCallinRecord()
|
||
{
|
||
DataSet ds = new DataSet();
|
||
|
||
//string strSqlCmd = "SELECT timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo ORDER BY timestamp DESC";
|
||
string strSqlCmd = "select DeviceName,Online,districtinfo,LastUpdateTime from deviceinformation where `Online`= 1 ";
|
||
try
|
||
{
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
public static void ClearAllCallinRecord()
|
||
{
|
||
DataSet ds = new DataSet();
|
||
|
||
//DELETE FROM table_name
|
||
//WHERE[condition];
|
||
|
||
string strSqlCmd = "DELETE FROM uploginfo";
|
||
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
using (MySqlCommand cmd = new MySqlCommand(strSqlCmd))
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(cmd);
|
||
|
||
command.Fill(ds);
|
||
|
||
}
|
||
}
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
public static void InsertCallin(JObject mqttmessage)
|
||
{
|
||
|
||
string strSqlCmd = "INSERT INTO uploginfo ( productid, devicename, topic, payload, seq, timestamp, timemills, timeappreceive) "
|
||
+ "VALUES('" + mqttmessage["productid"] + "','"
|
||
+ mqttmessage["devicename"] + "', '"
|
||
+ mqttmessage["topic"] + "', '"
|
||
+ mqttmessage["payload"] + "', '"
|
||
+ mqttmessage["seq"] + "', '"
|
||
+ mqttmessage["timestamp"] + "', '"
|
||
+ mqttmessage["timemills"] + "', '"
|
||
+ DateTime.Now.ToString() + "')";
|
||
|
||
try
|
||
{
|
||
//var UserlogList1 = dalHelperCustom.DataRowToModels(dataSetes.Tables[0]);
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
var strSql = strSqlCmd;
|
||
cmd.CommandText = strSql;
|
||
cmd.ExecuteNonQuery();
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//Logger.LogDownSide("in exception; sql is: " + strSqlCmd);
|
||
//Logger.LogDownSide("in exception; exception is: " + ex.ToString());
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
|
||
}
|
||
|
||
|
||
|
||
public static DataSet QueryCm6TSP()
|
||
{
|
||
DataSet ds = new DataSet();
|
||
|
||
string strSqlCmd = "SELECT configValue FROM config where configName='cmd6tsp'";
|
||
|
||
try
|
||
{
|
||
SQLiteConnection conn = new SQLiteConnection(strSqliteConn);
|
||
conn.Open();
|
||
SQLiteCommand command = new SQLiteCommand(strSqlCmd, conn);
|
||
SQLiteDataAdapter adapter = new SQLiteDataAdapter(command);
|
||
adapter.Fill(ds);
|
||
conn.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
|
||
|
||
}
|
||
public static void UpdateCm6TSP(string strNewValue)
|
||
{
|
||
string strSqlCmd = "UPDATE config SET configValue = '" + strNewValue + "' WHERE configName='cmd6tsp';";
|
||
|
||
|
||
try
|
||
{
|
||
SQLiteConnection conn = new SQLiteConnection(strSqliteConn);
|
||
conn.Open();
|
||
SQLiteCommand command = new SQLiteCommand(strSqlCmd, conn);
|
||
int retRecAffected = command.ExecuteNonQuery();
|
||
conn.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//Logger.LogDownSide("in exception; sql is: " + strSqlCmd);
|
||
//Logger.LogDownSide("in exception; exception is: " + ex.ToString());
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// api:https://restapi.amap.com/v3/geocode/regeo?key=2ed117b3dff55516d969e48fb78bda04" + "&location=" + paradv.longitude + "," + paradv.latitude访问次数一天5000次
|
||
/// 如果超过则会报错
|
||
/// </summary>
|
||
/// <param name="paradv"></param>
|
||
/// <returns></returns>
|
||
public static string Obtainlocationinformations(jizhanxx paradv)
|
||
{
|
||
string Wzdsad = "";
|
||
try
|
||
{
|
||
|
||
string url = "https://restapi.amap.com/v3/geocode/regeo?key=2ed117b3dff55516d969e48fb78bda04" + "&location=" + paradv.longitude + "," + paradv.latitude;
|
||
var request = (HttpWebRequest)WebRequest.Create(url);
|
||
var response = (HttpWebResponse)request.GetResponse();
|
||
var responseString = new StreamReader(response.GetResponseStream()).ReadToEnd();
|
||
//超过访问次数的报错位置
|
||
WZ shujiu = JsonConvert.DeserializeObject<WZ>(responseString);
|
||
Wzdsad = shujiu.regeocode.addressComponent.country
|
||
+ shujiu.regeocode.addressComponent.province
|
||
+ shujiu.regeocode.addressComponent.city
|
||
+ shujiu.regeocode.addressComponent.district
|
||
+ shujiu.regeocode.addressComponent.township
|
||
+ shujiu.regeocode.addressComponent.streetNumber.street;
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine(ex);
|
||
}
|
||
return Wzdsad;
|
||
}
|
||
/// <summary>
|
||
/// 设备状态填写数据库
|
||
/// </summary>
|
||
/// <param name="mqttmessage"></param>
|
||
public static void InsertState(JObject mqttmessage)
|
||
{
|
||
try
|
||
{
|
||
string ip = "";
|
||
|
||
// 获取所有网络接口
|
||
NetworkInterface[] interfaces = NetworkInterface.GetAllNetworkInterfaces();
|
||
|
||
// 遍历每个网络接口
|
||
foreach (NetworkInterface networkInterface in interfaces)
|
||
{
|
||
// 获取IP地址
|
||
IPInterfaceProperties ipProperties = networkInterface.GetIPProperties();
|
||
UnicastIPAddressInformationCollection ipAddresses = ipProperties.UnicastAddresses;
|
||
|
||
// 遍历每个IP地址
|
||
foreach (UnicastIPAddressInformation ipAddress in ipAddresses)
|
||
{
|
||
// 判断是否为IPv4地址
|
||
if (ipAddress.Address.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
|
||
{
|
||
//过滤本地ip
|
||
if (ipAddress.Address.ToString() != "127.0.0.1")
|
||
{
|
||
//局域网ip
|
||
ip = ipAddress.Address.ToString();
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
deviceState dds = JsonConvert.DeserializeObject<deviceState>(mqttmessage.ToString());
|
||
//Logger.LogCalloutanaSide("InsertState:__________________" + dds.payload.@event);
|
||
string strSqlCmd = "insert into devicestate(devicename,eventName,productid,reason,timestamp,topic,seq,timemills,ctime) value(";
|
||
strSqlCmd += "'" + dds.devicename + "',";
|
||
strSqlCmd += "'" + dds.payload.@event + "',";
|
||
strSqlCmd += "'" + dds.productID + "',";
|
||
strSqlCmd += "'" + dds.payload.reason + "',";
|
||
strSqlCmd += "'" + dds.timestamp + "',";
|
||
strSqlCmd += "'" + dds.topic + "',";
|
||
strSqlCmd += "'" + dds.seq + "',";
|
||
strSqlCmd += "'" + dds.timemills + "',";
|
||
strSqlCmd += "'" + DateTime.Now + "')";
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
var strSql = strSqlCmd;
|
||
cmd.CommandText = strSql;
|
||
int retRecAffected = cmd.ExecuteNonQuery();
|
||
}
|
||
}
|
||
strSqlCmd = "select DeviceName from deviceinformation where DeviceName = " + "'" + dds.devicename + "'";
|
||
DataSet ds = new DataSet();
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
string sql = "";
|
||
string sqls = "";
|
||
if (dds.payload.@event == "EV_OFFLINE")
|
||
{
|
||
sql = "update deviceinformation set Online = " + 0 + " where DeviceName = '" + row["DeviceName"] + "'";
|
||
sqls = "insert into programeventlog(eventname,modifycontent,Online,ip,ctime) value(";
|
||
sqls += "'腾讯云推送单个设备状态，修改本地设备状态',";
|
||
sqls += "'" + row["DeviceName"] + "',";
|
||
sqls += 0 + ",";
|
||
sqls += "'" + ip + "',";
|
||
sqls += "'" + DateTime.Now + "')";
|
||
}
|
||
else
|
||
{
|
||
sql = "update deviceinformation set Online = " + 1 + " where DeviceName = '" + row["DeviceName"] + "'";
|
||
sqls = "insert into programeventlog(eventname,modifycontent,Online,ip,ctime) value(";
|
||
sqls += "'腾讯云推送单个设备状态，修改本地设备状态',";
|
||
sqls += "'" + row["DeviceName"] + "',";
|
||
sqls += 1 + ",";
|
||
sqls += "'" + ip + "',";
|
||
sqls += "'" + DateTime.Now + "')";
|
||
}
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
//var strSqlname = sql;
|
||
cmd.CommandText = sql;
|
||
int retRecAffected = cmd.ExecuteNonQuery();
|
||
}
|
||
}
|
||
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
cmd.CommandText = sqls;
|
||
int retRecAffected = cmd.ExecuteNonQuery();
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Logger.LogCalloutanaSide("InsertState:__________________" + ex);
|
||
|
||
}
|
||
|
||
}
|
||
|
||
public static List<string> GetSelectStatus(string productid, string devicename, string times, string Statuss)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
|
||
string curline = "";
|
||
DataSet ds = new DataSet();
|
||
//if (string.IsNullOrEmpty(Name))
|
||
//{
|
||
// ds = GetAllCallinRecord();
|
||
//}
|
||
//else
|
||
//{
|
||
ds = GetAllSelectStatus(productid, devicename, times, Statuss);
|
||
//}
|
||
|
||
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
curline = "";
|
||
curline += "deviceName:" + row["deviceName"] + ",";
|
||
curline += "eventName:" + row["eventName"] + ",";
|
||
curline += "seq:" + row["seq"] + ",";
|
||
curline += "timemills:" + row["timemills"] + ",";
|
||
curline += "reason:" + row["reason"] + ",";
|
||
curline += "id:" + row["id"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
return listRet;
|
||
}
|
||
|
||
private static DataSet GetAllSelectStatus(string productid, string devicename, string times, string Statuss)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
string strSqlCmd = "";
|
||
if (string.IsNullOrEmpty(times) || string.IsNullOrEmpty(Statuss))
|
||
{
|
||
|
||
strSqlCmd = "Select * from devicestate where deviceName = '" + devicename + "' ORDER BY id DESC";
|
||
}
|
||
else if (times == "null" || Statuss == "null")
|
||
{
|
||
strSqlCmd = "Select * from devicestate where deviceName = '" + devicename + "' ORDER BY id DESC";
|
||
}
|
||
else
|
||
{
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
DateTime stimes = Convert.ToDateTime(times);
|
||
DateTime etimes = Convert.ToDateTime(Statuss);
|
||
int kstime = Convert.ToInt32((stimes - dateStart).TotalSeconds);
|
||
int jstime = Convert.ToInt32((etimes - dateStart).TotalSeconds);
|
||
strSqlCmd = "Select * from devicestate where deviceName = '" + devicename + "' and timestamp >='" + kstime + "' and timestamp<='" + jstime + "' ORDER BY id DESC";
|
||
}
|
||
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
//SQLiteConnection conn = new SQLiteConnection(strSqliteConn);
|
||
//conn.Open();
|
||
//SQLiteCommand command = new SQLiteCommand(strSqlCmd, conn);
|
||
//SQLiteDataAdapter adapter = new SQLiteDataAdapter(command);
|
||
//adapter.Fill(ds);
|
||
//conn.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
//方法重载GetSelectStatus
|
||
public static List<string> GetSelectStatus(string productid, string devicename)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
|
||
string curline = "";
|
||
DataSet ds = new DataSet();
|
||
ds = GetAllSelectStatus(productid, devicename);
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
curline = "";
|
||
curline += "eventName:" + row["eventName"] + ",";
|
||
curline += "shul:" + row["shul"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
return listRet;
|
||
}
|
||
//方法重载GetAllSelectStatus
|
||
private static DataSet GetAllSelectStatus(string productid, string devicename)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
string strSqlCmd = "select eventName, count(eventName) as shul from devicestate where deviceName = '" + devicename + "' GROUP BY eventName";
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
public static List<string> GetLOGCallin(string productid, string devicename)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
//DataSet ds = new DataSet();
|
||
string cachedata = RedisDBHelper.StringGet("mqttTopicMessage" + devicename, 1);
|
||
//using Newtonsoft.Json;
|
||
|
||
//// 将JSON字符串转换为对象
|
||
//string jsonString = "{\"Name\":\"John\",\"Age\":30}";
|
||
try
|
||
{
|
||
List<MqttTopicMessage> person = RedisDBHelper.ConvertObj<List<MqttTopicMessage>>(cachedata);
|
||
foreach (var item in person)
|
||
{
|
||
string curline = "";
|
||
curline += item.timeappreceive + " |";
|
||
//curline += "productid:" + row["productid"] + ",";
|
||
//curline += "devicename:" + row["devicename"] + ",";
|
||
//curline += "topic:" + row["topic"] + ",";
|
||
|
||
//curline += "payload:" + row["payload"] + ",";
|
||
curline += AnalysisByte(item.payload.ToString(), item.devicename.ToString());
|
||
//curline += "payload:" + AnalysisByte("pkwAf7vmZCwApwEEvQAAXEOuR0FAAACdQgAAAAAAAAAAAAAAAAAAAAAAAAA=") + ",";
|
||
|
||
//平台参数，暂时不需要
|
||
//curline += "seq:" + row["seq"] + ",";
|
||
//curline += "timestamp:" + row["timestamp"] + ",";
|
||
//curline += "timemills:" + row["timemills"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
|
||
Logger.LogCalloutanaSide("Redis取值错误:" + ex);
|
||
}
|
||
|
||
|
||
string com = "设备启动上报服务器信息";
|
||
listRet = listRet.Where(x => x.Contains(com)).ToList();
|
||
return listRet;
|
||
}
|
||
internal static List<string> GetLOGCallin(string productid, string devicename, string stime, string etime, int cmdname)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
DataSet ds = new DataSet()
|
||
; //1. get all
|
||
|
||
ds = GetAllCallinRecordBYTime(devicename);
|
||
|
||
//2. filter
|
||
|
||
List<MqttTopicMessage> pairs = new List<MqttTopicMessage>();
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
DataTable logs = ds.Tables[0];
|
||
|
||
EnumerableRowCollection<DataRow> query =
|
||
from log in logs.AsEnumerable()
|
||
where log.Field<string>("productid") == productid && log.Field<string>("devicename") == devicename
|
||
select log;
|
||
|
||
foreach (DataRow row in query)
|
||
{
|
||
|
||
//RedisValue[] mqttTopicMessage ={ row["id"].ToString(),row["payload"].ToString(), row["devicename"].ToString()};
|
||
//mqttTopicMessage ={
|
||
string ad = row.ToString();
|
||
|
||
// Redis缓存
|
||
MqttTopicMessage mqtt = new MqttTopicMessage();
|
||
//mqtt.id = int.Parse(row["id"].ToString());
|
||
mqtt.devicename = row["devicename"].ToString();
|
||
mqtt.productid = row["productid"].ToString();
|
||
mqtt.topic = row["topic"].ToString();
|
||
mqtt.payload = row["payload"].ToString();
|
||
mqtt.seq = long.Parse(row["seq"].ToString());
|
||
mqtt.timestamp = long.Parse(row["timestamp"].ToString());
|
||
mqtt.timemills = long.Parse(row["timemills"].ToString());
|
||
mqtt.timeappreceive = DateTime.Parse(row["timeappreceive"].ToString());
|
||
pairs.Add(mqtt);
|
||
|
||
}
|
||
}
|
||
//Redis缓存
|
||
try
|
||
{
|
||
RedisDBHelper.StringSet("mqttTopicMessage" + devicename, pairs, null, 1);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Logger.LogCalloutanaSide("Redis缓存错误:" + ex);
|
||
|
||
}
|
||
string cachedata = RedisDBHelper.StringGet("mqttTopicMessage" + devicename, 1);
|
||
//using Newtonsoft.Json;
|
||
|
||
|
||
try
|
||
{
|
||
List<MqttTopicMessage> person = RedisDBHelper.ConvertObj<List<MqttTopicMessage>>(cachedata);
|
||
long kstime;
|
||
long jstime;
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
if (stime == "null" || etime == "null")
|
||
{
|
||
//DateTime jieshu = DateTime.Now.AddMinutes(-10);
|
||
//kstime = Convert.ToInt64((jieshu - dateStart).TotalSeconds);
|
||
person = person.Take(10).OrderByDescending(x => x.timestamp).ToList();
|
||
}
|
||
else
|
||
{
|
||
|
||
DateTime stimes = Convert.ToDateTime(stime);
|
||
DateTime etimes = Convert.ToDateTime(etime);
|
||
kstime = Convert.ToInt64((stimes - dateStart).TotalSeconds);
|
||
jstime = Convert.ToInt64((etimes - dateStart).TotalSeconds);
|
||
person = person.Where(x => x.timestamp >= kstime && x.timestamp <= jstime).OrderByDescending(x => x.timestamp).ToList();
|
||
//strSqlCmd = "SELECT id, timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + kstime + "' and timestamp <='" + jstime + "' and devicename='" + devicename + "' ORDER BY timestamp DESC";
|
||
}
|
||
foreach (var item in person)
|
||
{
|
||
string curline = "";
|
||
curline += item.timemills + "|";
|
||
curline += item.timeappreceive + "|";
|
||
|
||
//curline += "productid:" + row["productid"] + ",";
|
||
//curline += "devicename:" + row["devicename"] + ",";
|
||
//curline += "topic:" + row["topic"] + ",";
|
||
|
||
//curline += "payload:" + row["payload"] + ",";
|
||
curline += AnalysisByte(item.payload.ToString(), item.devicename.ToString());
|
||
//curline += "payload:" + AnalysisByte("pkwAf7vmZCwApwEEvQAAXEOuR0FAAACdQgAAAAAAAAAAAAAAAAAAAAAAAAA=") + ",";
|
||
|
||
//平台参数，暂时不需要
|
||
//curline += "seq:" + row["seq"] + ",";
|
||
//curline += "timestamp:" + row["timestamp"] + ",";
|
||
//curline += "timemills:" + row["timemills"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
|
||
Logger.LogCalloutanaSide("Redis取值错误:" + ex);
|
||
}
|
||
|
||
|
||
//// 将对象转换为JSON字符串
|
||
//var person = new Person { Name = "John", Age = 30 };
|
||
//string jsonString = JsonConvert.SerializeObject(person);
|
||
|
||
if (cmdname != 0)
|
||
{
|
||
string com = "";
|
||
switch (cmdname)
|
||
{
|
||
case 1:
|
||
com = "设备上报门锁动作";
|
||
break;
|
||
case 2:
|
||
com = "设备上报PIR动作";
|
||
break;
|
||
case 3:
|
||
com = "设备定期上报";
|
||
break;
|
||
case 4:
|
||
com = "设备取电动作上报";
|
||
break;
|
||
case 5:
|
||
com = "设备获取云端服务器参数";
|
||
break;
|
||
case 6:
|
||
com = "云端服务器设置参数";
|
||
break;
|
||
case 7:
|
||
com = "服务器控制取电下发";
|
||
break;
|
||
case 8:
|
||
com = "服务器查询设备信息";
|
||
break;
|
||
case 9:
|
||
com = "设备启动上报服务器信息";
|
||
break;
|
||
case 10:
|
||
com = "获取设备位置信息";
|
||
break;
|
||
case 11:
|
||
com = "门磁动作上报";
|
||
break;
|
||
|
||
}
|
||
listRet = listRet.Where(x => x.Contains(com)).ToList();
|
||
}
|
||
|
||
return listRet;
|
||
}
|
||
public static List<string> GetAllpowerstatisticschart(string devname, string startT, string endT, string productid, int cmdname)
|
||
{
|
||
List<string> listRet = new List<string>();
|
||
#region Redis取值
|
||
|
||
|
||
|
||
//DataSet ds = new DataSet();
|
||
//1. get all
|
||
//string cachedata = RedisDBHelper.StringGet("mqttTopicMessage" + devname, 1);
|
||
//ds = GetAllpowerstatisticscharts(devname, startT, endT);
|
||
//try
|
||
//{
|
||
// List<MqttTopicMessage> person = RedisDBHelper.ConvertObj<List<MqttTopicMessage>>(cachedata);
|
||
// long kstime;
|
||
// long jstime;
|
||
|
||
// DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
// if (startT == "null" || endT == "null")
|
||
// {
|
||
// DateTime jieshu = DateTime.Now.AddDays(-5);
|
||
// kstime = Convert.ToInt64((jieshu - dateStart).TotalSeconds);
|
||
// person = person.Where(x => x.timestamp >= kstime).OrderByDescending(x => x.timestamp).ToList();
|
||
// }
|
||
// else
|
||
// {
|
||
// DateTime stimes = Convert.ToDateTime(startT);
|
||
// DateTime etimes = Convert.ToDateTime(endT);
|
||
// kstime = Convert.ToInt64((stimes - dateStart).TotalSeconds);
|
||
// jstime = Convert.ToInt64((etimes - dateStart).TotalSeconds);
|
||
// person = person.Where(x => x.timestamp >= kstime && x.timestamp <= jstime).OrderByDescending(x => x.timestamp).ToList();
|
||
// //strSqlCmd = "SELECT id, timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + kstime + "' and timestamp <='" + jstime + "' and devicename='" + devicename + "' ORDER BY timestamp DESC";
|
||
// }
|
||
|
||
// foreach (var item in person)
|
||
// {
|
||
// string curline = "";
|
||
// curline += item.timeappreceive + " |";
|
||
// //curline += "productid:" + row["productid"] + ",";
|
||
// //curline += "devicename:" + row["devicename"] + ",";
|
||
// //curline += "topic:" + row["topic"] + ",";
|
||
|
||
// //curline += "payload:" + row["payload"] + ",";
|
||
// curline += AnalysisByte(item.payload.ToString(), item.devicename.ToString());
|
||
// //curline += "payload:" + AnalysisByte("pkwAf7vmZCwApwEEvQAAXEOuR0FAAACdQgAAAAAAAAAAAAAAAAAAAAAAAAA=") + ",";
|
||
|
||
// //平台参数，暂时不需要
|
||
// //curline += "seq:" + row["seq"] + ",";
|
||
// //curline += "timestamp:" + row["timestamp"] + ",";
|
||
// //curline += "timemills:" + row["timemills"];
|
||
// listRet.Add(curline);
|
||
// }
|
||
|
||
|
||
//}
|
||
//catch (Exception ex)
|
||
//{
|
||
|
||
// Logger.LogCalloutanaSide("Redis取值错误:" + ex);
|
||
//}
|
||
|
||
//if (cmdname != 0)
|
||
//{
|
||
// string com = "";
|
||
// switch (cmdname)
|
||
// {
|
||
// case 1:
|
||
// com = "设备上报门锁动作";
|
||
// break;
|
||
// case 2:
|
||
// com = "设备上报PIR动作";
|
||
// break;
|
||
// case 3:
|
||
// com = "设备定期上报";
|
||
// break;
|
||
// case 4:
|
||
// com = "设备取电动作上报";
|
||
// break;
|
||
// case 5:
|
||
// com = "设备获取云端服务器参数";
|
||
// break;
|
||
// case 6:
|
||
// com = "云端服务器设置参数";
|
||
// break;
|
||
// case 7:
|
||
// com = "服务器控制取电下发";
|
||
// break;
|
||
// case 8:
|
||
// com = "服务器查询设备信息";
|
||
// break;
|
||
// case 9:
|
||
// com = "设备启动上报服务器信息";
|
||
// break;
|
||
// case 10:
|
||
// com = "获取设备位置信息";
|
||
// break;
|
||
|
||
// }
|
||
// listRet = listRet.Where(x => x.Contains(com)).ToList();
|
||
//}
|
||
|
||
//return listRet;
|
||
#endregion
|
||
#region sql语句取值
|
||
DataSet ds = new DataSet();
|
||
|
||
ds = GetAllpowerstatisticscharts(devname, startT, endT);
|
||
|
||
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
|
||
string curline = "";
|
||
//curline += "devicename:" + row["devicename"] + ",";
|
||
curline += "creationtime&" + row["creationtime"] + ",";
|
||
curline += "lockElectricQuantity:" + row["lockElectricQuantity"] + ",";
|
||
curline += "PIR1ElectricQuantity:" + row["PIR1ElectricQuantity"] + ",";
|
||
curline += "PIR2ElectricQuantity:" + row["PIR2ElectricQuantity"] + ",";
|
||
curline += "PIR3ElectricQuantity:" + row["PIR3ElectricQuantity"] + ",";
|
||
curline += "PIR4ElectricQuantity:" + row["PIR4ElectricQuantity"] + ",";
|
||
curline += "GMElectricQuantity:" + row["GMElectricQuantity"] + ",";
|
||
|
||
//curline += "lockElectricQuantity:" + row["lockElectricQuantity"] + ",";
|
||
curline += "PIR5ElectricQuantity:" + row["PIR5ElectricQuantity"] + ",";
|
||
curline += "PIR6ElectricQuantity:" + row["PIR6ElectricQuantity"] + ",";
|
||
curline += "PIR7ElectricQuantity:" + row["PIR7ElectricQuantity"] + ",";
|
||
curline += "PIR8ElectricQuantity:" + row["PIR8ElectricQuantity"] + ",";
|
||
curline += "Power:" + row["Power"] + ",";
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
return listRet;
|
||
#endregion
|
||
}
|
||
|
||
private static DataSet GetAllpowerstatisticscharts(string devname, string startT, string endT)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
//int kstime;
|
||
//int jstime;
|
||
string strSqlCmd;
|
||
//DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
//if (startT == "null" || endT == "null")
|
||
//{
|
||
// DateTime jieshu = DateTime.Now.AddMinutes(-30);
|
||
// kstime = Convert.ToInt32((jieshu - dateStart).TotalSeconds);
|
||
// strSqlCmd = "SELECT timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + kstime + "' and devicename='" + devname + "' ORDER BY timestamp DESC";
|
||
//}
|
||
//else
|
||
//{
|
||
// DateTime stimes = Convert.ToDateTime(startT);
|
||
// DateTime etimes = Convert.ToDateTime(endT);
|
||
// kstime = Convert.ToInt32((stimes - dateStart).TotalSeconds);
|
||
// jstime = Convert.ToInt32((etimes - dateStart).TotalSeconds);
|
||
// strSqlCmd = "SELECT timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + kstime + "' and timestamp <='" + jstime + "' and devicename='" + devname + "' ORDER BY timestamp DESC";
|
||
//}
|
||
//DataSet ds = new DataSet();
|
||
if (startT == "null" || endT == "null")
|
||
{
|
||
DateTime jieshu = DateTime.Now.AddDays(-30);
|
||
strSqlCmd = "select * from deviceelectricquantity where devicename='" + devname + "' and creationtime >='" + jieshu + "'";
|
||
}
|
||
else
|
||
{
|
||
strSqlCmd = "select * from deviceelectricquantity where devicename='" + devname + "' and creationtime >='" + startT + "' and creationtime <= '" + endT + "'";
|
||
}
|
||
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
//SQLiteConnection conn = new SQLiteConnection(strSqliteConn);
|
||
//conn.Open();
|
||
//SQLiteCommand command = new SQLiteCommand(strSqlCmd, conn);
|
||
//SQLiteDataAdapter adapter = new SQLiteDataAdapter(command);
|
||
//adapter.Fill(ds);
|
||
//conn.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
public static List<string> jianzaogduo(string productid, string devicename, string shijian, int cmdname)
|
||
{
|
||
|
||
List<string> listRet = new List<string>();
|
||
DataSet ds = new DataSet()
|
||
; //1. get all
|
||
|
||
//ds = GetAllCallinRecordBYTimes(productid, devicename, shijian);
|
||
|
||
string cachedata = RedisDBHelper.StringGet("mqttTopicMessage" + devicename, 1);
|
||
|
||
try
|
||
{
|
||
List<MqttTopicMessage> person = RedisDBHelper.ConvertObj<List<MqttTopicMessage>>(cachedata);
|
||
|
||
int kstime;
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
DateTime stimes = Convert.ToDateTime(shijian);
|
||
DateTime shijians = stimes.AddMinutes(-30);
|
||
kstime = Convert.ToInt32((shijians - dateStart).TotalSeconds);
|
||
|
||
person = person.Where(x => x.timestamp >= kstime).OrderByDescending(x => x.timestamp).ToList();
|
||
|
||
|
||
|
||
foreach (var item in person)
|
||
{
|
||
string curline = "";
|
||
curline += item.timemills + "|";
|
||
curline += item.timeappreceive + "|";
|
||
//curline += "productid:" + row["productid"] + ",";
|
||
//curline += "devicename:" + row["devicename"] + ",";
|
||
//curline += "topic:" + row["topic"] + ",";
|
||
|
||
//curline += "payload:" + row["payload"] + ",";
|
||
curline += AnalysisByte(item.payload.ToString(), item.devicename.ToString());
|
||
//curline += "payload:" + AnalysisByte("pkwAf7vmZCwApwEEvQAAXEOuR0FAAACdQgAAAAAAAAAAAAAAAAAAAAAAAAA=") + ",";
|
||
|
||
//平台参数，暂时不需要
|
||
//curline += "seq:" + row["seq"] + ",";
|
||
//curline += "timestamp:" + row["timestamp"] + ",";
|
||
//curline += "timemills:" + row["timemills"];
|
||
listRet.Add(curline);
|
||
}
|
||
|
||
if (cmdname != 0)
|
||
{
|
||
string com = "";
|
||
switch (cmdname)
|
||
{
|
||
case 1:
|
||
com = "设备上报门锁动作";
|
||
break;
|
||
case 2:
|
||
com = "设备上报PIR动作";
|
||
break;
|
||
case 3:
|
||
com = "设备定期上报";
|
||
break;
|
||
case 4:
|
||
com = "设备取电动作上报";
|
||
break;
|
||
case 5:
|
||
com = "设备获取云端服务器参数";
|
||
break;
|
||
case 6:
|
||
com = "云端服务器设置参数";
|
||
break;
|
||
case 7:
|
||
com = "服务器控制取电下发";
|
||
break;
|
||
case 8:
|
||
com = "服务器查询设备信息";
|
||
break;
|
||
case 9:
|
||
com = "设备启动上报服务器信息";
|
||
break;
|
||
case 10:
|
||
com = "获取设备位置信息";
|
||
break;
|
||
case 11:
|
||
com = "门磁动作上报";
|
||
break;
|
||
|
||
}
|
||
listRet = listRet.Where(x => x.Contains(com)).ToList();
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
|
||
Logger.LogCalloutanaSide("Redis取值错误:" + ex);
|
||
}
|
||
return listRet;
|
||
}
|
||
|
||
private static DataSet GetAllCallinRecordBYTimes(string productid, string devicename, string shijian)
|
||
{
|
||
DataSet ds = new DataSet();
|
||
int kstime;
|
||
|
||
string strSqlCmd;
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
DateTime stimes = Convert.ToDateTime(shijian);
|
||
DateTime shijians = stimes.AddMinutes(-30);
|
||
kstime = Convert.ToInt32((shijians - dateStart).TotalSeconds);
|
||
strSqlCmd = "SELECT id, timeappreceive, productid,devicename,topic,payload,seq,timestamp,timemills FROM uploginfo where timestamp >= '" + kstime + "' and devicename='" + devicename + "' ORDER BY timestamp DESC";
|
||
try
|
||
{
|
||
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
public static List<string> GetSelectStatus(string devicename, string stime, string etime)
|
||
{
|
||
|
||
|
||
List<string> listRet = new List<string>();
|
||
|
||
string curline = "";
|
||
DataSet ds = new DataSet();
|
||
//if (string.IsNullOrEmpty(Name))
|
||
//{
|
||
// ds = GetAllCallinRecord();
|
||
//}
|
||
//else
|
||
//{
|
||
|
||
ds = GetAllSelectStatus(devicename, stime, etime);
|
||
if (ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in ds.Tables[0].Rows)
|
||
{
|
||
curline = "";
|
||
curline += "deviceName:" + row["deviceName"] + ",";
|
||
curline += "eventName:" + row["eventName"] + ",";
|
||
curline += "seq:" + row["seq"] + ",";
|
||
curline += "timemills:" + row["timemills"] + ",";
|
||
curline += "reason:" + row["reason"] + ",";
|
||
curline += "id:" + row["id"];
|
||
listRet.Add(curline);
|
||
}
|
||
}
|
||
return listRet;
|
||
}
|
||
|
||
private static DataSet GetAllSelectStatus(string devicename, string stime, string etime)
|
||
{
|
||
long kstime;
|
||
long jstime;
|
||
DataSet ds = new DataSet();
|
||
string strSqlCmd = "";
|
||
if (devicename == "null" && stime != "null" && etime != "null")
|
||
{
|
||
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
DateTime stimes = Convert.ToDateTime(stime);
|
||
DateTime etimes = Convert.ToDateTime(etime);
|
||
kstime = Convert.ToInt64((stimes - dateStart).TotalSeconds);
|
||
jstime = Convert.ToInt64((etimes - dateStart).TotalSeconds);
|
||
strSqlCmd = "SELECT * FROM devicestate where timemills>= '" + kstime + "' and timemills<= '" + jstime + "' ORDER BY timemills desc";
|
||
}
|
||
else if (devicename != "null" && stime == "null" && etime == "null")
|
||
{
|
||
strSqlCmd = "SELECT * FROM devicestate where deviceName LIKE '%" + devicename + "%' ORDER BY timemills desc";
|
||
}
|
||
else if (devicename != "null" && stime != "null" && etime != "null")
|
||
{
|
||
DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
|
||
DateTime stimes = Convert.ToDateTime(stime);
|
||
DateTime etimes = Convert.ToDateTime(etime);
|
||
kstime = Convert.ToInt64((stimes - dateStart).TotalSeconds);
|
||
jstime = Convert.ToInt64((etimes - dateStart).TotalSeconds);
|
||
strSqlCmd = "SELECT * FROM devicestate where timemills>= '" + kstime + "' and timemills<= '" + jstime + "' and deviceName LIKE '%" + devicename + "%' ORDER BY timemills desc";
|
||
}
|
||
else
|
||
{
|
||
strSqlCmd = "SELECT * FROM devicestate ORDER BY timemills desc";
|
||
}
|
||
|
||
try
|
||
{
|
||
using (MySqlConnection connection = new MySqlConnection(strSqliteConn))
|
||
{
|
||
|
||
using (MySqlCommand cmd = new MySqlCommand())
|
||
{
|
||
connection.Open();
|
||
cmd.Connection = connection;
|
||
MySqlDataAdapter command = new MySqlDataAdapter(strSqlCmd, connection);
|
||
command.Fill(ds);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
System.Diagnostics.EventLog.WriteEntry("MQTTServerSideAPI", DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + " " + ex.ToString(), System.Diagnostics.EventLogEntryType.Error);
|
||
}
|
||
|
||
return ds;
|
||
}
|
||
|
||
public class deviceState
|
||
{
|
||
public device payload { get; set; }
|
||
public string timemills { get; set; }
|
||
public string seq { get; set; }
|
||
public string productID { get; set; }
|
||
|
||
public string timestamp { get; set; }
|
||
public string devicename { get; set; }
|
||
public string topic { get; set; }
|
||
}
|
||
public class device
|
||
{
|
||
public string deviceName { get; set; }
|
||
public string @event { get; set; }
|
||
public string productID { get; set; }
|
||
|
||
public string reason { get; set; }
|
||
public string timestamp { get; set; }
|
||
public string topic { get; set; }
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
public class WZ
|
||
{
|
||
public int status { get; set; }
|
||
public AA regeocode { get; set; }
|
||
public string info { get; set; }
|
||
public string infocode { get; set; }
|
||
}
|
||
public class AA
|
||
{
|
||
public BB addressComponent { get; set; }
|
||
public string formatted_address { get; set; }
|
||
}
|
||
|
||
public class BB
|
||
{
|
||
public string city { get; set; }
|
||
public string province { get; set; }
|
||
public string adcode { get; set; }
|
||
public string district { get; set; }
|
||
public string towncode { get; set; }
|
||
public string country { get; set; }
|
||
public string township { get; set; }
|
||
public string citycode { get; set; }
|
||
public DD streetNumber { get; set; }
|
||
}
|
||
public class DD
|
||
{
|
||
public string number { get; set; }
|
||
public string location { get; set; }
|
||
public string direction { get; set; }
|
||
public string distance { get; set; }
|
||
public string street { get; set; }
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
} |