Xem toàn bộ series bài viết hướng dẫn xây dựng ứng dụng Questions Management tại đây.
Trong bài viết trước, chúng ta đã chuẩn bị tất cả các cấu hình cần thiết để có thể xây dựng API xoá question trong Composite Question Service như: một đối tượng chứa tất cả các thông tin của một câu hỏi CompositeQuestion bao gồm Question, Category và Option; một interface CoreCategoryService với implementation là CoreCategoryServiceImpl đảm nhận việc thao tác với Core Category Service; một interface CoreQuestionService với implementation là CoreQuestionServiceImpl đảm nhận việc thao tác với Core Question Service; một interface CoreOptionService với implementation là CoreOptionServiceImpl đảm nhận việc thao tác với Core Option Service; một interface CompositeQuestionService đảm nhận việc thao tác với các Core Service; một CompositeQuestionController định nghĩa các API của Composite Question Service sẽ bắt đầu với “/question” và thông tin của các Core Service được cấu hình trong tập tin application.properties. Bây giờ, chúng ta sẽ tiến hành xây dựng API này các bạn nhé!
Đầu tiên, mình sẽ nói về ý tưởng để xoá một question trước. Để xoá một question từ Composite Question Service, chúng ta sẽ cần gọi tới Core Question Service để xoá question này và cũng cần phải gọi tới Core Option Service để xoá tất cả các option thuộc về question đó. Cụ thể như thế nào, các bạn đọc tiếp nhé!
Mình sẽ định nghĩa mới một method trong CoreQuestionService đảm nhận việc gọi tới API của Core Question Service để xoá question như sau:
|
1 |
Mono<Void> deleteById(String questionId); |
Implementation của method này trong class CoreQuestionServiceImpl sẽ như sau:
|
1 2 3 4 5 6 7 8 9 10 11 |
@Override public Mono<Void> deleteById(String questionId) { WebClient webClient = WebClient.builder() .baseUrl(getServiceUrl()) .build(); return webClient.delete() .uri("/question/" + questionId) .retrieve() .bodyToMono(Void.class); } |
Tiếp theo, mình sẽ định nghĩa mới một method trong CoreOptionService đảm nhận việc gọi tới API của Core Option Service để xoá tất cả các option thuộc về question này như sau:
|
1 |
Mono<Void> deleteByQuestionId(String questionId); |
Implementation của method này trong class CoreOptionServiceImpl sẽ như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 |
@Override public Mono<Void> deleteByQuestionId(String questionId) { WebClient client = WebClient.builder() .baseUrl(getServiceUrl()) .build(); WebClient.ResponseSpec responseSpec = client.delete() .uri("/option?questionId=" + questionId) .retrieve(); return responseSpec.bodyToMono(Void.class); } |
Tiếp theo nữa, mình cũng sẽ định nghĩa một method trong CompositeQuestionService để combine việc gọi tới Core Question Service và Core Option Service để xoá question như sau:
|
1 |
Mono<Void> deleteById(String questionId); |
Implementation của method này trong class CompositeQuestionServiceImpl sẽ như sau:
|
1 2 3 4 5 6 |
@Override public Mono<Void> deleteById(String questionId) { return coreQuestionService.deleteById(questionId) .flatMap(v -> coreOptionService.deleteByQuestionId(questionId)) .subscribeOn(Schedulers.elastic()); } |
Như các bạn thấy, mình đã gọi qua Core Question Service trước, trong trường hợp có thể xoá question trong service này, chúng ta mới gọi qua Core Option Service để thực hiện xoá các option tiếp.
Điều cuối cùng chúng ta cần làm đó là thêm mới một method vào class CompositeQuestionController để expose một DELETE request “/{id}” với id là id của question mà chúng ta cần xoá.
|
1 2 3 4 |
@DeleteMapping("/{id}") public Mono<ResponseEntity<Void>> deleteQuestion(@PathVariable(value = "id") String questionId) { } |
Việc chúng ta chỉ là gọi tới method deleteById() của class CompositeQuestionService mà thôi:
|
1 2 3 4 5 6 |
@DeleteMapping("/{id}") public Mono<ResponseEntity<Void>> deleteQuestion(@PathVariable(value = "id") String questionId) { return compositeQuestionService.deleteById(questionId) .then(Mono.just(new ResponseEntity<Void>(HttpStatus.OK))) .defaultIfEmpty(ResponseEntity.notFound().build()); } |
OK, đến đây là chúng ta đã hoàn thành việc xây dựng API xoá question cho Composite Question Service rồi đó các bạn. Test thử xem sao nhé.
Giả sử hiện tại mình đang có những question như sau:
Nếu bây giờ mình xoá question với id là 5b810abbbd264712e80d7f29 thì kết quả sẽ như sau:
