レコード一括削除

# WebサイトやAPIと通信するためのライブラリ
import requests

# JSON操作のためのライブラリ
import json

# サーバ名、APIキー
BASE_URL = (
    "【URL】"
)
API_KEY = "【APIキー】"

# 検索開始サイトID
START_SITE_ID = 【サイトID】

# 対象サイト名と削除対象ステータス
TARGET_SITE_NAME = "案件管理"
TARGET_STATUS = '["910"]'  # 保留(910)

# 物理削除（履歴/ゴミ箱も含めて削除）したい場合は True
PHYSICAL_DELETE = False

# セッション共通化
session = requests.Session()
session.headers.update({"Content-Type": "application/json"})

# JSON POST リクエスト共通関数
def post_json(url: str, payload: dict) -> dict:
    r = session.post(url, data=json.dumps(payload))
    if not r.ok:
        raise RuntimeError(f"HTTP {r.status_code} {url}\n{r.text}")
    return r.json()

# 1) サイト名から SiteId を取得
getclosest_url = f"{BASE_URL}/api/items/{START_SITE_ID}/getclosestsiteid"
closest_payload = {
    "ApiVersion": 1.1,
    "ApiKey": API_KEY,
    "FindSiteNames": [TARGET_SITE_NAME],
}

closest_res = post_json(getclosest_url, closest_payload)
data_list = closest_res.get("Data", [])
if not data_list:
    print(f"{TARGET_SITE_NAME} サイト情報取得失敗")
    raise SystemExit()

site_id = data_list[0].get("SiteId")
if not isinstance(site_id, int) or site_id <= 0:
    print(f"{TARGET_SITE_NAME} サイトID不正: {site_id}")
    raise SystemExit()

print(f"対象サイトID取得成功: {site_id}")

# 2) Status=910 のレコード取得（削除対象の確認用）
get_url = f"{BASE_URL}/api/items/{site_id}/get"
get_payload = {
    "ApiVersion": 1.1,
    "ApiKey": API_KEY,
    "View": {
        "ColumnFilterHash": {
            "Status": TARGET_STATUS,
        }
    },
}

get_res = post_json(get_url, get_payload)

rows = []
if isinstance(get_res, dict):
    rows = (get_res.get("Response", {}) or {}).get("Data", []) or []
elif isinstance(get_res, list):
    rows = get_res

if not rows:
    print("削除対象データなし")
    raise SystemExit()

# 3) 取得したレコードIDをまとめて bulkdelete（Selected指定）
record_ids = []
for row in rows:
    rid = row.get("ResultId") or row.get("Id")
    if isinstance(rid, int) and rid > 0:
        record_ids.append(rid)

# 念のため重複排除
record_ids = sorted(set(record_ids))

if not record_ids:
    print("削除対象IDが取得できませんでした")
    raise SystemExit()

bulkdelete_url = f"{BASE_URL}/api/items/{site_id}/bulkdelete"
bulkdelete_payload = {
    "ApiVersion": 1.1,
    "ApiKey": API_KEY,
    "Selected": record_ids,  # ← ID配列を指定して一括削除
    "PhysicalDelete": PHYSICAL_DELETE,
}

try:
    bulk_res = post_json(bulkdelete_url, bulkdelete_payload)
    # bulkdeleteのレスポンス例: { Id: <siteId>, StatusCode: 200, Message: "..." }
    print("bulkdelete 実行結果:", bulk_res)
except Exception as e:
    print("bulkdelete 失敗")
    print(e)

# WebサイトやAPIと通信するためのライブラリ
import requests

# JSON操作のためのライブラリ
import json

# サーバ名、APIキー
BASE_URL = "【URL】"
API_KEY = "【APIキー】"

# 検索開始サイトID
START_SITE_ID = 6429

# 対象サイト名と削除対象ステータス
TARGET_SITE_NAME = "案件管理"
TARGET_STATUS = '["910"]'  # 保留(910)

# 物理削除する場合は True（復元不可）
PHYSICAL_DELETE = False

# セッション共通化
session = requests.Session()
session.headers.update({"Content-Type": "application/json"})

def post_json(url: str, payload: dict) -> dict:
    r = session.post(url, data=json.dumps(payload))
    if not r.ok:
        raise RuntimeError(f"HTTP {r.status_code} {url}\n{r.text}")
    return r.json()

# 1) サイト名から SiteId を取得
getclosest_url = f"{BASE_URL}/api/items/{START_SITE_ID}/getclosestsiteid"
closest_payload = {
    "ApiVersion": 1.1,
    "ApiKey": API_KEY,
    "FindSiteNames": [TARGET_SITE_NAME],
}

closest_res = post_json(getclosest_url, closest_payload)
data_list = closest_res.get("Data", [])
if not data_list:
    print(f"{TARGET_SITE_NAME} サイト情報取得失敗")
    raise SystemExit()

site_id = data_list[0].get("SiteId")
if not isinstance(site_id, int) or site_id <= 0:
    print(f"{TARGET_SITE_NAME} サイトID不正: {site_id}")
    raise SystemExit()

print(f"対象サイトID取得成功: {site_id}")

# 2) View 条件を指定して bulkdelete
bulkdelete_url = f"{BASE_URL}/api/items/{site_id}/bulkdelete"
bulkdelete_payload = {
    "ApiVersion": 1.1,
    "ApiKey": API_KEY,
    "View": {"ColumnFilterHash": {"Status": TARGET_STATUS}},
    "PhysicalDelete": PHYSICAL_DELETE,
}

try:
    res = post_json(bulkdelete_url, bulkdelete_payload)
    print("bulkdelete 実行結果:", res)
except Exception as e:
    print("bulkdelete 失敗")
    print(e)