工单清理，检测线段

huanghongfeng

2024-07-09 a8e17feaaaafd549c81ea7e18f5c968af28d9391

 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/Services/system/Partial/dt_stationinfoService.cs

@@ -28,6 +28,7 @@
using WIDESEA_Comm;
using WIDESEA_Comm.TaskNo;
using WIDESEA_Common;
using static FreeSql.Internal.GlobalFilter;

namespace WIDESEA_WMS.Services
{
@@ -111,20 +112,25 @@
            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;
            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.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}桁架正在下料！");
                    if (agvtaskRepository.Find(x => x.agv_toaddress == station.stationCode).Any()) throw new Exception($"{station.stationCode}存在任务！");
                    
                    if (!agvtaskRepository.Find(x => x.agv_fromaddress == station.stationCode).Any())

                    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)
@@ -194,6 +200,7 @@
                    webResponse.Error(webResponse.Message += ex.Message);
                }
            }
            WriteDBLog.Write($"手动切换托盘 ", new { ä¿¡æ¯ = webResponse.Message }, LogState.Sucess, "WMS", UserContext.Current.UserName);
            return webResponse;
        }
        /// <summary>
@@ -208,6 +215,7 @@
            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
@@ -224,6 +232,9 @@
                    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,
@@ -234,9 +245,9 @@
                        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_tasktype = tasktype,
                        agv_toaddress = "",
                        agv_userid = UserContext.Current.UserName,
                        agv_userid = completor,
                        bindSN = station.bindSN,
                        agv_worktype = Convert.ToInt32(Work.processCode),
                        agv_materbarcode = Work.materialCode,
@@ -244,6 +255,7 @@
                        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);
@@ -254,6 +266,7 @@
                    webResponse.Error(webResponse.Message += ex.Message);
                }
            }
            WriteDBLog.Write($"手动下料任务 ", new { ä¿¡æ¯ = webResponse.Message }, LogState.Sucess, "WMS", completor);
            return webResponse;
        }

@@ -325,7 +338,7 @@
            WebResponseContent content = new WebResponseContent();
            VOLContext volContext = new VOLContext();
            Idt_stationinfoRepository dsta = new dt_stationinfoRepository(volContext);
            string[] stationCodes = { "A", "S", "X", "W", "DD", "B", "C", "D01" };
            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)
            {
@@ -337,5 +350,21 @@
            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;
        }

    }
}