using HotelPms.Data.Common;
using HotelPms.Share.Util;
using Grpc.Core;
using Grpc.Net.Client;
using System;
using System.Threading.Tasks;

namespace HotelPms.Data.Client
{
    public class GrpcClient
    {
        /// <summary>
        /// データ要求生成
        /// </summary>
        /// <param name="actionType"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static DataRequest CreateDataRequest(int actionType, string data)
        {
            return new DataRequest
            {
                ActionType = actionType,
                Data = data,
                CustomerID = "001",
                LoginID = "sa",
                Password = "123",
                SystemID = 1,
                RefTables = string.Empty,
                IP = "127.0.0.1",
                MachineName = Environment.MachineName,
                OS = Environment.OSVersion.ToString()
            };
        }

        /// <summary>
        /// TableのgRPCクライアント
        /// </summary>
        /// <param name="channel"></param>
        /// <returns></returns>
        public static GrpcTableCore.GrpcTableCoreClient CreateTableClient(GrpcChannel channel)
        {
            return new GrpcTableCore.GrpcTableCoreClient(channel);
        }

        public static async Task<GrpcTable> GetTableAsync(GrpcChannel channel, int actionType, string data)
        {
            GrpcTableCore.GrpcTableCoreClient client = CreateTableClient(channel);
            return await client.GetDataAsync(CreateDataRequest(actionType, data));
        }

        /// <summary>
        /// TableのgRPCクライアント
        /// </summary>
        /// <param name="client"></param>
        /// <param name="actionType"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static GrpcTable GetTable(GrpcChannel channel, int actionType, string data)
        {
            GrpcTableCore.GrpcTableCoreClient client = CreateTableClient(channel);
            return client.GetData(CreateDataRequest(actionType, data));
        }

        /// <summary>
        /// 自由SQL発行
        /// </summary>
        /// <param name="client"></param>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static GrpcTable GetTable(GrpcChannel channel, string sql)
        {
            return GetTable(channel, (int)ETableActionType.CustomSql, sql);
        }

        /// <summary>
        /// 0行、0列の値を返す（同期）
        /// </summary>
        /// <param name="channel"></param>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static string ExecuteScalarSync(GrpcChannel channel, string sql)
        {
            GrpcTable table = GetTable(channel, sql);
            if (table.ErrNo != 0) { return string.Empty; }
            return CConvert.ToString(table.ToDataTable().Rows[0][0]);
        }

        /// <summary>
        /// 0行、0列の値を返す
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static async Task<string> ExecuteScalar(GrpcChannel channel, string sql)
        {
            GrpcTableCore.GrpcTableCoreClient client = CreateTableClient(channel);
            GrpcTable table = await client.GetDataAsync(CreateDataRequest((int)ETableActionType.CustomSql, sql));
            if (table.ErrNo != 0) { return string.Empty; }
            return CConvert.ToString(table.ToDataTable().Rows[0][0]);
        }

        /// <summary>
        /// データの取得
        /// </summary>
        /// <param name="actionType"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static async Task<GrpcTable> GetTableStream(GrpcChannel channel, int actionType, string data)
        {
            GrpcTableCore.GrpcTableCoreClient client = CreateTableClient(channel);
            GrpcTable table = null;
            using (var call = client.GetDataStream())
            {
                await call.RequestStream.WriteAsync(CreateDataRequest(actionType, data));
                await call.RequestStream.CompleteAsync();   // Finish call and report results

                //データの取得
                await foreach (var message in call.ResponseStream.ReadAllAsync<GrpcTable>())
                {
                    table = message;
                    break;
                }
            }
            return table;
        }

        public static async Task<GrpcTable> GetTableStream(GrpcChannel channel, string sql)
        {
            return await GetTableStream(channel, (int)ETableActionType.CustomSql, sql);
        }

        /// <summary>
        /// データセットのgRPCクライアント
        /// </summary>
        /// <param name="channel"></param>
        /// <returns></returns>
        public static GrpcSetCore.GrpcSetCoreClient CreateSetClient(GrpcChannel channel)
        {
            return new GrpcSetCore.GrpcSetCoreClient(channel);
        }

        public async static Task<GrpcSet> GetGrpcSet(GrpcChannel channel, int actionType, string data)
        {
            GrpcSetCore.GrpcSetCoreClient client = CreateSetClient(channel);
            return await client.GetDataAsync(CreateDataRequest(actionType, data));
        }

        /// <summary>
        /// データセットの取得
        /// </summary>
        /// <param name="client"></param>
        /// <param name="actionType"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async static Task<GrpcSet> GetDataSet(GrpcChannel channel, int actionType, string data)
        {
            GrpcSetCore.GrpcSetCoreClient client = CreateSetClient(channel);
            GrpcSet set = null;
            using (var call = client.GetDataStream())
            {
                await call.RequestStream.WriteAsync(CreateDataRequest(actionType, data));
                await call.RequestStream.CompleteAsync();   // Finish call and report results

                //データの取得
                await foreach (var message in call.ResponseStream.ReadAllAsync<GrpcSet>())
                {
                    set = message;
                    break;
                }
            }
            return set;
        }
    }
}