using System;
using System.Linq;
using System.Threading.Tasks;
using Aliyun.Api.LogService;
using Aliyun.Api.LogService.Domain;
using Aliyun.Api.LogService.Domain.Log;
using Aliyun.Api.LogService.Infrastructure.Protocol;

namespace HDL_ON.Common.AliyunLog
{
	public class AliyunLogInvokeAsync
	{
		public AliyunLogInvokeAsync()
		{
		}

        /// <summary>
        /// 执行请求方法。
        /// </summary>
        public static async Task<GetLogsResult> Invoke(ILogServiceClient client)
        {
            var response = await client.GetLogsAsync
            (
                // 「必填参数」会在 Request 构造器中列出，并且不可set；
                new GetLogsRequest("example-logstore", (Int32)DateTimeOffset.UtcNow.AddDays(-1).ToUnixTimeSeconds(), (Int32)DateTimeOffset.UtcNow.ToUnixTimeSeconds())
                {
                    // 「可选参数」不会在 Request 构造器中列出，可通过setter设置。
                    Offset = 1,
                    Line = 100,
                }
            );

            var result = response
                // 此方法会确保返回的响应失败时候抛出`LogServiceException`。
                .EnsureSuccess()
                // 此处获取Result是安全的。
                .Result;

            Console.WriteLine($"RequestId：{response.RequestId}");
            Console.WriteLine($"日志总数：{result.Count}");
            Console.WriteLine($"首条日志：{result.Logs.FirstOrDefault()}");

            return result;
        }

        /// <summary>
        /// 在调用时可使用扩展方法，扩展方法会将简单的请求对象的属性展开到方法入参中。
        /// 使用扩展方法 `using Aliyun.Api.Log;` 即可。
        /// </summary>
        public static async Task<GetLogsResult> InvokeUsingExtension(ILogServiceClient client)
        {
            var response = await client.GetLogsAsync
            (
                // 「必填参数」作为方法的普通必须参数
                "example-logstore",
                DateTimeOffset.UtcNow.AddDays(-1),
                DateTimeOffset.UtcNow,

                // 「可选参数」作为方法的可选参数，可通过命名参数方式指定
                offset: 1,
                line: 10
            );

            var result = response
                // 此方法会确保返回的响应失败时候抛出`LogServiceException`。
                .EnsureSuccess()
                // 此处获取Result是安全的。
                .Result;

            Console.WriteLine($"RequestId：{response.RequestId}");
            Console.WriteLine($"日志总数：{result.Count}");
            Console.WriteLine($"首条日志：{result.Logs.FirstOrDefault()}");

            return result;
        }

        /// <summary>
        /// 处理服务器返回（包含在Response中）的错误。
        /// </summary>
        public static async Task<GetLogsResult> InvokeWithErrorHandling(ILogServiceClient client)
        {
            var response = await client.GetLogsAsync
            (
                // 「必填参数」作为方法的普通必须参数
                "example-logstore",
                DateTimeOffset.UtcNow.AddDays(-1),
                DateTimeOffset.UtcNow,

                // 「可选参数」作为方法的可选参数，可通过命名参数方式指定
                offset: 1,
                line: 10
            );

            GetLogsResult result;
            // 尝试处理可处理的错误。
            if (!response.IsSuccess)
            {
                // 错误码
                var errorCode = response.Error.ErrorCode;
                // 错误消息
                var errorMessage = response.Error.ErrorMessage;

                Console.WriteLine($"RequestId：{response.RequestId}");
                Console.WriteLine($"错误码：{errorCode}");
                Console.WriteLine($"错误信息：{errorMessage}");

                // `ErrorCode`类可支持与自身实例或字符串进行对比。
                if (errorCode == ErrorCode.SignatureNotMatch /* SDK中预定义的错误码 */)
                {
                    // 在这里处理业务可处理的错误。。。。。。
                    Console.WriteLine("Signature not match, {0}.", errorMessage);
                }
                else if (errorCode == "ParameterInvalid" /* 业务相关特殊的SDK中未定义的错误码 */)
                {
                    // 在这里处理业务可处理的错误。。。。。。
                    Console.WriteLine("Parameter invalid, {0}.", errorMessage);
                }

                // 任何处理不到的错误请务必抛出异常中断原流程，避免外部获取到 null 的结果！
                throw new Exception("这里可以是系统的业务异常。" + response.Error /* 最好带上服务返回的错误信息以便调试 */);
            }
            else
            {
                // 此处获取Result是安全的。
                result = response.Result;
            }

            Console.WriteLine($"RequestId：{response.RequestId}");
            Console.WriteLine($"日志总数：{result.Count}");
            Console.WriteLine($"首条日志：{result.Logs.FirstOrDefault()}");

            return result;
        }

        /// <summary>
        /// 处理以异常形式抛出的错误。
        /// </summary>
        public static async Task<GetLogsResult> InvokeWithExceptionHandling(ILogServiceClient client)
        {
            try
            {
                return await Invoke(client);
            }
            catch (LogServiceException e)
            {
                // 错误码
                var errorCode = e.ErrorCode;
                // 错误消息
                var errorMessage = e.ErrorMessage;

                Console.WriteLine($"RequestId：{e.RequestId}");
                Console.WriteLine($"错误码：{errorCode}");
                Console.WriteLine($"错误信息：{errorMessage}");

                // `ErrorCode`类可支持与自身实例或字符串进行对比。
                if (errorCode == ErrorCode.SignatureNotMatch /* SDK中预定义的错误码 */)
                {
                    // 在这里处理业务可处理的错误。。。。。。
                    Console.WriteLine("Signature not match, {0}.", errorMessage);
                }
                else if (errorCode == "ParameterInvalid" /* 业务相关特殊的SDK中未定义的错误码 */)
                {
                    // 在这里处理业务可处理的错误。。。。。。
                    Console.WriteLine("Parameter invalid, {0}.", errorMessage);
                }

                // 任何处理不到的错误请务必抛出异常中断原流程，避免外部获取到 null 的结果！
                throw new Exception("这里可以是系统的业务异常。", e /* 在自定义的异常中最好带上服务返回的异常以便调试 */);
            }
        }
    }
}