using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Text; using Quartz; namespace ICSSoft.FromERP { /// /// 红字采购入库单 /// public class ICSPurchaseReceive : 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 CAST(A2.ID AS NVARCHAR(50)) AS ERPAutoid, A1.Code AS RCVCode, CAST(A2.DocLineNo AS NVARCHAR(50)) AS Sequence, A2.SrcDoc_SrcDocNo as SourceCode, CAST(A2.SrcDoc_SrcDocLineNo AS NVARCHAR(50)) as SourceSequence, A2.ItemInfo_ItemCode AS InvCode, Case When A2.SplitFlag=2 Then (SELECT ArriveQtyCU FROM {0}.dbo.PM_RcvLine WHERE Receivement=A1.ID AND DocLineNo=A2.DocLineNo AND SplitFlag=1) ELSE A2.ArriveQtyCU END AS Quantity, 0 as Amount, 0 as RCVQuantity, A5.Code AS AS WhCode, '1' as Status, A1.CreatedBy as CreatePerson, A2.CreatedOn as CreateDateTime, A1.ID as RCVID, CAST(A2.ID AS NVARCHAR(50)) as RCVDetailID, ISNULL(A2.ModifiedOn ,A2.CreatedOn) AS MTIME, isnull(A7.Code,'') ProjectCode,isnull(A2.InvLotCode,'') 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, A6.Code as WorkPoint INTO #TempPOArrive FROM {1}.dbo.PM_Receivement A1 LEFT JOIN {1}.dbo.PM_RcvLine A2 ON A2.Receivement=A1.ID LEFT JOIN {1}.dbo.CBO_Department A3 ON A2.RcvDept=A3.ID LEFT JOIN {1}.dbo.CBO_Department_Trl A4 ON A4.ID = A3.ID AND A4.SysMLFlag='zh-CN' LEFT JOIN {1}.dbo.CBO_Wh A5 ON A2.Wh=A5.ID LEFT JOIN {1}.dbo.Base_Organization A6 ON A1.Org=A6.ID LEFT JOIN {1}.dbo.CBO_Project A7 ON A7.ID=A2.Project LEFT JOIN {1}.dbo.PM_RcvDocType A8 ON A1.RcvDocType=A8.ID WHERE A1.ReceivementType='0' AND A2.Status='3' AND (A2.QCQCConclusion=-1 OR A2.QCQCConclusion=0 OR A2.QCQCConclusion=1 OR A2.QCQCConclusion=5 OR A2.QCQCConclusion=6 OR A2.QCQCConclusion=7 OR A2.QCQCConclusion=12) and ISNULL(A2.ModifiedOn ,A2.CreatedOn)>=@LastTime update #TempPOArrive 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 #TempPOArrive IF NOT EXISTS(SELECT * FROM #TempPOArrive) RETURN"; sql = ICSHelper.Time(Namespace, Class, WorkPoint, sql, "#TempPOArrive"); 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 += "\r\n"; sql += @"--删除数据 -- DELETE ICSPurchaseReceive WHERE RCVDetailID NOT IN (SELECT Autoid FROM {1}.dbo.RdRecords01) AND LEN(RCVDetailID)>0 SELECT a.RCVDetailID INTO #tableICSPurchaseReceive FROM ICSPurchaseReceive a With(NoLock) LEFT JOIN {1}.dbo.[PM_RcvLine] b With(NoLock) ON a.RCVDetailID=b.ID WHERE a.WorkPoint='{0}' and b.Autoid IS NULL AND LEN(a.RCVDetailID)>0 DELETE ICSPurchaseReceive WHERE WorkPoint='{0}' and RCVDetailID IN ( SELECT RCVDetailID from #tableICSPurchaseReceive) "; Dictionary values = new Dictionary(); values.Add("RCVCode", "a.RCVCode");//入库单号 values.Add("Sequence", "a.Sequence");//入库单行号 values.Add("SourceCode", "a.SourceCode");//来源单号 values.Add("SourceSequence", "a.SourceSequence");//来源单号行号 values.Add("InvCode", "a.InvCode");//物料编码 values.Add("Quantity", "ABS(a.Quantity)");//入库数量 values.Add("Amount", "a.Amount");//辅助数量 values.Add("WHCode", "a.WHCode");//仓库代码 values.Add("RCVDetailID", "a.RCVDetailID"); values.Add("RCVID", "a.RCVID"); values.Add("CreateDateTime", "a.CreateDateTime"); values.Add("CreatePerson", "a.CreatePerson"); values.Add("Status", "a.Status");//状态 values.Add("ExtensionID", "c.ID"); values.Add("MTIME", "a.MTIME"); values.Add("Type", "2");//类型 //更新存在数据 sql += ICSHelper.UpdateSQL("b", values) + @" #TempPOArrive a INNER JOIN ICSPurchaseReceive b ON a.RCVDetailID=b.RCVDetailID 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("ID", "NewID()"); values.Add("RCVQuantity", "a.RCVQuantity"); sql += "\r\n"; //插入新增数据 sql += ICSHelper.InsertSQL("ICSPurchaseReceive", values) + @" #TempPOArrive a LEFT JOIN ICSPurchaseReceive b ON a.RCVDetailID=b.RCVDetailID and a.WorkPoint=b.WorkPoint inner join ICSExtension c on a.Colspan=c.Colspan and a.WorkPoint=c.WorkPoint WHERE b.RCVDetailID IS NULL and a.WorkPoint='" + WorkPoint + @"' "; sql += "DROP TABLE #TempPOArrive"; sql += " DROP TABLE #TempExtension " + "DROP TABLE #tableICSPurchaseReceive"; sql = string.Format(sql, WorkPoint, erpName); ICSHelper.ExecuteDate(conStr, sql); #endregion } } catch (Exception ex) { log.Error(ex.ToString()); } } } }