|
31 | 31 | import org.brapi.test.BrAPITestServer.service.germ.CrossService; |
32 | 32 | import org.brapi.test.BrAPITestServer.service.germ.GermplasmService; |
33 | 33 | import org.brapi.test.BrAPITestServer.service.germ.SeedLotService; |
| 34 | +import org.slf4j.Logger; |
| 35 | +import org.slf4j.LoggerFactory; |
34 | 36 | import org.springframework.beans.factory.annotation.Autowired; |
35 | 37 | import org.springframework.data.domain.Page; |
36 | 38 | import org.springframework.data.domain.PageRequest; |
|
60 | 62 |
|
61 | 63 | @Service |
62 | 64 | public class ObservationUnitService { |
| 65 | + |
| 66 | + private static final Logger log = LoggerFactory.getLogger(ObservationUnitService.class); |
63 | 67 | private final ObservationUnitRepository observationUnitRepository; |
64 | 68 |
|
65 | 69 | private final EntityManager entityManager; |
@@ -197,24 +201,18 @@ public List<ObservationUnit> findObservationUnits(@Valid ObservationUnitSearchRe |
197 | 201 | boolean includeObservations = request.isIncludeObservations() != null && request.isIncludeObservations(); |
198 | 202 |
|
199 | 203 | if(includeObservations) { |
200 | | - System.out.println("Fetching observations for OUs"); |
| 204 | + log.debug("Fetching observations for OUs"); |
201 | 205 | for(ObservationUnitEntity entity : page) { |
202 | | - System.out.println("Fetching observations for OU: " + entity.getId()); |
| 206 | + log.trace("Fetching observations for OU: " + entity.getId()); |
203 | 207 | entity.getObservations(); |
204 | 208 | } |
205 | 209 | } |
206 | 210 |
|
207 | | - System.out.println(new Date() + ": converting "+page.getSize()+" entities"); |
| 211 | + log.debug(new Date() + ": converting "+page.getSize()+" entities"); |
208 | 212 | List<ObservationUnit> observationUnits = page.map(observationUnitEntity -> this.convertFromEntity(observationUnitEntity, includeObservations)).getContent(); |
209 | | - System.out.println(new Date() + ": done converting entities"); |
| 213 | + log.debug(new Date() + ": done converting entities"); |
210 | 214 | PagingUtility.calculateMetaData(metadata, page); |
211 | 215 |
|
212 | | -// if (request.isIncludeObservations() == null || !request.isIncludeObservations()) { |
213 | | -// for (ObservationUnit ou : observationUnits) { |
214 | | -// ou.setObservations(null); |
215 | | -// } |
216 | | -// } |
217 | | - |
218 | 216 | return observationUnits; |
219 | 217 | } |
220 | 218 |
|
@@ -289,19 +287,13 @@ public Page<ObservationUnitEntity> findObservationUnitEntities(@Valid Observatio |
289 | 287 | .appendList(request.getStudyNames(), "study.studyName").appendList(request.getTrialDbIds(), "trial.id") |
290 | 288 | .appendList(request.getTrialNames(), "trial.trailName"); |
291 | 289 |
|
292 | | - System.out.println("Starting search: " + new Date()); |
| 290 | + log.debug("Starting search: " + new Date()); |
293 | 291 | Page<ObservationUnitEntity> page = observationUnitRepository.findAllBySearch(searchQuery, pageReq); |
294 | | - System.out.println("Search complete: " + new Date()); |
| 292 | + log.debug("Search complete: " + new Date()); |
295 | 293 |
|
296 | | - System.out.println("fetching OU xrefs: " + new Date()); |
297 | 294 | observationUnitRepository.fetchXrefs(page, ObservationUnitEntity.class); |
298 | | - System.out.println("done fetching OU xrefs: " + new Date()); |
299 | | - System.out.println("fetching OU treatments: " + new Date()); |
300 | 295 | fetchTreatments(page); |
301 | | - System.out.println("done fetching OU treatments: " + new Date()); |
302 | | - System.out.println("fetching OU position levels: " + new Date()); |
303 | 296 | fetchObsUnitLevelRelationships(page); |
304 | | - System.out.println("done fetching OU position levels: " + new Date()); |
305 | 297 | return page; |
306 | 298 | } |
307 | 299 |
|
@@ -332,7 +324,11 @@ private void fetchObsUnitLevelRelationships(Page<ObservationUnitEntity> page) { |
332 | 324 | positions.forEach(ou -> positionByOu.put(ou.getId(), ou.getPosition())); |
333 | 325 |
|
334 | 326 | page.forEach(ou -> { |
335 | | - ou.getPosition().setObservationLevelRelationships(positionByOu.get(ou.getId()).getObservationLevelRelationships()); |
| 327 | + if(ou.getPosition() != null) { |
| 328 | + ou.getPosition() |
| 329 | + .setObservationLevelRelationships(positionByOu.get(ou.getId()) |
| 330 | + .getObservationLevelRelationships()); |
| 331 | + } |
336 | 332 | }); |
337 | 333 | } |
338 | 334 |
|
@@ -455,7 +451,7 @@ private ObservationUnit convertFromEntity(ObservationUnitEntity entity) { |
455 | 451 | } |
456 | 452 |
|
457 | 453 | private ObservationUnit convertFromEntity(ObservationUnitEntity entity, boolean convertObservations) { |
458 | | - System.out.println(new Date() + ": converting ou: " + entity.getId()); |
| 454 | + log.trace(new Date() + ": converting ou: " + entity.getId()); |
459 | 455 | ObservationUnit unit = new ObservationUnit(); |
460 | 456 | UpdateUtility.convertFromEntity(entity, unit); |
461 | 457 |
|
|
0 commit comments