<?php

// DB関連&Constファイル
require_once("/home/homepage/public_html/devel/src/common/FlagConst.php");
require_once("/home/homepage/public_html/devel/src/common/SysConst.php");
require_once("/home/homepage/public_html/devel/src/common/CommonConst.php");
require_once("/home/homepage/public_html/devel/src/common/db/DBCtl.class.php");

// データ抽出クラス&データ整形
require_once(CARSENSOR_BATH_PATH . "carsensor_data.class.php");

// FPT Download 
require_once(CARSENSOR_BATH_PATH . "carsensor_ftp.php");

require_once(CARSENSOR_BATH_PATH . "carsensor_common.php");

ini_set("max_execution_time","1000");
 
Carsensor_Common::gfPrintLog("===========================バッチ処理開始===========================");

$carsensor_obj = new CarSensor_Data();


// カーセンサーと連動する店舗の企業法人一覧を取得する
$huojinList = $carsensor_obj->getHojincd();
$carsensor_hojincd = array();
if (isset($huojinList) && is_array($huojinList) && count($huojinList) > 0) {
    Carsensor_Common::gfPrintLog("カーセンサと連動する企業法人コード：");
    foreach($huojinList as $value) {
        $carsensor_hojincd[] = $value['carsensor_hojincd'];
        Carsensor_Common::gfPrintLog($value['carsensor_hojincd']);
    }
}else{
    Carsensor_Common::gfPrintLog("カーセンサと連動する店舗がありません。");
    $ret = Carsensor_Common::sendMailNg("カーセンサと連動する店舗がありません。");
    if ($ret) {
        Carsensor_Common::gfPrintLog("メール送信が成功しました。");
    } else {
        Carsensor_Common::gfPrintLog("メール送信が失敗しました。");
    }
    Carsensor_Common::gfPrintLog("===========================バッチ処理完了===========================");
    exit(1);
} 


// ここからFTPサーバにアクセスしてファイル一覧を取得する処理
$objFtp = new FTP_Carsensor(CARSENSOR_FTP_HOST, CARSENSOR_FTP_USER, CARSEBSOR_FTP_PASS);

// FTPサーバからファイルリストを取得する
$file_list = $objFtp->getFileList();


// ファイル名と現在の時間を比較して、ダウンロードすべきのデータ圧縮ファイル一覧を取得する
$arrDownloadList = $carsensor_obj->getDownloadList($file_list); 

if(!is_array($arrDownloadList) || count($arrDownloadList) == 0){
    Carsensor_Common::gfPrintLog("ダウンロードすべきのデータ圧縮ファイルが存在しません。");
    $ret = Carsensor_Common::sendMailNg("ダウンロードすべきのデータ圧縮ファイルが存在しません。");
    if ($ret) {
        Carsensor_Common::gfPrintLog("メール送信が成功しました。");
    } else {
        Carsensor_Common::gfPrintLog("メール送信が失敗しました。");
    }
    Carsensor_Common::gfPrintLog("===========================バッチ処理完了===========================");
    $carsensor_obj->destroy();
    exit(1);
}


// FTPサーバからデータ圧縮ファイルをダンロードする
$ret = $objFtp->getDownloadData($arrDownloadList); 

$objFtp->close();

if(!$ret){
    Carsensor_Common::gfPrintLog("データ圧縮ファイルのダウンロードが失敗しました!");
    $ret = Carsensor_Common::sendMailNg("データ圧縮ファイルのダウンロードが失敗しました!");
    if ($ret) {
        Carsensor_Common::gfPrintLog("メール送信が成功しました。");
    } else {
        Carsensor_Common::gfPrintLog("メール送信が失敗しました。");
    }
    Carsensor_Common::gfPrintLog("===========================バッチ処理完了===========================");
    $carsensor_obj->destroy();
    exit(1);
}

// ダウンロードしたファイルを解凍してデータを読む込んで一時テーブルに登録する。
$ret = $carsensor_obj->dataImport($arrDownloadList);  
if(!$ret){
    Carsensor_Common::gfPrintLog("データを一時テーブルに書き込みする処理が失敗しました!");
    $ret = Carsensor_Common::sendMailNg("データを一時テーブルに書き込みする処理が失敗しました!");
    if ($ret) {
        Carsensor_Common::gfPrintLog("メール送信が成功しました。");
    } else {
        Carsensor_Common::gfPrintLog("メール送信が失敗しました。");
    }
    Carsensor_Common::gfPrintLog("===========================バッチ処理完了===========================");
    $carsensor_obj->destroy();
    exit(1);
}

// add by wangchao in 20150619 start
//$carsensor_obj->addUpdateImgsArr();
// add by wangchao in 20150619 end


Carsensor_Common::gfPrintLog("更新の在庫一覧開始");

//UPDATE TOTAL 件数 取得
$cntUpdate = $carsensor_obj->getCarSensorUpdateCnt();
$updatePages = $cntUpdate ? $cntUpdate / CARSENSOR_DATA_PAGE + 1 : 0 ;

// 在庫を更新する
$updateOkCnt = 0;
$updateNgCnt = 0;

Carsensor_Common::gfPrintLog("更新在庫数:".$cntUpdate);
Carsensor_Common::gfPrintLog("更新在庫分ページ数:".$updatePages);

for( $icur = 0; $icur < $updatePages; $icur ++ ){

 Carsensor_Common::gfPrintLog("------------------ページNO: $icur "."-------------------");
 
 // 更新の在庫一覧
 $arrUpdateCarSensor = $carsensor_obj->getCarSensorUpdateData($icur,CARSENSOR_DATA_PAGE);

 if (is_array($arrUpdateCarSensor) && count($arrUpdateCarSensor) > 0)  {
    foreach($arrUpdateCarSensor as $updateData){
        // カーセンサーデータを輸入車データに変換する
        $impCarData = $carsensor_obj->getImpCarData($updateData);
        // modify by wangchao in 20151030 start
        $stockData = $carsensor_obj->getStockTableDataById($updateData['id']);
        //$stockData = $carsensor_obj->getStockTableData($impCarData["CARSENSOR_ID"]);
        // modify by wangchao in 20151030 end
        // 変換後の輸入車データを更新する
        $ret = $carsensor_obj->updateCarSensorData($impCarData, $stockData[0]);
        if(!$ret){
            $updateNgCnt++;
            Carsensor_Common::gfPrintLog("在庫情報の更新が失敗しました。企業コード：" . $updateData['hojin_cd'] . "　物件コード：" . $updateData['tmp_wns_bukken_cd']  . " 窓口コード: " . $updateData['madoguchi_cd'] ." 店舗ID : ".$updateData['shop_id']);
        } else {
            $updateOkCnt++;
            Carsensor_Common::gfPrintLog("在庫情報の更新が成功しました。企業コード：" . $updateData['hojin_cd'] . "　物件コード：" . $updateData['tmp_wns_bukken_cd'] . " 窓口コード: " . $updateData['madoguchi_cd'] ." 店舗ID : ".$updateData['shop_id']);
        }
        if (empty($updateOkCnt)) {
            $updateOkCnt = '0';
        }
        Carsensor_Common::gfPrintLog("在庫情報の更新が成功した件数：" . $updateOkCnt);
        if (empty($updateNgCnt)) {
            $updateNgCnt = '0';
        }
        Carsensor_Common::gfPrintLog("在庫情報の更新が失敗した件数：" . $updateNgCnt);
    }

 } else{
    Carsensor_Common::gfPrintLog("更新の在庫データがありません。");
 }

 unset($arrUpdateCarSensor);
}

Carsensor_Common::gfPrintLog("更新の在庫一覧完了");


// 一時テーブルに保存しているカーセンサの在庫データとACSSの在庫データとを比較して、新規、更新、削除すべきの在庫配列を纏める
// 新規登録の在庫一覧


Carsensor_Common::gfPrintLog("挿入の在庫一覧開始");

//INSERT TOTAL 件数 取得
$cntInsert = $carsensor_obj->getCarSensorInsertCnt();
$insertPages = $cntInsert ? intval($cntInsert / CARSENSOR_DATA_PAGE) + 1 : 0 ;
// 在庫を新規登録する
$insertOkCnt = 0;
$insertNgCnt = 0;

Carsensor_Common::gfPrintLog("挿入在庫数:".$cntInsert);
Carsensor_Common::gfPrintLog("挿入在庫分ページ数:".$insertPages);


for( $icur = 1; $icur <= $insertPages; $icur++ ){

  Carsensor_Common::gfPrintLog("-------------ページNO: $icur"."----------------------");

  ////paging データを取得
  $arrInsertCarSensor = $carsensor_obj->getCarSensorInsertData(0,CARSENSOR_DATA_PAGE);

    if (is_array($arrInsertCarSensor) && count($arrInsertCarSensor) != 0)  {
    foreach($arrInsertCarSensor as $insertData){
        // カーセンサーデータをACSSの在庫データに変換する
        $impCarData = $carsensor_obj->getImpCarData($insertData);

        // 変換後のACSSの在庫データを新規登録する
        $ret = $carsensor_obj->insertCarSensorData($impCarData);

        if(!$ret){
            $insertNgCnt++;
            Carsensor_Common::gfPrintLog("在庫の新規登録が失敗しました。企業コード：" . $insertData['hojin_cd'] . "　物件コード：" . $insertData['tmp_wns_bukken_cd'] . " 窓口コード: " . $insertData['madoguchi_cd'] ." 店舗ID : ".$insertData['shop_id']);
        } else {
            $insertOkCnt++;
            Carsensor_Common::gfPrintLog("在庫の新規登録が成功しました。企業コード：" . $insertData['hojin_cd'] . "　物件コード：" . $insertData['tmp_wns_bukken_cd'] . " 窓口コード: " . $insertData['madoguchi_cd'] ." 店舗ID : ".$insertData['shop_id']);
        }
        if (empty($insertOkCnt)) {
            $insertOkCnt = '0';
        }
        Carsensor_Common::gfPrintLog("在庫の新規登録が成功した件数：" . $insertOkCnt);
        if (empty($insertNgCnt)) {
            $insertNgCnt = '0';
        }
        Carsensor_Common::gfPrintLog("在庫の新規登録が失敗した件数：" . $insertNgCnt);
    }
 }else{
    Carsensor_Common::gfPrintLog("新規登録の在庫データがありません。");
 }
 
}

Carsensor_Common::gfPrintLog("挿入の在庫一覧完了");

/*
// 削除の在庫一覧
//$arrDeleteCarSensor = $carsensor_obj->getCarSensorDeleteData();

// 在庫を削除する
$deleteOkCnt = 0;
$deleteNgCnt = 0;
if (is_array($arrDeleteCarSensor) && count($arrDeleteCarSensor) > 0)  {
    foreach($arrDeleteCarSensor as $carsensor_carid){
        $ret = $carsensor_obj->deleteCarSensorData($carsensor_carid);
        if(!$ret){
            $deleteNgCnt++;
            Carsensor_Common::gfPrintLog("データの削除が失敗しました。　物件コード：" . $carsensor_carid);
        } else {
            $deleteOkCnt++;
            Carsensor_Common::gfPrintLog("データの削除が成功しました。　物件コード：" . $carsensor_carid);
        }
    }
    if (empty($deleteOkCnt)) {
        $deleteOkCnt = '0';
    }
    Carsensor_Common::gfPrintLog("在庫情報の削除が成功した件数：" . $deleteOkCnt);
    if (empty($deleteNgCnt)) {
        $deleteNgCnt = '0';
    }
    Carsensor_Common::gfPrintLog("在庫情報の削除が失敗した件数：" . $deleteNgCnt);
} else{
    Carsensor_Common::gfPrintLog("削除の在庫データがありません。");
}

*/
// 画像の更新リストを取得する
$img_hojincd = $carsensor_obj->getUpdateImgHojincdList(); 

if(isset($img_hojincd) && is_array($img_hojincd) && count($img_hojincd) > 0) {
    
    // ダウンロードすべきの画像ファイルリストを取得する
    $arrImgDownloadList = $carsensor_obj->getDownloadImgList($file_list);

    if(isset($arrImgDownloadList) && is_array($arrImgDownloadList) && count($arrImgDownloadList) > 0){
        $objFtp = new FTP_Carsensor(CARSENSOR_FTP_HOST, CARSENSOR_FTP_USER, CARSEBSOR_FTP_PASS);

        // FTPサーバから画像のダウンロード処理が開始する
        $ret = $objFtp->getDownloadData($arrImgDownloadList);
        $objFtp->close();

        if(!$ret){
            Carsensor_Common::gfPrintLog("画像のダウンロードが失敗しました。");
        }else{
            Carsensor_Common::gfPrintLog("画像のダウンロードが成功しました。");
        }

        // 画像解凍
        $carsensor_obj->unzipFile($arrImgDownloadList,"IMG");
        
        // 画像の変換と移動
        $carsensor_obj->uploadCarsensorImg($carsensor_obj->arr_img_upload_data); 
    } else {
        Carsensor_Common::gfPrintLog("ダウンロードの画像ありません。");
   }

}else{
    Carsensor_Common::gfPrintLog("更新の画像がありません。");
}
  
// ファイルバックアップ
$carsensor_obj->fileBackup();
// メール送信
$ret = Carsensor_Common::sendMailOk($insertOkCnt, $insertNgCnt, $updateOkCnt, $updateNgCnt, $deleteOkCnt, $deleteNgCnt);
if ($ret) {
    Carsensor_Common::gfPrintLog("メール送信が成功しました。");
} else {
    Carsensor_Common::gfPrintLog("メール送信が失敗しました。");
}
Carsensor_Common::gfPrintLog("===========================バッチ処理完了===========================");

$carsensor_obj->destroy();

?>