parent
6ca768b26b
commit
cd459f4952
@ -0,0 +1,29 @@
|
||||
### IntelliJ IDEA ###
|
||||
out/
|
||||
!**/src/main/**/out/
|
||||
!**/src/test/**/out/
|
||||
|
||||
### Eclipse ###
|
||||
.apt_generated
|
||||
.classpath
|
||||
.factorypath
|
||||
.project
|
||||
.settings
|
||||
.springBeans
|
||||
.sts4-cache
|
||||
bin/
|
||||
!**/src/main/**/bin/
|
||||
!**/src/test/**/bin/
|
||||
|
||||
### NetBeans ###
|
||||
/nbproject/private/
|
||||
/nbbuild/
|
||||
/dist/
|
||||
/nbdist/
|
||||
/.nb-gradle/
|
||||
|
||||
### VS Code ###
|
||||
.vscode/
|
||||
|
||||
### Mac OS ###
|
||||
.DS_Store
|
||||
@ -0,0 +1,8 @@
|
||||
# 默认忽略的文件
|
||||
/shelf/
|
||||
/workspace.xml
|
||||
# 基于编辑器的 HTTP 客户端请求
|
||||
/httpRequests/
|
||||
# Datasource local storage ignored files
|
||||
/dataSources/
|
||||
/dataSources.local.xml
|
||||
@ -0,0 +1,13 @@
|
||||
<component name="ArtifactManager">
|
||||
<artifact type="exploded-war" name="WaterFare:war exploded">
|
||||
<output-path>$PROJECT_DIR$/out/artifacts/WaterFare_war_exploded</output-path>
|
||||
<root id="root">
|
||||
<element id="javaee-facet-resources" facet="WaterFare/web/Web" />
|
||||
<element id="directory" name="WEB-INF">
|
||||
<element id="directory" name="classes">
|
||||
<element id="module-output" name="WaterFare" />
|
||||
</element>
|
||||
</element>
|
||||
</root>
|
||||
</artifact>
|
||||
</component>
|
||||
@ -0,0 +1,6 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ProjectRootManager" version="2" languageLevel="JDK_20" default="true" project-jdk-name="20" project-jdk-type="JavaSDK">
|
||||
<output url="file://$PROJECT_DIR$/out" />
|
||||
</component>
|
||||
</project>
|
||||
@ -0,0 +1,8 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ProjectModuleManager">
|
||||
<modules>
|
||||
<module fileurl="file://$PROJECT_DIR$/WaterFare.iml" filepath="$PROJECT_DIR$/WaterFare.iml" />
|
||||
</modules>
|
||||
</component>
|
||||
</project>
|
||||
@ -0,0 +1,32 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<module type="JAVA_MODULE" version="4">
|
||||
<component name="FacetManager">
|
||||
<facet type="web" name="Web">
|
||||
<configuration>
|
||||
<descriptors>
|
||||
<deploymentDescriptor name="web.xml" url="file://$MODULE_DIR$/web/WEB-INF/web.xml" />
|
||||
</descriptors>
|
||||
<webroots>
|
||||
<root url="file://$MODULE_DIR$/web" relative="/" />
|
||||
</webroots>
|
||||
</configuration>
|
||||
</facet>
|
||||
</component>
|
||||
<component name="NewModuleRootManager" inherit-compiler-output="true">
|
||||
<exclude-output />
|
||||
<content url="file://$MODULE_DIR$">
|
||||
<sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
|
||||
</content>
|
||||
<orderEntry type="inheritedJdk" />
|
||||
<orderEntry type="sourceFolder" forTests="false" />
|
||||
<orderEntry type="module-library">
|
||||
<library>
|
||||
<CLASSES>
|
||||
<root url="jar://D:/mysql-connector-j-9.1.0/mysql-connector-j-9.1.0/mysql-connector-j-9.1.0.jar!/" />
|
||||
</CLASSES>
|
||||
<JAVADOC />
|
||||
<SOURCES />
|
||||
</library>
|
||||
</orderEntry>
|
||||
</component>
|
||||
</module>
|
||||
@ -0,0 +1,79 @@
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
|
||||
public class ClientService {
|
||||
|
||||
// 新增客户
|
||||
public void addClient(String customerId, String name, String address, String contact, double balance) {
|
||||
String query = "INSERT INTO 客户信息表 (客户号, 姓名, 地址, 联系方式, 结余金额) VALUES (?, ?, ?, ?, ?)";
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
PreparedStatement stmt = connection.prepareStatement(query)) {
|
||||
|
||||
stmt.setString(1, customerId);
|
||||
stmt.setString(2, name);
|
||||
stmt.setString(3, address);
|
||||
stmt.setString(4, contact);
|
||||
stmt.setDouble(5, balance);
|
||||
|
||||
stmt.executeUpdate(); // 执行插入操作
|
||||
System.out.println("客户记录已插入。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 删除客户
|
||||
public void deleteClient(String customerId) {
|
||||
String query = "DELETE FROM 客户信息表 WHERE 客户号 = ?";
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
PreparedStatement stmt = connection.prepareStatement(query)) {
|
||||
|
||||
stmt.setString(1, customerId); // 设置客户号
|
||||
stmt.executeUpdate(); // 执行删除操作
|
||||
System.out.println("客户记录已删除。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 更新客户余额
|
||||
public void updateBalance(String customerId, double amount) {
|
||||
String query = "UPDATE 客户信息表 SET 结余金额 = ? WHERE 客户号 = ?";
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
PreparedStatement stmt = connection.prepareStatement(query)) {
|
||||
|
||||
stmt.setDouble(1, amount); // 设置新余额
|
||||
stmt.setString(2, customerId); // 设置客户号
|
||||
stmt.executeUpdate(); // 执行更新操作
|
||||
System.out.println("客户余额已更新。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 查询客户信息
|
||||
public void getClientInfo(String customerId) {
|
||||
String query = "SELECT * FROM 客户信息表 WHERE 客户号 = ?";
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
PreparedStatement stmt = connection.prepareStatement(query)) {
|
||||
|
||||
stmt.setString(1, customerId); // 设置客户号
|
||||
ResultSet rs = stmt.executeQuery(); // 执行查询
|
||||
|
||||
while (rs.next()) {
|
||||
System.out.println("客户号: " + rs.getString("客户号"));
|
||||
System.out.println("姓名: " + rs.getString("姓名"));
|
||||
System.out.println("地址: " + rs.getString("地址"));
|
||||
System.out.println("联系方式: " + rs.getString("联系方式"));
|
||||
System.out.println("结余金额: " + rs.getDouble("结余金额"));
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
import java.sql.Connection;
|
||||
import java.sql.DriverManager;
|
||||
import java.sql.SQLException;
|
||||
|
||||
public class DBConnection {
|
||||
|
||||
// 数据库连接配置
|
||||
private static final String URL = "jdbc:mysql://localhost:3306/WaterFare manage System"; // 数据库名 URL 编码
|
||||
private static final String USER = "admin_user"; // 管理员用户
|
||||
private static final String PASSWORD = "admin_password"; // 密码
|
||||
|
||||
// 获取数据库连接
|
||||
public static Connection getConnection() throws SQLException {
|
||||
try {
|
||||
// 显式加载 MySQL JDBC 驱动
|
||||
Class.forName("com.mysql.cj.jdbc.Driver");
|
||||
// 返回数据库连接
|
||||
return DriverManager.getConnection(URL, USER, PASSWORD);
|
||||
} catch (ClassNotFoundException e) {
|
||||
throw new SQLException("MySQL JDBC driver not found.", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,130 @@
|
||||
import java.util.Scanner;
|
||||
import java.sql.Date;
|
||||
|
||||
public class Main {
|
||||
|
||||
public static void main(String[] args) {
|
||||
Scanner scanner = new Scanner(System.in);
|
||||
|
||||
// 服务实例化
|
||||
ClientService clientService = new ClientService();
|
||||
ViewService viewService = new ViewService();
|
||||
ProcedureService procedureService = new ProcedureService();
|
||||
|
||||
// 菜单循环
|
||||
while (true) {
|
||||
System.out.println("欢迎使用水费管理系统");
|
||||
System.out.println("1. 增加客户");
|
||||
System.out.println("2. 删除客户");
|
||||
System.out.println("3. 更新客户余额");
|
||||
System.out.println("4. 查询客户信息");
|
||||
System.out.println("5. 查询客户用水信息视图");
|
||||
System.out.println("6. 查询未收费用客户视图");
|
||||
System.out.println("7. 调用存储过程更新客户余额");
|
||||
System.out.println("8. 调用存储过程生成费用记录");
|
||||
System.out.println("9. 调用存储过程更新收费状态");
|
||||
System.out.println("10. 调用存储过程生成订单记录");
|
||||
System.out.println("11. 退出");
|
||||
System.out.print("请输入选项: ");
|
||||
|
||||
int choice = scanner.nextInt();
|
||||
|
||||
switch (choice) {
|
||||
case 1: // 增加客户
|
||||
System.out.print("请输入客户号: ");
|
||||
String addId = scanner.next();
|
||||
System.out.print("请输入姓名: ");
|
||||
String addName = scanner.next();
|
||||
System.out.print("请输入地址: ");
|
||||
String addAddress = scanner.next();
|
||||
System.out.print("请输入联系方式: ");
|
||||
String addContact = scanner.next();
|
||||
System.out.print("请输入余额: ");
|
||||
double addBalance = scanner.nextDouble();
|
||||
clientService.addClient(addId, addName, addAddress, addContact, addBalance);
|
||||
break;
|
||||
|
||||
case 2: // 删除客户
|
||||
System.out.print("请输入要删除的客户号: ");
|
||||
String delId = scanner.next();
|
||||
clientService.deleteClient(delId);
|
||||
break;
|
||||
|
||||
case 3: // 更新客户余额
|
||||
System.out.print("请输入客户号: ");
|
||||
String updateId = scanner.next();
|
||||
System.out.print("请输入新余额: ");
|
||||
double updateBalance = scanner.nextDouble();
|
||||
clientService.updateBalance(updateId, updateBalance);
|
||||
break;
|
||||
|
||||
case 4: // 查询客户信息
|
||||
System.out.print("请输入客户号: ");
|
||||
String queryId = scanner.next();
|
||||
clientService.getClientInfo(queryId);
|
||||
break;
|
||||
|
||||
case 5: // 查询客户用水信息视图
|
||||
System.out.println("查询客户用水信息视图:");
|
||||
viewService.getClientWaterUsage();
|
||||
break;
|
||||
|
||||
case 6: // 查询未收费用客户视图
|
||||
System.out.println("查询未收费用客户视图:");
|
||||
viewService.getUnpaidClients();
|
||||
break;
|
||||
|
||||
case 7: // 调用存储过程更新客户余额
|
||||
System.out.print("请输入客户号: ");
|
||||
String procUpdateId = scanner.next();
|
||||
System.out.print("请输入实收费用: ");
|
||||
double procReceivedAmount = scanner.nextDouble();
|
||||
procedureService.updateClientBalance(procUpdateId, procReceivedAmount);
|
||||
break;
|
||||
|
||||
case 8: // 调用存储过程生成费用记录
|
||||
System.out.print("请输入客户号: ");
|
||||
String procGenFeeId = scanner.next();
|
||||
System.out.print("请输入月份 (yyyy-mm-dd): ");
|
||||
String procMonthStr = scanner.next();
|
||||
Date procMonth = Date.valueOf(procMonthStr);
|
||||
System.out.print("请输入用水量: ");
|
||||
double procUsage = scanner.nextDouble();
|
||||
System.out.print("请输入水价: ");
|
||||
double procUnitPrice = scanner.nextDouble();
|
||||
procedureService.generateClientFeeRecord(procGenFeeId, procMonth, procUsage, procUnitPrice);
|
||||
break;
|
||||
|
||||
case 9: // 调用存储过程更新收费状态
|
||||
System.out.print("请输入客户号: ");
|
||||
String procFeeStatusId = scanner.next();
|
||||
System.out.print("请输入月份 (yyyy-mm-dd): ");
|
||||
String procFeeMonthStr = scanner.next();
|
||||
Date procFeeMonth = Date.valueOf(procFeeMonthStr);
|
||||
procedureService.updateFeeStatus(procFeeStatusId, procFeeMonth);
|
||||
break;
|
||||
|
||||
case 10: // 调用存储过程生成订单记录
|
||||
System.out.print("请输入客户号: ");
|
||||
String procOrderId = scanner.next();
|
||||
System.out.print("请输入月份 (yyyy-mm-dd): ");
|
||||
String procOrderMonthStr = scanner.next();
|
||||
Date procOrderMonth = Date.valueOf(procOrderMonthStr);
|
||||
System.out.print("请输入用水量: ");
|
||||
double procOrderUsage = scanner.nextDouble();
|
||||
System.out.print("请输入用水类别ID: ");
|
||||
int procOrderTypeId = scanner.nextInt();
|
||||
procedureService.generateOrderRecord(procOrderId, procOrderMonth, procOrderUsage, procOrderTypeId);
|
||||
break;
|
||||
|
||||
case 11: // 退出系统
|
||||
System.out.println("感谢使用水费管理系统，再见！");
|
||||
scanner.close();
|
||||
System.exit(0);
|
||||
|
||||
default:
|
||||
System.out.println("无效选项，请重新输入。");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,98 @@
|
||||
import java.sql.CallableStatement;
|
||||
import java.sql.Connection;
|
||||
import java.sql.SQLException;
|
||||
import java.util.Date;
|
||||
|
||||
public class ProcedureService {
|
||||
|
||||
// 调用存储过程更新客户余额
|
||||
public void updateClientBalance(String customerId, double receivedAmount) {
|
||||
String query = "{CALL 更新客户余额(?, ?)}"; // 调用存储过程
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
CallableStatement stmt = connection.prepareCall(query)) {
|
||||
|
||||
stmt.setString(1, customerId); // 设置客户号
|
||||
stmt.setDouble(2, receivedAmount); // 设置实收费用
|
||||
stmt.executeUpdate(); // 执行存储过程
|
||||
System.out.println("客户余额已更新。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 调用存储过程为客户生成费用记录
|
||||
public void generateClientFeeRecord(String customerId, Date month, double usage, double unitPrice) {
|
||||
String query = "{CALL 生成客户费用记录(?, ?, ?, ?)}"; // 存储过程的调用
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
CallableStatement stmt = connection.prepareCall(query)) {
|
||||
|
||||
// 设置存储过程参数
|
||||
stmt.setString(1, customerId); // 客户号
|
||||
stmt.setDate(2, (java.sql.Date) month); // 月份
|
||||
stmt.setDouble(3, usage); // 用水量
|
||||
stmt.setDouble(4, unitPrice); // 水价
|
||||
|
||||
// 执行存储过程
|
||||
stmt.executeUpdate();
|
||||
System.out.println("费用记录已生成。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 调用存储过程更新收费状态
|
||||
public void updateFeeStatus(String customerId, Date month) {
|
||||
String query = "{CALL 更新收费状态(?, ?)}"; // 存储过程的调用
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
CallableStatement stmt = connection.prepareCall(query)) {
|
||||
|
||||
// 设置存储过程参数
|
||||
stmt.setString(1, customerId); // 客户号
|
||||
stmt.setDate(2, (java.sql.Date) month); // 月份
|
||||
|
||||
// 执行存储过程
|
||||
stmt.executeUpdate();
|
||||
System.out.println("收费状态已更新。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 调用存储过程生成订单记录
|
||||
public void generateOrderRecord(String customerId, Date month, double usage, int typeId) {
|
||||
String query = "{CALL 生成订单记录(?, ?, ?, ?)}"; // 存储过程的调用
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
CallableStatement stmt = connection.prepareCall(query)) {
|
||||
|
||||
// 设置存储过程参数
|
||||
stmt.setString(1, customerId); // 客户号
|
||||
stmt.setDate(2, (java.sql.Date) month); // 月份
|
||||
stmt.setDouble(3, usage); // 用水量
|
||||
stmt.setInt(4, typeId); // 用水类别ID
|
||||
|
||||
// 执行存储过程
|
||||
stmt.executeUpdate();
|
||||
System.out.println("订单记录已生成。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
// 调用存储过程统计区域客户总费用
|
||||
public void getAreaClientFeeStats(String area) {
|
||||
String query = "{CALL 统计区域客户费用(?)}"; // 存储过程的调用
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
CallableStatement stmt = connection.prepareCall(query)) {
|
||||
|
||||
// 设置存储过程参数
|
||||
stmt.setString(1, area); // 区域名称
|
||||
|
||||
// 执行存储过程
|
||||
stmt.executeUpdate();
|
||||
System.out.println("区域客户总费用统计完成。");
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,123 @@
|
||||
import java.sql.*;
|
||||
|
||||
public class ViewService {
|
||||
|
||||
// 查询客户用水信息视图
|
||||
public void getClientWaterUsage() {
|
||||
String query = "SELECT * FROM 客户用水信息视图"; // 假设此视图已经创建
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
Statement stmt = connection.createStatement()) {
|
||||
|
||||
// 执行查询操作
|
||||
ResultSet rs = stmt.executeQuery(query);
|
||||
|
||||
// 输出查询结果
|
||||
while (rs.next()) {
|
||||
System.out.println("客户号: " + rs.getString("客户编号"));
|
||||
System.out.println("姓名: " + rs.getString("客户姓名"));
|
||||
System.out.println("用水类别: " + rs.getString("用水类别"));
|
||||
System.out.println("用水量: " + rs.getDouble("用水量"));
|
||||
System.out.println("用水月份: " + rs.getDate("用水月份"));
|
||||
System.out.println("=================================");
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
// 查询未收费用的客户视图
|
||||
public void getUnpaidClients() {
|
||||
String query = "SELECT * FROM 未收费用客户视图"; // 假设此视图已经创建
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
Statement stmt = connection.createStatement()) {
|
||||
|
||||
// 执行查询操作
|
||||
ResultSet rs = stmt.executeQuery(query);
|
||||
|
||||
// 输出查询结果
|
||||
while (rs.next()) {
|
||||
System.out.println("客户号: " + rs.getString("客户编号"));
|
||||
System.out.println("姓名: " + rs.getString("客户姓名"));
|
||||
System.out.println("联系方式: " + rs.getString("联系方式"));
|
||||
System.out.println("应缴月份: " + rs.getDate("应缴月份"));
|
||||
System.out.println("未缴金额: " + rs.getDouble("未缴金额"));
|
||||
System.out.println("=================================");
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
// 查询区域业务员客户分布视图
|
||||
public void getClientDistributionByArea() {
|
||||
String query = "SELECT * FROM 区域业务员客户分布视图"; // 假设此视图已经创建
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
Statement stmt = connection.createStatement()) {
|
||||
|
||||
// 执行查询操作
|
||||
ResultSet rs = stmt.executeQuery(query);
|
||||
|
||||
// 输出查询结果
|
||||
while (rs.next()) {
|
||||
System.out.println("业务员姓名: " + rs.getString("业务员姓名"));
|
||||
System.out.println("负责区域: " + rs.getString("负责区域"));
|
||||
System.out.println("客户数量: " + rs.getInt("客户数量"));
|
||||
System.out.println("总余额: " + rs.getDouble("总余额"));
|
||||
System.out.println("=================================");
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
// 查询年度客户用水统计视图
|
||||
public void getAnnualClientWaterUsage() {
|
||||
String query = "SELECT * FROM 年度客户用水统计视图"; // 假设此视图已经创建
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
Statement stmt = connection.createStatement()) {
|
||||
|
||||
// 执行查询操作
|
||||
ResultSet rs = stmt.executeQuery(query);
|
||||
|
||||
// 输出查询结果
|
||||
while (rs.next()) {
|
||||
System.out.println("客户号: " + rs.getString("客户编号"));
|
||||
System.out.println("姓名: " + rs.getString("客户姓名"));
|
||||
System.out.println("总用水量: " + rs.getDouble("总用水量"));
|
||||
System.out.println("总费用: " + rs.getDouble("总费用"));
|
||||
System.out.println("=================================");
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
// 查询订单详细信息视图
|
||||
public void getOrderDetails() {
|
||||
String query = "SELECT * FROM 订单详细信息视图"; // 假设此视图已经创建
|
||||
|
||||
try (Connection connection = DBConnection.getConnection();
|
||||
Statement stmt = connection.createStatement()) {
|
||||
|
||||
// 执行查询操作
|
||||
ResultSet rs = stmt.executeQuery(query);
|
||||
|
||||
// 输出查询结果
|
||||
while (rs.next()) {
|
||||
System.out.println("订单编号: " + rs.getString("订单编号"));
|
||||
System.out.println("客户姓名: " + rs.getString("客户姓名"));
|
||||
System.out.println("用水类别: " + rs.getString("用水类别"));
|
||||
System.out.println("用水量: " + rs.getDouble("用水量"));
|
||||
System.out.println("应收费用: " + rs.getDouble("应收费用"));
|
||||
System.out.println("实收费用: " + rs.getDouble("实收费用"));
|
||||
System.out.println("=================================");
|
||||
}
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,259 @@
|
||||
import javax.swing.*;
|
||||
import javax.swing.table.DefaultTableModel;
|
||||
import java.awt.*;
|
||||
import java.sql.Date;
|
||||
|
||||
public class WaterFeeManagementApp {
|
||||
|
||||
// 实例化服务类
|
||||
private static ClientService clientService = new ClientService();
|
||||
private static ProcedureService procedureService = new ProcedureService();
|
||||
|
||||
public static void main(String[] args) {
|
||||
// 创建主窗口
|
||||
JFrame frame = new JFrame("水费管理系统");
|
||||
frame.setSize(800, 600);
|
||||
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
|
||||
|
||||
// 创建选项卡面板
|
||||
JTabbedPane tabbedPane = new JTabbedPane();
|
||||
|
||||
// 添加选项卡
|
||||
tabbedPane.addTab("客户管理", createClientPanel());
|
||||
tabbedPane.addTab("收费管理", createFeePanel());
|
||||
tabbedPane.addTab("订单管理", createOrderPanel());
|
||||
tabbedPane.addTab("统计与分析", createAnalysisPanel());
|
||||
|
||||
frame.add(tabbedPane);
|
||||
frame.setVisible(true);
|
||||
}
|
||||
|
||||
// **客户管理面板**
|
||||
private static JPanel createClientPanel() {
|
||||
JPanel panel = new JPanel();
|
||||
panel.setLayout(new BorderLayout());
|
||||
|
||||
// **表单区域**
|
||||
JPanel formPanel = new JPanel(new GridLayout(6, 2, 10, 10));
|
||||
JLabel lblCustomerId = new JLabel("客户号:");
|
||||
JTextField txtCustomerId = new JTextField();
|
||||
JLabel lblName = new JLabel("姓名:");
|
||||
JTextField txtName = new JTextField();
|
||||
JLabel lblAddress = new JLabel("地址:");
|
||||
JTextField txtAddress = new JTextField();
|
||||
JLabel lblContact = new JLabel("联系方式:");
|
||||
JTextField txtContact = new JTextField();
|
||||
JLabel lblBalance = new JLabel("余额:");
|
||||
JTextField txtBalance = new JTextField();
|
||||
JButton btnAddClient = new JButton("添加客户");
|
||||
|
||||
formPanel.add(lblCustomerId);
|
||||
formPanel.add(txtCustomerId);
|
||||
formPanel.add(lblName);
|
||||
formPanel.add(txtName);
|
||||
formPanel.add(lblAddress);
|
||||
formPanel.add(txtAddress);
|
||||
formPanel.add(lblContact);
|
||||
formPanel.add(txtContact);
|
||||
formPanel.add(lblBalance);
|
||||
formPanel.add(txtBalance);
|
||||
formPanel.add(new JLabel()); // 空白占位
|
||||
formPanel.add(btnAddClient);
|
||||
|
||||
// **表格区域**
|
||||
JTable table = new JTable(new DefaultTableModel(new Object[]{"客户号", "姓名", "地址", "联系方式", "余额"}, 0));
|
||||
JScrollPane tableScrollPane = new JScrollPane(table);
|
||||
|
||||
// **按钮区域**
|
||||
JPanel buttonPanel = new JPanel();
|
||||
JButton btnDeleteClient = new JButton("删除客户");
|
||||
JButton btnUpdateBalance = new JButton("更新余额");
|
||||
JButton btnQueryClient = new JButton("查询客户");
|
||||
buttonPanel.add(btnDeleteClient);
|
||||
buttonPanel.add(btnUpdateBalance);
|
||||
buttonPanel.add(btnQueryClient);
|
||||
|
||||
// **按钮事件监听**
|
||||
btnAddClient.addActionListener(e -> {
|
||||
try {
|
||||
String customerId = txtCustomerId.getText();
|
||||
String name = txtName.getText();
|
||||
String address = txtAddress.getText();
|
||||
String contact = txtContact.getText();
|
||||
double balance = Double.parseDouble(txtBalance.getText());
|
||||
|
||||
clientService.addClient(customerId, name, address, contact, balance);
|
||||
JOptionPane.showMessageDialog(panel, "客户添加成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "输入有误，请检查数据格式！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
btnDeleteClient.addActionListener(e -> {
|
||||
try {
|
||||
String customerId = JOptionPane.showInputDialog("请输入要删除的客户号:");
|
||||
clientService.deleteClient(customerId);
|
||||
JOptionPane.showMessageDialog(panel, "客户删除成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "删除失败，请检查客户号！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
btnUpdateBalance.addActionListener(e -> {
|
||||
try {
|
||||
String customerId = JOptionPane.showInputDialog("请输入客户号:");
|
||||
double balance = Double.parseDouble(JOptionPane.showInputDialog("请输入新的余额:"));
|
||||
clientService.updateBalance(customerId, balance);
|
||||
JOptionPane.showMessageDialog(panel, "余额更新成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "更新失败，请检查输入数据！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
btnQueryClient.addActionListener(e -> {
|
||||
String customerId = JOptionPane.showInputDialog("请输入客户号:");
|
||||
clientService.getClientInfo(customerId); // Replace with table update logic
|
||||
});
|
||||
|
||||
// **布局**
|
||||
panel.add(formPanel, BorderLayout.NORTH);
|
||||
panel.add(tableScrollPane, BorderLayout.CENTER);
|
||||
panel.add(buttonPanel, BorderLayout.SOUTH);
|
||||
|
||||
return panel;
|
||||
}
|
||||
|
||||
// **收费管理面板**
|
||||
private static JPanel createFeePanel() {
|
||||
JPanel panel = new JPanel(new BorderLayout());
|
||||
|
||||
// 表格区域
|
||||
JTable table = new JTable(new DefaultTableModel(new Object[]{"客户号", "姓名", "应缴月份", "未缴金额"}, 0));
|
||||
JScrollPane tableScrollPane = new JScrollPane(table);
|
||||
|
||||
// 按钮区域
|
||||
JPanel buttonPanel = new JPanel();
|
||||
JButton btnViewUnpaidFees = new JButton("查看未收费用");
|
||||
JButton btnUpdateFeeStatus = new JButton("更新收费状态");
|
||||
buttonPanel.add(btnViewUnpaidFees);
|
||||
buttonPanel.add(btnUpdateFeeStatus);
|
||||
|
||||
// 查看未收费用
|
||||
btnViewUnpaidFees.addActionListener(e -> {
|
||||
try {
|
||||
// TODO: Replace with database call to fetch unpaid fees
|
||||
DefaultTableModel model = (DefaultTableModel) table.getModel();
|
||||
model.setRowCount(0); // 清空表格
|
||||
// 模拟数据
|
||||
model.addRow(new Object[]{"C001", "张三", "2024-12-01", 50.0});
|
||||
model.addRow(new Object[]{"C002", "李四", "2024-12-01", 100.0});
|
||||
JOptionPane.showMessageDialog(panel, "未收费用加载成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "加载失败，请重试！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
// 更新收费状态
|
||||
btnUpdateFeeStatus.addActionListener(e -> {
|
||||
try {
|
||||
String customerId = JOptionPane.showInputDialog("请输入客户号:");
|
||||
String monthStr = JOptionPane.showInputDialog("请输入月份 (yyyy-mm-dd):");
|
||||
Date month = Date.valueOf(monthStr);
|
||||
procedureService.updateFeeStatus(customerId, month);
|
||||
JOptionPane.showMessageDialog(panel, "收费状态更新成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "更新失败，请检查输入数据！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
panel.add(tableScrollPane, BorderLayout.CENTER);
|
||||
panel.add(buttonPanel, BorderLayout.SOUTH);
|
||||
return panel;
|
||||
}
|
||||
|
||||
// **订单管理面板**
|
||||
private static JPanel createOrderPanel() {
|
||||
JPanel panel = new JPanel(new BorderLayout());
|
||||
|
||||
// 表格区域
|
||||
JTable table = new JTable(new DefaultTableModel(new Object[]{"订单编号", "客户号", "用水类别", "用水量", "应收费用", "实收费用"}, 0));
|
||||
JScrollPane tableScrollPane = new JScrollPane(table);
|
||||
|
||||
// 按钮区域
|
||||
JPanel buttonPanel = new JPanel();
|
||||
JButton btnViewOrders = new JButton("查看订单记录");
|
||||
JButton btnGenerateOrder = new JButton("生成订单记录");
|
||||
buttonPanel.add(btnViewOrders);
|
||||
buttonPanel.add(btnGenerateOrder);
|
||||
|
||||
// 查看订单记录
|
||||
btnViewOrders.addActionListener(e -> {
|
||||
try {
|
||||
// TODO: Replace with database call to fetch order records
|
||||
DefaultTableModel model = (DefaultTableModel) table.getModel();
|
||||
model.setRowCount(0); // 清空表格
|
||||
// 模拟数据
|
||||
model.addRow(new Object[]{"O001", "C001", "居民用水", 20.0, 50.0, 50.0});
|
||||
model.addRow(new Object[]{"O002", "C002", "工业用水", 30.0, 150.0, 0.0});
|
||||
JOptionPane.showMessageDialog(panel, "订单记录加载成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "加载失败，请重试！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
// 生成订单记录
|
||||
btnGenerateOrder.addActionListener(e -> {
|
||||
try {
|
||||
String customerId = JOptionPane.showInputDialog("请输入客户号:");
|
||||
String monthStr = JOptionPane.showInputDialog("请输入月份 (yyyy-mm-dd):");
|
||||
Date month = Date.valueOf(monthStr);
|
||||
double usage = Double.parseDouble(JOptionPane.showInputDialog("请输入用水量:"));
|
||||
int typeId = Integer.parseInt(JOptionPane.showInputDialog("请输入用水类别ID:"));
|
||||
procedureService.generateOrderRecord(customerId, month, usage, typeId);
|
||||
JOptionPane.showMessageDialog(panel, "订单记录生成成功！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "生成失败，请检查输入数据！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
panel.add(tableScrollPane, BorderLayout.CENTER);
|
||||
panel.add(buttonPanel, BorderLayout.SOUTH);
|
||||
return panel;
|
||||
}
|
||||
|
||||
|
||||
// **统计与分析面板**
|
||||
private static JPanel createAnalysisPanel() {
|
||||
JPanel panel = new JPanel(new BorderLayout());
|
||||
|
||||
// 表格区域
|
||||
JTable table = new JTable(new DefaultTableModel(new Object[]{"区域", "总费用", "总余额"}, 0));
|
||||
JScrollPane tableScrollPane = new JScrollPane(table);
|
||||
|
||||
// 按钮区域
|
||||
JPanel buttonPanel = new JPanel();
|
||||
JButton btnAnalyzeByArea = new JButton("按区域统计费用");
|
||||
buttonPanel.add(btnAnalyzeByArea);
|
||||
|
||||
// 按区域统计费用
|
||||
btnAnalyzeByArea.addActionListener(e -> {
|
||||
try {
|
||||
String area = JOptionPane.showInputDialog("请输入区域名称:");
|
||||
// TODO: Replace with database call to analyze data by area
|
||||
DefaultTableModel model = (DefaultTableModel) table.getModel();
|
||||
model.setRowCount(0); // 清空表格
|
||||
// 模拟数据
|
||||
model.addRow(new Object[]{"山东青岛", 500.0, 200.0});
|
||||
model.addRow(new Object[]{"山东济南", 300.0, 150.0});
|
||||
JOptionPane.showMessageDialog(panel, "统计完成！");
|
||||
} catch (Exception ex) {
|
||||
JOptionPane.showMessageDialog(panel, "统计失败，请检查输入！", "错误", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
});
|
||||
|
||||
panel.add(tableScrollPane, BorderLayout.CENTER);
|
||||
panel.add(buttonPanel, BorderLayout.SOUTH);
|
||||
return panel;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,481 @@
|
||||
/*
|
||||
Navicat Premium Dump SQL
|
||||
|
||||
Source Server : long
|
||||
Source Server Type : MySQL
|
||||
Source Server Version : 80040 (8.0.40)
|
||||
Source Host : localhost:3306
|
||||
Source Schema : waterfare manage system
|
||||
|
||||
Target Server Type : MySQL
|
||||
Target Server Version : 80040 (8.0.40)
|
||||
File Encoding : 65001
|
||||
|
||||
Date: 25/12/2024 09:20:41
|
||||
*/
|
||||
|
||||
SET NAMES utf8mb4;
|
||||
SET FOREIGN_KEY_CHECKS = 0;
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 业务员表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `业务员表`;
|
||||
CREATE TABLE `业务员表` (
|
||||
`业务员编号` bigint UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`姓名` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`联系方式` varchar(15) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
|
||||
`邮箱` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
|
||||
`入职日期` date NOT NULL,
|
||||
`负责区域` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
|
||||
PRIMARY KEY (`业务员编号`) USING BTREE,
|
||||
UNIQUE INDEX `业务员编号`(`业务员编号` ASC) USING BTREE,
|
||||
UNIQUE INDEX `联系方式`(`联系方式` ASC) USING BTREE,
|
||||
UNIQUE INDEX `邮箱`(`邮箱` ASC) USING BTREE
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 业务员表
|
||||
-- ----------------------------
|
||||
INSERT INTO `业务员表` VALUES (1, '李业务员', '1234567890', 'li@example.com', '2022-01-01', '山东青岛');
|
||||
INSERT INTO `业务员表` VALUES (2, '王业务员', '0987654321', 'wang@example.com', '2023-03-15', '山东济南');
|
||||
INSERT INTO `业务员表` VALUES (3, '赵业务员', '1234509876', 'zhao@example.com', '2023-05-10', '山东烟台');
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 客户信息表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `客户信息表`;
|
||||
CREATE TABLE `客户信息表` (
|
||||
`客户号` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`姓名` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`地址` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
|
||||
`联系方式` varchar(15) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`结余金额` decimal(10, 2) NULL DEFAULT 0.00,
|
||||
PRIMARY KEY (`客户号`) USING BTREE,
|
||||
UNIQUE INDEX `联系方式`(`联系方式` ASC) USING BTREE,
|
||||
INDEX `idx_客户余额`(`结余金额` ASC) USING BTREE
|
||||
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 客户信息表
|
||||
-- ----------------------------
|
||||
INSERT INTO `客户信息表` VALUES ('C001', '张三', '山东济南', '1234567890', 50.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C002', '李四', '山东济南', '0987654321', 200.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C003', '王五', '山东烟台', '1234509876', 150.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C004', '赵六', '山东潍坊', '0987654322', 300.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C005', '梁明', '山东青岛', '1234561234', 20.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C006', '朱明', '山东济南', '1234569876', 250.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C007', '韦明', '山东烟台', '9876543210', 155.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C008', '田明', '山东潍坊', '9876501234', 160.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C009', '王明', '山东东营', '8765432109', 300.00);
|
||||
INSERT INTO `客户信息表` VALUES ('C010', '马明', '山东威海', '6543210987', 220.00);
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 收费登记表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `收费登记表`;
|
||||
CREATE TABLE `收费登记表` (
|
||||
`收费编号` bigint UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`客户号` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`订单编号` bigint UNSIGNED NOT NULL,
|
||||
`收费日期` date NOT NULL,
|
||||
`实收费用` decimal(10, 2) NOT NULL,
|
||||
PRIMARY KEY (`收费编号`) USING BTREE,
|
||||
INDEX `客户号`(`客户号` ASC) USING BTREE,
|
||||
INDEX `订单编号`(`订单编号` ASC) USING BTREE,
|
||||
CONSTRAINT `收费登记表_ibfk_1` FOREIGN KEY (`客户号`) REFERENCES `客户信息表` (`客户号`) ON DELETE RESTRICT ON UPDATE RESTRICT,
|
||||
CONSTRAINT `收费登记表_ibfk_2` FOREIGN KEY (`订单编号`) REFERENCES `订单管理表` (`订单编号`) ON DELETE RESTRICT ON UPDATE RESTRICT
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 7 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 收费登记表
|
||||
-- ----------------------------
|
||||
INSERT INTO `收费登记表` VALUES (4, 'C001', 1, '2024-12-10', 50.00);
|
||||
INSERT INTO `收费登记表` VALUES (5, 'C005', 2, '2024-12-15', 100.00);
|
||||
INSERT INTO `收费登记表` VALUES (6, 'C007', 3, '2024-12-12', 25.00);
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 用水信息表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `用水信息表`;
|
||||
CREATE TABLE `用水信息表` (
|
||||
`用水记录编号` bigint UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`客户号` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`月份` date NOT NULL,
|
||||
`用水类别号` int NOT NULL,
|
||||
`用水量` decimal(10, 2) NOT NULL,
|
||||
PRIMARY KEY (`用水记录编号`) USING BTREE,
|
||||
UNIQUE INDEX `用水记录编号`(`用水记录编号` ASC) USING BTREE,
|
||||
INDEX `客户号`(`客户号` ASC) USING BTREE,
|
||||
INDEX `用水类别号`(`用水类别号` ASC) USING BTREE,
|
||||
INDEX `idx_用水记录月份`(`月份` ASC) USING BTREE,
|
||||
CONSTRAINT `用水信息表_ibfk_1` FOREIGN KEY (`客户号`) REFERENCES `客户信息表` (`客户号`) ON DELETE RESTRICT ON UPDATE RESTRICT,
|
||||
CONSTRAINT `用水信息表_ibfk_2` FOREIGN KEY (`用水类别号`) REFERENCES `用水类型表` (`类别号`) ON DELETE RESTRICT ON UPDATE RESTRICT,
|
||||
CONSTRAINT `用水信息表_chk_1` CHECK (`用水量` >= 0)
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 11 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 用水信息表
|
||||
-- ----------------------------
|
||||
INSERT INTO `用水信息表` VALUES (1, 'C001', '2024-12-01', 1, 20.00);
|
||||
INSERT INTO `用水信息表` VALUES (2, 'C002', '2024-12-01', 2, 50.00);
|
||||
INSERT INTO `用水信息表` VALUES (3, 'C003', '2024-12-01', 1, 15.00);
|
||||
INSERT INTO `用水信息表` VALUES (4, 'C004', '2024-12-01', 3, 30.00);
|
||||
INSERT INTO `用水信息表` VALUES (5, 'C005', '2024-12-01', 4, 25.00);
|
||||
INSERT INTO `用水信息表` VALUES (6, 'C006', '2024-12-01', 2, 40.00);
|
||||
INSERT INTO `用水信息表` VALUES (7, 'C007', '2024-12-01', 1, 10.00);
|
||||
INSERT INTO `用水信息表` VALUES (8, 'C008', '2024-12-01', 3, 35.00);
|
||||
INSERT INTO `用水信息表` VALUES (9, 'C009', '2024-12-01', 4, 20.00);
|
||||
INSERT INTO `用水信息表` VALUES (10, 'C010', '2024-12-01', 2, 60.00);
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 用水类型表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `用水类型表`;
|
||||
CREATE TABLE `用水类型表` (
|
||||
`类别号` int NOT NULL,
|
||||
`类别名` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`水价` decimal(10, 2) NOT NULL,
|
||||
PRIMARY KEY (`类别号`) USING BTREE,
|
||||
CONSTRAINT `用水类型表_chk_1` CHECK (`水价` > 0)
|
||||
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 用水类型表
|
||||
-- ----------------------------
|
||||
INSERT INTO `用水类型表` VALUES (1, '居民用水', 2.50);
|
||||
INSERT INTO `用水类型表` VALUES (2, '工业用水', 5.00);
|
||||
INSERT INTO `用水类型表` VALUES (3, '农业用水', 1.50);
|
||||
INSERT INTO `用水类型表` VALUES (4, '商业用水', 4.00);
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 订单管理表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `订单管理表`;
|
||||
CREATE TABLE `订单管理表` (
|
||||
`订单编号` bigint UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`客户号` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`月份` date NOT NULL,
|
||||
`用水类别号` int NOT NULL,
|
||||
`用水量` decimal(10, 2) NOT NULL,
|
||||
`应收费用` decimal(10, 2) NOT NULL,
|
||||
`实收费用` decimal(10, 2) NULL DEFAULT NULL,
|
||||
PRIMARY KEY (`订单编号`) USING BTREE,
|
||||
INDEX `客户号`(`客户号` ASC) USING BTREE,
|
||||
INDEX `用水类别号`(`用水类别号` ASC) USING BTREE,
|
||||
CONSTRAINT `订单管理表_ibfk_1` FOREIGN KEY (`客户号`) REFERENCES `客户信息表` (`客户号`) ON DELETE RESTRICT ON UPDATE RESTRICT,
|
||||
CONSTRAINT `订单管理表_ibfk_2` FOREIGN KEY (`用水类别号`) REFERENCES `用水类型表` (`类别号`) ON DELETE RESTRICT ON UPDATE RESTRICT
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 订单管理表
|
||||
-- ----------------------------
|
||||
INSERT INTO `订单管理表` VALUES (1, 'C001', '2024-12-01', 1, 20.00, 50.00, 50.00);
|
||||
INSERT INTO `订单管理表` VALUES (2, 'C005', '2024-12-01', 4, 25.00, 100.00, 100.00);
|
||||
INSERT INTO `订单管理表` VALUES (3, 'C007', '2024-12-01', 1, 10.00, 25.00, 25.00);
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for 费用管理表
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `费用管理表`;
|
||||
CREATE TABLE `费用管理表` (
|
||||
`费用编号` bigint UNSIGNED NOT NULL AUTO_INCREMENT,
|
||||
`客户号` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
|
||||
`月份` date NOT NULL,
|
||||
`应收费用` decimal(10, 2) NOT NULL,
|
||||
`收费标志` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT '未收',
|
||||
PRIMARY KEY (`费用编号`) USING BTREE,
|
||||
UNIQUE INDEX `费用编号`(`费用编号` ASC) USING BTREE,
|
||||
INDEX `客户号`(`客户号` ASC) USING BTREE,
|
||||
INDEX `idx_费用管理月份`(`月份` ASC) USING BTREE,
|
||||
CONSTRAINT `费用管理表_ibfk_1` FOREIGN KEY (`客户号`) REFERENCES `客户信息表` (`客户号`) ON DELETE RESTRICT ON UPDATE RESTRICT,
|
||||
CONSTRAINT `费用管理表_chk_1` CHECK (`应收费用` >= 0),
|
||||
CONSTRAINT `费用管理表_chk_2` CHECK (`收费标志` in (_utf8mb4'未收',_utf8mb4'已收'))
|
||||
) ENGINE = InnoDB AUTO_INCREMENT = 11 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = DYNAMIC;
|
||||
|
||||
-- ----------------------------
|
||||
-- Records of 费用管理表
|
||||
-- ----------------------------
|
||||
INSERT INTO `费用管理表` VALUES (1, 'C001', '2024-12-01', 50.00, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (2, 'C002', '2024-12-01', 250.00, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (3, 'C003', '2024-12-01', 37.50, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (4, 'C004', '2024-12-01', 45.00, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (5, 'C005', '2024-12-01', 100.00, '已收');
|
||||
INSERT INTO `费用管理表` VALUES (6, 'C006', '2024-12-01', 200.00, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (7, 'C007', '2024-12-01', 25.00, '已收');
|
||||
INSERT INTO `费用管理表` VALUES (8, 'C008', '2024-12-01', 52.50, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (9, 'C009', '2024-12-01', 80.00, '未收');
|
||||
INSERT INTO `费用管理表` VALUES (10, 'C010', '2024-12-01', 300.00, '未收');
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 区域业务员客户分布视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `区域业务员客户分布视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `区域业务员客户分布视图` AS select `业务员表`.`姓名` AS `业务员姓名`,`业务员表`.`负责区域` AS `负责区域`,count(`客户信息表`.`客户号`) AS `客户数量`,sum(`客户信息表`.`结余金额`) AS `总余额` from (`业务员表` left join `客户信息表` on((`业务员表`.`负责区域` = `客户信息表`.`地址`))) group by `业务员表`.`姓名`,`业务员表`.`负责区域`;
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 客户总费用与已支付费用视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `客户总费用与已支付费用视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `客户总费用与已支付费用视图` AS select `客户信息表`.`客户号` AS `客户编号`,`客户信息表`.`姓名` AS `客户姓名`,sum(`费用管理表`.`应收费用`) AS `总应收费用`,sum((case when (`收费登记表`.`实收费用` is not null) then `收费登记表`.`实收费用` else 0 end)) AS `已支付费用` from ((`客户信息表` join `费用管理表` on((`客户信息表`.`客户号` = `费用管理表`.`客户号`))) left join `收费登记表` on((`客户信息表`.`客户号` = `收费登记表`.`客户号`))) group by `客户信息表`.`客户号`,`客户信息表`.`姓名`;
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 客户用水信息视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `客户用水信息视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `客户用水信息视图` AS select `客户信息表`.`客户号` AS `客户编号`,`客户信息表`.`姓名` AS `客户姓名`,`客户信息表`.`地址` AS `客户地址`,`用水信息表`.`月份` AS `用水月份`,`用水类型表`.`类别名` AS `用水类别`,`用水信息表`.`用水量` AS `用水量` from ((`客户信息表` join `用水信息表` on((`客户信息表`.`客户号` = `用水信息表`.`客户号`))) join `用水类型表` on((`用水信息表`.`用水类别号` = `用水类型表`.`类别号`)));
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 年度客户用水统计视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `年度客户用水统计视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `年度客户用水统计视图` AS select `客户信息表`.`客户号` AS `客户编号`,`客户信息表`.`姓名` AS `客户姓名`,sum(`用水信息表`.`用水量`) AS `总用水量`,sum(`费用管理表`.`应收费用`) AS `总费用` from ((`客户信息表` join `用水信息表` on((`客户信息表`.`客户号` = `用水信息表`.`客户号`))) join `费用管理表` on((`客户信息表`.`客户号` = `费用管理表`.`客户号`))) where (`用水信息表`.`月份` between '2024-01-01' and '2024-12-31') group by `客户信息表`.`客户号`,`客户信息表`.`姓名`;
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 未收费用客户视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `未收费用客户视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `未收费用客户视图` AS select `客户信息表`.`客户号` AS `客户编号`,`客户信息表`.`姓名` AS `客户姓名`,`客户信息表`.`联系方式` AS `联系方式`,`费用管理表`.`月份` AS `应缴月份`,`费用管理表`.`应收费用` AS `未缴金额` from (`客户信息表` join `费用管理表` on((`客户信息表`.`客户号` = `费用管理表`.`客户号`))) where (`费用管理表`.`收费标志` = '未收');
|
||||
|
||||
-- ----------------------------
|
||||
-- View structure for 订单详细信息视图
|
||||
-- ----------------------------
|
||||
DROP VIEW IF EXISTS `订单详细信息视图`;
|
||||
CREATE ALGORITHM = UNDEFINED SQL SECURITY DEFINER VIEW `订单详细信息视图` AS select `订单管理表`.`订单编号` AS `订单编号`,`客户信息表`.`姓名` AS `客户姓名`,`用水类型表`.`类别名` AS `用水类别`,`订单管理表`.`用水量` AS `用水量`,`订单管理表`.`应收费用` AS `应收费用`,`订单管理表`.`实收费用` AS `实收费用` from ((`订单管理表` join `客户信息表` on((`订单管理表`.`客户号` = `客户信息表`.`客户号`))) join `用水类型表` on((`订单管理表`.`用水类别号` = `用水类型表`.`类别号`)));
|
||||
|
||||
-- ----------------------------
|
||||
-- Procedure structure for 更新客户余额
|
||||
-- ----------------------------
|
||||
DROP PROCEDURE IF EXISTS `更新客户余额`;
|
||||
delimiter ;;
|
||||
CREATE DEFINER=`root`@`localhost` PROCEDURE `更新客户余额`(
|
||||
IN p_customer_id VARCHAR(10),
|
||||
IN p_received_amount DECIMAL(10, 2)
|
||||
)
|
||||
BEGIN
|
||||
-- 更新客户余额
|
||||
UPDATE 客户信息表
|
||||
SET 结余金额 = 结余金额 - p_received_amount
|
||||
WHERE 客户号 = p_customer_id;
|
||||
|
||||
-- 确保余额不会变为负数
|
||||
IF (SELECT 结余金额 FROM 客户信息表 WHERE 客户号 = p_customer_id) < 0 THEN
|
||||
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '客户余额不足';
|
||||
END IF;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Procedure structure for 更新收费状态
|
||||
-- ----------------------------
|
||||
DROP PROCEDURE IF EXISTS `更新收费状态`;
|
||||
delimiter ;;
|
||||
CREATE DEFINER=`root`@`localhost` PROCEDURE `更新收费状态`(
|
||||
IN p_customer_id VARCHAR(10),
|
||||
IN p_month DATE
|
||||
)
|
||||
BEGIN
|
||||
-- 更新费用管理表中的收费标志
|
||||
UPDATE 费用管理表
|
||||
SET 收费标志 = '已收'
|
||||
WHERE 客户号 = p_customer_id AND 月份 = p_month;
|
||||
|
||||
-- 同时更新收费登记表中的状态
|
||||
UPDATE 收费登记表
|
||||
SET 实收费用 = (SELECT 应收费用 FROM 费用管理表 WHERE 客户号 = p_customer_id AND 月份 = p_month)
|
||||
WHERE 客户号 = p_customer_id AND 月份 = p_month;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Procedure structure for 生成客户费用记录
|
||||
-- ----------------------------
|
||||
DROP PROCEDURE IF EXISTS `生成客户费用记录`;
|
||||
delimiter ;;
|
||||
CREATE DEFINER=`root`@`localhost` PROCEDURE `生成客户费用记录`(
|
||||
IN p_customer_id VARCHAR(10),
|
||||
IN p_month DATE,
|
||||
IN p_usage DECIMAL(10, 2),
|
||||
IN p_unit_price DECIMAL(10, 2)
|
||||
)
|
||||
BEGIN
|
||||
-- 计算应收费用
|
||||
DECLARE total_fee DECIMAL(10, 2);
|
||||
SET total_fee = p_usage * p_unit_price;
|
||||
|
||||
-- 插入费用记录
|
||||
INSERT INTO 费用管理表 (客户号, 月份, 应收费用, 收费标志)
|
||||
VALUES (p_customer_id, p_month, total_fee, '未收');
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Procedure structure for 生成订单记录
|
||||
-- ----------------------------
|
||||
DROP PROCEDURE IF EXISTS `生成订单记录`;
|
||||
delimiter ;;
|
||||
CREATE DEFINER=`root`@`localhost` PROCEDURE `生成订单记录`(
|
||||
IN p_customer_id VARCHAR(10),
|
||||
IN p_month DATE,
|
||||
IN p_usage DECIMAL(10, 2),
|
||||
IN p_type_id INT
|
||||
)
|
||||
BEGIN
|
||||
-- 计算应收费用
|
||||
DECLARE fee DECIMAL(10, 2);
|
||||
SET fee = p_usage * (SELECT 水价 FROM 用水类型表 WHERE 类别号 = p_type_id);
|
||||
|
||||
-- 插入订单管理表
|
||||
INSERT INTO 订单管理表 (客户号, 月份, 用水类别号, 用水量, 应收费用, 实收费用)
|
||||
VALUES (p_customer_id, p_month, p_type_id, p_usage, fee, 0);
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Procedure structure for 统计区域客户费用
|
||||
-- ----------------------------
|
||||
DROP PROCEDURE IF EXISTS `统计区域客户费用`;
|
||||
delimiter ;;
|
||||
CREATE DEFINER=`root`@`localhost` PROCEDURE `统计区域客户费用`(
|
||||
IN p_area VARCHAR(50)
|
||||
)
|
||||
BEGIN
|
||||
DECLARE total_fee DECIMAL(10, 2);
|
||||
DECLARE total_balance DECIMAL(10, 2);
|
||||
|
||||
-- 统计总费用
|
||||
SELECT SUM(费用管理表.应收费用) INTO total_fee
|
||||
FROM 费用管理表
|
||||
JOIN 客户信息表 ON 费用管理表.客户号 = 客户信息表.客户号
|
||||
WHERE 客户信息表.地址 = p_area;
|
||||
|
||||
-- 统计总余额
|
||||
SELECT SUM(客户信息表.结余金额) INTO total_balance
|
||||
FROM 客户信息表
|
||||
WHERE 客户信息表.地址 = p_area;
|
||||
|
||||
-- 输出结果
|
||||
SELECT CONCAT('区域: ', p_area, ' 总费用: ', total_fee, ' 总余额: ', total_balance) AS 区域统计;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 客户信息表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_prevent_delete_customer`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_prevent_delete_customer` BEFORE DELETE ON `客户信息表` FOR EACH ROW BEGIN
|
||||
-- 检查客户是否有未结清的费用
|
||||
IF EXISTS (SELECT 1 FROM 费用管理表 WHERE 客户号 = OLD.客户号 AND 收费标志 = '未收') THEN
|
||||
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '客户有未结清费用，无法删除';
|
||||
END IF;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 收费登记表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `触发更新结余金额`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `触发更新结余金额` AFTER INSERT ON `收费登记表` FOR EACH ROW BEGIN
|
||||
-- 更新客户信息表中的结余金额
|
||||
UPDATE 客户信息表
|
||||
SET 结余金额 = 结余金额 - NEW.实收费用
|
||||
WHERE 客户号 = NEW.客户号;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 收费登记表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_update_balance`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_update_balance` AFTER INSERT ON `收费登记表` FOR EACH ROW BEGIN
|
||||
-- 更新客户余额，减少相应的费用金额
|
||||
UPDATE 客户信息表
|
||||
SET 结余金额 = 结余金额 - NEW.实收费用
|
||||
WHERE 客户号 = NEW.客户号;
|
||||
|
||||
-- 如果余额不足，抛出异常
|
||||
IF (SELECT 结余金额 FROM 客户信息表 WHERE 客户号 = NEW.客户号) < 0 THEN
|
||||
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '客户余额不足';
|
||||
END IF;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 收费登记表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_update_fee_status_insert`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_update_fee_status_insert` AFTER INSERT ON `收费登记表` FOR EACH ROW BEGIN
|
||||
IF NEW.实收费用 IS NOT NULL THEN
|
||||
-- 更新费用管理表中的收费标志为“已收”
|
||||
UPDATE 费用管理表
|
||||
SET 收费标志 = '已收'
|
||||
WHERE 客户号 = NEW.客户号 AND 月份 = NEW.收费日期;
|
||||
END IF;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 收费登记表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_update_fee_status_update`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_update_fee_status_update` AFTER UPDATE ON `收费登记表` FOR EACH ROW BEGIN
|
||||
IF NEW.实收费用 IS NOT NULL THEN
|
||||
-- 更新费用管理表中的收费标志为“已收”
|
||||
UPDATE 费用管理表
|
||||
SET 收费标志 = '已收'
|
||||
WHERE 客户号 = NEW.客户号 AND 月份 = NEW.收费日期;
|
||||
END IF;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 用水信息表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_generate_fee_record`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_generate_fee_record` AFTER INSERT ON `用水信息表` FOR EACH ROW BEGIN
|
||||
-- 计算应收费用
|
||||
DECLARE total_fee DECIMAL(10, 2);
|
||||
SET total_fee = NEW.用水量 * (SELECT 水价 FROM 用水类型表 WHERE 类别号 = NEW.用水类别号);
|
||||
|
||||
-- 插入费用管理表
|
||||
INSERT INTO 费用管理表 (客户号, 月份, 应收费用, 收费标志)
|
||||
VALUES (NEW.客户号, NEW.月份, total_fee, '未收');
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
-- ----------------------------
|
||||
-- Triggers structure for table 订单管理表
|
||||
-- ----------------------------
|
||||
DROP TRIGGER IF EXISTS `trg_calculate_fee`;
|
||||
delimiter ;;
|
||||
CREATE TRIGGER `trg_calculate_fee` AFTER INSERT ON `订单管理表` FOR EACH ROW BEGIN
|
||||
-- 计算应收费用
|
||||
DECLARE total_fee DECIMAL(10, 2);
|
||||
SET total_fee = NEW.用水量 * (SELECT 水价 FROM 用水类型表 WHERE 类别号 = NEW.用水类别号);
|
||||
|
||||
-- 更新订单中的应收费用
|
||||
UPDATE 订单管理表
|
||||
SET 应收费用 = total_fee
|
||||
WHERE 订单编号 = NEW.订单编号;
|
||||
END
|
||||
;;
|
||||
delimiter ;
|
||||
|
||||
SET FOREIGN_KEY_CHECKS = 1;
|
||||
Loading…
Reference in new issue