pinganxiaoyuan/SafeCampus.API/SafeCampus.Web.Core/Controllers/Application/Business/WarnInfoController.cs

using MoYu.RemoteRequest.Extensions;
using Newtonsoft.Json.Linq;
using SafeCampus.Application.Manager.DeepelephManager;
using SafeCampus.Application.Services.Business.Warn.Dto;
using SafeCampus.Application.Services.Business.Warn.Service;
using SimpleTool;
using SafeCampus.Core.Extension;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Logical;
using SafeCampus.Application.Services.Business;
using SafeCampus.Web.Core.Controllers.Application.Business.Dto;
using System.Collections.Generic;
using SafeCampus.Application.Services.Business.CameraInfoService;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SafeCampus.Core.Utils;
using MoYu.FriendlyException;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Information;

namespace SafeCampus.Web.Core.Controllers.Application.Business;
/// <summary>
/// 预警事件查询接口
/// </summary>
[ApiDescriptionSettings(ApiGroupConsts.SYSTEM_Business, Order = 92, Tag = "预警事件")]
[Route("/business/warn")]
[RolePermission]
public class WarnInfoController
{
    private readonly IWarnInfoService _warnInfoService;
    private readonly IDeepelephManager _deepelephManager;
    private readonly ISimpleCacheService _simpleCacheService;
    private readonly IConfigService _configService;
    private readonly ICameraInfoService _cameraInfoService;
    private readonly ISysUserService _sysUserService;

    public WarnInfoController(IWarnInfoService warnInfoService, IDeepelephManager deepelephManager, ISimpleCacheService simpleCacheService, IConfigService configService, ICameraInfoService cameraInfoService, ISysUserService sysUserService)
    {
        _warnInfoService = warnInfoService;
        _deepelephManager = deepelephManager;
        _simpleCacheService = simpleCacheService;
        _configService = configService;
        _cameraInfoService = cameraInfoService;
        _sysUserService = sysUserService;
    }

    /// <summary>
    /// 删除预警信息
    /// </summary>
    /// <param name="Id"></param>
    /// <returns></returns>
    [HttpPost]
    public async Task<bool> DeleteInfoD(BaseIdListInput input)
    {
        return await _warnInfoService.DeleteBatch(input.Ids);
    }
    /// <summary>
    /// 编辑预警信息
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<bool> UpdateInfoU(WarnInfoDto input)
    {
        return await _warnInfoService.Update(input);
    }
    /// <summary>
    /// 获取预警信息
    /// </summary>
    /// <param name="Id"></param>
    /// <returns></returns>
    public async Task<WarnInfoDto> GetInfo(long Id)
    {
        var model = await _warnInfoService.GetInfo(Id);
        var config = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        if (!string.IsNullOrEmpty(model.Extend))
        {
            if (string.IsNullOrEmpty(model.PersonId))
            {
                var extend = JsonConvert.DeserializeObject<JObject>(model.Extend);
                model.Extend = extend["age"] != null ? $"年龄：{extend["age"]};年龄置信度：{Convert.ToInt32(Convert.ToDecimal(extend["ageProb"]) * 100)}%;" : "";
            }
            
        }
        if (model.AlarmType == "crowd")
        {
            model.Extend = $"人群聚集数量：{model.Count}";
        }

        if (config!=null)
        {
            model.SceneName = config.FirstOrDefault(x =>
                x.Subset.Any(xx => xx.Code == model.AlarmType) &&
                x.Subset.Any(xx => xx.CameraId.Contains(model.CameraId)))?.Name;
        }
        try
        {
            var appSettings = App.GetOptionsMonitor<AppInfoOptions>();
            var str = await $"{appSettings.SXAPIURL}/dfield-api/ecology/alarm/query"
                .SetBody(new
                {
                    token = _deepelephManager.GetToken(),
                    tenantCode = appSettings.TenantCode,
                    poiId = appSettings.PoiId,
                    alarmId = model.AlarmId
                })
                .SetContentType("application/json")
                .PostAsAsync<string>();
            var json = JsonConvert.DeserializeObject<JObject>(str);
            if ((bool)json["success"])
            {
                if (json["data"]["videoUrl"] != null)
                {
                    model.VideoUrl = json["data"]["videoUrl"].ToString();
                }
            }
        }
        catch (SystemException)
        {

        }

        return model;
    }
    /// <summary>
    /// 获取预警信息列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [AllowAnonymous]
    public async Task<SqlSugarPagedList<WarnInfoList>> GetList([FromQuery] WarnInfoSearch input)
    {
        var config = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        var page= await _warnInfoService.GetList(input);
        if (config == null) return page;
        foreach (var item in page.List)
        {
            item.SceneName = config.FirstOrDefault(x =>
                x.Subset.Any(xx => xx.Code == item.AlarmType) && x.Subset.Any(xx=>xx.CameraId.Contains(item.CameraId)))?.Name;
        }
        return page;
    }
    /// <summary>
    /// 获取告警分组
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetWarnGroup(string cameraId)
    {
        var list = new List<WarnGroupInfo>();
        list = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        if (list != null)
        {
            foreach (var item in list)
            {
                if (item.PushUserId.HasValue)
                {
                    var user = await _sysUserService.Detail(new BaseIdInput { Id = item.PushUserId.Value });
                    item.PushUserName = user.Name;
                    item.PushPhone = user.Phone;
                }
               
            }
            return !string.IsNullOrEmpty(cameraId) ? list.Where(x => x.CameraId.Contains(cameraId)).ToList() : list;
        }
        var basePath = AppContext.BaseDirectory;//获取项目目录
        var json = basePath.CombinePath("SeedData", "Json", "WarnGroup.json");//获取文件路径
        var dataString = FileHelper.ReadFile(json);//读取文件
        list = JsonConvert.DeserializeObject<List<WarnGroupInfo>>(dataString);
        _simpleCacheService.Set(SafeCampusConst.WarnGroup, list);
        return list.Where(x=>x.CameraId.Contains(cameraId)).ToList();
    }
    /// <summary>
    /// 设置场景开关
    /// </summary>
    /// <returns></returns>
    public async Task<bool> SetWarnGroupDevice(ConfigJsonInput input)
    {
        var jsonList = JsonConvert.DeserializeObject<List<WarnGroupInfo>>(input.ConfigJson);
        var oldlist = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        foreach (var item in jsonList)
        {
            var model = oldlist.FirstOrDefault(x => x.Code == item.Code);
            if (model != null)
            {
                model.Subset = item.Subset;
                model.CameraId=item.Subset.Select(x=>x.CameraId).SelectMany(x=>x).ToList();
                model.CameraName=item.Subset.Select(x=>x.CameraName).SelectMany(x=>x).ToList();
            }
        }
        _simpleCacheService.Set(SafeCampusConst.WarnGroup, oldlist);
        return true;
    }
    /// <summary>
    /// 根据预警分组设置推送人
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<bool> SetPushPersonByWarn(SetPushPersonWarnInput input)
    {
        var warn = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        var warnGroupInfo = warn.FirstOrDefault(x => x.Code == input.WarnCode);
        if (warnGroupInfo != null) warnGroupInfo.PushUserId = input.UserId;
        _simpleCacheService.Set(SafeCampusConst.WarnGroup, warn);
        return true;
        //return await _cameraInfoService.BatchSetPushPersonByWarn(input);
    }
    /// <summary>
    /// 关联摄像头和告警分组
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<bool> SetWarnGroupCamera(ConfigJsonCamera input)
    {
        var list = _simpleCacheService.Get<List<WarnGroupInfo>>(SafeCampusConst.WarnGroup);
        var model = list.FirstOrDefault(x => x.Code == input.Code);
        if (model != null)
        {
            model.CameraId = input.CameraList;
        }
        _simpleCacheService.Set(SafeCampusConst.WarnGroup, list);
        return true;
    }
    /// <summary>
    /// 设置预警推送设置
    /// </summary>
    /// <returns></returns>
    public async Task<bool> SetWarnPushSetting(ConfigPush push)
    {
        var sysConfig=await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_STATES);
        if (sysConfig != null)
        {
            await _configService.Edit(new ConfigEditInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_STATES,
                ConfigValue = push.PushState.ToString()
            });
        }
        else
        {
            await _configService.Add(new ConfigAddInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_STATES,
                ConfigValue = push.PushState.ToString()
            });
        }
        var sysConfigDay = await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_STATES_DAY);
        if (sysConfigDay != null)
        {
            await _configService.Edit(new ConfigEditInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_STATES_DAY,
                ConfigValue = push.DaySum.ToString()
            });
        }
        else
        {
            await _configService.Add(new ConfigAddInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_STATES_DAY,
                ConfigValue = push.DaySum.ToString()
            });
        }
        var sysConfigInterval = await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_INTERVAL);
        if (sysConfigInterval != null)
        {
            await _configService.Edit(new ConfigEditInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_INTERVAL,
                ConfigValue = push.Interval.ToString()
            });
        }
        else
        {
            await _configService.Add(new ConfigAddInput
            {
                Category = CateGoryConst.CONFIG_BIZ_DEFINE,
                ConfigKey = BizConfigConst.BIZ_SMS_INTERVAL,
                ConfigValue = push.Interval.ToString()
            });
        }
        return true;
    }
    /// <summary>
    /// 获取预警推送内容
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetWarnPushSetting()
    {
        var sysConfigInterval= await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_INTERVAL);
        var configPush = new ConfigPush
        {
            PushState = (await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_STATES))
                .ConfigValue.ToBoolean(),
            DaySum = (await _configService.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, BizConfigConst.BIZ_SMS_STATES_DAY))
                .ConfigValue.ToInt(),
            Interval = sysConfigInterval==null?0: sysConfigInterval.ConfigValue.ToInt()
        };
        return configPush;
    }
    /// <summary> 
    /// 预警统计-饼图 Alarm 今日告警情况，Hand今日处理情况
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetWarnStatistics()
    {
        //今日告警情况饼图
        //今日处理情况

        var startTime = DateTime.Now.Date;
        var entTime = DateTime.Now;

        var list = await _warnInfoService.GetListNoPage(new WarnInfoSearch
        {
            StartTick = startTime,
            EndTick = entTime

        });
        var warnType = typeof(AlarmType).EnumToEnumModel();
        var alarmStatistics = warnType.Select(x => new
        {
            Name = x.Description,
            Code=x.Name,
            Count = list.Count(xx => xx.AlarmType == x.Name)
        }).Where(x => x.Count > 0).ToList();
        var numbers = new Dictionary<int, string> { { 0, "未处理" }, { 1, "已处理" } };
        var handStatistics = numbers.Select(x => new
        {
            Name = x.Value,
            Count = list.Count(xx => xx.WarnHand == x.Key)
        }).ToList();
        return new { Alarm = alarmStatistics, Hand = handStatistics };
    }
    /// <summary>
    /// 获取七天统计柱状图
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetWeekWarnStatistics()
    {
        var result = new StatistionModel
        {
           DataX = new List<string>(),
           DataY = new List<SeriesData>()
        };
        var startTime = DateTime.Now.AddDays(-7).Date;
        var entTime = DateTime.Now;

        var list = await _warnInfoService.GetListNoPage(new WarnInfoSearch
        {
            StartTick = startTime,
            EndTick = entTime

        });
        //var warnType = typeof(AlarmType).EnumToEnumModel();
        var climb_over = new List<int>();
        var crowd = new List<int>();
        var fire_smoke = new List<int>();
        var visual_fence = new List<int>();
        var wander = new List<int>();
        for (DateTime i = startTime; i <= entTime;)
        {
            var itemList = list.Where(x =>
                    x.Tick.Year == i.Year && x.Tick.Month == i.Month && x.Tick.Day == i.Day)
                .ToList();

            //var alarmStatistics = warnType.Where(x=>x.Value<=4).Select(x => new StatistionFunModel
            //{
            //    Name = x.Description,
            //    Code=x.Name,
            //    Count = itemList.Count(xx => xx.AlarmType == x.Name),
            //    Date = i.ToString("MM-dd")
            //}).ToList();
            result.DataX.Add(i.ToString("MM-dd"));
            climb_over.Add(itemList.Count(x=>x.AlarmType== "climb_over"));
            crowd.Add(itemList.Count(x=>x.AlarmType== "crowd"));
            fire_smoke.Add(itemList.Count(x=>x.AlarmType== "fire_smoke"));
            visual_fence.Add(itemList.Count(x=>x.AlarmType== "visual_fence"));
            wander.Add(itemList.Count(x=>x.AlarmType== "wander"));
            //result.Add(new StatistionModel
            //{
            //    Date = i.ToString("MM-dd"),
            //    visual_fence = 
            //    //FunList = alarmStatistics
            //});
            i = i.AddDays(1);
        }
        result.DataY.Add(new SeriesData
        {
            Name = AlarmType.climb_over.GetDescription(),
            Data = climb_over
        });
        result.DataY.Add(new SeriesData
        {
            Name = AlarmType.crowd.GetDescription(),
            Data = crowd
        });
        result.DataY.Add(new SeriesData
        {
            Name = AlarmType.fire_smoke.GetDescription(),
            Data = fire_smoke
        });
        result.DataY.Add(new SeriesData
        {
            Name = AlarmType.visual_fence.GetDescription(),
            Data = visual_fence
        });
        result.DataY.Add(new SeriesData
        {
            Name = AlarmType.wander.GetDescription(),
            Data = wander
        });
        return result ;
    }
    /// <summary>
    /// 获取告警枚举列表
    /// </summary>
    /// <returns></returns>
    public async Task<List<WarnType>> GetAlarmType()
    {
        return await _warnInfoService.GetWarnType();
    }
    /// <summary>
    /// 根据监控id获取大屏告警数据
    /// </summary>
    /// <returns></returns>
    [AllowAnonymous]
    public async Task<dynamic> GetLargeScreenData(string cameraId)
    {
        var startTime = DateTime.Now.AddDays(-7).Date;
        var entTime = DateTime.Now;
        var list=await _warnInfoService.GetListNoPage(new WarnInfoSearch
        {
            StartTick = startTime,
            EndTick = entTime,
            PageNum = 1,
            PageSize = 20,
            CameraId = cameraId
        });
        var warnType = typeof(AlarmType).EnumToEnumModel();
        var alarmStatistics = warnType.Select(x => new StatistionFunModel
        {
            Name = x.Description,
            Code = x.Name,
            Count = list.Count(xx => xx.AlarmType == x.Name),
        }).Where(x=>x.Count>0).ToList();
        return new { item = list, statistion = alarmStatistics };
    }
    /// <summary>
    /// 处理预警
    /// </summary>
    /// <returns></returns>
    public async Task<bool> HandWarn(HandWarnInput input)
    {
        return await _warnInfoService.HandWarn(input);
    }
    /// <summary>
    /// 获取首页基础数据
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetBaseStatistics()
    {
        var camera = await _cameraInfoService.GetCameraCount(new CameraSearch());
        var warnCount = await _warnInfoService.GetWarnCount(new WarnInfoSearch());
        var handCount = await _warnInfoService.GetWarnCount(new WarnInfoSearch{WarnHand = 1});
        var tacherCount = await _sysUserService.Page(new UserPageInput{PageSize = 2,PageNum = 1,OrgId = 0});
        return new
        {
            CameraCount= camera,
            WarnCount= warnCount,
            HandCount= handCount,
            TeacherCount= tacherCount.Total
        };
    }
    /// <summary>
    /// 获取高危信息
    /// </summary>
    /// <returns></returns>
    public async Task<dynamic> GetHighRisk()
    {
        var warnlist = await _warnInfoService.GetWarnType();
        var list = new List<dynamic>();
        //var group = warnlist.GroupBy(x => new { x.AlarmType, x.AlarmTypeDesc }).ToList();
        var startTime = DateTime.Now.AddDays(-7).Date;
        var entTime = DateTime.Now;
        foreach (var item in warnlist)
        {
                var model = new
                {
                    Name = item.Name,
                    Day =await _warnInfoService.GetWarnCount(new WarnInfoSearch { AlarmType = item.Code, EndTick = entTime, StartTick = new DateTime(entTime.Year,entTime.Month,entTime.Day).Date }),
                    Week =await _warnInfoService.GetWarnCount(new WarnInfoSearch { AlarmType = item.Code,EndTick = entTime,StartTick = startTime}),
                    Count =await _warnInfoService.GetWarnCount(new WarnInfoSearch{AlarmType = item.Code})
                };
                list.Add(model);
        }
        return list.Where(x=>x.Count>10).OrderByDescending(x=>x.Day).ToList();
    }
    /// <summary>
    /// 获取订阅配置
    /// </summary>
    /// <param name="code"></param>
    /// <param name="subsetCode"></param>
    /// <returns></returns>
    public async Task<dynamic> GetFuncConf(string subsetCode)
    {
        var appSettings = App.GetOptionsMonitor<AppInfoOptions>();
        var str = await $"{appSettings.SXAPIURL}/dfield-api/ecology/func/v1/conf/query-paged"
            .SetBody(new
            {
                token = _deepelephManager.GetToken(),
                tenantCode = appSettings.TenantCode,
                poiId = appSettings.PoiId,
                pageIndex=1,
                pageSize=1000
            })
            .SetContentType("application/json")
            .PostAsAsync<string>();
        var model = JsonConvert.DeserializeObject<JObject>(str);
        var result=new List<dynamic>();
        if ((bool)model["success"])
        {
            var list = model["data"].Where(x => x["funcType"].ToString().Contains(subsetCode));
            foreach (var item in list)
            {
                var ids = item["cameraIds"];
                var name = item["cameras"].ToString().Split('、');
                for (int i = 0; i < name.Length; i++)
                {
                    result.Add(new { id = ids[i].ToString(), name = name[i] });
                }
            }
            return result;
        }
        throw Oops.Oh(model["message"].ToString());
    }
}