删除空气质量信息~

src/main/java/com/mashibing/controller/AirController.java

@@ -9,12 +9,10 @@ import com.mashibing.util.R;
 import com.mashibing.vo.ResultVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;
+import javax.websocket.server.PathParam;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -141,4 +139,37 @@ public class AirController {
         //3、返回
         return R.ok();
     }
+
+
+    /**
+     * # 删除空气质量信息
+     * # 请求方式&路径
+     * DELETE	http://localhost:8080/air/delete/{id}
+     *
+     * # 请求参数
+     * 路径上的id
+     *
+     * # 业务流程
+     * 1、接收参数
+     * 2、删除指定id的数据
+     *
+     * # 响应数据
+     * 成功响应：
+     * {
+     *   "code": 0,
+     *   "msg": ""
+     * }
+     * 失败响应：
+     * {
+     *   "code": 错误编码,
+     *   "msg": "错误信息"
+     * }
+     */
+    @DeleteMapping("/air/delete/{id}")
+    public ResultVO airDelete(@PathVariable Integer id){
+        //1、调用service删除
+        airService.deleteById(id);
+        //2、响应数据
+        return R.ok();
+    }
 }

src/main/java/com/mashibing/mapper/AirMapper.java

@@ -1,6 +1,7 @@
 package com.mashibing.mapper;
 
 import com.mashibing.entity.Air;
+import org.apache.ibatis.annotations.Delete;
 import org.apache.ibatis.annotations.Insert;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Update;
@@ -23,4 +24,7 @@ public interface AirMapper {
     // 修改数据
     @Update("update air set district_id = #{districtId},monitor_time = #{monitorTime},pm10 = #{pm10},pm25 = #{pm25},monitoring_station = #{monitoringStation} where id = #{id}")
     int updateById(Air air);
+
+    @Delete("delete from air where id = #{id}")
+    int deleteById(@Param("id") Integer id);
 }

src/main/java/com/mashibing/service/AirService.java

@@ -38,4 +38,10 @@ public interface AirService {
      * @param air
      */
     void updateById(Air air);
+
+    /**
+     * 删除空气质量信息
+     * @param id
+     */
+    void deleteById(Integer id);
 }

src/main/java/com/mashibing/service/impl/AirServiceImpl.java

@@ -65,6 +65,7 @@ public class AirServiceImpl implements AirService {
     }
 
     @Override
+    @Transactional
     public void updateById(Air air) {
         //1、修改数据
         int count = airMapper.updateById(air);
@@ -74,4 +75,16 @@ public class AirServiceImpl implements AirService {
             throw new RuntimeException("【修改空气质量】  修改失败！！");
         }
     }
+
+    @Override
+    @Transactional
+    public void deleteById(Integer id) {
+        // 删除
+        int count = airMapper.deleteById(id);
+        // 判断
+        if (count != 1) {
+            System.out.println("【删除空气质量】  删除失败！！");
+            throw new RuntimeException("【删除空气质量】  删除失败！！");
+        }
+    }
 }

src/test/java/com/mashibing/mapper/AirMapperTest.java

@@ -54,4 +54,9 @@ class AirMapperTest {
         air.setMonitoringStation("长沙监测站！!!！");
         airMapper.updateById(air);
     }
+
+    @Test
+    public void deleteById(){
+        airMapper.deleteById(71);
+    }
 }

src/test/java/com/mashibing/service/AirServiceTest.java

@@ -60,4 +60,9 @@ public class AirServiceTest {
         air.setMonitoringStation("北京监测站！!!！");
         airService.updateById(air);
     }
+
+    @Test
+    public void deleteById(){
+        airService.deleteById(70);
+    }
 }