ユーザ取得（選択）

import datetime
import requests

# ===== 設定 =====
# 【重要】API_KEYは必ずテナント管理者権限のユーザーで発行したものを使用してください。
# 一般ユーザーのAPIキーでは、LastLoginTime等の項目が取得できず、正しく動作しません。
BASE_URL = "【BASE_URL】"
API_KEY = "【APIKEY】"
OUTPUT_SITE_ID = "【OUTPUT_SITE_ID】"

PAGE_SIZE = 200          # ユーザー取得時の1ページあたりの件数
BULK_UPSERT_MAX = 10000  # bulkupsertで1回に送れる件数の上限（General.jsonの既定値。環境により変更されている場合あり）

INACTIVE_DAYS = 90  # 何日以上ログインが無ければ棚卸対象とするか

LOGIN_ID_COLUMN = "ClassB"        # ログインID（Keyとして使用。重複判定・突合のキー）
LAST_LOGIN_COLUMN = "DateA"       # 最終ログイン日時（未ログインの場合は空欄のまま）
ELAPSED_DAYS_COLUMN = "NumA"      # 経過日数（最終ログインから、または未ログインならアカウント作成日時からの日数）
SYNCED_AT_COLUMN = "DateB"        # 棚卸実施日時（画面上のラベルは「同期日時」）
ACCOUNT_CREATED_COLUMN = "DateC"  # アカウント作成日時（経過日数の算出根拠を後から検証できるよう、常に書き込む）

# Pleasanterにおける「未ログイン」を表す内部的な固定値（実機確認済み。バージョンアップで変わる可能性あり）
NEVER_LOGGED_IN_SENTINEL = datetime.datetime(1899, 12, 30)


def api_post(url, payload):
    """Pleasanter APIへのPOSTリクエストを実行する共通処理"""
    response = requests.post(
        url,
        json=payload,
        headers={"Content-Type": "application/json"}
    )
    response.raise_for_status()
    return response


def fetch_all_users():
    """全ユーザーを、取得件数に応じてoffsetを進めながら取得する（テナント管理者のAPIキーが必要）"""
    users = []
    offset = 0

    while True:
        payload = {
            "ApiVersion": 1.1,
            "ApiKey": API_KEY,
            "Offset": offset,
            "PageSize": PAGE_SIZE,
        }
        body = api_post(f"{BASE_URL}/api/users/get", payload).json()

        page = body["Response"]["Data"]
        users.extend(page)

        offset += len(page)  # 固定値ではなく、取得件数に応じて進める
        total_count = body["Response"]["TotalCount"]

        if len(page) == 0 or offset >= total_count:
            return users


def parse_last_login(last_login_str):
    """未ログインを表す特殊値をNoneに変換し、それ以外はdatetimeで返す"""
    last_login_datetime = datetime.datetime.fromisoformat(last_login_str)

    if last_login_datetime == NEVER_LOGGED_IN_SENTINEL:
        return None

    return last_login_datetime


def elapsed_days_since_active(user, now):
    """経過日数を算出する。最終ログイン日時があればそこから、
    一度もログインしていない場合はアカウント作成日時(CreatedTime)からの日数にフォールバックする。
    アカウント作成日時は、経過日数の算出根拠を後から検証できるよう、ログイン有無に関わらず返す。
    戻り値は (経過日数, 最終ログイン日時 or None, アカウント作成日時)。"""
    last_login = parse_last_login(user.get("LastLoginTime"))
    created_time = datetime.datetime.fromisoformat(user["CreatedTime"])

    if last_login is not None:
        return (now - last_login).days, last_login, created_time

    return (now - created_time).days, None, created_time


def build_bulk_data(users, now):
    """棚卸対象（経過日数がINACTIVE_DAYS以上）のユーザーのみを、bulkupsert用のData配列に変換する
    （状況項目は含めない＝担当者がつけた対応状況を保持する）"""
    data = []

    for user in users:
        if user.get("TenantManager"):
            continue  # テナント管理者は対象外

        elapsed_days, last_login, created_time = elapsed_days_since_active(user, now)
        if elapsed_days < INACTIVE_DAYS:
            continue  # 直近ログインがある（＝アクティブな）ユーザーは棚卸対象外

        title = user["Name"] if last_login is not None else f"{user['Name']}（未ログイン）"

        date_hash = {
            SYNCED_AT_COLUMN: now.isoformat(),
            ACCOUNT_CREATED_COLUMN: created_time.isoformat(),
        }
        if last_login is not None:
            date_hash[LAST_LOGIN_COLUMN] = last_login.isoformat()

        data.append({
            "Title": title,
            "ClassHash": {
                LOGIN_ID_COLUMN: user["LoginId"]
            },
            "NumHash": {
                ELAPSED_DAYS_COLUMN: elapsed_days
            },
            "DateHash": date_hash,
        })

    return data


def chunked(items, size):
    """リストを指定件数ごとに分割する"""
    for i in range(0, len(items), size):
        yield items[i:i + size]


def bulk_upsert_records(data_chunk):
    """ログインIDをキーに、レコードをまとめて作成・更新する（1回分）"""
    payload = {
        "ApiVersion": 1.1,
        "ApiKey": API_KEY,
        "Keys": [LOGIN_ID_COLUMN],       # このキーで一致するレコードは更新、無ければ新規作成
        "KeyNotFoundCreate": True,
        "Data": data_chunk,
    }
    response = api_post(f"{BASE_URL}/api/items/{OUTPUT_SITE_ID}/bulkupsert", payload)
    return response.json()


def main():
    """長期間ログインの無いユーザーを抽出し、Pleasanterの棚卸テーブルへ一括で書き込む。
    状況項目はペイロードに含めないため、担当者が手動でつけた対応状況（対応中／完了等）は保持される。
    BulkUpsertMaxを超える件数がある場合は、BULK_UPSERT_MAXごとに分割して送信する。
    棚卸テーブル側で標準通知（作成後のみ）を設定しておくと、新規に棚卸対象となったユーザーの
    発生だけが自動的にメール通知される。"""
    now = datetime.datetime.now()

    all_users = fetch_all_users()
    bulk_data = build_bulk_data(all_users, now)

    if not bulk_data:
        print(f"(info) {INACTIVE_DAYS}日以上ログインの無いユーザーは見つかりませんでした。")
        return

    success_count = 0
    error_count = 0

    for chunk_index, data_chunk in enumerate(chunked(bulk_data, BULK_UPSERT_MAX), start=1):
        result = bulk_upsert_records(data_chunk)
        status_code = result.get("StatusCode")
        message = result.get("Message")

        print(f"[{chunk_index}回目の送信] StatusCode={status_code} Message={message}")

        if status_code != 200:
            error_count += 1
            print(f"[{chunk_index}回目の送信] エラーが発生したため、これ以降のユーザーは反映されていない可能性があります。")
        else:
            success_count += 1

    print(f"完了：棚卸対象={len(bulk_data)}件 成功した送信={success_count}回 エラーが起きた送信={error_count}回")


if __name__ == "__main__":
    main()