using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Bro.Common.Base;
using Bro.Common.Interface;
using static Bro.Common.Helper.EnumHelper;
using PostSharp.Aspects;
//using PostSharp.Laos;

namespace Bro.Common.Helper
{
    public static class JsonHelper
    {
        public static JsonSerializerSettings JsonSetWithType = new JsonSerializerSettings() { TypeNameHandling = TypeNameHandling.All };
    }

    #region PostSharp AOP related

    /// <summary>
    /// 工序设备运行切面  用于修饰DeviceBase的SetAndRun
    /// </summary>
    [Serializable]
    public sealed class DeviceRunAspect : OnMethodBoundaryAspect
    {
        //LogHelper logHelper = new LogHelper();
        /// <summary>
        /// 设备操作前
        /// </summary>
        /// <param name="args"></param>
        public override void OnEntry(MethodExecutionArgs args)
        {
            #region 检查设备状态
            DeviceBase device = args.Instance as DeviceBase;
            if (device.CurrentState != EnumHelper.DeviceState.DSOpen)
            {
                //throw new UserException(string.Format("{0}设备不在开启状态，无法操作！", device.Name), EnumHelper.LogType.Exception_Error);

                return;
            }
            #endregion

            IOperationConfig config = args.Arguments.FirstOrDefault() as IOperationConfig;
            if (config == null)
            {
                throw new ProcessException("设备操作转入参数类型错误！", null);
            }

            if (device.DeviceMode == DeviceMode.Run)
            {
                #region 通知流程控制工序开始
                //Client.InvokeAsync("DeviceHub", "RunStart", JsonConvert.SerializeObject(config, JsonHelper.JsonSetWithType));

                //Client.InvokeAsync("DeviceHub", "RunStart", config);

                //StateMachine.OnProcessStart?.Invoke(JsonConvert.SerializeObject(config, JsonHelper.JsonSetWithType));
                //StateMachine.OnProcessStart?.Invoke(config);
                #endregion

                #region 日志操作
                //Task.Run(() =>
                //{
                //    if (!string.IsNullOrWhiteSpace(config.ProcessId))
                //    {
                //        PRC_PROCESS process = new ProcessHelper().GetProcessById(config.ProcessId);
                //        if (process != null && process.IS_LOG == 1)
                //        {
                //            LOG_INFO log = new LOG_INFO();
                //            log.LOG_TYPE = (int)LogType.Info_Process;
                //            log.LOG_TITLE = string.Format("设备名称：{0}；开始工序：{1}", device.Name, config.ProcessName);
                //            log.LOG_TIME = DateTime.Now;
                //            logHelper.NewLog("ProcessStart", log);
                //        }
                //    }
                //});
                #endregion
            }
        }

        /// <summary>
        /// 设备完成操作后
        /// </summary>
        /// <param name="args"></param>
        public override void OnSuccess(MethodExecutionArgs args)
        {
            DeviceBase device = args.Instance as DeviceBase;

            if (device.DeviceMode == DeviceMode.Run)
            {
                IOperationConfig inputConfig = args.Arguments.FirstOrDefault() as IOperationConfig;
                IOperationConfig outputConfig = args.ReturnValue as IOperationConfig;

                if (outputConfig == null)
                {
                    outputConfig = new OperationConfigCommon();
                }

                //工序编号传递
                //outputConfig.ProcessId = inputConfig.ProcessId;
                //outputConfig.ProcessName = inputConfig.ProcessName;

                #region 通知流程控制本道工序结束 开始下道工序
                //Client.InvokeAsync("DeviceHub", "RunEnd", JsonConvert.SerializeObject(outputConfig, JsonHelper.JsonSetWithType));
                //Client.InvokeAsync("DeviceHub", "RunEnd", outputConfig);
                //StateMachine.OnProcessEnd?.Invoke(JsonConvert.SerializeObject(outputConfig, JsonHelper.JsonSetWithType));
                //StateMachine.OnProcessEnd?.Invoke(outputConfig);
                #endregion

                #region 日志操作
                //Task.Run(() =>
                //{
                //    PRC_PROCESS process = new ProcessHelper().GetProcessById(inputConfig.ProcessId);
                //    if (process != null && process.IS_LOG == 1)
                //    {
                //        LOG_INFO log = new LOG_INFO();
                //        log.LOG_TYPE = (int)LogType.Info_Process;
                //        log.LOG_TITLE = string.Format("设备名称：{0}；结束工序：{1}", device.Name, inputConfig.ProcessName);
                //        log.LOG_TIME = DateTime.Now;
                //        logHelper.NewLog("ProcessEnd", log);
                //    }
                //});
                #endregion
            }
        }
    }

    /// <summary>
    /// 设备状态变动切面 主要监控设备的大状态变动
    /// </summary>
    [Serializable]
    public class DeviceStateChangedAspect : OnMethodBoundaryAspect
    {
        public override void OnSuccess(MethodExecutionArgs args)
        {
            DeviceBase device = args.Instance as DeviceBase;

            #region 通知设备的状态变动
            if (device.CurrentState != EnumHelper.DeviceState.TBD)
            {
                //device.OnDeviceStateChanged?.Invoke(device.CurrentState);
            }
            #endregion

            #region 日志操作
            #endregion
        }
    }

    [Serializable]
    public class DeviceExceptionAspect : OnMethodBoundaryAspect
    {
        public override void OnException(MethodExecutionArgs args)
        {
            DeviceBase device = args.Instance as DeviceBase;
            if (device.CurrentState != EnumHelper.DeviceState.DSExcept)
            {
                device.CurrentState = EnumHelper.DeviceState.DSExcept;
                device.CurrentStateToBe = EnumHelper.DeviceState.DSExcept;
                Exception ex = args.Exception;

                #region 通知设备的状态变动
                device.OnDeviceException?.Invoke(device, ex);
                #endregion

                #region 异常日志记录
                #endregion
            }

            args.FlowBehavior = FlowBehavior.ThrowException;
        }
    }

    [Serializable]
    public class ProcessExceptionAspect : OnExceptionAspect
    {
        public override void OnException(MethodExecutionArgs args)
        {
            //base.OnException(args);

            Exception ex = args.Exception;

            if (!(ex is ProcessException))
            {
                new ProcessException(ex);
            }

            args.FlowBehavior = FlowBehavior.Return;
        }
    }
    #endregion
}