Code Coverage for /opt/homebrew/var/www/html/Linways/ams-professional-core/src/com/linways/core/ams/professional/service/AmsLogService.php

	Code Coverage
	Classes and Traits			Functions and Methods				Lines
Total	0.00% covered (danger)	0.00%	0 / 1	0.00% covered (danger)	0.00%	0 / 14	CRAP	0.00% covered (danger)	0.00%	0 / 384
AmsLogService	0.00% covered (danger)	0.00%	0 / 1	0.00% covered (danger)	0.00%	0 / 14	4032.00	0.00% covered (danger)	0.00%	0 / 384
__construct				0.00% covered (danger)	0.00%	0 / 1	2.00	0.00% covered (danger)	0.00%	0 / 3
__clone				0.00% covered (danger)	0.00%	0 / 1	2.00	0.00% covered (danger)	0.00%	0 / 2
getInstance				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 7
createAmsLog				0.00% covered (danger)	0.00%	0 / 1	72.00	0.00% covered (danger)	0.00%	0 / 19
getAmsLogDetails				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 23
getAmsLogById				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 27
getAmsLogByType				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 27
getAmsLogByName				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 27
getAmsLogByColumnName				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 26
getAmsLogByUserType				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 26
getAmsLogByUserID				0.00% covered (danger)	0.00%	0 / 1	6.00	0.00% covered (danger)	0.00%	0 / 26
updateAmsLog				0.00% covered (danger)	0.00%	0 / 1	506.00	0.00% covered (danger)	0.00%	0 / 77
updateAmsLogByCreatedAt				0.00% covered (danger)	0.00%	0 / 1	56.00	0.00% covered (danger)	0.00%	0 / 47
updateAmsLogById				0.00% covered (danger)	0.00%	0 / 1	72.00	0.00% covered (danger)	0.00%	0 / 47

1	<?php
2	namespace com\linways\core\ams\professional\service;
3
4	use com\linways\core\ams\professional\dto\AmsLog;
5	use com\linways\core\ams\professional\exception\ProfessionalException;
6	use com\linways\core\ams\professional\mapper\AmsLogServiceMapper;
7
8	use com\linways\core\ams\professional\util\UserUtil;
9	use Exception;
10
11	/**
12	*
13	* @Date 20/07/20
14	* @author Joel M John
15	*/
16	class AmsLogService extends BaseService
17	{
18	/**
19	* Presence of a static member variable
20	*
21	* @var null
22	*/
23	private static $_instance = null;
24
25	/**
26	* Mapper variable
27	* @var array
28	*/
29	private $mapper = [];
30
31	/**
32	* Initialise mapper, logger, hooks here
33	*
34	*
35	*/
36	private function __construct()
37	{
38	$this->mapper = AmsLogServiceMapper::getInstance()->getMapper();
39	}
40
41	/**
42	* Prevent any object or instance of that class to be cloned
43	*/
44	private function __clone()
45	{
46	}
47
48	/**
49	* Have a single globally accessible static method
50	*
51	* @return AmsLogService\|null
52	*/
53	public static function getInstance()
54	{
55	if (!is_object(self::$_instance))// or if( is_null(self::$_instance) ) or if( self::$_instance == null )
56	{
57	self::$_instance = new self();
58	}
59
60	return self::$_instance;
61	}
62
63
64	/**
65	* Creating AMS log
66	* @param Object $amsLog
67	* @return Boolean
68	* @throws ProfessionalException
69	*/
70	public function createAmsLog($amsLog)
71	{
72	list($userType,$userID) = UserUtil::getAdminUserTypeAndId();
73	try {
74	if ($amsLog->type == NULL \|\| $amsLog->name == NULL \|\|$amsLog->time == NULL \|\| $amsLog->entityID == NULL) {
75	throw new Exception("Fields cannot be NULL!");
76	}
77	$activities = array_filter((array) $amsLog, function($value) { //filter null objects
78	return !is_null($value) && $value !== '';
79	});
80	$activities = json_encode($activities);
81	$sql = "INSERT INTO ams_log(activities, user_id, user_type)
82	VALUES('$activities','$userID','$userType')";
83
84	if($this->executeQueryForObject($sql,true)) {
85	return true;
86	}
87	} catch (\Exception $e) {
88	throw new ProfessionalException($e->getCode(), $e->getMessage());
89	}
90	return false;
91	}
92
93
94	/**
95	* Select entire AMS log details
96	* @return result AmsLogDetails
97	* @throws ProfessionalException
98	*/
99	public function getAmsLogDetails()
100	{
101
102	try {
103	$sql = "SELECT id,
104	JSON_EXTRACT(activities, '$.type') AS type,
105	JSON_EXTRACT(activities, '$.name') AS name,
106	JSON_EXTRACT(activities, '$.columnName') AS columnName,
107	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
108	JSON_EXTRACT(activities, '$.toValue') AS toValue,
109	JSON_EXTRACT(activities, '$.entityName') AS entityName,
110	JSON_EXTRACT(activities, '$.entityID') AS entityID,
111	JSON_EXTRACT(activities, '$.message') AS message,
112	JSON_EXTRACT(activities, '$.time') AS time,
113	user_id,
114	user_type,
115	created_at
116	FROM
117	ams_log";
118
119
120	$result = $this->executeQueryForList($sql, $this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
121
122	} catch (\Exception $e) {
123	throw new ProfessionalException($e->getCode(), $e->getMessage());
124	}
125	return $result;
126	}
127
128
129
130	/**
131	* Select AMS log details by Id
132	* @param Int $id
133	* @return result AmsLogDetails
134	* @throws ProfessionalException
135	*/
136	public function getAmsLogById($id)
137	{
138	$amsLog = new AmsLog();
139	$amsLog->id = $id;
140	try {
141	$sql = "SELECT id,
142	JSON_EXTRACT(activities, '$.type') AS type,
143	JSON_EXTRACT(activities, '$.name') AS name,
144	JSON_EXTRACT(activities, '$.columnName') AS columnName,
145	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
146	JSON_EXTRACT(activities, '$.toValue') AS toValue,
147	JSON_EXTRACT(activities, '$.entityName') AS entityName,
148	JSON_EXTRACT(activities, '$.entityID') AS entityID,
149	JSON_EXTRACT(activities, '$.message') AS message,
150	JSON_EXTRACT(activities, '$.time') AS time,
151	user_id,
152	user_type,
153	created_at
154	FROM
155	ams_log
156	WHERE
157	id = '$amsLog->id'";
158
159	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
160
161	} catch (\Exception $e) {
162	throw new ProfessionalException($e->getCode(), $e->getMessage());
163	}
164	return $result;
165	}
166
167
168
169
170
171
172	/**
173	* Select AMS log details by Type
174	* @param Object $amsObj
175	* @return result AmsLogDetails
176	* @throws ProfessionalException
177	*/
178	public function getAmsLogByType($amsObj)
179	{
180
181	$amsLog = new AmsLog();
182	$amsLog->type = $amsObj->type;
183	try {
184	$sql = "SELECT id,
185	JSON_EXTRACT(activities, '$.type') AS type,
186	JSON_EXTRACT(activities, '$.name') AS name,
187	JSON_EXTRACT(activities, '$.columnName') AS columnName,
188	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
189	JSON_EXTRACT(activities, '$.toValue') AS toValue,
190	JSON_EXTRACT(activities, '$.entityName') AS entityName,
191	JSON_EXTRACT(activities, '$.entityID') AS entityID,
192	JSON_EXTRACT(activities, '$.message') AS message,
193	JSON_EXTRACT(activities, '$.time') AS time,
194	user_id,
195	user_type,
196	created_at
197	FROM
198	ams_log
199	WHERE
200	JSON_EXTRACT(activities, '$.type') = '$amsLog->type'";
201
202	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
203
204	} catch (\Exception $e) {
205	throw new ProfessionalException($e->getCode(), $e->getMessage());
206	}
207	return $result;
208	}
209
210
211	/**
212	* Select AMS log details by Name
213	* @param Object $amsObj
214	* @return result AmsLogDetails
215	* @throws ProfessionalException
216	*/
217	public function getAmsLogByName($amsObj)
218	{
219	$amsLog = new AmsLog();
220	$amsLog->name = $amsObj->name;
221	try {
222	$sql = "SELECT id,
223	JSON_EXTRACT(activities, '$.type') AS type,
224	JSON_EXTRACT(activities, '$.name') AS name,
225	JSON_EXTRACT(activities, '$.columnName') AS columnName,
226	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
227	JSON_EXTRACT(activities, '$.toValue') AS toValue,
228	JSON_EXTRACT(activities, '$.entityName') AS entityName,
229	JSON_EXTRACT(activities, '$.entityID') AS entityID,
230	JSON_EXTRACT(activities, '$.message') AS message,
231	JSON_EXTRACT(activities, '$.time') AS time,
232	user_id,
233	user_type,
234	created_at
235	FROM
236	ams_log
237	WHERE
238	JSON_EXTRACT(activities, '$.name') = '$amsLog->name'";
239
240	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
241
242	} catch (\Exception $e) {
243	throw new ProfessionalException($e->getCode(), $e->getMessage());
244	}
245	return $result;
246	}
247
248
249
250
251
252	/**
253	* Select AMS log details by ColumnName
254	* @param object $amsObj
255	* @return result AmsLogDetails
256	* @throws ProfessionalException
257	*/
258	public function getAmsLogByColumnName($amsObj)
259	{
260
261	$amsLog = new AmsLog();
262	$amsLog->columnName = $amsObj->columnName;
263	try {
264	$sql = "SELECT id,
265	JSON_EXTRACT(activities, '$.type') AS type,
266	JSON_EXTRACT(activities, '$.name') AS name,
267	JSON_EXTRACT(activities, '$.columnName') AS columnName,
268	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
269	JSON_EXTRACT(activities, '$.toValue') AS toValue,
270	JSON_EXTRACT(activities, '$.entityName') AS entityName,
271	JSON_EXTRACT(activities, '$.entityID') AS entityID,
272	JSON_EXTRACT(activities, '$.message') AS message,
273	JSON_EXTRACT(activities, '$.time') AS time,
274	user_id,
275	user_type,
276	created_at
277	FROM ams_log
278	WHERE
279	JSON_EXTRACT(activities, '$.columnName') = '$amsLog->columnName'";
280
281	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
282
283	} catch (\Exception $e) {
284	throw new ProfessionalException($e->getCode(), $e->getMessage());
285	}
286	return $result;
287	}
288
289
290
291	/**
292	* Select AMS log details by UserType
293	* @param object $amsObj
294	* @return result AmsLogDetails
295	* @throws ProfessionalException
296	*/
297	public function getAmsLogByUserType($amsObj)
298	{
299	$amsLog = new AmsLog();
300	$amsLog->user_type = $amsObj->user_type;
301	try {
302	$sql = "SELECT id,
303	JSON_EXTRACT(activities, '$.type') AS type,
304	JSON_EXTRACT(activities, '$.name') AS name,
305	JSON_EXTRACT(activities, '$.columnName') AS columnName,
306	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
307	JSON_EXTRACT(activities, '$.toValue') AS toValue,
308	JSON_EXTRACT(activities, '$.entityName') AS entityName,
309	JSON_EXTRACT(activities, '$.entityID') AS entityID,
310	JSON_EXTRACT(activities, '$.message') AS message,
311	JSON_EXTRACT(activities, '$.time') AS time,
312	user_id,
313	user_type,
314	created_at
315	FROM ams_log
316	WHERE
317	user_type = '$amsLog->user_type'";
318
319	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
320
321	} catch (\Exception $e) {
322	throw new ProfessionalException($e->getCode(), $e->getMessage());
323	}
324	return $result;
325	}
326
327
328
329	/**
330	* Select AMS log details by UserID
331	* @param Integer $id
332	* @return result AmsLogDetails
333	* @throws ProfessionalException
334	*/
335	public function getAmsLogByUserID($id)
336	{
337	//$id = SecurityUtils::getRandomString();
338	//list($userType,$userID) = UserUtil::getUserTypeAndId();
339	$amsLog = new AmsLog();
340	$amsLog->user_id = $id;
341	try {
342	$sql = "SELECT id,
343	JSON_EXTRACT(activities, '$.type') AS type,
344	JSON_EXTRACT(activities, '$.name') AS name,
345	JSON_EXTRACT(activities, '$.columnName') AS columnName,
346	JSON_EXTRACT(activities, '$.fromValue') AS fromValue,
347	JSON_EXTRACT(activities, '$.toValue') AS toValue,
348	JSON_EXTRACT(activities, '$.entityName') AS entityName,
349	JSON_EXTRACT(activities, '$.entityID') AS entityID,
350	JSON_EXTRACT(activities, '$.message') AS message,
351	JSON_EXTRACT(activities, '$.time') AS time,
352	user_id,
353	user_type,
354	created_at
355	FROM ams_log
356	WHERE
357	user_id = '$amsLog->user_id'";
358
359	$result = $this->executeQueryForList($sql,$this->mapper [AmsLogServiceMapper::SEARCH_AMS_LOG]);
360
361	} catch (\Exception $e) {
362	throw new ProfessionalException($e->getCode(), $e->getMessage());
363	}
364	return $result;
365	}
366
367
368
369
370	/**
371	* Update only selected Columns in AMS log details
372	* @param Object $amsObj
373	* @return Boolean
374	* @throws ProfessionalException
375	*/
376	public function updateAmsLog($amsObj)
377	{
378
379	$amsLog = new AmsLog();
380	$amsLog->id = $amsObj->id;
381	$amsLog->type = $amsObj->type;
382	$amsLog->name = $amsObj->name;
383	$amsLog->columnName = $amsObj->columnName;
384	$amsLog->fromValue = $amsObj->fromValue;
385	$amsLog->toValue = $amsObj->toValue;
386	$amsLog->message = $amsObj->message;
387	$amsLog->time = $amsObj->time;
388	$amsLog->user_id = $amsObj->user_id;
389	$amsLog->user_type = $amsObj->user_type;
390	try {
391	$sql = "UPDATE ams_log
392	SET
393	activities = JSON_SET(activities
394	";
395	$activityExist = 0; //flag
396	if($amsLog->type){
397	$sql .=", '$.type','$amsLog->type' ";
398	$activityExist = 1;
399	}
400	if($amsLog->name){
401	$sql .=", '$.name','$amsLog->name' ";
402	$activityExist = 1;
403	}
404	if($amsLog->columnName){
405	$sql .=", '$.columnName','$amsLog->columnName' ";
406	$activityExist = 1;
407	}
408	if($amsLog->fromValue){
409	$sql .=", '$.fromValue','$amsLog->fromValue' ";
410	$activityExist = 1;
411	}
412	if($amsLog->toValue){
413	$sql .=", '$.toValue','$amsLog->toValue' ";
414	$activityExist = 1;
415	}
416	if($amsLog->message){
417	$sql .=", '$.message','$amsLog->message' ";
418	$activityExist = 1;
419	}
420	if($amsLog->time){
421	$sql .=", '$.time','$amsLog->time' ";
422	$activityExist = 1;
423	}
424
425	if($activityExist == 1){
426	$sql .= " )";
427	}
428
429	if($activityExist == 0){
430	$sql = "UPDATE ams_log SET ";
431	}
432
433	$sqlConditionFlag = 0; //flag if more conditions exist for update
434	if($amsLog->user_id && $activityExist ==1){
435	$sql .=", user_id = '$amsLog->user_id' " ;
436	$sqlConditionFlag = 1;
437	}elseif($amsLog->user_id && $activityExist ==0){
438	$sql .=" user_id = '$amsLog->user_id' " ;
439	$sqlConditionFlag = 1;
440	}
441
442	if($amsLog->user_type && $sqlConditionFlag ==1){
443	$sql .= ", user_type = '$amsLog->user_type' ";
444	}elseif($amsLog->user_type && $activityExist == 1 && $sqlConditionFlag == 0 ){
445	$sql .= "AND user_type = '$amsLog->user_type' ";
446	}
447	elseif($amsLog->user_type){
448	$sql .= "user_type = '$amsLog->user_type' ";
449	}
450
451	$sql .= "WHERE id ='$amsLog->id' ";
452
453	if($this->executeQueryForObject($sql,true)){
454	return true;
455	}
456
457
458	} catch (\Exception $e) {
459	throw new ProfessionalException($e->getCode(), $e->getMessage());
460	}
461	return false;
462	}
463
464
465
466
467
468
469	/**
470	* Update AMS log details by CreatedAt
471	* @param Object $amsObj
472	* @return Boolean
473	* @throws ProfessionalException
474	*/
475	public function updateAmsLogByCreatedAt($amsObj)
476	{
477
478	$amsLog = new AmsLog();
479	$amsLog->id = $amsObj->id;
480	$amsLog->type = $amsObj->type;
481	$amsLog->name = $amsObj->name;
482	$amsLog->columnName = $amsObj->columnName;
483	$amsLog->fromValue = $amsObj->fromValue;
484	$amsLog->toValue = $amsObj->toValue;
485	$amsLog->message = $amsObj->message;
486	$amsLog->time = $amsObj->time;
487	$amsLog->user_id = $amsObj->user_id;
488	$amsLog->user_type = $amsObj->user_type;
489	$amsLog->created_at = $amsObj->created_at;
490	try {
491	if ($amsLog->type == NULL \|\| $amsLog->name == NULL\|\|$amsLog->columnName == NULL \|\|
492	$amsLog->time == NULL) {
493	throw new Exception("Fields cannot be NULL!");
494	}
495	$sql = "UPDATE ams_log
496	SET
497	activities = JSON_SET(activities,
498	'$.type',
499	'$amsLog->type',
500	'$.name',
501	'$amsLog->name',
502	'$.columnName',
503	'$amsLog->columnName',
504	'$.fromValue',
505	'$amsLog->fromValue',
506	'$.toValue',
507	'$amsLog->toValue',
508	'$.message',
509	'$amsLog->message',
510	'$.time',
511	'$amsLog->time'),
512	user_id = '$amsLog->user_id',
513	user_type = '$amsLog->user_type'
514	WHERE
515	created_at = '$amsLog->created_at' ";
516	if($this->executeQueryForObject($sql,true)){
517	return true;
518	}
519	} catch (\Exception $e) {
520	throw new ProfessionalException($e->getCode(), $e->getMessage());
521	}
522	return false;
523	}
524
525
526
527
528
529
530	/**
531	* Update AMS log details by Id
532	* @param Object $amsObj
533	* @return Boolean
534	* @throws ProfessionalException
535	*/
536	public function updateAmsLogById($amsObj)
537	{
538
539	$amsLog = new AmsLog();
540	$amsLog->id = $amsObj->id;
541	$amsLog->type = $amsObj->type;
542	$amsLog->name = $amsObj->name;
543	$amsLog->columnName = $amsObj->columnName;
544	$amsLog->fromValue = $amsObj->fromValue;
545	$amsLog->toValue = $amsObj->toValue;
546	$amsLog->message = $amsObj->message;
547	$amsLog->time = $amsObj->time;
548	$amsLog->user_id = $amsObj->user_id;
549	$amsLog->user_type = $amsObj->user_type;
550	$amsLog->created_at = $amsObj->created_at;
551	try {
552	if ($amsLog->id == NULL \|\| $amsLog->type == NULL \|\| $amsLog->name == NULL\|\|$amsLog->columnName == NULL \|\|
553	$amsLog->time == NULL) {
554	throw new Exception("Fields cannot be NULL!");
555	}
556	$sql = "UPDATE ams_log
557	SET
558	activities = JSON_SET(activities,
559	'$.type',
560	'$amsLog->type',
561	'$.name',
562	'$amsLog->name',
563	'$.columnName',
564	'$amsLog->columnName',
565	'$.fromValue',
566	'$amsLog->fromValue',
567	'$.toValue',
568	'$amsLog->toValue',
569	'$.message',
570	'$amsLog->message',
571	'$.time',
572	'$amsLog->time'),
573	user_id = '$amsLog->user_id',
574	user_type = '$amsLog->user_type'
575	WHERE
576	id = '$amsLog->id' ";
577	if($this->executeQueryForObject($sql,true)){
578	return true;
579	}
580	} catch (\Exception $e) {
581	throw new ProfessionalException($e->getCode(), $e->getMessage());
582	}
583	return false;
584	}
585
586
587	}