From 638754c75469e114340a75d74be7040da888aceb Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 15 Feb 2019 09:05:58 +0800 Subject: [PATCH] - ignore fake skuname in TransformJdSpu2Sku --- business/jxstore/tempop/tempop.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index b9dbf19e5..7be749b9b 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -651,7 +651,7 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA sql := ` SELECT t1.* FROM sku_name t1 - WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 1 + WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 1 AND jd_id <> 0 ` sqlParams := []interface{}{ utils.DefaultTimeValue, @@ -687,7 +687,7 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA batchSkNameList := skuNameList[step*batchSize : lastIndex] subTask := tasksch.NewParallelTask(fmt.Sprintf("TransformJdSpu2Sku:%d", step), tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx.GetUserName(), func(subTask *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { skuName := batchItemList[0].(*model.SkuName) - if true { //!jxutils.IsFakeID(skuName.JdID) { + if !jxutils.IsFakeID(skuName.JdID) { sql = ` SELECT * FROM sku @@ -743,6 +743,8 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA } } } + } else { + globals.SugarLogger.Debugf("TransformJdSpu2Sku skuName:%d is fake", skuName.ID) } return nil, err }, batchSkNameList)