From 4d989c21152ece846f80d17f1b8b32b75a4027ae Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 25 Oct 2018 09:52:51 +0800 Subject: [PATCH] - optimize jd SyncStoresSkus --- business/partner/purchase/jd/store_sku.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/business/partner/purchase/jd/store_sku.go b/business/partner/purchase/jd/store_sku.go index e2ea28e69..091f1ba92 100644 --- a/business/partner/purchase/jd/store_sku.go +++ b/business/partner/purchase/jd/store_sku.go @@ -25,9 +25,6 @@ type tStoreSkuBindExt struct { // 京东到家，以有库存表示关注（认领） func (p *PurchaseHandler) SyncStoresSkus(ctx *jxcontext.Context, parentTask tasksch.ITask, db *dao.DaoDB, storeIDs []int, skuIDs []int, isAsync bool) (hint string, err error) { globals.SugarLogger.Debugf("jd SyncStoresSkus, storeIDs:%v, skuIDs:%v", storeIDs, skuIDs) - if len(skuIDs) == 0 { - return "", nil - } parallelCount := 1 if len(skuIDs) < MaxSkuBatchSize { @@ -36,14 +33,13 @@ func (p *PurchaseHandler) SyncStoresSkus(ctx *jxcontext.Context, parentTask task task := tasksch.NewParallelTask("SyncStoresSkus", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx.GetUserName(), func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (interface{}, error) { storeID := batchItemList[0].(int) sqlWhere := ` - WHERE (t1.deleted_at = ? OR t1.jd_sync_status <> 0) AND t1.store_id = ? + WHERE (t1.jd_sync_status <> 0) AND t1.store_id = ? ` sqlWhereParams := []interface{}{ - utils.DefaultTimeValue, storeID, } - if skuIDs != nil && len(skuIDs) > 0 { + if len(skuIDs) > 0 { sqlWhere += " AND t1.sku_id IN (" + dao.GenQuestionMarks(len(skuIDs)) + ")" sqlWhereParams = append(sqlWhereParams, skuIDs) }