| | |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using Dm; |
| | | using Model.InterFaceModel; |
| | | using Model.ModelDto; |
| | | using Model.ModelDto.BllCheckDto; |
| | | using Model.ModelDto.PdaDto; |
| | | using Newtonsoft.Json; |
| | | using SqlSugar; |
| | | using Utility; |
| | | using Utility.Tools; |
| | | using WMS.BLL.LogServer; |
| | | using WMS.DAL; |
| | | using WMS.Entity.BllAsnEntity; |
| | |
| | | { |
| | | throw Oops.Bah("托盘储位信息不存在,请检查!"); |
| | | } |
| | | if (models.WareHouseNo != "W02") |
| | | if (models.WareHouseNo != "W04") |
| | | { |
| | | throw Oops.Bah("该托盘未在平库内,请检查!"); |
| | | } |
| | |
| | | { |
| | | throw Oops.Bah("托盘储位信息不存在,请检查!"); |
| | | } |
| | | if (models.WareHouseNo != "W02") |
| | | if (models.WareHouseNo != "W04") |
| | | { |
| | | throw Oops.Bah("该托盘未在平库内,请检查!"); |
| | | } |
| | |
| | | throw Oops.Bah("储位信息不存在,请检查!"); |
| | | } |
| | | |
| | | if (storageLocat.AreaNo.Contains("B0")) |
| | | { |
| | | storageArea = await Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.AreaNo.Contains("B0") && w.WareHouseNo == "W02").OrderBy(o => o.AreaNo).ToListAsync(); |
| | | } |
| | | else |
| | | { |
| | | storageArea = await Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.AreaNo.Contains("B1") && w.WareHouseNo == "W02").OrderBy(o => o.AreaNo).ToListAsync(); |
| | | } |
| | | |
| | | storageArea = await Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.AreaNo != storageLocat.AreaNo && w.WareHouseNo == "W04").OrderBy(o => o.AreaNo).ToListAsync(); |
| | | |
| | | } |
| | | return storageArea; |
| | | } |
| | |
| | | /// <param name="palletNo"></param> |
| | | /// <param name="areaNo"></param> |
| | | /// <param name="ruku"></param> |
| | | public async Task AgvTransport(string palletNo, string areaNo, string ruku, int userId) |
| | | public async Task AgvTransport(string palletNo, string areaNo, string ruku, string url, int userId) |
| | | { |
| | | if (string.IsNullOrEmpty(palletNo)) |
| | | try |
| | | { |
| | | throw Oops.Bah("请扫描托盘条码!"); |
| | | } |
| | | if (string.IsNullOrEmpty(areaNo) && string.IsNullOrEmpty(ruku)) |
| | | { |
| | | throw Oops.Bah("请选择目标区域或入库口!"); |
| | | } |
| | | if (!string.IsNullOrEmpty(areaNo) && !string.IsNullOrEmpty(ruku)) |
| | | { |
| | | throw Oops.Bah("目标区域和入库口不能同时选择!"); |
| | | } |
| | | string EndLocat = string.Empty;//目标位置 |
| | | |
| | | var log = await Db.Queryable<LogTask>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo && (w.Status == "0" || w.Status == "1")); |
| | | if (log != null) |
| | | { |
| | | throw Oops.Bah("该托盘已有小车等待执行或正在执行的任务!"); |
| | | } |
| | | var stockDetail = await Db.Queryable<DataStockDetail>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo); |
| | | if (stockDetail == null) |
| | | { |
| | | throw Oops.Bah("托盘上物料库存明细信息不存在,请检查!"); |
| | | } |
| | | if (!string.IsNullOrEmpty(areaNo)) |
| | | { |
| | | var storageArea = await Db.Queryable<SysStorageArea>().FirstAsync(w => w.IsDel == "0" && w.AreaNo == areaNo); |
| | | if (storageArea == null) |
| | | if (string.IsNullOrEmpty(palletNo)) |
| | | { |
| | | throw Oops.Bah("所选区域信息不存在,请检查!"); |
| | | throw Oops.Bah("请扫描托盘条码!"); |
| | | } |
| | | EndLocat = await GetLocat(areaNo, stockDetail.SkuNo, stockDetail.LotNo, palletNo); |
| | | } |
| | | else |
| | | { |
| | | EndLocat = ruku; |
| | | } |
| | | var stock = await Db.Queryable<DataStock>().FirstAsync(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo); |
| | | if (stock == null) |
| | | { |
| | | throw Oops.Bah("托盘上物料库存信息不存在,请检查!"); |
| | | } |
| | | if (string.IsNullOrEmpty(stockDetail.LocatNo)) |
| | | { |
| | | throw Oops.Bah("托盘储位信息不存在,请检查!"); |
| | | } |
| | | if (stockDetail.WareHouseNo != "W02") |
| | | { |
| | | throw Oops.Bah("该托盘未在平库内,请检查!"); |
| | | } |
| | | //起始储位信息 |
| | | var storageLocat = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == stockDetail.LocatNo); |
| | | if (storageLocat == null) |
| | | { |
| | | throw Oops.Bah("储位信息不存在,请检查!"); |
| | | } |
| | | //目标储位信息 |
| | | var storageLocatEnd = new SysStorageLocat(); |
| | | if (!string.IsNullOrEmpty(areaNo)) |
| | | { |
| | | storageLocatEnd = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == EndLocat && w.Flag == "0" && w.Status == "0"); |
| | | if (string.IsNullOrEmpty(areaNo) && string.IsNullOrEmpty(ruku)) |
| | | { |
| | | throw Oops.Bah("请选择目标区域或入库口!"); |
| | | } |
| | | if (!string.IsNullOrEmpty(areaNo) && !string.IsNullOrEmpty(ruku)) |
| | | { |
| | | throw Oops.Bah("目标区域和入库口不能同时选择!"); |
| | | } |
| | | string EndLocat = string.Empty;//目标位置 |
| | | |
| | | var log = await Db.Queryable<LogTask>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo && (w.Status == "0" || w.Status == "1")); |
| | | if (log != null) |
| | | { |
| | | throw Oops.Bah("该托盘已有等待执行或正在执行的任务!"); |
| | | } |
| | | var stockDetail = await Db.Queryable<DataStockDetail>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo); |
| | | if (stockDetail == null) |
| | | { |
| | | throw Oops.Bah("托盘上物料库存明细信息不存在,请检查!"); |
| | | } |
| | | if (!string.IsNullOrEmpty(areaNo)) |
| | | { |
| | | var storageArea = await Db.Queryable<SysStorageArea>().FirstAsync(w => w.IsDel == "0" && w.AreaNo == areaNo); |
| | | if (storageArea == null) |
| | | { |
| | | throw Oops.Bah("所选区域信息不存在,请检查!"); |
| | | } |
| | | EndLocat = await GetLocat(areaNo); |
| | | } |
| | | else |
| | | { |
| | | EndLocat = ruku; |
| | | } |
| | | var stock = await Db.Queryable<DataStock>().FirstAsync(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo); |
| | | if (stock == null) |
| | | { |
| | | throw Oops.Bah("托盘上物料库存信息不存在,请检查!"); |
| | | } |
| | | if (string.IsNullOrEmpty(stockDetail.LocatNo)) |
| | | { |
| | | throw Oops.Bah("托盘储位信息不存在,请检查!"); |
| | | } |
| | | if (stockDetail.WareHouseNo != "W04") |
| | | { |
| | | throw Oops.Bah("该托盘未在平库内,请检查!"); |
| | | } |
| | | //起始储位信息 |
| | | var storageLocat = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == stockDetail.LocatNo); |
| | | if (storageLocat == null) |
| | | { |
| | | throw Oops.Bah("储位信息不存在,请检查!"); |
| | | } |
| | | //目标储位信息 |
| | | //var storageLocatEnd = new SysStorageLocat(); |
| | | |
| | | var storageLocatEnd = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == EndLocat && w.Flag == "0"); |
| | | if (storageLocatEnd == null) |
| | | { |
| | | throw Oops.Bah("目标储位信息不存在,请检查!"); |
| | | } |
| | | |
| | | |
| | | //添加出库任务 |
| | | var taskNo = new Common().GetMaxNo("TK"); |
| | | var moveTask = new LogTask |
| | | { |
| | | TaskNo = taskNo, |
| | | Sender = "WMS", |
| | | Receiver = "WCS", |
| | | IsSuccess = 0, //是否下发成功 0失败 1成功 |
| | | |
| | | StartLocat = stockDetail.LocatNo,//起始位置 |
| | | EndLocat = EndLocat,//目标位置 |
| | | PalletNo = palletNo,//托盘码 |
| | | Msg = string.Format("转运任务:{0}=>>{1}", stockDetail.LocatNo, EndLocat), |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = "2",//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | OrderType = "3",//0 入库单 1 出库单 2 盘点单 3 移库单 |
| | | |
| | | CreateTime = DateTime.Now |
| | | }; |
| | | await Db.Insertable(moveTask).ExecuteCommandAsync(); |
| | | |
| | | //修改库存明细信息 |
| | | //stockDetail.Status = "4";//移库锁定 |
| | | //stockDetail.LockQty = stockDetail.Qty;//锁定库存数量 |
| | | //await Db.Updateable(stockDetail).ExecuteCommandAsync(); |
| | | ////修改库存信息 |
| | | //stock.LockQty += (decimal)stockDetail.Qty; |
| | | //await Db.Updateable(stock).ExecuteCommandAsync(); |
| | | |
| | | //修改起始储位地址状态 |
| | | storageLocat.Status = "5";//0:空储位 1:有物品 2:入库中 3:出库中 4:移入中 5:移出中 |
| | | await Db.Updateable(storageLocat).ExecuteCommandAsync(); |
| | | |
| | | //修改目标储位地址状态 |
| | | if (storageLocatEnd != null) |
| | | { |
| | | storageLocatEnd.Status = "4";//0:空储位 1:有物品 2:入库中 3:出库中 4:移入中 5:移出中 |
| | | await Db.Updateable(storageLocatEnd).ExecuteCommandAsync(); |
| | | } |
| | | //添加操作日志记录 |
| | | var k = new OperationCrServer().AddLogOperationCr("PDA模块", "AGV转运", palletNo, "移库", $"PDA呼叫小车对托盘号:{palletNo}发起转运", userId); |
| | | |
| | | var outDto = new List<OutCommandDto> |
| | | { |
| | | new OutCommandDto() |
| | | { |
| | | TaskNo = moveTask.TaskNo, // 任务号 |
| | | TaskType = "2",// 任务类型 0入 1出 2移 |
| | | PalletNo = moveTask.PalletNo,//托盘号 |
| | | |
| | | StartLocate = moveTask.StartLocat, // 起始位置 |
| | | EndLocate = EndLocat, // 目标位置 |
| | | |
| | | Order = 999, |
| | | Type = PLCTypeEnum.AGV |
| | | |
| | | } |
| | | }; |
| | | |
| | | // 正式运行程序放开 |
| | | var list2 = outDto.Select(m => m.TaskNo).ToList(); |
| | | var jsonData = JsonConvert.SerializeObject(outDto); |
| | | string response = ""; |
| | | |
| | | try |
| | | { |
| | | var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss") |
| | | response = HttpHelper.DoPost(url, jsonData, "下发给WCS出库命令", "WCS"); |
| | | var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss") |
| | | |
| | | //解析返回数据 |
| | | var wcsModel = JsonConvert.DeserializeObject<WcsModel2>(response); |
| | | if (wcsModel.code == 200) |
| | | { |
| | | // 更改任务的发送返回时间// |
| | | new TaskServer().EditTaskIssueOk(list2, time1, time2); |
| | | } |
| | | else |
| | | { |
| | | new TaskServer().EditTaskIssueNo(list2, time1, time2, wcsModel.message); |
| | | throw new Exception(wcsModel.message); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | throw new Exception(ex.Message); |
| | | } |
| | | |
| | | } |
| | | |
| | | //添加出库任务 |
| | | var taskNo = new Common().GetMaxNo("TK"); |
| | | var exTask = new LogTask |
| | | catch (Exception e) |
| | | { |
| | | TaskNo = taskNo, |
| | | Sender = "WMS", |
| | | Receiver = "AGV", |
| | | IsSuccess = 0, //是否下发成功 0失败 1成功 |
| | | |
| | | StartLocat = stockDetail.LocatNo,//起始位置 |
| | | EndLocat = EndLocat,//目标位置 |
| | | PalletNo = palletNo,//托盘码 |
| | | Msg = string.Format("转运任务:{0}=>>{1}", stockDetail.LocatNo, EndLocat), |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = "2",//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | OrderType = "3",//0 入库单 1 出库单 2 盘点单 3 移库单 |
| | | |
| | | CreateTime = DateTime.Now |
| | | }; |
| | | await Db.Insertable(exTask).ExecuteCommandAsync(); |
| | | |
| | | //修改库存明细信息 |
| | | stockDetail.Status = "4";//移库锁定 |
| | | stockDetail.LockQty = stockDetail.Qty;//锁定库存数量 |
| | | await Db.Updateable(stockDetail).ExecuteCommandAsync(); |
| | | //修改库存信息 |
| | | stock.LockQty += (decimal)stockDetail.Qty; |
| | | await Db.Updateable(stock).ExecuteCommandAsync(); |
| | | |
| | | //修改起始储位地址状态 |
| | | storageLocat.Status = "5";//0:空储位 1:有物品 2:入库中 3:出库中 4:移入中 5:移出中 |
| | | await Db.Updateable(storageLocat).ExecuteCommandAsync(); |
| | | |
| | | //修改目标储位地址状态 |
| | | if (storageLocatEnd != null) |
| | | { |
| | | storageLocatEnd.Status = "4";//0:空储位 1:有物品 2:入库中 3:出库中 4:移入中 5:移出中 |
| | | await Db.Updateable(storageLocatEnd).ExecuteCommandAsync(); |
| | | throw new Exception(e.Message); |
| | | } |
| | | //添加操作日志记录 |
| | | var k = new OperationCrServer().AddLogOperationCr("PDA模块", "AGV转运", palletNo, "移库", $"PDA呼叫小车对托盘号:{palletNo}发起转运", userId); |
| | | |
| | | #region 呼叫小车代码 |
| | | |
| | | #endregion |
| | | } |
| | | /// <summary> |
| | | /// agv转运呼叫小车取货 |
| | |
| | | throw Oops.Bah($"托盘号:{item.PalletNo}所在的储位信息不存在,请检查!"); |
| | | } |
| | | //获取目标储位 |
| | | EndLocat = await GetLocat(areaNo, item.SkuNo, item.LotNo, palletNo); |
| | | EndLocat = await GetLocat(areaNo); |
| | | if (string.IsNullOrEmpty(EndLocat)) |
| | | { |
| | | throw Oops.Bah("分配目标储位失败,请检查!"); |
| | |
| | | /// <param name="skuNo"></param> |
| | | /// <param name="lotNo"></param> |
| | | /// <returns></returns> |
| | | private async Task<string> GetLocat(string areaNo, string skuNo, string lotNo, string palletNo, string hasLocatNoList = "") |
| | | private async Task<string> GetLocat(string areaNo) |
| | | { |
| | | string endLocat = string.Empty;//目标储位 |
| | | //当然区域所有储位信息 |
| | | var storageLocatList = await Db.Queryable<SysStorageLocat>().Where(w => w.WareHouseNo == "W02" && w.AreaNo == areaNo).ToListAsync(); |
| | | //同区域同批次物料的储位信息 |
| | | List<string> locatList = await Db.Queryable<DataStockDetail>().Where(w => w.IsDel == "0" && w.SkuNo == skuNo && w.LotNo == lotNo && w.WareHouseNo == "W02" && w.AreaNo == areaNo && w.PalletNo != palletNo) |
| | | .OrderByDescending(o => o.LocatNo).Select(s => s.LocatNo).Distinct().ToListAsync(); |
| | | foreach (var item in locatList) |
| | | { |
| | | var locatInfo = storageLocatList.Where(w => w.LocatNo == item).First(); |
| | | //当前区域所有储位信息 |
| | | var storageLocatList = await Db.Queryable<SysStorageLocat>().Where(w => w.WareHouseNo == "W04" && w.AreaNo == areaNo).ToListAsync(); |
| | | |
| | | var locatInfo2 = storageLocatList.Where(w => w.IsDel == "0" && w.Flag == "0" && w.Status == "0") |
| | | .OrderByDescending(m => m.Layer).OrderByDescending(m => m.Column).OrderByDescending(m => m.Row).First(); |
| | | |
| | | var locatInfo2 = storageLocatList.Where(w => w.IsDel == "0" && w.Status == "0" && w.Flag == "0" && w.LocatNo != locatInfo.LocatNo && w.Row == locatInfo.Row && !hasLocatNoList.Contains(w.LocatNo)) |
| | | .OrderByDescending(o => o.Column).First(); |
| | | if (locatInfo2 != null) |
| | | { |
| | | endLocat = locatInfo2.LocatNo; |
| | | } |
| | | } |
| | | if (string.IsNullOrEmpty(endLocat)) |
| | | if (locatInfo2 != null) |
| | | { |
| | | var locatInfo3 = storageLocatList.Where(w => w.IsDel == "0" && w.Flag == "0" && w.Status == "0" && !hasLocatNoList.Contains(w.LocatNo)) |
| | | .OrderByDescending(m => m.Layer).OrderByDescending(m => m.Column).OrderByDescending(m => m.Row).First(); |
| | | |
| | | if (locatInfo3 != null) |
| | | { |
| | | endLocat = locatInfo3.LocatNo; |
| | | } |
| | | endLocat = locatInfo2.LocatNo; |
| | | } |
| | | |
| | | //if (string.IsNullOrEmpty(endLocat)) |
| | | //{ |
| | | // var locatInfo3 = storageLocatList.Where(w => w.IsDel == "0" && w.Flag == "0") |
| | | // .OrderByDescending(m => m.Layer).OrderByDescending(m => m.Column).OrderByDescending(m => m.Row).First(); |
| | | |
| | | // if (locatInfo3 != null) |
| | | // { |
| | | // endLocat = locatInfo3.LocatNo; |
| | | // } |
| | | //} |
| | | return endLocat; |
| | | } |
| | | #endregion |
| | |
| | | } |
| | | #endregion |
| | | |
| | | #region 箱码拆箱贴标 |
| | | #region 箱码拆箱贴标、人工确认收货 |
| | | /// <summary> |
| | | /// 拆箱添加标签 |
| | | /// </summary> |
| | | /// <param name="boxNo"></param> |
| | | /// <param name="devanQty"></param> |
| | | /// <param name="userId"></param> |
| | | public void AddLableByDevanning(string boxNo, decimal devanQty, int userId) |
| | | public BoxListInfoDto AddLableByDevanning(string boxNo, decimal devanQty, int userId) |
| | | { |
| | | try |
| | | { |
| | |
| | | Db.Updateable(boxInfo).ExecuteCommand(); |
| | | |
| | | var boxStr = boxInfo.BoxNo.Substring(0, boxInfo.BoxNo.Length - 6);//获取箱码前缀-除后六位流水外 |
| | | var maxBoxCode = Db.Queryable<BllBoxInfo>().Where(m => m.BoxNo.Contains(boxStr) && m.IsDel == "0" && m.Origin == "WMS生成").Max(a => a.BoxNo); |
| | | var maxBoxCode1 = Db.Queryable<BllBoxInfo>().Where(m => m.BoxNo.Contains(boxStr) && m.IsDel == "0" && m.Origin == "WMS生成").Max(a => a.BoxNo); |
| | | |
| | | var maxBoxCode2 = Db.Queryable<DataBoxInfo>().Where(m => m.BoxNo.Contains(boxStr) && m.IsDel == "0").Max(a => a.BoxNo); |
| | | //如果结果为0,则说明两个字符串相等; ABC BCE |
| | | //如果结果小于0,则说明第一个字符串小于第二个字符串; |
| | | //如果结果大于0,则说明第一个字符串大于第二个字符串。 |
| | | var maxBoxCode = maxBoxCode1; |
| | | var bol = String.CompareOrdinal(maxBoxCode1, maxBoxCode2); |
| | | if (bol<0) |
| | | { |
| | | maxBoxCode = maxBoxCode2; |
| | | } |
| | | var boxNoNew = maxBoxCode.Substring(0, maxBoxCode.Length - 6) + (int.Parse(maxBoxCode.Substring(maxBoxCode.Length - 6, 6)) + 1).ToString().PadLeft(6, '0'); |
| | | |
| | | // 添加新箱码信息 |
| | |
| | | new OperationCrServer().AddLogOperationCr("库内作业", "操作日志", boxNo, "编辑", $"拆箱贴标:原箱码:{boxNo}拆箱,添加新箱码{boxNoNew}", userId); |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | |
| | | #region 获取拆箱的信息打印 |
| | | |
| | | |
| | | var data = new BoxListInfoDto() |
| | | { |
| | | SkuNo = boxInfo.SkuNo, |
| | | SkuName = boxInfo.SkuName, |
| | | LotNo = boxInfo.LotNo, |
| | | BoxNoList = new List<string>() { boxNoNew } , |
| | | Date1 = boxInfo.ProductionTime.ToString(), |
| | | Date2 = boxInfo.ExpirationTime.ToString(), |
| | | |
| | | }; |
| | | |
| | | #endregion |
| | | |
| | | return data; |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | |
| | | public string GetReceiptSoNoByPallet(string palletNo) |
| | | { |
| | | try |
| | | { |
| | | var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == palletNo).GroupBy(m=>m.SONo).Select(m=>m.SONo).ToList(); |
| | | if (stockDetail.Count == 0) |
| | | { |
| | | throw new Exception("没有查询到托盘库存信息"); |
| | | } |
| | | if (stockDetail.Count != 1) |
| | | { |
| | | throw new Exception("库存托盘不是唯一出库单"); |
| | | } |
| | | var detail = stockDetail.First(); |
| | | if (string.IsNullOrWhiteSpace(detail)) |
| | | { |
| | | throw new Exception("托盘没有出库单信息"); |
| | | } |
| | | //var task = Db.Queryable<LogTask>().First(m => m.PalletNo == palletNo && m.IsDel == "0" && m.Status == "5"); |
| | | //if (task == null) |
| | | //{ |
| | | // throw new Exception("没有查询到托盘任务信息"); |
| | | //} |
| | | //if (task.Status != "5") |
| | | //{ |
| | | // throw new Exception("任务状态不是等待确认"); |
| | | //} |
| | | return detail; |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | |
| | | /// <summary> |
| | | /// 人工确认收货 |
| | | /// </summary> |
| | | /// <param name="palletNo"></param> |
| | | /// <param name="userId"></param> |
| | | public void ConfirmReceipt(string palletNo, int userId) |
| | | { |
| | | try |
| | | { |
| | | Db.BeginTran(); |
| | | //var task = Db.Queryable<LogTask>().First(m => m.PalletNo == palletNo && m.IsDel == "0" && m.Status == "5"); |
| | | //if (task == null) |
| | | //{ |
| | | // throw new Exception("没有查询到托盘任务信息"); |
| | | //} |
| | | //if (task.Status != "5") |
| | | //{ |
| | | // throw new Exception("任务状态不是等待确认"); |
| | | //} |
| | | ////任务状态变更为执行完成 |
| | | //task.Status = "2"; |
| | | //Db.Updateable(task).ExecuteCommand(); |
| | | var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && m.PalletNo == palletNo).ToList(); |
| | | if (stockDetail.Count == 0) |
| | | { |
| | | throw new Exception("库存托盘没有信息"); |
| | | } |
| | | var locate = stockDetail.First().LocatNo; |
| | | var locatList = Db.Queryable<SysStorageLocat>().Where(m=>m.WareHouseNo == "W04" && (m.AreaNo == "B06" || m.AreaNo == "B07" || m.AreaNo == "B09") && m.IsDel == "0").ToList(); |
| | | var locat = locatList.FirstOrDefault(m => m.LocatNo == locate); |
| | | //判断托盘储位是否在车间 |
| | | if (locat == null) |
| | | { |
| | | throw new Exception("储位信息没有在车间工位上"); |
| | | } |
| | | locat.Status = "0"; |
| | | Db.Updateable(locat).ExecuteCommand(); |
| | | //判断托盘信息 |
| | | |
| | | foreach (var item in stockDetail) |
| | | { |
| | | if (item.UDF5 != "1" || string.IsNullOrWhiteSpace(item.SONo)) |
| | | { |
| | | continue; |
| | | } |
| | | |
| | | //item.WareHouseNo = ""; |
| | | //item.RoadwayNo = ""; |
| | | //item.AreaNo = ""; |
| | | item.LocatNo = ""; |
| | | //item.PalletNo = ""; |
| | | item.LockQty = 0; // 锁定数量更为0 |
| | | item.Status = "0"; // 状态变为待分配 |
| | | var boxInfo = Db.Queryable<DataBoxInfo>().Where(m => m.StockDetailId == item.Id).ToList(); |
| | | foreach (var item2 in boxInfo) |
| | | { |
| | | item2.Status = "2"; //状态变为已入库 |
| | | } |
| | | |
| | | Db.Updateable(boxInfo).ExecuteCommand(); |
| | | } |
| | | Db.Updateable(stockDetail).ExecuteCommand(); |
| | | //托盘变更状态 |
| | | //var pallet = Db.Queryable<SysPallets>().First(m => m.IsDel == "0" && m.PalletNo == palletNo); |
| | | //if (pallet == null) |
| | | //{ |
| | | // throw new Exception("没有查询到托盘信息"); |
| | | //} |
| | | //pallet.Status = "0"; |
| | | //Db.Updateable(pallet).ExecuteCommand(); |
| | | //添加操作日志 |
| | | new OperationCrServer().AddLogOperationCr("PDA模块", "车间收货", palletNo, "完成", $"车间收货:{palletNo}托盘收货", userId); |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | Db.RollbackTran(); |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | #endregion |
| | | |
| | | #region 物料拆托 (标签、数量) |
| | | |
| | | /// <summary> |
| | | /// 查询箱信息 |
| | | /// </summary> |
| | | /// <param name="boxNo"></param> |
| | | /// <param name="pallNo"></param> |
| | | public void GetBoxInfo(string boxNo,string pallNo) |
| | | { |
| | | try |
| | | { |
| | | var boxInfo = Db.Queryable<DataBoxInfo>().Where(m=>m.IsDel == "0" && m.BoxNo == boxNo).ToList(); |
| | | if (!string.IsNullOrWhiteSpace(pallNo)) |
| | | { |
| | | boxInfo = boxInfo.Where(m=>m.PalletNo == pallNo).ToList(); |
| | | } |
| | | if (boxInfo.Count!=1) |
| | | { |
| | | throw new Exception("标签信息错误,请联系管理员"); |
| | | } |
| | | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | public void UpPalletByBox(string boxNo,string pallet,string palletNew,int userId) |
| | | { |
| | | try |
| | | { |
| | | Db.BeginTran(); |
| | | if (string.IsNullOrWhiteSpace(boxNo) || string.IsNullOrWhiteSpace(pallet) || string.IsNullOrWhiteSpace(palletNew)) |
| | | { |
| | | throw new Exception("参数错误,托盘、新托盘、箱码均不能为空"); |
| | | } |
| | | var boxInfoList = Db.Queryable<DataBoxInfo>().Where(m=>m.IsDel == "0" && m.BoxNo == boxNo).ToList(); |
| | | if (boxInfoList.Count != 1) |
| | | { |
| | | throw new Exception("标签信息数量不是1条"); |
| | | } |
| | | var boxInfo = boxInfoList.First(); |
| | | var detail1 = Db.Queryable<DataStockDetail>().First(m=>m.IsDel == "0" && m.PalletNo == pallet && m.Id == boxInfo.StockDetailId ); |
| | | if (detail1 == null) |
| | | { |
| | | throw new Exception("未查询到托盘和箱码的库存明细"); |
| | | } |
| | | var palletInfoNew = Db.Queryable<SysPallets>().First(m => m.IsDel == "0" && m.PalletNo == palletNew); |
| | | if (palletInfoNew == null) |
| | | { |
| | | throw new Exception("未查询到新托盘信息"); |
| | | } |
| | | var detailNewBl = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == palletNew && (m.SkuNo != boxInfo.SkuNo || m.LotNo != boxInfo.LotNo)); |
| | | if (detailNewBl!=null) |
| | | { |
| | | throw new Exception("新托盘上已有其他物料箱信息"); |
| | | } |
| | | //添加/更新库存托盘信息 |
| | | var detailNew1 = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == palletNew && m.SkuNo == boxInfo.SkuNo && m.LotNo == boxInfo.LotNo); |
| | | var newId = 0; |
| | | if (detailNew1 == null)//add |
| | | { |
| | | var detailNew = new DataStockDetail(); |
| | | detailNew.SkuNo = detail1.SkuNo; |
| | | detailNew.SkuName = detail1.SkuName; |
| | | detailNew.LotNo = detail1.LotNo; |
| | | detailNew.LotText = detail1.LotText; |
| | | detailNew.SupplierLot = detail1.SupplierLot; |
| | | detailNew.SupplierNo = detail1.SupplierNo; |
| | | detailNew.SupplierName = detail1.SupplierName; |
| | | detailNew.Standard = detail1.Standard; |
| | | detailNew.Qty = boxInfo.Qty; |
| | | detailNew.LockQty = 0; |
| | | detailNew.FrozenQty = 0; |
| | | detailNew.InspectQty = 0; |
| | | detailNew.ASNNo = ""; |
| | | |
| | | detailNew.PalletNo = palletNew; |
| | | detailNew.ProductionTime = detail1.ProductionTime; |
| | | detailNew.ExpirationTime = detail1.ExpirationTime; |
| | | detailNew.PalletTags = "0"; |
| | | detailNew.CompleteTime = DateTime.Now; |
| | | detailNew.Status = "0"; |
| | | detailNew.InspectMark = detail1.InspectMark; |
| | | detailNew.BitPalletMark = "1"; |
| | | detailNew.InspectStatus = detail1.InspectStatus; |
| | | detailNew.PackagNo = detail1.PackagNo; |
| | | detailNew.IsBale = detail1.IsBale; |
| | | detailNew.IsBelt = detail1.IsBelt; |
| | | detailNew.IsDel = "0"; |
| | | detailNew.CreateTime = DateTime.Now; |
| | | detailNew.CreateUser = 0; |
| | | |
| | | |
| | | newId = Db.Insertable(detailNew).ExecuteReturnIdentity(); |
| | | } |
| | | else //update |
| | | { |
| | | detailNew1.Qty += boxInfo.Qty; |
| | | detailNew1.PalletNo = palletNew; |
| | | |
| | | Db.Updateable(detailNew1).ExecuteCommand(); |
| | | newId = detailNew1.Id; |
| | | } |
| | | //更新托盘状态 |
| | | palletInfoNew.Status = "1"; |
| | | Db.Updateable(palletInfoNew).ExecuteCommand(); |
| | | |
| | | //更改原托盘信息 |
| | | detail1.Qty -= boxInfo.Qty; |
| | | detail1.BitPalletMark = "1"; |
| | | if (detail1.Qty <= 0) |
| | | { |
| | | //更新原托盘状态 |
| | | var palletInfo = Db.Queryable<SysPallets>().First(m => m.IsDel == "0" && m.PalletNo == pallet); |
| | | palletInfo.Status = "0"; |
| | | Db.Updateable(palletInfo).ExecuteCommand(); |
| | | |
| | | Db.Deleteable(detail1).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | Db.Updateable(detail1).ExecuteCommand(); |
| | | } |
| | | |
| | | //更新库存箱信息 |
| | | boxInfo.StockDetailId = newId; |
| | | boxInfo.BindNo = 0; |
| | | boxInfo.PalletNo = palletNew; |
| | | Db.Updateable(boxInfo).ExecuteCommand(); |
| | | //添加操作日志 |
| | | new OperationCrServer().AddLogOperationCr("库内作业", "操作日志", boxNo, "编辑", $"物料拆托:箱码:{boxNo}换托,原托盘{pallet},新托盘{palletNew}", userId); |
| | | |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | Db.RollbackTran(); |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | //数量页签----------------------------------------------------------------------------------------------------------------------------------------- |
| | | |
| | | /// <summary> |
| | | /// 根据托盘获取托盘上的物料批次信息 |
| | | /// </summary> |
| | | /// <param name="palletNo"></param> |
| | | /// <returns></returns> |
| | | /// <exception cref="Exception"></exception> |
| | | public List<SelectSkuLotNo> GetSelectSkuLotNo(string palletNo) |
| | | { |
| | | try |
| | | { |
| | | var data = new List<SelectSkuLotNo>(); |
| | | var detailList = Db.Queryable<DataStockDetail>().Where(m=>m.IsDel == "0" && m.PalletNo == palletNo).ToList(); |
| | | |
| | | foreach (var item in detailList) |
| | | { |
| | | if (data.Count(m=>m.DetailId == item.Id.ToString()) == 0) |
| | | { |
| | | data.Add(new SelectSkuLotNo() |
| | | { |
| | | SkuNo = item.SkuNo, |
| | | SkuName = item.SkuName, |
| | | LotNo = item.LotNo, |
| | | DetailId = item.Id.ToString(), |
| | | }); |
| | | } |
| | | } |
| | | return data; |
| | | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | |
| | | /// <summary> |
| | | /// 拆托-数量 |
| | | /// </summary> |
| | | /// <param name="palletNo"></param> |
| | | /// <param name="palletNoNew"></param> |
| | | /// <param name="detailId"></param> |
| | | /// <param name="qty"></param> |
| | | /// <param name="userId"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void UpPalletByQty(string palletNo,string palletNoNew,string detailId,decimal qty,int userId) |
| | | { |
| | | try |
| | | { |
| | | Db.BeginTran(); |
| | | if (string.IsNullOrWhiteSpace(detailId) || string.IsNullOrWhiteSpace(palletNo) || string.IsNullOrWhiteSpace(palletNoNew)) |
| | | { |
| | | throw new Exception("参数错误,托盘、新托盘、物料批次均不能为空"); |
| | | } |
| | | if (qty<=0) |
| | | { |
| | | throw new Exception("参数数量不能为小等0"); |
| | | } |
| | | var detailId2 = int.Parse(detailId); |
| | | var detail1 = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == palletNo && m.Id == detailId2); |
| | | if (detail1 == null) |
| | | { |
| | | throw new Exception("未查询到托盘库存明细"); |
| | | } |
| | | var palletInfoNew = Db.Queryable<SysPallets>().First(m => m.IsDel == "0" && m.PalletNo == palletNoNew); |
| | | if (palletInfoNew == null) |
| | | { |
| | | throw new Exception("未查询到新托盘信息"); |
| | | } |
| | | |
| | | //添加/更新库存托盘信息 |
| | | var detailNew1 = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == palletNoNew && m.SkuNo == detail1.SkuNo && m.LotNo == detail1.LotNo); |
| | | var newId = 0; |
| | | if (detailNew1 == null)//add |
| | | { |
| | | var detailNew = new DataStockDetail(); |
| | | detailNew.SkuNo = detail1.SkuNo; |
| | | detailNew.SkuName = detail1.SkuName; |
| | | detailNew.LotNo = detail1.LotNo; |
| | | detailNew.LotText = detail1.LotText; |
| | | detailNew.SupplierLot = detail1.SupplierLot; |
| | | detailNew.SupplierNo = detail1.SupplierNo; |
| | | detailNew.SupplierName = detail1.SupplierName; |
| | | detailNew.Standard = detail1.Standard; |
| | | detailNew.Qty = qty; |
| | | detailNew.LockQty = 0; |
| | | detailNew.FrozenQty = 0; |
| | | detailNew.InspectQty = 0; |
| | | detailNew.ASNNo = ""; |
| | | |
| | | detailNew.PalletNo = palletNoNew; |
| | | detailNew.ProductionTime = detail1.ProductionTime; |
| | | detailNew.ExpirationTime = detail1.ExpirationTime; |
| | | detailNew.PalletTags = "0"; |
| | | detailNew.CompleteTime = DateTime.Now; |
| | | detailNew.Status = "0"; |
| | | detailNew.InspectMark = detail1.InspectMark; |
| | | detailNew.BitPalletMark = "1"; |
| | | detailNew.InspectStatus = detail1.InspectStatus; |
| | | detailNew.PackagNo = detail1.PackagNo; |
| | | detailNew.IsBale = detail1.IsBale; |
| | | detailNew.IsBelt = detail1.IsBelt; |
| | | detailNew.IsDel = "0"; |
| | | detailNew.CreateTime = DateTime.Now; |
| | | detailNew.CreateUser = 0; |
| | | |
| | | |
| | | newId = Db.Insertable(detailNew).ExecuteReturnIdentity(); |
| | | } |
| | | else //update |
| | | { |
| | | detailNew1.Qty += qty; |
| | | detailNew1.PalletNo = palletNoNew; |
| | | |
| | | Db.Updateable(detailNew1).ExecuteCommand(); |
| | | newId = detailNew1.Id; |
| | | } |
| | | //更新托盘状态 |
| | | palletInfoNew.Status = "1"; |
| | | Db.Updateable(palletInfoNew).ExecuteCommand(); |
| | | |
| | | //更改原托盘信息 |
| | | detail1.Qty -= qty; |
| | | detail1.BitPalletMark = "1"; |
| | | if (detail1.Qty <= 0) |
| | | { |
| | | //更新原托盘状态 |
| | | var palletInfo = Db.Queryable<SysPallets>().First(m => m.IsDel == "0" && m.PalletNo == palletNo); |
| | | palletInfo.Status = "0"; |
| | | Db.Updateable(palletInfo).ExecuteCommand(); |
| | | |
| | | Db.Deleteable(detail1).ExecuteCommand(); |
| | | } |
| | | else |
| | | { |
| | | Db.Updateable(detail1).ExecuteCommand(); |
| | | } |
| | | |
| | | |
| | | //添加操作日志 |
| | | new OperationCrServer().AddLogOperationCr("库内作业", "操作日志", palletNo, "编辑", $"物料拆托:{detail1.SkuName}物料换托,原托盘{palletNo},新托盘{palletNoNew}", userId); |
| | | |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | | #endregion |
| | | |
| | | } |