高普立体库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yanjinhui
7 小时以前 cba2c0ff983f40757aa9840a3bd520c28a9896d9 
 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/Task/TaskJob.cs


@@ -2,8 +2,10 @@


using HslCommunication;


using HslCommunication.Core;


using Microsoft.VisualBasic.FileIO;


using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;


using Quartz;


using SixLabors.ImageSharp.PixelFormats;


using SqlSugar;


using System;


using System.Collections.Generic;


using System.ComponentModel;


@@ -11,14 +13,18 @@


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using WIDESEAWCS_BasicInfoService;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Communicator;


using WIDESEAWCS_Core.BaseRepository;


using WIDESEAWCS_Core.Enums;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_IBasicInfoService;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;




namespace WIDESEAWCS_Tasks


@@ -29,20 +35,54 @@


        private readonly ITaskService _taskService;


        private readonly IApiInfoService _apiInfoService;


        private readonly IRGVLocationInfoService _rGVLocationInfoService;


        public TaskJob(ITaskService taskService, IApiInfoService apiInfoService, IRGVLocationInfoService rGVLocationInfoService)


        private readonly IStationMangerService _stationMangerService;


        private readonly ITrackloginfoService _trackloginfoService;


        private readonly IUnitOfWorkManage _unitOfWorkManage;


        private readonly IAGVCartInfoService _agvcartInfoService;


        private readonly IStationInfoService _stationInfoService;




        public TaskJob(ITaskService taskService, IApiInfoService apiInfoService, IRGVLocationInfoService rGVLocationInfoService, IStationMangerService stationMangerService, ITrackloginfoService trackloginfoService, IUnitOfWorkManage unitOfWorkManage, IAGVCartInfoService agvcartInfoService, IStationInfoService stationInfoService)


        {


            _taskService = taskService;//娉ㄥ叆


            _apiInfoService = apiInfoService;


            _rGVLocationInfoService = rGVLocationInfoService;


            _stationMangerService = stationMangerService;


            _trackloginfoService = trackloginfoService;


            _unitOfWorkManage = unitOfWorkManage;


            _agvcartInfoService = agvcartInfoService;


            _stationInfoService = stationInfoService;


        }




        public Task Execute(IJobExecutionContext context)


        {


            try


            {


                SendTask();


                SendNewTask();




                SendWaitToTask();




                #region 澶勭悊鍐欏叆璁惧淇″彿寮傚父浠诲姟


                var tasks = _taskService.Repository.QueryData(x => x.TaskState == TaskStatusEnum.Finish.ObjToInt() && !string.IsNullOrEmpty(x.Remark));


                if (tasks.Count > 0)


                {


                    List<Dt_Task> list = new List<Dt_Task>();


                    foreach (var item in tasks)


                    {


                        var infos = item.Remark.Split("_");


                        var device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == infos[0]) as OtherDevice;


                        if (device != null && device.IsConnected)


                        {


                            DeviceProDTO? devicePro = device.DeviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == infos[1] && x.DeviceChildCode == infos[3]);


                            if (devicePro != null)


                            {


                                var W = device.Communicator.WriteObj(devicePro.DeviceProAddress, devicePro.DeviceDataType, infos[2]);


                                if (W) list.Add(item);


                            }


                        }


                    }


                    _taskService.Repository.DeleteAndMoveIntoHty(list, OperateTypeEnum.鑷姩鍒犻櫎);


                }


                #endregion


            }


            catch (Exception ex)


            {