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

- and param skuIDs to RefreshJdStoreSkuStock to speedup it

Browse Source
This commit is contained in:
gazebo
2018-11-26 10:03:57 +08:00
parent 02b325e33f
commit 00cfa73f92
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
business/jxstore/promotion/jd_promotion.go
View File

@@ -215,12 +215,12 @@ func scheduleRoutine(isFirst bool) {
if isFirst { if isFirst {
go func() { go func() {
RefreshJdLockStoreSku() RefreshJdLockStoreSku()
RefreshJdStoreSkuStock(0) RefreshJdStoreSkuStock(0, nil)
}() }()
} }
time.AfterFunc(stockRefreshGap, func() { time.AfterFunc(stockRefreshGap, func() {
RefreshJdLockStoreSku() RefreshJdLockStoreSku()
RefreshJdStoreSkuStock(0) RefreshJdStoreSkuStock(0, nil)
scheduleRoutine(false) scheduleRoutine(false)
}) })
} }
@@ -701,8 +701,8 @@ func RefreshJdLockStoreSku() (err error) {
return RefreshJdPromotionItemListLockStatus(promotionItemList) return RefreshJdPromotionItemListLockStatus(promotionItemList)
} }
func RefreshJdStoreSkuStock(promotionID int) (err error) { func RefreshJdStoreSkuStock(promotionID int, skuIDs []int) (err error) {
globals.SugarLogger.Debug("RefreshJdStoreSkuStock promotionID:%d", promotionID) globals.SugarLogger.Debugf("RefreshJdStoreSkuStock promotionID:%d", promotionID)
sql := ` sql := `
SELECT t22.vendor_store_id, t3.sku_id, t32.jd_id, MAX(t3.is_lock) is_lock, MAX(t1.end_at) end_at SELECT t22.vendor_store_id, t3.sku_id, t32.jd_id, MAX(t3.is_lock) is_lock, MAX(t1.end_at) end_at
@@ -729,6 +729,10 @@ func RefreshJdStoreSkuStock(promotionID int) (err error) {
sql += " AND t1.id = ?" sql += " AND t1.id = ?"
sqlParams = append(sqlParams, promotionID) sqlParams = append(sqlParams, promotionID)
} }
if len(skuIDs) > 0 {
sql += " AND t3.sku_id IN (" + dao.GenQuestionMarks(len(skuIDs)) + ")"
sqlParams = append(sqlParams, skuIDs)
}
sql += ` sql += `
GROUP BY 1,2,3 GROUP BY 1,2,3
ORDER BY 1,2,3 ORDER BY 1,2,3
@@ -741,7 +745,7 @@ func RefreshJdStoreSkuStock(promotionID int) (err error) {
} }
return err return err
} }
globals.SugarLogger.Debug("RefreshJdStoreSkuStock promotionID:%d, len(promotionItemList)=%d", promotionID, len(promotionItemList)) globals.SugarLogger.Debugf("RefreshJdStoreSkuStock promotionID:%d, len(promotionItemList)=%d", promotionID, len(promotionItemList))
if len(promotionItemList) > 0 { if len(promotionItemList) > 0 {
task := tasksch.NewParallelTask("RefreshJdStoreSkuStock", tasksch.NewParallelConfig().SetBatchSize(jdapi.MaxStoreSkuBatchSize).SetIsContinueWhenError(true), "schedule", func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task := tasksch.NewParallelTask("RefreshJdStoreSkuStock", tasksch.NewParallelConfig().SetBatchSize(jdapi.MaxStoreSkuBatchSize).SetIsContinueWhenError(true), "schedule", func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
stockList := make([]*jdapi.SkuStock, 0) stockList := make([]*jdapi.SkuStock, 0)
@@ -869,7 +873,7 @@ func LockPromotionSkus(ctx *jxcontext.Context, promotionID int, isLock int, skuI
} }
RefreshJdPromotionLockStatus(ctx, promotionID) RefreshJdPromotionLockStatus(ctx, promotionID)
if isLock != 0 { if isLock != 0 {
RefreshJdStoreSkuStock(promotionID) RefreshJdStoreSkuStock(promotionID, skuIDs)
} }
} }
globals.SugarLogger.Debugf("end LockPromotionSkus promotionID:%d, isLock:%d, skuIDs:%v", promotionID, isLock, skuIDs) globals.SugarLogger.Debugf("end LockPromotionSkus promotionID:%d, isLock:%d, skuIDs:%v", promotionID, isLock, skuIDs)