using Apache.NMS;
|
using Apache.NMS.ActiveMQ;
|
using Tiger.Model;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Rhea.Common;
|
using Microsoft.Extensions.Configuration;
|
using Tiger.IBusiness;
|
using Autofac;
|
|
namespace Tiger.Business
|
{
|
public partial class Biz : IBiz
|
{
|
/// <summary>
|
/// 数据源
|
/// </summary>
|
public static DataSource DataSource { get => DataSource.CreateInstance(BizConfig.Configuration); }
|
|
|
/// <summary>
|
/// 主数据库客户端
|
/// </summary>
|
public static DbClient Db { get =>ApiConfig.IsTestServer? DataSource["Test"]?.Client: DataSource["Main"]?.Client; }
|
|
/// <summary>
|
/// 主数据库基础方法
|
/// </summary>
|
public static DbBase Base { get => ApiConfig.IsTestServer ? DataSource["Test"]?.Base: DataSource["Main"]?.Base; }
|
|
#region 产品数据库
|
|
#endregion
|
|
/// <summary>
|
/// 根据数据库名获取数据库对象
|
/// </summary>
|
/// <param name="name">配置文件中的数据库名</param>
|
/// <returns></returns>
|
public DbClient DB(string name = "")
|
{
|
if (name.IsNullOrEmpty())
|
{
|
return Db;
|
}
|
else
|
{
|
return DataSource[name]?.Client;
|
}
|
}
|
|
/// <summary>
|
/// 根据数据库名获取数据库基础方法
|
/// </summary>
|
/// <param name="name">配置文件中的数据库名</param>
|
/// <returns></returns>
|
public IDbBase DbBase(string name = "")
|
{
|
if (name.IsNullOrEmpty())
|
{
|
return Base;
|
}
|
else
|
{
|
return DataSource[name]?.Base;
|
}
|
}
|
|
public void SetContainer(IContainer container)
|
{
|
BizContext.Container = container;
|
}
|
}//endClass
|
}
|
