using HanHe.Utility.Data;
|
using HH.WMS.Entitys;
|
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.Check
|
{
|
public class TN_WM_CHECK_WXYSDAL : DapperBaseDAL
|
{
|
#region GET
|
|
public DataTable GetCheckList(dynamic obj)
|
{
|
var sqlWhere = " WHERE 1=1 ";//" WHERE CN_S_OP_NO ='' ";
|
var orderBy = " ORDER BY CN_S_STOCK_AREA DESC ";
|
var opNo = obj.Value<string>("opNo");
|
var locationCode = obj.Value<string>("locationCode");
|
var stockArea = obj.Value<string>("stockArea");
|
|
if (string.IsNullOrEmpty(opNo))
|
{
|
sqlWhere += " AND CN_S_OP_NO='' ";
|
}
|
else
|
{
|
sqlWhere += " AND (CN_S_OP_NO='' OR CN_S_OP_NO='" + opNo + "') ";
|
}
|
if (!string.IsNullOrEmpty(locationCode))
|
{
|
sqlWhere += " AND CN_S_LOCATION_CODE LIKE '%" + locationCode + "%' ";
|
}
|
if (!string.IsNullOrEmpty(stockArea))
|
{
|
sqlWhere += " AND CN_S_STOCK_AREA='" + stockArea + "' ";
|
}
|
var tableName = " (SELECT DISTINCT CN_S_STOCK_AREA,CN_S_STOCK_CODE,CN_S_LOCATION_CODE,CN_S_TRAY_CODE FROM [dbo].[tn_wm_check_list] " + sqlWhere + ") a ";
|
DbCommand cmd = DataAccess.GetStoredProcCommand("prc_query");
|
this.DataAccess.AddInParameter(cmd, "TableName", ComDbType.CHAR, tableName);//"TN_WM_CHECK_LIST");
|
this.DataAccess.AddInParameter(cmd, "WhereStr", ComDbType.CHAR, "");
|
this.DataAccess.AddInParameter(cmd, "OrderByStr", ComDbType.CHAR, orderBy);
|
this.DataAccess.AddInParameter(cmd, "PageSize", ComDbType.INT, obj.pageSize);
|
this.DataAccess.AddInParameter(cmd, "PageIndex", ComDbType.INT, obj.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);
|
}
|
try
|
{
|
//获得列表
|
DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
|
obj.PageCount = Convert.ToInt32(this.DataAccess.GetParameterValue(cmd, "TotalRecord"));
|
return dt;
|
}
|
catch (Exception)
|
{
|
|
throw;
|
}
|
}
|
|
#endregion
|
|
#region UPDATE
|
|
public OperateResult UpdateCheckListOpNo(string beforeOpNo, string afterOpNo, IDbTransaction trans)
|
{
|
var sql = string.Format(@" UPDATE tn_wm_check_list SET CN_S_OP_NO='{0}' WHERE CN_S_OP_NO='{1}' ", afterOpNo, beforeOpNo);
|
return ExecuteTranSql(sql, null, trans);
|
}
|
|
#endregion
|
}
|
}
|
