Completed
Push — master ( 050fb9...428fac )
by Matias
16s queued 13s
created

ImageMapper::countUserProcessedImages()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 16
Code Lines 14

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 14
CRAP Score 1

Importance

Changes 0
Metric Value
cc 1
eloc 14
nc 1
nop 2
dl 0
loc 16
ccs 14
cts 14
cp 1
crap 1
rs 9.7998
c 0
b 0
f 0
1
<?php
2
/**
3
 * @copyright Copyright (c) 2017-2020, Matias De lellis <[email protected]>
4
 * @copyright Copyright (c) 2018-2019, Branko Kokanovic <[email protected]>
5
 *
6
 * @author Branko Kokanovic <[email protected]>
7
 *
8
 * @license GNU AGPL version 3 or any later version
9
 *
10
 * This program is free software: you can redistribute it and/or modify
11
 * it under the terms of the GNU Affero General Public License as
12
 * published by the Free Software Foundation, either version 3 of the
13
 * License, or (at your option) any later version.
14
 *
15
 * This program is distributed in the hope that it will be useful,
16
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18
 * GNU Affero General Public License for more details.
19
 *
20
 * You should have received a copy of the GNU Affero General Public License
21
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
22
 *
23
 */
24
namespace OCA\FaceRecognition\Db;
25
26
use OCP\IDBConnection;
27
use OCP\IUser;
28
29
use OCP\AppFramework\Db\QBMapper;
30
use OCP\AppFramework\Db\DoesNotExistException;
31
use OCP\DB\QueryBuilder\IQueryBuilder;
32
33
class ImageMapper extends QBMapper {
34
	/** @var FaceMapper Face mapper*/
35
	private $faceMapper;
36
37 1
	public function __construct(IDBConnection $db, FaceMapper $faceMapper) {
38 1
		parent::__construct($db, 'facerecog_images', '\OCA\FaceRecognition\Db\Image');
39 1
		$this->faceMapper = $faceMapper;
40 1
	}
41
42
	/**
43
	 * @param string $userId Id of user
44
	 * @param int $imageId Id of Image to get
45
	 */
46 4
	public function find(string $userId, int $imageId) {
47 4
		$qb = $this->db->getQueryBuilder();
48 4
		$qb->select('id', 'file', 'is_processed', 'error', 'last_processed_time', 'processing_duration')
49 4
			->from($this->getTableName(), 'i')
50 4
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
51 4
			->andWhere($qb->expr()->eq('id', $qb->createNamedParameter($imageId)));
52 4
		return $this->findEntity($qb);
53
	}
54
55
	/**
56
	 * @param string $userId Id of user
57
	 * @param int $modelId Id of model
58
	 * @param int $fileId Id of file to get Image
59
	 */
60
	public function findFromFile(string $userId, int $modelId, int $fileId) {
61
		$qb = $this->db->getQueryBuilder();
62
		$qb->select('id', 'is_processed', 'error')
63
			->from($this->getTableName(), 'i')
64
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
65
			->andwhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
66
			->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($fileId)));
67
68
		try {
69
			return $this->findEntity($qb);
70
		} catch (DoesNotExistException $e) {
71
			return null;
72
		}
73
	}
74
75 7
	public function imageExists(Image $image) {
76 7
		$qb = $this->db->getQueryBuilder();
77
		$query = $qb
78 7
			->select(['id'])
79 7
			->from($this->getTableName())
80 7
			->where($qb->expr()->eq('user', $qb->createParameter('user')))
81 7
			->andWhere($qb->expr()->eq('file', $qb->createParameter('file')))
82 7
			->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
83 7
			->setParameter('user', $image->getUser())
84 7
			->setParameter('file', $image->getFile())
85 7
			->setParameter('model', $image->getModel());
86 7
		$resultStatement = $query->execute();
87 7
		$row = $resultStatement->fetch();
88 7
		$resultStatement->closeCursor();
89 7
		return $row ? (int)$row['id'] : null;
90
	}
91
92
	public function countImages(int $model): int {
93
		$qb = $this->db->getQueryBuilder();
94
		$query = $qb
95
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
96
			->from($this->getTableName())
97
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
98
			->setParameter('model', $model);
99
		$resultStatement = $query->execute();
100
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
101
		$resultStatement->closeCursor();
102
103
		return (int)$data[0];
104
	}
105
106
	public function countProcessedImages(int $model): int {
107
		$qb = $this->db->getQueryBuilder();
108
		$query = $qb
109
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
110
			->from($this->getTableName())
111
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
112
			->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
113
			->setParameter('model', $model)
114
			->setParameter('is_processed', True);
115
		$resultStatement = $query->execute();
116
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
117
		$resultStatement->closeCursor();
118
119
		return (int)$data[0];
120
	}
121
122
	public function avgProcessingDuration(int $model): int {
123
		$qb = $this->db->getQueryBuilder();
124
		$query = $qb
125
			->select($qb->createFunction('AVG(' . $qb->getColumnName('processing_duration') . ')'))
126
			->from($this->getTableName())
127
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
128
			->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
129
			->setParameter('model', $model)
130
			->setParameter('is_processed', True);
131
		$resultStatement = $query->execute();
132
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
133
		$resultStatement->closeCursor();
134
135
		return (int)$data[0];
136
	}
137
138 3
	public function countUserImages(string $userId, int $model, $processed = false): int {
139 3
		$qb = $this->db->getQueryBuilder();
140
		$query = $qb
141 3
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
142 3
			->from($this->getTableName())
143 3
			->where($qb->expr()->eq('user', $qb->createParameter('user')))
144 3
			->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
145 3
			->setParameter('user', $userId)
146 3
			->setParameter('model', $model);
147
148 3
		if ($processed) {
149 1
			$query->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
150 1
			      ->setParameter('is_processed', true);
151
		}
152
153 3
		$resultStatement = $query->execute();
154 3
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
155 3
		$resultStatement->closeCursor();
156
157 3
		return (int)$data[0];
158
	}
159
160
	/**
161
	 * @param IUser|null $user User for which to get images for. If not given, all images from instance are returned.
162
	 * @param int $modelId Model Id to get images for.
163
	 */
164 9
	public function findImagesWithoutFaces(IUser $user = null, int $modelId): array {
165 9
		$qb = $this->db->getQueryBuilder();
166
		$qb
167 9
			->select(['id', 'user', 'file', 'model'])
168 9
			->from($this->getTableName())
169 9
			->where($qb->expr()->eq('is_processed',  $qb->createParameter('is_processed')))
170 9
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
171 9
			->setParameter('is_processed', false, IQueryBuilder::PARAM_BOOL);
172 9
		if (!is_null($user)) {
173 9
			$qb->andWhere($qb->expr()->eq('user', $qb->createNamedParameter($user->getUID())));
174
		}
175 9
		return $this->findEntities($qb);
176
	}
177
178 6
	public function findImages(string $userId, int $model): array {
179 6
		$qb = $this->db->getQueryBuilder();
180 6
		$qb->select('i.id', 'i.file')
181 6
			->from($this->getTableName(), 'i')
182 6
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
183 6
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)));
184
185 6
		$images = $this->findEntities($qb);
186 6
		return $images;
187
	}
188
189
	public function findFromPersonLike(string $userId, int $model, string $name, $offset = null, $limit = null): array {
190
		$qb = $this->db->getQueryBuilder();
191
		$qb->select('i.id', 'i.file')
192
			->from($this->getTableName(), 'i')
193
			->innerJoin('i', 'facerecog_faces', 'f', $qb->expr()->eq('f.image', 'i.id'))
194
			->innerJoin('i', 'facerecog_persons', 'p', $qb->expr()->eq('f.person', 'p.id'))
195
			->where($qb->expr()->eq('p.user', $qb->createNamedParameter($userId)))
196
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)))
197
			->andWhere($qb->expr()->eq('is_processed', $qb->createNamedParameter(True)))
198
			->andWhere($qb->expr()->like($qb->func()->lower('p.name'), $qb->createParameter('query')));
199
200
		$query = '%' . $this->db->escapeLikeParameter(strtolower($name)) . '%';
201
		$qb->setParameter('query', $query);
202
203
		$qb->setFirstResult($offset);
204
		$qb->setMaxResults($limit);
205
206
		return $this->findEntities($qb);
207
	}
208
209
	/**
210
	 * Writes to DB that image has been processed. Previously found faces are deleted and new ones are inserted.
211
	 * If there is exception, its stack trace is also updated.
212
	 *
213
	 * @param Image $image Image to be updated
214
	 * @param Face[] $faces Faces to insert
215
	 * @param int $duration Processing time, in milliseconds
216
	 * @param \Exception|null $e Any exception that happened during image processing
217
	 */
218 4
	public function imageProcessed(Image $image, array $faces, int $duration, \Exception $e = null) {
219 4
		$this->db->beginTransaction();
220
		try {
221
			// Update image itself
222
			//
223 4
			$error = null;
224 4
			if ($e !== null) {
225 1
				$error = substr($e->getMessage(), 0, 1024);
226
			}
227
228 4
			$qb = $this->db->getQueryBuilder();
229 4
			$qb->update($this->getTableName())
230 4
				->set("is_processed", $qb->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
231 4
				->set("error", $qb->createNamedParameter($error))
232 4
				->set("last_processed_time", $qb->createNamedParameter(new \DateTime(), IQueryBuilder::PARAM_DATE))
233 4
				->set("processing_duration", $qb->createNamedParameter($duration))
234 4
				->where($qb->expr()->eq('id', $qb->createNamedParameter($image->id)))
235 4
				->execute();
236
237
			// Delete all previous faces
238
			//
239 4
			$qb = $this->db->getQueryBuilder();
240 4
			$qb->delete('facerecog_faces')
241 4
				->where($qb->expr()->eq('image', $qb->createNamedParameter($image->id)))
242 4
				->execute();
243
244
			// Insert all faces
245
			//
246 4
			foreach ($faces as $face) {
247 1
				$this->faceMapper->insertFace($face, $this->db);
248
			}
249
250 4
			$this->db->commit();
251
		} catch (\Exception $e) {
252
			$this->db->rollBack();
253
			throw $e;
254
		}
255 4
	}
256
257
	/**
258
	 * Resets image by deleting all associated faces and prepares it to be processed again
259
	 *
260
	 * @param Image $image Image to reset
261
	 */
262
	public function resetImage(Image $image) {
263
		$qb = $this->db->getQueryBuilder();
264
		$qb->update($this->getTableName())
265
			->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
266
			->set("error", $qb->createNamedParameter(null))
267
			->set("last_processed_time", $qb->createNamedParameter(null))
268
			->where($qb->expr()->eq('user', $qb->createNamedParameter($image->getUser())))
269
			->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($image->getFile())))
270
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($image->getModel())))
271
			->execute();
272
	}
273
274
	/**
275
	 * Resets all image with error from that user and prepares it to be processed again
276
	 *
277
	 * @param string $userId User to reset errors
278
	 */
279
	public function resetErrors(string $userId) {
280
		$qb = $this->db->getQueryBuilder();
281
		$qb->update($this->getTableName())
282
			->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
283
			->set("error", $qb->createNamedParameter(null))
284
			->set("last_processed_time", $qb->createNamedParameter(null))
285
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
286
			->andWhere($qb->expr()->isNotNull('error'))
287
			->execute();
288
	}
289
290
	/**
291
	 * Deletes all images from that user.
292
	 *
293
	 * @param string $userId User to drop images from table.
294
	 */
295 28
	public function deleteUserImages(string $userId) {
296 28
		$qb = $this->db->getQueryBuilder();
297 28
		$qb->delete($this->getTableName())
298 28
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
299 28
			->execute();
300 28
	}
301
}
302