aa

business/jxstore/cms/store.go

@@ -4088,3 +4088,24 @@ func GetStoreAcctBalance(ctx *jxcontext.Context, storeID int) (storeAcct *model.
 // 	dao.GetStoresMapList(db, []int{model.VendorIDJD, model.VendorIDMTWM, model.VendorIDEBAI}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "")
 // 	return err
 // }
+
+func RefreshStoreBind(ctx *jxcontext.Context) (err error) {
+	var (
+		db = dao.GetDB()
+	)
+	stores, err := dao.GetStoreList(db, nil, nil, []int{model.StoreStatusClosed, model.StoreStatusHaveRest, model.StoreStatusOpened}, nil, nil, "")
+	task := tasksch.NewParallelTask("RefreshStoreBind", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			store := batchItemList[0].(*model.Store)
+			var userIDs []string
+			userList := getAllUsers4Store(ctx, db, store)
+			for _, v := range userList {
+				userIDs = append(userIDs, v.UserID)
+			}
+			err = AddUsers4Role(ctx, autils.NewRole(authz.StoreRoleBoss, store.ID), userIDs)
+			return retVal, err
+		}, stores)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetID()
+	return err
+}