aa

business/jxstore/cms/store.go

@@ -458,6 +458,16 @@ func setStoreMapInfo(ctx *jxcontext.Context, db *dao.DaoDB, storesInfo *StoresIn
 			v.Licence2Image = ""
 		}
 		for _, v2 := range storeMapMap[v.ID] {
+			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 {
@@ -469,12 +479,11 @@ func setStoreMapInfo(ctx *jxcontext.Context, db *dao.DaoDB, storesInfo *StoresIn
 						}
 					}
 				}
-			v.StoreMaps = append(v.StoreMaps, v2)
-		}
-		for _, v2 := range storeCourierMap[v.ID] {
-			v.CourierMaps = append(v.CourierMaps, v2)
-		}
 			}
+			return retVal, err
+		}, storesInfo.Stores)
+	task.Run()
+	task.GetResult(0)
 	return nil
 }