mymmreceiver.java

彩信开发一般应用好了不？彩信开发一般应用好了不？彩信开发一般应用好了不？彩信开发一般应用好了不？彩信开发一般应用好了不？

     */
    public MM7VASPRes doDeliveryReport(MM7DeliveryReportReq mm7DeliveryReportReq) {
        MM7DeliveryReportRes resReport = new MM7DeliveryReportRes();

        try{
            //阅读报告结构
            ReadReport report = new ReadReport();

            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.strMessageID = mm7DeliveryReportReq.getMessageID();
            }

            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.strMMSRelayServerID = mm7DeliveryReportReq.getMMSRelayServerID();
            }
            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.strRecipient = mm7DeliveryReportReq.getRecipient();
            }
            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.strSender = mm7DeliveryReportReq.getSender();
            }
            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.strStatusText = mm7DeliveryReportReq.getStatusText();
            }
            if (mm7DeliveryReportReq.isMessageIDExist()) {
                report.dDate = mm7DeliveryReportReq.getTimeStamp();
            }
            if(mm7DeliveryReportReq.isTransactionIDExist()){
                report.strTransactionID = mm7DeliveryReportReq.getTransactionID();
            }
            if(mm7DeliveryReportReq.isMMStatusExist()){
                report.nStatus = mm7DeliveryReportReq.getMMStatus();
            }

            AddDeliveryReport(report);
            resReport.setTransactionID(mm7DeliveryReportReq.getTransactionID());
            resReport.setStatusCode(1000);
        }catch(Exception ex){
            ex.printStackTrace();
        }

        return resReport;
    }

    /**
     * 处理到VASP的读后回复报告(阅读报告)
     * @param mm7ReadReplyReq MM7ReadReplyReq
     * @return MM7VASPRes
     */
    public MM7VASPRes doReadReply(MM7ReadReplyReq mm7ReadReplyReq) {
        MM7ReadReplyRes resRead = new MM7ReadReplyRes();
        try{
            //阅读报告结构
            ReadReport report = new ReadReport();

            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.strMessageID = mm7ReadReplyReq.getMessageID();
            }

            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.strMMSRelayServerID = mm7ReadReplyReq.getMMSRelayServerID();
            }
            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.strRecipient = mm7ReadReplyReq.getRecipient();
            }
            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.strSender = mm7ReadReplyReq.getSender();
            }
            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.strStatusText = mm7ReadReplyReq.getStatusText();
            }
            if (mm7ReadReplyReq.isMessageIDExist()) {
                report.dDate = mm7ReadReplyReq.getTimeStamp();
            }
            if(mm7ReadReplyReq.isTransactionIDExist()){
                report.strTransactionID = mm7ReadReplyReq.getTransactionID();
            }
            if(mm7ReadReplyReq.isMMStatusExist()){
                report.nStatus = mm7ReadReplyReq.getMMStatus();
            }

            AddReport(report);
            resRead.setTransactionID(mm7ReadReplyReq.getTransactionID());
            resRead.setStatusCode(1000);
        }catch(Exception ex){
            ex.printStackTrace();
        }
        return resRead;
    }

    /**
     * 将上行取得的数据插入数据库中
     * @param nMMContentType int 彩信类型
     * @param strTitle String 彩信标题
     * @param strPhoneNum String 发送号码
     * @param strReceiveNum String 接收号码
     * @param strLinkId String
     * @param strTxt String
     * @return int 返回刚刚插入数据库的id号
     */
    private int addMMSData(String strTransactionID, int nMMContentType,
            String strTitle,
            String strPhoneNum,
            String strReceiveNum,
            String strLinkId,
            String strTxt
            ) {
        int nNewId = 0;
        //int nMax = 0;

        String strSql = "INSERT INTO TB_MMS_RECEIVE_TEMP"
                + "(AcceptTime,PhoneNum,ReceiveNum,LINKID,TextContent,TransactionID,Title) "
                + "VALUES"
                + "(getDate(),?,?,?,?,?,?)";
        //String strSqlGetNewId = "SELECT ReceiveID FROM TB_RECEIVE";
        String strSqlGetNewId = "SELECT MAX(ReceiveID) FROM TB_MMS_RECEIVE_TEMP";

        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {

            conn = ConnectionManager.getSqlConnection();
            stmt = conn.prepareStatement(strSql);

            if (strPhoneNum != null) {
                stmt.setString(1, strPhoneNum.trim());
            } else {
                stmt.setString(1, "13900000000");
            }

            if (strReceiveNum != null) {
                stmt.setString(2, strReceiveNum.trim());
            } else {
                stmt.setString(2, "13900000000");
            }

            if (strLinkId != null) {
                stmt.setString(3, strLinkId.trim());
            } else {
                stmt.setString(3, "");
            }

            if (strTxt != null) {
                stmt.setString(4, strTxt.trim());
            } else {
                stmt.setString(4, "");
            }

            if (strTxt != null) {
                stmt.setString(5, strTransactionID.trim());
            } else {
                stmt.setString(5, "");
            }
            if (strTitle != null) {
        stmt.setString(6, strTitle.trim());
    } else {
        stmt.setString(6, "");
    }

            stmt.executeUpdate();

            ConnectionManager.closeSqlPreparedStatement(stmt);

            stmt = conn.prepareStatement(strSqlGetNewId);
            rs = stmt.executeQuery();

            while (rs.next()) {
                nNewId = rs.getInt(1);
            }

            Timestamp tt = new Timestamp(System.currentTimeMillis());
            String strTime = tt.toLocaleString();

        } catch (Exception e) {
            String strText = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(strText + "\n" + e.getMessage());
            nNewId = -1;
        } finally {
            ConnectionManager.closeSqlPreparedStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
        return nNewId;
    }
    /**
     * 将递送报告更新(需要改)
     * @param report ReadReport 阅读报告的结构
     */
    private void AddDeliveryReport(ReadReport report) {
        String strSql = "INSERT INTO tb_all_deliverreport("
                + "MessageID,"
                + "TransactionId,"
                + "MMSRelayServerID,"
                + "Recipient,"
                + "Sender,"
                + "StatusText,"
                + "Result,"
                + "GetTime) "
                + "VALUES(?,?,?,?,?,?,?,getdate())";

        Connection conn = null;
        PreparedStatement stmt = null;
        try {
            conn = ConnectionManager.getSqlConnection();
            stmt = conn.prepareStatement(strSql);
            stmt.setString(1, report.strMessageID);
            stmt.setString(2, report.strTransactionID);
            stmt.setString(3, report.strMMSRelayServerID);
            stmt.setString(4, report.strRecipient);
            stmt.setString(5, report.strSender);
            stmt.setString(6, report.strStatusText);
            stmt.setInt(7, report.nStatus);
            stmt.executeUpdate();
        }
        catch (Exception e)
        {
            e.printStackTrace();
            String temp = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(temp + e.getMessage() + "AddDeliveryReport添加内容" + "\n");
        }
        finally
        {

            ConnectionManager.closeSqlPreparedStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
    }

    /**
     * 将递送报告更新(需要改)
     * @param report ReadReport 阅读报告的结构
     */
    private void AddReport(ReadReport report) {
        String strSql = "INSERT INTO tb_all_report("
                + "MessageID,"
                + "TransactionId,"
                + "MMSRelayServerID,"
                + "Recipient,"
                + "Sender,"
                + "StatusText,"
                + "Result,"
                + "GetTime) "
                + "VALUES(?,?,?,?,?,?,?,getdate())";

        Connection conn = null;
        PreparedStatement stmt = null;
        try {
            conn = ConnectionManager.getSqlConnection();
            stmt = conn.prepareStatement(strSql);
            stmt.setString(1, report.strMessageID);
            stmt.setString(2, report.strTransactionID);
            stmt.setString(3, report.strMMSRelayServerID);
            stmt.setString(4, report.strRecipient);
            stmt.setString(5, report.strSender);
            stmt.setString(6, report.strStatusText);
            stmt.setInt(7, report.nStatus);
            stmt.executeUpdate();
        }
        catch (Exception e)
        {
            e.printStackTrace();
            String temp = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(temp + e.getMessage() + "AddReport添加内容" + "\n");
        }
        finally
        {

            ConnectionManager.closeSqlPreparedStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
    }

    private void jbInit() throws Exception {
    }

}