@Test public void process_courtNotFound() throws Exception { when(rawSourceCcJudgmentConverter.convertSourceCcJudgment(Mockito.isA(RawSourceCcJudgment.class))).thenThrow(new CcjImportProcessSkippableException("", ImportProcessingSkipReason.COURT_NOT_FOUND)); CatchExceptionAssertJ.when(ccjImportProcessProcessor).process(rJudgment); CatchExceptionAssertJ.then(CatchException.caughtException()) .isExactlyInstanceOf(CcjImportProcessSkippableException.class); assertThat((CcjImportProcessSkippableException) CatchException.caughtException(), CcjSkippableExceptionMatcher.hasSkipReason(ImportProcessingSkipReason.COURT_NOT_FOUND)); verify(rJudgment).getId(); ArgumentCaptor<RawSourceCcJudgment> argRJudgment = ArgumentCaptor.forClass(RawSourceCcJudgment.class); verify(rawSourceCcJudgmentConverter).convertSourceCcJudgment(argRJudgment.capture()); assertTrue(argRJudgment.getValue() == rJudgment); verify(ccjProcessingService, never()).processJudgment(Mockito.any(SourceCcJudgment.class)); verifyNoMoreInteractions(rJudgment); }
@Override public JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment) throws Exception { rawJudgment = rawSourceCcJudgmentRepository.findOne(rawJudgment.getId()); SourceCcJudgment sourceCcJudgment = rawSourceCcJudgmentConverter.convertSourceCcJudgment(rawJudgment); log.trace("process: \n {}", sourceCcJudgment); JudgmentWithCorrectionList<CommonCourtJudgment> judgmentWithCorrectionList = ccjProcessingService.processJudgment(sourceCcJudgment); markProcessed(rawJudgment); return judgmentWithCorrectionList; }
CcjImportProcessProcessor implements ItemProcessor<RawSourceCcJudgment, JudgmentWithCorrectionList<CommonCourtJudgment>> { @Override public JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment) throws Exception { rawJudgment = rawSourceCcJudgmentRepository.findOne(rawJudgment.getId()); SourceCcJudgment sourceCcJudgment = rawSourceCcJudgmentConverter.convertSourceCcJudgment(rawJudgment); log.trace("process: \n {}", sourceCcJudgment); JudgmentWithCorrectionList<CommonCourtJudgment> judgmentWithCorrectionList = ccjProcessingService.processJudgment(sourceCcJudgment); markProcessed(rawJudgment); return judgmentWithCorrectionList; } }
CcjImportProcessProcessor implements ItemProcessor<RawSourceCcJudgment, JudgmentWithCorrectionList<CommonCourtJudgment>> { @Override public JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment) throws Exception { rawJudgment = rawSourceCcJudgmentRepository.findOne(rawJudgment.getId()); SourceCcJudgment sourceCcJudgment = rawSourceCcJudgmentConverter.convertSourceCcJudgment(rawJudgment); log.trace("process: \n {}", sourceCcJudgment); JudgmentWithCorrectionList<CommonCourtJudgment> judgmentWithCorrectionList = ccjProcessingService.processJudgment(sourceCcJudgment); markProcessed(rawJudgment); return judgmentWithCorrectionList; }  }
CcjImportProcessProcessor implements ItemProcessor<RawSourceCcJudgment, JudgmentWithCorrectionList<CommonCourtJudgment>> { @Override public JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment) throws Exception { rawJudgment = rawSourceCcJudgmentRepository.findOne(rawJudgment.getId()); SourceCcJudgment sourceCcJudgment = rawSourceCcJudgmentConverter.convertSourceCcJudgment(rawJudgment); log.trace("process: \n {}", sourceCcJudgment); JudgmentWithCorrectionList<CommonCourtJudgment> judgmentWithCorrectionList = ccjProcessingService.processJudgment(sourceCcJudgment); markProcessed(rawJudgment); return judgmentWithCorrectionList; }  @Override JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment); @Autowired void setRawSourceCcjConverter(RawSourceCcJudgmentConverter rawSourceCcJudgmentConverter); @Autowired void setCcjProcessingService(CcjProcessingService ccjProcessingService); @Autowired void setRawSourceCcJudgmentRepository(RawSourceCcJudgmentRepository rawSourceCcJudgmentRepository); }
CcjImportProcessProcessor implements ItemProcessor<RawSourceCcJudgment, JudgmentWithCorrectionList<CommonCourtJudgment>> { @Override public JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment) throws Exception { rawJudgment = rawSourceCcJudgmentRepository.findOne(rawJudgment.getId()); SourceCcJudgment sourceCcJudgment = rawSourceCcJudgmentConverter.convertSourceCcJudgment(rawJudgment); log.trace("process: \n {}", sourceCcJudgment); JudgmentWithCorrectionList<CommonCourtJudgment> judgmentWithCorrectionList = ccjProcessingService.processJudgment(sourceCcJudgment); markProcessed(rawJudgment); return judgmentWithCorrectionList; }  @Override JudgmentWithCorrectionList<CommonCourtJudgment> process(RawSourceCcJudgment rawJudgment); @Autowired void setRawSourceCcjConverter(RawSourceCcJudgmentConverter rawSourceCcJudgmentConverter); @Autowired void setCcjProcessingService(CcjProcessingService ccjProcessingService); @Autowired void setRawSourceCcJudgmentRepository(RawSourceCcJudgmentRepository rawSourceCcJudgmentRepository);  }