16 changed files with 782 additions and 1 deletions
Binary file not shown.
@ -1,3 +1,6 @@ |
|||||||
# open-JSD-8144 |
# open-JSD-8144 |
||||||
|
|
||||||
JSD-8144 开源任务材料 |
JSD-8144 开源任务材料\ |
||||||
|
免责说明：该源码为第三方爱好者提供，不保证源码和方案的可靠性，也不提供任何形式的源码教学指导和协助！\ |
||||||
|
仅作为开发者学习参考使用！禁止用于任何商业用途！\ |
||||||
|
为保护开发者隐私，开发者信息已隐去！若原开发者希望公开自己的信息，可联系hugh处理。 |
||||||
@ -0,0 +1,6 @@ |
|||||||
|
ecName=xxxx |
||||||
|
apId=xxx |
||||||
|
secretKey=xxxx |
||||||
|
sign=xxxxx |
||||||
|
addSerial= |
||||||
|
url=http://xxxx/sms/norsubmit |
||||||
Binary file not shown.
@ -0,0 +1,17 @@ |
|||||||
|
<?xml version="1.0" encoding="UTF-8" standalone="no"?> |
||||||
|
<plugin> |
||||||
|
<id>com.fr.plugin.nnsz.sms</id> |
||||||
|
<name><![CDATA[短信对接]]></name> |
||||||
|
<active>yes</active> |
||||||
|
<version>1.3</version> |
||||||
|
<env-version>10.0</env-version> |
||||||
|
<jartime>2018-07-31</jartime> |
||||||
|
<vendor>fr.open</vendor> |
||||||
|
<description><![CDATA[短信对接]]></description> |
||||||
|
<change-notes><![CDATA[]]></change-notes> |
||||||
|
<extra-core> |
||||||
|
<SMSServiceProvider class="com.fr.plugin.nnsz.sms.SmsService"/> |
||||||
|
<DBAccessProvider class="com.fr.plugin.nnsz.sms.SyncDBAccessProvider"/> |
||||||
|
</extra-core> |
||||||
|
<function-recorder class="com.fr.plugin.nnsz.sms.SmsService"/> |
||||||
|
</plugin> |
||||||
@ -0,0 +1,114 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms; |
||||||
|
|
||||||
|
import com.fr.general.PropertiesUtils; |
||||||
|
import com.fr.json.JSONArray; |
||||||
|
import com.fr.json.JSONObject; |
||||||
|
import com.fr.log.FineLoggerFactory; |
||||||
|
import com.fr.plugin.nnsz.sms.action.SmsAction; |
||||||
|
import com.fr.plugin.nnsz.sms.client.SMSClient; |
||||||
|
import com.fr.plugin.nnsz.sms.entity.SmsRecord; |
||||||
|
import com.fr.plugin.transform.FunctionRecorder; |
||||||
|
import com.fr.stable.fun.impl.AbstractSMSServiceProvider; |
||||||
|
|
||||||
|
import java.util.HashMap; |
||||||
|
import java.util.Iterator; |
||||||
|
import java.util.List; |
||||||
|
import java.util.Map; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2020/11/3 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
@FunctionRecorder |
||||||
|
public class SmsService extends AbstractSMSServiceProvider { |
||||||
|
|
||||||
|
private SMSClient smsClient; |
||||||
|
|
||||||
|
private String url; |
||||||
|
|
||||||
|
public SmsService() { |
||||||
|
String ecName = PropertiesUtils.getProperties("conf").getProperty("ecName"); |
||||||
|
FineLoggerFactory.getLogger().info("ecName config is {}", ecName); |
||||||
|
String apid = PropertiesUtils.getProperties("conf").getProperty("apId"); |
||||||
|
FineLoggerFactory.getLogger().info("apId config is {}", apid); |
||||||
|
String secretKey = PropertiesUtils.getProperties("conf").getProperty("secretKey"); |
||||||
|
FineLoggerFactory.getLogger().info("secretKey config is {}", secretKey); |
||||||
|
String sign = PropertiesUtils.getProperties("conf").getProperty("sign"); |
||||||
|
FineLoggerFactory.getLogger().info("sign config is {}", sign); |
||||||
|
String addSerial = PropertiesUtils.getProperties("conf").getProperty("addSerial"); |
||||||
|
FineLoggerFactory.getLogger().info("addSerial config is {}", addSerial); |
||||||
|
url = PropertiesUtils.getProperties("conf").getProperty("url"); |
||||||
|
FineLoggerFactory.getLogger().info("url config is {}", url); |
||||||
|
smsClient = new SMSClient(apid, secretKey, ecName, sign, addSerial, url); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Map<String, String> mapping() { |
||||||
|
Map<String, String> map = new HashMap<>(); |
||||||
|
map.put("10", "【xxxx中心】尊敬的管理员，#taskname#于#time#运行失败，请知晓。"); |
||||||
|
map.put("11", "【xxxx中心】尊敬的#name#，您有一个工单号为：#order_number#的待处理工单，请您及时处理！"); |
||||||
|
map.put("13", "【xxxx中心】您好，#webname#系统内存持续#m#分钟内存高于#n#，可能存在宕机风险，请及时关注。"); |
||||||
|
map.put("14", "【xxxx中心】尊敬的管理员，#taskname#于#time#运行失败，请知晓。"); |
||||||
|
map.put("15", "【xxxx中心】您好，#taskname#于#time#运行成功。"); |
||||||
|
map.put("16", "【xxxx中心】您的手机验证码为#Verifiecode#，请于10分钟内正确输入。"); |
||||||
|
map.put("17", "【xxxx中心】您好，#webname#系统内存持续#m#分钟内存高于#n#，可能存在宕机风险，请及时关注。"); |
||||||
|
map.put("18", "【xxxx中心】恭喜！您的短信服务已经配置成功。"); |
||||||
|
map.put("19", "【xxxx中心】您好，#taskname#于#time#运行成功。"); |
||||||
|
map.put("20", "【xxxx中心】您的手机验证码为#verifiecode#，请于10分钟内正确输入。"); |
||||||
|
map.put("49", "【xxxx中心】您好，#webname#系统日志文件已大于#logsize#M，请及时登录平台进行日志清理。"); |
||||||
|
map.put("50", "【xxxx中心】您好，#webname#系统#clustername#内存持续#m#分钟内存高于#n#，可能存在宕机风险，请及时关注。"); |
||||||
|
map.put("51", "【xxxx中心】你好，#task#出错，请及时处理。该任务开始执行时间：#time#"); |
||||||
|
map.put("53", "【xxxx中心】上报任务 #task#，已经到您这里#time#，请尽快处理！"); |
||||||
|
map.put("63", "【xxxx中心】系统检测到，节点#node_id#的系统时间与其他节点不一致。请配置时间服务器，实现节点时间的自动同步。"); |
||||||
|
map.put("64", "【xxxx中心】节点#node_id#，非正常脱离集群环境。请重启该节点，加入集群。"); |
||||||
|
map.put("89", "【xxxx中心】节点#nodename#，与节点#node1name#的jar包不一致，将影响集群工程的稳定性，请前往集群节点管理页面查看详细异常信息，并及时处理。"); |
||||||
|
map.put("90", "【xxxx中心】节点#nodename#情况异常，用户不能正常访问，请及时检查该节点状态。"); |
||||||
|
map.put("125", "【xxxx中心】您有个#proname#任务即将过期，请您尽快办理。"); |
||||||
|
map.put("127", "【xxxx中心】您有个#proname#任务需要处理，请您尽快办理。发起人：#startpeople#，发起时间：#starttime#。"); |
||||||
|
map.put("134", "【xxxx中心】Redis集群#ip_port#节点已无法正常使用，可能原因为：节点宕机、内存已满、其他异常。为避免影响用户使用，请前往状态服务器配置页面查看详情，并及时处理。"); |
||||||
|
map.put("135", "【xxxx中心】文件服务器出现无法读写的情况，可能原因为：文件服务器宕机、磁盘已满、其他异常。为避免影响用户使用，请及时检查文件服务器状态。"); |
||||||
|
map.put("136", "【xxxx中心】您好，#webname#系统#clustername#当前负载状态过高，可能存在宕机风险，请及时关注。建议使用管理系统-智能运维-云端运维功能分析当前系统存在的性能问题。"); |
||||||
|
map.put("239", "【xxxx中心】您好，预警任务#warningname#达到阈值被触发，请及时关注！模板路径：#templatePath#。"); |
||||||
|
map.put("264", "【xxxx中心】更新任务「#job_name#」结束。任务开始于#year#年#month#月#day#日#hr_min#，累计耗时#c_hr#时#c_min#分#c_sec#秒，完成任务：基础表更新 #success_basetable#/#total_basetable# ，自助数据集更新 #success_dataset#/#total_dataset# ， 关联更新 #success_relation#/#total_relation#。"); |
||||||
|
map.put("265", "【xxxx中心】报表系统已宕机，请访问运维工具关注问题处理状态或及时进行系统重启。"); |
||||||
|
map.put("269", "【xxxx中心】检查到系统环境配置存有不合理项，请及时查看并改正不合理项。"); |
||||||
|
map.put("266", "【xxxx中心】报表系统已宕机，自动重启系统失败，请及时进行手动重启。"); |
||||||
|
map.put("276", "【xxxx中心】你好，[#taskname#]备份失败，请及时处理，备份时间：#time#。"); |
||||||
|
map.put("367", "【xxxx中心】集群节点#node_name#与基准节点存在不一致文件，且无法自动同步。请检查该节点状态。"); |
||||||
|
map.put("368", "【xxxx中心】集群节点#node_name#与基准节点存在不一致文件，已自动同步与基准节点一致，不一致文件备份在该节点工程WEB-INF/#directory#/下。"); |
||||||
|
map.put("998", "【xxxx中心】节点#nodename1#与节点#nodename2#之间通信异常，无法加入节点管理，请检查集群节点间通信端口是否已开放[TCP:7800,7810, 7820,7830, 7840, 7850,7860,7870][UDP:45588～65536 随机端口]。"); |
||||||
|
map.put("999", "【xxxx中心】节点#node_name#的#type#模块存在异常，暂无法正常提供服务，请及时对异常状况进行排查"); |
||||||
|
return map; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Response sendTest(String s) { |
||||||
|
return null; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Response send(String template, String mobile, JSONObject jsonObject, String receiver) throws Exception { |
||||||
|
Iterator<String> it = jsonObject.keys(); |
||||||
|
while (it.hasNext()) { |
||||||
|
String key = it.next(); |
||||||
|
template = template.replace(key, jsonObject.getString(key)); |
||||||
|
} |
||||||
|
String res = smsClient.sendMsg(mobile, template); |
||||||
|
SmsRecord record = new SmsRecord(); |
||||||
|
record.setUrl(url); |
||||||
|
record.setContent(template); |
||||||
|
record.setMobile(mobile); |
||||||
|
record.setResult(res); |
||||||
|
SyncDBAccessProvider.getDbAccessor().runDMLAction(new SmsAction(record)); |
||||||
|
return Response.create(Response.RES_STATUS_SUCCESS, "发送普通短信成功", JSONObject.create()); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Response batchSendSMS(String template, List<String> mobiles, JSONArray params, List<String> receivers) throws Exception { |
||||||
|
for (int i = 0; i < params.size(); i++) { |
||||||
|
send(template, receivers.get(i), params.getJSONObject(i), receivers.get(i)); |
||||||
|
} |
||||||
|
return Response.create(Response.RES_STATUS_SUCCESS, "发送批量短信成功", JSONObject.create()); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,42 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms; |
||||||
|
|
||||||
|
import com.fr.db.fun.impl.AbstractDBAccessProvider; |
||||||
|
import com.fr.plugin.nnsz.sms.dao.SmsRecordDao; |
||||||
|
import com.fr.plugin.nnsz.sms.entity.SmsRecord; |
||||||
|
import com.fr.stable.db.accessor.DBAccessor; |
||||||
|
import com.fr.stable.db.dao.BaseDAO; |
||||||
|
import com.fr.stable.db.dao.DAOProvider; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2020/5/24 |
||||||
|
**/ |
||||||
|
public class SyncDBAccessProvider extends AbstractDBAccessProvider { |
||||||
|
|
||||||
|
private static DBAccessor dbAccessor = null; |
||||||
|
|
||||||
|
public static DBAccessor getDbAccessor() { |
||||||
|
return dbAccessor; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public DAOProvider[] registerDAO() { |
||||||
|
return new DAOProvider[]{ |
||||||
|
new DAOProvider() { |
||||||
|
@Override |
||||||
|
public Class getEntityClass() { |
||||||
|
return SmsRecord.class; |
||||||
|
} |
||||||
|
@Override |
||||||
|
public Class<? extends BaseDAO> getDAOClass() { |
||||||
|
return SmsRecordDao.class; |
||||||
|
} |
||||||
|
} |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void onDBAvailable(DBAccessor dbAccessor) { |
||||||
|
SyncDBAccessProvider.dbAccessor = dbAccessor; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,26 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.action; |
||||||
|
|
||||||
|
import com.fr.plugin.nnsz.sms.dao.SmsRecordDao; |
||||||
|
import com.fr.plugin.nnsz.sms.entity.SmsRecord; |
||||||
|
import com.fr.stable.db.action.DBAction; |
||||||
|
import com.fr.stable.db.dao.DAOContext; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2021/7/9 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
public class SmsAction implements DBAction<SmsRecord> { |
||||||
|
|
||||||
|
private SmsRecord record; |
||||||
|
|
||||||
|
public SmsAction(SmsRecord record) { |
||||||
|
this.record = record; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public SmsRecord run(DAOContext daoContext) throws Exception { |
||||||
|
daoContext.getDAO(SmsRecordDao.class).addOrUpdate(record); |
||||||
|
return record; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,102 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.client; |
||||||
|
|
||||||
|
import com.fr.third.fasterxml.jackson.core.JsonParseException; |
||||||
|
import com.fr.third.fasterxml.jackson.core.JsonProcessingException; |
||||||
|
import com.fr.third.fasterxml.jackson.databind.JsonMappingException; |
||||||
|
import com.fr.third.fasterxml.jackson.databind.ObjectMapper; |
||||||
|
import org.slf4j.Logger; |
||||||
|
import org.slf4j.LoggerFactory; |
||||||
|
|
||||||
|
import java.io.IOException; |
||||||
|
import java.util.Map; |
||||||
|
|
||||||
|
|
||||||
|
/** |
||||||
|
* @author jhy |
||||||
|
* @description json工具 |
||||||
|
*/ |
||||||
|
public class JSONUtils { |
||||||
|
private final static ObjectMapper objectMapper = new ObjectMapper(); |
||||||
|
private static Logger log = LoggerFactory.getLogger(JSONUtils.class); |
||||||
|
|
||||||
|
private JSONUtils() { |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public static ObjectMapper getInstance() { |
||||||
|
|
||||||
|
return objectMapper; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* javaBean,list,array convert to json string |
||||||
|
*/ |
||||||
|
public static String obj2json(Object obj) { |
||||||
|
|
||||||
|
try { |
||||||
|
return objectMapper.writeValueAsString(obj); |
||||||
|
} catch (JsonProcessingException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} |
||||||
|
return null; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* javaBean,list,array convert to json string |
||||||
|
*/ |
||||||
|
public static String obj2jsonInoreString(Object obj) { |
||||||
|
|
||||||
|
try { |
||||||
|
return objectMapper.writeValueAsString(obj); |
||||||
|
} catch (JsonProcessingException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} |
||||||
|
return null; |
||||||
|
} |
||||||
|
/** |
||||||
|
* json string convert to javaBean |
||||||
|
*/ |
||||||
|
public static <T> T json2pojo(String jsonStr, Class<T> clazz) { |
||||||
|
try { |
||||||
|
return objectMapper.readValue(jsonStr, clazz); |
||||||
|
} catch (JsonParseException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} catch (JsonMappingException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} catch (IOException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} |
||||||
|
return null; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* json string convert to map |
||||||
|
*/ |
||||||
|
public static <T> Map<String, Object> json2map(String jsonStr) { |
||||||
|
try { |
||||||
|
return objectMapper.readValue(jsonStr, Map.class); |
||||||
|
} catch (JsonParseException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} catch (JsonMappingException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} catch (IOException e) { |
||||||
|
// TODO Auto-generated catch block
|
||||||
|
log.error(e.getMessage()); |
||||||
|
} |
||||||
|
return null; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* map convert to javaBean |
||||||
|
*/ |
||||||
|
public static <T> T map2pojo(Map map, Class<T> clazz) { |
||||||
|
return objectMapper.convertValue(map, clazz); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,112 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.client; |
||||||
|
|
||||||
|
import org.apache.commons.codec.binary.Base64; |
||||||
|
|
||||||
|
import javax.crypto.Mac; |
||||||
|
import javax.crypto.spec.SecretKeySpec; |
||||||
|
import java.security.MessageDigest; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2021/7/23 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
public class Md5Util { |
||||||
|
static final char hexDigits[] = { '0', '1', '2', '3', '4', '5', '6', '7', |
||||||
|
'8', '9', 'a', 'b', 'c', 'd', 'e', 'f' }; |
||||||
|
|
||||||
|
/** |
||||||
|
* 生成MD5码 |
||||||
|
* |
||||||
|
* @param plainText |
||||||
|
* 要加密的字符串 |
||||||
|
* @return md5值 |
||||||
|
*/ |
||||||
|
public final static String MD5(String plainText) { |
||||||
|
try { |
||||||
|
byte[] strTemp = plainText.getBytes("UTF-8"); |
||||||
|
MessageDigest mdTemp = MessageDigest.getInstance("MD5"); |
||||||
|
mdTemp.update(strTemp); |
||||||
|
byte[] md = mdTemp.digest(); |
||||||
|
int j = md.length; |
||||||
|
char str[] = new char[j * 2]; |
||||||
|
int k = 0; |
||||||
|
for (int i = 0; i < j; i++) { |
||||||
|
byte byte0 = md[i]; |
||||||
|
str[k++] = hexDigits[byte0 >>> 4 & 0xf]; |
||||||
|
str[k++] = hexDigits[byte0 & 0xf]; |
||||||
|
} |
||||||
|
return new String(str); |
||||||
|
} catch (Exception e) { |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 生成MD5码 |
||||||
|
* |
||||||
|
* @param plainText |
||||||
|
* 要加密的字符串 |
||||||
|
* @return md5值 |
||||||
|
*/ |
||||||
|
public final static String MD5(byte[] plainText) { |
||||||
|
try { |
||||||
|
byte[] strTemp = plainText; |
||||||
|
MessageDigest mdTemp = MessageDigest.getInstance("MD5"); |
||||||
|
mdTemp.update(strTemp); |
||||||
|
byte[] md = mdTemp.digest(); |
||||||
|
int j = md.length; |
||||||
|
char str[] = new char[j * 2]; |
||||||
|
int k = 0; |
||||||
|
for (int i = 0; i < j; i++) { |
||||||
|
byte byte0 = md[i]; |
||||||
|
str[k++] = hexDigits[byte0 >>> 4 & 0xf]; |
||||||
|
str[k++] = hexDigits[byte0 & 0xf]; |
||||||
|
} |
||||||
|
return new String(str); |
||||||
|
} catch (Exception e) { |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 先进行HmacSHA1转码再进行Base64编码 |
||||||
|
* @param data 要SHA1的串 |
||||||
|
* @param key 秘钥 |
||||||
|
* @return |
||||||
|
* @throws Exception |
||||||
|
*/ |
||||||
|
public static String HmacSHA1ToBase64(String data, String key) throws Exception { |
||||||
|
SecretKeySpec signingKey = new SecretKeySpec(key.getBytes(), "HmacSHA1"); |
||||||
|
Mac mac = Mac.getInstance("HmacSHA1"); |
||||||
|
mac.init(signingKey); |
||||||
|
byte[] rawHmac = mac.doFinal(data.getBytes()); |
||||||
|
return Base64.encodeBase64String(rawHmac); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 校验MD5码 |
||||||
|
* |
||||||
|
* @param text |
||||||
|
* 要校验的字符串 |
||||||
|
* @param md5 |
||||||
|
* md5值 |
||||||
|
* @return 校验结果 |
||||||
|
*/ |
||||||
|
public static boolean valid(String text, String md5) { |
||||||
|
return md5.equals(MD5(text)) || md5.equals(MD5(text).toUpperCase()); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* |
||||||
|
* @param params |
||||||
|
* @return |
||||||
|
*/ |
||||||
|
public static String MD5(String... params) { |
||||||
|
StringBuilder sb = new StringBuilder(); |
||||||
|
for (String param : params) { |
||||||
|
sb.append(param); |
||||||
|
} |
||||||
|
return MD5(sb.toString()); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,140 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.client; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2021/7/23 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
|
||||||
|
import com.fr.log.FineLoggerFactory; |
||||||
|
import com.fr.third.org.apache.commons.codec.binary.Base64; |
||||||
|
|
||||||
|
import java.io.*; |
||||||
|
import java.net.URL; |
||||||
|
import java.net.URLConnection; |
||||||
|
|
||||||
|
public class SMSClient { |
||||||
|
|
||||||
|
private String apId = "xxx"; |
||||||
|
private String secretKey = "xxxx"; |
||||||
|
private String ecName = "xxxx";//集团名称
|
||||||
|
private String sign = "xxxx";//网关签名编码
|
||||||
|
private String addSerial = "";//拓展码 填空
|
||||||
|
public String msg = "这是发送短信的内容！"; |
||||||
|
public String url = "http://xxxx/sms/norsubmit";//请求url
|
||||||
|
|
||||||
|
public SMSClient() { |
||||||
|
} |
||||||
|
|
||||||
|
public SMSClient(String apId, String secretKey, String ecName, String sign, String addSerial, String url) { |
||||||
|
this.apId = apId; |
||||||
|
this.secretKey = secretKey; |
||||||
|
this.ecName = ecName; |
||||||
|
this.sign = sign; |
||||||
|
this.addSerial = addSerial; |
||||||
|
this.url =url; |
||||||
|
} |
||||||
|
|
||||||
|
public String sendMsg(String mobiles, String content) { |
||||||
|
SendReq sendReq = new SendReq(); |
||||||
|
sendReq.setApId(apId); |
||||||
|
sendReq.setEcName(ecName); |
||||||
|
sendReq.setSecretKey(secretKey); |
||||||
|
sendReq.setContent(content); |
||||||
|
sendReq.setMobiles(mobiles); |
||||||
|
sendReq.setAddSerial(addSerial); |
||||||
|
sendReq.setSign(sign); |
||||||
|
|
||||||
|
StringBuffer stringBuffer = new StringBuffer(); |
||||||
|
stringBuffer.append(sendReq.getEcName()); |
||||||
|
stringBuffer.append(sendReq.getApId()); |
||||||
|
stringBuffer.append(sendReq.getSecretKey()); |
||||||
|
stringBuffer.append(sendReq.getMobiles()); |
||||||
|
stringBuffer.append(sendReq.getContent()); |
||||||
|
stringBuffer.append(sendReq.getSign()); |
||||||
|
stringBuffer.append(sendReq.getAddSerial()); |
||||||
|
|
||||||
|
//FineLoggerFactory.getLogger().info(stringBuffer.toString());
|
||||||
|
sendReq.setMac(Md5Util.MD5(stringBuffer.toString()).toLowerCase()); |
||||||
|
//FineLoggerFactory.getLogger().info(sendReq.getMac());
|
||||||
|
|
||||||
|
String reqText = JSONUtils.obj2json(sendReq); |
||||||
|
String encode = null; |
||||||
|
try { |
||||||
|
encode = Base64.encodeBase64String(reqText.getBytes("UTF-8")); |
||||||
|
} catch (UnsupportedEncodingException e) { |
||||||
|
FineLoggerFactory.getLogger().error(e.getMessage(),e); |
||||||
|
} |
||||||
|
//FineLoggerFactory.getLogger().info(encode);
|
||||||
|
|
||||||
|
String resStr = sendPost(url, encode); |
||||||
|
|
||||||
|
FineLoggerFactory.getLogger().info("send mess res is {}",resStr); |
||||||
|
|
||||||
|
SendRes sendRes = JSONUtils.json2pojo(resStr, SendRes.class); |
||||||
|
|
||||||
|
if (sendRes.isSuccess() && !"".equals(sendRes.getMsgGroup()) && "success".equals(sendRes.getRspcod())) { |
||||||
|
} else { |
||||||
|
} |
||||||
|
return resStr; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* main方法测试发送短信，返回1表示成功，0表示失败 |
||||||
|
*/ |
||||||
|
/*public static void main(String[] args){ |
||||||
|
int result = sendMsg("xxxxxx",msg); |
||||||
|
System.out.println(result); |
||||||
|
}*/ |
||||||
|
|
||||||
|
/** |
||||||
|
* 向指定 URL 发送POST方法的请求 |
||||||
|
* |
||||||
|
* @param url 发送请求的 URL |
||||||
|
* @param param 请求参数 |
||||||
|
* @return 所代表远程资源的响应结果 |
||||||
|
*/ |
||||||
|
private static String sendPost(String url, String param) { |
||||||
|
OutputStreamWriter out = null; |
||||||
|
|
||||||
|
BufferedReader in = null; |
||||||
|
String result = ""; |
||||||
|
try { |
||||||
|
URL realUrl = new URL(url); |
||||||
|
URLConnection conn = realUrl.openConnection(); |
||||||
|
conn.setRequestProperty("accept", "*/*"); |
||||||
|
conn.setRequestProperty("contentType", "utf-8"); |
||||||
|
conn.setRequestProperty("connection", "Keep-Alive"); |
||||||
|
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)"); |
||||||
|
conn.setDoOutput(true); |
||||||
|
conn.setDoInput(true); |
||||||
|
|
||||||
|
out = new OutputStreamWriter(conn.getOutputStream()); |
||||||
|
out.write(param); |
||||||
|
out.flush(); |
||||||
|
|
||||||
|
|
||||||
|
in = new BufferedReader( |
||||||
|
new InputStreamReader(conn.getInputStream())); |
||||||
|
String line; |
||||||
|
while ((line = in.readLine()) != null) { |
||||||
|
result += "\n" + line; |
||||||
|
} |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
} finally { |
||||||
|
try { |
||||||
|
if (out != null) { |
||||||
|
out.close(); |
||||||
|
} |
||||||
|
if (in != null) { |
||||||
|
in.close(); |
||||||
|
} |
||||||
|
} catch (IOException ex) { |
||||||
|
ex.printStackTrace(); |
||||||
|
} |
||||||
|
} |
||||||
|
return result; |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
@ -0,0 +1,81 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.client; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2021/7/23 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
public class SendReq { |
||||||
|
private String ecName;//集团客户名称
|
||||||
|
private String apId;//用户名
|
||||||
|
private String secretKey;//密码
|
||||||
|
private String mobiles;//手机号码逗号分隔。(如“xxxx,xxxxx”)
|
||||||
|
private String content;//发送短信内容
|
||||||
|
private String sign;//网关签名编码，必填，签名编码在中国移动集团开通帐号后分配，可以在xxx网页端管理子系统-SMS接口管理功能中下载。
|
||||||
|
private String addSerial;//扩展码，根据向移动公司申请的通道填写，如果申请的精确匹配通道，则填写空字符串("")，否则添加移动公司允许的扩展码。
|
||||||
|
private String mac;//API输入参数签名结果，签名算法：将ecName，apId，secretKey，mobiles，content ，sign，addSerial按照顺序拼接，然后通过md5(32位小写)计算后得出的值。
|
||||||
|
|
||||||
|
public String getEcName() { |
||||||
|
return ecName; |
||||||
|
} |
||||||
|
|
||||||
|
public void setEcName(String ecName) { |
||||||
|
this.ecName = ecName; |
||||||
|
} |
||||||
|
|
||||||
|
public String getApId() { |
||||||
|
return apId; |
||||||
|
} |
||||||
|
|
||||||
|
public void setApId(String apId) { |
||||||
|
this.apId = apId; |
||||||
|
} |
||||||
|
|
||||||
|
public String getSecretKey() { |
||||||
|
return secretKey; |
||||||
|
} |
||||||
|
|
||||||
|
public void setSecretKey(String secretKey) { |
||||||
|
this.secretKey = secretKey; |
||||||
|
} |
||||||
|
|
||||||
|
public String getMobiles() { |
||||||
|
return mobiles; |
||||||
|
} |
||||||
|
|
||||||
|
public void setMobiles(String mobiles) { |
||||||
|
this.mobiles = mobiles; |
||||||
|
} |
||||||
|
|
||||||
|
public String getContent() { |
||||||
|
return content; |
||||||
|
} |
||||||
|
|
||||||
|
public void setContent(String content) { |
||||||
|
this.content = content; |
||||||
|
} |
||||||
|
|
||||||
|
public String getSign() { |
||||||
|
return sign; |
||||||
|
} |
||||||
|
|
||||||
|
public void setSign(String sign) { |
||||||
|
this.sign = sign; |
||||||
|
} |
||||||
|
|
||||||
|
public String getAddSerial() { |
||||||
|
return addSerial; |
||||||
|
} |
||||||
|
|
||||||
|
public void setAddSerial(String addSerial) { |
||||||
|
this.addSerial = addSerial; |
||||||
|
} |
||||||
|
|
||||||
|
public String getMac() { |
||||||
|
return mac; |
||||||
|
} |
||||||
|
|
||||||
|
public void setMac(String mac) { |
||||||
|
this.mac = mac; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,36 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.client; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2021/7/23 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
public class SendRes { |
||||||
|
private String rspcod;//响应码
|
||||||
|
private String msgGroup;//消息批次号，由xxxx平台生成，用于验证短信提交报告和状态报告的一致性（取值msgGroup）注:如果数据验证不通过msgGroup为空
|
||||||
|
private boolean success; |
||||||
|
|
||||||
|
public String getRspcod() { |
||||||
|
return rspcod; |
||||||
|
} |
||||||
|
|
||||||
|
public void setRspcod(String rspcod) { |
||||||
|
this.rspcod = rspcod; |
||||||
|
} |
||||||
|
|
||||||
|
public String getMsgGroup() { |
||||||
|
return msgGroup; |
||||||
|
} |
||||||
|
|
||||||
|
public void setMsgGroup(String msgGroup) { |
||||||
|
this.msgGroup = msgGroup; |
||||||
|
} |
||||||
|
|
||||||
|
public boolean isSuccess() { |
||||||
|
return success; |
||||||
|
} |
||||||
|
|
||||||
|
public void setSuccess(boolean success) { |
||||||
|
this.success = success; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,21 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.dao; |
||||||
|
|
||||||
|
import com.fr.plugin.nnsz.sms.entity.SmsRecord; |
||||||
|
import com.fr.stable.db.dao.BaseDAO; |
||||||
|
import com.fr.stable.db.session.DAOSession; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2020/11/5 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
public class SmsRecordDao extends BaseDAO<SmsRecord> { |
||||||
|
public SmsRecordDao(DAOSession daoSession) { |
||||||
|
super(daoSession); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
protected Class<SmsRecord> getEntityClass() { |
||||||
|
return SmsRecord.class; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,75 @@ |
|||||||
|
package com.fr.plugin.nnsz.sms.entity; |
||||||
|
|
||||||
|
import com.fr.stable.db.entity.BaseEntity; |
||||||
|
import com.fr.third.javax.persistence.Column; |
||||||
|
import com.fr.third.javax.persistence.Entity; |
||||||
|
import com.fr.third.javax.persistence.Table; |
||||||
|
|
||||||
|
import java.util.Date; |
||||||
|
import java.util.UUID; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author fr.open |
||||||
|
* @Date 2020/11/5 |
||||||
|
* @Description |
||||||
|
**/ |
||||||
|
@Entity |
||||||
|
@Table(name = "plugin_nnsz_sms_record") |
||||||
|
public class SmsRecord extends BaseEntity { |
||||||
|
|
||||||
|
@Column(name = "send_url") |
||||||
|
private String url; |
||||||
|
@Column(name = "mobile") |
||||||
|
private String mobile; |
||||||
|
@Column(name = "content",length = 2000) |
||||||
|
private String content; |
||||||
|
@Column(name = "sendTime") |
||||||
|
private Date sendTime; |
||||||
|
@Column(name = "send_result",length = 2000) |
||||||
|
private String result; |
||||||
|
|
||||||
|
public SmsRecord() { |
||||||
|
this.setId(UUID.randomUUID().toString()); |
||||||
|
this.sendTime = new Date(); |
||||||
|
} |
||||||
|
|
||||||
|
public String getResult() { |
||||||
|
return result; |
||||||
|
} |
||||||
|
|
||||||
|
public void setResult(String result) { |
||||||
|
this.result = result; |
||||||
|
} |
||||||
|
|
||||||
|
public String getUrl() { |
||||||
|
return url; |
||||||
|
} |
||||||
|
|
||||||
|
public void setUrl(String url) { |
||||||
|
this.url = url; |
||||||
|
} |
||||||
|
|
||||||
|
public String getMobile() { |
||||||
|
return mobile; |
||||||
|
} |
||||||
|
|
||||||
|
public void setMobile(String mobile) { |
||||||
|
this.mobile = mobile; |
||||||
|
} |
||||||
|
|
||||||
|
public String getContent() { |
||||||
|
return content; |
||||||
|
} |
||||||
|
|
||||||
|
public void setContent(String content) { |
||||||
|
this.content = content; |
||||||
|
} |
||||||
|
|
||||||
|
public Date getSendTime() { |
||||||
|
return sendTime; |
||||||
|
} |
||||||
|
|
||||||
|
public void setSendTime(Date sendTime) { |
||||||
|
this.sendTime = sendTime; |
||||||
|
} |
||||||
|
} |
||||||
Loading…
Reference in new issue