delorderlistaction.java

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

package com.sztheater.biz.order;

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 DelOrderListAction extends Action {

    public ActionForward execute(ActionMapping mapping,
                                 ActionForm form,
                                 HttpServletRequest request,
                                 HttpServletResponse response) throws
            IOException, ServletException {
        int iSuccFlag = 0;
        int iExistsNum = 0;
        String strMsg = "";
        String strSQL = "";
        String target = "";
        String username = "";
        String ProgramID = "";
        String SeatID = "";
        String OrderID = "";
        String TicketID = "";
        boolean flag = true;

        ResultSet rs = null;
        Statement st = null;
        Connection conn = null;

        username = request.getParameter("username").trim();
        OrderID = request.getParameter("orderid").trim();
        SeatID = request.getParameter("seatid").trim();
        ProgramID = request.getParameter("programid").trim();
        TicketID = request.getParameter("ticketid").trim();
        System.out.println("*************\n");
        System.out.println("SeatID[" + SeatID + "]");
        System.out.println("*************\n");
        try {

            try {
                conn = DbFunc.getConnection(false);
            } catch (Exception e) {
                iSuccFlag = -90102;
                if (conn != null) {
                    DbFunc.free(conn, iSuccFlag);
                }
                conn = null;
                strMsg = "服务取数据库连接异常" + e.getMessage();
                System.out.println("strMsg" + strMsg);
            }
            //取得执行数据库操作Statement
            st = conn.createStatement();

            strSQL =
                    "select count(*) as num from t_seatsordered where orderid='" +
                    OrderID + "'";

            rs = st.executeQuery(strSQL);
            if (rs.next()) {

                iExistsNum = rs.getInt("num");

                if (iExistsNum == 0) {

                    target = "failure";
                    return (mapping.findForward(target));
                }

                if (iExistsNum > 0) {

                    strSQL =
                            "update t_ticketingseat set statusid=0 where programid='" +
                            ProgramID + "' and seatid='" + SeatID + "'";
                    flag = ModifyData.ModifyTicketingSeat(strSQL);
                    System.out.println("strSQL update=" + strSQL);
                    if (flag) {
                        strSQL = "delete from t_seatsordered where orderid='" +
                                 OrderID + "' \n"
                                 + "and ticketid ='" + TicketID +
                                 "' and programid='" + ProgramID + "'";
                        iSuccFlag = DbFunc.runsql(strSQL);
                        System.out.println("strSQL update=" + strSQL);
                        if (iSuccFlag < 1) {
                            target = "failure";
                            return (mapping.findForward(target));

                        }
                        if (iExistsNum == 1) {

                            strSQL = "delete from t_order where	orderid='" +
                                     OrderID + "'";

                            iSuccFlag = DbFunc.runsql(strSQL);
                            if (iSuccFlag < 1) {
                                target = "failure";
                                return (mapping.findForward(target));

                            }
                        }
                    }

                }
            }
            if (iSuccFlag > 0) {
                target = "success";
                System.out.println("success");

            } else {
                target = "failure";
                System.out.println("failure");
                return mapping.findForward(target);

            }
        } catch (Exception e) {

            iSuccFlag = 20102005;
            strMsg = e.getMessage();
            strMsg = "失败！";
        } finally {
            request.setAttribute("username", username);
            try {
                if (rs != null) {
                    rs.close();
                }
            } catch (Exception e1) {
            }
            try {
                if (st != null) {
                    st.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (Exception e1) {
            }
        }
        return (mapping.findForward(target));
    }

}