using iWareSAP.IDOC.Entity;
|
using iWareSAP.Properties;
|
using SAP.Middleware.Connector;
|
using System;
|
using System.Linq;
|
using System.Collections.Generic;
|
using UtilDll.UTIL;
|
|
namespace iWareSAP.CLIENT.Entity
|
{
|
public class SapncoClient
|
{
|
private RfcDestination _rfcDestination = null;
|
private string _logDir;
|
|
public SapncoClient()
|
{
|
_logDir = Resources.LogDir + @"\ATOIS";
|
|
}
|
|
/// <summary>
|
/// Register Client
|
/// </summary>
|
public void RegisterRfcDestination()
|
{
|
try
|
{
|
|
if (_rfcDestination == null)
|
{
|
_rfcDestination = RfcDestinationManager.GetDestination("NCO_Destination");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "RegisterRfcDestination", ex.Message);
|
}
|
}
|
|
|
/// <summary>
|
/// 调用时间
|
/// </summary>
|
/// <param name="dateStr"></param>
|
/// <returns></returns>
|
public string InvokeRFCFunctionGetDate(string dateStr)
|
{
|
string date = string.Empty;
|
try
|
{
|
IRfcFunction function = this._rfcDestination.Repository.CreateFunction("DATE_GET_WEEK");
|
function.SetParameterActive(0, true);
|
function.SetValue("DATE", dateStr);
|
function.Invoke(this._rfcDestination);
|
date = function.GetValue("DATE").ToString();
|
}
|
catch (RfcBaseException ex)
|
{
|
throw ex;
|
}
|
return date;
|
}
|
|
|
/// <summary>
|
/// 调用Sap函数BAPI_PO_GETDETAIL1
|
/// (非IDOC)
|
/// </summary>
|
/// <param name="orderCode"></param>
|
/// <returns></returns>
|
public PurchaseOrder InvokeRFCFunctionGetPoDetail(string poNumber, out string msg)
|
{
|
try
|
{
|
msg = "";
|
LogTextHelper.WriteLine(_logDir, "调用方法{0}，poNumber={1}", "InvokeRFCFunctionGetPoDetail", poNumber);
|
var function = _rfcDestination.Repository.CreateFunction("BAPI_PO_GETDETAIL");
|
|
|
|
function.SetParameterActive(0, true);
|
function.SetValue("PURCHASEORDER", poNumber);
|
function.SetValue("ACCOUNT_ASSIGNMENT", "X");
|
|
function.Invoke(_rfcDestination);
|
var header = function.GetStructure("PO_HEADER");
|
var purchaseOrder = new PurchaseOrder(header);
|
if (string.IsNullOrEmpty(purchaseOrder.PO_NUMBER))
|
{
|
msg = string.Format("未找到采购单{0}", poNumber);
|
LogTextHelper.WriteLine(_logDir, "msg={0}", msg);
|
return null;
|
}
|
var details = function.GetTable("PO_ITEMS");
|
|
foreach (IRfcStructure detail in details)
|
{
|
purchaseOrder.Materials.Add(new PurchaseOrderMaterial(detail));
|
}
|
|
var assignments = function.GetTable("PO_ITEM_ACCOUNT_ASSIGNMENT");
|
|
var flag = false;
|
foreach (IRfcStructure assignment in assignments)
|
{
|
if (!flag)
|
{
|
purchaseOrder.SD_DOC = assignment.GetValue("SD_DOC") == null ? "" : assignment.GetValue("SD_DOC").ToString();
|
purchaseOrder.SDOC_ITEM = assignment.GetValue("SDOC_ITEM") == null ? "" : assignment.GetValue("SDOC_ITEM").ToString();
|
flag = true;
|
}
|
|
var poItem = assignment.GetValue("PO_ITEM") == null ? "" : assignment.GetValue("PO_ITEM").ToString();
|
var m = purchaseOrder.Materials.FirstOrDefault(x => x.PO_ITEM == poItem);
|
if (m != null)
|
{
|
m.SD_DOC = assignment.GetValue("SD_DOC") == null ? "" : assignment.GetValue("SD_DOC").ToString();
|
m.SDOC_ITEM = assignment.GetValue("SDOC_ITEM") == null ? "" : assignment.GetValue("SDOC_ITEM").ToString();
|
}
|
}
|
LogTextHelper.WriteLine(_logDir, "purchaseOrder={0}", purchaseOrder);
|
return purchaseOrder;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "InvokeRFCFunctionGetPoDetail", ex.Message);
|
return null;
|
}
|
}
|
|
|
/// <summary>
|
/// 发送收货确认
|
/// </summary>
|
/// <returns></returns>
|
public string InvokeRFCFunctionPoGR(List<GRMaterial> grMaterials, out string msg)
|
{
|
try
|
{
|
msg = "";
|
|
|
if (grMaterials.Count <= 0)
|
{
|
msg = "确认物料数量不能为0";
|
return "";
|
}
|
var function = _rfcDestination.Repository.CreateFunction("/SIE/CHN_MM_WMS_PO_GR");
|
|
function.SetParameterActive(0, true);
|
function.SetParameterActive(1, true);
|
function.SetValue("I_BUDAT", DateTime.Now.ToString("yyyyMMdd"));
|
var items = function.GetTable("LT_GOODSMVT_ITEM");
|
|
grMaterials.ForEach(x =>
|
{
|
items.Append();
|
items.CurrentRow.SetValue("EBELN", x.EBELN);//采购单号
|
items.CurrentRow.SetValue("EBELP", x.EBELP);//行号
|
items.CurrentRow.SetValue("MATNR", x.MATNR);//物料号
|
items.CurrentRow.SetValue("BWART", x.BWART);//移动类型
|
items.CurrentRow.SetValue("WERKS", x.WERKS);//工厂
|
items.CurrentRow.SetValue("LGORT", x.LGORT);//存储位置
|
items.CurrentRow.SetValue("MENGE", x.MENGE);//数量
|
});
|
|
var grStr = "";
|
grMaterials.ForEach(x => grStr += x.ToString() + "\r\n");
|
LogTextHelper.WriteLine(_logDir, "调用方法{0}，grMaterials={1}", "InvokeRFCFunctionPoGR", grStr);
|
function.Invoke(_rfcDestination);
|
var materialDoc = function.GetValue("MATERIALDOCUMENT").ToString();
|
|
var etReturns = function.GetTable("ET_RETURN");
|
foreach (IRfcStructure etReturn in etReturns)
|
{
|
var message = etReturn.GetValue("MESSAGE") == null ? "" : etReturn.GetValue("MESSAGE").ToString();
|
msg = message == "Success" || message == "Successfully" ? "" : message;
|
break;
|
}
|
|
if (string.IsNullOrEmpty(materialDoc))
|
{
|
LogTextHelper.WriteLine(_logDir, "msg={0}", msg);
|
}
|
else
|
{
|
LogTextHelper.WriteLine(_logDir, "materialDoc={0}", materialDoc);
|
}
|
return materialDoc;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "InvokeRFCFunctionPoGR", ex.Message);
|
return "";
|
}
|
}
|
|
/// <summary>
|
/// 发送出库确认
|
/// </summary>
|
/// <returns></returns>
|
public string InvokeRFCFunctionWmsGI(List<GIMaterial> giMaterials, out string msg)
|
{
|
try
|
{
|
msg = "";
|
|
var function = _rfcDestination.Repository.CreateFunction("/SIE/CHN_MM_WMS_GI");
|
|
function.SetParameterActive(0, true);
|
function.SetParameterActive(1, true);
|
var items = function.GetTable("T_MSEG");
|
giMaterials.ForEach(x =>
|
{
|
if (x.BWART.EndsWith("E"))
|
{
|
x.SOBKZ = "E";
|
x.BWART = x.BWART.Substring(0, x.BWART.Length - 1);
|
}
|
else if (x.BWART.EndsWith("K"))
|
{
|
x.SOBKZ = "K";
|
x.BWART = x.BWART.Substring(0, x.BWART.Length - 1);
|
|
}
|
else
|
{
|
x.SOBKZ = "";
|
}
|
|
items.Append();
|
items.CurrentRow.SetValue("BWART", x.BWART);//移动类型
|
items.CurrentRow.SetValue("MATNR", x.MATNR);//物料号
|
items.CurrentRow.SetValue("WERKS", x.WERKS);//工厂
|
items.CurrentRow.SetValue("LGORT", x.LGORT);//存储位置
|
items.CurrentRow.SetValue("SOBKZ", x.SOBKZ);//特殊类型
|
items.CurrentRow.SetValue("LIFNR", x.LIFNR);//供应商
|
items.CurrentRow.SetValue("KDAUF", x.KDAUF);//销售订单
|
items.CurrentRow.SetValue("KDPOS", x.KDPOS);//销售订单项
|
items.CurrentRow.SetValue("ERFMG", x.ERFMG);//数量
|
items.CurrentRow.SetValue("ERFME", x.ERFME);//单位
|
items.CurrentRow.SetValue("CHARG", x.CHARG);//工作台
|
items.CurrentRow.SetValue("SERNR", x.SERNR);//序列号
|
items.CurrentRow.SetValue("AUFNR", x.AUFNR);//生产订单
|
items.CurrentRow.SetValue("KZEAR", x.KZEAR);//最终标识
|
items.CurrentRow.SetValue("RSNUM", x.RSNUM);//保留数
|
items.CurrentRow.SetValue("RSPOS", x.RSPOS);//保留项
|
items.CurrentRow.SetValue("BWTAR", x.BWTAR);//验证类型
|
});
|
|
var giStr = "";
|
giMaterials.ForEach(x => giStr += x.ToString() + "\r\n");
|
LogTextHelper.WriteLine(_logDir, "调用方法{0},giMaterials={1}", "InvokeRFCFunctionWmsGI", giStr);
|
function.Invoke(_rfcDestination);
|
|
var materialDoc = function.GetValue("MBLNR").ToString();
|
var res = function.GetValue("MJAHR").ToString();
|
|
var etReturns = function.GetTable("RETURN");
|
|
foreach (IRfcStructure etReturn in etReturns)
|
{
|
var message = etReturn.GetValue("MESSAGE") == null ? "" : etReturn.GetValue("MESSAGE").ToString();
|
msg = message == "Success" || message == "Successfully" ? "" : message;
|
break;
|
}
|
|
if (string.IsNullOrEmpty(materialDoc))
|
{
|
|
LogTextHelper.WriteLine(_logDir, "msg={0}", msg);
|
}
|
else
|
{
|
LogTextHelper.WriteLine(_logDir, "materialDoc={0}, res={1}", materialDoc, res);
|
}
|
|
return materialDoc;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "InvokeRFCFunctionWmsGI", ex.Message);
|
return "";
|
}
|
}
|
|
/// <summary>
|
/// 发送出库确认
|
/// </summary>
|
/// <returns></returns>
|
public string InvokeRFCFunctionWmsStkMov(List<MovMaterial> movMaterials, out string msg)
|
{
|
try
|
{
|
msg = "";
|
|
var function = _rfcDestination.Repository.CreateFunction("/SIE/CHN_MM_WMS_STKMOV");
|
|
function.SetParameterActive(0, true);
|
function.SetParameterActive(1, true);
|
var items = function.GetTable("T_MSEG");
|
|
movMaterials.ForEach(x =>
|
{
|
if (x.BWART.EndsWith("E"))
|
{
|
x.SOBKZ = "E";
|
x.BWART = x.BWART.Substring(0, x.BWART.Length - 1);
|
}
|
else if (x.BWART.EndsWith("K"))
|
{
|
x.SOBKZ = "K";
|
x.BWART = x.BWART.Substring(0, x.BWART.Length - 1);
|
}
|
else
|
{
|
x.SOBKZ = "";
|
}
|
|
items.Append();
|
items.CurrentRow.SetValue("BWART", x.BWART);//移动类型
|
items.CurrentRow.SetValue("MATNR", x.MATNR);//物料号
|
items.CurrentRow.SetValue("WERKS", x.WERKS);//工厂
|
items.CurrentRow.SetValue("LGORT", x.LGORT);//转出库位
|
items.CurrentRow.SetValue("SOBKZ", x.SOBKZ);//特殊类型
|
items.CurrentRow.SetValue("LIFNR", x.LIFNR);//供应商
|
items.CurrentRow.SetValue("KDAUF", x.KDAUF);//销售订单
|
items.CurrentRow.SetValue("KDPOS", x.KDPOS);//销售订单项
|
items.CurrentRow.SetValue("ERFMG", x.ERFMG);//数量
|
items.CurrentRow.SetValue("ERFME", x.ERFME);//单位
|
items.CurrentRow.SetValue("CHARG", x.CHARG);//批次
|
items.CurrentRow.SetValue("SERNR", x.SERNR);//序列号
|
items.CurrentRow.SetValue("UMLGO", x.UMLGO);//转入库位
|
items.CurrentRow.SetValue("BWTAR", x.BWTAR);//验证类型
|
});
|
|
var movStr = "";
|
movMaterials.ForEach(x => movStr += x.ToString() + "\r\n");
|
LogTextHelper.WriteLine(_logDir, "调用方法{0}，movMaterials={1}", "InvokeRFCFunctionWmsStkMov", movStr);
|
|
function.Invoke(_rfcDestination);
|
var materialDoc = function.GetValue("MBLNR").ToString();
|
var res = function.GetValue("MJAHR").ToString();
|
|
var etReturns = function.GetTable("RETURN");
|
|
foreach (IRfcStructure etReturn in etReturns)
|
{
|
var message = etReturn.GetValue("MESSAGE") == null ? "" : etReturn.GetValue("MESSAGE").ToString();
|
msg = message == "Success" || message == "Successfully" ? "" : message;
|
break;
|
}
|
|
if (string.IsNullOrEmpty(materialDoc))
|
{
|
LogTextHelper.WriteLine(_logDir, "msg={0}", msg);
|
}
|
else
|
{
|
LogTextHelper.WriteLine(_logDir, "materialDoc={0}, res={1}", materialDoc, res);
|
}
|
|
return materialDoc;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "InvokeRFCFunctionWmsStkMov", ex.Message);
|
return "";
|
}
|
}
|
|
/// <summary>
|
/// 调用Sap函数/SIE/CHN_MM_WMS_REVERSEGR
|
/// (非IDOC)
|
/// </summary>
|
/// <param name="doc">物料凭证</param>
|
/// <returns></returns>
|
public string InvokeRFCFunctionWmsReverser(string doc, out string msg)
|
{
|
try
|
{
|
msg = "";
|
LogTextHelper.WriteLine(_logDir, "调用方法{0}，doc={1}", "InvokeRFCFunctionWmsReverser", doc);
|
var function = _rfcDestination.Repository.CreateFunction("/SIE/CHN_MM_WMS_REVERSEGR");
|
function.SetParameterActive(0, true);
|
function.SetValue("MAT_DOC_NUMBER", doc);
|
|
function.Invoke(_rfcDestination);
|
|
var etReturns = function.GetTable("ET_RETURN");
|
|
foreach (IRfcStructure etReturn in etReturns)
|
{
|
|
var message = etReturn.GetValue("POSTING_RESULT") == null ? "" : etReturn.GetValue("POSTING_RESULT").ToString();
|
msg = message.ToLower().Contains("success") ? "" : message;
|
break;
|
}
|
|
var res = string.IsNullOrEmpty(msg) ? "Success" : "Failure";
|
LogTextHelper.WriteLine(_logDir, "res={0},msg={1}", res, msg);
|
|
return res;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "InvokeRFCFunctionGetPoDetail", ex.Message);
|
return null;
|
}
|
}
|
}
|
}
|
