JAVA易拍--epai(struts+Hibernate+Spring+Ajax版)

/* * Generated by MyEclipse Struts * Template path: templates/java/JavaClass.vtl */ package com.xpai.web; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.PrintWriter; import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.struts.action.ActionForm; import org.apache.struts.action.ActionForward; import org.apache.struts.action.ActionMapping; import org.apache.struts.upload.FormFile; import com.xpai.biz.BidBiz; import com.xpai.biz.GoodsBiz; import com.xpai.entity.Bid; import com.xpai.entity.Goods; import com.xpai.entity.User; import com.xpai.util.CosUtil; import com.xpai.util.JbUtils; import com.xpai.util.Page; import com.xpai.util.SpecialFilter; public class GoodsAction extends BaseAction { /* * Generated Methods */ private GoodsBiz goodsBiz = null; private BidBiz bidBiz = null; public ActionForward toAdd(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) { User saler = (User) request.getSession(false).getAttribute("user"); if(saler==null){ return new ActionForward("/index.jsp"); } return mapping.findForward("add_goods"); } public ActionForward upload(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { String fileName = CosUtil.upload(request); System.out.println(fileName); return null; } public ActionForward uploadImage(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception { // response.setContentType("text/html;charset=GBK"); // // 获取当前项目在Tomcat中的路径 // String path = // request.getSession().getServletContext().getRealPath("images"); // GoodsForm pf = (GoodsForm) form; // FormFile file = pf.getEditorImg(); // FileOutputStream fos = new FileOutputStream(path + "/" + // file.getFileName()); // // 将文件写入指定路径 // fos.write(file.getFileData()); // fos.flush(); // fos.close(); // PrintWriter out = response.getWriter(); // out.println(file.getFileName()); // return null; request.setCharacterEncoding("GBK"); GoodsForm goodsForm = (GoodsForm) form; // Goods item = goodsForm.getItem(); FormFile imageFile = goodsForm.getEditorImg(); // 文件名：不包含路径 String filename = imageFile.getFileName(); response.setContentType("text/html;charset=GBK"); response.getWriter().println(filename); // byte[] content=imageFile.getFileData(); 用这个byte[]就死了，outof // memory;提供吸管 InputStream contentStream = imageFile.getInputStream(); // 得到保存目录 // savedir=this.getServlet().getServletContext().getRealPath("/"); String savedir = request.getSession().getServletContext().getRealPath( "images"); // 构建file File fileImage = new File(savedir, filename); // 文件流:文件输出流 FileOutputStream fos = new FileOutputStream(fileImage); // 输入流内容导入到输出流里面去 int len = 0; byte[] buf = new byte[1024]; while ((len = contentStream.read(buf)) != -1) {// 读到了内容 fos.write(buf, 0, len); } // 关门：不关以后会out of memory,JVM会回收对象，但不会回收对象关联的系统资源 contentStream.close(); fos.close(); return null; } public ActionForward doAdd(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws IOException { request.setCharacterEncoding("GBK"); User saler = (User) request.getSession(false).getAttribute("user"); if(saler==null){ return new ActionForward("/index.jsp"); } GoodsForm goodsForm = (GoodsForm) form; // Goods item = goodsForm.getItem(); FormFile imageFile = goodsForm.getEditorImg(); // 文件名：不包含路径 String filename = imageFile.getFileName(); response.setContentType("text/html;charset=GBK"); response.getWriter().println(filename); if (!((imageFile.getFileSize() == 0) || filename.trim().equals(""))) { // byte[] content=imageFile.getFileData(); 用这个byte[]就死了，outof // memory;提供吸管 InputStream contentStream = imageFile.getInputStream(); //String savedir=this.getServlet().getServletContext().getRealPath("images"); String savedir = request.getSession().getServletContext().getRealPath("images"); // 构建file File fileImage = new File(savedir, filename); // 文件流:文件输出流 FileOutputStream fos = new FileOutputStream(fileImage); // 输入流内容导入到输出流里面去 int len = 0; byte[] buf = new byte[1024]; while ((len = contentStream.read(buf)) != -1) {// 读到了内容 fos.write(buf, 0, len); } // 关门：不关以后会out of memory,JVM会回收对象，但不会回收对象关联的系统资源 contentStream.close(); fos.close(); } Goods item = goodsForm.getItem(); item.setGoodsPic("images/" + filename); User user = getCurrUser(request); this.goodsBiz.addGoods(item, user); return mapping.findForward("index"); } public ActionForward doBid(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException { String goodsID = request.getParameter("goods_id"); Double myPrice = JbUtils.parseDouble(request.getParameter("myPrice")); if (myPrice == -1d) { request.getRequestDispatcher("/index.jsp").forward(request, response); } Long goodId = Long.parseLong(goodsID); Goods goods = goodsBiz.getGoods(goodId); User buyer = (User) request.getSession(false).getAttribute("user"); boolean goodIsSold = (goods.getGoodsStatus() == GoodsBiz.GOODS_STATUS_OUT) ? true : false; response.setCharacterEncoding("GBK"); PrintWriter out = response.getWriter(); if (goodIsSold) { out.write("sold"); } Double maxBidInHistory = goodsBiz.getMaxBidByGoods(goods); Double price = goods.getGoodsPrice(); if (maxBidInHistory == null) { if (myPrice <= price) { out.write("less"); } else if (myPrice > price) { bidBiz.addBid(goods, buyer, myPrice); out.write("ok"); } } else if (maxBidInHistory != null) { if (myPrice <= maxBidInHistory) { out.write("less"); } else if (myPrice > maxBidInHistory) { bidBiz.addBid(goods, buyer, myPrice); out.write("ok"); } } return null; // return new ActionForward("/user.do?operate=doLogin"); } public ActionForward doBidNormal(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException { String goodsID = request.getParameter("goods_id"); Double myPrice = JbUtils.parseDouble(request.getParameter("myPrice")); if (myPrice == -1d) { request.setAttribute("msg","Bid Price Invalid!You can't buy it or bid for it.."); request.getRequestDispatcher("msg.jsp").forward(request,response); } Long goodId = Long.parseLong(goodsID); Goods goods = goodsBiz.getGoods(goodId); User buyer = (User) request.getSession(false).getAttribute("user"); boolean goodIsSold = (goods.getGoodsStatus() == GoodsBiz.GOODS_STATUS_OUT) ? true : false; if (goodIsSold) { request.setAttribute("msg","Goods sold out! You can't buy it or bid for it.."); } Double maxBidInHistory = goodsBiz.getMaxBidByGoods(goods); Double price = goods.getGoodsPrice(); if (maxBidInHistory == null) { if (myPrice <= price) { request.setAttribute("msg","You bid too low.You can't buy it or bid for it.."); } else if (myPrice > price) { bidBiz.addBid(goods, buyer, myPrice); request.setAttribute("msg","竞拍成功"); } } else if (maxBidInHistory != null) { if (myPrice <= maxBidInHistory) { request.setAttribute("msg","You bid too low.You can't buy