using GB5Shared.DaprCache;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.Framework.User;
using GB5Shared.QueryExecutor;
using PayRollDAL.Query.User;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using static GB5Shared.GB5Constant.Constant;

namespace PayRollDAL.CustomeCode.User
{
    public class UserDAL : IUserDAL
    {
        private readonly IQueryExecutor _queryExecutor;
        private readonly Dapr.Client.DaprClient _daprClient;
        /// <summary>
        /// Initializes a new instance of the <see cref="UserDAL"/> class.
        /// </summary>
        /// <param name="queryExecutor">The query executor.</param>
        /// <param name="DaprClient">The Dapr client.</param>
        public UserDAL(IQueryExecutor queryExecutor, Dapr.Client.DaprClient DaprClient)
        {
            _queryExecutor = queryExecutor;
            _daprClient = DaprClient;
        }
    
        /// <summary>
        /// Saves the user.
        /// </summary>
        /// <param name="UserDTO">The user DTO.</param>
        /// <param name="LoginDTO">The login DTO.</param>
        /// <returns>The number of affected rows.</returns>
        public async Task<int> SaveUser(UserDTO UserDTO, LoginDTO LoginDTO)
        {
            try
            {
                const string Sql = UserQB.SAVE_USER;
                return await _queryExecutor.ExecuteAsync(LoginDTO, Sql, UserDTO);
            }
            catch (Exception ex)
            {
                throw new Exception("Error while saving user", ex);
            }
        }

        /// <summary>
        /// Updates the user.
        /// </summary>
        /// <param name="UserDTO">The user DTO.</param>
        /// <param name="LoginDTO">The login DTO.</param>
        /// <returns>The number of affected rows.</returns>
        public async Task<int> UpdateUser(UserDTO UserDTO, LoginDTO LoginDTO)
        {
            CacheKeyGeneration Key = new();
            try
            {
                string key = Key.KeyGeneration(UserDTO.UserId, EntityConstant.USER, CacheKeyLevel.USER_LEVEL, LoginDTO);
                await _daprClient.DeleteStateAsync("statestore", key);
                const string Sql = UserQB.UPDATE_USER;
                return await _queryExecutor.ExecuteAsync(LoginDTO, Sql, UserDTO);
            }
            catch (Exception ex)
            {
                throw new Exception("Error while saving user", ex);
            }
        }
    }
}