diff --git a/src/model/DataGoods.java b/src/model/DataGoods.java new file mode 100644 index 0000000..8a1520a --- /dev/null +++ b/src/model/DataGoods.java @@ -0,0 +1,144 @@ +package model; + +import java.sql.*; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; + +public class DataGoods { + private static DataGoods instance; + private Map goodsMap; + private Map inventory; + + + public DataGoods() { + goodsMap = new HashMap<>(); + inventory = new HashMap<>(); + initializeData(); + } + + public static DataGoods getInstance() { + if (instance == null) { + instance = new DataGoods(); + } + return instance; + } + 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); + } + + 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); + } + + public void addGoods(Goods goods) { + goodsMap.put(goods.getId(), goods); + if (!inventory.containsKey(goods.getId())) { + inventory.put(goods.getId(), 0); + } + } + + public Goods getGoods(String id) { + return goodsMap.get(id); + } + + public List getAllGoods() { + return new ArrayList<>(goodsMap.values()); + } + + public int getStock(String goodsId) { + return inventory.getOrDefault(goodsId, 0); + } + + public void updateStock(String goodsId, int quantity) { + inventory.put(goodsId, inventory.getOrDefault(goodsId, 0) + quantity); + } + + public Map getAllStock() { + return new HashMap<>(inventory); + } + + 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); // 同步内存中的数据 + DataManager.getInstance().addOperationLog("新增", goods.getId(), "当前用户", "新增货物: " + goods.getName()); + } catch (SQLException e) { + e.printStackTrace(); + DataManager.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(); + addGoods(goods); // 同步内存中的数据 + DataManager.getInstance().addOperationLog("更新", goods.getId(), "当前用户", "更新货物: " + goods.getName()); + } catch (SQLException e) { + e.printStackTrace(); + DataManager.showAlert("错误", "更新货物失败：" + e.getMessage()); + } + } + + public List getAllCategories() { + return goodsMap.values().stream() + .map(Goods::getCategory) + .distinct() + .collect(Collectors.toList()); + } +} diff --git a/src/model/DataManager.java b/src/model/DataManager.java index 68755c2..09d1dc3 100644 --- a/src/model/DataManager.java +++ b/src/model/DataManager.java @@ -250,7 +250,7 @@ public class DataManager { } - private void showAlert(String 错误, String s) { + protected static void showAlert(String 错误, String s) { } public List getAllCategories() { diff --git a/src/view/CategoryManagementView.java b/src/view/CategoryManagementView.java index 54fb5cd..6234f1e 100644 --- a/src/view/CategoryManagementView.java +++ b/src/view/CategoryManagementView.java @@ -12,7 +12,7 @@ import javafx.scene.input.MouseEvent; import javafx.scene.layout.AnchorPane; import javafx.scene.layout.BorderPane; import javafx.scene.layout.VBox; -import model.DataManager; +import model.DataGoods; import model.Goods; import java.util.HashMap; @@ -41,9 +41,9 @@ public class CategoryManagementView extends AnchorPane { } private void loadCategoriesAndGoods() { - DataManager dataManager = DataManager.getInstance(); - ObservableList allGoods = FXCollections.observableArrayList(dataManager.getAllGoods()); - ObservableList categories = FXCollections.observableArrayList(dataManager.getAllCategories()); + DataGoods dataGoods = DataGoods.getInstance(); + ObservableList allGoods = FXCollections.observableArrayList(dataGoods.getAllGoods()); + ObservableList categories = FXCollections.observableArrayList(dataGoods.getAllCategories()); // 对商品按照价格进行排序 allGoods.sort((g1, g2) -> Double.compare(g1.getPrice(), g2.getPrice())); @@ -89,9 +89,9 @@ public class CategoryManagementView extends AnchorPane { } // 获取库存和价格 - int stock = dataManager.getStock(goods.getId()); + int stock = dataGoods.getStock(goods.getId()); // 构建显示文本 - String displayText = goods.getName() + " (" + goods.getSpecification() + ") - 库存: " + stock + " - 价格: " + price; + String displayText = goods.getName() + " (" + goods.getSpecification() + ")"; TreeItem goodsItem = new TreeItem<>(displayText); priceRangeItem.getChildren().add(goodsItem); @@ -136,7 +136,7 @@ public class CategoryManagementView extends AnchorPane { Label specificationLabel = new Label("规格: " + goods.getSpecification()); Label categoryLabel = new Label("类别: " + goods.getCategory()); Label priceLabel = new Label("价格: " + goods.getPrice()); - Label stockLabel = new Label("库存: " + DataManager.getInstance().getStock(goods.getId())); + Label stockLabel = new Label("库存: " + DataGoods.getInstance().getStock(goods.getId())); detailsBox.getChildren().addAll(nameLabel, specificationLabel, categoryLabel, priceLabel, stockLabel);