package?com.winhands.quartz;
創(chuàng)新互聯(lián)公司是一家專業(yè)提供北塔企業(yè)網(wǎng)站建設(shè),專注與做網(wǎng)站、成都網(wǎng)站制作、H5頁面制作、小程序制作等業(yè)務(wù)。10年已為北塔眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進(jìn)行中。
import?java.io.PrintWriter;
import?java.io.StringWriter;
import?java.io.UnsupportedEncodingException;
import?java.util.ArrayList;
import?java.util.Date;
import?java.util.HashMap;
import?java.util.List;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?com.winhands.base.service.BaseService;
import?com.winhands.util.BaseConstant;
import?com.winhands.web.dict.entity.DictCommon;
import?com.winhands.web.xfhf.entity.SmsOutBox;
import?com.winhands.web.xfhf.entity.SmsVisit;
import?com.winhands.web.xfhf.entity.TaskInfo;
public?class?SmsSendSync?{
public?BaseService?baseService;
public?BaseService?baseServiceMas;
public?static?final?Logger?logger?=?LoggerFactory.getLogger(SmsSendSync.class);
//同步短信到mas機(jī)待發(fā)短信表
public?void?work()?{
//?任務(wù)ID?100001
//?首先查詢?nèi)蝿?wù)是否正在執(zhí)行
//?查詢列表
TaskInfo?taskInfo?=?new?TaskInfo();
taskInfo.setTask_id("100001");
try?{
taskInfo?=?(TaskInfo)?baseService.queryForObject("sms_send.queryTaskStatus",?taskInfo);
//如果狀態(tài)是處室狀態(tài)則執(zhí)行，否則此次任務(wù)不執(zhí)行
if?(BaseConstant.task_status_cs.equals(taskInfo.getTask_status()))?{
taskInfo.setTask_status(BaseConstant.task_status_zx);//設(shè)置任務(wù)執(zhí)行狀態(tài)為執(zhí)行
taskInfo.setTask_last_start_time(new?Date());//設(shè)置任務(wù)執(zhí)行開始時(shí)間
baseService.update("sms_send.updateTaskStatus",?taskInfo);//
//移動(dòng)號(hào)碼庫
HashMapString,String?hashMap?=?new?HashMapString,String();
//134?、135、136、137、138、139、150、151、152、158、159、182、183、184。157、187、188
hashMap.put("134",?"134");
hashMap.put("135",?"135");
hashMap.put("136",?"136");
hashMap.put("137",?"137");
hashMap.put("138",?"138");
hashMap.put("139",?"139");
hashMap.put("150",?"150");
hashMap.put("151",?"151");
hashMap.put("152",?"152");
hashMap.put("157",?"157");
hashMap.put("158",?"158");
hashMap.put("159",?"159");
hashMap.put("182",?"182");
hashMap.put("183",?"183");
hashMap.put("184",?"184");
hashMap.put("187",?"187");
hashMap.put("188",?"188");
SmsVisit?smsSend?=?new?SmsVisit();
smsSend.setSms_status(BaseConstant.sms_status_csh);
List?list?=?baseService.queryForList("sms_send.queryForSmsTask",?smsSend);
List?smsMasList?=?new?ArrayList();
List?smsList?=?new?ArrayList();
if?(list?==?null||list.size()==0)?return;//?如果列表為空，沒有待辦任務(wù)，則任務(wù)結(jié)束
for?(int?i?=?0;?i??list.size();?i++)?{
smsSend?=?(SmsVisit)?list.get(i);
//String?msg?=?messagecontent(smsSend);
String?msg?=?smsSend.getSpare_2();
if(hashMap.get(smsSend.getVisit_phone().substring(0,?3))!=null){
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid(smsSend.getP_id());
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr(smsSend.getVisit_phone());
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode(smsSend.getExtccode());
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
smsOutBox.setMessagecontent(msg);
smsMasList.add(smsOutBox);
}else{
boolean?con?=?true;
String?lastMsg?=?msg;
int?xh?=0;
while(con){
lastMsg?=?msg.substring(0,msg.length()??55???55?:?msg.length());
msg?=?msg.substring(msg.length()??55???55?:?msg.length(),msg.length());
if?(msg.equals(""))?{
con?=?false;
}
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid(smsSend.getP_id()+(xh==0?"":xh));
xh++;
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr(smsSend.getVisit_phone());
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode(smsSend.getExtccode());
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
smsOutBox.setMessagecontent(lastMsg);
smsMasList.add(smsOutBox);
}
}
SmsVisit?smsSendTemp?=?new?SmsVisit();
smsSendTemp.setP_id(smsSend.getP_id());?
//smsSendTemp.setSpare_2(msg);//短信內(nèi)容
smsSendTemp.setSms_status_time(new?Date());
smsSendTemp.setSms_status(BaseConstant.sms_status_yfswg);?
smsList.add(smsSendTemp);
}
baseService.insertBatch("sms_send.insertSmsOutBox",?smsMasList);//插入本地歷史記錄表
baseServiceMas.insertBatch("sms_mas.insertSmsOutBox",?smsMasList);//插入mas機(jī)待發(fā)送表
baseService.updateBatch("sms_send.updateSmsVisit",?smsList);//更新回訪記錄狀態(tài)
}
}?catch?(Exception?e)?{
e.printStackTrace();
//baseService.saveLog("同步短信到mas機(jī)待發(fā)短信表",?"100001",?"同步短信到mas機(jī)待發(fā)短信表錯(cuò)誤");
logger.error("同步短信到mas機(jī)待發(fā)短信表錯(cuò)誤",?getTrace(e));
}finally{
try?{
taskInfo.setTask_status(BaseConstant.task_status_cs);//設(shè)置任務(wù)執(zhí)行狀態(tài)為初始
taskInfo.setTask_last_end_time(new?Date());//設(shè)置任務(wù)執(zhí)行結(jié)束時(shí)間
taskInfo.setTask_status_desc("任務(wù)執(zhí)行結(jié)束");
baseService.update("sms_send.updateTaskStatus",?taskInfo);//
}?catch?(Exception?e2)?{
e2.printStackTrace();
//?TODO:?handle?exception
}
}
}
public?String?messagecontent(SmsVisit?smsSend){
//XX，您好！您于XX月XX日辦理XX業(yè)務(wù)(或XX，您好！XX大隊(duì)于XX月XX日對(duì)你單位進(jìn)行監(jiān)督檢查/行政處罰/火災(zāi)調(diào)查)，現(xiàn)進(jìn)行滿意度回訪，請(qǐng)回復(fù)數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對(duì)消防工作的支持！回復(fù)免費(fèi)。宿遷市公安消防支隊(duì)
//首先根據(jù)業(yè)務(wù)類型來判斷采用哪種模板?監(jiān)察
StringBuffer?msg?=?new?StringBuffer("");?
if(BaseConstant.jiancha.equals(smsSend.getVisit_deal_business_type())){
msg.append(smsSend.getVisit_name_cn())
???.append(",您好!")
???.append(smsSend.getVisit_deal_org_name())
???.append("于")
???.append(smsSend.getVisit_deal_time().substring(4,?6)).append("月")
???.append(smsSend.getVisit_deal_time().substring(6,?8)).append("日")
???.append("對(duì)你單位進(jìn)行").append(DictCommon.getEntryMap(BaseConstant.jiancha).get(smsSend.getVisit_deal_business()))
???.append(",現(xiàn)進(jìn)行滿意度回訪，請(qǐng)回復(fù)數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對(duì)消防工作的支持！");
}else?if(BaseConstant.yewu.equals(smsSend.getVisit_deal_business_type())){
msg.append(smsSend.getVisit_name_cn())
???.append(",您好!您于")
???.append(smsSend.getVisit_deal_time().substring(4,?6)).append("月")
???.append(smsSend.getVisit_deal_time().substring(6,?8)).append("日")
???.append("辦理").append(smsSend.getVisit_deal_business()).append("業(yè)務(wù),")
???.append("現(xiàn)進(jìn)行滿意度回訪，請(qǐng)回復(fù)數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對(duì)消防工作的支持！");
}
return?msg.toString();
}
public?BaseService?getBaseService()?{
return?baseService;
}
public?void?setBaseService(BaseService?baseService)?{
this.baseService?=?baseService;
}
public?BaseService?getBaseServiceMas()?{
return?baseServiceMas;
}
public?void?setBaseServiceMas(BaseService?baseServiceMas)?{
this.baseServiceMas?=?baseServiceMas;
}
public?static?void?main(String[]?args){
List?smsMasList?=?new?ArrayList();?
try?{
String?msg?=?"***，您好！*********于2015年5月2日對(duì)你單位進(jìn)行監(jiān)督檢查，現(xiàn)進(jìn)行滿意度回訪，請(qǐng)回復(fù)數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對(duì)消防工作的支持！";
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid("12344");
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr("111");
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode("2222");
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
boolean?con?=?true;
String?lastMsg?=?msg;
while(con){
lastMsg?=?msg.substring(0,msg.length()??55???55?:?msg.length());
msg?=?msg.substring(msg.length()??55???55?:?msg.length(),msg.length());
if?(msg.equals(""))?{
con?=?false;
}
SmsOutBox?smOutBox_temp?=?new?SmsOutBox();?
smOutBox_temp?=?smsOutBox;
smOutBox_temp.setMessagecontent(lastMsg);
?
smsMasList.add(smOutBox_temp);
}
for(Object?o:smsMasList){
SmsOutBox?smsOutBox2?=?(SmsOutBox)o;
System.out.println(smsOutBox2.getMessagecontent());
}
}?catch?(Exception?e)?{
//?TODO?Auto-generated?catch?block
e.printStackTrace();
}
}
public?static?String?getTrace(Throwable?t)?{
StringWriter?stringWriter=?new?StringWriter();
PrintWriter?writer=?new?PrintWriter(stringWriter);
t.printStackTrace(writer);
StringBuffer?buffer=?stringWriter.getBuffer();
return?buffer.toString();
}
}
短信不是你想發(fā)??想發(fā)就能發(fā)，是收費(fèi)的，我們公司是租用的移動(dòng)MAS平臺(tái)的短信發(fā)送接收平臺(tái)，上面那是和一個(gè)和mas同步的一個(gè)小程序，租用別人的mas平臺(tái)是收費(fèi)的，平臺(tái)有很多自己選擇，有發(fā)送接口可以調(diào)，發(fā)送內(nèi)容自己提供
發(fā)送短信的接口
根據(jù)自己的情況選擇服務(wù)商。
開發(fā)文檔
從開發(fā)文檔中我們可以看到. 可以直接使用http請(qǐng)求也可以使用WebService請(qǐng)求發(fā)送短信. 由于DEMO文件夾下的java和jsp文件夾中的代碼都是使用http請(qǐng)求發(fā)送短信. 所以這里就不再細(xì)說了, 我們使用WebService的方式演示發(fā)送短信.
生成客戶端代碼
從接口文檔中我們知道它的WebService的WSDL的url為:?那么我們可以執(zhí)行下面的命令生成客戶端代碼:
wsimport -keep
其中wsimport是JDK自帶的工具, -keep url選項(xiàng)是"保留生成的文件". 該命令會(huì)在當(dāng)前目錄下生成sms.cn.ihuyi._106包, 以及眾多的類. 接下來開始編寫我們自己的代碼.
定義接口
為了方便, 這里我們首先定義一個(gè)接口:
Sms.java
public?interface?Sms?{
/**
*?向mobile發(fā)送短信,?內(nèi)容為message
*?
*?@param?mobile?手機(jī)號(hào)
*?@param?message?短信內(nèi)容
*?@return?成功返回-1,?否則返回其他值
*/
int?sendMessage(String?mobile,?String?message);
}
這個(gè)接口很簡(jiǎn)單, 只有一個(gè)方法. 這個(gè)方法用來發(fā)送短信.
同步發(fā)送短信
接下來我們首先實(shí)現(xiàn)一個(gè)同步發(fā)送短信的類:
IhuyiSmsImpl.java
public?class?IhuyiSmsImpl?implements?Sms?{
private?String?account;
private?String?password;
public?void?setAccount(String?account)?{
this.account?=?account;
}
public?void?setPassword(String?password)?{
this.password?=?password;
}
@Override
public?int?sendMessage(String?mobile,?String?message)?{
cn.ihuyi._106.Sms?factory?=?new?cn.ihuyi._106.Sms();
SmsSoap?smsSoap?=?factory.getSmsSoap();
SubmitResult?submit?=?smsSoap.submit(account,?password,?mobile,?message);
int?code?=?submit.getCode();
if(code?==?2){
return?-1;
}
System.out.println("發(fā)送短信失敗,?code:"?+?code);
return?code;
}
}
異步發(fā)送短信
由于發(fā)送短信涉及到網(wǎng)絡(luò)通信, 因此sendMessage方法可能會(huì)有一些延遲. 為了改善用戶體驗(yàn), 我們可以使用異步發(fā)送短信的方法. 原理很簡(jiǎn)單: 如果用戶請(qǐng)求發(fā)送短信, 我們不是直接調(diào)用IhuyiSmsImpl的sendMessage方法, 而是將請(qǐng)求保存起來(生產(chǎn)者), 然后告訴用戶: 短信發(fā)送成功. 之后有若干個(gè)消費(fèi)者取出任務(wù), 調(diào)用sendMessage方法發(fā)送短信.
這里, 我使用線程池完成上面的任務(wù):
AsyncSmsImpl.java
public?class?AsyncSmsImpl?implements?Sms?{
public?Sms?sendSms;
private?ExecutorService?executorService?=?Executors.newFixedThreadPool(3);
public?void?setSendSms(Sms?sendSms)?{
this.sendSms?=?sendSms;
}
@Override
public?int?sendMessage(String?mobile,?String?message)?{
try?{
executorService.submit(()?-?sendSms.sendMessage(mobile,?message));
}
catch(Exception?e)?{
Sysemt.out.println("提交任務(wù)時(shí)發(fā)生錯(cuò)誤"?+?e);
return?0;
}
return?-1;
}
public?void?destroy(){
try{
executorService.shutdown();
}
catch(Exception?e){}
}
}
在第17行, 我們獲得遠(yuǎn)程對(duì)象的一個(gè)代理對(duì)象. 之后就可以通過這個(gè)代理對(duì)象進(jìn)行發(fā)送短信, 查詢賬戶余額等操作.
第18行, 使用該代理對(duì)象的submit方法提交了短信內(nèi)容. 該方法的參數(shù)信息及返回值含義在接口文檔中有詳細(xì)的說明.
第19行我們獲得了結(jié)果的狀態(tài)碼. 根據(jù)文檔上的說明, 狀態(tài)碼為2說明提交成功. 簡(jiǎn)單起見, 這里我們只關(guān)注提交成功的情況. 需要注意的是, 狀態(tài)碼為2只是說明提交成功. 根據(jù)官網(wǎng)上的"3-5秒內(nèi)響應(yīng)、100%到達(dá)", 我們可以推測(cè). 如果提交成功, 那么基本上3-5秒內(nèi),短信就會(huì)發(fā)送成功, 根據(jù)用戶的網(wǎng)絡(luò)情況, 可能稍有延遲用戶就可以收到短信.
使用這段代碼發(fā)送短信也很簡(jiǎn)單, 直接new一個(gè)對(duì)象, 設(shè)置好賬號(hào)和密碼就可以發(fā)送短信了.
代碼很簡(jiǎn)單, 直接將Sms接口的sendMessage(mobile, message)方法作為一個(gè)任務(wù)加到線程池的任務(wù)隊(duì)列中. 這樣等到有空閑線程時(shí), 就會(huì)執(zhí)行sendSms.sendMessage(mobile, message)發(fā)送短信. 這里我們假設(shè)只要保存到線程池就可以成功發(fā)送短信. 因?yàn)榘l(fā)送失敗的情況實(shí)際上很罕見.
JAVA實(shí)現(xiàn)短信群發(fā)的步驟：
1、使用第三方短信平臺(tái)服務(wù)商，接入短信服務(wù)；
2、調(diào)用短信提交頁面發(fā)送請(qǐng)求；
3、服務(wù)器向第三方短信平臺(tái)提交發(fā)送請(qǐng)求；
4、短信平臺(tái)通過運(yùn)營商將短信下發(fā)至用戶的手機(jī)上。
以下是秒賽短信平臺(tái)JAVA短信驗(yàn)證碼接口代碼示例
package test;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URISyntaxException;
import java.net.URLEncoder;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.lang3.StringUtils;
public class Apis {
// 短信發(fā)送接口的http地址，請(qǐng)咨詢客服
private static String url = “xxxxxxxxxxxxxxxxxxxxxxxxxxxx”;
// 編碼格式。發(fā)送編碼格式統(tǒng)一用UTF-8
private static String ENCODING = “UTF-8”;
public static void main（String[] args） throws IOException, URISyntaxException {
// 賬號(hào)
String account = “************************”;
// 密碼
String pswd = “************************”;
// 修改為您要發(fā)送的手機(jī)號(hào)，多個(gè)用，分割
String mobile = “13*********”;
// 設(shè)置您要發(fā)送的內(nèi)容
String msg = “【秒賽科技】您的驗(yàn)證碼是：1234”;
// 發(fā)短信調(diào)用示例
System.out.println（Apis.send（account,pswd, mobile, msg））；
}
/**
* 發(fā)送短信
*
* @param account
* ? ? ? ? ? ?account
* @param pswd
* ? ? ? ? ? ?pswd
* @param mobile
* ? ? ? ? ? ?手機(jī)號(hào)碼
* @param content
* ? ? ? ? ? ?短信發(fā)送內(nèi)容
*/
public static String send（String account,String pswd, String mobile, String msg） {
NameValuePair[] data = { new NameValuePair（“account”, account），
new NameValuePair（“pswd”, pswd），
new NameValuePair（“mobile”, mobile），
new NameValuePair（“msg”, msg），
new NameValuePair（“needstatus”, “true”），
new NameValuePair（“product”, “”） };
return doPost（url, data）；
}
/**
* 基于HttpClient的post函數(shù)
* PH
* @param url
* ? ? ? ? ? ?提交的URL
*
* @param data
* ? ? ? ? ? ?提交NameValuePair參數(shù)
* @return 提交響應(yīng)
*/
private static String doPost（String url, NameValuePair[] data） {
HttpClient client = new HttpClient（）；
PostMethod method = new PostMethod（url）；
// method.setRequestHeader（“ContentType”,
// “application/x-www-form-urlencoded;charset=UTF-8”）；
method.setRequestBody（data）；
// client.getParams（）。setContentCharset（“UTF-8”）；
client.getParams（）。setConnectionManagerTimeout（10000）；
try {
client.executeMethod（method）；
return method.getResponseBodyAsString（）；
} catch （Exception e） {
e.printStackTrace（）；
}
return null;
}
}
那你要做的就是向這個(gè)URL發(fā)送數(shù)據(jù)就好，給個(gè)例子：
public???class??Httptest1??{
8??
9???????public???static???void??main(String[]?args)??{
10??
11?????????URL?url??=???null?;
12?????????HttpURLConnection?conn??=???null?;
13?????????OutputStream?outStream??=???null?;
14?????????InputStream?inStream??=???null?;
15?????????
16???????????try???{
17?????????????url??=???new??URL(?"??"?);
18?????????????conn??=??(HttpURLConnection)?url.openConnection();
19?????????????conn.setDoOutput(?true?);
20?????????????conn.setDoInput(?true?);
21??
22?????????????String?sendXml??=???"??xml?version=\?"?1.0?\?"??encoding=\?"?UTF?-?16?\?"??!DOCTYPE?SigMailCommand?SYSTEM?\?"?SigMail.dtd\?"?"?;??//?XML數(shù)據(jù)?????
23??????????????sendXml??+=???"?SigMailCommand?Name=\?"?checkuser\?"?Param?Name=\?"?domainname\?"?test.com.cn/Param?"?;
24?????????????sendXml??+=???"?Param?Name=\?"?username\?"?admin/Param/SigMailCommand?"?;
25??
26?????????????outStream??=??conn.getOutputStream();
27??
28??????????????//?準(zhǔn)備通過CONN對(duì)象寫入XML數(shù)據(jù)?
29??????????????BufferedWriter?bw??=???new??BufferedWriter(?new??java.io.OutputStreamWriter(outStream,
30??????????????"?UTF-16?"?));
31?????????????bw.write(sendXml);
32?????????????bw.flush();
33?????????????bw.close();
34?????????????
35??????????????//?DataOutputStream?dataOutStream?=?new?DataOutputStream(outStream);
36??????????????//?dataOutStream.writeChars(xml);
37??????????????//?dataOutStream.flush();
38??????????????//?dataOutStream.close();
39?????????????
40??
41??????????????//?準(zhǔn)備通過CONN對(duì)象讀取返回的XML數(shù)據(jù)?
42??
43?????????????inStream??=??conn.getInputStream();
44?????????????StringBuffer?returnXml??=???new??StringBuffer(?""?);
45?????????????BufferedReader?rd??=???new??BufferedReader(?new??InputStreamReader(inStream,
46??????????????????????"?UTF-16?"?));
47???????????????for??(String?line??=???null?;?(line??=??rd.readLine())??!=???null?;)??{
48?????????????????returnXml.append(line);
49?????????????}?
50?????????????System.out.println(returnXml.toString());
51?????????????rd.close();
52??????????}???catch??(IOException?ex)??{
53?????????????ex.printStackTrace();
54??????????}?finally?{
55???????????????try???{
56??????????????????if??(outStream??!=???null?)
57?????????????????????outStream.close();
58??????????????????if??(inStream??!=???null?)
59?????????????????????inStream.close();
60??????????????????if??(conn??!=???null?)
61?????????????????????conn.disconnect();
62??????????????}???catch??(IOException?e)??{
63??????????????????//??TODO?自動(dòng)生成?catch?塊?
64??????????????????e.printStackTrace();
65?????????????}?
66?????????}?
67??
68?????}?
69??
70?}
重慶分公司
重慶分公司
