分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
dengjunjie
2024-04-16 e883d7e4bf057f7a2ed7cc001fe27083d82baa22 
 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs


@@ -25,6 +25,7 @@


using WIDESEA_Core.ManageUser;


using WIDESEA_Comm.LogInfo;


using StackExchange.Redis;


using WIDESEA_Comm;




namespace WIDESEA_WMS.Services


{


@@ -45,63 +46,118 @@


            //多租户会用到这init代码，其他情况可以不用


            //base.Init(dbRepository);


        }


        /// <summary>


        /// æ·»åŠ ä»»åŠ¡


        /// </summary>


        /// <param name="saveDataModel"></param>


        /// <returns></returns>




        #region æ·»åŠ NG任务


        public override WebResponseContent Add(SaveModel saveDataModel)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                var fromaddress = saveDataModel.MainData["agv_fromaddress"].ToString();


                VOLContext context = new VOLContext();


                Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(context);


                var fromaddress = saveDataModel.MainData["agv_fromaddress"].ToString();


                var toaddress = saveDataModel.MainData["agv_toaddress"].ToString();


                var tasktype = saveDataModel.MainData["agv_tasktype"].ToString();


                var grade = saveDataModel.MainData["agv_grade"].ToInt();


                var worktype = saveDataModel.MainData["agv_worktype"].ToInt();


                var station1 = stationinfoRepository.FindFirst(x => x.stationCode == fromaddress);


                var station2 = stationinfoRepository.FindFirst(x => x.stationCode == toaddress);


                if (station1 == null || station2 == null)


                    throw new Exception($"起点地址{fromaddress}或终点地址{toaddress}不存在！");


                if (string.IsNullOrEmpty(station1.stationType))


                    throw new Exception($"起点{fromaddress}未绑定物料类型！");


                var task = _repository.Find(t => t.agv_fromaddress == fromaddress


                       || t.agv_fromaddress == toaddress


                       || t.agv_toaddress == fromaddress


                       || t.agv_toaddress == toaddress


                       ).Any();


                if (task)


                    throw new Exception("起始或目的地址，已存在任务中！");


                dt_agvtask agvtask = new dt_agvtask();


                agvtask.agv_id = Guid.NewGuid();


                agvtask.agv_fromaddress = fromaddress;


                agvtask.agv_toaddress = toaddress;


                agvtask.agv_tasknum = IdenxManager.GetTaskNo("KH-");


                agvtask.agv_TrayStatus = station1.tray_status;


                agvtask.agv_Traytype = station1.tray_type;


                agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();


                agvtask.agv_tasktype = tasktype;


                agvtask.agv_worktype = worktype;//工作类型


                agvtask.bindSN = station1.bindSN;


                agvtask.agv_materielid = station1.stationType;//物料类型


                agvtask.agv_qty = station1.quantity;


                agvtask.agv_createtime = DateTime.Now;


                agvtask.agv_grade = grade;//任务优先级


                agvtask.agv_userid = UserContext.Current.UserName;


                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(context);


                var station = stationinfoRepository.Find(x => x.stationCode == fromaddress).FirstOrDefault();


                if (_repository.Find(x => x.agv_fromaddress == fromaddress || x.agv_toaddress == fromaddress).Any())


                    throw new Exception($"货位{fromaddress}已存在任务！");


                if (station == null) throw new Exception($"未找到货位{fromaddress}！");


                if (!station.enable) throw new Exception($"货位{fromaddress}未启用！");


                if (station.quantity < 1) throw new Exception($"货位{fromaddress}无车轮！");


                var Work = workinfoRepository.Find(x => x.workOrder == station.Number && x.processCode == "17").FirstOrDefault();


                if (Work == null) throw new Exception($"未找到货位{fromaddress}的机加工工单信息");


                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 = "Queue",


                    agv_materielid = station.stationType,


                    agv_qty = station.quantity,


                    agv_tasktype = "TaskType_OutsourceInbound",


                    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


                };


                _repository.Add(agvtask, true);


                station.location_state = LocationStateEnum.InBusy.ToString();


                stationinfoRepository.Update(station, true);


                content.OK();


                WriteDBLog.Success($"手动添加任务", new { æ•°æ® = saveDataModel }, "WMS", UserContext.Current.UserName);


            }


            catch (Exception ex)


            {


                WriteDBLog.Error($"手动添加任务", new { æ•°æ® = saveDataModel, å¼‚常信息 = ex.Message }, "WMS", UserContext.Current.UserName);


                content.Error(ex.Message);


                content.Message = ex.Message;


            }




            return content;


        }


        #endregion




        #region æ·»åŠ ä»»åŠ¡


        /// <summary>


        /// æ·»åŠ ä»»åŠ¡


        /// </summary>


        /// <param name="saveDataModel"></param>


        /// <returns></returns>


        //public override WebResponseContent Add(SaveModel saveDataModel)


        //{


        //    WebResponseContent content = new WebResponseContent();


        //    try


        //    {


        //        VOLContext context = new VOLContext();


        //        Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(context);


        //        var fromaddress = saveDataModel.MainData["agv_fromaddress"].ToString();


        //        var toaddress = saveDataModel.MainData["agv_toaddress"].ToString();


        //        var tasktype = saveDataModel.MainData["agv_tasktype"].ToString();


        //        var grade = saveDataModel.MainData["agv_grade"].ToInt();


        //        var worktype = saveDataModel.MainData["agv_worktype"].ToInt();


        //        var station1 = stationinfoRepository.FindFirst(x => x.stationCode == fromaddress);


        //        var station2 = stationinfoRepository.FindFirst(x => x.stationCode == toaddress);


        //        if (station1 == null || station2 == null)


        //            throw new Exception($"起点地址{fromaddress}或终点地址{toaddress}不存在！");


        //        if (string.IsNullOrEmpty(station1.stationType))


        //            throw new Exception($"起点{fromaddress}未绑定物料类型！");


        //        var task = _repository.Find(t => t.agv_fromaddress == fromaddress


        //               || t.agv_fromaddress == toaddress


        //               || t.agv_toaddress == fromaddress


        //               || t.agv_toaddress == toaddress


        //               ).Any();


        //        if (task)


        //            throw new Exception("起始或目的地址，已存在任务中！");


        //        dt_agvtask agvtask = new dt_agvtask();


        //        agvtask.agv_id = Guid.NewGuid();


        //        agvtask.agv_fromaddress = fromaddress;


        //        agvtask.agv_toaddress = toaddress;


        //        agvtask.agv_tasknum = IdenxManager.GetTaskNo("KH-");


        //        agvtask.agv_TrayStatus = station1.tray_status;


        //        agvtask.agv_Traytype = station1.tray_type;


        //        agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();


        //        agvtask.agv_tasktype = tasktype;


        //        agvtask.agv_worktype = worktype;//工作类型


        //        agvtask.bindSN = station1.bindSN;


        //        agvtask.agv_materielid = station1.stationType;//物料类型


        //        agvtask.agv_qty = station1.quantity;


        //        agvtask.agv_createtime = DateTime.Now;


        //        agvtask.agv_grade = grade;//任务优先级


        //        agvtask.agv_userid = UserContext.Current.UserName;


        //        _repository.Add(agvtask, true);


        //        content.OK();


        //        WriteDBLog.Success($"手动添加任务", new { æ•°æ® = saveDataModel }, "WMS", UserContext.Current.UserName);


        //    }


        //    catch (Exception ex)


        //    {


        //        WriteDBLog.Error($"手动添加任务", new { æ•°æ® = saveDataModel, å¼‚常信息 = ex.Message }, "WMS", UserContext.Current.UserName);


        //        content.Error(ex.Message);


        //    }




        //    return content;


        //}


        #endregion




    }


}