using IWareDataAccess.EF;
|
using IWareDataAccess.Entity.Sys;
|
using IWareDataAccess.Helper;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IWareDataAccess.Sys.USER
|
{
|
public static class ViewUserSqlFunc
|
{
|
/// <summary>
|
/// 搜索用户(视图)
|
/// </summary>
|
public static List<View_SYS_USER> SearchView(UserWebEntity webEntity, int page, int onePageNum)
|
{
|
using (Model edm = new Model())
|
{
|
var f = PredicateBuilder.True<View_SYS_USER>();
|
|
//便利所有属性
|
Type type = webEntity.GetType();
|
foreach (var i in type.GetProperties())
|
{
|
object v = Helper.Helper.GetFieldValueByName(webEntity, i.Name);
|
if (i.PropertyType == typeof(String))
|
{
|
string value;
|
if (v != null)
|
{
|
value = v.ToString();
|
f = f.And(x => Helper.Helper.GetFieldValueByName(x, i.Name) != null ? Helper.Helper.GetFieldValueByName(x, i.Name).ToString().Contains(value) : false);
|
}
|
}
|
else if (i.PropertyType == typeof(DateTime?))
|
{
|
if (v != null)
|
{
|
DateTime value = DateTime.Parse(v.ToString());
|
if (i.Name == "updateTimeStart")
|
{
|
f = f.And(x => x.updateTime > value);
|
}
|
if (i.Name == "updateTimeEnd")
|
{
|
f = f.And(x => x.updateTime < value);
|
}
|
}
|
}
|
else
|
{
|
if (v != null)
|
{
|
f = f.And(x => Object.Equals(Helper.Helper.GetFieldValueByName(x, i.Name), v));
|
}
|
}
|
}
|
|
List<View_SYS_USER> list = edm.View_SYS_USER.Where(f.Compile()).Skip((page - 1) * onePageNum).Take(onePageNum).ToList();
|
|
return list;
|
}
|
}
|
|
/// <summary>
|
/// 搜索用户总数
|
/// </summary>
|
public static int SearchViewNum(UserWebEntity webEntity, out string msg)
|
{
|
msg = "";
|
using (Model edm = new Model())
|
{
|
var f = PredicateBuilder.True<View_SYS_USER>();
|
|
//便利所有属性
|
Type type = webEntity.GetType();
|
foreach (var i in type.GetProperties())
|
{
|
object v = Helper.Helper.GetFieldValueByName(webEntity, i.Name);
|
if (i.PropertyType == typeof(String))
|
{
|
string value;
|
if (v != null)
|
{
|
value = v.ToString();
|
f = f.And(x => Helper.Helper.GetFieldValueByName(x, i.Name) != null ? Helper.Helper.GetFieldValueByName(x, i.Name).ToString().Contains(value) : false);
|
}
|
}
|
else if (i.PropertyType == typeof(DateTime?))
|
{
|
if (v != null)
|
{
|
DateTime value = DateTime.Parse(v.ToString());
|
if (i.Name == "updateTimeStart")
|
{
|
f = f.And(x => x.updateTime > value);
|
}
|
if (i.Name == "updateTimeEnd")
|
{
|
f = f.And(x => x.updateTime < value);
|
}
|
}
|
}
|
else
|
{
|
if (v != null)
|
{
|
f = f.And(x => Object.Equals(Helper.Helper.GetFieldValueByName(x, i.Name), v));
|
}
|
}
|
}
|
|
int num = edm.View_SYS_USER.Where(f.Compile()).Count();
|
|
return num;
|
}
|
}
|
|
/// <summary>
|
/// 搜索用户(表)
|
/// </summary>
|
public static List<SYS_USER> Search(UserWebEntity webEntity, int page, int onePageNum, out string msg)
|
{
|
msg = "";
|
using (Model edm = new Model())
|
{
|
var f = PredicateBuilder.True<SYS_USER>();
|
|
//便利所有属性
|
Type type = webEntity.GetType();
|
foreach (var i in type.GetProperties())
|
{
|
object v = Helper.Helper.GetFieldValueByName(webEntity, i.Name);
|
if (i.PropertyType == typeof(String))
|
{
|
string value;
|
if (v != null)
|
{
|
value = v.ToString();
|
f = f.And(x => Helper.Helper.GetFieldValueByName(x, i.Name) != null ? Helper.Helper.GetFieldValueByName(x, i.Name).ToString().Contains(value) : false);
|
}
|
}
|
else if (i.PropertyType == typeof(DateTime?))
|
{
|
if (v != null)
|
{
|
DateTime value = DateTime.Parse(v.ToString());
|
if (i.Name == "updateTimeStart")
|
{
|
f = f.And(x => x.UPDATETIME > value);
|
}
|
if (i.Name == "updateTimeEnd")
|
{
|
f = f.And(x => x.UPDATETIME < value);
|
}
|
}
|
}
|
else
|
{
|
if (v != null)
|
{
|
f = f.And(x => Object.Equals(Helper.Helper.GetFieldValueByName(x, i.Name), v));
|
}
|
}
|
}
|
|
|
List<SYS_USER> list = edm.SYS_USER.Where(f.Compile()).Skip((page - 1) * onePageNum).Take(onePageNum).ToList();
|
|
return list;
|
}
|
}
|
|
/// <summary>
|
/// 添加用户
|
/// </summary>
|
/// <returns></returns>
|
public static bool AddOrUpdate(UserWebEntity webUser, out string msg)
|
{
|
msg = "";
|
using (Model edm = new Model())
|
{
|
//查询是否已存在此用户
|
SYS_USER user = edm.SYS_USER.FirstOrDefault(x => x.USERNAME == webUser.userName);
|
if (user == null)
|
{
|
//无此用户，属于新建
|
user = new SYS_USER();
|
}
|
string pas = "";
|
if (webUser.password.Contains(","))
|
{
|
|
pas = webUser.password.Split(',')[0];
|
}
|
else
|
{
|
pas = webUser.password;
|
}
|
user.IsWeldingAuditGroup = webUser.IsWeldingAuditGroup;//是否是焊装审核组
|
user.USERNAME = webUser.userName ?? user.USERNAME;
|
user.USERTRUENAME = webUser.userTrueName ?? user.USERTRUENAME;
|
user.PASSWORD = pas ?? user.PASSWORD;
|
user.ENABLE = webUser.enable ?? user.ENABLE;
|
SYS_USER creator = edm.SYS_USER.FirstOrDefault(x => x.USERNAME == webUser.createName);
|
if (creator != null)
|
{
|
user.CREATORID = creator.ID;
|
}
|
user.UPDATETIME = DateTime.Now;
|
//绑定角色
|
SYS_ROLE role = edm.SYS_ROLE.FirstOrDefault(x => x.ROLENAME == webUser.roleName);
|
if (role != null)
|
{
|
SYS_USER_VS_ROLE uvr = edm.SYS_USER_VS_ROLE.FirstOrDefault(x => x.USERID == user.ID);
|
if (uvr == null)//新建或修改角色
|
{
|
uvr = new SYS_USER_VS_ROLE();
|
}
|
//判断用户是否新建
|
if (user.ID == 0)
|
{
|
uvr.SYS_USER = user;
|
}
|
else
|
{
|
uvr.USERID = user.ID;
|
}
|
uvr.ROLEID = role.ID;
|
edm.SYS_USER_VS_ROLE.AddOrUpdateExtension(uvr);
|
}
|
//绑定部门
|
SYS_DEPT dept = edm.SYS_DEPT.FirstOrDefault(x => x.DEPTNAME == webUser.deptName);
|
if (dept != null)
|
{
|
user.SYS_DEPT = dept;
|
}
|
edm.SYS_USER.AddOrUpdateExtension(user);
|
if (edm.SaveChanges() > 0)
|
{
|
return true;
|
}
|
else
|
{
|
msg = "修改失败";
|
return false;
|
}
|
}
|
}
|
|
/// <summary>
|
/// 删除用户
|
/// </summary>
|
/// <param name="webUser"></param>
|
/// <returns></returns>
|
public static bool Delete(UserWebEntity webUser, out string msg)
|
{
|
msg = "";
|
using (Model edm = new Model())
|
{
|
//查询是否已存在此用户
|
SYS_USER user = edm.SYS_USER.FirstOrDefault(x => x.USERNAME == webUser.userName);
|
if (user == null)
|
{
|
//无此用户，错误
|
msg = "无此用户";
|
return false;
|
}
|
else
|
{
|
return DeleteUserRelevance(user, out msg);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 关联删除(逻辑删除)
|
/// </summary>
|
/// <param name="user"></param>
|
/// <returns></returns>
|
public static bool DeleteUserRelevance(SYS_USER user, out string msg)
|
{
|
msg = "";
|
using (Model edm = new Model())
|
{
|
//因已释放连接，故重新指向数据库对象进行索引
|
SYS_USER userDelte = edm.SYS_USER.FirstOrDefault(x => x.USERNAME == user.USERNAME);
|
////删除角色关系
|
//edm.SYS_USER_VS_ROLE.RemoveRange(userDelte.SYS_USER_VS_ROLE);
|
////删除一些创建人
|
//List<SYS_ROLE> srList = userDelte.SYS_ROLE.ToList();
|
//foreach (var i in srList)
|
//{
|
// i.CREATORID = 0;
|
//}
|
//删除用户
|
//edm.SYS_USER.Remove(userDelte);
|
userDelte.ENABLE = 0;
|
if (edm.SaveChanges() > 0)
|
{
|
return true;
|
}
|
else
|
{
|
msg = "删除失败";
|
return false;
|
}
|
}
|
}
|
}
|
}
|
