abak126bservlet.java

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

package com.sxit.pim.black;

import com.sxit.common.*;
import com.sxit.operator.*;
import javax.servlet.http.*;
import javax.servlet.*;
import java.util.*;
import java.sql.*;
import java.io.*;

/**
 * <p>类名: ABAK126BServlet</p>
 * <p>功能: 批量导入黑名单</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2006-01-09
 * @修改纪录
 */

public class ABAK126BServlet
    extends ServletAdminBase {
    public ABAK126BServlet() {
        super();
        operationRight = "ABAK0,2";
    }

    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;
        Tblack tblack = null;
        Topmuser myMember = (Topmuser) request.getSession().getAttribute(
            "_currentUser");
        try {

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

            String mdn = "";
            Vector vector = null;
            java.sql.Timestamp createdate = new java.sql.Timestamp(System.
                currentTimeMillis());
            long corporationid = myMember.getTemp5();
            long staffid = myMember.getStaffid();
            int statusid = 0;
            String _filename = "";
            String _path = getConfig("ABAK", "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("statusid")) {
                        statusid = Integer.parseInt(value);
                    }
                }
            }
            int i = 0;
            Iterator iterator = vector.iterator();
            while (iterator.hasNext()) {
                mdn = iterator.next().toString();
                tblack = new Tblack();
                long blackid = KeyContainer.getNewSequence(con, "tblackid");
                tblack.insert(con, blackid, mdn, createdate, corporationid,
                              staffid, statusid);
                i++;
                if (i >= 20000) {
                    break;
                }
            }
            request.setAttribute("messageID", "新增黑名单信息成功");
            request.setAttribute("returnPage", "../abak/abak001");
            nextPage = "/abak/abakmessage.jsp";
            writeLog("ABAK", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "新增黑名单信息成功");
        }
        catch (SQLException e) {
            System.out.println(e);
            request.setAttribute("messageID", "新增黑名单信息数据错");
            request.setAttribute("returnPage", "../abak/abak001");
            nextPage = "/abak/abakmessage.jsp";
            writeLog("ABAK", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "新增黑名单信息数据错");

        }
        catch (Exception e) {
            System.out.println(e);
            request.setAttribute("messageID", "新增黑名单信息系统错");
            request.setAttribute("returnPage", "../abak/abak001");
            nextPage = "/abak/abakmessage.jsp";
            writeLog("ABAK", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "新增黑名单信息系统错");
        }
        finally {
            ConnPoolHandler.closeConnection(con);
        }
        javax.servlet.RequestDispatcher rd = getServletContext().
            getRequestDispatcher(nextPage);
        rd.forward(request, response);
        return nextPage;
    }
}