Eclipse+Java+Swing+Mysql实现进销存管理系统(下)

本文涉及的产品
云数据库 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.支持博主

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


相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
2月前
|
安全 关系型数据库 MySQL
如何将数据从MySQL同步到其他系统
【10月更文挑战第17天】如何将数据从MySQL同步到其他系统
256 0
|
29天前
|
监控 Java API
如何使用Java语言快速开发一套智慧工地系统
使用Java开发智慧工地系统,采用Spring Cloud微服务架构和前后端分离设计,结合MySQL、MongoDB数据库及RESTful API,集成人脸识别、视频监控、设备与环境监测等功能模块,运用Spark/Flink处理大数据,ECharts/AntV G2实现数据可视化,确保系统安全与性能,采用敏捷开发模式,提供详尽文档与用户培训,支持云部署与容器化管理,快速构建高效、灵活的智慧工地解决方案。
|
20天前
|
设计模式 消息中间件 搜索推荐
Java 设计模式——观察者模式:从优衣库不使用新疆棉事件看系统的动态响应
【11月更文挑战第17天】观察者模式是一种行为设计模式,定义了一对多的依赖关系,使多个观察者对象能直接监听并响应某一主题对象的状态变化。本文介绍了观察者模式的基本概念、商业系统中的应用实例,如优衣库事件中各相关方的动态响应,以及模式的优势和实际系统设计中的应用建议,包括事件驱动架构和消息队列的使用。
|
1月前
|
运维 自然语言处理 供应链
Java云HIS医院管理系统源码 病案管理、医保业务、门诊、住院、电子病历编辑器
通过门诊的申请,或者直接住院登记,通过”护士工作站“分配患者,完成后,进入医生患者列表,医生对应开具”长期医嘱“和”临时医嘱“,并在电子病历中,记录病情。病人出院时,停止长期医嘱,开具出院医嘱。进入出院审核,审核医嘱与住院通过后,病人结清缴费,完成出院。
86 3
|
1月前
|
关系型数据库 MySQL Linux
Linux系统如何设置自启动服务在MySQL数据库启动后执行?
【10月更文挑战第25天】Linux系统如何设置自启动服务在MySQL数据库启动后执行?
110 3
|
1月前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能
在Java应用开发中,数据库操作常成为性能瓶颈。本文通过问题解答形式,深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法,以及优化配置的技巧。
37 1
|
1月前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目(附源码)
基于SpringBoot + Vue的医院管理系统,涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X,环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
|
2月前
|
移动开发 前端开发 JavaScript
java家政系统成品源码的关键特点和技术应用
家政系统成品源码是已开发完成的家政服务管理软件,支持用户注册、登录、管理个人资料,家政人员信息管理,服务项目分类,订单与预约管理,支付集成,评价与反馈,地图定位等功能。适用于各种规模的家政服务公司,采用uniapp、SpringBoot、MySQL等技术栈,确保高效管理和优质用户体验。
|
2月前
|
XML JSON 监控
告别简陋:Java日志系统的最佳实践
【10月更文挑战第19天】 在Java开发中,`System.out.println()` 是最基本的输出方法,但它在实际项目中往往被认为是不专业和不足够的。本文将探讨为什么在现代Java应用中应该避免使用 `System.out.println()`,并介绍几种更先进的日志解决方案。
61 1
|
2月前
|
Java 关系型数据库 API
介绍一款Java开发的企业接口管理系统和开放平台
YesApi接口管理平台Java版,基于Spring Boot、Vue.js等技术,提供API接口的快速研发、管理、开放及收费等功能,支持多数据库、Docker部署,适用于企业级PaaS和SaaS平台的二次开发与搭建。

推荐镜像

更多
下一篇
DataWorks