using DM_Weight.Models;
using log4net;
using log4net.Repository.Hierarchy;
using MySql.Data.MySqlClient;
//using MySql.Data.MySqlClient;
//using MySqlConnector;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace DM_Weight.Services
{
    public class UserService
    {
        private readonly ILog logger = LogManager.GetLogger(typeof(UserService));
        //public static string connStr = ConfigurationManager.AppSettings["database"].ToString();
        public static string connStr = ConfigurationManager.ConnectionStrings["database"].ToString();
        public UserList CheckUserByFingerPrinter(int fingerPrinterId)
        {
            UserList? user = null;

            using (MySqlConnection con = new MySqlConnection(connStr))
            {
                logger.Info($"connStr：{connStr}");
                try
                {
                    con.Open();
                }
                catch (Exception ex)
                {
                    con.Close();
                    logger.Info($"Open失败：{ex.ToString()};连接状态：{con.State}");
                    logger.Info("再次Open");
                    con.Open();
                }
                //connOpen(con);
                //Thread.Sleep(10);
                //while (con.State != System.Data.ConnectionState.Open)
                //{
                //    logger.Info($"再次Open:{con.State}");
                //    connOpen(con);
                //    Thread.Sleep(10);
                //}

                logger.Info($"数据库连接状态{con.State}");
                //string sql = @"select ul.id as id,ul.User_name as userName,r.id,r.role_name,r.permissions,r.machine_id from user_list ul 
                //                INNER JOIN role r on ul.machine_role_id=r.id where ul.Id=@ID and ul.machine_id=@machine_id and r.machine_id=@machine_id;";
                //MySqlCommand cmd = new MySqlCommand(sql, con);
                //cmd.Parameters.Clear();
                //MySqlParameter[] mySqlParameter = new MySqlParameter[] { new MySqlParameter("ID", fingerPrinterId), new MySqlParameter("machine_id", (ConfigurationManager.AppSettings["machineId"] ?? "DM1")) };
                //cmd.Parameters.AddRange(mySqlParameter);
                ////执行语句
                //MySqlDataReader reader = cmd.ExecuteReader();
                //logger.Info("MySqlDataReader读数据");
                //while (reader.Read())
                //{
                //    user = new UserList();
                //    user.Id = reader.GetInt32("id");
                //    user.UserName = reader["userName"] is DBNull ? "" : reader.GetString("userName");
                //    //user.UserName = reader["id"] is DBNull ? "" : reader.GetString("id");
                //    user.Nickname = reader["userName"] is DBNull ? "" : reader.GetString("userName");
                //    user.MachineId = reader["machine_id"] is DBNull ? "" : reader.GetString("machine_id");
                //    RoleDm role = new RoleDm();
                //    role.Id = reader.GetInt32("id");
                //    //role.Permissions = reader["permissions"] is DBNull ? "" : reader.GetString("permissions");
                //    role.RoleName = reader["role_name"] is DBNull ? "" : reader.GetString("role_name");
                //    role.Permissions = JsonConvert.DeserializeObject<List<PremissionDm>>(reader["permissions"] is DBNull ? "" : reader.GetString("permissions"));  // JsonConvert.SerializeObject(reader.GetString("permissions")).ToList();
                //    user.Role = role;
                //}

                //reader.Close();
                //logger.Info($"sql：{sql}");
                return user;
            }

        }
        private Task connOpen(MySqlConnection con)
        {
            return Task.Run(() =>
            {
                if (con.State != System.Data.ConnectionState.Closed)
                {
                    con.Close();
                }
                try
                {
                    con.Open();
                }
                catch (Exception ex)
                {
                    logger.Info($"Open失败：{ex.Message}");
                }
            });
        }

    }
}