aa
This commit is contained in:
@@ -103,8 +103,6 @@ func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs
|
|||||||
needSyncParentIDs = append(needSyncParentIDs, cat.ParentID)
|
needSyncParentIDs = append(needSyncParentIDs, cat.ParentID)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Println("22222222222222222222222", utils.Format4Output(catList, false))
|
|
||||||
fmt.Println("22222222222222222222222", utils.Format4Output(needSyncParentIDs, false))
|
|
||||||
if len(needSyncParentIDs) > 0 {
|
if len(needSyncParentIDs) > 0 {
|
||||||
task := tasksch.NewSeqTask(fmt.Sprintf("同步分类1:%v", catIDs), ctx,
|
task := tasksch.NewSeqTask(fmt.Sprintf("同步分类1:%v", catIDs), ctx,
|
||||||
func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package dao
|
package dao
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"git.rosy.net.cn/baseapi/platformapi/aliupcapi"
|
"git.rosy.net.cn/baseapi/platformapi/aliupcapi"
|
||||||
@@ -260,6 +261,8 @@ func GetSkuCategoryWithVendor(db *DaoDB, vendorIDs []int, appOrgCodes []string,
|
|||||||
sqlParams = append(sqlParams, parentCatID)
|
sqlParams = append(sqlParams, parentCatID)
|
||||||
}
|
}
|
||||||
sql += " ORDER BY t1.seq"
|
sql += " ORDER BY t1.seq"
|
||||||
|
fmt.Println(sql)
|
||||||
|
fmt.Println(sqlParams)
|
||||||
err = GetRows(db, &catList, sql, sqlParams...)
|
err = GetRows(db, &catList, sql, sqlParams...)
|
||||||
return catList, err
|
return catList, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user