using ICSSoft.Common; using ICSSoft.Entity; using Newtonsoft.Json; using NFine.Code; using System; using System.Collections.Generic; using System.Data; using System.Data.SqlClient; using System.Linq; using System.Net.Http; using System.Text; using System.Threading.Tasks; namespace ICSSoft.DataProject { ///

/// 使用中 /// 提交业务处理 ///

public class ICSSubmitService { private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); private static string connString = System.Configuration.ConfigurationManager.AppSettings["ConnStr"]; #region 源头单据信息 ///

/// 源头单据信息 ///

/// /// public static DataTable TransInformationGet(WMSSourceDocumentModel JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; try { if (string.IsNullOrEmpty(JsonData.TransCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } else if (string.IsNullOrEmpty(JsonData.TransType)) { throw new Exception(language.GetNameByCode("WMSAPIInfo002"));//"单据类型不能为空！" } else if (!EnumHelper.HasDescriptions(typeof(TransTypeEnum), JsonData.TransType)) { throw new Exception(language.GetNameByCode("WMSAPIInfo003"));//"单据类型不存在！" } else if (string.IsNullOrEmpty(JsonData.WorkPoint)) { throw new Exception(language.GetNameByCode("WMSAPIInfo004"));//"站点不能为空！" } string TransType = JsonData.TransType; #region SLQ string sql = @"IF NOT EXISTS(SELECT a.ID FROM {1} WHERE {2}) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo035") + @"',16,1); RETURN END SELECT a.ID, {0} a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, a.WHCode, inv.AmountUnit, wh.WarehouseName AS WHName, ISNULL(ext.ProjectCode, '') AS ProjectCode, a.ExtensionID, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ISNULL(ext.BatchCode, '') ELSE '' END AS BatchCode, ISNULL(ext.Version, '') AS Version, ISNULL(ext.Brand, '') AS Brand, ISNULL(ext.cFree1, '') AS cFree1, ISNULL(ext.cFree2, '') AS cFree2, ISNULL(ext.cFree3, '') AS cFree3, ISNULL(ext.cFree4, '') AS cFree4, ISNULL(ext.cFree5, '') AS cFree5, ISNULL(ext.cFree6, '') AS cFree6, ISNULL(ext.cFree7, '') AS cFree7, ISNULL(ext.cFree8, '') AS cFree8, ISNULL(ext.cFree9, '') AS cFree9, ISNULL(ext.cFree10, '') AS cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM {1} INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint LEFT JOIN ICSWarehouse wh ON a.WHCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.WHCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint WHERE {2} "; #endregion bool isDeliveryNotice = false; //送货、到货、含委外 string columns = string.Empty; //查询源头单据表的特殊列名 string tableName = string.Empty; //查询源头单据表名 string where = string.Empty; //查询源头单据的过滤条件 #region 出库 #region 采购退货 if (TransType == TransTypeEnum.PurchaseReceiveDoctNegative.GetDescription()) { isDeliveryNotice = true; columns = @"a.DNCode AS TransCode, a.DNDetailID AS DetailID, a.DNType AS Type, a.Sequence AS TransSequence, a.RCVQuantity AS IssueQuantity, a.Quantity, a.Amount, a.MUSER AS [User], a.MTIME AS [MTime],"; tableName = @"ICSDeliveryNotice a "; where = @" a.DNCode='{0}' AND a.WorkPoint='{1}' AND a.DNType='2' "; } #endregion #region 委外发料 else if (TransType == TransTypeEnum.OutsourcingIssueDoc.GetDescription()) { columns = @"b.OOCode AS TransCode, a.PickID AS DetailID, a.SupplyType AS Type, b.Sequence+'-'+a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSOOPick a INNER JOIN ICSOutsourcingOrder b ON a.OODetailID=b.OODetailID AND a.WorkPoint=b.WorkPoint "; where = @" b.OOCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 委外退货 else if (TransType == TransTypeEnum.OutsourcingReturnBack.GetDescription()) { isDeliveryNotice = true; columns = @"a.ODNCode AS TransCode, a.ODNDetailID AS DetailID, a.ODNType AS Type, a.Sequence AS TransSequence, a.RCVQuantity AS IssueQuantity, a.Quantity, a.Amount, a.MUSER AS [User], a.MTIME AS [MTime],"; tableName = @"ICSODeliveryNotice a "; where = @" a.ODNCode='{0}' AND a.WorkPoint='{1}' AND a.ODNType='2' "; } #endregion #region 生产发料 else if (TransType == TransTypeEnum.MOIssueDoc.GetDescription()) { columns = @"b.MOCode AS TransCode, a.PickID AS DetailID, a.SupplyType AS Type, b.Sequence+'-'+a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSMOPick a INNER JOIN ICSMO b ON a.MODetailID=b.MODetailID AND a.WorkPoint=b.WorkPoint "; where = @" b.MOCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 销售出库 else if (TransType == TransTypeEnum.SalesShipmentDoc.GetDescription()) { columns = @"a.SDNCode AS TransCode, a.SDNDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.SDNQuantity AS IssueQuantity,"; tableName = @"ICSSDN a "; where = @" a.SDNCode='{0}' AND a.WorkPoint='{1}' AND a.Type='1' "; } #endregion #region 盘点 else if (TransType == TransTypeEnum.Check.GetDescription()) { #region SLQ sql = @"IF NOT EXISTS(SELECT a.ID FROM {1} WHERE {2}) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo035") + @"',16,1); RETURN END SELECT a.ID, {0} a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, a.WHCode, inv.AmountUnit, wh.WarehouseName AS WHName, a.MUSER AS [User], a.MTIME AS [MTime] FROM {1} INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint LEFT JOIN ICSWarehouse wh ON a.WHCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint WHERE {2} "; #endregion columns = @"a.CheckCode AS TransCode, a.ID AS DetailID, '' AS Type, row_number() OVER (ORDER BY a.InvCode) AS TransSequence, a.ActualQuantity AS IssueQuantity,"; tableName = @"ICSCheck a "; where = @" a.CheckCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 一步调拨 else if (TransType == TransTypeEnum.OneStepTransferDocIn.GetDescription()) { #region SLQ sql = @"IF NOT EXISTS(SELECT a.ID FROM {1} WHERE {2}) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo035") + @"',16,1); RETURN END SELECT a.ID, {0} a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, a.FromWarehouseCode AS WHCode, inv.AmountUnit, wh.WarehouseName AS WHName, a.ExtensionID, ext.ProjectCode, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM {1} INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint LEFT JOIN ICSWarehouse wh ON a.FromWarehouseCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.FromWarehouseCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint WHERE {2} "; #endregion columns = @"a.TransferNO AS TransCode, a.TransferDetailID AS DetailID, '' AS Type, a.Sequence AS TransSequence, a.TransferQuantity AS IssueQuantity, a.ToWarehouseCode,"; tableName = @"ICSTransfer a "; where = @" a.TransferNO='{0}' AND a.WorkPoint='{1}' AND a.Status='1' "; } #endregion #region 两步调出 else if (TransType == TransTypeEnum.TwoStepTransferDocOut.GetDescription()) { columns = @"a.OutCode AS TransCode, a.OutDetailID AS DetailID, '' AS Type, a.Sequence AS TransSequence, a.OutQuantity AS IssueQuantity,"; tableName = @"ICSOtherOut a INNER JOIN ICSTransfer tra ON a.TransferDetailID=tra.TransferDetailID AND a.WorkPoint=tra.WorkPoint "; where = @" a.OutCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 其他出库 else if (TransType == TransTypeEnum.OtherOutDoc.GetDescription()) { columns = @"a.OutCode AS TransCode, a.OutDetailID AS DetailID, '' AS Type, a.Sequence AS TransSequence, a.OutQuantity AS IssueQuantity,"; tableName = @"ICSOtherOut a "; where = @" a.OutCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 领料申请单发料 else if (TransType == TransTypeEnum.MOApply.GetDescription()) { columns = @"a.ApplyCode AS TransCode, a.ApplyDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSMOApply a "; where = @" a.ApplyCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 委外领料申请单发料 else if (TransType == TransTypeEnum.OOApply.GetDescription()) { columns = @"a.ApplyCode AS TransCode, a.ApplyDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSOApply a "; where = @" a.ApplyCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 开立材料出库 else if (TransType == TransTypeEnum.MOIssue.GetDescription()) { columns = @"a.IssueCode AS TransCode, a.IssueDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSMOIssue a "; where = @" a.IssueCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 开立委外材料出库 else if (TransType == TransTypeEnum.OOIssue.GetDescription()) { columns = @"a.IssueCode AS TransCode, a.IssueDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.IssueQuantity AS IssueQuantity,"; tableName = @"ICSOIssue a "; where = @" a.IssueCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 开立红字入库单 else if (TransType == TransTypeEnum.PurchaseReceive.GetDescription()) { columns = @"a.RCVCode AS TransCode, a.RCVDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.RCVQuantity AS IssueQuantity,"; tableName = @"ICSPurchaseReceive a "; where = @" a.RCVCode='{0}' AND a.WorkPoint='{1}' AND a.Type='2' "; } #endregion #region 开立委外红字入库单 else if (TransType == TransTypeEnum.OutsourcingReceiveDocNegative.GetDescription()) { columns = @"a.RCVCode AS TransCode, a.RCVDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.RCVQuantity AS IssueQuantity,"; tableName = @"ICSOutsourcingReceive a "; where = @" a.RCVCode='{0}' AND a.WorkPoint='{1}' AND a.Type='2' "; } #endregion #region 借用 else if (TransType == TransTypeEnum.BrrowDoc.GetDescription()) { columns = @"a.BrrowCode AS TransCode, a.BrrowDetailID AS DetailID, '' AS Type, a.Sequence AS TransSequence, a.BrrowQuantity AS IssueQuantity,"; tableName = @"ICSBrrow a "; where = @" a.BrrowCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 送货单 else if (TransType == TransTypeEnum.ASN.GetDescription()) { isDeliveryNotice = true; columns = @"asn.ASNCode AS TransCode, asn.ID AS DetailID, asn.LotNo, '' AS Type, asn.Sequence AS TransSequence, asn.DNQuantity AS IssueQuantity, asn.Quantity, asn.Quantity*a.AmountRate AS Amount, asn.MUSER AS [User], asn.MTIME AS [MTime],"; tableName = @"ICSInventoryLot a INNER JOIN ICSASNDetail asn ON a.LotNo=asn.LotNo AND a.WorkPoint=asn.WorkPoint "; where = @" asn.ASNCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 委外送货单 else if (TransType == TransTypeEnum.OASN.GetDescription()) { isDeliveryNotice = true; columns = @"asn.OASNCode AS TransCode, asn.ID AS DetailID, asn.LotNo, '' AS Type, asn.Sequence AS TransSequence, asn.ODNQuantity AS IssueQuantity, asn.Quantity, asn.Quantity*a.AmountRate AS Amount, asn.MUSER AS [User], asn.MTIME AS [MTime],"; tableName = @"ICSInventoryLot a INNER JOIN ICSOASNDetail asn ON a.LotNo=asn.LotNo AND a.WorkPoint=asn.WorkPoint "; where = @" asn.OASNCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #endregion #region 入库 #region 采购入库 else if (TransType == TransTypeEnum.PurchaseReceiveDoc.GetDescription()) { } #endregion #region 审核的到货单 else if (TransType == TransTypeEnum.DeliveryNotice.GetDescription()) { } #endregion #region 采购拒收 else if (TransType == TransTypeEnum.PurchaseRejectDoc.GetDescription()) { } #endregion #region 审核的委外到货单 else if (TransType == TransTypeEnum.ODeliveryNotice.GetDescription()) { } #endregion #region 委外拒收 else if (TransType == TransTypeEnum.OutsourcingRejectDoc.GetDescription()) { } #endregion #region 委外退料 else if (TransType == TransTypeEnum.ICSOutsourcingIssueDoNegative.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeApply.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeIssue.GetDescription()) { } #endregion #region 委外入库 else if (TransType == TransTypeEnum.OutsourcingReceiveDoc.GetDescription()) { } #endregion #region 生产退料 else if (TransType == TransTypeEnum.MOIssueDocNegative.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeApply.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeIssue.GetDescription()) { } #endregion #region 生产入库 else if (TransType == TransTypeEnum.ManufactureReceiveDoc.GetDescription()) { } #endregion #region 开立的生产入库单 else if (TransType == TransTypeEnum.ManufactureReceive.GetDescription()) { } #endregion #region 销售退货 else if (TransType == TransTypeEnum.SalesShipmentDocNegative.GetDescription()) { } #endregion #region 两步调入 else if (TransType == TransTypeEnum.TwoStepTransferDocIn.GetDescription()) { columns = @"a.InCode AS TransCode, a.InDetailID AS DetailID, '' AS Type, a.Sequence AS TransSequence, a.InQuantity AS IssueQuantity,"; tableName = @"ICSOtherIn a INNER JOIN ICSTransfer tra ON a.TransferDetailID=tra.TransferDetailID AND a.WorkPoint=tra.WorkPoint "; where = @" a.InCode='{0}' AND a.WorkPoint='{1}' "; } #endregion #region 销售退货-原条码 else if (TransType == TransTypeEnum.SalesReturnBack.GetDescription()) { columns = @"a.SDNCode AS TransCode, a.SDNDetailID AS DetailID, a.Type, a.Sequence AS TransSequence, a.SDNQuantity AS IssueQuantity,"; tableName = @"ICSSDN a "; where = @" a.SDNCode='{0}' AND a.WorkPoint='{1}' AND a.Type='2' "; } #endregion #region 其他入库 else if (TransType == TransTypeEnum.OtherInDoc.GetDescription()) { } #endregion #region 拆卸单 else if (TransType == TransTypeEnum.DisassemblyDoc.GetDescription()) { columns = @"a.DABDOCCode AS TransCode, a.DABDOCDetailID AS DetailID, a.DABDOCType AS Type, a.Sequence AS TransSequence, a.DABDOCQuantity AS IssueQuantity,"; tableName = @"ICSDisassemblyDoc a"; where = @" a.DABDOCCode='{0}' AND a.WorkPoint='{1}' AND a.DABDOCType='2' "; } #endregion #region 归还 else if (TransType == TransTypeEnum.ReturnDoc.GetDescription()) { } #endregion #endregion if (string.IsNullOrWhiteSpace(columns) || string.IsNullOrWhiteSpace(tableName) || string.IsNullOrWhiteSpace(where)) throw new Exception(language.GetNameByCode("WMSAPIInfo003")); if (isDeliveryNotice) { #region SLQ sql = @"IF NOT EXISTS(SELECT a.ID FROM {1} WHERE {2}) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo035") + @"',16,1); RETURN END SELECT a.ID, {0} a.InvCode, inv.InvName, inv.InvStd, inv.InvUnit, '' AS WHCode, inv.AmountUnit, '' AS WHName, a.ExtensionID, ext.ProjectCode, CASE WHEN ISNULL(inv.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10 FROM {1} INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE {2} "; #endregion } where = string.Format(where, JsonData.TransCode, JsonData.WorkPoint); sql = string.Format(sql, columns, tableName, where, JsonData.TransCode); DataTable table = DBHelper.SQlReturnData(sql, cmd); return table; } catch (Exception ex) { log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 条码信息 ///

/// 条码信息 ///

/// /// public static Result BarCodeInformationGet(BarCodeModel JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; try { if (string.IsNullOrEmpty(JsonData.Code)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"条码不能为空！" } else if (string.IsNullOrEmpty(JsonData.TransType)) { throw new Exception(language.GetNameByCode("WMSAPIInfo002"));//"单据类型不能为空！" } else if (!EnumHelper.HasDescriptions(typeof(TransTypeEnum), JsonData.TransType)) { throw new Exception(language.GetNameByCode("WMSAPIInfo003"));//"单据类型不存在！" } else if (string.IsNullOrEmpty(JsonData.WorkPoint)) { throw new Exception(language.GetNameByCode("WMSAPIInfo004"));//"站点不能为空！" } string TransType = JsonData.TransType; #region SLQ string sql = @" SELECT a.ID, con.ContainerCode, con.ContainerName, a.LotNo, a.InvCode, inv.InvName, inv.InvStd, inv.InvUnit, {0} inv.AmountUnit, ext.ID AS ExtensionID, ext.ProjectCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM {1} LEFT JOIN ICSContainerLot conlot ON a.LotNo=conlot.LotNo AND a.WorkPoint=conlot.WorkPoint LEFT JOIN ICSContainer con ON conlot.ContainerID=con.ID AND conlot.WorkPoint=con.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.LotNo='{2}' AND a.WorkPoint='{3}' "; #endregion bool isOut = false; //出库标记 string columns = string.Empty; //查询源头单据表的特殊列名 string tableName = string.Empty; //查询源头单据表名 if (TransType == TransTypeEnum.PurchaseReceiveDoctNegative.GetDescription() //采购退货 || TransType == TransTypeEnum.OutsourcingIssueDoc.GetDescription() //委外发料 || TransType == TransTypeEnum.OutsourcingReturnBack.GetDescription() //委外退货 || TransType == TransTypeEnum.MOIssueDoc.GetDescription() //生产发料 || TransType == TransTypeEnum.SalesShipmentDoc.GetDescription() //销售出库 || TransType == TransTypeEnum.OneStepTransferDocIn.GetDescription() //一步调拨 || TransType == TransTypeEnum.TwoStepTransferDocOut.GetDescription() //两步调出 || TransType == TransTypeEnum.OtherOutDoc.GetDescription() //其他出库 || TransType == TransTypeEnum.Check.GetDescription() //盘点 || TransType == TransTypeEnum.MOApply.GetDescription() //领料申请单 || TransType == TransTypeEnum.OOApply.GetDescription() //委外领料申请单 || TransType == TransTypeEnum.MOIssue.GetDescription() //开立材料出库单 || TransType == TransTypeEnum.OOIssue.GetDescription() //开立委外材料出库单 || TransType == TransTypeEnum.PurchaseReceive.GetDescription() //开立红字入库单 || TransType == TransTypeEnum.OutsourcingReceiveDocNegative.GetDescription()//开立委外红字入库单 || TransType == TransTypeEnum.BrrowDoc.GetDescription() //借用 || TransType == TransTypeEnum.TransferLibrary.GetDescription() //移库 ) { isOut = true; } //两步调入条码 if (TransType == TransTypeEnum.TwoStepTransferDocIn.GetDescription()) { if (string.IsNullOrEmpty(JsonData.TransCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSOtherIn Otin INNER JOIN ICSTransfer tra ON Otin.TransferDetailID=tra.TransferDetailID AND Otin.WorkPoint=tra.WorkPoint INNER JOIN ICSOtherOut out ON out.TransferDetailID=tra.TransferDetailID AND out.WorkPoint=tra.WorkPoint INNER JOIN ICSWareHouseLotInfoLog log ON out.OutCode=log.TransCode AND out.Sequence=log.TransSequence AND out.WorkPoint=log.WorkPoint INNER JOIN ICSWareHouseLotInfo a ON a.LotNo=log.LotNo AND a.WorkPoint=log.WorkPoint WHERE a.LotNo='{2}' AND a.WorkPoint='{3}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo036") + @"',16,1); RETURN END " + sql + "AND Otin.InCode = '" + JsonData.TransCode + "'" + @"GROUP BY a.ID,con.ContainerCode,con.ContainerName,a.LotNo,a.InvCode,inv.InvName,inv.InvStd,inv.InvUnit,a.WarehouseCode, wh.WarehouseName,a.LocationCode,loc.LocationName,CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END,inv.AmountUnit, ext.ProjectCode,ext.Version,ext.Brand,ext.cFree1,ext.cFree2,ext.cFree3,ext.cFree4,ext.cFree5,ext.cFree6,ext.cFree7,ext.cFree8,ext.cFree9,ext.cFree10,a.MUSER,a.MTIME"; columns = @"SUM(log.Quantity) AS Quantity, SUM(log.Quantity*lot.AmountRate) AS Amount, a.WarehouseCode AS WHCode, wh.WarehouseName AS WHName, a.LocationCode, loc.LocationName, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode,"; tableName = @"ICSOtherIn Otin INNER JOIN ICSTransfer tra ON Otin.TransferDetailID=tra.TransferDetailID AND Otin.WorkPoint=tra.WorkPoint INNER JOIN ICSOtherOut out ON out.TransferDetailID=tra.TransferDetailID AND out.WorkPoint=tra.WorkPoint INNER JOIN ICSWareHouseLotInfoLog log ON out.OutCode=log.TransCode AND out.Sequence=log.TransSequence AND out.WorkPoint=log.WorkPoint INNER JOIN ICSWareHouseLotInfo a ON a.LotNo=log.LotNo AND a.WorkPoint=log.WorkPoint INNER JOIN ICSInventoryLot lot ON a.LotNo=lot.LotNo AND a.WorkPoint=lot.WorkPoint INNER JOIN ICSExtension ext ON lot.ExtensionID=ext.ID AND lot.WorkPoint=ext.WorkPoint INNER JOIN ICSWarehouse wh ON a.WarehouseCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON a.LocationCode=loc.LocationCode AND a.WorkPoint=loc.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.WarehouseCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint"; } //销售退货-原条码 if (TransType == TransTypeEnum.SalesReturnBack.GetDescription()) { if (string.IsNullOrEmpty(JsonData.TransCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSSDN sdn INNER JOIN ICSWareHouseLotInfoLog log ON sdn.SDNCode=log.TransCode AND sdn.Sequence=log.TransSequence AND sdn.WorkPoint=log.WorkPoint INNER JOIN ICSWareHouseLotInfo a ON a.LotNo=log.LotNo AND a.WorkPoint=log.WorkPoint WHERE a.LotNo='{2}' AND a.WorkPoint='{3}' AND sdn.Type='1') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo037") + @"',16,1); RETURN END " + sql + "AND sdn.SDNCode = '" + JsonData.TransCode + "'" + @"GROUP BY a.ID,con.ContainerCode,con.ContainerName,a.LotNo,a.InvCode,inv.InvName,inv.InvStd,inv.InvUnit,a.WarehouseCode, wh.WarehouseName,a.LocationCode,loc.LocationName,CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END,inv.AmountUnit, ext.ProjectCode,ext.Version,ext.Brand,ext.cFree1,ext.cFree2,ext.cFree3,ext.cFree4,ext.cFree5,ext.cFree6,ext.cFree7,ext.cFree8,ext.cFree9,ext.cFree10,a.MUSER,a.MTIME"; columns = @"SUM(log.Quantity) AS Quantity, SUM(log.Quantity*lot.AmountRate) AS Amount, a.WarehouseCode AS WHCode, wh.WarehouseName AS WHName, a.LocationCode, loc.LocationName, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode,"; tableName = @"ICSSDN sdn INNER JOIN ICSWareHouseLotInfoLog log ON sdn.SDNCode=log.TransCode AND sdn.Sequence=log.TransSequence AND sdn.WorkPoint=log.WorkPoint INNER JOIN ICSWareHouseLotInfo a ON a.LotNo=log.LotNo AND a.WorkPoint=log.WorkPoint INNER JOIN ICSInventoryLot lot ON a.LotNo=lot.LotNo AND a.WorkPoint=lot.WorkPoint INNER JOIN ICSExtension ext ON lot.ExtensionID=ext.ID AND lot.WorkPoint=ext.WorkPoint INNER JOIN ICSWarehouse wh ON a.WarehouseCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON a.LocationCode=loc.LocationCode AND a.WorkPoint=loc.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.WarehouseCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint"; } //分批 else if (TransType == TransTypeEnum.LOTSplit.GetDescription()) { sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSWareHouseLotInfo a WHERE a.LotNo='{2}' AND a.WorkPoint='{3}' AND a.Quantity>0) BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo038"), "{2}") + @"',16,1); RETURN END " + sql; columns = @"a.Quantity, a.Quantity*lot.AmountRate AS Amount, a.WarehouseCode AS WHCode, wh.WarehouseName AS WHName, a.LocationCode, loc.LocationName, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode, ISNULL(split.SplitLotNo, a.LotNo+'-1') AS SplitLotNo,"; tableName = @"ICSWareHouseLotInfo a INNER JOIN ICSInventoryLot lot ON a.LotNo=lot.LotNo AND a.WorkPoint=lot.WorkPoint INNER JOIN ICSExtension ext ON lot.ExtensionID=ext.ID AND lot.WorkPoint=ext.WorkPoint INNER JOIN ICSWarehouse wh ON a.WarehouseCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON a.LocationCode=loc.LocationCode AND a.WorkPoint=loc.WorkPoint LEFT JOIN (SELECT EATTRIBUTE1 AS LotNo,WorkPoint,EATTRIBUTE1+'-'+CAST((MAX(CAST(SUBSTRING(LotNo, CHARINDEX('-', LotNo)+1, LEN(LotNo)-CHARINDEX('-', LotNo)) AS INT))+1) AS VARCHAR) AS SplitLotNo FROM ICSInventoryLot GROUP BY EATTRIBUTE1,WorkPoint) split ON a.LotNo=split.LotNo AND a.WorkPoint=split.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.WarehouseCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint"; } //出库条码 else if (isOut) { sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSWareHouseLotInfo a WHERE a.LotNo='{2}' AND a.WorkPoint='{3}' AND a.Quantity>0) BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo038"), "{2}") + @"',16,1); RETURN END " + sql; columns = @"a.Quantity, a.Quantity*lot.AmountRate AS Amount, a.WarehouseCode AS WHCode, wh.WarehouseName AS WHName, a.LocationCode, loc.LocationName, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode,"; tableName = @"ICSWareHouseLotInfo a INNER JOIN ICSInventoryLot lot ON a.LotNo=lot.LotNo AND a.WorkPoint=lot.WorkPoint INNER JOIN ICSExtension ext ON lot.ExtensionID=ext.ID AND lot.WorkPoint=ext.WorkPoint INNER JOIN ICSWarehouse wh ON a.WarehouseCode=wh.WarehouseCode AND a.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON a.LocationCode=loc.LocationCode AND a.WorkPoint=loc.WorkPoint LEFT JOIN ICSInventoryBatchEnable invBat ON a.InvCode=invBat.InvCode AND a.WarehouseCode=invBat.WHCode AND a.WorkPoint=invBat.WorkPoint"; } //入库条码 else { sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSInventoryLot a WHERE a.LotNo='{2}' AND a.WorkPoint='{3}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo038"), "{2}") + @"',16,1); RETURN END IF EXISTS(SELECT a.ID FROM ICSWareHouseLotInfo a WHERE a.LotNo='{2}' AND a.WorkPoint='{3}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo039") + @"',16,1); RETURN END IF EXISTS(SELECT a.ID FROM ICSInventoryLot a INNER JOIN ICSInventory b ON a.InvCode=b.InvCode AND a.WorkPoint=b.WorkPoint LEFT JOIN ICSInspection ins ON a.LotNo=ins.LotNo AND a.WorkPoint=ins.WorkPoint WHERE a.LotNo='{2}' AND a.WorkPoint='{3}' AND (b.InvIQC='1'AND ins.LotNo IS NULL)) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo040") + @"',16,1); RETURN END " + sql; columns = @"ISNULL(ins.QualifiedQuantity+ins.WaiveQuantity, a.Quantity) AS Quantity, a.Quantity*a.AmountRate AS Amount, '' AS WHCode, '' AS WHName, '' AS LocationCode, '' AS LocationName, ext.BatchCode AS BatchCode,"; tableName = @"ICSInventoryLot a INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint LEFT JOIN ICSInspection ins ON a.LotNo=ins.LotNo AND a.WorkPoint=ins.WorkPoint"; } if (string.IsNullOrWhiteSpace(columns) || string.IsNullOrWhiteSpace(tableName)) throw new Exception(language.GetNameByCode("WMSAPIInfo003")); sql = string.Format(sql, columns, tableName, JsonData.Code, JsonData.WorkPoint); DataTable table = DBHelper.SQlReturnData(sql, cmd); if (table == null || table.Rows.Count <= 0) throw new Exception(language.GetNameByCode("WMSAPIInfo008"));//"未查询到条码数据！" #region 出库检验是否符合源头单据 string msg = string.Empty; bool isLimit = false; if (isOut && TransType != TransTypeEnum.TransferLibrary.GetDescription() && TransType != TransTypeEnum.LOTSplit.GetDescription()) { if (string.IsNullOrEmpty(JsonData.TransCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } WMSSourceDocumentModel model = new WMSSourceDocumentModel(); model.TransCode = JsonData.TransCode; model.TransType = JsonData.TransType; model.WorkPoint = JsonData.WorkPoint; DataTable TransData = TransInformationGet(model); DataView dataView = TransData.DefaultView; foreach (DataRow drLot in table.Rows) { string Lot = drLot["LotNo"].ToString(); string rowFilter = "InvCode='" + drLot["InvCode"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo041"), Lot, drLot["InvCode"])); rowFilter += " AND (LEN(ISNULL(WHCode,''))<=0 OR (LEN(ISNULL(WHCode,''))>0 AND WHCode='" + drLot["WHCode"] + "'))"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo043"), Lot, drLot["WHCode"])); //盘点不需要对比以下属性 if (TransType == TransTypeEnum.Check.GetDescription()) continue; rowFilter += " AND ProjectCode='" + drLot["ProjectCode"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo043"), Lot, drLot["ProjectCode"])); rowFilter += " AND BatchCode='" + drLot["BatchCode"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo044"), Lot, drLot["BatchCode"])); rowFilter += " AND Version='" + drLot["Version"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo045"), Lot, drLot["Version"])); rowFilter += " AND Brand='" + drLot["Brand"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo046"), Lot, drLot["Brand"])); rowFilter += " AND cFree1='" + drLot["cFree1"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo047"), Lot, drLot["cFree1"])); rowFilter += " AND cFree2='" + drLot["cFree2"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo048"), Lot, drLot["cFree2"])); rowFilter += " AND cFree3='" + drLot["cFree3"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo049"), Lot, drLot["cFree3"])); rowFilter += " AND cFree4='" + drLot["cFree4"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo050"), Lot, drLot["cFree4"])); rowFilter += " AND cFree5='" + drLot["cFree5"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo051"), Lot, drLot["cFree5"])); rowFilter += " AND cFree6='" + drLot["cFree6"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo052"), Lot, drLot["cFree6"])); rowFilter += " AND cFree7='" + drLot["cFree7"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo053"), Lot, drLot["cFree7"])); rowFilter += " AND cFree8='" + drLot["cFree8"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo054"), Lot, drLot["cFree8"])); rowFilter += " AND cFree9='" + drLot["cFree9"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo055"), Lot, drLot["cFree9"])); rowFilter += " AND cFree10='" + drLot["cFree10"] + "'"; CheckTrans(dataView, rowFilter, string.Format(language.GetNameByCode("WMSAPIInfo056"), Lot, drLot["cFree10"])); //保质期管理 var resultEffective = Effective(Lot, JsonData.WorkPoint, cmd, language); //0 - 已经是最早的批次 //1 - 不管控 //2 - 提醒 //3 - 限制 if (resultEffective == "2") { msg += string.Format(language.GetNameByCode("WMSAPIInfo181"), Lot) + Environment.NewLine; } else if (resultEffective == "3") { msg += string.Format(language.GetNameByCode("WMSAPIInfo182"), Lot) + Environment.NewLine; isLimit = true; } //先进先出判断 var result = CanOut(Lot, JsonData.WorkPoint, JsonData.ScanLotCode, cmd, language); //0 - 已经是最早的批次 //1 - 不管控 //2 - 提醒 //3 - 限制 if (result == "2") { msg += string.Format(language.GetNameByCode("WMSAPIInfo178"), Lot) + Environment.NewLine; } else if (result == "3") { msg += string.Format(language.GetNameByCode("WMSAPIInfo179"), Lot) + Environment.NewLine; isLimit = true; } } } #endregion //return table; Result res = new Result(); res.Success = true; res.Message = msg;// "接口调用成功！"; if (!isLimit) res.Data = table; return res; //出库时 //Message无值、Data有值，可直接处理 //Message有值、Data有值，弹出提醒框（可点击确定、取消，确定后继续出库，取消后不处理这批条码），显示Message信息 //Message有值、Data无值，弹出警告框（只能点击确定，且不处理这批条码），显示Message信息 } catch (Exception ex) { log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 校验条码对应的物料、自由项等信息是否与源头单据匹配 ///

private static void CheckTrans(DataView dataView, string rowFilter, string message) { dataView.RowFilter = rowFilter; if (dataView == null || dataView.Count <= 0) throw new Exception(message); } #endregion ///

/// 上架 ///

BusinessCode,TransType 两个类型 /// /// public static DataTable LOTStockCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string TransType = string.Empty; string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { TransType = item.TransType; if (!EnumHelper.HasDescriptions(typeof(TransTypeEnum), TransType)) { throw new Exception(LanguageHelper.GetNameSingle("WMSAPIInfo003"));//"单据类型不存在！" } string WHTransType = "2"; string BusinessCode = string.Empty; foreach (var itemInfo in item.detail) { #region 两步调入 if (TransType == TransTypeEnum.TwoStepTransferDocIn.GetDescription()) { //更新源头单据数量 ICSWareHouseService.TwoStepTransferDocIn(itemInfo.TransCode, itemInfo.TransSequence, itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); //入库 ICSWareHouseLotInfoService.WareHouseLotInfoTwoStepTransferDocIn(Identification, itemInfo.TransCode, itemInfo.TransSequence, itemInfo.WarehouseCode, itemInfo.LocationCode, itemInfo.LotNo, itemInfo.Quantity, item.User, item.WorkPoint, "6", TransTypeEnum.TwoStepTransferDocIn.GetDescription(), cmd, language); } #endregion else { #region 采购入库 if (TransType == TransTypeEnum.PurchaseReceiveDoc.GetDescription()) { //更新源头单据数量 ICSPurchaseService.PurchaseReceiveDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.PurchaseReceiveDoc.GetDescription(); } #endregion #region 审核的到货单 else if (TransType == TransTypeEnum.DeliveryNotice.GetDescription()) { //更新源头单据数量 ICSPurchaseService.DeliveryNoticeIn(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.DeliveryNotice.GetDescription(); } #endregion #region 采购拒收 else if (TransType == TransTypeEnum.PurchaseRejectDoc.GetDescription()) { //更新源头单据数量 ICSPurchaseService.PurchaseRejectDocIn(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.PurchaseRejectDoc.GetDescription(); } #endregion #region 审核的委外到货单 else if (TransType == TransTypeEnum.ODeliveryNotice.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.ODeliveryNoticeIn(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.ODeliveryNotice.GetDescription(); } #endregion #region 委外拒收 else if (TransType == TransTypeEnum.OutsourcingRejectDoc.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingRejectDocIn(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.OutsourcingRejectDoc.GetDescription(); } #endregion #region 委外退料 else if (TransType == TransTypeEnum.ICSOutsourcingIssueDoNegative.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeApply.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeIssue.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingIssueDoNegative(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.ICSOutsourcingIssueDoNegative.GetDescription(); } #endregion #region 委外入库 else if (TransType == TransTypeEnum.OutsourcingReceiveDoc.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingReceiveDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.OutsourcingReceiveDoc.GetDescription(); } #endregion #region 生产退料 else if (TransType == TransTypeEnum.MOIssueDocNegative.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeApply.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeIssue.GetDescription()) { //更新源头单据数量 ICSManufactureService.MOIssueDocNegative(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.MOIssueDocNegative.GetDescription(); } #endregion #region 生产入库 else if (TransType == TransTypeEnum.ManufactureReceiveDoc.GetDescription()) { //更新源头单据数量 ICSManufactureService.ManufactureReceiveDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.ManufactureReceiveDoc.GetDescription(); } #endregion #region 开立的生产入库单 else if (TransType == TransTypeEnum.ManufactureReceive.GetDescription()) { //更新源头单据数量 ICSManufactureService.ManufactureReceive(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.ManufactureReceive.GetDescription(); } #endregion #region 销售退货 else if (TransType == TransTypeEnum.SalesShipmentDocNegative.GetDescription()) { //更新源头单据数量 ICSSalesService.SalesShipmentDocNegative(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.SalesShipmentDocNegative.GetDescription(); } #endregion #region 其他入库 else if (TransType == TransTypeEnum.OtherInDoc.GetDescription()) { //更新源头单据数量 ICSWareHouseService.OtherInDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.OtherInDoc.GetDescription(); } #endregion #region 拆卸单 else if (TransType == TransTypeEnum.DisassemblyDoc.GetDescription()) { ICSWareHouseService.DisassemblyDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); WHTransType = "11"; BusinessCode = TransTypeEnum.DisassemblyDoc.GetDescription(); } #endregion #region 归还 else if (TransType == TransTypeEnum.ReturnDoc.GetDescription()) { //更新源头单据数量 ICSWareHouseService.ReturnDoc(itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); BusinessCode = TransTypeEnum.ReturnDoc.GetDescription(); } #endregion #region 销售退货-原条码 else if (TransType == TransTypeEnum.SalesReturnBack.GetDescription()) { //更新源头单据数量 ICSSalesService.SalesReturnBackIn(itemInfo.TransCode, itemInfo.TransSequence, itemInfo.LotNo, itemInfo.Quantity, item.WorkPoint, cmd, language); //入库 BusinessCode = TransTypeEnum.SalesReturnBack.GetDescription(); } #endregion //入库 ICSWareHouseLotInfoService.WareHouseLotInfoUp(Identification, itemInfo.LocationCode, itemInfo.LotNo, itemInfo.Quantity, item.User, item.WorkPoint, WHTransType, BusinessCode, cmd, language); } } #region 拆卸单 if (TransType == TransTypeEnum.DisassemblyDoc.GetDescription()) { //更新套件锁定数量 ICSWareHouseService.DisassemblyDoc(Identification, cmd, language); } #endregion} } //上传ERP if (Convert.ToBoolean(System.Configuration.ConfigurationManager.AppSettings["UploadERP"])) { //采购入库 if (TransType == TransTypeEnum.PurchaseReceiveDoc.GetDescription()) ICSPurchaseService.PurchaseReceiveDocERP(TransType, Identification, cmd, language); //审核的到货单 else if (TransType == TransTypeEnum.DeliveryNotice.GetDescription()) ICSPurchaseService.DeliveryNoticeInERP(TransType, Identification, cmd, language); //采购拒收 else if (TransType == TransTypeEnum.PurchaseRejectDoc.GetDescription()) ICSPurchaseService.PurchaseRejectDocInERP(TransType, Identification, cmd, language); //审核的委外到货单 else if (TransType == TransTypeEnum.ODeliveryNotice.GetDescription()) ICSOutsourcingService.ODeliveryNoticeInERP(TransType, Identification, cmd, language); //委外拒收 else if (TransType == TransTypeEnum.OutsourcingRejectDoc.GetDescription()) ICSOutsourcingService.OutsourcingRejectDocInERP(TransType, Identification, cmd, language); //委外退料 else if (TransType == TransTypeEnum.ICSOutsourcingIssueDoNegative.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeApply.GetDescription() || TransType == TransTypeEnum.ICSOutsourcingIssueDoNegativeIssue.GetDescription()) ICSOutsourcingService.OutsourcingIssueDoNegativeERP(TransType, Identification, cmd, language); //委外入库 else if (TransType == TransTypeEnum.OutsourcingReceiveDoc.GetDescription()) ICSOutsourcingService.OutsourcingReceiveDocERP(TransType, Identification, cmd, language); //生产退料 else if (TransType == TransTypeEnum.MOIssueDocNegative.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeApply.GetDescription() || TransType == TransTypeEnum.MOIssueDocNegativeIssue.GetDescription()) ICSManufactureService.MOIssueDocNegativeERP(TransType, Identification, cmd, language); //生产入库 else if (TransType == TransTypeEnum.ManufactureReceiveDoc.GetDescription()) ICSManufactureService.ManufactureReceiveDocERP(TransType, Identification, cmd, language); //开立的生产入库单 else if (TransType == TransTypeEnum.ManufactureReceive.GetDescription()) ICSManufactureService.ManufactureReceiveERP(TransType, Identification, cmd, language); //销售退货 else if (TransType == TransTypeEnum.SalesShipmentDocNegative.GetDescription()) ICSSalesService.SalesShipmentDocNegativeERP(TransType, Identification, cmd, language); //两步调入 else if (TransType == TransTypeEnum.TwoStepTransferDocIn.GetDescription()) ICSWareHouseService.TwoStepTransferDocInERP(TransType, Identification, cmd, language); //销售退货-原条码 else if (TransType == TransTypeEnum.SalesReturnBack.GetDescription()) ICSSalesService.SalesReturnBackInERP(TransType, Identification, cmd, language); //其他入库 else if (TransType == TransTypeEnum.OtherInDoc.GetDescription()) ICSWareHouseService.OtherInDocERP(TransType, Identification, cmd, language); //拆卸单 if (TransType == TransTypeEnum.DisassemblyDoc.GetDescription()) ICSWareHouseService.DisassemblyDocERP(TransType, Identification, cmd, language); //归还 else if (TransType == TransTypeEnum.ReturnDoc.GetDescription()) ICSWareHouseService.ReturnDocERP(TransType, Identification, cmd, language); } DataTable table = GetData(Identification, 1, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 下架 ///

/// /// public static DataTable LOTStockDownCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } List model = new List(); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string TransType = string.Empty; string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { TransType = item.TransType; if (!EnumHelper.HasDescriptions(typeof(TransTypeEnum), TransType)) { throw new Exception(LanguageHelper.GetNameSingle("WMSAPIInfo003"));//"单据类型不存在！" } #region 采购退货 if (TransType == TransTypeEnum.PurchaseReceiveDoctNegative.GetDescription()) { //更新源头单据数量 ICSPurchaseService.PurchaseReceiveDoctNegative(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.PurchaseReceiveDoctNegative.GetDescription(), cmd, language); } } #endregion #region 委外发料 else if (TransType == TransTypeEnum.OutsourcingIssueDoc.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingIssueDoc(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OutsourcingIssueDoc.GetDescription(), cmd, language); } } #endregion #region 委外退货 else if (TransType == TransTypeEnum.OutsourcingReturnBack.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingReturnBack(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OutsourcingReturnBack.GetDescription(), cmd, language); } } #endregion #region 生产发料 else if (TransType == TransTypeEnum.MOIssueDoc.GetDescription()) { //更新源头单据数量 ICSManufactureService.MOIssueDoc(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.MOIssueDoc.GetDescription(), cmd, language); } } #endregion #region 销售出库 else if (TransType == TransTypeEnum.SalesShipmentDoc.GetDescription()) { //更新源头单据数量 ICSSalesService.SalesShipmentDoc(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.SalesShipmentDoc.GetDescription(), cmd, language); } } #endregion #region 两步调出 else if (TransType == TransTypeEnum.TwoStepTransferDocOut.GetDescription()) { //更新源头单据数量 ICSWareHouseService.TwoStepTransferDocOut(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "6", TransTypeEnum.TwoStepTransferDocOut.GetDescription(), cmd, language); } } #endregion #region 其他出库 else if (TransType == TransTypeEnum.OtherOutDoc.GetDescription()) { //更新源头单据数量 ICSWareHouseService.OtherOutDoc(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OtherOutDoc.GetDescription(), cmd, language); } } #endregion #region 领料申请单发料 else if (TransType == TransTypeEnum.MOApply.GetDescription()) { //更新源头单据数量 ICSManufactureService.MOApply(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.MOApply.GetDescription(), cmd, language); } } #endregion #region 委外领料申请单发料 else if (TransType == TransTypeEnum.OOApply.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OOApply(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OOApply.GetDescription(), cmd, language); } } #endregion #region 开立材料出库 else if (TransType == TransTypeEnum.MOIssue.GetDescription()) { //更新源头单据数量 ICSManufactureService.MOIssue(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.MOIssue.GetDescription(), cmd, language); } } #endregion #region 开立委外材料出库 else if (TransType == TransTypeEnum.OOIssue.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OOIssue(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OOIssue.GetDescription(), cmd, language); } } #endregion #region 开立红字入库单 else if (TransType == TransTypeEnum.PurchaseReceive.GetDescription()) { //更新源头单据数量 ICSPurchaseService.PurchaseReceive(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.PurchaseReceive.GetDescription(), cmd, language); } } #endregion #region 开立委外红字入库单 else if (TransType == TransTypeEnum.OutsourcingReceiveDocNegative.GetDescription()) { //更新源头单据数量 ICSOutsourcingService.OutsourcingReceiveDocNegative(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.OutsourcingReceiveDocNegative.GetDescription(), cmd, language); } } #endregion #region 借用 else if (TransType == TransTypeEnum.BrrowDoc.GetDescription()) { //更新源头单据数量 ICSWareHouseService.BrrowDoc(item.TransCode, item.TransSequence, item.Quantity, item.WorkPoint, cmd, language); foreach (var itemInfo in item.detail) { //出库 ICSWareHouseLotInfoService.WareHouseLotInfoDown(Identification, item.TransCode, item.TransSequence, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "3", TransTypeEnum.BrrowDoc.GetDescription(), cmd, language); } } #endregion } //上传ERP if (Convert.ToBoolean(System.Configuration.ConfigurationManager.AppSettings["UploadERP"])) { //采购退货 if (TransType == TransTypeEnum.PurchaseReceiveDoctNegative.GetDescription()) ICSPurchaseService.PurchaseReceiveDoctNegativeERP(TransType, Identification, cmd, language); //委外发料 else if (TransType == TransTypeEnum.OutsourcingIssueDoc.GetDescription()) ICSOutsourcingService.OutsourcingIssueDocERP(TransType, Identification, cmd, language); //委外退货 else if (TransType == TransTypeEnum.OutsourcingReturnBack.GetDescription()) ICSOutsourcingService.OutsourcingReturnBackERP(TransType, Identification, cmd, language); //生产发料 else if (TransType == TransTypeEnum.MOIssueDoc.GetDescription()) ICSManufactureService.MOIssueDocERP(TransType, Identification, cmd, language); //销售出库 else if (TransType == TransTypeEnum.SalesShipmentDoc.GetDescription()) ICSSalesService.SalesShipmentDocERP(TransType, Identification, cmd, language); //两步调出 else if (TransType == TransTypeEnum.TwoStepTransferDocOut.GetDescription()) ICSWareHouseService.TwoStepTransferDocOutERP(TransType, Identification, cmd, language); //其他出库 else if (TransType == TransTypeEnum.OtherOutDoc.GetDescription()) ICSWareHouseService.OtherOutDocERP(TransType, Identification, cmd, language); //领料申请单发料 if (TransType == TransTypeEnum.MOApply.GetDescription()) ICSManufactureService.MOApplyERP(TransType, Identification, cmd, language); //委外领料申请单发料 if (TransType == TransTypeEnum.OOApply.GetDescription()) ICSOutsourcingService.OOApplyERP(TransType, Identification, cmd, language); //开立材料出库 if (TransType == TransTypeEnum.MOIssue.GetDescription()) ICSManufactureService.MOIssueERP(TransType, Identification, cmd, language); //开立委外材料出库 if (TransType == TransTypeEnum.OOIssue.GetDescription()) ICSOutsourcingService.OOIssueERP(TransType, Identification, cmd, language); //开立红字入库单 if (TransType == TransTypeEnum.PurchaseReceive.GetDescription()) ICSPurchaseService.PurchaseReceiveERP(TransType, Identification, cmd, language); //开立委外红字入库单 if (TransType == TransTypeEnum.OutsourcingReceiveDocNegative.GetDescription()) ICSOutsourcingService.OutsourcingReceiveDocNegativeERP(TransType, Identification, cmd, language); //借用 if (TransType == TransTypeEnum.BrrowDoc.GetDescription()) ICSWareHouseService.BrrowDocERP(TransType, Identification, cmd, language); } DataTable table = GetData(Identification, 2, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #region 采购 ///

/// 采购到货 ///

/// /// public static DataTable DeliveryNoticeCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string asncodes = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.ASNCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo009"));//"送货单号不能为空！" } //获取单号 sql = @"IF EXISTS(SELECT a.ID FROM ICSDeliveryNotice a WHERE a.ASNCode='{0}' AND DNType = '1' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo057") + @"',16,1); RETURN END DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSASN WHERE ASNCode='{0}' and WorkPoint='{1}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo058") + @"',16,1); RETURN END ELSE IF (@Status!='2') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo059") + @"',16,1); RETURN END DECLARE @MaxNO INT,@date varchar(20)='DN'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(DNCode),LEN(@date)+1,LEN(MAX(DNCode))-LEN(@date))+1 FROM ICSDeliveryNotice WHERE SUBSTRING(DNCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; sql = string.Format(sql, item.ASNCode, item.WorkPoint); string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //修改送货单到货数量 foreach (var itemInfo in item.detail) { sql = @"UPDATE ICSASNDetail SET DNQuantity=ISNULL(DNQuantity, 0)+'{2}' WHERE LotNo='{0}' AND WorkPoint='{1}'"; sql = string.Format(sql, itemInfo.LotNo, item.WorkPoint, itemInfo.Quantity); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo010")); //"送货单子表信息更新失败！"); } } //创建到货单信息 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{1}' AND F_Location='{2}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{1}") + @"',16,1); RETURN END INSERT INTO ICSDeliveryNotice(ID,DNCode,Sequence,VenCode,DepCode, DNType,InvCode,Quantity,Amount,RCVQuantity, UnitPrice,Currency,Status,CreatePerson,CreateDateTime, POID,PODetailID,DNID,DNDetailID,ExtensionID, MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1,ASNCode) SELECT NEWID(),'{0}',row_number() OVER (ORDER BY b.InvCode),d.VenCode,d.DepCode, '1',b.InvCode,SUM(a.DNQuantity),'0','0', d.UnitPrice,d.Currency,'2',e.F_Account,GETDATE(), d.POID,d.PODetailID,newid(),newid(),b.ExtensionID, e.F_Account,e.F_RealName,GETDATE(),a.WorkPoint,'',a.ASNCode FROM ICSASNDetail a INNER JOIN ICSInventoryLot b ON a.LotNo=b.LotNo AND a.WorkPoint=b.WorkPoint INNER JOIN ICSInventoryLotDetail c ON b.LotNo=c.LotNo AND b.WorkPoint=c.WorkPoint INNER JOIN ICSPurchaseOrder d ON c.TransCode=d.POCode AND c.TransSequence=d.Sequence AND c.WorkPoint=d.WorkPoint INNER JOIN Sys_SRM_User e ON e.F_Account='{1}' AND e.F_Location='{2}' WHERE a.ASNCode='{3}' AND a.WorkPoint='{2}' GROUP BY d.POID,d.PODetailID,d.VenCode,d.UnitPrice,d.Currency,d.DepCode,b.ExtensionID,b.InvCode,a.ASNCode,e.F_Account,e.F_RealName,a.WorkPoint"; sql = string.Format(sql, Code, item.User, item.WorkPoint, item.ASNCode); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo011")); //"到货单信息创建失败！"); } ICSPurchaseService.DeliveryNoticeERP(Code, item.WorkPoint, cmd, language); asncodes += "'" + item.ASNCode + item.WorkPoint + "',"; } if (string.IsNullOrWhiteSpace(asncodes)) { throw new Exception(language.GetNameByCode("WMSAPIInfo009"));//"请传入送货单信息！"); } #region 查询返回数据 sql = @"SELECT n.POCode, n.Sequence AS POSequence, a.ASNCode, a.DNCode, a.Sequence, a.VenCode, a.DepCode, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.RCVQuantity, a.UnitPrice, a.Currency, a.POID, a.PODetailID, a.DNID, a.DNDetailID, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSDeliveryNotice a INNER JOIN ICSPurchaseOrder n ON a.POID =n.POID AND a.PODetailID=n.PODetailID AND a.WorkPoint=n.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.ASNCode+a.WorkPoint IN ({0})"; sql = string.Format(sql, asncodes.Substring(0, asncodes.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 采购拒收 ///

/// /// public static DataTable PurchaseRejectDocCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string lots = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.DNCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo012"));//"到货单号不能为空！"); } //获取单号 sql = @"DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSDeliveryNotice WHERE DNCode='{0}' and DNType='1' and WorkPoint='{1}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo061") + @"',16,1); RETURN END ELSE IF (@Status!='2') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo062") + @"',16,1); RETURN END DECLARE @MaxNO INT,@date varchar(20)='RJT'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(DNCode),LEN(@date)+1,LEN(MAX(DNCode))-LEN(@date))+1 FROM ICSDeliveryNotice WHERE SUBSTRING(DNCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; sql = string.Format(sql, item.DNCode, item.WorkPoint); string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //修改送货单到货数量 foreach (var itemInfo in item.detail) { sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{3}' AND F_Location='{2}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{3}") + @"',16,1); RETURN END IF EXISTS(SELECT a.ID FROM ICSDeliveryNotice a WHERE a.EATTRIBUTE1='{1}' AND DNType = '3' AND a.WorkPoint='{2}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo063") + @"',16,1); RETURN END INSERT INTO ICSDeliveryNotice(ID,DNCode,Sequence,VenCode,DepCode, DNType,InvCode,Quantity,Amount,RCVQuantity, UnitPrice,Currency,Status,CreatePerson,CreateDateTime, POID,PODetailID,DNID,DNDetailID,ExtensionID, MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1,ASNCode) SELECT NEWID(),'{4}', '{11}', '{5}', '{6}', '3',d.InvCode,'{7}', '{8}', 0, '{9}', '{10}', '2', e.F_Account, SYSDATETIME(), a.DNID,a.DNDetailID, '0', '0', a.ExtensionID, e.F_Account,e.F_RealName, SYSDATETIME(), a.WorkPoint, b.LOTNO,'' FROM ICSDeliveryNotice a INNER JOIN ICSASNDetail b ON a.ASNCode=b.ASNCode AND a.WorkPoint=b.WorkPoint INNER JOIN ICSInventoryLot d ON b.LotNo=d.LotNo AND a.InvCode=d.InvCode AND b.WorkPoint=d.WorkPoint INNER JOIN ICSInventoryLotDetail m on d.LotNo=m.LotNo and d.WorkPoint=m.WorkPoint INNER JOIN ICSPurchaseOrder n ON m.TransCode =n.POCode AND m.TransSequence=n.Sequence AND a.PODetailID=n.PODetailID AND m.WorkPoint=n.WorkPoint INNER JOIN ICSInspection h ON h.LotNo=b.LotNo AND h.WorkPoint=b.WorkPoint INNER JOIN Sys_SRM_User e ON e.F_Account='{3}' AND e.F_Location='{2}' WHERE a.DNCode='{0}' and b.LOTNO='{1}' AND a.WorkPoint='{2}'"; sql = string.Format(sql, item.DNCode, itemInfo.LotNo, item.WorkPoint, item.User, Code, item.VenCode, item.DepCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.UnitPrice, itemInfo.Currency, itemInfo.Sequence); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo013"));//"拒收单创建失败！"); } lots += "'" + itemInfo.LotNo + item.WorkPoint + "',"; } } if (string.IsNullOrWhiteSpace(lots)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"请传入条码信息！"); } #region 查询返回数据 sql = @"SELECT n.DNCode, n.Sequence, a.DNCode AS RJTCode, a.Sequence AS RJTSequence, a.VenCode, a.DepCode, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.RCVQuantity, a.UnitPrice, a.Currency, a.POID, a.PODetailID, a.DNID, a.DNDetailID, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSDeliveryNotice a INNER JOIN ICSDeliveryNotice n ON a.POID =n.DNID AND a.PODetailID=n.DNDetailID AND a.WorkPoint=n.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.EATTRIBUTE1+a.WorkPoint IN ({0})"; sql = string.Format(sql, lots.Substring(0, lots.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 委外 ///

/// 委外退料新建 ///

/// /// public static DataTable OutsourcingIssueDoNegativeApplyCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string codes = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { //获取单号 sql = @"DECLARE @MaxNO INT,@date varchar(20)='OOIA'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(OApplyNegCode),LEN(@date)+1,LEN(MAX(OApplyNegCode))-LEN(@date))+1 FROM ICSOApplyNeg WHERE SUBSTRING(OApplyNegCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //创建主表 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{2}' AND F_Location='{4}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{2}") + @"',16,1); RETURN END INSERT INTO ICSOApplyNeg(ID,OApplyNegCode,WHCode,Status,Type,Memo,CreatePerson,CreateDateTime,MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1) VALUES (NEWID(),'{0}','{1}','1','{5}','','{2}','{3}','{2}',(select F_RealName from Sys_SRM_User where F_Account='{2}' and F_Location='{4}'),'{3}','{4}','')"; sql = string.Format(sql, Code, item.WHCode, item.User, item.MTime, item.WorkPoint, item.Type); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo014"));//"委外退料单信息创建失败！"); } foreach (var itemInfo in item.detail) { //创建子表 sql = @"INSERT INTO ICSOApplyNegDetail(ID,OApplyNegCode,Sequence,SourceDetailID,InvCode, Quantity,Amount,IssueNegQuantity,ExtensionID,MUSER, MUSERName,MTIME,WorkPoint,EATTRIBUTE) VALUES (NEWID(),'{0}','{1}','{2}','{3}', '{4}','{5}',0,'{6}','{7}', (select F_RealName from Sys_SRM_User where F_Account='{7}' and F_Location='{8}'),SYSDATETIME(),'{8}','')"; sql = string.Format(sql, Code, itemInfo.Sequence, itemInfo.SourceDetailID, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.ExtensionID, item.User, item.WorkPoint); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo015"));//"委外退料单子表信息创建失败！"); } } //校验退料数量是否超出领料数量 sql = CheckOutsourcingIssueDoc(item.Type, item.id, item.WorkPoint, language); DBHelper.ExecuteNonQuery(sql, cmd); codes += "'" + Code + item.WorkPoint + "',"; } if (string.IsNullOrWhiteSpace(codes)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } #region 查询返回数据 sql = @"SELECT a.OApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSOApplyNegDetail a INNER JOIN ICSOApplyNeg c ON a.OApplyNegCode=c.OApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.OApplyNegCode+a.WorkPoint IN ({0})"; sql = string.Format(sql, codes.Substring(0, codes.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } private static string CheckOutsourcingIssueDoc(string Type, string ID, string WorkPoint, Dictionary language) { string sql = string.Empty; if (Type == "1") { sql = @"DECLARE @PickID VARCHAR(10) SELECT @PickID=b.PickID FROM ICSOApplyNegDetail a INNER JOIN ICSOOPick b ON a.SourceDetailID=b.PickID AND a.WorkPoint=b.WorkPoint INNER JOIN ICSOApplyNeg c ON a.OApplyNegCode=c.OApplyNegCode AND a.WorkPoint=c.WorkPoint WHERE c.ID='{0}' AND c.Type='{2}' AND a.WorkPoint='{1}' GROUP BY b.PickID HAVING MAX(b.Quantity) /// 委外退料修改 /// /// /// public static DataTable OutsourcingIssueDoNegativeApplyUpdate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string Code = string.Empty; string ids = string.Empty; foreach (var item in JsonData) { //主表修改 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{1}' AND F_Location='{4}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo060") + @"',16,1); RETURN END DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSOApplyNeg WHERE ID='{3}' and WorkPoint='{4}' IF (@Status IS NULL) BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo065"), "{3}") + @"',16,1); RETURN END ELSE IF (@Status!='1') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo066"), "{3}") + @"',16,1); RETURN END update ICSOApplyNeg set WHCode='{0}',MUSER='{1}',MUSERName=(select F_RealName from Sys_SRM_User where F_Account='{1}' and F_Location='{4}'),MTIME='{2}' where ID='{3}' and WorkPoint='{4}' "; sql = string.Format(sql, item.WHCode, item.User, item.MTime, item.id, item.WorkPoint); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo016"));//"委外退料单信息修改失败！"); } var detail = item.detail.Where(a => a.DetailID.Length <= 0).Count(); if (detail > 0) { sql = @"SELECT OApplyNegCode FROM ICSOApplyNeg where ID='{0}' and WorkPoint='{1}'"; sql = string.Format(sql, item.id, item.WorkPoint); Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); } foreach (var itemInfo in item.detail) { if (string.IsNullOrWhiteSpace(itemInfo.DetailID)) { //创建子表 sql = @"INSERT INTO ICSOApplyNegDetail(ID,OApplyNegCode,Sequence,SourceDetailID,InvCode, Quantity,Amount,IssueNegQuantity,ExtensionID,MUSER, MUSERName,MTIME,WorkPoint,EATTRIBUTE) VALUES (NEWID(),'{0}','{1}','{2}','{3}', '{4}','{5}',0,'{6}','{7}', (select F_RealName from Sys_SRM_User where F_Account='{7}' and F_Location='{8}'),SYSDATETIME(),'{8}','')"; sql = string.Format(sql, Code, itemInfo.Sequence, itemInfo.SourceDetailID, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.ExtensionID, item.User, item.WorkPoint); } else { //子表修改 sql = @"update ICSOApplyNegDetail set InvCode='{0}' ,Quantity='{1}',Amount='{2}',SourceDetailID='{3}',MUSER='{6}',MUSERName=(select F_RealName from Sys_SRM_User where F_Account='{6}' and F_Location='{5}') where ID='{4}' and WorkPoint='{5}'"; sql = string.Format(sql, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.SourceDetailID, itemInfo.DetailID, item.WorkPoint, item.User); } if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo017"));//"委外退料单子表信息修改失败！"); } } //校验退料数量是否超出领料数量 sql = CheckOutsourcingIssueDoc(item.Type, item.id, item.WorkPoint, language); DBHelper.ExecuteNonQuery(sql, cmd); ids += "'" + item.id + "',"; } if (string.IsNullOrWhiteSpace(ids)) { throw new Exception(language.GetNameByCode("WMSAPIInfo006"));//"ID不能为空！" } #region 查询返回数据 sql = @"SELECT a.OApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSOApplyNegDetail a INNER JOIN ICSOApplyNeg c ON a.OApplyNegCode=c.OApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE c.ID IN ({0})"; sql = string.Format(sql, ids.Substring(0, ids.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 委外退料审核 ///

/// /// public static DataTable OutsourcingIssueDoNegativeApplyApprove(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string ids = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.ID)) { throw new Exception(language.GetNameByCode("WMSAPIInfo018"));//"单据ID不能为空！"); } if (string.IsNullOrEmpty(item.User)) { throw new Exception(language.GetNameByCode("WMSAPIInfo019"));//"操作人不能为空！"); } if (item.MTime <= new DateTime(2000, 1, 1)) { throw new Exception(language.GetNameByCode("WMSAPIInfo020"));//"操作时间不能为空！"); } //获取单号 sql = @"DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSOApplyNeg WHERE ID='{0}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo065") + @"',16,1); RETURN END ELSE IF (@Status!='1') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo066") + @"',16,1); RETURN END update ICSOApplyNeg set Status='2',MUSER='{1}',MTIME='{2}' where ID='{0}'"; sql = string.Format(sql, item.ID, item.User, item.MTime); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo021"));//"委外退料申请单审核失败！"); } ids += "'" + item.ID + "',"; } if (string.IsNullOrWhiteSpace(ids)) { throw new Exception(language.GetNameByCode("WMSAPIInfo006"));//"ID不能为空！" } #region 查询返回数据 sql = @"SELECT a.OApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSOApplyNegDetail a INNER JOIN ICSOApplyNeg c ON a.OApplyNegCode=c.OApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE c.ID IN ({0})"; sql = string.Format(sql, ids.Substring(0, ids.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 委外到货 ///

/// /// public static DataTable OutsourcingDeliveryNoticeCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string asncodes = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.OASNCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo009"));//"送货单号不能为空！"); } //获取单号 sql = @"IF EXISTS(SELECT a.ID FROM ICSODeliveryNotice a WHERE a.OASNCode='{0}' AND ODNType = '1' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo057") + @"',16,1); RETURN END DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSOASN WHERE OASNCode='{0}' and WorkPoint='{1}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo058") + @"',16,1); RETURN END ELSE IF (@Status!='2') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo059") + @"',16,1); RETURN END DECLARE @MaxNO INT,@date varchar(20)='ODN'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(ODNCode),LEN(@date)+1,LEN(MAX(ODNCode))-LEN(@date))+1 FROM ICSODeliveryNotice WHERE SUBSTRING(ODNCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; sql = string.Format(sql, item.OASNCode, item.WorkPoint); string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //修改送货单到货数量 foreach (var itemInfo in item.detail) { sql = @"UPDATE ICSOASNDetail SET ODNQuantity=ISNULL(ODNQuantity, 0)+'{2}' WHERE LotNo='{0}' AND WorkPoint='{1}'"; sql = string.Format(sql, itemInfo.LotNo, item.WorkPoint, itemInfo.Quantity); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo010")); //"委外送货单子表信息更新失败！"); } } //创建到货单信息 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{1}' AND F_Location='{2}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo060") + @"',16,1); RETURN END INSERT INTO ICSODeliveryNotice(ID,ODNCode,Sequence,VenCode,DepCode, ODNType,InvCode,Quantity,Amount,RCVQuantity, UnitPrice,Currency,Status,CreatePerson,CreateDateTime, OOID,OODetailID,ODNID,ODNDetailID,ExtensionID, MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1,OASNCode) SELECT NEWID(),'{0}',row_number() OVER (ORDER BY b.InvCode),d.VenCode,d.DepCode, '1',b.InvCode,SUM(a.ODNQuantity),'0','0', d.UnitPrice,d.Currency,'2',e.F_Account,GETDATE(), d.OOID,d.OODetailID,newid(),newid(),b.ExtensionID, e.F_Account,e.F_RealName,GETDATE(),a.WorkPoint,'',a.OASNCode FROM ICSOASNDetail a INNER JOIN ICSInventoryLot b ON a.LotNo=b.LotNo AND a.WorkPoint=b.WorkPoint INNER JOIN ICSInventoryLotDetail c ON b.LotNo=c.LotNo AND b.WorkPoint=c.WorkPoint INNER JOIN ICSOutsourcingOrder d ON c.TransCode=d.OOCode AND c.TransSequence=d.Sequence AND c.WorkPoint=d.WorkPoint INNER JOIN Sys_SRM_User e ON e.F_Account='{1}' AND e.F_Location='{2}' WHERE a.OASNCode='{3}' AND a.WorkPoint='{2}' GROUP BY d.OOID,d.OODetailID,d.VenCode,d.UnitPrice,d.Currency,d.DepCode,b.ExtensionID,b.InvCode,a.OASNCode,e.F_Account,e.F_RealName,a.WorkPoint"; sql = string.Format(sql, Code, item.User, item.WorkPoint, item.OASNCode); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo011")); //"到货单信息创建失败！"); } ICSOutsourcingService.OutsourcingDeliveryNoticeERP(Code, item.WorkPoint, cmd, language); asncodes += "'" + item.OASNCode + item.WorkPoint + "',"; } if (string.IsNullOrWhiteSpace(asncodes)) { throw new Exception(language.GetNameByCode("WMSAPIInfo009"));//"请传入送货单信息！"); } #region 查询返回数据 sql = @"SELECT n.OOCode, n.Sequence AS OOSequence, a.OASNCode, a.ODNCode, a.Sequence, a.VenCode, a.DepCode, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.RCVQuantity, a.UnitPrice, a.Currency, a.OOID, a.OODetailID, a.ODNID, a.ODNDetailID, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSODeliveryNotice a INNER JOIN ICSOutsourcingOrder n ON a.OOID =n.OOID AND a.OODetailID=n.OODetailID AND a.WorkPoint=n.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.OASNCode+a.WorkPoint IN ({0})"; sql = string.Format(sql, asncodes.Substring(0, asncodes.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 委外拒收 ///

/// /// public static DataTable OutsourcingRejectDocCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string lots = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.ODNCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo012"));//"到货单号不能为空！"); } //获取单号 sql = @"DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSODeliveryNotice WHERE ODNCode='{0}' and ODNType='1' and WorkPoint='{1}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo061") + @"',16,1); RETURN END ELSE IF (@Status!='2') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo062") + @"',16,1); RETURN END DECLARE @MaxNO INT,@date varchar(20)='ORJT'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(ODNCode),LEN(@date)+1,LEN(MAX(ODNCode))-LEN(@date))+1 FROM ICSODeliveryNotice WHERE SUBSTRING(ODNCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; sql = string.Format(sql, item.ODNCode, item.WorkPoint); string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //修改送货单到货数量 foreach (var itemInfo in item.detail) { sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{3}' AND F_Location='{2}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{3}") + @"',16,1); RETURN END IF EXISTS(SELECT a.ID FROM ICSODeliveryNotice a WHERE a.EATTRIBUTE1='{1}' AND ODNType = '3' AND a.WorkPoint='{2}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo063") + @"',16,1); RETURN END INSERT INTO ICSODeliveryNotice(ID,ODNCode,Sequence,VenCode,DepCode, ODNType,InvCode,Quantity,Amount,RCVQuantity, UnitPrice,Currency,Status,CreatePerson,CreateDateTime, OOID,OODetailID,ODNID,ODNDetailID,ExtensionID, MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1,OASNCode) SELECT NEWID(),'{4}', '{11}', '{5}', '{6}', '3',d.InvCode,'{7}', '{8}', 0, '{9}', '{10}', '2', e.F_Account, SYSDATETIME(), a.ODNID,a.ODNDetailID, '0', '0', a.ExtensionID, e.F_Account,e.F_RealName, SYSDATETIME(), a.WorkPoint, b.LOTNO,'' FROM ICSODeliveryNotice a INNER JOIN ICSOASNDetail b ON a.OASNCode=b.OASNCode AND a.WorkPoint=b.WorkPoint INNER JOIN ICSInventoryLot d ON b.LotNo=d.LotNo AND a.InvCode=d.InvCode AND b.WorkPoint=d.WorkPoint INNER JOIN ICSInventoryLotDetail m on d.LotNo=m.LotNo and d.WorkPoint=m.WorkPoint INNER JOIN ICSOutsourcingOrder n ON m.TransCode =n.OOCode AND m.TransSequence=n.Sequence AND a.OODetailID=n.OODetailID AND m.WorkPoint=n.WorkPoint INNER JOIN ICSInspection h ON h.LotNo=b.LotNo AND h.WorkPoint=b.WorkPoint INNER JOIN Sys_SRM_User e ON e.F_Account='{3}' AND e.F_Location='{2}' WHERE a.ODNCode='{0}' and b.LOTNO='{1}' AND a.WorkPoint='{2}'"; sql = string.Format(sql, item.ODNCode, itemInfo.LotNo, item.WorkPoint, item.User, Code, item.VenCode, item.DepCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.UnitPrice, itemInfo.Currency, itemInfo.Sequence); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo013"));//"拒收单创建失败！"); } lots += "'" + itemInfo.LotNo + item.WorkPoint + "',"; } } if (string.IsNullOrWhiteSpace(lots)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"请传入条码信息！"); } #region 查询返回数据 sql = @"SELECT n.ODNCode, n.Sequence, a.ODNCode AS RJTCode, a.Sequence AS RJTSequence, a.VenCode, a.DepCode, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.RCVQuantity, a.UnitPrice, a.Currency, a.OOID, a.OODetailID, a.ODNID, a.ODNDetailID, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSODeliveryNotice a INNER JOIN ICSODeliveryNotice n ON a.OOID =n.ODNID AND a.OODetailID=n.ODNDetailID AND a.WorkPoint=n.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.EATTRIBUTE1+a.WorkPoint IN ({0})"; sql = string.Format(sql, lots.Substring(0, lots.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 生产 ///

/// 生产退料新建 ///

/// /// public static DataTable MOIssueDocNegativeApplyCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string codes = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { //获取单号 sql = @"DECLARE @MaxNO INT,@date varchar(20)='OOIA'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(ApplyNegCode),LEN(@date)+1,LEN(MAX(ApplyNegCode))-LEN(@date))+1 FROM ICSMOApplyNeg WHERE SUBSTRING(ApplyNegCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; string Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //创建主表 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{2}' AND F_Location='{4}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{2}") + @"',16,1); RETURN END INSERT INTO ICSMOApplyNeg(ID,ApplyNegCode,WHCode,Status,Type,Memo,CreatePerson,CreateDateTime,MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1) VALUES (NEWID(),'{0}','{1}','1','{5}','','{2}','{3}','{2}',(select F_RealName from Sys_SRM_User where F_Account='{2}' and F_Location='{4}'),'{3}','{4}','')"; sql = string.Format(sql, Code, item.WHCode, item.User, item.MTime, item.WorkPoint, item.Type); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo022"));//"生产退料单信息创建失败！"); } foreach (var itemInfo in item.detail) { //创建子表 sql = @"INSERT INTO ICSMOApplyNegDetail(ID,ApplyNegCode,Sequence,SourceDetailID,InvCode, Quantity,Amount,IssueNegQuantity,ExtensionID,MUSER, MUSERName,MTIME,WorkPoint,EATTRIBUTE) VALUES (NEWID(),'{0}','{1}','{2}','{3}', '{4}','{5}',0,'{6}','{7}', (select F_RealName from Sys_SRM_User where F_Account='{7}' and F_Location='{8}'),SYSDATETIME(),'{8}','')"; sql = string.Format(sql, Code, itemInfo.Sequence, itemInfo.SourceDetailID, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.ExtensionID, item.User, item.WorkPoint); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo023"));//"生产退料单子表信息创建失败！"); } } //校验退料数量是否超出领料数量 sql = CheckMOIssueDoc(item.Type, item.ID, item.WorkPoint, language); DBHelper.ExecuteNonQuery(sql, cmd); codes += "'" + Code + item.WorkPoint + "',"; } if (string.IsNullOrWhiteSpace(codes)) { throw new Exception(language.GetNameByCode("WMSAPIInfo001"));//"单据号不能为空！" } #region 查询返回数据 sql = @"SELECT a.ApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSMOApplyNegDetail a INNER JOIN ICSMOApplyNeg c ON a.ApplyNegCode=c.ApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSMOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.ApplyNegCode+a.WorkPoint IN ({0})"; sql = string.Format(sql, codes.Substring(0, codes.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } private static string CheckMOIssueDoc(string Type, string ID, string WorkPoint, Dictionary language) { string sql = string.Empty; if (Type == "1") { sql = @"DECLARE @PickID VARCHAR(10) SELECT @PickID=b.PickID FROM ICSMOApplyNegDetail a INNER JOIN ICSMOPick b ON a.SourceDetailID=b.PickID AND a.WorkPoint=b.WorkPoint INNER JOIN ICSMOApplyNeg c ON a.ApplyNegCode=c.ApplyNegCode AND a.WorkPoint=c.WorkPoint WHERE c.ID='{0}' AND c.Type='{2}' AND a.WorkPoint='{1}' GROUP BY b.PickID HAVING MAX(b.Quantity) /// 生产退料修改 /// /// /// public static DataTable MOIssueDocNegativeApplyUpdate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string Code = string.Empty; string ids = string.Empty; foreach (var item in JsonData) { //主表修改 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{1}' AND F_Location='{4}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo060"), "{1}") + @"',16,1); RETURN END DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSMOApplyNeg WHERE ID='{3}' and WorkPoint='{4}' IF (@Status IS NULL) BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo065"), "{3}") + @"',16,1); RETURN END ELSE IF (@Status!='1') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo066"), "{3}") + @"',16,1); RETURN END update ICSMOApplyNeg set WHCode='{0}',MUSER='{1}',MUSERName=(select F_RealName from Sys_SRM_User where F_Account='{1}' and F_Location='{4}'),MTIME='{2}' where ID='{3}' and WorkPoint='{4}' "; sql = string.Format(sql, item.WHCode, item.User, item.MTime, item.ID, item.WorkPoint); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo024"));//"生产退料单信息修改失败！"); } var detail = item.detail.Where(a => a.DetailID.Length <= 0).Count(); if (detail > 0) { sql = @"SELECT ApplyNegCode FROM ICSMOApplyNeg where ID='{0}' and WorkPoint='{1}'"; sql = string.Format(sql, item.ID, item.WorkPoint); Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); } foreach (var itemInfo in item.detail) { if (string.IsNullOrWhiteSpace(itemInfo.DetailID)) { //创建子表 sql = @"INSERT INTO ICSMOApplyNegDetail(ID,ApplyNegCode,Sequence,SourceDetailID,InvCode,Quantity,Amount,IssueNegQuantity,ExtensionID,MUSER, MUSERName,MTIME,WorkPoint,EATTRIBUTE) VALUES (NEWID(),'{0}','{1}','{2}','{3}', '{4}','{5}',0,'{6}','{7}', (select F_RealName from Sys_SRM_User where F_Account='{7}' and F_Location='{8}'),SYSDATETIME(),'{8}','')"; sql = string.Format(sql, Code, itemInfo.Sequence, itemInfo.SourceDetailID, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.ExtensionID, item.User, item.WorkPoint); } else { //子表修改 sql = @"update ICSMOApplyNegDetail set InvCode='{0}' ,Quantity='{1}',Amount='{2}',SourceDetailID='{3}',MUSER='{6}',MUSERName=(select F_RealName from Sys_SRM_User where F_Account='{6}' and F_Location='{5}') where ID='{4}' and WorkPoint='{5}'"; sql = string.Format(sql, itemInfo.InvCode, itemInfo.Quantity, itemInfo.Amount, itemInfo.SourceDetailID, itemInfo.DetailID, item.WorkPoint, item.User); } if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo025"));//"生产退料单子表信息修改失败！"); } } //校验退料数量是否超出领料数量 sql = CheckMOIssueDoc(item.Type, item.ID, item.WorkPoint, language); DBHelper.ExecuteNonQuery(sql, cmd); ids += "'" + item.ID + "',"; } if (string.IsNullOrWhiteSpace(ids)) { throw new Exception(language.GetNameByCode("WMSAPIInfo006"));//"ID不能为空！" } #region 查询返回数据 sql = @"SELECT a.ApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSMOApplyNegDetail a INNER JOIN ICSMOApplyNeg c ON a.ApplyNegCode=c.ApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSMOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE c.ID IN ({0})"; sql = string.Format(sql, ids.Substring(0, ids.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 生产退料审核 ///

/// /// public static DataTable MOIssueDocNegativeApplyApprove(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string ids = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.ID)) { throw new Exception(language.GetNameByCode("WMSAPIInfo018"));//"单据ID不能为空！"); } if (string.IsNullOrEmpty(item.User)) { throw new Exception(language.GetNameByCode("WMSAPIInfo019"));//"操作人不能为空！"); } if (item.MTime <= new DateTime(2000, 1, 1)) { throw new Exception(language.GetNameByCode("WMSAPIInfo020"));//"操作时间不能为空！"); } //获取单号 sql = @"DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSMOApplyNeg WHERE ID='{0}' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo065") + @"',16,1); RETURN END ELSE IF (@Status!='1') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo066") + @"',16,1); RETURN END update ICSMOApplyNeg set Status='2',MUSER='{1}',MTIME='{2}' where ID='{0}'"; sql = string.Format(sql, item.ID, item.User, item.MTime); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo026"));//"生产退料申请单审核失败！"); } ids += "'" + item.ID + "',"; } if (string.IsNullOrWhiteSpace(ids)) { throw new Exception(language.GetNameByCode("WMSAPIInfo006"));//"ID不能为空！" } #region 查询返回数据 sql = @"SELECT a.ApplyNegCode, c.WHCode, c.Memo, d.Name AS Status, a.Sequence, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.IssueNegQuantity, ext.ProjectCode, ext.BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSMOApplyNegDetail a INNER JOIN ICSMOApplyNeg c ON a.ApplyNegCode=c.ApplyNegCode AND a.WorkPoint=c.WorkPoint LEFT JOIN ICSType d ON d.TableCode='ICSMOApplyNeg' AND d.ColumnCode='Status' AND c.Status=d.Code AND c.WorkPoint=d.WorkPoint INNER JOIN ICSExtension ext ON a.ExtensionID=ext.ID AND a.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE c.ID IN ({0})"; sql = string.Format(sql, ids.Substring(0, ids.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 调拨 ///

/// 一步调拨 ///

/// /// public static DataTable OneStepTransferDocIn(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.TransCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo027"));//"调拨单号不能为空！"); } //验证信息 sql = @"DECLARE @Status VARCHAR(10) SELECT @Status=Status FROM ICSTransfer WHERE TransferNO='{0}' and WorkPoint='{1}' AND Type = '1' IF (@Status IS NULL) BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo067") + @"',16,1); RETURN END ELSE IF (@Status!='1') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo068") + @"',16,1); RETURN END"; sql = string.Format(sql, item.TransCode, item.WorkPoint); DBHelper.ExecuteNonQuery(sql, cmd); foreach (var itemInfo in item.Detail) { //验证仓库库位信息 sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSWareHouse a WHERE a.WarehouseCode='{0}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo069") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSLocation a WHERE a.LocationCode='{2}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo070"), "{2}") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSWareHouse a INNER JOIN ICSLocation b ON a.ID=b.WHID AND a.WorkPoint=b.WorkPoint WHERE a.WarehouseCode='{0}' AND a.WorkPoint='{1}' AND b.LocationCode='{2}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo071") + @"',16,1); RETURN END"; sql = string.Format(sql, itemInfo.WarehouseCode, item.WorkPoint, itemInfo.LocationCode); DBHelper.ExecuteNonQuery(sql, cmd); //更新源头单据信息 ICSWareHouseService.OneStepTransferDocIn(item.TransCode, item.TransSequence, item.WorkPoint, itemInfo.CurrentQuantity, cmd, language); //更新条码信息 ICSWareHouseLotInfoService.WareHouseLotInfoTransfer(Identification, item.TransCode, item.TransSequence, itemInfo.WarehouseCode, itemInfo.LocationCode, itemInfo.LotNo, itemInfo.CurrentQuantity, item.User, item.WorkPoint, "6", "21", cmd, language); } } ICSWareHouseService.OneStepTransferDocInERP(TransTypeEnum.OneStepTransferDocIn.GetDescription(), Identification, cmd, language); DataTable table = GetData(Identification, 3, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 移库 ///

/// 移库 ///

/// /// public static DataTable LibraryUpdate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.LotNo)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"条码不能为空！" } //验证仓库库位信息 sql = @"IF NOT EXISTS(SELECT a.ID FROM ICSWareHouse a WHERE a.WarehouseCode='{0}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo069") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSLocation a WHERE a.LocationCode='{2}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo072"), "{2}") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSWareHouse a INNER JOIN ICSLocation b ON a.ID=b.WHID AND a.WorkPoint=b.WorkPoint WHERE a.WarehouseCode='{0}' AND a.WorkPoint='{1}' AND b.LocationCode='{2}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo071") + @"',16,1); RETURN END"; sql = string.Format(sql, item.WarehouseCode, item.WorkPoint, item.LocationCode); DBHelper.ExecuteNonQuery(sql, cmd); //更新条码信息 ICSWareHouseLotInfoService.WareHouseLotInfoLibrary(Identification, item.TransCode, item.TransSequence, item.WarehouseCode, item.LocationCode, item.LotNo, item.User, item.WorkPoint, "7", "29", cmd, language); } DataTable table = GetData(Identification, 3, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 合并 ///

/// 合并 ///

/// /// public static DataTable LOTMergeCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.LotNo)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"条码不能为空！" } else if (item.detail.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo028"));//"明细信息不能为空！"); } //合并前日志 ICSWareHouseLotInfoService.WareHouseLotInfoLog(Identification, item.LotNo, item.User, item.WorkPoint, "5", TransTypeEnum.LOTMergeBefore.GetDescription(), cmd, language); foreach (var info in item.detail) { //合并前日志 ICSWareHouseLotInfoService.WareHouseLotInfoLog(Identification, info.CurrentLotNo, item.User, item.WorkPoint, "5", TransTypeEnum.LOTMergeBefore.GetDescription(), cmd, language); //更新条码信息 ICSWareHouseLotInfoService.WareHouseLotInfoMerge(Identification, item.LotNo, info.CurrentLotNo, info.CurrentQuantity, item.User, item.WorkPoint, "5", TransTypeEnum.LOTMergeAfter.GetDescription(), cmd, language); } //合并后日志 ICSWareHouseLotInfoService.WareHouseLotInfoLog(Identification, item.LotNo, item.User, item.WorkPoint, "5", TransTypeEnum.LOTMergeAfter.GetDescription(), cmd, language); } DataTable table = GetData(Identification, 1, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 拆分 ///

/// 拆分 ///

/// /// public static DataTable LOTSplitCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.LotNo)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"条码不能为空！" } else if (item.detail.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo028"));//"明细信息不能为空！"); } //拆分前日志 ICSWareHouseLotInfoService.WareHouseLotInfoLog(Identification, item.LotNo, item.User, item.WorkPoint, "4", TransTypeEnum.LOTSplitBefore.GetDescription(), cmd, language); foreach (var info in item.detail) { //更新条码信息 ICSWareHouseLotInfoService.WareHouseLotInfoSplit(Identification, item.LotNo, info.CurrentLotNo, info.CurrentQuantity, item.User, item.WorkPoint, "4", TransTypeEnum.LOTSplitAfter.GetDescription(), cmd, language); } //拆分后日志 ICSWareHouseLotInfoService.WareHouseLotInfoLog(Identification, item.LotNo, item.User, item.WorkPoint, "4", TransTypeEnum.LOTSplitAfter.GetDescription(), cmd, language); } DataTable table = GetData(Identification, 1, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion ///

/// 获取出入库记录信息 ///

/// /// 1:入库，2：出库，3：调拨 /// /// private static DataTable GetData(string Identification, int type, SqlCommand cmd) { #region SLQ string sql = @"SELECT log.ID, log.TransCode, log.TransSequence, log.LotNo, log.InvCode, inv.InvName, inv.InvStd, log.Quantity, inv.InvUnit, log.Quantity*lot.AmountRate AS Amount, inv.AmountUnit, {1} ext.ProjectCode, CASE WHEN ISNULL(invBat.BatchEnable, '0')='1' THEN ext.BatchCode ELSE '' END AS BatchCode, ext.Version, ext.Brand, ext.cFree1, ext.cFree2, ext.cFree3, ext.cFree4, ext.cFree5, ext.cFree6, ext.cFree7, ext.cFree8, ext.cFree9, ext.cFree10, type.Name AS TransType, log.MUSER AS [User], log.MTIME AS [MTime] FROM ICSWareHouseLotInfoLog log LEFT JOIN ICSType type ON type.TableCode='ICSWareHouseLotInfoLog' AND type.ColumnCode='BusinessCode' AND log.BusinessCode=type.Code AND log.WorkPoint=type.WorkPoint INNER JOIN ICSInventoryLot lot ON log.LotNo=lot.LotNo AND log.WorkPoint=lot.WorkPoint INNER JOIN ICSExtension ext ON lot.ExtensionID=ext.ID AND lot.WorkPoint=ext.WorkPoint INNER JOIN ICSInventory inv ON log.InvCode=inv.InvCode AND log.WorkPoint=inv.WorkPoint {2} LEFT JOIN ICSInventoryBatchEnable invBat ON log.InvCode=invBat.InvCode AND log.FromWarehouseCode=invBat.WHCode AND log.WorkPoint=invBat.WorkPoint WHERE log.Identification='{0}'"; #endregion string columns = @"log.ToWarehouseCode AS WHCode, log.ToLocationCode AS LocationCode, wh.WarehouseName AS WHName, loc.LocationName AS LocationName,"; string tables = @"INNER JOIN ICSWarehouse wh ON log.ToWarehouseCode=wh.WarehouseCode AND log.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON log.ToLocationCode=loc.LocationCode AND log.WorkPoint=loc.WorkPoint"; if (type == 2)//出库 { columns = @"log.FromWarehouseCode AS WHCode, log.FromLocationCode AS LocationCode, wh.WarehouseName AS WHName, loc.LocationName AS LocationName,"; tables = @"INNER JOIN ICSWarehouse wh ON log.FromWarehouseCode=wh.WarehouseCode AND log.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON log.FromLocationCode=loc.LocationCode AND log.WorkPoint=loc.WorkPoint"; } else if (type == 3)//调拨 { columns = @"log.FromWarehouseCode AS FromWHCode, log.FromLocationCode, wh.WarehouseName AS FromWHName, loc.LocationName AS FromLocationName, log.ToWarehouseCode AS ToWHCode, log.ToLocationCode, whto.WarehouseName AS ToWHName, locto.LocationName AS ToLocationName,"; tables = @"INNER JOIN ICSWarehouse wh ON log.FromWarehouseCode=wh.WarehouseCode AND log.WorkPoint=wh.WorkPoint INNER JOIN ICSLocation loc ON log.FromLocationCode=loc.LocationCode AND log.WorkPoint=loc.WorkPoint INNER JOIN ICSWarehouse whto ON log.ToWarehouseCode=whto.WarehouseCode AND log.WorkPoint=whto.WorkPoint INNER JOIN ICSLocation locto ON log.ToLocationCode=locto.LocationCode AND log.WorkPoint=locto.WorkPoint"; } sql = string.Format(sql, Identification, columns, tables); return DBHelper.SQlReturnData(sql, cmd); } ///

/// 先进先出批次管控 ///

/// /// /// /// public static string CanOut(string LotNo, string WorkPoitCode, string ScanLotCode, SqlCommand cmd, Dictionary language) { try { //根据Sys_SRM_Items.F_Description备注列维护的提前天数，比如维护的是1，最早条码是2022.5.16，现在扫描2022.5.17的条码也能出库，扫描2022.5.18的条码不能直接出，需要校验以下逻辑 string sql = @"DECLARE @CountNO INT,@Days INT SELECT @Days=F_Description FROM Sys_SRM_Items WHERE F_EnCode='FIFO' SET @CountNO=( SELECT COUNT(a.LotNO) FROM ICSWareHouseLotInfo a INNER JOIN ICSInventoryLot b ON a.LotNO=b.LotNO AND a.WorkPoint=b.WorkPoint WHERE a.WorkPoint='{1}' AND ISNULL(a.Quantity,0)>0 AND 1=1 AND CONVERT(varchar(100), a.InDate, 23)< (SELECT DATEADD(DAY, -@Days, CONVERT(varchar(100), x.InDate, 23)) FROM ICSWareHouseLotInfo x INNER JOIN ICSInventoryLot y ON x.LotNO=y.LotNO AND x.WorkPoint=y.WorkPoint WHERE x.LotNO='{0}' AND x.WorkPoint='{1}' AND y.INVCode=b.INVCode AND y.ExtensionID=b.ExtensionID) ) IF @CountNO>0 BEGIN SELECT TOP 1 CASE a.F_ItemCode WHEN 'FIFO01' THEN '1' WHEN 'FIFO02' THEN '2' ELSE '3' END AS Type FROM Sys_SRM_ItemsDetail a INNER JOIN Sys_SRM_Items b ON a.F_ItemId=b.F_Id WHERE b.F_EnCode='FIFO' AND a.F_EnabledMark='1' ORDER BY a.F_SortCode DESC END ELSE BEGIN SELECT @CountNO END"; //0 - 已经是最早的批次 //1 - 不管控 //2 - 提醒 //3 - 限制 sql = string.Format(sql, LotNo, WorkPoitCode); if (!string.IsNullOrWhiteSpace(ScanLotCode)) { sql = sql.Replace("1=1", "a.LotNO NOT IN (" + ScanLotCode + ")"); } var res = DBHelper.ExecuteScalar(sql, cmd).ToString(); if (string.IsNullOrWhiteSpace(res)) { throw new Exception(language.GetNameByCode("WMSAPIInfo183"));//"查询管控信息失败!"); } else return res; } catch (Exception ex) { throw new Exception(ex.Message); } } ///

/// 保质期管控 ///

/// /// /// /// public static string Effective(string LotNo, string WorkPoitCode, SqlCommand cmd, Dictionary language) { try { //根据Sys_SRM_Items.F_Description备注列维护的提前天数，比如维护的是1，最早条码是2022.5.16，现在扫描2022.5.17的条码也能出库，扫描2022.5.18的条码不能直接出，需要校验以下逻辑 string sql = @"DECLARE @CountNO INT,@Days INT,@CurrentDays INT SELECT @CountNO=EffectiveEnable,@Days=EffectiveDays,@CurrentDays=DATEDIFF(DAY, c.InDate, GETDATE()) FROM ICSInventory a INNER JOIN ICSInventoryLot b ON a.InvCode=b.InvCode AND a.WorkPoint=b.WorkPoint INNER JOIN ICSWareHouseLotInfo c ON b.LotNO=c.LotNO AND b.WorkPoint=c.WorkPoint WHERE b.LotNO='{0}' AND b.WorkPoint='{1}' IF @CountNO='1' AND @CurrentDays>@Days BEGIN SELECT TOP 1 CASE a.F_ItemCode WHEN 'Effective01' THEN '1' WHEN 'Effective02' THEN '2' ELSE '3' END AS Type FROM Sys_SRM_ItemsDetail a INNER JOIN Sys_SRM_Items b ON a.F_ItemId=b.F_Id WHERE b.F_EnCode='Effective' AND a.F_EnabledMark='1' ORDER BY a.F_SortCode DESC END ELSE BEGIN SELECT @CountNO END"; //0 - 已经是最早的批次 //1 - 不管控 //2 - 提醒 //3 - 限制 sql = string.Format(sql, LotNo, WorkPoitCode); var res = DBHelper.ExecuteScalar(sql, cmd).ToString(); if (string.IsNullOrWhiteSpace(res)) { throw new Exception(language.GetNameByCode("WMSAPIInfo183"));//"查询管控信息失败!"); } else return res; } catch (Exception ex) { throw new Exception(ex.Message); } } #region 包装 ///

/// 查询包装信息 ///

/// /// public static object ContainerGet(ICSContainer JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; //目标包装 if (JsonData.ToContainerCode != null) { sql = @"IF NOT EXISTS(SELECT ID FROM ICSContainer WHERE ContainerCODE ='{0}' and WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo072") + @"',16,1); RETURN END SELECT ContainerCode,ContainerName FROM ICSContainer WHERE ContainerCODE ='{0}' and WorkPoint='{1}'"; sql = string.Format(sql, JsonData.ToContainerCode, JsonData.WorkPoint); } ///原包装 else if (JsonData.FromContainerCode != null) { sql = @"IF NOT EXISTS(SELECT ID FROM ICSContainer WHERE ContainerCODE ='{0}' and WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo072") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSContainer a INNER JOIN ICSContainerLot b ON a.ID=b.ContainerID WHERE a.ContainerCODE ='{0}' and a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo073") + @"',16,1); RETURN END SELECT ContainerCode,ContainerName FROM ICSContainer WHERE ContainerCODE ='{0}' and WorkPoint='{1}'"; sql = string.Format(sql, JsonData.FromContainerCode, JsonData.WorkPoint); } else { throw new Exception(language.GetNameByCode("WMSAPIInfo029"));//"请传入包装条码！"); } DataTable table = DBHelper.SQlReturnData(sql, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 修改包装信息 ///

/// /// public static DataTable ContainerUpdate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = string.Empty; string codes = string.Empty; foreach (ICSContainer container in JsonData) { sql = @"IF NOT EXISTS(SELECT ID FROM ICSContainer WHERE ContainerCODE ='{0}' and WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo072") + @"',16,1); RETURN END IF NOT EXISTS(SELECT a.ID FROM ICSContainer a INNER JOIN ICSContainerLot b ON a.ID=b.ContainerID WHERE a.ContainerCODE ='{0}' and a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo073") + @"',16,1); RETURN END IF NOT EXISTS(SELECT ID FROM ICSContainer WHERE ContainerCODE ='{2}' and WorkPoint='{1}') BEGIN RAISERROR('" + string.Format(language.GetNameByCode("WMSAPIInfo072"), "{2}") + @"',16,1); RETURN END UPDATE b SET ContainerID=c.ID FROM ICSContainer a INNER JOIN ICSContainerLot b ON a.ID=b.ContainerID INNER JOIN ICSContainer c ON c.ContainerCODE ='{2}' and a.WorkPoint=c.WorkPoint WHERE a.ContainerCODE ='{0}' and a.WorkPoint='{1}'"; sql = string.Format(sql, container.FromContainerCode, container.WorkPoint, container.ToContainerCode); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo030"));//"包装更新失败！"); } codes += "'" + container.ToContainerCode + container.WorkPoint + "',"; } sql = @"SELECT a.ContainerCode, a.ContainerName,b.LotNo FROM ICSContainer a INNER JOIN ICSContainerLot b ON a.ID=b.ContainerID WHERE a.ContainerCODE+a.WorkPoint='{0}'"; sql = string.Format(sql, codes); DataTable table = DBHelper.SQlReturnData(sql, cmd); cmd.Transaction.Commit(); return table; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 盘点 ///

/// 创建盘点单 ///

/// /// public static DataTable CheckCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string Code = string.Empty; string sql = string.Empty; foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.User)) { throw new Exception(language.GetNameByCode("WMSAPIInfo018"));//"操作人不能为空！"); } if (string.IsNullOrEmpty(item.WorkPoint)) { throw new Exception(language.GetNameByCode("WMSAPIInfo004"));//"站点不能为空！" } //获取单号 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{0}' AND F_Location='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo060") + @"',16,1); RETURN END DECLARE @MaxNO INT,@date varchar(20)='CHK'+SUBSTRING(CONVERT(varchar(8), GETDATE(), 112), 1, 8) SELECT @MaxNO=SUBSTRING(MAX(CheckCode),LEN(@date)+1,LEN(MAX(CheckCode))-LEN(@date))+1 FROM ICSCheck WHERE SUBSTRING(CheckCode, 1, LEN(@date))=@date IF @MaxNO IS NULL BEGIN SELECT @date+'00001' AS Code END ELSE BEGIN SELECT @date+REPLICATE('0',5-LEN(@MaxNO))+CAST(@MaxNO AS nvarchar(10)) AS Code END "; sql = string.Format(sql, item.User, item.WorkPoint); Code = DBHelper.ExecuteScalar(sql, cmd).ToString(); //创建盘点单 foreach (var itemInfo in item.detail) { sql = @"IF NOT EXISTS(SELECT WarehouseCode FROM ICSWareHouseLotInfo WHERE WarehouseCode='{1}' AND WorkPoint='{3}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo074") + @"',16,1); RETURN END INSERT INTO ICSCheck (ID,CheckCode,WHCode,InvCode,Status,Quantity,Amount,ActualQuantity,ActualAmount,MUSER,MUSERName,MTIME,WorkPoint) SELECT NEWID(),'{0}',a.WarehouseCode,a.InvCode,'2',SUM(a.Quantity),0,0,0,b.F_Account,b.F_RealName,GETDATE(),a.WorkPoint FROM ICSWareHouseLotInfo a INNER JOIN Sys_SRM_User b ON b.F_Account='{2}' AND b.F_Location='{3}' WHERE a.WarehouseCode='{1}' and a.WorkPoint='{3}' GROUP BY a.WarehouseCode,a.InvCode,b.F_Account,b.F_RealName,a.WorkPoint"; sql = string.Format(sql, Code, itemInfo.WHCode, item.User, item.WorkPoint); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo031"));//"盘点单创建失败！"); } } } if (string.IsNullOrWhiteSpace(Code)) { throw new Exception(language.GetNameByCode("WMSAPIInfo032"));//"盘点单单号不能为空！"); } #region 查询返回数据 sql = @"SELECT a.ID,a.CheckCode,a.WHCode,a.ActualQuantity,a.ActualAmount, a.InvCode, inv.InvName, inv.InvStd, a.Quantity, inv.InvUnit, a.Amount, inv.AmountUnit, a.MUSER AS [User], a.MTIME AS [MTime] FROM ICSCheck a INNER JOIN ICSInventory inv ON a.InvCode=inv.InvCode AND a.WorkPoint=inv.WorkPoint WHERE a.CheckCode='{0}'"; sql = string.Format(sql, Code); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } ///

/// 盘点扫描 ///

/// /// public static DataTable LOTCheckCreate(List JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); if (JsonData.Count <= 0) { throw new Exception(language.GetNameByCode("WMSAPIInfo007"));//"传送数据为空！" } using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string lots = string.Empty; string sql = string.Empty; string Identification = Guid.NewGuid().ToString(); foreach (var item in JsonData) { if (string.IsNullOrEmpty(item.User)) { throw new Exception(language.GetNameByCode("WMSAPIInfo018"));//"操作人不能为空！"); } if (string.IsNullOrEmpty(item.WorkPoint)) { throw new Exception(language.GetNameByCode("WMSAPIInfo004"));//"站点不能为空！" } if (string.IsNullOrEmpty(item.CheckCode)) { throw new Exception(language.GetNameByCode("WMSAPIInfo032"));//"盘点单号不能为空！"); } //校验 sql = @"IF NOT EXISTS(SELECT F_Account FROM Sys_SRM_User WHERE F_Account='{0}' AND F_Location='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo060") + @"',16,1); RETURN END IF NOT EXISTS(SELECT ID FROM ICSCheck WHERE CheckCode='{2}' AND WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo075") + @"',16,1); RETURN END"; sql = string.Format(sql, item.User, item.WorkPoint, item.CheckCode); DBHelper.ExecuteNonQuery(sql, cmd); //创建盘点单 foreach (var itemInfo in item.detail) { sql = @"IF NOT EXISTS(SELECT LotNo FROM ICSWareHouseLotInfo WHERE LotNo='{1}' AND WorkPoint='{3}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo076") + @"',16,1); RETURN END IF EXISTS(SELECT LotNo FROM ICSCheckDetail WHERE CheckCode='{0}' AND LotNo='{1}' AND WorkPoint='{3}') BEGIN UPDATE a SET ActualQuantity='{4}',MUSER=b.F_Account,MUSERName=b.F_RealName,MTIME=GETDATE() FROM ICSCheckDetail a INNER JOIN Sys_SRM_User b ON b.F_Account='{2}' AND b.F_Location='{3}' WHERE a.CheckCode='{0}' AND a.LotNo='{1}' and a.WorkPoint='{3}' END ELSE BEGIN INSERT INTO ICSCheckDetail (ID,CheckCode,LotNo,Quantity,ActualQuantity,MUSER,MUSERName,MTIME,WorkPoint) SELECT NEWID(),'{0}',a.LotNo,a.Quantity,'{4}',b.F_Account,b.F_RealName,GETDATE(),a.WorkPoint FROM ICSWareHouseLotInfo a INNER JOIN Sys_SRM_User b ON b.F_Account='{2}' AND b.F_Location='{3}' WHERE a.LotNo='{1}' and a.WorkPoint='{3}' END"; sql = string.Format(sql, item.CheckCode, itemInfo.LotNo, item.User, item.WorkPoint, itemInfo.ActualQuantity); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo033"));//"盘点扫描创建失败！"); } #region 更新库存 if (item.UpdateWHLI) { ICSWareHouseLotInfoService.WareHouseLotInfoUpdate(Identification, item.CheckCode, "", itemInfo.LotNo, itemInfo.ActualQuantity, item.User, item.WorkPoint, "9", cmd, language); } #endregion lots += "'" + itemInfo.LotNo + item.WorkPoint + "',"; } if (string.IsNullOrWhiteSpace(lots)) { throw new Exception(language.GetNameByCode("WMSAPIInfo005"));//"请传入条码信息！"); } sql = @"UPDATE a SET ActualQuantity=b.ActualQuantity FROM ICSCheck a INNER JOIN (SELECT x.CheckCode,x.WorkPoint,y.WarehouseCode,y.InvCode,SUM(ActualQuantity) AS ActualQuantity FROM ICSCheckDetail x INNER JOIN ICSWareHouseLotInfo y ON x.LotNo=y.LotNo AND x.WorkPoint=y.WorkPoint WHERE x.LotNo+x.WorkPoint IN ({2}) GROUP BY x.CheckCode,x.WorkPoint,y.WarehouseCode,y.InvCode) b ON a.CheckCode=b.CheckCode AND a.WorkPoint=b.WorkPoint AND a.WHCode=b.WarehouseCode AND a.InvCode=b.InvCode WHERE a.CheckCode='{0}' and a.WorkPoint='{1}'"; sql = string.Format(sql, item.CheckCode, item.WorkPoint, lots.Substring(0, lots.Length - 1)); if (!DBHelper.ExecuteNonQuery(sql, cmd)) { throw new Exception(language.GetNameByCode("WMSAPIInfo034"));//"盘点扫描更新盘点单失败！"); } } #region 查询返回数据 sql = @"SELECT x.ID,x.CheckCode,y.WarehouseCode AS WHCode,x.LotNo, y.InvCode, inv.InvName, inv.InvStd, x.Quantity,x.ActualQuantity, inv.InvUnit, x.MUSER AS [User], x.MTIME AS [MTime] FROM ICSCheckDetail x INNER JOIN ICSWareHouseLotInfo y ON x.LotNo=y.LotNo AND x.WorkPoint=y.WorkPoint INNER JOIN ICSInventory inv ON y.InvCode=inv.InvCode AND y.WorkPoint=inv.WorkPoint WHERE x.LotNo+x.WorkPoint IN ({0})"; sql = string.Format(sql, lots.Substring(0, lots.Length - 1)); DataTable data = DBHelper.SQlReturnData(sql, cmd); #endregion cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 多语言 ///

/// 多语言查询 ///

/// /// public static DataTable PromptInformationGet(WMSBarCoreModel JsonData) { using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; try { string sql = @"select cnValue AS Name,Code from Sys_Language where 1=1"; if (!string.IsNullOrWhiteSpace(JsonData.Code)) { sql += " and Code LIKE '%{0}%'"; } sql = string.Format(sql, JsonData.Code); DataTable data = DBHelper.SQlReturnData(sql, cmd); return data; } catch (Exception ex) { log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 仓库/库位 ///

/// 仓库/库位 ///

/// /// public static DataTable LocationGet(ICSLocation JsonData) { var language = LanguageHelper.GetName("WMSAPIInfo"); using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlTransaction sqlTran = conn.BeginTransaction(); SqlCommand cmd = new SqlCommand(); cmd.Transaction = sqlTran; cmd.Connection = conn; try { string sql = @"IF NOT EXISTS(SELECT LocationCode FROM ICSLocation a where LocationCode='{0}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo070") + @"',16,1); RETURN END IF NOT EXISTS(SELECT LocationCode FROM ICSLocation a INNER JOIN ICSWarehouse b on a.WHID=b.ID and a.WorkPoint=b.WorkPoint where LocationCode='{0}' AND a.WorkPoint='{1}') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo077") + @"',16,1); RETURN END IF NOT EXISTS(SELECT LocationCode FROM ICSLocation a INNER JOIN ICSWarehouse b on a.WHID=b.ID and a.WorkPoint=b.WorkPoint where LocationCode='{0}' AND a.WorkPoint='{1}' and b.Enable='1') BEGIN RAISERROR('" + language.GetNameByCode("WMSAPIInfo078") + @"',16,1); RETURN END SELECT LocationCode, LocationName , WarehouseCode, WarehouseName FROM ICSLocation a INNER JOIN ICSWarehouse b on a.WHID=b.ID and a.WorkPoint=b.WorkPoint where LocationCode='{0}' AND a.WorkPoint='{1}' and b.Enable='1'"; sql = string.Format(sql, JsonData.LocationCode, JsonData.WorkPoint); DataTable data = DBHelper.SQlReturnData(sql, cmd); cmd.Transaction.Commit(); return data; } catch (Exception ex) { if (cmd.Transaction != null) cmd.Transaction.Rollback(); log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion #region 登陆 public static object CheckLogin(Sys_SRM_User userModel) { using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString)) { conn.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; try { string sql = @"select F_Account from Sys_SRM_User where F_Account='{0}' and F_Location='{1}' and F_EnabledMark='1'";//已经启用的账号 sql = string.Format(sql, userModel.UserCode, userModel.WorkPoint); DataTable dt = DBHelper.SQlReturnData(sql, cmd); if (dt != null && dt.Rows.Count > 0)//查询的数据不为空 { sql = @" select a.[F_Id] as UserId ,[F_Account] as userCode ,[F_RealName] as UserName ,[F_NickName] ,b.F_UserPassword ,b.F_UserSecretkey ,[F_HeadIcon] ,[F_Gender] ,[F_Birthday] ,[F_MobilePhone] ,[F_Email] ,[F_WeChat] ,[F_ManagerId] ,[F_SecurityLevel] ,[F_Signature] ,[F_OrganizeId] ,[F_DepartmentId] ,[F_RoleId] ,[F_DutyId] ,[F_IsAdministrator] ,[F_SortCode] ,[F_DeleteMark] ,[F_EnabledMark] ,[F_Description] ,[F_CreatorTime] ,[F_CreatorUserId] ,[F_LastModifyTime] ,[F_LastModifyUserId] ,[F_DeleteTime] ,[F_DeleteUserId] ,[F_Location] as WorkPoint ,[F_VenCode] from Sys_SRM_User a left join Sys_SRM_UserLogOn b on b.F_UserId=a.F_Id where F_Account='{0}' and F_Location='{1}' and F_EnabledMark='1'"; sql = string.Format(sql, userModel.UserCode, userModel.WorkPoint); dt = DBHelper.SQlReturnData(sql, cmd); IList users = DBHelper.ModelConvertHelper.ConvertToModel(dt); // string dbPassword = Md5.md5(DESEncrypt.Encrypt(userModel.F_UserPassword.ToLower(), item.F_UserSecretkey.ToLower()).ToLower(), 32).ToLower(); foreach (var item in users) { //string UserPassword = Md5.md5(DESEncrypt.Encrypt(userModel.F_UserPassword.ToLower()),16).ToLower(); string dbPassword = Md5.md5(DESEncrypt.Encrypt(userModel.UserPassword.ToLower(), item.F_UserSecretkey.ToLower()).ToLower(), 32).ToLower(); if (dbPassword == item.F_UserPassword) { string json = JsonConvert.SerializeObject(dt); List userLogOnEntity = JsonConvert.DeserializeObject>(json); return userLogOnEntity; } else { throw new Exception(LanguageHelper.GetNameSingle("WMSAPI004"));//"密码不正确，请重新输入"); } } } else { throw new Exception(LanguageHelper.GetNameSingle("WMSAPI005"));//"用户名不存在,请重新输入!"); } return null; } catch (Exception ex) { log.Error(ex.Message); throw new Exception(ex.Message); } finally { if (conn.State == ConnectionState.Open) { conn.Close(); } conn.Dispose(); } } } #endregion } }