OCA\Analytics\Service\StorageService

Complexity

Total Complexity

27

Size/Duplication

Total Lines	230
Duplicated Lines	0 %

Importance

Changes	4
Bugs	1	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
B	read()	0	39	7
A	convertGermanDateFormat()	0	12	4
A	deleteSimulate()	0	3	1
A	deleteWithFilterSimulate()	0	3	1
B	update()	0	40	8
A	deleteWithFilter()	0	3	1
A	floatvalue()	0	13	2
A	delete()	0	3	1
A	getRecordCount()	0	3	1

<?php
/**
 * Analytics
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the LICENSE.md file.
 *
 * @author Marcel Scherello <analytics@scherello.de>
 * @copyright 2019-2022 Marcel Scherello
 */

namespace OCA\Analytics\Service;

use OCA\Analytics\Db\StorageMapper;
use OCP\DB\Exception;
use OCP\IRequest;
use Psr\Log\LoggerInterface;

class StorageService
{
    private $logger;
    private $StorageMapper;
    private $ThresholdService;
    private $DatasetService;
    private $ReportService;
    private $VariableService;

    public function __construct(
        LoggerInterface $logger,
        StorageMapper $StorageMapper,
        DatasetService $DatasetService,
        ThresholdService $ThresholdService,
        VariableService $VariableService,
        ReportService $ReportService
    )
    {
        $this->logger = $logger;
        $this->StorageMapper = $StorageMapper;
        $this->DatasetService = $DatasetService;
        $this->ThresholdService = $ThresholdService;
        $this->VariableService = $VariableService;
        $this->ReportService = $ReportService;
    }

    /**
     * Get the items for the selected category
     *
     * @NoAdminRequired
     * @param $datasetId
     * @param $options
     * @return array
     * @throws \OCP\DB\Exception
     */
    public function read($datasetId, $reportMetadata)
    {
        $availableDimensions = array();
        $header = array();
        $datasetMetadata = $this->DatasetService->read($datasetId);
        if ($reportMetadata['filteroptions'] !== null) {
            $options = json_decode($reportMetadata['filteroptions'], true);
        } else {
            $options = null;
        }

        if (!empty($datasetMetadata)) {
            // output the dimensions available for filtering of this dataset
            // this needs to map the technical name to its display name in the report
            $availableDimensions['dimension1'] = $datasetMetadata['dimension1'];
            $availableDimensions['dimension2'] = $datasetMetadata['dimension2'];

            // return the header texts of the data being transferred according to the current drilldown state selected by user
            if (!isset($options['drilldown']['dimension1'])) $header[0] = $datasetMetadata['dimension1'];
            if (!isset($options['drilldown']['dimension2'])) $header[1] = $datasetMetadata['dimension2'];
            $header[6] = $datasetMetadata['value'];
            $header = array_values($header);

            $data = $this->StorageMapper->read($datasetMetadata['id'], $options);
            $data = array_values($data);
            foreach ($data as $key => $value) {
                $data[$key] = array_values($value);
            }
        }

        return empty($data) ? [
            'dimensions' => $availableDimensions,
            'status' => 'nodata',
            'error' => 0
        ] : [
            'header' => $header,
            'dimensions' => $availableDimensions,
            'data' => $data,
            'error' => 0
        ];
    }

    /**
     * Get the items for the selected category
     *
     * @NoAdminRequired
     * @param int $datasetId
     * @param $dimension1
     * @param $dimension2
     * @param $value
     * @param string|null $user_id
     * @param $bulkInsert
     * @param $aggregation
     * @return array
     * @throws Exception
     */
    public function update(int $datasetId, $dimension1, $dimension2, $value, string $user_id = null, $bulkInsert = null, $aggregation = null)
    {
        TODO:
        //dates in both columns
        $dimension2 = $this->convertGermanDateFormat($dimension2);
        //convert date into timestamp
        //$timestamp = $this->convertGermanDateFormat($timestamp);
        $value = $this->floatvalue($value);
        $validate = '';
        $insert = $update = $error = $action = 0;

The assignment to $action is dead and can be removed.

        // replace text variables like %now%
        $dimension1 = $this->VariableService->replaceTextVariablesSingle($dimension1);
        $dimension2 = $this->VariableService->replaceTextVariablesSingle($dimension2);

        if ($value !== false) {
            try {
                $action = $this->StorageMapper->create($datasetId, $dimension1, $dimension2, $value, $user_id, null, $bulkInsert, $aggregation);
            } catch (\Exception $e) {
                $error = 1;
            }
            if ($action === 'insert') $insert = 1;
            elseif ($action === 'update') $update = 1;
        } else {
            $error = 1;
        }

        // get all reports for the dataset and evaluate their thresholds for push notifications
        if ($error === 0) {
            foreach ($this->ReportService->reportsForDataset($datasetId) as $report) {
                $validateResult = $this->ThresholdService->validate($report['id'], $dimension1, $dimension2, $value, $insert);
                if ($validateResult !== '') $validate = $validateResult;
            }
        }

        return [
            'insert' => $insert,
            'update' => $update,
            'error' => $error,
            'validate' => $validate
        ];
    }

    /**
     * delete data
     *
     * @NoAdminRequired
     * @param int $datasetId
     * @param $dimension1
     * @param $dimension2
     * @param string|null $user_id
     * @return bool
     */
    public function delete(int $datasetId, $dimension1, $dimension2, string $user_id = null)
    {
        return $this->StorageMapper->delete($datasetId, $dimension1, $dimension2, $user_id);
    }

    /**
     * Simulate delete data
     *
     * @NoAdminRequired
     * @param int $datasetId
     * @param $dimension1
     * @param $dimension2
     * @return array
     * @throws Exception
     */
    public function deleteSimulate(int $datasetId, $dimension1, $dimension2)
    {
        return $this->StorageMapper->deleteSimulate($datasetId, $dimension1, $dimension2);
    }

    /**
     * Delete data with variables; used for data deletion jobs
     *
     * @NoAdminRequired
     * @param int $datasetId
     * @param $filter
     * @return bool
     * @throws Exception
     */
    public function deleteWithFilter(int $datasetId, $filter)
    {
        return $this->StorageMapper->deleteWithFilter($datasetId, $filter);
    }

    /**
     * Simulate delete data with variables; used for data deletion jobs
     *
     * @NoAdminRequired
     * @param int $datasetId
     * @param $filter
     * @return bool
     * @throws Exception
     */
    public function deleteWithFilterSimulate(int $datasetId, $filter)
    {
        return $this->StorageMapper->deleteWithFilterSimulate($datasetId, $filter);
    }

    /**
     * Get the number of records for a dataset
     * @param int $datasetId
     * @return array
     */
    public function getRecordCount(int $datasetId)
    {
        return $this->StorageMapper->getRecordCount($datasetId);
    }

    private function floatvalue($val)
    {
        // remove thousand separators
        $val = preg_replace('/(?<=\d)\,(?=\d{3}\b)/', '', $val);
        $val = preg_replace('/(?<=\d)\.(?=\d{3}\b)/', '', $val);
        // convert comma to decimal point
        $val = str_replace(",", ".", $val);
        //$val = preg_replace('/\.(?=.*\.)/', '', $val);
        //$val = preg_replace('/[^0-9-.]+/', '', $val);
        if (is_numeric($val)) {
            return number_format(floatval($val), 2, '.', '');
        } else {
            return false;
        }
    }

    private function convertGermanDateFormat($val)
    {
        $fullString = explode(' ', $val);
        $dateLength = strlen($fullString[0]);
        $dateParts = explode('.', $fullString[0]);

        if ($dateLength >= 6 && $dateLength <= 10 && count($dateParts) === 3) {
            // is most likely a german date format 20.02.2020
            $fullString[0] = $dateParts[2] . '-' . sprintf('%02d', $dateParts[1]) . '-' . sprintf('%02d', $dateParts[0]);
            $val = implode(' ', $fullString);
        }
        return $val;
    }
}