<?php
include dirname(__FILE__) . '/nocache.php';

include dirname(__FILE__) . '/dbconfig.php';
include dirname(__FILE__) . '/error.php';
include dirname(__FILE__) . '/utils.php';

include dirname(__FILE__) . '/session.php';

function check() {
check_session();

if ($_SERVER['REQUEST_METHOD'] != 'POST') {
  exit(0);
}
$POST = json_decode(file_get_contents('php://input'), true);

$lang = substr(setTextDomain('myapps'), 0, 2);

$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);

error_reporting(E_ALL & ~E_NOTICE);

$dbh->query('BEGIN');

  if (isset($POST['info_read']) && $POST['info_read']) {
    $sql = "UPDATE userdata SET info_read = ?, upd_log='read_info.php', upd_date=NOW() WHERE member_id=?";
    $stmt = $dbh->prepare($sql);
    $stmt->execute(array($POST['info_read'], $_SESSION['member_id']));
  }

  if (isset($POST['personal_info_read']) && $POST['personal_info_read']) {
    $sql = "UPDATE userdata SET personal_info_read = ?, upd_log='read_info.php', upd_date=NOW() WHERE member_id=?";
    $stmt = $dbh->prepare($sql);
    $stmt->execute(array($POST['personal_info_read'], $_SESSION['member_id']));
  }

  $sql = <<<EOF
SELECT
  1
FROM
  userdata as u
WHERE
  u.member_id=?
AND EXISTS (
  SELECT 1 FROM information
  WHERE id > u.info_read AND del_flg='0'
UNION
  SELECT 1 FROM personal_info
  WHERE id > u.personal_info_read AND user_id=u.id AND del_flg='0'
)
EOF;
  $stmt = $dbh->prepare($sql);
  $stmt->execute(array($_SESSION['member_id']));
  $result = $stmt->fetch(PDO::FETCH_ASSOC);

$dbh->query('COMMIT');

  if ($result) {
    return array('info_stat' => 'more');
  } else {
    return array('info_stat' => 'none');
  }
}

wrap(function() {
  echo json_encode(check());
});
