//数据库连接初始化 public class DBInfo { String url = null; String username = null; String password = null; String driverClass = null; private static DBInfo db = new DBInfo(); public static DBInfo getInstance(){ return db; } private DBInfo() { InputStream in = this.getClass().getClassLoader().getResourceAsStream("db.properties"); Properties pp = new Properties(); try { pp.load(in); url = pp.getProperty("jdbc.url"); username = pp.getProperty("jdbc.username"); password = pp.getProperty("jdbc.password"); driverClass = pp.getProperty("jdbc.driver"); Class.forName(driverClass); } catch (Exception e) { e.printStackTrace(); }finally{ try { in.close(); } catch (IOException e) { e.printStackTrace(); } } } public Connection getConnection(){ Connection conn = null; try { conn = DriverManager.getConnection(url, username, password); } catch (Exception e) { e.printStackTrace(); } return conn; } } //上传资源初始化 public void init() throws ServletException { super.init(); //servlet启动时 ，读取配置文件中关于上传的信息 InputStream in = this.getClass().getClassLoader().getResourceAsStream("ini.properties"); Properties pp = new Properties(); try { pp.load(in); UPLOAD_ROOT_PATH = pp.getProperty("upload.path"); String tmpPath = pp.getProperty("tmp.path"); //配置上传临时目录 factory = new DiskFileItemFactory(1024*1024*10,new File(tmpPath)); stu = new ServletFileUpload(factory); } catch (Exception e) { e.printStackTrace(); }finally{ try { in.close(); } catch (IOException e) { e.printStackTrace(); } } }

 //前端JSP代码 
 
 
 
 
 ×
上传文件
 
  关闭 
 //后端入库处理 protected void doPost(HttpServletRequest request, HttpServletResponse response) throws  IOException { User user = (User) request.getSession().getAttribute(Const.SESSION_USER); String from=""; try { List fileItemLists = stu.parseRequest(request); for(FileItem fileItem : fileItemLists){ if(fileItem.isFormField()){ from = fileItem.getString(); }else{ //上传文件名 String fileName = fileItem.getName(); String oldfilename = fileItem.getName(); int index = fileName.lastIndexOf("\\"); if(index != -1) { fileName = fileName.substring(index+1); } String root = UPLOAD_ROOT_PATH+user.getUsername(); //获取文件大小 long size = fileItem.getSize(); String sizeString = StringUtil.computeSize(size); Timestamp upTime = new Timestamp(new Date().getTime()); File file = new File(root,fileName); //解决文件同名 int cnt = 1; while(file.exists()){ StringBuffer sb = new StringBuffer(fileName); sb.insert(sb.lastIndexOf("."), "("+cnt+")"); file = new File(root,sb.toString()); cnt++; } //文件路径是否存在 if(!file.getParentFile().exists()){ file.getParentFile().mkdirs(); } try { fileItem.write(file); //上传成功，数据库保存记录 UserFile userFile = new UserFile(); userFile.setCreateTime(upTime); userFile.setFilename(file.getName()); userFile.setFilename(file.getName()); userFile.setFileSize(sizeString); userFile.setIsShared(0); userFile.setOwnerId(user.getId()); userFile.setPath(file.getAbsolutePath()); userFile.setOldfilename(oldfilename); userFileDao.save(userFile); response.sendRedirect(from+"?action=mydisk"); } catch (Exception e) { e.printStackTrace(); response.getWriter().print("上传出错"); } } } } catch (FileUploadException e) { e.printStackTrace(); response.setContentType("text/html; charset=utf8"); response.getWriter().print("上传出错!!"); } }

 //这里上传在上面上传资源时候，将保存原始资源名字 public List findRetrieveListByOwnerId(int ownerId,int isDelete){ List fileList = new ArrayList(); Connection conn = db.getConnection(); PreparedStatement ps = null; ResultSet rs = null; UserFile userFile = null; String sql="select * from file where oldfilename in ( " + " select a.oldfilename from (select oldfilename,count(id) counts from file GROUP BY oldfilename HAVING counts>1) a" + " ) and ownerid=? and isDelete=?"; ps = conn.prepareStatement(sql); ps.setInt(1, ownerId); ps.setInt(2, isDelete); rs = ps.executeQuery(); while(rs.next()){ userFile = new UserFile(); userFile.setId(rs.getInt(1)); userFile.setFilename(rs.getString(2)); userFile.setPath(rs.getString(3)); userFile.setCreateTime(rs.getTimestamp(4)); userFile.setIsShared(rs.getInt(5)); userFile.setOwnerId(rs.getInt(6)); userFile.setFileSize(rs.getString(7)); userFile.setCounts(rs.getInt(8)); userFile.setSharedReason(rs.getString("SharedReason")); userFile.setSharedTime(rs.getString("SharedTime")); fileList.add(userFile); } return fileList; }

 //前端jsp代码  
 <%@include file="common/nav.jsp" %>
 
 
 
以下是微信付款码，扫码即可支付
 
 
 
 
 
 ${msgSuccess }${msgFail }
 
 
 //js实现,采用定时跳转模拟真实用户支付流程，后续进行改动用户会员状态 var test1 = setTimeout(function(){ $("#div1").css("display","none"); $("#div2").css("display","block"); layer.msg('恭喜您，完成扫码支付！', {time: 4000, icon:6},function () { window.location.href="user?action=doTopUp"; }); clearTimeout(test1); },5000); //后端代码 public void doTopUp(User user) { Connection conn = db.getConnection(); PreparedStatement ps = null; ResultSet rs = null; try { //members=1为会员状态 ps = conn.prepareStatement("update user set members = 1 where id = ?"); ps.setInt(1, user.getId()); ps.execute(); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (ps != null) ps.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } }