From 493f2ba97b8609fc937d3f33f45351cff1cf4693 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 10 Mar 2021 10:10:55 +0800 Subject: [PATCH] aa --- business/jxcallback/orderman/orderman_ext.go | 14 ++++++++++---- business/jxstore/misc/misc.go | 3 --- business/jxstore/report/report.go | 20 ++++++++++++++++++-- business/partner/purchase/ebai/act.go | 5 +++++ globals/api/apimanager/apimanager.go | 4 ++++ 5 files changed, 37 insertions(+), 9 deletions(-) diff --git a/business/jxcallback/orderman/orderman_ext.go b/business/jxcallback/orderman/orderman_ext.go index b097c41ac..d081204e1 100644 --- a/business/jxcallback/orderman/orderman_ext.go +++ b/business/jxcallback/orderman/orderman_ext.go @@ -12,10 +12,9 @@ import ( "github.com/astaxie/beego" - "git.rosy.net.cn/jx-callback/globals/api" - "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" + "git.rosy.net.cn/baseapi/platformapi/jdapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/jxutils/excel" @@ -1399,9 +1398,16 @@ func GetMatterStoreOrderCount(ctx *jxcontext.Context, storeID int) (result *Orde func RefreshJdShopOrdersEarningPrice(ctx *jxcontext.Context, orderStartTime, orderEndTime string) (err error) { var ( - db = dao.GetDB() + db = dao.GetDB() + appOrgCode string ) - results, err := api.JdAPI.GetJdShopOrders(utils.Str2Time(orderStartTime).Format("20060102"), utils.Str2Time(orderEndTime).Format("20060102"), globals.JdOrgCode, globals.JdLoginName) + if beego.BConfig.RunMode == "jxgy" { + appOrgCode = "339032" + } else { + appOrgCode = "320406" + } + jdapi := partner.CurAPIManager.GetAPI(model.VendorIDJD, appOrgCode).(*jdapi.API) + results, err := jdapi.GetJdShopOrders(utils.Str2Time(orderStartTime).Format("20060102"), utils.Str2Time(orderEndTime).Format("20060102"), globals.JdOrgCode, globals.JdLoginName) if err != nil { return err } diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index f5f912995..7a26b4320 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -348,9 +348,6 @@ func Init() { jdsCookie = configs[0].Value api.JdShopAPI.SetCookieWithStr(jdsCookie) } - // if configs, err := dao.QueryConfigs(dao.GetDB(), "jdsCookie2", model.ConfigTypeCookie, ""); err == nil { - // api.JdShop2API.SetCookieWithStr(configs[0].Value) - // } if configs, err := dao.QueryConfigs(dao.GetDB(), "yinbaoCookie", model.ConfigTypeCookie, ""); err == nil { yinbaoCookie := configs[0].Value api.YinBaoAPI.SetCookie(".POSPALAUTH30220", yinbaoCookie) diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go index 9360389ec..63cd7bbfc 100644 --- a/business/jxstore/report/report.go +++ b/business/jxstore/report/report.go @@ -403,6 +403,7 @@ type GetStoreManageStateResult struct { ActAmple int `json:"actAmple"` //活动丰富的 NullOrderCount int `json:"nullOrderCount"` //无效订单数 RefuseOrderCount int `json:"refuseOrderCount"` //拒绝订单数 + StoreScore int `json:"storeScore"` //门店评分 RepurchaseRate int `json:"repurchaseRate"` //复购率(转化率) } @@ -468,12 +469,27 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f } } } - result.SkuCount = skuCount - result.HighSkuCount = highSkuCount + result.SkuCount, result.HighSkuCount = skuCount, highSkuCount //活动丰富度 handler := partner.GetPurchasePlatformFromVendorID(vendorID) ample, _ := handler.GetActAmple(ctx, storeDetail.VendorStoreID, storeDetail.VendorStoreID) result.ActAmple = ample + //订单 + nullOrderCount, refuseOrderCount := 0, 0 + if orderList, err := dao.QueryOrders(db, "", 0, []int{vendorID}, v, fromTimeT, toTimeT); err == nil { + for _, v := range orderList { + if v.Status == model.OrderStatusCanceled { + nullOrderCount++ + } + if waybills, err2 := dao.GetWayBillByOrderID(db, 0, vendorID, 0, v.VendorOrderID); err2 == nil { + if len(waybills) > 0 { + refuseOrderCount++ + } + } + } + } + result.NullOrderCount, result.RefuseOrderCount = nullOrderCount, refuseOrderCount + //转化率 getStoreManageStateResult = append(getStoreManageStateResult, result) } return getStoreManageStateResult, err diff --git a/business/partner/purchase/ebai/act.go b/business/partner/purchase/ebai/act.go index 5a7498ecb..eaa28f3d5 100644 --- a/business/partner/purchase/ebai/act.go +++ b/business/partner/purchase/ebai/act.go @@ -340,5 +340,10 @@ func (c *PurchaseHandler) SyncAct(ctx *jxcontext.Context, parentTask tasksch.ITa } func (c *PurchaseHandler) GetActAmple(ctx *jxcontext.Context, vendorStoreID, vendorOrgCode string) (ample int, err error) { + for _, v := range ebaiapi.ActivityTypeList { + if actIDs, err := api.EbaiAPI.ActMultiChannelQueryIDs("", utils.Str2Int64(vendorStoreID), v); err == nil && len(actIDs) > 0 { + ample++ + } + } return ample, err } diff --git a/globals/api/apimanager/apimanager.go b/globals/api/apimanager/apimanager.go index ec86495f2..f2510b6cd 100644 --- a/globals/api/apimanager/apimanager.go +++ b/globals/api/apimanager/apimanager.go @@ -50,6 +50,10 @@ func (a *APIManager) GetAPI(vendorID int, appOrgCode string) (pfAPI interface{}) JdStorePageCookie := configs[0].Value api.JdAPI.SetJdCookie(JdStorePageCookie) } + if configs, err := dao.QueryConfigs(dao.GetDB(), "jdStorePageEarning", model.ConfigTypeCookie, ""); err == nil { + jdStorePageEarning := configs[0].Value + api.JdAPI.SetCookie("user", jdStorePageEarning) + } } case model.VendorIDMTWM: pfAPI = api.MtwmAPI