From b129fc2ef2f1e67c3b85de994d6c0e8e03807416 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Wed, 22 Jul 2026 12:05:58 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=B9=B3=E5=8F=B0=E7=AE=A1=E7=90=86?=
 =?UTF-8?q?=E5=91=98(userorgid=3D0)=E4=B8=8D=E8=BF=87=E6=BB=A4=E6=9C=BA?=
 =?UTF-8?q?=E6=9E=84,=E7=9C=8B=E5=85=A8=E9=83=A8=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 sage_datamart/init.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/sage_datamart/init.py b/sage_datamart/init.py
index 1f10c9d..4258e56 100644
--- a/sage_datamart/init.py
+++ b/sage_datamart/init.py
@@ -24,12 +24,16 @@ MODULE_NAME = "sage_datamart"
 
 async def _resolve_view(request):
     """解析当前用户角色和机构过滤条件
-    返回 (scope, org_filter) — scope: 'customer'|'distributor', org_filter: org_id
+    返回 (scope, org_filter) — scope: 'customer'|'distributor'|None, org_filter: org_id|None
+    org_filter=None 表示不按机构过滤（平台管理员看全部数据）
     """
     env = request._run_ns
     userorgid = await env.get_userorgid()
     scope = CUSTOMER
     org_filter = userorgid
+    # 平台根机构('0')无过滤，看全部数据
+    if not userorgid or userorgid == '0':
+        return None, None
     try:
         async with get_sor_context(env, MODULE_NAME) as sor:
             recs = await sor.sqlExe(