- ignore fake skuname in TransformJdSpu2Sku

This commit is contained in:
gazebo
2019-02-15 09:05:58 +08:00
parent a3308c433e
commit 638754c754

View File

@@ -651,7 +651,7 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA
sql := ` sql := `
SELECT t1.* SELECT t1.*
FROM sku_name 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{}{ sqlParams := []interface{}{
utils.DefaultTimeValue, utils.DefaultTimeValue,
@@ -687,7 +687,7 @@ func TransformJdSpu2Sku(ctx *jxcontext.Context, skuNameIDs []int, count int, isA
batchSkNameList := skuNameList[step*batchSize : lastIndex] 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) { 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) skuName := batchItemList[0].(*model.SkuName)
if true { //!jxutils.IsFakeID(skuName.JdID) { if !jxutils.IsFakeID(skuName.JdID) {
sql = ` sql = `
SELECT * SELECT *
FROM sku 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 return nil, err
}, batchSkNameList) }, batchSkNameList)