using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using Quartz;
namespace ICSSoft.FromERP
{
/// <summary>
/// 材料出库单
/// </summary>
public class ICSOIssue : 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 IssueCode,
b.irowno as Sequence,
c.MoCode as SourceCode,
d.SortSeq as SourceSequence,
b.cInvCode as InvCode,
b.iQuantity as Quantity,
isnull(b.iNum,0) as Amount,
a.cWhCode as WHCode,
'1' as Type,
'1' as Status,
a.cMaker as CreatePerson,
a.dnmaketime as CreateDateTime,
a.id as IssueID,
b.AutoID as IssueDetailID ,
ISNULL(a.dnmodifytime, a.dnmaketime) AS MTIME,
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.iOMoMID PickID ,b.iMaIDs AppLyDetailID
INTO #TempRd
from {1}.dbo.rdrecord11 a
inner join {1}.dbo.rdrecords11 b on a.ID=b.ID
LEFT JOIN {1}.dbo.Inventory inv ON b.cInvCode = inv.cInvCode
left join {1}.dbo.mom_order c on a.iproorderid=c.MoId
left JOIN {1}.dbo.mom_orderdetail d ON c.MoId=d.MoId
where ISNULL(a.cHandler , '')='' and (a.cSource='委外订单' or a.cSource='领料申请单') and a.cBusType='委外发料' AND ISNULL(a.dnmodifytime, a.dnmaketime)>=@LastTime
update #TempRd 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 #TempRd
IF NOT EXISTS(SELECT * FROM #TempRd)
RETURN";
sql = ICSHelper.Time(Namespace, Class, WorkPoint, sql, "#TempRd");
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 ICSOIssue where ISNULL(IssueDetailID,'') NOT IN ( SELECT autoID FROM {1}.dbo.rdrecords11 )
SELECT a.IssueDetailID INTO #tableICSOIssue
FROM ICSOIssue a With(NoLock)
LEFT JOIN {1}.dbo.[rdrecords11] b With(NoLock) ON ISNULL(a.IssueDetailID,'')=b.AutoID
WHERE a.WorkPoint='{0}' and b.AutoID IS NULL
DELETE ICSOIssue
WHERE WorkPoint='{0}' and IssueDetailID IN ( SELECT IssueDetailID from #tableICSOIssue)
";
sql += "\r\n";
Dictionary<string, string> values = new Dictionary<string, string>();
values.Add("IssueCode", "a.IssueCode");
values.Add("Sequence", "a.Sequence");
values.Add("SourceCode", "a.SourceCode");
values.Add("SourceSequence", "a.SourceSequence");
values.Add("InvCode", "a.InvCode");
values.Add("Quantity", "a.Quantity");
values.Add("Amount", "a.Amount");
values.Add("WHCode", "a.WHCode");
values.Add("Type", "a.Type");
values.Add("Status", "a.Status");
values.Add("CreatePerson", "a.CreatePerson");
values.Add("CreateDateTime", "a.CreateDateTime");
values.Add("IssueID", "a.IssueID");
values.Add("IssueDetailID", "a.IssueDetailID");
values.Add("PickID", "a.PickID");
values.Add("AppLyDetailID", "a.AppLyDetailID");
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)
+ @" #TempRd a
INNER JOIN ICSOIssue b ON a.IssueDetailID=b.IssueDetailID 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("EATTRIBUTE3", "a.EATTRIBUTE3");
//插入新增数据
values.Add("ID", "newid()");
values.Add("IssueQuantity", "0");
sql += "\r\n";
sql += ICSHelper.InsertSQL("ICSOIssue", values)
+ @" #TempRd a
LEFT JOIN ICSOIssue b ON a.IssueDetailID=b.IssueDetailID and a.WorkPoint=b.WorkPoint
inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint
WHERE b.IssueDetailID IS NULL and a.WorkPoint='" + WorkPoint + @"'
";
sql += "DROP TABLE #TempRd";
sql += " DROP TABLE #TempExtension " +
" DROP TABLE #tableICSOIssue";
sql = string.Format(sql, WorkPoint, erpName);
ICSHelper.ExecuteDate(conStr, sql);
#endregion
}
}
catch (Exception ex)
{
log.Error(ex.ToString());
}
}
}
}