may/1KA_F2F
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
1KA_F2F/admin/survey/classes/class.SurveyMobile.php

1143 lines
61 KiB
PHP
Raw Normal View History

Dodan nov repozitorij
2020-08-14 13:36:36 +02:00
<?php
/**
*
* Class ki skrbi za komunikacijo z mobilno aplikacijo
*
*/
class SurveyMobile {
private $anketa; // id ankete
function __construct($anketa = 0) {
global $lang;
if ((int) $anketa > 0) {
$this->anketa = $anketa;
}
}
// Vrne string zadnje verzije mobilne app
//!! to je samo nek ostanek, ki se trenutno rabi samo zato, da se pac gre cez login in da po loginu klice neko funkcijo
public function getMobileVersion() {
/* $sql = sisplet_query("SELECT value FROM misc WHERE what='mobileApp_version'");
if(mysqli_num_rows($sql) > 0){
$row = mysqli_fetch_array($sql);
return $row['value'];
}
else
return 0; */
return 'ABORTED';
}
// Preveri username in pass ce sta ok za login
public function checkLogin($pass, $uname) {
global $lang;
global $pass_salt;
$login_check = false;
$sql = sisplet_query("SELECT id, pass, status FROM users WHERE email='" . $uname . "'");
if (mysqli_num_rows($sql) > 0) {
$row = mysqli_fetch_array($sql);
//if($row['pass'] == base64_encode(bin2hex(hash(SHA256, $pass.$pass_salt))))
if ($row['pass'] == base64_encode(hash('SHA256', $pass . $pass_salt)))
$login_check = true;
}
if ($login_check && $row['id'] > 0 && $row['status'] > 0)
return $row['id'];
else if ($login_check && $row['id'] > 0 && $row['status'] == 0)
return -1;
else
return 0;
}
// Login preko google account api
public function googleLogin($user_email) {
if ($user_email != '') {
$res = sisplet_query("SELECT id, pass FROM users WHERE email='" . $user_email . "'");
// Je noter, ga samo prijavim...
if (mysqli_num_rows($res) > 0) {
$r = mysqli_fetch_row($res);
return $r[0];
}
// Ni se registriran, ga je potrebno dodati na prijavno formo
else {
// geslo med 00000 in zzzzz
Uporaba kriptografsko ustreznih random generatorjev
2023-01-23 19:12:10 +01:00
$pass = base_convert(random_int(0x19A100, 0x39AA3FF), 10, 36);
Dodan nov repozitorij
2020-08-14 13:36:36 +02:00
$EncPass = base64_encode((hash('SHA256', $pass)));
$fn = explode("@", $user_email);
sisplet_query("INSERT INTO users (name, surname, email, pass, lang) VALUES ('" . $fn[0] . "', '', '" . $user_email . "', '" . $EncPass . "', '" . (isset($_GET['regFromEnglish']) && $_GET['regFromEnglish'] == "1" ? '2' : '1') . "')");
$uid = mysqli_insert_id($GLOBALS['connect_db']);
sisplet_query("INSERT INTO oid_users (uid) VALUES ('$uid')");
return $uid;
}
} else
return 0;
}
// update vrstnega reda vprasanj
public function updateQuestionOrder($ank_id, $data) {
if (!isset($data['to_place']) && !isset($data['que_id'])){
$json_array['error'] = 'Question ID or order number missing';
return $json_array;
}
//poizvedi, koliko je vseh spremenljivk
$sql = sisplet_query("SELECT MAX(vrstni_red) FROM srv_branching WHERE ank_id = '$ank_id'");
$row = mysqli_fetch_assoc($sql);
//ali se da spremenljivko na zadnje mesto? ce da, nastavi page_break = 2
$page_break = $row['MAX(vrstni_red)'] == $data['to_place'] ? 2 : 0;
//poizvedi, ali se premakne vprasanje navzgor ali navzdol
//to se rabi, ker ce se prestavi navzgor, je treba odsteti vrstni_red za 1
//zato, ker se v branchingu lahko razvrsca med vsako spremenljivko, pred prvo ter za zadnjo - to je skupaj vse +1
$sql = sisplet_query("SELECT vrstni_red FROM srv_branching WHERE element_spr = '" . $data['que_id'] . "'");
$row = mysqli_fetch_assoc($sql);
$vrstni_red = $row['vrstni_red'] >= $data['to_place'] ? $data['to_place'] - 1 : $data['to_place'];
$ba = new BranchingAjax($ank_id);
$json_array = $ba->ajax_accept_droppable($data['que_id'], $vrstni_red, $page_break, true);
if (empty($json_array))
$json_array['note'] = 'Question order updated';
Common::getInstance()->updateEditStamp();
Common::prestevilci();
return $json_array;
}
//MAZA
/**
* Check login data for MAZA modul app
* @param boolean $loginAction - true if action is only to check login, false otherwise
* @param type $identifier - identifier code for maza app user
* @param type $id_server - id of maza app user on server
* @return if $loginAction is true, return object with data, otherwise return id of maza app user
*/
public function checkMazaLogin($loginAction, $identifier, $id_server, $registration_id) {
global $lang;
global $pass_salt;
$login_check = false;
$id = 0;
$response;
if ($identifier == 'no_identifier') {
$maza = new MAZA();
$newuser = $maza -> insertNewUsers('self');
$login_check = true;
$id = $newuser['id'];
$response['note'] = "login OK";
$response['identifier'] = $newuser['identifier'];
$response['id_server'] = $newuser['id'];
$response['update'] = 'deviceInfo';
}
elseif($identifier == 'no_login'){
$response['note'] = "login OK";
}
else {
//$salted_identifier = base64_encode(hash(SHA256, $identifier . $pass_salt));
$check_id = '';
$does_id_serever_exist = false;
if(!$loginAction || ($loginAction && (isset($id_server) && $id_server!=''))){
$check_id = "id='".$id_server."' AND ";
$does_id_serever_exist = true;
}
$sql = sisplet_query("SELECT id, deviceInfo FROM maza_app_users WHERE ".$check_id."identifier='" . $identifier . "'");
if (mysqli_num_rows($sql) > 0) {
$row = mysqli_fetch_array($sql);
$login_check = true;
$id = $row['id'];
$deviceInfo = $row['deviceInfo'];
//update datetime_last_active
$maza = new MAZA();
$maza -> maza_update_user_active($id, $registration_id);
if(!isset($deviceInfo))
$response['update'] = 'deviceInfo';
if(!$does_id_serever_exist){
$response['identifier'] = $identifier;
$response['id_server'] = $id;
}
$response['note'] = "login OK";
}
//if only login
if($loginAction){
//update datetime_started in table maza_user_srv_access to set datetime of user linking to his survey is already existing (generated users)
sisplet_query("UPDATE maza_user_srv_access SET datetime_started = NOW() WHERE maza_user_id = '$id' AND datetime_started IS NULL;");
}
}
if ($login_check && $id > 0)
return $loginAction ? $response : $id;
else
return 0;
}
/**
* Udates device info with sensors
* @global type $global_user_id
* @return array
*/
public function mazaUpdateDeviceInfo($data) {
global $global_user_id;
$gotData = json_decode($data);
$sqldi = sisplet_query("SELECT deviceInfo FROM maza_app_users WHERE id = '$global_user_id'", 'obj');
if($sqldi->deviceInfo[0] == '{'){
$odlInfo = json_decode($sqldi->deviceInfo);
$lastInfo = end($odlInfo)->device_info;
$gotInfo = $gotData->device_info;
if($lastInfo->os_version == $gotInfo->os_version && $lastInfo->release == $gotInfo->release &&
$lastInfo->serial == $gotInfo->serial){
$json_array['note'] = 'Device info already up to date';
}
else{
$temptime = time();
$odlInfo->$temptime = $gotData;
$newInfo = $odlInfo;
sisplet_query("UPDATE maza_app_users SET deviceInfo = '" . json_encode($newInfo) . "' WHERE id = '$global_user_id'");
$json_array['note'] = 'Device info added';
}
}
else{
$newInfo = array(time()=>$gotData);
sisplet_query("UPDATE maza_app_users SET deviceInfo = '" . json_encode($newInfo) . "' WHERE id = '$global_user_id'");
$json_array['note'] = 'Device info inserted';
}
return $json_array;
}
/**
* Get all alarms of surveys for this user
* @global type $global_user_id
* @return array
*/
public function mazaGetAlarms() {
global $global_user_id;
$sql_arr = sisplet_query("SELECT ma.alarm_notif_title, ma.alarm_notif_message, ma.repeat_by AS alarm_repeat_by, "
. "ma.alarm_notif_sound, ma.time_in_day AS alarm_time_in_day, ma.day_in_week AS alarm_day_in_week, "
. "ma.every_which_day AS alarm_every_which_day, mr.every_which_day AS repeater_every_which_day, "
. "mr.time_in_day AS repeater_time_in_day, mr.repeat_by AS repeater_repeat_by, ma.ank_id, an.url, an.naslov, "
. "mr.day_in_week AS repeater_day_in_week, mr.datetime_start, mr.datetime_end, MAX(sa.srv_version_datetime) AS last_answered_version_datetime, "
. "CASE WHEN sa.datetime_started < mr.datetime_start THEN mr.datetime_start ELSE sa.datetime_started END AS datetime_user_started FROM maza_srv_alarms AS ma "
. "LEFT JOIN (SELECT sua.ank_id, sua.maza_user_id, sua.datetime_started, su.srv_version_datetime FROM maza_user_srv_access AS sua "
. "LEFT JOIN (SELECT msu.srv_version_datetime, msu.maza_user_id, su.ank_id FROM maza_srv_users AS msu "
. "LEFT JOIN (SELECT id, ank_id FROM srv_user) AS su ON su.id=msu.srv_user_id) AS su "
. "ON sua.maza_user_id=su.maza_user_id AND su.ank_id=sua.ank_id) AS sa ON ma.ank_id = sa.ank_id "
. "LEFT JOIN maza_srv_repeaters AS mr ON mr.ank_id = sa.ank_id "
. "LEFT JOIN (SELECT id, url, naslov FROM srv_anketa) AS an ON an.id = sa.ank_id "
. "WHERE sa.maza_user_id='$global_user_id' AND mr.repeater_on='1' GROUP BY ma.ank_id", 'array');
$alarms = array();
foreach ($sql_arr as $row) {
$last_answered_version_datetime = ($row['last_answered_version_datetime']) ? $row['last_answered_version_datetime'] : null;
$alarm = array('title' => $row['alarm_notif_title'], 'message' => $row['alarm_notif_message'], 'ank_id' => $row['ank_id'], 'sound' => $row['alarm_notif_sound'], 'link' => $row['url'].'a/'.$row['ank_id'], 'srv_title' => $row['naslov'],
'repeat' => array("repeat_by" => $row['alarm_repeat_by'], "time_in_day" => json_decode($row['alarm_time_in_day']), "day_in_week" => json_decode($row['alarm_day_in_week']),
"every_which_day" => $row['alarm_every_which_day']),
'repeater' => array("repeat_by" => $row['repeater_repeat_by'], "time_in_day" => json_decode($row['repeater_time_in_day']), "day_in_week" => json_decode($row['repeater_day_in_week']),
"every_which_day" => $row['repeater_every_which_day'], "datetime_start" => $row['datetime_start'], "datetime_end" => $row['datetime_end'],
"last_answered_version_datetime" => $last_answered_version_datetime, "datetime_user_started" => $row['datetime_user_started']));
array_push($alarms, $alarm);
}
return $alarms;
}
/**
* Get all geofences of surveys for this user
* @global type $global_user_id
* @return array
*/
public function mazaGetGeofences() {
global $global_user_id;
$sql_arr = sisplet_query("SELECT mg.id, mg.ank_id, mg.geofence_on, mg.lat, mg.lng, mg.radius, mg.address, mg.name, mg.notif_title, mg.trigger_survey, "
. "mg.notif_message, mg.notif_sound, mg.on_transition, mg.after_seconds, mg.location_triggered, an.url, an.naslov FROM maza_srv_geofences AS mg "
. "LEFT JOIN (SELECT ank_id, maza_user_id FROM maza_user_srv_access) AS sua ON mg.ank_id = sua.ank_id "
. "LEFT JOIN (SELECT id, url, naslov, active FROM srv_anketa) AS an ON an.id = sua.ank_id "
. "WHERE sua.maza_user_id='$global_user_id' AND mg.geofence_on='1' AND an.active='1'", 'array');
//array of all surveys with geofences
$surveys = array();
//object of one survey with its geofences
$survey = array();
//array of geofences of one survey
$geofences = array();
//temporary survey id
$srv_id_temp = -1;
//loop trough geofences
foreach ($sql_arr as $row) {
//if survey id is not equal to previous, create new survey array
if($srv_id_temp != $row['ank_id']){
//ingor first time
if($srv_id_temp > -1){
$survey['geofences'] = $geofences;
array_push($surveys, $survey);
}
//set survey array
$survey = array('ank_id' => $row['ank_id'], 'link' => $row['url'].'a/'.$row['ank_id'], 'srv_title' => $row['naslov']);
//reset geofences
$geofences = array();
//set temporary survey id
$srv_id_temp = $row['ank_id'];
}
//set geofence array
$geofence = array('id' => $row['id'], 'lat' => $row['lat'], 'lng' => $row['lng'], 'radius' => $row['radius'],
'address' => $row['address'], 'notif_title' => $row['notif_title'], 'notif_message' => $row['notif_message'],
'notif_sound' => $row['notif_sound'], 'on_transition' => $row['on_transition'], 'name' => $row['name'],
'after_seconds' => $row['after_seconds'], 'location_triggered' => $row['location_triggered'], 'trigger_survey' => $row['trigger_survey']);
//add geofence to geofences array of one survey
array_push($geofences, $geofence);
}
if(sizeof($sql_arr) > 0){
//add geofences to last survey
$survey['geofences'] = $geofences;
//add last survey to surveys aray
array_push($surveys, $survey);
}
return $surveys;
}
/**
* Get all activities of surveys for this user
* @global type $global_user_id
* @return array
*/
public function mazaGetActivities() {
global $global_user_id;
$sql_arr = sisplet_query("SELECT ma.id, ma.ank_id, ma.activity_on, ma.notif_title, ma.notif_message, ma.notif_sound, "
. "ma.activity_type, ma.after_seconds, ank.naslov, ank.id as ank_id, ank.url, sua.nextpin_tracking_permitted FROM maza_srv_activity AS ma "
. "LEFT JOIN (SELECT ank_id, maza_user_id, nextpin_tracking_permitted FROM maza_user_srv_access) AS sua ON ma.ank_id = sua.ank_id "
. "LEFT JOIN (SELECT id, url, naslov FROM srv_anketa) AS ank ON ma.ank_id = ank.id "
. "WHERE sua.maza_user_id='$global_user_id' AND ma.activity_on='1'", 'array');
//array of all surveys with activities
$surveys = array();
//object of one survey with its activities
$survey = array();
//loop trough activities
foreach ($sql_arr as $row) {
//set survey array
$survey = array('ank_id' => $row['ank_id'], 'link' => $row['url'].'a/'.$row['ank_id'], 'srv_title' => $row['naslov'],
'notif_title' => $row['notif_title'], 'notif_message' => $row['notif_message'], 'notif_sound' => $row['notif_sound'],
'activity' => array('id' => $row['id'], 'activity_type' => $row['activity_type'], 'after_seconds' => $row['after_seconds']), 'permitted'=>$row['nextpin_tracking_permitted']);
array_push($surveys, $survey);
}
return $surveys;
}
/**
* Get all tracking of surveys for this user
* @global type $global_user_id
* @return array
*/
public function mazaGetTracking() {
global $global_user_id;
$sql_arr = sisplet_query("SELECT ank.id, ma.ank_id, ma.tracking_on, ma.activity_recognition, ma.tracking_accuracy, ma.interval_wanted, "
. "ma.interval_fastes, ma.displacement_min, ma.ar_interval_wanted, ank.naslov, ank.url, sua.tracking_permitted FROM maza_srv_tracking AS ma "
. "LEFT JOIN (SELECT ank_id, maza_user_id, tracking_permitted FROM maza_user_srv_access) AS sua ON ma.ank_id = sua.ank_id "
. "LEFT JOIN (SELECT id, url, naslov, active FROM srv_anketa) AS ank ON ma.ank_id = ank.id "
. "WHERE sua.maza_user_id='$global_user_id' AND ma.tracking_on='1' AND ank.active='1'", 'array');
//array of all surveys with tracking
$surveys = array();
//object of one survey with its tracking
$survey = array();
//loop trough trackings
foreach ($sql_arr as $row) {
//set survey array
$survey = array('ank_id' => $row['ank_id'], 'link' => $row['url'].'a/'.$row['ank_id'], 'srv_title' => $row['naslov'],
'tracking' => array('id' => $row['id'], 'activity_recognition' => $row['activity_recognition'], 'tracking_accuracy' => $row['tracking_accuracy'],
'displacement_min' => $row['displacement_min'], 'interval_wanted' => $row['interval_wanted'], 'interval_fastes' => $row['interval_fastes'],
'ar_interval_wanted' => $row['ar_interval_wanted'], 'permitted'=>$row['tracking_permitted']));
array_push($surveys, $survey);
}
return $surveys;
}
/**
* Get all data entries of surveys for this user
* @global type $global_user_id
* @return array
*/
public function mazaGetEntries() {
global $global_user_id;
$sql_arr = sisplet_query("SELECT ank.id, me.ank_id, me.entry_on, me.location_check, ank.naslov, ank.url FROM maza_srv_entry AS me "
. "LEFT JOIN (SELECT ank_id, maza_user_id FROM maza_user_srv_access) AS sua ON me.ank_id = sua.ank_id "
. "LEFT JOIN (SELECT id, url, naslov, active FROM srv_anketa) AS ank ON sua.ank_id = ank.id "
. "WHERE sua.maza_user_id='$global_user_id' AND me.entry_on='1' AND ank.active='1'", 'array');
//array of all surveys with tracking
$surveys = array();
//object of one survey with its tracking
$survey = array();
//loop trough trackings
foreach ($sql_arr as $row) {
//set survey array
$survey = array('ank_id' => $row['ank_id'], 'link' => $row['url'].'a/'.$row['ank_id'], 'srv_title' => $row['naslov'],
'entry' => array('id' => $row['id'], 'location_check' => $row['location_check']));
array_push($surveys, $survey);
}
return $surveys;
}
/**
* Get all locations and AR of user
* @global type $global_user_id
* @return array
*/
public function mazaGetMyLocations() {
global $global_user_id;
//array of locations of user
$sql_loc = sisplet_query("SELECT lat, lng, provider, UNIX_TIMESTAMP(timestamp) as timestamp, "
. "accuracy, altitude, bearing, speed, vertical_acc, bearing_acc, speed_acc, extras, is_mock "
. "FROM maza_user_locations WHERE maza_user_id='$global_user_id' ORDER BY timestamp ASC", 'array');
//array of all AR of user
$sql_ar = sisplet_query("SELECT UNIX_TIMESTAMP(timestamp) as timestamp, in_vehicle, on_bicycle, "
. "on_foot, still, unknown, tilting, running, walking FROM maza_user_activity_recognition "
. "WHERE maza_user_id='$global_user_id' ORDER BY timestamp ASC", 'array');
return array("locations" => $sql_loc, "ar" => $sql_ar);
}
/**
* Update tracking log for this user
* @global type $global_user_id
* @param type $jsonArray - array of logs to save
*/
public function mazaUpdateTrackingLog($jsonArray) {
global $global_user_id;
$update = "";
foreach ($jsonArray as $obj) {
$date = new DateTime();
$date->setTimestamp($obj['tsSec']);
$update .= $obj['value'] . " " . $obj['event'] . " " . $date->format('Y-m-d H:i:s') . "; ";
}
sisplet_query("UPDATE maza_app_users SET tracking_log = CONCAT(tracking_log, '" . $update . "') WHERE id = '$global_user_id'");
}
/**
* Insert tracking locations for this user
* @global type $global_user_id
* @param type $jsonArray - array of locations to insert
* @param type $triggered_geofence_id - ID of triggered geofence to pin location on
*/
public function mazaInsertTrackingLocations($jsonArray, $triggered_geofence_id=null) {
global $global_user_id;
$querryFirst = $querry = "INSERT INTO maza_user_locations (maza_user_id, lat, lng, provider, timestamp, accuracy, altitude, bearing, speed, vertical_acc, bearing_acc, speed_acc, extras, is_mock, tgeof_id) VALUES ";
foreach ($jsonArray as $obj) {
$date = new DateTime();
$date->setTimestamp($obj['timestamp']);
$date = $date->format('Y-m-d H:i:s');
if(!isset($obj['server_input_id']) || $obj['server_input_id'] == -1){
$querry .= "($global_user_id, ".$obj['lat'].", ".$obj['lng'].", '".$obj['provider']."', '".$date."', ".($obj['accuracy'] ? $obj['accuracy'] : "NULL").", ".
($obj['altitude'] ? $obj['altitude'] : "NULL").", ".($obj['bearing'] ? $obj['bearing'] : "NULL").", ".($obj['speed'] ? $obj['speed'] : "NULL").", ".
($obj['vertical_acc'] ? $obj['vertical_acc'] : "NULL").", ".($obj['bearing_acc'] ? $obj['bearing_acc'] : "NULL").", ".
($obj['speed_acc'] ? $obj['speed_acc'] : "NULL").", '".($obj['extras'] ? $obj['extras'] : "")."', ".$obj['is_mock'].", ".($triggered_geofence_id ? $triggered_geofence_id : "NULL")."), ";
}
else{
$querry1 = "INSERT INTO maza_user_locations (maza_user_id, lat, lng, provider, timestamp, accuracy, altitude, bearing, speed, vertical_acc, bearing_acc, speed_acc, extras, is_mock, tgeof_id) VALUES "
. "($global_user_id, ".$obj['lat'].", ".$obj['lng'].", '".$obj['provider']."', '".$date."', ".($obj['accuracy'] ? $obj['accuracy'] : "NULL").", ".
($obj['altitude'] ? $obj['altitude'] : "NULL").", ".($obj['bearing'] ? $obj['bearing'] : "NULL").", ".($obj['speed'] ? $obj['speed'] : "NULL").", ".
($obj['vertical_acc'] ? $obj['vertical_acc'] : "NULL").", ".($obj['bearing_acc'] ? $obj['bearing_acc'] : "NULL").", ".
($obj['speed_acc'] ? $obj['speed_acc'] : "NULL").", '".($obj['extras'] ? $obj['extras'] : "")."', ".$obj['is_mock'].", ".($triggered_geofence_id ? $triggered_geofence_id : "NULL").");";
$loc_id = sisplet_query($querry1, 'id');
$querry2 = "UPDATE maza_srv_users SET loc_id='$loc_id' WHERE srv_user_id='".$obj['server_input_id']."';";
sisplet_query($querry2);
}
}
if($querryFirst != $querry){
$querry = substr($querry, 0, -2);
sisplet_query($querry);
}
}
/**
* Edit tracking locations for this user
* @global type $global_user_id
* @param type $jsonArray - array of locations to edit
*/
public function mazaEditTrackingLocations($jsonArray) {
global $global_user_id;
if(isset($jsonArray['delete']) && !empty($jsonArray['delete'])){
$set_timestamp = "";
$where_delete="";
foreach ($jsonArray['delete'] as $obj) {
$set_timestamp.=" when UNIX_TIMESTAMP(timestamp)=".$obj['timestamp']." then FROM_UNIXTIME(".$obj['extras'].")";
$where_delete.=$obj['timestamp'].", ";
}
$where_delete = substr($where_delete, 0, -2);
$querry_delete = "UPDATE maza_user_locations SET timestamp = (case$set_timestamp end), "
. "lat=999, lng=999, provider='deleted', accuracy=NULL, altitude=NULL, bearing=NULL, speed=NULL, vertical_acc=NULL, bearing_acc=NULL, speed_acc=NULL, extras=NULL, is_mock=NULL WHERE maza_user_id=$global_user_id AND "
. "UNIX_TIMESTAMP(timestamp) IN (".$where_delete.");";
sisplet_query($querry_delete);
}
if(isset($jsonArray['edit']) && !empty($jsonArray['edit'])){
$set_lat = "";
$set_lng = "";
$where_edit="";
foreach ($jsonArray['edit'] as $obj) {
$set_lat.=" when UNIX_TIMESTAMP(timestamp)=".$obj['timestamp']." then ".$obj['lat'];
$set_lng.=" when UNIX_TIMESTAMP(timestamp)=".$obj['timestamp']." then ".$obj['lng'];
$where_edit.=$obj['timestamp'].", ";
}
$where_edit = substr($where_edit, 0, -2);
$querry_delete = "UPDATE maza_user_locations SET lat = (case$set_lat end), lng = (case$set_lng end), "
. "provider='manual' WHERE maza_user_id=$global_user_id AND "
. "UNIX_TIMESTAMP(timestamp) IN (".$where_edit.");";
sisplet_query($querry_delete);
}
}
/**
* Insert tracking locations for this user
* @global type $global_user_id
* @param type $jsonArray - array of locations to insert
*/
public function mazaInsertTrackingAR($jsonArray) {
global $global_user_id;
$querry = "INSERT INTO maza_user_activity_recognition (maza_user_id, timestamp, in_vehicle, on_bicycle, on_foot, still, unknown, tilting, running, walking) VALUES ";
foreach ($jsonArray as $obj) {
$date = new DateTime();
$date->setTimestamp($obj['timestamp']);
$date = $date->format('Y-m-d H:i:s');
$querry .= "($global_user_id, '$date', ".$obj['in_vehicle'].", ".
$obj['on_bicycle'].", ".$obj['on_foot'].", ".$obj['still'].", ".
$obj['unknown'].", ".$obj['tilting'].", ".
$obj['running'].", ".$obj['walking']."), ";
}
$querry = substr($querry, 0, -2);
sisplet_query($querry);
}
/**
* Insert new triggered geofences
* @global type $global_user_id
* @param type $jsonArray - arrays of triggered geofences to save
*/
public function mazaInsertTriggeredGeofences($jsonArray) {
global $global_user_id;
$new_tgeof_id = 0;
foreach ($jsonArray as $obj) {
$date = new DateTime();
$triggered_timestamp = $date->setTimestamp($obj['geofence']['tsSec'])->format('Y-m-d H:i:s');
$enter_timestamp = $date->setTimestamp($obj['geofence']['enter_timestamp'])->format('Y-m-d H:i:s');
$dwell_timestamp = $date->setTimestamp($obj['geofence']['dwell_timestamp'])->format('Y-m-d H:i:s');
$tgeo_id = sisplet_query("INSERT INTO maza_srv_triggered_geofences (geof_id, maza_user_id, triggered_timestamp, enter_timestamp, dwell_timestamp) VALUES "
. "('".$obj['geofence']['value']."','$global_user_id', '$triggered_timestamp', '$enter_timestamp' ,'$dwell_timestamp')", "id");
$this->mazaInsertTrackingLocations($obj['locations'], $tgeo_id);
if(isset($obj['geofence']['return_server_id']) && $obj['geofence']['return_server_id'] == true)
$new_tgeof_id = $tgeo_id;
}
return $new_tgeof_id;
}
/**
* Unsubscribe survey for this user
* @global type $global_user_id
* @param type $ank_id - survey ID to unsuscribe
*/
public function mazaUnsubscribeSurvey($ank_id) {
global $global_user_id;
sisplet_query("UPDATE maza_user_srv_access SET datetime_unsubscribed = NOW() WHERE maza_user_id = '$global_user_id' AND ank_id = '$ank_id';");
$json_array['note'] = 'Unsubscribed from survey';
return $json_array;
}
/**
* Set agreed permission for tracking and register listener on nextpin API
* @global type $global_user_id
* @param type $data - array of data
*/
public function mazaSetNextpinTrackingPermission($data) {
global $global_user_id;
if (isset($data['tracking_permission']) && isset($data['srv_id'])) {
sisplet_query("UPDATE maza_user_srv_access SET nextpin_tracking_permitted = '" . $data['tracking_permission'] . "' WHERE maza_user_id = '$global_user_id' AND ank_id = '".$data['srv_id']."'");
if($data['tracking_permission'] == 1){
$sql_pass = sisplet_query("SELECT nextpin_password, identifier FROM maza_app_users WHERE id='$global_user_id';", 'obj');
if($sql_pass){
$maza = new MAZA($data['srv_id']);
//password is null, user is not registered on nextpin yet
if(!$sql_pass->nextpin_password){
//generate new password
$newpass = $maza -> randomAlphaNumericCode(4);
//set password in db
sisplet_query("UPDATE maza_app_users SET nextpin_password = '$newpass' WHERE id = '$global_user_id'");
$json_array['data']['nextpin_password'] = $newpass;
//create new user in nextpin
$maza -> nextpin_create_user($sql_pass->identifier, $newpass);
}
//create new activity listener for this identifier
$maza -> nextpin_set_activity_listener($sql_pass->identifier);
}
}
$json_array['note'] = 'Tracking permission updated';
}
else
$json_array['error'] = 'Param tracking_permission or srv_id missing';
return $json_array;
}
/**
* Set agreed permission for tracking and register listener
* @global type $global_user_id
* @param type $data - array of data
*/
public function mazaSetTrackingPermission($data) {
global $global_user_id;
if (isset($data['tracking_permission']) && isset($data['srv_id'])) {
sisplet_query("UPDATE maza_user_srv_access SET tracking_permitted = '" . $data['tracking_permission'] . "' WHERE maza_user_id = '$global_user_id' AND ank_id = '".$data['srv_id']."'");
$json_array['note'] = 'Tracking permission updated';
}
else
$json_array['error'] = 'Param tracking_permission or srv_id missing';
return $json_array;
}
/**
* Merge identifiers
* @global type $global_user_id
* @param type $identifier - identifier to merge
*/
public function mazaMergeIdentifier($identifier) {
global $global_user_id;
//check if this identifier exists
$sql_arr = sisplet_query("SELECT id FROM maza_app_users WHERE identifier='$identifier';", 'obj');
if($sql_arr->id == $global_user_id)
return array('error' => 'incorrect identifier');
//identifier exsits
else if($sql_arr){
//get survey access of user
$sql_user_access = sisplet_query("SELECT ank_id FROM maza_user_srv_access WHERE maza_user_id='$global_user_id';", 'array');
//get survey access of identifier
$sql_identifier_access = sisplet_query("SELECT ank_id FROM maza_user_srv_access WHERE maza_user_id='$sql_arr->id';", 'array');
$user_access_arr = array();
$identifier_access_arr = array();
//create array of user accesses
foreach($sql_user_access as $ua)
array_push($user_access_arr, $ua['ank_id']);
//create array of identifier accesses
foreach($sql_identifier_access as $ia)
array_push($identifier_access_arr, $ia['ank_id']);
//array of which surveys does indentifier has access and not user
$what_to_add_array = array_diff($identifier_access_arr, $user_access_arr);
//if not empty, go insert
if($what_to_add_array){
$sql_values = "";
//create string of values(accesses) to insert to user access
foreach($what_to_add_array as $add)
$sql_values .= "('$global_user_id','$add', NOW()),";
//remove last comma
$sql_values = substr($sql_values, 0, -1);
//insert new accesses from identifier to user
sisplet_query("INSERT INTO maza_user_srv_access (maza_user_id, ank_id, datetime_started) VALUES $sql_values");
}
//delete all accesses of identifier
sisplet_query("DELETE FROM maza_user_srv_access WHERE maza_user_id = '$sql_arr->id'");
//delete identifier from user table
sisplet_query("DELETE FROM maza_app_users WHERE id = '$sql_arr->id'");
return array('note' => 'merge OK');
}
//identifier does not exist
else
return array('error' => 'identifier does not exist');
}
/**
* Get info of surveys to merge (by identifier)
* @global type $global_user_id
* @param type $identifier - identifier to get linked surveys info from
*/
public function mazaGetSurveysInfoByIdentifier($identifier) {
global $global_user_id;
//check if this identifier exists
$sql_arr = sisplet_query("SELECT id FROM maza_app_users WHERE identifier='$identifier';", 'obj');
//identifier exsits
if($sql_arr){
//get survey access of user
$sql_user_access = sisplet_query("SELECT ank_id FROM maza_user_srv_access WHERE maza_user_id='$global_user_id';", 'array');
//get survey access of identifier
$sql_identifier_access = sisplet_query("SELECT ank_id FROM maza_user_srv_access WHERE maza_user_id='$sql_arr->id';", 'array');
$user_access_arr = array();
$identifier_access_arr = array();
//create array of user accesses
foreach($sql_user_access as $ua)
array_push($user_access_arr, $ua['ank_id']);
//create array of identifier accesses
foreach($sql_identifier_access as $ia)
array_push($identifier_access_arr, $ia['ank_id']);
//array of which surveys does indentifier has access and not user
$what_to_add_array = array_diff($identifier_access_arr, $user_access_arr);
//if not empty, or get info about users identifier, go selelct
if($sql_arr->id == $global_user_id || $what_to_add_array){
$sur_ids_in_string = "(".implode( ", ", $what_to_add_array ).")";
//get surveys info
$sql = "SELECT s.id, s.naslov, s.active, s.starts, s.expire, s.url, "
. "ge.geofences, sr.repeater_on, sr.repeat_by, sr.datetime_start, sr.datetime_end, "
. "ac.activities, se.entry_on, se.location_check, tr.tracking_on, tr.activity_recognition "
. "FROM srv_anketa AS s "
. "LEFT JOIN maza_srv_repeaters AS sr ON s.id = sr.ank_id "
. "LEFT JOIN (SELECT ank_id, COUNT(id) as geofences FROM maza_srv_geofences WHERE geofence_on='1' GROUP BY ank_id) AS ge ON s.id = ge.ank_id "
. "LEFT JOIN (SELECT ank_id, COUNT(id) as activities FROM maza_srv_activity WHERE activity_on='1' GROUP BY ank_id) AS ac ON s.id = ac.ank_id "
. "LEFT JOIN (SELECT entry_on, location_check, ank_id FROM maza_srv_entry) AS se ON s.id = se.ank_id "
. "LEFT JOIN (SELECT tracking_on, activity_recognition, ank_id FROM maza_srv_tracking) AS tr ON s.id = tr.ank_id "
. "WHERE s.id IN $sur_ids_in_string;";
$sql_surveys_info = sisplet_query($sql, 'array');
return $sql_surveys_info;
}
else
return array('note' => 'already participant');
}
//identifier does not exist
else
return array('error' => 'identifier does not exist');
}
/**
* Get all subscriptions/surveys of user
* @global type $global_user_id
* @return type
*/
public function mazaGetSubscriptionsList($timeZone){
global $global_user_id;
//get surveys
$Sql = "SELECT *, UNIX_TIMESTAMP(datetime_started) as unixstart FROM maza_user_srv_access AS sa "
. "LEFT JOIN (SELECT id AS srv_id, naslov, active, starts, expire, url FROM srv_anketa) AS s ON s.srv_id = sa.ank_id "
. "LEFT JOIN maza_srv_repeaters AS sr ON s.srv_id = sr.ank_id "
. "LEFT JOIN (SELECT ank_id, COUNT(id) as geofences FROM maza_srv_geofences WHERE geofence_on='1' GROUP BY ank_id) AS ge ON s.srv_id = ge.ank_id "
. "LEFT JOIN (SELECT ank_id, COUNT(id) as activities FROM maza_srv_activity WHERE activity_on='1' GROUP BY ank_id) AS ac ON s.srv_id = ac.ank_id "
. "LEFT JOIN (SELECT entry_on, location_check, ank_id FROM maza_srv_entry) AS se ON s.srv_id = se.ank_id "
. "LEFT JOIN (SELECT tracking_on, activity_recognition, ank_id FROM maza_srv_tracking) AS tr ON s.srv_id = tr.ank_id "
. "LEFT JOIN (SELECT srv_description, srv_id as ank_id FROM maza_survey) AS ms ON ms.ank_id = s.srv_id "
. "WHERE sa.maza_user_id = '$global_user_id' AND s.active = '1' AND sa.datetime_unsubscribed IS NULL;";
//all active surveys on which user has access
$sarray = sisplet_query($Sql, 'array');
$resultarray = array();
//get nuber of unfidished questionnaires
$surveyListArray = $this->mazaGetSurveyList($timeZone);
foreach($sarray as $survey){
$survey['unfinished_cnt'] = $surveyListArray[$survey['srv_id']]['unfinished_cnt'];
$survey['url'] = $survey['url'].'a/'.$survey['srv_id'];
$resultarray[] = $survey;
}
return $resultarray;
}
/**
* Vrne seznam anket na katere je uporabnik narocen
* @param type $timeZone - timezone ID of user
* @return array
*/
public function mazaGetSurveyList($timeZone, $srv_id = null) {
global $global_user_id;
$surveyWhere = $srv_id == null ? '' : ' AND s.srv_id = '.$srv_id;
$json_array = array();
//get surveys
$Sql = "SELECT * FROM maza_user_srv_access AS sa "
. "LEFT JOIN (SELECT id AS srv_id, naslov, active, starts, expire, url FROM srv_anketa) AS s ON s.srv_id = sa.ank_id "
. "LEFT JOIN maza_srv_repeaters AS sr ON s.srv_id = sr.ank_id "
. "LEFT JOIN (SELECT id, ank_id, COUNT(id) as geofences FROM maza_srv_geofences WHERE geofence_on='1' GROUP BY ank_id) AS ge ON s.srv_id = ge.ank_id "
. "LEFT JOIN (SELECT id, ank_id, COUNT(id) as activities FROM maza_srv_activity WHERE activity_on='1' GROUP BY ank_id) AS ac ON s.srv_id = ac.ank_id "
. "LEFT JOIN (SELECT tracking_on, ank_id FROM maza_srv_tracking) AS st ON s.srv_id = st.ank_id "
. "LEFT JOIN (SELECT entry_on, ank_id FROM maza_srv_entry) AS se ON s.srv_id = se.ank_id "
. "WHERE sa.maza_user_id = '$global_user_id' AND s.active = '1' AND sa.datetime_unsubscribed IS NULL$surveyWhere;";
//all active surveys on which user has access
$sarray = sisplet_query($Sql, 'array');
//get existing surveys for this user
$Sql = "SELECT *, UNIX_TIMESTAMP(srv_version_datetime) as unixver FROM maza_srv_users AS msu "
. "LEFT JOIN (SELECT id, cookie, ank_id, last_status, time_insert FROM srv_user) AS su ON msu.srv_user_id = su.id "
. "LEFT JOIN (SELECT id AS srv_id, active, starts, naslov, url FROM srv_anketa) AS s ON su.ank_id = s.srv_id "
. "LEFT JOIN (SELECT maza_user_id, ank_id, datetime_unsubscribed FROM maza_user_srv_access) AS sa ON sa.ank_id = s.srv_id "
. "WHERE s.active = '1' AND msu.maza_user_id = '$global_user_id' AND sa.maza_user_id = '$global_user_id' AND sa.datetime_unsubscribed IS NULL$surveyWhere;";
//cookies of surveys for all active surveys of this user
$uarray = sisplet_query($Sql, 'array');
//do we have any active survey with data entries?
$dataEntryArray = null;
//create array of users surveys to later access it
$cookies_array = array();
foreach($uarray as $row){
//if we have a entry mode and didnt get data entry array yet, run it
if($dataEntryArray == null && $row['mode'] == 'entry'){
$dataEntryArray = $this->getDataEntryArray();
}
$link = $row['url'].'a/'.$row['srv_id'].'&survey-'.$row['srv_id'].'='.$row['cookie'];
$srv_version_datetime = ($row['srv_version_datetime'] != null && $row['unixver'] != null) ? $row["srv_version_datetime"] : $row["time_insert"];
$temp_date = new DateTime($srv_version_datetime);
//$srv_version_datetime = $temp_date->format('Hi_d_m_Y');
$srv_version_timestamp = $row['unixver'] != null ? $row['unixver'] : $temp_date->getTimestamp();
$cookies_array[$row['srv_id']][$srv_version_timestamp] = array('status'=>$row['last_status'], 'link'=>$link, 'naslov'=>$row['naslov'], 'srv_id'=>$row['ank_id'],
'timestamp'=>$srv_version_timestamp, 'datetime'=>$srv_version_datetime, 'mode'=>$row['mode'], 'srv_version'=>$srv_version_datetime,
'latitude'=>$dataEntryArray[$row['srv_user_id']]['latitude'], 'longitude'=>$dataEntryArray[$row['srv_user_id']]['longitude'], 'srv_user_id'=>$row['srv_user_id']);
}
//set users timezone (all calculations are for users timezone)
$dateTz = new DateTimeZone($timeZone);
//what is now a time of users device
$Udate = new DateTime("now", $dateTz);
//get offset in hours of user timezone versus server timezone (for calculations of datetime from DB)
$offset = $dateTz->getOffset($Udate)-date('Z');
//set users timestamp based on time of DB datetimes
$user_timestamp_now = $Udate->getTimestamp()+$offset;
//geofences
$sql_geo = sisplet_query("SELECT g.ank_id, tg.id, tg.geof_id, tg.triggered_timestamp, g.address, g.name, g.trigger_survey, s.naslov, s.url, sa.ank_id, sa.maza_user_id, sa.datetime_unsubscribed "
. "FROM maza_srv_triggered_geofences AS tg "
. "LEFT JOIN (SELECT ank_id, geofence_on, id, address, name, trigger_survey FROM maza_srv_geofences) AS g ON g.id=tg.geof_id "
. "LEFT JOIN (SELECT id as srv_id, active, naslov, url FROM srv_anketa) AS s ON g.ank_id = s.srv_id "
. "LEFT JOIN (SELECT maza_user_id, ank_id, datetime_unsubscribed FROM maza_user_srv_access) AS sa ON sa.ank_id = g.ank_id "
. "WHERE tg.maza_user_id='$global_user_id' AND s.active = '1' AND sa.maza_user_id = '$global_user_id' AND sa.datetime_unsubscribed IS NULL$surveyWhere;", 'array');
//this survey has geofencing
if (count($sql_geo) > 0) {
foreach($sql_geo as $tgeo){
if($tgeo['trigger_survey']!=null){
$triggered_datetime = new DateTime($tgeo['triggered_timestamp']);
$triggered_timestamp = $triggered_datetime->getTimestamp();
$link = isset($cookies_array[$tgeo['ank_id']][$triggered_timestamp]) ? $cookies_array[$tgeo['ank_id']][$triggered_timestamp]['link'] : $tgeo['url'].'a/'.$tgeo['ank_id'];
$user_status = isset($cookies_array[$tgeo['ank_id']][$triggered_timestamp]) ? $cookies_array[$tgeo['ank_id']][$triggered_timestamp]['status'] : '';
$srv_user_id = isset($cookies_array[$tgeo['ank_id']][$triggered_timestamp]) ? $cookies_array[$tgeo['ank_id']][$triggered_timestamp]['srv_user_id'] : '';
//$srv_version = $temp_date->format('Hi_d_m_Y');
/*$new_array = array('timestamp' => $triggered_timestamp, 'datetime' => $tgeo['triggered_timestamp'], 'srv_id' => $tgeo['ank_id'], 'naslov' => $tgeo['naslov'], 'name' => $tgeo['name'],
'srv_version' => $tgeo['triggered_timestamp'], 'link' => $link, 'status' => $user_status, 'address' => $tgeo['address'], 'tgeof_id' => $tgeo['id'], 'mode' => 'geofence', 'srv_user_id'=>$srv_user_id);*/
$unfinished = $user_status == 6 ? 0 : 1;
if(isset($json_array[$tgeo['ank_id']]['surveys'])){
$json_array[$tgeo['ank_id']]['surveys'][]=array('timestamp' => $triggered_timestamp, 'datetime' => $tgeo['triggered_timestamp'], 'srv_version' => $tgeo['triggered_timestamp'],
'link' => $link, 'status' => $user_status, 'tgeof_id' => $tgeo['id'], 'mode' => 'geofence', 'srv_user_id'=>$srv_user_id, 'name' => $tgeo['name'], 'address' => $tgeo['address']);
$json_array[$tgeo['ank_id']]['unfinished_cnt']+=$unfinished;
}
else{
$json_array[$tgeo['ank_id']]=array('srv_id' => $tgeo['ank_id'], 'naslov' => $tgeo['naslov'], 'unfinished_cnt' => $unfinished,
'surveys' => array(array('timestamp' => $triggered_timestamp, 'datetime' => $tgeo['triggered_timestamp'], 'srv_version' => $tgeo['triggered_timestamp'], 'link' => $link,
'status' => $user_status, 'tgeof_id' => $tgeo['id'], 'mode' => 'geofence', 'srv_user_id'=>$srv_user_id, 'name' => $tgeo['name'], 'address' => $tgeo['address'])));
}
//array_push($json_array, $new_array);
if(isset($cookies_array[$tgeo['ank_id']][$triggered_timestamp]))
unset($cookies_array[$tgeo['ank_id']][$triggered_timestamp]);
}
}
}
//activity
$sql_act = sisplet_query("SELECT a.ank_id, ta.id, ta.act_id, ta.triggered_timestamp, s.naslov, s.url, sa.ank_id, sa.maza_user_id, sa.datetime_unsubscribed "
. "FROM maza_srv_triggered_activities AS ta "
. "LEFT JOIN (SELECT ank_id, activity_on, id FROM maza_srv_activity) AS a ON a.id=ta.act_id "
. "LEFT JOIN (SELECT id as srv_id, active, naslov, url FROM srv_anketa) AS s ON a.ank_id = s.srv_id "
. "LEFT JOIN (SELECT maza_user_id, ank_id, datetime_unsubscribed FROM maza_user_srv_access) AS sa ON sa.ank_id = g.ank_id "
. "WHERE ta.maza_user_id='$global_user_id' AND s.active = '1' AND sa.maza_user_id = '$global_user_id' AND sa.datetime_unsubscribed IS NULL$surveyWhere;", 'array');
//this survey has activities
if (count($sql_act) > 0) {
foreach($sql_act as $tact){
$triggered_datetime = new DateTime($tact['triggered_timestamp']);
$triggered_timestamp = $triggered_datetime->getTimestamp();
$link = isset($cookies_array[$tact['ank_id']][$triggered_timestamp]) ? $cookies_array[$tact['ank_id']][$triggered_timestamp]['link'] : $tact['url'].'a/'.$tact['ank_id'];
$user_status = isset($cookies_array[$tact['ank_id']][$triggered_timestamp]) ? $cookies_array[$tact['ank_id']][$triggered_timestamp]['status'] : '';
$srv_user_id = isset($cookies_array[$tact['ank_id']][$triggered_timestamp]) ? $cookies_array[$tact['ank_id']][$triggered_timestamp]['srv_user_id'] : '';
//$srv_version = $temp_date->format('Hi_d_m_Y');
/*$new_array = array('timestamp' => $triggered_timestamp, 'datetime' => $tact['triggered_timestamp'], 'srv_id' => $tact['ank_id'], 'naslov' => $tact['naslov'],
'srv_version' => $tact['triggered_timestamp'], 'link' => $link, 'status' => $user_status, 'tact_id' => $tact['id'], 'mode' => 'activity', 'srv_user_id'=>$srv_user_id);*/
$unfinished = $user_status == 6 ? 0 : 1;
if(isset($json_array[$tact['ank_id']]['surveys'])){
$json_array[$tgeo['ank_id']]['surveys'][]= array('timestamp' => $triggered_timestamp, 'datetime' => $tact['triggered_timestamp'], 'srv_version' => $tact['triggered_timestamp'],
'link' => $link, 'status' => $user_status, 'tact_id' => $tact['id'], 'mode' => 'activity', 'srv_user_id'=>$srv_user_id);
$json_array[$tgeo['ank_id']]['unfinished_cnt']+=$unfinished;
}
else
$json_array[$tact['ank_id']]=array('srv_id' => $tact['ank_id'], 'naslov' => $tact['naslov'], 'unfinished_cnt' => $unfinished,
'surveys' => array(array('timestamp' => $triggered_timestamp, 'datetime' => $tact['triggered_timestamp'], 'srv_version' => $tact['triggered_timestamp'],
'link' => $link, 'status' => $user_status, 'tact_id' => $tact['id'], 'mode' => 'activity', 'srv_user_id'=>$srv_user_id)));
//array_push($json_array, $new_array);
if(isset($cookies_array[$tact['ank_id']][$triggered_timestamp]))
unset($cookies_array[$tact['ank_id']][$triggered_timestamp]);
}
}
foreach($sarray as $survey){
//if($survey["repeater_on"] != '2'){
//survey with no repeater
if($survey["repeater_on"] == '0'){
//only basic survey with no answer
if(($survey['geofences'] == null || $survey['geofences'] == '0') &&
($survey['activities'] == null || $survey['activities'] == '0') &&
($survey['entry_on'] == null || $survey['entry_on'] == '0') &&
($survey['tracking_on'] == null || $survey['tracking_on'] == '0') &&
!isset($cookies_array[$survey['srv_id']])){
$link = $survey['url'].'a/'.$survey['srv_id'];
$user_status = '';
$temp_timestamp = strtotime($survey['starts']);
//$srv_version = $temp_date->format('Hi_d_m_Y');
/*$new_array = array('timestamp' => $temp_timestamp, 'datetime' => $survey['starts'], 'srv_id' => $survey['srv_id'], 'naslov' => $survey['naslov'],
'srv_version' => '', 'link' => $link, 'status' => $user_status, 'mode' => 'basic', 'srv_user_id'=>'');*/
$json_array[$survey['srv_id']] = array('srv_id' => $survey['srv_id'], 'naslov' => $survey['naslov'], 'unfinished_cnt' => 1,
'surveys' => array(array('timestamp' => $temp_timestamp, 'datetime' => $survey['starts'], 'link' => $link, 'srv_version' => '', 'status' => $user_status, 'mode' => 'basic', 'srv_user_id'=>'')));
//array_push($json_array, $new_array);
}
}
//survey with repeater
else{
//use latest datetime to start repeater for this user (when repeater started or when user accessed)
$Accessdate = new DateTime($survey["datetime_started"]);
$Startdate = new DateTime($survey["datetime_start"]);
$Startdate = $Startdate < $Accessdate ? $Accessdate : $Startdate;
$Startdate_string = $Startdate->format('Y-m-d');
//if, based on timezone user-server differences, users timestamp is less than starting of repeater, there are no avalible surveys yet
//we have to wait until users date and time gets at least to date and time of servers datetime of repeater started
if(strtotime($Startdate_string) <= $user_timestamp_now /*&& $user_timestamp_now <= $Endtimestamp*/){
switch($survey["repeat_by"]){
case 'everyday':
$temp_date_by_day = new DateTime($Startdate_string);
$edited_arr = $this->createArrayRepeater($json_array, $temp_date_by_day, $user_timestamp_now, $survey, $cookies_array, 1);
$json_array = $edited_arr['surveys'];
$cookies_array = $edited_arr['cookies'];
break;
case 'daily':
$temp_date_by_day = new DateTime($Startdate_string);
$edited_arr = $this->createArrayRepeater($json_array, $temp_date_by_day, $user_timestamp_now, $survey, $cookies_array, $survey['every_which_day']);
$json_array = $edited_arr['surveys'];
$cookies_array = $edited_arr['cookies'];
break;
case 'weekly':
foreach(json_decode($survey['day_in_week']) as $dayinweek){
$temp_date_by_day = new DateTime($Startdate_string);
$dayinweek_string = ['Monday', 'Tuesday', 'Wednesday', 'Thursday', 'Friday', 'Saturday', 'Sunday'];
if($temp_date_by_day->format('l') != $dayinweek_string[$dayinweek-1])
$temp_date_by_day->modify('next '.$dayinweek_string[$dayinweek-1]);
$edited_arr = $this->createArrayRepeater($json_array, $temp_date_by_day, $user_timestamp_now, $survey, $cookies_array, 7);
$json_array = $edited_arr['surveys'];
$cookies_array = $edited_arr['cookies'];
}
break;
}
}
}
//}
}
//for data entry surveys and basic survey with answer
foreach($cookies_array as $survey){
foreach($survey as $cookie){
//include basic survey with answer and data entry if it is still on
if(!isset($cookie['mode']) || ($cookie['mode'] == 'entry')){
//array_push($json_array, $cookie);
if(isset($json_array[$cookie['srv_id']]['surveys']))
$json_array[$cookie['srv_id']]['surveys'][] = $cookie;
else
$json_array[$cookie['srv_id']] = array('srv_id' => $cookie['srv_id'], 'naslov' => $cookie['naslov'], 'surveys'=>array($cookie));
$json_array[$cookie['srv_id']]['unfinished_cnt']+=($cookie['status']==6 ? 0:1);
}
}
}
//krsort($json_array);
//tole mislim da sicer razvrsti, ampak pobrise keye
/*usort($json_array, function ($a, $b)
{
return -strcmp($a['timestamp'], $b['timestamp']);
});*/
return $json_array;
}
/**
* Get array of data entry latitude and longitude values from answers
* @global type $global_user_id
* @return type array of data with usr_id as keys
*/
private function getDataEntryArray(){
global $global_user_id;
$dataEntryArray = array();
$Sql = "SELECT * FROM maza_srv_users AS msu "
. "LEFT JOIN (SELECT id, ank_id FROM srv_user) AS su ON msu.srv_user_id = su.id "
. "LEFT JOIN (SELECT id AS srv_id, active FROM srv_anketa) AS s ON su.ank_id = s.srv_id "
. "LEFT JOIN (SELECT id as gru_id, ank_id FROM srv_grupa) AS gru ON su.ank_id = gru.ank_id "
. "LEFT JOIN (SELECT id AS lat_spr_id, gru_id FROM srv_spremenljivka WHERE variable='latitude' AND sistem='1') AS spr1 ON gru.gru_id = spr1.gru_id "
. "LEFT JOIN (SELECT text as latitude, usr_id, spr_id FROM srv_data_text_active) AS dt1 ON msu.srv_user_id = dt1.usr_id AND dt1.spr_id = spr1.lat_spr_id "
. "LEFT JOIN (SELECT id AS lng_spr_id, gru_id FROM srv_spremenljivka WHERE variable='longitude' AND sistem='1') AS spr2 ON gru.gru_id = spr2.gru_id "
. "LEFT JOIN (SELECT text as longitude, usr_id, spr_id FROM srv_data_text_active) AS dt2 ON msu.srv_user_id = dt2.usr_id AND dt2.spr_id = spr2.lng_spr_id "
. "WHERE s.active = '1' AND msu.maza_user_id = '$global_user_id' AND msu.mode='entry' AND dt1.latitude IS NOT NULL AND dt2.longitude IS NOT NULL;";
//coordinates of data entries for all active surveys of this user
$entryarray = sisplet_query($Sql, 'array');
foreach($entryarray as $array){
$dataEntryArray[$array['srv_user_id']] = $array;
}
return $dataEntryArray;
}
/**
* MAZA function
* Creates or modifies a json array of surveys with repeater
* @param type $json_array - array to modify or empty array
* @param type $temp_date_by_day - DateTime object of starting day
* @param type $user_timestamp_now - timestamp of users now (by users timezone)
* @param type $survey - array of surveys and repeaters data for survey, to which user has access
* @param type $cookies_array - array of existing surveys for this user
* @param type $every_which_day - every which day has to be repeated (every day - 1, weekly - 7,...)
* @return type json array of surveys for this user
*/
private function createArrayRepeater($json_array, $temp_date_by_day, $user_timestamp_now, $survey, $cookies_array, $every_which_day){
//get ending timestamp time of repeater
$Endtimestamp = $survey["datetime_end"] != null ? (new DateTime($survey["datetime_end"]))->getTimestamp() : null;
//loop until users timestamp of now
while($temp_date_by_day->getTimestamp() <= $user_timestamp_now && ($Endtimestamp != null ? $temp_date_by_day->getTimestamp() <= $Endtimestamp : true)){
//iterate trough times in day
foreach(json_decode($survey['time_in_day']) as $timeinday){
//set temporary datetime of given date and time in day
$temp_date = DateTime::createFromFormat('Y-m-d Hi', $temp_date_by_day->format('Y-m-d').' '.$timeinday);
$temp_date_timestamp = $temp_date->getTimestamp();
if(/*$temp_date_timestamp > strtotime($survey["datetime_started"]) &&*/ $temp_date_timestamp < $user_timestamp_now){
$srv_version = $temp_date->format('Hi_d_m_Y');
$link = isset($cookies_array[$survey['srv_id']][$temp_date_timestamp]) ? $cookies_array[$survey['srv_id']][$temp_date_timestamp]['link'] : $survey['url'].'a/'.$survey['srv_id'];
$user_status = isset($cookies_array[$survey['srv_id']][$temp_date_timestamp]) ? $cookies_array[$survey['srv_id']][$temp_date_timestamp]['status'] : '';
$srv_user_id = isset($cookies_array[$survey['srv_id']][$temp_date_timestamp]) ? $cookies_array[$survey['srv_id']][$temp_date_timestamp]['srv_user_id'] : '';
/*$new_array = array('timestamp' => $temp_date_timestamp, 'datetime' => $temp_date->format('Y-m-d H:i:s'), 'srv_id' => $survey['srv_id'], 'naslov' => $survey['naslov'],
'srv_version' => $srv_version, 'link' => $link, 'status' => $user_status, 'mode' => 'repeater', 'srv_user_id'=>$srv_user_id);*/
//array_push($json_array, $new_array);
$unfinished = $user_status == 6 ? 0:1;
$survey_array = array('timestamp' => $temp_date_timestamp, 'datetime' => $temp_date->format('Y-m-d H:i:s'), 'link' => $link,
'srv_version' => $srv_version, 'status' => $user_status, 'mode' => 'repeater', 'srv_user_id'=>$srv_user_id);
if(isset($json_array[$survey['srv_id']]['surveys'])){
array_push($json_array[$survey['srv_id']]['surveys'], $survey_array);
$json_array[$survey['srv_id']]['unfinished_cnt']+=$unfinished;
}
else
$json_array[$survey['srv_id']] = array('srv_id' => $survey['srv_id'], 'naslov' => $survey['naslov'], 'unfinished_cnt' => $unfinished, 'surveys'=>array($survey_array));
if(isset($cookies_array[$survey['srv_id']][$temp_date_timestamp]))
unset($cookies_array[$survey['srv_id']][$temp_date_timestamp]);
}
}
//increase date by given number of days
$temp_date_by_day->modify('+'.$every_which_day.' day');
}
$result = array('surveys' => $json_array, 'cookies' => $cookies_array);
return $result;
}
//END MAZA
}
Reference in New Issue Copy Permalink