4-30 叫料&拉出空框代码已写完

xiaojiao

3 天以前 4a6319fa5be9ef5f9741c3507825667f523d9b2b

 ÏîÄ¿´úÂë/WIDESEA_WCSServer/WIDESEAWCS_Tasks/TaskAcquisition/TaskAcquisition_Back1_Job.cs

@@ -8,8 +8,10 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common.StationEnum;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Communicator;
using WIDESEAWCS_DTO.PDA;
using WIDESEAWCS_IBasicInfoRepository;
using WIDESEAWCS_IBasicInfoService;
using WIDESEAWCS_ISystemServices;
@@ -43,101 +45,136 @@
        }
        public Task Execute(IJobExecutionContext context)
        {
            string ip = "127.0.0.1";
            int port = 502;
            string Region = "后底板1";
            ModbusTcp modbusTcp = new ModbusTcp(ip, port, Region);
            Baseconversion baseconversion = new Baseconversion();
            modbusTcp.Connect();

            Dictionary<int, int> Signal = new Dictionary<int, int>() { [10] = 2, [30] = 3, [50] = 4, [70] = 5 }; 
            Dictionary<int, int> FeedingPoint = new Dictionary<int, int>() { [10] = 2001, [30] = 2002, [50] = 2003, [70] = 2004 }; // å«æ–™çš„点位 ç»ˆç‚¹ä½ç½®

            try
            bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
            if (flag && value != null)
            {
                for (int i = 10; i < 90; i += 20)
                OtherDevice device = (OtherDevice)value;
                if (!device.IsConnected)
                {
                    byte[] SignalNumber = modbusTcp.Read(Signal[i].ToString(), 1); // ä¿¡å· 1：叫料 2：拉出空框
                    return Task.CompletedTask;
                }
                //string ip = "127.0.0.1";
                //int port = 502;
                //string Region = "后底板1";
                //ModbusTcp modbusTcp = new ModbusTcp(ip, port, Region);
                //modbusTcp.Connect();
                Baseconversion baseconversion = new Baseconversion();
                Dictionary<int, int> Signal = new Dictionary<int, int>() { [10] = 2, [30] = 3, [50] = 4, [70] = 5 };
                Dictionary<int, int> FeedingPoint = new Dictionary<int, int>() { [10] = 2001, [30] = 2002, [50] = 2003, [70] = 2004 }; // å«æ–™çš„点位 ç»ˆç‚¹ä½ç½®

                    if (SignalNumber[1] == 1)
                try
                {
                    for (int i = 10; i < 90; i += 20)
                    {
                        byte[] PartNumber = modbusTcp.Read(i.ToString(), 20); // è¯»å–零件号
                        byte[] SignalNumber = device.Communicator.Read(Signal[i].ToString(), 1); // ä¿¡å· 1：叫料 2：拉出空框

                        if (PartNumber[1] == 0) continue;

                        string Ku1_Value = baseconversion.TenthTurn16(PartNumber); 
                        if (Ku1_Value != "" && Ku1_Value != null)
                        Dt_StationManager dt_StationManager = _stationManagerRepository.QueryFirst(
                                    x => x.StationLocation == FeedingPoint[i].ToString()
                                    && x.StationStatus != ((int)StationEnum.Disable).ToString());
                        if (dt_StationManager == null)
                        {
                            // ç­‰åŠŸèƒ½æµ‹è¯•å®Œï¼Œè¿™é‡Œè¦åšæ—¥å¿—记录

                            Console.WriteLine(Ku1_Value);
                            // æ‰¾å¯¹åº”的零件号是否已经绑定(组盘)
                            Dt_MaterialInfo dt_MaterialInfo = _IDt_MaterialInfoRepository.QueryFirst(x => x.MaterialName == Ku1_Value);
                            
                            if (dt_MaterialInfo != null && dt_MaterialInfo.IsBind && dt_MaterialInfo.EndPosition == null)
                            {
                                Dt_Task dt_Task = _taskRepository.QueryFirst(x => x.PalletCode == dt_MaterialInfo.ContainerCode);
                                if (dt_Task != null) continue; //证明有当前任务

                                dt_Task = new Dt_Task();
                                dt_Task.PalletCode = dt_MaterialInfo.ContainerCode;
                                dt_Task.SourceAddress = dt_MaterialInfo.Position; // å½“前位置
                                dt_Task.TargetAddress = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®
                                dt_Task.Grade = 2;
                                dt_Task.TaskState = TaskAGVCarryStatusEnum.AGV_CarryNew.ObjToInt();
                                dt_Task.TaskType = TaskAGVCarryTypeEnum.Carry.ObjToInt();
                                dt_Task.Roadway = (Signal[i] - 1).ToString(); // åº“1 å«æ–™é‚£å°±æ˜¯1巷道
                                dt_Task.CurrentAddress = dt_MaterialInfo.Position; // å½“前位置
                                dt_Task.NextAddress = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®

                                dt_MaterialInfo.EndPosition = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®

                                _taskRepository.AddData(dt_Task);
                                _IDt_MaterialInfoRepository.UpdateData(dt_MaterialInfo);
                            }

                            // å¦‚果没绑定则不生成任务 å¦‚果查找到对应的零件号绑定了 åˆ™ç”Ÿæˆä¸€æ¡ä»»åŠ¡æ•°æ®
                            // è¿™é‡Œåº”该要加日志 è®°å½•æ‰¾ä¸åˆ°ç«™å°çš„信息
                            Console.WriteLine($"{DateTime.Now} å½“前站台【{FeedingPoint[i].ToString()} æœªé…ç½®æˆ–已禁用】");
                            continue;
                        }

                        if (SignalNumber[1] == 1)
                        {
                            byte[] PartNumber = device.Communicator.Read(i.ToString(), 20); // è¯»å–零件号

                            string Ku1_Value = baseconversion.TenthTurn16(PartNumber);
                            if (Ku1_Value != "" && Ku1_Value != null)
                            {
                                // ç­‰åŠŸèƒ½æµ‹è¯•å®Œï¼Œè¿™é‡Œè¦åšæ—¥å¿—记录

                                Console.WriteLine(Ku1_Value);
                                // æ‰¾å¯¹åº”的零件号是否已经绑定(组盘) // è¿™é‡Œè¦æ”¹è¦åŠ åŒºåŸŸ åŠ æ˜¯å¦å·²ç”Ÿæˆä»»åŠ¡ è¿˜è¦æ ¹æ®æ—¶é—´æŽ’序 å…ˆç»‘定的先发过去
                                Dt_MaterialInfo? dt_MaterialInfo = _IDt_MaterialInfoRepository.QueryData(x => x.MaterialName == Ku1_Value
                                                                   && x.Region == ((int)StationEnum.Rearbaseplate1).ToString()
                                                                   && (x.EndPosition == null || x.EndPosition == "")).OrderBy(x => x.CreateDate).FirstOrDefault();

                                if (dt_MaterialInfo != null)
                                {
                                    Dt_Task dt_Task = _taskRepository.QueryFirst(x => x.PalletCode == dt_MaterialInfo.ContainerCode);
                                    if (dt_Task != null) continue; //证明有当前任务

                                    dt_Task = new Dt_Task();
                                    dt_Task.PalletCode = dt_MaterialInfo.ContainerCode;
                                    dt_Task.SourceAddress = dt_MaterialInfo.Position; // å½“前位置
                                    dt_Task.TargetAddress = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®
                                    dt_Task.Grade = 2;
                                    dt_Task.TaskState = TaskAGVCarryStatusEnum.AGV_CarryNew.ObjToInt();
                                    dt_Task.TaskType = TaskAGVCarryTypeEnum.Carry.ObjToInt();
                                    dt_Task.Roadway = (Signal[i] - 1).ToString(); // åº“1 å«æ–™é‚£å°±æ˜¯1巷道
                                    dt_Task.CurrentAddress = dt_MaterialInfo.Position; // å½“前位置
                                    dt_Task.NextAddress = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®

                                    dt_MaterialInfo.EndPosition = FeedingPoint[i].ToString(); // ç»ˆç‚¹ä½ç½®

                                    dt_StationManager.StationStatus = ((int)StationEnum.Thereisatask).ToString();
                                    dt_StationManager.StationRemark = dt_MaterialInfo.ContainerCode;
                                    _stationManagerRepository.UpdateData(dt_StationManager);


                                    _taskRepository.AddData(dt_Task);
                                    _IDt_MaterialInfoRepository.UpdateData(dt_MaterialInfo);
                                }

                                // å¦‚果没绑定则不生成任务 å¦‚果查找到对应的零件号绑定了 åˆ™ç”Ÿæˆä¸€æ¡ä»»åŠ¡æ•°æ®
                            }
                        }

                        if (SignalNumber[1] == 2) // è¡¨ç¤ºæ‹‰å‡ºç©ºæ¡†
                        {
                            Dt_Task dt_Task = _taskRepository.QueryFirst(x => x.SourceAddress == FeedingPoint[i].ToString() && x.TaskType == (int)TaskAGVCarryTypeEnum.CarryEmpty);
                            if (dt_Task != null) continue;

                            Dt_StationManager RecyclingpointStation = _stationManagerRepository.QueryFirst(x =>
                            x.StationStatus == ((int)StationEnum.Enable).ToString()
                            && x.StationArea == ((int)StationEnum.Rearbaseplate1).ToString()
                            && x.Remark == "回收点");

                            if (RecyclingpointStation == null)
                            {
                                // è®°å½•é”™è¯¯æ—¥å¿—
                                continue;
                            }
                            dt_Task = new Dt_Task();
                            dt_Task.PalletCode = dt_StationManager.StationRemark;
                            dt_Task.SourceAddress = FeedingPoint[i].ToString();
                            dt_Task.TargetAddress = RecyclingpointStation.StationLocation;
                            dt_Task.Grade = 2;
                            dt_Task.TaskState = TaskAGVCarryStatusEnum.AGV_CarryNew.ObjToInt();
                            dt_Task.TaskType = TaskAGVCarryTypeEnum.CarryEmpty.ObjToInt();
                            dt_Task.Roadway = (Signal[i] - 1).ToString(); // åº“1 å«æ–™é‚£å°±æ˜¯1巷道
                            dt_Task.CurrentAddress = FeedingPoint[i].ToString(); // å½“前位置
                            dt_Task.NextAddress = RecyclingpointStation.StationLocation;// ç»ˆç‚¹ä½ç½®

                            RecyclingpointStation.StationStatus = ((int)StationEnum.Thereisatask).ToString();

                            _stationManagerRepository.UpdateData(RecyclingpointStation);
                            _taskRepository.AddData(dt_Task);
                        }

                    }
                }
                catch (Exception)
                {

                    if (SignalNumber[1] == 2) // è¡¨ç¤ºæ‹‰å‡ºç©ºæ¡†
                    {
                        Dictionary<int, int> Endpointposition = new Dictionary<int, int>() { [10] = 3001, [20] = 3002, [30] = 3003, [40] = 3004 }; // å«æ–™çš„点位 ç»ˆç‚¹ä½ç½®
                        Dt_Task dt_Task = _taskRepository.QueryFirst(x => x.SourceAddress == FeedingPoint[i].ToString() && x.TaskType == (int)TaskAGVCarryTypeEnum.CarryEmpty);
                        if (dt_Task != null) continue;

                        dt_Task = new Dt_Task();
                        dt_Task.PalletCode = "空框子";
                        dt_Task.SourceAddress = FeedingPoint[i].ToString();
                        dt_Task.TargetAddress = Endpointposition[i].ToString(); 
                        dt_Task.Grade = 2;
                        dt_Task.TaskState = TaskAGVCarryStatusEnum.AGV_CarryNew.ObjToInt();
                        dt_Task.TaskType = TaskAGVCarryTypeEnum.CarryEmpty.ObjToInt();
                        dt_Task.Roadway = (Signal[i] - 1).ToString(); // åº“1 å«æ–™é‚£å°±æ˜¯1巷道
                        dt_Task.CurrentAddress = FeedingPoint[i].ToString(); // å½“前位置
                        dt_Task.NextAddress = Endpointposition[i].ToString(); // ç»ˆç‚¹ä½ç½®
                        _taskRepository.AddData(dt_Task);
                    }

                    throw;
                }
            }
            catch (Exception)
            {

                throw;
            }


            // 16进制转成10进制
            // 2. 16进制 â†’ è½¬å›žåè¿›åˆ¶ï¼ˆä½ è¦çš„功能）
            ulong decimalResult = Convert.ToUInt64("123", 16);
            Console.WriteLine("16进制转回十进制：" + decimalResult);
            //ulong decimalResult = Convert.ToUInt64("123", 16);
            //Console.WriteLine("16进制转回十进制：" + decimalResult);

            // å†™å…¥
            bool flag = modbusTcp.Write("30", decimalResult.ToString());
            //// å†™å…¥
            //bool flag2 = modbusTcp.Write("30", decimalResult.ToString());

            modbusTcp.Disconnect();
            Console.WriteLine("进入了TaskAcquisition_Back1_Job");
            //modbusTcp.Disconnect();
            //Console.WriteLine("进入了TaskAcquisition_Back1_Job");
            return Task.CompletedTask;
        }
    }