<?php
//------------------------------
// 設定値
//------------------------------
define("API_URL", "https://api.spiral-platform.com/v1");
//APIKEY
define("API_KEY", "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx");
//APIアプリロールの識別名
define("APP_ROLE", "xxxxx");
//物件マスタDBのDBID
define("PROPERTY_DB_ID", "xxxxx");
//カレンダーDBのDBID
define("CALENDER_DB_ID", "xxxxx");
//エラー内容メール通知DBのDBID
define("ERRORMAIL_DB_ID", "xxxxx");
//アプリID
define("APP_ID", "xxxxx");

//------------------------------
// API実行
//------------------------------

$commonBase = CommonBase::getInstance();

//------------------------------
// 物件マスタDBの取得
//------------------------------

//公開フラグが公開のフィールドを取得(publicFlgは物件マスタDBの公開フラグの識別名)
$where = "?where=@publicFlg='2'";

//取得するフィールドの決定(propertyID,propertyName,week,seatNum,publicDateは物件マスタDBの物件ID、物件名、予約不可曜日、残席数、公開日の識別名)
$fields = "&fields=propertyID,propertyName,week,seatNum,publicDate";

// totalCountを取得するため、enableTotalCountをtrue
$enableTotalCount = "&enableTotalCount=true";

//レコードの取得
$resultRecordListSelect = $commonBase->apiCurlAction("GET", "/apps/". APP_ID. "/dbs/". PROPERTY_DB_ID. "/records" . $where . $fields . $enableTotalCount);

//------------------------------
// 21日後の日付の取得
//------------------------------

$threeWeekDate = date("Y-m-d",strtotime("+21 day"));

//------------------------------
// 登録するデータの作成
//------------------------------

//予約時間
$reservationTime = array(10,13,16);
//登録するデータを格納する配列
$regData=array();

if($resultRecordListSelect["totalCount"]>0){
    //物件分だけ値を出す
    foreach($resultRecordListSelect["items"] as $propertyValue){
        //1週間分のデータを登録
        for($i=0; $i<7; $i++){
            foreach($reservationTime as $timeValue){
                //登録する日付
                $date = date("Y-m-d",strtotime($threeWeekDate ."+" . $i ." day"));
                if(is_array($propertyValue["week"])){
                    //array_searchで配列の中にその値が含まれているかをチェック(weekは物件マスタDBの予約不可曜日の識別名)
                    if(in_array(date('w', strtotime($date)),$propertyValue["week"])){
                        $regData[] = array(
                            //参照フィールドのid(preview_refはカレンダーDBの参照＿物件マスタDBの識別名)
                            "preview_ref"  => $propertyValue["_id"],
                            //物件名(propertyNameはカレンダーDBの物件名の識別名)
                            "propertyName"  => $propertyValue["propertyName"],
                            //予約日付が21日後の$i日後を登録(reservationDateはカレンダーDBの予約日の識別名)
                            "reservationDate" => $date,
                            //予約時間の入力(reservationTimeはカレンダーDBの予約時間の識別名)
                            "reservationTime" => $timeValue . ":0:0",
                            //残席数(seatNumはカレンダーDBの残席数の識別名)
                            "seatNum" => $propertyValue["seatNum"],
                            //値がある場合、休日フラグを立てる(holidayFlagはカレンダーDBの休日フラグの識別名)
                            "holidayFlag" => "2",
                            //予約IDの作成(物件ID_yyyy-mm-dd-hh)(物件ID_yyyy-mm-dd-hh)(reservationIDはカレンダーDBの予約ID、propertyIDは物件マスタDBの物件IDの識別名)
                            "reservationID"  => $propertyValue["propertyID"] . "_" . $date . "-" . $timeValue ,
                            //物件ID(propertyIDはカレンダーDB、$propertyValue["propertyID"]のpropertyIDは物件マスタDBの物件IDの識別名)
                            "propertyID" => $propertyValue["propertyID"]
                        );
                    }else{
                        $regData[] = array(
                            //参照フィールドのid(preview_refはカレンダーDBの参照＿物件マスタDBの識別名)
                            "preview_ref"  => $propertyValue["_id"],
                            //物件名(propertyNameはカレンダーDBの物件名の識別名)
                            "propertyName"  => $propertyValue["propertyName"],
                            //予約日付が21日後の$i日後を登録(reservationDateはカレンダーDBの予約日の識別名)
                            "reservationDate" => $date,
                            //予約時間の入力(reservationTimeはカレンダーDBの予約時間の識別名)
                            "reservationTime" => $timeValue . ":0:0",
                            //残席数(seatNumはカレンダーDBの残席数の識別名)
                            "seatNum" => $propertyValue["seatNum"],
                            //値がない場合、休日フラグを立てない(holidayFlagはカレンダーDBの休日フラグの識別名)
                            "holidayFlag" => "1",
                            //予約IDの作成(物件ID_yyyy-mm-dd-hh)(物件ID_yyyy-mm-dd-hh)(reservationIDはカレンダーDBの予約ID、propertyIDは物件マスタDBの物件IDの識別名)
                            "reservationID"  => $propertyValue["propertyID"] . "_" . $date . "-" . $timeValue ,
                            //物件ID(propertyIDはカレンダーDB、$propertyValue["propertyID"]のpropertyIDは物件マスタDBの物件IDの識別名)
                            "propertyID" => $propertyValue["propertyID"]
                        );
                    }
                }else{
                    $regData[] = array(
                        //参照フィールドのid(preview_refはカレンダーDBの参照＿物件マスタDBの識別名)
                        "preview_ref"  => $propertyValue["_id"],
                        //物件名(propertyNameはカレンダーDBの物件名の識別名)
                        "propertyName"  => $propertyValue["propertyName"],
                        //予約日付が21日後の$i日後を登録(reservationDateはカレンダーDBの予約日の識別名)
                        "reservationDate" => $date,
                        //予約時間の入力(reservationTimeはカレンダーDBの予約時間の識別名)
                        "reservationTime" => $timeValue . ":0:0",
                        //残席数(seatNumはカレンダーDBの残席数の識別名)
                        "seatNum" => $propertyValue["seatNum"],
                        //値がない場合、休日フラグを立てない(holidayFlagはカレンダーDBの休日フラグの識別名)
                        "holidayFlag" => "1",
                        //予約IDの作成(物件ID_yyyy-mm-dd-hh)(物件ID_yyyy-mm-dd-hh)(reservationIDはカレンダーDBの予約ID、propertyIDは物件マスタDBの物件IDの識別名)
                        "reservationID"  => $propertyValue["propertyID"] . "_" . $date . "-" . $timeValue ,
                        //物件ID(propertyIDはカレンダーDB、$propertyValue["propertyID"]のpropertyIDは物件マスタDBの物件IDの識別名)
                        "propertyID" => $propertyValue["propertyID"]
                    );
                }
            }
        }
    }

    //------------------------------
    // データの複数登録
    //------------------------------

    $bulkInsertData = array("records" => $regData);
    $resultRecordListInsert = $commonBase->apiCurlAction("POST", "/apps/". APP_ID. "/dbs/". CALENDER_DB_ID. "/records/bulk", $bulkInsertData);

    //------------------------------
    //データの登録に失敗したとき
    //------------------------------

    if(array_key_exists('status',$resultRecordListInsert)){
        // スケジュールトリガで登録される予定の最後の日付
        $threeWeekRegistDate = date("Y-m-d",strtotime("+27 day"));
        // 登録するデータを指定
        $insertData = array(
            ////エラーメッセージの作成(errorMessageはエラー内容メール通知DBのエラーメッセージの識別名)
            "errorMessage"  => ("code：" . $resultRecordListInsert["errors"][0]["code"] . "\n" . "message：" . $resultRecordListInsert["errors"][0]["message"] . "\n" . 
                                "locationType：" . $resultRecordListInsert["errors"][0]["locationType"] . "\n" . "location："  . $resultRecordListInsert["errors"][0]["location"] . "\n\n" .
                                "messageがvalue is duplicatedlocationの場合、カレンダーDBに登録する予定の日付が既に登録されています。" . "\n" .
                                $threeWeekDate . "から" . $threeWeekRegistDate . "の登録されている日付を手動で削除し、スケジュールトリガを手動実行をしてください。") ,
            //エラーフラグをエラーで登録(errorFlgはエラー内容メール通知DBのエラーフラグの識別名)
            "errorFlg"  => "0"
        );
        $resultRecordInsert = $commonBase->apiCurlAction("POST", "/apps/". APP_ID. "/dbs/". ERRORMAIL_DB_ID. "/records", $insertData);
        // 出力チェック
        // print_r($resultRecordInsert);
    }
}else{
    // 出力チェック
    // echo "公開準備が「公開」のフィールドがありません";
}

//------------------------------
// 共通モジュール
//------------------------------
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);
        }
    }
}
?>

<?php
//------------------------------
// 設定値
//------------------------------
define("API_URL", "https://api.spiral-platform.com/v1");
//APIKEY
define("API_KEY", "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx");
//APIアプリロールの識別名
define("APP_ROLE", "xxxxx");
//カレンダーDBのDBID
define("CALENDER_DB_ID", "xxxxx");
//アプリID
define("APP_ID", "xxxxx");

//------------------------------
// API実行
//------------------------------

$commonBase = CommonBase::getInstance();

// 検索条件：今日より前の日付(reservationDateにはカレンダーDBの予約日の識別名)
$requestBody = array(
    "where" => "@reservationDate < DATE(NOW())"
);

// 削除バッチ処理
$resultBatch = $commonBase->apiCurlAction("POST", "/apps/". APP_ID. "/dbs/". CALENDER_DB_ID. "/records/batchDeletes", $requestBody);

//------------------------------
// 共通モジュール
//------------------------------
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);
        }
    }
}
?>