メール送信

# ==========================================================
# 請求書の発行完了の通知：会計システムが出力した発行完了のCSVを1行ずつ読み、
# 案件コードで案件管理のレコードを探して、担当者のメールアドレスへ請求書のPDFを
# 添付して送ります（メール送信APIは、送るときにレコードのIDを指定します。ここでは見つけた案件のID）。
# ==========================================================
import base64
import csv
import sys
from pathlib import Path

import requests

# ===== 設定 =====
BASE_URL = "【URL】"
API_KEY = "【APIキー】"
PROJECT_SITE_ID = "【案件管理のサイトID】"
CODE_COLUMN = "ClassA"   # 案件コード
MAIL_COLUMN = "ClassB"   # 担当者のメールアドレス
INPUT_CSV = Path("./invoice_completed.csv")  # 1行目は見出し「案件コード,請求書ファイル,請求金額,発行日」


def api_post(path, payload=None):
    """Pleasanter APIへPOSTする。HTTPステータスとレスポンスのJSONを返す"""
    response = requests.post(
        f"{BASE_URL}{path}",
        json={"ApiVersion": 1.1, "ApiKey": API_KEY, **(payload or {})},
        headers={"Content-Type": "application/json"},
        timeout=60,
    )
    return response.status_code, response.json()


def find_project(code):
    """案件コードが一致する案件を探す。1件に決まらなければ None"""
    # 分類項目の絞り込みは、配列形式＋ExactMatchMultipleでないと完全一致にならない
    view = {
        "ColumnFilterHash": {CODE_COLUMN: f'["{code}"]'},
        "ColumnFilterSearchTypes": {CODE_COLUMN: "ExactMatchMultiple"},
    }
    _, body = api_post(f"/api/items/{int(PROJECT_SITE_ID)}/get", {"View": view})
    rows = body.get("Response", {}).get("Data", [])
    return rows[0] if len(rows) == 1 else None


def send_notice(row):
    """1行分の通知を送る。失敗したら理由を返す（送れたら None）"""
    project = find_project(row["案件コード"])
    if project is None:
        return "案件が1件に決まりません"
    to = project.get("ClassHash", {}).get(MAIL_COLUMN, "")
    if not to:
        return "担当者のメールアドレスが空です"
    pdf = Path(row["請求書ファイル"])
    if not pdf.is_file():
        return f"請求書ファイルがありません（{pdf}）"
    status, body = api_post(f"/api/items/{project['IssueId']}/OutgoingMails/Send", {
        "To": to,
        "Title": f"【請求書発行】{row['案件コード']} {project['Title']}",
        "Body": f"{project['Title']} の請求書を発行しました。\n請求金額：{int(row['請求金額']):,}円\n発行日：{row['発行日']}",
        "Attachments": [{
            "Name": pdf.name,
            "Base64": base64.b64encode(pdf.read_bytes()).decode("ascii"),
            "ContentType": "application/pdf",
        }],
    })
    if status != 200 or body.get("StatusCode") != 200:
        return body.get("Message", f"HTTP {status}")
    return None


def main():
    with open(INPUT_CSV, encoding="utf-8-sig", newline="") as f:
        rows = [row for row in csv.DictReader(f) if row["案件コード"].strip()]
    failed = 0
    for row in rows:
        reason = send_notice(row)
        if reason:
            # 1行で失敗しても、残りの行は送る
            print(f"[NG] {row['案件コード']}: {reason}")
            failed += 1
        else:
            print(f"[OK] {row['案件コード']}: 送りました")
    # 失敗があれば終了コード 1 にして、呼び出し元で気付けるようにする
    if failed:
        sys.exit(1)


if __name__ == "__main__":
    main()