hotline/src/Hotline.Application/CallCenter/Calls/TelsStatusRefreshService.cs

using Hotline.CallCenter.Tels;
using Hotline.Realtimes;
using Hotline.Users;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using System.Threading;
using Tr.Sdk;
using XF.Domain.Cache;
using XF.Domain.Repository;

namespace Hotline.Application.CallCenter.Calls
{
    public class TelsStatusRefreshService : BackgroundService
    {
        private readonly IServiceScopeFactory _serviceScopeFactory;
        public TelsStatusRefreshService(IServiceScopeFactory serviceScopeFactory)
        {
            _serviceScopeFactory = serviceScopeFactory;
        }


        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            using var scope = _serviceScopeFactory.CreateScope();
            var realtimeService = scope.ServiceProvider.GetRequiredService<IRealtimeService>();
            var _trClient = scope.ServiceProvider.GetRequiredService<ITrClient>();
            var _workRepository = scope.ServiceProvider.GetRequiredService<IRepository<Work>>();
            var _telRestRepository = scope.ServiceProvider.GetRequiredService<IRepository<TelRest>>();
            var _cacheWork = scope.ServiceProvider.GetRequiredService<ITypedCache<Work>>();
            int times = 300000;
            while (!stoppingToken.IsCancellationRequested)
            {
                try
                {
                    //var list = await _workRepository.Queryable().Where(x => !x.EndTime.HasValue).ToListAsync();
                    var list = await _workRepository.Queryable().Where(x => 1==1 && !x.EndTime.HasValue).ToListAsync();
                    //var list = await _workRepository.Queryable().Where(x => x.EndTime is null).ToListAsync();
                    var tellist = await _trClient.QueryTelStateAsync(new Tr.Sdk.Tels.QueryTelStateRequest { }, stoppingToken);
                    foreach (var item in list)
                    {
                        var telmodel = tellist.AgentList.First(x => x.TelNo == item.TelNo);
                        if (telmodel != null)
                        {
                            if (telmodel.State == "logout")
                            {
                                var telRest = await _telRestRepository.GetAsync(x => x.TelNo == item.TelNo && x.EndTime != null, stoppingToken);
                                if (telRest is not null)
                                {
                                    telRest.EndRest();
                                    await _telRestRepository.UpdateAsync(telRest, stoppingToken);
                                }

                                item.OffDuty();
                                await _workRepository.UpdateAsync(item, stoppingToken);
                                _cacheWork.Remove(item.GetKey(KeyMode.UserId));
                                _cacheWork.Remove(item.GetKey(KeyMode.TelNo));
                            }
                        }
                    }
                }
                catch
                {

                }
                await Task.Delay(times);
            }
        }
    }
}