using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using Quartz;
namespace ICSSoft.FromERP
{
/// <summary>
/// 调拨单
/// </summary>
public class ICSTransfer : 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 Class = this.GetType().Name;
DataTable dt = ICSHelper.GetERPDB(conStr);
foreach (DataRow dr in dt.Rows)
{
string erpName = ICSHelper.GetConfigString()["ERPDB"];
string WorkPoint = dr["WorkPointCode"].ToString();
string Class = this.GetType().Name + WorkPoint;
erpName = string.Format(erpName, WorkPoint);
#region SQL
string sql = @"
SELECT A1.DocNo AS TransferNO,
CAST(A2.DocLineNo AS NVARCHAR(50)) AS Sequence,
A6.Code AS FromWarehouseCode,
--d.LocationCode as FromLocationCode,
A3.Code AS ToWarehouseCode,
'1' AS Status,
A2.ItemInfo_ItemCode AS InvCode,
A2.StoreUOMQty AS Quantity,
0 as Amount,
'1' AS Type,
A14.Memo as Memo,
A1.CreatedBy as CreatePerson,
A1.CreatedOn as CreateDateTime,
A1.ID as TransferID,
CAST(A2.ID AS NVARCHAR(50)) AS TransferDetailID,
ISNULL(A2.ModifiedOn ,A2.CreatedOn) AS MTIME,
isnull(A12.Code,'') ProjectCode,isnull(A5.LotInfo_LotCode,'') cBatch,'' version ,'' brand,
'' as cFree1,
'' as cFree2,
'' as cFree3,
'' as cFree4,
'' as cFree5,
'' as cFree6,
'' as cFree7,
'' as cFree8,
'' as cFree9,
'' as cFree10,CAST('' AS NVARCHAR(500)) as Colspan
,A13.Code as WorkPoint
INTO #TempTrans
FROM {1}.dbo.InvDoc_TransferIn A1
LEFT JOIN {1}.dbo.InvDoc_TransINLine A2 ON A2.TransferIn=A1.ID
LEFT JOIN {1}.dbo.CBO_Wh A3 ON A2.TransInWh=A3.ID
LEFT JOIN {1}.dbo.CBO_Wh_Trl A4 ON A4.ID = A3.ID AND A4.SysMLFlag='zh-CN'
LEFT JOIN {1}.dbo.InvDoc_TransINSubLine A5 ON A2.ID=A5.TransINLine
LEFT JOIN {1}.dbo.CBO_Wh A6 ON A5.TransOutWh=A6.ID
LEFT JOIN {1}.dbo.CBO_Wh_Trl A7 ON A7.ID = A6.ID AND A7.SysMLFlag='zh-CN'
LEFT JOIN {1}.dbo.Base_Organization A8 ON A1.Org=A8.ID
LEFT JOIN {1}.dbo.[CBO_Project] as A11 on (A2.[Project] = A11.[ID])
LEFT JOIN {1}.dbo.[CBO_Project] as A12 on (A5.[Project] = A12.[ID])
LEFT JOIN {1}.dbo.Base_Organization A13 ON A1.Org=A13.ID
LEFT JOIN {1}.dbo.InvDoc_TransferIn_Trl A14 ON A14.ID=A1.ID
where ISNULL(A2.ModifiedOn ,A2.CreatedOn)>=@LastTime and A1.Status=1 AND A13.Code='{0}'
update #TempTrans set Colspan=isNULL(ProjectCode,'')+'~'+isNULL(cBatch,'')+'~'+isNULL(Version,'')+'~'+isNULL(Brand,'')+'~'+isNULL(cFree1,'')+'~'+isnull(cFree2,'')+'~'+isnull(cFree3,'')+'~'+isnull(cFree4,'')+'~'+isnull(cFree5,'')+'~'+isnull(cFree6,'')+'~'+isnull(cFree7,'')+'~'+isnull(cFree8,'')+'~'+isnull(cFree9,'')+'~'+isnull(cFree10,'')
select distinct
Colspan,ProjectCode,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10,WorkPoint,cBatch,version ,brand
INTO #TempExtension
from #TempTrans
IF NOT EXISTS(SELECT * FROM #TempTrans)
RETURN";
sql = ICSHelper.Time(Namespace, Class, WorkPoint, sql, "#TempTrans");
Dictionary<string, string> value = new Dictionary<string, string>();
value.Add("ID", "NEWID()");
value.Add("BatchCode", "a.cBatch");
value.Add("version", "a.version");
value.Add("brand", "a.brand");
value.Add("ProjectCode", "a.ProjectCode");
value.Add("cFree1", "a.cFree1");
value.Add("cFree2", "a.cFree2");
value.Add("cFree3", "a.cFree3");
value.Add("cFree4", "a.cFree4");
value.Add("cFree5", "a.cFree5");
value.Add("cFree6", "a.cFree6");
value.Add("cFree7", "a.cFree7");
value.Add("cFree8", "a.cFree8");
value.Add("cFree9", "a.cFree9");
value.Add("cFree10", "a.cFree10");
value.Add("Colspan", "a.Colspan");
value.Add("MTIME", "GETDATE()");
value.Add("MUSER", "'" + ConstWorkPoint.Muser + "'");
value.Add("MUSERName", "'" + ConstWorkPoint.Musername + "'");
value.Add("WorkPoint", "'" + WorkPoint + "'");
//插入新增数据->ICSExtension表
sql += ICSHelper.InsertSQL("ICSExtension", value)
+ @"#TempExtension a
LEFT JOIN ICSExtension b ON a.ProjectCode+'~'+a.cBatch+'~'+a.Version+'~'+a.Brand+'~'+a.cFree1+'~'+a.cFree2+'~'+a.cFree3+'~'+a.cFree4+'~'+a.cFree5+'~'+a.cFree6+'~'+a.cFree7+'~'+a.cFree8+'~'+a.cFree9+'~'+a.cFree10=b.Colspan and a.WorkPoint=b.WorkPoint
WHERE b.Colspan IS NULL";
sql += @"--删除数据
-- DELETE ICSTransfer where ISNULL(TransferDetailID,'') NOT IN ( SELECT autoID FROM {1}.dbo.TransVouchs )
SELECT ISNULL(a.TransferDetailID,'') TransferDetailID INTO #tableICSTransfer
FROM ICSTransfer a With(NoLock)
LEFT JOIN {1}.dbo.[InvDoc_TransINLine] b With(NoLock) ON ISNULL(a.TransferDetailID,'')=b.ID
WHERE a.WorkPoint='{0}' and b.ID IS NULL
DELETE ICSTransfer
WHERE WorkPoint='{0}' and ISNULL(TransferDetailID,'') IN ( SELECT TransferDetailID from #tableICSTransfer)
";
sql += "\r\n";
Dictionary<string, string> values = new Dictionary<string, string>();
values.Add("TransferNO", "a.TransferNO");
values.Add("Sequence", "a.Sequence");
values.Add("FromWarehouseCode", "a.FromWarehouseCode");
//values.Add("FromLocationCode", "a.FromLocationCode");
values.Add("ToWarehouseCode", "a.ToWarehouseCode");
values.Add("Status", "a.Status");
values.Add("InvCode", "a.InvCode");
values.Add("Quantity", "a.Quantity");
values.Add("Amount", "a.Amount");
values.Add("Type", "a.Type");
values.Add("Memo", "a.Memo");
values.Add("CreateDateTime", "a.CreateDateTime");
values.Add("CreatePerson", "a.CreatePerson");
values.Add("TransferID", "a.TransferID");
values.Add("TransferDetailID", "a.TransferDetailID");
values.Add("ExtensionID", "c.ID");
values.Add("MUSER", "'" + ConstWorkPoint.Muser + "'");
values.Add("MUSERNAME", "'" + ConstWorkPoint.Musername + "'");
values.Add("WorkPoint", "'" + WorkPoint + "'");
values.Add("MTIME", "a.MTIME");
//更新存在数据
sql += "\r\n";
sql += ICSHelper.UpdateSQL("b", values)
+ @" #TempTrans a
INNER JOIN ICSTransfer b ON a.TransferDetailID=b.TransferDetailID and a.WorkPoint=b.WorkPoint
inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint
WHERE a.WorkPoint='" + WorkPoint + "' ";
values.Add("ID", "newid()");
values.Add("TransferQuantity", "0");
//values.Add("EATTRIBUTE3", "a.EATTRIBUTE3");
//插入新增数据
sql += "\r\n";
sql += ICSHelper.InsertSQL("ICSTransfer", values)
+ @" #TempTrans a
LEFT JOIN ICSTransfer b ON a.TransferDetailID=b.TransferDetailID and a.WorkPoint=b.WorkPoint
inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint
WHERE b.TransferDetailID IS NULL and a.WorkPoint='" + WorkPoint + @"' ";
sql += "DROP TABLE #TempTrans";
sql += " DROP TABLE #TempExtension " +
" DROP TABLE #tableICSTransfer";
sql = string.Format(sql, WorkPoint, erpName);
ICSHelper.ExecuteDate(conStr, sql);
#endregion
}
}
catch (Exception ex)
{
log.Error(ex.ToString());
}
}
}
}