ticketsaction.java~240~

来自「采用web2.0技术,采用动态标签,sql语句全部存储在数据库里面.开发速度快.」· JAVA~240~ 代码 · 共 131 行

package com.sztheater.biz.order;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2006</p>
 * <p>Company: </p>
 * @author not attributable up-and-up
 * @version 1.0
 */
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionForward;
import java.sql.*;
import com.sztheater.framework.web.*;
import com.sztheater.framework.util.*;
import java.util.*;
import javax.servlet.http.*;

public class TicketsAction extends Action {

    public ActionForward execute(ActionMapping mapping,
                                 ActionForm form,
                                 HttpServletRequest request,
                                 HttpServletResponse response) throws
            IOException, ServletException {
        ResultSet rs = null;
        Statement stmt = null;
        Connection conn = null;
        HttpSession _httpsession = null;
        _httpsession = request.getSession();
        String strSQLCount = null, strSQLUp = null;
        String strMsg = null, target = "error";

        int iSuccFlag = 0, ileftCount = 0, iID = 0;
        String ClassID = null, UserName = null, ProgramID = null, SeatID;
        String HallID = null, FloorID = null;

        try {
            HallID = request.getParameter("hallid") == null ?
                     "0" : request.getParameter("hallid");
            FloorID = request.getParameter("floorid") == null ?
                      "0" : request.getParameter("floorid");
            ClassID = request.getParameter("classid") == null ?
                      "0" : request.getParameter("classid");
            UserName = request.getParameter("username") == null ?
                       "" : request.getParameter("username");
            ProgramID = request.getParameter("programid") == null ?
                        "0" : request.getParameter("programid");
            SeatID = request.getParameter("seatid") == null ?
                     "0" : request.getParameter("seatid");
            strSQLCount ="select count(*) as count from t_order_cart a "+
                         "where a.username='" + UserName.trim() + "' and OrderFlag='0' ";

            System.out.println("strSQLCount[" + strSQLCount + "]");

            try {
                conn = DbFunc.getConnection(false);
            } catch (Exception e) {
                iSuccFlag = -90102;
                if (conn != null) {
                    DbFunc.free(conn, iSuccFlag);
                }
                conn = null;
                strMsg = "服务取数据库连接异常" + e.getMessage();
            }
            stmt = conn.createStatement();
            rs = stmt.executeQuery(strSQLCount);
            if (rs.next()) {
                ileftCount = 20 - rs.getInt("leftCount");
                if (ileftCount <= 0) {
                    strMsg = "用户一次只能预订20张票！";
                } else {
                    strSQLUp =
                            "update T_TicketingSeat set StatusID = 5 where SeatID='" +
                            SeatID + "' and programid=" + ProgramID;
                    System.out.println("strSQLUp["+strSQLUp+"]\n");

                    ModifyData.ModifyTicketingSeat(strSQLUp);

                    strSQLUp = "insert into  T_Order_Cart"+
                               "(UserName,ProgramID,HallID,FloorID,ClassID,SeatID,DisCount)"+
                               "values('"+UserName.trim()+
                               "',"+ProgramID+","+HallID+","+FloorID+","+ClassID+","+SeatID+",0);
                    System.out.println("strSQLUp[" + strSQLUp + "]\n");

                    iSuccFlag = stmt.executeUpdate(strSQLUp);
                    System.out.println("iSuccFlag[" + Integer.toString(iSuccFlag) + "]");
                    if (iSuccFlag >= 1)
                        target = "success";
                    else
                        strMsg = "数据库更新错误！请重新操作！";
                }
            } else
                strMsg = "您还没有选票数跟折扣，请先选择！";

        } catch (Exception ex) {
            strMsg = "程序执行异常！";
            ex.printStackTrace();
        } finally {
            request.setAttribute("hallid", HallID);
            request.setAttribute("floorid", FloorID);
            request.setAttribute("username", UserName);
            request.setAttribute("programid", ProgramID);
            if (target.compareToIgnoreCase("error") == 0)
                _httpsession.setAttribute("ErrMsg", strMsg);
            try {
                if (rs != null) {
                    rs.close();
                }
            } catch (Exception ex) {
            }
            try {
                if (stmt != null) {
                    stmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (Exception ex) {
            }
        }
        System.out.println("\n\ntarget["+target+"]\n\n");
        return (mapping.findForward(target));
    }
}