diff --git a/business/jxstore/misc/misc2.go b/business/jxstore/misc/misc2.go index 9ba8019fa..f0df3cdb0 100644 --- a/business/jxstore/misc/misc2.go +++ b/business/jxstore/misc/misc2.go @@ -1,6 +1,7 @@ package misc import ( + "time" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxstore/cms" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" @@ -59,6 +60,7 @@ func FilterSkuNameList(storeSkuNameList []*partner.SkuNameInfo) (filterStoreSkuN } func StartOrEndOpStore(isStart bool, startTime, endTime int16) { + startProcessTime := time.Now().Unix() startOpStoreTime := startOpStoreTimeDefault endOpStoreTime := endOpStoreTimeDefault if startTime != 0 && endTime != 0 { @@ -79,33 +81,31 @@ func StartOrEndOpStore(isStart bool, startTime, endTime int16) { vendorID := int(utils.MustInterface2Int64(vendorListValue["vendorID"])) if _, ok := vendorList[vendorID]; ok { vendorStoreID := utils.Interface2String(vendorListValue["vendorStoreID"]) - baseapi.SugarLogger.Debugf("storeID:%d vendorID:%d vendorStoreID:%s vendorListValue:%v", storeID, vendorID, vendorStoreID, vendorListValue) + baseapi.SugarLogger.Debugf("storeID:%d vendorID:%d vendorStoreID:%s", storeID, vendorID, vendorStoreID) singleStoreHandler := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreStoreSkuHandler) storeSkuNameList, err := singleStoreHandler.GetStoreSkusFullInfo(ctx, nil, storeID, vendorStoreID, nil) - filterStoreSkuNameList := FilterSkuNameList(storeSkuNameList) - storeSkuList := putils.StoreSkuFullList2Bare(filterStoreSkuNameList) if err != nil { baseapi.SugarLogger.Errorf("storeSkuList error:%v", err) } else { + filterStoreSkuNameList := FilterSkuNameList(storeSkuNameList) + storeSkuList := putils.StoreSkuFullList2Bare(filterStoreSkuNameList) if len(storeSkuList) > 0 { - canProcessSkuList := true if !isStart { - canProcessSkuList = AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, false) - } - if canProcessSkuList { - _, err = putils.FreeBatchStoreSkuInfo(func(batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, err error) { - for _, skuValue := range batchedStoreSkuList { - skuValue.Stock = GetStockValue(isStart) - } - var successList []*partner.StoreSkuInfo - if successList, err = singleStoreHandler.UpdateStoreSkusStock(ctx, storeID, vendorStoreID, batchedStoreSkuList); err == nil { - successList = batchedStoreSkuList - baseapi.SugarLogger.Debugf("successList:%v error:%v", successList, err) - } - return nil, err - }, ctx, nil, storeSkuList, singleStoreHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkusStock), true) + AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, false) } + _, err = putils.FreeBatchStoreSkuInfo(func(batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, err error) { + for _, skuValue := range batchedStoreSkuList { + skuValue.Stock = GetStockValue(isStart) + } + //var successList []*partner.StoreSkuInfo + if _, err = singleStoreHandler.UpdateStoreSkusStock(ctx, storeID, vendorStoreID, batchedStoreSkuList); err == nil { + //successList = batchedStoreSkuList + //baseapi.SugarLogger.Debugf("successList:%v error:%v", successList, err) + } + return nil, err + }, ctx, nil, storeSkuList, singleStoreHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkusStock), true) + if isStart { AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, true) } @@ -116,6 +116,9 @@ func StartOrEndOpStore(isStart bool, startTime, endTime int16) { } } } + endProcessTime := time.Now().Unix() + diff := endProcessTime - startProcessTime + baseapi.SugarLogger.Debugf("StartOrEndOpStore cost time: %d sec", diff) } func InitEx() {