diff --git a/business/netspider/netspider.go b/business/netspider/netspider.go index 7f44e2ee0..c8bf7db23 100644 --- a/business/netspider/netspider.go +++ b/business/netspider/netspider.go @@ -3,6 +3,8 @@ package netspider import ( "fmt" + "git.rosy.net.cn/jx-callback/globals" + "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils/ditu" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" @@ -148,3 +150,29 @@ func GetAndStoreCitiesShops(ctx *jxcontext.Context, vendorIDs []int, cityCodeLis tasksch.ManageTask(task).Run() return task.GetID(), err } + +func RefreshPageStore(ctx *jxcontext.Context) (err error) { + sql := ` + SELECT * + FROM page_shop t1 + WHERE t1.vendor_id = 0 + ` + db := dao.GetDB() + var shopList []*model.PageShop + if err = dao.GetRows(db, &shopList, sql); err != nil { + return err + } + for _, v := range shopList { + if handler, _ := partner.GetPurchasePlatformFromVendorID(v.VendorID).(partner.IPurchasePlatformNetSpiderHandler); handler != nil { + storePageInfo, err2 := handler.GetStorePageInfo(ctx, "", v.VendorStoreID) + if err2 == nil { + v.RecentOrderNum = storePageInfo.RecentOrderNum + v.SkuCount = storePageInfo.SkuCount + dao.UpdateEntity(db, v, "RecentOrderNum", "SkuCount") + } else { + globals.SugarLogger.Debugf("RefreshPageStore err:%v", err) + } + } + } + return err +} diff --git a/controllers/temp_op.go b/controllers/temp_op.go index 1e24b1996..755369cfb 100644 --- a/controllers/temp_op.go +++ b/controllers/temp_op.go @@ -1,9 +1,9 @@ package controllers import ( - "git.rosy.net.cn/jx-callback/business/jxstore/cms" "git.rosy.net.cn/jx-callback/business/jxstore/tempop" "git.rosy.net.cn/jx-callback/business/jxutils" + "git.rosy.net.cn/jx-callback/business/netspider" "github.com/astaxie/beego" ) @@ -240,7 +240,8 @@ func (c *TempOpController) RefreshMtpsWaybillFee() { // @router /TestIt [get] func (c *TempOpController) TestIt() { c.callTestIt(func(params *tTempopTestItParams) (retVal interface{}, errCode string, err error) { - err = cms.SaveAndSendAlarmVendorSnapshot(params.Ctx, nil, nil) + // err = cms.SaveAndSendAlarmVendorSnapshot(params.Ctx, nil, nil) + err = netspider.RefreshPageStore(params.Ctx) return retVal, "", err }) }