| | |
| | | using Model.InterFaceModel; |
| | | using Model.ModelDto; |
| | | using Model.ModelDto.DataDto; |
| | | using Model.ModelDto.LogDto; |
| | | using Newtonsoft.Json; |
| | | using SqlSugar; |
| | | using System; |
| | |
| | | using System.Linq; |
| | | using System.Security.Policy; |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using Utility.Tools; |
| | | using WMS.BLL.LogServer; |
| | | using WMS.DAL; |
| | | using WMS.Entity.BllAsnEntity; |
| | | using WMS.Entity.BllSoEntity; |
| | |
| | | using WMS.Entity.SysEntity; |
| | | using WMS.IBLL.IBllTransServer; |
| | | using static Model.InterFaceModel.RCSModel; |
| | | using static System.Collections.Specialized.BitVector32; |
| | | |
| | | namespace WMS.BLL.BllTransServer |
| | | { |
| | |
| | | { |
| | | private static readonly SqlSugarScope Db = DataContext.Db; |
| | | /// <summary> |
| | | /// RCS叫桶(净桶和脏桶) |
| | | /// RCS叫桶 |
| | | /// </summary> |
| | | /// <param name="warehouseno">库区</param> |
| | | /// <param name="type">叫料类型</param> |
| | | /// <returns></returns> |
| | | public void GetPalletNo(Pallnetmsg model,string url) |
| | | { |
| | | DataStockDetail pallet = new DataStockDetail(); |
| | | /// <param name="model"></param> |
| | | /// <param name="url"></param> |
| | | /// <param name="taskNo"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void GetPalletNo(Pallnetmsg model, string url, out string taskNo) |
| | | { |
| | | try |
| | | { |
| | | string taskMsg = ""; |
| | | if (string.IsNullOrEmpty(model.Location)) |
| | | { |
| | | throw new Exception("设备所在位置不可为空"); |
| | | } |
| | | var locatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == model.Location); |
| | | if (locatInfo == null) |
| | | //叫桶设备所在储位信息(目标储位) |
| | | var endLoction = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == model.Location); |
| | | if (endLoction == null) |
| | | { |
| | | throw new Exception("设备储位信息不存在"); |
| | | } |
| | | var house = locatInfo.WareHouseNo;//叫桶位置,后续根据位置关联或定义,来判断叫桶位置所属车间 |
| | | var houseNo = endLoction.WareHouseNo;//叫桶位置,后续根据位置关联或定义,来判断叫桶位置所属车间 |
| | | var urlMes = "";//回传MES的接口地址 |
| | | var noticeno = "0";//出入库单据明细ID |
| | | var sql = "select PalletNo,LocatNo from DataStockDetail where Status = '0'"; |
| | | var noticeNo = "0";//出入库单据明细ID |
| | | var stockDetail = Db.Queryable<DataStockDetail>().Where(w => w.Status == "0");//所有待分配的桶 |
| | | |
| | | //开始事务 |
| | | Db.BeginTran(); |
| | | DataStockDetail pallet = new DataStockDetail(); |
| | | switch (model.Type) |
| | | { |
| | | case "0"://叫净桶 |
| | | sql += $"and WareHouseNo = '{house}' and (AreaNo like '%01' or AreaNo like '%11' or AreaNo like '%21' or AreaNo like '%31') and PalletStatus = '0' order by CreateTime desc"; |
| | | pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); |
| | | //查找到该车间净桶区 |
| | | List<string> areaNoList = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "0" && w.WareHouseNo == houseNo).Select(s=>s.AreaNo).ToList(); |
| | | //查找净桶 |
| | | pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "0" && w.Status == "0" |
| | | && areaNoList.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First(); |
| | | if (pallet == null) |
| | | { |
| | | throw new Exception("暂无净桶可分配"); |
| | | } |
| | | } |
| | | pallet.Status = "2";//分配状态 0:待分配,1:部分分配 , 2:已分配 |
| | | //更新桶库存明细 |
| | | Db.Updateable(pallet).ExecuteCommand(); |
| | | |
| | | taskMsg = "设备叫净桶任务"; |
| | | break; |
| | | case "1"://叫料桶(混料) |
| | | //判断是否有批次号 |
| | |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | /*BllArrivalNoticeDetail ArriveMes = new BllArrivalNoticeDetail(); |
| | | //判断该批次是否有对应入库单 |
| | | sql = $"select * from BllArrivalNoticeDetail where LotNo = '{pallnetmsg.LotNo}' order by CreateTime desc"; |
| | | ArriveMes = Db.Ado.SqlQuery<BllArrivalNoticeDetail>(sql).FirstOrDefault(); |
| | | if (ArriveMes == null) |
| | | { |
| | | throw new Exception("该批次没有对应的入库单"); |
| | | } |
| | | noticeno = ArriveMes.Id.ToString();*/ |
| | | //查找到该车间预混区 |
| | | List<string> areaNoList2 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "1" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | //查找库存中是否有可用的此批次的混料桶 |
| | | sql= $@"select PalletNo,LocatNo from DataStockDetail where LotNo = '{model.LotNo}'and (AreaNo like '%02' or AreaNo like '%12' or AreaNo like '%22' or AreaNo like '%32') |
| | | and WareHouseNo = '{house}' and status = '0' and PalletStatus = '1' order by CompleteTime desc"; |
| | | pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); |
| | | pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "1" && w.Status == "0" && w.LotNo == model.LotNo |
| | | && areaNoList2.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).First(); |
| | | if (pallet == null) |
| | | { |
| | | throw new Exception("暂无混料桶可分配"); |
| | | } |
| | | pallet.Status = "2";//分配状态 0:待分配,1:部分分配 , 2:已分配 |
| | | //更新桶库存明细 |
| | | Db.Updateable(pallet).ExecuteCommand(); |
| | | |
| | | taskMsg = "设备叫料桶混料任务"; |
| | | break; |
| | | case "2"://叫料桶(下料) |
| | | BllExportNoticeDetail bllSo = new BllExportNoticeDetail(); |
| | | //判断是否有批次号 |
| | | if (string.IsNullOrWhiteSpace(model.LotNo)) |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | //查找是否有此批次出库单 |
| | | sql = $"select * from BllExportNoticeDetail where LotNo = '{model.LotNo}' order by CreateTime desc"; |
| | | bllSo = Db.Ado.SqlQuery<BllExportNoticeDetail>(sql).FirstOrDefault(); |
| | | if (bllSo == null) |
| | | //查找是否有此批次出库单明细 |
| | | var soNoticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(w => w.IsDel == "0" && w.LotNo == model.LotNo).OrderBy(o => o.CreateTime).First(); |
| | | if (soNoticeDetail == null) |
| | | { |
| | | throw new Exception("该批次没有对应的出库单明细"); |
| | | } |
| | | noticeNo = soNoticeDetail.Id.ToString(); |
| | | //出库总单 |
| | | var soNotice = Db.Queryable<BllExportNotice>().Where(w => w.IsDel == "0" && w.SONo == soNoticeDetail.SONo).First(); |
| | | if (soNotice == null) |
| | | { |
| | | throw new Exception("该批次没有对应的出库单"); |
| | | } |
| | | noticeno = bllSo.Id.ToString(); |
| | | soNotice.Status = "3";//正在执行 |
| | | soNotice.UpdateTime = DateTime.Now; |
| | | //更新出库单 |
| | | Db.Updateable(soNotice).ExecuteCommand(); |
| | | |
| | | //查找到该车间半成品区 |
| | | List<string> areaNoList3 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "2" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | //查找库存中是否有此批次的合格下料桶 |
| | | sql = $@"select PalletNo,LocatNo from DataStockDetail where LotNo = '{model.LotNo}'and (AreaNo like '%03' or AreaNo like '%13' or AreaNo like '%23' or AreaNo like '%33') |
| | | and WareHouseNo = '{house}' and status = '0' and PalletStatus = '2' and InspectStatus = '1' order by CompleteTime desc"; |
| | | pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); |
| | | pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "2" && w.Status == "0" && w.LotNo == model.LotNo && w.InspectStatus=="1" |
| | | && areaNoList3.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).First(); |
| | | if (pallet == null) |
| | | { |
| | | throw new Exception("暂无下料桶可分配"); |
| | | } |
| | | pallet.Status = "2";//分配状态 0:待分配,1:部分分配 , 2:已分配 |
| | | //更新桶库存明细 |
| | | Db.Updateable(pallet).ExecuteCommand(); |
| | | |
| | | taskMsg = "设备叫料桶下料任务"; |
| | | break; |
| | | case "3"://叫脏桶 |
| | | sql += $"and WareHouseNo = '{house}' and (AreaNo like '%04' or AreaNo like '%14' or AreaNo like '%24' or AreaNo like '%34') and PalletStatus='3' order by CreateTime desc"; |
| | | List<DataStockDetail> palletList = Db.Ado.SqlQuery<DataStockDetail>(sql).ToList(); |
| | | //查找到该车间脏桶区 |
| | | List<string> areaNoList4 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "3" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | List<DataStockDetail> palletList = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "3" && w.Status == "0" |
| | | && areaNoList4.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).ToList(); |
| | | if (palletList.Count <= 0) |
| | | { |
| | | throw new Exception("暂无脏桶可分配"); |
| | |
| | | //} |
| | | #endregion |
| | | |
| | | //下发小车任务 |
| | | item.Status = "2";//分配状态 0:待分配,1:部分分配 , 2:已分配 |
| | | //更新桶库存明细 |
| | | Db.Updateable(item).ExecuteCommand(); |
| | | //起始储位地址信息 |
| | | var startLoction2 = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == item.LocatNo); |
| | | if (startLoction2 == null) |
| | | { |
| | | throw new Exception($"起始目标储位信息不存在,桶号:{item.LocatNo}"); |
| | | } |
| | | |
| | | taskNo = new Common().GetMaxNo("TK");//任务号 |
| | | var logTaskEntry2 = new LogTask |
| | | { |
| | | TaskNo = taskNo, |
| | | Sender = "WMS", |
| | | Receiver = "RCS", |
| | | //IsSuccess = 1, //是否下发成功 0失败 1成功 |
| | | SendDate = DateTime.Now, //发送时间 |
| | | //BackDate = DateTime.Now, //返回时间 |
| | | StartLocat = item.LocatNo,//起始位置 |
| | | EndLocat = model.Location,//目标位置 |
| | | PalletNo = item.PalletNo,//托盘码 |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | OrderType = "3",//单据类型 0 入库 1 出库 3 移库 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | NoticeDetailNo = int.Parse(noticeNo), |
| | | Msg = taskMsg, //关键信息 |
| | | }; |
| | | //组织下发小车任务信息 |
| | | var task2 = new TaskDetial |
| | | { |
| | | Taskno = taskNo,//任务号 |
| | | Startport = item.LocatNo, |
| | | Endport = model.Location, |
| | | Pallno = item.PalletNo, |
| | | Type = model.Type, |
| | | Crtype = "1", |
| | | Noticedetailno = int.Parse(noticeno), |
| | | Crtype = "1",//叫桶 |
| | | }; |
| | | CreateLotTask(task2, url); |
| | | //给下车下发任务 |
| | | logTaskEntry2.SendDate = DateTime.Now;//发送时间 |
| | | var agvResult2 = CreateTaskForAgv(task2, url); |
| | | if (agvResult2)//成功 |
| | | { |
| | | //请求成功修改任务表相应字段状态 |
| | | logTaskEntry2.IsSuccess = 1; |
| | | logTaskEntry2.IsSend = 0; |
| | | //logTaskEntry2.IsCancel = 0; |
| | | logTaskEntry2.BackDate = DateTime.Now; |
| | | logTaskEntry2.Status = "1"; |
| | | Db.Insertable(logTaskEntry2).ExecuteCommand(); |
| | | |
| | | startLoction2.Status = "3";//出库中 |
| | | Db.Updateable(startLoction2).ExecuteCommand(); |
| | | |
| | | endLoction.Status = "2";//入库中 |
| | | Db.Updateable(endLoction).ExecuteCommand(); |
| | | } |
| | | else//失败 |
| | | { |
| | | logTaskEntry2.IsSuccess = 0; |
| | | Db.Insertable(logTaskEntry2).ExecuteCommand(); |
| | | |
| | | } |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | return; |
| | | } |
| | | |
| | | taskMsg = "设备叫脏桶任务"; |
| | | break; |
| | | default: |
| | | throw new Exception("任务类型无效"); |
| | | } |
| | | //下发小车任务 |
| | | //起始储位地址信息 |
| | | var startLoction = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == pallet.LocatNo); |
| | | if (startLoction == null) |
| | | { |
| | | throw new Exception($"起始目标储位信息不存在,桶号:{pallet.LocatNo}"); |
| | | } |
| | | |
| | | taskNo = new Common().GetMaxNo("TK");//任务号 |
| | | //任务信息 |
| | | var logTaskEntry = new LogTask |
| | | { |
| | | TaskNo = taskNo, |
| | | Sender = "WMS", |
| | | Receiver = "RCS", |
| | | //IsSuccess = 1, //是否下发成功 0失败 1成功 |
| | | SendDate = DateTime.Now, //发送时间 |
| | | //BackDate = DateTime.Now, //返回时间 |
| | | StartLocat = pallet.LocatNo,//起始位置 |
| | | EndLocat = model.Location,//目标位置 |
| | | PalletNo = pallet.PalletNo,//托盘码 |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | OrderType = "3",//单据类型 0 入库 1 出库 3移库 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | NoticeDetailNo = int.Parse(noticeNo), |
| | | Msg = taskMsg, //关键信息 |
| | | }; |
| | | |
| | | //组织下发小车任务信息 |
| | | var task = new TaskDetial |
| | | { |
| | | Taskno= taskNo,//任务号 |
| | | Startport = pallet.LocatNo,//起始位置 |
| | | Endport = model.Location,//目标位置 |
| | | Pallno = pallet.PalletNo,//桶号 |
| | | Type = model.Type,//桶类型 |
| | | Crtype = "1", |
| | | Noticedetailno = int.Parse(noticeno), |
| | | LotNo = model.LotNo, |
| | | Crtype = "1",//叫桶 |
| | | }; |
| | | CreateLotTask(task, url); |
| | | return; |
| | | //给下车下发任务 |
| | | logTaskEntry.SendDate = DateTime.Now;//发送时间 |
| | | var agvResult = CreateTaskForAgv(task, url); |
| | | if (agvResult)//成功 |
| | | { |
| | | //请求成功修改任务表相应字段状态 |
| | | logTaskEntry.IsSuccess = 1; |
| | | logTaskEntry.IsSend = 0; |
| | | //logTaskEntry.IsCancel = 0; |
| | | logTaskEntry.BackDate = DateTime.Now; |
| | | logTaskEntry.Status = "1";//正在执行 |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | |
| | | startLoction.Status = "3";//出库中 |
| | | Db.Updateable(startLoction).ExecuteCommand(); |
| | | |
| | | endLoction.Status = "2";//入库中 |
| | | Db.Updateable(endLoction).ExecuteCommand(); |
| | | } |
| | | else//失败 |
| | | { |
| | | logTaskEntry.IsSuccess = 0; |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | |
| | | } |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Db.Ado.RollbackTran(); |
| | | //回滚事务 |
| | | Db.RollbackTran(); |
| | | throw new Exception(ex.Message); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 申请储位 |
| | | /// </summary> |
| | | /// <param name="model"></param> |
| | | /// <param name="url"></param> |
| | | /// <param name="taskNo"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void ApplyLocatNo(Pallnetmsg model, string url, out string taskNo) |
| | | { |
| | | try |
| | | { |
| | | string taskMsg = ""; |
| | | //查找该桶有没有正在执行的任务 |
| | | var tasking = Db.Queryable<LogTask>().First(w => w.IsDel == "0" && w.Status == "1" && w.PalletNo == model.PalletNo); |
| | | if (tasking != null) |
| | | { |
| | | throw new Exception($"该桶有正在执行的任务,PalletNo:{model.PalletNo}"); |
| | | } |
| | | //设备所在储位信息(起始储位) |
| | | var deviceLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == model.Location); |
| | | if (deviceLocatInfo == null) |
| | | { |
| | | throw new Exception($"未查询到该设备所在储位信息,Location:{model.Location}"); |
| | | } |
| | | var houseNo = deviceLocatInfo.WareHouseNo;//申请储位设备所在车间编号 |
| | | var noticeno = "0";//出入库单据明细ID |
| | | //桶库存信息 |
| | | var palletInfo = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == model.PalletNo); |
| | | if (palletInfo == null) |
| | | { |
| | | throw new Exception($"未查询到该桶的库存信息,PalletNo:{model.PalletNo}"); |
| | | } |
| | | |
| | | var storageLocat = Db.Queryable<SysStorageLocat>().Where(w => w.IsDel == "0" && w.Status == "0"); |
| | | //开启事务 |
| | | Db.BeginTran(); |
| | | |
| | | SysStorageLocat loction = new SysStorageLocat();//目标储位信息 |
| | | switch (model.Type) |
| | | { |
| | | case "3"://清洗设备申请储位(净桶申请储位) |
| | | //查找到该车间净桶区 |
| | | List<string> areaNoList = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "0" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | loction = storageLocat.Where(w => w.WareHouseNo == houseNo && areaNoList.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间净桶区暂无空余储位"); |
| | | } |
| | | |
| | | taskMsg = "清洗设备(净桶)申请储位任务"; |
| | | break; |
| | | case "0"://接料设备申请储位(预混料桶申请储位) |
| | | //判断是否有批次号 |
| | | if (string.IsNullOrWhiteSpace(model.LotNo)) |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | //查找到该车间预混区 |
| | | List<string> areaNoList2 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "1" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | loction = storageLocat.Where(w => w.WareHouseNo == houseNo && areaNoList2.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间预混区暂无空余储位"); |
| | | } |
| | | palletInfo.LotNo = model.LotNo;//批次号 |
| | | //更新桶库存信息 |
| | | Db.Updateable(palletInfo).ExecuteCommand(); |
| | | |
| | | taskMsg = "接料设备(预混料桶)申请储位任务"; |
| | | break; |
| | | case "1"://混料设备申请储位(半成品桶申请储位) |
| | | //判断是否有批次号 |
| | | if (string.IsNullOrWhiteSpace(model.LotNo)) |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | //校验此批次是否有入库单 |
| | | var noticeDetail = Db.Queryable<BllArrivalNoticeDetail>().Where(w => w.IsDel == "0" && w.Status == "0" && w.LotNo == model.LotNo).OrderByDescending(o => o.CreateTime).First(); |
| | | if (noticeDetail == null) |
| | | { |
| | | throw new Exception("该批次没有对应的入库单明细"); |
| | | } |
| | | noticeno = noticeDetail.Id.ToString(); |
| | | //入库总单 |
| | | var notice = Db.Queryable<BllArrivalNotice>().Where(w => w.IsDel == "0" && w.ASNNo == noticeDetail.ASNNo).First(); |
| | | if (notice == null) |
| | | { |
| | | throw new Exception("该批次没有对应的入库单"); |
| | | } |
| | | notice.Status = "1";//正在执行 |
| | | //更新入库单状态 |
| | | Db.Updateable(notice).ExecuteCommand(); |
| | | |
| | | //查找到该车间半成品区 |
| | | List<string> areaNoList3 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "2" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | loction = storageLocat.Where(w => w.WareHouseNo == houseNo && areaNoList3.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间半成品区暂无空余储位"); |
| | | } |
| | | |
| | | taskMsg = "接料设备(混料桶)申请储位任务"; |
| | | break; |
| | | case "2"://下料设备申请储位(脏桶申请储位) |
| | | //查找到该车间脏桶区 |
| | | List<string> areaNoList4 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "3" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList(); |
| | | loction = storageLocat.Where(w => w.WareHouseNo == houseNo && areaNoList4.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间脏桶区暂无空余储位"); |
| | | } |
| | | |
| | | taskMsg = "下料设备(脏桶)申请储位任务"; |
| | | break; |
| | | } |
| | | |
| | | taskNo = new Common().GetMaxNo("TK");//任务号 |
| | | //任务信息 |
| | | var logTaskEntry = new LogTask |
| | | { |
| | | TaskNo = taskNo, |
| | | Sender = "WMS", |
| | | Receiver = "RCS", |
| | | //IsSuccess = 1, //是否下发成功 0失败 1成功 |
| | | SendDate = DateTime.Now, //发送时间 |
| | | //BackDate = DateTime.Now, //返回时间 |
| | | StartLocat = model.Location,//起始位置 |
| | | EndLocat = loction.LocatNo,//目标位置 |
| | | PalletNo = model.PalletNo,//桶号 |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = "0",//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | OrderType = "3",//单据类型 0 入库 1 出库 3 移库 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | NoticeDetailNo = int.Parse(noticeno), |
| | | Msg = taskMsg, //关键信息 |
| | | }; |
| | | var task = new TaskDetial |
| | | { |
| | | Taskno = taskNo,//任务号 |
| | | Startport = model.Location, |
| | | Endport = loction.LocatNo, |
| | | Pallno = model.PalletNo, |
| | | Crtype = "0",//入库 |
| | | }; |
| | | //给下车下发任务 |
| | | logTaskEntry.SendDate = DateTime.Now;//发送时间 |
| | | var agvResult = CreateTaskForAgv(task, url); |
| | | if (agvResult)//成功 |
| | | { |
| | | //请求成功修改任务表相应字段状态 |
| | | logTaskEntry.IsSuccess = 1; |
| | | logTaskEntry.IsSend = 0; |
| | | //logTaskEntry.IsCancel = 0; |
| | | logTaskEntry.BackDate = DateTime.Now; |
| | | logTaskEntry.Status = "1";//正在执行 |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | |
| | | deviceLocatInfo.Status = "3";//出库中 |
| | | Db.Updateable(deviceLocatInfo).ExecuteCommand(); |
| | | |
| | | loction.Status = "2";//入库中 |
| | | Db.Updateable(loction).ExecuteCommand(); |
| | | } |
| | | else//失败 |
| | | { |
| | | logTaskEntry.IsSuccess = 0; |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | } |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //回滚事务 |
| | | Db.RollbackTran(); |
| | | throw new Exception(ex.Message); |
| | | } |
| | | } |
| | | |
| | | |
| | | /// <summary> |
| | | /// MES下发将净桶改为脏桶并拉到脏桶区 |
| | |
| | | Startport = detail.LocatNo, |
| | | Endport = endLocat.LocatNo, |
| | | Pallno = PalletNo, |
| | | Type = "3", |
| | | Crtype = "2", |
| | | Noticedetailno = 0, |
| | | }; |
| | | CreateLotTask(ztask,url); |
| | | string taskNo = ""; |
| | | CreateTaskForAgv(ztask, url); |
| | | |
| | | statrtLocat.Status = "3";//出库中 |
| | | //修改起始储位状态 |
| | |
| | | Startport = detail.LocatNo, |
| | | Endport = pallnetmsg.Location, |
| | | Pallno = detail.PalletNo, |
| | | Type = "3", |
| | | Crtype = "1", |
| | | Noticedetailno = 0, |
| | | LotNo = "", |
| | | }; |
| | | CreateLotTask(task,url); |
| | | string taskNo = ""; |
| | | CreateTaskForAgv(task,url); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 申请储位 |
| | | /// 任务完成 |
| | | /// </summary> |
| | | /// <param name="PalletNo"></param> |
| | | /// <returns></returns> |
| | | public void ApplyLocatNo(Pallnetmsg model,string url) |
| | | /// <param name="TaskNo"></param> |
| | | /// <param name="Status"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void RCSFinishTask(string taskNo, string status, string comeFrom, int userId = 0) |
| | | { |
| | | var sql = $"select LocatNo from SysStorageLocat where status = '0'"; |
| | | var sql2 = ""; |
| | | var houseNo = "";//申请储位设备所在车间编号 |
| | | var noticeno = "0";//出入库单据明细ID |
| | | SysStorageLocat loction = new SysStorageLocat();//目标储位信息 |
| | | BllArrivalNoticeDetail noticeDetail = new BllArrivalNoticeDetail();//入库单明细 |
| | | try |
| | | { |
| | | //设备所在储位信息 |
| | | var deviceLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == model.LotNo); |
| | | if (deviceLocatInfo == null) |
| | | #region 条件判断 |
| | | var resultModel = new ErpModel() { Success = -1, Message = "" }; |
| | | if (string.IsNullOrEmpty(taskNo)) |
| | | { |
| | | throw new Exception($"未查询到该设备所在储位信息,Location:{model.Location}"); |
| | | throw new Exception("任务号不可为空"); |
| | | } |
| | | houseNo = deviceLocatInfo.WareHouseNo;//设备所属车间 |
| | | switch (model.Type) |
| | | //任务信息 |
| | | var taskInfo = Db.Queryable<LogTask>().First(w => w.TaskNo == taskNo); |
| | | if (taskInfo == null) |
| | | { |
| | | case "3"://清洗设备申请储位(净桶申请储位) |
| | | sql += $" and (AreaNo like '%01' or AreaNo like '%11' or AreaNo like '%21' or AreaNo like '%31') and WareHouseNo = '{houseNo}'"; |
| | | loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间净桶区暂无空余储位"); |
| | | } |
| | | break; |
| | | case "0"://接料设备申请储位(混料桶申请储位) |
| | | //判断是否有批次号 |
| | | if (string.IsNullOrWhiteSpace(model.LotNo)) |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | //校验此批次是否有入库单 |
| | | /*sql2 = $"select * from BllArrivalNoticeDetail where LotNo = '{pallnetmsg.LotNo}' order by CreateTime desc"; |
| | | noticeDetail = Db.Ado.SqlQuery<BllArrivalNoticeDetail>(sql).FirstOrDefault(); |
| | | if (noticeDetail == null) |
| | | { |
| | | throw new Exception("该批次没有对应的入库单"); |
| | | } |
| | | noticeno = noticeDetail.Id.ToString();*/ |
| | | sql += $" and (AreaNo like '%02' or AreaNo like '%12' or AreaNo like '%22' or AreaNo like '%32') and WareHouseNo = '{houseNo}'"; |
| | | loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间预混区暂无空余储位"); |
| | | } |
| | | break; |
| | | case "1"://混料设备申请储位(半成品桶申请储位) |
| | | //判断是否有批次号 |
| | | if (string.IsNullOrWhiteSpace(model.LotNo)) |
| | | { |
| | | throw new Exception("批次号为空!"); |
| | | } |
| | | //校验此批次是否有入库单 |
| | | sql2 = $"select * from BllArrivalNoticeDetail where LotNo = '{model.LotNo}' order by CreateTime desc"; |
| | | noticeDetail = Db.Ado.SqlQuery<BllArrivalNoticeDetail>(sql2).FirstOrDefault(); |
| | | if (noticeDetail == null) |
| | | { |
| | | throw new Exception("该批次没有对应的入库单"); |
| | | } |
| | | noticeno = noticeDetail.Id.ToString(); |
| | | sql += $" and (AreaNo like '%03' or AreaNo like '%13' or AreaNo like '%23' or AreaNo like '%33') and WareHouseNo = '{houseNo}'"; |
| | | loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间半成品区暂无空余储位"); |
| | | } |
| | | break; |
| | | case "2"://下料设备申请储位(脏桶申请储位) |
| | | sql += $" and (AreaNo like '%04' or AreaNo like '%14' or AreaNo like '%24' or AreaNo like '%34') and WareHouseNo = '{houseNo}'"; |
| | | loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); |
| | | if (loction == null) |
| | | { |
| | | throw new Exception("该车间脏桶区暂无空余储位"); |
| | | } |
| | | break; |
| | | throw new Exception($"任务号为:{taskNo}的任务不存在!"); |
| | | } |
| | | var task = new TaskDetial |
| | | if (taskInfo.Status != "1" && comeFrom != "WMS") |
| | | { |
| | | Startport = model.Location, |
| | | Endport = loction.LocatNo, |
| | | Pallno = model.PalletNo, |
| | | Type = model.Type, |
| | | Crtype = "0", |
| | | Noticedetailno = int.Parse(noticeno), |
| | | LotNo = model.LotNo, |
| | | }; |
| | | CreateLotTask(task,url); |
| | | throw new Exception($"任务号为:{taskNo}的任务状态异常"); |
| | | } |
| | | #endregion |
| | | //开启事务 |
| | | Db.BeginTran(); |
| | | var comTime = DateTime.Now; |
| | | |
| | | if (status == "0") |
| | | { |
| | | taskInfo.Status = "3";//异常结束 |
| | | //修改任务状态 |
| | | Db.Updateable(taskInfo).ExecuteCommand(); |
| | | |
| | | resultModel.Success = 0; |
| | | resultModel.Message = "成功"; |
| | | |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | |
| | | return; |
| | | } |
| | | //库存明细 |
| | | var stockDetail = Db.Queryable<DataStockDetail>().First(w => w.PalletNo == taskInfo.PalletNo); |
| | | if (stockDetail == null) |
| | | { |
| | | throw new Exception($"桶库存信息不存在"); |
| | | } |
| | | //起始储位信息 |
| | | var startLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.LocatNo == taskInfo.StartLocat && w.IsDel == "0"); |
| | | if (startLocatInfo == null) |
| | | { |
| | | throw new Exception($"起始储位信息不存在"); |
| | | } |
| | | startLocatInfo.Status = "0";//空储位 |
| | | //修改起始储位状态 |
| | | Db.Updateable(startLocatInfo).ExecuteCommand(); |
| | | |
| | | //目标储位信息 |
| | | var endLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.LocatNo == taskInfo.EndLocat && w.IsDel == "0"); |
| | | if (endLocatInfo == null) |
| | | { |
| | | throw new Exception($"目标储位信息不存在"); |
| | | } |
| | | endLocatInfo.Status = "1";//有物品 |
| | | //修改目标储位状态 |
| | | Db.Updateable(endLocatInfo).ExecuteCommand(); |
| | | |
| | | //目标储位所属区域 |
| | | var endAreaInfo = Db.Queryable<SysStorageArea>().First(w => w.IsDel == "0" && w.WareHouseNo == endLocatInfo.WareHouseNo && w.AreaNo == endLocatInfo.AreaNo); |
| | | if (endAreaInfo == null) |
| | | { |
| | | throw new Exception($"目标储位所属区域信息不存在"); |
| | | } |
| | | |
| | | stockDetail.WareHouseNo = endLocatInfo.WareHouseNo;//所属仓库 |
| | | stockDetail.RoadwayNo = endLocatInfo.RoadwayNo;//所属巷道 |
| | | stockDetail.AreaNo = endLocatInfo.AreaNo;//所属区域 |
| | | stockDetail.LocatNo = endLocatInfo.LocatNo;//储位地址 |
| | | if (endAreaInfo.Type == "0")//洁净区 |
| | | { |
| | | stockDetail.PalletStatus = "0"; |
| | | stockDetail.Status = "0";//待分配 |
| | | } |
| | | else if (endAreaInfo.Type == "1")//预混区 |
| | | { |
| | | stockDetail.PalletStatus = "1"; |
| | | stockDetail.Status = "0";//待分配 |
| | | } |
| | | else if (endAreaInfo.Type == "2")//半成品区 |
| | | { |
| | | stockDetail.PalletStatus = "2"; |
| | | stockDetail.Status = "0";//待分配 |
| | | } |
| | | else if (endAreaInfo.Type == "3")//脏桶区 |
| | | { |
| | | stockDetail.PalletStatus = "3"; |
| | | stockDetail.LotNo = "";//批次 |
| | | stockDetail.SkuNo = ""; |
| | | stockDetail.SkuName = ""; |
| | | stockDetail.Status = "0";//待分配 |
| | | stockDetail.InspectStatus = "0";//待检验 |
| | | } |
| | | //修改库存明细 |
| | | Db.Updateable(stockDetail).ExecuteCommand(); |
| | | //入库任务,处理入库单 |
| | | if (taskInfo.Type == "0" && taskInfo.NoticeDetailNo != 0) |
| | | { |
| | | var notice = Db.Queryable<BllArrivalNotice>().First(w => w.IsDel == "0" && w.Status == "1"); |
| | | if (notice != null) |
| | | { |
| | | notice.Status = "2";//执行完成 |
| | | notice.UpdateTime = DateTime.Now; |
| | | notice.CompleteTime = DateTime.Now; |
| | | //修改入库单状态 |
| | | Db.Updateable(notice).ExecuteCommand(); |
| | | } |
| | | } |
| | | //出库任务,处理出库单 |
| | | if (taskInfo.Type == "1" && taskInfo.NoticeDetailNo != 0)//入库 |
| | | { |
| | | var notice = Db.Queryable<BllExportNotice>().First(w => w.IsDel == "0" && w.Status == "3"); |
| | | if (notice != null) |
| | | { |
| | | notice.Status = "4";//执行完成 |
| | | notice.UpdateTime = DateTime.Now; |
| | | notice.CompleteTime = DateTime.Now; |
| | | //修改入库单状态 |
| | | Db.Updateable(notice).ExecuteCommand(); |
| | | } |
| | | } |
| | | |
| | | #region 去掉MES |
| | | //回传桶状态给MES |
| | | //BackPalletStatus(taskInfo.PalletNo, sd3.PalletStatus); |
| | | #endregion |
| | | |
| | | taskInfo.Status = "2";//执行完成 |
| | | taskInfo.IsSend = 0; |
| | | taskInfo.IsCancel = 0; |
| | | taskInfo.IsFinish = 0; |
| | | taskInfo.FinishDate = DateTime.Now;//完成时间 |
| | | //修改任务状态 |
| | | Db.Updateable(taskInfo).ExecuteCommand(); |
| | | |
| | | if (comeFrom == "WMS") |
| | | { |
| | | //添加操作日志记录 |
| | | var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskInfo.TaskNo, "完成", $"点击完成按钮、任务号为:{taskInfo.TaskNo}的任务", userId); |
| | | } |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | //回滚事务 |
| | | Db.RollbackTran(); |
| | | throw new Exception(ex.Message); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 手动取消任务 |
| | | /// </summary> |
| | | /// <param name="taskNo"></param> |
| | | /// <param name="userId"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void CancelTask(string taskNo, int userId) |
| | | { |
| | | try |
| | | { |
| | | //开启事务 |
| | | Db.BeginTran(); |
| | | //任务信息 |
| | | var task = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0"); |
| | | if (task == null) |
| | | { |
| | | throw new Exception("未查询到任务信息"); |
| | | } |
| | | //if (task.Status != "0") |
| | | //{ |
| | | // throw new Exception("只有等待执行的任务才可取消"); |
| | | //} |
| | | //修改任务 |
| | | task.IsSuccess = 0; |
| | | task.IsSend = 0; |
| | | task.IsCancel = 0; |
| | | task.IsFinish = 0; |
| | | task.Status = "4";//已取消 |
| | | task.CancelDate = DateTime.Now; |
| | | Db.Updateable(task).ExecuteCommand(); |
| | | |
| | | //修改起始储位信息 |
| | | var locat = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.LocatNo == task.StartLocat); |
| | | if (locat == null) |
| | | { |
| | | throw new Exception("未查询到起始位置储位信息,请核实!"); |
| | | } |
| | | locat.Status = "1"; //有物品 |
| | | Db.Updateable(locat).ExecuteCommand(); |
| | | |
| | | //修改目标储位信息 |
| | | var locatEnd = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.LocatNo == task.EndLocat); |
| | | if (locatEnd == null) |
| | | { |
| | | throw new Exception("未查询到目标位置储位信息,请核实!"); |
| | | } |
| | | locatEnd.Status = "0"; //空储位 |
| | | Db.Updateable(locatEnd).ExecuteCommand(); |
| | | |
| | | if (task.Type == "1")//出库任务 |
| | | { |
| | | //修改库存明细 |
| | | var stockDetail = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == task.PalletNo && w.Status == "2"); |
| | | if (stockDetail == null) |
| | | { |
| | | throw new Exception("未查询到该桶库存信息,请检查!"); |
| | | } |
| | | stockDetail.Status = "0";//待分配 |
| | | Db.Updateable(stockDetail).ExecuteCommand(); |
| | | } |
| | | //添加操作日志记录 |
| | | var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "取消", $"点击取消按钮、取消了任务号为:{taskNo}的任务", userId); |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | Db.RollbackTran(); |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// 手动下发任务 |
| | | /// </summary> |
| | | /// <param name="taskNo"></param> |
| | | /// <param name="userId"></param> |
| | | /// <exception cref="Exception"></exception> |
| | | public void DownTask(string taskNo, int userId,string url) |
| | | { |
| | | try |
| | | { |
| | | //开启事务 |
| | | Db.BeginTran(); |
| | | //任务信息 |
| | | var logTaskEntry = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0"); |
| | | if (logTaskEntry == null) |
| | | { |
| | | throw new Exception("未查询到任务信息"); |
| | | } |
| | | if (logTaskEntry.Status != "0") |
| | | { |
| | | throw new Exception("只有等待执行的任务才可手动下发"); |
| | | } |
| | | //查找该桶有没有正在执行的任务 |
| | | var tasking = Db.Queryable<LogTask>().First(w => w.IsDel == "0" && w.Status == "1" && w.PalletNo == logTaskEntry.PalletNo); |
| | | if (tasking != null) |
| | | { |
| | | throw new Exception($"该桶有正在执行的任务"); |
| | | } |
| | | //起始储位信息 |
| | | var startLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == logTaskEntry.StartLocat); |
| | | if (startLocatInfo == null) |
| | | { |
| | | throw new Exception($"未查询到起始储位信息"); |
| | | } |
| | | if (startLocatInfo.Status != "1") |
| | | { |
| | | throw new Exception($"起始储位状态异常"); |
| | | } |
| | | //目标储位信息 |
| | | var endLocatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == logTaskEntry.EndLocat); |
| | | if (endLocatInfo == null) |
| | | { |
| | | throw new Exception($"未查询到目标储位信息"); |
| | | } |
| | | if (endLocatInfo.Status != "0") |
| | | { |
| | | throw new Exception($"目标储位状态异常"); |
| | | } |
| | | //组织给小车下发任务信息 |
| | | var task = new TaskDetial |
| | | { |
| | | Taskno = taskNo,//任务号 |
| | | Startport = logTaskEntry.StartLocat, |
| | | Endport = logTaskEntry.EndLocat, |
| | | Pallno = logTaskEntry.PalletNo, |
| | | Crtype = logTaskEntry.Type, |
| | | }; |
| | | //给下车下发任务 |
| | | logTaskEntry.SendDate = DateTime.Now;//发送时间 |
| | | var agvResult = CreateTaskForAgv(task, url); |
| | | if (agvResult)//成功 |
| | | { |
| | | //请求成功修改任务表相应字段状态 |
| | | logTaskEntry.IsSuccess = 1; |
| | | logTaskEntry.IsSend = 0; |
| | | logTaskEntry.IsCancel = 0; |
| | | logTaskEntry.BackDate = DateTime.Now; |
| | | logTaskEntry.Status = "1";//正在执行 |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | |
| | | startLocatInfo.Status = "3";//出库中 |
| | | Db.Updateable(startLocatInfo).ExecuteCommand(); |
| | | |
| | | endLocatInfo.Status = "2";//入库中 |
| | | Db.Updateable(endLocatInfo).ExecuteCommand(); |
| | | } |
| | | else//失败 |
| | | { |
| | | logTaskEntry.IsSuccess = 0; |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | } |
| | | |
| | | //添加操作日志记录 |
| | | var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "下发", $"点击下发按钮、任务号为:{taskNo}的任务", userId); |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | Db.RollbackTran(); |
| | | throw new Exception(e.Message); |
| | | } |
| | | } |
| | | |
| | |
| | | /// </summary> |
| | | /// <param name="req"></param> |
| | | /// <returns></returns> |
| | | public void CreateLotTask(TaskDetial taskDetial,string url) |
| | | public bool CreateTaskForAgv(TaskDetial taskDetial, string url) |
| | | { |
| | | try |
| | | bool result = false; |
| | | |
| | | #region 呼叫小车代码 |
| | | List<AgvSchedulingTask> agvTaskList = new List<AgvSchedulingTask>(); |
| | | |
| | | List<PositionCodePath> pahtList = new List<PositionCodePath>(); |
| | | //起始位置 |
| | | PositionCodePath path1 = new PositionCodePath(); |
| | | path1.positionCode = taskDetial.Startport; |
| | | if (taskDetial.Crtype == "1")//叫桶(桶出库) |
| | | { |
| | | //开启事务 |
| | | Db.BeginTran(); |
| | | var typeDesc = ""; |
| | | switch (taskDetial.Crtype) |
| | | { |
| | | case "0": |
| | | typeDesc = "入库"; |
| | | break; |
| | | case "1": |
| | | typeDesc = "出库"; |
| | | break; |
| | | case "2": |
| | | typeDesc = "移库"; |
| | | break; |
| | | } |
| | | var msg = ""; |
| | | switch (taskDetial.Type) |
| | | { |
| | | case "0": |
| | | msg = "净桶"+ typeDesc + "任务"; |
| | | break; |
| | | case "1": |
| | | msg = "预混料桶" + typeDesc + "任务"; |
| | | break; |
| | | case "2": |
| | | msg = "半成品料桶" + typeDesc + "任务"; |
| | | break; |
| | | case "3": |
| | | msg = "脏桶" + typeDesc + "任务"; |
| | | break; |
| | | } |
| | | var sql = ""; |
| | | var sql2 = ""; |
| | | var ordertype = "3"; |
| | | //涉及出入库单据的状态信息改变 |
| | | if (taskDetial.Type == "2" && taskDetial.Crtype =="1")//半成品出库 |
| | | { |
| | | ordertype = "1"; |
| | | sql = $"UPDATE BllExportNotice SET Status ='1' " + |
| | | $"where SoNO = (select SoNO from BllExportNoticeDetail where id = {taskDetial.Noticedetailno})"; |
| | | Db.Ado.ExecuteCommand(sql); |
| | | } |
| | | else if(taskDetial.Type =="2" && taskDetial.Crtype == "0")//半成品入库 |
| | | { |
| | | ordertype = "0"; |
| | | var ArrivalMsg = Db.Queryable<BllArrivalNoticeDetail>().First(it => it.Id == taskDetial.Noticedetailno); |
| | | //修改入库单总表中单据状态为正在执行 |
| | | sql = $"UPDATE BllArrivalNotice SET Status ='1' where asnno = '{ArrivalMsg.ASNNo}'"; |
| | | Db.Ado.ExecuteCommand(sql); |
| | | //库存中添加此托盘物料编码和编码名称 |
| | | sql2 = $"UPDATE DataStockDetail SET SkuNo = '{ArrivalMsg.SkuNo}',SkuName = '{ArrivalMsg.SkuName}' " + |
| | | $"where PalletNo = '{taskDetial.Pallno}'and LotNo = '{taskDetial.LotNo}'"; |
| | | Db.Ado.ExecuteCommand(sql2); |
| | | } |
| | | else if (taskDetial.Type == "1" && taskDetial.Crtype == "0")//预混桶入库 |
| | | { |
| | | //预混桶入库时添加到库存中此托盘的批次信息 |
| | | sql2 = $"UPDATE DataStockDetail SET LotNo = '{taskDetial.LotNo}' where PalletNo = '{taskDetial.Pallno}'"; |
| | | Db.Ado.ExecuteCommand(sql2); |
| | | } |
| | | |
| | | //判断任务是否为新任务 |
| | | if (string.IsNullOrWhiteSpace(taskDetial.Taskno)) |
| | | { |
| | | taskDetial.Taskno = new Common().GetMaxNo("TK"); |
| | | } |
| | | var logTaskEntry = new LogTask |
| | | { |
| | | TaskNo = taskDetial.Taskno, |
| | | Sender = "WMS", |
| | | Receiver = "RCS", |
| | | //IsSuccess = 1, //是否下发成功 0失败 1成功 |
| | | SendDate = DateTime.Now, //发送时间 |
| | | //BackDate = DateTime.Now, //返回时间 |
| | | StartLocat = taskDetial.Startport,//起始位置 |
| | | EndLocat = taskDetial.Endport,//目标位置 |
| | | PalletNo = taskDetial.Pallno,//托盘码 |
| | | IsSend = 1,//是否可再次下发 |
| | | IsCancel = 1,//是否可取消 |
| | | IsFinish = 1,//是否可完成 |
| | | Type = taskDetial.Crtype,//任务类型 0 入库任务 1 出库任务 2 移库任务 |
| | | OrderType = ordertype,//单据类型 0 入库 1 出库 3其他 |
| | | Status = "0",//任务状态0:等待执行1正在执行2执行完成 |
| | | NoticeDetailNo = int.Parse(taskDetial.Noticedetailno.ToString()), |
| | | Msg = msg, //关键信息 |
| | | }; |
| | | |
| | | #region 呼叫小车代码 |
| | | List<AgvSchedulingTask> agvTaskList = new List<AgvSchedulingTask>(); |
| | | |
| | | List<PositionCodePath> pahtList = new List<PositionCodePath>(); |
| | | //起始位置 |
| | | PositionCodePath path1 = new PositionCodePath(); |
| | | path1.positionCode = taskDetial.Startport; |
| | | path1.type = "05"; |
| | | |
| | | pahtList.Add(path1); |
| | | |
| | | //目标位置 |
| | | PositionCodePath path2 = new PositionCodePath(); |
| | | path2.positionCode = taskDetial.Endport; |
| | | path2.type = "00"; |
| | | |
| | | pahtList.Add(path2); |
| | | //下车任务单 |
| | | AgvSchedulingTask agvTask = new AgvSchedulingTask(); |
| | | agvTask.reqCode = logTaskEntry.TaskNo;//任务号 |
| | | agvTask.ctnrTyp = "3"; |
| | | agvTask.reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");//请求时间 |
| | | agvTask.taskTyp = "Z2";//任务类型 线边到托盘收集器 Z1, 托盘垛申请入库 Z2 |
| | | agvTask.wbCode = ""; |
| | | agvTask.positionCodePath = pahtList;//小车路径 |
| | | agvTask.podCode = ""; |
| | | agvTask.userCallCode = taskDetial.Endport;//目标位置 |
| | | |
| | | agvTaskList.Add(agvTask); |
| | | |
| | | // 正式运行程序放开 |
| | | string str = ""; |
| | | var list2 = agvTaskList.Select(m => m.reqCode).ToList(); |
| | | var jsonData = JsonConvert.SerializeObject(agvTaskList); |
| | | jsonData = jsonData.Substring(1); |
| | | jsonData = jsonData.Substring(0, jsonData.Length - 1); |
| | | string response = ""; |
| | | |
| | | try |
| | | { |
| | | logTaskEntry.SendDate = DateTime.Now;//发送时间 |
| | | |
| | | response = HttpHelper.DoPost(url, jsonData, "下发给AGV转运命令", "AGV"); |
| | | //解析返回数据 |
| | | var agvModel = JsonConvert.DeserializeObject<OutCommanAgvDto>(response); |
| | | if (agvModel.Code == "0") |
| | | { |
| | | str += "下发成功"; |
| | | |
| | | //请求成功修改任务表相应字段状态 |
| | | logTaskEntry.IsSuccess = 1; |
| | | logTaskEntry.BackDate = DateTime.Now; |
| | | logTaskEntry.Status = "1"; |
| | | if (taskDetial.Crtype == "0" || taskDetial.Crtype == "2") |
| | | { |
| | | sql = $"UPDATE SysStorageLocat SET Status = '2' where LocatNo = '{taskDetial.Endport}'"; |
| | | if (taskDetial.Type == "2") |
| | | { |
| | | sql2 = $"UPDATE DataStockDetail SET PalletStatus = '{taskDetial.Type}'" + |
| | | $"where PalletNo = '{taskDetial.Pallno}'"; |
| | | Db.Ado.ExecuteCommand(sql2); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | sql = $"UPDATE SysStorageLocat SET Status = '3' where LocatNo = '{taskDetial.Startport}' "; |
| | | } |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | Db.Ado.ExecuteCommand(sql); |
| | | } |
| | | if (agvModel.Code == "1") |
| | | { |
| | | logTaskEntry.IsSuccess = 0; |
| | | Db.Insertable(logTaskEntry).ExecuteCommand(); |
| | | Db.CommitTran(); |
| | | throw new Exception("RCS任务下发错误,RCS返回消息:" + agvModel.Message); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | throw new Exception(ex.Message); |
| | | } |
| | | #endregion |
| | | //提交事务 |
| | | Db.CommitTran(); |
| | | } |
| | | catch (Exception ex) |
| | | else//申请储位(桶入库) |
| | | { |
| | | Db.RollbackTran(); |
| | | throw ex; |
| | | path1.type = "05"; |
| | | } |
| | | pahtList.Add(path1); |
| | | |
| | | //目标位置 |
| | | PositionCodePath path2 = new PositionCodePath(); |
| | | path2.positionCode = taskDetial.Endport; |
| | | if (taskDetial.Crtype == "1")//叫桶(桶出库) |
| | | { |
| | | path2.type = "05"; |
| | | } |
| | | else//申请储位(桶入库) |
| | | { |
| | | path2.type = "05"; |
| | | } |
| | | pahtList.Add(path2); |
| | | |
| | | //下车任务单 |
| | | AgvSchedulingTask agvTask = new AgvSchedulingTask(); |
| | | agvTask.reqCode = taskDetial.Taskno;//请求编号 |
| | | agvTask.taskCode = taskDetial.Taskno;//任务号 |
| | | agvTask.ctnrCode = taskDetial.Pallno;//桶号 |
| | | agvTask.ctnrTyp = "1"; |
| | | agvTask.reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");//请求时间 |
| | | agvTask.wbCode = ""; |
| | | agvTask.positionCodePath = pahtList;//小车路径 |
| | | agvTask.podCode = ""; |
| | | agvTask.userCallCode = "";//taskDetial.Endport;//目标位置 |
| | | if (taskDetial.Crtype == "1")//叫桶(桶出库) |
| | | { |
| | | agvTask.taskTyp = "Z3";//任务类型 线边到托盘收集器 Z1, 托盘垛申请入库 Z2 |
| | | } |
| | | else//申请储位(桶入库) |
| | | { |
| | | agvTask.taskTyp = "Z4";//任务类型 线边到托盘收集器 Z1, 托盘垛申请入库 Z2 |
| | | } |
| | | agvTaskList.Add(agvTask); |
| | | |
| | | // 正式运行程序放开 |
| | | var list2 = agvTaskList.Select(m => m.reqCode).ToList(); |
| | | var jsonData = JsonConvert.SerializeObject(agvTaskList); |
| | | jsonData = jsonData.Substring(1); |
| | | jsonData = jsonData.Substring(0, jsonData.Length - 1); |
| | | |
| | | string response = HttpHelper.DoPost(url, jsonData, "下发给AGV转运命令", "AGV"); |
| | | //解析返回数据 |
| | | var agvModel = JsonConvert.DeserializeObject<OutCommanAgvDto>(response); |
| | | if (agvModel.Code == "0") |
| | | { |
| | | result = true;//给下车下发任务成功 |
| | | } |
| | | else |
| | | { |
| | | string logMsg = ""; |
| | | if (taskDetial.Crtype == "1")//叫桶(桶出库) |
| | | { |
| | | logMsg = "申请叫桶"; |
| | | } |
| | | else if (taskDetial.Crtype == "0")//申请储位(桶入库) |
| | | { |
| | | logMsg = "申请储位"; |
| | | } |
| | | var logStr = $@".\log\AGV\AGV{logMsg}" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; |
| | | LogFile.SaveLogToFile($"AGV{logMsg}异常:( {agvModel.Message} ),", logStr); |
| | | } |
| | | return result; |
| | | #endregion |
| | | } |
| | | } |
| | | } |