分支自 SuZhouGuanHong/TaiYuanTaiZhong
´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/Services/system/Partial/dt_stationinfoService.cs
@@ -23,6 +23,12 @@ using WIDESEA_Core.ManageUser; using OfficeOpenXml.FormulaParsing.Excel.Functions.Text; using static System.Collections.Specialized.BitVector32; using WIDESEA_Core.EFDbContext; using WIDESEA_WMS.Repositories; using WIDESEA_Comm; using WIDESEA_Comm.TaskNo; using WIDESEA_Common; using static FreeSql.Internal.GlobalFilter; namespace WIDESEA_WMS.Services { @@ -95,18 +101,172 @@ } return webResponse; } public WebResponseContent SendAGVTask(object json) /// <summary> /// åæ¢æç /// </summary> /// <param name="saveModel"></param> /// <returns></returns> public WebResponseContent Trayswitching(SaveModel saveModel) { WebResponseContent webResponse = new WebResponseContent(); try VOLContext context = new VOLContext(); Idt_agvtaskRepository agvtaskRepository = new dt_agvtaskRepository(context); IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(context); foreach (var Key in saveModel.DelKeys) { try { var station = repository.Find(x => x.id.ToString() == Key.ToString()).FirstOrDefault(); if (!station.stationCode.Contains("X") && !station.stationCode.Contains("W01001004") && !station.stationCode.Contains("W01001005")) throw new Exception($"æ {station.stationCode}使ç¨æéï¼"); if (!station.enable) throw new Exception($"{station.stationCode}æªå¯ç¨ï¼"); if (station.location_state == LocationStateEnum.Abnormal.ToString()) throw new Exception($"{station.stationCode}ç¶æå¼å¸¸ï¼"); if (station.location_state == LocationStateEnum.Empty.ToString()) throw new Exception($"{station.stationCode}ç¶æ为空ï¼"); if (station.remark == "æ¡æ¶ä¸æ") throw new Exception($"{station.stationCode}æ¡æ¶æ£å¨ä¸æï¼"); var task = agvtaskRepository.Find(x => x.agv_toaddress == station.stationCode).FirstOrDefault(); if (task != null) { if (task.agv_taskstate != AGVTaskStateEnum.Queue.ToString()) throw new Exception($"{station.stationCode}åå¨ä»»å¡ï¼"); task.agv_Traytype = station.tray_type == TrayTypeEnum.SmallTray.ToString() ? TrayTypeEnum.LargeTray.ToString() : TrayTypeEnum.SmallTray.ToString(); agvtaskRepository.Update(task, x => new { x.agv_Traytype }, true); } else if (!agvtaskRepository.Find(x => x.agv_fromaddress == station.stationCode).Any()) { #region 为空æ并ä¸æ°é为0,å建å空æä»»å¡ if (station.tray_status == TrayStateEnum.EmptyTray.ToString() && station.quantity == 0) { dt_agvtask agvtask = new dt_agvtask() { agv_fromaddress = station.stationCode, agv_id = Guid.NewGuid(), agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), agv_grade = 1, agv_createtime = DateTime.Now, agv_taskstate = AGVTaskStateEnum.Queue.ToString(), agv_qty = 1, StarQuantity = 0, EndQuantity = 0,//EmptyStation.quantity, agv_tasktype = AGVTaskTypeEnum.TaskType_EmptyPallet.ToString(), agv_toaddress = "", agv_userid = UserContext.Current.UserName, agv_TrayStatus = station.tray_status, agv_Traytype = station.tray_type }; agvtaskRepository.Add(agvtask, true); station.location_state = LocationStateEnum.Busy.ToString(); } #endregion #region åå»ºå ¥åºä»»å¡ else if (station.location_state == LocationStateEnum.Stroge.ToString() && station.quantity > 0) { var Work = workinfoRepository.Find(x => x.workOrder == station.Number && x.processCode == "17").FirstOrDefault(); if (Work == null) throw new Exception($"æªæ¾å°è´§ä½{station.stationCode}çæºå 工工åä¿¡æ¯ï¼"); dt_agvtask agvtask = new dt_agvtask() { agv_fromaddress = station.stationCode, agv_id = Guid.NewGuid(), agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), agv_grade = 1, agv_createtime = DateTime.Now, agv_taskstate = AGVTaskStateEnum.Queue.ToString(), agv_materielid = station.stationType, agv_qty = station.quantity, agv_tasktype = station.stationCode.Contains("3") ? AGVTaskTypeEnum.TaskType_OutsourceInbound.ToString() : AGVTaskTypeEnum.TaskType_Inbound.ToString(), agv_toaddress = "", agv_userid = UserContext.Current.UserName, bindSN = station.bindSN, agv_worktype = Convert.ToInt32(Work.processCode), agv_materbarcode = Work.materialCode, agv_Traytype = station.tray_type, jobID = station.Number, agv_TrayStatus = station.tray_status }; agvtaskRepository.Add(agvtask, true); station.location_state = LocationStateEnum.InBusy.ToString(); } #endregion } station.tray_type = station.tray_type == TrayTypeEnum.SmallTray.ToString() ? TrayTypeEnum.LargeTray.ToString() : TrayTypeEnum.SmallTray.ToString(); repository.Update(station, x => new { x.location_state, x.tray_type }, true); webResponse.OK(webResponse.Message += $"{station.stationCode}åæ¢æå!"); } catch (Exception ex) { webResponse.Error(webResponse.Message += ex.Message); } } catch (Exception ex) WriteDBLog.Write($"æå¨åæ¢æç ", new { ä¿¡æ¯ = webResponse.Message }, LogState.Sucess, "WMS", UserContext.Current.UserName); return webResponse; } /// <summary> /// ä¸æä»»å¡ /// </summary> /// <param name="saveModel"></param> /// <returns></returns> public WebResponseContent SendAGVTask(SaveModel saveModel) { WebResponseContent webResponse = new WebResponseContent(); VOLContext context = new VOLContext(); Idt_agvtaskRepository agvtaskRepository = new dt_agvtaskRepository(context); IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(context); string completor = UserContext.Current.UserName; //List<object> jsons = null; foreach (var Key in saveModel.DelKeys) { try { var station = repository.Find(x => x.id.ToString() == Key.ToString()).FirstOrDefault(); if (!station.stationCode.Contains("X")) throw new Exception($"æ {station.stationCode}使ç¨æéï¼"); if (!station.enable) throw new Exception($"{station.stationCode}æªå¯ç¨ï¼"); if (station.location_state == LocationStateEnum.Abnormal.ToString()) throw new Exception($"{station.stationCode}ç¶æå¼å¸¸ï¼"); if (station.location_state == LocationStateEnum.Empty.ToString()) throw new Exception($"{station.stationCode}ç¶æ为空ï¼"); if (station.tray_status == TrayStateEnum.EmptyTray.ToString()) throw new Exception($"{station.stationCode}为空æçï¼"); if (station.quantity < 1) throw new Exception($"{station.stationCode}æ°éå°äº1ï¼"); if (station.remark == "æ¡æ¶ä¸æ") throw new Exception($"{station.stationCode}æ¡æ¶æ£å¨ä¸æï¼"); //if (station.location_state.Contains("Busy")) throw new Exception($"{station.stationCode}å ç¨ï¼"); if (agvtaskRepository.Find(x => x.agv_fromaddress == station.stationCode || x.agv_fromaddress == station.stationCode).Any()) throw new Exception($"{station.stationCode}åå¨ä»»å¡ï¼"); var Work = workinfoRepository.Find(x => x.workOrder == station.Number && x.processCode == "17").FirstOrDefault(); if (Work == null) throw new Exception($"æªæ¾å°è´§ä½{station.stationCode}çæºå 工工åä¿¡æ¯ï¼"); string tasktype = AGVTaskTypeEnum.TaskType_Inbound.ToString(); if (!string.IsNullOrEmpty(Work.area) || station.stationCode.Contains("3")) tasktype = AGVTaskTypeEnum.TaskType_OutsourceInbound.ToString(); dt_agvtask agvtask = new dt_agvtask() { agv_fromaddress = station.stationCode, agv_id = Guid.NewGuid(), agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), agv_grade = 1, agv_createtime = DateTime.Now, agv_taskstate = AGVTaskStateEnum.Queue.ToString(), agv_materielid = station.stationType, agv_qty = station.quantity, agv_tasktype = tasktype, agv_toaddress = "", agv_userid = completor, bindSN = station.bindSN, agv_worktype = Convert.ToInt32(Work.processCode), agv_materbarcode = Work.materialCode, agv_Traytype = station.tray_type, jobID = station.Number, agv_TrayStatus = station.tray_status }; //jsons.Add(agvtask); agvtaskRepository.Add(agvtask, true); station.location_state = LocationStateEnum.InBusy.ToString(); repository.Update(station, x => new { x.location_state }, true); webResponse.OK(webResponse.Message += $"{station.stationCode}ä»»å¡æ·»å æå!"); } catch (Exception ex) { webResponse.Error(webResponse.Message += ex.Message); } } WriteDBLog.Write($"æå¨ä¸æä»»å¡ ", new { ä¿¡æ¯ = webResponse.Message }, LogState.Sucess, "WMS", completor); return webResponse; } @@ -147,6 +307,10 @@ station.Number = string.Empty; } station.tray_status = string.IsNullOrEmpty(station.stationType) ? "EmptyTray" : "StrogeTray"; if (station.location_state == "Empty" && !string.IsNullOrEmpty(station.stationType)) { webResponse.Error("å¾å·ä¸ä¸ºç©º,è´§ä½ç¶æä¸è½è®¾ç½®ä¸ºç©ºè´§ä½ï¼"); } //station.tray_status = list.Count == 0 ? "EmptyTray" : "StrogeTray"; if (station.location_state == "Empty") { @@ -168,5 +332,39 @@ return webResponse; } public WebResponseContent dt_stationinfolist() { WebResponseContent content = new WebResponseContent(); VOLContext volContext = new VOLContext(); Idt_stationinfoRepository dsta = new dt_stationinfoRepository(volContext); string[] stationCodes = { "W", "A", "B", "C", "D01" }; List<Tuple<List<dt_stationinfo>, int>> responseData = new List<Tuple<List<dt_stationinfo>, int>>(); foreach (string code in stationCodes) { var data = dsta.Find(_ => true).Where(a => a.stationCode.Contains(code)).OrderBy(a => a.stationCode).ToList(); int inst = dsta.Find(_ => true).Where(a => a.stationCode.Contains(code)).GroupBy(a => a.line).Count(); responseData.Add(Tuple.Create(data, inst)); } content.Data = responseData; return content; } public WebResponseContent pcs_dt_stationinfolist() { WebResponseContent content = new WebResponseContent(); VOLContext volContext = new VOLContext(); Idt_stationinfoRepository dsta = new dt_stationinfoRepository(volContext); string[] stationCodes = { "X01", "X02", "X03", "S", "DD001" }; List<Tuple<List<dt_stationinfo>>> responseData = new List<Tuple<List<dt_stationinfo>>>(); foreach (string code in stationCodes) { var data = dsta.Find(_ => true).Where(a => a.stationCode.Contains(code)).OrderBy(a => a.stationCode).ToList(); responseData.Add(Tuple.Create(data)); } content.Data = responseData; return content; } } }
