apus002bservlet.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>类名: APUS002BServlet</p>
 * <p>功能: 新增单条push</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-15
 * @修改纪录
 */

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

    public String perform(HttpServletRequest request,
                          HttpServletResponse response) throws Exception {
        String nextPage = "";
        Connection con = null;
        Tpush tpush = null;
        Topmuser myMember = (Topmuser) request.getSession().getAttribute(
            "_currentUser");
        try {
            con = ConnPoolHandler.getConnection();
            MultipartHeader multipartHeader;
            UploadReader uploadReader = new UploadReader(request);
            int id = (int) KeyContainer.getNewSequence(con, "tpushid");
            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("tomdn")) {
                        tomdn = value;
                    }
                    if (name.equals("title")) {
                        title = value;
                    }
                    if (name.equals("url")) {
                        url = value;
                    }
                    if (name.equals("channelid")) {
                        channelid = value;
                    }
                    corporationid = myMember.getTemp5();
                }
            }
            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);
            request.setAttribute("messageID", "新增push成功");
            request.setAttribute("returnPage", "../apus/apus001");
            nextPage = "/apus/apusmessage.jsp";
            writeLog("APUS", LogManager.LOGTYPE_APP, myMember.getStaffid(),
                     "新增push成功");
            }else{
                request.setAttribute("messageID", "禁止发送！该号码已被列入黑名单");
                request.setAttribute("returnPage", "../apus/apus001");
                nextPage = "/apus/apusmessage.jsp";
            }
        }
        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;
    }
}