fluent-boards / app / Hooks / Handlers / TaskHandler.php

TaskHandler.php in FluentBoards – Project Management, Task Management, Goal Tracking, Kanban Board, and, Team Collaboration 1.95, at app/Hooks/Handlers/TaskHandler.php

230 lines 7.3 KB

Raw Download Zip

1	<?php
2
3	namespace FluentBoards\App\Hooks\Handlers;
4
5	use DateTimeImmutable;
6	use Exception;
7	use FluentBoards\App\Models\Activity;
8	use FluentBoards\App\Models\Meta;
9	use FluentBoards\App\Models\TaskMeta;
10	use FluentBoards\App\Models\Task;
11	use FluentBoards\App\Models\User;
12	use FluentBoards\App\Services\Constant;
13	use FluentBoards\App\Services\OptionService;
14	use FluentCrm\App\Models\Subscriber;
15	use FluentBoards\App\Models\Relation;
16	use FluentCrm\App\Services\ContactsQuery;
17	use FluentCrm\App\Services\PermissionManager as CRMPermissionManager;
18
19	class TaskHandler
20	{
21	private $fileHandler;
22
23	public function __construct(FileHandler $fileHandler)
24	{
25	$this->fileHandler = $fileHandler;
26	}
27	public function taskDeleted($task)
28	{
29	// Delete all activities and comments related to this task
30	Activity::where('object_id', $task->id)->where('object_type', Constant::ACTIVITY_TASK)->delete();
31	Meta::where('object_id', $task->id)->where('object_type', Constant::REPEAT_TASK_META)->delete();
32	}
33
34	public function searchAssignees($options, $search, $includedIds)
35	{
36	$users = get_users([
37	'number' => 20,
38	'search' => $search,
39	]);
40
41	$formattedUsers = [];
42
43	$pushedIds = [];
44
45	foreach ($users as $user) {
46	$pushedIds[] = $user->ID;
47
48	$formattedUsers[] = [
49	'id' => $user->ID,
50	'title' => $user->display_name . ' (' . $user->user_email . ')',
51	'photo' => get_avatar_url($user->user_email),
52	'left_side_value' => $user->display_name,
53	'right_side_value' => $user->user_email,
54	];
55	}
56
57	if (!$includedIds) {
58	return $formattedUsers;
59	}
60
61	if (!is_array($includedIds)) {
62	$includedIds = [$includedIds];
63	}
64
65	$includedIds = array_diff(array_map('intval', $includedIds), $pushedIds);
66
67	if ($includedIds) {
68	$users = get_users([
69	'include' => $includedIds,
70	]);
71
72	foreach ($users as $user) {
73	$formattedUsers[] = [
74	'id' => $user->ID,
75	'title' => $user->display_name . ' (' . $user->user_email . ')',
76	'photo' => get_avatar_url($user->user_email),
77	'left_side_value' => $user->display_name,
78	'right_side_value' => $user->user_email,
79	];
80	}
81	}
82
83	return $formattedUsers;
84	}
85
86	public function searchNonBoardWordpressUsers()
87	{
88	$superAdmin = Relation::select('user_id')->distinct()->pluck('user_id');
89	$users = User::whereDoesntHave('boards')->whereNotIn('ID', $superAdmin)->get();
90
91	$formattedUsers = [];
92
93	foreach ($users as $user) {
94	$formattedUsers[] = [
95	'id' => $user->ID,
96	'photo' => $user->photo,
97	'title' => $user->display_name . ' (' . $user->user_email . ')',
98	'left_side_value' => $user->display_name,
99	'right_side_value' => $user->user_email,
100	];
101	}
102
103	return $formattedUsers;
104	}
105
106	public function searchContact($options, $search, $includedIds)
107	{
108	if (!defined('FLUENTCRM')) {
109	return [];
110	}
111
112	// check if the use has permission to access contacts
113	$contactPermission = CRMPermissionManager::currentUserCan('fcrm_read_contacts');
114	if(!$contactPermission) {
115	return [];
116	}
117
118	$contactsQuery = new ContactsQuery([
119	'search' => $search,
120	'with' => [],
121	'limit' => 20,
122	'offset' => 0,
123	]);
124	$subscribers = $contactsQuery->get();
125
126	$formattedSubscribers = [];
127
128	$pushedIs = [];
129	foreach ($subscribers as $subscriber) {
130	$pushedIs[] = $subscriber->id;
131	$formattedSubscribers[] = [
132	'id' => $subscriber->id,
133	'title' => $subscriber->full_name . ' (' . $subscriber->email . ')',
134	'photo' => $subscriber->photo,
135	'name' => $subscriber->full_name,
136	'email' => $subscriber->email,
137	];
138	}
139
140	if (!is_array($includedIds)) {
141	$includedIds = [$includedIds];
142	}
143
144	if (!$includedIds) {
145	return $formattedSubscribers;
146	}
147
148	$remainingIds = array_diff($includedIds, $pushedIs);
149
150	if ($remainingIds) {
151	$remainingContacts = Subscriber::whereIn('id', $remainingIds)->get();
152	foreach ($remainingContacts as $subscriber) {
153	$formattedSubscribers[] = [
154	'id' => $subscriber->id,
155	'title' => $subscriber->full_name . ' (' . $subscriber->email . ')',
156	'photo' => $subscriber->photo,
157	'name' => $subscriber->full_name,
158	'email' => $subscriber->email,
159	];
160	}
161	}
162
163	return $formattedSubscribers;
164	}
165
166
167
168	/**
169	* Summary of taskAttachmentDeleted
170	* @param mixed $task
171	* @param mixed $deleteUrl
172	* @return void
173	*/
174	public function taskAttachmentDeleted($deletedAttachment)
175	{
176	try {
177	$deleteUrl = $deletedAttachment->full_url;
178	$this->fileHandler->deleteFileByUrl($deleteUrl);
179	} catch (Exception $e) {
180	wp_send_json_error($e->getMessage());
181	}
182	}
183
184	public function onTaskCreated($task)
185	{
186	$currentSettings = $this->getGlobalNotificationSettings();
187	$shouldWatch = isset($currentSettings['watch_on_creating_task']) && $currentSettings['watch_on_creating_task'];
188
189	if ($shouldWatch) {
190	$task->watchers()->syncWithoutDetaching([get_current_user_id() => ['object_type' => Constant::OBJECT_TYPE_USER_TASK_WATCH]]);
191	}
192	}
193
194	public function onCommentCreated($comment)
195	{
196	$task = $comment->task;
197	$currentSettings = $this->getGlobalNotificationSettings();
198	$shouldWatch = isset($currentSettings['watch_on_commenting']) && $currentSettings['watch_on_commenting'];
199
200	if ($shouldWatch) {
201	$task->watchers()->syncWithoutDetaching([get_current_user_id() => ['object_type' => Constant::OBJECT_TYPE_USER_TASK_WATCH]]);
202	}
203	}
204
205	public function onAssignAnotherUser($task, $assigneeId)
206	{
207	$currentSettings = $this->getGlobalNotificationSettings();
208	$shouldWatch = isset($currentSettings['watch_on_assigning']) && $currentSettings['watch_on_assigning'];
209
210	if ($shouldWatch) {
211	$task->watchers()->syncWithoutDetaching([$assigneeId => ['object_type' => Constant::OBJECT_TYPE_USER_TASK_WATCH]]);
212	}
213	}
214
215	private function getGlobalNotificationSettings()
216	{
217	$globalSettings = (new OptionService())->getGlobalNotificationSettings();
218
219	return maybe_unserialize($globalSettings->value);
220	}
221
222	public function taskCloned($originalTask, $clonedTask)
223	{
224	Activity::where('object_id', $clonedTask->id)
225	->where('object_type', Constant::ACTIVITY_TASK)
226	->delete();
227	do_action('fluent_boards/task_cloned_activity', $originalTask, $clonedTask);
228	}
229	}
230