From 1096613dd51ba73d059d3e103c9621bf57796045 Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 19 Jul 2019 13:57:43 +0800 Subject: [PATCH] - TestIt --- controllers/temp_op.go | 26 +++++++++++++++++++++++--- 1 file changed, 23 insertions(+), 3 deletions(-) diff --git a/controllers/temp_op.go b/controllers/temp_op.go index 755369cfb..dfe8fff9a 100644 --- a/controllers/temp_op.go +++ b/controllers/temp_op.go @@ -1,9 +1,11 @@ package controllers import ( + "git.rosy.net.cn/baseapi/platformapi/ebaiapi" "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" + "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" + "git.rosy.net.cn/jx-callback/globals/api" "github.com/astaxie/beego" ) @@ -240,8 +242,26 @@ 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 = netspider.RefreshPageStore(params.Ctx) + shopList, err := api.EbaiAPI.ShopList(ebaiapi.SysStatusAll) + task := tasksch.NewParallelTask("tttt", nil, params.Ctx, + func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + shop := batchItemList[0].(*ebaiapi.ShopInfo) + skuInfo, err := api.EbaiAPI.SkuList(shop.ShopID, &ebaiapi.SkuListParams{}) + if err == nil && skuInfo.Total > 500 { + errSkuCount := 0 + for _, sku := range skuInfo.List { + if sku.CustomCatIDs == "" { + errSkuCount++ + } + } + if errSkuCount > len(skuInfo.List)/3 { + retVal = []string{shop.ShopID} + } + } + return retVal, err + }, shopList) + task.Run() + retVal, err = task.GetResult(0) return retVal, "", err }) }