autoresponsion.java

用JAVA实现串口GSM发信息

package com;

import java.sql.ResultSet;
import java.sql.Statement;

import javax.swing.JOptionPane;

public class AutoResponsion extends Thread {
	String phoneNumber = "";

	String isLook = "";

	String userMsg = "";

	public AutoResponsion(String phoneNumber, String isLook, String userMsg) {
		// **set**房号:命令:密码**end**
		// **look**查询的房号**end**
		this.isLook = isLook;
		this.userMsg = userMsg;
		this.phoneNumber = phoneNumber;
	}

	public void run() {// 自动回复
		Gsm_Main_Frame.aotu_jTextArea.insert("用户:" + phoneNumber + "请求操作:"
				+ isLook + "\n", 0);
		String str = "您的操作结果:\n";

		if (isLook.equals("look"))// 查询
		{
			Statement stmt;
			ResultSet rs;
			String sql;			

			try {
				DataBase Test = new DataBase();
				stmt = Test.getStatement();
				sql = "select * from test";
				rs = stmt.executeQuery(sql);
				while (rs.next()) {
					str = str + rs.getString(1) + ";" + rs.getString(2);
				}
				Test.close();
				System.out.println("connect to database OK!\n" + str);
			} catch (Exception e) {
				System.out.println("connect to database Err!");
				e.printStackTrace();
				str = str + "从数据库读取信息时出现错误!";
			}
		}
		
		if (isLook.equals("set"))// 设定
		{
			Statement stmt;
			ResultSet rs;
			String sql;
			DataBase Test = new DataBase();

			try {
				stmt = Test.getStatement();
				sql = "select * from test";
				rs = stmt.executeQuery(sql);
				while (rs.next()) {
					str = str + rs.getString(1) + ";" + rs.getString(2);
				}
				Test.close();
				System.out.println("connect to database OK!\n" + str);
			} catch (Exception e) {
				System.out.println("connect to database Err!");
				e.printStackTrace();
				str = str + "从数据库读取信息时出现错误!";
			}
		}

		if (Gsm_Main_Frame.sendMsg.Send(phoneNumber, str, true, 50001))// 连接数据库,查询后返回结果,发送信息
			JOptionPane.showMessageDialog(null, "已回复:" + phoneNumber);	
		Gsm_Main_Frame.aotu_jTextArea.insert("用户:" + phoneNumber + "的查询已回复,回答内容:\n"+str,
				0);
	}

}