liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- test Convert2JDSPU

Browse Source
This commit is contained in:
gazebo
2019-01-03 09:55:26 +08:00
parent 7fb93596f6
commit b145c9d535
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/initdata/initdata.go
View File

@@ -204,7 +204,7 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h
LEFT JOIN sku_name t2 ON t1.link_id = t2.id 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 = '份' WHERE t1.deleted_at = ? AND t1.status <> ? AND t1.is_spu = 0 AND t1.unit = '份'
AND t2.id IS NULL AND t2.id IS NULL
LIMIT 1; LIMIT 10;
` `
sqlParams := []interface{}{ sqlParams := []interface{}{
utils.DefaultTimeValue, utils.DefaultTimeValue,
@@ -246,6 +246,7 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h
} }
if len(skuList) > 0 { if len(skuList) > 0 {
globals.SugarLogger.Debugf("Convert2JDSPU, name:%s", skuName.Name)
dao.Begin(db) dao.Begin(db)
skuNameNew2 := *skuName skuNameNew2 := *skuName
skuNameNew := &skuNameNew2 skuNameNew := &skuNameNew2
@@ -288,13 +289,12 @@ func Convert2JDSPU(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (h
FROM sku_name t1 FROM sku_name t1
WHERE t1.link_id <> 0; WHERE t1.link_id <> 0;
` `
skuNameList = []*model.SkuName{}
if err = dao.GetRows(db, &skuNameList, sql); err != nil { if err = dao.GetRows(db, &skuNameList, sql); err != nil {
return "", err 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) { 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) skuName := batchItemList[0].(*model.SkuName)
globals.SugarLogger.Debug(utils.Format4Output(skuName, false))
_, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, ctx.GetUserName()) _, err = cms.CurVendorSync.SyncSku(ctx, db, skuName.ID, -1, false, ctx.GetUserName())
return nil, err return nil, err
}, skuNameList) }, skuNameList)