using HH.WMS.Common;
|
using HH.WMS.Entitys;
|
using HH.WMS.Entitys.Basic;
|
using HH.WMS.Entitys.Dto;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.DAL.OutStock
|
{
|
public class OutStockDAL : DapperBaseDAL
|
{
|
#region 发货通知单主表-分页
|
/// <summary>
|
/// 发货通知单主表-分页
|
/// </summary>
|
/// <param name="param"></param>
|
/// <param name="total"></param>
|
/// <returns></returns>
|
public DataTable GetOutList(OutSearchDto param, out long total)
|
{
|
string sql = @" SELECT * FROM TN_WM_OUT_MST WHERE 1=1 ";
|
|
sql += GetFilterField("CN_S_OP_NO", param.CN_S_OP_NO, "like");
|
sql += GetFilterField("CN_S_STATE", param.CN_S_STATE, "in");
|
sql += GetFilterField("CN_T_CREATE", param.CN_T_CREATE, "dateArray");
|
|
sql = "(" + sql + ") t";
|
int pageIndex = Convert.ToInt32(param.pageIndex);
|
int pageSize = Convert.ToInt32(param.pageSize);
|
string orderBy = Util.ToString(param.orderBy);
|
return ExecutePagingData(sql, pageIndex, pageSize, out total, orderBy);
|
}
|
#endregion
|
|
#region 修改库区分配量
|
/// <summary>
|
/// 修改库区分配量
|
/// </summary>
|
/// <param name="areaQtyList"></param>
|
/// <returns></returns>
|
public OperateResult UpdateAreaAlloc(TN_WM_B_AREA_QTYEntity areaQty, IDbTransaction trans)
|
{
|
if (areaQty.CN_F_QUANTITY == 0)
|
{
|
string sql = @"DELETE FROM TN_WM_B_AREA_QTY WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
return ExecuteTranSql(sql, areaQty, trans);
|
}
|
else
|
{
|
string sql = @"UPDATE TN_WM_B_AREA_QTY SET CN_F_ALLOC_QTY=@CN_F_ALLOC_QTY,CN_F_QUANTITY=@CN_F_QUANTITY,CN_S_TIMESTAMP='{0}' WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
sql = string.Format(sql, DateTime.Now.ToString("yyyyMMddHHmmssffff"));
|
return ExecuteTranSql(sql, areaQty, trans);
|
}
|
}
|
#endregion
|
|
#region 修改库存分配量
|
/// <summary>
|
/// 修改库存分配量
|
/// </summary>
|
/// <param name="stockList"></param>
|
/// <param name="trans"></param>
|
/// <returns></returns>
|
public OperateResult UpdateStockAllocQty(TN_WM_B_STOCK_QTYEntity stockQty, IDbTransaction trans, string timeStamp = "")
|
{
|
if (stockQty.CN_F_QUANTITY == 0)
|
{
|
string sql = @"DELETE FROM TN_WM_B_STOCK_QTY WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
return ExecuteTranSql(sql, stockQty, trans);
|
}
|
else
|
{
|
string sql = "UPDATE TN_WM_B_STOCK_QTY SET CN_F_ALLOC_QTY=@CN_F_ALLOC_QTY,CN_F_QUANTITY=@CN_F_QUANTITY,CN_S_TIMESTAMP='{0}' WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
sql = string.Format(sql, string.IsNullOrEmpty(timeStamp) ? DateTime.Now.ToString("yyyyMMddHHmmssffff") : timeStamp);
|
return ExecuteTranSql(sql, stockQty, trans);
|
}
|
}
|
#endregion
|
|
#region 修改托盘物料分配量
|
/// <summary>
|
/// 修改托盘物料分配量
|
/// </summary>
|
/// <param name="trayItemList"></param>
|
/// <param name="trans"></param>
|
/// <param name="timeStamp"></param>
|
/// <returns></returns>
|
public OperateResult UpdateTrayItemAllocQty(TN_WM_B_TRAY_ITEM_MSTEntity trayItem, IDbTransaction trans, string timeStamp = "")
|
{
|
if (trayItem.CN_F_QUANTITY == 0)
|
{
|
string sql = @"DELETE FROM TN_WM_B_TRAY_ITEM_MST WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
var or = ExecuteTranSql(sql, trayItem, trans);
|
if (or.AffectedRows == 0) return or;
|
sql = @"DELETE FROM TN_WM_B_TRAY_ITEM_DTL WHERE CN_PARENT_GUID=@CN_GUID";
|
return ExecuteTranSql(sql, trayItem, trans);
|
}
|
else
|
{
|
string sql = "UPDATE TN_WM_B_TRAY_ITEM_MST SET CN_F_ALLOC_QTY=@CN_F_ALLOC_QTY,CN_F_QUANTITY=@CN_F_QUANTITY,CN_S_TIMESTAMP='{0}' WHERE CN_GUID=@CN_GUID AND (CN_S_TIMESTAMP = @CN_S_TIMESTAMP OR CN_S_TIMESTAMP IS NULL)";
|
sql = string.Format(sql, string.IsNullOrEmpty(timeStamp) ? DateTime.Now.ToString("yyyyMMddHHmmssffff") : timeStamp);
|
var or = ExecuteTranSql(sql, trayItem, trans);
|
if (or.AffectedRows == 0) return or;
|
sql = " UPDATE TN_WM_B_TRAY_ITEM_DTL SET CN_F_QUANTITY=@CN_F_QUANTITY WHERE CN_PARENT_GUID=@CN_GUID ";
|
return ExecuteTranSql(sql, trayItem, trans);
|
}
|
}
|
#endregion
|
|
#region 取货位分拣中的物料
|
/// <summary>
|
/// 取货位分拣中的物料
|
/// </summary>
|
/// <param name="locationCode"></param>
|
/// <returns></returns>
|
public List<TN_WM_SORTING_LOCATIONEntity> GetSortingLocation(string locationCode)
|
{
|
string sql = @"SELECT * FROM TN_WM_SORTING_LIST A,
|
TN_WM_SORTING_LOCATION B
|
WHERE A.CN_S_SORTING_NO = B.CN_S_SORTING_NO AND A.CN_S_STATE='分拣中' AND B.CN_S_LOCATION_CODE IN(
|
SELECT TOP 1 CN_S_START_BIT FROM TN_WM_TASK WHERE CN_S_END_BIT=@CN_S_END_BIT ORDER BY CN_T_CREATE DESC)";
|
return ExecuteQuery<TN_WM_SORTING_LOCATIONEntity>(sql, new
|
{
|
CN_S_END_BIT = locationCode
|
});
|
}
|
#endregion
|
}
|
}
|
