using HH.MData;
using HH.WMS.Common;
using HH.WMS.Common.Response;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.External;
using MongoDB.Driver.Builders;
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
{
    public class TN_WM_B_OBJ_INOUTDAL : BaseDAL
    {

        #region 添加出入库明细


        public WebApiResponse Add(TN_WM_B_OBJ_INOUTEntity model, DbTransaction trans)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append(" INSERT INTO dbo.TN_WM_B_OBJ_INOUT (");
                strSql.Append(" CN_GUID, CN_S_LOCATION_CODE, CN_S_OBJ_CODE, CN_N_INDEX, CN_S_ITEM_CODE, CN_S_ITEM_NAME, CN_S_PRODUCTION_BATCH, CN_S_LOT_NO, CN_S_OWNER, CN_S_ITEM_STATE, CN_S_MODEL, CN_F_QUANTITY, CN_S_CHANGE_TYPE, CN_S_CHANGE_TIME, CN_S_STOCK_CODE, CN_S_STOCK_AREA, CN_S_SYSNAME, CN_S_USER, CN_S_EXT1, CN_S_EXT2, CN_S_EXT3 )");
                strSql.Append(" VALUES (");
                strSql.Append(":CN_GUID,:CN_S_LOCATION_CODE,:CN_S_OBJ_CODE,:CN_N_INDEX,:CN_S_ITEM_CODE,:CN_S_ITEM_NAME,:CN_S_PRODUCTION_BATCH,:CN_S_LOT_NO,:CN_S_OWNER,:CN_S_ITEM_STATE,:CN_S_MODEL,:CN_F_QUANTITY,:CN_S_CHANGE_TYPE,:CN_S_CHANGE_TIME,:CN_S_STOCK_CODE,:CN_S_STOCK_AREA,:CN_S_SYSNAME,:CN_S_USER,:CN_S_EXT1,:CN_S_EXT2,:CN_S_EXT3)");
                DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
                DataAccess.AddInParameter(cmd, "CN_GUID", ComDbType.STRING, model.CN_GUID);
                DataAccess.AddInParameter(cmd, "CN_S_LOCATION_CODE", ComDbType.STRING, model.CN_S_LOCATION_CODE);
                DataAccess.AddInParameter(cmd, "CN_S_OBJ_CODE", ComDbType.STRING, model.CN_S_OBJ_CODE);
                DataAccess.AddInParameter(cmd, "CN_N_INDEX", ComDbType.INT, model.CN_N_INDEX);
                DataAccess.AddInParameter(cmd, "CN_S_ITEM_CODE", ComDbType.STRING, model.CN_S_ITEM_CODE);
                DataAccess.AddInParameter(cmd, "CN_S_ITEM_NAME", ComDbType.STRING, model.CN_S_ITEM_NAME);
                DataAccess.AddInParameter(cmd, "CN_S_PRODUCTION_BATCH", ComDbType.STRING, model.CN_S_PRODUCTION_BATCH);
                DataAccess.AddInParameter(cmd, "CN_S_LOT_NO", ComDbType.STRING, model.CN_S_LOT_NO);
                DataAccess.AddInParameter(cmd, "CN_S_OWNER", ComDbType.STRING, model.CN_S_OWNER);
                DataAccess.AddInParameter(cmd, "CN_S_ITEM_STATE", ComDbType.STRING, model.CN_S_ITEM_STATE);
                DataAccess.AddInParameter(cmd, "CN_S_MODEL", ComDbType.STRING, model.CN_S_MODEL);
                DataAccess.AddInParameter(cmd, "CN_F_QUANTITY", ComDbType.DECIMAL, model.CN_F_QUANTITY);
                DataAccess.AddInParameter(cmd, "CN_S_CHANGE_TYPE", ComDbType.STRING, model.CN_S_CHANGE_TYPE);
                DataAccess.AddInParameter(cmd, "CN_S_CHANGE_TIME", ComDbType.DATE, model.CN_S_CHANGE_TIME);
                DataAccess.AddInParameter(cmd, "CN_S_STOCK_CODE", ComDbType.STRING, model.CN_S_STOCK_CODE);
                DataAccess.AddInParameter(cmd, "CN_S_STOCK_AREA", ComDbType.STRING, model.CN_S_STOCK_AREA);
                DataAccess.AddInParameter(cmd, "CN_S_SYSNAME", ComDbType.STRING, model.CN_S_SYSNAME);
                DataAccess.AddInParameter(cmd, "CN_S_USER", ComDbType.STRING, model.CN_S_USER);
                DataAccess.AddInParameter(cmd, "CN_S_EXT1", ComDbType.STRING, model.CN_S_EXT1);
                DataAccess.AddInParameter(cmd, "CN_S_EXT2", ComDbType.STRING, model.CN_S_EXT2);
                DataAccess.AddInParameter(cmd, "CN_S_EXT3", ComDbType.STRING, model.CN_S_EXT3);
                var result = ExecuteCommand(cmd, trans);
                return WebApiResponse.GetSqlResult(result);
            }
            catch (Exception ex)
            {
                Log.Error("添加出入库明细", "Add方法异常！" + ex.Message);
                return WebApiResponse.GetResult(null, ex.Message);
            }

        }

        #endregion

        #region 删除货位变化表

        public WebApiResponse Delete(string strWhere)
        {
            var sqlStr = string.Format(@"DELETE FROM [dbo].[TN_WM_B_OBJ_INOUT] WHERE  '{0}' ", strWhere);
            var cmd = DataAccess.GetSqlStringCommand(sqlStr);
            var result = ExecuteCommand(cmd, null);
            return WebApiResponse.GetSqlResult(result);
        }
        #endregion


        #region 备份货位变化表

        public WebApiResponse BackData(string strWhere)
        {
            var sqlStr = string.Format(@"INSERT INTO FROM [dbo].[TN_WM_B_OBJ_INOUT_BAK] WHERE  '{0}' ", strWhere);
            var cmd = DataAccess.GetSqlStringCommand(sqlStr);
            var result = ExecuteCommand(cmd, null);
            return WebApiResponse.GetSqlResult(result);
        }

        #endregion
    }
}