組織取得

# ==========================================================
# 組織マスタの棚卸：組織取得APIで全組織を取得し、棚卸テーブルに保存した前回の状態と比べて、
# 新設・廃止・名称変更があった組織だけを棚卸テーブルへ書き込みます。
# 棚卸テーブルの通知（作成後・更新後）と組み合わせると、組織の変更があったときだけメールが届きます。
# 変更が無い組織は書き込まないため、通知も届きません。
# ==========================================================
import datetime

import requests

# ===== 設定 =====
# APIキーは、全組織を取得できるテナント管理者のものを使ってください
BASE_URL = "【URL】"
API_KEY = "【APIキー】"
INVENTORY_SITE_ID = "【棚卸テーブルのサイトID】"

PAGE_SIZE = 200           # 1回の取得件数
BULK_UPSERT_MAX = 10000   # bulkupsertで1回に送れる件数の上限（General.jsonの既定値）

DEPT_CODE_COLUMN = "ClassB"    # 組織コード（突合のキー）
DEPT_NAME_COLUMN = "ClassA"    # 組織名
CHANGE_COLUMN = "ClassC"       # 検知した変更（新設／廃止／再開／名称変更）
OLD_NAME_COLUMN = "ClassD"     # 変更前の組織名（名称変更のときのみ）
DISABLED_COLUMN = "CheckA"     # 無効（廃止）
DETECTED_AT_COLUMN = "DateA"   # 検知日時


def api_post(path, payload):
    """Pleasanter APIへPOSTし、レスポンスのJSONを返す"""
    response = requests.post(
        f"{BASE_URL}{path}",
        json={"ApiVersion": 1.1, "ApiKey": API_KEY, **payload},
        headers={"Content-Type": "application/json"},
        timeout=60,
    )
    response.raise_for_status()
    return response.json()


def fetch_all(path):
    """取得件数に応じてOffsetを進めながら、全件を取得する"""
    rows = []
    while True:
        body = api_post(path, {"Offset": len(rows), "PageSize": PAGE_SIZE})
        page = body["Response"]["Data"]
        rows.extend(page)
        if len(page) == 0 or len(rows) >= body["Response"]["TotalCount"]:
            return rows


def load_last_state():
    """棚卸テーブルに保存した前回の状態を、組織コードごとに返す"""
    state = {}
    for record in fetch_all(f"/api/items/{INVENTORY_SITE_ID}/get"):
        class_hash = record.get("ClassHash") or {}
        code = class_hash.get(DEPT_CODE_COLUMN)
        if code:
            state[code] = {
                "name": class_hash.get(DEPT_NAME_COLUMN, ""),
                "disabled": bool((record.get("CheckHash") or {}).get(DISABLED_COLUMN)),
            }
    return state


def detect_changes(dept, last):
    """前回の状態と比べて、変更の種類のリストを返す（変更が無ければ空）"""
    if last is None:
        return ["新設"]
    changes = []
    if dept["Disabled"] and not last["disabled"]:
        changes.append("廃止")
    if not dept["Disabled"] and last["disabled"]:
        changes.append("再開")
    if dept["DeptName"] != last["name"]:
        changes.append("名称変更")
    return changes


def build_bulk_data(depts, last_state, now):
    """変更があった組織のみを、bulkupsert用のData配列にする"""
    data = []
    for dept in depts:
        code = dept.get("DeptCode")
        if not code:
            print(f"組織コードが空のため対象外：{dept['DeptName']}（組織ID：{dept['DeptId']}）")
            continue
        last = last_state.get(code)
        changes = detect_changes(dept, last)
        if not changes:
            continue
        old_name = last["name"] if "名称変更" in changes else ""
        data.append({
            "Title": dept["DeptName"],
            "ClassHash": {
                DEPT_CODE_COLUMN: code,
                DEPT_NAME_COLUMN: dept["DeptName"],
                CHANGE_COLUMN: "・".join(changes),
                OLD_NAME_COLUMN: old_name,
            },
            "CheckHash": {DISABLED_COLUMN: bool(dept["Disabled"])},
            "DateHash": {DETECTED_AT_COLUMN: now.isoformat()},
        })
        print(f"{code} {dept['DeptName']}：{'・'.join(changes)}")
    return data


def bulk_upsert(data):
    """組織コードをキーに、BULK_UPSERT_MAX件ずつ作成・更新する"""
    for i in range(0, len(data), BULK_UPSERT_MAX):
        api_post(f"/api/items/{INVENTORY_SITE_ID}/bulkupsert", {
            "Keys": [DEPT_CODE_COLUMN],
            "KeyNotFoundCreate": True,
            "Data": data[i:i + BULK_UPSERT_MAX],
        })


def main():
    now = datetime.datetime.now()
    depts = fetch_all("/api/depts/get")
    data = build_bulk_data(depts, load_last_state(), now)
    if data:
        bulk_upsert(data)
    print(f"組織 {len(depts)} 件のうち、変更があった {len(data)} 件を棚卸テーブルへ書き込みました。")


if __name__ == "__main__":
    main()