using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;

namespace Tiger.Business.MengQi
{
    /// <summary>
    /// 客户
    /// </summary>
    public partial class MqCustomer : ICustomer
    {
        /// <summary>
        /// 获取分页
        /// </summary>
        /// <param name="pageList"></param>
        /// <returns></returns>
        public async Task<ApiAction<PageAble<Customer>>> GetCustomers(PageAble<Customer> pageList)
        {
            var res = new ApiAction<PageAble<Customer>>();
            try
            {
                RefAsync<int> total = 0;
                pageList.data = await Biz.Db.Queryable<Customer>().WhereIF(!string.IsNullOrEmpty(pageList.sqlcmd), x => x.CustomerCode.Contains(pageList.sqlcmd)).OrderBy(x => x.CustomerCode).ToPageListAsync(pageList.pageIndex, pageList.pageSize, total);
                pageList.totals = total;
            }
            catch (Exception ex)
            {
                res.CatchExceptionWithLog(ex, "获取客户信息异常");
            }
            res.Data = pageList;
            return res;
        }

        /// <summary>
        /// 获取客户信息
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction<List<Customer>>> GetCustomerInfo()
        {
            var res = new ApiAction<List<Customer>>();
            try
            {
                List<Customer> result = await Biz.Db.Queryable<Customer>().ToListAsync();
                res.Data = result;
            }
            catch (Exception ex)
            {
                res.CatchExceptionWithLog(ex, "获取客户信息异常");
            }
            return res;
        }

        public async Task<ApiAction> SaveImportCustomerInfo(List<Customer> list)
        {
            var res = new ApiAction();
            //更新客户记录
            var db = Biz.Db;
            var dbTran = await db.UseTranAsync(async () =>
            {
                await db.Saveable(list).ExecuteCommandAsync();
            });
            if (!dbTran.IsSuccess)
            {
                res.IsSuccessed = false;
                res.Message = $"导入异常";
            }
            return res;
        }

        /// <summary>
        /// 保存客户
        /// </summary>
        /// <param name="user"></param>
        /// <returns></returns>
        public async Task<ApiAction> SaveCustomer(Customer customer)
        {
            var result = new ApiAction();
            try
            {

                var db = Biz.Db;
                var dbTran = db.UseTran(() =>
                {
                    var y = db.Storageable(customer)
                       .WhereColumns(t => new { t.CustomerCode })
                       .ToStorage();
                    y.AsInsertable.ExecuteCommand();
                    y.AsUpdateable.ExecuteCommand();
                });
                if (!dbTran.IsSuccess)
                {
                    result.IsSuccessed = false;
                    result.Message = $"导入异常";
                }
            }
            catch (Exception ex)
            {
                result.CatchExceptionWithLog(ex, "保存客户异常");
            }
            return result;
        }
    }
}