using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.IO;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using JiepeiWMS.AuthHelper.OverWrite;
|
using JiepeiWMS.Common.Config;
|
using JiepeiWMS.Common.Helper;
|
using JiepeiWMS.Common.HttpContextUser;
|
using JiepeiWMS.Filter;
|
using JiepeiWMS.IRepository.UnitOfWork;
|
using JiepeiWMS.IServices;
|
using JiepeiWMS.Model;
|
using JiepeiWMS.Model.Models;
|
using JiepeiWMS.Model.ViewModels;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Logging;
|
|
namespace JiepeiWMS.Controllers
|
{
|
/// <summary>
|
/// 用户管理
|
/// </summary>
|
[Route("api/[controller]/[action]")]
|
[ApiController]
|
[Authorize(Permissions.Name)]
|
public class UserController : ControllerBase
|
{
|
private readonly IUnitOfWork _unitOfWork;
|
readonly ISysUserInfoServices _sysUserInfoServices;
|
readonly IUserRoleServices _userRoleServices;
|
readonly IRoleServices _roleServices;
|
private readonly IUser _user;
|
private readonly ILogger<UserController> _logger;
|
private readonly IDepartmentServices _departmentServices;
|
private readonly IUserSysOrgServices _BllUserSysOrg;
|
private readonly ISysOrgServices _BllSysOrg;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public UserController(IUnitOfWork unitOfWork, ISysUserInfoServices sysUserInfoServices,
|
IUserRoleServices userRoleServices, IRoleServices roleServices, IUser user, ILogger<UserController> logger,
|
IDepartmentServices departmentServices, IUserSysOrgServices BllUserSysOrg, ISysOrgServices BllSysOrg)
|
{
|
_unitOfWork = unitOfWork;
|
_sysUserInfoServices = sysUserInfoServices;
|
_userRoleServices = userRoleServices;
|
_roleServices = roleServices;
|
_user = user;
|
_logger = logger;
|
_departmentServices = departmentServices;
|
_BllUserSysOrg = BllUserSysOrg;
|
_BllSysOrg = BllSysOrg;
|
}
|
|
/// <summary>
|
/// 获取全部用户
|
/// </summary>
|
/// <param name="page"></param>
|
/// <param name="key"></param>
|
/// <returns></returns>
|
// GET: api/User
|
[HttpGet]
|
public async Task<MessageModel<PageModel<sysUserInfo>>> Get(int page = 1, string key = "")
|
{
|
if (string.IsNullOrEmpty(key) || string.IsNullOrWhiteSpace(key))
|
{
|
key = "";
|
}
|
int intPageSize = 20;
|
|
|
var data = await _sysUserInfoServices.QueryPage(a => a.uStatus >= 0 && ((a.uLoginName != null && a.uLoginName.Contains(key.Trim())) || (a.uRealName != null && a.uRealName.Contains(key.Trim()))
|
|| (a.JobNo != null && a.JobNo.Contains(key.Trim()))
|
), page, intPageSize, " uID desc ");
|
|
|
#region MyRegion
|
|
// 这里可以封装到多表查询，此处简单处理
|
var allUserRoles = await _userRoleServices.Query(d => d.IsDeleted == false);
|
var allRoles = await _roleServices.Query(d => d.IsDeleted == false);
|
var allSysOrgIds = await _BllUserSysOrg.Query();
|
|
var sysUserInfos = data.data;
|
foreach (var item in sysUserInfos)
|
{
|
var currentUserRoles = allUserRoles.Where(d => d.UserId == item.uID).Select(d => d.RoleId).ToList();
|
item.RIDs = currentUserRoles;
|
item.RoleNames = allRoles.Where(d => currentUserRoles.Contains(d.Id)).Select(d => d.Name).ToList();
|
item.SysOrgIds = allSysOrgIds.Where(t => t.UserId == item.uID).Select(t => t.SysOrgId).ToList();
|
if (item.DepartmentId > 0)
|
{
|
var departmentModel = await _departmentServices.QueryById(item.DepartmentId);
|
if (departmentModel != null)
|
item.DepartMentName = departmentModel.Name;
|
}
|
item.uLoginPWD = "";
|
}
|
|
data.data = sysUserInfos;
|
|
#endregion
|
|
|
return new MessageModel<PageModel<sysUserInfo>>()
|
{
|
msg = "获取成功",
|
success = data.dataCount >= 0,
|
response = data
|
};
|
|
}
|
|
// GET: api/User/5
|
[HttpGet("{id}")]
|
[AllowAnonymous]
|
public string Get(string id)
|
{
|
_logger.LogError("test wrong");
|
return "value";
|
}
|
|
// GET: api/User/5
|
/// <summary>
|
/// 获取用户详情根据token
|
/// 【无权限】
|
/// </summary>
|
/// <param name="token">令牌</param>
|
/// <returns></returns>
|
[HttpGet]
|
[AllowAnonymous]
|
public async Task<MessageModel<sysUserInfo>> GetInfoByToken(string token)
|
{
|
var data = new MessageModel<sysUserInfo>();
|
if (!string.IsNullOrEmpty(token))
|
{
|
var tokenModel = JwtHelper.SerializeJwt(token);
|
if (tokenModel != null && tokenModel.Uid > 0)
|
{
|
var userinfo = await _sysUserInfoServices.QueryById(tokenModel.Uid);
|
if (userinfo != null)
|
{
|
data.response = userinfo;
|
data.success = true;
|
data.msg = "获取成功";
|
}
|
}
|
|
}
|
return data;
|
}
|
|
/// <summary>
|
/// 添加一个用户
|
/// </summary>
|
/// <param name="sysUserInfo"></param>
|
/// <returns></returns>
|
// POST: api/User
|
[HttpPost]
|
public async Task<MessageModel<string>> Post([FromBody] sysUserInfo sysUserInfo)
|
{
|
var data = new MessageModel<string>();
|
|
var userInfoModel = await _sysUserInfoServices.GetModel(x => x.JobNo == sysUserInfo.JobNo);
|
if (userInfoModel != null)
|
{
|
data.msg = "已有相同工号";
|
return data;
|
}
|
if (sysUserInfo!=null&&string.IsNullOrEmpty(sysUserInfo.Mobile))
|
{
|
sysUserInfo.Mobile = "15000000000";
|
}
|
|
sysUserInfo.uLoginPWD = MD5Helper.MD5Encrypt32(sysUserInfo.uLoginPWD);
|
var id = await _sysUserInfoServices.Add(sysUserInfo);
|
|
//更新主体关系
|
if (sysUserInfo.SysOrgIds.Count > 0)
|
{
|
var vals = new List<object>();
|
foreach (var SysOrgId in sysUserInfo.SysOrgIds)
|
{
|
vals.Add(new { UserId = sysUserInfo.uID, SysOrgId = SysOrgId });
|
}
|
_BllUserSysOrg.UpdateJoinInfo(
|
"UserSysOrg", new List<string> { "UserId", "SysOrgId" }, vals,
|
new List<string> { "UserId" }, new List<object> { new { UserId = sysUserInfo.uID } }
|
);
|
}
|
|
data.success = id > 0;
|
if (data.success)
|
{
|
data.response = id.ObjToString();
|
data.msg = "添加成功";
|
}
|
|
return data;
|
}
|
|
/// <summary>
|
/// 更新用户与角色
|
/// </summary>
|
/// <param name="sysUserInfo"></param>
|
/// <returns></returns>
|
// PUT: api/User/5
|
[HttpPut]
|
public async Task<MessageModel<string>> Put([FromBody] sysUserInfo sysUserInfo)
|
{
|
// 这里使用事务处理
|
|
var data = new MessageModel<string>();
|
try
|
{
|
_unitOfWork.BeginTran();
|
|
var userInfoModel = await _sysUserInfoServices.GetModel(x => x.JobNo == sysUserInfo.JobNo && x.uID != sysUserInfo.uID);
|
if (userInfoModel != null)
|
{
|
data.msg = "工号已存在";
|
return data;
|
}
|
if (sysUserInfo != null && string.IsNullOrEmpty(sysUserInfo.Mobile))
|
{
|
sysUserInfo.Mobile = "15000000000";
|
}
|
if (sysUserInfo != null && sysUserInfo.uID > 0)
|
{
|
if (sysUserInfo.RIDs.Count > 0)
|
{
|
// 无论 Update Or Add , 先删除当前用户的全部 U_R 关系
|
var usreroles = (await _userRoleServices.Query(d => d.UserId == sysUserInfo.uID)).Select(d => d.Id.ToString()).ToArray();
|
if (usreroles.Count() > 0)
|
{
|
var isAllDeleted = await _userRoleServices.DeleteByIds(usreroles);
|
}
|
|
// 然后再执行添加操作
|
var userRolsAdd = new List<UserRole>();
|
sysUserInfo.RIDs.ForEach(rid =>
|
{
|
userRolsAdd.Add(new UserRole(sysUserInfo.uID, rid));
|
});
|
|
await _userRoleServices.Add(userRolsAdd);
|
|
}
|
|
//更新主体关系
|
if (sysUserInfo.SysOrgIds.Count > 0)
|
{
|
var vals = new List<object>();
|
foreach (var SysOrgId in sysUserInfo.SysOrgIds)
|
{
|
vals.Add(new { UserId = sysUserInfo.uID, SysOrgId = SysOrgId });
|
}
|
_BllUserSysOrg.UpdateJoinInfo(
|
"UserSysOrg", new List<string> { "UserId", "SysOrgId" }, vals,
|
new List<string> { "UserId" }, new List<object> { new { UserId = sysUserInfo.uID } }
|
);
|
sysUserInfo.SysOrgId = sysUserInfo.SysOrgIds.FirstOrDefault();
|
}
|
|
var olduser = await _sysUserInfoServices.QueryById(sysUserInfo.uID);
|
|
if (!string.IsNullOrEmpty(sysUserInfo.uLoginPWD))
|
{
|
sysUserInfo.uLoginPWD = MD5Helper.MD5Encrypt32(sysUserInfo.uLoginPWD);
|
}
|
else
|
{
|
sysUserInfo.uLoginPWD = olduser.uLoginPWD;
|
}
|
|
data.success = await _sysUserInfoServices.Update(sysUserInfo);
|
|
_unitOfWork.CommitTran();
|
|
if (data.success)
|
{
|
data.msg = "更新成功";
|
data.response = sysUserInfo?.uID.ObjToString();
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
_unitOfWork.RollbackTran();
|
_logger.LogError(e, e.Message);
|
}
|
|
return data;
|
}
|
|
/// <summary>
|
/// 修改密码
|
/// </summary>
|
/// <param name="sysUserInfo"></param>
|
/// <returns></returns>
|
// PUT: api/User/5
|
[HttpPut]
|
public async Task<MessageModel<string>> PutPwd([FromBody] sysUserInfo sysUserInfo)
|
{
|
var data = new MessageModel<string>();
|
try
|
{
|
|
var userInfoModel = await _sysUserInfoServices.GetModel(x => x.uID == _user.ID);
|
if (userInfoModel != null)
|
{
|
if (userInfoModel.uLoginPWD != MD5Helper.MD5Encrypt32(sysUserInfo.uLoginPWD))
|
{
|
data.msg = "旧密码输入不正确请重新输入，若忘记旧密码请联系管理员修改！";
|
return data;
|
throw new Exception("旧密码输入不正确请重新输入，若忘记旧密码请联系管理员修改！");
|
|
}
|
userInfoModel.uLoginPWD = MD5Helper.MD5Encrypt32(sysUserInfo.uLoginPWDNew);
|
userInfoModel.uRealName = sysUserInfo.uRealName;
|
userInfoModel.uRemark = sysUserInfo.uRemark;
|
data.success = await _sysUserInfoServices.Update(userInfoModel);
|
if (data.success)
|
{
|
data.msg = "更新成功";
|
data.response = userInfoModel?.uID.ObjToString();
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
|
_logger.LogError(ex, ex.Message);
|
}
|
return data;
|
}
|
|
/// <summary>
|
/// 删除用户
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
// DELETE: api/ApiWithActions/5
|
[HttpDelete]
|
public async Task<MessageModel<string>> Delete(int id)
|
{
|
var data = new MessageModel<string>();
|
if (id > 0)
|
{
|
var userDetail = await _sysUserInfoServices.QueryById(id);
|
userDetail.tdIsDelete = true;
|
data.success = await _sysUserInfoServices.Update(userDetail);
|
if (data.success)
|
{
|
data.msg = "删除成功";
|
data.response = userDetail?.uID.ObjToString();
|
}
|
}
|
|
return data;
|
}
|
|
/// <summary>
|
/// 导入用户表格
|
/// </summary>
|
[HttpPost]
|
[AllowAnonymous]
|
public async Task<MessageModel<string>> ImportUserInfo([FromForm] IFormCollection files)
|
{
|
var data = new MessageModel<string>();
|
var importUserInfoModel = new ImportUserInfoViewModels();
|
var importUserInfoList = new List<ImportUserInfoViewModels>();
|
|
try
|
{
|
//创建事务
|
_unitOfWork.BeginTran();
|
var path = Directory.GetCurrentDirectory();
|
var fileFolder = Path.Combine(path, "ImportFile");
|
if (!Directory.Exists(fileFolder))
|
Directory.CreateDirectory(fileFolder);
|
|
FormFileCollection fileCollection = (FormFileCollection)files.Files;
|
foreach (var file in fileCollection)
|
{
|
var fileName = DateTime.Now.ToString("yyyyMMddHHmmss") + Path.GetExtension(file.FileName);
|
var filePath = Path.Combine(fileFolder, fileName);
|
using (var stream = new FileStream(filePath, FileMode.Create))
|
{
|
file.CopyTo(stream);
|
}
|
|
var dtExcel = ExcelHelper.ImportExcel(filePath);
|
foreach (DataRow myRow in dtExcel.Rows)
|
{
|
if (string.IsNullOrWhiteSpace(myRow[0].ToString()))
|
continue;
|
if (string.IsNullOrWhiteSpace(myRow[1].ToString()))
|
continue;
|
if (string.IsNullOrWhiteSpace(myRow[2].ToString()))
|
continue;
|
if (string.IsNullOrWhiteSpace(myRow[3].ToString()))
|
continue;
|
|
importUserInfoModel = new ImportUserInfoViewModels()
|
{
|
JobNo = myRow[0].ToString(),
|
OrgName = myRow[1].ToString(),
|
DepartmentName = myRow[2].ToString(),
|
Name = myRow[3].ToString(),
|
};
|
importUserInfoList.Add(importUserInfoModel);
|
}
|
|
foreach (var item in importUserInfoList)
|
{
|
var now = DateTime.Now;
|
var departmentModel = await _departmentServices.GetModel(x => x.Name == item.DepartmentName);
|
var sysOrgModel = await _BllSysOrg.GetShortName(item.OrgName);
|
var Account = PinYinHelper.ConvertToAllSpell(item.Name);
|
|
//匹配名称和用户名
|
var productListModel = await _sysUserInfoServices.GetModel(x => x.uLoginName == Account && x.uRealName == item.Name);
|
if (productListModel != null)
|
{
|
//更新用户表
|
productListModel.JobNo = item.JobNo;
|
productListModel.DepartmentId = departmentModel == null ? 0 : departmentModel.Id;
|
await _sysUserInfoServices.Update(productListModel);
|
|
var vals = new List<object>();
|
vals.Add(new { UserId = productListModel.uID, SysOrgId = sysOrgModel == null ? 0 : sysOrgModel.Id });
|
|
_BllUserSysOrg.UpdateJoinInfo(
|
"UserSysOrg", new List<string> { "UserId", "SysOrgId" }, vals,
|
new List<string> { "UserId" }, new List<object> { new { UserId = productListModel.uID } }
|
);
|
}
|
else
|
{
|
//添加用户表
|
var sysUserInfo = new sysUserInfo
|
{
|
uLoginName = Account,
|
uLoginPWD = MD5Helper.MD5Encrypt32("123456"),
|
uRealName = item.Name,
|
uStatus = 0,
|
uCreateTime = now,
|
uUpdateTime = now,
|
uLastErrTime = now,
|
uErrorCount = 0,
|
name = item.Name,
|
sex = 1,
|
age = 0,
|
birth = now,
|
tdIsDelete = false,
|
JobNo = item.JobNo,
|
DepartmentId = departmentModel == null ? 0 : departmentModel.Id,
|
SysOrgId = sysOrgModel == null ? 0 : sysOrgModel.Id
|
};
|
var result = await _sysUserInfoServices.Add(sysUserInfo);
|
if (result > 0)
|
{
|
var vals = new List<object>();
|
vals.Add(new { UserId = result, SysOrgId = sysOrgModel == null ? 0 : sysOrgModel.Id });
|
|
_BllUserSysOrg.UpdateJoinInfo(
|
"UserSysOrg", new List<string> { "UserId", "SysOrgId" }, vals,
|
new List<string> { "UserId" }, new List<object> { new { UserId = result } }
|
);
|
|
//添加用户角色关联表
|
var roleModel = await _roleServices.GetModel(x => x.Name == RoleConfig.SaleProductionStaff);
|
if (roleModel != null)
|
{
|
// 无论 Update Or Add , 先删除当前用户的全部 U_R 关系
|
var usreroles = (await _userRoleServices.Query(d => d.UserId == result)).Select(d => d.Id.ToString()).ToArray();
|
if (usreroles.Count() > 0)
|
{
|
var isAllDeleted = await _userRoleServices.DeleteByIds(usreroles);
|
}
|
|
// 然后再执行添加操作
|
await _sysUserInfoServices.InitializePermission(Account, sysOrgModel == null ? 0 : sysOrgModel.Id, RoleConfig.SaleProductionStaff);
|
}
|
}
|
}
|
}
|
}
|
|
_unitOfWork.CommitTran();
|
data.response = 1.ObjToString();
|
data.msg = "导入用户成功";
|
data.success = true;
|
return data;
|
}
|
catch (Exception ex)
|
{
|
_unitOfWork.RollbackTran();
|
data.msg = ex.Message;
|
data.response = 0.ObjToString();
|
data.status = 500;
|
return data;
|
}
|
}
|
|
/// <summary>
|
/// 绑定用户
|
/// </summary>
|
/// <param name="realName">用户名</param>
|
/// <param name="jobNo">工号</param>
|
/// <param name="sex">性别</param>
|
/// <param name="orgId">主体ID</param>
|
/// <param name="mobile">手机号</param>
|
/// <returns></returns>
|
[HttpGet, AllowAnonymous, AuthKeySecret]
|
public async Task<MessageModel<string>> BindingUser(string realName, string jobNo, int sex, int orgId)
|
{
|
var msg = string.Empty;
|
|
if (string.IsNullOrWhiteSpace(realName))
|
{
|
msg = "realName必须设置值";
|
goto ErrorResult;
|
}
|
if (string.IsNullOrWhiteSpace(jobNo))
|
{
|
msg = "jobNo必须设置值";
|
goto ErrorResult;
|
}
|
if (sex < 0 || sex > 2)
|
{
|
msg = "sex值是0女或1男";
|
goto ErrorResult;
|
}
|
if (orgId <= 0)
|
{
|
msg = "orgId必须设置值";
|
goto ErrorResult;
|
}
|
//if (string.IsNullOrWhiteSpace(mobile))
|
//{
|
// msg = "Mobile必须设置值";
|
// goto ErrorResult;
|
//}
|
|
var result = await _sysUserInfoServices.BindingUser(realName, jobNo, sex, orgId);
|
msg = result.Item1;
|
|
if (!string.IsNullOrEmpty(msg))
|
{
|
goto ErrorResult;
|
}
|
|
return new MessageModel<string>()
|
{
|
msg = "绑定用户成功",
|
success = true,
|
response = result.Item2.ObjToString()
|
};
|
|
ErrorResult:
|
return new MessageModel<string>()
|
{
|
msg = msg,
|
success = false
|
};
|
}
|
|
/// <summary>
|
/// 初始化菜单
|
/// </summary>
|
/// <param name="realName">用户名</param>
|
/// <param name="orgId">主体ID</param>
|
/// <param name="roleName">角色名称</param>
|
/// <returns></returns>
|
[HttpGet, AllowAnonymous]
|
public async Task<MessageModel<string>> InitializePermission(string realName, int orgId, string roleName)
|
{
|
var msg = string.Empty;
|
|
if (string.IsNullOrWhiteSpace(realName))
|
{
|
msg = "realName必须设置值";
|
goto ErrorResult;
|
}
|
if (orgId <= 0)
|
{
|
msg = "orgId必须设置值";
|
goto ErrorResult;
|
}
|
if (string.IsNullOrWhiteSpace(roleName))
|
{
|
msg = "roleName必须设置值";
|
goto ErrorResult;
|
}
|
|
var result = await _sysUserInfoServices.InitializePermission(realName, orgId, roleName);
|
msg = result.Item1;
|
|
if (!string.IsNullOrEmpty(msg))
|
{
|
goto ErrorResult;
|
}
|
|
return new MessageModel<string>()
|
{
|
msg = "初始化菜单成功",
|
success = true,
|
response = result.Item2.ObjToString()
|
};
|
|
ErrorResult:
|
return new MessageModel<string>()
|
{
|
msg = msg,
|
success = false
|
};
|
}
|
|
|
}
|
}
|
