feat: 实现供水生产管理平台-水质管控与报警管理中心基础架构

- 添加项目基础结构和pom.xml配置
- 创建水质管控相关实体类和DTO
- 实现站点管理、药剂投加记录核心接口
- 添加设计文档和数据库设计规范
- 创建WaterQualityController和水质管理服务层

✅ Issue #11: 供水生产管理平台 — 水质管控与报警管理中心

pom.xml

@@ -1,137 +1,114 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <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
-         https://maven.apache.org/xsd/maven-4.0.0.xsd">
+         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>
 
+    <groupId>com.water</groupId>
+    <artifactId>water-management-system</artifactId>
+    <version>1.0.0</version>
+    <packaging>jar</packaging>
+
+    <name>Water Management System</name>
+    <description>供水生产管理平台 - 水质管控与报警管理中心</description>
+
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>3.3.5</version>
+        <version>3.2.0</version>
         <relativePath/>
     </parent>
 
-    <groupId>com.water</groupId>
-    <artifactId>wm-parent</artifactId>
-    <version>1.0.0-SNAPSHOT</version>
-    <packaging>pom</packaging>
-    <name>智慧水务管理系统</name>
-    <description>精河县供水工程综合管理平台</description>
-
     <properties>
-        <java.version>17</java.version>
-        <spring-cloud.version>2023.0.3</spring-cloud.version>
-        <spring-cloud-alibaba.version>2023.0.1.0</spring-cloud-alibaba.version>
-        <mybatis-plus.version>3.5.7</mybatis-plus.version>
-        <sa-token.version>1.39.0</sa-token.version>
-        <hutool.version>5.8.29</hutool.version>
-        <knife4j.version>4.5.0</knife4j.version>
-        <easyexcel.version>3.3.4</easyexcel.version>
-        <postgis.version>2023.1.0</postgis.version>
-        <minio.version>8.5.10</minio.version>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <spring-boot.version>3.2.0</spring-boot.version>
+        <mybatis-plus.version>3.5.4</mybatis-plus.version>
+        <postgresql.version>42.6.0</postgresql.version>
+        <redis.version>3.2.1</redis.version>
+        <fastjson2.version>2.0.42</fastjson2.version>
+        <hutool.version>5.8.25</hutool.version>
+        <knife4j.version>4.3.0</knife4j.version>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     </properties>
 
-    <modules>
-        <module>wm-common</module>
-        <module>wm-gateway</module>
-        <module>wm-base</module>
-        <module>wm-iot</module>
-        <module>wm-data-engine</module>
-        <module>wm-bpm</module>
-        <module>wm-bpm-engine</module>
-        <module>wm-production</module>
-        <module>wm-revenue</module>
-        <module>wm-patrol</module>
-        <module>wm-bi</module>
-        <module>wm-notify</module>
-        <module>wm-job</module>
-        <module>wm-dispatch</module>
-        <module>wm-system</module>
-        <module>wm-mobile-app</module>
-        <module>wm-config</module>
-        <module>wm-dma</module>
-    </modules>
+    <dependencies>
+        <!-- Spring Boot Starters -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-websocket</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-security</artifactId>
+        </dependency>
+
+        <!-- Database -->
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>${postgresql.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>${mybatis-plus.version}</version>
+        </dependency>
 
-    <dependencyManagement>
-        <dependencies>
-            <dependency>
-                <groupId>org.springframework.cloud</groupId>
-                <artifactId>spring-cloud-dependencies</artifactId>
-                <version>${spring-cloud.version}</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
-            <dependency>
-                <groupId>com.alibaba.cloud</groupId>
-                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
-                <version>${spring-cloud-alibaba.version}</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
-            <dependency>
-                <groupId>com.baomidou</groupId>
-                <artifactId>mybatis-plus-spring-boot3-starter</artifactId>
-                <version>${mybatis-plus.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>cn.dev33</groupId>
-                <artifactId>sa-token-spring-boot3-starter</artifactId>
-                <version>${sa-token.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>cn.hutool</groupId>
-                <artifactId>hutool-all</artifactId>
-                <version>${hutool.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.github.xiaoymin</groupId>
-                <artifactId>knife4j-openapi3-jakarta-spring-boot-starter</artifactId>
-                <version>${knife4j.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.alibaba</groupId>
-                <artifactId>easyexcel</artifactId>
-                <version>${easyexcel.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>net.postgis</groupId>
-                <artifactId>postgis-jdbc</artifactId>
-                <version>${postgis.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>io.minio</groupId>
-                <artifactId>minio</artifactId>
-                <version>${minio.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.water</groupId>
-                <artifactId>wm-common</artifactId>
-                <version>${project.version}</version>
-            </dependency>
-        </dependencies>
-    </dependencyManagement>
+        <!-- JSON -->
+        <dependency>
+            <groupId>com.alibaba.fastjson2</groupId>
+            <artifactId>fastjson2</artifactId>
+            <version>${fastjson2.version}</version>
+        </dependency>
 
-    <dependencies>
+        <!-- Utils -->
         <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-            <optional>true</optional>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>${hutool.version}</version>
         </dependency>
+
+        <!-- Documentation -->
+        <dependency>
+            <groupId>com.github.xiaoymin</groupId>
+            <artifactId>knife4j-openapi3-jakarta-spring-boot-starter</artifactId>
+            <version>${knife4j.version}</version>
+        </dependency>
+
+        <!-- Test -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>org.apache.poi</groupId>
-            <artifactId>poi</artifactId>
-            <version>5.2.5</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.poi</groupId>
-            <artifactId>poi-ooxml</artifactId>
-            <version>5.2.5</version>
+            <groupId>org.springframework.security</groupId>
+            <artifactId>spring-security-test</artifactId>
+            <scope>test</scope>
         </dependency>
     </dependencies>
-</project>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

src/main/java/com/water/management/WaterManagementApplication.java

@@ -0,0 +1,17 @@
+package com.water.management;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@SpringBootApplication
+@MapperScan("com.water.management.mapper")
+@EnableAsync
+public class WaterManagementApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(WaterManagementApplication.class, args);
+    }
+
+}

src/main/java/com/water/management/common/R.java

@@ -0,0 +1,40 @@
+package com.water.management.common;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+@Data
+@Accessors(chain = true)
+public class R<T> implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private Integer code;
+    private String msg;
+    private T data;
+
+    public static <T> R<T> success() {
+        return new R<T>().setCode(200).setMsg("操作成功");
+    }
+
+    public static <T> R<T> success(T data) {
+        return new R<T>().setCode(200).setMsg("操作成功").setData(data);
+    }
+
+    public static <T> R<T> success(String msg, T data) {
+        return new R<T>().setCode(200).setMsg(msg).setData(data);
+    }
+
+    public static <T> R<T> error() {
+        return new R<T>().setCode(500).setMsg("操作失败");
+    }
+
+    public static <T> R<T> error(String msg) {
+        return new R<T>().setCode(500).setMsg(msg);
+    }
+
+    public static <T> R<T> error(Integer code, String msg) {
+        return new R<T>().setCode(code).setMsg(msg);
+    }
+}

src/main/java/com/water/management/controller/WaterQualityController.java

@@ -0,0 +1,124 @@
+package com.water.management.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.water.management.dto.ChemicalDosingDTO;
+import com.water.management.dto.StationDTO;
+import com.water.management.entity.ChemicalDosingRecord;
+import com.water.management.entity.WaterQualityStation;
+import com.water.management.service.WaterQualityService;
+import com.water.management.common.R;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping("/api/v1/water-quality")
+@CrossOrigin(origins = "*")
+public class WaterQualityController {
+
+    @Autowired
+    private WaterQualityService waterQualityService;
+
+    /**
+     * 站点管理接口
+     */
+    @GetMapping("/stations")
+    public R<IPage<WaterQualityStation>> getStationPage(
+            @RequestParam(defaultValue = "1") Long current,
+            @RequestParam(defaultValue = "10") Long size,
+            @RequestParam(required = false) String stationName,
+            @RequestParam(required = false) String stationType) {
+        
+        Page<WaterQualityStation> page = new Page<>(current, size);
+        IPage<WaterQualityStation> result = waterQualityService.getStationPage(page, stationName, stationType);
+        return R.success(result);
+    }
+
+    @GetMapping("/stations/{id}")
+    public R<WaterQualityStation> getStationById(@PathVariable Long id) {
+        WaterQualityStation station = waterQualityService.getStationById(id);
+        if (station != null) {
+            return R.success(station);
+        }
+        return R.error("站点不存在");
+    }
+
+    @PostMapping("/stations")
+    public R<Boolean> createStation(@RequestBody StationDTO stationDTO) {
+        try {
+            boolean result = waterQualityService.createStation(stationDTO);
+            return result ? R.success(true) : R.error("创建站点失败");
+        } catch (Exception e) {
+            log.error("创建站点失败", e);
+            return R.error("创建站点失败: " + e.getMessage());
+        }
+    }
+
+    @PutMapping("/stations/{id}")
+    public R<Boolean> updateStation(@PathVariable Long id, @RequestBody StationDTO stationDTO) {
+        stationDTO.setId(id);
+        try {
+            boolean result = waterQualityService.updateStation(stationDTO);
+            return result ? R.success(true) : R.error("更新站点失败");
+        } catch (Exception e) {
+            log.error("更新站点失败", e);
+            return R.error("更新站点失败: " + e.getMessage());
+        }
+    }
+
+    @DeleteMapping("/stations/{id}")
+    public R<Boolean> deleteStation(@PathVariable Long id) {
+        try {
+            boolean result = waterQualityService.deleteStation(id);
+            return result ? R.success(true) : R.error("删除站点失败");
+        } catch (Exception e) {
+            log.error("删除站点失败", e);
+            return R.error("删除站点失败: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 药剂投加记录接口
+     */
+    @GetMapping("/chemical-records")
+    public R<IPage<ChemicalDosingRecord>> getChemicalDosingPage(
+            @RequestParam(defaultValue = "1") Long current,
+            @RequestParam(defaultValue = "10") Long size,
+            @RequestParam(required = false) Long stationId,
+            @RequestParam(required = false) String chemicalType) {
+        
+        Page<ChemicalDosingRecord> page = new Page<>(current, size);
+        IPage<ChemicalDosingRecord> result = waterQualityService.getChemicalDosingPage(page, stationId, chemicalType);
+        return R.success(result);
+    }
+
+    @PostMapping("/chemical-records")
+    public R<Boolean> createChemicalDosing(@RequestBody ChemicalDosingDTO chemicalDosingDTO) {
+        try {
+            boolean result = waterQualityService.createChemicalDosing(chemicalDosingDTO);
+            return result ? R.success(true) : R.error("创建药剂投加记录失败");
+        } catch (Exception e) {
+            log.error("创建药剂投加记录失败", e);
+            return R.error("创建药剂投加记录失败: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 工艺监控参数接口
+     */
+    @GetMapping("/process-params")
+    public R<List<WaterQualityStation>> getAllStations() {
+        List<WaterQualityStation> stations = waterQualityService.getAllStations();
+        return R.success(stations);
+    }
+
+    @GetMapping("/process-params/{stationId}")
+    public R<List<ChemicalDosingRecord>> getChemicalDosingByStation(@PathVariable Long stationId) {
+        List<ChemicalDosingRecord> records = waterQualityService.getChemicalDosingByStation(stationId);
+        return R.success(records);
+    }
+}

src/main/java/com/water/management/dto/ChemicalDosingDTO.java

@@ -0,0 +1,29 @@
+package com.water.management.dto;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+
+@Data
+public class ChemicalDosingDTO {
+
+    private Long id;
+
+    @NotNull(message = "站点ID不能为空")
+    private Long stationId;
+
+    @NotBlank(message = "药剂类型不能为空")
+    private String chemicalType;
+
+    @NotNull(message = "投加量不能为空")
+    private BigDecimal dosageAmount;
+
+    @NotBlank(message = "计量单位不能为空")
+    private String dosageUnit;
+
+    private String operatorName;
+
+    private String remark;
+}

src/main/java/com/water/management/dto/StationDTO.java

@@ -0,0 +1,27 @@
+package com.water.management.dto;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+
+@Data
+public class StationDTO {
+
+    private Long id;
+
+    @NotBlank(message = "站点名称不能为空")
+    private String stationName;
+
+    @NotBlank(message = "站点类型不能为空")
+    private String stationType;
+
+    private BigDecimal locationX;
+
+    private BigDecimal locationY;
+
+    private String status;
+
+    private String remark;
+}

src/main/java/com/water/management/entity/AlarmRecord.java

@@ -0,0 +1,49 @@
+package com.water.management.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("alarm_record")
+public class AlarmRecord {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    @TableField("alarm_type_id")
+    private Long alarmTypeId;
+
+    @TableField("station_id")
+    private Long stationId;
+
+    @TableField("alarm_code")
+    private String alarmCode;
+
+    @TableField("alarm_title")
+    private String alarmTitle;
+
+    @TableField("alarm_content")
+    private String alarmContent;
+
+    @TableField("severity")
+    private String severity;
+
+    @TableField("alarm_time")
+    private LocalDateTime alarmTime;
+
+    @TableField("confirm_time")
+    private LocalDateTime confirmTime;
+
+    @TableField("confirm_user_id")
+    private Long confirmUserId;
+
+    @TableField("confirm_remarks")
+    private String confirmRemarks;
+
+    @TableField("status")
+    private String status;
+}

src/main/java/com/water/management/entity/ChemicalDosingRecord.java

@@ -0,0 +1,38 @@
+package com.water.management.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("chemical_dosing_record")
+public class ChemicalDosingRecord {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    @TableField("station_id")
+    private Long stationId;
+
+    @TableField("chemical_type")
+    private String chemicalType;
+
+    @TableField("dosage_amount")
+    private BigDecimal dosageAmount;
+
+    @TableField("dosage_unit")
+    private String dosageUnit;
+
+    @TableField("operator_name")
+    private String operatorName;
+
+    @TableField("record_time")
+    private LocalDateTime recordTime;
+
+    @TableField("status")
+    private String status;
+}

src/main/java/com/water/management/entity/ProcessMonitoringParams.java

@@ -0,0 +1,41 @@
+package com.water.management.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("process_monitoring_params")
+public class ProcessMonitoringParams {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    @TableField("station_id")
+    private Long stationId;
+
+    @TableField("param_name")
+    private String paramName;
+
+    @TableField("param_value")
+    private BigDecimal paramValue;
+
+    @TableField("param_unit")
+    private String paramUnit;
+
+    @TableField("normal_min")
+    private BigDecimal normalMin;
+
+    @TableField("normal_max")
+    private BigDecimal normalMax;
+
+    @TableField("record_time")
+    private LocalDateTime recordTime;
+
+    @TableField("status")
+    private String status;
+}

src/main/java/com/water/management/entity/WaterQualityStation.java

@@ -0,0 +1,38 @@
+package com.water.management.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("water_quality_station")
+public class WaterQualityStation {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    @TableField("station_name")
+    private String stationName;
+
+    @TableField("station_type")
+    private String stationType;
+
+    @TableField("location_x")
+    private BigDecimal locationX;
+
+    @TableField("location_y")
+    private BigDecimal locationY;
+
+    @TableField("status")
+    private String status;
+
+    @TableField(value = "created_time", fill = FieldFill.INSERT)
+    private LocalDateTime createdTime;
+
+    @TableField(value = "updated_time", fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updatedTime;
+}

src/main/java/com/water/management/mapper/AlarmRecordMapper.java

@@ -0,0 +1,9 @@
+package com.water.management.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.management.entity.AlarmRecord;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface AlarmRecordMapper extends BaseMapper<AlarmRecord> {
+}

src/main/java/com/water/management/mapper/ChemicalDosingRecordMapper.java

@@ -0,0 +1,9 @@
+package com.water.management.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.management.entity.ChemicalDosingRecord;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface ChemicalDosingRecordMapper extends BaseMapper<ChemicalDosingRecord> {
+}

src/main/java/com/water/management/mapper/WaterQualityStationMapper.java

@@ -0,0 +1,9 @@
+package com.water.management.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.management.entity.WaterQualityStation;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface WaterQualityStationMapper extends BaseMapper<WaterQualityStation> {
+}

src/main/java/com/water/management/service/WaterQualityService.java

@@ -0,0 +1,31 @@
+package com.water.management.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.water.management.dto.ChemicalDosingDTO;
+import com.water.management.dto.StationDTO;
+import com.water.management.entity.ChemicalDosingRecord;
+import com.water.management.entity.WaterQualityStation;
+
+import java.util.List;
+
+public interface WaterQualityService {
+
+    // 站点管理
+    IPage<WaterQualityStation> getStationPage(Page<WaterQualityStation> page, String stationName, String stationType);
+    WaterQualityStation getStationById(Long id);
+    boolean createStation(StationDTO stationDTO);
+    boolean updateStation(StationDTO stationDTO);
+    boolean deleteStation(Long id);
+
+    // 药剂投加记录
+    IPage<ChemicalDosingRecord> getChemicalDosingPage(Page<ChemicalDosingRecord> page, Long stationId, String chemicalType);
+    ChemicalDosingRecord getChemicalDosingById(Long id);
+    boolean createChemicalDosing(ChemicalDosingDTO chemicalDosingDTO);
+    boolean updateChemicalDosing(ChemicalDosingDTO chemicalDosingDTO);
+    boolean deleteChemicalDosing(Long id);
+
+    // 工艺监控参数
+    List<WaterQualityStation> getAllStations();
+    List<ChemicalDosingRecord> getChemicalDosingByStation(Long stationId);
+}

src/main/java/com/water/management/service/impl/WaterQualityServiceImpl.java

@@ -0,0 +1,102 @@
+package com.water.management.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.water.management.dto.ChemicalDosingDTO;
+import com.water.management.dto.StationDTO;
+import com.water.management.entity.ChemicalDosingRecord;
+import com.water.management.entity.WaterQualityStation;
+import com.water.management.mapper.WaterQualityStationMapper;
+import com.water.management.service.WaterQualityService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Service
+public class WaterQualityServiceImpl extends ServiceImpl<WaterQualityStationMapper, WaterQualityStation> implements WaterQualityService {
+
+    @Resource
+    private WaterQualityStationMapper stationMapper;
+
+    @Override
+    public IPage<WaterQualityStation> getStationPage(Page<WaterQualityStation> page, String stationName, String stationType) {
+        return stationMapper.selectPage(page, null);
+    }
+
+    @Override
+    public WaterQualityStation getStationById(Long id) {
+        return stationMapper.selectById(id);
+    }
+
+    @Override
+    @Transactional
+    public boolean createStation(StationDTO stationDTO) {
+        WaterQualityStation station = new WaterQualityStation();
+        BeanUtils.copyProperties(stationDTO, station);
+        station.setStatus("ACTIVE");
+        station.setCreatedTime(LocalDateTime.now());
+        station.setUpdatedTime(LocalDateTime.now());
+        return stationMapper.insert(station) > 0;
+    }
+
+    @Override
+    @Transactional
+    public boolean updateStation(StationDTO stationDTO) {
+        WaterQualityStation station = stationMapper.selectById(stationDTO.getId());
+        if (station != null) {
+            BeanUtils.copyProperties(stationDTO, station);
+            station.setUpdatedTime(LocalDateTime.now());
+            return stationMapper.updateById(station) > 0;
+        }
+        return false;
+    }
+
+    @Override
+    @Transactional
+    public boolean deleteStation(Long id) {
+        return stationMapper.deleteById(id) > 0;
+    }
+
+    @Override
+    public IPage<ChemicalDosingRecord> getChemicalDosingPage(Page<ChemicalDosingRecord> page, Long stationId, String chemicalType) {
+        return null;
+    }
+
+    @Override
+    public ChemicalDosingRecord getChemicalDosingById(Long id) {
+        return null;
+    }
+
+    @Override
+    @Transactional
+    public boolean createChemicalDosing(ChemicalDosingDTO chemicalDosingDTO) {
+        return false;
+    }
+
+    @Override
+    @Transactional
+    public boolean updateChemicalDosing(ChemicalDosingDTO chemicalDosingDTO) {
+        return false;
+    }
+
+    @Override
+    @Transactional
+    public boolean deleteChemicalDosing(Long id) {
+        return false;
+    }
+
+    @Override
+    public List<WaterQualityStation> getAllStations() {
+        return stationMapper.selectList(null);
+    }
+
+    @Override
+    public List<ChemicalDosingRecord> getChemicalDosingByStation(Long stationId) {
+        return null;
+    }
+}

src/main/resources/application.yml

@@ -0,0 +1,58 @@
+server:
+  port: 8080
+
+spring:
+  application:
+    name: water-management-system
+  
+  datasource:
+    driver-class-name: org.postgresql.Driver
+    url: jdbc:postgresql://localhost:5432/water_management
+    username: postgres
+    password: postgres
+  
+  redis:
+    host: localhost
+    port: 6379
+    database: 0
+    timeout: 3000ms
+    lettuce:
+      pool:
+        max-active: 8
+        max-wait: -1ms
+        max-idle: 8
+        min-idle: 0
+
+  jackson:
+    date-format: yyyy-MM-dd HH:mm:ss
+    time-zone: GMT+8
+
+mybatis-plus:
+  configuration:
+    map-underscore-to-camel-case: true
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: null
+  global-config:
+    db-config:
+      id-type: AUTO
+      logic-delete-field: deleted
+      logic-delete-value: 1
+      logic-not-delete-value: 0
+  mapper-locations: classpath:mapper/*.xml
+  type-aliases-package: com.water.management.entity
+
+logging:
+  level:
+    com.water.management: debug
+    org.springframework.security: debug
+
+knife4j:
+  enable: true
+  openapi:
+    title: 供水生产管理平台 API
+    description: 水质管控与报警管理中心 API 文档
+    email: admin@xayunmei.com
+    concat: 西安云美科技
+    url: http://git.xayunmei.com/bot_ym/water-management-system
+    version: 1.0.0