<!--  每天给项目经理发送短信避免短信服务挂了 定时每天08:30执行--> <job><name>SendToManagerJob</name><job-class>com.xxx.cscns.sms.SendToManagerJob</job-class></job><trigger><cron><name>SendToManagerJob</name><job-name>SendToManagerJob</job-name><cron-expression>0 30 8 * * ?</cron-expression></cron></trigger>

<!-- 实时扫描短信数据表，没有发送的调用运营商给的接口推送，完成发送短信操作 --><job><name>ReceiveMessageJob</name><job-class>com.xxx.cscns.sms.ReceiveMessageJob</job-class></job><trigger><simple><name>ReceiveMessageJob</name><job-name>ReceiveMessageJob</job-name><repeat-count>-1</repeat-count><repeat-interval>1</repeat-interval></simple></trigger>

package com.xxx.cscns.sms;import java.util.Date;
import java.util.List;import org.quartz.DisallowConcurrentExecution;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;import com.xxx.cert.basic.certinfo.inter.ICertInfo;
import com.xxx.core.grammar.Record;
import com.xxx.core.utils.config.ConfigUtil;
import com.xxx.core.utils.container.ContainerFactory;
import com.xxx.core.utils.string.StringUtil;
import com.xxx.cscns.impl.SMSReceiveImpl;
import com.xxx.cscns.service.MessageService;
import com.xxx.cscns.utils.ConstValue;
import com.xxx.database.jdbc.connection.DataSourceConfig;
import com.xxx.frame.service.metadata.code.api.ICodeItemsService;
import com.xxx.frame.service.metadata.code.entity.CodeItems;
import com.esotericsoftware.minlog.Log;
import com.linkage.netmsg.NetMsgclient;
import com.linkage.netmsg.server.ReceiveMsg;/** * 短信接收服务* @author wmqiang* @see [相关类/方法]* @since [产品/模块版本]*/
@DisallowConcurrentExecution
public class ReceiveMessageJob implements Job {
    // 封装的获取运营商的参数，ip，端口，账号和密码private static String ip = ConstValue.QXT_IP;private static int port = Integer.parseInt(ConstValue.QXT_PORT);private static String userName = ConstValue.QXT_USERNAME;private static String pwd = ConstValue.QXT_PWD; //升级系统数据库连接配置信息public static  String sjUrl = ConstValue.sjUrl;public static  String sjUsername =  ConstValue.sjUsername;public static  String sjPassword =  ConstValue.sjPassword; @Overridepublic void execute(JobExecutionContext arg0) throws JobExecutionException {try {try {System.out.println("------------进入短信发送服务-----------\r\n");MessageService messgeService = new MessageService(); MessageService sjmessgeService = new MessageService(sjUrl,sjUsername,sjPassword); NetMsgclient client = new NetMsgclient();ReceiveMsg receiveMsg = new SMSReceiveImpl();client = client.initParameters(ip, port, userName, pwd, receiveMsg);/* 登录认证 */boolean isLogin = client.anthenMsg(client);Log.info("------------receive " + isLogin + " loginsucess------------\r\n"); if (isLogin) {String phone = "";String content = "";String rowguid = "";//获取分表表名，找到数据表就行，不用管ICodeItemsService iCodeItemsService = ContainerFactory.getContainInfo().getComponent(ICodeItemsService.class);List<CodeItems> codeItemsList = iCodeItemsService.listCodeItemsByCodeName("短信分表");if(codeItemsList != null){for(CodeItems codeitem : codeItemsList){//分表表名String tablename = codeitem.getItemText();// 调用方法找出系统数据表中没有发送的短信List<Record> listInfo = messgeService.getSendMessage(tablename);for (Record info : listInfo) {phone = info.get("MessageTarget"); content = info.get("Content");rowguid = info.get("MessageItemGuid");if (StringUtil.isNotBlank(content) && StringUtil.isNotBlank(phone)) {System.out.println(new Date() + "【xxx项目】短信发送服务已发送短信：" + phone + "  内容：" + content + "\r\n");client.sendMsg(client, 0, phone, content, 1);messgeService.updateMessageCenterByRowguid(rowguid,tablename);}} //升级项目短信发送List<Record> SJlistInfo = sjmessgeService.getSendMessage(tablename);for (Record info : SJlistInfo) {phone = info.get("MessageTarget"); content = info.get("Content");rowguid = info.get("MessageItemGuid");if (StringUtil.isNotBlank(content) && StringUtil.isNotBlank(phone)) { client.sendMsg(client, 0, phone, content, 1);sjmessgeService.updateMessageCenterByRowguid(rowguid,tablename);System.out.println(new Date() + "【升级项目】短信发送服务已发送短信：" + phone + "  内容：" + content + "\r\n");}} }} client.closeConn();Thread.sleep(5000);}} catch (Exception e1) {e1.printStackTrace();} finally {}} catch (Exception e) {e.printStackTrace();}}
}

public class MessageService {
/*** 找出未发送短信* @return* @exception/throws [违例类型] [违例说明]* @see [类、类#方法、类#成员]*/public List<Record> getSendMessage(String tablename) {List<Record> list = new ArrayList<>();
// 获取到短信表中需要发送短信的信息即可
/*String strSql = "SELECT  *  FROM Messages_Center WHERE SendMode=1 and ((IsSchedule=1 and ScheduleSendDate< NOW() ) or ( IsSchedule=0) ) ";*/String strSql = "SELECT  *  FROM "+tablename+" WHERE SendMode=1 and ((IsSchedule=1 and ScheduleSendDate< NOW() )"+ " or ( IsSchedule=0) ) "+ " and GENERATEDATE >= (select date_sub(now(), interval 2 hour)) "; try {list = dao.findList(strSql, Record.class);} catch (Exception e) {e.printStackTrace();} finally {if (dao != null){dao.close();} }return list;}}

package com.xxx.cscns.sms;import org.quartz.DisallowConcurrentExecution;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;import com.xxx.core.xxxFrameDsManager;
import com.xxx.cscns.service.MessageService;@DisallowConcurrentExecution
public class SendToManagerJob implements Job{@Overridepublic void execute(JobExecutionContext arg0) throws JobExecutionException { try {xxxFrameDsManager.begin(null);MessageService messageService  = new MessageService(); // 调用业务逻辑实施层方法，实现发短信操作messageService.sendToManger();System.out.println("上班前半小时发送一次短信给项目经理成功！");}catch (Exception e) {xxxFrameDsManager.rollback();e.printStackTrace(); System.out.println("上班前半小时发送一次短信给项目经理异常："+e.toString());}finally {xxxFrameDsManager.close();}}
}

 　　/** * 每天给项目经理发送短信避免短信服务挂了 */public void sendToManger() { try {//系统参数配置项目经理手机号码,这儿是封装的方法，只要能获取到项目经理手机号就行String messageTarget = new FrameConfigService9().getFrameConfigValue("ASP_MESSAGE_TEST_TEL");//时间格式化SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String sql = "insert into Messages_center ( MessageItemGuid, Content, GenerateDate, IsSchedule,  MessageTarget,  sendMode,messagetype)";sql += "values( '" + UUID.randomUUID().toString() + "', '【XXX项目】短信服务正常。', to_date('" + sdf2.format(new Date())+ "', 'yyyy-mm-dd hh24:mi:ss'), 0, '" + messageTarget + "', 1,'短信')";if(StringUtil.isNotBlank(messageTarget)){dao.execute(sql);  } }catch (Exception e) {e.printStackTrace();dao.rollBackTransaction();}finally {if (dao != null){dao.close(); } }}