using Cis.Application.Core.Component.PtzServer; using Cis.Core.Common; using EC.Helper.CameraSDK; using Newtonsoft.Json.Linq; namespace Cis.Application.Cm; /// /// 标签服务 /// [ApiDescriptionSettings(CmInfo.GroupName, Order = CmInfo.GroupOrder)] public class CmMarkLabelService : ServiceBase, ITransient { private ICameraSdkServer _cameraSdk { get; set; } public CmMarkLabelService(SqlSugarRepository baseRep, ICameraSdkServer cameraSdk) : base(baseRep) { _cameraSdk = cameraSdk; } [HttpPost] public override async Task Add([FromForm] CmMarkLabel entity) { bool ret = _cameraSdk.TryGetPtzInfoById(entity.CbCameraId.ToString(), out PtzInfo ptzInfo); if (!ret) return false; entity.PanPosition = ptzInfo.Pan; entity.TiltPosition = ptzInfo.Tilt; entity.ZoomPosition = ptzInfo.Zoom; return await _baseRep.InsertAsync(entity); } [HttpPost] public override async Task AddReturnId([FromForm] CmMarkLabel entity) { bool ret = _cameraSdk.TryGetPtzInfoById(entity.CbCameraId.ToString(), out PtzInfo ptzInfo); if (!ret) return 0; entity.PanPosition = ptzInfo.Pan; entity.TiltPosition = ptzInfo.Tilt; entity.ZoomPosition = ptzInfo.Zoom; await _baseRep.InsertAsync(entity); return entity.Id; } /// /// /// /// equal:cbCameraId,cmMarkGroupId; like:name; between:[startTime,endTime]; /// [HttpGet] public override async Task> GetList(string queryJson = "") { JObject queryObj = queryJson.ToJObject(); var exp = Expressionable.Create(); if (queryObj.TryGetValue("cbCameraId", StringComparison.OrdinalIgnoreCase, out JToken cbCameraId)) exp.And(it => it.CbCameraId.Equals(cbCameraId)); if (queryObj.TryGetValue("cmMarkGroupId", StringComparison.OrdinalIgnoreCase, out JToken cmMarkGroupId)) exp.And(it => it.CmMarkGroupId.Equals(cmMarkGroupId)); if (queryObj.TryGetValue("name", StringComparison.OrdinalIgnoreCase, out JToken name)) exp.And(it => it.Name.Contains(name.ToString())); if (queryObj.TryGetValue("StartTime", StringComparison.OrdinalIgnoreCase, out JToken startTime) && queryObj.TryGetValue("EndTime", StringComparison.OrdinalIgnoreCase, out JToken endTime)) exp.And(it => it.CreateTime >= startTime.ToDateTime() && it.CreateTime <= endTime.ToDateTime()); var list = await _baseRep.AsQueryable() .Where(exp.ToExpression()) .ToListAsync(); return list; } /// /// /// /// equal:cbCameraId,cmMarkGroupId; like:name; between:[startTime,endTime]; /// index,size /// [HttpGet] public override async Task> GetPageList(string queryJson, string pagination) { JObject queryObj = queryJson.ToJObject(); Pagination pageObj = pagination.ToObject(); var exp = Expressionable.Create(); if (queryObj.TryGetValue("cbCameraId", StringComparison.OrdinalIgnoreCase, out JToken cbCameraId)) exp.And(it => it.CbCameraId.Equals(cbCameraId)); if (queryObj.TryGetValue("cmMarkGroupId", StringComparison.OrdinalIgnoreCase, out JToken cmMarkGroupId)) exp.And(it => it.CmMarkGroupId.Equals(cmMarkGroupId)); if (queryObj.TryGetValue("name", StringComparison.OrdinalIgnoreCase, out JToken name)) exp.And(it => it.Name.Contains(name.ToString())); if (queryObj.TryGetValue("StartTime", StringComparison.OrdinalIgnoreCase, out JToken startTime) && queryObj.TryGetValue("EndTime", StringComparison.OrdinalIgnoreCase, out JToken endTime)) exp.And(it => it.CreateTime >= startTime.ToDateTime() && it.CreateTime <= endTime.ToDateTime()); var list = await _baseRep.AsQueryable() .Where(exp.ToExpression()) .ToPageListAsync(pageObj.Index, pageObj.Size); return list; } }