using Dapper; using Estsh.Core.Base; using Estsh.Core.Model.EnumUtil; using Estsh.Core.Models; using Estsh.Core.Services; using Estsh.Core.Wms.IRepositories; using Estsh.Core.Wms.IServices; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace Estsh.Core.Wms.Services { /// /// 拆分台车 /// public class SplitCarrierService : BaseService, ISplitCarrierService { private readonly ISplitCarrierRepository repository; public SplitCarrierService(ISplitCarrierRepository _repository) : base(_repository) { repository = _repository; } public SetObjectDetail GetCarrierByName(string srcRackNo) { SetObjectDetail rfInfo = new SetObjectDetail(); //查询台车信息 List wmsRacks = repository.GetCarrierByName(srcRackNo); if (wmsRacks.Count == 0) { //提示 [A1-2-2]:该库位不存在,请检查! rfInfo.type = "FAIL"; rfInfo.message = "[" + srcRackNo + "]:该台车未绑定箱条码,请检查!"; return rfInfo; } List sysStocks = repository.GetSysStockBySumQty(srcRackNo); rfInfo.type = "PASS"; rfInfo.message = "[" + srcRackNo + "]:扫描成功,请扫描产品条码"; rfInfo.wmsObjectDetail = sysStocks.ConvertAll(s => (object)s); return rfInfo; } public SetObjectDetail CheckStockByCartonNo(string srcRackNo, string cartonNo, string loginId) { SetObjectDetail rfInfo = new SetObjectDetail(); List sysStocks = repository.GetSysStockByNO(cartonNo); if (sysStocks.Count == 0) { //提示 [M0090105]:该条码不存在,请检查! rfInfo.type = "FAIL"; rfInfo.message = "[" + cartonNo + "]:该条码不存在,请检查!"; return rfInfo; } else if (string.IsNullOrEmpty(sysStocks[0].PartNo)) { //提示 [M0090105]:该条码对应零件号为空,无法操作! rfInfo.type = "FAIL"; rfInfo.message = "[" + cartonNo + "]:该条码对应零件号为空,请检查!"; return rfInfo; } List stocks = repository.GetSysStockByPartNoSumQty(srcRackNo, sysStocks[0].PartNo); if (stocks.Count == 0) { rfInfo.type = "FAIL"; rfInfo.message = "[" + cartonNo + "]:该条码对应零件号未维护到源台车,请检查!"; return rfInfo; } rfInfo.type = "PASS"; rfInfo.message = "[" + cartonNo + "]:扫描成功,请输入台车容量"; rfInfo.wmsObjectDetail = stocks.ConvertAll(s => (object)s); return rfInfo; } public SetObjectDetail CheckStockByCartonNoAndQty(string srcRackNo, string cartonNo, string qty, string loginId) { SetObjectDetail rfInfo = new SetObjectDetail(); StringBuilder stringBuilder = new StringBuilder(1024); List sqlStrings = new List(); List parameterList = new List(); List sysStocks = repository.GetSysStockByNO(cartonNo); List stocks = repository.GetSysStockByPartNoSumQty(srcRackNo, sysStocks[0].PartNo); if (stocks[0].Qty < decimal.Parse(qty)) { rfInfo.type = "FAIL"; rfInfo.message = "拆分数量大于源台车容量,请检查!"; return rfInfo; } rfInfo.type = "PASS"; rfInfo.message = "台车容量处理成功,请扫描目标台车"; return rfInfo; } public SetObjectDetail CheckStockByCartonNoAndQtyAddRackNo(string srcRackNo, string cartonNo, string qty, string destRackNo, string loginId) { SetObjectDetail rfInfo = new SetObjectDetail(); if (string.IsNullOrEmpty(srcRackNo)) { rfInfo.type = "FAIL"; rfInfo.message = "料架号为空,请重扫料架号"; return rfInfo; } StringBuilder stringBuilder = new StringBuilder(1024); List sqlStrings = new List(); List parameterList = new List(); StringBuilder SqlStringBuilder = new StringBuilder(1024); DynamicParameters parameters = new DynamicParameters(); List sysStocks = repository.GetSysStockByNO(cartonNo); decimal qtyNum = decimal.Parse(qty); List stocks = repository.GetSysStockByPartInfo(srcRackNo, sysStocks[0].PartNo); for (int i = 0; i < stocks.Count; i++) { if (qtyNum > 0) { if (stocks[i].Qty <= qtyNum) { SqlStringBuilder = new StringBuilder(1024); SqlStringBuilder.Append(" update sys_stock set qty=@qty,enabled='N' where ruid=@ruid "); sqlStrings.Add(SqlStringBuilder.ToString()); parameters = new DynamicParameters(); parameters.Add("@qty", 0); parameters.Add("@ruid", stocks[i].Ruid); parameterList.Add(parameters); SqlStringBuilder = new StringBuilder(1024); SqlStringBuilder.Append(@"UPDATE wms_rack_package SET enabled='N' where rack_no=@rackNo and carton_no=@cartonNo"); sqlStrings.Add(SqlStringBuilder.ToString()); parameters = new DynamicParameters(); parameters.Add("@rackNo", srcRackNo); parameters.Add("@cartonNo", stocks[i].CartonNo); parameterList.Add(parameters); qtyNum -= stocks[i].Qty; } else if (stocks[i].Qty > qtyNum) { SqlStringBuilder = new StringBuilder(1024); SqlStringBuilder.Append(" update sys_stock set qty-=@qty where ruid=@ruid "); sqlStrings.Add(SqlStringBuilder.ToString()); parameters = new DynamicParameters(); parameters.Add("@qty", qtyNum); parameters.Add("@ruid", stocks[i].Ruid); parameterList.Add(parameters); qtyNum = 0; } } } List rackStock = repository.GetCarrierByStockRackNo(destRackNo); if (rackStock.Count == 0) { #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", sysStocks[0].VendorId); updateStringparameters3.Add("@vendor_code", sysStocks[0].VendorName); updateStringparameters3.Add("@carton_no", destRackNo); updateStringparameters3.Add("@carton_type", "1"); updateStringparameters3.Add("@part_id", "0"); updateStringparameters3.Add("@part_no", destRackNo); updateStringparameters3.Add("@part_spec", ""); updateStringparameters3.Add("@lot_no", "99999999"); 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", 0); updateStringparameters3.Add("@locate_name", ""); updateStringparameters3.Add("@group_no", ""); updateStringparameters3.Add("@erp_warehouse", ""); updateStringparameters3.Add("@date_code", ""); updateStringparameters3.Add("@qms_status", ""); updateStringparameters3.Add("@ref_order_no", "台车"); updateStringparameters3.Add("@unit", ""); updateStringparameters3.Add("@dock", ""); updateStringparameters3.Add("@warehouse_id", 0); updateStringparameters3.Add("@warehouse_name", ""); updateStringparameters3.Add("@zone_id", 0); updateStringparameters3.Add("@zone_name", ""); updateStringparameters3.Add("@printed", ""); updateStringparameters3.Add("@print_time", ""); updateStringparameters3.Add("@remark", ""); updateStringparameters3.Add("@factory_id", sysStocks[0].FactoryId); updateStringparameters3.Add("@factory_code", sysStocks[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.PART_SPLIT); updateStringparameters4.Add("@carton_no", destRackNo); updateStringparameters4.Add("@part_id", 0); updateStringparameters4.Add("@part_no", destRackNo); updateStringparameters4.Add("@part_spec", ""); updateStringparameters4.Add("@src_locate_id", 0); updateStringparameters4.Add("@src_locate_name", ""); updateStringparameters4.Add("@dest_locate_id", 0); updateStringparameters4.Add("@dest_locate_name", ""); updateStringparameters4.Add("@old_qty", 1); updateStringparameters4.Add("@new_qty", 1); updateStringparameters4.Add("@trans_qty", 1); updateStringparameters4.Add("@old_status", ""); updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters4.Add("@old_qms_status", ""); updateStringparameters4.Add("@new_qms_status", ""); updateStringparameters4.Add("@unit", ""); updateStringparameters4.Add("@factory_id", sysStocks[0].FactoryId); updateStringparameters4.Add("@factory_code", sysStocks[0].FactoryCode); updateStringparameters4.Add("@src_erp_warehouse", ""); updateStringparameters4.Add("@dest_erp_warehouse", ""); updateStringparameters4.Add("@src_warehouse_id", "0"); updateStringparameters4.Add("@src_warehouse_name", ""); updateStringparameters4.Add("@dest_warehouse_id", "0"); updateStringparameters4.Add("@dest_warehouse_name", ""); updateStringparameters4.Add("@src_zone_id", "0"); updateStringparameters4.Add("@src_zone_name", ""); updateStringparameters4.Add("@dest_zone_id", "0"); updateStringparameters4.Add("@dest_zone_name", ""); 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 } string carton_no_new = repository.GetOrderNo("StockOrder", "T"); List sysStocksDest = repository.GetSysStockByPartInfo(destRackNo, sysStocks[0].PartNo); if (sysStocksDest.Count > 0) { SqlStringBuilder = new StringBuilder(1024); SqlStringBuilder.Append(" update sys_stock set qty+=@qty where ruid=@ruid "); sqlStrings.Add(SqlStringBuilder.ToString()); parameters = new DynamicParameters(); parameters.Add("@qty", qty); parameters.Add("@ruid", sysStocksDest[0].Ruid); parameterList.Add(parameters); } else { #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", sysStocks[0].VendorId); updateStringparameters3.Add("@vendor_code", sysStocks[0].VendorName); updateStringparameters3.Add("@carton_no", carton_no_new); updateStringparameters3.Add("@carton_type", "0"); updateStringparameters3.Add("@part_id", sysStocks[0].PartId); updateStringparameters3.Add("@part_no", sysStocks[0].PartNo); updateStringparameters3.Add("@part_spec", sysStocks[0].PartSpec); updateStringparameters3.Add("@lot_no", "99999999"); updateStringparameters3.Add("@fix_lot_no", ""); updateStringparameters3.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters3.Add("@qty", qty); updateStringparameters3.Add("@snp_qty", qty); updateStringparameters3.Add("@locate_id", 0); updateStringparameters3.Add("@locate_name", ""); updateStringparameters3.Add("@group_no", ""); updateStringparameters3.Add("@erp_warehouse", ""); updateStringparameters3.Add("@date_code", ""); updateStringparameters3.Add("@qms_status", ""); updateStringparameters3.Add("@ref_order_no", ""); updateStringparameters3.Add("@unit", ""); updateStringparameters3.Add("@dock", ""); updateStringparameters3.Add("@warehouse_id", 0); updateStringparameters3.Add("@warehouse_name", ""); updateStringparameters3.Add("@zone_id", 0); updateStringparameters3.Add("@zone_name", ""); updateStringparameters3.Add("@printed", ""); updateStringparameters3.Add("@print_time", ""); updateStringparameters3.Add("@remark", ""); updateStringparameters3.Add("@factory_id", sysStocks[0].FactoryId); updateStringparameters3.Add("@factory_code", sysStocks[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.PART_SPLIT); updateStringparameters4.Add("@carton_no", carton_no_new); updateStringparameters4.Add("@part_id", sysStocks[0].PartId); updateStringparameters4.Add("@part_no", sysStocks[0].PartNo); updateStringparameters4.Add("@part_spec", sysStocks[0].PartSpec); updateStringparameters4.Add("@src_locate_id", 0); updateStringparameters4.Add("@src_locate_name", ""); updateStringparameters4.Add("@dest_locate_id", 0); updateStringparameters4.Add("@dest_locate_name", ""); updateStringparameters4.Add("@old_qty", 1); updateStringparameters4.Add("@new_qty", 1); updateStringparameters4.Add("@trans_qty", 1); updateStringparameters4.Add("@old_status", ""); updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED); updateStringparameters4.Add("@old_qms_status", ""); updateStringparameters4.Add("@new_qms_status", ""); updateStringparameters4.Add("@unit", ""); updateStringparameters4.Add("@factory_id", sysStocks[0].FactoryId); updateStringparameters4.Add("@factory_code", sysStocks[0].FactoryCode); updateStringparameters4.Add("@src_erp_warehouse", ""); updateStringparameters4.Add("@dest_erp_warehouse", ""); updateStringparameters4.Add("@src_warehouse_id", "0"); updateStringparameters4.Add("@src_warehouse_name", ""); updateStringparameters4.Add("@dest_warehouse_id", "0"); updateStringparameters4.Add("@dest_warehouse_name", ""); updateStringparameters4.Add("@src_zone_id", "0"); updateStringparameters4.Add("@src_zone_name", ""); updateStringparameters4.Add("@dest_zone_id", "0"); updateStringparameters4.Add("@dest_zone_name", ""); 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", destRackNo);//新台车号 updateStringparameters2.Add("@carton_no", carton_no_new); updateStringparameters2.Add("@factory_id", sysStocks[0].FactoryId); updateStringparameters2.Add("@factory_code", sysStocks[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); } int recNum = repository.SQLTransaction(sqlStrings, parameterList); if (recNum > 0) { List sysStocksSrc = repository.GetSysStockBySumQty(srcRackNo); if (sysStocksSrc.Count==0) { repository.UpdateStockByRackNo(srcRackNo); } List sysStocksSum = repository.GetSysStockBySumQty(destRackNo); if (sysStocksSum.Count > 0) { rfInfo.type = "PASS"; rfInfo.message = "拆分成功,请扫描源台车"; rfInfo.wmsObjectDetail = sysStocksSum.ConvertAll(s => (object)s); } else { rfInfo.type = "FAIL"; rfInfo.message = "未查询到数据,请检查!"; } } return rfInfo; } } }