Java从零实现超市会员管理系统

Java Fans 2022-12-13 我要评论

项目需求

为某超市开发一个超市会员管理系统，实现会员的管理，具体实现功能如下：

（1）积分累计

（2）积分兑换

（3）查询剩余积分

（4）查询所有会员信息

（5）修改密码

（6）开卡（注册会员）

覆盖知识

程序基本概念、数据类型、流程控制、顺序、选择、循环、跳转语句、变量、类、方法、实用类等

掌握数据库、JDBC、三层架构等相关知识。

掌握Druid连接池、Apache的DBUtils使用。

开发思路

（1）明确需求

（2）编码顺序

数据初始化，完成数据表创建，三层架构的搭建
循环完成各种超市会员管理操作
菜单切换

（3）测试

开发步骤

1）、添加需要的jar包到项目中，将lib文件夹中的jar文件通过鼠标右单击选择Build Path的方式添加到你设置的eatJar文件目录里。

2）、创建database.properties文件，用来配置注册驱动和数据库连接对象的相关数据。

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/java221804
username=root
password=huanghuang
initialSize=10
maxActive=30
maxIdle=5
maxWait=3000

3）、添加需要的工具类DBUtils类

package cn.book.utils;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
public class DBUtils {
	private static DruidDataSource druidDataSource;
	static {
		Properties properties = new Properties();
		try {
			InputStream is = DBUtils.class
					.getResourceAsStream("/database.properties");
			properties.load(is);
			druidDataSource = (DruidDataSource) DruidDataSourceFactory
					.createDataSource(properties);
		} catch (IOException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public static DataSource getDataSource(){
		return druidDataSource;
	}
}

4）、创建数据表：member表

CREATE TABLE `member` (
  `name` varchar(20) NOT NULL,
  `cardId` int(11) NOT NULL,
  `password` varchar(20) NOT NULL,
  `score` int(11) NOT NULL,
  `registDate` varchar(20) NOT NULL,
  UNIQUE KEY `cardId` (`cardId`)
);

5）、编写book类，包含get/set方法、有参/无参构造、toString方法

6）、数据访问层DAO层的接口和实现类的增删改查方法的编写

7）、服务层Service层的接口和实现类的增删改查方法的编写

8）、最后完成视图层View层测试类的编写

全部代码展示

1、Member类

package cn.member.entity;
public class Member {
	// 定义属性
	private String name;
	private int cardId;
	private String password;
	private int score;
	private String registDate;
	public Member() {
		super();
	}
	public Member(String name, int cardId, String password, int score,
			String registDate) {
		super();
		this.name = name;
		this.cardId = cardId;
		this.password = password;
		this.score = score;
		this.registDate = registDate;
	}
	// 定义get/set方法
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getCardId() {
		return cardId;
	}
	public void setCardId(int cardId) {
		this.cardId = cardId;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public int getScore() {
		return score;
	}
	public void setScore(int score) {
		this.score = score;
	}
	public String getRegistDate() {
		return registDate;
	}
	public void setRegistDate(String registDate) {
		this.registDate = registDate;
	}
	@Override
	public String toString() {
		return "Member [name=" + name + ", cardId=" + cardId + ", password="
				+ password + ", score=" + score + ", registDate=" + registDate
				+ "]";
	}
}

2、DBUtils类

（使用连接池DruidDataSource、Apache的知识）

package cn.member.utils;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
public class DBUtils {
	private static DruidDataSource druidDataSource;
	static {
		Properties properties = new Properties();
		try {
			InputStream is = DBUtils.class
					.getResourceAsStream("/database.properties");
			properties.load(is);
			druidDataSource = (DruidDataSource) DruidDataSourceFactory
					.createDataSource(properties);
		} catch (IOException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public static DataSource getDataSource(){
		return druidDataSource;
	}
}

3、数据访问层的MemberDao接口

package cn.member.dao;
import java.util.List;
import cn.member.entity.Member;
public interface MemberDao {
	// 增
	public int insert(Member member);
	// 删
	public int delete(int cardId);
	// 改
	public int update(Member book);
	// 查一个
	public Member select(int cardId);
	// 查全部
	public List<Member> selectAll();
}

4、数据访问层的MemberDaoImpl类

package cn.member.dao.impl;
import java.sql.SQLException;
import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import cn.member.dao.MemberDao;
import cn.member.entity.Member;
import cn.member.utils.DBUtils;
public class MemberDaoImpl implements MemberDao {
	private QueryRunner queryRunner = new QueryRunner(DBUtils.getDataSource());
	@Override
	public int insert(Member member) {
		String sql = "insert into member(name,cardId,password,score,registDate) values(?,?,?,?,?);";
		Object[] args = { member.getName(), member.getCardId(),
				member.getPassword(), member.getScore(), member.getRegistDate() };
		try {
			return queryRunner.update(sql, args);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return 0;
	}
	@Override
	public int delete(int cardId) {
		String sql = "delete from member where cardId=?;";
		try {
			return queryRunner.update(sql, cardId);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return 0;
	}
	@Override
	public int update(Member member) {
		String sql = "update `member` set `name`=?,`password`=?,`score`=?,`registDate`=? where `cardId`=?;";
		Object[] args={member.getName(),member.getPassword(),member.getScore(),member.getRegistDate(),member.getCardId()};
		try {
			return queryRunner.update(sql, args);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return 0;
	}
	@Override
	public Member select(int cardId) {
		String sql = "select * from member where cardId=?;";
		try {
			return queryRunner.query(sql,
					new BeanHandler<Member>(Member.class), cardId);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}
	@Override
	public List<Member> selectAll() {
		String sql = "SELECT * FROM member;";
		try {
			return queryRunner.query(sql, new BeanListHandler<Member>(
					Member.class));
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}
}

5、服务层的MemberService接口

package cn.member.service;
import java.util.List;
import cn.member.entity.Member;
public interface MemberService {
	// 增
	public int insertMember(Member member);
	// 删
	public int deleteMember(int cardId);
	// 改
	public int updateMember(Member member);
	// 查一个
	public Member selectMember(int cardId);
	// 查全部
	public List<Member> selectAllMembers();
}

6、服务层的MemberServiceImpl类

package cn.member.service.impl;
import java.util.List;
import cn.member.dao.MemberDao;
import cn.member.dao.impl.MemberDaoImpl;
import cn.member.entity.Member;
import cn.member.service.MemberService;
public class MemberServiceImpl implements MemberService {
	MemberDao memberDao = new MemberDaoImpl();
	@Override
	public int insertMember(Member Member) {
		if (memberDao.select(Member.getCardId()) == null) {
			return memberDao.insert(Member);
		}
		return 0;
	}
	@Override
	public int deleteMember(int cardId) {
		if (memberDao.select(cardId) != null) {
			return memberDao.delete(cardId);
		}
		return 0;
	}
	@Override
	public int updateMember(Member Member) {
		if (memberDao.select(Member.getCardId()) != null) {
			return memberDao.update(Member);
		}
		return 0;
	}
	@Override
	public Member selectMember(int cardId) {
		memberDao.select(cardId);
		return null;
	}
	@Override
	public List<Member> selectAllMembers() {
		List<Member> listMembers = memberDao.selectAll();
		return listMembers;
	}
}

7、视图层MemberMgr测试类

package cn.member.view;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Scanner;
import cn.member.entity.Member;
import cn.member.service.MemberService;
import cn.member.service.impl.MemberServiceImpl;
public class MemberMgr {
	// 定义一个Scanner
	Scanner sc = new Scanner(System.in);
	// 定义Member对象
	Member member = new Member();
	MemberService ms=new MemberServiceImpl();
	//从数据库中查全部会员信息
	List<Member> listM=null;
	// 菜单选择栏
	public void showFirst() {
		System.out
				.println("****************************************欢迎使用超市会员管理系统*****************************************");
		System.out
				.println("1.开卡\t2.修改密码\t3.积分累计\t4.积分兑换\t5.剩余积分查询\t6.查看所有会员信息\t7.退出");
		System.out
				.println("*******************************************************************************************************");
	}
	// 会员卡号随机产生方法
	public int cardRandom() {
		return (int) (Math.random() * (19999999 - 10000000) + 10000000);
	}
	// 注册时判断会员是否存在
	public boolean isCardId(int mm) {
		boolean isCId = false;
		if (listM.size() > 0) {
			for (Member memberC : listM) {
				if (mm == memberC.getCardId()) {
					isCId = true;
					return isCId;
				}
			}
		}
		return isCId;
	}
	// 判断会员卡和密码是否正确
	public boolean isMember(int mm, String pwd) {
		boolean isCId = false;
		if (listM.size() > 0) {
			for (Member memberC : listM) {
//				System.out.println(mm+"/"+pwd+"/"+memberC.getCardId()+"/"+memberC.getPassword());
				if (mm == memberC.getCardId()
						&& pwd.equals(memberC.getPassword())) {
					isCId = true;
					member = memberC;
					return isCId;
				}
			}
		}
		return isCId;
	}
	// 1、开卡
	public void OpenCard() {
		// 每次都初始化一条member对象
		member = new Member();
		do {
			member.setCardId(cardRandom());
		} while (isCardId(member.getCardId()));
		System.out.print("请输入注册姓名：");
		member.setName(sc.next());
		System.out.print("请输入注册密码：");
		String password1 = sc.next();
		do {
			if (password1.length() < 6) {
				System.out.print("会员密码不能小于6位，请重新输入注册密码：");
				password1 = sc.next();
			}
		} while (password1.length() < 6);
		member.setPassword(password1);
		member.setScore(100);
		Date data = new Date();
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日 HH:mm");
		member.setRegistDate(sdf.format(data));
//		ms.insertMember(member);
		if(ms.insertMember(member)>0){
			System.out.println("恭喜,开通会员卡成功！系统赠送您" + member.getScore()
					+ "积分，您的会员卡号是：" + member.getCardId());
		}else{
			System.out.println("会员开通失败！");
		}
//		listM.add(member);
	}
	// 2、修改密码
	public void changePassword() {
		System.out.print("请输入您的会员卡号：");
		int cardNum = sc.nextInt();
		System.out.print("请输入您的会员密码：");
		String cardPwd = sc.next();
		if (isMember(cardNum, cardPwd)) {
			System.out.print("请输入您的会员新密码：");
			member.setPassword(sc.next());
			if(ms.updateMember(member)>0){
				System.out.println("新密码设置成功！");
			}else{
				System.out.println("新密码设置失败！");
			}
		} else {
			System.out.println("您输入的会员卡号或密码错误，无法修改密码！");
		}
	}
	// 3、积分累计
	public void scoresAdd() {
		System.out.print("请输入您的会员卡号：");
		int cardNum = sc.nextInt();
		System.out.print("请输入您的会员密码：");
		String cardPwd = sc.next();
		if (isMember(cardNum, cardPwd)) {
			System.out.print("请输入本次消费金额（消费1元累计1分）：");
			int scoreCurrent = sc.nextInt();
			member.setScore(scoreCurrent + member.getScore());
			if(ms.updateMember(member)>0){
				System.out.println("积分累计成功！你重新累计的积分为：" + member.getScore() + "分");
			}else{
				System.out.println("积分累计失败！");
			}
			
		} else {
			System.out.println("您输入的会员卡号或密码错误，无法累计积分！");
		}
	}
	// 4、积分兑换
	public void scoresConver() {
		System.out.print("请输入您的会员卡号：");
		int cardNum = sc.nextInt();
		System.out.print("请输入您的会员密码：");
		String cardPwd = sc.next();
		if (isMember(cardNum, cardPwd)) {
			System.out.print("请输入您要兑换使用的积分（100积分抵用0.1元，不足100的积分不做抵用）：");
			int scoreCurrent = sc.nextInt();
			if (scoreCurrent < member.getScore()&&scoreCurrent>100) {
				member.setScore(member.getScore() - scoreCurrent);
				ms.updateMember(member);
				if(ms.updateMember(member)>0){
					System.out.println("您消费金额中使用会员积分抵扣了0."
							+ (scoreCurrent /100) + "元");
				}else{
					System.out.println("积分兑换失败！");
				}
			}else if(scoreCurrent<100){
				System.out.println("不满足积分兑换规则，不足100的积分不做抵用！");
			}else {			
				System.out.println("积分不足！");
			}
		} else {
			System.out.println("您输入的会员卡号或密码错误，无法进行兑换！");
		}
	}
	// 5、剩余积分查询
	public void scoresRemain() {
		System.out.print("请输入您的会员卡号：");
		int cardNum = sc.nextInt();
		System.out.print("请输入您的会员密码：");
		String cardPwd = sc.next();
		if (isMember(cardNum, cardPwd)) {
			System.out.println("会员信息【会员卡号：" + member.getCardId() + ",姓名："
					+ member.getName() + ",可用积分：" + member.getScore()
					+ ",开卡时间：" + member.getRegistDate() + "】");
		} else {
			System.out.println("您输入的会员卡号或密码错误，无法查询到信息！");
		}
	}
	// 6、查看所有会员信息
	public void LookMembers() {
		int i = 0;
		for (Member member : listM) {
			i++;
			System.out.println("会员" + i + "信息【会员卡号：" + member.getCardId()
					+ ",姓名：" + member.getName() + ",可用积分：" + member.getScore()
					+ ",开卡时间：" + member.getRegistDate() + "】");
		}
	}
	public void MainMethod() {
		//从数据库中查全部会员信息
		listM=ms.selectAllMembers();
		boolean isIn = true;
		do {
			showFirst();
			System.out.print("请选择：");
			switch (sc.nextInt()) {
			case 1:
				OpenCard();
				break;
			case 2:
				changePassword();
				break;
			case 3:
				scoresAdd();
				break;
			case 4:
				scoresConver();
				break;
			case 5:
				scoresRemain();
				break;
			case 6:
				LookMembers();
				break;
			case 7:
				isIn = false;
				break;
			}
		} while (isIn);
	}
	public static void main(String[] args) {
		MemberMgr memberMgr=new MemberMgr();
		memberMgr.MainMethod();
	}
}