using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Tiger.IBusiness;
|
using Tiger.Model;
|
|
namespace Tiger.Business.MengQi
|
{
|
/// <summary>
|
/// 用户
|
/// </summary>
|
public partial class Users : IUser
|
{
|
/// <summary>
|
/// 获取用户信息
|
/// </summary>
|
/// <param name="pageList"></param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
public async Task<PageAble<User>> GetUserInfo(PageAble<User> pageList)
|
{
|
RefAsync<int> total = 0;
|
pageList.data = await Biz.Db.Queryable<User>().WhereIF(!string.IsNullOrEmpty(pageList.sqlcmd), x => x.UserCode.Contains(pageList.sqlcmd)).ToPageListAsync(pageList.pageIndex, pageList.pageSize, total);
|
pageList.totals = total;
|
return pageList;
|
}
|
|
/// <summary>
|
/// 用户登录
|
/// </summary>
|
/// <param name="userInfo"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<User>> Login(User userInfo)
|
{
|
var res = new ApiAction<User>();
|
try
|
{
|
string usercode = userInfo.UserCode;
|
if (userInfo.UserCode == "品质用户")
|
{
|
var user = await Biz.Db.Queryable<User>().Where(x => x.RoleCode == "品质").FirstAsync();
|
if (user != null) { usercode = user.UserCode; }
|
}
|
if (!Biz.Db.Queryable<User>().Where(x => x.UserCode == usercode && x.Password == userInfo.Password).Any())
|
{
|
//result = new(Result.Flags.Failed, "用户没有权限或者用户名和密码错误！");
|
userInfo = new();
|
}
|
else
|
{
|
userInfo = await Biz.Db.Queryable<User>().Where(x => x.UserCode == usercode && x.Password == userInfo.Password).FirstAsync();
|
}
|
res.Data = userInfo;
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "登录异常");
|
}
|
return res;
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="dt"></param>
|
/// <returns></returns>
|
public async Task<Result> SaveImportUserInfo(DataTable dt)
|
{
|
|
Result result = new Result(Result.Flags.Success, $"导入成功");
|
List<User> list = new();
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
User item = new()
|
{
|
id = Guid.NewGuid().ToString("N"),
|
UserCode = dt.Rows[i]["用户ID"].ToString(),
|
UserName = dt.Rows[i]["用户名称"].ToString(),
|
RoleCode = dt.Rows[i]["用户角色"].ToString(),
|
};
|
var info = Biz.Db.Queryable<User>().Where(x => x.UserCode == dt.Rows[i]["用户ID"].ToString()).First();
|
if (info != null)
|
{
|
item.id = info.id;
|
}
|
list.Add(item);
|
}
|
//更新机型记录
|
var db = Biz.Db;
|
var dbTran = await db.UseTranAsync(async () =>
|
{
|
await db.Saveable(list).ExecuteCommandAsync();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
result.Flag = Result.Flags.Failed;
|
result.Message = $"导入异常";
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 保存用户
|
/// </summary>
|
/// <param name="user"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> SaveUser(User user)
|
{
|
var result = new ApiAction();
|
try
|
{
|
|
var db = Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{
|
var y = db.Storageable(user)
|
.WhereColumns(t => new { t.UserCode })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"导入异常";
|
}
|
}
|
catch (Exception ex)
|
{
|
result.CatchExceptionWithLog(ex, "保存用户异常");
|
}
|
return result;
|
}
|
}
|
}
|
