<?php

require_once dirname(__FILE__) . '/../api/utils.php';

$UPDATE_FTP = '';
$sql = '';
$params = array();

if ( $argv[1] == '-d' ) {
  $sql = "SELECT u.member_id,ftp.* FROM userdata as u INNER JOIN ftp ON ftp.id=u.id AND ftp.del_flg='0' WHERE ? LIKE CONCAT(ftp.dir,'%') AND u.del_flg='0'";
  $params[] = $argv[2];
  $UPDATE_FTP = ',ftp_lastupdate=NOW()';
} else {
  $sql = "SELECT u.member_id,ftp.* FROM userdata as u INNER JOIN ftp ON ftp.id=u.id AND ftp.del_flg='0' WHERE u.member_id=? AND u.del_flg='0'";
  $params[] = $argv[1];
}

include dirname(__FILE__) . '/../api/dbconfig.php';

$options = array(PDO::MYSQL_ATTR_INIT_COMMAND=>"SET CHARACTER SET 'utf8'");
$dbh = new PDO(DB_DSN, DB_USER, DB_PASSWORD, $options);

$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$stmt = $dbh->prepare($sql);
$stmt->execute($params);

$account = $stmt->fetch(PDO::FETCH_ASSOC);
if (empty($account)) {
  exit(0);
}

$member_id = $account['member_id'];
$top = $account['dir'];
if (empty($top)) {
  $top = '/var/www/html';
}

$req = array( 'cmd' => 'info', 'top' => $top );
$contents = call_api($req);

$data = json_decode($contents,true);
error_log('data: '. var_export($data,true));

$sql = "UPDATE userdata SET use_data=?,file=?,lastupdate=NOW()$UPDATE_FTP WHERE member_id=?";
$stmt = $dbh->prepare($sql);
$stmt->execute(array($data['use_data'],$data['file'],$member_id));