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
    }
}