You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
320 lines
12 KiB
320 lines
12 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
|
|
using System.Data;
|
|
using MySql.Data.MySqlClient;
|
|
|
|
namespace FangYar.OracleDAL.TBL
|
|
{
|
|
public class SysDeptDAL:FangYar.IDAL.TBL.SysDeptIDAL
|
|
{
|
|
|
|
#region 私有方法
|
|
/// <summary>
|
|
/// DataRow转model实体类对象
|
|
/// </summary>
|
|
/// <param name="dr"></param>
|
|
/// <returns></returns>
|
|
private void DataRowToModel(Model.TBL.TBL_SYS_DEPT_Model model, DataRow dr)
|
|
{
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
|
model.ID = dr["ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["ORG_CLASS"]))
|
|
model.ORG_CLASS = dr["ORG_CLASS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["ORG_ID"]))
|
|
model.ORG_ID = dr["ORG_ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["DEPT_NAME"]))
|
|
model.DEPT_NAME = dr["DEPT_NAME"].ToString();
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// DataRow转model实体类对象
|
|
/// </summary>
|
|
/// <param name="dr"></param>
|
|
/// <returns></returns>
|
|
private FangYar.Model.TBL.TBL_SYS_DEPT_Model DataRowToModel(DataRow dr)
|
|
{
|
|
FangYar.Model.TBL.TBL_SYS_DEPT_Model model = new FangYar.Model.TBL.TBL_SYS_DEPT_Model();
|
|
if (dr != null)
|
|
{
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
|
model.ID = dr["ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["ORG_CLASS"]))
|
|
model.ORG_CLASS = dr["ORG_CLASS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["ORG_ID"]))
|
|
model.ORG_ID = dr["ORG_ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["DEPT_NAME"]))
|
|
model.DEPT_NAME = dr["DEPT_NAME"].ToString();
|
|
if (!DBNull.Value.Equals(dr["IS_DEL"]))
|
|
model.IS_DEL = dr["IS_DEL"].ToString();
|
|
if (!DBNull.Value.Equals(dr["OGR_NAME"]))
|
|
model.ORG_NAME = dr["OGR_NAME"].ToString();
|
|
}
|
|
return model;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 把DataTable行转成实体类List集合
|
|
/// </summary>
|
|
private List<FangYar.Model.TBL.TBL_SYS_DEPT_Model> DataTableToList(DataTable dt)
|
|
{
|
|
List<FangYar.Model.TBL.TBL_SYS_DEPT_Model> deptlist = new List<FangYar.Model.TBL.TBL_SYS_DEPT_Model>();
|
|
if (dt.Rows.Count > 0)
|
|
{
|
|
foreach (DataRow myRow in dt.Rows)
|
|
{
|
|
deptlist.Add(DataRowToModel(myRow));
|
|
}
|
|
}
|
|
return deptlist;
|
|
|
|
}
|
|
#endregion
|
|
#region 基本方法
|
|
/// <summary>
|
|
/// 根据ID获取model
|
|
/// </summary>
|
|
public FangYar.Model.TBL.TBL_SYS_DEPT_Model GetModelByID(string ID) {
|
|
Model.TBL.TBL_SYS_DEPT_Model model = null;
|
|
string sql = "select * from TBL_SYS_DEPT where ID=@ID";
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ID",MySqlDbType.VarChar,36)
|
|
};
|
|
paras[0].Value = ID;
|
|
DataTable dt = FangYar.Common.MySqlHelper.QueryTable(sql, paras);
|
|
if (dt.Rows.Count > 0)
|
|
{
|
|
model = new Model.TBL.TBL_SYS_DEPT_Model();
|
|
DataRowToModel(model, dt.Rows[0]);
|
|
return model;
|
|
|
|
}
|
|
else
|
|
{
|
|
|
|
return null;
|
|
}
|
|
|
|
}
|
|
/// <summary>
|
|
/// 添加菜单
|
|
/// </summary>
|
|
public bool Add(FangYar.Model.TBL.TBL_SYS_DEPT_Model model) {
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("insert into TBL_SYS_DEPT (ORG_CLASS,ORG_ID,DEPT_NAME,IS_DEL)");
|
|
strsql.Append("values");
|
|
strsql.Append("(@ORG_CLASS,@ORG_ID,@DEPT_NAME,@IS_DEL)");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ORG_CLASS",MySqlDbType.VarChar,1),
|
|
new MySqlParameter("@ORG_ID",MySqlDbType.VarChar,36),
|
|
new MySqlParameter("@DEPT_NAME",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@IS_DEL",MySqlDbType.VarChar,1)
|
|
};
|
|
paras[0].Value = model.ORG_CLASS;
|
|
paras[1].Value = model.ORG_ID;
|
|
paras[2].Value = model.DEPT_NAME;
|
|
paras[3].Value = model.IS_DEL;
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
|
if (i > 0)
|
|
{
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
|
|
}
|
|
/// <summary>
|
|
/// 删除
|
|
/// </summary>
|
|
public bool Delete(string IDList) {
|
|
string sql = "delete from TBL_SYS_DEPT where ID in('" + IDList + "')";
|
|
try
|
|
{
|
|
FangYar.Common.MySqlHelper.ExecuteSql(sql);
|
|
return true;
|
|
}
|
|
catch
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 编辑
|
|
/// </summary>
|
|
public bool Edit(FangYar.Model.TBL.TBL_SYS_DEPT_Model model) {
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("update TBL_SYS_DEPT set ");
|
|
strsql.Append("ORG_CLASS=@ORG_CLASS,");
|
|
strsql.Append("ORG_ID=@ORG_ID,");
|
|
strsql.Append("DEPT_NAME=@DEPT_NAME,");
|
|
strsql.Append("IS_DEL=@IS_DEL ");
|
|
strsql.Append(" where ID=@ID");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ORG_CLASS",model.ORG_CLASS),
|
|
new MySqlParameter("@ORG_ID",model.ORG_ID),
|
|
new MySqlParameter("@DEPT_NAME",model.DEPT_NAME),
|
|
new MySqlParameter("@IS_DEL",model.IS_DEL),
|
|
new MySqlParameter("@ID",model.ID)
|
|
};
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
|
if (i > 0) { return true; }
|
|
else { return false; }
|
|
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 2019_05_30 swr 新增方法
|
|
/// <summary>
|
|
/// 获取记录总数
|
|
/// </summary>
|
|
public int GetRecordCount(string strWhere)
|
|
{
|
|
StringBuilder strSql = new StringBuilder();
|
|
strSql.Append("select count(1) FROM TBL_SYS_DEPT ");
|
|
if (strWhere.Trim() != "")
|
|
{
|
|
strSql.Append(" where " + strWhere);
|
|
}
|
|
object obj = FangYar.Common.MySqlHelper.GetSingle(strSql.ToString());
|
|
if (obj == null)
|
|
{
|
|
return 0;
|
|
}
|
|
else
|
|
{
|
|
return Convert.ToInt32(obj);
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 分页无排序
|
|
/// </summary>
|
|
/// <param name="PageIndex">页面索引</param>
|
|
/// <param name="PageSize">页面大小</param>
|
|
/// <param name="strwhere">查询条件</param>
|
|
/// <returns></returns>
|
|
public List<FangYar.Model.TBL.TBL_SYS_DEPT_Model> QueryList(int PageIndex, int PageSize, string strwhere, string order)
|
|
{
|
|
|
|
return DataTableToList(QueryPage(PageIndex, PageSize, strwhere, order));
|
|
}
|
|
/// <summary>
|
|
/// 分页无排序
|
|
/// </summary>
|
|
/// <param name="PageIndex">页面索引</param>
|
|
/// <param name="PageSize">页面大小</param>
|
|
/// <param name="strwhere">查询条件</param>
|
|
/// <returns></returns>
|
|
public DataTable QueryPage(int PageIndex, int PageSize, string strwhere, string order)
|
|
{
|
|
int startnum = (PageIndex - 1) * PageSize;
|
|
StringBuilder strSql = new StringBuilder();
|
|
strSql.Append("SELECT t.*,(select org_name from tbl_sys_org o where o.id = t.org_id ) OGR_NAME FROM TBL_SYS_DEPT t ");
|
|
if (strwhere != null && strwhere != "")
|
|
{
|
|
strSql.Append(" where " + strwhere);
|
|
}
|
|
if (order != null && order != "")
|
|
{
|
|
strSql.Append(" ORDER BY " + order);
|
|
}
|
|
strSql.Append(" limit " + startnum + ", " + PageSize);
|
|
return FangYar.Common.MySqlHelper.QueryTable(strSql.ToString());
|
|
}
|
|
|
|
/// <summary>
|
|
/// 添加部门
|
|
/// </summary>
|
|
public bool AddDept(FangYar.Model.TBL.TBL_SYS_DEPT_Model model)
|
|
{
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("insert into TBL_SYS_DEPT (ORG_ID,DEPT_NAME,IS_DEL)");
|
|
strsql.Append("values");
|
|
strsql.Append("(@ORG_ID,@DEPT_NAME,@IS_DEL)");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ORG_ID",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@DEPT_NAME",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@IS_DEL",MySqlDbType.VarChar,1)
|
|
};
|
|
paras[0].Value = model.ORG_ID;
|
|
paras[1].Value = model.DEPT_NAME;
|
|
paras[2].Value = model.IS_DEL;
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
|
if (i > 0)
|
|
{
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 修改部门信息
|
|
/// </summary>
|
|
public bool EditDept(FangYar.Model.TBL.TBL_SYS_DEPT_Model model)
|
|
{
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("update TBL_SYS_DEPT set ");
|
|
strsql.Append("ORG_ID=@ORG_ID,");
|
|
strsql.Append("DEPT_NAME=@DEPT_NAME ");
|
|
strsql.Append(" where ID=@ID");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ORG_ID",model.ORG_ID),
|
|
new MySqlParameter("@DEPT_NAME",model.DEPT_NAME),
|
|
new MySqlParameter("@ID",model.ID)
|
|
};
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
|
if (i > 0) { return true; }
|
|
else { return false; }
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取部门包含人员数
|
|
/// </summary>
|
|
public int GetEmpCount(string strWhere)
|
|
{
|
|
StringBuilder strSql = new StringBuilder();
|
|
strSql.Append("select count(1) FROM TBL_SYS_EMP ");
|
|
if (strWhere.Trim() != "")
|
|
{
|
|
strSql.Append(" where " + strWhere);
|
|
}
|
|
object obj = FangYar.Common.MySqlHelper.GetSingle(strSql.ToString());
|
|
if (obj == null)
|
|
{
|
|
return 0;
|
|
}
|
|
else
|
|
{
|
|
return Convert.ToInt32(obj);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 删除
|
|
/// </summary>
|
|
public bool DelDept(string DeptList)
|
|
{
|
|
string sql = "update TBL_SYS_DEPT set IS_DEL = '1' where ID in(" + DeptList + ")";
|
|
try
|
|
{
|
|
FangYar.Common.MySqlHelper.ExecuteSql(sql);
|
|
return true;
|
|
}
|
|
catch
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
#endregion 2019_05_30 swr 新增方法
|
|
}
|
|
|
|
}
|
|
|