apus102bservlet.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.sxit.pim.push;

import com.sxit.common.*;
import com.sxit.operator.*;
import javax.servlet.http.*;
import javax.servlet.*;
import java.util.*;
import java.sql.*;
import java.io.*;
import com.sxit.pim.black.*;
/**
 * <p>类名: APUS102BServlet</p>
 * <p>功能: 对互动内蒙用户发送push</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-15
 * @修改纪录
 */

public class APUS102BServlet
    extends ServletAdminBase {
    public APUS102BServlet() {
        super();
        operationRight = "APUS0,2";
    }

    public String perform(HttpServletRequest request,
                          HttpServletResponse response) throws Exception {

        String nextPage = "";
        Connection con = null;
        Connection con1 = null;
        Statement stat = null;
        Tpush tpush = null;
        PreparedStatement stmt = null;
        ResultSet rs=null;

        Topmuser myMember = (Topmuser) request.getSession().getAttribute(
            "_currentUser");
        try {
            Collection col = new Vector();
            MultipartHeader multipartHeader;
            UploadReader uploadReader = new UploadReader(request);
            FileOutputStream foStream;

            int id = 0;
            int j = 0;
            String frommdn = "";
            String tomdn = "";
            String title = "";
            String url = "";
            int status = 0;
            String transid = "";
            String result = "";
            String channelid = "";
            long corporationid = 0;

            while ( (multipartHeader = uploadReader.getHeader()) != null) {
                if (multipartHeader.isFile()) {
                    uploadReader.skipFile();
                }
                else {
                    String name = multipartHeader.getParamName();
                    String value = uploadReader.getParamValue();
                    if (name.equals("frommdn")) {
                        frommdn = value;
                    }
                    if (name.equals("title")) {
                        title = value;
                    }
                    if (name.equals("url")) {
                        url = value;
                    }
                    if (name.equals("channelid")) {
                        channelid = value;
                    }
                    corporationid = myMember.getTemp5();
                }
            }
            //System.out.println("11111");
            try{
                con1 = getnmDB.getConnection();
                stat = con1.createStatement();
                rs = stat.executeQuery(
                    "SELECT USER_MDN FROM WAP_USER WHERE USER_AGENT IS NOT NULL");
                while (rs.next()) {
                    col.add(rs.getString("USER_MDN"));
                }
                //System.out.println("0000");
                stat.close();
                rs.close();
            }
            catch(SQLException e){
                con1.rollback();
                System.out.println(e);
                request.setAttribute("messageID", "发送push数据错");
                request.setAttribute("returnPage", "../apus/apus001");
                nextPage = "/apus/apusmessage.jsp";
                writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                         "发送push数据错");
            }
            //System.out.println("取得号码");
            Iterator i = col.iterator();
            con=ConnPoolHandler.getConnection();
            con.setAutoCommit(false);
            String sql = "";
            sql = "insert into tpush " +
                "(id,frommdn,tomdn,title,url,status,result,channelid,systime,transid,corporationid) " +
                "values (?,?,?,?,?,?,?,?,sysdate,?,?)";
            stmt = con.prepareStatement(sql);
            while (i.hasNext()) {
                j++;
                id = (int) KeyContainer.getNewSequence(con, "tpushid");
                tomdn = (String) i.next();
                //判断号码是否在黑名单中
                Tblack tblack = new Tblack();
                if (tblack.isExist(con, tomdn) == false) {
                    stmt.setInt(1, id);
                    stmt.setString(2, frommdn);
                    stmt.setString(3, tomdn);
                    stmt.setString(4, title);
                    stmt.setString(5, url);
                    stmt.setInt(6, status);
                    stmt.setString(7, result);
                    stmt.setString(8, channelid);
                    stmt.setString(9, transid);
                    stmt.setLong(10, corporationid);
                    stmt.addBatch();
                    if (j % 100 == 0) {
                        stmt.executeBatch();
                        stmt.clearBatch();
                    }
                }
            }
            stmt.executeBatch();
            con.commit();
            con.setAutoCommit(true);
            stmt.close();
            request.setAttribute("messageID", "发送成功");
            request.setAttribute("returnPage", "../apus/apus001");
            nextPage = "/apus/apusmessage.jsp";
            writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "新增push管理成功");
        }
        catch (SQLException e) {
            System.out.println(e);
            con.rollback();
            request.setAttribute("messageID", "发送push数据错");
            request.setAttribute("returnPage", "../apus/apus001");
            nextPage = "/apus/apusmessage.jsp";
            writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "发送push数据错");

        }
        catch (Exception e) {
            System.out.println(e);
            request.setAttribute("messageID", "发送push系统错");
            request.setAttribute("returnPage", "../apus/apus001");
            nextPage = "/apus/apusmessage.jsp";
            writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "发送push系统错");
        }
        finally {
            if (stmt != null) {
                stmt.close();
                stmt = null;
            }
            if (rs != null) {
                rs.close();
                rs = null;
            }
            ConnPoolHandler.closeConnection(con);
            ConnPoolHandler.closeConnection(con1);
        }
        javax.servlet.RequestDispatcher rd = getServletContext().
            getRequestDispatcher(nextPage);
        rd.forward(request, response);
        return nextPage;
    }
}