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

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using Ropin.Core.Extensions.Redis;
using Ropin.Core.Extensions;
using Ropin.Inspection.Api.Common.Options;
using Ropin.Inspection.Api.Common.Token;
using Ropin.Inspection.Service.Interface;
using Ropin.Inspection.Service.SYS.Interface;
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.AspNetCore.Identity;
using Microsoft.Extensions.Configuration;

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 string IsUpdateAI = "false";
        public AIController(IHttpClientFactory httpClientFactory, ITsysMessageService tsysMessageService, IPushMsgService pushMsgService, IConfiguration configuration)
        {
            aIHelper = new AIProjectHelper(httpClientFactory);
            _TsysMessageService = tsysMessageService;
            _pushMsgService = pushMsgService;
            string IsUpdate = configuration.GetSection("AIIsUpdate")?.Value;
            IsUpdateAI = !string.IsNullOrEmpty(IsUpdate) ? IsUpdate : "false";
        }
        /// <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, 100, 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);
        }
    }
}