smssender.java

Java短信猫收发短信编程：利用java串口通信功能

}

class SmsSender_jButton3_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jButton3_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton3_actionPerformed(e);
  }
}

class SmsSender_jTextPane1_keyAdapter
    extends java.awt.event.KeyAdapter {
  SmsSender adaptee;

  SmsSender_jTextPane1_keyAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void keyReleased(KeyEvent e) {
    adaptee.jTextPane1_keyReleased(e);
  }
}

class SmsSender_jTextField1_keyAdapter
    extends java.awt.event.KeyAdapter {
  SmsSender adaptee;

  SmsSender_jTextField1_keyAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void keyPressed(KeyEvent e) {
    adaptee.jTextField1_keyPressed(e);
  }

  public void keyReleased(KeyEvent e) {
    adaptee.jTextField1_keyReleased(e);
  }
}

class SmsSender_jButton4_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jButton4_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton4_actionPerformed(e);
  }
}

class SmsSender_jButton5_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jButton5_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton5_actionPerformed(e);
  }
}

class smsThread
    extends Thread {
  SmsSender ss;
  public smsThread(SmsSender parent) {
    ss = parent;
  }

  public void run() {
    while (true) {
      System.out.println("-------" +
                         new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").
                         format(new java.util.Date()) + ", 扫描数据库...-----");
      DbConnect dbConnect = new DbConnect();
      dbConnect.openConnection();
      String sql = "select * from shortmsg where nStatus = 1";
      try {
        ResultSet rs = dbConnect.executeQuery(sql);
        if (rs.next()) {
          int nMsgID = rs.getInt(1);
          String dialNums = rs.getString("sMobile").trim();
          String dialText = rs.getString("sMsgContent").trim();
          rs.close();
          dialText = dialText.substring(0, 69);
          System.out.println("手机号码: " + dialNums);
          System.out.println("短信内容: " + dialText);
          sql = "update shortmsg set nStatus = 2 where nMsgID=" + "'" + nMsgID +
              "'";
          dbConnect.executeUpdate(sql);
          dbConnect.close();
          String dialNum;
          int dialTextLen = ss.getDialTextHex(dialText).length() / 2;
          String dialTextLenHex = Integer.toHexString(dialTextLen);
          if (dialTextLen < 15) {
            dialTextLenHex = "0" + dialTextLenHex;
          }
          String dialNumAr[] = dialNums.split(",");
          for (int i = 0; i < dialNumAr.length; i++) {
            dialNum = dialNumAr[i];
            if (ss.isDialNumValid(dialNum)) {
              try {
                String cmd0 = "AT+CMGS=" + (dialTextLen + 15) + "\r";
                ss.smsout.write(cmd0.getBytes());
                String cmd1 = "0011000D9168" + ss.getDialNumHex(dialNum) +
                    "0008A7" + dialTextLenHex + ss.getDialTextHex(dialText) +
                    (char) 26;
                ss.smsout.write(cmd1.getBytes());
                System.out.println("正在向 " + dialNum + " 发短信...");
              }
              catch (Exception e1) {
                JOptionPane.showMessageDialog(null, e1.getMessage(), "error", 1);
              }
              try {
                Thread.sleep(5000);
              }
              catch (Exception e1) {
                JOptionPane.showMessageDialog(null, e1.getMessage(), "error", 1);
              }
            }
            else {
              System.out.println("手机号 " + dialNum + " 不合法...");
            }
          }
          System.out.println("发送完毕，谢谢使用...");
        }
      }
      catch (SQLException e) {
        System.out.println(e.getMessage());
      }
      try {
        this.sleep(5000);
      }
      catch (Exception e) {
        return;
      }
    }
  }
}

class DbConnect {

  Connection conn = null;
  Statement stmt = null;
  ResultSet rset = null;

  public DbConnect() {
  }

  public static void main(String args[]) {
    DbConnect dbconnect = new DbConnect();
    System.out.println(dbconnect.openConnection());
  }

  public boolean openConnection() {
    Properties properties = new Properties();
    try {
      InputStream inputstream = new FileInputStream(System.getProperty(
          "user.dir") + "\\dbgb2312.txt");
      properties.load(inputstream);
      if (inputstream != null) {
        inputstream.close();
      }
    }
    catch (IOException ioexception) {
      System.out.println("[DbConnection] Open db.txt File, Error!");
    }
    String driver = properties.getProperty("driver");
    String conparam = properties.getProperty("url");
    try {
      Class.forName(driver).newInstance();
    }
    catch (ClassNotFoundException classnotfoundexception) {
      System.out.println("JDBC login, Error!@" +
                         classnotfoundexception.getMessage());
      return false;
    }
    catch (Exception exception) {
      System.err.println("Unable to load driver!");
      exception.printStackTrace();
    }
    try {
      conn = DriverManager.getConnection(conparam);
    }
    catch (SQLException sqlexception) {
      System.out.println("Generate Connection, Error!" +
                         sqlexception.getMessage());
      return false;
    }
    return true;
  }

  public Connection getConn() {
    return conn;
  }

  public ResultSet executeQuery(String sql) throws SQLException {
    stmt = conn.createStatement(1005, 1008);
    rset = stmt.executeQuery(sql);
    return rset;
  }

  public void executeUpdate(String sql) throws SQLException {
    stmt = conn.createStatement(1005, 1008);
    stmt.executeUpdate(sql);
    if (stmt != null) {
      stmt.close();
    }
  }

  public void close() throws SQLException {
    if (conn != null) {
      conn.close();
    }
    if (rset != null) {
      rset.close();
    }
    if (stmt != null) {
      stmt.close();
    }
  }
}

class SmsSender_jMenuItem1_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem1_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem1_actionPerformed(e);
  }
}

class SmsSender_jMenuItem2_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem2_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem2_actionPerformed(e);
  }
}

class SmsSender_jMenuItem3_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem3_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem3_actionPerformed(e);
  }
}

class SmsSender_jMenuItem4_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem4_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem4_actionPerformed(e);
  }
}

class SmsSender_jMenuItem5_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem5_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem5_actionPerformed(e);
  }
}

class SmsSender_jMenuItem6_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem6_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem6_actionPerformed(e);
  }
}

class SmsSender_jMenuItem7_actionAdapter
    implements java.awt.event.ActionListener {
  SmsSender adaptee;

  SmsSender_jMenuItem7_actionAdapter(SmsSender adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jMenuItem7_actionPerformed(e);
  }
}