factory.go

package repos

import (
	"github.com/ixre/go2o/core/domain/interface/ad"
	"github.com/ixre/go2o/core/domain/interface/aftersales"
	"github.com/ixre/go2o/core/domain/interface/cart"
	"github.com/ixre/go2o/core/domain/interface/content"
	"github.com/ixre/go2o/core/domain/interface/delivery"
	"github.com/ixre/go2o/core/domain/interface/express"
	"github.com/ixre/go2o/core/domain/interface/item"
	"github.com/ixre/go2o/core/domain/interface/job"
	"github.com/ixre/go2o/core/domain/interface/member"
	"github.com/ixre/go2o/core/domain/interface/merchant"
	"github.com/ixre/go2o/core/domain/interface/merchant/shop"
	"github.com/ixre/go2o/core/domain/interface/merchant/user"
	"github.com/ixre/go2o/core/domain/interface/merchant/wholesaler"
	"github.com/ixre/go2o/core/domain/interface/message"
	"github.com/ixre/go2o/core/domain/interface/message/notify"
	"github.com/ixre/go2o/core/domain/interface/order"
	"github.com/ixre/go2o/core/domain/interface/payment"
	"github.com/ixre/go2o/core/domain/interface/personfinance"
	"github.com/ixre/go2o/core/domain/interface/pro_model"
	"github.com/ixre/go2o/core/domain/interface/product"
	"github.com/ixre/go2o/core/domain/interface/promotion"
	"github.com/ixre/go2o/core/domain/interface/registry"
	"github.com/ixre/go2o/core/domain/interface/shipment"
	"github.com/ixre/go2o/core/domain/interface/valueobject"
	"github.com/ixre/go2o/core/domain/interface/wallet"
	"github.com/ixre/gof/db/orm"
	"github.com/ixre/gof/storage"
)

var (
	Repo = &RepoFactory{}
)

type RepoFactory struct {
	registryRepo registry.IRegistryRepo
	proMRepo     promodel.IProductModelRepo
	valueRepo    valueobject.IValueRepo
	userRepo     user.IUserRepo
	notifyRepo   notify.INotifyRepo
	mssRepo      mss.IMssRepo

	expressRepo express.IExpressRepo
	shipRepo    shipment.IShipmentRepo
	memberRepo  member.IMemberRepo
	productRepo product.IProductRepo
	itemWsRepo  item.IItemWholesaleRepo
	catRepo     product.ICategoryRepo
	itemRepo    item.IItemRepo
	tagSaleRepo item.ISaleLabelRepo
	promRepo    promotion.IPromotionRepo

	shopRepo          shop.IShopRepo
	wholesaleRepo     wholesaler.IWholesaleRepo
	mchRepo           merchant.IMerchantRepo
	cartRepo          cart.ICartRepo
	personFinanceRepo personfinance.IPersonFinanceRepository
	deliveryRepo      delivery.IDeliveryRepo
	contentRepo       content.IArchiveRepo
	adRepo            ad.IAdRepo
	orderRepo         order.IOrderRepo
	paymentRepo       payment.IPaymentRepo
	asRepo            afterSales.IAfterSalesRepo

	walletRepo wallet.IWalletRepo
	jobRepo    job.IJobRepo
	_orm       orm.Orm
}

func (r *RepoFactory) Init(o orm.Orm, sto storage.Interface) *RepoFactory {
	r._orm = o
	Repo = r

	/** Repository **/
	r.registryRepo = NewRegistryRepo(o, sto)
	r.proMRepo = NewProModelRepo(o)
	r.valueRepo = NewValueRepo("", o, sto)
	r.userRepo = NewUserRepo(o)
	r.walletRepo = NewWalletRepo(o)
	r.notifyRepo = NewNotifyRepo(o, r.registryRepo)
	r.mssRepo = NewMssRepo(o, r.notifyRepo, r.registryRepo, r.valueRepo)
	r.expressRepo = NewExpressRepo(o, r.valueRepo)
	r.shipRepo = NewShipmentRepo(o, r.expressRepo)
	r.memberRepo = NewMemberRepo(sto, o, r.walletRepo, r.mssRepo, r.valueRepo, r.registryRepo)
	r.productRepo = NewProductRepo(o, r.proMRepo, r.valueRepo)
	r.itemWsRepo = NewItemWholesaleRepo(o)
	r.catRepo = NewCategoryRepo(o, r.proMRepo,r.registryRepo, sto)
	r.shopRepo = NewShopRepo(o, sto, r.valueRepo, r.registryRepo)
	r.itemRepo = NewGoodsItemRepo(o, r.catRepo, r.productRepo,
		r.proMRepo, r.itemWsRepo, r.expressRepo, r.registryRepo, r.shopRepo)
	r.tagSaleRepo = NewTagSaleRepo(o, r.valueRepo)
	r.promRepo = NewPromotionRepo(o, r.itemRepo, r.memberRepo)

	//afterSalesRepo := repository.NewAfterSalesRepo(_orm)
	r.wholesaleRepo = NewWholesaleRepo(o)
	r.mchRepo = NewMerchantRepo(o, sto, r.wholesaleRepo,
		r.itemRepo, r.shopRepo, r.userRepo, r.memberRepo, r.mssRepo, r.walletRepo, r.valueRepo, r.registryRepo)
	r.cartRepo = NewCartRepo(o, r.memberRepo, r.mchRepo, r.itemRepo)
	r.personFinanceRepo = NewPersonFinanceRepository(o, r.memberRepo)
	r.deliveryRepo = NewDeliverRepo(o)
	r.contentRepo = NewContentRepo(o)
	r.adRepo = NewAdvertisementRepo(o, sto)
	r.orderRepo = NewOrderRepo(sto, o, r.mchRepo, nil,
		r.productRepo, r.cartRepo, r.itemRepo, r.promRepo, r.memberRepo,
		r.deliveryRepo, r.expressRepo, r.shipRepo, r.shopRepo, r.valueRepo, r.registryRepo)
	r.paymentRepo = NewPaymentRepo(sto, o, r.memberRepo, r.orderRepo, r.registryRepo)
	r.asRepo = NewAfterSalesRepo(o, r.orderRepo, r.memberRepo, r.paymentRepo)
	r.jobRepo = NewJobRepository(o, sto)

	// 解决依赖
	r.orderRepo.(*OrderRepImpl).SetPaymentRepo(r.paymentRepo)
	// 初始化数据
	r.memberRepo.GetManager().GetAllBuyerGroups()
	return r
}

func (r *RepoFactory) GetOrm() orm.Orm {
	return r._orm
}

func (r *RepoFactory) GetProModelRepo() promodel.IProductModelRepo {
	return r.proMRepo
}

func (r *RepoFactory) GetValueRepo() valueobject.IValueRepo {
	return r.valueRepo
}
func (r *RepoFactory) GetUserRepo() user.IUserRepo {
	return r.userRepo
}
func (r *RepoFactory) GetNotifyRepo() notify.INotifyRepo {
	return r.notifyRepo
}
func (r *RepoFactory) GetMssRepo() mss.IMssRepo {
	return r.mssRepo
}
func (r *RepoFactory) GetExpressRepo() express.IExpressRepo {
	return r.expressRepo
}
func (r *RepoFactory) GetShipmentRepo() shipment.IShipmentRepo {
	return r.shipRepo
}
func (r *RepoFactory) GetMemberRepo() member.IMemberRepo {
	return r.memberRepo
}
func (r *RepoFactory) GetProductRepo() product.IProductRepo {
	return r.productRepo
}
func (r *RepoFactory) GetItemWholesaleRepo() item.IItemWholesaleRepo {
	return r.itemWsRepo
}
func (r *RepoFactory) GetCategoryRepo() product.ICategoryRepo {
	return r.catRepo
}
func (r *RepoFactory) GetItemRepo() item.IItemRepo {
	return r.itemRepo
}
func (r *RepoFactory) GetSaleLabelRepo() item.ISaleLabelRepo {
	return r.tagSaleRepo
}
func (r *RepoFactory) GetPromotionRepo() promotion.IPromotionRepo {
	return r.promRepo
}
func (r *RepoFactory) GetShopRepo() shop.IShopRepo {
	return r.shopRepo
}
func (r *RepoFactory) GetWholesaleRepo() wholesaler.IWholesaleRepo {
	return r.wholesaleRepo
}
func (r *RepoFactory) GetMerchantRepo() merchant.IMerchantRepo {
	return r.mchRepo
}
func (r *RepoFactory) GetCartRepo() cart.ICartRepo {
	return r.cartRepo
}
func (r *RepoFactory) GetPersonFinanceRepository() personfinance.IPersonFinanceRepository {
	return r.personFinanceRepo
}
func (r *RepoFactory) GetDeliveryRepo() delivery.IDeliveryRepo {
	return r.deliveryRepo
}
func (r *RepoFactory) GetContentRepo() content.IArchiveRepo {
	return r.contentRepo
}
func (r *RepoFactory) GetAdRepo() ad.IAdRepo {
	return r.adRepo
}
func (r *RepoFactory) GetOrderRepo() order.IOrderRepo {
	return r.orderRepo
}
func (r *RepoFactory) GetPaymentRepo() payment.IPaymentRepo {
	return r.paymentRepo
}
func (r *RepoFactory) GetAfterSalesRepo() afterSales.IAfterSalesRepo {
	return r.asRepo
}
func (r *RepoFactory) GetWalletRepo() wallet.IWalletRepo {
	return r.walletRepo
}

func (r *RepoFactory) GetRegistryRepo() registry.IRegistryRepo {
	return r.registryRepo
}

func (r *RepoFactory) GetJobRepo() job.IJobRepo {
	return r.jobRepo
}