尝试银豹skuname上
This commit is contained in:
@@ -506,9 +506,9 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
|||||||
for _, v := range list1 {
|
for _, v := range list1 {
|
||||||
skuNameMap[v.NameID] = v
|
skuNameMap[v.NameID] = v
|
||||||
}
|
}
|
||||||
fmt.Println(utils.Format4Output(skuNameMap, false))
|
|
||||||
list1 = list1[0:0]
|
list1 = list1[0:0]
|
||||||
for _, v := range skuNameMap {
|
for _, v := range skuNameMap {
|
||||||
|
fmt.Println(utils.Format4Output(v, false))
|
||||||
list1 = append(list1, v)
|
list1 = append(list1, v)
|
||||||
}
|
}
|
||||||
for _, v := range list1 {
|
for _, v := range list1 {
|
||||||
@@ -522,7 +522,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
|||||||
changeList2Yb(createList, nil)
|
changeList2Yb(createList, nil)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Println(utils.Format4Output(createList, false))
|
|
||||||
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
||||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||||
step := batchItemList[0].(int)
|
step := batchItemList[0].(int)
|
||||||
|
|||||||
Reference in New Issue
Block a user