Source for file PolarDbQuery.class.php

Documentation is available at PolarDbQuery.class.php

  1. <?php
  2. /**
  3.  * Class to query / update database to get various data
  4.  * (day info, exercises, stats, ...)
  5.  *
  6.  * @author    Jean-Philippe Brunon <jp75018@free.fr>
  7.  * @copyright    2007-2009 Jean-Philippe Brunon
  8.  * @license    http://www.opensource.org/licenses/gpl-license.php GPL
  9.  * @package    php-endurance
  10.  * @version    $Id: PolarDbQuery.class.php 68 2009-03-28 22:57:30Z jp75018 $
  11.  */
  12.  
  13. /**
  14.  * Class to query / update database to get various data
  15.  * (day info, exercises, stats, ...)
  16.  */
  17. class PolarDbQuery
  18. {
  19. /**
  20.  * Class constructor
  21.  *
  22.  * @return      void 
  23.  */
  24.   function PolarDbQuery ()
  25.   {
  26.   }
  27.  
  28. /**
  29.  * Get user information data
  30.  *
  31.  * @param    integer    $user_id User ID
  32.  * @return      array    User information (associative array with plw_user
  33.  *             SQL table structure)
  34.  */
  35.   function get_user_info($user_id)
  36.   {
  37.     $request = sprintf("SELECT * FROM plw_user WHERE id = %d", $user_id);
  38.     $result = mysql_query($request);
  39.     $user_info = mysql_fetch_assoc($result);
  40.     mysql_free_result($result);
  41.  
  42.     return $user_info;
  43.   }
  44.  
  45. /**
  46.  * Login user, get user information data
  47.  *
  48.  * User status must be 'active'.
  49.  * Also set last visit timestamp and use user language.
  50.  *
  51.  * @param    string    $email Email of user
  52.  * @param    string    $password Password of user
  53.  * @return      array    User fields on success, else null
  54.  */
  55.   function login_user($email, $password,
  56.     $email_cookie = false, $password_cookie = false)
  57.   {
  58.     $info = null;
  59.  
  60.     $request = sprintf("SELECT * FROM plw_user WHERE status = 'active' AND LOWER(email) = '%s' AND password = MD5('%s')",
  61.       strtolower($email), $password);
  62.     $result = mysql_query($request);
  63.     if (mysql_num_rows($result))
  64.     { $info = mysql_fetch_assoc($result); }
  65.     mysql_free_result($result);
  66.  
  67.   // Update last visit timestamp (do not update last mod date)
  68.     if (is_array($info))
  69.     {
  70.       $request = sprintf("UPDATE plw_user SET mod_date = mod_date, visit_date = NOW() WHERE id = %d",
  71.     $info['id']);
  72.       mysql_query($request);
  73.  
  74.     // Use user language (only if a session)
  75.       if (is_array($_SESSION))
  76.       { set_language($info['language']); }
  77.       $cur_time = time();
  78.       setcookie('lang', $info['language'], $cur_time + 365 * 86400);
  79.       if ($email_cookie)
  80.       {
  81.       // Set email cookie
  82.     setcookie('email', $email, $cur_time + 365 * 86400);
  83.     if ($password_cookie)
  84.     {
  85.     // Set password cookie
  86.       setcookie('password', $password, $cur_time + 365 * 86400);
  87.     }
  88.     else
  89.     {
  90.     // Unset password cookie
  91.       setcookie('password', '', $cur_time - 1000000);
  92.     }
  93.       }
  94.       else
  95.       {
  96.       // Unset email / password cookies
  97.     setcookie('email', '', $cur_time - 1000000);
  98.     setcookie('password', '', $cur_time - 1000000);
  99.       }
  100.     }
  101.  
  102.     return $info;
  103.   }
  104.  
  105. /**
  106.  * Update user password
  107.  *
  108.  * @param    integer    $user_id User ID
  109.  * @param    string    $old_password Old (current) user password
  110.  * @param    string    $new_password New user password
  111.  * @return      boolean    true on success, else false
  112.  */
  113.   function change_user_password($user_id, $old_password, $new_password)
  114.   {
  115.     $ret_val = false;
  116.  
  117.     $request = sprintf("UPDATE plw_user SET password = MD5('%s') WHERE id = %d AND password = MD5('%s')",
  118.       $new_password, $user_id, $old_password);
  119.     mysql_query($request);
  120.     if (mysql_affected_rows())
  121.     { $ret_val = true; }
  122.  
  123.     return $ret_val;
  124.   }
  125.  
  126. /**
  127.  * Create a new user (with inactive status)
  128.  *
  129.  * @param    array    $info Associative array of user fields :
  130.  *             - 'nickname' : User nickname
  131.  *             - 'email' : User email address
  132.  *             - 'password' : User password
  133.  *             - 'publish' : Publish status
  134.  * @param    integer    &$user_id ID of user created
  135.  * @param    string    &$activ_code Activation code (32 chars MD5 generated)
  136.  * @return      boolean    true on success, else false
  137.  */
  138.   function insert_user($info, &$user_id, &$activ_code)
  139.   {
  140.     $ret_val = false;
  141.  
  142.     $activ_code = md5(time() . '/' . $email);
  143.     $request = sprintf("INSERT INTO plw_user(nickname, email, cre_date, mod_date, activ_code, password, publish, language) VALUES('%s', '%s', NOW(), NOW(), '%s', MD5('%s'), '%s', '%s')",
  144.       $info['nickname'], $info['email'], $activ_code, $info['password'],
  145.       $info['publish'], $GLOBALS['lang']);
  146.     @mysql_query($request);
  147.     if (! mysql_errno())
  148.     {
  149.     // Get user ID
  150.       $user_id = mysql_insert_id();
  151.       $ret_val = true;
  152.     }
  153.  
  154.     return $ret_val;
  155.   }
  156.  
  157. /**
  158.  * Activate a new user
  159.  *
  160.  * @param    integer    $user_id ID of user to activate
  161.  * @param    string    $activ_code Activation code (32 chars)
  162.  * @return      boolean    true on success, else false
  163.  */
  164.   function activate_user($user_id, $activ_code)
  165.   {
  166.     $ret_val = false;
  167.  
  168.     $request = sprintf("UPDATE plw_user SET status = 'active', activ_code = NULL WHERE id = %d AND status = 'inactive' AND activ_code = '%s'",
  169.       $user_id, $activ_code);
  170.     @mysql_query($request);
  171.     if ((! mysql_errno()) && mysql_affected_rows())
  172.     { $ret_val = true; }
  173.  
  174.   // Add default preferences
  175.     $this->set_user_preferences($user_id,
  176.       array('mailing_lists' => 'newsletter'));
  177.  
  178.     return $ret_val;
  179.   }
  180.  
  181. /**
  182.  * Update user fields
  183.  *
  184.  * @param    integer    $user_id User ID
  185.  * @param    array    $info Associative array of user fields :
  186.  *             - 'nickname' : User nickname
  187.  *             - 'publish' : Publish status
  188.  *             - 'language' : Language
  189.  *             - 'unit' : Unit (metric or us)
  190.  *             - 'gender' : Gender
  191.  *             - 'birthdate' : Birthdate dd/mm/yy[yy] (sep /,-,., ' ')
  192.  *             - 'height' : Height in cm (decimal sep is . or ,)
  193.  *             - 'weight' : Weight in kg (decimal sep is . or ,)
  194.  *             - 'rest_hr' : Rest HR (bpm)
  195.  *             - 'max_hr' : Max HR (bpm)
  196.  *             - 'vo2max' : VO2max in ml/kg/min (decimal sep is . or ,)
  197.  *             - 'vma' : MAS in km/h (decimal sep is . or ,)
  198.  * @return      boolean    true on success, else false
  199.  */
  200.   function update_user_info($user_id, $info)
  201.   {
  202.     $ret_val = false;
  203.  
  204.     if (preg_match('/^([0-9]{1,2})[\/\-\. ]([0-9]{1,2})[\/\-\. ]((19|20)?[0-9]{2})$/',
  205.       $info['birthdate'], $matches))
  206.     {
  207.       $year = $matches[3];
  208.       if ($year < 100)
  209.       {
  210.     $year += 1900;
  211.           if ($year < 1910)
  212.     { $year += 100; }
  213.       }
  214.       $info['birthdate'] =
  215.     sprintf("%04d-%02d-%02d", $year, $matches[2], $matches[1]);
  216.     }
  217.     else
  218.     { $info['birthdate'] = null; }
  219.     $info['height'] = strtr($info['height'], ',', '.');
  220.     $info['weight'] = strtr($info['weight'], ',', '.');
  221.     $info['vo2max'] = strtr($info['vo2max'], ',', '.');
  222.     $info['vma'] = strtr($info['vma'], ',', '.');
  223.     $request = sprintf("UPDATE plw_user SET nickname = '%s', publish = '%s', language = '%s', unit = '%s', gender = %s, birthdate = %s, height = %s, weight = %s, rest_hr = %s, max_hr = %s, vo2max = %s, vma = %s WHERE id = %d",
  224.       $info['nickname'], $info['publish'], $info['language'], $info['unit'],
  225.       $info['gender'] ? '\'' . $info['gender'] . '\'' : 'null',
  226.       $info['birthdate'] ? '\'' . $info['birthdate'] . '\'' : 'null',
  227.       $info['height'] ? round($info['height'] * 10, 2) : 'null',
  228.       $info['weight'] ? round($info['weight'] * 10, 2) : 'null',
  229.       $info['rest_hr'] ? round($info['rest_hr']) : 'null',
  230.       $info['max_hr'] ? round($info['max_hr']) : 'null',
  231.       $info['vo2max'] ? round($info['vo2max'] * 10, 2) : 'null',
  232.       $info['vma'] ? round($info['vma'] * 10, 2) : 'null',
  233.       $user_id);
  234.     @mysql_query($request);
  235.     if (! mysql_errno())
  236.     {
  237.     // Use new language (only if a session)
  238.       if (is_array($_SESSION))
  239.       { set_language($info['language']); }
  240.       $ret_val = true;
  241.     }
  242.  
  243.     return $ret_val;
  244.   }
  245.  
  246. /**
  247.  * Get read rights on one user booknote for another user (or anonymous reader)
  248.  *
  249.  * @todo    Return day info display flag
  250.  * @todo    Add groups rights
  251.  *
  252.  * @param    integer    $publish_user_id ID of user owner of booknote
  253.  * @param    integer    $logged_user_id ID uf user logged in (null if anonymous)
  254.  * @return      string    Read rights, one of :
  255.  *             - null : <publish_user_id> does not exist
  256.  *             - 'private' : No read rights
  257.  *             - 'public' : Read rights
  258.  *             - 'public-but-desc' : Read rights except descriptions
  259.  * @param    string    &$nickname Nickname of <publish_user_id> user
  260.  */
  261.   function get_read_rights($publish_user_id, $logged_user_id, &$nickname)
  262.   {
  263.     $info = null;
  264.     $nickname = null;
  265.  
  266.     if ($publish_user_id == $logged_user_id)
  267.     {
  268.     // All rights for user on itself
  269.       $rights = 'public';
  270.       if (isset($_SESSION['user_nickname']))
  271.       { $nickname = $_SESSION['user_nickname']; }
  272.     }
  273.     else
  274.     {
  275.       $request = sprintf("SELECT publish, nickname FROM plw_user WHERE id = %d",
  276.     $publish_user_id);
  277.       $result = mysql_query($request);
  278.       $info = mysql_fetch_assoc($result);
  279.       mysql_free_result($result);
  280.       if ($info)
  281.       {
  282.     $rights = $info['publish'];
  283.     $nickname = $info['nickname'];
  284.       }
  285.     }
  286.  
  287.     return $rights;
  288.   }
  289.  
  290. /**
  291.  * Get user preferences
  292.  *
  293.  * @param    integer    $user_id User ID
  294.  * @return      array    User preferences : Associative array of preferences :
  295.  *             - 'mailing_lists' : List of mailing lists
  296.  *             - 'display_width' : Browser width in pixels
  297.  *             - 'display_day_info' : Flag to display day info or not
  298.  *             - 'home_exes_sums' : To display exes stats in home page
  299.  */
  300.   function get_user_preferences($user_id)
  301.   {
  302.     $prefs = array();
  303.  
  304.     $request = sprintf("SELECT name, value FROM plw_user_preference WHERE user_id = %d",
  305.       $user_id);
  306.     $result = mysql_query($request);
  307.     while ($row = mysql_fetch_assoc($result))
  308.     { $prefs[$row['name']] = $row['value']; }
  309.     mysql_free_result($result);
  310.  
  311.     return $prefs;
  312.   }
  313.  
  314. /**
  315.  * Set user preferences
  316.  *
  317.  * Insert preference if not exist, delete if value is '', else update value.
  318.  *
  319.  * @param    integer    $user_id User ID
  320.  * @param      array    User preferences : Associative array of preferences
  321.  *             (see get_user_preferences)
  322.  * @return      boolean    true on success, else false
  323.  */
  324.   function set_user_preferences($user_id, $prefs)
  325.   {
  326.     $ret_val = true;
  327.  
  328.     if (! is_array($prefs))
  329.     { return $ret_val; }
  330.  
  331.   // 1. Get null and not null preferences
  332.     $del_prefs = array();
  333.     $ins_prefs = array();
  334.     reset($prefs);
  335.     while (list($name, $value) = each($prefs))
  336.     {
  337.       if ($value == '')
  338.       { array_push($del_prefs, $name); }
  339.       else
  340.       { $ins_prefs[$name] = $value; }
  341.     }
  342.  
  343.   // 2. Delete preferences with null value
  344.     if (count($del_prefs))
  345.     {
  346.       $request = sprintf("DELETE FROM plw_user_preference WHERE user_id = %d AND name IN ('%s')",
  347.     $user_id, implode('\',\'', $del_prefs));
  348.       @mysql_query($request);
  349.       if (mysql_errno())
  350.       { $ret_val = false; }
  351.     }
  352.  
  353.   // 3. Insert / update other preferences
  354.     if (count($ins_prefs))
  355.     {
  356.       reset($ins_prefs);
  357.       while (list($name, $value) = each($ins_prefs))
  358.       {
  359.     $request = sprintf("INSERT INTO plw_user_preference(user_id, name, value) VALUES (%d, '%s', '%s') ON DUPLICATE KEY UPDATE value = '%s'",
  360.        $user_id, $name, mysql_escape_string($value),
  361.        mysql_escape_string($value));
  362.     @mysql_query($request);
  363.     if (mysql_errno())
  364.     { $ret_val = false; }
  365.       }
  366.     }
  367.  
  368.     return $ret_val;
  369.   }
  370.  
  371. /**
  372.  * Get day information data for a user
  373.  *
  374.  * @param    integer    $user_id User ID
  375.  * @param    string    $day Day (format : YYYY-MM-DD)
  376.  * @return      array    Day information (associative array with plw_day_info
  377.  *             SQL table structure)
  378.  */
  379.   function get_day_info($user_id, $day)
  380.   {
  381.     $request = sprintf("SELECT * FROM plw_day_info WHERE user_id = %d AND day = '%s'",
  382.       $user_id, $day);
  383.     $result = mysql_query($request);
  384.     $day_info = mysql_fetch_assoc($result);
  385.     mysql_free_result($result);
  386.  
  387.     return $day_info;
  388.   }
  389.  
  390. /**
  391.  * Get exercise information
  392.  *
  393.  * @param    integer    $exe_id Exercise ID
  394.  * @return      array    Exercise information (associative array with
  395.  *              plw_exercise SQL table structure)
  396.  */
  397.   function get_exercise_info($exe_id)
  398.   {
  399.     $request = sprintf("SELECT * FROM plw_exercise WHERE id = %d", $exe_id);
  400.     $result = mysql_query($request);
  401.     $exe = mysql_fetch_assoc($result);
  402.     mysql_free_result($result);
  403.  
  404.     return $exe;
  405.   }
  406.  
  407. /**
  408.  * Get exercises summary + sum / avg / max by sport within a period
  409.  * 
  410.  * Used to compute weekly statistics for instance.
  411.  *
  412.  * Consider exercises in reports only.
  413.  *
  414.  * @param    integer    $user_id User ID
  415.  * @param    string    $min_day First day in period (format : YYYY-MM-DD)
  416.  * @param    string    $max_day Last day in period (format : YYYY-MM-DD)
  417.  *             If null, then period ends at current date.
  418.  * @param    boolean    $detail true to get exercises summary, else false
  419.  * @return      array    Indexed by sport ID. For each sport :
  420.  *             - 'nb' : Number of exercises
  421.  *             - 'exe' : Array of exercises
  422.  *             - 'elapsed' : Total duration in seconds * 10
  423.  *             - 'real_distance' : Total real distance in meters
  424.  *             - 'running_index' : Average Polar running index
  425.  *             - 'max_hr' : Maximum heart rate in bpm
  426.  *             - 'max_speed' : Maximum speed rate in km/h * 10
  427.  *             - 'avg_cadence' : Average cadence in cycles / minute
  428.  *             - 'max_cadence' : Maximum cadence in cycles / minute
  429.  *             - 'ascend' : Total ascend in meters
  430.  *             - 'energy' : Total energy -Polar- in Kcal
  431.  *             - 'physio_energy' : Total physio energy -f(HR)- in Kcal
  432.  *             - 'beat_sum' : Total number of heart beats
  433.  *             For each exercise in 'exe' (if $detail = true) :
  434.  *             - 'day' : Day of exercise (format : YYYY-MM-DD)
  435.  *             - 'rank' : Rank of exercise in day
  436.  *             - 'start_time' : Start time (format : HH:MM:SS)
  437.  *             - 'elapsed' : Total duration in seconds * 10
  438.  *             - 'real_distance' : Total real distance in meters
  439.  *             - 'running_index' : Average Polar running index
  440.  *             - 'max_hr' : Maximum heart rate in bpm
  441.  *             - 'max_speed' : Maximum speed rate in km/h * 10
  442.  *             - 'avg_cadence' : Average cadence in cycles / minute
  443.  *             - 'max_cadence' : Maximum cadence in cycles / minute
  444.  *             - 'ascend' : Total ascend in meters
  445.  *             - 'energy' : Total energy -Polar- in Kcal
  446.  *             - 'physio_energy' : Total physio energy -f(HR)- in Kcal
  447.  *             - 'beat_sum' : Total number of heart beats
  448.  *             - 'exercise_type' : exe type in ('training','contest')
  449.  */
  450.   function get_exercises_by_sport($user_id, $min_day, $max_day = null,
  451.     $detail = true)
  452.   {
  453.     $exes = array();
  454.  
  455.   // 1. Get sum / avg / max by sport
  456.     $request = sprintf("SELECT sport_id, COUNT(*) AS nb, SUM(elapsed) AS elapsed, SUM(real_distance) AS real_distance, SUM(running_index*elapsed)/SUM(elapsed*running_index/running_index) AS running_index, MAX(max_hr) AS max_hr, MAX(max_speed) AS max_speed, SUM(avg_cadence*elapsed)/SUM(elapsed*avg_cadence/avg_cadence) AS avg_cadence, MAX(max_cadence) AS max_cadence, SUM(ascend) AS ascend, SUM(energy) AS energy, SUM(physio_energy) AS physio_energy, SUM(beat_sum) AS beat_sum FROM plw_exercise WHERE user_id = %d AND day >= '%s' AND day <= '%s' AND status = 'online' AND in_reports = 'all' GROUP BY sport_id ORDER BY sport_id",
  457.       $user_id, $min_day, $max_day ? $max_day : '2099-12-31');
  458.     $result = mysql_query($request);
  459.     while ($row = mysql_fetch_assoc($result))
  460.     {
  461.       $exes[$row['sport_id']] = $row;
  462.       unset($exes[$row['sport_id']]['sport_id']);
  463.     }
  464.     mysql_free_result($result);
  465.  
  466.   // 2. Get exercises summary
  467.     if ($detail)
  468.     {
  469.       $prev_sport_id = 0;
  470.       $request = sprintf("SELECT sport_id, day, rank, start_time, elapsed, real_distance, running_index, max_hr, max_speed, avg_cadence, max_cadence, ascend, energy, physio_energy, beat_sum, exercise_type FROM plw_exercise WHERE user_id = %d AND day >= '%s' AND day <= '%s' AND status = 'online' AND in_reports = 'all' ORDER BY sport_id, day, rank",
  471.     $user_id, $min_day, $max_day);
  472.       $result = mysql_query($request);
  473.       while ($row = mysql_fetch_assoc($result))
  474.       {
  475.     if ($row['sport_id'] != $prev_sport_id)
  476.     {
  477.       $prev_sport_id = $row['sport_id'];
  478.       $i = 0;
  479.     }
  480.     $exes[$row['sport_id']]['exe'][$i] = $row;
  481.     unset($exes[$row['sport_id']]['exe'][$i]['sport_id']);
  482.     $i++;
  483.       }
  484.       mysql_free_result($result);
  485.     }
  486.  
  487.     return $exes;
  488.   }
  489.  
  490. /**
  491.  * Get all laps in an exercise
  492.  *
  493.  * @param    integer    $exe_id Exercise ID
  494.  * @param    string    $lap_type Lap type in
  495.  *             ('polar','distance','altitude','interval').
  496.  *             If null, all types are returned.
  497.  * @return      array    Array of laps indexed by lap number from 1.
  498.  *             Each lap is an associative array with plw_lap
  499.  *             SQL table structure. If $lap_type is null, associative
  500.  *             array of lap types.
  501.  */
  502.   function get_exercise_laps($exe_id, $lap_type = null)
  503.   {
  504.     $laps = array();
  505.     if ($lap_type)
  506.     { $where = sprintf("AND lap_type = '%s'", $lap_type); }
  507.     else
  508.     { $where = ''; }
  509.     $request = sprintf("SELECT * FROM plw_lap WHERE exercise_id = %d %s ORDER BY lap_type, rank",
  510.       $exe_id, $where);
  511.     $result = mysql_query($request);
  512.     while ($row = mysql_fetch_assoc($result))
  513.     {
  514.       $laps[$row['lap_type']][$row['rank']] = $row;
  515.       unset($laps[$row['lap_type']][$row['rank']]['exercise_id']);
  516.       unset($laps[$row['lap_type']][$row['rank']]['lap_type']);
  517.       unset($laps[$row['lap_type']][$row['rank']]['rank']);
  518.     }
  519.     mysql_free_result($result);
  520.  
  521.     if ($lap_type)
  522.     { $laps = $laps[$lap_type]; }
  523.  
  524.     return $laps;
  525.   }
  526.  
  527. /**
  528.  * Get interval training elements in an exercise
  529.  *
  530.  * @param    integer    $exe_id Exercise ID
  531.  * @return      array    Array of interval training elements indexed from 0. Each
  532.  *             element is an associative array with plw_int_training
  533.  *             SQL table structure.
  534.  */
  535.   function get_interval_training($exe_id)
  536.   {
  537.     $elements = array();
  538.     $request = sprintf("SELECT * FROM plw_int_training WHERE exercise_id = %d ORDER BY rank",
  539.       $exe_id);
  540.     $result = mysql_query($request);
  541.     while ($row = mysql_fetch_assoc($result))
  542.     {
  543.       $elements[$row['rank']] = $row;
  544.       unset($elements[$row['rank']]['exercise_id']);
  545.       unset($elements[$row['rank']]['rank']);
  546.     }
  547.     mysql_free_result($result);
  548.  
  549.     return $elements;
  550.   }
  551.  
  552. /**
  553.  * Get statistics for an exercise
  554.  *
  555.  * Statistics are for heart rate, speed, cadence, and stride length depending
  556.  * on s_mode while recording.
  557.  *
  558.  * @param    integer    $exe_id Exercise ID
  559.  * @return      array    Array of statistics indexed by type in
  560.  *             ('hr','speed','cadence','stride').
  561.  *             For each type, statistics is an array of
  562.  *             <value> => <nb of occurences in exercise>.
  563.  *             <value> is bpm for 'hr', km/h * 10 for 'speed',
  564.  *             cycles / minute for 'cadence', cm for 'stride'.
  565.  */
  566.   function get_exercise_stats($exe_id)
  567.   {
  568.     $stats = array();
  569.     $request = sprintf("SELECT * FROM plw_stat WHERE exercise_id = %d ORDER BY data_type, value",
  570.       $exe_id);
  571.     $result = mysql_query($request);
  572.     while ($row = mysql_fetch_assoc($result))
  573.     { $stats[$row['data_type']][$row['value']] = $row['nb']; }
  574.     mysql_free_result($result);
  575.  
  576.     return $stats;
  577.   }
  578.  
  579. /**
  580.  * Get statistics for all exercises within a period
  581.  * 
  582.  * Used to compute weekly statistics for instance.
  583.  *
  584.  * Consider exercises in reports only.
  585.  *
  586.  * Statistics are for heart rate, speed, cadence, and stride length depending
  587.  * on s_mode while recording.
  588.  *
  589.  * @param    integer    $user_id User ID
  590.  * @param    string    $min_day First day in period (format : YYYY-MM-DD)
  591.  * @param    string    $max_day Last day in period (format : YYYY-MM-DD)
  592.  * @return      array    Array of statistics as in get_exercise_stats().
  593.  */
  594.   function get_stats_for_period($user_id, $min_day, $max_day)
  595.   {
  596.     $stats = array();
  597.     $request = sprintf("SELECT data_type, value, SUM(nb) AS nb FROM plw_stat s, plw_exercise e WHERE e.id = s.exercise_id AND e.user_id = %d AND e.status='online' AND e.in_reports = 'all' AND e.day >= '%s' AND e.day <= '%s' GROUP BY data_type, value ORDER BY data_type, value",
  598.       $user_id, $min_day, $max_day);
  599.     $result = mysql_query($request);
  600.     while ($row = mysql_fetch_assoc($result))
  601.     { $stats[$row['data_type']][$row['value']] = $row['nb']; }
  602.     mysql_free_result($result);
  603.  
  604.     return $stats;
  605.   }
  606.  
  607. /**
  608.  * Get last active and public members
  609.  *
  610.  * Last means most recent members (registration date). Members are sorted
  611.  * from most recent to less recent.
  612.  *
  613.  * @param    array    $params Associative array of parameters :
  614.  *             - 'max_mbr' : Maximum number of members to return
  615.  *             - 'max_age' : Only members newer than <max_age> days
  616.  *             - 'min_exe' : Only public members with at least
  617.  *               <min_exe> public exercises are considered.
  618.  * @return      array    Array of members indexed from 0. Each member is an
  619.  *             associative array :
  620.  *             - 'user_id' : User ID
  621.  *             - 'nickname' : User nickname
  622.  *             - 'gender' : User gender in ('male','female')
  623.  *             - 'birthdate' : User birthdate (YYYY-MM-DD)
  624.  *             - 'reg_date' : registration date (YYYY-MM-DD)
  625.  *             - 'exe_nb' : Number of online exercises
  626.  */
  627.   function get_last_members_summary($params = null)
  628.   {
  629.     $max_mbr = $params['max_mbr'] ? $params['max_mbr'] : 100;
  630.     $max_age = $params['max_age'] ? $params['max_age'] : 92;
  631.     $min_exe = isset($params['min_exe']) ? $params['min_exe'] : 1;
  632.     $members = array();
  633.  
  634.     if ($min_exe > 0)
  635.     {
  636.       $request = sprintf("SELECT u.id AS user_id, u.nickname AS nickname, u.gender AS gender, u.birthdate AS birthdate, u.cre_date AS reg_date, COUNT(e.id) AS exe_nb FROM plw_user u, plw_exercise e WHERE u.id = e.user_id AND u.status = 'active' AND u.publish != 'private' AND e.status = 'online' AND DATEDIFF(NOW(),u.cre_date) <= %d GROUP BY u.id HAVING exe_nb >= %d ORDER BY reg_date DESC, user_id DESC LIMIT %d",
  637.     $max_age, $min_exe, $max_mbr);
  638.       $result = mysql_query($request);
  639.       while ($row = mysql_fetch_assoc($result))
  640.       { array_push($members, $row); }
  641.       mysql_free_result($result);
  642.     }
  643.     else
  644.     {
  645.     // 1. Get <max_mbr> most recent active and public members
  646.       $users = array();
  647.       $user_ids = array();
  648.       $request = sprintf("SELECT id AS user_id, nickname, gender, birthdate, cre_date AS reg_date FROM plw_user WHERE status = 'active' AND publish != 'private' AND DATEDIFF(NOW(),cre_date) <= %d ORDER BY reg_date DESC LIMIT %d",
  649.           $max_age, $max_mbr);
  650.       $result = mysql_query($request);
  651.       while ($row = mysql_fetch_assoc($result))
  652.       {
  653.     $users[$row['user_id']] = $row;
  654.     array_push($user_ids, $row['user_id']);
  655.       }
  656.       mysql_free_result($result);
  657.     // 2. Get number of exercises for those members and complete user array
  658.       if (count($user_ids))
  659.       {
  660.           $request = sprintf("SELECT user_id, COUNT(*) AS exe_nb FROM plw_exercise WHERE status = 'online' AND user_id IN (%s) GROUP BY user_id",
  661.       implode(',', $user_ids));
  662.     $result = mysql_query($request);
  663.     while ($row = mysql_fetch_assoc($result))
  664.     { $users[$row['user_id']]['exe_nb'] = $row['exe_nb']; }
  665.     mysql_free_result($result);
  666.       }
  667.     // 3. Build 0 .. N indexed array
  668.       reset($users);
  669.       while (list($user_id, $user) = each($users))
  670.       { array_push($members, $user); }
  671.     }
  672.  
  673.     return $members;
  674.   }
  675.  
  676. /**
  677.  * Get last exercises of all public (and active) users.
  678.  *
  679.  * Last means most recent exercise date / time. Exercises are sorted from most
  680.  * recent to less recent.
  681.  * Consider all online exercises having a matching sport ID (even unknown).
  682.  *
  683.  * @param    array    $params Associative array of parameters :
  684.  *             - 'max_exe' : Maximum number of exercises to return
  685.  *             - 'max_age' : Only exercises newer than <max_age> days
  686.  *             - 'min_elapsed' : Only exercises during at least
  687.  *               <min_elapsed> minutes
  688.  * @return      array    Array of exercises indexed from 0. Each exercise is an
  689.  *             associative array :
  690.  *             - 'user_id' : User ID
  691.  *             - 'nickname' : User nickname
  692.  *             - 'gender' : User gender in ('male','female')
  693.  *             - 'birthdate' : User birthdate (YYYY-MM-DD)
  694.  *             - 'weather' : Weather string
  695.  *             - 'temperature' : Temperature in Celcius x 10
  696.  *             - 'sport_index' : Sport index string
  697.  *             - 'sport_name' : Sport name in case sport is unknown
  698.  *             - 'exe_id' : Exercise ID
  699.  *             - 'exe_type' : Exercise type string
  700.  *             - 'day' : Exercise date (YYYY-MM-DD format)
  701.  *             - 'start_time' : Exercise start time (HH:MI:SS format)
  702.  *             - 'title' => Exercise title
  703.  *             - 'monitor_type' => HR Monitor ID (polar_monitors.php)
  704.  *             - 's_mode' => List of data measured (comma sep)
  705.  *             - 'elapsed' => Exercice duration in seconds x 10
  706.  *             - 'distance' => Exercice distance in meters
  707.  *             - 'ascend' => Ascend in meters
  708.  */
  709.   function get_last_exercises_summary($params = null)
  710.   {
  711.     $max_exe = $params['max_exe'] ? $params['max_exe'] : 100;
  712.     $max_age = $params['max_age'] ? $params['max_age'] : 31;
  713.     $min_elapsed = $params['min_elapsed'] ? $params['min_elapsed'] : 0;
  714.     $exes = array();
  715.  
  716.     $request = sprintf("SELECT u.id AS user_id, u.nickname AS nickname, u.gender AS gender, u.birthdate AS birthdate, d.weather AS weather, d.temperature AS temperature, s.sport_index AS sport_index, s.name AS sport_name, e.id AS exe_id, e.exercise_type AS exe_type, e.day AS day, e.start_time AS start_time, e.title AS title, e.monitor_type AS monitor_type, e.s_mode AS s_mode, e.elapsed AS elapsed, e.real_distance AS distance, e.ascend AS ascend FROM plw_user u, plw_day_info d, plw_sport s, plw_exercise e WHERE u.id = d.user_id AND u.id = s.user_id AND u.id = e.user_id AND s.id = e.sport_id AND d.day = e.day AND u.status = 'active' AND u.publish != 'private' AND e.status = 'online' AND DATEDIFF(NOW(),d.day) <= %d AND e.elapsed >= %d ORDER BY day DESC, start_time DESC, user_id LIMIT %d",
  717.       $max_age, $min_elapsed * 600, $max_exe);
  718.     $result = mysql_query($request);
  719.     while ($row = mysql_fetch_assoc($result))
  720.     { array_push($exes, $row); }
  721.     mysql_free_result($result);
  722.  
  723.     return $exes;
  724.   }
  725.  
  726. /**
  727.  * Get global statistics about active members / online exercises
  728.  *
  729.  * Consider all active members.
  730.  * Consider all online exercises (even with none matching sport ID)
  731.  *
  732.  * @param    array    $params Associative array of parameters :
  733.  *             - 'publish_list' : Array of publish status to filter
  734.  *               ('public' => 'public' or 'public-but-desc')
  735.  *             - 'by_publish' : Split by publish status if true
  736.  * @return      array    Associative arrays of records :
  737.  *             + 'mbr' : active member count indexed by
  738.  *             publish status ('all' if not splitted), 'public' and
  739.  *             'public-but-desc' are grouped as 'public'.
  740.  *             Each record is an associative array :
  741.  *             - 'nb' => Number of active members
  742.  *             + 'exe' : Exercise count indexed by
  743.  *             publish status ('all' if not splitted), 'public' and
  744.  *             'public-but-desc' are grouped as 'public'.
  745.  *             Each record is an associative array :
  746.  *             - 'nb' => Number of exercises
  747.  *             - 'elapsed' => Sum of exercices duration in seconds x 10
  748.  *             Both arrays are sorted by publish status;
  749.  */
  750.   function get_global_stats($params)
  751.   {
  752.     $where = array();
  753.     $order_by = array();
  754.     $group_by = array();
  755.     $group_by_col = array();
  756.     if (is_array($params['publish_list']))
  757.     {
  758.       if (in_array('public', $params['publish_list']))
  759.       { array_push($params['publish_list'], 'public-but-desc'); }
  760.       array_push($where, sprintf("u.publish IN ('%s')",
  761.     implode('\',\'', $params['publish_list'])));
  762.     }
  763.     if ($params['by_publish'])
  764.     {
  765.       array_push($group_by_col,
  766.     'IF(u.publish=\'private\', \'private\', \'public\') AS my_publish');
  767.       array_push($group_by, 'my_publish');
  768.       array_push($order_by, 'my_publish');
  769.     }
  770.     $stats = array();
  771.  
  772.     $request = sprintf("SELECT %sCOUNT(*) AS nb FROM plw_user u WHERE u.status = 'active' %s%s%s",
  773.       count($group_by_col) ? implode(', ', $group_by_col) . ', ' : '',
  774.       count($where) ? ' AND ' . implode(' AND ', $where) : '',
  775.       count($group_by) ? ' GROUP BY ' . implode(', ', $group_by) : '',
  776.       count($order_by) ? ' ORDER BY ' . implode(', ', $order_by) : '');
  777.     $result = mysql_query($request);
  778.     while ($row = mysql_fetch_assoc($result))
  779.     {
  780.       $key_publish = $row['my_publish'] ? $row['my_publish'] : 'all';
  781.       if ($row['my_publish'])
  782.       { unset($row['my_publish']); }
  783.       $stats['mbr'][$key_publish] = $row;
  784.     }
  785.     mysql_free_result($result);
  786.  
  787.     $request = sprintf("SELECT %sCOUNT(*) AS nb, SUM(e.elapsed) AS elapsed FROM plw_user u, plw_exercise e WHERE u.id = e.user_id AND u.status = 'active' AND e.status = 'online'%s%s%s",
  788.       count($group_by_col) ? implode(', ', $group_by_col) . ', ' : '',
  789.       count($where) ? ' AND ' . implode(' AND ', $where) : '',
  790.       count($group_by) ? ' GROUP BY ' . implode(', ', $group_by) : '',
  791.       count($order_by) ? ' ORDER BY ' . implode(', ', $order_by) : '');
  792.     $result = mysql_query($request);
  793.     while ($row = mysql_fetch_assoc($result))
  794.     {
  795.       $key_publish = $row['my_publish'] ? $row['my_publish'] : 'all';
  796.       if ($row['my_publish'])
  797.       { unset($row['my_publish']); }
  798.       $stats['exe'][$key_publish] = $row;
  799.     }
  800.     mysql_free_result($result);
  801.  
  802.     return $stats;
  803.   }
  804.  
  805. /**
  806.  * Get global statistics about online exercises
  807.  *
  808.  * Consider all active members.
  809.  * Consider all online exercises having a matching sport ID (even unknown).
  810.  *
  811.  * @param    array    $params Associative array of parameters :
  812.  *             - 'max_age' : Only exercises newer than <max_age> days
  813.  *             - 'min_elapsed' : Only exercises during at least
  814.  *               <min_elapsed> minutes
  815.  *             - 'publish_list' : Array of publish status to filter
  816.  *               ('public' => 'public' or 'public-but-desc')
  817.  *             - 'by_publish' : Split by publish status if true
  818.  *             - 'sport_list' : Array of sport indexes to filter
  819.  *             - 'by_sport' : Split by sport index if true
  820.  * @param    integer    &$sum_nb_exe Total nb of matching exercises
  821.  * @return      array    Associative array of records indexed by
  822.  *             publish status ('all' if not splitted), 'public' and
  823.  *             'public-but-desc' are grouped as 'public'.
  824.  *             then by sport index ('all' if not splitted).
  825.  *             Each record is an associative array :
  826.  *             - 'nb' => Number of exercises
  827.  *             - 'elapsed' => Sum of exercices duration in seconds x 10
  828.  *             - 'distance' => Sum of exercices distance in meters
  829.  *             - 'ascend' => Sum of exercices ascend in meters
  830.  *             Array is sorted by publish status, then by decreasing
  831.  *             number of exercises for each sport.
  832.  */
  833.   function get_exercises_stats($params, &$sum_nb_exe)
  834.   {
  835.     $sum_nb_exe = 0;
  836.     $max_age = $params['max_age'] ? $params['max_age'] : 99999;
  837.     $min_elapsed = $params['min_elapsed'] ? $params['min_elapsed'] : 0;
  838.     $where = array();
  839.     $order_by = array();
  840.     $group_by = array();
  841.     $group_by_col = array();
  842.     if (is_array($params['publish_list']))
  843.     {
  844.       if (in_array('public', $params['publish_list']))
  845.       { array_push($params['publish_list'], 'public-but-desc'); }
  846.       array_push($where, sprintf("u.publish IN ('%s')",
  847.     implode('\',\'', $params['publish_list'])));
  848.     }
  849.     if ($params['by_publish'])
  850.     {
  851.       array_push($group_by_col,
  852.     'IF(u.publish=\'private\', \'private\', \'public\') AS my_publish');
  853.       array_push($group_by, 'my_publish');
  854.       array_push($order_by, 'my_publish');
  855.     }
  856.     if (is_array($params['sport_list']))
  857.     {
  858.       array_push($where, sprintf("s.sport_index IN ('%s')",
  859.     implode('\',\'', $params['sport_list'])));
  860.     }
  861.     if ($params['by_sport'])
  862.     {
  863.       array_push($group_by_col, 's.sport_index AS my_sport_index');
  864.       array_push($group_by, 'my_sport_index');
  865.       array_push($order_by, 'nb DESC, s.sport_index');
  866.     }
  867.     $stats = array();
  868.  
  869.     $request = sprintf("SELECT %sCOUNT(*) AS nb, SUM(e.elapsed) AS elapsed, SUM(e.real_distance) AS distance, SUM(e.ascend) AS ascend FROM plw_user u, plw_sport s, plw_exercise e WHERE u.id = s.user_id AND u.id = e.user_id AND s.id = e.sport_id AND u.status = 'active' AND e.status = 'online' AND DATEDIFF(NOW(),e.day) <= %d AND e.elapsed >= %d%s%s%s",
  870.       count($group_by_col) ? implode(', ', $group_by_col) . ', ' : '',
  871.       $max_age, $min_elapsed * 600,
  872.       count($where) ? ' AND ' . implode(' AND ', $where) : '',
  873.       count($group_by) ? ' GROUP BY ' . implode(', ', $group_by) : '',
  874.       count($order_by) ? ' ORDER BY ' . implode(', ', $order_by) : '');
  875.     $result = mysql_query($request);
  876.     while ($row = mysql_fetch_assoc($result))
  877.     {
  878.       $key_publish = $row['my_publish'] ? $row['my_publish'] : 'all';
  879.       if ($row['my_publish'])
  880.       { unset($row['my_publish']); }
  881.       $key_sport = $row['my_sport_index'] ? $row['my_sport_index'] : 'all';
  882.       if ($row['my_sport_index'])
  883.       { unset($row['my_sport_index']); }
  884.       $stats[$key_publish][$key_sport] = $row;
  885.       $sum_nb_exe += $row['nb'];
  886.     }
  887.     mysql_free_result($result);
  888.  
  889.     return $stats;
  890.   }
  891.  
  892. /**
  893.  * Delete day info from database (by user ID and day)
  894.  * 
  895.  * @param    integer    $user_id User ID
  896.  * @param    string    $day day of day info (format : YYYY-MM-DD)
  897.  * @return      boolean    true on success, else false (no day info)
  898.  */
  899.   function delete_day_info($user_id, $day)
  900.   {
  901.     mysql_query("DELETE FROM plw_day_info WHERE user_id = $user_id AND day = '$day'");
  902.     $ret_val = mysql_affected_rows() ? true : false;
  903.  
  904.     return $ret_val;
  905.   }
  906.  
  907. /**
  908.  * Delete exercise and all related data from database by user ID, day, and rank
  909.  * 
  910.  * Note : Get exercise ID, then calls delete_exercise_by_id().
  911.  *
  912.  * @param    integer    $user_id User ID
  913.  * @param    string    $day day of exercise (format : YYYY-MM-DD)
  914.  * @param    integer    $rank Rank of exercise within day
  915.  * @return      boolean    true on success, else false (no exercise)
  916.  */
  917.   function delete_exercise_by_day_rank($user_id, $day, $rank)
  918.   {
  919.     $request = sprintf("SELECT id FROM plw_exercise WHERE user_id = %d AND day = '%s' AND rank = %d",
  920.       $user_id, $day, $rank);
  921.     $result = mysql_query($request);
  922.     if ($row = mysql_fetch_assoc($result))
  923.     { $ret_val = $this->delete_exercise_by_id($row['id']); }
  924.     else
  925.     { $ret_val = false; }
  926.     mysql_free_result($result);
  927.  
  928.     return $ret_val;
  929.   }
  930.  
  931. /**
  932.  * Delete exercise and all related data from database by exercise ID
  933.  * 
  934.  * Note : Related data in tables :
  935.  * - plw_data : Exercise data as in HRM file (if recorded)
  936.  * - plw_stat : Exercise statistics (if recorded)
  937.  * - plw_int_training : Interval training elements (if type is int_training)
  938.  * - plw_lap : Exercise laps
  939.  *
  940.  * @param    integer    $id Exercise ID
  941.  * @return      boolean    true on success, else false (no exercise)
  942.  */
  943.   function delete_exercise_by_id($id)
  944.   {
  945.     mysql_query("DELETE FROM plw_data WHERE exercise_id = $id");
  946.     mysql_query("DELETE FROM plw_stat WHERE exercise_id = $id");
  947.     mysql_query("DELETE FROM plw_int_training WHERE exercise_id = $id");
  948.     mysql_query("DELETE FROM plw_lap WHERE exercise_id = $id");
  949.  
  950.     mysql_query("DELETE FROM plw_exercise WHERE id = $id");
  951.     $ret_val = mysql_affected_rows() ? true : false;
  952.  
  953.     return $ret_val;
  954.   }
  955. }
  956. ?>

Documentation generated on Sat, 28 Mar 2009 23:16:08 +0000 by phpDocumentor 1.4.1