❤️JavaWeb《超市订单管理系统—了解底层原理》（建议收藏）❤️
2024-04-10 03:02:26
SMBMS
图示
登录界面
主界面
订单管理页面
添加订单页面
供应商管理页面
供应商添加页面
用户管理页面
用户添加页面
修改密码页面
…
系统功能结构图：
数据库结构：
1、项目搭建前期准备
1.1.用webapp模板创建一个Maven项目
1.2.初始化配置pom.xml和web.xml
web.xml页面
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"version="4.0"metadata-complete="true"></web-app>
pom.xml页面
<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>sumasy</artifactId><version>1.0-SNAPSHOT</version><packaging>war</packaging></project>
1.3在src/main文件夹下创建java和resources目录并标记
1.4.配置Tomcat
1.5.在pom.xml中写入相应的依赖jar包
<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency><dependency><groupId>org.hamcrest</groupId><artifactId>hamcrest-core</artifactId><version>1.3</version>
</dependency><dependency><groupId>javax.servlet</groupId><artifactId>servlet-api</artifactId><version>2.5</version>
</dependency><dependency><groupId>javax.servlet.jsp</groupId><artifactId>javax.servlet.jsp-api</artifactId><version>2.3.3</version>
</dependency><dependency><groupId>javax.servlet.jsp</groupId><artifactId>jsp-api</artifactId><version>2.1</version>
</dependency><dependency><groupId>javax.servlet</groupId><artifactId>jstl</artifactId><version>1.2</version>
</dependency><dependency><groupId>taglibs</groupId><artifactId>standard</artifactId><version>1.1.2</version>
</dependency><!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.26</version>
</dependency><!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.61</version>
</dependency>
</dependencies>
1.6.创建项目包结构
1.7.连接smbms数据库
CREATE DATABASE `smbms`;USE `smbms`;DROP TABLE IF EXISTS `smbms_address`;CREATE TABLE `smbms_address` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',`contact` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '联系人姓名',`addressDesc` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '收货地址明细',`postCode` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '邮编',`tel` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '联系人电话',`createdBy` bigint(20) DEFAULT NULL COMMENT '创建者',`creationDate` datetime DEFAULT NULL COMMENT '创建时间',`modifyBy` bigint(20) DEFAULT NULL COMMENT '修改者',`modifyDate` datetime DEFAULT NULL COMMENT '修改时间',`userId` bigint(20) DEFAULT NULL COMMENT '用户ID',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;insert into `smbms_address`(`id`,`contact`,`addressDesc`,`postCode`,`tel`,`createdBy`,`creationDate`,`modifyBy`,`modifyDate`,`userId`) values (1,'王丽','北京市东城区东交民巷44号','100010','13678789999',1,'2016-04-13 00:00:00',NULL,NULL,1),(2,'张红丽','北京市海淀区丹棱街3号','100000','18567672312',1,'2016-04-13 00:00:00',NULL,NULL,1),(3,'任志强','北京市东城区美术馆后街23号','100021','13387906742',1,'2016-04-13 00:00:00',NULL,NULL,1),(4,'曹颖','北京市朝阳区朝阳门南大街14号','100053','13568902323',1,'2016-04-13 00:00:00',NULL,NULL,2),(5,'李慧','北京市西城区三里河路南三巷3号','100032','18032356666',1,'2016-04-13 00:00:00',NULL,NULL,3),(6,'王国强','北京市顺义区高丽营镇金马工业区18号','100061','13787882222',1,'2016-04-13 00:00:00',NULL,NULL,3);DROP TABLE IF EXISTS `smbms_bill`;CREATE TABLE `smbms_bill` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',`billCode` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '账单编码',`productName` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '商品名称',`productDesc` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '商品描述',`productUnit` varchar(10) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '商品单位',`productCount` decimal(20,2) DEFAULT NULL COMMENT '商品数量',`totalPrice` decimal(20,2) DEFAULT NULL COMMENT '商品总额',`isPayment` int(10) DEFAULT NULL COMMENT '是否支付（1：未支付 2：已支付）',`createdBy` bigint(20) DEFAULT NULL COMMENT '创建者（userId）',`creationDate` datetime DEFAULT NULL COMMENT '创建时间',`modifyBy` bigint(20) DEFAULT NULL COMMENT '更新者（userId）',`modifyDate` datetime DEFAULT NULL COMMENT '更新时间',`providerId` bigint(20) DEFAULT NULL COMMENT '供应商ID',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=19 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;insert into `smbms_bill`(`id`,`billCode`,`productName`,`productDesc`,`productUnit`,`productCount`,`totalPrice`,`isPayment`,`createdBy`,`creationDate`,`modifyBy`,`modifyDate`,`providerId`) values (2,'BILL2016_002','香皂、肥皂、药皂','日用品-皂类','块','1000.00','10000.00',2,1,'2016-03-23 04:20:40',NULL,NULL,13),(3,'BILL2016_003','大豆油','食品-食用油','斤','300.00','5890.00',2,1,'2014-12-14 13:02:03',NULL,NULL,6),(4,'BILL2016_004','橄榄油','食品-进口食用油','斤','200.00','9800.00',2,1,'2013-10-10 03:12:13',NULL,NULL,7),(5,'BILL2016_005','洗洁精','日用品-厨房清洁','瓶','500.00','7000.00',2,1,'2014-12-14 13:02:03',NULL,NULL,9),(6,'BILL2016_006','美国大杏仁','食品-坚果','袋','300.00','5000.00',2,1,'2016-04-14 06:08:09',NULL,NULL,4),(7,'BILL2016_007','沐浴液、精油','日用品-沐浴类','瓶','500.00','23000.00',1,1,'2016-07-22 10:10:22',NULL,NULL,14),(8,'BILL2016_008','不锈钢盘碗','日用品-厨房用具','个','600.00','6000.00',2,1,'2016-04-14 05:12:13',NULL,NULL,14),(9,'BILL2016_009','塑料杯','日用品-杯子','个','350.00','1750.00',2,1,'2016-02-04 11:40:20',NULL,NULL,14),(10,'BILL2016_010','豆瓣酱','食品-调料','瓶','200.00','2000.00',2,1,'2013-10-29 05:07:03',NULL,NULL,8),(11,'BILL2016_011','海之蓝','饮料-国酒','瓶','50.00','10000.00',1,1,'2016-04-14 16:16:00',NULL,NULL,1),(12,'BILL2016_012','芝华士','饮料-洋酒','瓶','20.00','6000.00',1,1,'2016-09-09 17:00:00',NULL,NULL,1),(13,'BILL2016_013','长城红葡萄酒','饮料-红酒','瓶','60.00','800.00',2,1,'2016-11-14 15:23:00',NULL,NULL,1),(14,'BILL2016_014','泰国香米','食品-大米','斤','400.00','5000.00',2,1,'2016-10-09 15:20:00',NULL,NULL,3),(15,'BILL2016_015','东北大米','食品-大米','斤','600.00','4000.00',2,1,'2016-11-14 14:00:00',NULL,NULL,3),(16,'BILL2016_016','可口可乐','饮料','瓶','2000.00','6000.00',2,1,'2012-03-27 13:03:01',NULL,NULL,2),(17,'BILL2016_017','脉动','饮料','瓶','1500.00','4500.00',2,1,'2016-05-10 12:00:00',NULL,NULL,2),(18,'BILL2016_018','哇哈哈','饮料','瓶','2000.00','4000.00',2,1,'2015-11-24 15:12:03',NULL,NULL,2);DROP TABLE IF EXISTS `smbms_provider`;CREATE TABLE `smbms_provider` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',`proCode` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '供应商编码',`proName` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '供应商名称',`proDesc` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '供应商详细描述',`proContact` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '供应商联系人',`proPhone` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '联系电话',`proAddress` varchar(50) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '地址',`proFax` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '传真',`createdBy` bigint(20) DEFAULT NULL COMMENT '创建者（userId）',`creationDate` datetime DEFAULT NULL COMMENT '创建时间',`modifyDate` datetime DEFAULT NULL COMMENT '更新时间',`modifyBy` bigint(20) DEFAULT NULL COMMENT '更新者（userId）',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=16 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;insert into `smbms_provider`(`id`,`proCode`,`proName`,`proDesc`,`proContact`,`proPhone`,`proAddress`,`proFax`,`createdBy`,`creationDate`,`modifyDate`,`modifyBy`) values (1,'BJ_GYS001','北京三木堂商贸有限公司','长期合作伙伴，主营产品:茅台、五粮液、郎酒、酒鬼酒、泸州老窖、赖茅酒、法国红酒等','张国强','13566667777','北京市丰台区育芳园北路','010-58858787',1,'2013-03-21 16:52:07',NULL,NULL),(2,'HB_GYS001','石家庄帅益食品贸易有限公司','长期合作伙伴，主营产品:饮料、水饮料、植物蛋白饮料、休闲食品、果汁饮料、功能饮料等','王军','13309094212','河北省石家庄新华区','0311-67738876',1,'2016-04-13 04:20:40',NULL,NULL),(3,'GZ_GYS001','深圳市泰香米业有限公司','初次合作伙伴，主营产品：良记金轮米,龙轮香米等','郑程瀚','13402013312','广东省深圳市福田区深南大道6006华丰大厦','0755-67776212',1,'2014-03-21 16:56:07',NULL,NULL),(4,'GZ_GYS002','深圳市喜来客商贸有限公司','长期合作伙伴，主营产品：坚果炒货.果脯蜜饯.天然花茶.营养豆豆.特色美食.进口食品.海味零食.肉脯肉','林妮','18599897645','广东省深圳市福龙工业区B2栋3楼西','0755-67772341',1,'2013-03-22 16:52:07',NULL,NULL),(5,'JS_GYS001','兴化佳美调味品厂','长期合作伙伴，主营产品：天然香辛料、鸡精、复合调味料','徐国洋','13754444221','江苏省兴化市林湖工业区','0523-21299098',1,'2015-11-22 16:52:07',NULL,NULL),(6,'BJ_GYS002','北京纳福尔食用油有限公司','长期合作伙伴，主营产品：山茶油、大豆油、花生油、橄榄油等','马莺','13422235678','北京市朝阳区珠江帝景1号楼','010-588634233',1,'2012-03-21 17:52:07',NULL,NULL),(7,'BJ_GYS003','北京国粮食用油有限公司','初次合作伙伴，主营产品：花生油、大豆油、小磨油等','王驰','13344441135','北京大兴青云店开发区','010-588134111',1,'2016-04-13 00:00:00',NULL,NULL),(8,'ZJ_GYS001','慈溪市广和绿色食品厂','长期合作伙伴，主营产品：豆瓣酱、黄豆酱、甜面酱，辣椒，大蒜等农产品','薛圣丹','18099953223','浙江省宁波市慈溪周巷小安村','0574-34449090',1,'2013-11-21 06:02:07',NULL,NULL),(9,'GX_GYS001','优百商贸有限公司','长期合作伙伴，主营产品：日化产品','李立国','13323566543','广西南宁市秀厢大道42-1号','0771-98861134',1,'2013-03-21 19:52:07',NULL,NULL),(10,'JS_GYS002','南京火头军信息技术有限公司','长期合作伙伴，主营产品：不锈钢厨具等','陈女士','13098992113','江苏省南京市浦口区浦口大道1号新城总部大厦A座903室','025-86223345',1,'2013-03-25 16:52:07',NULL,NULL),(11,'GZ_GYS003','广州市白云区美星五金制品厂','长期合作伙伴，主营产品：海绵床垫、坐垫、靠垫、海绵枕头、头枕等','梁天','13562276775','广州市白云区钟落潭镇福龙路20号','020-85542231',1,'2016-12-21 06:12:17',NULL,NULL),(12,'BJ_GYS004','北京隆盛日化科技','长期合作伙伴，主营产品：日化环保清洗剂，家居洗涤专卖、洗涤用品网、墙体除霉剂、墙面霉菌清除剂等','孙欣','13689865678','北京市大兴区旧宫','010-35576786',1,'2014-11-21 12:51:11',NULL,NULL),(13,'SD_GYS001','山东豪克华光联合发展有限公司','长期合作伙伴，主营产品：洗衣皂、洗衣粉、洗衣液、洗洁精、消杀类、香皂等','吴洪转','13245468787','山东济阳济北工业区仁和街21号','0531-53362445',1,'2015-01-28 10:52:07',NULL,NULL),(14,'JS_GYS003','无锡喜源坤商行','长期合作伙伴，主营产品：日化品批销','周一清','18567674532','江苏无锡盛岸西路','0510-32274422',1,'2016-04-23 11:11:11',NULL,NULL),(15,'ZJ_GYS002','乐摆日用品厂','长期合作伙伴，主营产品：各种中、高档塑料杯，塑料乐扣水杯（密封杯）、保鲜杯（保鲜盒）、广告杯、礼品杯','王世杰','13212331567','浙江省金华市义乌市义东路','0579-34452321',1,'2016-08-22 10:01:30',NULL,NULL);DROP TABLE IF EXISTS `smbms_role`;CREATE TABLE `smbms_role` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',`roleCode` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '角色编码',`roleName` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '角色名称',`createdBy` bigint(20) DEFAULT NULL COMMENT '创建者',`creationDate` datetime DEFAULT NULL COMMENT '创建时间',`modifyBy` bigint(20) DEFAULT NULL COMMENT '修改者',`modifyDate` datetime DEFAULT NULL COMMENT '修改时间',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;insert into `smbms_role`(`id`,`roleCode`,`roleName`,`createdBy`,`creationDate`,`modifyBy`,`modifyDate`) values (1,'SMBMS_ADMIN','系统管理员',1,'2016-04-13 00:00:00',NULL,NULL),(2,'SMBMS_MANAGER','经理',1,'2016-04-13 00:00:00',NULL,NULL),(3,'SMBMS_EMPLOYEE','普通员工',1,'2016-04-13 00:00:00',NULL,NULL);DROP TABLE IF EXISTS `smbms_user`;CREATE TABLE `smbms_user` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',`userCode` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '用户编码',`userName` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '用户名称',`userPassword` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '用户密码',`gender` int(10) DEFAULT NULL COMMENT '性别（1:女、 2:男）',`birthday` date DEFAULT NULL COMMENT '出生日期',`phone` varchar(15) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '手机',`address` varchar(30) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '地址',`userRole` bigint(20) DEFAULT NULL COMMENT '用户角色（取自角色表-角色id）',`createdBy` bigint(20) DEFAULT NULL COMMENT '创建者（userId）',`creationDate` datetime DEFAULT NULL COMMENT '创建时间',`modifyBy` bigint(20) DEFAULT NULL COMMENT '更新者（userId）',`modifyDate` datetime DEFAULT NULL COMMENT '更新时间',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=16 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;insert into `smbms_user`(`id`,`userCode`,`userName`,`userPassword`,`gender`,`birthday`,`phone`,`address`,`userRole`,`createdBy`,`creationDate`,`modifyBy`,`modifyDate`) values (1,'admin','系统管理员','1234567',1,'1983-10-10','13688889999','北京市海淀区成府路207号',1,1,'2013-03-21 16:52:07',NULL,NULL),(2,'liming','李明','0000000',2,'1983-12-10','13688884457','北京市东城区前门东大街9号',2,1,'2014-12-31 19:52:09',NULL,NULL),(5,'hanlubiao','韩路彪','0000000',2,'1984-06-05','18567542321','北京市朝阳区北辰中心12号',2,1,'2014-12-31 19:52:09',NULL,NULL),(6,'zhanghua','张华','0000000',1,'1983-06-15','13544561111','北京市海淀区学院路61号',3,1,'2013-02-11 10:51:17',NULL,NULL),(7,'wangyang','王洋','0000000',2,'1982-12-31','13444561124','北京市海淀区西二旗辉煌国际16层',3,1,'2014-06-11 19:09:07',NULL,NULL),(8,'zhaoyan','赵燕','0000000',1,'1986-03-07','18098764545','北京市海淀区回龙观小区10号楼',3,1,'2016-04-21 13:54:07',NULL,NULL),(10,'sunlei','孙磊','0000000',2,'1981-01-04','13387676765','北京市朝阳区管庄新月小区12楼',3,1,'2015-05-06 10:52:07',NULL,NULL),(11,'sunxing','孙兴','0000000',2,'1978-03-12','13367890900','北京市朝阳区建国门南大街10号',3,1,'2016-11-09 16:51:17',NULL,NULL),(12,'zhangchen','张晨','0000000',1,'1986-03-28','18098765434','朝阳区管庄路口北柏林爱乐三期13号楼',3,1,'2016-08-09 05:52:37',1,'2016-04-14 14:15:36'),(13,'dengchao','邓超','0000000',2,'1981-11-04','13689674534','北京市海淀区北航家属院10号楼',3,1,'2016-07-11 08:02:47',NULL,NULL),(14,'yangguo','杨过','0000000',2,'1980-01-01','13388886623','北京市朝阳区北苑家园茉莉园20号楼',3,1,'2015-02-01 03:52:07',NULL,NULL),(15,'zhaomin','赵敏','0000000',1,'1987-12-04','18099897657','北京市昌平区天通苑3区12号楼',2,1,'2015-09-12 12:02:12',NULL,NULL);
1.8.IDEA连接数据库
****
1.9.编写实体类
pojo下编写对应数据库表的实体类，分类为Bill Provider Role User
Bill
package com.kk.pojo;import java.math.BigDecimal;
import java.util.Date;public class Bill {private Integer id; //idprivate String billCode; //账单编码private String productName; //商品名称private String productDesc; //商品描述private String productUnit; //商品单位private BigDecimal productCount; //商品数量private BigDecimal totalPrice; //总金额private Integer isPayment; //是否支付private Integer providerId; //供应商IDprivate Integer createBy; //创建者private Date creationDate; //创建时间private Integer modifyBy; //更新者private Date modifyDate;//更新时间private String providerName;//供应商名称public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getBillCode() {return billCode;}public void setBillCode(String billCode) {this.billCode = billCode;}public String getProductName() {return productName;}public void setProductName(String productName) {this.productName = productName;}public String getProductDesc() {return productDesc;}public void setProductDesc(String productDesc) {this.productDesc = productDesc;}public String getProductUnit() {return productUnit;}public void setProductUnit(String productUnit) {this.productUnit = productUnit;}public BigDecimal getProductCount() {return productCount;}public void setProductCount(BigDecimal productCount) {this.productCount = productCount;}public BigDecimal getTotalPrice() {return totalPrice;}public void setTotalPrice(BigDecimal totalPrice) {this.totalPrice = totalPrice;}public Integer getIsPayment() {return isPayment;}public void setIsPayment(Integer isPayment) {this.isPayment = isPayment;}public Integer getProviderId() {return providerId;}public void setProviderId(Integer providerId) {this.providerId = providerId;}public Integer getCreateBy() {return createBy;}public void setCreateBy(Integer createBy) {this.createBy = createBy;}public Date getCreationDate() {return creationDate;}public void setCreationDate(Date creationDate) {this.creationDate = creationDate;}public Integer getModifyBy() {return modifyBy;}public void setModifyBy(Integer modifyBy) {this.modifyBy = modifyBy;}public Date getModifyDate() {return modifyDate;}public void setModifyDate(Date modifyDate) {this.modifyDate = modifyDate;}public String getProviderName() {return providerName;}public void setProviderName(String providerName) {this.providerName = providerName;}
}
Provider
package com.kk.pojo;import java.util.Date;public class Provider {private Integer id; //idprivate String proCode; //供应商编码private String proName; //供应商名称private String proDesc; //供应商描述private String proContact; //供应商联系人private String proPhone; //供应商电话private String proAddress; //供应商地址private String proFax; //供应商传真private Integer createBy; //创建者private Date creationDate; //创建时间private Integer modifyBy; //更新者private Date modifyDate;//更新时间public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getProCode() {return proCode;}public void setProCode(String proCode) {this.proCode = proCode;}public String getProName() {return proName;}public void setProName(String proName) {this.proName = proName;}public String getProDesc() {return proDesc;}public void setProDesc(String proDesc) {this.proDesc = proDesc;}public String getProContact() {return proContact;}public void setProContact(String proContact) {this.proContact = proContact;}public String getProPhone() {return proPhone;}public void setProPhone(String proPhone) {this.proPhone = proPhone;}public String getProAddress() {return proAddress;}public void setProAddress(String proAddress) {this.proAddress = proAddress;}public String getProFax() {return proFax;}public void setProFax(String proFax) {this.proFax = proFax;}public Integer getCreateBy() {return createBy;}public void setCreateBy(Integer createBy) {this.createBy = createBy;}public Date getCreationDate() {return creationDate;}public void setCreationDate(Date creationDate) {this.creationDate = creationDate;}public Integer getModifyBy() {return modifyBy;}public void setModifyBy(Integer modifyBy) {this.modifyBy = modifyBy;}public Date getModifyDate() {return modifyDate;}public void setModifyDate(Date modifyDate) {this.modifyDate = modifyDate;}
}
Role
package com.kk.pojo;import java.util.Date;public class Role {private Integer id; //idprivate String roleCode; //角色编码private String roleName; //角色名称private Integer createBy; //创建者private Date creationDate; //创建时间private Integer modifyBy; //更新者private Date modifyDate;//更新时间public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getRoleCode() {return roleCode;}public void setRoleCode(String roleCode) {this.roleCode = roleCode;}public String getRoleName() {return roleName;}public void setRoleName(String roleName) {this.roleName = roleName;}public Integer getCreateBy() {return createBy;}public void setCreatedBy(Integer createBy) {this.createBy = createBy;}public Date getCreationDate() {return creationDate;}public void setCreationDate(Date creationDate) {this.creationDate = creationDate;}public Integer getModifyBy() {return modifyBy;}public void setModifyBy(Integer modifyBy) {this.modifyBy = modifyBy;}public Date getModifyDate() {return modifyDate;}public void setModifyDate(Date modifyDate) {this.modifyDate = modifyDate;}
}
User
package com.kk.pojo;import java.util.Date;public class User {private Integer id; //idprivate String userCode; //用户编码private String userName; //用户名称private String userPassword; //用户密码private Integer gender; //性别private Date birthday; //出生日期private String phone; //电话private String address; //地址private Integer userRole; //用户角色private Integer createBy; //创建者private Date creationDate; //创建时间private Integer modifyBy; //更新者private Date modifyDate; //更新时间private Integer age;//年龄private String userRoleName; //用户角色名称public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getUserCode() {return userCode;}public void setUserCode(String userCode) {this.userCode = userCode;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName = userName;}public String getUserPassword() {return userPassword;}public void setUserPassword(String userPassword) {this.userPassword = userPassword;}public Integer getGender() {return gender;}public void setGender(Integer gender) {this.gender = gender;}public Date getBirthday() {return birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}public String getPhone() {return phone;}public void setPhone(String phone) {this.phone = phone;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}public Integer getUserRole() {return userRole;}public void setUserRole(Integer userRole) {this.userRole = userRole;}public Integer getCreateBy() {return createBy;}public void setCreateBy(Integer createBy) {this.createBy = createBy;}public Date getCreationDate() {return creationDate;}public void setCreationDate(Date creationDate) {this.creationDate = creationDate;}public Integer getModifyBy() {return modifyBy;}public void setModifyBy(Integer modifyBy) {this.modifyBy = modifyBy;}public Date getModifyDate() {return modifyDate;}public void setModifyDate(Date modifyDate) {this.modifyDate = modifyDate;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}public String getUserRoleName() {return userRoleName;}public void setUserRoleName(String userRoleName) {this.userRoleName = userRoleName;}
}
1.9.1. 数据库配置文件
resources下新建db.properties文件
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/smbms?useUnicode=true&characterEncoding=UTF-8&useSSL=true&serverTimezone=UTC
username=root
password=123456
1.9.2 编写数据库的公共类
在dao下新建BaseDao类用于读取上面的数据库配置文件
package com.kk.dao;import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;public class BaseDao {private static String driver;private static String url;private static String username;private static String password;//静态代码块，类加载的时候就初始化了static {Properties properties = new Properties();//通过类加载器读取对应的资源InputStream is = BaseDao.class.getClassLoader().getResourceAsStream("db.properties");try {properties.load(is);} catch (IOException e) {e.printStackTrace();}driver = properties.getProperty("driver");url = properties.getProperty("url");username = properties.getProperty("username");password = properties.getProperty("password");}//获取数据库的链接public static Connection getConnection(){Connection connection = null;try {Class.forName(driver);connection = DriverManager.getConnection(url, username, password);} catch (Exception e) {e.printStackTrace();}return connection;}//编写查询公共方法public static ResultSet execute(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet, String sql, Object[] params) throws SQLException {//预编译的sql，在后面直接执行就可以了preparedStatement = connection.prepareStatement(sql);for (int i = 0; i < params.length; i++) {//setObject,占位符从1开始，但是我们的数组是从0开始！preparedStatement.setObject(i+1,params[i]);}resultSet = preparedStatement.executeQuery();return resultSet;}//编写增删改公共方法public static int execute(Connection connection,PreparedStatement preparedStatement,String sql,Object[] params) throws SQLException {preparedStatement = connection.prepareStatement(sql);for (int i = 0; i < params.length; i++) {//setObject,占位符从1开始，但是我们的数组是从0开始！preparedStatement.setObject(i+1,params[i]);}int updateRows = preparedStatement.executeUpdate();return updateRows;}//释放资源public static boolean closeResource(Connection connection,PreparedStatement preparedStatement,ResultSet resultSet){boolean flag = true;if (resultSet!=null){try {resultSet.close();//GC回收resultSet = null;} catch (SQLException e) {e.printStackTrace();flag = false;}}if (preparedStatement!=null){try {preparedStatement.close();//GC回收preparedStatement = null;} catch (SQLException e) {e.printStackTrace();flag = false;}}if (connection!=null){try {connection.close();//GC回收connection = null;} catch (SQLException e) {e.printStackTrace();flag = false;}}return flag;}}
1.9.3 编写字符编码过滤器
CharacterEncodingFilter
package com.kk.filter;import javax.servlet.*;
import java.io.IOException;public class CharacterEncodingFilter implements Filter {@Overridepublic void init(FilterConfig filterConfig) throws ServletException {}@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {request.setCharacterEncoding("utf-8");response.setCharacterEncoding("utf-8");chain.doFilter(request,response);}@Overridepublic void destroy() {}
}
SysFilter
package com.kk.filter;import com.kk.pojo.User;import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;public class SysFilter implements Filter {@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {HttpServletRequest rq = (HttpServletRequest) request;HttpServletResponse rp = (HttpServletResponse) response;//过滤器，从session中获取用户User userSession = (User) rq.getSession().getAttribute("userSession");if (null == userSession) {rp.sendRedirect("/error.jsp");} else {chain.doFilter(request, response);}}@Overridepublic void destroy() {}@Overridepublic void init(FilterConfig filterConfig) throws ServletException {}}
在web.xml注册
<!--字符编码过滤器-->
<filter><filter-name>CharacterEncodingFilter</filter-name><filter-class>com.kk.filter.CharacterEncodingFilter</filter-class>
</filter>
<filter-mapping><filter-name>CharacterEncodingFilter</filter-name><url-pattern>/*</url-pattern>
</filter-mapping><!-- 用户登录过滤器-->
<filter><filter-name>SysFilter</filter-name><filter-class>com.kk.filter.SysFilter</filter-class>
</filter>
<filter-mapping><filter-name>SysFilter</filter-name><url-pattern>/jsp/*</url-pattern>
</filter-mapping>
1.10.导入静态资源
链接：https://pan.baidu.com/s/1MXLlcg1t0tCcXVjC3HYh_A
提取码：kk80
2、登陆功能的实现
实现流程结构
2.1.编写前端页面
2.1.1.登陆界面login.jsp
<%@ page language="java" contentType="text/html; charset=UTF-8"pageEncoding="UTF-8" %><html>
<head lang="en"><meta charset="UTF-8"><title>系统登录 - 超市订单管理系统</title><link type="text/css" rel="stylesheet" href="${pageContext.request.contextPath}/css/style.css"/>
</head>
<body class="login_bg">
<section class="loginBox"><header class="loginHeader"><h1>超市订单管理系统</h1></header><section class="loginCont"><form class="loginForm" action="${pageContext.request.contextPath}/login.do" method="post" name="actionForm"id="actionForm"><div class="info">${error}</div><div class="inputbox"><label for="userCode">用户名：</label><input type="text" class="input-text" id="userCode" name="userCode" placeholder="请输入用户名" required/></div><div class="inputbox"><label for="userPassword">密码：</label><input type="password" id="userPassword" name="userPassword" placeholder="请输入密码" required/></div><div class="subBtn"><input type="submit" value="登录"/><input type="reset" value="重置"/></div></form></section>
</section>
</body>
</html>
2.1.2.将登陆页面设置为首页
注册web.xml
<!-- 设置欢迎页面-->
<welcome-file-list><welcome-file>login.jsp</welcome-file>
</welcome-file-list>
2.1.3 编写dao层用户登录的接口UserDao
在dao中建立一个user包，在包中建一个UserDao接口
package com.kk.dao.user;import com.kk.pojo.User;import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;public interface UserDao {//得到要登陆的用户public User getLoginUser(Connection connection, String userCode) throws SQLException;}
2.1.4 编写UserDao接口的实现类UserDaoImpl
package com.kk.dao.user;import com.kk.dao.BaseDao;
import com.kk.pojo.User;
import com.mysql.cj.util.StringUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;public class UserDaoImp implements UserDao{//得到(查找)要登陆的用户@Overridepublic User getLoginUser(Connection connection, String userCode) throws SQLException {PreparedStatement pstm=null;ResultSet rs=null;User user =null;if (connection!=null){String sql="select * from smbms_user where userCode=?";Object[] params={userCode};rs = BaseDao.execute(connection,pstm, rs,sql,params);if (rs.next()){user = new User();user.setId((int) rs.getLong("id"));user.setUserCode(rs.getString("userCode"));user.setUserName(rs.getString("userName"));user.setUserPassword(rs.getString("userPassword"));user.setGender(rs.getInt("gender"));//getDate只返回日期即哪一天；getTime只返回具体时间；getTimestamp返回日期和时间user.setBirthday(rs.getDate("birthday"));user.setPhone(rs.getString("phone"));user.setAddress(rs.getString("address"));user.setUserRole((int) rs.getLong("userRole"));user.setCreateBy((int) rs.getLong("createBy"));user.setCreationDate(rs.getTimestamp("creationDate"));user.setModifyBy((int) rs.getLong("modifyBy"));user.setModifyDate(rs.getTimestamp("modifyDate"));}//connection先不用关，可能存在业务BaseDao.closeResource(null,pstm,rs);}return user;}}
2.1.5 编写业务层接口
在service下建立user包，建立UserService接口
package com.kk.service.user;import com.kk.pojo.User;import java.util.List;public interface UserService {//用户登录public User login(String userCode, String password);}
2.1.6 编写业务层接口的实现类
在service的user包中建立UserServiceImp
package com.kk.service.user;import com.kk.dao.BaseDao;
import com.kk.dao.user.UserDao;
import com.kk.dao.user.UserDaoImp;
import com.kk.pojo.User;import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;public class UserServiceImp implements UserService{//调用Dao层private UserDao userDao;public UserServiceImp(){userDao = new UserDaoImp();}//用户登录@Overridepublic User login(String userCode, String password) {Connection connection = null;User user = null;try {connection = BaseDao.getConnection();//通过业务层调用对应的具体的数据库操作user = userDao.getLoginUser(connection, userCode);//通过调用userDao 再取到getLoginUser的方法} catch (SQLException e) {e.printStackTrace();}finally {BaseDao.closeResource(connection,null,null);}//匹配密码if (null != user) {if (!user.getUserPassword().equals(password)) {user = null;}}return user;}}
2.1.7 编写Servlet类
在Servlet包中创建user包，在user包中建立LoginServlet类
package com.kk.servlet.user;import com.kk.pojo.User;
import com.kk.service.user.UserServiceImp;
import com.kk.util.Constants;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;public class LoginServlet extends HttpServlet {//Servlet:控制层 调用业务代码层@Overrideprotected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {System.out.println("LoginServlet---start");//获取用户名和密码String userCode = req.getParameter("userCode");String userPassword = req.getParameter("userPassword");//和数据库中的密码进行对比 调用业务层UserServiceImp userService = new UserServiceImp(); //调用service方法，进行用户匹配User user = userService.login(userCode, userPassword);//这里已经把登录的用户给查出来了if (user != null) {//查到有这位用户 可以登录if(user.getUserPassword().equals(userPassword)) {//请求取到session 设置setAttribute 将数据放入参数里边req.getSession().setAttribute(Constants.USER_SESSION, user); //登录成功后 将用户的信息放到session中//跳转到内部主页resp.sendRedirect("/jsp/frame.jsp");} else{//转发回登录页面，提示用户名或密码错误req.setAttribute("error","用户名或密码错误");req.getRequestDispatcher("/login.jsp").forward(req,resp);}}else{//没有查到 无法登录//转发回登录页面 顺带提示 用户名或者密码错误req.setAttribute("error","用户名或者密码错误");req.getRequestDispatcher("/login.jsp").forward(req,resp);}}@Overrideprotected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {doGet(req, resp);}
}
3、登陆功能的优化
3.1.注销功能
移除session，返回登录页面,servlet.user下创建LogoutServlet类
package com.kk.servlet.user;import com.kk.util.Constants;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;public class LogoutServlet extends HttpServlet {@Overrideprotected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {//移除用户的session Constants.USER_SESSIONreq.getSession().removeAttribute(Constants.USER_SESSION);resp.sendRedirect("/login.jsp"); //返回登录页面}@Overrideprotected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {doGet(req, resp);}
}
在web.xml中注册这个注销的servlet
<servlet><servlet-name>LogoutServlet</servlet-name><servlet-class>com.kk.servlet.user.LogoutServlet</servlet-class>
</servlet>
<servlet-mapping><servlet-name>LogoutServlet</servlet-name><url-pattern>/jsp/logout.do</url-pattern>
</servlet-mapping>
3.2.登陆拦截器
在filter下创建SysFilter类
package com.kk.filter;import com.kk.pojo.User;import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;public class SysFilter implements Filter {@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {HttpServletRequest rq = (HttpServletRequest) request;HttpServletResponse rp = (HttpServletResponse) response;//过滤器，从session中获取用户User userSession = (User) rq.getSession().getAttribute("userSession");if (null == userSession) {rp.sendRedirect("/error.jsp");} else {chain.doFilter(request, response);}}@Overridepublic void destroy() {}@Overridepublic void init(FilterConfig filterConfig) throws ServletException {}}
在web.xml注册
<!-- 用户登录过滤器-->
<filter><filter-name>SysFilter</filter-name><filter-class>com.kk.filter.SysFilter</filter-class>
</filter>
<filter-mapping><filter-name>SysFilter</filter-name><url-pattern>/jsp/*</url-pattern>
</filter-mapping>
3.3.密码修改
自顶向下设计，自底向上实现
- 先写dao层–>再写service层–>最后在写servlet层
3.3.1 编写dao层用户修改密码的接口UserDao
在dao.user.UserDao的接口下增加updatepwd
//修改当前用户密码 增删改都是int类型public int updatePwd(Connection connection,int id, String password) throws SQLException;
3.3.2 编写dao层用户修改密码的接口实现类
UserDaoImpl下增加
//修改当前用户密码 增删改都是int类型
@Override
public int updatePwd(Connection connection, int id, String password) throws SQLException {PreparedStatement pstm= null; //执行对象（用它来执行编译）int flag=0;if (connection!=null){String sql = "update smbms_user set userPassword = ? where id =?";Object params[] = {password,id};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null,pstm,null);}return flag;
}
3.3.3 编写业务层Service的用户修改密码的接口
UserService下增加
//根据用户id 修改密码
@Override
public boolean updatePwd(int id, String password) {System.out.println("UserServlet:"+password);Connection connection =null;boolean flag=false;//修改密码try {connection = BaseDao.getConnection(); //调用Dao层 获得数据库连接 就可以做数据库的任何事情if (userDao.updatePwd(connection,id,password)>0){flag=true;}} catch (SQLException e) {e.printStackTrace();}finally {BaseDao.closeResource(connection,null,null);}return flag;
}
3.3.密码修改
3.3.5 编写修改密码的Servlet类
servlet.user 下新增UserServl
String method = req.getParameter("method");if (method!=null&&method.equals("savepwd")){this.updatePwd(req,resp);}//修改密码
public void updatePwd(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {//从Session获取IdObject o = req.getSession().getAttribute(Constants.USER_SESSION);String newpassword = req.getParameter("newpassword");System.out.println("UserServlet:"+newpassword);boolean flag =false;//!StringUtils.isNullOrEmpty(newpassword)if(o!=null&& newpassword!=null&& newpassword.length()!=0){UserServiceImp userService = new UserServiceImp();//将 o 强制转换为新的对象 （User）flag = userService.updatePwd(((User) o).getId(), newpassword);if (flag){//给前端页面展示信息req.getSession().setAttribute("message","修改密码成功，请退出重新登录!");//密码修改成功，移除当前sessionreq.getSession().removeAttribute(Constants.USER_SESSION);}else{req.getSession().setAttribute("message","密码修改失败!");}}else{req.getSession().setAttribute("message","新密码有问题!");}req.getRequestDispatcher("/jsp/pwdmodify.jsp").forward(req,resp);
3.4.使用Ajax优化密码修改
阿里巴巴的fastjson.jar包
<!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.61</version>
</dependency>
</dependencies>
编写验证旧密码的servlet类，servlet方法复用
else if ( method!=null&&method.equals("pwdmodify")){this.pwdmodify(req,resp);
}//验证旧密码 session中有用户的密码public void pwdmodify(HttpServletRequest req, HttpServletResponse resp) {//从Session里边拿到idObject o = req.getSession().getAttribute(Constants.USER_SESSION);String oldpassword=req.getParameter("oldpassword");//万能Map ： 结果集Map<String, String> resultMap = new HashMap<String,String>();if (o==null){//Session失效 Session过期了resultMap.put("result","sessionerror");}else if (StringUtils.isNullOrEmpty(oldpassword)){//输入的密码为空resultMap.put("result","error");}else{String userPassword = ((User) o).getUserPassword();//session中用户的密码if (oldpassword.equals(userPassword)){resultMap.put("result","true");}else{resultMap.put("result","false");}}try {resp.setContentType("application/json");PrintWriter writer = resp.getWriter(); //流//JSONArray 阿里巴巴 json工具类 转换格式writer.write(JSONArray.toJSONString(resultMap));writer.flush();writer.close();} catch (IOException e) {e.printStackTrace();}}4、用户管理模块实现
结构流程图
静态资源需要导入分页的工具类 页面还需要导入用户列表 按照自底向上的流程，编写顺序
dao DaoImpl Service ServiceImpl Servlet
4.1 获取用户的数量
首先是UserDao接口添加一个函数
//根据用户名或者角色查询用户总数
public int getUserCount(Connection connection,String userName,int userRole) throws SQLException;
UserDaoImpl里实现上面接口里新增的函数
//根据用户名或者角色查询用户总数
@Override
public int getUserCount(Connection connection, String userName, int userRole) throws SQLException {PreparedStatement pstm=null; //执行对象（用它来执行编译）ResultSet rs=null; //需要返回结果集int count =0;int startIndex=0;List<User> userList=new ArrayList<User>();if (connection!=null){StringBuffer sql= new StringBuffer();sql.append("select count(1) as count from smbms_user u,smbms_role r where u.userRole=r.id");ArrayList<Object> list = new ArrayList<Object>();//用来存放我们的参数if (!StringUtils.isNullOrEmpty(userName)){sql.append(" and u.userName like ?");list.add("%"+userName+"%"); //sql中 用 %？%的形式 模糊查询 这里index从0开始}if (userRole>0){sql.append(" and u.userRole = ?");list.add(userRole); //这里index 从1 开始}//如何把list转换为数组Object[] params = list.toArray();rs = BaseDao.execute(connection, pstm, rs, sql.toString(), params);if (rs.next()){//从结果中获取最终的数量count = rs.getInt("count");}BaseDao.closeResource(null,pstm,rs);}return count;
}
UserService接口里面增加一个新的函数
//查询记录数
public int getUserCount(String queryUserName,int queryUserRole);
在UserServiceImpl实现这个方法
//查询记录数
@Override
public int getUserCount(String queryUserName, int queryUserRole) {Connection connection=null;int count=0;try {connection = BaseDao.getConnection();//调取dao层count = userDao.getUserCount(connection, queryUserName, queryUserRole);//得到数量} catch (SQLException throwables) {throwables.printStackTrace();}finally {BaseDao.closeResource(connection, null,null);}return count;
}
4.2 根据输入的条件获取当前的用户列表
首先是UserDao接口添加一个函数
//通过条件查询 获取用户列表 userlist
public List<User> getUserList(Connection connection, String userName, int userRole, int currentPageNo, int pageSize) throws SQLException;
UserDaoImpl里实现上面接口里新增的函数
//通过条件查询userlist
@Override
public List<User> getUserList(Connection connection, String userName, int userRole, int currentPageNo, int pageSize) throws SQLException {PreparedStatement pstm = null;ResultSet rs = null;List<User> userList = new ArrayList<User>();if (connection != null) {StringBuffer sql = new StringBuffer();sql.append("select u.*,r.roleName as userRoleName from smbms_user u,smbms_role r where u.userRole = r.id");List<Object> list = new ArrayList<Object>();if (!StringUtils.isNullOrEmpty(userName)) {sql.append(" and u.userName like ?");list.add("%" + userName + "%");}if (userRole > 0) {sql.append(" and u.userRole = ?");list.add(userRole);}//数据库中分页使用limit startIndex，pageSize（当前页起始页码和页面容量两个参数）//其中startIndex=（当前页码-1）*页面容量;order by:排序；DESC：降序sql.append(" order by creationDate DESC limit ?,?");currentPageNo=(currentPageNo-1)*pageSize;list.add(currentPageNo);list.add(pageSize);Object[] params = list.toArray();rs = BaseDao.execute(connection,pstm, rs,sql.toString(),params);while (rs.next()){User _user = new User();_user.setId(rs.getInt("id"));_user.setUserCode(rs.getString("userCode"));_user.setUserName(rs.getString("userName"));_user.setGender(rs.getInt("gender"));_user.setBirthday(rs.getDate("birthday"));_user.setPhone(rs.getString("phone"));_user.setUserRole(rs.getInt("userRole"));_user.setUserRoleName(rs.getString("userRoleName"));userList.add(_user);}BaseDao.closeResource(null,pstm,rs);}return userList;
}
UserService接口里面增加一个新的函数
//根据条件查询用户列表
public List<User> getUserList(String queryUserName, int queryUserRole, int currentPageNo, int pageSize);
在UserServiceImpl实现这个方法
//根据条件查询用户列表
@Override
public List<User> getUserList(String queryUserName, int queryUserRole, int currentPageNo, int pageSize) {Connection connection=null;List<User> userList=null;try {connection = BaseDao.getConnection();userList = userDao.getUserList(connection, queryUserName, queryUserRole, currentPageNo, pageSize);} catch (SQLException throwables) {throwables.printStackTrace();}finally {BaseDao.closeResource(connection,null,null);}return userList;
}
4.3 根据用户输入的条件获取当前的用户角色栏
首先在dao层新建role目录，新建roledao
在roledao接口添加一个函数
package com.kk.dao.role;import com.kk.pojo.Role;
import java.sql.Connection;
import java.util.ArrayList;public interface roledao {public ArrayList<Role> getRoleList(Connection connection) throws Exception;}
然后在dao层role目录下新建roledaoImpl实现接口
package com.kk.dao.role;import com.kk.dao.BaseDao;
import com.kk.pojo.Role;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;public class roledaoImp implements roledao {@Overridepublic ArrayList<Role> getRoleList(Connection connection) throws Exception {PreparedStatement pstm = null;ResultSet rs = null;ArrayList<Role> roleList = new ArrayList<Role>();if (connection != null) {String sql = "select * from smbms_role";Object[] params = {};rs = BaseDao.execute(connection, pstm, rs, sql, params);while (rs.next()) {com.kk.pojo.Role _role = new com.kk.pojo.Role();_role.setId(rs.getInt("id"));_role.setRoleCode(rs.getString("roleCode"));_role.setRoleName(rs.getString("roleName"));roleList.add(_role);}BaseDao.closeResource(null, pstm, rs);}return roleList;}}
在service层新建role目录，新建roleService接口
package com.kk.service.role;import com.kk.pojo.Role;import java.util.List;public interface roleService {//获取角色列表public List<Role> getRoleList();}
在service层role目录下，新建RoleServiceImlp接口实现
package com.kk.service.role;import com.kk.dao.BaseDao;
import com.kk.dao.role.roledao;
import com.kk.dao.role.roledaoImp;
import com.kk.pojo.Role;import java.sql.Connection;
import java.util.List;
public class roleServiceImp implements roleService {//引入Daoprivate roledao roledao;public roleServiceImp(){roledao = new roledaoImp();}@Overridepublic List<Role> getRoleList() {Connection connection = null;List<Role> roleList= null;try {connection = BaseDao.getConnection(); //获取连接执行操作roleList =roledao.getRoleList(connection);//获取的连接给roleList} catch (Exception e) {e.printStackTrace();}finally {BaseDao.closeResource(connection,null,null);}return roleList;}
}
4.4 .用户管理query模块的Servlet编写
else if( method!=null&&method.equals("query")){this.query(req,resp);//查询用户列表public void query(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException{//从前端获取数据String queryUserName = req.getParameter("queryname");String temp = req.getParameter("queryUserRole");String pageIndex = req.getParameter("pageIndex");int queryUserRole = 0;// 获取用户列表UserServiceImp userService = new UserServiceImp();List<User> userList=null;//第一次走这个请求，一定是第一页 页面大小是固定的int pageSize = Constants.pageSize; //可以把这个写到配置文件里 方便后期修改int currentPageNo=1;if(queryUserName==null){queryUserName="";}if (temp!=null&&!temp.equals("")){queryUserRole = Integer.parseInt(temp);//给查询赋值}if (pageIndex != null) {try {currentPageNo = Integer.valueOf(pageIndex);} catch (NumberFormatException e) {resp.sendRedirect("error.jsp");}}//获取用户总数 (分页 上一页 下一页的情况)int totalCount = userService.getUserCount(queryUserName, queryUserRole);//总页数pageSupport pageSupport = new pageSupport();pageSupport.setCurrentPageNo(currentPageNo); //当前页pageSupport.setPageSize(pageSize); //页面大小pageSupport.setTotalCount(totalCount); //总数量int totalPageCount =(int) (totalCount/pageSize)+1;//控制首页和尾页//如果页面要小于1 就显示第一页的东西if (totalPageCount<1){currentPageNo = 1;}if(currentPageNo>totalPageCount){//当前页面大于最后一页currentPageNo=totalPageCount;}//获取用户列表展示userList = userService.getUserList(queryUserName, queryUserRole, currentPageNo, pageSize);req.setAttribute("userList",userList);roleServiceImp roleService = new roleServiceImp();List<Role> roleList = null;roleList = roleService.getRoleList();req.setAttribute("roleList", roleList);req.setAttribute("totalCount", totalCount);req.setAttribute("currentPageNo", currentPageNo);req.setAttribute("totalPageCount", totalPageCount);req.setAttribute("queryUserName", queryUserName);req.setAttribute("queryUserRole", queryUserRole);//返回前端req.getRequestDispatcher("userlist.jsp").forward(req,resp);}4.5 用户管理模块的增删改查
Dao
//添加用户信息
int add(Connection connection, User user) throws Exception;//通过userId删除user
int deleteUserById(Connection connection, Integer delId) throws Exception;//通过userId获取user
User getUserById(Connection connection, String id) throws Exception;//修改用户信息
int modify(Connection connection, User user) throws Exception;
DaoImpl
// 添加用户信息
@Override
public int add(Connection connection, User user) throws Exception {PreparedStatement pstm = null;int updateRows = 0;if (null != connection) {String sql = "insert into smbms_user (userCode,userName,userPassword," +"userRole,gender,birthday,phone,address,creationDate,createBy) " +"values(?,?,?,?,?,?,?,?,?,?)";Object[] params = {user.getUserCode(), user.getUserName(), user.getUserPassword(),user.getUserRole(), user.getGender(), user.getBirthday(),user.getPhone(), user.getAddress(), user.getCreationDate(), user.getCreateBy()};updateRows = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return updateRows;
}//删除用户信息
@Override
public int deleteUserById(Connection connection, Integer delId) throws Exception {PreparedStatement pstm = null;int flag = 0;if (null != connection) {String sql = "delete from smbms_user where id=?";Object[] params = {delId};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;
}//通过userId获取user
@Override
public User getUserById(Connection connection, String id) throws Exception {User user = null;PreparedStatement pstm = null;ResultSet rs = null;if (null != connection) {String sql = "select u.*,r.roleName as userRoleName from smbms_user u,smbms_role r where u.id=? and u.userRole = r.id";Object[] params = {id};rs = BaseDao.execute(connection, pstm, rs, sql, params);if (rs.next()) {user = new User();user.setId(rs.getInt("id"));user.setUserCode(rs.getString("userCode"));user.setUserName(rs.getString("userName"));user.setUserPassword(rs.getString("userPassword"));user.setGender(rs.getInt("gender"));user.setBirthday(rs.getDate("birthday"));user.setPhone(rs.getString("phone"));user.setAddress(rs.getString("address"));user.setUserRole(rs.getInt("userRole"));user.setCreateBy(rs.getInt("createBy"));user.setCreationDate(rs.getTimestamp("creationDate"));user.setModifyBy(rs.getInt("modifyBy"));user.setModifyDate(rs.getTimestamp("modifyDate"));user.setUserRoleName(rs.getString("userRoleName"));}BaseDao.closeResource(null, pstm, rs);}return user;
}//修改用户信息
@Override
public int modify(Connection connection, User user) throws Exception {int flag = 0;PreparedStatement pstm = null;if (null != connection) {String sql = "update smbms_user set userName=?," +"gender=?,birthday=?,phone=?,address=?,userRole=?,modifyBy=?,modifyDate=? where id = ? ";Object[] params = {user.getUserName(), user.getGender(), user.getBirthday(),user.getPhone(), user.getAddress(), user.getUserRole(), user.getModifyBy(),user.getModifyDate(), user.getId()};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;
}
Service
//增加用户信息
public boolean add(User user);//根据ID删除user
public boolean deleteUserById(Integer delId);//根据ID查找user
public User getUserById(String id);//修改用户信息
public boolean modify(User user);//根据userCode查询出User
public User selectUserCodeExist(String userCode);
ServiceImpl
//增加用户信息
@Override
public boolean add(User user) {boolean flag = false;Connection connection = null;try {connection = BaseDao.getConnection(); //调BaseDao层，获取数据库的链接connection.setAutoCommit(false);//开启JDBC事务管理int updateRows = userDao.add(connection, user);connection.commit();if (updateRows > 0) {flag = true;System.out.println("add success!");} else {System.out.println("add failed!");}} catch (Exception e) {e.printStackTrace();try {System.out.println("rollback==================");connection.rollback();} catch (SQLException e1) {e1.printStackTrace();}} finally {//在service层进行connection连接的关闭BaseDao.closeResource(connection, null, null);}return flag;
}//根据ID删除user
@Override
public boolean deleteUserById(Integer delId) {Connection connection = null;boolean flag = false;try {connection = BaseDao.getConnection();if (userDao.deleteUserById(connection, delId) > 0) {flag = true;}} catch (Exception e) {e.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return flag;
}//根据ID查找user
@Override
public User getUserById(String id) {User user = null;Connection connection = null;try {connection = BaseDao.getConnection();user = userDao.getUserById(connection, id);} catch (Exception e) {e.printStackTrace();user = null;} finally {BaseDao.closeResource(connection, null, null);}return user;
}//修改用户信息
@Override
public boolean modify(User user) {Connection connection = null;boolean flag = false;try {connection = BaseDao.getConnection();if (userDao.modify(connection, user) > 0) {flag = true;}} catch (Exception e) {e.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return flag;
}//根据userCode查询出User
@Override
public User selectUserCodeExist(String userCode) {Connection connection = null;User user = null;try {connection = BaseDao.getConnection();user = userDao.getLoginUser(connection, userCode);} catch (Exception e) {e.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return user;
}
增删改查Servlet
else if( method!=null&&method.equals("query")){this.query(req,resp);
else if(method != null && method.equals("add")){//增加操作this.add(req, resp);
}else if(method != null && method.equals("deluser")){this.delUser(req, resp);
}else if (method != null && method.equals("modify")) {this.getUserById(req, resp, "usermodify.jsp");
}else if(method!=null&&method.equals("modifyexe")){this.modify(req, resp);
}else if (method != null && method.equals("ucexist")) {this.userCodeExist(req, resp);
}else if (method != null && method.equals("view")) {this.getUserById(req, resp, "userview.jsp");}else if (method != null && method.equals("getrolelist")) {this.getRoleList(req, resp);}
//查询用户列表
public void query(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException{//从前端获取数据String queryUserName = req.getParameter("queryname");String temp = req.getParameter("queryUserRole");String pageIndex = req.getParameter("pageIndex");int queryUserRole = 0;// 获取用户列表UserServiceImp userService = new UserServiceImp();List<User> userList=null;//第一次走这个请求，一定是第一页 页面大小是固定的int pageSize = Constants.pageSize; //可以把这个写到配置文件里 方便后期修改int currentPageNo=1;if(queryUserName==null){queryUserName="";}if (temp!=null&&!temp.equals("")){queryUserRole = Integer.parseInt(temp);//给查询赋值}if (pageIndex != null) {try {currentPageNo = Integer.valueOf(pageIndex);} catch (NumberFormatException e) {resp.sendRedirect("error.jsp");}}//获取用户总数 (分页 上一页 下一页的情况)int totalCount = userService.getUserCount(queryUserName, queryUserRole);//总页数pageSupport pageSupport = new pageSupport();pageSupport.setCurrentPageNo(currentPageNo); //当前页pageSupport.setPageSize(pageSize); //页面大小pageSupport.setTotalCount(totalCount); //总数量int totalPageCount =(int) (totalCount/pageSize)+1;//控制首页和尾页//如果页面要小于1 就显示第一页的东西if (totalPageCount<1){currentPageNo = 1;}if(currentPageNo>totalPageCount){//当前页面大于最后一页currentPageNo=totalPageCount;}//获取用户列表展示userList = userService.getUserList(queryUserName, queryUserRole, currentPageNo, pageSize);req.setAttribute("userList",userList);roleServiceImp roleService = new roleServiceImp();List<Role> roleList = null;roleList = roleService.getRoleList();req.setAttribute("roleList", roleList);req.setAttribute("totalCount", totalCount);req.setAttribute("currentPageNo", currentPageNo);req.setAttribute("totalPageCount", totalPageCount);req.setAttribute("queryUserName", queryUserName);req.setAttribute("queryUserRole", queryUserRole);//返回前端req.getRequestDispatcher("userlist.jsp").forward(req,resp);
}//添加用户
public void add(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException{String userCode = req.getParameter("userCode");String userName = req.getParameter("userName");String userPassword = req.getParameter("userPassword");String gender = req.getParameter("gender");String birthday = req.getParameter("birthday");String phone = req.getParameter("phone");String address = req.getParameter("address");String userRole = req.getParameter("userRole");//进行存储User user = new User();user.setUserCode(userCode);user.setUserName(userName);user.setUserPassword(userPassword);user.setAddress(address);user.setGender(Integer.valueOf(gender));try {user.setBirthday(new SimpleDateFormat("yyyy-MM-dd").parse(birthday));} catch (ParseException e) {e.printStackTrace();}user.setPhone(phone);user.setUserRole(Integer.valueOf(userRole));user.setCreationDate(new Date());user.setCreateBy(((User) req.getSession().getAttribute(Constants.USER_SESSION)).getId());UserService userService = new UserServiceImp();//调用UserServiceImp 将user添加进去然后进行处理if (userService.add(user)) {resp.sendRedirect(req.getContextPath() + "/jsp/user.do?method=query");} else {req.getRequestDispatcher("useradd.jsp").forward(req, resp);}}//删除用户
private void delUser(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {String id = req.getParameter("uid");Integer delId = 0;try {delId = Integer.parseInt(id);} catch (Exception e) {delId = 0;}HashMap<String, String> resultMap = new HashMap<String, String>();if (delId <= 0) {resultMap.put("delResult", "notexist");} else {UserService userService = new UserServiceImp();if (userService.deleteUserById(delId)) {resultMap.put("delResult", "true");} else {resultMap.put("delResult", "false");}}//把resultMap转换成json对象输出resp.setContentType("application/json");PrintWriter outPrintWriter = resp.getWriter();outPrintWriter.write(JSONArray.toJSONString(resultMap));outPrintWriter.flush();outPrintWriter.close();
}根据ID查找user
private void getUserById(HttpServletRequest req, HttpServletResponse resp, String url) throws ServletException, IOException {String id = req.getParameter("uid");if (!StringUtils.isNullOrEmpty(id)) {//调用后台方法得到user对象UserService userService = new UserServiceImp();User user = userService.getUserById(id);req.setAttribute("user", user);req.getRequestDispatcher(url).forward(req, resp);}}修改用户信息
private void modify(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {String id = req.getParameter("uid");String userName = req.getParameter("userName");String gender = req.getParameter("gender");String birthday = req.getParameter("birthday");String phone = req.getParameter("phone");String address = req.getParameter("address");String userRole = req.getParameter("userRole");User user = new User();user.setId(Integer.valueOf(id));user.setUserName(userName);user.setGender(Integer.valueOf(gender));try {user.setBirthday(new SimpleDateFormat("yyyy-MM-dd").parse(birthday));} catch (ParseException e) {e.printStackTrace();}user.setPhone(phone);user.setAddress(address);user.setUserRole(Integer.valueOf(userRole));user.setModifyBy(((User) req.getSession().getAttribute(Constants.USER_SESSION)).getId());user.setModifyDate(new Date());UserService userService = new UserServiceImp();if (userService.modify(user)) {resp.sendRedirect(req.getContextPath() + "/jsp/user.do?method=query");} else {req.getRequestDispatcher("usermodify.jsp").forward(req, resp);}}//根据userCode查询出User
private void userCodeExist(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {//判断用户账号是否可用String userCode = req.getParameter("userCode");HashMap<String, String> resultMap = new HashMap<String, String>();if (StringUtils.isNullOrEmpty(userCode)) {//userCode == null || userCode.equals("")resultMap.put("userCode", "exist");} else {UserService userService = new UserServiceImp();User user = userService.selectUserCodeExist(userCode);if (null != user) {resultMap.put("userCode", "exist");} else {resultMap.put("userCode", "notexist");}}//把resultMap转为json字符串以json的形式输出//配置上下文的输出类型resp.setContentType("application/json");//从response对象中获取往外输出的writer对象PrintWriter outPrintWriter = resp.getWriter();//把resultMap转为json字符串 输出outPrintWriter.write(JSONArray.toJSONString(resultMap));outPrintWriter.flush();//刷新outPrintWriter.close();//关闭流
}private void getRoleList(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {List<Role> roleList = null;roleServiceImp roleService = new roleServiceImp();roleList = roleService.getRoleList();//把roleList转换成json对象输出resp.setContentType("application/json");PrintWriter outPrintWriter = resp.getWriter();outPrintWriter.write(JSONArray.toJSONString(roleList));outPrintWriter.flush();outPrintWriter.close();
}
5.订单管理模块
5.1 BillDao
package com.kk.dao.bill;import com.kk.pojo.Bill;import java.sql.Connection;
import java.util.List;public interface BillDao {/*** 增加订单** @param connection* @param bill* @return* @throws Exception*/int add(Connection connection, Bill bill) throws Exception;/*** 通过查询条件获取供应商列表-模糊查询-getBillList** @param connection* @param bill* @return* @throws Exception*/List<Bill> getBillList(Connection connection, Bill bill) throws Exception;/*** 通过delId删除Bill** @param connection* @param delId* @return* @throws Exception*/int deleteBillById(Connection connection, String delId) throws Exception;/*** 通过billId获取Bill** @param connection* @param id* @return* @throws Exception*/Bill getBillById(Connection connection, String id) throws Exception;/*** 修改订单信息** @param connection* @param bill* @return* @throws Exception*/int modify(Connection connection, Bill bill) throws Exception;/*** 根据供应商ID查询订单数量** @param connection* @param providerId* @return* @throws Exception*/int getBillCountByProviderId(Connection connection, String providerId) throws Exception;}
5.2 BillDaoImpl
package com.kk.dao.bill;import com.kk.dao.BaseDao;
import com.kk.pojo.Bill;
import com.mysql.cj.util.StringUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;public class BillDaoImpl implements BillDao {@Overridepublic int add(Connection connection, Bill bill) throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;int flag = 0;if (null != connection) {String sql = "insert into smbms_bill (billCode,productName,productDesc," +"productUnit,productCount,totalPrice,isPayment,providerId,createBy,creationDate) " +"values(?,?,?,?,?,?,?,?,?,?)";Object[] params = {bill.getBillCode(), bill.getProductName(), bill.getProductDesc(),bill.getProductUnit(), bill.getProductCount(), bill.getTotalPrice(), bill.getIsPayment(),bill.getProviderId(), bill.getCreateBy(), bill.getCreationDate()};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);System.out.println("dao--------flag " + flag);}return flag;}@Overridepublic List<Bill> getBillList(Connection connection, Bill bill)throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;ResultSet rs = null;List<Bill> billList = new ArrayList<Bill>();if (connection != null) {StringBuffer sql = new StringBuffer();sql.append("select b.*,p.proName as providerName from smbms_bill b, smbms_provider p where b.providerId = p.id");List<Object> list = new ArrayList<Object>();if (!StringUtils.isNullOrEmpty(bill.getProductName())) {sql.append(" and productName like ?");list.add("%" + bill.getProductName() + "%");}if (bill.getProviderId() > 0) {sql.append(" and providerId = ?");list.add(bill.getProviderId());}if (bill.getIsPayment() > 0) {sql.append(" and isPayment = ?");list.add(bill.getIsPayment());}Object[] params = list.toArray();System.out.println("sql --------- > " + sql.toString());rs = BaseDao.execute(connection, pstm, rs, sql.toString(), params);while (rs.next()) {Bill _bill = new Bill();_bill.setId(rs.getInt("id"));_bill.setBillCode(rs.getString("billCode"));_bill.setProductName(rs.getString("productName"));_bill.setProductDesc(rs.getString("productDesc"));_bill.setProductUnit(rs.getString("productUnit"));_bill.setProductCount(rs.getBigDecimal("productCount"));_bill.setTotalPrice(rs.getBigDecimal("totalPrice"));_bill.setIsPayment(rs.getInt("isPayment"));_bill.setProviderId(rs.getInt("providerId"));_bill.setProviderName(rs.getString("providerName"));_bill.setCreationDate(rs.getTimestamp("creationDate"));_bill.setCreateBy(rs.getInt("createBy"));billList.add(_bill);}BaseDao.closeResource(null, pstm, rs);}return billList;}@Overridepublic int deleteBillById(Connection connection, String delId)throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;int flag = 0;if (null != connection) {String sql = "delete from smbms_bill where id=?";Object[] params = {delId};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;}@Overridepublic Bill getBillById(Connection connection, String id) throws Exception {// TODO Auto-generated method stubBill bill = null;PreparedStatement pstm = null;ResultSet rs = null;if (null != connection) {String sql = "select b.*,p.proName as providerName from smbms_bill b, smbms_provider p " +"where b.providerId = p.id and b.id=?";Object[] params = {id};rs = BaseDao.execute(connection, pstm, rs, sql, params);if (rs.next()) {bill = new Bill();bill.setId(rs.getInt("id"));bill.setBillCode(rs.getString("billCode"));bill.setProductName(rs.getString("productName"));bill.setProductDesc(rs.getString("productDesc"));bill.setProductUnit(rs.getString("productUnit"));bill.setProductCount(rs.getBigDecimal("productCount"));bill.setTotalPrice(rs.getBigDecimal("totalPrice"));bill.setIsPayment(rs.getInt("isPayment"));bill.setProviderId(rs.getInt("providerId"));bill.setProviderName(rs.getString("providerName"));bill.setModifyBy(rs.getInt("modifyBy"));bill.setModifyDate(rs.getTimestamp("modifyDate"));}BaseDao.closeResource(null, pstm, rs);}return bill;}@Overridepublic int modify(Connection connection, Bill bill) throws Exception {// TODO Auto-generated method stubint flag = 0;PreparedStatement pstm = null;if (null != connection) {String sql = "update smbms_bill set productName=?," +"productDesc=?,productUnit=?,productCount=?,totalPrice=?," +"isPayment=?,providerId=?,modifyBy=?,modifyDate=? where id = ? ";Object[] params = {bill.getProductName(), bill.getProductDesc(),bill.getProductUnit(), bill.getProductCount(), bill.getTotalPrice(), bill.getIsPayment(),bill.getProviderId(), bill.getModifyBy(), bill.getModifyDate(), bill.getId()};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;}@Overridepublic int getBillCountByProviderId(Connection connection, String providerId)throws Exception {// TODO Auto-generated method stubint count = 0;PreparedStatement pstm = null;ResultSet rs = null;if (null != connection) {String sql = "select count(1) as billCount from smbms_bill where" +" providerId = ?";Object[] params = {providerId};rs = BaseDao.execute(connection, pstm, rs, sql, params);if (rs.next()) {count = rs.getInt("billCount");}BaseDao.closeResource(null, pstm, rs);}return count;}
}
5.3 BillService
package com.kk.service.bill;import com.kk.pojo.Bill;import java.util.List;public interface BillService {/*** 增加订单** @param bill* @return*/public boolean add(Bill bill);/*** 通过条件获取订单列表-模糊查询-billList** @param bill* @return*/public List<Bill> getBillList(Bill bill);/*** 通过billId删除Bill** @param delId* @return*/public boolean deleteBillById(String delId);/*** 通过billId获取Bill** @param id* @return*/public Bill getBillById(String id);/*** 修改订单信息** @param bill* @return*/public boolean modify(Bill bill);}
5.4 BillServiceImpl
package com.kk.service.bill;import com.kk.dao.BaseDao;
import com.kk.dao.bill.BillDao;
import com.kk.dao.bill.BillDaoImpl;
import com.kk.pojo.Bill;import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;public class BillServiceImpl implements BillService {private BillDao billDao;public BillServiceImpl() {billDao = new BillDaoImpl();}@Overridepublic boolean add(Bill bill) {// TODO Auto-generated method stubboolean flag = false;Connection connection = null;try {connection = BaseDao.getConnection();connection.setAutoCommit(false);//开启JDBC事务管理if (billDao.add(connection, bill) > 0)flag = true;connection.commit();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();try {System.out.println("rollback==================");connection.rollback();} catch (SQLException e1) {// TODO Auto-generated catch blocke1.printStackTrace();}} finally {//在service层进行connection连接的关闭BaseDao.closeResource(connection, null, null);}return flag;}@Overridepublic List<Bill> getBillList(Bill bill) {// TODO Auto-generated method stubConnection connection = null;List<Bill> billList = null;System.out.println("query productName ---- > " + bill.getProductName());System.out.println("query providerId ---- > " + bill.getProviderId());System.out.println("query isPayment ---- > " + bill.getIsPayment());try {connection = BaseDao.getConnection();billList = billDao.getBillList(connection, bill);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return billList;}@Overridepublic boolean deleteBillById(String delId) {// TODO Auto-generated method stubConnection connection = null;boolean flag = false;try {connection = BaseDao.getConnection();if (billDao.deleteBillById(connection, delId) > 0)flag = true;} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return flag;}@Overridepublic Bill getBillById(String id) {// TODO Auto-generated method stubBill bill = null;Connection connection = null;try {connection = BaseDao.getConnection();bill = billDao.getBillById(connection, id);} catch (Exception e) {// TODO: handle exceptione.printStackTrace();bill = null;} finally {BaseDao.closeResource(connection, null, null);}return bill;}@Overridepublic boolean modify(Bill bill) {// TODO Auto-generated method stubConnection connection = null;boolean flag = false;try {connection = BaseDao.getConnection();if (billDao.modify(connection, bill) > 0)flag = true;} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return flag;}}
5.5 BillServlet
package com.kk.servlet.bill;import com.alibaba.fastjson.JSONArray;
import com.kk.pojo.Bill;
import com.kk.pojo.Provider;
import com.kk.pojo.User;
import com.kk.service.bill.BillService;
import com.kk.service.bill.BillServiceImpl;
import com.kk.service.provider.ProviderService;
import com.kk.service.provider.ProviderServiceImpl;
import com.kk.util.Constants;
import com.mysql.cj.util.StringUtils;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;public class BillServlet extends HttpServlet {private static final long serialVersionUID = -1898446683172394681L;/*** Destruction of the servlet. <br>*/@Overridepublic void destroy() {super.destroy(); // Just puts "destroy" string in log// Put your code here}/*** The doGet method of the servlet. <br>* <p>* This method is called when a form has its tag value method equals to get.** @param request the request send by the client to the server* @param response the response send by the server to the client* @throws ServletException if an error occurred* @throws IOException if an error occurred*/@Overridepublic void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {doPost(request, response);}/*** The doPost method of the servlet. <br>* <p>* This method is called when a form has its tag value method equals to post.** @param request the request send by the client to the server* @param response the response send by the server to the client* @throws ServletException if an error occurred* @throws IOException if an error occurred*/@Overridepublic void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {/*String totalPrice = request.getParameter("totalPrice");//23.234 45BigDecimal totalPriceBigDecimal = //设置规则，小数点保留两位，多出部分，ROUND_DOWN 舍弃//ROUND_HALF_UP 四舍五入(5入) ROUND_UP 进位 //ROUND_HALF_DOWN 四舍五入（5不入）new BigDecimal(totalPrice).setScale(2,BigDecimal.ROUND_DOWN);*/String method = request.getParameter("method");if (method != null && method.equals("query")) {this.query(request, response);} else if (method != null && method.equals("add")) {this.add(request, response);} else if (method != null && method.equals("view")) {this.getBillById(request, response, "billview.jsp");} else if (method != null && method.equals("modify")) {this.getBillById(request, response, "billmodify.jsp");} else if (method != null && method.equals("modifysave")) {this.modify(request, response);} else if (method != null && method.equals("delbill")) {this.delBill(request, response);} else if (method != null && method.equals("getproviderlist")) {this.getProviderlist(request, response);}}private void getProviderlist(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println("getproviderlist ========================= ");List<Provider> providerList = new ArrayList<Provider>();ProviderService providerService = new ProviderServiceImpl();providerList = providerService.getProviderList("", "");//把providerList转换成json对象输出response.setContentType("application/json");PrintWriter outPrintWriter = response.getWriter();outPrintWriter.write(JSONArray.toJSONString(providerList));outPrintWriter.flush();outPrintWriter.close();}private void getBillById(HttpServletRequest request, HttpServletResponse response, String url)throws ServletException, IOException {String id = request.getParameter("billid");if (!StringUtils.isNullOrEmpty(id)) {BillService billService = new BillServiceImpl();Bill bill = null;bill = billService.getBillById(id);request.setAttribute("bill", bill);request.getRequestDispatcher(url).forward(request, response);}}private void modify(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println("modify===============");String id = request.getParameter("id");String productName = request.getParameter("productName");String productDesc = request.getParameter("productDesc");String productUnit = request.getParameter("productUnit");String productCount = request.getParameter("productCount");String totalPrice = request.getParameter("totalPrice");String providerId = request.getParameter("providerId");String isPayment = request.getParameter("isPayment");Bill bill = new Bill();bill.setId(Integer.valueOf(id));bill.setProductName(productName);bill.setProductDesc(productDesc);bill.setProductUnit(productUnit);bill.setProductCount(new BigDecimal(productCount).setScale(2, BigDecimal.ROUND_DOWN));bill.setIsPayment(Integer.parseInt(isPayment));bill.setTotalPrice(new BigDecimal(totalPrice).setScale(2, BigDecimal.ROUND_DOWN));bill.setProviderId(Integer.parseInt(providerId));bill.setModifyBy(((User) request.getSession().getAttribute(Constants.USER_SESSION)).getId());bill.setModifyDate(new Date());boolean flag = false;BillService billService = new BillServiceImpl();flag = billService.modify(bill);if (flag) {response.sendRedirect(request.getContextPath() + "/jsp/bill.do?method=query");} else {request.getRequestDispatcher("billmodify.jsp").forward(request, response);}}private void delBill(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String id = request.getParameter("billid");HashMap<String, String> resultMap = new HashMap<String, String>();if (!StringUtils.isNullOrEmpty(id)) {BillService billService = new BillServiceImpl();boolean flag = billService.deleteBillById(id);if (flag) {//删除成功resultMap.put("delResult", "true");} else {//删除失败resultMap.put("delResult", "false");}} else {resultMap.put("delResult", "notexit");}//把resultMap转换成json对象输出response.setContentType("application/json");PrintWriter outPrintWriter = response.getWriter();outPrintWriter.write(JSONArray.toJSONString(resultMap));outPrintWriter.flush();outPrintWriter.close();}private void add(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String billCode = request.getParameter("billCode");String productName = request.getParameter("productName");String productDesc = request.getParameter("productDesc");String productUnit = request.getParameter("productUnit");String productCount = request.getParameter("productCount");String totalPrice = request.getParameter("totalPrice");String providerId = request.getParameter("providerId");String isPayment = request.getParameter("isPayment");Bill bill = new Bill();bill.setBillCode(billCode);bill.setProductName(productName);bill.setProductDesc(productDesc);bill.setProductUnit(productUnit);bill.setProductCount(new BigDecimal(productCount).setScale(2, BigDecimal.ROUND_DOWN));bill.setIsPayment(Integer.parseInt(isPayment));bill.setTotalPrice(new BigDecimal(totalPrice).setScale(2, BigDecimal.ROUND_DOWN));bill.setProviderId(Integer.parseInt(providerId));bill.setCreateBy(((User) request.getSession().getAttribute(Constants.USER_SESSION)).getId());bill.setCreationDate(new Date());boolean flag = false;BillService billService = new BillServiceImpl();flag = billService.add(bill);System.out.println("add flag -- > " + flag);if (flag) {response.sendRedirect(request.getContextPath() + "/jsp/bill.do?method=query");} else {request.getRequestDispatcher("billadd.jsp").forward(request, response);}}private void query(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {List<Provider> providerList = new ArrayList<Provider>();ProviderService providerService = new ProviderServiceImpl();providerList = providerService.getProviderList("", "");request.setAttribute("providerList", providerList);String queryProductName = request.getParameter("queryProductName");String queryProviderId = request.getParameter("queryProviderId");String queryIsPayment = request.getParameter("queryIsPayment");if (StringUtils.isNullOrEmpty(queryProductName)) {queryProductName = "";}List<Bill> billList = new ArrayList<Bill>();BillService billService = new BillServiceImpl();Bill bill = new Bill();if (StringUtils.isNullOrEmpty(queryIsPayment)) {bill.setIsPayment(0);} else {bill.setIsPayment(Integer.parseInt(queryIsPayment));}if (StringUtils.isNullOrEmpty(queryProviderId)) {bill.setProviderId(0);} else {bill.setProviderId(Integer.parseInt(queryProviderId));}bill.setProductName(queryProductName);billList = billService.getBillList(bill);request.setAttribute("billList", billList);request.setAttribute("queryProductName", queryProductName);request.setAttribute("queryProviderId", queryProviderId);request.setAttribute("queryIsPayment", queryIsPayment);request.getRequestDispatcher("billlist.jsp").forward(request, response);}public static void main(String[] args) {System.out.println(new BigDecimal("23.235").setScale(2, BigDecimal.ROUND_HALF_DOWN));}/*** Initialization of the servlet. <br>** @throws ServletException if an error occurs*/@Overridepublic void init() throws ServletException {// Put your code here}}
6.供应商管理模块
6.1 ProviderDao
package com.kk.dao.provider;import com.kk.pojo.Provider;import java.sql.Connection;
import java.util.List;public interface ProviderDao {/*** 增加供应商** @param connection* @param provider* @return* @throws Exception*/int add(Connection connection, Provider provider) throws Exception;/*** 通过供应商名称、编码获取供应商列表-模糊查询-providerList** @param connection* @param proName* @return* @throws Exception*/List<Provider> getProviderList(Connection connection, String proName, String proCode) throws Exception;/*** 通过proId删除Provider** @param delId* @return* @throws Exception*/int deleteProviderById(Connection connection, String delId) throws Exception;/*** 通过proId获取Provider** @param connection* @param id* @return* @throws Exception*/Provider getProviderById(Connection connection, String id) throws Exception;/*** 修改用户信息** @param connection* @param provider* @return* @throws Exception*/int modify(Connection connection, Provider provider) throws Exception;}
6.2 ProviderDaoImpl
package com.kk.dao.provider;import com.kk.dao.BaseDao;
import com.kk.pojo.Provider;
import com.mysql.cj.util.StringUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;public class ProviderDaoImpl implements ProviderDao {@Overridepublic int add(Connection connection, Provider provider)throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;int flag = 0;if (null != connection) {String sql = "insert into smbms_provider (proCode,proName,proDesc," +"proContact,proPhone,proAddress,proFax,createdBy,creationDate) " +"values(?,?,?,?,?,?,?,?,?)";Object[] params = {provider.getProCode(), provider.getProName(), provider.getProDesc(),provider.getProContact(), provider.getProPhone(), provider.getProAddress(),provider.getProFax(), provider.getCreateBy(), provider.getCreationDate()};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;}@Overridepublic List<Provider> getProviderList(Connection connection, String proName, String proCode)throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;ResultSet rs = null;List<Provider> providerList = new ArrayList<Provider>();if (connection != null) {StringBuffer sql = new StringBuffer();sql.append("select * from smbms_provider where 1=1 ");List<Object> list = new ArrayList<Object>();if (!StringUtils.isNullOrEmpty(proName)) {sql.append(" and proName like ?");list.add("%" + proName + "%");}if (!StringUtils.isNullOrEmpty(proCode)) {sql.append(" and proCode like ?");list.add("%" + proCode + "%");}Object[] params = list.toArray();System.out.println("sql ----> " + sql.toString());rs = BaseDao.execute(connection, pstm, rs, sql.toString(), params);while (rs.next()) {Provider _provider = new Provider();_provider.setId(rs.getInt("id"));_provider.setProCode(rs.getString("proCode"));_provider.setProName(rs.getString("proName"));_provider.setProDesc(rs.getString("proDesc"));_provider.setProContact(rs.getString("proContact"));_provider.setProPhone(rs.getString("proPhone"));_provider.setProAddress(rs.getString("proAddress"));_provider.setProFax(rs.getString("proFax"));_provider.setCreationDate(rs.getTimestamp("creationDate"));providerList.add(_provider);}BaseDao.closeResource(null, pstm, rs);}return providerList;}@Overridepublic int deleteProviderById(Connection connection, String delId)throws Exception {// TODO Auto-generated method stubPreparedStatement pstm = null;int flag = 0;if (null != connection) {String sql = "delete from smbms_provider where id=?";Object[] params = {delId};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;}@Overridepublic Provider getProviderById(Connection connection, String id)throws Exception {// TODO Auto-generated method stubProvider provider = null;PreparedStatement pstm = null;ResultSet rs = null;if (null != connection) {String sql = "select * from smbms_provider where id=?";Object[] params = {id};rs = BaseDao.execute(connection, pstm, rs, sql, params);if (rs.next()) {provider = new Provider();provider.setId(rs.getInt("id"));provider.setProCode(rs.getString("proCode"));provider.setProName(rs.getString("proName"));provider.setProDesc(rs.getString("proDesc"));provider.setProContact(rs.getString("proContact"));provider.setProPhone(rs.getString("proPhone"));provider.setProAddress(rs.getString("proAddress"));provider.setProFax(rs.getString("proFax"));provider.setCreateBy(rs.getInt("createdBy"));provider.setCreationDate(rs.getTimestamp("creationDate"));provider.setModifyBy(rs.getInt("modifyBy"));provider.setModifyDate(rs.getTimestamp("modifyDate"));}BaseDao.closeResource(null, pstm, rs);}return provider;}@Overridepublic int modify(Connection connection, Provider provider)throws Exception {// TODO Auto-generated method stubint flag = 0;PreparedStatement pstm = null;if (null != connection) {String sql = "update smbms_provider set proName=?,proDesc=?,proContact=?," +"proPhone=?,proAddress=?,proFax=?,modifyBy=?,modifyDate=? where id = ? ";Object[] params = {provider.getProName(), provider.getProDesc(), provider.getProContact(), provider.getProPhone(), provider.getProAddress(),provider.getProFax(), provider.getModifyBy(), provider.getModifyDate(), provider.getId()};flag = BaseDao.execute(connection, pstm, sql, params);BaseDao.closeResource(null, pstm, null);}return flag;}}
6.3 ProviderService
package com.kk.service.provider;import com.kk.pojo.Provider;import java.util.List;public interface ProviderService {/*** 增加供应商** @param provider* @return*/public boolean add(Provider provider);/*** 通过供应商名称、编码获取供应商列表-模糊查询-providerList** @param proName* @return*/public List<Provider> getProviderList(String proName, String proCode);/*** 通过proId删除Provider** @param delId* @return*/public int deleteProviderById(String delId);/*** 通过proId获取Provider** @param id* @return*/public Provider getProviderById(String id);/*** 修改用户信息** @param* @return*/public boolean modify(Provider provider);}
6.4 ProviderServiceImpl
package com.kk.service.provider;import com.kk.dao.BaseDao;
import com.kk.dao.bill.BillDao;
import com.kk.dao.bill.BillDaoImpl;
import com.kk.dao.provider.ProviderDao;
import com.kk.dao.provider.ProviderDaoImpl;
import com.kk.pojo.Provider;import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;public class ProviderServiceImpl implements ProviderService {private ProviderDao providerDao;private BillDao billDao;public ProviderServiceImpl() {providerDao = new ProviderDaoImpl();billDao = new BillDaoImpl();}@Overridepublic boolean add(Provider provider) {// TODO Auto-generated method stubboolean flag = false;Connection connection = null;try {connection = BaseDao.getConnection();connection.setAutoCommit(false);//开启JDBC事务管理if (providerDao.add(connection, provider) > 0)flag = true;connection.commit();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();try {System.out.println("rollback==================");connection.rollback();} catch (SQLException e1) {// TODO Auto-generated catch blocke1.printStackTrace();}} finally {//在service层进行connection连接的关闭BaseDao.closeResource(connection, null, null);}return flag;}@Overridepublic List<Provider> getProviderList(String proName, String proCode) {// TODO Auto-generated method stubConnection connection = null;List<Provider> providerList = null;System.out.println("query proName ---- > " + proName);System.out.println("query proCode ---- > " + proCode);try {connection = BaseDao.getConnection();providerList = providerDao.getProviderList(connection, proName, proCode);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return providerList;}/*** 业务：根据ID删除供应商表的数据之前，需要先去订单表里进行查询操作* 若订单表中无该供应商的订单数据，则可以删除* 若有该供应商的订单数据，则不可以删除* 返回值billCount* 1> billCount == 0 删除---1 成功 （0） 2 不成功 （-1）* 2> billCount > 0 不能删除 查询成功（0）查询不成功（-1）* <p>* ---判断* 如果billCount = -1 失败* 若billCount >= 0 成功*/@Overridepublic int deleteProviderById(String delId) {// TODO Auto-generated method stubConnection connection = null;int billCount = -1;try {connection = BaseDao.getConnection();connection.setAutoCommit(false);billCount = billDao.getBillCountByProviderId(connection, delId);if (billCount == 0) {providerDao.deleteProviderById(connection, delId);}connection.commit();} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();billCount = -1;try {connection.rollback();} catch (SQLException e1) {// TODO Auto-generated catch blocke1.printStackTrace();}} finally {BaseDao.closeResource(connection, null, null);}return billCount;}@Overridepublic Provider getProviderById(String id) {// TODO Auto-generated method stubProvider provider = null;Connection connection = null;try {connection = BaseDao.getConnection();provider = providerDao.getProviderById(connection, id);} catch (Exception e) {// TODO: handle exceptione.printStackTrace();provider = null;} finally {BaseDao.closeResource(connection, null, null);}return provider;}@Overridepublic boolean modify(Provider provider) {// TODO Auto-generated method stubConnection connection = null;boolean flag = false;try {connection = BaseDao.getConnection();if (providerDao.modify(connection, provider) > 0)flag = true;} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {BaseDao.closeResource(connection, null, null);}return flag;}}
6.5 ProviderServlet
package com.kk.servlet.provider;import com.alibaba.fastjson.JSONArray;
import com.kk.pojo.Provider;
import com.kk.pojo.User;
import com.kk.service.provider.ProviderService;
import com.kk.service.provider.ProviderServiceImpl;
import com.kk.util.Constants;
import com.mysql.cj.util.StringUtils;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;public class ProviderServlet extends HttpServlet {private static final long serialVersionUID = -3029814594716051531L;/*** Destruction of the servlet. <br>*/@Overridepublic void destroy() {super.destroy(); // Just puts "destroy" string in log// Put your code here}/*** The doGet method of the servlet. <br>* <p>* This method is called when a form has its tag value method equals to get.** @param request the request send by the client to the server* @param response the response send by the server to the client* @throws ServletException if an error occurred* @throws IOException if an error occurred*/@Overridepublic void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {doPost(request, response);}/*** The doPost method of the servlet. <br>* <p>* This method is called when a form has its tag value method equals to post.** @param request the request send by the client to the server* @param response the response send by the server to the client* @throws ServletException if an error occurred* @throws IOException if an error occurred*/@Overridepublic void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String method = request.getParameter("method");if (method != null && method.equals("query")) {this.query(request, response);} else if (method != null && method.equals("add")) {this.add(request, response);} else if (method != null && method.equals("view")) {this.getProviderById(request, response, "providerview.jsp");} else if (method != null && method.equals("modify")) {this.getProviderById(request, response, "providermodify.jsp");} else if (method != null && method.equals("modifysave")) {this.modify(request, response);} else if (method != null && method.equals("delprovider")) {this.delProvider(request, response);}}private void delProvider(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String id = request.getParameter("proid");HashMap<String, String> resultMap = new HashMap<String, String>();if (!StringUtils.isNullOrEmpty(id)) {ProviderService providerService = new ProviderServiceImpl();int flag = providerService.deleteProviderById(id);if (flag == 0) {//删除成功resultMap.put("delResult", "true");} else if (flag == -1) {//删除失败resultMap.put("delResult", "false");} else if (flag > 0) {//该供应商下有订单，不能删除，返回订单数resultMap.put("delResult", String.valueOf(flag));}} else {resultMap.put("delResult", "notexit");}//把resultMap转换成json对象输出response.setContentType("application/json");PrintWriter outPrintWriter = response.getWriter();outPrintWriter.write(JSONArray.toJSONString(resultMap));outPrintWriter.flush();outPrintWriter.close();}private void modify(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String proContact = request.getParameter("proContact");String proPhone = request.getParameter("proPhone");String proAddress = request.getParameter("proAddress");String proFax = request.getParameter("proFax");String proDesc = request.getParameter("proDesc");String id = request.getParameter("id");Provider provider = new Provider();provider.setId(Integer.valueOf(id));provider.setProContact(proContact);provider.setProPhone(proPhone);provider.setProFax(proFax);provider.setProAddress(proAddress);provider.setProDesc(proDesc);provider.setModifyBy(((User) request.getSession().getAttribute(Constants.USER_SESSION)).getId());provider.setModifyDate(new Date());boolean flag = false;ProviderService providerService = new ProviderServiceImpl();flag = providerService.modify(provider);if (flag) {response.sendRedirect(request.getContextPath() + "/jsp/provider.do?method=query");} else {request.getRequestDispatcher("providermodify.jsp").forward(request, response);}}private void getProviderById(HttpServletRequest request, HttpServletResponse response, String url)throws ServletException, IOException {String id = request.getParameter("proid");if (!StringUtils.isNullOrEmpty(id)) {ProviderService providerService = new ProviderServiceImpl();Provider provider = null;provider = providerService.getProviderById(id);request.setAttribute("provider", provider);request.getRequestDispatcher(url).forward(request, response);}}private void add(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String proCode = request.getParameter("proCode");String proName = request.getParameter("proName");String proContact = request.getParameter("proContact");String proPhone = request.getParameter("proPhone");String proAddress = request.getParameter("proAddress");String proFax = request.getParameter("proFax");String proDesc = request.getParameter("proDesc");Provider provider = new Provider();provider.setProCode(proCode);provider.setProName(proName);provider.setProContact(proContact);provider.setProPhone(proPhone);provider.setProFax(proFax);provider.setProAddress(proAddress);provider.setProDesc(proDesc);provider.setCreateBy(((User) request.getSession().getAttribute(Constants.USER_SESSION)).getId());provider.setCreationDate(new Date());boolean flag = false;ProviderService providerService = new ProviderServiceImpl();flag = providerService.add(provider);if (flag) {response.sendRedirect(request.getContextPath() + "/jsp/provider.do?method=query");} else {request.getRequestDispatcher("provideradd.jsp").forward(request, response);}}private void query(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String queryProName = request.getParameter("queryProName");String queryProCode = request.getParameter("queryProCode");if (StringUtils.isNullOrEmpty(queryProName)) {queryProName = "";}if (StringUtils.isNullOrEmpty(queryProCode)) {queryProCode = "";}List<Provider> providerList = new ArrayList<Provider>();ProviderService providerService = new ProviderServiceImpl();providerList = providerService.getProviderList(queryProName, queryProCode);request.setAttribute("providerList", providerList);request.setAttribute("queryProName", queryProName);request.setAttribute("queryProCode", queryProCode);request.getRequestDispatcher("providerlist.jsp").forward(request, response);}/*** Initialization of the servlet. <br>** @throws ServletException if an error occurs*/@Overridepublic void init() throws ServletException {// Put your code here}}
7、以上所有资源的下载地址
链接：https://pan.baidu.com/s/1rWxWtSBeV6cl6JIMFb9LNw
fyDate(new Date());
boolean flag = false;
ProviderService providerService = new ProviderServiceImpl();
flag = providerService.modify(provider);
if (flag) {
response.sendRedirect(request.getContextPath() + “/jsp/provider.do?method=query”);
} else {
request.getRequestDispatcher(“providermodify.jsp”).forward(request, response);
}
}
private void getProviderById(HttpServletRequest request, HttpServletResponse response, String url)throws ServletException, IOException {String id = request.getParameter("proid");if (!StringUtils.isNullOrEmpty(id)) {ProviderService providerService = new ProviderServiceImpl();Provider provider = null;provider = providerService.getProviderById(id);request.setAttribute("provider", provider);request.getRequestDispatcher(url).forward(request, response);}
}private void add(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String proCode = request.getParameter("proCode");String proName = request.getParameter("proName");String proContact = request.getParameter("proContact");String proPhone = request.getParameter("proPhone");String proAddress = request.getParameter("proAddress");String proFax = request.getParameter("proFax");String proDesc = request.getParameter("proDesc");Provider provider = new Provider();provider.setProCode(proCode);provider.setProName(proName);provider.setProContact(proContact);provider.setProPhone(proPhone);provider.setProFax(proFax);provider.setProAddress(proAddress);provider.setProDesc(proDesc);provider.setCreateBy(((User) request.getSession().getAttribute(Constants.USER_SESSION)).getId());provider.setCreationDate(new Date());boolean flag = false;ProviderService providerService = new ProviderServiceImpl();flag = providerService.add(provider);if (flag) {response.sendRedirect(request.getContextPath() + "/jsp/provider.do?method=query");} else {request.getRequestDispatcher("provideradd.jsp").forward(request, response);}
}private void query(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {String queryProName = request.getParameter("queryProName");String queryProCode = request.getParameter("queryProCode");if (StringUtils.isNullOrEmpty(queryProName)) {queryProName = "";}if (StringUtils.isNullOrEmpty(queryProCode)) {queryProCode = "";}List<Provider> providerList = new ArrayList<Provider>();ProviderService providerService = new ProviderServiceImpl();providerList = providerService.getProviderList(queryProName, queryProCode);request.setAttribute("providerList", providerList);request.setAttribute("queryProName", queryProName);request.setAttribute("queryProCode", queryProCode);request.getRequestDispatcher("providerlist.jsp").forward(request, response);
}/*** Initialization of the servlet. <br>** @throws ServletException if an error occurs*/
@Override
public void init() throws ServletException {// Put your code here
}
}
7、以上所有资源的下载地址
链接：https://pan.baidu.com/s/1rWxWtSBeV6cl6JIMFb9LNw
提取码：kk80
❤️JavaWeb《超市订单管理系统—了解底层原理》（建议收藏）❤️相关推荐
- 狂神Smbms(javaWeb超市订单管理系统)实现
Smbms 数据库: driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/smbms?characterEncoding=utf8 ...
- JavaWeb项目smbms超市订单管理系统
项目简介 smbms超市订单管理系统,主要用于用户管理.订单管理.供应商管理等功能,是学习JavaWeb练习的一个小项目 这个博客只讲了部分功能(用户登录界面,和密码修改界面),以及用户管理的实现. ...
- SMBMS 超市订单管理系统
SMBMS 超市订单管理系统 文章目录 前言 SMBMS 超市订单管理系统 项目搭建准备工作 1. smbms项目搭建 0.数据库: 1.搭建一个mavenWeb项目 2.配置Tomcat 3.测试项 ...
- SMBMS超市订单管理系统
文章目录 MVC三层架构(代码整体以此分层编写) 基本架构 项目搭建准备工作 1- 4 5 创建项目包结构 6-7 8 导致静态资源 登录功能实现 1.编写前端页面 2.设置首页 3.编写Dao层用户 ...
- SSM超市订单管理系统(源码+数据库+文档)
基于SSM超市订单管理系统(MYSQL版) 技术:spring+springmvc+mybatis 数据库:mysql 图形化工具:Navicat 服务器:tomcat 开发工具:eclipse 功能 ...
- 开源项目-超市订单管理系统
哈喽,大家好,今天给大家带来的开源系统是-超市订单管理系统 系统主要包括订单管理,供应商管理,用户管理等模块 系统登录 订单管理 供应商管理 用户管理 以上就是该系统的大致内容了,感兴趣的同学可以下载 ...
- xdm俺来了、详解超市订单管理系统SSM版本
演示视频 超市订单管理系统SSM版本 声名:此系统修改了一些原来的页面内容,以及修补之前项目不足的地方- 另外新添了一个 根据时间 计算 早上 中午 下午 晚上的demo 记录在右上角 另外优化了一个 ...
- 基于SSM框架+MySQL的超市订单管理系统【源码+文档+PPT】
目录 1.系统需求分析 1.1 系统功能分析 1.2 系统功能需求 1.3 系统性能需求 2.数据库设计 2.1 数据库需求分析 3.数据库物理结构设计 4.各功能模块的设计与实现 4.1 开发框架 ...
- [附源码]java毕业设计超市订单管理系统
项目运行 环境配置: Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(IntelliJ IDEA,Eclispe,MyEclis ...
最新文章
- 根据16S预测微生物群落功能最全攻略
- git在实际开发中的应用
- 干货：数据仓库架构及基础知识
- 排查 Linux 系统故障，看这一篇足够了。
- Postgresql 8.2.15 安装文档
- linux添加Mib库,Linux SNMP中的管理信息库（MIB）学习
- OpenSSL 修复高危的无限循环漏洞
- Python寻找第N个默尼森数
- 怎样鉴别台式计算机主板型号,如何识别联想主板型号
- 基于SSM+MySQL+Vue前后端分离的在线问卷调查系统
- Tensorflow可视化好助手 Tensorboard (四)-Deep Learning
- alios是安卓吗_揭秘：阿里云OS和Android的主要区别是什么
- 8.13.2020 excel表格筛选按钮位置设置
- 上市公司环境投资数据（2009-2020年 ）
- 测试硬盘,ssd,优盘读取速度
- 财务系统数字转化方法
- STM32单片机使用ADC功能驱动手指检测心跳模块
- 12Cr2Mo1R(H)化学成分
- 有服务器端源码和客户端源码,C#远程控制服务器端和客户端源代码
- 鹰硕区域智慧教育云平台 AI助力搭建线上教学平台