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>
|
/// 获取登录信息
|
/// </summary>
|
/// <param name="token"></param>
|
/// <param name="Async"></param>
|
/// <returns></returns>
|
public async Task<SYS_BS_LOGIN> GetBSLoginInfo(string token, bool Async = true)
|
{
|
SYS_BS_LOGIN query = null;
|
try
|
{
|
query = Db.Queryable<SYS_BS_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>
|
/// 添加记录
|
/// </summary>
|
/// <param name="parm"></param>
|
/// <param name="Async"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> AddLOG_BS_LOGINAsync(SYS_BS_LOGIN parm, bool Async = true)
|
{
|
var res = new ApiAction();
|
try
|
{
|
var dbres = Async ? await Db.Insertable(parm).ExecuteCommandAsync() : Db.Insertable(parm).ExecuteCommand();
|
res.Data = dbres.ToString();
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "增加登录信息异常");
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 登录
|
/// </summary>
|
/// <param name="action"></param>
|
/// <param name="Async"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<SYS_BS_LOGIN>> BSLogin(ApiAction<UserInfo> action, bool Async = true)
|
{
|
var res = new ApiAction<SYS_BS_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_BS_LOGIN logininfo = new SYS_BS_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,
|
FTY_CODE = _factory?.FTY_CODE,
|
FTY_NAME = _factory?.FTY_NAME,
|
TOKEN = userInfo.Token ?? Guid.NewGuid().ToString("N"),
|
ID = Guid.NewGuid().ToString("N"),
|
ACCOUNT_TYPE = 0,
|
ORG_CODE = userInfo.ORG_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.FTY_CODE = prod_code.PROD_CODE;
|
logininfo.FTY_NAME = prod_code.PROD_NAME;
|
}
|
else
|
{
|
res.IsSuccessed = false;
|
res.Data = null;
|
res.LocaleMsg = L("SYS.Login.isNotOrgCode");//用户没有该据点的权限 }
|
}
|
}
|
LOG_BS_LOGIN loginlog = new()
|
{
|
//FACTORY = _factory.FTY_CODE,
|
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
|
|
};
|
//保存登录日志
|
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>
|
/// 切换据点
|
/// </summary>
|
/// <param name="action"></param>
|
/// <param name="Async"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> BSSwitchOrgCode(string token,string org, string fty)
|
{
|
var action = new ApiAction();
|
try
|
{
|
//查回来
|
var query = Db.Queryable<SYS_BS_LOGIN>().Where(x => x.TOKEN == token).First();
|
|
query.ORG_CODE = org;
|
query.FTY_CODE = fty;
|
var db = Business.Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{
|
db.Updateable(query).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
action.IsSuccessed = false;
|
action.Data = null;
|
action.LocaleMsg = L("SYS.Login.dbTranError");
|
}
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, "切换异常");
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 注销
|
/// </summary>
|
/// <param name="token"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> BSLogout(string token)
|
{
|
var res = new ApiAction();
|
try
|
{
|
var query = Db.Queryable<SYS_BS_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);
|
}
|
}
|
}
|
