liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-01-12 10:58:43 +08:00
parent 48cf10b07c
commit 4165ee2162
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/cms/sync2.go
View File

@@ -97,8 +97,6 @@ func syncCategories(ctx *jxcontext.Context, db *dao.DaoDB, parentTask tasksch.IT
func SyncCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int, appOrgCodes []string, catIDs []int, isAsync bool) (hint string, err error) {
db := dao.GetDB()
catList, err := dao.GetSkuCategoryWithVendor(db, vendorIDs, appOrgCodes, -1, catIDs, true)
globals.SugarLogger.Debug("========catList %s", utils.Format4Output(catList, false))
globals.SugarLogger.Debug("========err %v", err)
if err == nil && len(catList) > 0 {
//TODO 同一平台不同账号会有影响needSyncParentIDs，暂不处理
var needSyncParentIDs []int
@@ -144,6 +142,7 @@ func SyncSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, vendorIDs []int,
db := dao.GetDB()
skuList, err := dao.GetSkusWithVendor(db, vendorIDs, appOrgCodes, nameIDs, skuIDs, true)
globals.SugarLogger.Debug("========skuList %s", utils.Format4Output(skuList, false))
cc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
skuVendorInfo := batchItemList[0].(*dao.StoreSkuSyncInfo)
var failedList []*partner.StoreSkuInfoWithErr

4
business/model/dao/sku.go
View File

@@ -291,8 +291,6 @@ func GetSkuCategoryWithVendor(db *DaoDB, vendorIDs []int, appOrgCodes []string,
sqlParams = append(sqlParams, parentCatID)
}
sql += " ORDER BY t1.seq"
globals.SugarLogger.Debug("==sql %s", sql)
globals.SugarLogger.Debug("==sql %s", utils.Format4Output(sqlParams, false))
err = GetRows(db, &catList, sql, sqlParams...)
return catList, err
}
@@ -369,6 +367,8 @@ func GetSkusWithVendor(db *DaoDB, vendorIDs []int, appOrgCodes []string, nameIDs
sqlParams = append(sqlParams, skuIDs)
}
sql += " ORDER BY t1.seq"
globals.SugarLogger.Debug("============sql := %s", sql)
globals.SugarLogger.Debug("==========sqlParams := %s", utils.Format4Output(sqlParams, false))
if err = GetRows(db, &skuList, sql, sqlParams...); err == nil {
skuPlaceList, err2 := GetSkuNamePlaces(db, nameIDs, skuIDs)
if err = err2; err == nil {