sendletterdao.java

一个简单博客的软件项目,可以给初学者一个引导

package com.wgh.dao;

import java.lang.*;
import java.io.*;
import BestMail.smssend;
import java.sql.*;
import java.util.*;

import com.wgh.actionForm.PersonnelForm;
import com.wgh.actionForm.SendLetterForm;
import com.wgh.core.ConnDB;

public class SendLetterDAO {
	private ConnDB conn=new ConnDB();
	private smssend smssendinformation = null;
	// 发送短信
	public String sendLetter(SendLetterForm s) {
		String ret = "";
		String device="";
		String baud="";
		String sn="";
		String info="";
		String sendnum="";
		String flag="";
		try {
			String sql_p="SELECT top 1 * FROM tb_parameter";
			ResultSet rs=conn.executeQuery(sql_p);
			if(rs.next()){
				device=rs.getString(2);
				baud=rs.getString(3);
				sn=rs.getString(4);
				info=s.getContent();
				sendnum=s.getToMan();
				System.out.println("SN:"+sn+"***********"+info);
				flag=mySend(device,baud,sn,info,sendnum);//发送短信
				if(flag.equals("ok")){
		            String sql = "INSERT INTO tb_shortLetter (toMan,content,fromMan) values('" +s.getToMan() +"','"+s.getContent()+"','"+s.getFromMan()+"')";
		            int r= conn.executeUpdate(sql);
		            System.out.println("添加短信发送历史记录的SQL：" + sql);
		            if(r==0){
		            	ret="添加短信发送历史记录失败！";
		            }else{
		            	ret="ok";
		            }
				}else{
					ret=flag;
				}				
			}else{
				ret="发送短信失败！";
			}
		} catch (Exception e) {
			System.out.println("发送短信产生的错误：" + e.getMessage());
			ret = "发送短信失败！";
		}finally{
			conn.close();
		}
		return ret;
	}
	
	// 初始化GSM Modem设备
	public boolean getConnectionModem(String device,String baud,String sn) {
		smssendinformation = new smssend();
		boolean connection = true;
		if (!smssendinformation.GSMModemInitNew(device, baud, null, "GSM",
			false, sn)) {
			System.out.println("初始化GSM Modem 设备失败："
					+ smssendinformation.GSMModemGetErrorMsg());
			connection = false;
		}
		return connection;	
	}
	// 发送手机短信的方法
	public String mySend(String device,String baud,String sn,String info, String sendnum) {
		boolean flag = false;
		String rtn="";
		flag=this.getConnectionModem(device,baud,sn);

		if(flag){
			byte[] sendtest = smssendinformation.getUNIByteArray(info); // 转化为UNICOCE		
			//实现群发
			String[] arrSendnum=sendnum.split(",");
			for(int i=0;i<arrSendnum.length;i++){
				if (!smssendinformation.GSMModemSMSsend(null, 8, sendtest, arrSendnum[i],false)) {
					System.out.println("发送短信失败："
							+ smssendinformation.GSMModemGetErrorMsg());
					rtn =rtn+"向"+arrSendnum[i]+"发送短信失败!<br>原因是："+smssendinformation.GSMModemGetErrorMsg()+"<br>";
				}
			}
		}else{
			rtn="初始化GSM Modem设备失败！";
		}
		if(rtn.equals("")){
			rtn="ok";
		}
		closeConnection();		//关闭连接
		return rtn;
	}
	// 关闭连接的方法
	public void closeConnection() {
		if (smssendinformation != null) {
			smssendinformation.GSMModemRelease();
			System.out.println("关闭成功！！！");
		}

	}	
    //查询方法
    public List query(){
    	List personnelList = new ArrayList();
        SendLetterForm s = null;
        String sql = "SELECT * FROM tb_shortLetter";
        ResultSet rs = conn.executeQuery(sql);
        String ss="";
        try {
            while (rs.next()) {
                s = new SendLetterForm();
                s.setID(rs.getInt(1));
                s.setToMan(rs.getString(2));
                s.setContent(rs.getString(3));
                s.setFromMan(rs.getString(4));
                ss=rs.getString(5);
                 s.setSendTime(java.text.DateFormat.getDateTimeInstance().parse(ss));//将String型字符串转换成java.util.Date型
                personnelList.add(s);
            }
        } catch (Exception ex) {
        	System.out.println(ex.getMessage());
        }
        return personnelList;
    }
    //接收短信
    public List getLetter(){
    	List list=new ArrayList();
		String device="";
		String baud="";
		String sn="";
		try {
			String sql_p="SELECT top 1 * FROM tb_parameter";
			ResultSet rs=conn.executeQuery(sql_p);
			if(rs.next()){
				device=rs.getString(2);
				baud=rs.getString(3);
				sn=rs.getString(4);
				list=myGet(device,baud,sn);//接收短信
			}else{
				System.out.println("接收短信失败");
			}
		} catch (Exception e) {
			System.out.println("接收短信产生的错误：" + e.getMessage());
		}finally{
			conn.close();
		}
    	return list;
    }
    //接收短信的方法
    public List myGet(String device,String baud,String sn) {
		boolean flag = false;
		flag=this.getConnectionModem(device,baud,sn);
		List list=new ArrayList();
		if(flag){
			String[] allmsg = smssendinformation.GSMModemSMSReadAll(1);
	        // 读出的每一条信息由三部分组成：电话号码#编码#文本内容
	        for (int kk = 0; allmsg != null && kk < allmsg.length; kk++) {
	        	if (allmsg[kk] == null) continue;
	        	String[] tmp = allmsg[kk].split("#");
	        	if (tmp == null || tmp.length != 3) continue;
	        	//获取数据
	        	String codeflg = tmp[1];	//编码
	        	String recvtext = tmp[2];	//短信内容
	        	if (recvtext != null && codeflg.equalsIgnoreCase("8")){
	        		recvtext = smssendinformation.HexToBuf(recvtext);//得到Java的短信文本字符串
	        	}
	        	tmp[2]=recvtext;
	        	System.out.println("短信内容："+recvtext);
	        	list.add(tmp);
	        } 
		}
		closeConnection();		//关闭连接
		return list;
	}
}