From b145c9d535c28716ba56c5d8a576231232f8e6c4 Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 3 Jan 2019 09:55:26 +0800 Subject: [PATCH] - test Convert2JDSPU --- business/jxstore/initdata/initdata.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/business/jxstore/initdata/initdata.go b/business/jxstore/initdata/initdata.go index 4add609cb..6bef28353 100644 --- a/business/jxstore/initdata/initdata.go +++ b/business/jxstore/initdata/initdata.go @@ -204,7 +204,7 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h LEFT JOIN sku_name t2 ON t1.link_id = t2.id WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 0 AND t1.unit = '份' AND t2.id IS NULL - LIMIT 1; + LIMIT 10; ` sqlParams := []interface{}{ utils.DefaultTimeValue, @@ -246,6 +246,7 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h } if len(skuList) > 0 { + globals.SugarLogger.Debugf("Convert2JDSPU, name:%s", skuName.Name) dao.Begin(db) skuNameNew2 := *skuName skuNameNew := &skuNameNew2 @@ -288,13 +289,12 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h FROM sku_name t1 WHERE t1.link_id <> 0; ` + skuNameList = []*model.SkuName{} if err = dao.GetRows(db, &skuNameList, sql); err != nil { return "", err } - globals.SugarLogger.Debug(utils.Format4Output(skuNameList, false)) rootTask := tasksch.NewParallelTask("Convert2JDSPU", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx.GetUserName(), func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { skuName := batchItemList[0].(*model.SkuName) - globals.SugarLogger.Debug(utils.Format4Output(skuName, false)) _, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, ctx.GetUserName()) return nil, err }, skuNameList)