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