using DapperORMCore.Context.DataContext; using DapperORMCore.Model.CoreModel; using DapperORMCore.Repository.IRepositorys; using Microsoft.Extensions.Configuration; using NXWMS.IService.NXWMS; using NXWMS.IService.NXWMS.Instock; using NXWMS.Model.AppModels.Condition.Instock; using NXWMS.Model.Common; using System; using System.Collections.Generic; using System.Linq; using System.ServiceProcess; //using System.Runtime.InteropServices.WindowsRuntime; using System.Text; using System.Threading.Tasks; using WestDistance.DapperORM.Repository.Repositorys; namespace NXWMS.Service.NXWMS.Instock { /// /// 到货通知单服务 /// [AutoInject(typeof(IWmsInArrivalService), InjectType.Scope)] public class WmsInArrivalService : ServiceBase, IWmsInArrivalService { #region 全局变量、构造注入 /// /// 系统操作仓储中转 /// private IDataRepositoryContext _dataContext; /// /// SQL节点仓储 /// private ISQLNodeRepository _iSQLNodeRepository; /// /// 配置 /// private IConfiguration _configuration; private IErpSyncServer _syncServer; /// /// 构造注入 /// /// /// /// public WmsInArrivalService(IDataRepositoryContext dataRepositoryContext, IConfiguration configuration, ISQLNodeRepository iSQLNodeRepository, IErpSyncServer erpSyncServer) { this._dataContext = dataRepositoryContext; this._configuration = configuration; this._iSQLNodeRepository = iSQLNodeRepository; this._syncServer = erpSyncServer; } #endregion #region 到货通知单主表 /// /// 分页查询到货通知单主表数据 /// /// 到货通知单查询条件实体类对象 /// public OperateResultInfo> GetWmsInArrivalListForPage(WmsInArrivalSearchMd arrivalSearchMd) { try { #region SQL语句生成 StringBuilder sqlCondition = new StringBuilder(); if (!string.IsNullOrEmpty(arrivalSearchMd.ArrivalNoMsg)) { sqlCondition.Append($" AND ARRIVAL_NO = '{arrivalSearchMd.ArrivalNoMsg}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.SourceNoMsg)) { sqlCondition.Append($" AND SOURCE_BILL_NO = '{arrivalSearchMd.SourceNoMsg}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.WarehouseMsg)) { sqlCondition.Append($" AND WAREHOUSE_CODE = '{arrivalSearchMd.WarehouseMsg}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.PurchaseStaffMsg)) { sqlCondition.Append($" AND PURCHASE_STAFF = '{arrivalSearchMd.PurchaseStaffMsg}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.ArrivalTypeMsg)) { sqlCondition.Append($" AND ARRIVAL_TYPE = '{arrivalSearchMd.ArrivalTypeMsg}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.ArrivalStatus)) { sqlCondition.Append($" AND ARRIVAL_STATUS = '{arrivalSearchMd.ArrivalStatus}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.MaterialMsg)) { sqlCondition.Append($" AND ARRIVAL_ID IN (SELECT ARRIVAL_ID FROM VW_WMS_IN_ARRIVAL_DTL WHERE MATERIEL_CODE LIKE '%{arrivalSearchMd.MaterialMsg}%' OR MATERIEL_NAME LIKE '%{arrivalSearchMd.MaterialMsg}%' OR MATERIEL_BARCODE LIKE '%{arrivalSearchMd.MaterialMsg}%')"); } if (!string.IsNullOrEmpty(arrivalSearchMd.SupplierMsg)) { sqlCondition.Append($" AND ARRIVAL_ID IN (SELECT ARRIVAL_ID FROM VW_WMS_IN_ARRIVAL_DTL WHERE SUPPLIER_CODE LIKE '%{arrivalSearchMd.SupplierMsg}%' OR SUPPLIER_NAME LIKE '%{arrivalSearchMd.SupplierMsg}%')"); } if (!string.IsNullOrEmpty(arrivalSearchMd.StartCreateTime)) { sqlCondition.Append($" AND CREATE_TIME >= '{arrivalSearchMd.StartCreateTime}'"); } if (!string.IsNullOrEmpty(arrivalSearchMd.EndCreateTime)) { sqlCondition.Append($" AND CREATE_TIME <= '{arrivalSearchMd.EndCreateTime}'"); } //StringBuilder sqlCountArrivalData = new StringBuilder($@"SELECT COUNT(1) FROM VW_WMS_IN_ARRIVAL WHERE 1=1"); //sqlCountArrivalData.Append(sqlCondition.ToString()); int pageStartIndex = (arrivalSearchMd.PageNum - 1) * arrivalSearchMd.EveryPageQty; int pageEndIndex = arrivalSearchMd.PageNum * arrivalSearchMd.EveryPageQty; //StringBuilder sqlQueryArrivalData = new StringBuilder($@" // SELECT // ARRIVAL_ID, // ARRIVAL_NO, // SOURCE_BILL_NO, // ARRIVAL_TYPE, // ARRIVAL_TYPE_NAME, // PURCHASE_ORDER_NO, // PURCHASE_STAFF, // PURCHASE_TIME, // WAREHOUSE_CODE, // WAREHOUSE_NAME, // ARRIVAL_STATUS, // ARRIVAL_STATUS_NAME, // EXPECT_ARRIVAL_TIME, // ACTUAL_ARRIVAL_TIME, // DESCRIBE, // CREATE_BY, // CREATE_NAME, // CREATE_TIME, // UPDATE_BY, // UPDATE_NAME, // UPDATE_TIME // FROM // VW_WMS_IN_ARRIVAL // WHERE // 1=1 // {sqlCondition} // ORDER BY UPDATE_TIME DESC,CREATE_TIME DESC // OFFSET {pageStartIndex} ROWS // FETCH NEXT {arrivalSearchMd.EveryPageQty} ROWS ONLY // "); StringBuilder sqlQueryArrivalData = new StringBuilder($@" SELECT ARRIVAL_ID, ARRIVAL_NO, SOURCE_BILL_NO, ARRIVAL_TYPE, ARRIVAL_TYPE_NAME, PURCHASE_ORDER_NO, PURCHASE_STAFF, PURCHASE_TIME, WAREHOUSE_CODE, WAREHOUSE_NAME, ARRIVAL_STATUS, ARRIVAL_STATUS_NAME, EXPECT_ARRIVAL_TIME, ACTUAL_ARRIVAL_TIME, DESCRIBE, CREATE_BY, CREATE_NAME, CREATE_TIME, UPDATE_BY, UPDATE_NAME, UPDATE_TIME FROM VW_WMS_IN_ARRIVAL WHERE 1=1 {sqlCondition} "); #endregion //int dataCount = Convert.ToInt32(new DataRepository(_dataContext).ExecuteScalar(sqlCountArrivalData.ToString())); //List resultList = new DataRepository(_dataContext).Query(sqlQueryArrivalData.ToString()).ToList(); (var count, var data) = new DataRepository(_dataContext).QueryPageByCount(sqlQueryArrivalData.ToString(), " UPDATE_TIME DESC,CREATE_TIME", arrivalSearchMd.EveryPageQty, arrivalSearchMd.PageNum, true); OperateResultInfo> retDataMsg = SuccessStatus(data.ToList()); retDataMsg.DataCount = count; return retDataMsg; } catch (Exception ex) { return FailMessageStatus>($"查询到货通知单数据发生异常,【{ex.Message}】", null); } } /// /// 获取未完成的到货通知单数据 /// /// public OperateResultInfo> GetWmsInArrivalList_InComplete() { try { StringBuilder sqlQueryArrivalData = new StringBuilder($@" SELECT ARRIVAL_ID, ARRIVAL_NO, SOURCE_BILL_NO, ARRIVAL_TYPE, ARRIVAL_TYPE_NAME, PURCHASE_ORDER_NO, PURCHASE_STAFF, PURCHASE_TIME, WAREHOUSE_CODE, WAREHOUSE_NAME, ARRIVAL_STATUS, ARRIVAL_STATUS_NAME, EXPECT_ARRIVAL_TIME, ACTUAL_ARRIVAL_TIME, DESCRIBE, CREATE_BY, CREATE_NAME, CREATE_TIME, UPDATE_BY, UPDATE_NAME, UPDATE_TIME FROM VW_WMS_IN_ARRIVAL WHERE 1=1 AND ARRIVAL_STATUS < 99 AND ARRIVAL_ID IN (SELECT ARRIVAL_ID FROM VW_WMS_IN_ARRIVAL_DTL WHERE ARRIVAL_DTL_STATUS < 99 AND RECEIPT_QTY < ARRIVAL_QTY) ORDER BY UPDATE_TIME DESC,CREATE_TIME DESC; "); List resultList = new DataRepository(_dataContext).Query(sqlQueryArrivalData.ToString()).ToList(); OperateResultInfo> retDataMsg = SuccessStatus(resultList); return retDataMsg; } catch (Exception ex) { return FailMessageStatus>($"查询为完成的到货通知单数据发生异常,【{ex.Message}】", null); } } /// /// 根据到货通知单主键Id查询到货通知单明细数据 /// /// 到货通知单实体类对象 /// public OperateResultInfo GetWmsInArrivalDtlListForID(WmsInArrivalResult wmsInArrival) { try { #region SQL语句生成 string sqlQueryWmsInArrival = $@" SELECT ARRIVAL_ID, ARRIVAL_NO, SOURCE_BILL_NO, ARRIVAL_TYPE, ARRIVAL_TYPE_NAME, PURCHASE_ORDER_NO, PURCHASE_STAFF, PURCHASE_TIME, WAREHOUSE_CODE, WAREHOUSE_NAME, ARRIVAL_STATUS, ARRIVAL_STATUS_NAME, EXPECT_ARRIVAL_TIME, ACTUAL_ARRIVAL_TIME, DESCRIBE, CREATE_BY, CREATE_NAME, CREATE_TIME, UPDATE_BY, UPDATE_NAME, UPDATE_TIME FROM VW_WMS_IN_ARRIVAL WHERE ARRIVAL_ID = '{wmsInArrival.ArrivalId}' "; string strWhere = string.Empty; if (wmsInArrival.Remarks1 == "查询已删除明细数据") { strWhere = "1=1"; } else { strWhere = "ARRIVAL_DTL_STATUS < 99"; } string sqlQueryWmsInArivalDtl = $@" SELECT * FROM VW_WMS_IN_ARRIVAL_DTL WHERE ARRIVAL_ID = '{wmsInArrival.ArrivalId}' AND {strWhere} ORDER BY ARRIVAL_DTL_STATUS,ARRIVAL_DTL_ID "; #endregion List resultList = new DataRepository(_dataContext).Query(sqlQueryWmsInArrival).ToList(); List resultDtlList = new DataRepository(_dataContext).Query(sqlQueryWmsInArivalDtl).ToList(); wmsInArrival = resultList[0]; wmsInArrival.WmsInArrivalDtlList = resultDtlList; OperateResultInfo retDataMsg = SuccessStatus(wmsInArrival); return retDataMsg; } catch (Exception ex) { return FailMessageStatus($"查询到货通知单明细数据发生异常,【{ex.Message}】", null); } } /// /// 根据到货通知单号查询到货通知单明细数据 /// /// 到货通知单实体类对象 /// public async Task>> GetWmsInArrivalDtlDataForNo(WmsInArrivalResult wmsInArrival) { try { var info = await this._syncServer.UpdateArrival(wmsInArrival.ArrivalNo); string sqlCondition = $" AND RECEIPT_QTY < ARRIVAL_QTY"; if (wmsInArrival.Remarks1 == "编辑收货单") { sqlCondition = ""; } string sqlQueryWmsInArivalDtl = $@" SELECT * FROM VW_WMS_IN_ARRIVAL_DTL WHERE ARRIVAL_NO = '{wmsInArrival.ArrivalNo}' {sqlCondition} AND ARRIVAL_DTL_STATUS < 99 AND INSPECTION_RESULT = 'OK' "; List resultDtlList = new DataRepository(_dataContext).Query(sqlQueryWmsInArivalDtl).ToList(); OperateResultInfo> retDataMsg = SuccessStatus(resultDtlList); return retDataMsg; } catch (Exception ex) { return FailMessageStatus>($"查询到货通知单明细数据发生异常,【{ex.Message}】", null); } } /// /// 查询待检验的到货通知单数据 /// /// public OperateResultInfo> GetAllWaitForQaArrivalDtlData() { try { string sqlQueryWaitQaReceiptDtl = "SELECT * FROM VW_WMS_IN_ARRIVAL_DTL WHERE ARRIVAL_DTL_STATUS = 0 AND INSPECTION_RESULT = 'Wait'"; List resultList = new DataRepository(_dataContext).Query(sqlQueryWaitQaReceiptDtl).ToList(); OperateResultInfo> retDataMsg = SuccessStatus(resultList); return retDataMsg; } catch (Exception ex) { return FailMessageStatus>($"查询待检验的到货通知单数据发生异常,【{ex.Message}】", null); } } /// /// 新增到货通知单数据 /// /// 到货通知单主表对象 /// public OperateResultInfo AddWmsInArrivalData(WmsInArrivalResult wmsInArrival) { try { #region SQL语句生成 List sqlList = new List(); wmsInArrival.ArrivalId = Convert.ToInt32(new DataRepository(_dataContext).GetSequenceMsg("Arrival_Id")); wmsInArrival.ArrivalNo = new DataRepository(_dataContext).GetSequenceMsg("Arrival_No"); wmsInArrival.ArrivalStatus = 0; StringBuilder sqlAddWmsInArrival = new StringBuilder(); string purchaseTime = DateTime.Compare(wmsInArrival.PurchaseTime, new DateTime()) == 0 ? "NULL" : $"'{wmsInArrival.PurchaseTime}'"; string expectArrTime = DateTime.Compare(wmsInArrival.ExpectArrivalTime, new DateTime()) == 0 ? "NULL" : $"'{wmsInArrival.ExpectArrivalTime}'"; sqlAddWmsInArrival.Append($@" INSERT INTO [WMS_IN_ARRIVAL] ( [ARRIVAL_ID], [ARRIVAL_NO], [SOURCE_BILL_NO], [ARRIVAL_TYPE], [PURCHASE_ORDER_NO], [PURCHASE_TIME], [PURCHASE_STAFF], [WAREHOUSE_CODE], [WAREHOUSE_NAME], [ARRIVAL_STATUS], [EXPECT_ARRIVAL_TIME], [ACTUAL_ARRIVAL_TIME], [DESCRIBE], [CREATE_BY], [CREATE_TIME], [UPDATE_BY], [UPDATE_TIME], [DATA_VERSION], [REMARKS1], [REMARKS2], [REMARKS3], [REMARKS4], [REMARKS5] ) VALUES ( '{wmsInArrival.ArrivalId}', '{wmsInArrival.ArrivalNo}', '{wmsInArrival.SourceBillNo}', '{wmsInArrival.ArrivalType}', '{wmsInArrival.PurchaseOrderNo}', {purchaseTime}, '{wmsInArrival.PurchaseStaff}', '{wmsInArrival.WarehouseCode}', '{wmsInArrival.WarehouseName}', '{wmsInArrival.ArrivalStatus}', {expectArrTime}, NULL, '{wmsInArrival.Describe}', '{wmsInArrival.CreateBy}', GETDATE(), '{wmsInArrival.UpdateBy}', GETDATE(), '0', NULL, NULL, NULL, NULL, NULL ); "); sqlList.Add(sqlAddWmsInArrival.ToString()); foreach (WmsInArrivalDtlResult item in wmsInArrival.WmsInArrivalDtlList) { StringBuilder sqlAddWmsInArrivalDtl = new StringBuilder(); item.ArrivalDtlId = Convert.ToInt32(new DataRepository(_dataContext).GetSequenceMsg("Arrival_Dtl_Id")); item.ArrivalId = wmsInArrival.ArrivalId; item.ArrivalDtlStatus = 0; sqlAddWmsInArrivalDtl.Append($@" INSERT INTO [WMS_IN_ARRIVAL_DTL] ( [ARRIVAL_DTL_ID], [ARRIVAL_ID], [MATERIEL_CODE], [MATERIEL_NAME], [MATERIEL_BARCODE], [BATCH_NO], [PACKAGE_CODE], [UNIT_CODE], [ARRIVAL_QTY], [RECEIPT_QTY], [SUPPLIER_CODE], [SUPPLIER_NAME], [PRODUCT_DATE], [EXP_DATE], [ARRIVAL_DTL_STATUS], [INSPECTION_RESULT], [SOURCE_BILL_DTL_IDX], [PURCHASE_ORDER_DTL_IDX], [PURCHASE_ORDER_DTL_STATUS], [DESCRIBE], [CREATE_BY], [CREATE_TIME], [UPDATE_BY], [UPDATE_TIME], [DATA_VERSION], [REMARKS1], [REMARKS2], [REMARKS3], [REMARKS4], [REMARKS5] ) VALUES ( '{item.ArrivalDtlId}', '{item.ArrivalId}', '{item.MaterielCode}', '{item.MaterielName}', '{item.MaterielBarcode}', '{item.BatchNo}', '{item.PackageCode}', '{item.UnitCode}', '{item.ArrivalQty}', 0, '{item.SupplierCode}', '{item.SupplierName}', '{item.ProductDate}', '{item.ExpDate}', '{item.ArrivalDtlStatus}', 'OK', NULL, NULL, NULL, '{item.Describe}', '{item.CreateBy}', GETDATE(), '{item.UpdateBy}', GETDATE(), '0', NULL, NULL, NULL, NULL, NULL ); "); sqlList.Add(sqlAddWmsInArrivalDtl.ToString()); } #endregion int row = new DataRepository(_dataContext).ExecSqlListTran(sqlList); if (row > 0) { return SuccessMessageStatus("新增到货通知单数据成功!", row); } else { return FailMessageStatus("新增到货通知单数据失败!", row); } } catch (Exception ex) { return FailMessageStatus($"新增到货通知单数据发生异常,【{ex.Message}】"); } } /// /// 修改到货通知单数据 /// /// 到货通知单主表对象 /// public OperateResultInfo EditWmsInArrivalData(WmsInArrivalResult wmsInArrival) { try { #region SQL语句生成 List sqlList = new List(); string actualArrTime = DateTime.Compare(wmsInArrival.ActualArrivalTime, new DateTime()) == 0 ? "NULL" : $"'{wmsInArrival.ActualArrivalTime}'"; string expectArrTime = DateTime.Compare(wmsInArrival.ExpectArrivalTime, new DateTime()) == 0 ? "NULL" : $"'{wmsInArrival.ExpectArrivalTime}'"; string purchaseTime = DateTime.Compare(wmsInArrival.PurchaseTime, new DateTime()) == 0 ? "NULL" : $"'{wmsInArrival.PurchaseTime}'"; string sqlUpdateWmsInArrival = $@" UPDATE [WMS_IN_ARRIVAL] SET [ARRIVAL_NO] = '{wmsInArrival.ArrivalNo}', [SOURCE_BILL_NO] = '{wmsInArrival.SourceBillNo}', [ARRIVAL_TYPE] = '{wmsInArrival.ArrivalType}', [PURCHASE_ORDER_NO] = '{wmsInArrival.PurchaseOrderNo}', [PURCHASE_TIME] = {purchaseTime}, [PURCHASE_STAFF] = '{wmsInArrival.PurchaseStaff}', [WAREHOUSE_CODE] = '{wmsInArrival.WarehouseCode}', [WAREHOUSE_NAME] = '{wmsInArrival.WarehouseName}', [ARRIVAL_STATUS] = '{wmsInArrival.ArrivalStatus}', [EXPECT_ARRIVAL_TIME] = {expectArrTime}, [ACTUAL_ARRIVAL_TIME] = {actualArrTime}, [DESCRIBE] = '{wmsInArrival.Describe}', [UPDATE_BY] = '{wmsInArrival.UpdateBy}', [UPDATE_TIME] = GETDATE(), [DATA_VERSION] = [DATA_VERSION] + 1 WHERE [ARRIVAL_ID] = '{wmsInArrival.ArrivalId}'; "; sqlList.Add(sqlUpdateWmsInArrival); foreach (WmsInArrivalDtlResult item in wmsInArrival.WmsInArrivalDtlList) { if (item.Remarks1 == "更新" || item.Remarks1 == "删除") { string sqlUpdateWmsInArrivalDtl = $@" UPDATE [WMS_IN_ARRIVAL_DTL] SET [MATERIEL_CODE] = '{item.MaterielCode}', [MATERIEL_NAME] = '{item.MaterielName}', [MATERIEL_BARCODE] = '{item.MaterielBarcode}', [BATCH_NO] = '{item.BatchNo}', [PACKAGE_CODE] = '{item.PackageCode}', [UNIT_CODE] = '{item.UnitCode}', [ARRIVAL_QTY] = '{item.ArrivalQty}', [RECEIPT_QTY] = '{item.ReceiptQty}', [SUPPLIER_CODE] = '{item.SupplierCode}', [SUPPLIER_NAME] = '{item.SupplierName}', [PRODUCT_DATE] = '{item.ProductDate}', [EXP_DATE] = '{item.ExpDate}', [ARRIVAL_DTL_STATUS] = '{item.ArrivalDtlStatus}', [DESCRIBE] = '{item.Describe}', [UPDATE_BY] = '{item.UpdateBy}', [UPDATE_TIME] = GETDATE(), [DATA_VERSION] = [DATA_VERSION] + 1 WHERE [ARRIVAL_DTL_ID] = '{item.ArrivalDtlId}' AND [ARRIVAL_ID] = '{wmsInArrival.ArrivalId}'; "; sqlList.Add(sqlUpdateWmsInArrivalDtl); } if (item.Remarks1 == "添加") { StringBuilder sqlAddWmsInArrivalDtl = new StringBuilder(); item.ArrivalDtlId = Convert.ToInt32(new DataRepository(_dataContext).GetSequenceMsg("Arrival_Dtl_Id")); item.ArrivalId = wmsInArrival.ArrivalId; item.ArrivalDtlStatus = 0; sqlAddWmsInArrivalDtl.Append($@" INSERT INTO [WMS_IN_ARRIVAL_DTL] ( [ARRIVAL_DTL_ID], [ARRIVAL_ID], [MATERIEL_CODE], [MATERIEL_NAME], [MATERIEL_BARCODE], [BATCH_NO], [PACKAGE_CODE], [UNIT_CODE], [ARRIVAL_QTY], [RECEIPT_QTY], [SUPPLIER_CODE], [SUPPLIER_NAME], [PRODUCT_DATE], [EXP_DATE], [ARRIVAL_DTL_STATUS], [INSPECTION_RESULT], [SOURCE_BILL_DTL_IDX], [PURCHASE_ORDER_DTL_IDX], [PURCHASE_ORDER_DTL_STATUS], [DESCRIBE], [CREATE_BY], [CREATE_TIME], [UPDATE_BY], [UPDATE_TIME], [DATA_VERSION], [REMARKS1], [REMARKS2], [REMARKS3], [REMARKS4], [REMARKS5] ) VALUES ( '{item.ArrivalDtlId}', '{item.ArrivalId}', '{item.MaterielCode}', '{item.MaterielName}', '{item.MaterielBarcode}', '{item.BatchNo}', '{item.PackageCode}', '{item.UnitCode}', '{item.ArrivalQty}', 0, '{item.SupplierCode}', '{item.SupplierName}', '{item.ProductDate}', '{item.ExpDate}', '{item.ArrivalDtlStatus}', 'OK', NULL, NULL, NULL, '{item.Describe}', '{item.CreateBy}', GETDATE(), '{item.UpdateBy}', GETDATE(), '0', NULL, NULL, NULL, NULL, NULL ); "); sqlList.Add(sqlAddWmsInArrivalDtl.ToString()); } } #endregion int row = new DataRepository(_dataContext).ExecSqlListTran(sqlList); if (row > 0) { return SuccessMessageStatus("修改到货通知单数据成功!", row); } else { return FailMessageStatus("修改到货通知单数据失败!", row); } } catch (Exception ex) { return FailMessageStatus($"修改到货通知单数据发生异常,【{ex.Message}】"); } } /// /// 删除到货通知单数据 /// /// 到货通知单主表对象 /// public OperateResultInfo DeleteWmsInArrivalData(WmsInArrivalResult wmsInArrival) { try { #region SQL语句生成 string[] arrivalIdList = wmsInArrival.ArrivalNo.Split(','); List sqlList = new List(); foreach (string item in arrivalIdList) { string sqlDeleteWmsInArrival = $@" UPDATE WMS_IN_ARRIVAL SET ARRIVAL_STATUS = '111', UPDATE_BY = '{wmsInArrival.UpdateBy}', UPDATE_TIME = GETDATE(), DATA_VERSION = DATA_VERSION + 1 WHERE ARRIVAL_ID = '{item}'; "; string sqlDeleteWmsInArrivalDtl = $@" UPDATE WMS_IN_ARRIVAL_DTL SET ARRIVAL_DTL_STATUS = '111', UPDATE_BY = '{wmsInArrival.UpdateBy}', UPDATE_TIME = GETDATE(), DATA_VERSION = DATA_VERSION + 1 WHERE ARRIVAL_ID = '{item}'; "; sqlList.Add(sqlDeleteWmsInArrival); sqlList.Add(sqlDeleteWmsInArrivalDtl); /* ToDo: 后续增加删除移至历史表中。 */ } #endregion int row = new DataRepository(_dataContext).ExecSqlListTran(sqlList); if (row > 0) { return SuccessMessageStatus("删除到货通知单数据成功!", row); } else { return FailMessageStatus("删除到货通知单数据失败!", row); } } catch (Exception ex) { return FailMessageStatus($"删除到货通知单数据发生异常,【{ex.Message}】"); } } #endregion } }