listentask.java

中国电信isag短信部分源码和ismp部分源码

package test.send;

import java.util.ArrayList;
import java.util.List;

import test.jdbc.SmsDAO;
import test.sms.SMSTest;




//检测发送短信任务
public class ListenTask extends Thread
{
	
	private SendMessageEntity sengMessageEntity;
	private SMSTest sMSTest;
	private SmsDAO insertSMSAction; 
	public ListenTask()
	{
		
		sMSTest = new SMSTest();
		insertSMSAction = new SmsDAO();
	}
	public void run()
	{
	  while(true)
	  {
		  //查询发送短信任务
		  sengMessageEntity = insertSMSAction.selectSms();
		 
		   //如果有记录就进行发送短信操作
		  if(sengMessageEntity!=null)
		  {
			
				 //调用发送短信方法
			    sMSTest.sendSMS(sengMessageEntity);
				//修改短信状态
				insertSMSAction.updateStatus(sengMessageEntity.getSmsID());
				
				System.out.println("发送成功");
		  }
		  else
		  {
			  try
			{
				System.out.println("没有任务,休息一分钟");  
				this.sleep(10 * 60*1000);
			}
			catch (InterruptedException e)
			{
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			 
		  }
		  
	  }
		
		
	}
}