//--------------------------------------------------------------------
//     此代码由T4模板自动生成  byzhouhang 20210918
//	   生成时间 2024-03-22 15:44:31 
//     对此文件的更改可能会导致不正确的行为，并且如果重新生成代码，这些更改将会丢失。
//--------------------------------------------------------------------

using IRaCIS.Core.Domain.Models;
using Microsoft.AspNetCore.Mvc;
using IRaCIS.Core.Application.Interfaces;
using IRaCIS.Core.Application.ViewModel;
using FellowOakDicom.Network.Client;
using FellowOakDicom.Network;
using IRaCIS.Application.Contracts;
using IRaCIS.Core.Domain.Share;
namespace IRaCIS.Core.Application.Service
{
    /// <summary>
    /// DicomAEService
    /// </summary>	
    [ApiExplorerSettings(GroupName = "Common")]
    public class DicomAEService (IRepository<DicomAE> _dicomAERepository, IMapper _mapper, IUserInfo _userInfo) : BaseService, IDicomAEService
    {

       

        [HttpPost]
        public async Task<IResponseOutput< PageOutput<DicomAEView>>> GetDicomAEList(DicomAEQuery inQuery)
        {

            var dicomAEQueryable = _dicomAERepository
                               .WhereIf(!string.IsNullOrWhiteSpace(inQuery.IP), t => t.IP.Contains(inQuery.IP))
                               .WhereIf(inQuery.Port != null, t => t.Port == inQuery.Port)
                               .WhereIf(!string.IsNullOrWhiteSpace(inQuery.CalledAE), t => t.CalledAE.Contains(inQuery.CalledAE))
                               .WhereIf(!string.IsNullOrWhiteSpace(inQuery.Description), t => t.Description.Contains(inQuery.Description))
                               .WhereIf(!string.IsNullOrWhiteSpace(inQuery.Modality), t => t.Modality.Contains(inQuery.Modality))
                               .ProjectTo<DicomAEView>(_mapper.ConfigurationProvider);




            var pageList = await dicomAEQueryable.ToPagedListAsync(inQuery, nameof(DicomAEView.CalledAE));


            return ResponseOutput.Ok(pageList);
        }


        public async Task<IResponseOutput> AddOrUpdateDicomAE(DicomAEAddOrEdit addOrEditDicomAE)
        {
            var verifyExp1 = new EntityVerifyExp<DicomAE>()
            {
                VerifyExp = u => u.IP == addOrEditDicomAE.IP && u.Port == addOrEditDicomAE.Port,

                VerifyMsg = "不允许添加相同的IP和端口的记录"
            };

            //  在此处拷贝automapper 映射       
            var entity = await _dicomAERepository.InsertOrUpdateAsync(addOrEditDicomAE, true, verifyExp1);

            return ResponseOutput.Ok(entity.Id.ToString());

        }


        [HttpDelete("{dicomAEId:guid}")]
        public async Task<IResponseOutput> DeleteDicomAE(Guid dicomAEId)
        {
            var success = await _dicomAERepository.DeleteFromQueryAsync(t => t.Id == dicomAEId, true);
            return ResponseOutput.Ok();
        }


        /// <summary>
        /// 测试scp server 是否可以连接
        /// </summary>
        /// <returns></returns>
        [HttpGet("{dicomAEId:guid}")]
        public async Task<bool> TestSCPServerConnect(Guid dicomAEId)
        {
            var find = await _dicomAERepository.FirstOrDefaultAsync(t => t.Id == dicomAEId);

            if (find == null)
            {

                return false;
            }
            else
            {
                find.LatestTestTime = DateTime.Now;

                try
                {
                    var client = DicomClientFactory.Create(find.IP, find.Port, false, "test-callingAE", find.CalledAE);


                    client.NegotiateAsyncOps();

                    await client.AddRequestAsync(new DicomCEchoRequest());

                    // 创建一个超时任务，设置超时时间为1秒
                    var timeoutTask = Task.Delay(TimeSpan.FromSeconds(3));

                    // 发送 DICOM 请求
                    var sendTask = client.SendAsync();

                    // 等待任务完成，若超时任务先完成则抛出超时异常
                    if (await Task.WhenAny(sendTask, timeoutTask) == timeoutTask)
                    {
                        throw new TimeoutException("DICOM 请求超时。");
                    }

                    find.IsTestOK = true;
                    await _dicomAERepository.SaveChangesAsync();

                    return true;                  
                }
                catch (Exception ex)
                {
                    find.IsTestOK = false;
                    await _dicomAERepository.SaveChangesAsync();

                    return false;
                }
            }


        }


    }
}