using System;
using System.Data;
using System.Threading.Tasks;
using Znyc.Admin.Commons.Cache;
using Znyc.Admin.Commons.Services;
using Znyc.Admin.Security.Dtos;
using Znyc.Admin.Security.Entitys;
using Znyc.Admin.Security.IRepositories;
using Znyc.Admin.Security.IServices;

namespace Znyc.Admin.Security.Services
{
    /// <summary>
    ///
    /// </summary>
    public class MessageLogsService : BaseService<MessageRecord, MessageLogsOutputDto, long>, IMessageLogsService
    {
        private readonly IMessageLogsRepository _messageLogsRepository;
        private readonly IMessageRepository _messageRepository;

        public MessageLogsService(
            IMessageLogsRepository messageLogsRepository,
            IMessageRepository messageRepository
        ) : base(messageLogsRepository)
        {
            _messageLogsRepository = messageLogsRepository;
            _messageRepository = messageRepository;
        }

        /// <summary>
        /// 同步新增实体。
        /// </summary>
        /// <param name="entity">实体</param>
        /// <param name="trans">事务对象</param>
        /// <returns></returns>
        public override long Insert(MessageRecord entity, IDbTransaction trans = null)
        {
            entity.Id = Yitter.IdGenerator.YitIdHelper.NextId();
            long result = repository.Insert(entity, trans);
            return result;
        }

        /// <summary>
        /// 异步更新实体。
        /// </summary>
        /// <param name="entity">实体</param>
        /// <param name="id">主键ID</param>
        /// <param name="trans">事务对象</param>
        /// <returns></returns>
        public override async Task<bool> UpdateAsync(MessageRecord entity, long id, IDbTransaction trans = null)
        {
            bool result = await repository.UpdateAsync(entity, id, trans);
            return result;
        }

        /// <summary>
        /// 异步步新增实体。
        /// </summary>
        /// <param name="entity">实体</param>
        /// <param name="trans">事务对象</param>
        /// <returns></returns>
        public override async Task<int> InsertAsync(MessageRecord entity, IDbTransaction trans = null)
        {
            entity.Id = Yitter.IdGenerator.YitIdHelper.NextId();
            int result = await repository.InsertAsync(entity, trans);
            return result;
        }

        /// <summary>
        ///     添加消息记录
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<bool> AddAsync(MessageInputDto input)
        {
            Message entity = new Message()
            {
                Id = Yitter.IdGenerator.YitIdHelper.NextId(),
                SendId = input.CreatedUserId,
                MessageTitle = input.MessageTitle,
                Type = 2,
                GroupId = 0,
                Content = "",
                SendTime = DateTime.Now,
                CreatedTime = DateTime.Now,
                CreatedUserId = input.CreatedUserId,
                ModifiedTime = DateTime.Now
            };
            int id = await _messageRepository.InsertAsync(entity);
            MessageRecord messageLogs = new MessageRecord()
            {
                Id = Yitter.IdGenerator.YitIdHelper.NextId(),
                ReceiverId = input.UserId,
                MessageId = entity.Id,
                Status = 0, //未读
                CreatedTime = DateTime.Now,
                ModifiedTime = DateTime.Now,
                CreatedUserId = input.CreatedUserId
            };
            await _messageLogsRepository.InsertAsync(messageLogs);
            CacheHelper cacheHelper = new CacheHelper();
            string key = string.Format("unread:number:{0}", input.UserId);
            cacheHelper.Remove(key);
            return true;
        }
    }
}