apus126bservlet.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>类名: APUS126BServlet</p>
 * <p>功能: 处理上传文本发送push</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-15
 * @修改纪录
 */

public class APUS126BServlet
    extends ServletAdminBase {
    public APUS126BServlet() {
        super();
        operationRight = "APUS0,4";
    }

    public Vector getVector(InputStream in) throws Exception {
        Vector vector = new Vector();
        int buffersize = 102400;
        int safesize = 100000;
        byte[] by = new byte[buffersize];
        byte[] tmp = new byte[buffersize];
        int i = 0;
        int j = 0;
        int c = in.read(by, 0, safesize);
        j = 0;
        while (c != -1) {
            i = 0;
            while (i < c) {
                if (by[i] == 0x0d && by[i + 1] == 0x0a) {
                    vector.add(new String(tmp, 0, j, "gb2312"));
                    i = i + 1;
                    j = 0;
                }
                else {
                    tmp[j] = by[i];
                    j++;

                }
                i++;
            }
            if (c < safesize)
                break;
            c = in.read(by, 0, safesize);
        }
        if (j > 0) {
            vector.add(new String(tmp, 0, j, "gb2312"));
        }
        return vector;
    }

    public String perform(HttpServletRequest request,
                          HttpServletResponse response) throws Exception {
        String nextPage = "";
        Connection con = null;
        Tpush tpush = null;
        Vector vector = null;
        Topmuser myMember = (Topmuser) request.getSession().getAttribute(
            "_currentUser");
        try {

            con = ConnPoolHandler.getConnection();
            int c = 0;
            MultipartHeader multipartHeader;
            UploadReader uploadReader = new UploadReader(request);
            FileOutputStream foStream;

            int id = 0;
            String frommdn = "";
            String tomdn = "";
            String title = "";
            String transid = "";
            String url = "";
            int status = 0;
            String result = "";
            String channelid = "";
            java.sql.Timestamp systime = null;
            long corporationid = 0;
            String _filename = "";
            String _path = getConfig("APUS", "path");
            while ( (multipartHeader = uploadReader.getHeader()) != null) {
                if (multipartHeader.isFile()) {
                    if (multipartHeader.getFileName().compareTo("") != 0) {
                        String paramName = multipartHeader.getParamName();
                        int aPos = multipartHeader.getFileName().lastIndexOf(
                            ".");
                        String fileName1 = multipartHeader.getFileName().
                            substring(aPos).toLowerCase();
                        if (!fileName1.equals(".txt"))
                            throw new Exception();

                        vector = getVector(uploadReader.getBodyInputStream());
                    }
                    else {
                        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();
            int i = 0;
            Iterator iterator = vector.iterator();
            while (iterator.hasNext()) {
                i++;
                id = (int) KeyContainer.getNewSequence(con, "tpushid");
                tomdn = iterator.next().toString();
                //判断号码是否在黑名单中
                Tblack tblack = new Tblack();
                if (tblack.isExist(con, tomdn) == false) {
                    tpush = new Tpush();
                    tpush.insert(con, id, frommdn, tomdn, title, url, status,
                                 result, channelid, transid, corporationid);
                    if (i >= 20000) {
                        break;
                    }
                }
            }
            request.setAttribute("messageID", "发送push成功");
            request.setAttribute("returnPage", "../apus/apus001");
            nextPage = "/apus/apusmessage.jsp";
            writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "发送push成功");
        }
        catch (SQLException 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数据错");
        }
        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 {
            ConnPoolHandler.closeConnection(con);
        }
        javax.servlet.RequestDispatcher rd = getServletContext().
            getRequestDispatcher(nextPage);
        rd.forward(request, response);
        return nextPage;
    }
}