using DS.WMS.Core.TaskInteraction.Dtos;
using DS.WMS.Core.TaskInteraction.Interface;
using SqlSugar;

namespace DS.WMS.Core.TaskInteraction.Method.DataProvider
{
    /// <summary>
    /// 默认数据库提供程序
    /// </summary>
    public class DefaultDatabaseProvider : ServiceBase, IDataProvider
    {
        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="provider"></param>
        public DefaultDatabaseProvider(IServiceProvider provider) : base(provider)
        {
        }

        /// <summary>
        /// 执行数据库查询
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        public async Task FetchDataAsync(DataFetchContext context)
        {
            SugarParameter[] sugarParams = [
                new SugarParameter(nameof(context.BusinessId), context.BusinessId, System.Data.DbType.Int64),
                new SugarParameter(nameof(context.BusinessType), context.BusinessType, System.Data.DbType.Int32),
            ];
            context.Data = await TenantDb.Ado.SqlQueryAsync<dynamic>(context.Content, sugarParams);
        }
    }
}