querydatabase.java

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

                            + " WHERE "
                            + " s.FlagSend=? "
                            + " AND s.TimeToSend<=getdate() and  ReceiveID>0  order by s.sendID";
        }
        Connection conn = null;
        PreparedStatement stmt = null;

        //创建结果集
        ResultSet rsSend = null;

        try {
            conn = ConnectionManager.getSqlConnection();
            stmt = conn.prepareStatement(strSqlSend);
            stmt.setInt(1, 0);
            rsSend = stmt.executeQuery();

            while (rsSend.next()) {
                //创建需要发送数据的对象模型
                SendData sd = new SendData();

                sd.TransactionID = rsSend.getString("TransactionID");
                sd.SendID = rsSend.getInt("SendID");
                sd.ServiceCode = rsSend.getString("ServiceCode").trim();
                sd.MMContentType = rsSend.getInt("MMContentType");
                sd.MessageClass = rsSend.getInt("MessageClass");
                sd.Title = rsSend.getString("Title");
                sd.RecvPhoneNum = rsSend.getString("RecvPhoneNum").trim();

                //2005-07-11修改
                //如果是有"+86"则去掉
                if(sd.RecvPhoneNum.indexOf("+86")>=0){
                    sd.RecvPhoneNum=sd.RecvPhoneNum.substring(3);
                }

                //sd.PrivacyNum = rsSend.getString("PrivacyNum");
                //sd.CopyNum = rsSend.getString("CopyNum");
                //linkid is added  2005
                try {
                    sd.LinkId = rsSend.getString("LinkID").trim();
                } catch (Exception ex) {
                    sd.LinkId = "";
                }

                //sd.IsShowPhone = (!rsSend.getBoolean("IsShowPhone"));
                sd.IsShowPhone = true;

                /*设置VASP所提交MM的付费方，例如，发送方、接收方、发送方和接收方或两方均不付费，
                 //可选，0：Sender、1：Recipients、2：Both、3：Neither、4：ThirdParty*/
                sd.ChangeType = rsSend.getInt("ChargedParty");

                sd.FromPhoneNum = rsSend.getString("FromPhoneNum").trim();

                // /*消息的优先级（重要性）（0=最低优先级，1=正常，2=紧急），byte类型的值，可选*/
                sd.Priority = 1;

                //计费号码
                if(sd.ChangeType==1){
                    sd.ChargedNumber = sd.RecvPhoneNum;
                  }else //if(sd.ChangeType==0){
                  {    sd.ChargedNumber = sd.FromPhoneNum;
                  }


                //需要处理路径为空的问题哦.......2005-07-05
                //主路径
                String MixContentPath = "";
                try {
                    MixContentPath = rsSend.getString("MixPath").trim();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }

                //如果内容路径
                if (MixContentPath.equals("")) {
                    String PicContentPath = "";
                    try {
                        PicContentPath = rsSend.getString("PicPath").trim();
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }

                    String RingContentPath = "";
                    try {
                        RingContentPath = rsSend.getString("RingPath").trim();
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }

                    try {
                        if (!PicContentPath.equals("")) {
                            if (!RingContentPath.equals("")) {
                                sd.ContentNames = new String[2];
                                sd.ContentPaths = new String[2];

                                sd.ContentPaths[0] = PicContentPath;
                                sd.ContentPaths[1] = RingContentPath;
                                sd.ContentNames[0] = PicContentPath.substring(PicContentPath.
                                        lastIndexOf("\\"));
                                sd.ContentNames[1] = RingContentPath.substring(PicContentPath.
                                        lastIndexOf("\\"));
                            } else {
                                sd.ContentNames = new String[1];
                                sd.ContentPaths = new String[1];
                                sd.ContentPaths[0] = PicContentPath;
                                sd.ContentNames[0] = PicContentPath.substring(PicContentPath.
                                        lastIndexOf("\\"));
                            }
                        }
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }

                } else {
                    try {
                        //设置彩信标题为文件夹的名称
                        //sd.Title = MixContentPath.substring(MixContentPath.lastIndexOf("\\") + 1);
                        File MyDir = new File(MixContentPath);
                        //String[] strFileNames = MyDir.list();
                        sd.ContentNames = MyDir.list();
                        sd.ContentPaths = new String[sd.ContentNames.length];
                        for (int i = 0; i < sd.ContentNames.length; i++) {
                            sd.ContentPaths[i] = MixContentPath + "\\" + sd.ContentNames[i];
                            System.out.println(sd.ContentPaths[i]);
                        }

                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
                vData.add(sd);
            }
        } catch (Exception ex) {
            //显示出错信息
            ex.printStackTrace();
            String temp = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(temp + ex.getMessage() + "Querybase查询数据库" + "\n");
        } finally {
            //关闭数据库连接
            ConnectionManager.closeSqlResultSet(rsSend);
            ConnectionManager.closeSqlPreparedStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
        return vData;
    }

    /**
     * 更新数据库中的发送状态(参数见api)
     */
    public static void updateSendStatus(String strCode, int nSendId) {
        String strSql = "UPDATE TB_MMS_SEND_TEMP SET "
                + "RetCode=?"
                + " WHERE SendId=?";
        Connection conn = null;
        PreparedStatement stmt = null;
        try {
            conn = ConnectionManager.getSqlConnection();
            stmt = conn.prepareStatement(strSql);
            stmt.setString(1, strCode);
            stmt.setInt(2, nSendId);
            stmt.executeUpdate();

        } catch (Exception e) {
            e.printStackTrace();
            String temp = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(temp + e.getMessage() + "mymmssender更新数据库" + "\n");
        } finally {
            ConnectionManager.closeSqlPreparedStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
    }

    /**
     * 更新数据库中的发送状态(参数见api)
     */
    public static void GetSystemDefiniens() {
        String strSql = "select * from TB_SYSTEM_DEFINED";
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = ConnectionManager.getSqlConnection();
            stmt = conn.createStatement();
            rs = stmt.executeQuery(strSql);

            while (rs.next()) {
                MMSManage.strContentPath = rs.getString("ContentPath");
                MMSManage.strReceivePath = rs.getString("ReceivedPath");
            }

        } catch (Exception e) {
            e.printStackTrace();
            String temp = FrmMMSManage.m_txtStatus.getText();
            FrmMMSManage.m_txtStatus.setText(e.getMessage() + "mymmssender获取系统设置" + "\n" + temp);
        } finally {
            ConnectionManager.closeSqlStatement(stmt);
            ConnectionManager.closeSqlConnection(conn);
        }
    }


}