using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using Quartz;
namespace ICSSoft.FromERP
{
///
/// 销售发货退货单
///
public class ICSSoDispatch : 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 b.cDLCode AS SDNCode,
CAST(a.irowno AS NVARCHAR(50)) AS Sequence,
ISNULL(d.cSoCode,'') AS SOCode,
CAST(ISNULL(d.iRowNo,'') AS NVARCHAR(50)) AS SOSequence,
b.cCusCode AS CusCode,
b.cCusName AS CusName,
CASE WHEN a.iQuantity>=0 THEN '1' ELSE '2' END AS Type,
a.cInvCode AS InvCode,
a.cWhCode AS WHCode,
CASE WHEN a.iQuantity>=0 THEN a.iQuantity ELSE -a.iQuantity END AS Quantity,
isnull(a.iNum,0) as Amount,
b.cMaker AS CreatePerson,
b.dcreatesystime as CreateDateTime,
CASE WHEN ISNULL(b.cVerifier, '')='' THEN '1' ELSE '2' END AS Status,
CAST(b.DLID AS NVARCHAR(50)) AS SDNID,
CAST(a.AutoID AS NVARCHAR(50)) AS SDNDetailID,
ISNULL(b.dverifysystime,ISNULL(b.dmodifysystime, b.dcreatesystime)) AS MTIME,
ISNULL(b.dverifysystime,ISNULL(b.dmodifysystime, b.dcreatesystime)) AS ArriveDate,
isnull(a.cItemCode,'') ProjectCode,isnull(a.cbatch,'') cBatch, '' version ,'' brand,
(case WHEN inv.bFree1=1 THEN isnull(a.cFree1,'') ELSE '' END) as cFree1,
(case WHEN inv.bFree2=1 THEN isnull(a.cFree2,'') ELSE '' END) as cFree2,
(case WHEN inv.bFree3=1 THEN isnull(a.cFree3,'') ELSE '' END) as cFree3,
(case WHEN inv.bFree4=1 THEN isnull(a.cFree4,'') ELSE '' END) as cFree4,
(case WHEN inv.bFree5=1 THEN isnull(a.cFree5,'') ELSE '' END) as cFree5,
(case WHEN inv.bFree6=1 THEN isnull(a.cFree6,'') ELSE '' END) as cFree6,
(case WHEN inv.bFree7=1 THEN isnull(a.cFree7,'') ELSE '' END) as cFree7,
(case WHEN inv.bFree8=1 THEN isnull(a.cFree8,'') ELSE '' END) as cFree8,
(case WHEN inv.bFree9=1 THEN isnull(a.cFree9,'') ELSE '' END) as cFree9,
(case WHEN inv.bFree10=1 THEN isnull(a.cFree10,'') ELSE '' END) as cFree10,CAST('' AS NVARCHAR(500)) as Colspan,
(case WHEN inv.bService=1 THEN '1' ELSE '0' END) as EATTRIBUTE1
, '{0}' as WorkPoint
INTO #TempSO
FROM {1}.dbo.DispatchLists a
INNER JOIN {1}.dbo.DispatchList b ON a.DLID = b.DLID
LEFT JOIN {1}.dbo.Inventory inv ON a.cInvCode = inv.cInvCode
LEFT JOIN {1}.dbo.Inventory c ON a.cInvCode = c.cInvCode
LEFT JOIN {1}.dbo.SO_SODetails d ON a.iSOsID = d.iSOsID
LEFT JOIN {1}.dbo.ComputationUnit e ON c.cComUnitCode = e.cComunitCode
WHERE ISNULL(b.cVerifier, '')!='' AND ISNULL(b.cCloser, '')='' AND ISNULL(b.dverifysystime,ISNULL(b.dmodifysystime, b.dcreatesystime))>=@LastTime
update #TempSO 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 #TempSO
IF NOT EXISTS(SELECT * FROM #TempSO)
RETURN";
sql = ICSHelper.Time(Namespace, Class, WorkPoint, sql, "#TempSO");
Dictionary value = new Dictionary();
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 ICSSDN WHERE SDNDetailID NOT IN (SELECT CAST(AutoID as VARCHAR) FROM {1}.dbo.DispatchLists)
SELECT a.SDNDetailID INTO #tableICSSDN
FROM ICSSDN a With(NoLock)
LEFT JOIN {1}.dbo.[DispatchLists] b With(NoLock) ON a.SDNDetailID=CAST(b.AutoID as VARCHAR)
WHERE a.WorkPoint='{0}' and b.AutoID IS NULL
DELETE ICSSDN
WHERE WorkPoint='{0}' and SDNDetailID IN ( SELECT SDNDetailID from #tableICSSDN)
";
Dictionary values = new Dictionary();
values.Add("SDNCode", "a.SDNCode");
values.Add("Sequence", "a.Sequence");
values.Add("SOCode", "a.SOCode");
values.Add("SOSequence", "a.SOSequence");
values.Add("CusCode", "a.CusCode");
values.Add("CusName", "a.CusName");
values.Add("Type", "a.Type");
values.Add("InvCode", "a.InvCode");
values.Add("WHCode", "a.WHCode");
values.Add("ArriveDate", "a.ArriveDate");
values.Add("Quantity", "a.Quantity");
values.Add("EATTRIBUTE1", "a.EATTRIBUTE1");
values.Add("Amount", "a.Amount");
values.Add("CreatePerson", "a.CreatePerson");
values.Add("CreateDateTime", "a.CreateDateTime");
values.Add("Status", "a.Status");
values.Add("SDNID", "a.SDNID");
values.Add("ExtensionID", "c.ID");
values.Add("SDNDetailID", "a.SDNDetailID");
//更新存在数据
sql += ICSHelper.UpdateSQL("ICSSDN", values)
+ @" #TempSO a
INNER JOIN ICSSDN b ON a.SDNDetailID=b.SDNDetailID 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("MTIME", "a.MTIME");
values.Add("ID", "NEWID()");
values.Add("SDNQuantity", "0");
values.Add("MUSER", "'" + ConstWorkPoint.Muser + "'");
values.Add("MUSERNAME", "'" + ConstWorkPoint.Musername + "'");
values.Add("WorkPoint", "'" + WorkPoint + "'");
//插入新增数据
sql += ICSHelper.InsertSQL("ICSSDN", values)
+ @" #TempSO a
LEFT JOIN ICSSDN b ON a.SDNDetailID=b.SDNDetailID and a.WorkPoint=b.WorkPoint
inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint
WHERE b.SDNDetailID IS NULL and a.WorkPoint='" + WorkPoint + @"'
";
sql += " DROP TABLE #TempSO";
sql += " DROP TABLE #TempExtension" +
" DROP TABLE #tableICSSDN";
sql = string.Format(sql, WorkPoint, erpName);
ICSHelper.ExecuteDate(conStr, sql);
#endregion
}
}
catch (Exception ex)
{
log.Error(ex.ToString());
}
}
}
}