Code Coverage
 
Lines
Functions and Methods
Classes and Traits
Total
100.00%
94 / 94
100.00%
13 / 13
 CRAP
100.00%
1 / 1
Organisation
100.00%
94 / 94
100.00%
13 / 13
 29
100.00%
1 / 1
 readEntity
100.00%
8 / 8
100.00%
1 / 1
 2
 readResolvedReferences
100.00%
6 / 6
100.00%
1 / 1
 3
 readByScopeId
100.00%
6 / 6
100.00%
1 / 1
 1
 readByDepartmentId
100.00%
6 / 6
100.00%
1 / 1
 1
 readByClusterId
100.00%
4 / 4
100.00%
1 / 1
 2
 readByOwnerId
100.00%
12 / 12
100.00%
1 / 1
 4
 readByHash
100.00%
4 / 4
100.00%
1 / 1
 1
 readList
100.00%
11 / 11
100.00%
1 / 1
 3
 deleteEntity
100.00%
6 / 6
100.00%
1 / 1
 3
 writeEntity
100.00%
9 / 9
100.00%
1 / 1
 2
 updateEntity
100.00%
8 / 8
100.00%
1 / 1
 2
 writeOrganisationTicketprinters
100.00%
8 / 8
100.00%
1 / 1
 3
 updateOrganisationTicketprinters
100.00%
6 / 6
100.00%
1 / 1
 2
1<?php
2
3namespace BO\Zmsdb;
4
5use BO\Zmsentities\Organisation as Entity;
6use BO\Zmsentities\Collection\OrganisationList as Collection;
7
8/**
9 *
10 * @SuppressWarnings(Public)
11 *
12 */
13class Organisation extends Base
14{
15    public function readEntity($itemId, $resolveReferences = 0)
16    {
17        $query = new Query\Organisation(Query\Base::SELECT);
18        $query->addEntityMapping()
19            ->addResolvedReferences($resolveReferences)
20            ->addConditionOrganisationId($itemId);
21        $organisation = $this->fetchOne($query, new Entity());
22        if (isset($organisation['id'])) {
23            return $this->readResolvedReferences($organisation, $resolveReferences);
24        }
25        return array();
26    }
27
28    #[\Override]
29    public function readResolvedReferences(\BO\Zmsentities\Schema\Entity $entity, $resolveReferences)
30    {
31        if (0 < $resolveReferences && $entity->hasId()) {
32            $entity['departments'] = (new Department())
33                ->readByOrganisationId($entity->id, $resolveReferences - 1);
34            $entity['ticketprinters'] = (new Ticketprinter())
35                ->readByOrganisationId($entity->id, $resolveReferences - 1);
36        }
37        return $entity;
38    }
39
40    public function readByScopeId($scopeId, $resolveReferences = 0)
41    {
42        $query = new Query\Organisation(Query\Base::SELECT);
43        $query->addEntityMapping()
44            ->addResolvedReferences($resolveReferences)
45            ->addConditionScopeId($scopeId);
46        $organisation = $this->fetchOne($query, new Entity());
47        return $this->readResolvedReferences($organisation, $resolveReferences);
48    }
49
50    public function readByDepartmentId($departmentId, $resolveReferences = 0)
51    {
52        $query = new Query\Organisation(Query\Base::SELECT);
53        $query->addEntityMapping()
54            ->addResolvedReferences($resolveReferences)
55            ->addConditionDepartmentId($departmentId);
56        $organisation = $this->fetchOne($query, new Entity());
57        return $this->readResolvedReferences($organisation, $resolveReferences);
58    }
59
60    public function readByClusterId($clusterId, $resolveReferences = 0)
61    {
62        $scope = (new Scope())->readByClusterId($clusterId, $resolveReferences)->getFirst();
63        if (! $scope) {
64            throw new Exception\ClusterWithoutScopes();
65        }
66        return $this->readByScopeId($scope->id, $resolveReferences);
67    }
68
69    public function readByOwnerId($ownerId, $resolveReferences = 0)
70    {
71        $organisationList = new Collection();
72        $query = new Query\Organisation(Query\Base::SELECT);
73        $query->addEntityMapping()
74            ->addResolvedReferences($resolveReferences)
75            ->addConditionOwnerId($ownerId);
76        $result = $this->fetchList($query, new Entity());
77        if (count($result)) {
78            foreach ($result as $organisation) {
79                $entity = $this->readResolvedReferences($organisation, $resolveReferences);
80                if ($entity instanceof Entity) {
81                    $organisationList->addEntity($entity);
82                }
83            }
84        }
85        return $organisationList;
86    }
87
88    public function readByHash($hash)
89    {
90        $organisationId = $this->getReader()
91            ->fetchValue((new Query\Ticketprinter(Query\Base::SELECT))
92            ->getOrganisationIdByHash(), ['hash' => $hash]);
93
94        return $this->readEntity($organisationId);
95    }
96
97    public function readList($resolveReferences = 0)
98    {
99        $organisationList = new Collection();
100        $query = new Query\Organisation(Query\Base::SELECT);
101        $query->addEntityMapping()
102            ->addResolvedReferences($resolveReferences);
103        $result = $this->fetchList($query, new Entity());
104        if (count($result)) {
105            foreach ($result as $organisation) {
106                $entity = new Entity($organisation);
107                $entity = $this->readResolvedReferences($entity, $resolveReferences);
108                $organisationList->addEntity($entity);
109            }
110        }
111        return $organisationList;
112    }
113
114    public function deleteEntity($itemId)
115    {
116        $entity = $this->readEntity($itemId, 1);
117        if (0 < $entity->toProperty()->departments->get()->count()) {
118            throw new Exception\Organisation\DepartmentListNotEmpty();
119        }
120        $query = new Query\Organisation(Query\Base::DELETE);
121        $query->addConditionOrganisationId($itemId);
122        return ($this->deleteItem($query)) ? $entity : null;
123    }
124
125    public function writeEntity(\BO\Zmsentities\Organisation $entity, $parentId)
126    {
127        $query = new Query\Organisation(Query\Base::INSERT);
128        $values = $query->reverseEntityMapping($entity, $parentId);
129        $query->addValues($values);
130        $this->writeItem($query);
131        $lastInsertId = $this->getWriter()
132            ->lastInsertId();
133        if ($entity->toProperty()->ticketprinters->isAvailable()) {
134            $this->writeOrganisationTicketprinters($lastInsertId, $entity->ticketprinters);
135        }
136        return $this->readEntity($lastInsertId);
137    }
138
139    public function updateEntity($organisationId, \BO\Zmsentities\Organisation $entity)
140    {
141        $query = new Query\Organisation(Query\Base::UPDATE);
142        $query->addConditionOrganisationId($organisationId);
143        $values = $query->reverseEntityMapping($entity);
144        $query->addValues($values);
145        $this->writeItem($query);
146        if ($entity->toProperty()->ticketprinters->isAvailable()) {
147            $this->updateOrganisationTicketprinters($entity->ticketprinters, $organisationId);
148        }
149        return $this->readEntity($organisationId, 1, true);
150    }
151
152    protected function writeOrganisationTicketprinters($organisationId, $ticketprinterList)
153    {
154        $deleteQuery = new Query\Ticketprinter(Query\Base::DELETE);
155        $deleteQuery->addConditionOrganisationId($organisationId);
156        $this->deleteItem($deleteQuery);
157        foreach ($ticketprinterList as $ticketprinter) {
158            $ticketprinter['enabled'] = (isset($ticketprinter['enabled']) && $ticketprinter['enabled']);
159            $ticketprinter = new \BO\Zmsentities\Ticketprinter($ticketprinter);
160            $query = new Ticketprinter();
161            $query->writeEntity($ticketprinter, $organisationId);
162        }
163    }
164
165    protected function updateOrganisationTicketprinters($ticketprinterList, $organisationId)
166    {
167        foreach ($ticketprinterList as $item) {
168            $query = new Query\Ticketprinter(Query\Base::UPDATE);
169            $entity = new \BO\Zmsentities\Ticketprinter($item);
170            $query->addConditionHash($entity->getId());
171            $query->addValues($query->reverseEntityMapping($entity, $organisationId));
172            $this->writeItem($query);
173        }
174    }
175}