diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index eda37cc69..ceb0b2be3 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -458,23 +458,32 @@ func setStoreMapInfo(ctx *jxcontext.Context, db *dao.DaoDB, storesInfo *StoresIn v.Licence2Image = "" } for _, v2 := range storeMapMap[v.ID] { - if isStoreVendorStatus { - if handler := CurVendorSync.GetStoreHandler(v2.VendorID); handler != nil { - if store, err := handler.ReadStore(ctx, v2.VendorOrgCode, v2.VendorStoreID); err == nil && store != nil { - if store.Status != model.StoreStatusDisabled { - v2.BussinessStatus = 1 - } else { - v2.BussinessStatus = -1 - } - } - } - } v.StoreMaps = append(v.StoreMaps, v2) } for _, v2 := range storeCourierMap[v.ID] { v.CourierMaps = append(v.CourierMaps, v2) } } + task := tasksch.NewParallelTask("上下线状态", tasksch.NewParallelConfig().SetParallelCount(4), ctx, + func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + store := batchItemList[0].(*StoreExt) + for _, v2 := range store.StoreMaps { + if isStoreVendorStatus { + if handler := CurVendorSync.GetStoreHandler(v2.VendorID); handler != nil { + if store, err := handler.ReadStore(ctx, v2.VendorOrgCode, v2.VendorStoreID); err == nil && store != nil { + if store.Status != model.StoreStatusDisabled { + v2.BussinessStatus = 1 + } else { + v2.BussinessStatus = -1 + } + } + } + } + } + return retVal, err + }, storesInfo.Stores) + task.Run() + task.GetResult(0) return nil }