using JCSoft.WX.Framework.Api;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Common.Wechat;
using Common;
using System.Data;
using Common.Model;
using ZcPeng.PublicLibrary;
using CoreEntity.Entity;
using CoreEntity.DAL;
using System.Collections.Concurrent;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json;
using System.Data.SqlClient;
using Microsoft.Extensions.Primitives;
using Microsoft.Extensions.Caching.Memory;
using Jwt;
using PublicLibrary.Model;
using Newtonsoft.Json.Linq;
using SupplierWeb.Codes.mvc;
using SupplierWeb.Codes.Auth;
using Common.Config;

namespace SupplierWeb.Controllers
{
    [Route("web/CM_User")]
    public class CM_UserController : BaseController
    {
        public CM_UserController(IMemoryCache cache, IApiClient client) : base(cache, client)
        {

        }
        private ConcurrentDictionary<String, CM_User> UserMap = new ConcurrentDictionary<String, CM_User>();
        public class TempTableResult
        {
            public int id { get; set; }
            public string permissionName { get; set; }
            public string permissionUrl { get; set; }
            public int UserId { get; set; }
            public int checkedValue { get; set; }
            public string permissionRule { get; set; }
            public string permissionRuleType { get; set; }
            public int relateId { get; set; }
            public string AuthType { get; set; }
        }
        public class TempUserResult
        {
            public string parentValue { get; set; }
            public string label { get; set; }
            public int value { get; set; }

        }
        public class TempQuery
        {
            public int[] data { get; set; }
            public int UserId { get; set; }
        }
        public class SortContent
        {
            public Object content { get; set; }//权限内容
            public string code { get; set; }//权限id
            public int sort { get; set; }//权限序号
        }



        /// <summary>
        /// 用户列表
        /// </summary>
        /// <param name="filters"></param>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="sortField"></param>
        /// <param name="sortDirection"></param>
        /// <param name="sumFields"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        [AuthPermission]
        [HttpPost, Route("index")]
        public JsonResult Indexp(QueryFilter[] filters, Int32 pageIndex, Int32 pageSize,
            string sortField, Int32 sortDirection, string[] sumFields, [FromBody]dynamic data)
        {
            if (data != null)
            {
                filters = data.filters.ToObject<QueryFilter[]>();
                pageIndex = data.pageIndex;
                pageSize = data.pageSize;
                sortField = data.sortField;
                sortDirection = data.sortDirection;
                sumFields = data.sumFields.ToObject<string[]>();
            }
            #region 获取角色列表
            DataTable dt = new DataTable();
            string result;
            IList<CM_User> permss = new List<CM_User>(0);

            List<SqlParameter> parameters = new List<SqlParameter>();
            string filterstr = QueryFilter.getFilterSqlParam(filters, out parameters, new CM_User(), "A.");

            string direct = " desc ";
            if (sortDirection != 1)
            {
                direct = " asc";
            }

            int start = (pageIndex - 1) * pageSize;
            int end = (start + 1 + pageSize);

            string commandText0 = "select * from ";
            string commandText1 = "(" +
                "select A.*,row_number() over" +
                "(  order by A.UserId " + direct + " )  as rownum from " +
                "CM_User as A  " +
                " where  1=1 " +
                    //" and A.CreationPerson = '" + userids + "'" +
                    filterstr +
            ")AAA ";
            string commandText2 = " where AAA.rownum>" + start + " and AAA.rownum<" + end;
            string commandText3 = commandText0 + commandText1 + commandText2;
            bool success = DataAccess.GetValues(commandText3, ref dt, parameters.ToArray(), out result);

            #endregion
            if (dt != null && dt.Rows.Count > 0)
            {
                // 把DataTable转换为IList<Permission>  
                permss = ModelConvertHelper<CM_User>.ConvertToModel(dt);

                #region 获取权限的角色列表，角色列表
                //角色列表
                IList<CM_User> Users = GetUsers();
                // 把DataTable转换为IList<User>  
                if (UserMap.Count < Users.Count)
                {
                    foreach (CM_User User in Users)
                    {
                        UserMap.TryAdd(User.UserId, User);
                    }
                }
                #region
                foreach (CM_User perms in permss)
                {
                    string direct1 = " desc ";
                    dt = DataAccess.GetDataTable("CM_User", "UserId", "*", "UserId=" + perms.UserId, "", "UserId" + direct1, 1, 100, out var msg);
                    // 把DataTable转换为IList<UserRelatePermission>  
                    if (dt != null && dt.Rows.Count > 0)
                    {
                        IList<CM_User> permRelates = ModelConvertHelper<CM_User>.ConvertToModel(dt);

                        List<CM_User> listUsers = new List<CM_User>();
                        List<int> superior_list = new List<int>(0);
                        foreach (CM_User permsr in permRelates)
                        {
                            CM_User User;
                            if (UserMap.TryGetValue(permsr.UserId, out User))
                            {
                                listUsers.Add(User);
                            }
                            superior_list.Add(Convert.ToInt32(permsr.UserId));
                        }
                        //perms.UserList = listUsers;
                        perms.UserId = string.Join(",", superior_list.ToArray());
                    }
                }
                #endregion
                #endregion
            }
            string result1;
            long totalcount = DataAccess.GetRowCountDefine("select count(UserId) from " + commandText1, parameters.ToArray(), out result1);
            IsoDateTimeConverter timejson = new IsoDateTimeConverter
            {
                DateTimeFormat = "yyyy'-'MM'-'dd' 'HH':'mm':'ss"
            };
            //IList<Menu> menus = Permission.Convert(permss);
            var jsonData = JsonConvert.SerializeObject(permss, timejson);

            return Json(new
            {
                items = JsonConvert.DeserializeObject(jsonData),
                sum = new { },
                totalCount = totalcount
            });
        }

        /// <summary>
        /// 新增用户
        /// </summary>
        /// <param name="UserId"></param>
        /// <param name="UserCode"></param>
        /// <param name="UserName"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        [AuthPermission]
        [HttpPost, Route("add")]
        public JsonResult Addp(
            String UserId, String OrgId,
            string LoginName, [FromBody]dynamic data
        )
        {
            string UserName = "";
            string IsActive = "";
            if (data != null)
            {
                UserId = data.UserId;
                OrgId = data.OrgId;
                LoginName = data.LoginName;
                UserName = data.UserName;
                IsActive = data.IsActive;
            }

            #region 添加角色
            String uuid = System.Guid.NewGuid().ToString("N");
            string commandText = "INSERT INTO CM_User (UserId," +
                "OrgId,LoginName,UserName,IsActive)" +
                " VALUES ('" + uuid + "',@OrgId,@LoginName,@UserName,@IsActive)";
            string result;
            //准备参数
            List<List<Object>> parameters = new List<List<Object>>();
            parameters.Add(new List<Object>() { "UserId", uuid });
            parameters.Add(new List<Object>() { "OrgId", OrgId });
            parameters.Add(new List<Object>() { "LoginName", LoginName });
            parameters.Add(new List<Object>() { "UserName", UserName });
            parameters.Add(new List<Object>() { "IsActive", IsActive });

            List<SqlParameter> parameters1 = DataAccess.ToParameters(parameters);
            int success = DataAccess.ExecuteCommand(commandText, parameters1, out result);
            #endregion
            //#region 添加角色
            //int id = BaseDAL.GetId(Config.TablePrefix + "Permission");
            //UserDAL.SaveUsersRelatePermission(id, UserIdis);
            //#endregion

            return Json(new
            {
                success = success

            });
        }


        /// <summary>
        /// 修改用户
        /// </summary>
        /// <param name="UserId"></param>
        /// <param name="UserCode"></param>
        /// <param name="UserName"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        [AuthPermission]
        [HttpPost, Route("edit")]
        public JsonResult editp(String UserId, String OrgId,
            string LoginName, [FromBody]dynamic data)
        {
            string UserName = "";
            string IsActive = "";
            if (data != null)
            {
                UserId = data.UserId;
                OrgId = data.OrgId;
                LoginName = data.LoginName;
                UserName = data.UserName;
                IsActive = data.IsActive;
            }
            #region 编辑用户
            string commandText = "UPDATE CM_User " +
                " SET  OrgId = @OrgId,LoginName = @LoginName,UserName = @UserName,IsActive = @IsActive " +
                "WHERE UserId= @UserId";
            string result;
            //准备参数
            List<List<Object>> parameters = new List<List<Object>>();
            parameters.Add(new List<Object>() { "UserId", UserId });
            parameters.Add(new List<Object>() { "OrgId", OrgId });
            parameters.Add(new List<Object>() { "LoginName", LoginName });
            parameters.Add(new List<Object>() { "UserName", UserName });
            parameters.Add(new List<Object>() { "IsActive", IsActive });

            List<SqlParameter> parameters1 = DataAccess.ToParameters(parameters);
            int success = DataAccess.ExecuteCommand(commandText, parameters1, out result);
            #endregion

            return Json(new
            {
                success = success
            });
        }
        

        /// <summary>
        /// 删除用户
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [AuthPermission]
        [HttpPost, Route("delete")]
        public ActionResult Delete(string id)
        {
            string commandText = "DELETE FROM CM_User WHERE UserId = @UserId";

            //准备参数
            List<List<Object>> parameters = new List<List<Object>>();
            parameters.Add(new List<Object>() { "UserId", id });

            string result = "";
            List<SqlParameter> parameters1 = DataAccess.ToParameters(parameters);
            int success = DataAccess.ExecuteCommand(commandText, parameters1, out result);
            return Content("{success:" + success + "}");
        }


        [HttpGet, Route("Users")]
        public ActionResult Users()
        {

            var permss = GetTopUsers();
            IList<Option> options = new List<Option>();
            foreach (CM_User perms in permss)
            {

                var option = new Option() { label = perms.UserName, value = perms.UserId.ToString() };
                options.Add(option);
            }
            var jsonData = JsonConvert.SerializeObject(options);

            return Content(jsonData);
        }
        


        public static IList<CM_User> GetUsers()
        {
            IList<CM_User> UserList = new List<CM_User>(0);

            DataTable result;

            string direct = " desc ";

            result = DataAccess.GetDataTable("CM_User", "Id", "UserId,UserName,UserCode", "", "", "Id" + direct, 1, 100, out var msg);
            if (result != null && result.Rows.Count > 0)
            {
                // 把DataTable转换为IList<User>  
                UserList = ModelConvertHelper<CM_User>.ConvertToModel(result);
            }
            return UserList;
        }

        public IList<CM_User> GetTopUsers()
        {
            IList<CM_User> permsList = new List<CM_User>(0);

            DataTable dt = new DataTable();
            string result = string.Empty;
            var sortDirection = 1;
            var pageIndex = 1;
            var pageSize = Config.MaxPageSize;

            string direct = " desc ";
            if (sortDirection != 1)
                direct = " asc";
            int start = (pageIndex - 1) * pageSize;
            int end = (start + 1 + pageSize);
            string commandText = "select * from (" +
                "select A.*, row_number() over" +
                "(  order by A.UserId " + direct + " )  as rownum" +
                "  from CM_User A ) AAA" +
                " where AAA.rownum>" + start + " and AAA.rownum<" + end +
                " ";


            List<List<Object>> parameters1 = new List<List<Object>>();
            parameters1.Add(new List<Object>() { "UserId", 0 });
            bool result1 = DataAccess.GetValues(commandText, ref dt, DataAccess.ToParameters(parameters1).ToArray(), out result);

            if (result1 && dt.Rows.Count > 0)
            {
                // 把DataTable转换为IList<User>  
                permsList = ModelConvertHelper<CM_User>.ConvertToModel(dt);
            }
            return permsList;
        }
       
        

    }

}