using HH.WMS.Common;
|
using HH.WMS.DAL;
|
using HH.WMS.DAL.InStock;
|
using HH.WMS.Entitys;
|
using HH.WMS.Entitys.Basic;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.BLL.Interface
|
{
|
public class InfOMSRequest : DapperBaseBLL
|
{
|
#region WMS到货单审核调用OMS入库确认接口发送确认指令
|
/// <summary>
|
/// WMS到货单审核调用OMS入库确认接口发送确认指令
|
/// </summary>
|
/// <param name="opArrivalNoList">到货单号</param>
|
/// <returns></returns>
|
public OperateResult ArrivalDoOmsConfirm(List<string> opArrivalNoList)
|
{
|
OperateResult oresult = new OperateResult() { Success = true };
|
try
|
{
|
QimenStockInConfirmEntity InConfirmEntity = new QimenStockInConfirmEntity();
|
// qstcF.entryOrder.
|
|
foreach (string ArrivalNo in opArrivalNoList)
|
{
|
DataTable dt = CreateDAL<TN_WM_ARRIVALDAL>().GetArrivalOmsConfirmData(ArrivalNo);
|
if (dt.Rows.Count == 0) continue;
|
|
List<orderLines> orderList = new List<orderLines>();
|
entryOrder entryOrderEntity = new entryOrder()
|
{
|
entryOrderCode = dt.Rows[0]["CN_S_OP_NO"].ToString(), //入库单号
|
purchaseOrderCode = dt.Rows[0]["CN_S_FROM_NO"].ToString(), //采购订单号（WMS系统：上游来源业务号）
|
ownerCode = dt.Rows[0]["CN_S_OWNER"].ToString(), //货主
|
warehouseCode = dt.Rows[0]["CN_S_STOCK_CODE"].ToString(), //仓库编码
|
outBizCode = dt.Rows[0]["CN_GUID"].ToString(), //外部业务编码，讲究唯一性
|
status = dt.Rows[0]["CN_S_STATE"].ToString() //状态
|
};
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
orderLines orderEntity = new orderLines()
|
{
|
ownerCode = dt.Rows[0]["CN_S_OWNER"].ToString(), //货主
|
itemCode = dt.Rows[i]["CN_S_ITEM_CODE"].ToString(), //物料编码
|
itemName = dt.Rows[i]["CN_S_ITEM_NAME"].ToString(), //物料名称
|
planQty = int.Parse(decimal.Parse(dt.Rows[i]["PLANQTY"].ToString()).ToString("0")), //订单总数量
|
actualQty = int.Parse(decimal.Parse(dt.Rows[i]["ACTUALQTY"].ToString()).ToString("0")) //实收数量（WMS系统：本次到货数）
|
};
|
orderList.Add(orderEntity);
|
}
|
InConfirmEntity.entryOrder = entryOrderEntity;
|
InConfirmEntity.orderLines = orderList;
|
|
string postData = JsonConvert.SerializeObject(InConfirmEntity);
|
string resultEntity = WebApiManager.HttpOms_Post("api/PurchaseService/UpdateAccArriveNum", postData);
|
if (!string.IsNullOrEmpty(resultEntity))
|
{
|
oresult.Success = false;
|
oresult.Msg = "UpdateAccArriveNum接口未调通！";
|
return oresult;
|
}
|
|
|
TN_WMS_REQ_LOGEntity ril = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = System.Guid.NewGuid().ToString().ToUpper(),
|
CN_S_INTERFACE = "ArrivalDoOmsConfirm",
|
CN_S_INTERFACE_NAME = "WMS到货单审核调用OMS入库确认接口发送确认指令",
|
CN_S_REQUEST = postData,
|
CN_S_RESPONSE = resultEntity,
|
CN_T_CREATE = DateTime.Now
|
};
|
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(ril);
|
QiMenInConfirmResponse qir = JsonConvert.DeserializeObject<QiMenInConfirmResponse>(resultEntity);
|
|
if (qir.flag == "failure")
|
{
|
oresult.Success = false;
|
oresult.Msg = qir.message;
|
return oresult;
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
oresult.Success = false;
|
oresult.Msg = ex.Message.ToString();
|
Log.Info("WMS入库确认调用OMS接口发送确认指令报错！！！", oresult.Msg);
|
return oresult;
|
}
|
return oresult;
|
}
|
#endregion
|
|
#region WMS到货单反审核调用OMS接口发送反审指令
|
/// <summary>
|
/// WMS到货单反审核调用OMS接口发送反审指令
|
/// </summary>
|
/// <param name="opArrivalNoList">到货单号</param>
|
/// <returns></returns>
|
public OperateResult ReArrivalDoOmsConfirm(List<string> opArrivalNoList)
|
{
|
OperateResult oresult = new OperateResult();
|
try
|
{
|
WmsReAuditToOmsEntity ReAuditToOmsEntity = new WmsReAuditToOmsEntity();
|
// qstcF.entryOrder.
|
|
foreach (string ArrivalNo in opArrivalNoList)
|
{
|
DataTable dt = CreateDAL<TN_WM_ARRIVALDAL>().GetArrivalOmsConfirmData(ArrivalNo);
|
if (dt.Rows.Count == 0) continue;
|
List<InOrderList> inorderList = new List<InOrderList>();
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
InOrderList inorderEntity = new InOrderList()
|
{
|
purchaseOrderCode = dt.Rows[i]["CN_S_FROM_NO"].ToString(), //采购单
|
itemCode = dt.Rows[i]["CN_S_ITEM_CODE"].ToString(), //物料编码
|
rowNum = int.Parse(string.IsNullOrEmpty(dt.Rows[i]["CN_N_FROM_ROW_NO"].ToString()) ? "0" : dt.Rows[i]["CN_N_FROM_ROW_NO"].ToString()),//采购单行号
|
Nums = decimal.Parse(string.IsNullOrEmpty(dt.Rows[i]["ACTUALQTY"].ToString()) ? "0" : dt.Rows[i]["ACTUALQTY"].ToString()) //到货数量
|
};
|
inorderList.Add(inorderEntity);
|
}
|
ReAuditToOmsEntity.InOrderList = inorderList;
|
|
string postData = JsonConvert.SerializeObject(ReAuditToOmsEntity.InOrderList);
|
string resultEntity = WebApiManager.HttpOms_Post("api/PurchaseService/UpdateAccArriveNumDesc", postData);
|
if (!string.IsNullOrEmpty(resultEntity))
|
{
|
oresult.Success = false;
|
oresult.Msg = "UpdateAccArriveNumDesc接口未调通！";
|
return oresult;
|
}
|
|
QiMenInConfirmResponse qir = JsonConvert.DeserializeObject<QiMenInConfirmResponse>(resultEntity);
|
|
TN_WMS_REQ_LOGEntity ril = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = System.Guid.NewGuid().ToString().ToUpper(),
|
CN_S_INTERFACE = "ArrivalDoOmsConfirm",
|
CN_S_INTERFACE_NAME = "WMS入库确认调用OMS接口发送反审核指令",
|
CN_S_REQUEST = postData,
|
CN_S_RESPONSE = resultEntity,
|
CN_T_CREATE = DateTime.Now
|
};
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(ril);
|
|
if (qir.flag == "failure")
|
{
|
oresult.Success = false;
|
oresult.Msg = qir.message;
|
return oresult;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
oresult.Success = false;
|
oresult.Msg = ex.Message.ToString();
|
Log.Info("WMS入库确认调用OMS接口发送反审核指令报错！！！", oresult.Msg);
|
return oresult;
|
}
|
return oresult;
|
}
|
#endregion
|
|
#region WMS检验单提交调用OMS接口更新采购订单待检验数量
|
/// <summary>
|
/// WMS检验单提交调用OMS接口更新采购订单待检验数量
|
/// </summary>
|
/// <param name="InspectNoList">检验单号</param>
|
/// <returns></returns>
|
public OperateResult InspectUpdateCheckResult(List<string> InspectNoList)
|
{
|
OperateResult oresult = new OperateResult();
|
|
List<OmsCheckResultEntity> CheckResultlist = new List<OmsCheckResultEntity>();
|
try
|
{
|
foreach (string opinspectNo in InspectNoList)
|
{
|
OmsCheckResultEntity CheckResult = new OmsCheckResultEntity();
|
DataTable dt = CreateDAL<TN_WM_INSPECTDAL>().GetOmsCheckResultData(opinspectNo);
|
if (dt.Rows.Count == 0) continue;
|
if (dt.Rows[0]["CN_S_OP_TYPE"].ToString() == "退库入库") continue;//业务类型：退库入库，检验单提交时无需调用OMS
|
|
List<Inspects> inspectList = new List<Inspects>();
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
Inspects inspect = new Inspects();
|
inspect.CN_S_OP_NO = dt.Rows[i]["CN_S_FROM_NO"].ToString();
|
inspect.CN_N_ROW = dt.Rows[i]["CN_N_ROW_NO"].ToString();
|
inspect.CN_S_ITEM_CODE = dt.Rows[i]["CN_S_ITEM_CODE"].ToString();
|
inspect.CN_S_CHECK_QTY = int.Parse(decimal.Parse(dt.Rows[i]["CN_F_QUANTITY"].ToString()).ToString("0"));
|
inspect.CN_S_REGULAR_QTY = int.Parse(decimal.Parse(dt.Rows[i]["CN_F_QUALIFIED"].ToString()).ToString("0"));
|
inspect.CN_S_NREG_QTY = int.Parse(decimal.Parse(dt.Rows[i]["CN_F_UNQUALIFIED"].ToString()).ToString("0"));
|
|
inspectList.Add(inspect);
|
}
|
CheckResult.CN_S_INSPECT_NO = opinspectNo;
|
CheckResult.InspectList = inspectList;
|
|
CheckResultlist.Add(CheckResult);
|
}
|
if (CheckResultlist.Count > 0)
|
{
|
string postOmsData = JsonConvert.SerializeObject(CheckResultlist);
|
string resultEntity = WebApiManager.HttpOms_Post("api/PurchaseService/UpdateCheckResult", postOmsData);
|
if (!string.IsNullOrEmpty(resultEntity))
|
{
|
oresult.Success = false;
|
oresult.Msg = "UpdateCheckResult接口未调通！";
|
return oresult;
|
}
|
|
OmsCheckResultResponse qir = JsonConvert.DeserializeObject<OmsCheckResultResponse>(resultEntity);
|
TN_WMS_REQ_LOGEntity ril = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = System.Guid.NewGuid().ToString().ToUpper(),
|
CN_S_INTERFACE = "InspectUpdateCheckResult",
|
CN_S_INTERFACE_NAME = "WMS调用OMS更新待检验数量接口发送指令",
|
CN_S_REQUEST = postOmsData,
|
CN_S_RESPONSE = resultEntity,
|
CN_T_CREATE = DateTime.Now
|
};
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(ril);
|
|
if (qir.Success)
|
{
|
oresult.Success = false;
|
oresult.Msg = qir.ErrorMes;
|
return oresult;
|
}
|
}
|
else
|
{
|
Log.Info("WMS检验单提交调用OMS接口更新采购订单待检验数量报错！！！", "没组织到数据");
|
oresult.Success = true;
|
oresult.Msg = "没组织到数据";
|
return oresult;
|
}
|
}
|
catch (Exception ex)
|
{
|
oresult.Success = false;
|
oresult.Msg = ex.Message.ToString();
|
Log.Info("WMS检验单提交调用OMS接口更新采购订单待检验数量报错！！！", oresult.Msg);
|
return oresult;
|
}
|
return oresult;
|
}
|
#endregion
|
|
#region WMS调用OMS删除入库单发送删除指令
|
public OperateResult InspectUpdateCheckResultDesc(string opNo)
|
{
|
OperateResult oresult = new OperateResult();
|
|
//拼接调用OMS参数，删除入库单需要发送OMS指令
|
List<OmsCheckResultEntity> CheckResultlist = new List<OmsCheckResultEntity>();
|
try
|
{
|
OmsCheckResultEntity CheckResult = new OmsCheckResultEntity();
|
DataTable dtDeleteIn = CreateDAL<TN_WM_INCREASE_INVENTORYDAL>().GetDeleteInOmsModel(opNo);
|
if (dtDeleteIn.Rows.Count == 0)
|
{
|
oresult.Success = false;
|
oresult.Msg = "未获取到入库单实体！";
|
return oresult;
|
}
|
|
List<Inspects> inspectList = new List<Inspects>();
|
for (int i = 0; i < dtDeleteIn.Rows.Count; i++)
|
{
|
Inspects inspect = new Inspects();
|
inspect.CN_S_OP_NO = dtDeleteIn.Rows[0]["CN_S_FROM_NO"].ToString();
|
inspect.CN_S_ITEM_CODE = dtDeleteIn.Rows[i]["CN_S_ITEM_CODE"].ToString();
|
inspect.CN_S_CHECK_QTY = int.Parse(decimal.Parse(dtDeleteIn.Rows[i]["CN_F_QUANTITY"].ToString()).ToString("0"));
|
inspect.CN_S_REGULAR_QTY = int.Parse(decimal.Parse(dtDeleteIn.Rows[i]["CN_F_QUALIFIED"].ToString()).ToString("0"));
|
inspect.CN_S_NREG_QTY = int.Parse(decimal.Parse(dtDeleteIn.Rows[i]["CN_F_UNQUALIFIED"].ToString()).ToString("0"));
|
|
inspectList.Add(inspect);
|
}
|
CheckResult.CN_S_INSPECT_NO = dtDeleteIn.Rows[0]["CN_S_INSPECT_NO"].ToString();
|
CheckResult.InspectList = inspectList;
|
|
CheckResultlist.Add(CheckResult);
|
|
string postOmsData = JsonConvert.SerializeObject(CheckResultlist);
|
string resultEntity = WebApiManager.HttpOms_Post("api/PurchaseService/UpdateCheckResultDesc", postOmsData);
|
if (!string.IsNullOrEmpty(resultEntity))
|
{
|
oresult.Success = false;
|
oresult.Msg = "UpdateCheckResultDesc接口未调通！";
|
return oresult;
|
}
|
|
OmsCheckResultResponse qir = JsonConvert.DeserializeObject<OmsCheckResultResponse>(resultEntity);
|
TN_WMS_REQ_LOGEntity ril = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = System.Guid.NewGuid().ToString().ToUpper(),
|
CN_S_INTERFACE = "Increase-Delete",
|
CN_S_INTERFACE_NAME = "WMS调用OMS删除入库单发送删除指令",
|
CN_S_REQUEST = postOmsData,
|
CN_S_RESPONSE = resultEntity,
|
CN_T_CREATE = DateTime.Now
|
};
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(ril);
|
|
if (!qir.Success)
|
{
|
oresult.Success = false;
|
oresult.Msg = "调用删除入库单失败！";
|
return oresult;
|
}
|
}
|
catch (Exception ex)
|
{
|
oresult.Success = false;
|
oresult.Msg = ex.Message.ToString();
|
Log.Info("WMS调用OMS删除入库单发送删除指令报错！！！", oresult.Msg);
|
return oresult;
|
}
|
return oresult;
|
}
|
#endregion
|
}
|
}
|
