using HanHe.Utility.Data;
|
using HH.WMS.Common.MagicModel;
|
using HH.WMS.Entitys.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.Common;
|
using System.Data.OracleClient;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.DAL.Common
|
{
|
/// <summary>
|
/// 通用数据处理类
|
/// </summary>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
public class GeneralDAL : BaseDAL
|
{
|
#region 获取版本清单
|
/// <summary>
|
/// 根据条件，获取版本信息
|
/// </summary>
|
/// <param name="queryEntity">条件</param>
|
/// <returns>返回满足条件的历次版本信息</returns>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
public List<VersionEntity> GetVersions(MagicQueryEntity queryEntity)
|
{
|
// 组织sql
|
string where, orderBy,tbName;
|
string sql = MagicDataAccess.GetMagic_Page_Model(queryEntity, out where, out orderBy, out tbName);
|
|
// 执行查询
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
return DataAccessExtensive.ExecuteListEntity<VersionEntity>(this.DataAccess, cmd, SetVersionEntity);
|
}
|
|
/// <summary>
|
/// 设置版本的实体
|
/// </summary>
|
/// <param name="entity">版本实体</param>
|
/// <param name="reader">数据集</param>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
private void SetVersionEntity(VersionEntity entity, IDataReader reader)
|
{
|
SetEntityUti(entity, "Code", "Code", reader);
|
SetEntityUti(entity, "Status", "Status", reader);
|
}
|
#endregion
|
|
#region 获取对象列表
|
/// <summary>
|
/// 根据条件，获取列表信息
|
/// </summary>
|
/// <param name="queryEntity">条件</param>
|
/// <returns>返回满足条件的对象清单</returns>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
public DataTable GetList(MagicQueryEntity queryEntity)
|
{
|
// 组织sql
|
string where, orderBy,tbName;
|
string sql = MagicDataAccess.GetMagic_Page_Model(queryEntity, out where, out orderBy, out tbName);
|
|
DbCommand cmd;
|
// 不分页
|
if (!queryEntity.isPageing)
|
cmd = DataAccess.GetSqlStringCommand(sql);
|
else
|
{
|
// 分页
|
cmd = DataAccess.GetStoredProcCommand("prc_query");
|
this.DataAccess.AddInParameter(cmd, "TableName", ComDbType.CHAR, sql);
|
this.DataAccess.AddInParameter(cmd, "WhereStr", ComDbType.CHAR, where);
|
this.DataAccess.AddInParameter(cmd, "OrderByStr", ComDbType.CHAR, orderBy);
|
this.DataAccess.AddInParameter(cmd, "PageSize", ComDbType.INT, queryEntity.pageSize);
|
this.DataAccess.AddInParameter(cmd, "PageIndex", ComDbType.INT, queryEntity.pageIndex);
|
this.DataAccess.AddOutParameter(cmd, "TotalPage", ComDbType.INT, 4);
|
this.DataAccess.AddOutParameter(cmd, "TotalRecord", ComDbType.INT, 4);
|
|
//如果是oracle 增加特性
|
if (!string.IsNullOrEmpty(Now_dbType) && Now_dbType.Equals("ORACLE"))
|
{
|
//处理游标类型 因DbType无游标类型,游标类型单独处理
|
ComDbType.AddOrcOutParameter(cmd, "v_cur", OracleType.Cursor);
|
}
|
}
|
// 执行查询
|
return DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd, null);
|
}
|
#endregion
|
|
#region 获取对象实体
|
/// <summary>
|
/// 根据条件，获取对象实体
|
/// </summary>
|
/// <param name="queryEntity">条件</param>
|
/// <returns>返回满足条件的对象实体</returns>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
public DataTable GetEntity(MagicQueryEntity queryEntity)
|
{
|
// 组织sql
|
string where, orderBy, tbName;
|
string sql = MagicDataAccess.GetMagic_Page_Model(queryEntity, out where, out orderBy, out tbName);
|
|
// 执行查询
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
return DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd, null);
|
}
|
#endregion
|
|
#region 判断记录是否存在
|
/// <summary>
|
/// 判断记录是否存在
|
/// </summary>
|
/// <param name="queryEntity">条件</param>
|
/// <returns>true：存在 false：不存在</returns>
|
/// <history>[HanHe(HHC)] CREATED 2017/9/27</history>
|
public bool CheckExists(MagicQueryEntity queryEntity)
|
{
|
// 组织sql
|
string where, orderBy, tbName;
|
string sql = MagicDataAccess.GetMagic_Page_Model(queryEntity, out where, out orderBy, out tbName);
|
|
// 执行查询
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
object obj = DataAccess.ExecuteScalar(cmd);
|
return obj != null;
|
}
|
#endregion
|
|
#region 判断数据是否存在(简便)
|
/// <summary>
|
/// 判断数据是否存在
|
/// </summary>
|
/// <param name="tableName"></param>
|
/// <param name="columnName"></param>
|
/// <param name="value"></param>
|
/// <returns></returns>
|
public bool Exists(string tableName, string columnName, string value)
|
{
|
string strSql = "SELECT " + columnName + " FROM " + tableName + " where " + columnName + " ='" + value + "'";
|
// 执行查询
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
|
object obj = DataAccess.ExecuteScalar(cmd);
|
return obj != null;
|
}
|
#endregion
|
}
|
}
|
