同步测试

This commit is contained in:
苏尹岚
2020-04-29 11:06:17 +08:00
parent 8225b52caa
commit a7bffdaf41

View File

@@ -950,9 +950,9 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt
deleteList = append(deleteList, v)
}
}
// fmt.Println("addList", utils.Format4Output(addList, false))
// fmt.Println("updateList", utils.Format4Output(updateList, false))
// fmt.Println("deleteList", utils.Format4Output(deleteList, false))
fmt.Println("addList", len(addList))
fmt.Println("updateList", len(updateList))
fmt.Println("deleteList", len(deleteList))
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
store, _ := dao.GetStoreDetail(db, storeID, vendorID)
switch step {