using Dapper; using Estsh.Core.Base; using Estsh.Core.Dapper; using Estsh.Core.Wms.IRepositories; using Estsh.Core.Model.Result; using Estsh.Core.Repositories; using System.Collections; using System.Data; using System.Text; using System.Security.Cryptography; using System.Text.Json; using Estsh.Core.Models; using Newtonsoft.Json.Linq; using Estsh.Core.Model.EnumUtil; namespace Estsh.Core.Wms.Repositories { public class SemiFinishInStockRepository : BaseRepository, ISemiFinishInStockRepository { public SemiFinishInStockRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext) { } public List GetRackNo(string RKNO) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("select * from wms_rack (nolock) where rack_no=@rack_no "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@rack_no", RKNO); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public List CheckCartonNoStatus(string cartonNo) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("select a.*,b.rack_part,b.part_package from sys_stock as a (nolock) left join wms_rack_part_package as b (nolock) on a.part_no=b.rack_part where carton_no=@carton_no and a.enabled='Y'"); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@carton_no", cartonNo); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public List CheckRKNoStatus(string RKNo) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("select a.* from sys_stock as a (nolock) left join wms_rack_package as b (nolock) on a.carton_no = b.rack_no left join sys_stock as c (nolock) on b.carton_no = c.carton_no where a.carton_no = @carton_no and a.enabled = 'Y' and b.enabled = 'Y' and c.enabled='Y'"); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@carton_no", RKNo); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public List CheckCartonNoByRackNo(string cartonNo) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append("select * from sys_stock as a (nolock) left join wms_rack_part_package as b (nolock) on a.part_no=b.rack_part where carton_no=@carton_no and a.enabled='Y' "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@carton_no", cartonNo); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public List GetSemiFinishList(string carton_no, string partno, string num) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append(@" select top " + num + " * from sys_stock (nolock) where locate_id = (select dest_locate_id from sys_pdline (nolock) where pdline_code = ( select pdline_code from mes_out_pdline (nolock) where serial_number = @carton_no ) or pdline_code = ( select pdline_code from mes_hg_out_pdline (nolock) where serial_number = @carton_no )) and part_no = @partno and enabled = 'Y' "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@carton_no", carton_no); parameters.Add("@partno", partno.Trim()); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public List CheckLocateStatus(string locateName) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; StringBuilder sql = new StringBuilder(1024); sql.Append(@"SELECT a.*,B.*,c.erp_warehouse FROM dbo.sys_locate a (nolock) LEFT JOIN sys_locate_part b (nolock) ON a.locate_id = b.locate_id LEFT join sys_zone as c (nolock) on a.zone_id=c.zone_id WHERE a.locate_name =@locateName "); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@locateName", locateName); return dbConn.Query(sql.ToString(), parameters).ToList(); } } public int UpdateRackCarBinding(string RKNO) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); string result = string.Empty; List sqlStrings = new List(); List parameterList = new List(); StringBuilder sql = new StringBuilder(1024); sql.Append(@"update wms_rack_package set enabled='N' where rack_no =@rack_no "); sqlStrings.Add(sql.ToString()); DynamicParameters parameters = new DynamicParameters(); parameters.Add("@rack_no", RKNO); parameterList.Add(parameters); //sql = new StringBuilder(1024); //sql.Append(@"update sys_stock set enabled='N' where carton_no in (@rack_no)"); //sqlStrings.Add(sql.ToString()); //parameters = new DynamicParameters(); //parameters.Add("@rack_no", RKNO); //parameterList.Add(parameters); //执行事务 IDbTransaction transaction = dbConn.BeginTransaction(); try { for (int i = 0; i < sqlStrings.Count; i++) { dbConn.Execute(sqlStrings[i], parameterList[i], transaction); } transaction.Commit(); return 1; } catch (Exception ex) { transaction.Rollback(); return 0; } } } /// /// 获取订单编号 /// /// public string GetOrderNo(string stockOrder, string p) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); DynamicParameters list = new DynamicParameters(); list.Add("@order_type", stockOrder); list.Add("@order_prefix", p); list.Add("@order_no", null, DbType.String, ParameterDirection.Output, 50); var hashtable = dbConn.Execute("sys_create_orderno", list, commandType: CommandType.StoredProcedure); string result = list.Get("@order_no"); return result; } } public string Insertinfo(string locateName, string RKno, string productNo, string Num, string loginId) { using (IDbConnection dbConn = dapperDbContext.GetDbConnection()) { dbConn.Open(); List oldStock = CheckCartonNoStatus(productNo); List locate = CheckLocateStatus(locateName); List RKInfo = CheckCartonNoByRackNo(RKno); //List Getsemi = GetSemiFinishList(productNo, oldStock[0].PartNo, Num); List sqlStrings = new List(); List parameterList = new List(); //if (Convert.ToInt32(Num)> Getsemi.Count) //{ // return "成品下线数小于待入库数，请检查！"; //} //冻结条码 //StringBuilder sql = new StringBuilder(1024); //sql.Append(@" update sys_stock set enabled='N' where carton_no in (select top " + Num + " carton_no from sys_stock (nolock) where locate_id = (select dest_locate_id from sys_pdline (nolock) where pdline_code = ( select pdline_code from mes_out_pdline (nolock) where serial_number = @carton_no ) or pdline_code = ( select pdline_code from mes_hg_out_pdline (nolock) where serial_number = @carton_no )) and part_no = @partno and enabled = 'Y' ) "); //sqlStrings.Add(sql.ToString()); //DynamicParameters parameters = new DynamicParameters(); //parameters.Add("@carton_no", productNo); //parameters.Add("@partno", oldStock[0].PartNo.Trim()); //parameterList.Add(parameters); string carNo_New = GetOrderNo("StockOrder", "T"); #region 新增库存表 //在STOCK中插入料架 StringBuilder updateString3 = new StringBuilder(1024); updateString3.Append(@" INSERT INTO [dbo].[sys_stock] ([vendor_id] ,[vendor_code] ,[carton_no] ,[carton_type] ,[part_id] ,[part_no] ,[part_spec] ,[lot_no] ,[fix_lot_no] ,[status] ,[qty] ,[snp_qty] ,[locate_id] ,[locate_name] ,[group_no] ,[erp_warehouse] ,[date_code] ,[qms_status] ,[ref_order_no] ,[unit] ,[dock] ,[warehouse_id] ,[warehouse_name] ,[zone_id] ,[zone_name] ,[printed] ,[print_time] ,[remark] ,[factory_id] ,[factory_code] ,[enabled] ,[create_userid] ,[create_time] ,[update_userid] ,[update_time] ,[guid]) VALUES(@vendor_id,@vendor_code,@carton_no,@carton_type,@part_id,@part_no,@part_spec,@lot_no,@fix_lot_no,@status,@qty,@snp_qty ,@locate_id,@locate_name,@group_no,@erp_warehouse,@date_code,@qms_status,@ref_order_no,@unit,@dock,@warehouse_id,@warehouse_name,@zone_id,@zone_name ,@printed,@print_time,@remark,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid )"); DynamicParameters updateStringparameters3 = new DynamicParameters(); updateStringparameters3.Add("@vendor_id", oldStock[0].VendorId); updateStringparameters3.Add("@vendor_code", oldStock[0].VendorName); updateStringparameters3.Add("@carton_no", carNo_New); updateStringparameters3.Add("@carton_type", "0"); updateStringparameters3.Add("@part_id", oldStock[0].PartId); updateStringparameters3.Add("@part_no", oldStock[0].PartNo); updateStringparameters3.Add("@part_spec", oldStock[0].PartSpec); updateStringparameters3.Add("@lot_no", DateTime.Now.ToString("yyyy-MM-dd")); updateStringparameters3.Add("@fix_lot_no", ""); updateStringparameters3.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters3.Add("@qty", Num); updateStringparameters3.Add("@snp_qty", Num); updateStringparameters3.Add("@locate_id", locate[0].LocateId); updateStringparameters3.Add("@locate_name", locate[0].LocateName); updateStringparameters3.Add("@group_no", ""); updateStringparameters3.Add("@erp_warehouse", locate[0].ErpWarehouse); updateStringparameters3.Add("@date_code", ""); updateStringparameters3.Add("@qms_status", ""); updateStringparameters3.Add("@ref_order_no", ""); updateStringparameters3.Add("@unit", ""); updateStringparameters3.Add("@dock", ""); updateStringparameters3.Add("@warehouse_id", locate[0].WarehouseId); updateStringparameters3.Add("@warehouse_name", locate[0].WarehouseName); updateStringparameters3.Add("@zone_id", locate[0].ZoneId); updateStringparameters3.Add("@zone_name", locate[0].ZoneName); updateStringparameters3.Add("@printed", ""); updateStringparameters3.Add("@print_time", ""); updateStringparameters3.Add("@remark", ""); updateStringparameters3.Add("@factory_id", locate[0].FactoryId); updateStringparameters3.Add("@factory_code", locate[0].FactoryCode); updateStringparameters3.Add("@enabled", "Y"); updateStringparameters3.Add("@update_userid", loginId); updateStringparameters3.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters3.Add("@create_userid", loginId); updateStringparameters3.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters3.Add("@guid", Guid.NewGuid()); sqlStrings.Add(updateString3.ToString()); parameterList.Add(updateStringparameters3); #endregion #region 新增 sys_stock_trans 事务表 StringBuilder updateString4 = new StringBuilder(1024); updateString4.Append(@" INSERT INTO[dbo].[sys_stock_trans] ([trans_code] ,[carton_no] ,[part_id] ,[part_no] ,[part_spec] ,[src_locate_id] ,[src_locate_name] ,[dest_locate_id] ,[dest_locate_name] ,[old_qty] ,[new_qty] ,[trans_qty] ,[old_status] ,[new_status] ,[old_qms_status] ,[new_qms_status] ,[unit] ,[factory_id] ,[factory_code] ,[src_erp_warehouse] ,[dest_erp_warehouse] ,[src_warehouse_id] ,[src_warehouse_name] ,[dest_warehouse_id] ,[dest_warehouse_name] ,[src_zone_id] ,[src_zone_name] ,[dest_zone_id] ,[dest_zone_name] ,[enabled] ,[update_userid] ,[update_time] ,[create_userid] ,[create_time] ,[guid]) VALUES (@trans_code,@carton_no,@part_id,@part_no,@part_spec,@src_locate_id ,@src_locate_name ,@dest_locate_id ,@dest_locate_name ,@old_qty ,@new_qty ,@trans_qty ,@old_status ,@new_status ,@old_qms_status ,@new_qms_status ,@unit ,@factory_id ,@factory_code ,@src_erp_warehouse ,@dest_erp_warehouse ,@src_warehouse_id ,@src_warehouse_name ,@dest_warehouse_id ,@dest_warehouse_name ,@src_zone_id ,@src_zone_name ,@dest_zone_id ,@dest_zone_name ,@enabled ,@update_userid ,@update_time ,@create_userid ,@create_time ,@guid )"); DynamicParameters updateStringparameters4 = new DynamicParameters(); updateStringparameters4.Add("@trans_code", (int)WmsEnumUtil.TransType.IN_STOCK_RACK_PACKAGE_RACK); updateStringparameters4.Add("@carton_no", carNo_New); updateStringparameters4.Add("@part_id", oldStock[0].PartId); updateStringparameters4.Add("@part_no", oldStock[0].PartNo); updateStringparameters4.Add("@part_spec", oldStock[0].PartSpec); updateStringparameters4.Add("@src_locate_id", oldStock[0].LocateId); updateStringparameters4.Add("@src_locate_name", oldStock[0].LocateName); updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId); updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName); updateStringparameters4.Add("@old_qty", oldStock[0].Qty); updateStringparameters4.Add("@new_qty", Num); updateStringparameters4.Add("@trans_qty", oldStock[0].Qty); updateStringparameters4.Add("@old_status", oldStock[0].Status); updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters4.Add("@old_qms_status", oldStock[0].QmsStatus); updateStringparameters4.Add("@new_qms_status", oldStock[0].QmsStatus); updateStringparameters4.Add("@unit", oldStock[0].Unit); updateStringparameters4.Add("@factory_id", oldStock[0].FactoryId); updateStringparameters4.Add("@factory_code", oldStock[0].FactoryCode); updateStringparameters4.Add("@src_erp_warehouse", locate[0].ErpWarehouse); updateStringparameters4.Add("@dest_erp_warehouse", locate[0].ErpWarehouse); updateStringparameters4.Add("@src_warehouse_id", oldStock[0].WarehouseId); updateStringparameters4.Add("@src_warehouse_name", oldStock[0].WarehouseName); updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId); updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName); updateStringparameters4.Add("@src_zone_id", oldStock[0].ZoneId); updateStringparameters4.Add("@src_zone_name", oldStock[0].ZoneName); updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId); updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName); updateStringparameters4.Add("@enabled", "Y"); updateStringparameters4.Add("@update_userid", loginId); updateStringparameters4.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters4.Add("@create_userid", loginId); updateStringparameters4.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters4.Add("@guid", Guid.NewGuid()); sqlStrings.Add(updateString4.ToString()); parameterList.Add(updateStringparameters4); #endregion //新增料架与包装信息 StringBuilder updateString2 = new StringBuilder(1024); updateString2.Append(@"INSERT INTO [dbo].[wms_rack_package] ([rack_no] ,[carton_no] ,[factory_id] ,[factory_code] ,[enabled] ,[create_userid] ,[create_time] ,[update_userid] ,[update_time] ,[guid],rack_num) VALUES (@rack_no,@carton_no,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid,@rack_num )"); DynamicParameters updateStringparameters2 = new DynamicParameters(); updateStringparameters2.Add("@rack_no", RKno); updateStringparameters2.Add("@carton_no", carNo_New); updateStringparameters2.Add("@factory_id", locate[0].FactoryId); updateStringparameters2.Add("@factory_code", locate[0].FactoryCode); updateStringparameters2.Add("@enabled", "Y"); updateStringparameters2.Add("@create_userid", loginId); updateStringparameters2.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters2.Add("@guid", Guid.NewGuid()); updateStringparameters2.Add("@rack_num", 1); updateStringparameters2.Add("@update_userid", loginId); updateStringparameters2.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); sqlStrings.Add(updateString2.ToString()); parameterList.Add(updateStringparameters2); if (RKInfo.Count == 0) { #region 新增库存表 //在STOCK中插入料架 updateString3 = new StringBuilder(1024); updateString3.Append(@" INSERT INTO [dbo].[sys_stock] ([vendor_id] ,[vendor_code] ,[carton_no] ,[carton_type] ,[part_id] ,[part_no] ,[part_spec] ,[lot_no] ,[fix_lot_no] ,[status] ,[qty] ,[snp_qty] ,[locate_id] ,[locate_name] ,[group_no] ,[erp_warehouse] ,[date_code] ,[qms_status] ,[ref_order_no] ,[unit] ,[dock] ,[warehouse_id] ,[warehouse_name] ,[zone_id] ,[zone_name] ,[printed] ,[print_time] ,[remark] ,[factory_id] ,[factory_code] ,[enabled] ,[create_userid] ,[create_time] ,[update_userid] ,[update_time] ,[guid]) VALUES(@vendor_id,@vendor_code,@carton_no,@carton_type,@part_id,@part_no,@part_spec,@lot_no,@fix_lot_no,@status,@qty,@snp_qty ,@locate_id,@locate_name,@group_no,@erp_warehouse,@date_code,@qms_status,@ref_order_no,@unit,@dock,@warehouse_id,@warehouse_name,@zone_id,@zone_name ,@printed,@print_time,@remark,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid )"); updateStringparameters3 = new DynamicParameters(); updateStringparameters3.Add("@vendor_id", oldStock[0].VendorId); updateStringparameters3.Add("@vendor_code", oldStock[0].VendorName); updateStringparameters3.Add("@carton_no", RKno); updateStringparameters3.Add("@carton_type", "1"); updateStringparameters3.Add("@part_id", "0"); updateStringparameters3.Add("@part_no", RKno); updateStringparameters3.Add("@part_spec", ""); updateStringparameters3.Add("@lot_no", DateTime.Now.ToString("yyyy-MM-dd")); updateStringparameters3.Add("@fix_lot_no", ""); updateStringparameters3.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters3.Add("@qty", 1); updateStringparameters3.Add("@snp_qty", 1); updateStringparameters3.Add("@locate_id", locate[0].LocateId); updateStringparameters3.Add("@locate_name", locate[0].LocateName); updateStringparameters3.Add("@group_no", ""); updateStringparameters3.Add("@erp_warehouse", locate[0].ErpWarehouse); updateStringparameters3.Add("@date_code", ""); updateStringparameters3.Add("@qms_status", ""); updateStringparameters3.Add("@ref_order_no", "台车"); updateStringparameters3.Add("@unit", ""); updateStringparameters3.Add("@dock", ""); updateStringparameters3.Add("@warehouse_id", locate[0].WarehouseId); updateStringparameters3.Add("@warehouse_name", locate[0].WarehouseName); updateStringparameters3.Add("@zone_id", locate[0].ZoneId); updateStringparameters3.Add("@zone_name", locate[0].ZoneName); updateStringparameters3.Add("@printed", ""); updateStringparameters3.Add("@print_time", ""); updateStringparameters3.Add("@remark", ""); updateStringparameters3.Add("@factory_id", locate[0].FactoryId); updateStringparameters3.Add("@factory_code", locate[0].FactoryCode); updateStringparameters3.Add("@enabled", "Y"); updateStringparameters3.Add("@update_userid", loginId); updateStringparameters3.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters3.Add("@create_userid", loginId); updateStringparameters3.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters3.Add("@guid", Guid.NewGuid()); sqlStrings.Add(updateString3.ToString()); parameterList.Add(updateStringparameters3); #endregion #region 新增 sys_stock_trans 事务表 updateString4 = new StringBuilder(1024); updateString4.Append(@" INSERT INTO[dbo].[sys_stock_trans] ([trans_code] ,[carton_no] ,[part_id] ,[part_no] ,[part_spec] ,[src_locate_id] ,[src_locate_name] ,[dest_locate_id] ,[dest_locate_name] ,[old_qty] ,[new_qty] ,[trans_qty] ,[old_status] ,[new_status] ,[old_qms_status] ,[new_qms_status] ,[unit] ,[factory_id] ,[factory_code] ,[src_erp_warehouse] ,[dest_erp_warehouse] ,[src_warehouse_id] ,[src_warehouse_name] ,[dest_warehouse_id] ,[dest_warehouse_name] ,[src_zone_id] ,[src_zone_name] ,[dest_zone_id] ,[dest_zone_name] ,[enabled] ,[update_userid] ,[update_time] ,[create_userid] ,[create_time] ,[guid]) VALUES (@trans_code,@carton_no,@part_id,@part_no,@part_spec,@src_locate_id ,@src_locate_name ,@dest_locate_id ,@dest_locate_name ,@old_qty ,@new_qty ,@trans_qty ,@old_status ,@new_status ,@old_qms_status ,@new_qms_status ,@unit ,@factory_id ,@factory_code ,@src_erp_warehouse ,@dest_erp_warehouse ,@src_warehouse_id ,@src_warehouse_name ,@dest_warehouse_id ,@dest_warehouse_name ,@src_zone_id ,@src_zone_name ,@dest_zone_id ,@dest_zone_name ,@enabled ,@update_userid ,@update_time ,@create_userid ,@create_time ,@guid )"); updateStringparameters4 = new DynamicParameters(); updateStringparameters4.Add("@trans_code", (int)WmsEnumUtil.TransType.IN_STOCK_RACK_PACKAGE_RACK); updateStringparameters4.Add("@carton_no", RKno); updateStringparameters4.Add("@part_id", 0); updateStringparameters4.Add("@part_no", RKno); updateStringparameters4.Add("@part_spec", ""); updateStringparameters4.Add("@src_locate_id", oldStock[0].LocateId); updateStringparameters4.Add("@src_locate_name", oldStock[0].LocateName); updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId); updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName); updateStringparameters4.Add("@old_qty", 1); updateStringparameters4.Add("@new_qty", 1); updateStringparameters4.Add("@trans_qty", 1); updateStringparameters4.Add("@old_status", oldStock[0].Status); updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters4.Add("@old_qms_status", oldStock[0].QmsStatus); updateStringparameters4.Add("@new_qms_status", oldStock[0].QmsStatus); updateStringparameters4.Add("@unit", oldStock[0].Unit); updateStringparameters4.Add("@factory_id", oldStock[0].FactoryId); updateStringparameters4.Add("@factory_code", oldStock[0].FactoryCode); updateStringparameters4.Add("@src_erp_warehouse", locate[0].ErpWarehouse); updateStringparameters4.Add("@dest_erp_warehouse", locate[0].ErpWarehouse); updateStringparameters4.Add("@src_warehouse_id", oldStock[0].WarehouseId); updateStringparameters4.Add("@src_warehouse_name", oldStock[0].WarehouseName); updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId); updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName); updateStringparameters4.Add("@src_zone_id", oldStock[0].ZoneId); updateStringparameters4.Add("@src_zone_name", oldStock[0].ZoneName); updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId); updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName); updateStringparameters4.Add("@enabled", "Y"); updateStringparameters4.Add("@update_userid", loginId); updateStringparameters4.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters4.Add("@create_userid", loginId); updateStringparameters4.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); updateStringparameters4.Add("@guid", Guid.NewGuid()); sqlStrings.Add(updateString4.ToString()); parameterList.Add(updateStringparameters4); #endregion } StringBuilder updateString5 = new StringBuilder(1024); updateString5.Append(@" update sys_stock set status=@status,locate_id=@locate_id,locate_name=@locate_name,erp_warehouse=@erp_warehouse,warehouse_id=@warehouse_id,warehouse_name=@warehouse_name,zone_id=@zone_id,zone_name=@zone_name,update_userid=@update_userid,update_time=@update_time where carton_no=@carton_no "); DynamicParameters updateStringparameters5 = new DynamicParameters(); updateStringparameters5.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters5.Add("@locate_id", locate[0].LocateId); updateStringparameters5.Add("@locate_name", locate[0].LocateName); updateStringparameters5.Add("@carton_no", RKno); updateStringparameters5.Add("@erp_warehouse", locate[0].ErpWarehouse); updateStringparameters5.Add("@warehouse_id", locate[0].WarehouseId); updateStringparameters5.Add("@warehouse_name", locate[0].WarehouseName); updateStringparameters5.Add("@zone_id", locate[0].ZoneId); updateStringparameters5.Add("@zone_name", locate[0].ZoneName); updateStringparameters5.Add("@update_userid", loginId); updateStringparameters5.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); sqlStrings.Add(updateString5.ToString()); parameterList.Add(updateStringparameters5); //执行事务 IDbTransaction transaction = dbConn.BeginTransaction(); bool successCount = true; for (int i = 0; i < sqlStrings.Count; i++) { if (dbConn.Execute(sqlStrings[i], parameterList[i], transaction) < 1) { successCount = false; } } if (successCount) { transaction.Commit(); return "OK" + oldStock[0].PartSpec; } else { transaction.Rollback(); return "操作失败，请重新尝试！"; } } } } }