1790429840
/
KN_CAMP_SOFTWARE_TEST
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
软测单独项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2 Commits
1 Branch
0 Tags
273 MiB
 
 
 
 
 
 
Tree: 801c22ec74
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '801c22ec74'
${ noResults }
KN_CAMP_SOFTWARE_TEST/Code/智慧营区/HardWareInteface/Common/hikAlarmQueueTask.cs

352 lines
15 KiB
Raw Blame History

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using RestHttp;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Linq;
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using System.Web;
using System.Web.Caching;
namespace HardWareInteface.Common
{
public class hikAlarmQueueTask
{
private static FangYar.BLL.TBL_ALARMDATA aBll = new FangYar.BLL.TBL_ALARMDATA();
//
public static ConcurrentQueue<string> infoQueue = new ConcurrentQueue<string>();
private static CancellationTokenSource m_DealToken = new CancellationTokenSource();
private static Task m_DealTask = Task.Factory.StartNew(DealInfoList, m_DealToken.Token);
private static int i = 0;
public static void infoQueueFun(string model)
{
try
{
infoQueue.Enqueue(model); //添加
}
catch (Exception e)
{
WriteLog(e.Message);
}
WriteLog("新疆队列长度：" + infoQueue.Count.ToString());
}
private static void DealInfoList()
{
while (!m_DealToken.IsCancellationRequested)
{
string dataInfo = null;
if (infoQueue.TryDequeue(out dataInfo))
{
try
{
WriteLog("开始处理...");
DealInfo(dataInfo);
WriteLog("结束处理...");
}
catch (Exception ex)
{
WriteLog(ex.Source + ex.StackTrace + ex.Message + "DealInfoList_Error");
}
}
else
{
WriteLog("新疆队列长度：" + infoQueue.Count.ToString() + "，正在等待...");
Thread.Sleep(100);
}
}
}
private static string DealInfo(string data)
{
try
{
//data = "{\"alarmTime\":1627919606000,\"channel\":\"11\",\"channelType\":\"10300\",\"devSerial\":\"G99356847\",\"alarmId\":\"20210802235327-E35064652-11-10014\",\"alarmType\":\"10014\",\"channelName\":\"东南1号向西\",\"pictureUrl\":[\"https://i.ys7.com/streamer/alarm/url/get?fileId=20210802235327-E35064652-11-10014-2-1&deviceSerialNo=E35064652&cn=11&isEncrypted=0&isCloudStored=0&ct=1&lc=7&bn=1_hikalarm&isDevVideo=0\"]}";
//data = "{\"alarmTime\":1627919606000,\"channel\":\"8\",\"channelType\":\"10300\",\"devSerial\":\"G16833582\",\"alarmId\":\"20210802235327-E35064652-11-10014\",\"alarmType\":\"10014\",\"channelName\":\"东南1号向西\",\"pictureUrl\":[\"https://dn-od4ir4su9.qbox.me/7/G16833582_8_20210822020009-G16833582-8-10014-2-1?e=1630395821&token=5JNHy55nNlr5InRTUltuUGUbGkZQb9Vpzf_Ko-XH:0Bjgn_WFVsYQA0nTkVpy_3V4XN8=\"]}";
data = System.Web.HttpUtility.UrlDecode(data, System.Text.Encoding.UTF8);
#region 用于传递数据的输出
WriteLog(data.ToString());
#endregion
//FangYar.FYMQTT.MQTT2 mq = new FangYar.FYMQTT.MQTT2();
//mq.messagePublished(data, "video-http-hk/abc");
string redata_string = data.Replace(Environment.NewLine, "");
string redata_string_json = "[";
if (redata_string.Contains("} {"))
{
redata_string = redata_string.Replace("} {", "},{");
}
else if (redata_string.Contains("}{"))
{
redata_string = redata_string.Replace("}{", "},{");
}
redata_string_json += redata_string;
redata_string_json += "]";
try
{
JArray jsonStr = JsonConvert.DeserializeObject<JArray>(redata_string_json);
}
catch (Exception e)
{
WriteLog("\r\n 数据有误: 字符串不是json格式");
}
List<FangYar.Model.AlarmReception_DATA> ar_data = JsonConvert.DeserializeObject<List<FangYar.Model.AlarmReception_DATA>>(redata_string_json);
FangYar.BLL.TBL_CAMERA bll_cam = new FangYar.BLL.TBL_CAMERA();
for (int i = 0; i < ar_data.Count; i++)
{
//判断是否该条报警为重复上报，已存在于缓存中
object cameraAlarmTime = FangYar.Common.CacheHelper.GetCache(ar_data[i].devSerial + "_" + ar_data[i].channel + "_" + ar_data[i].alarmTime + "_" + ar_data[i].alarmType);
if (cameraAlarmTime != null)
{
return ""; //
}
else
{
FangYar.Common.CacheHelper.SetCache(ar_data[i].devSerial + "_" + ar_data[i].channel + "_" + ar_data[i].alarmTime + "_" + ar_data[i].alarmType, true, Cache.NoAbsoluteExpiration, new TimeSpan(7, 0, 0, 0, 0));
#region 根据设备序列号获取设备所属机构；判断是否为西藏设备，如果是择转发西藏ashx处理程序
//将设备的序列号和所属西藏、新疆类型 存入缓存
object orgAreaType = FangYar.Common.CacheHelper.GetCache(ar_data[i].devSerial);
if (orgAreaType == null)
{
DataTable orgDt = FangYar.Common.MySqlHelper.QueryTable("select ORG_ID,ORG_NAME,TYPE from tbl_device_org where devSerial = '" + ar_data[i].devSerial + "'");
if (orgDt.Rows.Count > 0)
{
FangYar.Common.CacheHelper.SetCache(ar_data[i].devSerial, orgDt.Rows[0]["TYPE"].ToString(), Cache.NoAbsoluteExpiration, new TimeSpan(7, 0, 0, 0, 0)); //将时间间隔初始化为7天0小时0分0秒0毫秒
if (orgDt.Rows[0]["TYPE"].ToString() == "1")
{
try
{
string xzIp = ConfigurationManager.AppSettings["XZHardWareIntefaceIP"];
var xzRsp = RestHttpRequest.HttpPost("http://" + xzIp + ":8310/Handle/hikAlarmReceptionXZ.ashx", data);
}
catch (Exception e)
{
WriteLog(e.Message);
}
}
else
{
DataWarehousing(ar_data[i]);
}
}
else
{
DataWarehousing(ar_data[i]);
}
}
else
{
if (orgAreaType.ToString() == "1")
{
try
{
string xzIp = ConfigurationManager.AppSettings["XZHardWareIntefaceIP"];
var xzRsp = RestHttpRequest.HttpPost("http://" + xzIp + ":8310/Handle/hikAlarmReceptionXZ.ashx", data);
}
catch (Exception e)
{
WriteLog(e.Message);
}
}
else
{
DataWarehousing(ar_data[i]);
}
}
}
#endregion
}
}
catch (Exception e)
{
WriteLog(e.Message);
}
return "";
}
public static void DataWarehousing(FangYar.Model.AlarmReception_DATA dataInfo)
{
FangYar.Model.OA.TBL_ALARMDATA amodel = new FangYar.Model.OA.TBL_ALARMDATA();
amodel.ID = Guid.NewGuid().ToString("N");
amodel.DVC_ID = dataInfo.devSerial;
amodel.TYPE = "0";
System.DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); // 当地时区
DateTime dt = startTime.AddTicks(dataInfo.alarmTime * 10000);
amodel.TIME = dt;
amodel.ALARM_TYPE = "0";
amodel.CHANNEL = dataInfo.channel;
amodel.CHANNELTYPE = dataInfo.channelType;
amodel.CUSTOMINFO = dataInfo.customInfo;
amodel.DEVSERIAL = dataInfo.devSerial;
amodel.ALARMID = dataInfo.alarmId;
amodel.ALARMTYPE = dataInfo.alarmType;
amodel.CHANNELNAME = dataInfo.channelName;
string picsrcs = "";
for (int y = 0; y < dataInfo.pictureUrl.Length; y++)
{
WebClient client = new WebClient();
byte[] byteArray = client.DownloadData(dataInfo.pictureUrl[y]);
if (y == 0)
{
picsrcs = GetFilePath(byteArray, dataInfo.devSerial);
}
else
{
picsrcs += "," + GetFilePath(byteArray, dataInfo.devSerial);
}
}
amodel.PICSRC = picsrcs;
#region 老版固定设备
switch (dataInfo.devSerial)
{
case "E35064652":
amodel.ORG_ID = "362AD769D3B74C8D9BC20A1DC0E9CC92";
amodel.ADDR = "哈密消防支队";
break;
case "G16833582":
amodel.ORG_ID = "021933cc9b11441c920a431eeffe60c2";
amodel.ADDR = "特勤大队一站";
break;
case "G46238993":
amodel.ORG_ID = "01c56fc1145a48e1b3690460a287de12";
amodel.ADDR = "西一路消防救援站";
break;
case "J04022168":
amodel.ORG_ID = "CEC6CC9DB57E4F43A61A07A9DCD1BF39";
amodel.ADDR = "南子午路消防站";
break;
case "G46239003":
amodel.ORG_ID = "f9a14b93970644fa8b6d8bfca3418b9b";
amodel.ADDR = "北八路特勤站";
break;
case "F24995053":
amodel.ORG_ID = "9d567172979c4e77a2ab30344943106b";
amodel.ADDR = "天山路消防救援站";
break;
}
#endregion
bool isadd = aBll.Add(amodel);
WriteLog("结果:" + isadd + "_" + amodel.DVC_ID + "_" + amodel.TIME);
}
/// <summary>
/// base转图片保存到服务器
/// </summary>
/// <param name="msg"></param>
private static string GetFilePath(byte[] bytes, string devSerial)
{
string fileName = DateTime.Now.Year.ToString() + DateTime.Now.Month.ToString();//年月
string ImageFilePath = "/Attachment" + "/hikAlarmReception/" + devSerial + "/" + DateTime.Now.Year.ToString() + "/" + DateTime.Now.Month.ToString();
//图片保存地址
string imgSavePath = System.Configuration.ConfigurationManager.AppSettings["imgSavePath"] + "";
if (HttpContext.Current != null) //web应用程序 单线程
{
if (System.IO.Directory.Exists(HttpContext.Current.Server.MapPath(ImageFilePath)) == false)//如果不存在就创建文件夹
{
System.IO.Directory.CreateDirectory(HttpContext.Current.Server.MapPath(ImageFilePath));
}
}
else //非web程序引用 多线程
{
//ImageFilePath = ImageFilePath.Replace("/", "\\");
string filePath = imgSavePath + ImageFilePath;
if (System.IO.Directory.Exists(filePath) == false)//如果不存在就创建文件夹
{
System.IO.Directory.CreateDirectory(filePath);
}
}
string ImagePath;
string str = System.DateTime.Now.ToString("yyyyHHddHHmmssfff") + Guid.NewGuid().ToString();
ImagePath = imgSavePath + ImageFilePath + "/" + str;//定义图片名称
File.WriteAllBytes(ImagePath + ".png", bytes); //保存图片到服务器，然后获取路径
return ImageFilePath + "/" + str + ".png";//获取保存后的路径
}
static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim();
private static void WriteLog(string msg)
{
FangYar.Common.MyLogHelper.WriteMsg(new FangYar.Common.LogInfoMo() { message = msg, msgType = FangYar.Common.EnumLogMsgTypeEnum.Error, path = "hikAlarmReceptionXJ" });
//try
//{
// LogWriteLock.EnterWriteLock();
// string path = AppDomain.CurrentDomain.BaseDirectory + "log\\hikAlarmReceptionXJ\\";
// string filename = DateTime.Now.ToString("yyyyMMdd") + ".txt";
// if (Directory.Exists(path) == false)//如果不存在就创建文件夹
// {
// Directory.CreateDirectory(path);
// }
// FileInfo file = new FileInfo(path + filename);
// if (!file.Exists)
// {
// try
// {
// FileStream fs;
// fs = File.Create(path + filename);
// fs.Close();
// }
// catch
// {
// }
// }
// using (FileStream fs = new FileStream(path + filename, FileMode.Append, FileAccess.Write))
// {
// using (StreamWriter sw = new StreamWriter(fs))
// {
// sw.WriteLine("时间：" + DateTime.Now.ToString() + " 信息：" + msg);
// }
// }
//}
//catch (Exception e)
//{
//}
//finally
//{
// LogWriteLock.ExitWriteLock();
//}
}
}
}