using Tiger.Model;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using Rhea.Common;
using Tiger.IBusiness;
using Dm.filter.log;

namespace Tiger.Business
{
    public partial class Biz : ILogin
    {
        /// <summary>
        /// 获取CS登录信息
        /// </summary>
        /// <param name="token"></param>
        /// <param name="Async"></param>
        /// <returns></returns>
        public async Task<SYS_CS_LOGIN> GetCSLoginInfo(string token, bool Async = true)
        {
            SYS_CS_LOGIN query = null;
            try
            {
                query = Db.Queryable<SYS_CS_LOGIN>().Where(x => x.TOKEN == token).First();
                if (query != null)
                {
                    //超过8小时删除登录
                    if ((DateTime.Now - query.LAST_ACCESS).Hours > 4)
                    {
                        Db.Deleteable(query).ExecuteCommand();
                        return null;
                    }
                }
            }
            catch (System.Exception ex)
            {

            }
            return await Task.FromResult(query);
        }

        /// <summary>
        /// CS登录
        /// </summary>
        /// <param name="action"></param>
        /// <param name="Async"></param>
        /// <returns></returns>
        public async Task<ApiAction<SYS_CS_LOGIN>> CSLogin(ApiAction<UserInfo> action, bool Async = true)
        {
            var res = new ApiAction<SYS_CS_LOGIN>();
            try
            {
                UserInfo userInfo = action.Data;
                var user = Db.Queryable<SYS_USER>().Where(x => x.USER_ID == userInfo.USER_CODE && x.USER_PWD == userInfo.PASSWORD).First();
                if (user != null)
                {
                    if (user.STATUS_CODE == "ENABLE")
                    {
                        MES_FACTORY _factory = Db.Queryable<MES_FACTORY>()
                                                .WhereIF(!userInfo.FTY_CODE.IsNullOrEmpty(),x => x.FTY_CODE == userInfo.FTY_CODE)
                                                .First();

                        SYS_CS_LOGIN logininfo = new SYS_CS_LOGIN
                        {
                            USER_ID = user.USER_ID,
                            USER_NAME = user.USER_NAME,
                            LAST_ACCESS = DateTime.Now,
                            CREATE_TIME = DateTime.Now,
                            STATUS_CODE = user.STATUS_CODE,
                            CLIENT_IP = userInfo?.ip,
                            TOKEN = userInfo.Token ?? Guid.NewGuid().ToString("N"),
                            ID = Guid.NewGuid().ToString("N"),
                            ACCOUNT_TYPE = 0,
                            ORG_CODE = userInfo.ORG_CODE,
                            PROD_CODE = _factory?.FTY_CODE,
                        };
                        var org_code=Db.Queryable<V_USER_ORG>().Where(q=>q.USER_ID == userInfo.USER_CODE && q.ORG_CODE==userInfo.ORG_CODE).First();
                        if (org_code != null)
                        {
                            logininfo.ORG_CODE = org_code.ORG_CODE;
                        }
                        else
                        {
                            var prod_code = Db.Queryable<V_USER_PROD>().Where(q => q.USER_ID == userInfo.USER_CODE && q.PROD_CODE == userInfo.PROD_CODE).First();
                            if (prod_code != null)
                            {
                                logininfo.PROD_CODE = prod_code.PROD_CODE;
                            }
                            else
                            {
                                res.IsSuccessed = false;
                                res.Data = null;
                                res.LocaleMsg = L("SYS.Login.isNotOrgCode");//用户没有该据点的权限 }
                            }
                        }
                        LOG_CS_LOGIN loginlog = new()
                        {
                            USER_ID = user.USER_ID,
                            LOGIN_FROM = $"{userInfo?.ad_info?.nation}->{userInfo?.ad_info?.province}->{userInfo?.ad_info?.city};IP:{userInfo?.ip}",
                            LOGIN_TIME = DateTime.Now,
                            ORG_CODE = userInfo.ORG_CODE,
                            PROD_CODE = _factory?.FTY_CODE,
                        };
                        //保存登录日志
                        var db = Business.Biz.Db;
                        var dbTran = db.UseTran(() =>
                        {
                            db.Insertable(loginlog).ExecuteCommand();

                            if (logininfo != null)
                            {
                                var deres = db.Storageable(logininfo).ExecuteCommand();
                            }
                            res.Data = logininfo;
                        });
                        if (!dbTran.IsSuccess)
                        {
                            res.IsSuccessed = false;
                            res.Data = null;
                            res.LocaleMsg = L("SYS.Login.dbTranError");
                        }
                        res.Data = logininfo;
                    }
                    else
                    {
                        res.IsSuccessed = false;
                        res.Data = null;
                        res.LocaleMsg = L("SYS.Login.dbTranError");//用户已禁用
                    }
                }
                else
                {
                    res.IsSuccessed = false;
                    res.Data = null;
                    res.LocaleMsg = L("SYS.Login.errMsg401");//用户没有权限（令牌、用户名、密码错误）!
                }
            }
            catch (Exception ex)
            {
                res.CatchExceptionWithLog(ex, "登录异常");
            }
            return await Task.FromResult(res);
        }

        /// <summary>
        /// CS登出
        /// </summary>
        /// <param name="token"></param>
        /// <returns></returns>
        public async Task<ApiAction> CSLogout(string token)
        {
            var res = new ApiAction();
            try
            {
                var query = Db.Queryable<SYS_CS_LOGIN>().Where(x => x.TOKEN == token).First();
                if (query != null)
                {
                    Db.Deleteable(query).ExecuteCommand();
                    return res;
                }
            }
            catch (Exception ex)
            {
                res.CatchExceptionWithLog(ex, "注销登录异常");
            }
            return await Task.FromResult(res);
        }
    }
}