AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Eclipse+Java+Swing+Mysql实现进销存管理系统（下）

2022-05-26 165
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： Eclipse+Java+Swing+Mysql实现进销存管理系统

三、部分代码

CategoryServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.services.CategoryService;
public class CategoryServiceImpl implements CategoryService {
  // 查询所有分类
  @Override
  public List selectAll() throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    List list = dao.select("select id,name from category where 1=1 and del_flag='0' ", 2, null);
    if (!list.isEmpty()) {
      return list;
    }
    return null;
  }
}

GoodsServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import java.util.Vector;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.services.GoodsService;
public class GoodsServiceImpl implements GoodsService {
  // 条件查询商品
  @Override
  public Vector<Vector> selectByCondition(Object[] paraArray) throws Exception {
    Vector<Vector> rows = new Vector<Vector>();
    BaseDaoImpl dao = new BaseDaoImpl();
    StringBuilder sqlBuilder = new StringBuilder(
        "select g.id,g.name,g.price,g.origin,c.name as categoryName,w.name as warehouseName, g.stock,w.id as warehouseId,c.id as categoryId "
            + "from goods g,warehouse w,category c "
            + "where 1=1 and g.del_flag='0' and w.del_flag='0' and c.del_flag='0' and g.warehouse_id=w.id and g.category_id=c.id ");
    if (!"全部".equals(paraArray[0])) {
      sqlBuilder.append(" and g.category_id='" + paraArray[0] + "'");
    }
    if (!"全部".equals(paraArray[1])) {
      sqlBuilder.append(" and g.warehouse_id='" + paraArray[1] + "'");
    }
    String sql = sqlBuilder.toString();
    List<Object[]> list = dao.select(sql, 9, null);
    if (!list.isEmpty()) {
      for (Object[] object : list) {
        Vector temp = new Vector<String>();
        for (int i = 0; i < object.length; i++) {
          temp.add(object[i]);
        }
        rows.add(temp);
      }
    }
    return rows;
  }
  // 逻辑删除商品
  @Override
  public int deleteById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update goods set del_flag='1' where id=?", paraArray);
    return result;
  }
  // 通过id修改销售单
  @Override
  public int updateById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update goods set name=?,price=?,origin=?,stock=?,warehouse_id=?,category_id=? where id=?",
        paraArray);
    return result;
  }
  // 插入销售单
  @Override
  public int insertById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.insert(
        "insert into goods(id,name,price,origin,stock,warehouse_id,category_id,del_flag)  values(?,?,?,?,?,?,?,'0')",
        paraArray);
    return result;
  }
  // 查询所有销售单
  @Override
  public List selectAll() throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    String sql = "select id,name from goods where 1=1 and del_flag='0' ";
    List<Object[]> list = dao.select(sql, 2, null);
    return list;
  }
  // 通过id查询销售单
  @Override
  public List selectById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    String sql = "select c.id,c.name,w.id,w.name,g.stock " + "from goods g,category c,warehouse w "
        + "where g.category_id=c.id and g.warehouse_id=w.id and g.del_flag='0' and c.del_flag='0' and w.del_flag='0' and g.id=?";
    List<Object[]> list = dao.select(sql, 5, paraArray);
    return list;
  }
  // 通过id修改库存
  @Override
  public int updateStockById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update goods set stock=stock+? where id=?", paraArray);
    return result;
  }
}

SaleOrderServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import java.util.Vector;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.services.SaleOrderService;
public class SaleOrderServiceImpl implements SaleOrderService {
  // 条件查询销售单
  @Override
  public Vector<Vector> selectByCondition(Object[] paraArray) throws Exception {
    Vector<Vector> rows = new Vector<Vector>();
    BaseDaoImpl dao = new BaseDaoImpl();
    StringBuilder sqlBuilder = new StringBuilder(
        "select s.id,s.bill_no,g.name,s.amount,c.name,w.name,u.name,c.id,w.id "
            + " from sale_order s,user u,goods g,category c,warehouse w "
            + " where s.handler_id=u.id and s.category_id=c.id and s.warehouse_id=w.id and s.goods_id=g.id and s.del_flag='0' and g.del_flag='0' and c.del_flag='0' and w.del_flag='0'");
    String name = paraArray[0].toString().trim();
    if (!name.isEmpty()) {
      sqlBuilder.append(" and g.name like '%" + paraArray[0] + "%' ");
    }
    if (!"全部".equals(paraArray[1])) {
      sqlBuilder.append(" and s.category_id='" + paraArray[1] + "' ");
    }
    if (!"全部".equals(paraArray[2])) {
      sqlBuilder.append(" and s.warehouse_id='" + paraArray[2] + "' ");
    }
    String sql = sqlBuilder.toString();
    List<Object[]> list = dao.select(sql, 9, null);
    if (!list.isEmpty()) {
      for (Object[] object : list) {
        Vector temp = new Vector<String>();
        for (int i = 0; i < object.length; i++) {
          temp.add(object[i]);
        }
        rows.add(temp);
      }
    }
    return rows;
  }
  // 插入销售单
  @Override
  public int insert(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.insert(
        "insert into sale_order(id,bill_no,handler_id,category_id,warehouse_id,amount,goods_id)  values(?,?,?,?,?,?,?)",
        paraArray);
    return result;
  }
}

StockOrderServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import java.util.Vector;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.services.StockOrderService;
public class StockOrderServiceImpl implements StockOrderService {
  // 条件查询入库单
  @Override
  public Vector<Vector> selectStockInputByCondition(Object[] paraArray) throws Exception {
    Vector<Vector> rows = new Vector<Vector>();
    BaseDaoImpl dao = new BaseDaoImpl();
    StringBuilder sqlBuilder = new StringBuilder(
        "select s.id,s.bill_no,g.name,s.amount,c.name,w.name,u.name,c.id,w.id "
            + " from stock_order s,goods g,user u,category c,warehouse w "
            + " where s.handler_id=u.id and s.goods_id=g.id and s.category_id=c.id and s.warehouse_id=w.id and s.sign='0' and s.del_flag='0' and g.del_flag='0' and c.del_flag=0 and w.del_flag='0' ");
    String name = paraArray[0].toString().trim();
    if (!name.isEmpty()) {
      sqlBuilder.append(" and g.name like '%" + paraArray[0] + "%' ");
    }
    if (!"全部".equals(paraArray[1])) {
      sqlBuilder.append(" and s.category_id='" + paraArray[1] + "' ");
    }
    if (!"全部".equals(paraArray[2])) {
      sqlBuilder.append(" and s.warehouse_id='" + paraArray[2] + "' ");
    }
    if (!"全部".equals(paraArray[3])) {
      sqlBuilder.append(" and s.handler_id='" + paraArray[3] + "' ");
    }
    String sql = sqlBuilder.toString();
    List<Object[]> list = dao.select(sql, 9, null);
    if (!list.isEmpty()) {
      for (Object[] object : list) {
        Vector temp = new Vector<String>();
        for (int i = 0; i < object.length; i++) {
          temp.add(object[i]);
        }
        rows.add(temp);
      }
    }
    return rows;
  }
  // 通过id逻辑删除入库单
  @Override
  public int deleteStockInputById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update stock_order set del_flag='1' where id=?", paraArray);
    return result;
  }
  // 通过id修改入库单
  @Override
  public int updateStockInputById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update stock_order set amount=? where id=?", paraArray);
    return result;
  }
  // 插入入库单
  @Override
  public int insertStockInput(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.insert(
        "insert into stock_order(id,bill_no,handler_id,warehouse_id,category_id,amount,goods_id,sign)  values(?,?,?,?,?,?,?,'0')",
        paraArray);
    return result;
  }
  // 条件查询出库单
  @Override
  public Vector<Vector> selectStockOutputByCondition(Object[] paraArray) throws Exception {
    Vector<Vector> rows = new Vector<Vector>();
    BaseDaoImpl dao = new BaseDaoImpl();
    StringBuilder sqlBuilder = new StringBuilder(
        "select s.id,s.bill_no,g.name,s.amount,c.name,w.name,u.name,c.id,w.id "
            + " from stock_order s,goods g,user u,category c,warehouse w "
            + " where s.handler_id=u.id and s.goods_id=g.id and s.category_id=c.id and s.warehouse_id=w.id and s.sign='1' and s.del_flag='0' and g.del_flag='0' and c.del_flag=0 and w.del_flag='0' ");
    String name = paraArray[0].toString().trim();
    if (!name.isEmpty()) {
      sqlBuilder.append(" and g.name like '%" + paraArray[0] + "%' ");
    }
    if (!"全部".equals(paraArray[1])) {
      sqlBuilder.append(" and s.category_id='" + paraArray[1] + "' ");
    }
    if (!"全部".equals(paraArray[2])) {
      sqlBuilder.append(" and s.warehouse_id='" + paraArray[2] + "' ");
    }
    if (!"全部".equals(paraArray[3])) {
      sqlBuilder.append(" and s.handler_id='" + paraArray[3] + "' ");
    }
    String sql = sqlBuilder.toString();
    List<Object[]> list = dao.select(sql, 9, null);
    if (!list.isEmpty()) {
      for (Object[] object : list) {
        Vector temp = new Vector<String>();
        for (int i = 0; i < object.length; i++) {
          temp.add(object[i]);
        }
        rows.add(temp);
      }
    }
    return rows;
  }
  // 通过id逻辑删除出库单
  @Override
  public int deleteStockOutputById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update stock_order set del_flag='1' where id=?", paraArray);
    return result;
  }
  // 通过id修改出库单
  @Override
  public int updateStockOutputById(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update stock_order set amount=? where id=?", paraArray);
    return result;
  }
  // 插入出库单
  @Override
  public int insertStockOutput(Object[] paraArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.insert(
        "insert into stock_order(id,bill_no,handler_id,warehouse_id,category_id,amount,goods_id,sign)  values(?,?,?,?,?,?,?,'1')",
        paraArray);
    return result;
  }
}

UserServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import org.omg.PortableServer.SERVANT_RETENTION_POLICY_ID;
import org.rancode.module.dao.BaseDao;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.entity.User;
import org.rancode.module.services.UserService;
public class UserServiceImpl implements UserService {
  // 查询一条记录
  @Override
  public User selectOne(Object[] paraArray) throws Exception {
    User user = new User();
    BaseDaoImpl dao = new BaseDaoImpl();
    String sql = "select id,name,password,identity from user where name=? and password=?";
    List list = dao.select(sql, 4, paraArray);
    if (!list.isEmpty()) {
      user.setId((String) ((Object[]) list.get(0))[0]);
      user.setName((String) ((Object[]) list.get(0))[1]);
      user.setPassword((String) ((Object[]) list.get(0))[2]);
      user.setIdentity((String) ((Object[]) list.get(0))[3]);
      return user;
    }
    return null;
  }
  // 通过Id修改用户
  @Override
  public int updateUserById(Object[] paraArray) throws Exception {
    int result = 0;
    BaseDaoImpl dao = new BaseDaoImpl();
    String sql = "update user set name = ?,password=? where id=?";
    result = dao.update(sql, paraArray);
    return result;
  }
}

WarehouseServiceImpl

package org.rancode.module.services.Impl;
import java.util.List;
import java.util.Vector;
import org.rancode.module.dao.Impl.BaseDaoImpl;
import org.rancode.module.services.WarehouseService;
public class WarehouseServiceImpl implements WarehouseService {
  // 遍历所有仓库
  @Override
  public List selectAll() throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    List list = dao.select("select id,name from warehouse where 1=1 and del_flag='0' ", 2, null);
    if (!list.isEmpty()) {
      return list;
    }
    return null;
  }
  // 遍历所有仓库返回Vector
  @Override
  public Vector<Vector> selectAllVexctor() throws Exception {
    Vector<Vector> rows = new Vector<Vector>();
    BaseDaoImpl dao = new BaseDaoImpl();
    List<Object[]> list = dao.select("select id,sort,name from warehouse where 1=1 and del_flag='0'  order by sort",
        3, null);
    if (!list.isEmpty()) {
      int number = 1;
      for (Object[] object : list) {
        Vector temp = new Vector<String>();
        for (int i = 0; i < object.length; i++) {
          if (i == 1) {
            temp.add(number);
          } else {
            temp.add(object[i]);
          }
        }
        rows.add(temp);
        number++;
      }
    }
    return rows;
  }
  // 通过Id修改仓库
  @Override
  public int updateById(Object[] paramArray) throws Exception {
    int result = 0;
    BaseDaoImpl dao = new BaseDaoImpl();
    result = dao.update("update warehouse set name=? where id=?", paramArray);
    return result;
  }
  // 通过Id逻辑删除仓库
  @Override
  public int deleteById(Object[] paramArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.update("update warehouse set del_flag='1' where id=?", paramArray);
    return result;
  }
  // 插入仓库
  @Override
  public int insertById(Object[] paramArray) throws Exception {
    BaseDaoImpl dao = new BaseDaoImpl();
    int result = 0;
    result = dao.insert("insert into warehouse(id,name) values(?,?) ", paramArray);
    return result;
  }
}


四、其他

1.更多系统


更多JavaSwing系统请关注专栏。


https://blog.csdn.net/helongqiang/category_6229101.html

https://blog.csdn.net/helongqiang/category_6229101.html


2.源码下载


Java+Swing+Mysql实现进销存管理系统


3.运行项目


请点击以下链接，部署你的项目。


Eclipse如何导入JavaSwing项目超详细图文教程


Eclipse如何导入JavaSwing项目超详细视频教程


4.备注


如有侵权请联系我删除。


5.支持博主

如果您觉得此文对您有帮助，请点赞加关注加收藏。祝您生活愉快！


文章标签：
云数据库 RDS MySQL 版
Android开发
关键词：
Java系统
Java MYSQL
云数据库 RDS MySQL 版系统
Eclipse MySql
云数据库 RDS MySQL 版java
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
水坚石青
目录
相关文章
源码星辰
|
10天前
|
运维 自然语言处理 供应链
Java云HIS医院管理系统源码 病案管理、医保业务、门诊、住院、电子病历编辑器
通过门诊的申请，或者直接住院登记，通过”护士工作站“分配患者，完成后，进入医生患者列表，医生对应开具”长期医嘱“和”临时医嘱“，并在电子病历中，记录病情。病人出院时，停止长期医嘱，开具出院医嘱。进入出院审核，审核医嘱与住院通过后，病人结清缴费，完成出院。
源码星辰
35 3
东方睿赢
|
14天前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销，从而显著提升系统性能
在Java应用开发中，数据库操作常成为性能瓶颈。本文通过问题解答形式，深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销，从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法，以及优化配置的技巧。
东方睿赢
16 1
程序员皮皮林
|
15天前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目（附源码）
基于SpringBoot + Vue的医院管理系统，涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X，环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
程序员皮皮林
102 0
高端源码库
|
18天前
|
移动开发 前端开发 JavaScript
java家政系统成品源码的关键特点和技术应用
家政系统成品源码是已开发完成的家政服务管理软件，支持用户注册、登录、管理个人资料，家政人员信息管理，服务项目分类，订单与预约管理，支付集成，评价与反馈，地图定位等功能。适用于各种规模的家政服务公司，采用uniapp、SpringBoot、MySQL等技术栈，确保高效管理和优质用户体验。
高端源码库
30 1
a15034260562-24955
|
Java
java中获取当前系统日期
java中获取当前系统日期
a15034260562-24955
94 0
小目标青年
|
Java
JAVA 获取系统日期时间
JAVA 获取系统日期时间
小目标青年
297 0
白展糖
|
Java 应用服务中间件
JAVA 取系统当前日期　少8个小时
        Date now = new Date();          DateFormat data = newjava.text.
白展糖
823 0
运营研究坊
|
5天前
|
安全 Java 测试技术
Java并行流陷阱：为什么指定线程池可能是个坏主意
本文探讨了Java并行流的使用陷阱，尤其是指定线程池的问题。文章分析了并行流的设计思想，指出了指定线程池的弊端，并提供了使用CompletableFuture等替代方案。同时，介绍了Parallel Collector库在处理阻塞任务时的优势和特点。
运营研究坊
23 2
众所周知
|
2天前
|
安全 Java 开发者
深入解读JAVA多线程：wait()、notify()、notifyAll()的奥秘
在Java多线程编程中，`wait()`、`notify()`和`notifyAll()`方法是实现线程间通信和同步的关键机制。这些方法定义在`java.lang.Object`类中，每个Java对象都可以作为线程间通信的媒介。本文将详细解析这三个方法的使用方法和最佳实践，帮助开发者更高效地进行多线程编程。 示例代码展示了如何在同步方法中使用这些方法，确保线程安全和高效的通信。
众所周知
15 9
叫个什么名字
|
5天前
|
存储 安全 Java
Java多线程编程的艺术：从基础到实践####
本文深入探讨了Java多线程编程的核心概念、应用场景及其实现方式，旨在帮助开发者理解并掌握多线程编程的基本技能。文章首先概述了多线程的重要性和常见挑战，随后详细介绍了Java中创建和管理线程的两种主要方式：继承Thread类与实现Runnable接口。通过实例代码，本文展示了如何正确启动、运行及同步线程，以及如何处理线程间的通信与协作问题。最后，文章总结了多线程编程的最佳实践，为读者在实际项目中应用多线程技术提供了宝贵的参考。 ####
叫个什么名字
26 5

热门文章

最新文章

  • 1
    测试开启MySQL performance_schema后对性能的影响
  • 2
    RDS入门——Excel文件转存到RDS数据库实践
  • 3
    应用MySQL MGR
  • 4
    MySQL-5.5.33主从复制
  • 5
    干货分享 ｜ 揭秘下一代云数据库引擎MyBase for MySQL
  • 6
    MySQl复制---基于行的复制
  • 7
    将日志记录在是mysql中，实现loganalyzer
  • 8
    Mariadb/Mysql TEMPORARY表
  • 9
    mysql查询拼接
  • 10
    mysql中char与varchar的区别分析
  • 1
    解决Eclipse中文乱码
    70
  • 2
    建立ubuntu下基于eclipse的android开发环境
    46
  • 3
    如何在Eclipse中查看Android源码或者第三方组件包源码（转）
    53
  • 4
    在Eclipse配置安装Android详细教程(新手)
    154
  • 5
    【Eclipse安装及使用(面向小白)】
    117
  • 6
    eclipse安装教程
    87
  • 7
    双击eclipse提示an error has occurred See the log file E:\javatool\eclipse-mars-2\configuration\156991769
    76
  • 8
    【eclipse】pom.xml 红叉的解决办法
    121
  • 9
    eclipse的详细安装教程
    85
  • 10
    修改Eclipse新建jsp文件的默认编码
    56

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 基于ECS搭建Java Web开发环境
  • 使用Aliyun Java Intializr进行项目开发
  • 搭建Java Web开发环境
  • 部署基于Dragonwell的Java运行环境
  • 如何开通MySQL的专属集群

    • 推荐镜像

    更多
  • mysql
  • eclipse
  • maven
    • 下一篇
    阿里云OSS设置跨域访问