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

打印处理时间，修正错误

Browse Source
This commit is contained in:
Rosy-zhudan
2019-07-30 15:28:40 +08:00
parent df92f78cc4
commit 17ce70be72
1 changed files with 21 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
business/jxstore/misc/misc2.go
View File

@@ -1,6 +1,7 @@
package misc package misc
import ( import (
"time"
"git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/jxstore/cms" "git.rosy.net.cn/jx-callback/business/jxstore/cms"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "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) { func StartOrEndOpStore(isStart bool, startTime, endTime int16) {
startProcessTime := time.Now().Unix()
startOpStoreTime := startOpStoreTimeDefault startOpStoreTime := startOpStoreTimeDefault
endOpStoreTime := endOpStoreTimeDefault endOpStoreTime := endOpStoreTimeDefault
if startTime != 0 && endTime != 0 { if startTime != 0 && endTime != 0 {
@@ -79,32 +81,30 @@ func StartOrEndOpStore(isStart bool, startTime, endTime int16) {
vendorID := int(utils.MustInterface2Int64(vendorListValue["vendorID"])) vendorID := int(utils.MustInterface2Int64(vendorListValue["vendorID"]))
if _, ok := vendorList[vendorID]; ok { if _, ok := vendorList[vendorID]; ok {
vendorStoreID := utils.Interface2String(vendorListValue["vendorStoreID"]) 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) singleStoreHandler := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreStoreSkuHandler)
storeSkuNameList, err := singleStoreHandler.GetStoreSkusFullInfo(ctx, nil, storeID, vendorStoreID, nil) storeSkuNameList, err := singleStoreHandler.GetStoreSkusFullInfo(ctx, nil, storeID, vendorStoreID, nil)
filterStoreSkuNameList := FilterSkuNameList(storeSkuNameList)
storeSkuList := putils.StoreSkuFullList2Bare(filterStoreSkuNameList)
if err != nil { if err != nil {
baseapi.SugarLogger.Errorf("storeSkuList error:%v", err) baseapi.SugarLogger.Errorf("storeSkuList error:%v", err)
} else { } else {
filterStoreSkuNameList := FilterSkuNameList(storeSkuNameList)
storeSkuList := putils.StoreSkuFullList2Bare(filterStoreSkuNameList)
if len(storeSkuList) > 0 { if len(storeSkuList) > 0 {
canProcessSkuList := true
if !isStart { if !isStart {
canProcessSkuList = AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, false) AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, false)
} }
if canProcessSkuList {
_, err = putils.FreeBatchStoreSkuInfo(func(batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, err error) { _, err = putils.FreeBatchStoreSkuInfo(func(batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, err error) {
for _, skuValue := range batchedStoreSkuList { for _, skuValue := range batchedStoreSkuList {
skuValue.Stock = GetStockValue(isStart) skuValue.Stock = GetStockValue(isStart)
} }
var successList []*partner.StoreSkuInfo //var successList []*partner.StoreSkuInfo
if successList, err = singleStoreHandler.UpdateStoreSkusStock(ctx, storeID, vendorStoreID, batchedStoreSkuList); err == nil { if _, err = singleStoreHandler.UpdateStoreSkusStock(ctx, storeID, vendorStoreID, batchedStoreSkuList); err == nil {
successList = batchedStoreSkuList //successList = batchedStoreSkuList
baseapi.SugarLogger.Debugf("successList:%v error:%v", successList, err) //baseapi.SugarLogger.Debugf("successList:%v error:%v", successList, err)
} }
return nil, err return nil, err
}, ctx, nil, storeSkuList, singleStoreHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkusStock), true) }, ctx, nil, storeSkuList, singleStoreHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkusStock), true)
}
if isStart { if isStart {
AddOrDelExtraStoreOptime(vendorID, storeID, vendorStoreID, &storeListValue.Store, startOpStoreTime, endOpStoreTime, true) 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() { func InitEx() {