diff --git a/.vs/ICSSoft.FromERP/v16/.suo b/.vs/ICSSoft.FromERP/v16/.suo index 29cb8c0..0656a8c 100644 Binary files a/.vs/ICSSoft.FromERP/v16/.suo and b/.vs/ICSSoft.FromERP/v16/.suo differ diff --git a/ICSSoft.FromERP/ConvertExt.cs b/ICSSoft.FromERP/ConvertExt.cs index f1241be..3d8a1fe 100644 --- a/ICSSoft.FromERP/ConvertExt.cs +++ b/ICSSoft.FromERP/ConvertExt.cs @@ -7,6 +7,11 @@ namespace ICSSoft.FromERP { public static class ConvertExt { + public static string ToStringBz(this DateTime date) + { + + return date.ToString("yyyy-MM-dd HH:mm:ss"); + } public static char ToChar(this object data) { char returnValue = default(char); diff --git a/ICSSoft.FromERP/ICSHelper.cs b/ICSSoft.FromERP/ICSHelper.cs index 420b869..9a44e2f 100644 --- a/ICSSoft.FromERP/ICSHelper.cs +++ b/ICSSoft.FromERP/ICSHelper.cs @@ -410,5 +410,105 @@ WHERE Namespace='{0}' AND ClassName='{1}' AND TenantId='{2}' return obj; } } + + public static DateTime GetTime(string Conn, string Namespace, string ClassName, string TenantId) + { + + try + { + string value = @"DECLARE @LastTime datetime='2000-01-01' + --同步时间表不存在插入记录 + IF NOT EXISTS(SELECT ID FROM ICSERPTime WHERE Namespace='{0}' AND ClassName='{1}' AND TenantId='{2}') + BEGIN + INSERT INTO ICSERPTime VALUES('{0}','{1}',@LastTime + ,'','','{2}' + ,@LastTime,'job',@LastTime,'job','job','job') + END + --取出最后同步日期 + SELECT @LastTime=ModifyDate FROM ICSERPTime WHERE Namespace='{0}' AND ClassName='{1}' AND TenantId='{2}' + --根据时间过滤所需数据放入临时表，必须要有MTIME字段 + Select @LastTime + "; + return ExecuteScalar(Conn, string.Format(value, Namespace, ClassName, TenantId)).ToDateTime(); + } + catch (Exception ex) + { + log.Error(ex.ToString()); + throw; + } + + } + + public static void UpdateTime(string Conn, string Namespace, string ClassName, string TenantId, DateTime time) + { + + try + { + string value = @"DECLARE @LastTime datetime='2000-01-01' + --同步时间表不存在插入记录 + IF NOT EXISTS(SELECT ID FROM ICSERPTime WHERE Namespace='{0}' AND ClassName='{1}' AND TenantId='{2}') + BEGIN + INSERT INTO ICSERPTime VALUES('{0}','{1}',@LastTime + ,'','','{2}' + ,@LastTime,'job',@LastTime,'job','job','job') + END + select @LastTime='{3}' + --取出最后同步日期 + UPDATE ICSERPTime SET ModifyDate=@LastTime,LastModificationTime=GETDATE(),LastModifierUserName='job' ,LastModifierUserId='job' + WHERE Namespace='{0}' AND ClassName='{1}' AND TenantId='{2}' + "; + ExecuteScalar(Conn, string.Format(value, Namespace, ClassName, TenantId, time.ToStringBz())); + } + catch (Exception ex) + { + log.Error(ex.ToString()); + throw; + } + + } + + public static void ExecuteDateNew(string conStr, string sql) + { + + using (SqlConnection con = new SqlConnection(conStr)) + { + con.Open(); + try + { + Dictionary dictionary = new Dictionary(); + using (SqlTransaction tran = con.BeginTransaction()) + { + using (SqlCommand command = new SqlCommand()) + { + command.Connection = con; + command.Transaction = tran; + command.CommandTimeout = 100; + command.CommandText = sql; + try + { + int result = command.ExecuteNonQuery(); + tran.Commit(); + } + catch (Exception ex) + { + tran.Rollback(); + throw ex; + } + } + } + } + catch (Exception ex) + { + log.Error(ex.ToString() + Environment.NewLine + "异常SQL：" + Environment.NewLine + sql); + throw ex; + } + finally + { + if (con.State == ConnectionState.Open) + con.Close(); + con.Dispose(); + } + } + } } } diff --git a/ICSSoft.FromERP/ICSInventory_Rhtyon.cs b/ICSSoft.FromERP/ICSInventory_Rhtyon.cs new file mode 100644 index 0000000..0319242 --- /dev/null +++ b/ICSSoft.FromERP/ICSInventory_Rhtyon.cs @@ -0,0 +1,163 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using Quartz; +using System.Data; +namespace ICSSoft.FromERP +{ + /// + /// 物料档案(锐腾) + /// + public class ICSInventory_Rhtyon : 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 conERPStr = ICSHelper.GetERPConnectString(); + 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 TenantId = dr["TenantId"].ToString(); + string TenantCode = dr["TenantCode"].ToString(); + string ErpId = dr["ErpID"].ToString(); //erpID + string Class = this.GetType().Name + TenantCode; + erpName = string.Format(erpName, TenantId); + + #region SQL + string sql = @" select A.ID AS ID, + A.Code AS ItemCode +,a.ItemFormAttribute + ,dbo.GetReplaceStr(A.Name) AS ItemName, +a.DescFlexField_PrivateDescSeg2 ItemDrawingNo + ,b.Description ItemDesc, + dbo.GetReplaceStr(A.SPECS) AS ItemStd, + D.Name AS ItemUnit, + G.Code as ItemMainCategoryCode, + H.Name as ClassName, + 1 as ItemRate, + 1 as EffectiveDays, + A.ModifiedOn as MTime + ,I.id as Org + ,Case When Q.IsSueOverType=0 THEN 1 WHEN Q.IsSueOverType=1 THEN 2 WHEN Q.IsSueOverType=2 THEN 3 ELSE 0 END AS 备料超额类型 + ,Case When Q.IsSueOverType=0 Then Q.StandardMaterialScale When Q.IsSueOverType=1 Then Q.StandardMaterialQty + ELSE 0 END AS 备料超额值 + INTO #TempINV + from {1}.dbo.[CBO_ItemMaster] AS A + LEFT JOIN {1}.dbo.[CBO_ItemMaster_Trl] AS B ON ( A.[ID] = B.[ID] AND B.SysMLFlag='zh-CN') + LEFT JOIN {1}.dbo.[Base_UOM] AS C ON ( A.[CostUOM] = C.[ID] ) + LEFT JOIN {1}.dbo.[Base_UOM_Trl] AS D ON ( C.[ID] = D.[ID] AND D.SysMLFlag='zh-CN') + LEFT JOIN {1}.dbo.[Base_UOM] AS E ON ( A.[InventoryUOM] = E.[ID] ) + LEFT JOIN {1}.dbo.[Base_UOM_Trl] AS F ON ( E.[ID] = F.[ID] AND F.SysMLFlag='zh-CN') + LEFT JOIN {1}.dbo.[CBO_Category] AS G ON ( A.[MainItemCategory] = G.[ID] ) + LEFT JOIN {1}.dbo.[CBO_Category_Trl] AS H ON ( G.[ID] = H.[ID] AND H.SysMLFlag='zh-CN') + LEFT JOIN {1}.dbo.[Base_Organization] AS I ON ( A.[Org] = I.[ID] ) + LEFT JOIN {1}.dbo.[Base_Organization_Trl] AS J ON ( I.[ID] = J.[ID] AND J.SysMLFlag='zh-CN') + LEFT JOIN {1}.dbo.CBO_InventoryInfo L on A.id=L.ItemMaster + LEFT JOIN {1}.dbo.CBO_Wh M on L.warehouse=M.id and A.org=M.org + LEFT JOIN {1}.dbo.CBO_Category_Trl P ON P.ID=A.MainItemCategory + LEFT JOIN {1}.dbo.CBO_MfgInfo Q ON Q.ItemMaster=A.ID + where A.ModifiedOn>=@LastTime AND I.id={0} + ORDER BY A.Code + + IF NOT EXISTS(SELECT * FROM #TempINV) + RETURN"; + sql = string.Format(sql, ErpId, erpName); + sql = ICSHelper.Time(Namespace, Class, TenantId, sql, "#TempINV"); + + sql += @"--删除数据 + + SELECT a.ItemCode INTO #tableICSINVENTORY + FROM ICSINVENTORY a With(NoLock) + LEFT JOIN {1}.dbo.[CBO_ItemMaster] b With(NoLock) ON a.ItemCode=b.code + WHERE b.code is null + and a.TenantId='{0}' + AND b.Org={2} + + DELETE ICSINVENTORY + WHERE TenantId='{0}' and ItemCode IN ( SELECT ItemCode from #tableICSINVENTORY) "; + Dictionary values = new Dictionary(); + values.Add("ItemCode", "a.ItemCode");//物料编号 + values.Add("ItemName", "a.ItemName");//物料名称 + values.Add("ItemDesc", "a.ItemDesc");//物料描述 + values.Add("ItemStd", "a.ItemStd");//规格型号 + values.Add("ItemAttribute", "a.ItemFormAttribute");//规格型号 + values.Add("ItemUnit", "a.ItemUnit");//主计量单位 + values.Add("ItemMainCategoryCode", "a.ItemMainCategoryCode");//大类编码 + values.Add("ItemRate", "a.ItemRate"); + values.Add("InvVersion", "''"); + values.Add("InvBrand", "''"); + values.Add("InvIQC", "0");//大类编码 + values.Add("InvFQC", "0");//大类编码 + values.Add("EffectiveEnable", "0");//大类名称 + values.Add("EffectiveDays", "a.EffectiveDays");//大类名称 + values.Add("BatchEnable", "1");//大类名称 + values.Add("LotEnable", "0");//大类名称 + values.Add("PrintEnable", "0");//大类名称 + values.Add("OverType", "a.备料超额类型"); + values.Add("OverValue", "a.备料超额值"); + values.Add("LastModificationTime", "a.Mtime");//操作时间 + //values.Add("ItemType", "d.ItemType");//操作时间 + values.Add("ItemContype", "d.ItemContype");//操作时间 + values.Add("ItemControlType", "d.ItemControlType");//操作时间 + values.Add("ItemDrawingNo", "b.ItemDrawingNo");//操作时间 + values.Add("ItemType", "'itemtype_finishedproduct'"); + + //更新存在数据 + sql += ICSHelper.UpdateSQL("b", values) + + @" #TempINV a + INNER JOIN ICSINVENTORY b ON a.ItemCode=b.ItemCode + left join IcsMainCategoryCode d on b.ItemMainCategoryCode=d.ItemMainCategoryCode and b.TenantId=d.TenantId + WHERE b.TenantId='" + TenantId + "' and a.Org={2} "; + + values.Add("CreationTime", "a.MTime");//操作人 + values.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + values.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + values.Add("TenantId", "'" + TenantId + "'");//站点 + //插入新增数据 + sql += ICSHelper.InsertSQL("ICSINVENTORY", values) + + @" #TempINV a + LEFT JOIN ICSINVENTORY b ON a.ItemCode=b.ItemCode and b.TenantId='{0}' + left join IcsMainCategoryCode d on b.ItemMainCategoryCode=d.ItemMainCategoryCode and b.TenantId=d.TenantId + WHERE 1=1 and b.ItemCode is null + and a.Org={2} "; + sql += " DROP TABLE #TempINV " + + " DROP TABLE #tableICSINVENTORY "; + sql = string.Format(sql, TenantId, erpName, ErpId); + // return; + ICSHelper.ExecuteDate(conStr, sql); + #endregion + } + } + catch (Exception ex) + { + log.Error(ex.ToString()); + } + } + } +} diff --git a/ICSSoft.FromERP/ICSSoft.FromERP.csproj b/ICSSoft.FromERP/ICSSoft.FromERP.csproj index 2b6ac2b..abe9feb 100644 --- a/ICSSoft.FromERP/ICSSoft.FromERP.csproj +++ b/ICSSoft.FromERP/ICSSoft.FromERP.csproj @@ -51,6 +51,9 @@ ..\..\..\50-job\Scheduler_4.0\Scheduler\JOB\Newtonsoft.Json.DLL + + ..\Root\NPinyin.dll + False bin\Debug\Quartz.dll @@ -95,12 +98,15 @@ + + + @@ -119,6 +125,7 @@ + diff --git a/ICSSoft.FromERP/IcsMo_Rhtyon.cs b/ICSSoft.FromERP/IcsMo_Rhtyon.cs new file mode 100644 index 0000000..421f108 --- /dev/null +++ b/ICSSoft.FromERP/IcsMo_Rhtyon.cs @@ -0,0 +1,219 @@ +using Quartz; +using System; +using System.Collections.Generic; +using System.Data; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace ICSSoft.FromERP +{ + /// + /// 工单(锐腾) + /// + public class IcsMo_Rhtyon : 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 TenantId = dr["TenantId"].ToString();//mes 组织 + string TenantCode = dr["TenantCode"].ToString(); + string ErpId = dr["ErpID"].ToString(); //erpID + string Class = this.GetType().Name + TenantCode; + erpName = string.Format(erpName, TenantId); + #region SQL + string sql = @" + select A.ID as ID, + A.DocNO as MOCODE, + 1 as Sequence, + A7.Code as InvCode, + CASE WHEN A.IsStartMO != 1 THEN + (SELECT TOP 1 TotalStartQty FROM {1}.dbo.MO_MOStartInfo WHERE MO=A.ID ORDER BY StartDatetime DESC) + ELSE (SELECT TOP 1 ActualStartQty FROM {1}.dbo.MO_MOStartInfo WHERE MO=A.ID ORDER BY StartDatetime DESC) END as Quantity, + A.CreatedBy as CreatePerson, + A.CreatedOn as CreateDateTime, + 0 as Amount, + 0 as RCVQuantity, + A13.Code as DepCode, + A22.Code as WHCode, + 'mostatus_initial' as MOStatus, + A2.Description as MOMemo, + '2' as ERPStatus, + A.StartDate as StartDate, + A.CompleteDate as DueDate, + A.ID as MOID, + A.ID as MODetailID, + ISNULL(A.ModifiedOn,A.BusinessCreatedOn) as MTIME, + isnull(A11.Code,'') ProjectCode,isnull(A19.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 + ,A12.Code as TenantId + ,A12.id as Org + ,a.DescFlexField_PrivateDescSeg1 AS EATTRIBUTE1 + ,( + select b1.code from {1}.dbo.UBF_Sys_ExtEnumType a1 + left join {1}.dbo.UBF_Sys_ExtEnumValue b1 on a1.ID=b1.ExtEnumType + left join {1}.dbo.UBF_Sys_ExtEnumValue_Trl c1 on b1.id=c1.ID + WHERE a1.Code like 'UFIDA.U9.CBO.Enums.DemandCodeEnum' + and b1.evalue=a.DemandCode +and b1.code not like 'K10%' + ) as NeedType + ,A4.Name as MoDocType +,case when a.ActualCompleteDate is null then '' +else Convert(varchar(10),a.ActualCompleteDate,120 ) end as ActualCompleteDate + INTO #TempMO + from {1}.dbo.MO_MO as A With(NoLock) + left join {1}.dbo.[MO_MOMemo] as A1 With(NoLock) on (A.[ID] = A1.[MO]) + left join {1}.dbo.[MO_MOMemo_Trl] as A2 With(NoLock) on (A2.SysMlFlag = 'zh-CN') and (A1.[ID] = A2.[ID]) + left join {1}.dbo.[MO_MODocType] as A3 With(NoLock) on (A.[MODocType] = A3.[ID]) + left join {1}.dbo.[MO_MODocType_Trl] as A4 With(NoLock) on (A4.SysMlFlag = 'zh-CN') and (A3.[ID] = A4.[ID]) + left join {1}.dbo.[MO_MOTaskPlan] as A5 With(NoLock) on (A.[ID] = A5.[MO]) + left join {1}.dbo.[Base_User] as A6 With(NoLock) on (A.ModifiedBy = A6.Code) + left join {1}.dbo.[CBO_ItemMaster] as A7 With(NoLock) on (A.[ItemMaster] = A7.[ID]) + left join {1}.dbo.[MO_MO_Trl] as A8 With(NoLock) on (A8.SysMlFlag = 'zh-CN') and (A.[ID] = A8.[ID]) + left join {1}.dbo.[CBO_BOMVersion] as A9 With(NoLock) on (A.[BOMVersion] = A9.[ID]) + left join {1}.dbo.[CBO_ItemMaster_Trl] as A10 With(NoLock) on (A10.SysMlFlag = 'zh-CN') and (A7.[ID] = A10.[ID]) + left join {1}.dbo.[CBO_Project] as A11 With(NoLock) on (A.[Project] = A11.[ID]) + left join {1}.dbo.[Base_Organization] as A12 With(NoLock) on (A.[Org] = A12.[ID]) + left join {1}.dbo.[CBO_Department] as A13 With(NoLock) on (A.[Department] = A13.[ID]) + left join {1}.dbo.[CBO_Department_Trl] as A14 With(NoLock) on (A14.SysMlFlag = 'zh-CN') and (A13.[ID] = A14.[ID]) + left join {1}.dbo. MO_MO As A16 With(NoLock) on A16.[MODocType]=1001603110990023 and A.[Project]=A16.Project and A.ItemMaster=A16.ItemMaster + left join {1}.dbo.[CBO_ItemMaster] as A17 With(NoLock) on (A16.[ItemMaster] = A17.[ID]) + left join {1}.dbo.[CBO_ItemMaster_Trl] as A18 With(NoLock) on (A18.SysMlFlag = 'zh-CN') and (A17.[ID] = A16.[ID]) + left join {1}.dbo.[MO_MOLot] as A19 With(NoLock) on (A16.[ID] = A19.[MO]) + left join (select * from (select ROW_NUMBER() over( partition by dept order by code desc ) row,* from {1}.dbo.CBO_Operators with(nolock) ) bb + where bb.row='1' )as A20 on A20.dept=A.Department and a20.Org=a.Org + --left join {1}.dbo.[MO_IssueDoc] as A21 With(NoLock) on A21.[SourceDoc_SrcDocNo]=A.DocNo + LEFT JOIN {1}.dbo.[CBO_Wh] AS A22 With(NoLock) ON A22.ID=A.CompleteWh + where (A.DocState=2 OR A.DocState=3) and A.[BusinessType] != 50 and (A.[BusinessType] != 52) + and (A.[BusinessType] != 2417) and (A.[IsMultiRouting] != 1) and A.[ItemMaster] is not null --and (A.[IsStartMO] != 1) + and ISNULL(A.ModifiedOn,A.BusinessCreatedOn)>=@LastTime AND A12.id='{0}' + + --update #TempMO 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,TenantId,cBatch,version ,brand + -- INTO #TempExtensionMO + -- from #TempMO + + IF NOT EXISTS(SELECT * FROM #TempMO) + begin + DROP TABLE #TempMO + RETURN + + end"; + sql = string.Format(sql, ErpId, erpName); + sql = ICSHelper.Time(Namespace, Class, TenantId, sql, "#TempMO"); + Dictionary value = new Dictionary(); + + sql += @"--删除数据 + -- DELETE ICSMO WHERE MODetailID NOT IN (SELECT CAST(MoDId AS VARCHAR) FROM {1}.dbo.[mom_orderdetail]) + SELECT a.MoCode INTO #tableICSMO + FROM ICSMO a With(NoLock) + LEFT JOIN {1}.dbo.[MO_MO] b With(NoLock) ON a.Mocode=b.DocNO + WHERE a.TenantId='{0}' and b.DocNO IS NULL AND b.Org={2} + + DELETE ICSMO + WHERE TenantId='{0}' and mocode IN ( SELECT MoCode from #tableICSMO) + "; + Dictionary values = new Dictionary(); + values.Add("MoCode", "a.MOCODE");//工单号 + values.Add("MoSeq", "a.Sequence");//工单行号 + values.Add("ItemCode", "a.InvCode");//物料代码 + values.Add("MoPlanQty", "a.Quantity");//数量 + values.Add("Amount", "a.Amount");//辅机数量 + values.Add("DepCode", "a.DepCode");//辅机数量 + values.Add("SegCode", "a.DepCode");//辅机数量 + values.Add("WHCode", "a.WHCode");//仓库 + values.Add("MoPlanStartDate", "a.StartDate");//开工日 + values.Add("MoPlanEndDate", "a.DueDate");//完工日 + + values.Add("MOMemo", "a.MOMemo");//生产订单状态 + values.Add("MoUser", "a.CreatePerson");//生产订单状态 + values.Add("MODOWNDATE", "a.CreateDateTime");//生产订单状态 + values.Add("MOID", "a.MoId");//生产订单状态 + values.Add("MODetailID", "a.MODetailID");//生产订单状态 + values.Add("LastModifierUserId", "'" + ConstWorkPoint.Muser + "'"); + values.Add("LastModifierUserName", "'" + ConstWorkPoint.Musername + "'"); + values.Add("LastModificationTime", "a.Mtime");//操作时间 + //values.Add("Default1", "a.EATTRIBUTE1"); + //values.Add("Default2", "a.NeedType"); + values.Add("DocType", "a.MoDocType"); + // values.Add("Default3", "a.ActualCompleteDate"); + + //更新存在数据 + sql += ICSHelper.UpdateSQL("b", values) + + @" #TempMO a + INNER JOIN ICSMO b ON a.Mocode=b.Mocode + WHERE b.TenantId='{0}' and a.Org={2} "; + + // values.Add("ID", "NEWID()"); + values.Add("MoType", "'normal'");//辅机数量 + values.Add("MOVER", "'1'");//辅机数量 + values.Add("ProjectCode", "a.ProjectCode");//辅机数量 + + values.Add("MOINPUTQTY", "0");//辅机数量 + values.Add("MOSCRAPQTY", "0");//辅机数量 + values.Add("MOACTQTY", "0");//辅机数量 + values.Add("CollectModel", "'SS'");//辅机数量 + values.Add("CollectType", "'collecttype_one'");//辅机数量 + values.Add("MoBom", "'1'");//辅机数量 + values.Add("CreationTime", "a.MTime");//操作人 + values.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + values.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + values.Add("TenantId", "'" + TenantId + "'");//站点 + values.Add("MOSTATUS", "a.MOStatus");//生产订单状态 + //插入新增数据 + sql += ICSHelper.InsertSQL("ICSMO", values) + + @" #TempMO a + LEFT JOIN ICSMO b on a.Mocode=b.Mocode and b.TenantId='{0}' + WHERE 1=1 and b.MoCode is null and a.Org={2} "; + sql += "DROP TABLE #TempMO"; + sql += " DROP TABLE #tableICSMO "; + sql = string.Format(sql, TenantId, erpName, ErpId); + //return; + ICSHelper.ExecuteDate(conStr, sql); + #endregion + } + } + catch (Exception ex) + { + log.Error(ex.ToString()); + } + } + } +} diff --git a/ICSSoft.FromERP/IcsOp.cs b/ICSSoft.FromERP/IcsOp.cs new file mode 100644 index 0000000..c7b9169 --- /dev/null +++ b/ICSSoft.FromERP/IcsOp.cs @@ -0,0 +1,485 @@ +using NPinyin; +using Quartz; +using System; +using System.Collections.Generic; +using System.Data; +using System.Linq; +using System.Text; + +namespace ICSSoft.FromERP +{ + /// + /// 工序/工艺路线(锐腾) + /// + public class IcsOp : 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; + DataTable dt = ICSHelper.GetERPDB(conStr); + foreach (DataRow dr in dt.Rows) + { + string erpName = ICSHelper.GetConfigString()["ERPDB"]; + string TenantId = dr["TenantId"].ToString(); + string TenantCode = dr["TenantCode"].ToString(); + string ErpId = dr["ErpID"].ToString(); //erpID + string Class = this.GetType().Name + TenantCode; + //erpName = string.Format(erpName, TenantId); + string time = ICSHelper.GetTime(conStr, Namespace, Class, TenantId).ToStringBz(); + string sql = @"select DISTINCT EffectiveDate,DisableDate,ITEM.Code+'_'+RoutingVersionCode+'_'+cast(AlternateType as nvarchar) AS ROUTECODE, +ITEM.Code+'_'+RoutingVersionCode+'_'+(case AlternateType when '0' then '主制造' when '1' then '委外' when '2001' then '试制' end ) AS RouteDesc,RoutingVersionCode,RoutingVersion, +u9route.CreatedOn as RouteCreateTime,u9route.ModifiedOn as RouteModifiedTime,opu9.Sequence as opseq, +opu9trl.Description+'_'+OPU9.Sequence as U9Opcode,opu9.CreatedOn as opCreateTime,opu9.ModifiedOn as OpModifiedTime,opu9trl.Description as OpDesc, +u9route.ID as routeID,opu9.ID as OPID,work.Code AS SegCode,u9Group.Code as CrewCode,u9route.Lot,u9Line.Code as LineCode,'' as MesOpcode, +case when timeuom.Name='小时' then cast (opu9.RunTime as decimal(18,3)) + when timeuom.Name='秒' then cast (opu9.RunTime/3600 as decimal(18,3)) + when timeuom.Name='分钟' then cast (opu9.RunTime/60 as decimal(18,3)) + when timeuom.Name='天' then cast (opu9.RunTime/24 as decimal(18,3)) + end as Rtime, + case when timeuom.Name='小时' then cast (opu9.SetupTime as decimal(18,3)) + when timeuom.Name='秒' then cast (opu9.SetupTime/3600 as decimal(18,3)) + when timeuom.Name='分钟' then cast (opu9.SetupTime/60 as decimal(18,3)) + when timeuom.Name='天' then cast (opu9.SetupTime/24 as decimal(18,3)) + end as Stime,u9Res.Code AS resCode,u9Restrl.Name as resName,PerResUsage,PerResOutput, + case when IsSubcOperation='0' THEN 'N' + else 'Y' end as IsSubcOperation,ITEM.Code as ItemCode,u9Group.Name AS CREWName,u9Linetrl.Name as LineName,worktrl.Name as SegNAME + from +{2}.DBO.CBO_Routing u9route +LEFT JOIN {2}.DBO.CBO_Routing_Trl u9routetrl on u9routetrl.ID=u9route.ID +LEFT JOIN {2}.DBO.CBO_ItemMaster ITEM ON ITEM.ID=ItemMaster +LEFT JOIN {2}.DBO.CBO_Operation opu9 on opu9.Routing=u9route.ID +LEFT JOIN {2}.DBO.CBO_Operation_Trl opu9trl on opu9.ID=opu9trl.ID +LEFT JOIN {2}.DBO.CBO_StdOperation opstdu9 on opstdu9.id=opu9.StdOperation +LEFT JOIN {2}.DBO.CBO_ShiftGroup u9Group on u9Group.ID=opu9.ShiftGroup +LEFT JOIN {2}.DBO.CBO_WorkCenter work on work.ID=opu9.WorkCenter +LEFT JOIN {2}.DBO.CBO_WorkCenter_Trl worktrl on work.ID=worktrl.ID +LEFT JOIN {2}.DBO.Base_UOM_Trl timeuom on timeuom.ID=opu9.TimeUOM +LEFT JOIN {2}.DBO.CBO_ProductionLine u9Line on u9Line.ID=ProductionLine +LEFT JOIN {2}.DBO.CBO_ProductionLine_Trl u9Linetrl on u9Linetrl.ID=ProductionLine +LEFT JOIN {2}.DBO.CBO_OpResource opRes ON opRes.Operation=opu9.id +LEFT JOIN {2}.DBO.CBO_Resource u9Res on u9Res.ID=opRes.Resource +LEFT JOIN {2}.DBO.CBO_Resource_Trl u9Restrl on u9Restrl.ID=u9Res.ID +WHERE u9route.org='{0}' And u9route.ModifiedOn>='{1}' and u9route.ApproveDate is not null +"; + sql = string.Format(sql, ErpId, time, erpName); + var table = ICSHelper.ExecuteTable(conStr, sql); + if (table.Rows.Count <= 0) + { + log.Info("未查询到工艺路线数据,同步结束"); + return; + } + table.AsEnumerable().ToList().ForEach(row => + { + row["MesOpcode"] = Pinyin.GetPinyin(row["U9Opcode"].ToString()).Replace(" ", ""); + }); + table.AcceptChanges(); + + #region 工序 + string opsql = ""; + int count = 0; + var opObj = table.AsEnumerable().Select(a => new { opcode = a["MesOpcode"].ToString(), opdesc = a["OpDesc"].ToString(), Opseq = a["opseq"].ToString(), u9Opcode = a["U9Opcode"].ToString() }). + Distinct().ToList(); + opObj.ForEach(b => { + count++; + + if (count != opObj.Count) + opsql += $" SELECT '{b.opcode}' as Opcode,'{b.opdesc}' as Opdesc,'{b.Opseq}' as opseq,'{b.u9Opcode}' as u9Opcode union all "; + else + opsql += $" SELECT '{b.opcode}' as Opcode,'{b.opdesc}' as Opdesc,'{b.Opseq}' as opseq,'{b.u9Opcode}' as u9Opcode"; + + }); + + opsql = "select * into #TempOp from (" + opsql + ") a"; + + Dictionary opDic = new Dictionary(); + opDic.Add("Opcode", "A.OPCODE"); + opDic.Add("Opdesc", "A.OPDESC"); + opDic.Add("OPNAME", "A.OPDESC"); + opDic.Add("OPSEQ", "A.OPSEQ"); + opDic.Add("OPCOLLECTION", "'MANUAl'"); + opDic.Add("OPCONTROL", "'10000000'"); + opDic.Add("ISMaterial", "'N'"); + opDic.Add("ISMerge", "'N'"); + opDic.Add("OPLevel", "'A'"); + opDic.Add("STIME", "0.00"); + opDic.Add("RTIME", "0.00"); + opDic.Add("Default1", "A.u9Opcode"); + opDic.Add("TenantId", "'" + TenantId + "'"); + opDic.Add("CreationTime", "GETDATE()");//操作时间 + opDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + opDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + + opsql += @" + DELETE OP + FROM ICSOP OP + LEFT JOIN + (SELECT opu9trl.Description+'_'+Sequence as Opcode FROM {1}.DBO.CBO_Operation opu9 + LEFT JOIN {1}.DBO.CBO_Operation_Trl opu9trl on opu9.ID=opu9trl.ID + WHERE opu9.org='{2}' + ) u9op on u9op.Opcode=OP.Default1 + WHERE TenantId='{0}' and u9op.Opcode is null "; + + opsql += ICSHelper.InsertSQL("ICSOP", opDic) + + @" #TempOp a + LEFT JOIN ICSOP b on a.OPCODE=b.OPCODE and b.TenantId='{0}' + WHERE 1=1 and b.OPCODE is null"; + opsql += " DROP TABLE #TempOp"; + opsql = string.Format(opsql, TenantId, erpName, ErpId); + #endregion + + #region 途程 + String routeSql = ""; + string itemRouteSql = ""; + count = 0; + var RouteObj = table.AsEnumerable().Select(a => new { RouteCode = a["ROUTECODE"].ToString(), RouteName = a["RouteDesc"].ToString(), EffDate = ((DateTime)a["EffectiveDate"]).ToStringBz(), IvlDate = ((DateTime)a["DisableDate"]).ToStringBz(), ProductLine = a["LineCode"].ToString(), ProductLineName = a["LineName"].ToString(), ItemCode = a["ItemCode"].ToString(), RouteVersion = a["RoutingVersion"].ToString(), Lot = a["Lot"].ToString() }). + Distinct().ToList(); + RouteObj.ForEach(b => { + count++; + + if (count != RouteObj.Count) + routeSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.RouteName}' as RouteName,'{b.EffDate}' as EffDate,'{b.IvlDate}' as IvlDate,'{b.ItemCode}' as ItemCode,'{b.Lot}' AS Lot,'{b.ProductLine}' as ProductLine,'{b.ProductLineName}' as ProductLineName,'{b.RouteVersion}' as RouteVersion union all "; + else + routeSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.RouteName}' as RouteName,'{b.EffDate}' as EffDate,'{b.IvlDate}' as IvlDate,'{b.ItemCode}' as ItemCode,'{b.Lot}' AS Lot,'{b.ProductLine}' as ProductLine,'{b.ProductLineName}' as ProductLineName,'{b.RouteVersion}' as RouteVersion"; + + }); + itemRouteSql = routeSql; + routeSql = " select * into #TempRoute from (" + routeSql + ") a"; + Dictionary routeDic = new Dictionary(); + routeDic.Add("RouteCode", "A.RouteCode"); + routeDic.Add("RouteName", "A.RouteName"); + routeDic.Add("RouteDesc", "A.RouteName"); + routeDic.Add("RouteType", "'Normal'"); + routeDic.Add("EffDate", "a.EffDate"); + routeDic.Add("IvlDate", "a.IvlDate"); + routeDic.Add("Enabled", "'Y'"); + routeDic.Add("TenantId", "'" + TenantId + "'"); + routeDic.Add("CreationTime", "GETDATE()");//操作时间 + routeDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + routeDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + + + + routeSql += @" + DELETE ROUTE + FROM ICSROUTE ROUTE + LEFT JOIN + (SELECT item.Code+'_'+route.RoutingVersionCode+'_'+cast(AlternateType as nvarchar) as RouteCode FROM {1}.DBO.CBO_Routing route + LEFT JOIN {1}.DBO.CBO_ItemMaster item on route.ItemMaster=item.ID + WHERE route.org='{2}' + ) u9route on u9route.RouteCode=ROUTE.ROUTECODE + WHERE TenantId='{0}' and u9route.RouteCode is null "; + + routeSql += ICSHelper.InsertSQL("ICSROUTE", routeDic) + + @"#TempRoute a + LEFT JOIN ICSROUTE b on a.ROUTECODE=b.ROUTECODE and b.TenantId='{0}' + WHERE 1=1 and b.ID is null"; + routeSql += " DROP TABLE #TempRoute "; + routeSql = string.Format(routeSql, TenantId, erpName, ErpId); + #endregion + + + #region 途程关联工序 + string routeOpSql = ""; + count = 0; + var RouteOpObj = table.AsEnumerable().Select(a => new { RouteCode = a["ROUTECODE"].ToString(), Opcode = a["MesOpcode"].ToString(), Opseq = a["opseq"].ToString(), ParallelOp = a["IsSubcOperation"].ToString(), ItemCode = a["ItemCode"].ToString(), RouteVersion = a["RoutingVersion"].ToString(), Stime = a["Stime"].ToString(), Rtime = a["Rtime"].ToString(), SEGCODE = a["SegCode"].ToString(), SegName = a["SegNAME"].ToString(), CrewCode = a["CrewCode"].ToString(), CREWName = a["CREWName"].ToString() }). + Distinct().ToList(); + RouteOpObj.ForEach(b => { + count++; + + if (count != RouteOpObj.Count) + routeOpSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.Opcode}' as Opcode,'{b.Opseq}' as Opseq,'{b.ParallelOp}' as ParallelOp,'{b.ItemCode}' as ItemCode,{b.Rtime} as Rtime,{b.Stime} as Stime,'{b.SEGCODE}' as SEGCODE,'{b.SegName}' as SegName,'{b.CrewCode}' as CrewCode,'{b.CREWName}' as CREWName union all"; + else + routeOpSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.Opcode}' as Opcode,'{b.Opseq}' as Opseq,'{b.ParallelOp}' as ParallelOp,'{b.ItemCode}' as ItemCode,{b.Rtime} as Rtime,{b.Stime} as Stime,'{b.SEGCODE}' as SEGCODE,'{b.SegName}' as SegName,'{b.CrewCode}' as CrewCode,'{b.CREWName}' as CREWName "; + + }); + var itemOpSql = routeOpSql; + routeOpSql = $@"SELECT a.*,B.ID AS ROUTEID,C.ID AS OPID INTO #TempRoute2op FROM ({routeOpSql}) a + LEFT JOIN ICSROUTE b on b.RouteCode=a.RouteCode and b.TenantId='{TenantId}' + LEFT JOIN ICSOP C ON C.OPCODE=A.OPCODE AND C.TenantId='{TenantId}' + "; + Dictionary routeOpDic = new Dictionary(); + routeOpDic.Add("RouteCode", "A.RouteCode"); + routeOpDic.Add("OPCODE", "A.OPCODE"); + routeOpDic.Add("ROUTEID", "A.ROUTEID"); + routeOpDic.Add("OPID", "A.OPID"); + routeOpDic.Add("OPSEQ", "a.OPSEQ"); + routeOpDic.Add("IsMaterial", "'N'"); + routeOpDic.Add("IsMerge", "'N'"); + routeOpDic.Add("OpLevel", "'A'"); + routeOpDic.Add("OpControlSeq", "a.OPSEQ"); + routeOpDic.Add("OPControl", "'10000000'"); + routeOpDic.Add("ParallelOp", "a.ParallelOp"); + routeOpDic.Add("TenantId", "'" + TenantId + "'"); + routeOpDic.Add("CreationTime", "GETDATE()");//操作时间 + routeOpDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + routeOpDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + + routeOpSql += @" + DELETE ROUTEOP + FROM ICSROUTE2OP ROUTEOP + LEFT JOIN ICSOP OP ON ROUTEOP.OPID=OP.ID + LEFT JOIN + (SELECT item.Code+'_'+u9route.RoutingVersionCode+'_'+cast(u9route.AlternateType as nvarchar) as U9RouteCode,opu9trl.Description+'_'+OPU9.Sequence as u9Opcode + FROM {1}.DBO.CBO_Routing u9route + LEFT JOIN {1}.DBO.CBO_ItemMaster item on u9route.ItemMaster=item.ID + LEFT JOIN {1}.DBO.CBO_Operation opu9 on opu9.Routing=u9route.ID + LEFT JOIN {1}.DBO.CBO_Operation_Trl opu9trl on opu9.ID=opu9trl.ID + WHERE u9route.org='{2}' + ) u9routeOp on u9routeOp.U9RouteCode=ROUTEOP.ROUTECODE AND u9routeOp.u9Opcode=OP.DEFAULT1 + WHERE ROUTEOP.TenantId='{0}' and u9routeOp.U9RouteCode is null "; + + routeOpSql += ICSHelper.InsertSQL("ICSROUTE2OP", routeOpDic) + + @"#TempRoute2op a + LEFT JOIN ICSROUTE2OP b on a.ROUTECODE=b.ROUTECODE and A.OPCODE=B.OPCODE AND b.TenantId='{0}' + WHERE 1=1 and b.OPCODE is null"; + routeOpSql += " DROP TABLE #TempRoute2op"; + routeOpSql = string.Format(routeOpSql, TenantId, erpName, ErpId); + + #endregion + + + #region 物料关联途程 + itemRouteSql = $@"SELECT A.*,B.ID AS ITEMID,C.ID AS ROUTEID INTO #TempItemRoute + FROM ({itemRouteSql}) A + LEFT JOIN IcsInventory B ON A.ItemCode=B.ItemCode AND B.TenantId='{TenantId}' + LEFT JOIN ICSROUTE C ON C.ROUTECODE=A.ROUTECODE AND C.TenantId='{TenantId}' + "; + + itemRouteSql += @" + DELETE ITEMROUTE + FROM IcsItem2Route ITEMROUTE + LEFT JOIN + (SELECT item.Code+'_'+u9route.RoutingVersionCode+ '_'+cast(u9route.AlternateType as nvarchar) as U9RouteCode, + item.Code as itemcode + FROM {1}.DBO.CBO_Routing u9route + LEFT JOIN {1}.DBO.CBO_ItemMaster item on u9route.ItemMaster=item.ID + WHERE u9route.org='{2}' + ) u9routeOp on u9routeOp.U9RouteCode=ITEMROUTE.ROUTECODE AND u9routeOp.ITEMCODE=ITEMROUTE.itemcode + WHERE TenantId='{0}' and u9routeOp.itemcode is null "; + + Dictionary ItemRouteDic = new Dictionary(); + ItemRouteDic.Add("RouteCode", "A.RouteCode"); + ItemRouteDic.Add("ItemCode", "A.ItemCode"); + ItemRouteDic.Add("ROUTEID", "A.ROUTEID"); + ItemRouteDic.Add("ITEMID", "A.ITEMID"); + ItemRouteDic.Add("IsRef", "'Y'"); + ItemRouteDic.Add("Default1", "A.ProductLine"); + ItemRouteDic.Add("Default2", "A.ProductLineName"); + ItemRouteDic.Add("Default3", "A.LOT"); + ItemRouteDic.Add("TenantId", "'" + TenantId + "'"); + ItemRouteDic.Add("CreationTime", "GETDATE()");//操作时间 + ItemRouteDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + ItemRouteDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + + itemRouteSql += ICSHelper.InsertSQL("ICSITEM2ROUTE", ItemRouteDic) + + @" #TempItemRoute a + LEFT JOIN ICSITEM2ROUTE b on a.ROUTECODE=b.ROUTECODE and A.ITEMCODE=B.ITEMCODE AND b.TenantId='{0}' + WHERE 1=1 and b.ID is null "; + + + + itemRouteSql += @" Update A SET IsRef='N' FROM ICSITEM2ROUTE A INNER JOIN + (SELECT A.ROUTECODE,A.ITEMCODE FROM #TempItemRoute A LEFT JOIN ICSITEM2ROUTE B ON a.ROUTECODE=b.ROUTECODE and A.ITEMCODE=B.ITEMCODE AND b.TenantId='{0}' Where b.ID is null)B + ON B.ITEMCODE=A.ITEMCODE AND B.ROUTECODE<>A.ROUTECODE + "; + itemRouteSql += " DROP TABLE #TempItemRoute"; + + itemRouteSql = string.Format(itemRouteSql, TenantId, erpName, ErpId); + #endregion + + #region 物料关联途程与工序 + itemOpSql = $@"Select a.*,B.ID AS RouteId,c.id as OpId,d.id as ItemId,C.DEFAULT1 AS U9OPCODE INTO #TEMPITEMOP from ({itemOpSql})a + LEFT JOIN ICSROUTE b on b.RouteCode=a.RouteCode and b.TenantId='{TenantId}' + LEFT JOIN ICSOP C ON C.OPCODE=A.OPCODE AND C.TenantId='{TenantId}' + LEFT JOIN IcsInventory D ON D.ItemCode=A.ItemCode AND D.TenantId='{TenantId}' + "; + + Dictionary ItemOpDic = new Dictionary(); + ItemOpDic.Add("STIME", "A.STIME"); + ItemOpDic.Add("RTIME", "A.RTIME"); + ItemOpDic.Add("Default1", "A.SEGCODE"); + ItemOpDic.Add("Default2", "A.SEGNAME"); + ItemOpDic.Add("Default3", "A.CREWCODE"); + ItemOpDic.Add("Default4", "A.CREWNAME"); + ItemOpDic.Add("LastModificationTime", "GETDATE()");//操作时间 + ItemOpDic.Add("LastModifierUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + ItemOpDic.Add("LastModifierUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + itemOpSql += ICSHelper.UpdateSQL("b", ItemOpDic) + + "#TEMPITEMOP a" + + " INNER JOIN ICSITEMROUTE2OP b on a.ROUTECODE = b.ROUTECODE and A.ITEMCODE = B.ITEMCODE AND A.OPCODE = B.OPCODE AND b.TenantId = '{0}'"; + + ItemOpDic.Add("RouteCode", "A.RouteCode"); + ItemOpDic.Add("ItemCode", "A.ItemCode"); + ItemOpDic.Add("OpCode", "A.OpCode"); + ItemOpDic.Add("OpSeq", "A.OpSeq"); + ItemOpDic.Add("ITEMID", "A.ITEMID"); + ItemOpDic.Add("RouteId", "A.RouteId"); + ItemOpDic.Add("OpId", "A.OpId"); + ItemOpDic.Add("OPCONTROL", "'10000000'"); + ItemOpDic.Add("IdMergeRule", "'0'"); + ItemOpDic.Add("OpLevel", "'A'"); + ItemOpDic.Add("OpControlSeq", "A.OpSeq"); + ItemOpDic.Add("TenantId", "'" + TenantId + "'"); + ItemOpDic.Add("CreationTime", "GETDATE()");//操作时间 + ItemOpDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + ItemOpDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + + + itemOpSql += @" + DELETE ITEMOP + FROM ICSITEMROUTE2OP ITEMOP + LEFT JOIN ICSOP OP ON ITEMOP.OPID=OP.ID + LEFT JOIN + (SELECT item.Code+'_'+u9route.RoutingVersionCode+ '_'+cast(u9route.AlternateType as nvarchar) as U9RouteCode, + item.Code as itemcode, + opu9trl.Description+'_'+OPU9.Sequence as U9Opcode + FROM {1}.DBO.CBO_Routing u9route + LEFT JOIN {1}.DBO.CBO_Operation opu9 on opu9.Routing=u9route.ID + LEFT JOIN {1}.DBO.CBO_Operation_TRL opu9trl on opu9trl.ID=opu9.ID + LEFT JOIN {1}.DBO.CBO_ItemMaster item on u9route.ItemMaster=item.ID + WHERE u9route.org='{2}' + ) u9ItemOp on u9ItemOp.U9RouteCode=ITEMOP.ROUTECODE AND u9ItemOp.ITEMCODE=ITEMOP.itemcode AND u9ItemOp.U9Opcode=OP.DEFAULT1 + WHERE ITEMOP.TenantId='{0}' and u9ItemOp.U9RouteCode is null "; + + itemOpSql += ICSHelper.InsertSQL("ICSITEMROUTE2OP", ItemOpDic) + + @" #TEMPITEMOP a + LEFT JOIN ICSITEMROUTE2OP b on a.ROUTECODE=b.ROUTECODE and A.ITEMCODE=B.ITEMCODE AND A.OPCODE=B.OPCODE AND b.TenantId='{0}' + WHERE 1=1 and b.ID is null"; + + itemOpSql = string.Format(itemOpSql, TenantId, erpName, ErpId); + + itemOpSql += " DROP TABLE #TEMPITEMOP"; + + #endregion + + #region 工序资源 + string opResSql = ""; + count = 0; + var opResObj = table.AsEnumerable().Where(a => a["resCode"].ToString() != "").Select(a => new { RouteCode = a["ROUTECODE"].ToString(), Opcode = a["MesOpcode"].ToString(), Opseq = a["opseq"].ToString(), ItemCode = a["ItemCode"].ToString(), resCode = a["resCode"].ToString(), resName = a["resName"].ToString(), PerResUsage = a["PerResUsage"].ToString(), PerResOutput = a["PerResOutput"].ToString() }). + Distinct().ToList(); + opResObj.ForEach(b => { + count++; + + if (count != opResObj.Count) + opResSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.Opcode}' as Opcode,'{b.Opseq}' as Opseq,'{b.resCode}' as resCode,'{b.ItemCode}' as ItemCode,'{b.resName}' as resName,'{b.PerResUsage}' as PerResUsage,'{b.PerResOutput}' as PerResOutput union all"; + else + opResSql += $" SELECT '{b.RouteCode}' as RouteCode,'{b.Opcode}' as Opcode,'{b.Opseq}' as Opseq,'{b.resCode}' as resCode,'{b.ItemCode}' as ItemCode,'{b.resName}' as resName,'{b.PerResUsage}' as PerResUsage,'{b.PerResOutput}' as PerResOutput "; + + }); + + opResSql = $@"SELECT a.*,B.ID AS RouteId,c.id as OpId,d.id as ItemId,C.DEFAULT1 AS U9OPCODE INTO #TempOPRes FROM ({opResSql}) a + LEFT JOIN ICSROUTE b on b.RouteCODE=a.RouteCode and b.TenantId='{TenantId}' + LEFT JOIN ICSOP C ON C.OPCODE=A.OPCODE AND C.TenantId='{TenantId}' + LEFT JOIN IcsInventory D ON D.ItemCode=A.ItemCode AND D.TenantId='{TenantId}' + "; + Dictionary opResDic = new Dictionary(); + opResDic.Add("PerResUsage", "CAST(A.PerResUsage AS DECIMAL)"); + opResDic.Add("PerResOutput", "CAST(A.PerResOutput AS DECIMAL)"); + opResDic.Add("LastModificationTime", "GETDATE()");//操作时间 + opResDic.Add("LastModifierUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + opResDic.Add("LastModifierUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + opResSql += ICSHelper.UpdateSQL("b", opResDic) + + " #TempOPRes a" + + " INNER JOIN IcsOpResU9 b on a.ROUTECODE = b.ROUTECODE and A.ITEMCODE = B.ITEMCODE AND A.OPCODE = B.OPCODE AND A.ResCode=B.U9ResCode AND b.TenantId = '{0}'"; + + opResSql += @" + DELETE OPRES + FROM IcsOpResU9 OPRES + LEFT JOIN ICSOP OP ON OPRES.OPID=OP.ID + LEFT JOIN + (SELECT item.Code+'_'+u9route.RoutingVersionCode+ '_'+cast(u9route.AlternateType as nvarchar) as U9RouteCode, + item.Code as itemcode, + opu9trl.Description+'_'+OPU9.Sequence as U9Opcode, + u9Res.code as resCode + FROM {1}.DBO.CBO_Routing u9route + LEFT JOIN {1}.DBO.CBO_Operation opu9 on opu9.Routing=u9route.ID + LEFT JOIN {1}.DBO.CBO_ItemMaster item on u9route.ItemMaster=item.ID + LEFT JOIN {1}.DBO.CBO_OpResource opRes ON opRes.Operation=opu9.id + LEFT JOIN {1}.DBO.CBO_Operation_TRL opu9trl on opu9trl.ID=opu9.ID + LEFT JOIN {1}.DBO.CBO_Resource u9Res on u9Res.ID=opRes.Resource + WHERE u9route.org='{2}' + ) u9opres on u9opres.U9RouteCode=OPRES.ROUTECODE AND u9opres.ITEMCODE=OPRES.itemcode AND u9opres.U9Opcode=OP.DEFAULT1 and u9opres.rescode=OPRES.U9ResCode + WHERE OPRES.TenantId='{0}' and u9opres.U9Opcode is null "; + + opResDic.Add("RouteCode", "A.RouteCode"); + opResDic.Add("ItemCode", "A.ItemCode"); + opResDic.Add("u9Rescode", "A.Rescode"); + opResDic.Add("u9ResName", "A.ResName"); + opResDic.Add("OpCode", "A.OpCode"); + opResDic.Add("OpSeq", "A.OpSeq"); + opResDic.Add("ITEMID", "A.ITEMID"); + opResDic.Add("RouteId", "A.RouteId"); + opResDic.Add("OpId", "A.OpId"); + opResDic.Add("TenantId", "'" + TenantId + "'"); + opResDic.Add("CreationTime", "GETDATE()");//操作时间 + opResDic.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + opResDic.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + opResSql += ICSHelper.InsertSQL("IcsOpResU9", opResDic) + + " #TempOPRes a" + + " LEFT JOIN IcsOpResU9 b on a.ROUTECODE = b.ROUTECODE and A.ITEMCODE = B.ITEMCODE AND A.OPCODE = B.OPCODE AND A.ResCode=B.U9ResCode AND b.TenantId = '{0}' WHERE B.ID IS NULL "; + + opResSql = string.Format(opResSql, TenantId, erpName, ErpId); + + opResSql += " DROP TABLE #TempOPRes"; + #endregion + + log.Info("开始同步工序"); + ICSHelper.ExecuteDateNew(conStr, opsql); + log.Info("结束同步工序"); + + log.Info("开始同步途程"); + ICSHelper.ExecuteDateNew(conStr, routeSql); + log.Info("结束同步途程"); + + log.Info("开始同步途程关联工序"); + ICSHelper.ExecuteDateNew(conStr, routeOpSql); + log.Info("结束同步途程关联工序"); + + log.Info("开始同步物料关联途程"); + ICSHelper.ExecuteDateNew(conStr, itemRouteSql); + log.Info("结束同步物料关联途程"); + + log.Info("开始同步物料关联途程与工序"); + ICSHelper.ExecuteDateNew(conStr, itemOpSql); + log.Info("结束同步物料关联途程与工序"); + + log.Info("开始同步工序关联资源信息"); + ICSHelper.ExecuteDateNew(conStr, opResSql); + log.Info("结束同步工序关联资源信息"); + + var maxTime = table.AsEnumerable().Max(a => Convert.ToDateTime(a["RouteModifiedTime"])); + ICSHelper.UpdateTime(conStr, Namespace, Class, TenantId, maxTime); + + } + } + catch (Exception ex) + { + + throw ex; + } + + } + } +} diff --git a/ICSSoft.FromERP/IcsSBom.cs b/ICSSoft.FromERP/IcsSBom.cs index 5e078ec..f772a1b 100644 --- a/ICSSoft.FromERP/IcsSBom.cs +++ b/ICSSoft.FromERP/IcsSBom.cs @@ -59,7 +59,9 @@ A5.Description as 子阶料描述, A.FixedScrap as 固定损耗, isnull( A6.[Code],'') as 项目号, isnull( A.[ECNCode],'') as 工程变更号, - A.[UsageQty] as 子阶料计量数量, + A.[UsageQty], + a.ParentQty, + cast(isnull( A.[UsageQty],0)/isnull( a.ParentQty,1) as decimal(18,6)) 子阶料计量数量, A.[ItemVersionCode] as 子阶料物料版本, A.[EffectiveDate] as 生效日期, isnull( A.IsSpecialUseItem,'') as 管控类型, @@ -147,7 +149,7 @@ left join IcsMainCategoryCode d on c.ItemMainCategoryCode=d.ItemMainCategoryCode sql += " DROP TABLE #TempBOM " + "DROP TABLE #tableICSSBOM"; sql = string.Format(sql, TenantId, erpName, ErpId); - //return; + // return; ICSHelper.ExecuteDate(conStr, sql); #endregion } diff --git a/ICSSoft.FromERP/IcsSBom_Rhtyon.cs b/ICSSoft.FromERP/IcsSBom_Rhtyon.cs new file mode 100644 index 0000000..30cd933 --- /dev/null +++ b/ICSSoft.FromERP/IcsSBom_Rhtyon.cs @@ -0,0 +1,165 @@ +using Quartz; +using System; +using System.Collections.Generic; +using System.Data; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace ICSSoft.FromERP +{ + /// + /// 产品Bom(锐腾) + /// + public class IcsSBom_Rhtyon : 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 TenantId = dr["TenantId"].ToString(); + string TenantCode = dr["TenantCode"].ToString(); + string ErpId = dr["ErpID"].ToString(); //erpID + string Class = this.GetType().Name + TenantCode; + erpName = string.Format(erpName, TenantId); + #region SQL + string sql = @" select distinct A2.[ID] as 料品ID, + A2.[Code] as 料品编码, +A2.Name as 料品名称, +A4.Description as 料品描述, +A3.ID as 子阶料ID, + A3.[Code] as 子阶料编码, + A3.[Name] as 子阶料名称, +A5.Description as 子阶料描述, +A.FixedScrap as 固定损耗, +isnull( A6.[Code],'') as 项目号, + isnull( A.[ECNCode],'') as 工程变更号, + A.[UsageQty], + a.ParentQty, + cast(isnull( A.[UsageQty],0)/isnull( a.ParentQty,1) as decimal(18,6)) 子阶料计量数量, + A.[ItemVersionCode] as 子阶料物料版本, + A.[EffectiveDate] as 生效日期, + isnull( A.IsSpecialUseItem,'') as 管控类型, + A.[DisableDate] as 失效日期, + A.[Sequence] as 次序, + A.[IsEffective] as 有效, + A1.[BOMVersionCode] as 母料版本号, + A.[OperationNum] as 工序号 +,I.id as Org +,A.ModifiedOn as MTime +,A.ID as ErpDetailID + INTO #TempBOM +from {1}.dbo.CBO_BOMComponent as A +left join {1}.dbo.[CBO_BOMMaster] as A1 on (A.[BOMMaster] = A1.[ID]) +left join {1}.dbo.[CBO_ItemMaster] as A2 on (A1.[ItemMaster] = A2.[ID]) +left join {1}.dbo.[CBO_ItemMaster_Trl] as A4 on (A4.SysMlFlag = 'zh-CN') and (A2.[ID] = A4.[ID]) +left join {1}.dbo.[CBO_ItemMaster] as A3 on (A.[ItemMaster] = A3.[ID]) +left join {1}.dbo.[CBO_ItemMaster_Trl] as A5 on (A5.SysMlFlag = 'zh-CN') and (A3.[ID] = A5.[ID]) +left join {1}.dbo.[CBO_Project] as A6 on (A.[CompProject] = A6.[ID]) + LEFT JOIN {1}.dbo.[Base_Organization] AS I ON ( A1.[Org] = I.[ID] ) +LEFT JOIN {1}.dbo.[Base_Organization_Trl] AS J ON ( I.[ID] = J.[ID] AND J.SysMLFlag='zh-CN') +where 1=1 and IsEffective=1 and A.ModifiedOn>=@LastTime AND I.id={0} and A.ComponentType=0 and A1.AlternateType=0 + + IF NOT EXISTS(SELECT * FROM #TempBOM) + RETURN"; + + sql = string.Format(sql, ErpId, erpName); + sql = ICSHelper.Time(Namespace, Class, TenantId, sql, "#TempBOM"); + sql += "\r\n"; + sql += @"--删除数据 + -- DELETE ICSSBOM WHERE moOpComponentId NOT IN (SELECT OpComponentId FROM {1}.dbo.bom_opcomponent) +SELECT a.ErpId INTO #tableICSSBOM +FROM ICSSBOM a With(NoLock) +LEFT JOIN {1}.dbo.[CBO_BOMComponent] b With(NoLock) ON a.ErpId=b.Id +LEFT JOIN {1}.dbo.CBO_BOMMaster c With(NoLock) ON b.BOMMaster=c.Id +WHERE b.id is null +and a.TenantId='{0}' +AND c.Org={2} + + DELETE ICSSBOM + WHERE TenantId='{0}' and ErpId IN ( SELECT ErpId from #tableICSSBOM) +"; + Dictionary values = new Dictionary(); + values.Add("SBOMVER", "a.母料版本号"); + values.Add("ITEMCODE", "a.料品编码"); + values.Add("SBITEMCODE", "a.子阶料编码"); + values.Add("SBItemName", "a.子阶料名称"); + //values.Add("SBItemDesc", "a.子阶料描述"); + values.Add("SBSITEMCODE", "a.子阶料编码"); + values.Add("SBITEMQTY", "a.子阶料计量数量"); + values.Add("SEQ", "1"); + values.Add("SBItemECN", "a.工程变更号"); + values.Add("SBItemStatus", "'Y'"); + values.Add("SBItemEfftime", "a.生效日期"); + values.Add("SBItemInvtime", "a.失效日期"); + values.Add("SBItemProject", "a.项目号"); + values.Add("SBItemSeq", "a.次序"); + values.Add("Location", "a.工序号"); + values.Add("LastModificationTime", "a.Mtime");//操作时间 + values.Add("LastModifierUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + values.Add("LastModifierUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + values.Add("SBItemContype", "c.ItemContype"); + //更新存在数据 + sql += ICSHelper.UpdateSQL("b", values) + + @" #TempBOM a + INNER JOIN ICSSBOM b ON a.ErpDetailID=b.ErpId +left join IcsInventory c on b.SBItemCode=c.ItemCode and b.TenantId=c.TenantId +left join IcsMainCategoryCode d on c.ItemMainCategoryCode=d.ItemMainCategoryCode and c.TenantId=d.TenantId + WHERE b.TenantId='{0}' and a.Org={2} "; + + values.Add("ErpId", "convert(nvarchar(100), a.ErpDetailID)"); + values.Add("CreationTime", "a.MTime");//操作人 + values.Add("CreatorUserId", "'" + ConstWorkPoint.Muser + "'");//操作人 + values.Add("CreatorUserName", "'" + ConstWorkPoint.Musername + "'");//操作人名称 + values.Add("TenantId", "'" + TenantId + "'");//站点 + sql += "\r\n"; + //插入新增数据 + sql += ICSHelper.InsertSQL("ICSSBOM", values) + + @" #TempBOM a + LEFT JOIN ICSSBOM b ON a.ErpDetailID=b.ErpId and b.TenantId='{0}' +left join IcsInventory c on a.子阶料编码=c.ItemCode and c.TenantId='{0}' +left join IcsMainCategoryCode d on c.ItemMainCategoryCode=d.ItemMainCategoryCode and d.TenantId='{0}' + WHERE 1=1 and b.id is null + and a.Org={2} "; + sql += " DROP TABLE #TempBOM " + + "DROP TABLE #tableICSSBOM"; + sql = string.Format(sql, TenantId, erpName, ErpId); + // return; + ICSHelper.ExecuteDate(conStr, sql); + #endregion + } + } + catch (Exception ex) + { + log.Error(ex.ToString()); + } + } + + } +} diff --git a/Root/NPinyin.dll b/Root/NPinyin.dll new file mode 100644 index 0000000..9e7a4eb Binary files /dev/null and b/Root/NPinyin.dll differ