using Grpc.Core;
using HotelPms.Data;
using HotelPms.Data.UseInfo;
using HotelPms.GrpcService.Util;
using HotelPms.Share.Data;
using HotelPms.Share.IO;
using HotelPms.Share.Util;

namespace HotelPms.GrpcService
{
    /// <summary>
    /// ■攻略
    /// 1.Use.proto(message：Use、UseTable;Service：UseCore) ⇒ projectファイルのInclude
    /// 2.Use.cs(両方)
    /// 3.UseTable.cs(両方)
    /// 4.UseService.cs(サーバー側) ⇒　StartupでMapGrpcServiceの処理が必要
    /// 5.UseAccess.cs(クライアント側)
    /// </summary>
    public class UseService : UseCore.UseCoreBase
    {
        #region  ★★★★★　Declartions　★★★★★

        private static string TableName = "D_Use";
        private readonly ILogger<UseService> _logger;
        private IConfiguration m_Configuration;

        #endregion

        #region  ★★★★★　Property　★★★★★
        #endregion

        #region  ★★★★★　Class Event　★★★★★

        public UseService(ILogger<UseService> logger, IConfiguration configuration)
        {
            _logger = logger;
            m_Configuration = configuration;
        }

        #endregion

        #region  ★★★★★　Private Function　★★★★★

        /// <summary>
        /// 利用情報取得
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        private Use? Get(DataRequest request)
        {
            try
            {                
                OperationLog.Instance.WriteLog($"データ請求：{request.ToString()}");
                using MsSqlNet msSqlNet = new(Setting.HotelPmsDB);
                Use? item = Use.Get(CConvert.ToInt(request.Data), msSqlNet);
                OperationLog.Instance.WriteLog("データ読込完了");
                return item;
            }
            catch(Exception ex)
            {
                OperationLog.Instance.WriteLog($"UseService.Get({request.Data})：{ex.Message}");
                return null; 
            }    
        }

        /// <summary>
        /// 利用データ更新
        /// </summary>
        /// <param name="use"></param>
        /// <returns></returns>
        private DataResult Set(Use use)
        {
            DataResult result = new() { ErrNo = 0, ErrData = string.Empty };
            try
            {
                OperationLog.Instance.WriteLog($"■利用情報保存開始：{use.ID}");

                string sql = use.ToSql();
                OperationLog.Instance.WriteLog($"利用情報保存Sql生成：{sql}");

                using MsSqlNet msSqlNet = new(Setting.HotelPmsDB);
                if (!msSqlNet.ExecuteNonQueryWithTran(sql))
                {
                    result.ErrNo = msSqlNet.ErrNo;
                    result.ErrData = msSqlNet.ErrInfo;
                }
                OperationLog.Instance.WriteLog($"利用情報保存結果：{result.ErrNo}.{result.ErrData}");

                //非同期実行
                if (result.ErrNo == 0)
                {
                    Task.Run(() =>
                    {
                        OperationLog.Instance.WriteLog($"非同期更新：{use.ID}");
                        using MsSqlNet msSqlNet = new(Setting.HotelPmsDB);
                        int cnt = msSqlNet.ExecuteNonQuery($"EXECUTE SaveUseAfterAsync {use.ID}");
                        OperationLog.Instance.WriteLog($"非同期更新結果：{cnt},ErrNo：{msSqlNet.ErrNo},ErrInfo：{msSqlNet.ErrInfo}");
                    });
                }                
            }
            catch(Exception ex)
            {
                OperationLog.Instance.WriteLog($"UseService.Set()：{ex.Message}");
                result.ErrNo = 999999;
                result.ErrData = ex.Message;
            }
            return result;
        }

        #endregion

        #region  ★★★★★　Public  Function　★★★★★

        /// <summary>
        /// 同期実行
        /// </summary>
        /// <param name="request"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        public override Task<Use?> GetData(DataRequest request, ServerCallContext context)
        {
            return Task.FromResult(Get(request));
        }

        public async override Task GetDataStream(IAsyncStreamReader<DataRequest> requestStream, IServerStreamWriter<Use> responseStream, ServerCallContext context)
        {
            DataRequest request = null;
            await foreach (var message in requestStream.ReadAllAsync())
            {
                request = message;
                break;
            }
            Use? use = Get(request);
            await responseStream.WriteAsync(use);  //データ送信
        }

        public override Task<DataResult> SetData(Use request, ServerCallContext context)
        {
            return Task.FromResult(Set(request));
        }

        public async override Task SetDataStream(IAsyncStreamReader<Use> requestStream, IServerStreamWriter<DataResult> responseStream, ServerCallContext context)
        {
            Use table = null;
            await foreach (var message in requestStream.ReadAllAsync())
            {
                table = message;
                break;
            }

            DataResult result = Set(table);
            //データ送信
            await responseStream.WriteAsync(result);
        }

        #endregion
    }
}