SOMS/Yunda.SOMS.DataMonitoringServer.Service/DataAnalysis/TeleInfoSave/TelesignalizationResultSaveTask.cs

using Abp.Dependency;
using System.Collections.Generic;
using System.Threading.Tasks;
using Yunda.ISAS.DataMonitoringServer.DataCenter;
using Yunda.ISAS.MongoDB.Entities.DataMonitoring;

namespace Yunda.ISAS.DataMonitoringServer.DataAnalysis.TeleInfoSave
{
    public class TelesignalizationResultSaveTask : ISingletonDependency
    {
        private List<TelesignalisationResult> telesignalisationResults = new List<TelesignalisationResult>();
        private readonly DataRepository _dataRepository;
        public TelesignalizationResultSaveTask(DataRepository dataRepository)
        {
            _dataRepository = dataRepository;
        }
        public Task SaveOneDataAsync(TelesignalisationResult telesignalisationResult)
        {
            return Task.Run(() =>
            {
                _dataRepository.TelesignalisationResultRepository.InsertOne(telesignalisationResult);
            });
        }
        public void SaveDatasAsync(List<TelesignalisationResult> rstModels)
        {
            if (rstModels == null || rstModels.Count == 0) return;
            telesignalisationResults.AddRange(rstModels);
        }
    }
}