using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using Quartz;
namespace ICSSoft.FromERP
{
///
/// 委外到货(退货单)
///
public class ICSODeliveryNotice : 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 a.cCode as ODNCode,
b.ivouchrowno as Sequence,
a.cVenCode as VenCode ,
cDepCode as DepCode ,
CASE WHEN b.iQuantity>=0 THEN '1' ELSE '2' END AS ODNType,
b.cInvCode as InvCode,
b.iQuantity as Quantity ,
isnull(b.iNum,0) as Amount,
a.cexch_name as Currency,
b.iCost as UnitPrice,
a.cMaker as CreatePerson,
a.cMakeTime as CreateDateTime,
a.iverifystateex as Status,
a.cMakeTime as MTIME,
a.ID as ODNID,
isnull(c.MOID,'') as OOID,
isnull(b.iPOsID,'') as OODetailID,
cast( b.AutoID AS VARCHAR) as ODNDetailID,
isnull(b.cItemCode,'') ProjectCode,isnull(b.cbatch,'') cBatch,'' version ,'' brand,
(case WHEN inv.bFree1=1 THEN b.cFree1 ELSE '' END) as cFree1,
(case WHEN inv.bFree2=1 THEN b.cFree2 ELSE '' END) as cFree2,
(case WHEN inv.bFree3=1 THEN b.cFree3 ELSE '' END) as cFree3,
(case WHEN inv.bFree4=1 THEN b.cFree4 ELSE '' END) as cFree4,
(case WHEN inv.bFree5=1 THEN b.cFree5 ELSE '' END) as cFree5,
(case WHEN inv.bFree6=1 THEN b.cFree6 ELSE '' END) as cFree6,
(case WHEN inv.bFree7=1 THEN b.cFree7 ELSE '' END) as cFree7,
(case WHEN inv.bFree8=1 THEN b.cFree8 ELSE '' END) as cFree8,
(case WHEN inv.bFree9=1 THEN b.cFree9 ELSE '' END) as cFree9,
(case WHEN inv.bFree10=1 THEN b.cFree10 ELSE '' END) as cFree10,CAST('' AS NVARCHAR(500)) as Colspan,
'{0}' as WorkPoint,
b.cWhCode as WHCode
INTO #ICSSODelive
from {1}.DBO.PU_ArrivalVouch a
inner join {1}.DBO.PU_ArrivalVouchs b on a.ID =b.ID
left join {1}.DBO.OM_MODetails c on b.iPOsID=c.MODetailsID
LEFT JOIN {1}.dbo.Inventory inv ON b.cInvCode = inv.cInvCode
where a.cBusType in('委外加工') and a.iBillType <>2 and
ISNULL (a.cverifier ,'') <> ''and ISNULL(a.cAuditTime, ISNULL(a.cModifyTime, a.cmaketime))>=@LastTime
update #ICSSODelive 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 #ICSSODelive
IF NOT EXISTS(SELECT * FROM #ICSSODelive)
RETURN";
sql = ICSHelper.Time(Namespace, Class, WorkPoint, sql, "#ICSSODelive");
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 ICSODeliveryNotice WHERE ODNDetailID NOT IN ( SELECT AutoID FROM {1}.dbo.PU_ArrivalVouchs) and OASNCode IS NULL
SELECT a.ODNDetailID INTO #tableICSODeliveryNotice
FROM ICSODeliveryNotice a With(NoLock)
LEFT JOIN {1}.dbo.[PU_ArrivalVouchs] b With(NoLock) ON a.ODNDetailID=b.AutoID
WHERE a.WorkPoint='{0}' and b.AutoID IS NULL and a.OASNCode IS NULL
DELETE ICSODeliveryNotice
WHERE WorkPoint='{0}' and ODNDetailID IN ( SELECT ODNDetailID from #tableICSODeliveryNotice)
";
Dictionary values = new Dictionary();
values.Add("ODNCode", "a.ODNCode");
values.Add("Sequence", "a.Sequence");
values.Add("VenCode", "a.VenCode");
values.Add("DepCode", "a.DepCode");
values.Add("ODNType", "a.ODNType");
values.Add("InvCode", "a.InvCode");
values.Add("Quantity", "abs(a.Quantity)");
values.Add("WHCode", "a.WHCode");
values.Add("UnitPrice", "a.UnitPrice ");
values.Add("Currency", "a.Currency");
values.Add("Status", "a.Status");
values.Add("CreatePerson", "a.CreatePerson");
values.Add("CreateDateTime", "a.CreateDateTime");
values.Add("OOID", "a.OOID");
values.Add("OODetailID", "a.OODetailID");
values.Add("ODNDetailID", "a.ODNDetailID");
values.Add("ODNID", "a.ODNID");
values.Add("ExtensionID", "c.ID");
values.Add("EATTRIBUTE1", "''");
//更新存在数据
sql += ICSHelper.UpdateSQL("ICSODeliveryNotice", values)
+ @" #ICSSODelive a
INNER JOIN ICSODeliveryNotice b ON a.ODNDetailID=b.ODNDetailID 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("MUSER", "'" + ConstWorkPoint.Muser + "'");
values.Add("MUSERName", "'" + ConstWorkPoint.Musername + "'");
values.Add("WorkPoint", "'" + WorkPoint + "'");
values.Add("MTIME", "a.MTIME");
values.Add("ID", "NEWID()");
values.Add("RCVQuantity", "0");
//values.Add("ErpAutoID", "a.ErpAutoID");
//values.Add("ErpID", "a.ErpID");
//values.Add("iFQuantity", "a.iFQuantity");
//插入新增数据
sql += ICSHelper.InsertSQL("ICSODeliveryNotice", values)
+ @" #ICSSODelive a
LEFT JOIN ICSODeliveryNotice b ON a.ODNDetailID=b.ODNDetailID and a.WorkPoint=b.WorkPoint
inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint
WHERE b.ODNDetailID IS NULL and a.WorkPoint='" + WorkPoint + @"'
";
sql += "DROP TABLE #ICSSODelive";
sql += " DROP TABLE #TempExtension " +
" DROP TABLE #tableICSODeliveryNotice";
sql = string.Format(sql, WorkPoint, erpName);
ICSHelper.ExecuteDate(conStr, sql);
#endregion
}
}
catch (Exception ex)
{
log.Error(ex.ToString());
}
}
}
}