From ea4fe1a6d1decf926292d3d71e7656bbcff4c937 Mon Sep 17 00:00:00 2001 From: Administrator <Administrator@DESKTOP-5BIMHQ3> Date: 星期三, 03 七月 2024 16:58:52 +0800 Subject: [PATCH] 修改问题 --- Wms/WMS.BLL/BllTransServer/RcsServer.cs | 348 +++++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 235 insertions(+), 113 deletions(-) diff --git a/Wms/WMS.BLL/BllTransServer/RcsServer.cs b/Wms/WMS.BLL/BllTransServer/RcsServer.cs index f6e21d9..eff7a95 100644 --- a/Wms/WMS.BLL/BllTransServer/RcsServer.cs +++ b/Wms/WMS.BLL/BllTransServer/RcsServer.cs @@ -1,5 +1,4 @@ -锘縰sing Microsoft.IdentityModel.Protocols; -using Newtonsoft.Json; +锘縰sing Newtonsoft.Json; using SqlSugar; using System; using System.Collections.Generic; @@ -30,7 +29,6 @@ public void GetPalletNo(Pallnetmsg pallnetmsg) { DataStockDetail pallet = new DataStockDetail(); - SysStorageLocat locat = new SysStorageLocat(); try { var house = "W01";//鍙《浣嶇疆锛屽悗缁牴鎹綅缃叧鑱旀垨瀹氫箟锛屾潵鍒ゆ柇鍙《浣嶇疆鎵�灞炶溅闂� @@ -40,47 +38,86 @@ switch (pallnetmsg.Type) { case "0"://鍙噣妗� - List<DataStockDetail> jtpallet = new List<DataStockDetail>(); - sql += $"and WareHouseNo = '{house}' and AreaNo like '%01' order by CreateTime desc"; - jtpallet = Db.Ado.SqlQuery<DataStockDetail>(sql).ToList(); - if (jtpallet.Count == 0) + sql += $"and WareHouseNo = '{house}' and AreaNo like '%01' and PalletStatus = '0' order by CreateTime desc"; + pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); + if (pallet == null) { throw new Exception("鏆傛棤鍑�妗跺彲鍒嗛厤"); } - //閬嶅巻搴撳瓨鍑�妗讹紝杩斿洖MES楠岃瘉 - foreach (var item in jtpallet) + + break; + case "1"://鍙枡妗讹紙娣锋枡锛� + //鍒ゆ柇鏄惁鏈夋壒娆″彿 + if (string.IsNullOrWhiteSpace(pallnetmsg.LotNo)) + { + 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();*/ + //鏌ユ壘搴撳瓨涓槸鍚︽湁鍙敤鐨勬鎵规鐨勬贩鏂欐《 + sql= $@"select PalletNo,LocatNo from DataStockDetail where LotNo = '{pallnetmsg.LotNo}'and AreaNo like '%02' + and WareHouseNo = '{house}' and status = '0' and PalletStatus = '1' order by CompleteTime desc"; + pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); + if (pallet == null) + { + throw new Exception("鏆傛棤娣锋枡妗跺彲鍒嗛厤"); + } + + break; + case "2"://鍙枡妗讹紙涓嬫枡锛� + BllExportNoticeDetail bllSo = new BllExportNoticeDetail(); + //鍒ゆ柇鏄惁鏈夋壒娆″彿 + if (string.IsNullOrWhiteSpace(pallnetmsg.LotNo)) + { + throw new Exception("鎵规鍙蜂负绌猴紒"); + } + //鏌ユ壘鏄惁鏈夋鎵规鍑哄簱鍗� + sql = $"select * from BllExportNoticeDetail where LotNo = '{pallnetmsg.LotNo}' order by CreateTime desc"; + bllSo = Db.Ado.SqlQuery<BllExportNoticeDetail>(sql).FirstOrDefault(); + if (bllSo == null) + { + throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍑哄簱鍗�"); + } + noticeno = bllSo.Id.ToString(); + //鏌ユ壘搴撳瓨涓槸鍚︽湁姝ゆ壒娆$殑涓嬫枡妗� + sql = $@"select PalletNo,LocatNo from DataStockDetail where LotNo = '{pallnetmsg.LotNo}'and AreaNo like '%03' + and WareHouseNo = '{house}' and status = '0' and PalletStatus = '2' order by CompleteTime desc"; + pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); + if (pallet == null) + { + throw new Exception("鏆傛棤涓嬫枡妗跺彲鍒嗛厤"); + } + + break; + case "3"://鍙剰妗� + sql += $"and WareHouseNo = '{house}' and AreaNo like '%04' and PalletStatus='3' order by CreateTime desc"; + List<DataStockDetail> palletList = Db.Ado.SqlQuery<DataStockDetail>(sql).ToList(); + if (palletList.Count <= 0) + { + throw new Exception("鏆傛棤鑴忔《鍙垎閰�"); + } + //閬嶅巻搴撳瓨鑴忔《锛岃繑鍥濵ES楠岃瘉 + foreach (var item in palletList) { string jsonReq = JsonConvert.SerializeObject(item.PalletNo); - var response = HttpHelper.DoPost(url, jsonReq, "鍥炰紶MES鍑�妗剁紪鍙�", "RCS").ToString(); + var response = HttpHelper.DoPost(url, jsonReq, "鍥炰紶MES鑴忔《缂栧彿", "RCS").ToString(); var obj = JsonConvert.DeserializeObject<ReMes>(response);//瑙f瀽杩斿洖鏁版嵁 if (obj.Success == "0") { - if (obj.Result != "0")//鍙敤锛岀敓鎴愬皬杞︽媺鍑�妗朵换鍔� + if (obj.Result != "1")//涓嶅彲娓呮礂锛屽皢鑴忔《鍐荤粨 { - //鏌ユ壘鏄惁鏈夌┖浣欒剰妗朵綅 - sql = $"select LocatNo from SysStorageLocat where AreaNo like '%04' and WareHouseNo = wareno and Status = 0"; - locat = Db.Ado.SqlQuery<SysStorageLocat>(sql).FirstOrDefault(); - if (locat == null) - { - Db.Ado.BeginTran(); - //鑴忔《鍖烘棤绌轰綑搴撲綅锛屽垯閿佸畾姝ゅ噣妗跺簱瀛�,骞堕噸鏂伴亶鍘� - sql = $"UPDATE DataStockDetail Set Status = '5' Where locat ='{locat.LocatNo}'"; - Db.Ado.ExecuteCommand(sql); - Db.Ado.CommitTran(); - break; - } - //鐢熸垚璋冨害灏忚溅鍑�妗跺幓鑴忔《鍖轰换鍔� - var ztask = new TaskDetial - { - Startport = item.LocatNo, - Endport = locat.LocatNo, - Pallno = item.PalletNo, - Type = "4", - Crtype = "0", - Noticedetailno = int.Parse(noticeno), - }; - CreateLotTask(ztask); - return; + item.Status = "5";//寮傚父鍐荤粨 + //淇敼璇ユ《搴撳瓨鐘舵�� + Db.Updateable(item).ExecuteCommand(); + + continue; } //涓嬪彂灏忚溅浠诲姟 var task2 = new TaskDetial @@ -101,75 +138,17 @@ } } break; - case "1"://鍙枡妗讹紙娣锋枡锛� - //鍒ゆ柇鏄惁鏈夋壒娆″彿 - if (string.IsNullOrWhiteSpace(pallnetmsg.LotNo)) - { - 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();*/ - //鏌ユ壘搴撳瓨涓槸鍚︽湁鍙敤鐨勬鎵规鐨勬贩鏂欐《 - sql= $"select PalletNo,LocatNo from DataStockDetail where a.LotNo = '{pallnetmsg.LotNo}'and AreaNo like '%02' " + - $"and a.WareHouseNo = '{house}' and b.status = '0' order by CompleteTime desc"; - pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); - if (pallet == null) - { - throw new Exception("鏆傛棤娣锋枡妗跺彲鍒嗛厤"); - } - - break; - case "2"://鍙枡妗讹紙涓嬫枡锛� - BllExportNoticeDetail bllSo = new BllExportNoticeDetail(); - //鍒ゆ柇鏄惁鏈夋壒娆″彿 - if (string.IsNullOrWhiteSpace(pallnetmsg.LotNo)) - { - throw new Exception("鎵规鍙蜂负绌猴紒"); - } - //鏌ユ壘鏄惁鏈夋鎵规鍑哄簱鍗� - sql = $"select * from BllSoNoticeDetail where LotNo = '{pallnetmsg.LotNo}' order by CreateTime desc"; - bllSo = Db.Ado.SqlQuery<BllExportNoticeDetail>(sql).FirstOrDefault(); - if (bllSo == null) - { - throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍑哄簱鍗�"); - } - noticeno = bllSo.Id.ToString(); - //鏌ユ壘搴撳瓨涓槸鍚︽湁姝ゆ壒娆$殑涓嬫枡妗� - sql += $"select PalletNo,LocatNo from DataStockDetail where a.LotNo = '{pallnetmsg.LotNo}'and AreaNo like '%03' " + - $"and a.WareHouseNo = '{house}' and b.status = '0' order by CompleteTime desc"; - pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); - if (pallet == null) - { - throw new Exception("鏆傛棤涓嬫枡妗跺彲鍒嗛厤"); - } - - break; - case "3"://鍙剰妗� - sql += $"and WareHouseNo = '{house}' and AreaNo like '%04' order by CreateTime desc"; - pallet = Db.Ado.SqlQuery<DataStockDetail>(sql).FirstOrDefault(); - if (pallet == null) - { - throw new Exception("鏆傛棤鑴忔《鍙垎閰�"); - } - - break; } //涓嬪彂灏忚溅浠诲姟 var task = new TaskDetial { Startport = pallet.LocatNo, Endport = pallnetmsg.Location, - Pallno = pallet.PackagNo, + Pallno = pallet.PalletNo, Type = pallnetmsg.Type, Crtype = "1", Noticedetailno = int.Parse(noticeno), + LotNo = pallnetmsg.LotNo, }; CreateLotTask(task); return; @@ -177,6 +156,102 @@ catch (Exception ex) { Db.Ado.RollbackTran(); + throw ex; + } + } + + /// <summary> + /// MES涓嬪彂灏嗗噣妗舵敼涓鸿剰妗跺苟鎷夊埌鑴忔《鍖� + /// </summary> + /// <param name="PalletNo"></param> + /// <returns></returns> + public void ChangePalletStatus(string PalletNo) + { + try + { + var detail = Db.Queryable<DataStockDetail>().First(w => w.PalletNo == PalletNo && w.PalletStatus == "0"); + if (detail == null) + { + throw new Exception($"搴撳瓨涓笉瀛樺湪妗跺彿涓猴細{PalletNo}鐨勫簱瀛�!"); + } + //璧峰鐩爣鍌ㄤ綅淇℃伅 + var statrtLocat = Db.Queryable<SysStorageLocat>().First(w => w.WareHouseNo == detail.WareHouseNo && w.AreaNo == detail.AreaNo && w.LocatNo == detail.LocatNo); + if (statrtLocat == null) + { + throw new Exception($"璇ユ《鎵�鍦ㄧ殑鍌ㄤ綅淇℃伅涓嶅瓨鍦�!"); + } + //寮�鍚簨鍔� + Db.BeginTran(); + + //鏌ユ壘鏄惁鏈夌┖浣欒剰妗朵綅 + var endLocat = Db.Queryable<SysStorageLocat>().First(w => w.WareHouseNo == detail.WareHouseNo && w.AreaNo.Contains("04") && w.Status == "0" && w.Flag=="0"); + if (endLocat == null) + { + detail.Status = "5";//寮傚父閿佸畾 + detail.PalletStatus = "3";//鑴忔《 + //淇敼搴撳瓨鐘舵�� + Db.Updateable(detail).ExecuteCommand(); + } + else + { + //鐢熸垚璋冨害灏忚溅鍑�妗跺幓鑴忔《鍖轰换鍔� + var ztask = new TaskDetial + { + Startport = detail.LocatNo, + Endport = endLocat.LocatNo, + Pallno = PalletNo, + Type = "3", + Crtype = "2", + Noticedetailno = 0, + }; + CreateLotTask(ztask); + + statrtLocat.Status = "3";//鍑哄簱涓� + //淇敼璧峰鍌ㄤ綅鐘舵�� + Db.Updateable(statrtLocat).ExecuteCommand(); + + detail.Status = "5";//寮傚父閿佸畾 + detail.PalletStatus = "3";//鑴忔《 + //淇敼搴撳瓨鐘舵�� + Db.Updateable(detail).ExecuteCommand(); + } + Db.CommitTran(); + } + catch (Exception ex) + { + Db.RollbackTran(); + throw ex; + } + } + + /// <summary> + /// MES涓嬪彂娓呮礂閿佸畾鑴忔《 + /// </summary> + /// <param name="pallnetmsg"></param> + public void CleanPallet(Pallnetmsg pallnetmsg) + { + try + { + var detail = Db.Queryable<DataStockDetail>().First(w => w.PalletNo == pallnetmsg.PalletNo && w.PalletStatus == "3"); + if (detail == null) + { + throw new Exception($"搴撳瓨涓笉瀛樺湪妗跺彿涓猴細{pallnetmsg.PalletNo}鐨勫簱瀛�!"); + } + //涓嬪彂灏忚溅浠诲姟 + var task = new TaskDetial + { + Startport = detail.LocatNo, + Endport = pallnetmsg.Location, + Pallno = detail.PalletNo, + Type = "3", + Crtype = "1", + Noticedetailno = 0, + LotNo = "", + }; + CreateLotTask(task); + } + catch (Exception ex) + { throw ex; } } @@ -191,7 +266,7 @@ var sql = $"select LocatNo from SysStorageLocat where status = '0'"; var sql2 = ""; var house = "W01";//鈥︹�﹀彨妗朵綅缃紝鍚庣画鏍规嵁浣嶇疆鍏宠仈鎴栧畾涔夛紝鏉ュ垽鏂彨妗朵綅缃墍灞炶溅闂� - var noticeno = "";//鍑哄叆搴撳崟鎹槑缁咺D + var noticeno = "0";//鍑哄叆搴撳崟鎹槑缁咺D SysStorageLocat loction = new SysStorageLocat(); BllArrivalNoticeDetail ArriveMes = new BllArrivalNoticeDetail(); try @@ -199,7 +274,7 @@ switch (pallnetmsg.Type) { case "0"://鍑�妗剁敵璇峰偍浣� - sql += $"and AreaNo like '%01' and WareHouseNo = {house}"; + sql += $"and AreaNo like '%01' and WareHouseNo = '{house}'"; loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); if (loction == null) { @@ -220,7 +295,7 @@ throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍏ュ簱鍗�"); } noticeno = ArriveMes.Id.ToString();*/ - sql += $"and AreaNo like '%02' and WareHouseNo = {house}"; + sql += $"and AreaNo like '%02' and WareHouseNo = '{house}'"; loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); if (loction == null) { @@ -235,13 +310,13 @@ } //鏍¢獙姝ゆ壒娆℃槸鍚︽湁鍏ュ簱鍗� sql2 = $"select * from BllArrivalNoticeDetail where LotNo = '{pallnetmsg.LotNo}' order by CreateTime desc"; - ArriveMes = Db.Ado.SqlQuery<BllArrivalNoticeDetail>(sql).FirstOrDefault(); + ArriveMes = Db.Ado.SqlQuery<BllArrivalNoticeDetail>(sql2).FirstOrDefault(); if (ArriveMes == null) { throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍏ュ簱鍗�"); } noticeno = ArriveMes.Id.ToString(); - sql += $"and AreaNo like '%03' and WareHouseNo = {house}"; + sql += $"and AreaNo like '%03' and WareHouseNo = '{house}'"; loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); if (loction == null) { @@ -249,7 +324,7 @@ } break; case "3"://鑴忔《鐢宠鍌ㄤ綅 - sql += $"and AreaNo like '%04' and WareHouseNo = {house}"; + sql += $"and AreaNo like '%04' and WareHouseNo = '{house}'"; loction = Db.Ado.SqlQuery<SysStorageLocat>(sql).OrderByDescending(a => a.CreateTime).FirstOrDefault(); if (loction == null) { @@ -261,10 +336,11 @@ { Startport = pallnetmsg.Location, Endport = loction.LocatNo, - Pallno = pallnetmsg.Palletno, + Pallno = pallnetmsg.PalletNo, Type = pallnetmsg.Type, Crtype = "0", Noticedetailno = int.Parse(noticeno), + LotNo = pallnetmsg.LotNo, }; CreateLotTask(task); } @@ -367,24 +443,65 @@ { try { - var na = taskDetial.Crtype == "0"?"鍏ュ簱":"鍑哄簱"; + //寮�鍚簨鍔� + Db.BeginTran(); + var na = ""; + switch (taskDetial.Crtype) + { + case "0": + na = "鍏ュ簱"; + break; + case "1": + na = "鍑哄簱"; + break; + case "2": + na = "绉诲簱"; + break; + } + var bz = ""; + switch (taskDetial.Type) + { + case "0": + bz = "鍑�妗�"+na+"浠诲姟"; + break; + case "1": + bz = "棰勬贩鏂欐《" + na + "浠诲姟"; + break; + case "2": + bz = "鍗婃垚鍝佹枡妗�" + na + "浠诲姟"; + break; + case "3": + bz = "鑴忔《" + na + "浠诲姟"; + break; + } var sql = ""; var sql2 = ""; var ordertype = "3"; - if (taskDetial.Type == "2" && taskDetial.Crtype =="1") + //娑夊強鍑哄叆搴撳崟鎹殑鐘舵�佷俊鎭敼鍙� + if (taskDetial.Type == "2" && taskDetial.Crtype =="1")//鍗婃垚鍝佸嚭搴� { ordertype = "1"; + sql = $"UPDATE BllExportNotice SET Status ='1' " + + $"where asnno = (select ASNNO from BllExportNoticeDetail where id = {taskDetial.Noticedetailno})"; + Db.Ado.ExecuteCommand(sql); } - else if(taskDetial.Type =="2" && taskDetial.Crtype == "0") + else if(taskDetial.Type =="2" && taskDetial.Crtype == "0")//鍗婃垚鍝佸叆搴� { ordertype = "0"; + var ArrivalMsg = Db.Queryable<BllArrivalNoticeDetail>().First(it => it.Id == taskDetial.Noticedetailno); + //淇敼鍏ュ簱鍗曟�昏〃涓崟鎹姸鎬佷负姝e湪鎵ц + 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); } - //寮�鍚簨鍔� - Db.BeginTran(); + //鍒ゆ柇浠诲姟鏄惁涓烘柊浠诲姟 if (string.IsNullOrWhiteSpace(taskDetial.Taskno)) { - taskDetial.Taskno = new Common().GetMaxNo("T"); + taskDetial.Taskno = new Common().GetMaxNo("TK"); } var logTaskEntry = new LogTask { @@ -404,7 +521,7 @@ OrderType = ordertype,//鍗曟嵁绫诲瀷 0 鍏ュ簱 1 鍑哄簱 3鍏朵粬 Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚 NoticeDetailNo = int.Parse(taskDetial.Noticedetailno.ToString()), - Msg = $"{taskDetial.Endport}鐨剓na}浠诲姟", //鍏抽敭淇℃伅 + Msg = bz, //鍏抽敭淇℃伅 }; var Agv = new AgvTask { @@ -414,6 +531,7 @@ endPos = taskDetial.Endport, agvCode = "1",//鈥︹�﹂渶瑕佸拰AGV纭姝ゅ瓧娈靛�� }; + //璇锋眰灏忚溅 genAgvSchedulingTaskRep chrep =genAgvSchedulingTask(Agv, "url"); if (chrep.code != "0") @@ -423,14 +541,19 @@ Db.CommitTran(); throw new Exception("RCS浠诲姟涓嬪彂閿欒锛孯CS杩斿洖娑堟伅锛�" + chrep.message); } + //璇锋眰鎴愬姛淇敼浠诲姟琛ㄧ浉搴斿瓧娈电姸鎬� logTaskEntry.IsSuccess = 1; logTaskEntry.BackDate = DateTime.Now; logTaskEntry.Status = "1"; - if (taskDetial.Crtype == "0") + if (taskDetial.Crtype == "0" || taskDetial.Crtype == "2") { sql = $"UPDATE SysStorageLocat SET Status = '2' where LocatNo = '{taskDetial.Endport}'"; - sql2 = $"UPDATE DataStockDetail SET PalletStatus = '{taskDetial.Type}' where PalletNo = '{taskDetial.Pallno}'"; - Db.Ado.ExecuteCommand(sql2); + if (taskDetial.Type == "2") + { + sql2 = $"UPDATE DataStockDetail SET PalletStatus = '{taskDetial.Type}',LotNo = '{taskDetial.LotNo}' " + + $"where PalletNo = '{taskDetial.Pallno}'"; + Db.Ado.ExecuteCommand(sql2); + } } else { @@ -446,7 +569,6 @@ Db.RollbackTran(); throw ex; } - } } } -- Gitblit v1.8.0