@@ -98,13 +98,13 @@ discard block |
||
98 | 98 | */ |
99 | 99 | protected function updateIndex($document) |
100 | 100 | { |
101 | - if(!$document instanceof Job){ |
|
101 | + if (!$document instanceof Job) { |
|
102 | 102 | return; |
103 | 103 | } |
104 | 104 | $solrDoc = $this->generateInputDocument($document, new \SolrInputDocument()); |
105 | - try{ |
|
106 | - $this->solrManager->addDocument($solrDoc,$this->solrManager->getOptions()->getJobsPath()); |
|
107 | - }catch (\Exception $e){ |
|
105 | + try { |
|
106 | + $this->solrManager->addDocument($solrDoc, $this->solrManager->getOptions()->getJobsPath()); |
|
107 | + } catch (\Exception $e) { |
|
108 | 108 | // @TODO: What to do when the process failed? |
109 | 109 | } |
110 | 110 | } |
@@ -118,38 +118,38 @@ discard block |
||
118 | 118 | */ |
119 | 119 | public function generateInputDocument(Job $job, $document) |
120 | 120 | { |
121 | - $document->addField('id',$job->getId()); |
|
122 | - $document->addField('title',$job->getTitle()); |
|
123 | - $document->addField('applicationEmail',$job->getContactEmail()); |
|
121 | + $document->addField('id', $job->getId()); |
|
122 | + $document->addField('title', $job->getTitle()); |
|
123 | + $document->addField('applicationEmail', $job->getContactEmail()); |
|
124 | 124 | |
125 | - if($job->getDateCreated()){ |
|
125 | + if ($job->getDateCreated()) { |
|
126 | 126 | $document->addField('dateCreated', |
127 | 127 | $job->getDateCreated()->setTimezone(new \DateTimeZone('UTC'))->format(Manager::SOLR_DATE_FORMAT) |
128 | 128 | ); |
129 | 129 | } |
130 | - if($job->getDateModified()){ |
|
130 | + if ($job->getDateModified()) { |
|
131 | 131 | $document->addField('dateModified', |
132 | 132 | $job->getDateModified()->setTimezone(new \DateTimeZone('UTC'))->format(Manager::SOLR_DATE_FORMAT) |
133 | 133 | ); |
134 | 134 | } |
135 | - if($job->getDatePublishStart()){ |
|
135 | + if ($job->getDatePublishStart()) { |
|
136 | 136 | $document->addField('datePublishStart', |
137 | 137 | $job->getDatePublishStart()->setTimezone(new \DateTimeZone('UTC'))->format(Manager::SOLR_DATE_FORMAT) |
138 | 138 | ); |
139 | 139 | } |
140 | 140 | |
141 | - if($job->getDatePublishEnd()){ |
|
141 | + if ($job->getDatePublishEnd()) { |
|
142 | 142 | $document->addField('datePublishEnd', |
143 | 143 | $job->getDatePublishEnd()->setTimezone(new \DateTimeZone('UTC'))->format(Manager::SOLR_DATE_FORMAT) |
144 | 144 | ); |
145 | 145 | } |
146 | 146 | |
147 | - $document->addField('isActive',$job->isActive()); |
|
148 | - $document->addField('lang',$job->getLanguage()); |
|
147 | + $document->addField('isActive', $job->isActive()); |
|
148 | + $document->addField('lang', $job->getLanguage()); |
|
149 | 149 | |
150 | - $this->processLocation($job,$document); |
|
151 | - if(!is_null($job->getOrganization())){ |
|
152 | - $this->processOrganization($job,$document); |
|
150 | + $this->processLocation($job, $document); |
|
151 | + if (!is_null($job->getOrganization())) { |
|
152 | + $this->processOrganization($job, $document); |
|
153 | 153 | } |
154 | 154 | return $document; |
155 | 155 | } |
@@ -160,14 +160,14 @@ discard block |
||
160 | 160 | * @param Job $job |
161 | 161 | * @param \SolrInputDocument $document |
162 | 162 | */ |
163 | - public function processOrganization(Job $job,$document) |
|
163 | + public function processOrganization(Job $job, $document) |
|
164 | 164 | { |
165 | - if(!is_null($job->getOrganization()->getImage())){ |
|
165 | + if (!is_null($job->getOrganization()->getImage())) { |
|
166 | 166 | $uri = $job->getOrganization()->getImage()->getUri(); |
167 | - $document->addField('companyLogo',$uri); |
|
167 | + $document->addField('companyLogo', $uri); |
|
168 | 168 | } |
169 | - $document->addField('organizationName',$job->getOrganization()->getOrganizationName()->getName()); |
|
170 | - $document->addField('organizationId',$job->getOrganization()->getId()); |
|
169 | + $document->addField('organizationName', $job->getOrganization()->getOrganizationName()->getName()); |
|
170 | + $document->addField('organizationId', $job->getOrganization()->getId()); |
|
171 | 171 | } |
172 | 172 | |
173 | 173 | /** |
@@ -175,18 +175,18 @@ discard block |
||
175 | 175 | * @param Job $job |
176 | 176 | * @param \SolrInputDocument $document |
177 | 177 | */ |
178 | - public function processLocation(Job $job,$document) |
|
178 | + public function processLocation(Job $job, $document) |
|
179 | 179 | { |
180 | 180 | /* @var \Jobs\Entity\Location $location */ |
181 | - foreach($job->getLocations() as $location){ |
|
182 | - if(is_object($location->getCoordinates())){ |
|
181 | + foreach ($job->getLocations() as $location) { |
|
182 | + if (is_object($location->getCoordinates())) { |
|
183 | 183 | $coord = $location->getCoordinates()->getCoordinates(); |
184 | - $document->addField('latLon',doubleval($coord[0]).','.doubleval($coord[1])); |
|
184 | + $document->addField('latLon', doubleval($coord[0]).','.doubleval($coord[1])); |
|
185 | 185 | } |
186 | - $document->addField('postCode',$location->getPostalCode()); |
|
187 | - $document->addField('regionText',$location->getRegion()); |
|
186 | + $document->addField('postCode', $location->getPostalCode()); |
|
187 | + $document->addField('regionText', $location->getRegion()); |
|
188 | 188 | } |
189 | 189 | |
190 | - $document->addField('location',$job->getLocation()); |
|
190 | + $document->addField('location', $job->getLocation()); |
|
191 | 191 | } |
192 | 192 | } |
193 | 193 | \ No newline at end of file |
@@ -55,7 +55,7 @@ |
||
55 | 55 | $client->addDocument($document); |
56 | 56 | $client->commit(); |
57 | 57 | $client->optimize(); |
58 | - }catch (\Exception $e){ |
|
58 | + } catch (\Exception $e){ |
|
59 | 59 | throw new ServerException('Can not add document to server!',$e->getCode(),$e); |
60 | 60 | } |
61 | 61 | } |
@@ -24,7 +24,7 @@ discard block |
||
24 | 24 | */ |
25 | 25 | class ConsoleController extends AbstractActionController |
26 | 26 | { |
27 | - const EVENT_UPDATE_INDEX = 'solr.console.update_index'; |
|
27 | + const EVENT_UPDATE_INDEX = 'solr.console.update_index'; |
|
28 | 28 | |
29 | 29 | public function activeJobIndexAction() |
30 | 30 | { |
@@ -42,7 +42,7 @@ discard block |
||
42 | 42 | |
43 | 43 | $progressBar = new ProgressBar($count); |
44 | 44 | $i = 1; |
45 | - foreach($jobs as $job){ |
|
45 | + foreach ($jobs as $job) { |
|
46 | 46 | /* @var Job $job */ |
47 | 47 | $jobSubscriber->consoleIndex($job); |
48 | 48 | $progressBar->update($i, 'Job '.$i.' / '.$count); |