// 借方の債権科目は「受注書 → 取引先 → 奉行 債権科目」とたどる
acReceivable = "";
custCode     = "";
subAcctCode  = "";
acctRef = so.get("Account_Name");
if (acctRef != null && acctRef.get("id") != null)
{
    acct = zoho.crm.getRecordById("Accounts", acctRef.get("id").toLong());
    if (acct != null)
    {
        custCode    = ifnull(acct.get("Bugyo_Customer_Code"),   "").toString().trim();
        subAcctCode = ifnull(acct.get("Bugyo_Sub_Account_Code"),"").toString().trim();
        // マスタの Name は「<コード> <名称>」で同期する。
        // 表示名の先頭を取れば、参照先レコードを取りに行かずに済む
        raRef = acct.get("Bugyo_Receivable_Account");
        if (raRef != null)
        {
            acReceivable = ifnull(raRef.get("name"), "").toString().trim().getPrefix(" ").trim();
        }
    }
}
// マスタに無ければ組織変数の既定値を使う
if (acReceivable == "")
{
    acReceivable = ifnull(zoho.crm.getOrgVariable("Bugyo_Default_Receivable_Account"), "").toString().trim();
}

// 貸方の売上科目は「受注明細の商品 → 奉行 売上科目」とたどる（同じ形なので省略）

// 既定値も空なら計上しない。科目が分からないまま伝票を立てない
if (acReceivable == "" || acSales == "")
{
    emap = Map();
    emap.put("Bugyo_Sync_Status", "エラー");
    emap.put("Bugyo_Sync_Error",  "勘定科目が決まりません。取引先の債権科目／商品の売上科目／組織変数の既定値のいずれかを設定してください");
    zoho.crm.updateRecord("Sales_Orders", soId.toLong(), emap);
    return "{\"error\":\"ACCOUNT_NOT_RESOLVED\"}";
}

// 計上日の前後31日を照会する。計上日が後から変更されても拾えるようにするため
qBody = Map();
qBody.put("startDate", slipDate.toDate().subDay(31).toString("yyyy/MM/dd"));
qBody.put("endDate",   slipDate.toDate().addDay(31).toString("yyyy/MM/dd"));
qBody.put("itemList",  qItems);   // 照会したい項目のリスト。奉行の照会APIでは必須

exResp = invokeurl
[
    url        : baseUrl + "/gl/ExportJournalSlip"
    type       : POST
    headers    : hdrBase
    parameters : qBody.toString()   // ← Map を直渡しすると form-encoded になる。必ず文字列化する
    connection : "bugyo_conn"       // ← 鍵はここから自動で付く
    detailed   : true               // ← これが無いと responseCode も responseHeader も取れない
];

exCode = ifnull(exResp.get("responseCode"), 0);

// 照会そのものが失敗したら計上しない（fail-closed）
// 「二重計上していないか分からない」状態で起票するのが一番まずい
if (exCode != 200)
{
    emap = Map();
    emap.put("Bugyo_Sync_Status", "エラー");
    emap.put("Bugyo_Sync_Error",  "重複確認の照会が HTTP " + exCode + " のため計上を中止しました");
    uR = zoho.crm.updateRecord("Sales_Orders", soId.toLong(), emap);
    wb = "";
    if (uR.toString().contains("error")) { wb = ",\"writebackFailed\":true"; }
    return "{\"error\":\"DEDUPE_CHECK_FAILED\",\"httpCode\":" + exCode + wb + "}";
}

baseUrl  = ifnull(zoho.crm.getOrgVariable("Bugyo_Base_URL"),          "").toString().trim();
subKey   = ifnull(zoho.crm.getOrgVariable("Bugyo_Subscription_Key"), "").toString().trim();
tenantId = ifnull(zoho.crm.getOrgVariable("Bugyo_Tenant_ID"),        "").toString().trim();
if (baseUrl == "" || subKey == "" || tenantId == "")
{
    return "{\"error\":\"CONFIG_MISSING\"}";
}

// 全リクエスト共通のヘッダー。Authorization は Connection が付けるのでここには書かない
hdrBase = Map();
hdrBase.put("X-OBC-TenantID",        tenantId);
hdrBase.put("X-OBC-SubscriptionKey", subKey);
hdrBase.put("Content-Type",          "application/json");

so = zoho.crm.getRecordById("Sales_Orders", soId.toLong());
if (so == null || so.get("id") == null) { return "{\"error\":\"SO_NOT_FOUND\"}"; }

traceKey = "ZOHO-SO-" + soId;

// 関所1: すでに連携済みなら、奉行の API を1回も呼ばずに終わる
curStatus = ifnull(so.get("Bugyo_Sync_Status"), "").toString();
curSlipNo = ifnull(so.get("Bugyo_Slip_No"),     "").toString();
if (curStatus == "連携済")      // ← 選択肢の表示値と完全一致させること
{
    return "{\"skipped\":\"ALREADY_POSTED_LOCAL\",\"slipNo\":\"" + curSlipNo + "\"}";
}

// 関所2: 受注ステータスは白リスト。下書きやキャンセルは計上しない
// ※ getRecordById が返すのは「表示値」。自組織の値を確認してから書くこと
soStatus = ifnull(so.get("Status"), "").toString();
// ↓ 自組織の getRecordById が返す値に置き換えること（日本語組織では「承認済み」等）
if (soStatus != "Approved" && soStatus != "Delivered")
{
    wmap = Map();
    wmap.put("Bugyo_Sync_Status", "エラー");
    wmap.put("Bugyo_Sync_Error", "計上できるのは承認済または納品済の受注だけです。現在: " + soStatus);
    uR = zoho.crm.updateRecord("Sales_Orders", soId.toLong(), wmap);
    wb = "";
    if (uR.toString().contains("error")) { wb = ",\"writebackFailed\":true"; }   // ← 黙って落ちる
    return "{\"error\":\"SO_STATUS_NOT_ALLOWED\",\"status\":\"" + soStatus + "\"" + wb + "}";
}

// 関所3: 計上日は受注の「期限」を正とする。実行日から推測しない
dueDate  = so.get("Due_Date");
slipDate = "";
if (dueDate != null && dueDate.toString().length() >= 10)
{
    slipDate = dueDate.toString().subString(0, 10).replaceAll("-", "/");
}
if (slipDate == "")
{
    emap = Map();
    emap.put("Bugyo_Sync_Status", "エラー");
    emap.put("Bugyo_Sync_Error", "計上日に使う「期限」が未設定です。実行日から推測すると会計期間がずれるため計上しません");
    uR = zoho.crm.updateRecord("Sales_Orders", soId.toLong(), emap);
    wb = "";
    if (uR.toString().contains("error")) { wb = ",\"writebackFailed\":true"; }
    return "{\"error\":\"NO_SLIP_DATE\"" + wb + "}";
}

// 受注書の Tax 項目は getRecordById から 0 にしか見えないため、総計から逆算する
subTotal   = ifnull(so.get("Sub_Total"),   0).toDecimal();
discount   = ifnull(so.get("Discount"),    0).toDecimal();
adjust     = ifnull(so.get("Adjustment"),  0).toDecimal();
grandTotal = ifnull(so.get("Grand_Total"), 0).toDecimal();

netRaw = subTotal - discount + adjust;   // 税抜の本体金額
taxRaw = grandTotal - netRaw;            // 消費税額（無ければ 0 になる）

// 丸めは先に総計と税で行い、本体は差で出す。
// こうすると net + tax = total が定義として必ず成立する
totalR = grandTotal.round(0);
taxR   = taxRaw.round(0);
netR   = totalR - taxR;

// 件名は人が自由に書くテキスト。JSON を壊す文字を潰してから使う
rawSubject = ifnull(so.get("Subject"), "Zoho CRM juchu").toString();
rawSubject = rawSubject.replaceAll("\\", "/");
rawSubject = rawSubject.replaceAll("\"", "'");
rawSubject = rawSubject.replaceAll("\n", " ");
rawSubject = rawSubject.replaceAll("\r", " ");

// トレースキーは必ず先頭に置く。摘要は200字で切られるので、
// 後ろが切れても重複検知の鍵だけは生き残るようにする
lineMemo = "[" + traceKey + "] " + rawSubject;
if (lineMemo.length() > 200)
{
    lineMemo = lineMemo.subString(0, 200);
}

// 税区分。税額0を勝手に「不課税」と決めつけない
taxType   = ifnull(so.get("Bugyo_Tax_Type"), "").toString().trim();
isTaxable = false;
rateKind  = RATEKIND_STD;                       // 0: 標準
if (taxType == "課税売上 10%")    { isTaxable = true; rateKind = RATEKIND_STD; }
if (taxType == "課税売上 軽減8%") { isTaxable = true; rateKind = RATEKIND_RED; }   // 1: 軽減

taxErr = "";
if (taxType == "")
{
    taxErr = "税区分が未設定です。課税／軽減／非課税／不課税のどれかを選んでください";
}
else if (isTaxable && taxR <= 0)
{
    taxErr = "税区分が課税売上なのに消費税額が0です。税率マスタの設定か金額を確認してください";
}
else if (!isTaxable && taxR > 0)
{
    taxErr = "税区分が " + taxType + " なのに消費税額が " + taxR + " あります";
}
if (taxErr != "")
{
    emap = Map();
    emap.put("Bugyo_Sync_Status", "エラー");
    emap.put("Bugyo_Sync_Error",  taxErr);
    uR = zoho.crm.updateRecord("Sales_Orders", soId.toLong(), emap);
    wb = "";
    if (uR.toString().contains("error")) { wb = ",\"writebackFailed\":true"; }
    return "{\"error\":\"TAX_TYPE_INVALID\",\"taxType\":\"" + taxType + "\"" + wb + "}";
}

// 項目記号（伝票日付・摘要・借方科目…を指す識別子）は
// 勘定奉行クラウドの API 仕様書に記載がある。ここでは意味が読めるよう定数名に写してある。
line = Map();
line.put(ITEM_ROW_MARK,  "*");          // 新規行を表す区分値
line.put(ITEM_SLIP_DATE, slipDate);     // 伝票日付
line.put(ITEM_LINE_MEMO, lineMemo);     // 明細行の摘要（ここにトレースキーが入る）

// 借方: 債権科目（取引先マスタ由来）
line.put(ITEM_DR_ACCOUNT, acReceivable);
line.put(ITEM_DR_AMOUNT,  totalR.toString());    // 借方は税込の総額
line.put(ITEM_DR_TAX,     "0");
line.put(ITEM_DR_TAXCALC, TAXCALC_NONE);         // 借方では税計算させない

// 貸方: 売上科目（商品マスタ由来）と消費税区分（マスタ由来）
line.put(ITEM_CR_ACCOUNT,     acSales);
line.put(ITEM_CR_TAXCATEGORY, taxCatCode);   // 課税・非課税にかかわらず必ず送る

// 補助科目・取引先コードは設定されているときだけ送る（空で送ると弾かれる）
if (subAcctCode != "")
{
    line.put(ITEM_DR_SUBACCOUNT, subAcctCode);
    line.put(ITEM_CR_SUBACCOUNT, subAcctCode);
}
if (custCode != "")
{
    line.put(ITEM_DR_CUSTOMER, custCode);
    line.put(ITEM_CR_CUSTOMER, custCode);
}

if (isTaxable)
{
    // 税抜金額と消費税額を明示する。奉行に税を計算させない
    // 消費税率種別で標準(10%)と軽減(8%)を分ける
    line.put(ITEM_CR_AMOUNT,   netR.toString());
    line.put(ITEM_CR_TAX,      taxR.toString());
    line.put(ITEM_CR_TAXCALC,  TAXCALC_EXCL);
    line.put(ITEM_CR_RATEKIND, rateKind);
}
else
{
    // 非課税・不課税。税額は0で立てる
    // 消費税区分は上で送っているので、科目マスタの既定（課税売上）は使われない
    line.put(ITEM_CR_AMOUNT,  totalR.toString());
    line.put(ITEM_CR_TAX,     "0");
    line.put(ITEM_CR_TAXCALC, TAXCALC_NONE);
}

// 奉行に送る消費税区分コードをマスタから引く
// 受注書の上書き > 商品マスタの既定 の順に見る
taxCatCode = "";
taxCatName = "";
if (taxCatRef != null)
{
    tcLabel    = ifnull(taxCatRef.get("name"), "").toString().trim();
    taxCatCode = tcLabel.getPrefix(" ").trim();   // 「0005 不課税売上」の先頭
    taxCatName = tcLabel.getSuffix(" ").trim();
}
if (taxCatCode == "")
{
    // 区分が決まらないなら計上しない。ここも他のガードと同じ fail-closed に揃える
    emap = Map();
    emap.put("Bugyo_Sync_Status", "エラー");
    emap.put("Bugyo_Sync_Error",  "消費税区分が決まりません。受注書か商品に「奉行 消費税区分」を設定してください");
    uR = zoho.crm.updateRecord("Sales_Orders", soId.toLong(), emap);
    wb = "";
    if (uR.toString().contains("error")) { wb = ",\"writebackFailed\":true"; }
    return "{\"error\":\"TAX_CATEGORY_NOT_RESOLVED\"" + wb + "}";
}

// 税区分（課税か否か）とマスタの区分名が食い違っていたら止める
catIsTaxable = taxCatName.startsWith("課税売上");
if (catIsTaxable != isTaxable)
{
    return "{\"error\":\"TAX_CATEGORY_MISMATCH\"}";
}

string button.bugyoPostFromButton(String soId)
{
    // カスタムボタンから選べるのは「ボタン」カテゴリーの関数だけなので、
    // 本体を単独関数に置き、ここは薄いラッパーにしている
    return standalone.postSalesOrderToBugyo(soId);
}

// Deluge の単独関数では while が使えないため、固定リストを回す
for each idx in {1,2,3,4,5,6,7,8,9,10,11,12}
{
    if (!isFinished)
    {
        pollHdr = Map();
        pollHdr.put("X-OBC-TenantID",        tenantId);
        pollHdr.put("X-OBC-SubscriptionKey", subKey);
        pollHdr.put("Content-Type",          "application/json");
        if (contToken != "")
        {
            pollHdr.put("X-OBC-ContinuationToken", contToken);
        }

        pResp = invokeurl
        [
            url        : baseUrl + "/gl/v2/ImportJournalSlipResult"
            type       : POST
            headers    : pollHdr
            parameters : pBody.toString()      // {"operationID": opId}
            connection : "bugyo_conn"
            detailed   : true                  // responseHeader を取るために必須
        ];

        // 次のリクエストのためにトークンを取り出しておく
        respHdrs  = ifnull(pResp.get("responseHeader"), Map());
        contToken = ifnull(respHdrs.get("X-OBC-ContinuationToken"),
                    ifnull(respHdrs.get("x-obc-continuationtoken"), "")).toString();

        pText = ifnull(pResp.get("responseText"), "").toString().trim();
        if (pText.startsWith("{"))
        {
            pMap = pText.toMap();
            if (ifnull(pMap.get("status"), "").toString() == "Finished") { isFinished = true; }
        }
    }
}

// 参照先を取りに行かず、表示名からコードを取る（1往復ぶん節約）
raRef = acct.get("Bugyo_Receivable_Account");
if (raRef != null)
{
    acReceivable = ifnull(raRef.get("name"), "").toString().trim().getPrefix(" ").trim();
}