银豹同步京西删除测试
This commit is contained in:
@@ -950,9 +950,9 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt
|
|||||||
deleteList = append(deleteList, v)
|
deleteList = append(deleteList, v)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Println("addList", utils.Format4Output(addList, false))
|
// fmt.Println("addList", utils.Format4Output(addList, false))
|
||||||
// fmt.Println("updateList", utils.Format4Output(updateList, false))
|
fmt.Println("updateList", utils.Format4Output(updateList, false))
|
||||||
fmt.Println("deleteList", utils.Format4Output(deleteList, false))
|
// fmt.Println("deleteList", utils.Format4Output(deleteList, false))
|
||||||
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
||||||
store, _ := dao.GetStoreDetail(db, storeID, vendorID)
|
store, _ := dao.GetStoreDetail(db, storeID, vendorID)
|
||||||
switch step {
|
switch step {
|
||||||
|
|||||||
Reference in New Issue
Block a user