using Dapper;
using System.Threading.Tasks;
using Znyc.Cloudcar.Admin.Commons.IDbContext;
using Znyc.Cloudcar.Admin.Commons.Repositories;
using Znyc.Cloudcar.Admin.Security.Entitys;
using Znyc.Cloudcar.Admin.Security.IRepositories;

namespace Znyc.Cloudcar.Admin.Security.Repositories
{
    /// <summary>
    ///     应用仓储实现
    /// </summary>
    public class MessageRepository : BaseRepository<MessageEntity, long>, IMessageRepository
    {
        public MessageRepository()
        {
        }

        public MessageRepository(IDbContextCore context) : base(context)
        {
        }

        ///// <summary>
        /////     添加信息
        ///// </summary>
        ///// <param name="entity"></param>
        //public async Task<object> InsertAsync(MessageEntity entity)
        //{
        //    string sql = string.Format(
        //        @"INSERT INTO `message`(`CreatedUserId`, `CreatedTime`, `IsDeleted`, `SendId`, `Type`, `GroupId`,
        //                            `Content`, `SendTime`, `ProductId`, `Title`, `MessageTitle`, `ProductType`) VALUES
        //                            ({0}, now(), 0, {1},{2},{3}, '{4}', now(), {5}, '{6}','{7}', {8}); SELECT LAST_INSERT_ID();",
        //        entity.SendId, entity.SendId, entity.Type, entity.GroupId, entity.Content, entity.ProductId,
        //        entity.Title, entity.MessageTitle, entity.ProductType);
        //    //var input= await DapperConn.QueryFirstOrDefaultAsync<Message>(sql);
        //    long input = await DapperConn.ExecuteScalarAsync<long>(sql, entity);
        //    return input;
        //}
    }
}