forked from mikhainin/flyspray
-
Notifications
You must be signed in to change notification settings - Fork 0
/
schedule.php
150 lines (125 loc) · 6.92 KB
/
schedule.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
<?php
/********************************************************\
| Scheduled Jobs (poor man's cron) |
| ~~~~~~~~~~~~~~ |
| This script checks for pending scheduled notifications |
| and sends them at the right time. |
\********************************************************/
define('IN_FS', true);
/**
* Developers warning :
* Be aware while debugging this, it actually daemonize ¡¡
* it runs **forever** in the background every ten minutes
* to simulate a real cron task, it WONT STOP if you click
* stop in your browser, it will only stop if you restart
* your webserver.
*/
require_once 'header.php';
if ($conf['general']['reminder_daemon'] && (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] === '127.0.0.1' || php_sapi_name() === 'cli')) {
//keep going, execute the script in the background
ignore_user_abort(true);
set_time_limit(0);
include_once BASEDIR . '/includes/class.notify.php';
do {
//we touch the file on every single iteration to avoid
//the possible restart done by Startremiderdaemon method
//in class.flyspray.conf
touch(Flyspray::get_tmp_dir() . '/flysprayreminders.run');
$user = new User(0);
$now = time();
############ Task one: Send reminders ############
$reminders = $db->x->getAll("SELECT r.reminder_message AS message, r.*
FROM {reminders} r
INNER JOIN {users} u ON u.user_id = r.to_user_id
INNER JOIN {tasks} t ON r.task_id = t.task_id
INNER JOIN {projects} p ON t.project_id = p.project_id
WHERE t.is_closed = '0' AND r.start_time < ?
AND r.last_sent + r.how_often < ?
ORDER BY r.reminder_id", null, array(time(), time()));
foreach ($reminders as $row) {
if (Notifications::send_now($row['to_user_id'], ADDRESS_USER, NOTIFY_REMINDER, $row)) {
// Update the database with the time sent
$db->x->execParam('UPDATE {reminders}
SET last_sent = ?
WHERE reminder_id = ?', null,
array(time(), $row['reminder_id']));
}
}
############ Task two: send stored notifications ############
Notifications::send_stored();
############ Task three: send project manager digests ############
$sql = $db->x->getAll('SELECT project_id, project_title, last_digest, project_prefix
FROM {projects}
WHERE send_digest = 1 AND last_digest < ?',
null, time() - 60*60*24*7);
foreach ($sql as $project) {
// find out all project managers
$pms = $db->x->GetCol('SELECT uig.user_id
FROM {users_in_groups} uig
LEFT JOIN {groups} g ON uig.group_id = g.group_id
WHERE g.project_id = ? AND g.manage_project = 1',
null, $project['project_id']);
// Now generate the message, we are interested in opened/reopened, closed and assigned tasks
$opened = $reopened = $closed = $assigned = array();
$message = L('digestfor') . ' ' . $project['project_title'] . ":\n\n";
$evt = $db->x->getAll('SELECT h.event_type, lr.item_name AS resolution_name, t.task_id,
t.item_summary, u.user_name, u.real_name, t.prefix_id
FROM {history} h
LEFT JOIN {tasks} t ON h.task_id = t.task_id
LEFT JOIN {users} u ON h.user_id = u.user_id
LEFT JOIN {list_items} lr ON h.new_value = lr.list_item_id AND event_type = 2
WHERE t.project_id = ? AND event_type IN (1,2,13,19)
AND event_date > ?', null,
array($project['project_id'], max($project['last_digest'], time() - 60*60*24*7)));
foreach ($evt as $row) {
switch ($row['event_type'])
{
case '1':
$opened[] = sprintf("%s#%d: %s\n-> %s %s (%s)",
$project['project_prefix'], $row['prefix_id'], $row['item_summary'], L('openedby'), $row['real_name'], $row['user_name']);
break;
case '2':
$closed[] = sprintf("%s#%d: %s (%s)\n-> %s %s (%s)",
$project['project_prefix'], $row['prefix_id'], $row['item_summary'], $row['resolution_name'], L('openedby'), $row['real_name'], $row['user_name']);
break;
case '13':
$reopened[] = sprintf("%s#%d: %s\n-> %s %s (%s)",
$project['project_prefix'], $row['prefix_id'], $row['item_summary'], L('reopenedby'), $row['real_name'], $row['user_name']);
break;
case '19':
$assigned[] = sprintf("%s#%d: %s\n-> %s %s (%s)",
$project['project_prefix'], $row['prefix_id'], $row['item_summary'], L('assignedto'), $row['real_name'], $row['user_name']);
break;
}
}
foreach (array('opened', 'closed', 'reopened', 'assigned') as $type) {
if (count($$type)) {
$message .= L($type . 'tasks') . ':' . "\n" . implode("\n", $$type) . "\n\n";
}
}
if (Notifications::send_now($pms, ADDRESS_USER, NOTIFY_DIGEST, array('message' => $message))) {
$db->x->execParam('UPDATE {projects} SET last_digest = ? WHERE project_id = ?',
array(time(), $project['project_id']));
}
}
############ Task four: Close tasks ############
$tasks = $db->query('SELECT t.*, c.date_added, max(c.date_added) FROM {tasks} t
LEFT JOIN {comments} c ON t.task_id = c.task_id
WHERE is_closed = 0 AND close_after > 0
GROUP BY t.task_id');
while ($row = $tasks->FetchRow()) {
if (max($row['date_added'], $row['last_edited_time']) + $row['close_after'] < time()) {
Backend::close_task($row['task_id'], $row['resolution_reason'], $row['closure_comment'], false);
$db->x->execParam('UPDATE {tasks} SET close_after = 0 WHERE task_id = ?', $row['task_id']);
}
}
//wait 10 minutes for the next loop.
if (php_sapi_name() !== 'cli') {
sleep(600);
}
} while(php_sapi_name() !== 'cli'); //forever ¡¡¡ ( oh well. a least will not stop unless killed or the server restarted)
@register_shutdown_function('unlink', Flyspray::get_tmp_dir() . '/flysprayreminders.run');
} else {
die('You are not authorized to start the remider daemon.');
}
?>