美瑞安淮安立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
helongyang
昨天 cb25acc46bf41863e068b6f968f1592b7a14d1c9 
 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/¸¨ÁϲÖ/ConveyorLineJob_FL.cs


@@ -1,10 +1,12 @@


using Microsoft.AspNetCore.Components.Routing;


using HslCommunication.WebSocket;


using Microsoft.AspNetCore.Components.Routing;


using Newtonsoft.Json;


using Quartz;


using SqlSugar.Extensions;


using System;


using System.Collections.Generic;


using System.Linq;


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using WIDESEAWCS_Common;


@@ -19,6 +21,7 @@


using WIDESEAWCS_QuartzJob.Repository;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using WIDESEAWCS_Tasks.辅料仓;


using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;




namespace WIDESEAWCS_Tasks


@@ -30,13 +33,15 @@


        private readonly ITaskService _taskService;


        private readonly ITaskExecuteDetailService _taskExecuteDetailService;


        private readonly ITaskRepository _taskRepository;


        public static FLReadData fLReadData = new FLReadData();


        private readonly IStationMangerRepository _stationMangerRepository;


        private readonly IRouterRepository _routerRepository;


        private readonly IRouterService _routerService;


        private readonly IRouterExtension _routerExtension;


        private readonly List<Dt_WarehouseDevice> warehouseDevices;


        private WebSocketServer _webSocketServer;




        public ConveyorLineJob_FL(ICacheService cacheService, ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IRouterService routerService, IRouterExtension routerExtension)


        public ConveyorLineJob_FL(ICacheService cacheService, ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, IRouterService routerService, IRouterExtension routerExtension,WebSocketServer webSocketServer)


        {


            _cacheService = cacheService;


            _taskService = taskService;


@@ -46,6 +51,7 @@


            _routerRepository = routerRepository;


            _routerService = routerService;


            _routerExtension = routerExtension;


            _webSocketServer = webSocketServer;




            string? warehouseDevicesStr = _cacheService.Get<string>(nameof(Dt_WarehouseDevice));


            if (!string.IsNullOrEmpty(warehouseDevicesStr))


@@ -98,6 +104,22 @@


                                _taskService.UpdateTask(newTask, TaskStatusEnum.Line_Executing);


                            }


                        }


                        if (item.StationCode == "8005")


                        {


                            R_ConveyorLineFLInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_ConveyorLineFLInfo>(deviceProRead.DeviceProAddress);


                            bool conveyArrivaled = device.GetValue<R_ConveyorLineFLDB, bool>(R_ConveyorLineFLDB.ConveyArrivaled, item.StationCode);


                            fLReadData.W_PutFinish5 = device.GetValue<GroundStationDBName, bool>(GroundStationDBName.W_PutFinish, item.StationCode);


                            fLReadData.R_ConveyArrivaled5 = device.GetValue<R_ConveyorLineFLDB, bool>(R_ConveyorLineFLDB.ConveyArrivaled, item.StationCode);


                            fLReadData.R_Barcode5 = conveyorLineInfoRead.Barcode;


                            fLReadData.R_TaskNum5 = conveyorLineInfoRead.TaskNum;


                        }


                        else if (item.StationCode == "8001")


                        {


                            fLReadData.W_PutFinish1 = device.GetValue<GroundStationDBName, bool>(GroundStationDBName.W_PutFinish, item.StationCode);


                            fLReadData.R_IsCanPut = device.GetValue<GroundStationDBName, bool>(GroundStationDBName.R_IsCanPut, item.StationCode);


                        }


                        string yMData = JsonConvert.SerializeObject(fLReadData);


                        _webSocketServer.PublishAllClientPayload(yMData);


                    }




                }