qlhb/Ropin.Inspection.Service/SYS/TsysMessageService.cs

using AutoMapper;
using LinqKit;
using Newtonsoft.Json;
using Ropin.Inspection.Common.Accessor.Interface;
using Ropin.Inspection.Common.Helper;
using Ropin.Inspection.Model;
using Ropin.Inspection.Model.Entities;
using Ropin.Inspection.Repository;
using Ropin.Inspection.Repository.Interface;
using Ropin.Inspection.Repository.SYS.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace Ropin.Inspection.Service
{
    public class TsysMessageService : ITsysMessageService
    {
        private readonly ITsysMessageRepository _repository;
        private readonly ITsysMessageFileRepository _tsysMessageFileRepository;
        private readonly IMapper _mapper;
        private readonly IClaimsAccessor _claims;
        private readonly IUnitOfWork _unitOfWork;
        public TsysMessageService(IClaimsAccessor claims, ITsysMessageRepository repository, IMapper mapper, ITsysMessageFileRepository tsysMessageFileRepository, IUnitOfWork unitOfWork)
        {
            _repository = repository;
            _mapper = mapper;
            _claims = claims;
            _tsysMessageFileRepository = tsysMessageFileRepository;
            _unitOfWork = unitOfWork;
        }
        public async Task CreateOneAsync(TsysMessageViewModel viewModel)
        {
            bool result = false;
            try
            {
                _unitOfWork.BeginTransaction();

                var content = _mapper.Map<TSYS_Message>(viewModel);
                content.C_ID = StringHelper.GetULIDStr();
                content.C_LicenseCode = _claims.Linsence;
                content.C_CreateBy = _claims.ApiUserId.ToString();
                content.C_Creator = _claims.ApiUserName;
                content.D_CreateOn = DateTime.Now;
                content.C_Status = "1";
                result = await _unitOfWork.RegisterNew(content);
                if (!result)
                {
                    throw new Exception("创建失败");
                }
                if (viewModel.fileList != null && viewModel.fileList.Count > 0)
                {
                    List<TSYS_MessageFile> fileList = new List<TSYS_MessageFile>();
                    foreach (var item in viewModel.fileList)
                    {
                        TSYS_MessageFile app = new TSYS_MessageFile
                        {
                            C_ID = Guid.NewGuid().ToString(),
                            C_MessageCode= content.C_ID,
                            C_Url = item.C_Url,
                            C_Type = item.C_Type,
                            C_CreateBy = _claims.ApiUserId.ToString(),
                            D_CreateOn = DateTime.Now,
                            C_Status = "1"
                        };
                        fileList.Add(app);
                    }
                    if (fileList.Count > 0)
                    {
                        result = await _unitOfWork.RegisterRangeNew(fileList);
                    }
                }
            }
            catch
            {
                _unitOfWork.Rollback();
                throw;
            }
            finally
            {
                if (result)
                    await _unitOfWork.CommitAsync();
                else
                    _unitOfWork.Rollback();
            }
        }

        public async Task<bool> AddMessage(AlmRecordOutput almRecord)
        {
            var IsData = await _repository.GetByConditionAsync(t => t.C_GenerationCode == almRecord.Id.ToString());
            var dataList = IsData.ToList();
            if (dataList != null && dataList.Count() > 0)
            {
                return true;
            }
            bool result = false;
            try
            {
                _unitOfWork.BeginTransaction();
                TSYS_Message content = new TSYS_Message();
                content.C_ID = StringHelper.GetULIDStr();
                content.C_LicenseCode = "SYSTEM";
                content.C_Content = almRecord.Event_Name;
                content.C_DevStoreCode = "d705ceb5-7473-4b19-91dd-d3eff223f05b";
                content.C_MsgTypeCode = "MSG_TYPE_024";
                content.C_Subject = almRecord.Device_TypeName + "报警";
                content.D_MsgCreateOn = almRecord.StartTime;
                content.C_GenerationCode= almRecord.Id.ToString();
                content.I_GenerationType = 1;
                content.I_MsgStatus = 1;
                content.C_Remark = "来源：AI项目报警处理";
                content.C_CreateBy = "6e864cbc-5252-11ec-8681-fa163e02b3e4";
                content.C_Creator = "AI";
                content.D_CreateOn = DateTime.Now;
                content.C_Status = "1";
                result = await _unitOfWork.RegisterNew(content);
                if (!result)
                {
                    throw new Exception("创建失败");
                }
                else
                {
                    var textJson = new
                    {
                        PanoramaId=almRecord.PanoramaId,
                        PanoramaUrl=almRecord.PanoramaUrl,
                        RoiJson=almRecord.RoiJson,
                        NonRoiJson=almRecord.NonRoiJson,
                        DetectionFrameJson=almRecord.DetectionFrameJson
                    };
                    var datas = JsonConvert.SerializeObject(textJson);
                    TSYS_MessageFile app = new TSYS_MessageFile
                    {
                        C_ID = Guid.NewGuid().ToString(),
                        C_MessageCode = content.C_ID,
                        C_Type = "FILE_TYP_006",
                        C_Text = datas,
                        C_CreateBy = "6e864cbc-5252-11ec-8681-fa163e02b3e4",
                        D_CreateOn = DateTime.Now,
                        C_Status = "1"
                    };
                    result = await _unitOfWork.RegisterNew(app); 
                }
            }
            catch
            {
                _unitOfWork.Rollback();
                throw;
            }
            finally
            {
                if (result)
                    await _unitOfWork.CommitAsync();
                else
                    _unitOfWork.Rollback();
            }
            return result;
        }

        public async Task DeleteAsync(string id)
        {
            var content = await _repository.GetByIdAsync(id);
            if (content == null)
            {
                throw new Exception("数据库中没有此数据");
            }
            //_repository.Delete(content);
            //var result = await _repository.SaveAsync();
            content.C_LastUpdatedBy = _claims.ApiUserId.ToString();
            content.D_LastUpdatedOn = DateTime.Now;
            content.C_Status = "0";
            _repository.Update(content);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("删除失败");
            }
        }
        public async Task<IEnumerable<TsysMessageViewModel>> GetAllAsync()
        {
            var pagedList = await _repository.GetAllAsync();
            var contentDtoList = _mapper.Map<IEnumerable<TsysMessageViewModel>>(pagedList.Where(i => i.C_Status == "1").ToList());
            return contentDtoList.ToList();
        }
        public async Task<IEnumerable<TsysMessageViewModel>> GetConditionAsync(TsysMessageSearchModel searchModel)
        {
            return await _repository.GetList(searchModel);
        }
        public async Task<IEnumerable<TsysMessageModel>> GetConditionScreenAsync(TsysMessageSearchModel searchModel)
        {
            IEnumerable<TsysMessageViewModel> data= await _repository.GetList(searchModel);
            IEnumerable<TsysMessageModel> result = _mapper.Map<IEnumerable<TsysMessageViewModel>, IEnumerable<TsysMessageModel>>(data);
            return result;
        }
        public async Task<TsysMessageViewModel> GetByIdAsync(string id)
        {
            TsysMessageSearchModel searchModel = new TsysMessageSearchModel();
            searchModel.C_ID = id;
            searchModel.IsPagination = false;
            var content = await _repository.GetList(searchModel);
            if (content == null)
            {
                return null;
            }
            else
            {
                var contentDto = content.FirstOrDefault();
                if (contentDto != null)
                {
                    TsysMessageFileSearchModel fileSearch = new TsysMessageFileSearchModel();
                    fileSearch.C_MessageCode = id; fileSearch.IsPagination = false; fileSearch.C_Status = "1";
                    contentDto.fileList = (List<MessageFileViewModel>)await _tsysMessageFileRepository.GetList(fileSearch);
                }
                return contentDto;
            }
        }


        public async Task UpdateAsync(string id, TsysMessageUpdateModel updateModel)
        {
            var content = await _repository.GetByIdAsync(id);
            if (content == null)
            {
                throw new Exception("没有此数据");
            }
            _mapper.Map(updateModel, content, typeof(TsysMessageUpdateModel), typeof(TSYS_Message));
            content.C_LastUpdatedBy = _claims.ApiUserId.ToString();
            content.D_LastUpdatedOn = DateTime.Now;
            _repository.Update(content);
            var result = await _repository.SaveAsync();
            if (result)
            {
                if (updateModel.DelFile!=null&&updateModel.DelFile.Count>0)
                {
                    var delFileResult= await _tsysMessageFileRepository.DeleteMultitByID(updateModel.DelFile,null);
                }
                if (updateModel.fileList != null && updateModel.fileList.Count > 0)
                {
                    List<TSYS_MessageFile> fileList = new List<TSYS_MessageFile>();
                    foreach (var item in updateModel.fileList)
                    {
                        TSYS_MessageFile app = new TSYS_MessageFile
                        {
                            C_ID = Guid.NewGuid().ToString(),
                            C_MessageCode = content.C_ID,
                            C_Url = item.C_Url,
                            C_Type = item.C_Type,
                            C_CreateBy = _claims.ApiUserId.ToString(),
                            D_CreateOn = DateTime.Now,
                            C_Status = "1"
                        };
                        fileList.Add(app);
                    }
                    if (fileList.Count > 0)
                    {
                        result = await _tsysMessageFileRepository.CreateRangeAsync(fileList)>0;
                    }
                }
            }
            if (!result)
            {
                throw new Exception("更新失败");
            }
        }

        public async Task UpdateMsgStatusAsync(string id, int msgStatus)
        {
            var result = await _repository.UpdateMsgStatus(id,msgStatus);
            if (!result)
            {
                throw new Exception("更新失败");
            }
        }

        public Task<int> UpdateOneAsync(TsysMessageViewModel viewModel, params string[] fields)
        {
            throw new NotImplementedException();
        }

        public Task<IEnumerable<TsysMessageViewModel>> GetByConditionAsync(Expression<Func<TsysMessageViewModel, bool>> expression)
        {
            throw new NotImplementedException();
        }

        public Task<bool> IsExistAsync(string id)
        {
            throw new NotImplementedException();
        }
    }
}