using HanHe.Utility.Data;
|
using HH.WMS.Common;
|
using HH.WMS.Common.Response;
|
using HH.WMS.Entitys.External;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.Common;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.DAL.External
|
{
|
/// <summary>
|
/// 货位变化管理
|
/// </summary>
|
public class TN_WM_B_LOCATION_CHANGEDAL : BaseDAL
|
{
|
#region 获取货位状态变化表
|
public WebApiResponse Get(string strWhere, string pageSize, string pageIndex)
|
{
|
StringBuilder sqlWhere = new StringBuilder();
|
sqlWhere.Append(" WHERE 1=1 ");
|
if (!string.IsNullOrEmpty(strWhere))
|
sqlWhere.Append(strWhere);
|
var cmd = DataAccess.GetStoredProcCommand("prc_query");
|
DataAccess.AddInParameter(cmd, "TableName", ComDbType.STRING, "TN_WM_B_LOCATION_CHANGE");
|
DataAccess.AddInParameter(cmd, "WhereStr", ComDbType.STRING, sqlWhere.ToString());
|
DataAccess.AddInParameter(cmd, "OrderByStr", ComDbType.STRING, " ORDER BY CN_S_CHANGE_TIME DESC ");
|
DataAccess.AddInParameter(cmd, "PageSize", ComDbType.INT, pageSize);
|
DataAccess.AddInParameter(cmd, "PageIndex", ComDbType.INT, pageIndex);
|
DataAccess.AddOutParameter(cmd, "TotalPage", ComDbType.INT, 4);
|
DataAccess.AddOutParameter(cmd, "TotalRecord", ComDbType.INT, 4);
|
var list = DataAccessExtensive.ExecuteListEntity<TN_WM_B_LOCATION_CHANGEEntity>(this.DataAccess, cmd, (entity, reader) =>
|
{
|
SetEntityUti(entity, "CN_S_LOCATION_CODE", "CN_S_LOCATION_CODE", reader);
|
SetEntityUti(entity, "CN_S_LOCATION_BSTATE", "CN_S_LOCATION_BSTATE", reader);
|
SetEntityUti(entity, "CN_S_LOCATION_ASTATE", "CN_S_LOCATION_ASTATE", reader);
|
SetEntityUti(entity, "CN_S_OBJ_CODE", "CN_S_OBJ_CODE", reader);
|
SetEntityUti(entity, "CN_N_INDEX", "CN_N_INDEX", reader);
|
SetEntityUti(entity, "CN_S_CHANGE_TYPE", "CN_S_CHANGE_TYPE", reader);
|
SetEntityUti(entity, "CN_S_CHANGE_REASON", "CN_S_CHANGE_REASON", reader);
|
SetEntityUti(entity, "CN_S_CHANGE_TIME", "CN_S_CHANGE_TIME", reader);
|
SetEntityUti(entity, "CN_S_STOCK_CODE", "CN_S_STOCK_CODE", reader);
|
SetEntityUti(entity, "CN_S_STOCK_AREA", "CN_S_STOCK_AREA", reader);
|
SetEntityUti(entity, "CN_S_TASK_NO", "CN_S_TASK_NO", reader);
|
SetEntityUti(entity, "CN_S_SYSNAME", "CN_S_SYSNAME", reader);
|
SetEntityUti(entity, "CN_S_USER", "CN_S_USER", reader);
|
SetEntityUti(entity, "CN_S_EXT1", "CN_S_EXT1", reader);
|
SetEntityUti(entity, "CN_S_EXT2", "CN_S_EXT2", reader);
|
SetEntityUti(entity, "CN_S_EXT3", "CN_S_EXT3", reader);
|
});
|
var pageCount = Convert.ToInt32(this.DataAccess.GetParameterValue(cmd, "TotalRecord"));
|
return WebApiResponse.GetResult(new
|
{
|
rows = list,
|
total = pageCount
|
});
|
}
|
#endregion
|
|
|
#region 删除货位变化表
|
|
public WebApiResponse Delete(string strWhere)
|
{
|
var sqlStr = string.Format(@"DELETE FROM [dbo].[TN_WM_B_LOCATION_CHANGE] WHERE '{0}' ", strWhere);
|
var cmd = DataAccess.GetSqlStringCommand(sqlStr);
|
var result = ExecuteCommand(cmd, null);
|
return WebApiResponse.GetSqlResult(result);
|
}
|
|
#endregion
|
}
|
}
|
