XdCxRhDW/XdCxRhDW.App/X2D1PosRef/X2D1PosRefService.cs

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using XdCxRhDW.Dto;
using XdCxRhDW.Entity;
using XdCxRhDW.Repostory;
namespace XdCxRhDW.App
{
    /// <summary>
    /// 两星一地定位取参考服务 
    /// </summary>
    public class X2D1PosRefService
    {
        public static X2D1PosRefService Instance { get; private set; } = new X2D1PosRefService();

        readonly List<X2D1PosHandle> handles = new List<X2D1PosHandle>();

        public X2D1PosRefService()
        {
            StartMonitor();
        }
        public void StartMonitor()
        {
            Task.Run(() =>
            {
                while (true)
                {
                    if (handles.Count == 0)
                    {
                        Thread.Sleep(5000);
                    }
                    try
                    {
                        lock (this)
                        {
                            List<X2D1PosHandle> deletes = new List<X2D1PosHandle>();
                            using (RHDWContext db = new RHDWContext())
                            {
                                for (int i = 0; i < handles.Count; i++)
                                {
                                    var handle = handles[i];
                                    var runTask = db.TaskInfos.FirstOrDefault(p => p.ID == handle.TaskId && p.TaskState == EnumTaskState.Running);
                                    if (runTask == null)
                                    {
                                        handle.Stop();
                                        deletes.Add(handle);
                                    }
                                }

                            }
                            //删除未运行的任务
                            handles.RemoveAll(r => deletes.Any(d => d.TaskId == r.TaskId));
                        }
                        Thread.Sleep(5000);
                    }
                    catch (Exception ex)
                    {
                        Serilog.Log.Error(ex, $"【监视取参考任务运行状态异常，{ex.Message}");

                    }

                }
            });
        }
        public void AddPosDto(X2D1NoXlNoParlPosDto dto)
        {
            try
            {
                lock (this)
                {
                    var firstDto = handles.FirstOrDefault(m => m.TaskId == dto.TaskID);
                    if (firstDto == null)
                    {
                        firstDto = new X2D1PosHandle(dto.TaskID.Value);
                        handles.Add(firstDto);
                    }
                    firstDto.Append(dto);
                }
            }
            catch (Exception ex)
            {
                Serilog.Log.Error(ex, $"【任务{dto.TaskID}】添加取参考信号流程异常，{ex.Message}");

            }
        }
        public void Stop(int taskID)
        {
            try
            {
                lock (this)
                {
                    var firstDto = handles.FirstOrDefault(m => m.TaskId == taskID);
                    if (firstDto != null)
                    {
                        firstDto.Stop();
                        handles.Remove(firstDto);
                    }
                }
            }
            catch (Exception ex)
            {
                Serilog.Log.Error(ex, $"停止【任务{taskID}】取参考信号流程异常，{ex.Message}");

            }
        }

    }
}