| @@ 119-137 (lines=19) @@ | ||
| 116 | { |
|
| 117 | $_oJobEntityLocal = $this->oJobRepositoryLocal->getJob($_oJobEntity->name); |
|
| 118 | // new job |
|
| 119 | if (empty($_oJobEntityLocal->name)) |
|
| 120 | { |
|
| 121 | if ($this->oJobRepositoryLocal->addJob($_oJobEntity)) |
|
| 122 | { |
|
| 123 | $this->oLogger->notice(sprintf( |
|
| 124 | 'Job "%s" successfully stored in local repository', |
|
| 125 | $_oJobEntity->name |
|
| 126 | )); |
|
| 127 | } |
|
| 128 | else |
|
| 129 | { |
|
| 130 | $this->oLogger->error(sprintf( |
|
| 131 | 'Failed to store job "%s" in local repository', |
|
| 132 | $_oJobEntity->name |
|
| 133 | )); |
|
| 134 | } |
|
| 135 | ||
| 136 | continue; |
|
| 137 | } |
|
| 138 | ||
| 139 | // update job |
|
| 140 | $_aDiff = $this->oJobComparisonBusinessCase->getJobDiff($_oJobEntity->name); |
|
| @@ 153-166 (lines=14) @@ | ||
| 150 | ); |
|
| 151 | } |
|
| 152 | ||
| 153 | if ($this->oJobRepositoryLocal->updateJob($_oJobEntity)) |
|
| 154 | { |
|
| 155 | $this->oLogger->notice(sprintf( |
|
| 156 | 'Job "%s" successfully updated in local repository', |
|
| 157 | $_oJobEntity->name |
|
| 158 | )); |
|
| 159 | } |
|
| 160 | else |
|
| 161 | { |
|
| 162 | $this->oLogger->error(sprintf( |
|
| 163 | 'Failed to update job "%s" in local repository', |
|
| 164 | $_oJobEntity->name |
|
| 165 | )); |
|
| 166 | } |
|
| 167 | ||
| 168 | // remove job from index in case off added in the past |
|
| 169 | $this->oJobIndexService->removeJob($_oJobEntity->name); |
|