<?php
//------------------------------
// 設定値
//------------------------------
define("API_URL", "https://api.spiral-platform.com/v1");
define("API_KEY", "");
define("APP_ROLE", "");
define("APP_ID", "");
define("DB_ID", "");
// 複数のファイルフィールドとテキストフィールドの組み合わせ
$fieldMappings = [
    [
        'fileFieldTitle' => 'file1', // リネームしたいファイルフィールドの識別名 
        'fileFieldId' => '2', // ファイルフィールドのIDを設定
        'textFieldTitle' => 'text1', // 自動発番されるフィールドの識別名
        'prefix' => ['接頭語1_', '接頭語2_'], // 接頭語
        'suffixes' => ['_接尾語1', '_接尾語2'] // 接尾語
    ],
    [
        'fileFieldTitle' => 'file2', 
        'fileFieldId' => '4', 
        'textFieldTitle' => 'text2',
        'prefix' => [], // 接頭語なし
        'suffixes' => [] // 接尾語なし
    ]
];

//------------------------------
// API実行
//------------------------------
$commonBase = CommonBase::getInstance();

// レコード取得
$record = $SPIRAL->getRecord();

foreach ($fieldMappings as $mapping) {
    $fileFieldId = $mapping['fileFieldId'];
    $fileFieldTitle = $mapping['fileFieldTitle'];
    $textFieldTitle = $mapping['textFieldTitle'];
    $prefixes = $mapping['prefix'];
    $suffixes = $mapping['suffixes'];

    // テキストフィールドとファイルフィールドの値を取得
    $textValue = $record['item'][$textFieldTitle];
    $files = $record['item'][$fileFieldTitle];

    // ファイルキーを格納する配列
    $fileKeyArray = [];

    //------------------------------
    // ファイルをダウンロードしてリネーム
    //------------------------------
    foreach ($files as $index => $file) {
        $fileKey = $file['fileKey']; // ファイルキーを取得
        $recordId = $record['item']['_id']; // レコードIDも取得

        // ダウンロード用のAPI URLを作成
        $apiUrlPass = "/apps/" . APP_ID . "/dbs/" . DB_ID . "/" . $fileFieldId . "/" . $recordId . "/files/" . $fileKey . "/download";

        // APIを使ってファイルをダウンロード 
        $apiResponse = $commonBase->apiCurlAction("GET", $apiUrlPass, "", "", "not");
        $fileContent = $apiResponse;

        // 元のファイル名を取得
        $originalFileName = $file['fileName'];
        $fileExtension = '';
        if (strpos($originalFileName, '.') !== false) {
            $fileExtension = substr($originalFileName, strrpos($originalFileName, '.') + 1);
        }

        // 接頭語と接尾語を取得
        $prefix = isset($prefixes[$index]) ? $prefixes[$index] : '';
        $suffix = isset($suffixes[$index]) ? $suffixes[$index] : '';

        // 新しいファイル名を作成
        $newFileName = $prefix . $textValue . $suffix . "." . $fileExtension;

        //------------------------------
        // アップロード
        //------------------------------
        // アップロードトークン生成
        $uploadTokenResponse = $commonBase->apiCurlAction("POST", "/apps/" . APP_ID . "/dbs/" . DB_ID . "/" . $fileFieldId . "/files/uploadToken");
        if (isset($uploadTokenResponse['fileUploadToken'])) {
            $uploadToken = $uploadTokenResponse['fileUploadToken'];
            // アップロード用のリクエストボディを作成
            $requestBody = "--WebKitFormBoundary7MA4YWxkTrZu0gW\r\n";
            $requestBody .= "Content-Disposition: form-data; name=\"file\"; filename=\"" . $newFileName . "\"\r\n";
            $requestBody .= "Content-Type: text/plain\r\n\r\n";
            $requestBody .= $fileContent . "\r\n";  // 直接ファイル内容をアップロード
            $requestBody .= "--WebKitFormBoundary7MA4YWxkTrZu0gW\r\n";
            $requestBody .= "Content-Disposition: form-data; name=\"fileUploadToken\"\r\n\r\n";
            $requestBody .= $uploadToken . "\r\n";
            $requestBody .= "--WebKitFormBoundary7MA4YWxkTrZu0gW--";

            $contentType = "Content-Type: multipart/form-data; boundary=WebKitFormBoundary7MA4YWxkTrZu0gW";
            $apiResponse = $commonBase->apiCurlAction("POST", "/apps/". APP_ID. "/dbs/". DB_ID. "/". $fileFieldId. "/files", $requestBody, $contentType);

            // ファイルキーを配列に追加
            if (isset($apiResponse['fileKey'])) {
                $fileKeyArray[] = $apiResponse['fileKey'];
            }
        }
    }

    // レコードにファイルを紐づけ
    $updateData = [
        $fileFieldTitle => $fileKeyArray // fileFieldTitleを使用してファイルキーを配列にまとめる
    ];

    $apiResponse = $commonBase->apiCurlAction("PATCH", "/apps/". APP_ID. "/dbs/". DB_ID. "/records/". $recordId, $updateData);
}

//------------------------------
// 共通モジュール
//------------------------------
class CommonBase {
    /**
     * シングルトンインスタンス
     * @var UserManager
     */
    protected static $singleton;

    public function __construct() {
        if (self::$singleton) {
            throw new Exception('must be singleton');
        }
        self::$singleton = $this;
    }

    /**
     * シングルトンインスタンスを返す
     * @return UserManager
     */
    public static function getInstance() {
        if (!self::$singleton) {
            return new CommonBase();
        } else {
            return self::$singleton;
        }
    }

    /**
     * V2用 API送信ロジック
     * @return Result
     */
    function apiCurlAction($method, $addUrlPass, $data = null, $multiPart = null, $jsonDecode = null) {
        $header = array(
            "Authorization:Bearer " . API_KEY,
            "X-Spiral-Api-Version: 1.1",
        );
        if ($multiPart) {
            $header = array_merge($header, array($multiPart));
        } else {
            $header = array_merge($header, array("Content-Type:application/json"));
        }
        if (APP_ROLE) {
            $header = array_merge($header, array("X-Spiral-App-Role: " . APP_ROLE));
        }

        // curl
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_URL, API_URL . $addUrlPass);
        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
        if ($method == "POST") {
            if ($multiPart) {
                curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
            } else {
                curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
            }
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
        }
        if ($method == "PATCH") {
            curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
        }
        if ($method == "DELETE") {
            curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
            curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
        }
        $response = curl_exec($curl);
        if (curl_errno($curl)) echo curl_error($curl);
        curl_close($curl);
        if ($jsonDecode) {
            return $response;
        } else {
            return json_decode($response, true);
        }
    }
}
?>