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 MqModelInfo : IModelInfo
    {
        /// <summary>
        /// 获取分页
        /// </summary>
        /// <param name="pageList"></param>
        /// <returns></returns>
        public async Task<ApiAction<PageAble<ModelInfo>>> GetModelInfo(PageAble<ModelInfo> pageList)
        {
            var res = new ApiAction<PageAble<ModelInfo>>();
            try
            {
                RefAsync<int> total = 0;
                pageList.data = await Biz.Db.Queryable<ModelInfo>().WhereIF(!string.IsNullOrEmpty(pageList.sqlcmd), x => x.Model.Contains(pageList.sqlcmd)).OrderBy(x => x.Model).ToPageListAsync(pageList.pageIndex, pageList.pageSize, total);
                pageList.totals = total;
            }
            catch (Exception ex)
            {
                res.CatchExceptionWithLog(ex, "获取产品信息异常");
            }
            res.Data = pageList;
            return res;
        }

        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="list"></param>
        /// <returns></returns>
        public async Task<ApiAction> SaveImportModelInfo(List<ModelInfo> 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> SaveModel(ModelInfo modelInfo)
        {
            var result = new ApiAction();
            try
            {

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