~tjx/GsMes.git - Gitblit

			@@ -8,6 +8,10 @@
			using System.Linq;
			using System.Text;
			using Gs.User.Modes;
			using System.Diagnostics;
			using System.Diagnostics.Metrics;
			using System.Security.Principal;
			using System.Net;

			namespace Gs.User.Service
			{
			@@ -55,17 +59,6 @@
			System.Data.DataRow row = dset.Tables[0].Rows[0];
			m.loginGuid = Guid.Parse(row["loginGuid"].ToString());
			m.loginOrgGuid = row["loginOrgGuid"].ToString();
			System.Text.StringBuilder sbR = new StringBuilder();
			if (dset.Tables.Count > 1 && dset.Tables[1].Rows.Count > 1)
			{
			foreach (System.Data.DataRow r in dset.Tables[1].Rows)
			{
			if (sbR.Length > 0)
			sbR.Append(",");
			sbR.Append(r["rightGuid"].ToString());
			}
			}
			m.loginRightList = sbR.ToString();
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, "登录成功！");
			}
			}
			@@ -81,5 +74,403 @@
			}
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Exception, "登录失败！");
			}

			/// <summary>
			/// 读取用户登录信息
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<System.Dynamic.ExpandoObject> GetUserLoginInfo([FromBody] UserLogin model)
			{
			Guid userGuid = model.userGuid;
			DataSet dset = new DataSet();
			dynamic m = new System.Dynamic.ExpandoObject();
			using (SqlConnection conn = new SqlConnection(DbHelperSQL.strConn))
			{
			using (SqlCommand cmd = new SqlCommand("[prc_user_info]", conn))
			{
			try
			{
			conn.Open();
			cmd.CommandType = CommandType.StoredProcedure;
			SqlParameter[] parameters = new SqlParameter[] {
			new SqlParameter("@userGuid",userGuid),
			};
			foreach (SqlParameter parameter in parameters)
			{
			cmd.Parameters.Add(parameter);
			}
			using (SqlDataAdapter dt = new SqlDataAdapter(cmd))
			{
			dt.Fill(dset, "0");
			}
			if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)
			{
			System.Data.DataRow row = dset.Tables[0].Rows[0];
			m.loginGuid = Guid.Parse(row["loginGuid"].ToString());
			m.loginOrgGuid = row["loginOrgGuid"].ToString();
			m.list = new List<MenuAction>();
			if (dset.Tables.Count > 1 && dset.Tables[1].Rows.Count > 1)
			{
			foreach (DataRow dr in dset.Tables[1].Rows)
			{
			m.list.Add(
			new MenuAction()
			{
			guid = Guid.Parse(dr["rightGuid"].ToString()),
			upGuid = dr["upGuid"].ToString().Length > 0 ? Guid.Parse(dr["upGuid"].ToString()) : null,
			name = dr["name"].ToString(),
			icon = dr["icon"].ToString(),
			formPath = dr["formPath"].ToString(),
			category = int.Parse(dr["category"].ToString()),
			}
			);
			}
			string _msg = "欢迎使用某某公司EMS系统，你的角色为【管理员】当前共有【20】条信息未处理";
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, _msg);
			}
			}
			}
			catch (Exception ex)
			{
			LogHelper.Debug(this.ToString(), "GetUserInfo error：" + ex.Message);
			}
			finally
			{
			conn.Close();
			}
			}
			}
			return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Exception, "登录失败！");
			}


			#region
			/// <summary>
			/// 读取列表，支持分页
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<PageList<dynamic>> GetListPage([FromBody] PageQuery model)
			{
			int currentPage = model.currentPage;
			int everyPageSize = model.everyPageSize;
			string sortName = string.IsNullOrEmpty(model.sortName) ? "a.name" : model.sortName;
			System.Text.StringBuilder sbSql = new StringBuilder();
			sbSql.Append("select * from ");
			sbSql.Append("( ");
			sbSql.Append("select top 100000 ROW_NUMBER() over(order by " + sortName + " " + model.sortOrder + ") as rowIndex,* from sys_User a where 1=1" + model.keyWhere);
			sbSql.Append(") as T ");
			sbSql.Append(" where T.rowindex>(" + currentPage + "-1)" + everyPageSize + " and T.rowindex<=" + currentPage + "" + everyPageSize + "");
			sbSql.Append(" select count(1) as intTotal from sys_User a where 1=1 " + model.keyWhere).ToString();
			DataSet dset = new DataSet();
			try
			{
			dset = Gs.Toolbox.DbHelperSQL.Query(sbSql.ToString());
			}
			catch (Exception ex)
			{
			Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetListPage error：" + ex.Message);
			return ReturnDto<PageList<dynamic>>.QuickReturn(default(PageList<dynamic>), ReturnCode.Exception, "读取失败");
			}
			PageList<dynamic> _pglist = new PageList<dynamic>
			{
			total = 0,
			everyPageSize = 0,
			pages = 0,
			list = new List<dynamic>()
			};
			if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)//有数据
			{
			int intTotal = int.Parse(dset.Tables[1].Rows[0]["intTotal"].ToString());
			int pages = (intTotal % everyPageSize != 0) ? (intTotal / everyPageSize + 1) : (intTotal / everyPageSize);
			_pglist.total = intTotal;
			_pglist.everyPageSize = everyPageSize;
			_pglist.pages = pages;
			foreach (DataRow row in dset.Tables[0].Rows)
			{
			Sys_User _model = new Sys_User();
			if (row["guid"] != null && row["guid"].ToString() != "")
			{
			_model.guid = new Guid(row["guid"].ToString());
			}
			if (row["account"] != null)
			{
			_model.account = row["account"].ToString();
			}
			if (row["password"] != null && row["password"].ToString() != "")
			{
			_model.password = new Guid(row["password"].ToString());
			}
			if (row["userName"] != null)
			{
			_model.userName = row["userName"].ToString();
			}
			if (row["address"] != null)
			{
			_model.address = row["address"].ToString();
			}
			if (row["tel"] != null)
			{
			_model.tel = row["tel"].ToString();
			}
			if (row["email"] != null)
			{
			_model.email = row["email"].ToString();
			}
			if (row["lastLoginTime"] != null && row["lastLoginTime"].ToString() != "")
			{
			_model.lastLoginTime = DateTime.Parse(row["lastLoginTime"].ToString());
			}
			if (row["lastLogoutTime"] != null && row["lastLogoutTime"].ToString() != "")
			{
			_model.lastLogoutTime = DateTime.Parse(row["lastLogoutTime"].ToString());
			}
			if (row["isLocked"] != null && row["isLocked"].ToString() != "")
			{
			_model.isLocked = int.Parse(row["isLocked"].ToString());
			}
			if (row["createTime"] != null && row["createTime"].ToString() != "")
			{
			_model.createTime = DateTime.Parse(row["createTime"].ToString());
			}
			if (row["flagAdmin"] != null && row["flagAdmin"].ToString() != "")
			{
			_model.flagAdmin = int.Parse(row["flagAdmin"].ToString());
			}
			if (row["flagOnline"] != null && row["flagOnline"].ToString() != "")
			{
			_model.flagOnline = int.Parse(row["flagOnline"].ToString());
			}
			if (row["loginCounter"] != null && row["loginCounter"].ToString() != "")
			{
			_model.loginCounter = int.Parse(row["loginCounter"].ToString());
			}
			if (row["workerID"] != null)
			{
			_model.workerID = row["workerID"].ToString();
			}
			if (row["remark"] != null)
			{
			_model.remark = row["remark"].ToString();
			}
			if (row["departGuid"] != null && row["departGuid"].ToString() != "")
			{
			_model.departGuid = new Guid(row["departGuid"].ToString());
			}
			if (row["isSys"] != null && row["isSys"].ToString() != "")
			{
			_model.isSys = int.Parse(row["isSys"].ToString());
			}
			_model.isLockedTxt = row["isLocked"].ToString() != "1" ? "正常" : "被锁定";
			_pglist.list.Add(_model);
			}
			}
			return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist, ReturnCode.Success, "读取成功");
			}


			/// <summary>
			/// 删除
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<int?> DeleteModel([FromBody] string guidList)
			{
			int rtnInt = (int)ReturnCode.Default;
			int cont = 0;
			try
			{
			//是否内置
			cont = int.Parse(DbHelperSQL.GetSingle("select count(1) from sys_User where [isSys]=1 and guid in split('" + guidList + "',',')").ToString());
			if (cont > 0)
			{
			return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "删除失败，该条目为系统内置，不可删除！");
			}
			StringBuilder strSql = new StringBuilder();
			strSql.Append("delete from sys_User ");
			strSql.Append(" where guid in (" + guidList + ") ");
			int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
			rtnInt = rows;
			}
			catch (Exception ex)
			{
			LogHelper.Debug(this.ToString(), "DeleteModel error：" + ex.Message);
			rtnInt = (int)ReturnCode.Exception;
			}
			if (rtnInt > 0)
			return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Success, "操作成功，共删除" + rtnInt.ToString() + "条数据！");
			else
			return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "删除失败，请重试！");
			}

			/// <summary>
			/// 增加
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			public ReturnDto<int?> EditModel([FromBody] Sys_User model)
			{
			Guid? guid = model.guid;
			string strPass = Guid.NewGuid().ToString();
			int? rtnInt = (int)ReturnCode.Default;
			if (guid == null)
			{
			int cont = 0;
			cont = int.Parse(DbHelperSQL.GetSingle("select count(1) from sys_User where account='" + guid.ToString() + "'").ToString());
			if (cont > 0)
			{
			return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Exception, "增加失败，该账号已存在！");
			}
			}
			StringBuilder strSql = new StringBuilder();
			if (guid != null)
			{
			strSql.Append(" UPDATE [dbo].[sys_User]");
			strSql.Append(" SET [userName] = @userName ,[address] =@address ,[tel] = @tel,[email] = @email ,[isLocked] =@isLocked,[createTime] = getdate() ,[flagAdmin] =@flagAdmin,[workerID] =@workerID ,[remark] = @remark,[departGuid] = @departGuid ");
			strSql.Append(" where guid='" + guid + "'");
			}
			else
			{
			guid = Guid.NewGuid();
			strSql.Append("insert into sys_User");
			strSql.Append(" ([guid],[account],[password],[userName],[address],[tel],[email],[isLocked],[createTime],[flagAdmin],[flagOnline],[loginCounter],[workerID],[remark],[departGuid])");
			strSql.Append(" values (");
			strSql.Append("'" + guid + "',@account,'" + strPass + "',@userName,@address,@tel,@email,@isLocked,getdate(),@flagAdmin,0,0 ,@workerID,@remark,@departGuid)");
			}
			SqlParameter[] parameters = {
			new SqlParameter("@account", model.account),
			new SqlParameter("@userName",model.userName),
			new SqlParameter("@address",model.address),
			new SqlParameter("@tel",model.tel),
			new SqlParameter("@email",model.email),
			new SqlParameter("@isLocked",model.isLocked),
			new SqlParameter("@flagAdmin",model.flagAdmin),
			new SqlParameter("@workerID",model.workerID),
			new SqlParameter("@remark",model.remark),
			new SqlParameter("@departGuid",model.departGuid),
			};
			try
			{
			rtnInt = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
			}
			catch (Exception ex)
			{
			LogHelper.Debug(this.ToString(), "EditModel error：" + ex.Message);
			rtnInt = (int)ReturnCode.Exception;
			}
			if (rtnInt > 0)
			return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success, "操作成功！");
			else
			return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception, "增加失败，请重试！");
			}

			/// <summary>
			/// 读取
			/// </summary>
			/// <param name="guid"></param>
			/// <returns></returns>
			[RequestMethod(RequestMethods.POST)]
			[AllowAnonymous]
			public ReturnDto<Sys_User> GetModel([FromBody] Sys_User model)
			{
			Sys_User _model = new Sys_User();
			System.Text.StringBuilder sbSql = new StringBuilder();
			sbSql.Append("select top 1 * from sys_Organization where 1=1 and guid='" + model.guid.ToString() + "' ");
			try
			{
			DataSet dset = new DataSet();
			dset = DbHelperSQL.Query(sbSql.ToString());
			if (dset != null && dset.Tables.Count > 0 && dset.Tables[0].Rows.Count > 0)
			{
			System.Data.DataRow row = dset.Tables[0].Rows[0];
			if (row["guid"] != null && row["guid"].ToString() != "")
			{
			_model.guid = new Guid(row["guid"].ToString());
			}
			if (row["account"] != null)
			{
			_model.account = row["account"].ToString();
			}
			if (row["password"] != null && row["password"].ToString() != "")
			{
			_model.password = new Guid(row["password"].ToString());
			}
			if (row["userName"] != null)
			{
			_model.userName = row["userName"].ToString();
			}
			if (row["address"] != null)
			{
			_model.address = row["address"].ToString();
			}
			if (row["tel"] != null)
			{
			_model.tel = row["tel"].ToString();
			}
			if (row["email"] != null)
			{
			_model.email = row["email"].ToString();
			}
			if (row["lastLoginTime"] != null && row["lastLoginTime"].ToString() != "")
			{
			_model.lastLoginTime = DateTime.Parse(row["lastLoginTime"].ToString());
			}
			if (row["lastLogoutTime"] != null && row["lastLogoutTime"].ToString() != "")
			{
			_model.lastLogoutTime = DateTime.Parse(row["lastLogoutTime"].ToString());
			}
			if (row["isLocked"] != null && row["isLocked"].ToString() != "")
			{
			_model.isLocked = int.Parse(row["isLocked"].ToString());
			}
			if (row["createTime"] != null && row["createTime"].ToString() != "")
			{
			_model.createTime = DateTime.Parse(row["createTime"].ToString());
			}
			if (row["flagAdmin"] != null && row["flagAdmin"].ToString() != "")
			{
			_model.flagAdmin = int.Parse(row["flagAdmin"].ToString());
			}
			if (row["flagOnline"] != null && row["flagOnline"].ToString() != "")
			{
			_model.flagOnline = int.Parse(row["flagOnline"].ToString());
			}
			if (row["loginCounter"] != null && row["loginCounter"].ToString() != "")
			{
			_model.loginCounter = int.Parse(row["loginCounter"].ToString());
			}
			if (row["workerID"] != null)
			{
			_model.workerID = row["workerID"].ToString();
			}
			if (row["remark"] != null)
			{
			_model.remark = row["remark"].ToString();
			}
			if (row["departGuid"] != null && row["departGuid"].ToString() != "")
			{
			_model.departGuid = new Guid(row["departGuid"].ToString());
			}
			if (row["isSys"] != null && row["isSys"].ToString() != "")
			{
			_model.isSys = int.Parse(row["isSys"].ToString());
			}
			return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Success, "读取成功！");
			}
			else
			return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Default, "读取失败！");
			}
			catch (Exception ex)
			{
			LogHelper.Debug(this.ToString(), "GetModel error:" + ex.Message);
			return ReturnDto<Sys_User>.QuickReturn(_model, ReturnCode.Default, "读取失败！");
			}
			}
			#endregion
			}
			}