using Gs.Toolbox;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Data;
using System.Linq;
using System.Text;
using Gs.User.Modes;
using System.Diagnostics;
using System.Diagnostics.Metrics;
using System.Security.Principal;
using System.Net;

namespace Gs.User.Service
{

    [ApiGroup(ApiGroupNames.Auth)]
    public class UserController : IRomteService
    {
        /// <summary>
        /// 用户登录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<System.Dynamic.ExpandoObject> UserLogin([FromBody] UserLogin model)
        {
            string accountPwd = model.accountPwd;
            string accountNo = model.accountNo;
            Guid orgGuid = model.orgGuid;
            string strPass = "";
            DataSet dset = new DataSet();
            dynamic m = new System.Dynamic.ExpandoObject();
            using (SqlConnection conn = new SqlConnection(DbHelperSQL.strConn))
            {
                using (SqlCommand cmd = new SqlCommand("[prc_user_login]", conn))
                {
                    try
                    {
                        conn.Open();
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters = new SqlParameter[] {
                                new SqlParameter("@accountNo",accountNo),
                                new SqlParameter("@accountPwd",strPass),
                                new SqlParameter("@orgGuid",orgGuid),
                            };
                        foreach (SqlParameter parameter in parameters)
                        {
                            cmd.Parameters.Add(parameter);
                        }
                        using (SqlDataAdapter dt = new SqlDataAdapter(cmd))
                        {
                            dt.Fill(dset, "0");
                        }
                        if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)
                        {
                            System.Data.DataRow row = dset.Tables[0].Rows[0];
                            m.loginGuid = Guid.Parse(row["loginGuid"].ToString());
                            m.loginOrgGuid = row["loginOrgGuid"].ToString();
                            return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, "登录成功！");
                        }
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Debug(this.ToString(), "UserLogin error：" + ex.Message);
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Exception, "登录失败！");
        }

        /// <summary>
        /// 读取用户登录信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<System.Dynamic.ExpandoObject> GetUserLoginInfo([FromBody] UserLogin model)
        {
            Guid userGuid = model.userGuid;
            DataSet dset = new DataSet();
            dynamic m = new System.Dynamic.ExpandoObject();
            using (SqlConnection conn = new SqlConnection(DbHelperSQL.strConn))
            {
                using (SqlCommand cmd = new SqlCommand("[prc_user_info]", conn))
                {
                    try
                    {
                        conn.Open();
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters = new SqlParameter[] {
                                new SqlParameter("@userGuid",userGuid),
                            };
                        foreach (SqlParameter parameter in parameters)
                        {
                            cmd.Parameters.Add(parameter);
                        }
                        using (SqlDataAdapter dt = new SqlDataAdapter(cmd))
                        {
                            dt.Fill(dset, "0");
                        }
                        if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)
                        {
                            System.Data.DataRow row = dset.Tables[0].Rows[0];
                            m.loginGuid = Guid.Parse(row["loginGuid"].ToString());
                            m.loginOrgGuid = row["loginOrgGuid"].ToString();
                            m.list = new List<MenuAction>();
                            if (dset.Tables.Count > 1 && dset.Tables[1].Rows.Count > 1)
                            {
                                foreach (DataRow dr in dset.Tables[1].Rows)
                                {
                                    m.list.Add(
                                        new MenuAction()
                                        {
                                            guid = Guid.Parse(dr["rightGuid"].ToString()),
                                            upGuid = dr["upGuid"].ToString().Length > 0 ? Guid.Parse(dr["upGuid"].ToString()) : null,
                                            name = dr["name"].ToString(),
                                            icon = dr["icon"].ToString(),
                                            formPath = dr["formPath"].ToString(),
                                            category = int.Parse(dr["category"].ToString()),
                                        }
                                    );
                                }
                                string _msg = "欢迎使用某某公司EMS系统，你的角色为【管理员】当前共有【20】条信息未处理";
                                return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, _msg);
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Debug(this.ToString(), "GetUserInfo error：" + ex.Message);
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Exception, "登录失败！");
        }


        #region
        /// <summary>
        /// 读取列表，支持分页
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<PageList<dynamic>> GetListPage([FromBody] PageQuery model)
        {
            int currentPage = model.currentPage;
            int everyPageSize = model.everyPageSize;
            string sortName = string.IsNullOrEmpty(model.sortName) ? "a.name" : model.sortName;
            System.Text.StringBuilder sbSql = new StringBuilder();
            sbSql.Append("select * from ");
            sbSql.Append("( ");
            sbSql.Append("select top 100000 ROW_NUMBER() over(order by " + sortName + " " + model.sortOrder + ") as rowIndex,* from sys_User a where 1=1" + model.keyWhere);
            sbSql.Append(") as T ");
            sbSql.Append(" where T.rowindex>(" + currentPage + "-1)*" + everyPageSize + " and  T.rowindex<=" + currentPage + "*" + everyPageSize + "");
            sbSql.Append(" select count(1) as intTotal  from sys_User a where 1=1 " + model.keyWhere).ToString();
            DataSet dset = new DataSet();
            try
            {
                dset = Gs.Toolbox.DbHelperSQL.Query(sbSql.ToString());
            }
            catch (Exception ex)
            {
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetListPage error：" + ex.Message);
                return ReturnDto<PageList<dynamic>>.QuickReturn(default(PageList<dynamic>), ReturnCode.Exception, "读取失败");
            }
            PageList<dynamic> _pglist = new PageList<dynamic>
            {
                total = 0,
                everyPageSize = 0,
                pages = 0,
                list = new List<dynamic>()
            };
            if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)//有数据
            {
                int intTotal = int.Parse(dset.Tables[1].Rows[0]["intTotal"].ToString());
                int pages = (intTotal % everyPageSize != 0) ? (intTotal / everyPageSize + 1) : (intTotal / everyPageSize);
                _pglist.total = intTotal;
                _pglist.everyPageSize = everyPageSize;
                _pglist.pages = pages;
                foreach (DataRow row in dset.Tables[0].Rows)
                {
                    Sys_User _model = new Sys_User();
                    if (row["guid"] != null && row["guid"].ToString() != "")
                    {
                        _model.guid = new Guid(row["guid"].ToString());
                    }
                    if (row["account"] != null)
                    {
                        _model.account = row["account"].ToString();
                    }
                    if (row["password"] != null && row["password"].ToString() != "")
                    {
                        _model.password = new Guid(row["password"].ToString());
                    }
                    if (row["userName"] != null)
                    {
                        _model.userName = row["userName"].ToString();
                    }
                    if (row["address"] != null)
                    {
                        _model.address = row["address"].ToString();
                    }
                    if (row["tel"] != null)
                    {
                        _model.tel = row["tel"].ToString();
                    }
                    if (row["email"] != null)
                    {
                        _model.email = row["email"].ToString();
                    }
                    if (row["lastLoginTime"] != null && row["lastLoginTime"].ToString() != "")
                    {
                        _model.lastLoginTime = DateTime.Parse(row["lastLoginTime"].ToString());
                    }
                    if (row["lastLogoutTime"] != null && row["lastLogoutTime"].ToString() != "")
                    {
                        _model.lastLogoutTime = DateTime.Parse(row["lastLogoutTime"].ToString());
                    }
                    if (row["isLocked"] != null && row["isLocked"].ToString() != "")
                    {
                        _model.isLocked = int.Parse(row["isLocked"].ToString());
                    }
                    if (row["createTime"] != null && row["createTime"].ToString() != "")
                    {
                        _model.createTime = DateTime.Parse(row["createTime"].ToString());
                    }
                    if (row["flagAdmin"] != null && row["flagAdmin"].ToString() != "")
                    {
                        _model.flagAdmin = int.Parse(row["flagAdmin"].ToString());
                    }
                    if (row["flagOnline"] != null && row["flagOnline"].ToString() != "")
                    {
                        _model.flagOnline = int.Parse(row["flagOnline"].ToString());
                    }
                    if (row["loginCounter"] != null && row["loginCounter"].ToString() != "")
                    {
                        _model.loginCounter = int.Parse(row["loginCounter"].ToString());
                    }
                    if (row["workerID"] != null)
                    {
                        _model.workerID = row["workerID"].ToString();
                    }
                    if (row["remark"] != null)
                    {
                        _model.remark = row["remark"].ToString();
                    }
                    if (row["departGuid"] != null && row["departGuid"].ToString() != "")
                    {
                        _model.departGuid = new Guid(row["departGuid"].ToString());
                    }
                    if (row["isSys"] != null && row["isSys"].ToString() != "")
                    {
                        _model.isSys = int.Parse(row["isSys"].ToString());
                    }
                    _model.isLockedTxt = row["isLocked"].ToString() != "1" ? "正常" : "被锁定";
                    _pglist.list.Add(_model);
                }
            }
            return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, ReturnCode.Success, "读取成功");
        }


        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<int?> DeleteModel([FromBody] string guidList)
        {
            int rtnInt = (int)ReturnCode.Default;
            int cont = 0;
            try
            {
                //是否内置
                cont = int.Parse(DbHelperSQL.GetSingle("select count(1) from sys_User where   [isSys]=1 and guid in split('" + guidList + "',',')").ToString());
                if (cont > 0)
                {
                    return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "删除失败，该条目为系统内置，不可删除！");
                }
                StringBuilder strSql = new StringBuilder();
                strSql.Append("delete from sys_User ");
                strSql.Append(" where guid in (" + guidList + ")  ");
                int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
                rtnInt = rows;
            }
            catch (Exception ex)
            {
                LogHelper.Debug(this.ToString(), "DeleteModel error：" + ex.Message);
                rtnInt = (int)ReturnCode.Exception;
            }
            if (rtnInt > 0)
                return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Success, "操作成功，共删除" + rtnInt.ToString() + "条数据！");
            else
                return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "删除失败，请重试！");
        }

        /// <summary>
        /// 增加
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<int?> EditModel([FromBody] Sys_User model)
        {
            Guid? guid = model.guid;
            string strPass = Guid.NewGuid().ToString();
            int? rtnInt = (int)ReturnCode.Default;
            if (guid == null)
            {
                int cont = 0;
                cont = int.Parse(DbHelperSQL.GetSingle("select count(1) from sys_User where account='" + guid.ToString() + "'").ToString());
                if (cont > 0)
                {
                    return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "增加失败，该账号已存在！");
                }
            }
            StringBuilder strSql = new StringBuilder();
            if (guid != null)
            {
                strSql.Append(" UPDATE [dbo].[sys_User]");
                strSql.Append(" SET [userName] = @userName ,[address] =@address ,[tel] = @tel,[email] = @email ,[isLocked] =@isLocked,[createTime] = getdate() ,[flagAdmin] =@flagAdmin,[workerID] =@workerID ,[remark] = @remark,[departGuid] = @departGuid ");
                strSql.Append(" where guid='" + guid + "'");
            }
            else
            {
                guid = Guid.NewGuid();
                strSql.Append("insert into sys_User");
                strSql.Append(" ([guid],[account],[password],[userName],[address],[tel],[email],[isLocked],[createTime],[flagAdmin],[flagOnline],[loginCounter],[workerID],[remark],[departGuid])");
                strSql.Append(" values (");
                strSql.Append("'" + guid + "',@account,'" + strPass + "',@userName,@address,@tel,@email,@isLocked,getdate(),@flagAdmin,0,0 ,@workerID,@remark,@departGuid)");
            }
            SqlParameter[] parameters = {
             new SqlParameter("@account", model.account),
             new SqlParameter("@userName",model.userName),
             new SqlParameter("@address",model.address),
             new SqlParameter("@tel",model.tel),
             new SqlParameter("@email",model.email),
             new SqlParameter("@isLocked",model.isLocked),
             new SqlParameter("@flagAdmin",model.flagAdmin),
             new SqlParameter("@workerID",model.workerID),
             new SqlParameter("@remark",model.remark),
             new SqlParameter("@departGuid",model.departGuid),
         };
            try
            {
                rtnInt = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
            }
            catch (Exception ex)
            {
                LogHelper.Debug(this.ToString(), "EditModel error：" + ex.Message);
                rtnInt = (int)ReturnCode.Exception;
            }
            if (rtnInt > 0)
                return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, "操作成功！");
            else
                return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception, "增加失败，请重试！");
        }

        /// <summary>
        /// 读取
        /// </summary>
        /// <param name="guid"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        [AllowAnonymous]
        public ReturnDto<Sys_User> GetModel([FromBody] Sys_User model)
        {
            Sys_User _model = new Sys_User();
            System.Text.StringBuilder sbSql = new StringBuilder();
            sbSql.Append("select top 1 * from sys_Organization where 1=1 and guid='" + model.guid.ToString() + "' ");
            try
            {
                DataSet dset = new DataSet();
                dset = DbHelperSQL.Query(sbSql.ToString());
                if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)
                {
                    System.Data.DataRow row = dset.Tables[0].Rows[0];
                    if (row["guid"] != null && row["guid"].ToString() != "")
                    {
                        _model.guid = new Guid(row["guid"].ToString());
                    }
                    if (row["account"] != null)
                    {
                        _model.account = row["account"].ToString();
                    }
                    if (row["password"] != null && row["password"].ToString() != "")
                    {
                        _model.password = new Guid(row["password"].ToString());
                    }
                    if (row["userName"] != null)
                    {
                        _model.userName = row["userName"].ToString();
                    }
                    if (row["address"] != null)
                    {
                        _model.address = row["address"].ToString();
                    }
                    if (row["tel"] != null)
                    {
                        _model.tel = row["tel"].ToString();
                    }
                    if (row["email"] != null)
                    {
                        _model.email = row["email"].ToString();
                    }
                    if (row["lastLoginTime"] != null && row["lastLoginTime"].ToString() != "")
                    {
                        _model.lastLoginTime = DateTime.Parse(row["lastLoginTime"].ToString());
                    }
                    if (row["lastLogoutTime"] != null && row["lastLogoutTime"].ToString() != "")
                    {
                        _model.lastLogoutTime = DateTime.Parse(row["lastLogoutTime"].ToString());
                    }
                    if (row["isLocked"] != null && row["isLocked"].ToString() != "")
                    {
                        _model.isLocked = int.Parse(row["isLocked"].ToString());
                    }
                    if (row["createTime"] != null && row["createTime"].ToString() != "")
                    {
                        _model.createTime = DateTime.Parse(row["createTime"].ToString());
                    }
                    if (row["flagAdmin"] != null && row["flagAdmin"].ToString() != "")
                    {
                        _model.flagAdmin = int.Parse(row["flagAdmin"].ToString());
                    }
                    if (row["flagOnline"] != null && row["flagOnline"].ToString() != "")
                    {
                        _model.flagOnline = int.Parse(row["flagOnline"].ToString());
                    }
                    if (row["loginCounter"] != null && row["loginCounter"].ToString() != "")
                    {
                        _model.loginCounter = int.Parse(row["loginCounter"].ToString());
                    }
                    if (row["workerID"] != null)
                    {
                        _model.workerID = row["workerID"].ToString();
                    }
                    if (row["remark"] != null)
                    {
                        _model.remark = row["remark"].ToString();
                    }
                    if (row["departGuid"] != null && row["departGuid"].ToString() != "")
                    {
                        _model.departGuid = new Guid(row["departGuid"].ToString());
                    }
                    if (row["isSys"] != null && row["isSys"].ToString() != "")
                    {
                        _model.isSys = int.Parse(row["isSys"].ToString());
                    }
                    return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Success, "读取成功！");
                }
                else
                    return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Default, "读取失败！");
            }
            catch (Exception ex)
            {
                LogHelper.Debug(this.ToString(), "GetModel error:" + ex.Message);
                return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Default, "读取失败！");
            }
        }
        #endregion
    }
}