using System;
using System.Collections;
using System.Collections.Concurrent;
using System.Linq.Expressions;
using System.Threading;

namespace WCS.Core
{
    /// <summary>
    /// Rdeis 数据上抛
    /// </summary>
    public static class Ltc
    {
        private static ConcurrentDictionary<Thread, string> Channels = new ConcurrentDictionary<Thread, string>();

        public static void SetChannel(string channel)
        {
            Channels[Thread.CurrentThread] = channel;
        }

        public static string GetChannel()
        {
            return Channels[Thread.CurrentThread];
        }

        public static void Log(string msg)
        {
            var channel = GetChannel();
            if (channel == "刷新")
            {
                return;
            }
            DebugPublisher.Publish(GetChannel(), msg);
        }

        private static string ResultString<T>(T obj)
        {
            if (obj == null)
            {
                return "null";
            }
            else if (obj is bool)
            {
                var b = obj as Boolean?;
                return b.Value ? "成立" : "不成立";
            }
            else if (obj is ICollection)
            {
                var coll = obj as ICollection;
                return coll.Count.ToString() + "元素";
            }

            return obj.ToString();
        }

        public static T Do<T>(Expression<Func<T>> exp)
        {
            var msg = exp.ExpToString();
            msg += "  结果:";
            try
            {
                var res = exp.Compile().Invoke();

                return res;
            }
            catch (Exception ex)
            {
                msg += ex.GetBaseException().Message;
                throw;
            }
            finally
            {
                Log(msg);
            }
        }

        /// <summary>
        ///  判断执行条件是否有效
        /// </summary>
        /// <typeparam name="T1"></typeparam>
        /// <typeparam name="T"></typeparam>
        /// <param name="obj">表达式需要用到的传参</param>
        /// <param name="exp">表达式</param>
        /// <param name="message">焦点</param>
        /// <param name="errorMessage"></param>
        /// <returns></returns>
        public static T Do<T1, T>(T1 obj, Expression<Func<T1, T>> exp,string message,string errorMessage)
        {
            var msg = "";
            try
            {
                try
                {
                    msg = exp.ExpToString();
                }
                catch (Exception)
                {
                    //TODO：日志记录
                }
                msg += "  结果:";
                var res = exp.Compile().Invoke(obj);
                msg += ResultString(res);
                return res;
            }
            catch (Exception ex)
            {
                msg += ex.GetBaseException().Message;
                throw;
            }
            finally
            {
                Log(msg);
            }
        }

        public static T Do<T1, T2, T>(T1 obj, T2 obj2, Expression<Func<T1, T2, T>> exp)
        {
            var msg = exp.ExpToString();
            msg += "  结果:";
            try
            {
                var res = exp.Compile().Invoke(obj, obj2);
                msg += ResultString(res);
                return res;
            }
            catch (Exception ex)
            {
                msg += ex.GetBaseException().Message;
                throw;
            }
            finally
            {
                Log(msg);
            }
        }

        public static T Do<T1, T2, T3, T>(T1 obj, T2 obj2, T3 obj3, Expression<Func<T1, T2, T3, T>> exp)
        {
            var msg = exp.ExpToString();
            msg += "  结果:";
            try
            {
                var res = exp.Compile().Invoke(obj, obj2, obj3);
                msg += ResultString(res);
                return res;
            }
            catch (Exception ex)
            {
                msg += ex.GetBaseException().Message;
                throw;
            }
            finally
            {
                Log(msg);
            }
        }
    }
}