京东商城订单初测试

business/jxstore/misc/misc.go

@@ -261,6 +261,8 @@ func Init() {
 		}, []string{
 			"04:05:06",
 		})
+		ScheduleTimerFuncByInterval(func() {
+		}, 5*time.Second, 5*time.Minute)
 	}
 	if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieExdTOKEN", model.ConfigTypeCookie, ""); err == nil {
 		ebaiStorePageCookieExdTOKEN = configs[0].Value

business/partner/purchase/jdshop/order.go

@@ -1,8 +1,11 @@
 package jdshop
 
 import (
+	"git.rosy.net.cn/baseapi/platformapi/jdshopapi"
+	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/business/model"
+	"git.rosy.net.cn/jx-callback/globals/api"
 )
 
 func (p *PurchaseHandler) AcceptOrRefuseFailedGetOrder(ctx *jxcontext.Context, order *model.GoodsOrder, isAcceptIt bool) (err error) {
@@ -10,10 +13,21 @@ func (p *PurchaseHandler) AcceptOrRefuseFailedGetOrder(ctx *jxcontext.Context, o
 }
 
 func (p *PurchaseHandler) Map2Order(orderData map[string]interface{}) (order *model.GoodsOrder) {
+	result := &jdshopapi.AllOrdersResult{}
+	utils.Map2StructByJson(orderData, &result, false)
+	jdsOrder := result.OrderList[0]
+	order = &model.GoodsOrder{
+		VendorOrderID: utils.Int64ToStr(jdsOrder.OrderID),
+	}
 	return order
 }
 func (p *PurchaseHandler) GetOrder(vendorOrgCode, vendorOrderID string) (order *model.GoodsOrder, err error) {
-	return order, err
+	resultOrders, err := api.JdShopAPI.AllOrders(&jdshopapi.AllOrdersParam{
+		OrderID:  vendorOrderID,
+		Current:  1,
+		PageSize: 1,
+	})
+	return p.Map2Order(utils.Struct2FlatMap(resultOrders)), err
 }
 func (p *PurchaseHandler) GetOrderStatus(vendorOrgCode, vendorOrderID string) (status int, err error) {
 	return status, err
@@ -74,3 +88,7 @@ func (p *PurchaseHandler) AgreeOrRefuseRefund(ctx *jxcontext.Context, order *mod
 func (p *PurchaseHandler) ConfirmReceivedReturnGoods(ctx *jxcontext.Context, order *model.AfsOrder) (err error) {
 	return err
 }
+
+func GetJdsOrder(ctx *jxcontext.Context, vendorOrderID string) {
+
+}