fdzcxy212206305
/
uml
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

货物信息连接数据库v2

Browse Source
master
xzk 7 months ago
parent cba3cb7438
commit 2d7557e547
7 changed files with 79 additions and 119 deletions
Show Stats Download Patch File Download Diff File

177
src/model/DataManager.java
Unescape View File

@ -31,43 +31,64 @@ public class DataManager {
}
private void initializeData() {
// 电子产品类
addGoodsWithStock("G001", "苹果手机", "iPhone 15", "台", 6999.00, "电子产品", 50);
addGoodsWithStock("G002", "联想笔记本", "ThinkPad T14", "台", 5999.00, "电子产品", 30);
addGoodsWithStock("G003", "华为平板", "MatePad Pro", "台", 3999.00, "电子产品", 40);
addGoodsWithStock("G004", "戴尔显示器", "27寸 4K", "台", 2399.00, "电子产品", 25);
// 办公家具类
addGoodsWithStock("G005", "办公桌", "1.4米", "张", 799.00, "办公家具", 100);
addGoodsWithStock("G006", "办公椅", "人体工学", "把", 599.00, "办公家具", 150);
addGoodsWithStock("G007", "文件柜", "三层", "个", 459.00, "办公家具", 80);
addGoodsWithStock("G008", "会议桌", "2.4米", "张", 1599.00, "办公家具", 20);
// 办公用品类
addGoodsWithStock("G009", "打印纸", "A4 70g", "箱", 89.00, "办公用品", 200);
addGoodsWithStock("G010", "签字笔", "0.5mm黑色", "盒", 15.00, "办公用品", 500);
addGoodsWithStock("G011", "订书机", "标准型", "个", 35.00, "办公用品", 300);
addGoodsWithStock("G012", "文件夹", "A4蓝色", "个", 8.00, "办公用品", 1000);
// 添加供应商
suppliers.add("苹果官方旗舰店");
suppliers.add("联想专卖店");
suppliers.add("华为授权店");
suppliers.add("戴尔官方店");
suppliers.add("京东自营");
suppliers.add("天猫超市");
suppliers.add("办公伙伴专营店");
suppliers.add("文具批发商");
suppliers.add("家具城");
suppliers.add("办公用品直营店");
}
private void addGoodsWithStock(String id, String name, String specification,
String unit, double price, String category, int initialStock) {
Goods goods = new Goods(id, name, specification, unit, price, category, initialStock, "");
goodsMap.put(id, goods);
inventory.put(id, initialStock);
// 从数据库加载数据
loadDataFromDatabase();
}
private void loadDataFromDatabase() {
String url = "jdbc:sqlite:db/dbuml.db3";
try (Connection conn = DriverManager.getConnection(url)) {
// 加载商品数据
loadGoods(conn);
// 加载供应商数据
loadSuppliers(conn);
// 加载库存数据
loadInventory(conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
private void loadGoods(Connection conn) throws SQLException {
String sql = "SELECT * FROM goods";
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql)) {
while (rs.next()) {
String id = rs.getString("id");
String name = rs.getString("name");
String specification = rs.getString("specification");
String unit = rs.getString("unit");
double price = rs.getDouble("price");
String category = rs.getString("category");
String remark = rs.getString("remark");
Goods goods = new Goods(id, name, specification, unit, price, category, 0, remark);
goodsMap.put(id, goods);
}
}
}
private void loadSuppliers(Connection conn) throws SQLException {
String sql = "SELECT supplier_name FROM suppliers";
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql)) {
while (rs.next()) {
suppliers.add(rs.getString("supplier_name"));
}
}
}
private void loadInventory(Connection conn) throws SQLException {
String sql = "SELECT goods_id, quantity FROM inventory";
try (Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql)) {
while (rs.next()) {
String goodsId = rs.getString("goods_id");
int quantity = rs.getInt("quantity");
inventory.put(goodsId, quantity);
}
}
}
public void addGoods(Goods goods) {
@ -79,14 +100,26 @@ public class DataManager {
public static List<InventoryReport> generateInventoryReport() {
List<InventoryReport> reports = new ArrayList<>();
// 数据库连接URL
String url = "jdbc:sqlite:db/dbuml.db3";
try (Connection conn = DriverManager.getConnection(url);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT goods_id, goods_name, SUM(quantity) as total_quantity, supplier, remark FROM inbound_records GROUP BY goods_id")) {
Statement stmt = conn.createStatement()) {
// 使用与InboundView相同的表结构
String sql = "SELECT " +
" goods_id, " +
" goods_id as goods_name, " + // 因为InboundView中使用goods_id存储的是货物名称
" SUM(quantity) as total_quantity, " +
" GROUP_CONCAT(DISTINCT supplier) as supplier, " +
" CASE " +
" WHEN SUM(quantity) < 10 THEN '库存偏低' " +
" ELSE '库存正常' " +
" END as remark " +
"FROM inbound_records " +
"GROUP BY goods_id " +
"ORDER BY goods_id";
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
String goodsId = rs.getString("goods_id");
String goodsName = rs.getString("goods_name");
@ -153,64 +186,4 @@ public class DataManager {
})
.collect(Collectors.toList());
}
public void addGoodsToDatabase(Goods goods) {
String url = "jdbc:sqlite:db/dbuml.db3";
String sql = "INSERT INTO goods (id, name, specification, unit, price, category, quantity, remark, inbound_time, operator, supplier) " +
"VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
try (Connection conn = DriverManager.getConnection(url);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setString(1, goods.getId());
pstmt.setString(2, goods.getName());
pstmt.setString(3, goods.getSpecification());
pstmt.setString(4, goods.getUnit());
pstmt.setDouble(5, goods.getPrice());
pstmt.setString(6, goods.getCategory());
pstmt.setInt(7, goods.getQuantity());
pstmt.setString(8, goods.getRemark());
pstmt.setString(9, goods.getInboundTime().toString());
pstmt.setString(10, goods.getOperator());
pstmt.setString(11, goods.getSupplier());
pstmt.executeUpdate();
addGoods(goods); // 同步内存中的数据
addOperationLog("新增", goods.getId(), "当前用户", "新增货物: " + goods.getName());
} catch (SQLException e) {
e.printStackTrace();
showAlert("错误", "添加货物失败：" + e.getMessage());
}
}
public void updateGoodsInDatabase(Goods goods) {
String url = "jdbc:sqlite:db/dbuml.db3";
String sql = "UPDATE goods SET name = ?, specification = ?, unit = ?, price = ?, category = ?, " +
"quantity = ?, remark = ?, inbound_time = ?, operator = ?, supplier = ? WHERE id = ?";
try (Connection conn = DriverManager.getConnection(url);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setString(1, goods.getName());
pstmt.setString(2, goods.getSpecification());
pstmt.setString(3, goods.getUnit());
pstmt.setDouble(4, goods.getPrice());
pstmt.setString(5, goods.getCategory());
pstmt.setInt(6, goods.getQuantity());
pstmt.setString(7, goods.getRemark());
pstmt.setString(8, goods.getInboundTime().toString());
pstmt.setString(9, goods.getOperator());
pstmt.setString(10, goods.getSupplier());
pstmt.setString(11, goods.getId());
pstmt.executeUpdate();
addOperationLog("更新", goods.getId(), "当前用户", "更新货物: " + goods.getName());
} catch (SQLException e) {
e.printStackTrace();
showAlert("错误", "更新货物失败：" + e.getMessage());
}
}
private void showAlert(String 错误, String s) {
}
}

1
src/view/CategoryManagementView.java
Unescape View File

@ -5,7 +5,6 @@ import javafx.collections.ObservableList;
import javafx.scene.control.TreeItem;
import javafx.scene.control.TreeView;
import javafx.scene.layout.AnchorPane;
import model.DataManager;
import model.Goods;
public class CategoryManagementView extends AnchorPane {

1
src/view/GoodsManagementView.java
Unescape View File

@ -6,7 +6,6 @@ import javafx.geometry.Pos;
import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.scene.control.cell.PropertyValueFactory;
import model.DataManager;
import model.Goods;
import java.sql.Connection;

8
src/view/InboundView.java
Unescape View File

@ -6,13 +6,9 @@ import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.scene.control.cell.PropertyValueFactory;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import model.InboundRecord;
import model.DataManager;
import model.Goods;
import javafx.collections.FXCollections;
import java.util.List;
import java.util.stream.Collectors;
import java.sql.*;
public class InboundView extends BorderPane {

3
src/view/InventoryReportView.java
Unescape View File

@ -1,13 +1,12 @@
package view;
import javafx.collections.FXCollections;
import javafx.geometry.Insets;
import javafx.geometry.Pos;
import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.scene.control.cell.PropertyValueFactory;
import model.InventoryReport;
import model.DataManager;
import java.util.List;
public class InventoryReportView extends BorderPane {

1
src/view/OperationLogView.java
Unescape View File

@ -5,7 +5,6 @@ import javafx.geometry.Insets;
import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.scene.control.cell.PropertyValueFactory;
import model.DataManager;
import model.OperationLog;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

7
src/view/OutboundView.java
Unescape View File

@ -6,13 +6,8 @@ import javafx.scene.control.*;
import javafx.scene.layout.*;
import javafx.scene.control.cell.PropertyValueFactory;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import model.OutboundRecord;
import model.DataManager;
import model.Goods;
import javafx.collections.FXCollections;
import java.util.List;
import java.util.stream.Collectors;
public class OutboundView extends BorderPane {

Write Preview
Loading…
Cancel
Save