Lines 97.21% 279 / 287
Methods 84.61% 22 / 26
Classes 0.00% 0 / 1
Name Lines Methods CRAP
 readEntity 100.00% 42 / 42 100.00% 1 / 1 3
 readSubjectList 100.00% 11 / 11 100.00% 1 / 1 2
 readPeriodList 100.00% 22 / 22 100.00% 1 / 1 4
 readByDateTime 100.00% 19 / 19 100.00% 1 / 1 2
 writeWaitingTimeCalculated 95.23% 20 / 21 0.00% 0 / 1 3
 writeWaitingTime 96.29% 26 / 27 0.00% 0 / 1 4
 updateWaitingStatistics 96.42% 27 / 28 0.00% 0 / 1 2
 [BO\Zmsbackend\Base] __construct 100.00% 2 / 2 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] init 100.00% 2 / 2 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] getWriter 100.00% 4 / 4 100.00% 1 / 1 2
 [BO\Zmsbackend\Base] getReader 100.00% 5 / 5 100.00% 1 / 1 3
 [BO\Zmsbackend\Base] fetchPreparedStatement 100.00% 9 / 9 100.00% 1 / 1 3
 [BO\Zmsbackend\Base] startExecute 100.00% 5 / 5 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] pdoExceptionHandler 100.00% 13 / 13 100.00% 1 / 1 4
 [BO\Zmsbackend\Base] fetchStatement 100.00% 3 / 3 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchOne 100.00% 7 / 7 100.00% 1 / 1 2
 [BO\Zmsbackend\Base] fetchRow 100.00% 7 / 7 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchValue 100.00% 7 / 7 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchAll 100.00% 7 / 7 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchHandle 100.00% 5 / 5 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchList 100.00% 8 / 8 100.00% 1 / 1 2
 [BO\Zmsbackend\Base] writeItem 100.00% 7 / 7 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] deleteItem 100.00% 1 / 1 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] perform 100.00% 7 / 7 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] fetchAffected 100.00% 8 / 8 100.00% 1 / 1 1
 [BO\Zmsbackend\Base] readResolvedReferences n/a 0 / 0 n/a 0 / 0 1
 [BO\Zmsbackend\Base] hashStringValue 50.00% 5 / 10 0.00% 0 / 1 8.12
7class ExchangeWaitingscope extends \BO\Zmsbackend\Base implements \BO\Zmsbackend\Interfaces\ExchangeSubject
8{
9    /**
10     * @return Exchange
11     */
12    #[\Override]
13    public function readEntity(
14        $subjectid,
15        \DateTimeInterface $datestart,
16        \DateTimeInterface $dateend,
17        $period = 'day'
18    ) {
19        $scope = (new \BO\Zmsbackend\Scope\Service\Scope())->readEntity($subjectid);
20        $entity = new Exchange();
21        $entity['title'] = "Wartestatistik " . $scope->contact->name . " " . $scope->shortName;
22        $entity->setPeriod($datestart, $dateend, $period);
23        $entity->addDictionaryEntry('subjectid', 'string', 'ID of a scope', 'scope.id');
24        $entity->addDictionaryEntry('date', 'string', 'date of report entry');
25        $entity->addDictionaryEntry('hour', 'string', 'hour of report entry');
26        $entity->addDictionaryEntry('waitingcount', 'number', 'amount of waiting spontaneous clients');
27        $entity->addDictionaryEntry('waitingtime', 'number', 'real waitingtime for spontaneous clients');
28        $entity->addDictionaryEntry('waytime', 'number', 'real waytime for spontaneous clients');
29        $entity->addDictionaryEntry('waitingcalculated', 'number', 'calculated waitingtime for spontaneous clients');
30        $entity->addDictionaryEntry('waitingcount_termin', 'number', 'amount of waiting clients with termin');
31        $entity->addDictionaryEntry('waitingtime_termin', 'number', 'real waitingtime with termin');
32        $entity->addDictionaryEntry('waytime_termin', 'number', 'real waytime with appointment');
33        $entity->addDictionaryEntry('waitingcalculated_termin', 'number', 'calculated waitingtime with termin');
34        $subjectIdList = explode(',', $subjectid);
35
36        $raw = $this
37            ->getReader()
38            ->fetchAll(
39                constant("\BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::QUERY_READ_" . strtoupper($period)),
40                [
41                    'scopeid' => $subjectIdList,
42                    'datestart' => $datestart->format('Y-m-d'),
43                    'dateend' => $dateend->format('Y-m-d')
44                ]
45            );
46
47        foreach ($raw as $entry) {
48            foreach (range(7, 19) as $hour) {
49                $entity->addDataSet([
50                    $entry['standortid'],
51                    $entry['datum'],
52                    $hour,
53                    $entry[sprintf('hour_%02d_waiting_count_spontaneous', $hour)],
54                    $entry[sprintf('hour_%02d_waiting_time_spontaneous', $hour)],
55                    $entry[sprintf('hour_%02d_way_time_spontaneous', $hour)],
56                    $entry[sprintf('hour_%02d_estimated_waiting_time_spontaneous', $hour)],
57                    $entry[sprintf('hour_%02d_waiting_count_appointment', $hour)],
58                    $entry[sprintf('hour_%02d_waiting_time_appointment', $hour)],
59                    $entry[sprintf('hour_%02d_way_time_appointment', $hour)],
60                    $entry[sprintf('hour_%02d_estimated_waiting_time_appointment', $hour)],
61                ]);
62            }
63        }
64
65        return $entity;
66    }
67
68    /**
69     * @return Exchange
70     */
71    #[\Override]
72    public function readSubjectList()
73    {
74        $raw = $this->getReader()->fetchAll(\BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::QUERY_SUBJECTS, []);
75        $entity = new Exchange();
76        $entity['title'] = "Wartestatistik";
77        $entity->setPeriod(new \DateTimeImmutable(), new \DateTimeImmutable());
78        $entity->addDictionaryEntry('subject', 'string', 'Standort ID', 'scope.id');
79        $entity->addDictionaryEntry('periodstart', 'string', 'Datum von');
80        $entity->addDictionaryEntry('periodend', 'string', 'Datum bis');
81        $entity->addDictionaryEntry('description', 'string', 'Standort Beschreibung');
82        foreach ($raw as $entry) {
83            $entity->addDataSet(array_values($entry));
84        }
85        return $entity;
86    }
87
88    /**
89     * @return Exchange
90     */
91    #[\Override]
92    public function readPeriodList($subjectid, $period = 'day')
93    {
94        $scope = (new \BO\Zmsbackend\Scope\Service\Scope())->readEntity($subjectid);
95        $entity = new Exchange();
96        $entity['title'] = "Wartestatistik " . $scope->contact->name . " " . $scope->shortName;
97        $entity->setPeriod(new \DateTimeImmutable(), new \DateTimeImmutable(), $period);
98        $entity->addDictionaryEntry('period');
99
100        $montsList = $this->getReader()->fetchAll(
101            constant("\BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::QUERY_PERIODLIST_MONTH"),
102            [
103                'scopeid' => $subjectid,
104            ]
105        );
106        $raw = [];
107        foreach ($montsList as $month) {
108            $date = new \DateTimeImmutable($month['date']);
109            $raw[$date->format('Y')][] = $month['date'];
110            rsort($raw[$date->format('Y')]);
111        }
112        krsort($raw);
113
114        foreach ($raw as $year => $months) {
115            $entity->addDataSet([$year]);
116            foreach ($months as $month) {
117                $entity->addDataSet([$month]);
118            }
119        }
120        return $entity;
121    }
122
123    /**
124     * fetch entry by scope and date or create an entry, if it does not exists
125     * the returned entry is save for updating
126     */
127    public function readByDateTime(
128        \BO\Zmsentities\Scope $scope,
129        \DateTimeInterface $date,
130        bool $isWithAppointment = false
131    ) {
132        $sql = \BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::getQuerySelectByDateTime($date, $isWithAppointment);
133        $existingEntry = $this->getReader()->fetchOne(
134            $sql,
135            [
136                'scopeid' => $scope->id,
137                'date' => $date->format('Y-m-d'),
138                'hour' => $date->format('H')
139            ]
140        );
141        if (!$existingEntry) {
142            $this->perform(
143                \BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::QUERY_CREATE,
144                [
145                    'scopeid' => $scope->id,
146                    'date' => $date->format('Y-m-d'),
147                ]
148            );
149            $existingEntry = $this->readByDateTime($scope, $date, $isWithAppointment);
150        }
151        return $existingEntry;
152    }
153
154    /**
155     * Write calculated waiting time and count of queued processes into statistic
156     */
157    public function writeWaitingTimeCalculated(
158        \BO\Zmsentities\Scope $scope,
159        \DateTimeInterface $now,
160        bool $isWithAppointment = false
161    ): static {
162        if ($now > (new \DateTime())) {
163            return $this;
164        }
165
166        $queueList = (new \BO\Zmsbackend\Scope\Service\Scope())->readQueueListWithWaitingTime($scope, $now);
167
168        $existingEntry = $this->readByDateTime($scope, $now, $isWithAppointment);
169        $queueEntry = $queueList->getFakeOrLastWaitingnumber();
170        $waitingCalculated = $existingEntry['waitingcalculated'] > $queueEntry['waitingTimeEstimate'] ?
171            $existingEntry['waitingcalculated']
172            : $queueEntry['waitingTimeEstimate'];
173
174        $this->perform(
175            \BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::getQueryUpdateByDateTime($now, $isWithAppointment),
176            [
177                'waitingcalculated' => $waitingCalculated,
178                'waitingcount' => $existingEntry['waitingcount'],
179                'waitingtime' => $existingEntry['waitingtime'],
180                'waytime' => $existingEntry['waytime'],
181                'scopeid' => $scope->id,
182                'date' => $now->format('Y-m-d'),
183                'hour' => $now->format('H')
184            ]
185        );
186        return $this;
187    }
188
189    /**
190     * Write real waiting time into statistics
191     */
192    public function writeWaitingTime(
193        \BO\Zmsentities\Process $process,
194        \DateTimeInterface $now
195    ): static {
196        if ($now > (new \DateTime())) {
197            return $this;
198        }
199
200        $waitingTime = $process->getWaitedMinutes($now);
201        $wayTime = $process->getWayMinutes($now);
202        $existingEntry = $this->readByDateTime(
203            $process->scope,
204            $process->getArrivalTime($now),
205            $process->isWithAppointment()
206        );
207        $waitingTime = $existingEntry['waitingtime'] > $waitingTime ? $existingEntry['waitingtime'] : $waitingTime;
208        $wayTime = $existingEntry['waytime'] > $wayTime ? $existingEntry['waytime'] : $wayTime;
209        $this->perform(
210            \BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::getQueryUpdateByDateTime(
211                $process->getArrivalTime($now),
212                $process->isWithAppointment()
213            ),
214            [
215                'waitingcalculated' => $existingEntry['waitingcalculated'],
216                'waitingcount' => $existingEntry['waitingcount'],
217                'waitingtime' => $waitingTime,
218                'waytime' => $wayTime,
219                'scopeid' => $process->scope->id,
220                'date' => $now->format('Y-m-d'),
221                'hour' => $now->format('H')
222            ]
223        );
224        return $this;
225    }
226
227    public function updateWaitingStatistics(
228        \BO\Zmsentities\Process $process,
229        \DateTimeInterface $now
230    ): static {
231        if ($now > (new \DateTime())) {
232            return $this;
233        }
234
235        $newWaitingTime = $process->getWaitedMinutes($now);
236        $newWayTime = $process->getWayMinutes($now);
237
238        $existingEntry = $this->readByDateTime(
239            $process->scope,
240            $process->getArrivalTime($now),
241            $process->isWithAppointment()
242        );
243
244        $waitingCount = $existingEntry['waitingcount'] + 1;
245
246        $averageWaitingTime = ($existingEntry['waitingtime'] * $existingEntry['waitingcount'] + $newWaitingTime) / $waitingCount;
247        $averageWayTime = ($existingEntry['waytime'] * $existingEntry['waitingcount'] + $newWayTime) / $waitingCount;
248
249        $this->perform(
250            \BO\Zmsbackend\Exchange\Repository\ExchangeWaitingscope::getQueryUpdateByDateTime(
251                $process->getArrivalTime($now),
252                $process->isWithAppointment()
253            ),
254            [
255                'waitingcalculated' => $existingEntry['waitingcalculated'],
256                'waitingcount' => $waitingCount,
257                'waitingtime' => $averageWaitingTime,
258                'waytime' => $averageWayTime,
259                'scopeid' => $process->scope->id,
260                'date' => $now->format('Y-m-d'),
261                'hour' => $now->format('H')
262            ]
263        );
264
265        return $this;
266    }
267}

Inherited from BO\Zmsbackend\Base

38    public function __construct(?Connection\Pdo $writeConnection = null, ?Connection\Pdo $readConnection = null)
39    {
40        $this->writeDb = $writeConnection;
41        $this->readDb = $readConnection;
42    }
44    public static function init(?Connection\Pdo $writeConnection = null, ?Connection\Pdo $readConnection = null): static
45    {
46        $instance = new static($writeConnection, $readConnection);
47        return $instance;
48    }
50    public function getWriter(): Connection\Pdo
51    {
52        if (null === $this->writeDb) {
53            $this->writeDb = Connection\Select::getWriteConnection();
54            $this->readDb = $this->writeDb;
55        }
56        return $this->writeDb;
57    }
59    public function getReader(): Connection\Pdo
60    {
61        if (null !== $this->writeDb) {
62            // if readDB gets a reset, still use writeDB
63            return $this->writeDb;
64        }
65        if (null === $this->readDb) {
66            $this->readDb = Connection\Select::getReadConnection();
67        }
68        return $this->readDb;
69    }
71    public function fetchPreparedStatement(Query\Base|string $query)
72    {
73        $sql = "$query";
74        $reader = $this->getReader();
75        if (spl_object_hash($reader) != static::$preparedConnectionId) {
76            // do not use prepared statements on a different connection
77            static::$preparedCache = [];
78            static::$preparedConnectionId = spl_object_hash($reader);
79        }
80        if (!isset(static::$preparedCache[$sql])) {
81            $prepared = $this->getReader()->prepare($sql);
82            static::$preparedCache[$sql] = $prepared;
83        }
84        return static::$preparedCache[$sql];
85    }
87    public function startExecute($statement, array $parameters)
88    {
89        $statement = static::pdoExceptionHandler(function () use ($statement, $parameters) {
90            $statement->execute($parameters);
91            return $statement;
92        });
93        return $statement;
94    }
96    protected static function pdoExceptionHandler(\Closure $pdoFunction, $parameters = [])
97    {
98        try {
99            $statement = $pdoFunction($parameters);
100        } catch (\PDOException $pdoException) {
101            if (stripos($pdoException->getMessage(), 'Lock wait timeout') !== false) {
102                throw new \BO\Zmsbackend\Exception\Pdo\LockTimeout();
103            }
104            //@codeCoverageIgnoreStart
105            if (stripos($pdoException->getMessage(), 'Deadlock found') !== false) {
106                throw new \BO\Zmsbackend\Exception\Pdo\DeadLockFound();
107            }
108            //@codeCoverageIgnoreEnd
109            $message = "SQL: "
110                . " Err: "
111                . $pdoException->getMessage()
112                //. " || Statement: "
113                //.$statement->queryString
114                //." || Parameters=". var_export($parameters, true)
115                ;
116            throw new \BO\Zmsbackend\Exception\Pdo\PDOFailed($message, 0, $pdoException);
117        }
118        return $statement;
119    }
121    public function fetchStatement(Query\Base $query)
122    {
123        $parameters = $query->getParameters();
124        $statement = $this->startExecute($this->fetchPreparedStatement($query), $parameters);
125        return $statement;
126    }
133    public function fetchOne(Query\Base $query, \BO\Zmsentities\Schema\Entity $entity)
134    {
135        $statement = $this->fetchStatement($query);
136        $data = $statement->fetch(\PDO::FETCH_ASSOC);
137        if ($data) {
138            $entity->exchangeArray($query->postProcessJoins($data));
139            $entity->setResolveLevel($query->getResolveLevel());
140        }
141        $statement->closeCursor();
142        return $entity;
143    }
145    public function fetchRow(Query\Base|string $query, array|null $parameters = null)
146    {
147        return static::pdoExceptionHandler(function () use ($query, $parameters) {
148            $prepared = $this->fetchPreparedStatement($query);
149            $prepared->execute($parameters);
150            $row = $prepared->fetch(\PDO::FETCH_ASSOC);
151            $prepared->closeCursor();
152            return $row;
153        });
154    }
156    public function fetchValue(Query\Base|string $query, array|null $parameters = null)
157    {
158        return static::pdoExceptionHandler(function () use ($query, $parameters) {
159            $prepared = $this->fetchPreparedStatement($query);
160            $prepared->execute($parameters);
161            $value = $prepared->fetchColumn();
162            $prepared->closeCursor();
163            return $value;
164        });
165    }
167    public function fetchAll(Query\Base|string $query, array|null $parameters = null)
168    {
169        return static::pdoExceptionHandler(function () use ($query, $parameters) {
170            $prepared = $this->fetchPreparedStatement($query);
171            $prepared->execute($parameters);
172            $list = $prepared->fetchAll(\PDO::FETCH_ASSOC);
173            $prepared->closeCursor();
174            return $list;
175        });
176    }
178    public function fetchHandle(Query\Base|string $query, array|null $parameters = null)
179    {
180        return static::pdoExceptionHandler(function () use ($query, $parameters) {
181            $prepared = $this->fetchPreparedStatement($query);
182            $prepared->execute($parameters);
183            return $prepared;
184        });
185    }
187    public function fetchList(Query\Base $query, \BO\Zmsentities\Schema\Entity $entity, array|\ArrayAccess $resultList = [])
188    {
189        $statement = $this->fetchStatement($query);
190        while ($data = $statement->fetch(\PDO::FETCH_ASSOC)) {
191            $dataEntity = clone $entity;
192            $dataEntity->exchangeArray($query->postProcessJoins($data));
193            $dataEntity->setResolveLevel($query->getResolveLevel());
194            $resultList[] = $dataEntity;
195        }
196        $statement->closeCursor();
197        return $resultList;
198    }
206    public function writeItem(Query\Base $query)
207    {
208        return static::pdoExceptionHandler(function () use ($query) {
209            $this->getWriter(); //Switch to writer for write/delete
210            $statement = $this->fetchPreparedStatement($query);
211            $status = $statement->execute($query->getParameters());
212            $statement->closeCursor();
213            return $status;
214        });
215    }
221    public function deleteItem(Query\Base $query)
222    {
223        return $this->writeItem($query);
224    }
226    public function perform(string $sql, array|null $parameters = null)
227    {
228        return static::pdoExceptionHandler(function () use ($sql, $parameters) {
229            $this->getWriter(); //Switch to writer for perform
230            $prepared = $this->fetchPreparedStatement($sql);
231            $status = $prepared->execute($parameters);
232            $prepared->closeCursor();
233            return $status;
234        });
235    }
237    public function fetchAffected(string $sql, array|null $parameters = null)
238    {
239        return static::pdoExceptionHandler(function () use ($sql, $parameters) {
240            $this->getWriter(); //Switch to writer for perform
241            $prepared = $this->fetchPreparedStatement($sql);
242            $prepared->execute($parameters);
243            $count = $prepared->rowCount();
244            $prepared->closeCursor();
245            return $count;
246        });
247    }
256    public function readResolvedReferences(\BO\Zmsentities\Schema\Entity $entity, int $resolveReferences)
257    {
258        return $entity;
259    }
268    public function hashStringValue(string $value, ?callable $callable = null): string
269    {
270        if ($callable === null) {
271            $callable = 'sha1';
272        }
273
274        if (is_callable($callable)) {
275            $hash = $callable($value);
276
277            if (is_string($callable)) {
278                return $callable . ':' . $hash;
279            }
280            if ($callable instanceof \Closure) {
281                return 'closure:' . $hash;
282            }
283            // else
284            return 'custom:' . $hash;
285        }
286
287        throw new \InvalidArgumentException('hashStringValue() should be called with a callable as second parameter.');
288    }