HuNan_DM/DM_Weight/Services/UserService.cs

using DM_Weight.Models;
using log4net;
using log4net.Repository.Hierarchy;
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)
                //{
                //    logger.Info($"Open失败：{ex.ToString()}");
                //    if (con.State == System.Data.ConnectionState.Open)
                //    {
                //        con.Close();
                //    }
                //    Thread.Sleep(200);
                //    logger.Info("再次Open");
                //    con.Open();
                //}
               connOpen(con);
                Thread.Sleep(100);
                while(con.State != System.Data.ConnectionState.Open)
                {
                    logger.Info("再次Open");
                    connOpen(con);
                    Thread.Sleep(100);
                }

                logger.Info("数据库连接已打开");
                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.Open)
                {
                    con.Close();
                }
                try
                {
                    con.Open();
                }
                catch (Exception ex)
                {
                    logger.Info($"Open失败：{ex.Message}");
                }
            });
        }


    }
}