WebFlux 实战城市管理系统

springboot-webflux-10-book-manage-sys/pom.xml

@@ -2,7 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <description>WebFlux 实战图书管理系统</description>
+    <description>WebFlux 实战城市管理系统</description>
 
     <groupId>demo.springboot</groupId>
     <artifactId>springboot-webflux-10-book-manage-sys</artifactId>

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/dao/BookRepository.java → springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/dao/CityRepository.java

@@ -1,10 +1,10 @@
 package demo.springboot.dao;
 
-import demo.springboot.domain.Book;
+import demo.springboot.domain.City;
 import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
 import org.springframework.stereotype.Repository;
 
 @Repository
-public interface BookRepository extends ReactiveMongoRepository<Book, Long> {
+public interface CityRepository extends ReactiveMongoRepository<City, Long> {
 
 }

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/domain/City.java

@@ -0,0 +1,60 @@
+package demo.springboot.domain;
+
+/**
+ * 城市实体类
+ *
+ */
+public class City {
+
+    /**
+     * 城市编号
+     */
+    private Long id;
+
+    /**
+     * 省份编号
+     */
+    private Long provinceId;
+
+    /**
+     * 城市名称
+     */
+    private String cityName;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getProvinceId() {
+        return provinceId;
+    }
+
+    public void setProvinceId(Long provinceId) {
+        this.provinceId = provinceId;
+    }
+
+    public String getCityName() {
+        return cityName;
+    }
+
+    public void setCityName(String cityName) {
+        this.cityName = cityName;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/service/CityService.java

@@ -0,0 +1,18 @@
+package demo.springboot.service;
+
+import demo.springboot.domain.City;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface CityService {
+
+    Flux<City> findAll();
+
+    Mono<City> insertByCity(City city);
+
+    Mono<City> update(City city);
+
+    Mono<Void> delete(Long id);
+
+    Mono<City> findById(Long id);
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/service/impl/CityServiceImpl.java

@@ -0,0 +1,45 @@
+package demo.springboot.service.impl;
+
+import demo.springboot.dao.CityRepository;
+import demo.springboot.domain.City;
+import demo.springboot.service.CityService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Component
+public class CityServiceImpl implements CityService {
+
+    private final CityRepository cityRepository;
+
+    @Autowired
+    public CityServiceImpl(CityRepository cityRepository) {
+        this.cityRepository = cityRepository;
+    }
+
+    @Override
+    public Flux<City> findAll() {
+        return cityRepository.findAll();
+    }
+
+    @Override
+    public Mono<City> insertByCity(City city) {
+        return cityRepository.save(city);
+    }
+
+    @Override
+    public Mono<City> update(City city) {
+        return cityRepository.save(city);
+    }
+
+    @Override
+    public Mono<Void> delete(Long id) {
+        return cityRepository.deleteById(id);
+    }
+
+    @Override
+    public Mono<City> findById(Long id) {
+        return cityRepository.findById(id);
+    }
+}