1
This commit is contained in:
@@ -6604,18 +6604,13 @@ func CopyMtToJd(ctx *jxcontext.Context, mtStoreID, mtOrgCode, jdStoreID, jdOrgCo
|
||||
// }
|
||||
//}
|
||||
case 1:
|
||||
globals.SugarLogger.Debugf("-----------lens := %d", 1)
|
||||
//建商品
|
||||
skuList := make([]*mtwmapi.AppFood, 0, 0)
|
||||
for {
|
||||
skuList2, _ := mtapi.RetailListAll(mtStoreID, 0)
|
||||
globals.SugarLogger.Debugf("-----------lens2 := %d", len(skuList2))
|
||||
for i := 0; i < 9; i++ {
|
||||
skuList2, _ := mtapi.RetailListAll(mtStoreID, i)
|
||||
skuList = append(skuList, skuList2...)
|
||||
if len(skuList2) < 100 {
|
||||
break
|
||||
}
|
||||
}
|
||||
globals.SugarLogger.Debugf("-----------lens3 := %d", len(skuList))
|
||||
globals.SugarLogger.Debugf("-----len := %d", len(skuList))
|
||||
//skuList, _ := mtapi.RetailList(mtStoreID, 0, 2)
|
||||
task2 := tasksch.NewParallelTask("美团到京东, 建商品", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx,
|
||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||
|
||||
Reference in New Issue
Block a user