From 69d6ce134ac8e01195d539c11520fa482fc8116a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Fri, 20 Mar 2020 14:19:02 +0800
Subject: [PATCH] =?UTF-8?q?=E9=93=B6=E8=B1=B9partner?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/partner/purchase/yb/store_sku.go | 16 ++++++
 business/partner/purchase/yb/yb.go        | 63 +++++++++++++++++++++++
 globals/api/api.go                        | 10 ++--
 3 files changed, 84 insertions(+), 5 deletions(-)
 create mode 100644 business/partner/purchase/yb/store_sku.go
 create mode 100644 business/partner/purchase/yb/yb.go

diff --git a/business/partner/purchase/yb/store_sku.go b/business/partner/purchase/yb/store_sku.go
new file mode 100644
index 000000000..1334d3aa9
--- /dev/null
+++ b/business/partner/purchase/yb/store_sku.go
@@ -0,0 +1,16 @@
+package yb
+
+import (
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
+	"git.rosy.net.cn/jx-callback/business/partner"
+)
+
+func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
+
+	return failedList, err
+}
+
+func (p *PurchaseHandler) UpdateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
+	return failedList, err
+}
diff --git a/business/partner/purchase/yb/yb.go b/business/partner/purchase/yb/yb.go
new file mode 100644
index 000000000..5fe7705da
--- /dev/null
+++ b/business/partner/purchase/yb/yb.go
@@ -0,0 +1,63 @@
+package yb
+
+import (
+	"sync"
+
+	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
+	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/business/partner"
+	"git.rosy.net.cn/jx-callback/business/partner/putils"
+	"git.rosy.net.cn/jx-callback/globals/api"
+)
+
+var (
+	CurPurchaseHandler *PurchaseHandler
+)
+
+type PurchaseHandler struct {
+	partner.BasePurchasePlatform
+	putils.DefSingleStorePlatform
+
+	locker sync.RWMutex
+}
+
+func init() {
+	if api.YinBaoAPI != nil {
+		CurPurchaseHandler = New()
+		partner.RegisterPurchasePlatform(CurPurchaseHandler)
+	}
+}
+
+func New() (obj *PurchaseHandler) {
+	obj = new(PurchaseHandler)
+	obj.ISingleStoreStoreSkuHandler = obj
+	return obj
+}
+
+func (p *PurchaseHandler) GetVendorID() int {
+	return model.VendorIDYB
+}
+
+func (p *PurchaseHandler) AcceptOrRefuseFailedGetOrder(ctx *jxcontext.Context, order *model.GoodsOrder, isAcceptIt bool) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) AcceptOrRefuseOrder(order *model.GoodsOrder, isAcceptIt bool, userName string) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) AdjustOrder(ctx *jxcontext.Context, order *model.GoodsOrder, removedSkuList []*model.OrderSku, reason string) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) AgreeOrRefuseCancel(ctx *jxcontext.Context, order *model.GoodsOrder, isAgree bool, reason string) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) CancelOrder(ctx *jxcontext.Context, order *model.GoodsOrder, reason string) (err error) {
+	return err
+}
+
+func (c *PurchaseHandler) AgreeOrRefuseRefund(ctx *jxcontext.Context, order *model.AfsOrder, approveType int, reason string) (err error) {
+	return err
+}
diff --git a/globals/api/api.go b/globals/api/api.go
index e47c0c46d..5edcafe87 100644
--- a/globals/api/api.go
+++ b/globals/api/api.go
@@ -159,11 +159,11 @@ func Init() {
 		Ebai2API = nil
 	}
 
-	// if !beego.AppConfig.DefaultBool("disableYb", false) {
-	// 	YinBaoAPI = yinbaoapi.New(beego.AppConfig.String("yinbaoAppKey"), beego.AppConfig.String("yinbaoAppID"))
-	// } else {
-	// 	YinBaoAPI = nil
-	// }
+	if !beego.AppConfig.DefaultBool("disableYb", false) {
+		YinBaoAPI = yinbaoapi.New(beego.AppConfig.String("yinbaoAppKey"), beego.AppConfig.String("yinbaoAppID"))
+	} else {
+		YinBaoAPI = nil
+	}
 
 	if !beego.AppConfig.DefaultBool("disableMtps", false) {
 		MtpsAPI = mtpsapi.New(beego.AppConfig.String("mtpsAppKey"), beego.AppConfig.String("mtpsSecret"))