Skip to content

Commit

Permalink
Merge pull request #9 from kusitms-28th-Meetup-E/feat/batch
Browse files Browse the repository at this point in the history
feat(#1) : scheduled cron Log
  • Loading branch information
eojinny authored Nov 14, 2023
2 parents 890e25c + fa295fc commit 27a63ba
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 7 deletions.
3 changes: 3 additions & 0 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -85,6 +85,9 @@ dependencies {

implementation "org.springframework.boot:spring-boot-starter-quartz"

implementation 'commons-logging:commons-logging:1.2'
implementation group: 'log4j', name: 'log4j', version: '1.2.17'

}

dependencyManagement {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,43 +21,46 @@
@RestController
@RequestMapping("/keyword")
@RequiredArgsConstructor
@Log4j

public class MorphemeController {
private static final Logger logger = (Logger) LoggerFactory.getLogger(MorphemeController.class);

private final NewsAPIService newsAPIService;
private final MorphemeService morphemeService;
//@GetMapping("/analysis/{msg}")

//@Scheduled(cron = "55 3 * * 2")
@GetMapping("/test")
public String analysis() throws JsonProcessingException {
logger.info("ASYNC Start");
System.out.println("ASYNC Start");
String newsList1 = newsAPIService.naverAPI("주 69시간 근로시간 제도 개편");
String newsList2 = newsAPIService.naverAPI("이태원 참사");
String newsList3 = newsAPIService.naverAPI("국민연금 개혁");

asyncMethodNews(newsList1);
asyncMethodNews2(newsList2);
asyncMethodNews3(newsList3);
logger.info("End");
System.out.println("ASYNC END");
return "success";
}
@Async
public void asyncMethodNews(String newsList1) throws JsonProcessingException {
logger.info("ASYNC Start 1");
System.out.println("ASYNC Start 1");
List<Token> newsAnalysis1 =newsAPIService.analysis(newsList1);
System.out.println("ASYNC END");
morphemeService.saveOrUpdateWord(newsAnalysis1, 100 );
}
@Async
public void asyncMethodNews2(String newsList2) throws JsonProcessingException {
logger.info("ASYNC Start 2");
System.out.println("ASYNC Start 2");
List<Token> newsAnalysis2 =newsAPIService.analysis(newsList2);
System.out.println("ASYNC END");
morphemeService.saveOrUpdateWord(newsAnalysis2, 200);
}
@Async
public void asyncMethodNews3(String newsList3) throws JsonProcessingException {
logger.info("ASYNC Start 3");
System.out.println("ASYNC Start 3");
List<Token> newsAnalysis3 =newsAPIService.analysis(newsList3);
System.out.println("ASYNC END");
morphemeService.saveOrUpdateWord(newsAnalysis3, 300);
}
}

0 comments on commit 27a63ba

Please sign in to comment.