430 lines
20 KiB
C#
430 lines
20 KiB
C#
|
//2021年4月14日16点36分 联动的时候不在多次登录NVR,
|
|||
|
|
using Abp.Dependency;
|
|||
|
|
using Newtonsoft.Json.Linq;
|
|||
|
|
using System.Collections.Concurrent;
|
|||
|
|
using VideoSurveillanceAdapter;
|
|||
|
|
using Yunda.ISAS.DataMonitoringServer.DataAnalysis.AlarmQueue;
|
|||
|
|
using Yunda.ISAS.DataMonitoringServer.DataAnalysis.DataCollection;
|
|||
|
|
using Yunda.ISAS.DataMonitoringServer.DataAnalysis.Helper;
|
|||
|
|
using Yunda.ISAS.DataMonitoringServer.DataAnalysis.Model;
|
|||
|
|
using Yunda.ISAS.DataMonitoringServer.DataCenter;
|
|||
|
|
using YunDa.ISAS.Core.Entity;
|
|||
|
|
using YunDa.ISAS.DataTransferObject.DataMonitoring.LinkageExecuteActivityDto;
|
|||
|
|
using YunDa.ISAS.DataTransferObject.VideoSurveillance.PresetPointDto;
|
|||
|
|
using YunDa.ISAS.Entities.MySQL.DataMonitoring;
|
|||
|
|
using YunDa.ISAS.ExternalInteraction.DataTransferObject.InspectionEquipment;
|
|||
|
|
|
|||
|
|
namespace Yunda.ISAS.DataMonitoringServer.DataAnalysis.LinkageAnalysis
|
|||
|
|
{
|
|||
|
|
public class ImpletementLinkActives : ISingletonDependency
|
|||
|
|
{
|
|||
|
|
private readonly CameraDataCenter _cameraDataCenter;
|
|||
|
|
private readonly WebApiRequest _webApiRequest;
|
|||
|
|
private readonly ConfigurationHepler _configurationHepler;
|
|||
|
|
private readonly RunningDataCache _runningDataCache;
|
|||
|
|
private readonly TeleCommandDataSendTask _teleCommandDataSendTask;
|
|||
|
|
private readonly AlarmQueueDataPublish _alarmQueueDataPublish;
|
|||
|
|
public ImpletementLinkActives(CameraDataCenter cameraDataCenter,
|
|||
|
|
WebApiRequest webApiRequest,
|
|||
|
|
ConfigurationHepler configurationHepler,
|
|||
|
|
RunningDataCache runningDataCache,
|
|||
|
|
TeleCommandDataSendTask teleCommandDataSendTask,
|
|||
|
|
AlarmQueueDataPublish alarmQueueDataPublish
|
|||
|
|
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
_cameraDataCenter = cameraDataCenter;
|
|||
|
|
_webApiRequest = webApiRequest;
|
|||
|
|
_configurationHepler = configurationHepler;
|
|||
|
|
_teleCommandDataSendTask = teleCommandDataSendTask;
|
|||
|
|
_runningDataCache = runningDataCache;
|
|||
|
|
_alarmQueueDataPublish = alarmQueueDataPublish;
|
|||
|
|
}
|
|||
|
|
private readonly object locker = new object();
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行联动
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="linkageStrategy"></param>
|
|||
|
|
public Task ExecuteLinkageDataAsync(LinkageStrategyModel linkageStrategy,
|
|||
|
|
string reslutStr,
|
|||
|
|
string code
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
List<Guid> cameraActives = new List<Guid>();
|
|||
|
|
Task rstTask = null;
|
|||
|
|
ConcurrentDictionary<Guid, List<LinkageExecuteActivityOutput>> _cameraActives
|
|||
|
|
= new ConcurrentDictionary<Guid, List<LinkageExecuteActivityOutput>>();
|
|||
|
|
|
|||
|
|
var req = new LinkageResultInput
|
|||
|
|
{
|
|||
|
|
TransformerSubstationId = _configurationHepler.SubstationId,
|
|||
|
|
LinkageStrategyId = linkageStrategy.Id,
|
|||
|
|
LinkageStrategyName = linkageStrategy.Name,
|
|||
|
|
LinkageStartTime = DateTime.Now,
|
|||
|
|
AlarmLevel = linkageStrategy.DMAlarmCategory == null ? 0 : linkageStrategy.DMAlarmCategory.Level,
|
|||
|
|
AlarmName = linkageStrategy.DMAlarmCategory?.Name,
|
|||
|
|
DMAlarmCategoryId = linkageStrategy.DMAlarmCategoryId,
|
|||
|
|
LinkageEndTime = null,
|
|||
|
|
Result = reslutStr,
|
|||
|
|
Status = 0,
|
|||
|
|
Message = "",
|
|||
|
|
};
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
JObject rstDataJObject = ToolLibrary.HttpHelper.HttpGetRequest<JObject>($"{ConstantModel.RequestLinkageExecuteActivityFindActivityByLinkageIdUri}?linkageId={linkageStrategy.Id}", null);
|
|||
|
|
var rst = rstDataJObject?["result"]?["resultData"];//获取结果集
|
|||
|
|
if (rst == null)
|
|||
|
|
{
|
|||
|
|
return rstTask;
|
|||
|
|
}
|
|||
|
|
var actives = rst.ToObject<List<LinkageExecuteActivityOutput>>();
|
|||
|
|
var listFiles = new List<AttachmentFile>();
|
|||
|
|
///当执行活动为摄像机时，需要异步处理
|
|||
|
|
List<Task> tasks = new List<Task>();
|
|||
|
|
foreach (var item in actives)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
|
|||
|
|
if (item.ActivityType == ActivityTypeEnum.Video)
|
|||
|
|
{
|
|||
|
|
if (item?.PresetPoint?.VideoDev == null)
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
if (_cameraActives.ContainsKey(item.PresetPoint.VideoDev.Id))
|
|||
|
|
{
|
|||
|
|
_cameraActives[item.PresetPoint.VideoDev.Id].Add(item);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
while (!_cameraActives.TryAdd(item.PresetPoint.VideoDev.Id, new List<LinkageExecuteActivityOutput>() { item }))
|
|||
|
|
{
|
|||
|
|
Task.Delay(10).Wait();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
else if (item.ActivityType == YunDa.ISAS.Entities.MySQL.DataMonitoring.ActivityTypeEnum.Telecommand) //遥控命令直接执行
|
|||
|
|
{
|
|||
|
|
var equipment = _webApiRequest.GetEquipmentInfo((Guid)item.EquipmentInfoId);
|
|||
|
|
if (equipment != null)
|
|||
|
|
{
|
|||
|
|
if (!equipment.IsActive || equipment.SafetyStateType == YunDa.ISAS.Entities.GeneralInformation.SafetyStateTypeEnum.Disarming)
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// 执行 发送遥控命令操作
|
|||
|
|
ImplementTeleCommandAction(item, ref req);
|
|||
|
|
MonitoringEventBus.LogHandler(req.Message, "联动遥控信息");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
foreach (var item in _cameraActives)
|
|||
|
|
{
|
|||
|
|
Task task = Task.Run(() =>
|
|||
|
|
{
|
|||
|
|
ExcuteCameraAction(item.Value, ref req, ref listFiles, code);
|
|||
|
|
});
|
|||
|
|
tasks.Add(task);
|
|||
|
|
}
|
|||
|
|
//bool isPersonInvasion = false;
|
|||
|
|
if (linkageStrategy.IsPatternRecognize)
|
|||
|
|
{
|
|||
|
|
foreach (var item in listFiles)
|
|||
|
|
{
|
|||
|
|
var path = Path.GetFullPath("./CaptureJPEGPicture/" + item.FileName);
|
|||
|
|
if (File.Exists(path))
|
|||
|
|
{
|
|||
|
|
var res = _webApiRequest.GetPatternRecongnozeResult(path);
|
|||
|
|
if (res!="")
|
|||
|
|
{
|
|||
|
|
reslutStr += ";图形复核结果："+ res;
|
|||
|
|
//isPersonInvasion = true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
_alarmQueueDataPublish.LinkageAlarmAsync(linkageStrategy, reslutStr, _cameraActives);
|
|||
|
|
//当动作执行完后进行异步上传文件
|
|||
|
|
rstTask = Task.WhenAll(tasks.ToArray()).ContinueWith((t) =>
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
req.LinkageEndTime = DateTime.Now;
|
|||
|
|
req.LinkageFiles = listFiles;
|
|||
|
|
string filePath = _webApiRequest.GetRelativePath(ref req); //获取相对路径
|
|||
|
|
foreach (var item in listFiles)
|
|||
|
|
{
|
|||
|
|
if (item.FileType == AttachmentFileType.Photo)
|
|||
|
|
{
|
|||
|
|
var path = Path.GetFullPath("./CaptureJPEGPicture/" + item.FileName);
|
|||
|
|
if (File.Exists(path))
|
|||
|
|
{
|
|||
|
|
string result = _webApiRequest.ResumeFile(ConstantModel.RequestLinkageResultFileUploadUri, path, filePath, 0, 1024 * 128);
|
|||
|
|
MonitoringEventBus.LogHandler($"{item.FileName}_{result}", "上传联动文件");
|
|||
|
|
//File.Delete(path);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else if (item.FileType == AttachmentFileType.Video)
|
|||
|
|
{
|
|||
|
|
//var path = Path.GetFullPath("./RecordVideo/" + item.FileName);
|
|||
|
|
//if (File.Exists(path))
|
|||
|
|
//{
|
|||
|
|
// string result = LinkCommuication.Instance.ResumeFile(ConstantModel.RequestLinkageResultFileUploadUri, path, filePath, 0, 1024 * 128);
|
|||
|
|
// MonitoringEventBus.LogHandler($"{ item.FileName}_{result}", "上传联动文件");
|
|||
|
|
// File.Delete(path);
|
|||
|
|
//}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (Directory.Exists("./CaptureJPEGPicture/"))
|
|||
|
|
{
|
|||
|
|
var files = Directory.GetFiles("./CaptureJPEGPicture/");
|
|||
|
|
//var delefiles = new List<string>();
|
|||
|
|
foreach (var file in files)
|
|||
|
|
{
|
|||
|
|
if (DateTime.Now - File.GetCreationTime(file) > TimeSpan.FromDays(1))
|
|||
|
|
{
|
|||
|
|
File.Delete(file);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(ex.ToString(), "异常信息");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(ex.ToString(), "异常信息");
|
|||
|
|
}
|
|||
|
|
return rstTask;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行摄像机动作
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="linkageExecuteActivities"></param>
|
|||
|
|
/// <param name="req"></param>
|
|||
|
|
/// <param name="listFiles"></param>
|
|||
|
|
/// <param name="code"></param>
|
|||
|
|
public void ExcuteCameraAction(List<LinkageExecuteActivityOutput> linkageExecuteActivities,
|
|||
|
|
ref LinkageResultInput req,
|
|||
|
|
ref List<AttachmentFile> listFiles,
|
|||
|
|
string code
|
|||
|
|
)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
foreach (var linkageExecuteActivity in linkageExecuteActivities)
|
|||
|
|
{
|
|||
|
|
if (linkageExecuteActivity.KeepTime == null)
|
|||
|
|
{
|
|||
|
|
linkageExecuteActivity.KeepTime = 0;
|
|||
|
|
}
|
|||
|
|
var camera = _webApiRequest.GetVideoDevData(linkageExecuteActivity.PresetPointId).Item1;
|
|||
|
|
if (camera == null)
|
|||
|
|
{
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
var apply = _webApiRequest.GetApplyControlToExternalstr(camera.Id,
|
|||
|
|
(int)linkageExecuteActivity.KeepTime, code);
|
|||
|
|
if (!apply)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(camera.DevName + "权限获取失败", "摄像头error");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
var preset = _webApiRequest.GetVideoDevData(linkageExecuteActivity.PresetPointId).Item2;
|
|||
|
|
var nvr = camera.Parent;
|
|||
|
|
CameraBrand cb = CameraBrand.None;
|
|||
|
|
Enum.TryParse(nvr.ManufacturerInfo.ManufacturerCode, out cb);
|
|||
|
|
if (cb == CameraBrand.None)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler("[" + nvr.DevName + "]NVR厂商品牌不正确！", "摄像头error");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VideoPlayer videoPlayer = new VideoPlayer();
|
|||
|
|
videoPlayer.CameraConfigure = new CameraConfigure
|
|||
|
|
{
|
|||
|
|
ID = nvr.Id.ToString(),
|
|||
|
|
Name = nvr.DevName,
|
|||
|
|
Ip = nvr.IP,
|
|||
|
|
Port = (int)nvr.Port,
|
|||
|
|
UserName = nvr.DevUserName,
|
|||
|
|
Password = nvr.DevPassword,
|
|||
|
|
IsRecordVideo = false,
|
|||
|
|
//VideoPath = @".\Video\",
|
|||
|
|
//CapturePath = @".\Capture\",
|
|||
|
|
CameraBrand = cb,
|
|||
|
|
//PlayChannel = Convert.ToInt32(camera.ChannelNo)
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
|
|||
|
|
var player = _cameraDataCenter.FindCamera(videoPlayer);
|
|||
|
|
if (player == null)
|
|||
|
|
{
|
|||
|
|
var isloginSuccess = videoPlayer.LoginCamera();
|
|||
|
|
if (isloginSuccess)
|
|||
|
|
{
|
|||
|
|
_cameraDataCenter.CameraCollection.Add(videoPlayer);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler($"{videoPlayer.CameraConfigure.Name}登陆失败", "异常信息");
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
videoPlayer = player;
|
|||
|
|
}
|
|||
|
|
bool isSccess = videoPlayer.GotoPreset(preset.Number, Convert.ToInt32(camera.ChannelNo)); ///转到预置位 枪机不同的型号表现不同，这里采用不管转预置位的成功与否
|
|||
|
|
|
|||
|
|
//是否拍照
|
|||
|
|
if (linkageExecuteActivity.IsCapturePicture)
|
|||
|
|
{
|
|||
|
|
Task.Delay(linkageExecuteActivity.KeepTime.HasValue ? (int)linkageExecuteActivity.KeepTime * 1000 : 0).Wait();
|
|||
|
|
// 执行拍照动作
|
|||
|
|
var req1 = new ApplyControlToExternalInput()
|
|||
|
|
{
|
|||
|
|
Code = code,
|
|||
|
|
CamNames = new List<string>() { camera.DevName }
|
|||
|
|
};
|
|||
|
|
_webApiRequest.SendFreeCamAuth(req1);
|
|||
|
|
var res = LinkActivesCaptureJPEGPicture(videoPlayer, camera, preset, ref listFiles);
|
|||
|
|
//if (camera.IsInfraredCamera)
|
|||
|
|
//{
|
|||
|
|
// var res = LinkActivesCaptureJPEGPicture(videoPlayer, camera, preset, ref listFiles);
|
|||
|
|
// var filePath = res.Item2;
|
|||
|
|
// if (res.Item1) //拍照成功
|
|||
|
|
// {
|
|||
|
|
// //根据预置点查找测温点信息
|
|||
|
|
// List<MeasureTemperaturePoint> mesurePonitInfos = _webApiRequest.GetMeasurePointInfoByPresetPointId(preset.Id);
|
|||
|
|
// DrawMeasurePointInfo(mesurePonitInfos, ref filePath);
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
//else
|
|||
|
|
//{
|
|||
|
|
// var res = LinkActivesCaptureJPEGPicture(videoPlayer, camera, preset, ref listFiles);
|
|||
|
|
|
|||
|
|
//}
|
|||
|
|
}
|
|||
|
|
//是否录像
|
|||
|
|
if (linkageExecuteActivity.IsRecordVideo)
|
|||
|
|
{
|
|||
|
|
//var res = LinkActivesRecordVideoAsync(videoPlayer, camera, preset, linkageExecuteActivity.RecordDuration).GetAwaiter().GetResult();
|
|||
|
|
//if (res.Item1)
|
|||
|
|
//{
|
|||
|
|
// req.Message += $"相机:{camera.DevName}\r\n预置点:{preset.Name}\r\n结果信息:录像成功\r\n";
|
|||
|
|
// if (res.Item3 != null)
|
|||
|
|
// listFiles.AddRange(res.Item3);
|
|||
|
|
//}
|
|||
|
|
//else
|
|||
|
|
//{
|
|||
|
|
// req.Message += $"相机:{camera.DevName}\r\n预置点:{preset.Name}\r\n结果信息:录像失败\r\n";
|
|||
|
|
//}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(ex.ToString(), "摄像头error");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(ex.ToString(), "异常信息");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//private void DrawMeasurePointInfo(List<MeasureTemperaturePoint> mesurePonitInfos, ref string filePath)
|
|||
|
|
//{
|
|||
|
|
// foreach (var mesurePonitInfo in mesurePonitInfos)
|
|||
|
|
// {
|
|||
|
|
// var tmpValue = _webApiRequest.GetMeasurePointNearestValue((Guid)mesurePonitInfo.PresetPointId, mesurePonitInfo.Number);
|
|||
|
|
// List<MeasureTempCoordinate> measureTempCoordinates = JsonConvert.DeserializeObject<List<MeasureTempCoordinate>>(mesurePonitInfo.CoordinateJsonStr);
|
|||
|
|
// if (measureTempCoordinates != null && measureTempCoordinates.Count > 0)
|
|||
|
|
// {
|
|||
|
|
// SkiaSharpHandlePicture skiaSharpHandlePicture = new SkiaSharpHandlePicture();
|
|||
|
|
// //温度值采用四舍五入的方式保留两位小数
|
|||
|
|
// //绘图
|
|||
|
|
// //返回的文件路径作为下次绘图的底图
|
|||
|
|
// skiaSharpHandlePicture.Bitmap(measureTempCoordinates, ref filePath, $"{mesurePonitInfo.Name}:{ Math.Round(tmpValue, 2)}℃");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 截图
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="videoPlayer"></param>
|
|||
|
|
/// <param name="camera"></param>
|
|||
|
|
/// <param name="preset"></param>
|
|||
|
|
private (bool, string) LinkActivesCaptureJPEGPicture(VideoPlayer videoPlayer, VideoDev camera,
|
|||
|
|
PresetPointProperty preset, ref List<AttachmentFile> listFiles)
|
|||
|
|
{
|
|||
|
|
if (!Directory.Exists("./CaptureJPEGPicture"))
|
|||
|
|
{
|
|||
|
|
Directory.CreateDirectory("./CaptureJPEGPicture");
|
|||
|
|
}
|
|||
|
|
var name = $"{camera.DevName}_{preset.Name}_{DateTime.Now.ToString("HHmmss")}_{Guid.NewGuid().ToString()}.jpg";
|
|||
|
|
var fileName = $"./CaptureJPEGPicture/{name}";
|
|||
|
|
var filePath = Path.GetFullPath(fileName);
|
|||
|
|
var res = videoPlayer.CaptureJPEGPicture(filePath, Convert.ToInt32(camera.ChannelNo));
|
|||
|
|
if (res)
|
|||
|
|
{
|
|||
|
|
listFiles.Add(new AttachmentFile
|
|||
|
|
{
|
|||
|
|
FileExtension = ".jpg",
|
|||
|
|
FileName = name,
|
|||
|
|
FileType = AttachmentFileType.Photo
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
return (res, filePath);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行遥控联动
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="item"></param>
|
|||
|
|
public void ImplementTeleCommandAction(LinkageExecuteActivityOutput item, ref LinkageResultInput req)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var telecommand = _runningDataCache.TelecommandModels.FirstOrDefault(t => t.Id == item.TelecommandConfigurationId);
|
|||
|
|
if (telecommand != null)
|
|||
|
|
{
|
|||
|
|
telecommand.CommandValue = item.TelecommandValue;
|
|||
|
|
telecommand.Source = "服务联动";
|
|||
|
|
telecommand.Sender = telecommand.Name;
|
|||
|
|
//发送给104装置
|
|||
|
|
_teleCommandDataSendTask.TelecommandTActionBlock.Post(new DataCollection.TelcommandDataModel()
|
|||
|
|
{
|
|||
|
|
Telecommand = telecommand
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
MonitoringEventBus.LogHandler(ex.ToString(), "异常信息");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|