You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
482 lines
29 KiB
482 lines
29 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using ICSSoft.Base.Config.AppConfig;
|
|
using ICSSoft.Frame.Data.Entity;
|
|
using Quartz;
|
|
|
|
|
|
namespace ICSSoft.FromERP
|
|
{
|
|
/// <summary>
|
|
/// 委外到货(退货单)
|
|
/// </summary>
|
|
public class ICSDispatchDoc : IJob
|
|
{
|
|
private static object key = new object();
|
|
private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
|
|
public void Execute(IJobExecutionContext context)
|
|
{
|
|
try
|
|
{
|
|
lock (key)
|
|
{
|
|
log.Info("开始……………………………………………………………………");
|
|
Execute();
|
|
log.Info("结束……………………………………………………………………");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
log.Error(ex.ToString());
|
|
}
|
|
}
|
|
|
|
public void Execute()
|
|
{
|
|
try
|
|
{
|
|
string conStr = ICSHelper.GetConnectString();
|
|
string Namespace = this.GetType().Namespace;
|
|
string WHCode = ICSHelper.GetConfigString()["WHCode"];
|
|
string Date = ICSHelper.GetConfigString()["Date"];
|
|
string DocNO = ICSHelper.GetConfigString()["DocNo"];
|
|
|
|
DataTable dt = ICSHelper.GetERPDB(conStr);
|
|
using (FramDataContext db = new FramDataContext(conStr))
|
|
{
|
|
db.Connection.Open();
|
|
db.Transaction = db.Connection.BeginTransaction();
|
|
try
|
|
{
|
|
#region 销售发退货单同步
|
|
foreach (DataRow dr in dt.Rows)
|
|
{
|
|
SAPDispatchGetZS.ZWMS_SK_DO_READ client = new SAPDispatchGetZS.ZWMS_SK_DO_READ();
|
|
SAPDispatchGetZS.ZWMS_SK_DO_READ1 Info = new SAPDispatchGetZS.ZWMS_SK_DO_READ1();
|
|
if (DocNO != "")
|
|
{
|
|
Info.VBELN = DocNO;
|
|
Info.CHG_DATE = "";
|
|
}
|
|
if (Date != "")
|
|
{
|
|
Info.VBELN = "";
|
|
Info.CHG_DATE = Date;
|
|
}
|
|
if (DocNO == "" && Date == "")
|
|
{
|
|
Info.VBELN = "";
|
|
Info.CHG_DATE = DateTime.Now.Year + "-" + DateTime.Now.Month.ToString().PadLeft(2, '0') + "-" + DateTime.Now.Day.ToString().PadLeft(2, '0');
|
|
}
|
|
Info.T_HEAD = new SAPDispatchGetZS.ZWMS_DO_HEAD[1];
|
|
Info.T_ITEM = new SAPDispatchGetZS.ZWMS_DO_ITEM[1];
|
|
Info.T_GERNR = new SAPDispatchGetZS.ZWMS_DO_GERNR[1];
|
|
|
|
SAPDispatchGetZS.ZWMS_SK_DO_READResponse result = new SAPDispatchGetZS.ZWMS_SK_DO_READResponse();
|
|
client.Timeout = 300000;
|
|
result = client.CallZWMS_SK_DO_READ(Info);
|
|
List<SAPDispatchGetZS.ZWMS_DO_ITEM> ItemInfoList = new List<SAPDispatchGetZS.ZWMS_DO_ITEM>();
|
|
ItemInfoList.AddRange(result.T_ITEM);
|
|
List<SAPDispatchGetZS.ZWMS_DO_GERNR> SubLineInfoList = new List<SAPDispatchGetZS.ZWMS_DO_GERNR>();
|
|
SubLineInfoList.AddRange(result.T_GERNR);
|
|
foreach (SAPDispatchGetZS.ZWMS_DO_HEAD HeadInfo in result.T_HEAD)
|
|
{
|
|
var ItemInfo = ItemInfoList.Where(a => a.VBELN == HeadInfo.VBELN);
|
|
int LineNum = 10;
|
|
foreach (SAPDispatchGetZS.ZWMS_DO_ITEM Item in ItemInfo)
|
|
{
|
|
if (Item.SERAIL != "ZS01")
|
|
{
|
|
string ExtensionID = "";
|
|
bool isNew = false;
|
|
string Colspan = "";
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Colspan = Item.KDAUF + "~~~" + Item.KDPOS + "~~~~~~~~~~";
|
|
}
|
|
else
|
|
{
|
|
Colspan = "~~~~~~~~~~~~~";
|
|
}
|
|
var Extensionline = db.ICSExtension.SingleOrDefault(a => a.Colspan == Colspan);
|
|
if (Extensionline == null)
|
|
{
|
|
ExtensionID = AppConfig.GetGuid();
|
|
Extensionline = new ICSExtension();
|
|
Extensionline.ID = ExtensionID;
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Extensionline.BatchCode = "";
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = Item.KDPOS;
|
|
Extensionline.ProjectCode = Item.KDAUF;
|
|
}
|
|
else
|
|
{
|
|
Extensionline.BatchCode = "";
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = "";
|
|
Extensionline.ProjectCode = "";
|
|
}
|
|
Extensionline.cFree1 = "";
|
|
Extensionline.cFree2 = "";
|
|
Extensionline.cFree3 = "";
|
|
Extensionline.cFree4 = "";
|
|
Extensionline.cFree5 = "";
|
|
Extensionline.cFree6 = "";
|
|
Extensionline.cFree7 = "";
|
|
Extensionline.cFree8 = "";
|
|
Extensionline.cFree9 = "";
|
|
Extensionline.cFree10 = "";
|
|
Extensionline.Colspan = Colspan;
|
|
Extensionline.MTIME = DateTime.Now;
|
|
Extensionline.MUSER = "JOB";
|
|
Extensionline.MUSERName = "JOB";
|
|
Extensionline.WorkPoint = Item.WERKS;
|
|
|
|
db.ICSExtension.InsertOnSubmit(Extensionline);
|
|
db.SubmitChanges();
|
|
}
|
|
else
|
|
{
|
|
ExtensionID = Extensionline.ID;
|
|
}
|
|
|
|
var rcvline = db.ICSSDN.SingleOrDefault(a => a.SDNCode == Item.VBELN && a.SAPSequence == Item.POSNR && a.ExtensionID == ExtensionID && a.WorkPoint == Item.WERKS);
|
|
if (rcvline == null)
|
|
{
|
|
isNew = true;
|
|
rcvline = new Frame.Data.Entity.ICSSDN();
|
|
rcvline.ID = AppConfig.GetGuid();
|
|
rcvline.SDNQuantity = 0;
|
|
rcvline.SDNCode = Item.VBELN;//销售出/退货单（交货单）
|
|
rcvline.Sequence = LineNum.ToString();//行号
|
|
rcvline.SAPSequence = Item.POSNR;
|
|
rcvline.InvCode = Item.MATNR.TrimStart('0');//物料编码
|
|
rcvline.SOCode = Item.KDAUF;//销售订单
|
|
rcvline.SOSequence = Item.KDPOS;//销售订单行号
|
|
}
|
|
rcvline.CusCode = HeadInfo.KUNNR;//送达方
|
|
rcvline.CusName = HeadInfo.NAME1;//送达方名称
|
|
rcvline.ArriveDate = Convert.ToDateTime(HeadInfo.LFDAT);//交货日期
|
|
rcvline.WHCode = Item.LGORT;//仓库
|
|
if (HeadInfo.LFART == "LF" || HeadInfo.LFART == "ZLF" || HeadInfo.LFART == "ZYB1")
|
|
{
|
|
rcvline.Type = "1";
|
|
}
|
|
else
|
|
{
|
|
rcvline.Type = "2";
|
|
}
|
|
rcvline.Quantity = Item.LFIMG;//数量
|
|
rcvline.Amount = 0;
|
|
rcvline.CreatePerson = "JOB";
|
|
rcvline.CreateDateTime = DateTime.Now;
|
|
rcvline.Status = "1";
|
|
rcvline.ExtensionID = ExtensionID;
|
|
rcvline.MUSER = "JOB";
|
|
rcvline.MUSERName = "JOB";
|
|
rcvline.MTIME = DateTime.Now;
|
|
rcvline.WorkPoint = Item.WERKS;//站点
|
|
|
|
//新增字段
|
|
//装运点
|
|
rcvline.Points = HeadInfo.VSTEL;
|
|
//交货类型
|
|
rcvline.DeliveryType = HeadInfo.LFART;
|
|
//交货描述
|
|
rcvline.DeliveryDescribe = HeadInfo.VTEXT;
|
|
//物料描述
|
|
rcvline.InvDescribe = Item.MAKTX;
|
|
//辅助描述
|
|
rcvline.OtherDescribe = Item.DESCR;
|
|
//销售单位
|
|
rcvline.SalesUnit = Item.VRKME;
|
|
//特殊库存标识
|
|
rcvline.StockIndicator = Item.SOBKZ;
|
|
//序列号参数
|
|
rcvline.IsSerialNumber = Item.SERAIL;
|
|
|
|
|
|
|
|
if (isNew == true)
|
|
{
|
|
db.ICSSDN.InsertOnSubmit(rcvline);
|
|
}
|
|
db.SubmitChanges();
|
|
LineNum += 10;
|
|
}
|
|
else
|
|
{
|
|
var SubLineInfo = SubLineInfoList.Where(a => a.VBELN == Item.VBELN);
|
|
if (SubLineInfo.Count() == 0)
|
|
{
|
|
string ExtensionID = "";
|
|
bool isNew = false;
|
|
string Colspan = "";
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Colspan = Item.KDAUF + "~~~" + Item.KDPOS + "~~~~~~~~~~";
|
|
}
|
|
else
|
|
{
|
|
Colspan = "~~~~~~~~~~~~~";
|
|
}
|
|
var Extensionline = db.ICSExtension.SingleOrDefault(a => a.Colspan == Colspan);
|
|
if (Extensionline == null)
|
|
{
|
|
ExtensionID = AppConfig.GetGuid();
|
|
Extensionline = new ICSExtension();
|
|
Extensionline.ID = ExtensionID;
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Extensionline.BatchCode = "";
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = Item.KDPOS;
|
|
Extensionline.ProjectCode = Item.KDAUF;
|
|
}
|
|
else
|
|
{
|
|
Extensionline.BatchCode = "";
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = "";
|
|
Extensionline.ProjectCode = "";
|
|
}
|
|
Extensionline.cFree1 = "";
|
|
Extensionline.cFree2 = "";
|
|
Extensionline.cFree3 = "";
|
|
Extensionline.cFree4 = "";
|
|
Extensionline.cFree5 = "";
|
|
Extensionline.cFree6 = "";
|
|
Extensionline.cFree7 = "";
|
|
Extensionline.cFree8 = "";
|
|
Extensionline.cFree9 = "";
|
|
Extensionline.cFree10 = "";
|
|
Extensionline.Colspan = Colspan;
|
|
Extensionline.MTIME = DateTime.Now;
|
|
Extensionline.MUSER = "JOB";
|
|
Extensionline.MUSERName = "JOB";
|
|
Extensionline.WorkPoint = Item.WERKS;
|
|
|
|
db.ICSExtension.InsertOnSubmit(Extensionline);
|
|
db.SubmitChanges();
|
|
}
|
|
else
|
|
{
|
|
ExtensionID = Extensionline.ID;
|
|
}
|
|
|
|
var rcvline = db.ICSSDN.SingleOrDefault(a => a.SDNCode == Item.VBELN && a.SAPSequence == Item.POSNR && a.ExtensionID == ExtensionID && a.WorkPoint == Item.WERKS);
|
|
if (rcvline == null)
|
|
{
|
|
isNew = true;
|
|
rcvline = new Frame.Data.Entity.ICSSDN();
|
|
rcvline.ID = AppConfig.GetGuid();
|
|
rcvline.SDNQuantity = 0;
|
|
rcvline.SDNCode = Item.VBELN;//销售出/退货单（交货单）
|
|
rcvline.Sequence = LineNum.ToString();//行号
|
|
rcvline.SAPSequence = Item.POSNR;
|
|
rcvline.InvCode = Item.MATNR.TrimStart('0');//物料编码
|
|
rcvline.SOCode = Item.KDAUF;//销售订单
|
|
rcvline.SOSequence = Item.KDPOS;//销售订单行号
|
|
}
|
|
rcvline.CusCode = HeadInfo.KUNNR;//送达方
|
|
rcvline.CusName = HeadInfo.NAME1;//送达方名称
|
|
rcvline.ArriveDate = Convert.ToDateTime(HeadInfo.LFDAT);//交货日期
|
|
rcvline.WHCode = Item.LGORT;//仓库
|
|
if (HeadInfo.LFART == "LF" || HeadInfo.LFART == "ZLF" || HeadInfo.LFART == "ZYB1")
|
|
{
|
|
rcvline.Type = "1";
|
|
}
|
|
else
|
|
{
|
|
rcvline.Type = "2";
|
|
}
|
|
rcvline.Quantity = 1;//数量
|
|
rcvline.Amount = 0;
|
|
rcvline.CreatePerson = "JOB";
|
|
rcvline.CreateDateTime = DateTime.Now;
|
|
rcvline.Status = "1";
|
|
rcvline.ExtensionID = ExtensionID;
|
|
rcvline.MUSER = "JOB";
|
|
rcvline.MUSERName = "JOB";
|
|
rcvline.MTIME = DateTime.Now;
|
|
rcvline.WorkPoint = Item.WERKS;//站点
|
|
|
|
//新增字段
|
|
//装运点
|
|
rcvline.Points = HeadInfo.VSTEL;
|
|
//交货类型
|
|
rcvline.DeliveryType = HeadInfo.LFART;
|
|
//交货描述
|
|
rcvline.DeliveryDescribe = HeadInfo.VTEXT;
|
|
//物料描述
|
|
rcvline.InvDescribe = Item.MAKTX;
|
|
//辅助描述
|
|
rcvline.OtherDescribe = Item.DESCR;
|
|
//销售单位
|
|
rcvline.SalesUnit = Item.VRKME;
|
|
//特殊库存标识
|
|
rcvline.StockIndicator = Item.SOBKZ;
|
|
//序列号参数
|
|
rcvline.IsSerialNumber = Item.SERAIL;
|
|
|
|
|
|
|
|
if (isNew == true)
|
|
{
|
|
db.ICSSDN.InsertOnSubmit(rcvline);
|
|
}
|
|
db.SubmitChanges();
|
|
LineNum += 10;
|
|
}
|
|
else
|
|
{
|
|
foreach (SAPDispatchGetZS.ZWMS_DO_GERNR SubInfo in SubLineInfo)
|
|
{
|
|
string ExtensionID = "";
|
|
bool isNew = false;
|
|
string Colspan = "";
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Colspan = Item.KDAUF + "~" + SubInfo.GERNR + "~~" + Item.KDPOS + "~~~~~~~~~~";
|
|
}
|
|
else
|
|
{
|
|
Colspan = "~" + SubInfo.GERNR + "~~~~~~~~~~~~";
|
|
}
|
|
var Extensionline = db.ICSExtension.SingleOrDefault(a => a.Colspan == Colspan);
|
|
if (Extensionline == null)
|
|
{
|
|
ExtensionID = AppConfig.GetGuid();
|
|
Extensionline = new ICSExtension();
|
|
Extensionline.ID = ExtensionID;
|
|
if (Item.SOBKZ == "E")
|
|
{
|
|
Extensionline.BatchCode = SubInfo.GERNR;
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = Item.KDPOS;
|
|
Extensionline.ProjectCode = Item.KDAUF;
|
|
}
|
|
else
|
|
{
|
|
Extensionline.BatchCode = SubInfo.GERNR;
|
|
Extensionline.Version = "";
|
|
Extensionline.Brand = "";
|
|
Extensionline.ProjectCode = "";
|
|
}
|
|
Extensionline.cFree1 = "";
|
|
Extensionline.cFree2 = "";
|
|
Extensionline.cFree3 = "";
|
|
Extensionline.cFree4 = "";
|
|
Extensionline.cFree5 = "";
|
|
Extensionline.cFree6 = "";
|
|
Extensionline.cFree7 = "";
|
|
Extensionline.cFree8 = "";
|
|
Extensionline.cFree9 = "";
|
|
Extensionline.cFree10 = "";
|
|
Extensionline.Colspan = Colspan;
|
|
Extensionline.MTIME = DateTime.Now;
|
|
Extensionline.MUSER = "JOB";
|
|
Extensionline.MUSERName = "JOB";
|
|
Extensionline.WorkPoint = Item.WERKS;
|
|
|
|
db.ICSExtension.InsertOnSubmit(Extensionline);
|
|
db.SubmitChanges();
|
|
}
|
|
else
|
|
{
|
|
ExtensionID = Extensionline.ID;
|
|
}
|
|
|
|
var rcvline = db.ICSSDN.SingleOrDefault(a => a.SDNCode == Item.VBELN && a.SAPSequence == Item.POSNR && a.ExtensionID == ExtensionID && a.WorkPoint == Item.WERKS);
|
|
if (rcvline == null)
|
|
{
|
|
isNew = true;
|
|
rcvline = new Frame.Data.Entity.ICSSDN();
|
|
rcvline.ID = AppConfig.GetGuid();
|
|
rcvline.SDNQuantity = 0;
|
|
rcvline.SDNCode = Item.VBELN;//销售出/退货单（交货单）
|
|
rcvline.Sequence = LineNum.ToString();//行号
|
|
rcvline.SAPSequence = Item.POSNR;
|
|
rcvline.InvCode = Item.MATNR.TrimStart('0');//物料编码
|
|
rcvline.SOCode = Item.KDAUF;//销售订单
|
|
rcvline.SOSequence = Item.KDPOS;//销售订单行号
|
|
}
|
|
rcvline.CusCode = HeadInfo.KUNNR;//送达方
|
|
rcvline.CusName = HeadInfo.NAME1;//送达方名称
|
|
rcvline.ArriveDate = Convert.ToDateTime(HeadInfo.LFDAT);//交货日期
|
|
rcvline.WHCode = Item.LGORT;//仓库
|
|
if (HeadInfo.LFART == "LF" || HeadInfo.LFART == "ZLF" || HeadInfo.LFART == "ZYB1")
|
|
{
|
|
rcvline.Type = "1";
|
|
}
|
|
else
|
|
{
|
|
rcvline.Type = "2";
|
|
}
|
|
rcvline.Quantity = 1;//数量
|
|
rcvline.Amount = 0;
|
|
rcvline.CreatePerson = "JOB";
|
|
rcvline.CreateDateTime = DateTime.Now;
|
|
rcvline.Status = "1";
|
|
rcvline.ExtensionID = ExtensionID;
|
|
rcvline.MUSER = "JOB";
|
|
rcvline.MUSERName = "JOB";
|
|
rcvline.MTIME = DateTime.Now;
|
|
rcvline.WorkPoint = Item.WERKS;//站点
|
|
|
|
//新增字段
|
|
//装运点
|
|
rcvline.Points = HeadInfo.VSTEL;
|
|
//交货类型
|
|
rcvline.DeliveryType = HeadInfo.LFART;
|
|
//交货描述
|
|
rcvline.DeliveryDescribe = HeadInfo.VTEXT;
|
|
//物料描述
|
|
rcvline.InvDescribe = Item.MAKTX;
|
|
//辅助描述
|
|
rcvline.OtherDescribe = Item.DESCR;
|
|
//销售单位
|
|
rcvline.SalesUnit = Item.VRKME;
|
|
//特殊库存标识
|
|
rcvline.StockIndicator = Item.SOBKZ;
|
|
//序列号参数
|
|
rcvline.IsSerialNumber = Item.SERAIL;
|
|
|
|
|
|
|
|
if (isNew == true)
|
|
{
|
|
db.ICSSDN.InsertOnSubmit(rcvline);
|
|
}
|
|
db.SubmitChanges();
|
|
LineNum += 10;
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
db.Transaction.Commit();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
db.Transaction.Rollback();
|
|
log.Error(ex.ToString());
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
log.Error(ex.ToString());
|
|
}
|
|
}
|
|
}
|
|
}
|