using HH.WMS.BLL.Basic;
|
using HH.WMS.BLL.SysMgr;
|
using HH.WMS.Common;
|
using HH.WMS.Common.External;
|
using HH.WMS.Common.Response;
|
using HH.WMS.DAL;
|
using HH.WMS.DAL.Algorithm;
|
using HH.WMS.DAL.Basic;
|
using HH.WMS.DAL.External;
|
using HH.WMS.DAL.InStock;
|
using HH.WMS.DAL.SysMgr;
|
using HH.WMS.Entitys;
|
using HH.WMS.Entitys.Basic;
|
using HH.WMS.Entitys.Common;
|
using HH.WMS.Entitys.Entitys;
|
using HH.WMS.Entitys.External;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Globalization;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.BLL.External
|
{
|
/// <summary>
|
/// 简易出入库对外提供的接口逻辑处理类
|
/// </summary>
|
public class ExternalBLL : DapperBaseBLL
|
{
|
private static string _className = "ExternalBLL";
|
|
#region 入作业区批量 + InWorkArea
|
/// <summary>
|
/// 入作业区批量
|
/// </summary>
|
/// <param name="inWorkAreaList"></param>
|
/// <returns></returns>
|
public ExternalResponse InWorkArea(List<InWorkAreaEntity> inWorkAreaList)
|
{
|
_className += "_InWorkArea";
|
|
var response = new ExternalResponse();
|
if (inWorkAreaList == null) return response.Error<InWorkAreaEntity>(null, "参数不正确!");
|
for (var i = 0; i < inWorkAreaList.Count; i++)
|
{
|
if (string.IsNullOrEmpty(inWorkAreaList[i].sysName))
|
{
|
inWorkAreaList[i].sysName = "AMS";
|
}
|
var result = ExecuteInWorkArea(inWorkAreaList[i], i);
|
if (result.BasisResponse.Success)
|
{
|
response.success = true;
|
response.okList.Add(result.TaskExecuteState.okTask);
|
}
|
else
|
{
|
response.failList.Add(result.TaskExecuteState.Error(i, result.BasisResponse.Message).FailTask);
|
//入库转运锁定起点的，如果执行不成功则解锁
|
if (result.RollbackLocations.Count > 0)
|
{
|
foreach (string sLocation in result.RollbackLocations)
|
{
|
BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().UpdateState(sLocation, Constants.Location_State_Normal, "");
|
AutoBomLocationEntity locationModel = CreateDAL<TN_WMS_LOCATIONDAL>().GetModel(sLocation);
|
BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(sLocation, "", "正常", "入库请求失败回滚过程中锁定的货位", inWorkAreaList[i].sysName, "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE, null);
|
}
|
}
|
|
//删除当前托盘的任务
|
CreateDAL<DapperDAL<TN_WM_TASKEntity>>().Delete(new { CN_S_TRAY_CODE = result.InWorkAreaEntity.trayCode, CN_S_STATE = "未执行" });
|
}
|
}
|
|
return response.failList.Any() ? response.Error(null, string.Empty, inWorkAreaList) : response.Ok(null, inWorkAreaList);
|
}
|
#endregion
|
|
#region 入作业区执行 + ExecuteInWorkArea
|
/// <summary>
|
/// 入作业区
|
/// </summary>
|
/// <param name="inWorkAreaEntity"></param>
|
/// <param name="index">索引</param>
|
/// <returns></returns>
|
private ExecuteInWorkAreaPara ExecuteInWorkArea(InWorkAreaEntity inWorkAreaEntity, int index)
|
{
|
var executeInWorkAreaPara = new ExecuteInWorkAreaPara { InWorkAreaEntity = inWorkAreaEntity };
|
|
try
|
{
|
#region 参数验证
|
executeInWorkAreaPara = ParameterVerifyBLL.VerifyInWorkArea(executeInWorkAreaPara);
|
if (!executeInWorkAreaPara.BasisResponse.Success) return executeInWorkAreaPara;
|
#endregion
|
|
#region 参数处理
|
executeInWorkAreaPara = ParameterHandleBLL.HandleInWorkArea(executeInWorkAreaPara);
|
if (!executeInWorkAreaPara.BasisResponse.Success) return executeInWorkAreaPara;
|
#endregion
|
|
if (!string.IsNullOrEmpty(executeInWorkAreaPara.InWorkAreaEntity.endBit))
|
{
|
|
var endLocation = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeInWorkAreaPara.InWorkAreaEntity.endBit });
|
if (endLocation == null)
|
{
|
executeInWorkAreaPara.BasisResponse = BasisResponse.Error("结束货位不正确！");
|
return executeInWorkAreaPara;
|
}
|
|
//结束库区实体
|
var endStockArea = DALCreator.Create<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(executeInWorkAreaPara.InWorkAreaEntity.startBit.Trim());
|
if (endStockArea == null)
|
{
|
executeInWorkAreaPara.BasisResponse = BasisResponse.Error("当前结束位置未找到对应的库区！", _className);
|
return executeInWorkAreaPara;
|
}
|
|
#region 创建转运任务
|
executeInWorkAreaPara.TransportEntity.CN_S_TASK_NO = executeInWorkAreaPara.InWorkAreaEntity.taskNo;
|
executeInWorkAreaPara.TransportEntity.CN_S_CIR_OBJ = "托盘";
|
executeInWorkAreaPara.TransportEntity.CN_S_CIR_OBJ_CODE = executeInWorkAreaPara.InWorkAreaEntity.trayCode;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_BIT = executeInWorkAreaPara.InWorkAreaEntity.startBit;
|
executeInWorkAreaPara.TransportEntity.CN_S_STATE = Constants.TaskStateList[0];
|
executeInWorkAreaPara.TransportEntity.CN_N_PRIORITY = executeInWorkAreaPara.InWorkAreaEntity.priority;
|
executeInWorkAreaPara.TransportEntity.CN_T_CREATE = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");//DateTime.Now.ToString();
|
executeInWorkAreaPara.TransportEntity.CN_T_MODIFY = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");//DateTime.Now.ToString();
|
executeInWorkAreaPara.TransportEntity.CN_S_REMARK = executeInWorkAreaPara.InWorkAreaEntity.remark;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_AREA = executeInWorkAreaPara.InWorkAreaEntity.startArea;
|
executeInWorkAreaPara.TransportEntity.CN_S_STOCK_CODE = executeInWorkAreaPara.InWorkAreaEntity.startStock;
|
executeInWorkAreaPara.TransportEntity.CN_S_TASK_TYPE = executeInWorkAreaPara.InWorkAreaEntity.isTransport == "Y" ? "转运" : "入库";
|
executeInWorkAreaPara.TransportEntity.CN_S_START_AREA_TYPE = executeInWorkAreaPara.StartStockAreaEntity.CN_S_STRUCTURE;
|
executeInWorkAreaPara.TransportEntity.CN_C_START_IS_CONTROL_QTY = executeInWorkAreaPara.StartStockAreaEntity.CN_C_IS_CONTROL_QTY;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_CONTROL_INV = executeInWorkAreaPara.StartStockAreaEntity.CN_C_IS_INVENTORY;
|
executeInWorkAreaPara.TransportEntity.CN_S_END_BIT = endLocation.CN_S_LOCATION_CODE;
|
executeInWorkAreaPara.TransportEntity.CN_S_END_AREA = endLocation.CN_S_AREA_CODE;
|
executeInWorkAreaPara.TransportEntity.CN_C_END_IS_CONTROL_QTY = endStockArea.CN_C_IS_CONTROL_QTY;
|
executeInWorkAreaPara.TransportEntity.CN_S_END_CONTROL_INV = endStockArea.CN_C_IS_INVENTORY;
|
executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE = endStockArea.CN_S_STRUCTURE;
|
|
#endregion
|
}
|
else
|
{
|
#region 计算转运路径
|
executeInWorkAreaPara = ExternalInWorkAreaBLL.CalculateTransPath(executeInWorkAreaPara);
|
if (!executeInWorkAreaPara.BasisResponse.Success) return executeInWorkAreaPara;
|
#endregion
|
|
#region 创建转运任务
|
executeInWorkAreaPara.TransportEntity.CN_S_TASK_NO = executeInWorkAreaPara.InWorkAreaEntity.taskNo;
|
executeInWorkAreaPara.TransportEntity.CN_S_CIR_OBJ = "托盘";
|
executeInWorkAreaPara.TransportEntity.CN_S_CIR_OBJ_CODE = executeInWorkAreaPara.InWorkAreaEntity.trayCode;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_BIT = executeInWorkAreaPara.InWorkAreaEntity.startBit;
|
executeInWorkAreaPara.TransportEntity.CN_S_STATE = Constants.TaskStateList[0];
|
executeInWorkAreaPara.TransportEntity.CN_N_PRIORITY = executeInWorkAreaPara.InWorkAreaEntity.priority;
|
executeInWorkAreaPara.TransportEntity.CN_T_CREATE = DateTime.Now.ToString(CultureInfo.InvariantCulture);
|
executeInWorkAreaPara.TransportEntity.CN_T_MODIFY = DateTime.Now.ToString(CultureInfo.InvariantCulture);
|
executeInWorkAreaPara.TransportEntity.CN_S_REMARK = executeInWorkAreaPara.InWorkAreaEntity.remark;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_AREA = executeInWorkAreaPara.InWorkAreaEntity.startArea;
|
executeInWorkAreaPara.TransportEntity.CN_S_STOCK_CODE = executeInWorkAreaPara.InWorkAreaEntity.startStock;
|
executeInWorkAreaPara.TransportEntity.CN_S_TASK_TYPE = executeInWorkAreaPara.InWorkAreaEntity.isTransport == "Y" ? "转运" : "入库";
|
executeInWorkAreaPara.TransportEntity.CN_S_START_AREA_TYPE = executeInWorkAreaPara.StartStockAreaEntity.CN_S_STRUCTURE;
|
executeInWorkAreaPara.TransportEntity.CN_C_START_IS_CONTROL_QTY = executeInWorkAreaPara.StartStockAreaEntity.CN_C_IS_CONTROL_QTY;
|
executeInWorkAreaPara.TransportEntity.CN_S_START_CONTROL_INV = executeInWorkAreaPara.StartStockAreaEntity.CN_C_IS_INVENTORY;
|
|
#endregion
|
|
#region 算法计算终点货位
|
executeInWorkAreaPara = ExternalInWorkAreaBLL.InAss(executeInWorkAreaPara);
|
Log.Detail("入作业区", "算法计算终点货位结果：" + JsonConvert.SerializeObject(executeInWorkAreaPara.BasisResponse) + "货位号：" + executeInWorkAreaPara.TransportEntity.CN_S_END_BIT);
|
|
if (!executeInWorkAreaPara.BasisResponse.Success) return executeInWorkAreaPara;
|
#endregion
|
}
|
|
#region 事务 执行存储过程(处理托盘、托盘产品关联、生成任务、设置任务号、更新货位状态)
|
var result = UseTransaction(trans => {
|
|
if (executeInWorkAreaPara.InWorkAreaEntity.data != null)
|
{
|
if (executeInWorkAreaPara.InWorkAreaEntity.data.Count > 0)
|
{
|
//删除托盘产品关联
|
CreateDAL<DAL.InStock.TN_WM_B_TRAY_ITEM_RELDAL>().DeleteTrayItem(" CN_S_TRAY_CODE='" + executeInWorkAreaPara.InWorkAreaEntity.trayCode + "' ", trans);
|
|
foreach (var item in executeInWorkAreaPara.InWorkAreaEntity.data)
|
{
|
var trayItemMstGuid = Guid.NewGuid().ToString();
|
//添加托盘物料关联主表
|
var transResult = CreateDAL<HH.WMS.DAL.InStock.TN_WM_B_TRAY_ITEM_RELDAL>().AddMst(new TN_WM_B_TRAY_ITEM_MSTEntity
|
{
|
CN_GUID = trayItemMstGuid,
|
CN_S_TRAY_CODE = executeInWorkAreaPara.InWorkAreaEntity.trayCode,
|
CN_S_ITEM_CODE = item.itemCode,
|
CN_S_ITEM_NAME = item.itemName,
|
CN_S_ITEM_STATE = item.itemState == null ? "" : item.itemState,
|
CN_F_QUANTITY = item.qty,
|
CN_S_MEASURE_UNIT = item.itemPackUnit,
|
CN_F_ALLOC_QTY = item.qty,
|
CN_S_MODEL = item.itemModel
|
}, trans);
|
|
if (!transResult.Success)
|
{
|
trans.Rollback();
|
return;
|
}
|
|
//添加托盘物料关联子表
|
var curResult = CreateDAL<HH.WMS.DAL.InStock.TN_WM_B_TRAY_ITEM_RELDAL>().AddDtl(new List<TN_WM_B_TRAY_ITEM_DTLEntity>()
|
{
|
new TN_WM_B_TRAY_ITEM_DTLEntity{
|
CN_PARENT_GUID = trayItemMstGuid,
|
CN_S_LOT_NO = item.lotNo,
|
CN_S_UNIQUE_CODE = item.uniqueCode,
|
CN_S_PACKING_UNIT = item.itemPackUnit,
|
CN_F_PACKING_QTY = item.qty,
|
CN_F_QUANTITY = item.qty,
|
CN_T_PRODUCTION = item.productionDate,
|
CN_S_CREATOR = "hh",
|
CN_S_CREATOR_BY = "",
|
CN_T_CREATE = DateTime.Now,
|
CN_GUID = Guid.NewGuid().ToString(),
|
sqlwhere = " WHERE CN_PARENT_GUID='" + trayItemMstGuid + "' "
|
}
|
}, trans);
|
transResult = new OperateResult { Success = curResult.Success, Msg = curResult.Success ? "" : curResult.Exception.Message };
|
if (!transResult.Success)
|
{
|
trans.Rollback();
|
return;
|
}
|
}
|
}
|
}
|
|
|
|
var transport = executeInWorkAreaPara.TransportEntity;
|
|
//创建任务
|
var operateResult = BLLCreator.Create<DapperBLL<TN_WM_TASKEntity>>().Add(new TN_WM_TASKEntity
|
{
|
CN_S_TASK_NO = transport.CN_S_TASK_NO,
|
CN_S_TRAY_CODE = transport.CN_S_CIR_OBJ_CODE,
|
CN_S_START_BIT = transport.CN_S_START_BIT,
|
CN_S_END_BIT = transport.CN_S_END_BIT,
|
//CN_S_PRO_CODE = transport.CN_S_PRO_CODE,
|
CN_S_STATE = transport.CN_S_STATE,
|
CN_S_BF_TASK_NO = transport.CN_S_BF_TASK_NO,
|
CN_S_AF_TASK_NO = transport.CN_S_AF_TASK_NO,
|
CN_S_STOCK_CODE = transport.CN_S_STOCK_CODE,
|
CN_S_START_AREA = transport.CN_S_START_AREA,
|
CN_S_END_AREA = transport.CN_S_END_AREA,
|
CN_N_PRIORITY = transport.CN_N_PRIORITY,
|
CN_S_CREATOR = transport.CN_S_CREATOR,
|
CN_S_CREATOR_BY = transport.CN_S_CREATOR_BY,
|
CN_T_CREATE = Convert.ToDateTime(transport.CN_T_CREATE),
|
CN_T_MODIFY = Convert.ToDateTime(transport.CN_T_MODIFY),
|
CN_S_REMARK = transport.CN_S_REMARK,
|
//CN_C_IS_AUTO = transport.CN_C_IS_AUTO,
|
CN_S_TASK_TYPE = transport.CN_S_TASK_TYPE,
|
CN_C_START_IS_CONTROL_QTY = transport.CN_C_START_IS_CONTROL_QTY,
|
CN_C_END_IS_CONTROL_QTY = transport.CN_C_END_IS_CONTROL_QTY,
|
CN_S_START_CONTROL_INV = transport.CN_S_START_CONTROL_INV,
|
CN_S_END_CONTROL_INV = transport.CN_S_END_CONTROL_INV,
|
CN_S_START_AREA_TYPE = transport.CN_S_START_AREA_TYPE,
|
CN_S_END_AREA_TYPE = transport.CN_S_END_AREA_TYPE,
|
CN_S_FROM_OP = "入库/转运"
|
//CN_S_PROJECT_CODE = executeOutWorkAreaPara.OutWorkAreaEntity.projectCode
|
});
|
|
//更新结束点的任务号
|
if (executeInWorkAreaPara.TransportEntity.CN_C_END_IS_CONTROL_QTY.Equals("Y"))
|
{
|
CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(executeInWorkAreaPara.TransportEntity.CN_S_END_BIT, "", "", executeInWorkAreaPara.TransportEntity.CN_S_TASK_NO, trans);
|
}
|
//if (executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE.Equals("平库") || executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE.Equals("立库")){}
|
|
//更新起点的任务号
|
if (executeInWorkAreaPara.TransportEntity.CN_C_START_IS_CONTROL_QTY.Equals("Y") && executeInWorkAreaPara.InWorkAreaEntity.isTransport.Equals("Y"))
|
{
|
CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(executeInWorkAreaPara.TransportEntity.CN_S_START_BIT, "", "", executeInWorkAreaPara.TransportEntity.CN_S_TASK_NO, trans);
|
}
|
//if (executeInWorkAreaPara.TransportEntity.CN_S_START_AREA_TYPE.Equals("平库") || executeInWorkAreaPara.TransportEntity.CN_S_START_AREA_TYPE.Equals("立库")){}
|
});
|
|
#endregion
|
|
#region 处理结果
|
if (!result.Success)
|
{
|
executeInWorkAreaPara.BasisResponse = BasisResponse.Error("执行存储过程失败！" + result.Msg, _className);
|
return executeInWorkAreaPara;
|
}
|
|
if (executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE == Constants.Area_Struc_LiuLiStock || executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE == Constants.Area_Struc_DuiDieStock)
|
{
|
executeInWorkAreaPara.TransportEntity.CN_S_END_BIT += "-" + executeInWorkAreaPara.TransportEntity.CN_S_QTY_INDEX;
|
}
|
executeInWorkAreaPara.TaskExecuteState = new TaskExecuteState().Ok(new OkTask()
|
{
|
index = index,
|
taskNo = executeInWorkAreaPara.TransportEntity.CN_S_TASK_NO,
|
startStock = executeInWorkAreaPara.TransportEntity.CN_S_STOCK_CODE,
|
startArea = executeInWorkAreaPara.TransportEntity.CN_S_START_AREA,
|
startBit = executeInWorkAreaPara.TransportEntity.CN_S_START_BIT,
|
endStock = executeInWorkAreaPara.TransportEntity.CN_S_STOCK_CODE,
|
endArea = executeInWorkAreaPara.TransportEntity.CN_S_END_AREA,
|
endBit = executeInWorkAreaPara.TransportEntity.CN_S_END_BIT,
|
priority = executeInWorkAreaPara.TransportEntity.CN_N_PRIORITY,
|
trayCode = executeInWorkAreaPara.TransportEntity.CN_S_CIR_OBJ_CODE,
|
startAreaClass = executeInWorkAreaPara.TransportEntity.CN_S_START_AREA_TYPE,
|
endAreaClass = executeInWorkAreaPara.TransportEntity.CN_S_END_AREA_TYPE
|
});
|
#endregion
|
}
|
catch (Exception ex)
|
{
|
executeInWorkAreaPara.BasisResponse = BasisResponse.Error("ExecuteInWorkArea 方法异常：" + JsonConvert.SerializeObject(ex.Message + ex.StackTrace));
|
}
|
|
return executeInWorkAreaPara;
|
}
|
#endregion
|
|
#region 出作业区 + OutWorkArea
|
/// <summary>
|
/// 出作业区批量
|
/// </summary>
|
/// <param name="outWorkAreaList"></param>
|
/// <returns></returns>
|
public ExternalResponse OutWorkArea(List<OutWorkAreaEntity> outWorkAreaList)
|
{
|
var response = new ExternalResponse();
|
if (outWorkAreaList == null) return response.Error<OutWorkAreaEntity>(null, "参数不正确!");
|
for (var i = 0; i < outWorkAreaList.Count; i++)
|
{
|
if (string.IsNullOrEmpty(outWorkAreaList[i].sysName))
|
{
|
outWorkAreaList[i].sysName = "AMS";
|
}
|
var result = ExecuteOutWorkArea(outWorkAreaList[i], i);
|
if (result.BasisResponse.Success)
|
{
|
response.success = true;
|
response.okList.Add(result.TaskExecuteState.okTask);
|
}
|
else
|
{
|
response.failList.Add(new TaskExecuteState().Error(i, result.BasisResponse.Message).FailTask);
|
if (result.RollLocations.Count > 0)
|
{
|
foreach (string sLocation in result.RollLocations)
|
{
|
BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().UpdateState(sLocation, Constants.Location_State_Normal, "");
|
AutoBomLocationEntity locationModel = CreateDAL<TN_WMS_LOCATIONDAL>().GetModel(sLocation);
|
BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(sLocation, "", "正常", "出库请求失败回滚过程中锁定的货位", outWorkAreaList[i].sysName, "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE, null);
|
}
|
}
|
}
|
}
|
return response.failList.Any() ? response.Error(null, string.Empty, outWorkAreaList) : response.Ok(null, outWorkAreaList);
|
}
|
#endregion
|
|
#region 出作业区执行 + ExecuteOutWorkArea
|
/// <summary>
|
/// 出作业区执行
|
/// </summary>
|
/// <param name="outWorkAreaEntity"></param>
|
/// <param name="index"></param>
|
/// <returns></returns>
|
private ExecuteOutWorkAreaPara ExecuteOutWorkArea(OutWorkAreaEntity outWorkAreaEntity, int index)
|
{
|
_className += ".ExecuteOutWorkArea";
|
var executeOutWorkAreaPara = new ExecuteOutWorkAreaPara { OutWorkAreaEntity = outWorkAreaEntity };
|
try
|
{
|
#region 参数验证
|
executeOutWorkAreaPara = ParameterVerifyBLL.VerifyOutWorkArea(executeOutWorkAreaPara);
|
if (!executeOutWorkAreaPara.BasisResponse.Success) return executeOutWorkAreaPara;
|
#endregion
|
|
#region 参数处理
|
executeOutWorkAreaPara = ParameterHandleBLL.HandleOutWorkArea(executeOutWorkAreaPara);
|
if (!executeOutWorkAreaPara.BasisResponse.Success) return executeOutWorkAreaPara;
|
#endregion
|
|
#region 算法计算货位
|
if (string.IsNullOrEmpty(executeOutWorkAreaPara.OutWorkAreaEntity.startBit))
|
{
|
executeOutWorkAreaPara = new ExternalOutWorkAreaBLL().CalculateLoaction(executeOutWorkAreaPara);
|
if (!executeOutWorkAreaPara.BasisResponse.Success) return executeOutWorkAreaPara;
|
}
|
#endregion
|
|
#region 事务 执行存储过程()
|
|
//任务
|
var transport = executeOutWorkAreaPara.TransportList.FirstOrDefault();
|
|
//添加任务
|
var sqlResult = BLLCreator.Create<DapperBLL<TN_WM_TASKEntity>>().Add(new TN_WM_TASKEntity
|
{
|
CN_S_TASK_NO = transport.CN_S_TASK_NO,
|
CN_S_TRAY_CODE = transport.CN_S_CIR_OBJ_CODE,
|
CN_S_START_BIT = transport.CN_S_START_BIT,
|
CN_S_END_BIT = transport.CN_S_END_BIT,
|
//CN_S_PRO_CODE = transport.CN_S_PRO_CODE,
|
CN_S_STATE = transport.CN_S_STATE,
|
CN_S_BF_TASK_NO = transport.CN_S_BF_TASK_NO,
|
CN_S_AF_TASK_NO = transport.CN_S_AF_TASK_NO,
|
CN_S_STOCK_CODE = transport.CN_S_STOCK_CODE,
|
CN_S_START_AREA = transport.CN_S_START_AREA,
|
CN_S_END_AREA = transport.CN_S_END_AREA,
|
CN_N_PRIORITY = transport.CN_N_PRIORITY,
|
CN_S_CREATOR = transport.CN_S_CREATOR,
|
CN_S_CREATOR_BY = transport.CN_S_CREATOR_BY,
|
CN_T_CREATE = Convert.ToDateTime(transport.CN_T_CREATE),
|
CN_T_MODIFY = Convert.ToDateTime(transport.CN_T_MODIFY),
|
CN_S_REMARK = transport.CN_S_REMARK,
|
//CN_C_IS_AUTO = transport.CN_C_IS_AUTO,
|
CN_S_TASK_TYPE = transport.CN_S_TASK_TYPE,
|
CN_C_START_IS_CONTROL_QTY = transport.CN_C_START_IS_CONTROL_QTY,
|
CN_C_END_IS_CONTROL_QTY = transport.CN_C_END_IS_CONTROL_QTY,
|
CN_S_START_CONTROL_INV = transport.CN_S_START_CONTROL_INV,
|
CN_S_END_CONTROL_INV = transport.CN_S_END_CONTROL_INV,
|
CN_S_START_AREA_TYPE = transport.CN_S_START_AREA_TYPE,
|
CN_S_END_AREA_TYPE = transport.CN_S_END_AREA_TYPE,
|
//CN_S_PROJECT_CODE = executeOutWorkAreaPara.OutWorkAreaEntity.projectCode
|
});
|
|
//更新起点的任务号
|
if (transport.CN_S_START_AREA_TYPE.Equals("平库") || transport.CN_S_START_AREA_TYPE.Equals("立库"))
|
{
|
if (transport.CN_C_START_IS_CONTROL_QTY.Equals("Y"))
|
{
|
sqlResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(transport.CN_S_START_BIT, "", "", transport.CN_S_TASK_NO, null);
|
}
|
}
|
|
//更新结束点的任务号
|
if (transport.CN_S_END_AREA_TYPE.Equals("平库") || transport.CN_S_END_AREA_TYPE.Equals("立库"))
|
{
|
if (transport.CN_C_END_IS_CONTROL_QTY.Equals("Y") && executeOutWorkAreaPara.OutWorkAreaEntity.IsTransport.Equals("Y"))
|
{
|
sqlResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(transport.CN_S_END_BIT, "", "", transport.CN_S_TASK_NO, null);
|
}
|
}
|
|
#region 出库影响库存，已注释
|
|
////托盘物料关联数据
|
//var trayItemMst = CreateDAL<DapperBaseDAL>().ExecuteQuery<TN_WM_B_TRAY_ITEM_MSTEntity>(" SELECT * FROM TN_WM_B_TRAY_ITEM_MST WHERE CN_S_TRAY_CODE='" + transport.CN_S_CIR_OBJ_CODE + "' ").FirstOrDefault();
|
//var trayItemDtl = CreateDAL<DapperBaseDAL>().ExecuteQuery<TN_WM_B_TRAY_ITEM_MSTEntity>(" SELECT * FROM TN_WM_B_TRAY_ITEM_DTL ", new {
|
// CN_PARENT_GUID=trayItemMst.CN_GUID
|
//}).FirstOrDefault();
|
|
//if (transport.CN_C_START_IS_CONTROL_QTY.Equals("Y") && transport.CN_S_START_CONTROL_INV.Equals("Y"))
|
//{
|
// //仓库量表
|
// var stockQtys = CreateDAL<DapperBaseDAL>().ExecuteQuery<TN_WM_B_STOCK_QTYEntity>(" SELECT * FROM tn_wm_b_stock_qty ", new {
|
// CN_S_STOCK_CODE = trayItemMst.CN_S_STOCK_CODE,
|
// CN_S_ITEM_CODE=trayItemMst.CN_S_ITEM_CODE,
|
// CN_S_ITEM_STATE=trayItemMst.CN_S_ITEM_STATE,
|
// CN_S_LOT_NO=trayItemDtl.CN_S_LOT_NO
|
// });
|
|
// if (stockQtys.Count > 0)
|
// {
|
// //升库存
|
// stockQtys.First().CN_F_ALLOC_QTY += (decimal) trayItemMst.CN_F_PACKING_QTY;
|
// CreateDAL<HH.WMS.DAL.Basic.TN_WM_B_STOCK_QTYDAL>().UpdateStockAllocQty(stockQtys, null);
|
// }
|
|
// //库区量表
|
// var areaQtys = CreateDAL<DapperBaseDAL>().ExecuteQuery<TN_WM_B_AREA_QTYEntity>(" SELECT * FROM tn_wm_b_stock_qty ", new
|
// {
|
// CN_S_STOCK_CODE = trayItemMst.CN_S_STOCK_CODE,
|
// CN_S_STOCK_AREA = trayItemMst.CN_S_IN_AREA_CODE,
|
// CN_S_ITEM_CODE = trayItemMst.CN_S_ITEM_CODE,
|
// CN_S_ITEM_STATE = trayItemMst.CN_S_ITEM_STATE,
|
// CN_S_LOT_NO = trayItemDtl.CN_S_LOT_NO
|
// });
|
|
// if (areaQtys.Count > 0)
|
// {
|
// //升库存
|
// areaQtys.First().CN_F_ALLOC_QTY += (decimal)trayItemMst.CN_F_PACKING_QTY;
|
// CreateDAL<HH.WMS.DAL.Basic.TN_WM_B_AREA_QTYDAL>().UpdateAreaAlloc(areaQtys, null);
|
// }
|
//}
|
|
#endregion
|
|
if (!sqlResult.Success)
|
{
|
executeOutWorkAreaPara.BasisResponse = BasisResponse.Error("执行存储过程失败！" + sqlResult.Msg, _className);
|
return executeOutWorkAreaPara;
|
}
|
#endregion
|
|
#region 处理结果
|
executeOutWorkAreaPara.TaskExecuteState = new TaskExecuteState().Ok(ParameterHandleBLL.HandleOutWorkAreaResponse(executeOutWorkAreaPara.TransportList[0], index), null);
|
#endregion
|
|
}
|
catch (Exception ex)
|
{
|
executeOutWorkAreaPara.BasisResponse = BasisResponse.Error("executeOutWorkArea 方法异常：" + JsonConvert.SerializeObject(ex.Message + ex.StackTrace));
|
}
|
return executeOutWorkAreaPara;
|
}
|
#endregion
|
|
#region 完工回报 + ExecuteState
|
|
public OperateResult ExecuteState(string taskNo, string taskState, LogPara logPara)
|
{
|
//TODO 加项目编号
|
|
var executeStatePara = new ExecuteStateParaDto();
|
|
var result = new OperateResult();
|
|
//查询任务
|
executeStatePara.transportTask = CreateDAL<DapperDAL<TN_WM_TASKEntity>>().GetSingleEntity(new { CN_S_TASK_NO = taskNo });
|
Log.Detail(logPara, LogDescribe.Content(executeStatePara.transportTask));
|
|
//起点货位是否绑定托盘
|
executeStatePara.startTrayLocation = CreateDAL<DapperDAL<TN_WM_B_TRAY_LOCATIONEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_START_BIT, executeStatePara.transportTask.CN_S_TRAY_CODE });
|
//终点货位是否绑定托盘
|
executeStatePara.endTrayLocation = CreateDAL<DapperDAL<TN_WM_B_TRAY_LOCATIONEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_END_BIT, executeStatePara.transportTask.CN_S_TRAY_CODE });
|
//起点货位是否绑定任务
|
executeStatePara.startIsCurrentTask = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_START_BIT, CN_S_TASK_NO = taskNo });
|
//终点货位是否绑定任务
|
executeStatePara.endIsCurrentTask = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_END_BIT, CN_S_TASK_NO = taskNo });
|
//托盘物料主表
|
executeStatePara.trayItemMsts = CreateDAL<DapperDAL<TN_WM_B_TRAY_ITEM_MSTEntity>>().GetList(new { executeStatePara.transportTask.CN_S_TRAY_CODE });
|
if (executeStatePara.trayItemMsts.Count > 0)
|
{
|
foreach (var trayItemMst in executeStatePara.trayItemMsts)
|
{
|
var item = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(trayItemMst.CN_S_ITEM_CODE);
|
trayItemMst.CN_F_INQTY = item.CN_F_NW;
|
trayItemMst.CN_S_WEIGHT = trayItemMst.CN_F_QUANTITY;//= item.CN_F_NW;
|
//trayItemMst.CN_F_INQTY = 0;
|
trayItemMst.TrayItemDtlList = CreateDAL<DapperDAL<TN_WM_B_TRAY_ITEM_DTLEntity>>().GetList(new { CN_PARENT_GUID = trayItemMst.CN_GUID });
|
//foreach (var trayItemDtl in trayItemMst.TrayItemDtlList)
|
//{
|
// trayItemMst.CN_S_WEIGHT += Convert.ToDecimal(trayItemDtl.CN_S_SERIAL_NO);
|
//}
|
}
|
}
|
|
//起点库区
|
executeStatePara.startStockArea = CreateDAL<TN_AB_B_STOCK_AREADAL>().GetStockAreaEntity(executeStatePara.transportTask.CN_S_START_AREA.Trim());
|
//结束库区
|
executeStatePara.endStockArea = CreateDAL<TN_AB_B_STOCK_AREADAL>().GetStockAreaEntity(executeStatePara.transportTask.CN_S_END_AREA.Trim());
|
//任务状态
|
executeStatePara.taskState = taskState;
|
|
var t = new Redis.ReisModel.RedisUserEntity();
|
|
//完成
|
if (taskState.Equals(Constants.TaskState_Complete))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().EndTaskForAuto(executeStatePara, logPara);
|
}
|
//取消
|
else if (taskState.Equals("取消"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().CancelTask(executeStatePara, logPara);
|
}
|
//空取
|
else if (taskState.Equals("空取"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().EmptyFetchTask(executeStatePara);
|
}
|
//取货完成
|
else if (taskState.Equals("取货完成"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().PickSucc(executeStatePara);
|
}
|
//卸货完成
|
else if (taskState.Equals("卸货完成"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().UnloadingSucc(executeStatePara, t, logPara);
|
}
|
|
return result;
|
}
|
|
#endregion
|
|
#region 完工回报（无锡宇寿） + ExecuteState
|
|
public OperateResult ExecuteStateForWxys(string taskNo, string taskState, LogPara logPara)
|
{
|
//TODO 加项目编号
|
|
var executeStatePara = new ExecuteStateParaDto();
|
|
var result = new OperateResult();
|
|
//查询任务
|
executeStatePara.transportTask = CreateDAL<DapperDAL<TN_WM_TASKEntity>>().GetSingleEntity(new { CN_S_TASK_NO = taskNo });
|
Log.Detail(logPara, LogDescribe.Content(executeStatePara.transportTask));
|
|
//起点货位是否绑定托盘
|
executeStatePara.startTrayLocation = CreateDAL<DapperDAL<TN_WM_B_TRAY_LOCATIONEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_START_BIT, executeStatePara.transportTask.CN_S_TRAY_CODE });
|
//终点货位是否绑定托盘
|
executeStatePara.endTrayLocation = CreateDAL<DapperDAL<TN_WM_B_TRAY_LOCATIONEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_END_BIT, executeStatePara.transportTask.CN_S_TRAY_CODE });
|
//起点货位是否绑定任务
|
executeStatePara.startIsCurrentTask = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_START_BIT, CN_S_TASK_NO = taskNo });
|
//终点货位是否绑定任务
|
executeStatePara.endIsCurrentTask = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = executeStatePara.transportTask.CN_S_END_BIT, CN_S_TASK_NO = taskNo });
|
//托盘物料主表
|
executeStatePara.trayItemMsts = CreateDAL<DapperDAL<TN_WM_B_TRAY_ITEM_MSTEntity>>().GetList(new { executeStatePara.transportTask.CN_S_TRAY_CODE });
|
if (executeStatePara.trayItemMsts.Count > 0)
|
{
|
foreach (var trayItemMst in executeStatePara.trayItemMsts)
|
{
|
var item = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(trayItemMst.CN_S_ITEM_CODE);
|
trayItemMst.CN_F_INQTY = item.CN_F_NW;
|
trayItemMst.CN_S_WEIGHT = 0;//= item.CN_F_NW;
|
//trayItemMst.CN_F_INQTY = 0;
|
trayItemMst.TrayItemDtlList = CreateDAL<DapperDAL<TN_WM_B_TRAY_ITEM_DTLEntity>>().GetList(new { CN_PARENT_GUID = trayItemMst.CN_GUID });
|
foreach (var trayItemDtl in trayItemMst.TrayItemDtlList)
|
{
|
trayItemMst.CN_S_WEIGHT += Convert.ToDecimal(trayItemDtl.CN_S_SERIAL_NO);
|
}
|
}
|
}
|
Log.Detail(logPara, "托盘物料关联表数据：" + LogDescribe.Content(executeStatePara.trayItemMsts));
|
|
//起点库区
|
executeStatePara.startStockArea = CreateDAL<TN_AB_B_STOCK_AREADAL>().GetStockAreaEntity(executeStatePara.transportTask.CN_S_START_AREA.Trim());
|
//结束库区
|
executeStatePara.endStockArea = CreateDAL<TN_AB_B_STOCK_AREADAL>().GetStockAreaEntity(executeStatePara.transportTask.CN_S_END_AREA.Trim());
|
//任务状态
|
executeStatePara.taskState = taskState;
|
|
var t = new Redis.ReisModel.RedisUserEntity();
|
|
//完成
|
if (taskState.Equals(Constants.TaskState_Complete))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().EndTaskForAuto(executeStatePara, logPara);
|
}
|
//取消
|
else if (taskState.Equals("取消"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().CancelTask(executeStatePara, logPara);
|
}
|
//空取
|
else if (taskState.Equals("空取"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().EmptyFetchTask(executeStatePara);
|
}
|
//取货完成
|
else if (taskState.Equals("取货完成"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().PickSucc(executeStatePara);
|
}
|
//卸货完成
|
else if (taskState.Equals("卸货完成"))
|
{
|
result = BLLCreator.Create<TN_WM_TASKBLL>().UnloadingSucc(executeStatePara, t, logPara);
|
}
|
|
return result;
|
}
|
|
#endregion
|
|
#region 同步货位状态，货位状态不一致设为异常
|
/// <summary>
|
/// 同步货位状态，货位状态不一致设为异常
|
/// </summary>
|
/// <param name="synchroLocationEntity"></param>
|
/// <returns></returns>
|
/// <history>[HanHe(zh)] CREATED 2018/5/3</history>
|
public ExternalResponse SynchroLocation(List<SynchroLocationEntity> synchroLocationList)
|
{
|
ExternalResponse result = new ExternalResponse();
|
if (synchroLocationList == null || synchroLocationList.Count == 0)
|
return result.Error<SynchroLocationEntity>(null, "接受同步货位数据为空！", synchroLocationList);
|
foreach (var item in synchroLocationList)
|
{
|
result = ExecuteSynchroLocation(item);
|
if (!result.success)
|
{
|
return result;
|
}
|
}
|
return result;
|
}
|
public ExternalResponse ExecuteSynchroLocation(SynchroLocationEntity synchroLocationEntity)
|
{
|
ExternalResponse response = new ExternalResponse();
|
try
|
{
|
AutoBomLocationEntity location = BLLCreator.Create<HH.WMS.BLL.Basic.TN_AB_STOCK_LOCATIONBLL>().GetModel(synchroLocationEntity.Location, synchroLocationEntity.StockCode);
|
if (location != null)
|
{
|
//获取库区实体
|
AutoBomStockAreaEntity stockAreaEntity = CreateDAL<HH.WMS.DAL.Basic.TN_AB_B_STOCK_AREADAL>().GetEntityByArea(location.CN_S_AREA_CODE);
|
if (stockAreaEntity == null)
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, "未找到库区");
|
|
TN_WM_LOCATION_EXTEntity locationExt = CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().GetSingleEntity(new { CN_S_LOCATION_CODE = synchroLocationEntity.Location, CN_S_STOCK_CODE = synchroLocationEntity.StockCode });// CreateDAL<TN_WM_LOCATION_EXTDAL>().GetEntityByCode(synchroLocationEntity.Location, synchroLocationEntity.StockCode);
|
if (locationExt == null)
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, "货位在TN_WM_LOCATION_EXT表中不存在");
|
|
//是否没有故障
|
bool isNotFault = true;
|
|
switch (synchroLocationEntity.State)
|
{
|
//有货
|
case 1:
|
isNotFault = locationExt.CN_S_USE_STATE != "空";
|
break;
|
//无货
|
case 2:
|
isNotFault = locationExt.CN_S_USE_STATE == "空";
|
break;
|
//故障
|
case 3:
|
isNotFault = false;
|
break;
|
}
|
if (!isNotFault)
|
{
|
string updateState = "全部故障";
|
//switch (synchroLocationEntity.Type)
|
//{
|
// case 1:
|
// updateState = "入库故障";
|
// break;
|
// case 2:
|
// updateState = "出库故障";
|
// break;
|
//}
|
if (locationExt.CN_S_LOCATION_STATE == Constants.Location_State_Normal)
|
{
|
var result = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationState(synchroLocationEntity.Location, updateState, "", null);
|
if (!result.Success)
|
{
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, result.Exception.Message);
|
}
|
else
|
{
|
AutoBomLocationEntity locationModel = CreateDAL<TN_WMS_LOCATIONDAL>().GetModel(synchroLocationEntity.Location);
|
BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(synchroLocationEntity.Location, "正常", updateState, "同步货位状态发现货位存储状态不一致时将货位设置为故障状态", "AMS", "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE, null);
|
}
|
}
|
}
|
else
|
{
|
if (locationExt.CN_S_LOCATION_STATE == Constants.Location_State_AllFault)
|
{
|
var result = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationState(synchroLocationEntity.Location, "正常", "", null);
|
if (!result.Success)
|
{
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, result.Exception.Message);
|
}
|
else
|
{
|
AutoBomLocationEntity locationModel = CreateDAL<TN_WMS_LOCATIONDAL>().GetModel(synchroLocationEntity.Location);
|
BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(synchroLocationEntity.Location, "全部故障", "正常", "同步货位状态发现货位存储状态一致时将货位设置为正常", "AMS", "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE, null);
|
}
|
}
|
}
|
return response.Ok<SynchroLocationEntity>(synchroLocationEntity);
|
}
|
else
|
{
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, "在仓库中未找到该货位");
|
}
|
}
|
catch (Exception ex)
|
{
|
return response.Error<SynchroLocationEntity>(synchroLocationEntity, "ExecuteSynchroLocation方法异常;" + ex.Message + ex.StackTrace);
|
}
|
}
|
#endregion
|
|
#region 外部请求本地 返回消息
|
|
|
public class UpdateWayResult
|
{
|
public bool success { get; set; }
|
public string errCode { get; set; }
|
public string errMsg { get; set; }
|
public string location { get; set; }
|
}
|
|
|
#endregion
|
}
|
}
|
