using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Tiger.Business.SqlSugarHepler
{
    /// <summary>
    ///
    /// </summary>
    public class BizSqlsugar
    {
        #region 私有变量

        /// <summary>
        /// 最大插入数
        /// </summary>
        private const int MaxCount = 1000;

        /// <summary>
        /// T100接口URL
        /// </summary>
        public static string t100Url { get; set; } = @"http://172.18.8.11/wstopprd/ws/r/awsp920";

        #endregion 私有变量

        /// <summary>
        /// 循环插入
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="input"></param>
        /// <param name="db"></param>
        public static int InsertDataTable<T>(List<T> input, DbClient db) where T : class, new()
        {
            int count = input.Count();
            int result = 0;
            if (input.Count() > MaxCount)
            {
                int round = (count / MaxCount) + ((count % MaxCount) > 0 ? 1 : 0);
                List<T> addLst = new List<T>();
                for (int i = 0; i < round; i++)
                {
                    int start = i * MaxCount;
                    int end = i == (round - 1) ? count : (start + MaxCount);
                    for (int j = start; j < end; j++)
                    {
                        addLst.Add(input[j]);
                    }
                    result += db.Fastest<T>().BulkCopy(addLst);
                    addLst.Clear();
                }
            }
            else
            {
                //result += db.Insertable(input).ExecuteCommand();
                result += db.Fastest<T>().BulkCopy(input);
            }
            return result;
        }

        /// <summary>
        /// 循环更新
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="input"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        public static int UpdateDataTable<T>(List<T> input, DbClient db) where T : class, new()
        {
            int res = 0;
            foreach (var item in input)
            {
                res += db.Updateable(item).ExecuteCommand();
            }
            return res;
        }

        #region 事务

        /// <summary>
        /// 同步事务
        /// </summary>
        /// <param name="action"></param>
        /// <exception cref="Exception"></exception>
        /// <exception cref="BizException"></exception>
        public static void CreateTran(Action<ISqlSugarClient> action, DbClient _dbContext)
        {
            if (action == null)
            {
                throw new Exception("方法CreateTran的参数不能为空！");
            }
            string bizErrorMsg = string.Empty;
            Exception error = null;
            var res = _dbContext.Ado.UseTran(() =>
            {
                try
                {
                    action.Invoke(_dbContext);
                    _dbContext.Ado.CommitTran();
                }
                catch (Exception ex)
                {
                    _dbContext.Ado.RollbackTran();
                    if (ex is Exception)
                    {
                        bizErrorMsg = ex.Message;
                    }
                    else
                    {
                        error = ex;
                    }
                }
                finally
                {
                    _dbContext.Ado.Close();
                }
            });

            if (!string.IsNullOrWhiteSpace(bizErrorMsg))
            {
                throw new Exception(bizErrorMsg);
            }
            if (error != null)
            {
                throw error;
            }
            if (!res.IsSuccess)
            {
                throw new Exception(res.ErrorMessage);
            }
        }

        /// <summary>
        /// 同步事务
        /// </summary>
        /// <param name="action"></param>
        /// <param name="_dbContext"></param>
        /// <exception cref="Exception"></exception>
        public static void CreateTran(Action action, DbClient _dbContext)
        {
            if (action == null)
            {
                throw new Exception("方法CreateTran的参数不能为空！");
            }
            string bizErrorMsg = string.Empty;
            Exception error = null;
            var res = _dbContext.Ado.UseTran(() =>
            {
                try
                {
                    action.Invoke();
                    _dbContext.Ado.CommitTran();
                }
                catch (Exception ex)
                {
                    _dbContext.Ado.RollbackTran();
                    if (ex is Exception)
                    {
                        bizErrorMsg = ex.Message;
                    }
                    else
                    {
                        error = ex;
                    }
                }
                finally
                {
                    _dbContext.Ado.Close();
                }
            });
            if (!string.IsNullOrWhiteSpace(bizErrorMsg))
            {
                throw new Exception(bizErrorMsg);
            }
            if (error != null)
            {
                throw error;
            }
            if (!res.IsSuccess)
            {
                throw new Exception(res.ErrorMessage);
            }
        }

        /// <summary>
        /// 同步带返回类型的事务
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="action"></param>
        /// <param name="_dbContext"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public static T CreateTran<T>(Func<T> action, DbClient _dbContext)
        {
            if (action == null)
            {
                throw new Exception("方法CreateTran的参数不能为空！");
            }
            var res = _dbContext.Ado.UseTran(() =>
            {
                return action.Invoke();
            }, (exception) =>
            {
                throw exception;
            });
            if (!res.IsSuccess)
            {
                throw new Exception(res.ErrorMessage);
            }
            return res.Data;
        }

        /// <summary>
        /// 异步带返回类型的事务
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="action"></param>
        /// <param name="_dbContext"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public static async Task<T> CreateTranAsync<T>(Func<T> action, DbClient _dbContext)
        {
            if (action == null)
            {
                throw new Exception("方法CreateTran的参数不能为空！");
            }
            var res = await _dbContext.Ado.UseTranAsync(() =>
            {
                return Task.FromResult(action.Invoke());
            }, (exception) =>
            {
                throw exception;
            });
            if (!res.IsSuccess)
            {
                throw new Exception(res.ErrorMessage);
            }
            return res.Data;
        }

        #endregion 事务
    }
}