299 lines
12 KiB
PHP
299 lines
12 KiB
PHP
<?php
|
|
|
|
class CalendarApicontroller extends mfBaseApicontroller
|
|
{
|
|
protected function init()
|
|
{
|
|
|
|
$this->addRoute("/calendar/calendarStream", "calendarStream", "GET");
|
|
$this->addRoute("/calendar/calendarNotify", "calendarNotify", "POST");
|
|
$this->addRoute("/calendar/calendarUserSubscriptions", "getcalendarUserSubscriptions", "GET");
|
|
$this->addRoute("/calendar/calendarUserSubscriptions", "updatecalendarUserSubscriptions", "POST");
|
|
$this->addRoute("/calendar/calendarUsers", "getcalendarUsers", "GET");
|
|
$this->addRoute("/calendar/calendarAbsence", "getCalendarAbsence", "GET");
|
|
$this->addRoute("/calendar/calendarAbsence", "updateCalendarAbsence", "POST");
|
|
}
|
|
|
|
|
|
protected function calendarNotify()
|
|
{
|
|
|
|
$myfile = fopen(__DIR__ . "/../../../var/log/microsoft_notify_log.txt", "a") or die("Unable to open file!");
|
|
$get = json_encode($_GET);
|
|
fwrite($myfile, "\nGET: " . $get);
|
|
$post = serialize($_POST);
|
|
fwrite($myfile, "\nPOST: " . $post);
|
|
if ($_GET['validationToken']) {
|
|
echo $_GET['validationToken'];
|
|
die();
|
|
}
|
|
$input = file_get_contents('php://input');
|
|
|
|
fwrite($myfile, "\nINPUT: " . $input);
|
|
$result = 'ok';
|
|
CalendarModel::insertMicrosoftCalendarEvent($input);
|
|
die();
|
|
}
|
|
|
|
protected function getcalendarUsers()
|
|
{
|
|
$users = UserModel::search(['employee' => 'true']);
|
|
$json['data'] = $users;
|
|
$json['status'] = "success";
|
|
$result = json_encode($json);
|
|
echo $result;
|
|
die();
|
|
}
|
|
|
|
protected function getCalendarAbsence()
|
|
{
|
|
$starttime = time() - 86400 * 30;
|
|
$db = FronkDB::singleton();
|
|
$sql = "SELECT `Timerecording`.`id`, `Timerecording`.`start` start_time, `Timerecording`.`end` end_time,`Calendar`.`microsoft_id`,`Timerecording`.`microsoft_event_id`,`Calendar`.`go_calendar_id` calendar_id,`TimerecordingCategory`.`name`,`TimerecordingCategory`.`id` CategoryId,`Timerecording`.`create` ctime,`Timerecording`.`edit` mtime FROM `Timerecording`
|
|
INNER JOIN `TimerecordingCategory` ON `TimerecordingCategory`.`id`=`Timerecording`.`timerecordingCategory_id`
|
|
INNER JOIN `Calendar` ON `Calendar`.`user_id`=`Timerecording`.`user_id`
|
|
WHERE `TimerecordingCategory`.`hourday`!='1' AND `TimerecordingCategory`.`hourday`!='7' AND `TimerecordingCategory`.`hourday`!='5' AND `Timerecording`.start >= $starttime
|
|
";
|
|
//AND `Timerecording`.`user_id` = '173'
|
|
$res = $db->query($sql);
|
|
if ($db->num_rows($res)) {
|
|
|
|
while ($data = $db->fetch_array($res)) {
|
|
if (!$data['end_time']) {
|
|
continue;
|
|
}
|
|
if ($data['CategoryId'] != 11) {
|
|
$data['start_time'] = $data['start_time'];
|
|
$all_day_event = 1;
|
|
|
|
} else {
|
|
$starttime = date("Y-m-d H:i", $data['start_time']);
|
|
$endtime = date("Y-m-d H:i", $data['end_time']);
|
|
$all_day_event = 0;
|
|
}
|
|
$rows[] = array(
|
|
'id' => $data['id'],
|
|
'name' => $data['name'],
|
|
'start_time' => $data['start_time'],
|
|
'end_time' => $data['end_time'],
|
|
'all_day_event' => $all_day_event,
|
|
'calendar_id' => $data['calendar_id'],
|
|
'microsoft_id' => $data['microsoft_id'],
|
|
'microsoft_event_id' => $data['microsoft_event_id'],
|
|
);
|
|
}
|
|
|
|
}
|
|
$json['success'] = true;
|
|
$json['data'] = $rows;
|
|
$json['status'] = "success";
|
|
$result = json_encode($json, JSON_UNESCAPED_UNICODE);
|
|
echo $result;
|
|
die();
|
|
}
|
|
|
|
protected function updateCalendarAbsence()
|
|
{
|
|
$id = $this->post['id'];
|
|
|
|
$microsoft_event_id = $this->post['microsoft_event_id'];
|
|
|
|
$timercording = new Timerecording($id);
|
|
|
|
if (!($timercording->id) || $timercording->id != $id) {
|
|
die();
|
|
}
|
|
$data = [];
|
|
if ($microsoft_event_id) {
|
|
$data['microsoft_event_id'] = $microsoft_event_id;
|
|
} else {
|
|
$data['microsoft_event_id'] = null;
|
|
}
|
|
|
|
$timercording->update($data);
|
|
$timercording->save();
|
|
$json['status'] = "success";
|
|
$result = json_encode($json);
|
|
echo $result;
|
|
die();
|
|
}
|
|
|
|
protected function getcalendarUserSubscriptions()
|
|
{
|
|
if ($_GET['onlymsuser']) {
|
|
$userSubscriptions = CalendarModel::search(array("checkSubscriptions" => 1));
|
|
} else {
|
|
$userSubscriptions = CalendarModel::getAll();
|
|
}
|
|
$json['data'] = $userSubscriptions;
|
|
$json['status'] = "success";
|
|
$result = json_encode($json);
|
|
echo $result;
|
|
die();
|
|
}
|
|
|
|
protected function updatecalendarUserSubscriptions()
|
|
{
|
|
$id = $this->post['id'];
|
|
$user_id = $this->post['user_id'];
|
|
$go_calendar_id = $this->post['go_calendar_id'];
|
|
$microsoft_id = $this->post['microsoft_id'];
|
|
$subscription_id = $this->post['subscription_id'];
|
|
$expirationDateTime = $this->post['expirationDateTime'];
|
|
$Calendar = new Calendar($id);
|
|
|
|
if (!($Calendar->id) || $Calendar->id != $id) {
|
|
$mode = "add";
|
|
} else {
|
|
$mode = "update";
|
|
}
|
|
$data = [];
|
|
if ($user_id) {
|
|
$data['user_id'] = $user_id;
|
|
}
|
|
if ($go_calendar_id) {
|
|
$data['go_calendar_id'] = $go_calendar_id;
|
|
}
|
|
if ($microsoft_id) {
|
|
$data['microsoft_id'] = $microsoft_id;
|
|
}
|
|
if ($subscription_id) {
|
|
$data['subscription_id'] = $subscription_id;
|
|
}
|
|
if ($expirationDateTime) {
|
|
$data['expirationDateTime'] = $expirationDateTime;
|
|
}
|
|
if ($mode == "add") {
|
|
$data['create_by'] = '154';
|
|
}
|
|
$data['edit_by'] = '154';
|
|
$Calendar->update($data);
|
|
$Calendar->save();
|
|
$json['status'] = "success";
|
|
$result = json_encode($json);
|
|
echo $result;
|
|
die();
|
|
}
|
|
|
|
protected function decryptString($cipherText, $password, $salt)
|
|
{
|
|
// Definiere den Algorithmus und die Länge des Initialisierungsvektors
|
|
$cipher = "aes-256-cbc";
|
|
$ivlen = openssl_cipher_iv_length($cipher);
|
|
|
|
// Dekodiere den verschlüsselten Text von base64
|
|
$cipherText = base64_decode($cipherText);
|
|
|
|
// Extrahiere den Initialisierungsvektor und den verschlüsselten Text
|
|
$iv = substr($cipherText, 0, $ivlen);
|
|
$cipherText = substr($cipherText, $ivlen);
|
|
|
|
// Erzeuge einen Schlüssel aus dem Passwort und dem Salt
|
|
$key = hash_pbkdf2("sha256", $password, $salt, 1000, 32, true);
|
|
|
|
// Entschlüssele den Text
|
|
$plainText = openssl_decrypt($cipherText, $cipher, $key, 0, $iv);
|
|
|
|
return $plainText;
|
|
}
|
|
|
|
protected function calendarStream()
|
|
{
|
|
$decstring = $this->decryptString($_GET['user'], "testpw", "testsalt");
|
|
date_default_timezone_set('Europe/Berlin');
|
|
header('Content-Type: text/event-stream');
|
|
header('Cache-Control: no-cache');
|
|
header('Connection: keep-alive');
|
|
$timestamp = time();
|
|
|
|
$Calendar = CalendarModel::search(array("user_id" => $decstring));
|
|
$rights = json_decode($Calendar[0]->rights, true);
|
|
if (!$Calendar[0]->rights) {
|
|
$allowedCalendar[] = $Calendar[0]->calendar_id;
|
|
} else {
|
|
foreach (json_decode($Calendar[0]->rights, true) as $key => $value) {
|
|
$allowedCalendar[] = $key;
|
|
}
|
|
}
|
|
if ($Calendar[0]->colors) {
|
|
$calendarColors = json_decode($Calendar[0]->colors, true);
|
|
}
|
|
$redis = new Redis();
|
|
//Connecting to Redis
|
|
$redis->connect('172.16.5.5', '6379');
|
|
//$redis->auth('password');
|
|
|
|
$oldoutput = "";
|
|
$now = floor(microtime(true) * 1000);
|
|
$timenow = time();
|
|
while (true) {
|
|
|
|
$colors = $redis->get('thetool_calendar_usercolors_' . $decstring);
|
|
if ($colors) {
|
|
$calendarColors = json_decode($colors, true);
|
|
}
|
|
$output = $redis->get('thetool_calendar_event_tigger');
|
|
$json = json_decode($output, true);
|
|
$message[0] = $json;
|
|
|
|
|
|
if ($json['time'] > $now && $output !== $oldoutput) {
|
|
$timenow = time();
|
|
// $Calendar=CalendarModel::getCalendarEvents($decstring, $json['cal_events_id']);
|
|
$Calendarevent = json_decode(CalendarModel::getCalendarEvents($decstring, $json['cal_events_id']), true);
|
|
if ($json['all_day_event'] == 1) {
|
|
$message[0]['start_time'] = date('Y-m-d', $json['start_time']);
|
|
$message[0]['end_time'] = date('Y-m-d', $json['end_time']);
|
|
} else {
|
|
$message[0]['start_time'] = date('Y-m-d H:i', $json['start_time']);
|
|
$message[0]['end_time'] = date('Y-m-d H:i', $json['end_time']);
|
|
}
|
|
$message[0]['name'] = $Calendarevent['data'][0]['category']['category'];
|
|
$message[0]['description'] = $Calendarevent['data'][0]['description']['description'];
|
|
$message[0]['location'] = $Calendarevent['data'][0]['location']['location'];
|
|
$message[0]['event_type'] = $Calendarevent['data'][0]['event_type']['event_type'];
|
|
$message[0]['attachment'] = $Calendarevent['data'][0]['attachment']['attachment'];
|
|
$message[0]['attachments'] = $Calendarevent['data'][0]['attachments']['attachments'];
|
|
$message[0]['calendar_name'] = $Calendarevent['data'][0]['calendar_name']['calendar_name'];
|
|
$message[0]['isorganizer'] = $Calendarevent['data'][0]['isorganizer']['isorganizer'];
|
|
$message[0]['privateflag'] = $Calendarevent['data'][0]['privateflag']['privateflag'];
|
|
$message[0]['rrule'] = $Calendarevent['data'][0]['rrule']['rrule'];
|
|
$message[0]['duration'] = $Calendarevent['data'][0]['duration']['duration'];
|
|
$message[0]['mtime'] = $Calendarevent['data'][0]['mtime']['mtime'];
|
|
$message[0]['mname'] = $Calendarevent['data'][0]['mname']['mname'];
|
|
$message[0]['ctime'] = $Calendarevent['data'][0]['ctime']['ctime'];
|
|
$message[0]['cname'] = $Calendarevent['data'][0]['cname']['cname'];
|
|
$message[0]['busy'] = $Calendarevent['data'][0]['busy']['busy'];
|
|
$message[0]['canceld'] = $Calendarevent['data'][0]['canceld']['canceld'];
|
|
$message[0]['calendar_id_check'] = array('calendar_id' => $json['calendar_id'], 'order' => $json['calendar_id']);;
|
|
$message[0]['userr'] = $Calendar[0]->calendar_id;
|
|
$message[0]['bgColor'] = $calendarColors[$json['calendar_id']]['bgcolor'];
|
|
$message[0]['txtColor'] = $calendarColors[$json['calendar_id']]['txtcolor'];
|
|
$message[0]['rights'] = $rights[$json['calendar_id']];
|
|
$message[0]['me'] = $decstring;
|
|
|
|
|
|
$result = json_encode($message);
|
|
if (in_array($message[0]['calendar_id'], $allowedCalendar)) {
|
|
echo "data: " . ($result) . "\n\n";
|
|
}
|
|
unset($Array);
|
|
$now = floor(microtime(true) * 1000);;
|
|
}
|
|
if (ob_get_level() > 0) {
|
|
ob_flush();
|
|
}
|
|
if ($timenow + 300 < time()) {
|
|
die();
|
|
}
|
|
|
|
flush();
|
|
if (connection_aborted()) die();
|
|
usleep(100000);
|
|
$oldoutput = $output;;
|
|
}
|
|
die();
|
|
}
|
|
|
|
|
|
} |