qlhb/Ropin.Inspection.Api/Controllers/Base/AIController.cs

using Microsoft.AspNetCore.Mvc;
using Ropin.Inspection.Service;
using System.Net.Http;
using Ropin.Inspection.Common.Helper;
using Microsoft.AspNetCore.Authorization;
using Ropin.Inspection.Api.Common;
using System.Threading.Tasks;
using Ropin.Inspection.Model;
using System.Collections.Generic;
using System;
using Newtonsoft.Json;
using Microsoft.Extensions.Configuration;
using Ropin.Inspection.Service.VMC.Interface;
using Newtonsoft.Json.Linq;
using System.IO;

namespace Ropin.Inspection.Api.Controllers.Base
{
    public class AIController : BaseController
    {
        private readonly IHttpClientFactory _httpClientFactory;
        private readonly AIProjectHelper aIHelper;
        private readonly ITsysMessageService _TsysMessageService;
        private readonly IPushMsgService _pushMsgService;
        private readonly IVmcCameraService _vmcCameraService;
        private string IsUpdateAI = "false";
        private static readonly log4net.ILog log = log4net.LogManager.GetLogger(typeof(AIController));
        public AIController(IHttpClientFactory httpClientFactory, ITsysMessageService tsysMessageService, IPushMsgService pushMsgService, IConfiguration configuration, IVmcCameraService vmcCameraService)
        {
            aIHelper = new AIProjectHelper(httpClientFactory);
            _TsysMessageService = tsysMessageService;
            _pushMsgService = pushMsgService;
            string IsUpdate = configuration.GetSection("AIIsUpdate")?.Value;
            IsUpdateAI = !string.IsNullOrEmpty(IsUpdate) ? IsUpdate : "false";
            _vmcCameraService = vmcCameraService;
        }
        /// <summary>
        /// AI会话
        /// </summary>
        /// <returns></returns>
        [HttpPost("AiConversation")]
        [AllowAnonymous]
        public async Task<object> AiConversation(AIConversationSearch search)
        {
            var meg = await aIHelper.AiConversation(search);
            return new ApiResult<object>(meg);
        }

        /// <summary>
        /// AI登录
        /// </summary>
        /// <returns></returns>
        [HttpGet("AiLogin")]
        [AllowAnonymous]
        public async Task<AILoginOutput> AiLogin()
        {
            var token = await aIHelper.GetToken();
            return token;
        }

        /// <summary>
        /// AI-获取历史报警记录
        /// </summary>
        /// <returns></returns>
        [HttpGet("AiHistoricAlmrecord/{Devno}/{Page}/{pageSize}")]
        [AllowAnonymous]
        public async Task<ApiResult<AISqlSugarPagedList<AlmRecordOutput>>> AiHistoricAlmrecord(string Devno, int Page = 1, int pageSize = 10, long? entityId = null)
        {
            var data = await aIHelper.GetHistoricAlmrecord(Devno, Page, pageSize, entityId);
            return new ApiResult<AISqlSugarPagedList<AlmRecordOutput>>(data, ReturnCode.Success);
        }
        /// <summary>
        /// AI-获取报警处理列表
        /// </summary>
        /// <returns></returns>
        [HttpGet("AiAlmDispose/{Devno}/{Page}/{pageSize}")]
        [AllowAnonymous]
        public async Task<ApiResult<AISqlSugarPagedList<AlmRecordOutput>>> AiAlmDispose(string Devno, int Page = 1, int pageSize = 10, long? entityId = null)
        {
            var data = await aIHelper.GetAlmDispose(Devno, Page, pageSize, entityId);
            return new ApiResult<AISqlSugarPagedList<AlmRecordOutput>>(data, ReturnCode.Success);
        }
        /// <summary>
        /// AI-报警数据保存到环保消息表数据
        /// </summary>
        /// <returns></returns>
        [HttpGet("AiAlmSaveMessage")]
        [AllowAnonymous]
        public async Task<ApiResult> AiAlmSaveMessage()
        {
            //40124884581189；33379713109829
            var data = await aIHelper.GetAlmDispose("", 1, 10, 40124884581189);
            //var data = await aIHelper.GetHistoricAlmrecord("", 1, 10, 40124884581189);
            if (data != null)
            {
                foreach (var item in data.Items)
                {
                    if (item != null)
                    {
                        var textJson = new
                        {
                            PanoramaId = item.PanoramaId,
                            PanoramaUrl = item.PanoramaUrl,
                            RoiJson = item.RoiJson,
                            NonRoiJson = item.NonRoiJson,
                            DetectionFrameJson = item.DetectionFrameJson
                        };
                        var datas = JsonConvert.SerializeObject(textJson);
                        MessageFile messageFile = new MessageFile();
                        messageFile.Text = datas;
                        messageFile.Type = "FILE_TYP_006";
                        string msg = item.Event_Name;
                        if (string.IsNullOrEmpty(msg))
                        {
                            msg = item.Event_Code;
                        }
                        TpushMsgModel model = new TpushMsgModel
                        {
                            C_DevStoreCode = "d705ceb5-7473-4b19-91dd-d3eff223f05b",
                            C_MsgTypeCode = "MSG_TYPE_024",
                            Subject = item.Device_TypeName + "报警",
                            Msg = msg,
                            UserName = "AI盒子",
                            UserMobile = "",
                            CreateOn = item.StartTime?.ToString("yyyy-MM-dd HH:mm:ss"),
                            GenerationType = 1,
                            msgStatus = 1,
                            FileList = new List<MessageFile> { messageFile }
                        };
                        bool bol = await _pushMsgService.PushAlarmMsgAsync(model, model.Subject);
                        if (bol && IsUpdateAI == "true")
                        {
                            DateTime updTime = DateTime.Now;
                            var updData = new
                            {
                                Id = item.Id,
                                ConfrimContent = "环保测试数据，自动确认",
                                Mistake = false,
                                Confirmed = true,
                                ConfirmTime = updTime,
                                ConfirmUserName = "环保同步程序",
                                Closed = true,
                                CloseContent = "环保测试数据，自动关闭",
                                EndTime = updTime,
                                CloseUserName = "环保同步程序"
                            };
                            var dataStr = JsonConvert.SerializeObject(updData);
                            bool result = await aIHelper.UpdateAlm(dataStr);
                            //bool result = await aIHelper.UpdateAlmIsDelete(item.Id);
                        }
                    }
                }
            }
            //TsysMessageSearchModel searchModel = new TsysMessageSearchModel();
            //searchModel.IsPagination = true;
            //searchModel.C_MsgTypeCode = "MSG_TYPE_024";
            //var msgData = await _TsysMessageService.GetConditionAsync(searchModel);
            return new ApiResult(ReturnCode.Success);
        }

        
        [HttpPost]
        [AllowAnonymous]
        [Route("/device/business/generalApp/pushData/alarmData/{deviceNo}")]
        public async Task<ApiResultModel<object>> AlarmData([FromRoute] string deviceNo, [FromBody] JObject alarmDataModel)
        {
            try
            {
                string startupDirectory = Directory.GetCurrentDirectory();
                log.Info($"进入AI[/device/business/generalApp/pushData/alarmData/{deviceNo}]");
                AlarmDataModel alarmData = JsonConvert.DeserializeObject<AlarmDataModel>(alarmDataModel.ToString());
                log.Info("获取deviceNo="+ alarmData.deviceNo);
                var devIds = await _vmcCameraService.GetCameraByTDH(alarmData.deviceNo);
                log.Info($"获取到的设备ID：【{JsonConvert.SerializeObject(devIds)}】");
                var cameraModel = await _vmcCameraService.GetCameraEntity(alarmData.deviceNo);
                log.Info($"获取到的摄像头数据：【{JsonConvert.SerializeObject(cameraModel)}】");
                int row = 0;
                foreach (var x in devIds)
                {
                    List<MessageFile> messageFiles = new List<MessageFile>();
                    string fileRelativePath = "";
                    if (!string.IsNullOrEmpty(alarmData.panoramaDataId))
                    {
                        try
                        {
                            byte[] dataBytes = Convert.FromBase64String(s: alarmData.panoramaDataId);
                            var relativePath = Path.Combine("wwwroot/uploads/images/", DateTime.Now.ToString("yyyyMM"));
                            var directoryPath = Path.Combine(startupDirectory, relativePath);
                            string imgName = $"{alarmData.panoramaId}.png";
                            fileRelativePath = "/" + Path.Combine(relativePath + "/", imgName);
                            if (!Directory.Exists(directoryPath))
                            {
                                Directory.CreateDirectory(directoryPath);
                            }
                            var filePath = Path.Combine(directoryPath + "/", imgName);// 替换为你想要保存的文件路径及名称
                            using FileStream fs = new FileStream(filePath, FileMode.Create);
                            fs.Write(dataBytes, 0, dataBytes.Length);
                            fs.Close();
                        }
                        catch (Exception ex)
                        {
                            fileRelativePath = "";
                            log.Info("全景图异常：" + ex.Message);
                        }
                    }
                    var textJson = new
                    {
                        PanoramaId = alarmData.panoramaId,
                        PanoramaUrl = fileRelativePath,//alarmData.panoramaUrl,
                        RoiJson = alarmData.roiJson,
                        NonRoiJson = alarmData.nonRoiJson,
                        DetectionFrameJson = alarmData.detectionFrameJson
                    };
                    var datas = JsonConvert.SerializeObject(textJson);
                    MessageFile messageFile = new MessageFile();
                    messageFile.Text = datas;
                    messageFile.Type = "FILE_TYP_006";
                    messageFiles.Add(messageFile);
                    TpushMsgModel model = new TpushMsgModel
                    {
                        C_DevStoreCode = x,
                        C_MsgTypeCode = "MSG_TYPE_024",
                        Subject = cameraModel==null?"AI盒子报警": cameraModel.C_Name+"报警",
                        Msg = alarmData.alarmTypeChineseName,
                        UserName = cameraModel == null ? "AI盒子" : cameraModel.C_Name,
                        UserMobile = "",
                        CreateOn = alarmData.captureTime,
                        GenerationType = 1,
                        msgStatus = 1,
                        FileList = messageFiles
                    };
                    bool bol = await _pushMsgService.PushAlarmMsgAsync(model, model.Subject);
                    log.Info($"执行发送结果=[{bol}]");
                    if (bol) { row++; }
                }
                return ApiResultModel<object>.GetSuccess(row);
            }
            catch (Exception ex)
            {
                log.Info("异常："+ex.Message);
                return ApiResultModel<object>.GetSuccess(0);
            }
            //return await Task.FromResult(ApiResultModel<object>.GetSuccess(new object { }));
        }
        //[HttpPost]
        //[AllowAnonymous]
        //[Route("/device/business/generalApp/pushData/alarmData/{deviceNo}")]
        //public async Task<ApiResultModel<object>> AlarmData([FromRoute] string deviceNo, AlarmDataModel alarmDataModel)
        //{
        //    Console.WriteLine("进入/device/business/generalApp/pushData/alarmData/" + deviceNo);
        //    var devIds = await _vmcCameraService.GetCameraByTDH(alarmDataModel.deviceNo);
        //    int row = 0;
        //    foreach (var x in devIds)
        //    {
        //        List<MessageFile> messageFiles = new List<MessageFile>();
        //        var textJson = new
        //        {
        //            PanoramaId = alarmDataModel.panoramaId,
        //            PanoramaUrl = alarmDataModel.panoramaUrl,
        //            RoiJson = alarmDataModel.roiJson,
        //            NonRoiJson = alarmDataModel.nonRoiJson,
        //            DetectionFrameJson = alarmDataModel.detectionFrameJson
        //        };
        //        var datas = JsonConvert.SerializeObject(textJson);
        //        MessageFile messageFile = new MessageFile();
        //        messageFile.Text = datas;
        //        messageFile.Type = "FILE_TYP_006";
        //        messageFiles.Add(messageFile);
        //        TpushMsgModel model = new TpushMsgModel
        //        {
        //            C_DevStoreCode = x,
        //            C_MsgTypeCode = "MSG_TYPE_024",
        //            Subject = "AI盒子报警",
        //            Msg = alarmDataModel.alarmType,
        //            UserName = "AI盒子",
        //            UserMobile = "",
        //            CreateOn = alarmDataModel.captureTime,
        //            GenerationType = 1,
        //            msgStatus = 1,
        //            FileList = messageFiles
        //        };
        //        bool bol = await _pushMsgService.PushAlarmMsgAsync(model, model.Subject);
        //        log.Info($"执行发送结果=[{bol}]");
        //        if (bol) { row++; }
        //    }
        //    return ApiResultModel<object>.GetSuccess(row);
        //    //return await Task.FromResult(ApiResultModel<object>.GetSuccess(new object { }));
        //}

        /// <summary>
        /// 注册
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="registerModel"></param>
        /// <returns></returns>
        [HttpPost]
        [AllowAnonymous]
        [Route("/api/base/deviceServerSdk/register/{deviceNo}")]
        public async Task<ApiResultModel<object>> Register([FromRoute] string deviceNo, [FromBody] RegisterModel registerModel)
        {
            return await Task.FromResult(ApiResultModel<object>.GetSuccess(new object { }));
        }

        /// <summary>
        /// 状态变化
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="statusChangeModel"></param>
        /// <returns></returns>
        [HttpPost]
        [AllowAnonymous]
        [Route("/api/base/deviceServerSdk/statusChange/{deviceNo}")]
        public async Task<ApiResultModel<object>> StatusChange([FromRoute] string deviceNo, [FromBody] StatusChangeModel statusChangeModel)
        {
            return await Task.FromResult(ApiResultModel<object>.GetSuccess(new object { }));
        }

        /// <summary>
        /// 心跳
        /// </summary>
        /// <param name="heartbeatModel"></param>
        /// <returns></returns>
        [HttpPost]
        [AllowAnonymous]
        [Route("/api/base/deviceServerSdk/heartbeat")]
        public async Task<ApiResultModel<object>> Heartbeat([FromBody] HeartbeatModel heartbeatModel)
        {
            return await Task.FromResult(ApiResultModel<object>.GetSuccess(new object { }));
        }
    }

    public class RegisterModel
    {
        public string username { get; set; }
        public string password { get; set; }
    }

    public class StatusChangeModel
    {
        public int status { get; set; }
    }

    public class HeartbeatModel
    {
        public DateTime startTime { get; set; }
    }
    
    /// <summary>
     /// api结果模型
     /// </summary>
    public class ApiResultModel
    {
        /// <summary>
        /// api状态枚举
        /// </summary>
        public int Code { get; set; }

        /// <summary>
        /// 成功、错误消息
        /// </summary>
        public string? Msg { get; set; }
    }

    /// <summary>
    /// api结果模型，带着数据
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public class ApiResultModel<T> : ApiResultModel where T : new()
    {
        /// <summary>
        /// 返回数据
        /// </summary>
        public T? Data { get; set; }

        /// <summary>
        /// 获取成功返回对象
        /// </summary>
        /// <param name="data">返回数据</param>
        /// <returns></returns>
        public static ApiResultModel<T> GetSuccess(T data)
        {
            ApiResultModel<T> apiResult = new ApiResultModel<T>();
            apiResult.Data = data;
            apiResult.Code = 0;
            apiResult.Msg = "成功";
            return apiResult;
        }
    }
}