using Microsoft.AspNetCore.Mvc;
using System.Net;
using System.Net.Http.Headers;
using Microsoft.Extensions.Hosting.Internal;
using Microsoft.AspNetCore.Http.Extensions;
using IStation.Untity;
using Furion.DynamicApiController;
using System.ComponentModel.DataAnnotations;
using Mapster;

namespace IStation.Application
{
    /// <summary>
    /// FlowMeter
    /// </summary>
    [Route("Dma/FlowMeter/Logic")]
    [ApiDescriptionSettings("Dma", Name = "流量计(业务)", Order = 70)]
    public class FlowMeter_LogicController : IDynamicApiController
    {

        /// <summary>
        /// 通过 CorpID 获取列表（业务）
        /// </summary>
        [Route("GetListByCorpID@V1.0")]
        [HttpGet]
        public List<FlowMeterLogicDto> GetListByCorpID([FromQuery][Required] CorpIDInput input)
        {
            var corpId = input.CorpID;
            var cacheKey = $"Dma_FlowMeter_Logic_GetListByCorpID_{corpId}";

            var vmList = MemoryCacheHelper.GetSet(cacheKey, () =>
            {
                var siteList=new Service.DmaSite().GetByCorpID(corpId);
                if (siteList == null || siteList.Count < 1)
                    return default;
                var serviceBinding = new Service.DmaSiteBinding();
                var serviceProduct = new Service.Product();
                var serviceManu = new Service.Manufacturer();
                var serviceMapping = new Service.DmaSiteMapping();
                var serviceDma = new Service.DmaArea();
                var vmCacheList = new List<FlowMeterLogicDto>();
                foreach (var site in siteList)
                {
                    var binding = serviceBinding.GetUseByDmaSiteID(site.CorpID, site.ID);
                    if (binding == null)
                        continue;
                    var product = serviceProduct.GetByID(binding.CorpID, binding.FlowMeterID);
                    if (product == null)
                        continue;
                    var manu = serviceManu.GetByID(product.CorpID,product.ManufacturerID);
                    var vm = new FlowMeterLogicDto(product,manu?.Name);
                    vmCacheList.Add(vm);
                    var mappingList = serviceMapping.GetByDmaSiteID(site.CorpID,site.ID);
                    if (mappingList != null && mappingList.Count > 0)
                    {
                        var flowIn = mappingList.Find(t=>t.Direction==Model.eDmaDirection.FlowIn);
                        if (flowIn != null)
                        {
                            var flowInDma = serviceDma.GetByID(flowIn.CorpID,flowIn.DmaAreaID);
                            vm.FlowIn = flowInDma?.Name;
                        }
                        var flowOut = mappingList.Find(t=>t.Direction==Model.eDmaDirection.FlowOut);
                        if (flowOut != null)
                        {
                            var flowOutDma = serviceDma.GetByID(flowOut.CorpID, flowOut.DmaAreaID);
                            vm.FlowOut = flowOutDma?.Name;
                        }
                    }
                }
                return vmCacheList;
            }, CacheHelper.CacheLevel2);

            return vmList;
        }



    }
}