using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.Entities.OP;
using APT.BaseData.Domain.Enums.OP;
using APT.BaseData.Domain.IServices.OP;
using APT.Infrastructure.Api;
using APT.Infrastructure.Core;
using APT.Migrations;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Net;

namespace APT.BaseData.Services.Services.OP
{
    public class OPTenantDBConnService : CommonService, IOPTenantDBConnService
    {
        public OPTenantDBConnService(IRepository repository) : base(repository)
        {
        }

        /// <summary>
        /// 获取 除 ORG_IDBeside 之外对应的数据库链接字典  ORG_ID  DB_CONN
        /// </summary>
        /// <param name="ORG_IDBeside"></param>
        /// <returns></returns>
        public Dictionary<Guid, string> GetConnDictionary(Guid? ORG_IDBeside)
        {
            Dictionary<Guid, string> dicORGCONN = new Dictionary<Guid, string>();
            string conn = string.Empty;
            IEnumerable<T_OP_TENANT> listTent = null;
            using (var context = new MigrationContext())
            {
                Expression<Func<T_OP_TENANT, bool>> expression = e => e.DB_CONN_ID.HasValue;
                if (ORG_IDBeside.HasValue)
                {
                    expression = expression.And(e => e.ID != ORG_IDBeside);
                }

                listTent = context.GetEntities(expression, null, null);
                List<Guid> listConnID = listTent.Select(e => e.DB_CONN_ID.Value).ToList();
                var listDbConn = context.GetEntities<T_OP_TENANT_DB_CONN>(e => listConnID.Contains(e.ID), null, null);
                if (listDbConn != null && listDbConn.Count() > 0)
                {
                    var env = ConfigurationManager.AppSettings["Env"];
                    foreach (var item in listDbConn)
                    {
                        conn = item.DB_CONN;
                        if (env == ((int)EnvType.外网).ToString())
                        {
                            conn = item.DB_CONN_WAN;
                        }
                        if (!dicORGCONN.ContainsKey(item.ID))
                        {
                            dicORGCONN.Add(listTent.First(e => e.DB_CONN_ID == item.ID).ID, conn);
                        }
                    }
                }
            }
            return dicORGCONN;
        }
    }
}