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:
邹宗楠
2022-12-21 11:46:44 +08:00
parent 12a98750ee
commit 5ab644b1a4
2 changed files with 0 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
business/jxstore/cms/sync_store_sku.go
View File

@@ -484,11 +484,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
} }
now := jxutils.OperationTime2HourMinuteFormat(time.Now()) now := jxutils.OperationTime2HourMinuteFormat(time.Now())
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
var skuList []int
for _, sku := range skus { for _, sku := range skus {
if vendorID == 14 && storeID == 668594 {
skuList = append(skuList, sku.SkuID)
}
if !useVendorPriceDirectly && !isSkuLockTimeValid(sku) { if !useVendorPriceDirectly && !isSkuLockTimeValid(sku) {
sku.VendorPrice = 0 sku.VendorPrice = 0
} }
@@ -534,8 +530,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
} }
} }
} else { } else {
globals.SugarLogger.Debugf("======skuid %d", sku.SkuID)
globals.SugarLogger.Debugf("======MergedStatus %d", sku.MergedStatus)
if sku.MergedStatus == model.SkuStatusNormal { if sku.MergedStatus == model.SkuStatusNormal {
if vendorID == model.VendorIDDD { if vendorID == model.VendorIDDD {
createList = append(createList, sku) createList = append(createList, sku)
@@ -627,9 +621,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
} }
return skuList return skuList
} }
if vendorID == 14 && storeID == 668594 {
globals.SugarLogger.Debugf("==========sku %s", utils.Format4Output(skuList, false))
}
isContinueWhenError2 := true isContinueWhenError2 := true
//如果是银豹平台，则要按照商品skuname维度同步 //如果是银豹平台，则要按照商品skuname维度同步
@@ -686,14 +677,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
// } // }
} }
if vendorID == model.VendorIDDD && storeDetail.Store.ID == 668594 {
globals.SugarLogger.Debugf("== createList %s", utils.Format4Output(createList, false))
globals.SugarLogger.Debugf("== updateList %s", utils.Format4Output(updateList, false))
globals.SugarLogger.Debugf("== deleteList %s", utils.Format4Output(deleteList, false))
globals.SugarLogger.Debugf("== stockList %s", utils.Format4Output(stockList, false))
globals.SugarLogger.Debugf("== priceList %s", utils.Format4Output(priceList, false))
}
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx, task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
step := batchItemList[0].(int) step := batchItemList[0].(int)

5
business/model/dao/store_sku.go
View File

@@ -690,11 +690,6 @@ func GetStoreSkus2(db *DaoDB, vendorID, storeID int, skuIDs []int, mustDirty boo
if err = GetRows(db, &skus, sql, sqlParams...); err != nil { if err = GetRows(db, &skus, sql, sqlParams...); err != nil {
return nil, err return nil, err
} }
if vendorID == 14 && storeID == 668594 {
globals.SugarLogger.Debugf("============sql := %s", sql)
globals.SugarLogger.Debugf("============param := %s", utils.Format4Output(sqlParams, false))
}
return skus, err return skus, err
} }