data/pgdata/postmaster.pid

@@ -0,0 +1,8 @@
+1
+/var/lib/postgresql/data
+1767598673
+5432
+/var/run/postgresql
+*
+      742         0
+ready   

extensions/example/__init__.py

@@ -0,0 +1,3 @@
+#
+
+

extensions/example/client.py

@@ -0,0 +1,16 @@
+from __future__ import annotations
+
+from app.integrations.base import BaseClient
+
+
+class ExampleClient(BaseClient):
+    """
+    演示用 Client：真实业务中应封装 OA/HR/ERP 的 API。
+    这里不做实际外部请求，仅保留结构与调用方式。
+    """
+
+    def ping(self) -> dict:
+        # 真实情况：return self.get_json("/ping")
+        return {"ok": True}
+
+

extensions/example/job.py

@@ -0,0 +1,33 @@
+from __future__ import annotations
+
+import logging
+from typing import Any
+
+from app.jobs.base import BaseJob
+from extensions.example.client import ExampleClient
+
+
+logger = logging.getLogger("connecthub.extensions.example")
+
+
+class ExampleJob(BaseJob):
+    job_id = "example.hello"
+
+    def run(self, params: dict[str, Any], secrets: dict[str, Any]) -> dict[str, Any]:
+        # params: 明文配置，例如 {"name": "Mars"}
+        name = params.get("name", "World")
+
+        # secrets: 解密后的明文，例如 {"token": "..."}
+        token = secrets.get("token", "<missing>")
+
+        client = ExampleClient(base_url="https://baidu.com", headers={"Authorization": f"Bearer {token}"})
+        try:
+            pong = client.ping()
+            
+        finally:
+            client.close()
+
+        logger.info("ExampleJob ran name=%s pong=%s", name, pong)
+        return {"hello": name, "pong": pong}
+
+

extensions/sync_oa_to_didi/job.py

@@ -248,7 +248,6 @@ class SyncOAToDidiLegalEntitySyncJob(BaseJob):
             seeyon.close()
 
         payload = json.loads(raw) if raw else {}
-        logger.info(payload)
         outer = payload.get("data") or {}
         inner = outer.get("data") or {}
         inner2 = inner.get("data") or {}