From c8edb512fdb2a4fa71d5fb25ff340701561f9734 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Thu, 15 Apr 2021 10:03:15 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/store.go | 31 ++++++++++++++++++++-----------
 1 file changed, 20 insertions(+), 11 deletions(-)

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
 }