基于SSM快递系统（含百度地图，移动端扫一扫功能）.zip

package com.mzy.dao; import java.sql.*; import java.util.ArrayList; import java.util.List; import java.util.Random; import com.mzy.bean.Express; import com.mzy.db.DruidUtil; public class ExpressDaoImp implements BaseExpressDao { private static final String SQL_CREATE_TABLE = "CREATE TABLE web_express(id INT PRIMARY KEY AUTO_INCREMENT,enumber VARCHAR(64) UNIQUE,username VARCHAR(64),userphone VARCHAR(64),company VARCHAR(64),CODE VARCHAR(64) UNIQUE,intime DATETIME,outtime DATETIME,STATUS INT,sysPhone VARCHAR(64))"; private static final String SQL_FIND_ALL = "SELECT * FROM WEB_EXPRESS"; private static final String SQL_FIND_BY_CODE = "SELECT * FROM WEB_EXPRESS WHERE CODE=?"; private static final String SQL_FIND_BY_ENUMBER = "SELECT * FROM WEB_EXPRESS WHERE ENUMBER=?"; private static final String SQL_FIND_BY_USERPHONE = "SELECT * FROM WEB_EXPRESS WHERE USERPHONE=?"; private static final String SQL_INSERT = "INSERT INTO WEB_EXPRESS (ENUMBER,COMPANY,USERNAME,USERPHONE,CODE,SYSPHONE,INTIME,STATUS) VALUES(?,?,?,?,?,?,now(),0)"; private static final String SQL_DELETE_BY_ID_OR_ENUMBER = "DELETE FROM WEB_EXPRESS WHERE ID=? OR ENUMBER=?"; private static final String SQL_UPDATE_BY_ID_OR_ENUMBER = "UPDATE WEB_EXPRESS SET ENUMBER=?,COMPANY=?,USERNAME=?,USERPHONE=? WHERE ID=? OR ENUMBER=?"; private static final String SQL_UPDATE_STATUS_BY_CODE = "UPDATE WEB_EXPRESS SET OUTTIME=now(),CODE=?,STATUS=1 WHERE CODE=?"; private static final String SQL_FIND_SIZE = "SELECT COUNT(ID) ecount FROM WEB_EXPRESS"; private static final String SQL_FIND_STATUS_SIZE = "SELECT COUNT(ID) ecount FROM WEB_EXPRESS WHERE STATUS=?"; static{ //1. 获取连接 Connection conn = DruidUtil.getConnection(); Statement state = null; try { state = conn.createStatement(); state.execute(SQL_CREATE_TABLE); } catch (SQLException e) { //e.printStackTrace(); } } @Override public List<Express> findAll() { ArrayList<Express> data = new ArrayList<>(); //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; try { state = conn.prepareStatement(SQL_FIND_ALL); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 while(result.next()) { int id = result.getInt("ID"); String eNumber = result.getString("ENUMBER"); String username = result.getString("USERNAME"); String userphone = result.getString("USERPHONE"); String company = result.getString("COMPANY"); String code = result.getString("CODE"); Timestamp inTime = result.getTimestamp("INTIME"); Timestamp outTime = result.getTimestamp("OUTTIME"); int status = result.getInt("STATUS"); String sysPhone = result.getString("SYSPHONE"); Express e = new Express(id, eNumber, username, userphone, company, code, inTime, outTime, status, sysPhone); data.add(e); } //5. 查询完毕, 返回集合 } catch (SQLException e) { e.printStackTrace(); } return data; } /** * 通过取件码查询快递 * * @param code * @return 快递对象 */ @Override public Express findByCode(String code) { //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; try { state = conn.prepareStatement(SQL_FIND_BY_CODE); state.setString(1, code); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 if(result.next()) { int id = result.getInt("ID"); String username = result.getString("USERNAME"); String userphone = result.getString("USERPHONE"); String company = result.getString("COMPANY"); String eNumber = result.getString("ENUMBER"); Timestamp inTime = result.getTimestamp("INTIME"); Timestamp outTime = result.getTimestamp("OUTTIME"); int status = result.getInt("STATUS"); String sysPhone = result.getString("SYSPHONE"); Express e = new Express(id, eNumber, username, userphone, company, code, inTime, outTime, status, sysPhone); return e; } //5. 查询完毕, 返回集合 } catch (SQLException e) { e.printStackTrace(); }finally { DruidUtil.close(conn,state,result); } return null; } @Override public int size() { //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; int ecount = 0 ; try { state = conn.prepareStatement(SQL_FIND_SIZE); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 while(result.next()) { ecount = result.getInt("ecount"); } //5. 查询完毕, 返回集合 } catch (SQLException e) { e.printStackTrace(); }finally { DruidUtil.close(conn,state,result); } return ecount; } /** * 根据快递状态查询所有快递数量 * * @param status * @return */ @Override public int statusSize(int status) { //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; int ecount = 0 ; try { state = conn.prepareStatement(SQL_FIND_STATUS_SIZE); state.setInt(1,status); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 while(result.next()) { ecount = result.getInt("ecount"); } //5. 查询完毕, 返回集合 } catch (SQLException e) { e.printStackTrace(); }finally { DruidUtil.close(conn,state,result); } return ecount; } @Override public Express findByENumber(String eNumber) { //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; try { state = conn.prepareStatement(SQL_FIND_BY_ENUMBER); state.setString(1, eNumber); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 if(result.next()) { int id = result.getInt("ID"); String username = result.getString("USERNAME"); String userphone = result.getString("USERPHONE"); String company = result.getString("COMPANY"); String code = result.getString("CODE"); Timestamp inTime = result.getTimestamp("INTIME"); Timestamp outTime = result.getTimestamp("OUTTIME"); int status = result.getInt("STATUS"); String sysPhone = result.getString("SYSPHONE"); Express e = new Express(id, eNumber, username, userphone, company, code, inTime, outTime, status, sysPhone); return e; } //5. 查询完毕, 返回集合 } catch (SQLException e) { e.printStackTrace(); } return null; } @Override public List<Express> findByUserPhone(String userPhone) { ArrayList<Express> data = new ArrayList<>(); //1. 获取连接 Connection conn = DruidUtil.getConnection(); //2. 预编译SQL执行环境 PreparedStatement state = null; ResultSet result = null; try { state = conn.prepareStatement(SQL_FIND_BY_USERPHONE); state.setString(1, userPhone); //3. 执行sql语句 并得到结果集 result = state.executeQuery(); //4. 遍历结果集 , 并将每一行数据 存储到对象中 , 将对象存储到集合中 while(result.next()) { int id = result.getInt("ID"); String eNumber = result.getString("ENUMBER"); String username = result.getString("USERNAME"); String company = result.getString