| | |
|---|
| | | case "TB_MESTOERP_SCDDXD"://推送审核送货单 |
|---|
| | | case "TB_MESTOERP_TransferIn"://分布式调入单 |
|---|
| | | case "TB_MESTOERP_ZJDB"://直接调拨单 |
|---|
| | | case "TB_MESTOERP_WWDDXD"://委外订单下达 |
|---|
| | | case "TB_MESTOERP_WWCG"://委外下推采购 |
|---|
| | | result = MesToErp(drSource, ref msg, rtaskid); |
|---|
| | | break; |
|---|
| | | case "TB_MESTOERP_GDRK"://ERP工单入库查询 |
|---|
| | |
|---|
| | | try |
|---|
| | | { |
|---|
| | | DataTable dt = ds.Tables[0]; |
|---|
| | | if (operatype == "INSERT") |
|---|
| | | if (operatype == "INSERT" || operatype == "UPDATE") |
|---|
| | | { |
|---|
| | | #region INSERT |
|---|
| | | //dt.Columns.Add("MAA005", typeof(string)); |
|---|
| | |
|---|
| | | GYS005='{5}', |
|---|
| | | FUseOrgld='{6}' |
|---|
| | | where ERPID='{0}'; ", dr["ERPID"] |
|---|
| | | , dr["GYS001"], dr["GYS002"], dr["GYS003"], dr["GYS004"], dr["GYS005"], dr["FUseOrgld"]); |
|---|
| | | , dr["GYSA001"], dr["GYSA002"], dr["GYSA003"], dr["GYSA004"], dr["GYSA005"], dr["FUseOrgld"]); |
|---|
| | | } |
|---|
| | | return _sqlHelper.ExecuteNonQuery(sql) > 0; |
|---|
| | | #endregion |
|---|
| | |
|---|
| | | { |
|---|
| | | if (dF["TLA020"].ToString().Contains("装配")) |
|---|
| | | { |
|---|
| | | if (dF["TLA023"].ToString().Contains("-")) |
|---|
| | | if (dF["TLA023"].ToString().Contains("*")) |
|---|
| | | { |
|---|
| | | string[] tr = dF["TLA023"].ToString().Split('*'); |
|---|
| | | |
|---|
| | | //int i = dF["TLA023"].ToString().LastIndexOf('-'); |
|---|
| | | string StrNew = tr[1].ToString();//dF["TLA023"].ToString().Substring(i + 1, 10); |
|---|
| | | string SQLT = string.Format(@"SELECT TOP 1 * FROM WOMCAA(NOLOCK) WHERE CAA018='{0}' ", StrNew); |
|---|
| | | DataTable CAA = _sqlHelper.ExecuteDataTable(SQLT); |
|---|
| | | if (CAA.Rows.Count > 0) |
|---|
| | | { |
|---|
| | | string UP = string.Format(@"UPDATE WOMCAA SET CAA016='{0}',CAA017='{1}',CAA018='{2}' WHERE CAA002='{3}' ", CAA.Rows[0]["CAA016"].ToString(), CAA.Rows[0]["CAA017"].ToString(), CAA.Rows[0]["CAA018"].ToString(), dF["TLA002"].ToString()); |
|---|
| | | _sqlHelper.ExecuteNonQuery(UP); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | else if (dF["TLA023"].ToString().Contains("-")) |
|---|
| | | { |
|---|
| | | string[] tr = dF["TLA023"].ToString().Split('-'); |
|---|
| | | |
|---|
| | |
|---|
| | | string res = a.Body(US).msg.ToString(); |
|---|
| | | |
|---|
| | | sql = string.Format(@" update sysdec set states='NEW' WHERE TASK_ID='{0}' ", rtaskid); |
|---|
| | | |
|---|
| | | _sqlHelper.ExecuteNonQuery(sql); |
|---|
| | | //string res = a.arg0.ws.MES_TO_ERP_DataTransport(task_name, descript, create_time, creator, operatype, source_table, target_table, data, data_inserted, data_deleted); |
|---|
| | | if (res.Contains("OK")) |
|---|
| | |
|---|
| | | colMapping[23] = new SqlBulkCopyColumnMapping("FHB022", "DFB022"); //出库下线 |
|---|
| | | colMapping[24] = new SqlBulkCopyColumnMapping("FHB023", "DFB023"); //是否控制出库数量 |
|---|
| | | colMapping[25] = new SqlBulkCopyColumnMapping("FHB024", "DFB024"); //累计出库数 |
|---|
| | | colMapping[26] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID |
|---|
| | | colMapping[26] = new SqlBulkCopyColumnMapping("FHB025", "DFB025"); //产品类型 |
|---|
| | | colMapping[27] = new SqlBulkCopyColumnMapping("FHB026", "DFB026"); //父标识 |
|---|
| | | colMapping[28] = new SqlBulkCopyColumnMapping("FHB027", "DFB027"); //标识列 |
|---|
| | | colMapping[29] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID |
|---|
| | | DataTableToSQLServer(dt, conStr, "COMDFB", colMapping, ref ErrorMsg); |
|---|
| | | #endregion |
|---|
| | | } |
|---|
