Lombok @Builder.Default 之坑
如果一个用了 Lombok， 带了 @Builder的类中，给某个property设置了一个初始值，在编译时会 … Read moreLombok @Builder.Default 之坑
Java
Word 模板动态数据合成
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 |
/* * Copyright (c) 2017 西安才多信息技术有限责任公司。 * 项目名称：dev * 文件名称：DocxTemplateUtils.java * 日期：17-10-11 下午2:18 * 作者：yangyan * */ package com.deyatong.common.util; import org.apache.commons.lang3.StringUtils; import org.apache.poi.xwpf.usermodel.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.*; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; /** * WORD DOCX 文件变量替换输出工具类 */ public class DocxTemplateUtils { Logger logger = LoggerFactory.getLogger(getClass()); /** * 变量替换符号的正则，用来找到 ${xxx} 这样的内容，并实现替换 */ Pattern compile = Pattern.compile("(\\$\\{([^\\}]*)\\})"); private final Map<String, ?> params; //数据填充对象 InputStream is; //读入模板文件的流 XWPFDocument doc; //内存中构建的文档对象 /** * 使用文件路径和变量集合创建 * * @param templateDocxFile * @param params */ public DocxTemplateUtils(String templateDocxFile, Map<String, ?> params) { this.params = params; try { is = new FileInputStream(templateDocxFile); doc = new XWPFDocument(is); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } /** * 使用文件和和变量集合创建 * * @param templateDocxFile * @param params */ public DocxTemplateUtils(File templateDocxFile, Map<String, ?> params) { this.params = params; try { is = new FileInputStream(templateDocxFile); doc = new XWPFDocument(is); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } /** * 使用模板读入的流和变量集合创建 * * @param templateDocxFileInputStream * @param params */ public DocxTemplateUtils(InputStream templateDocxFileInputStream, Map<String, ?> params) { this.params = params; try { is = templateDocxFileInputStream; doc = new XWPFDocument(is); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } /** * 此类为poi操作word模板的工具类 **/ public XWPFDocument getDoc() { return doc; } /** * 替换所有段落中的变量 */ public void replaceInPara() { Iterator<XWPFParagraph> iterator = doc.getParagraphsIterator(); XWPFParagraph para; while (iterator.hasNext()) { para = iterator.next(); this.replaceInPara(para); } } /** * 替换传入段落里面的变量 * * @param para 要替换的段落 */ private void replaceInPara(XWPFParagraph para) { String paragraphText = para.getParagraphText(); int start = paragraphText.indexOf("${"); int end = paragraphText.indexOf("}"); if (start == -1 && end == -1) { //段落中没有变量直接跳过 logger.warn("没开始，没结束，直接跳过：" + paragraphText); return; } boolean isStart = false; boolean isEnd = false; StringBuilder varName = null; List<XWPFRun> runs; Matcher matcher; runs = para.getRuns(); //不同的文字片段可能有不同的样式 logger.info("整段：" + paragraphText); // for (int i = 0; i < runs.size(); i++) { // XWPFRun run = runs.get(i); // String runText = run.toString().trim(); // System.out.println(runText); // } for (int i = 0; i < runs.size(); i++) { XWPFRun run = runs.get(i); String runText = run.toString().trim(); logger.debug(">>>处理文字片段：" + runText); String tail = ""; if (runText.trim().length() == 0) { continue; } if (varName == null) { varName = new StringBuilder(); } int s = runText.indexOf("${"); if (s > -1) { //有开始 int n = runText.indexOf("}", s); if (n != -1) { //有结束 varName.append(runText.substring(s, n + 1)); isEnd = true; if (runText.indexOf("${", n) != -1) { //一行内是否有第二个变量开启 isStart = true; } tail = runText.substring(n + 1); } else { //没结束 isStart = true; isEnd = false; varName.append(runText.substring(s)); run.setText("", 0); } } else { //没开始 if (isStart) { //之前开始了 int n = runText.indexOf("}"); if (n == -1) { //没结束 varName.append(runText); run.setText("", 0); } else { //结束 isStart = false; varName.append(runText.substring(0, n + 1)); if (runText.indexOf("${", n) != -1) { //一行内是否有第二个变量开启 isStart = true; tail = runText.substring(n + 1); } isEnd = true; } } } if (isEnd) { String s1 = varName.toString(); logger.warn("拼接结果：" + s1); Object o = params.get(s1); String value = o == null ? "" : o.toString(); run.setText(value + tail, 0); varName = null; isEnd = false; } // if (s == -1) { //如果没有开始标记后面的就不用执行了 // break; // } //文字替换处理 matcher = compile.matcher(runText); while (matcher.find()) { String group = matcher.group(1); logger.debug("----找到变量：" + group + String.format("，文字片段内位置：(%s-%s)", matcher.start(), matcher.end())); Object o = params.get(group); String replacement = ""; if (o != null) { if (o instanceof List) { //替换的内容 logger.debug("----变量替换成为：" + StringUtils.join(o)); run.setText("", 0); List list = (List) o; for (Object o1 : list) { run.addCarriageReturn(); run.setText(o1.toString()); } break; } else { replacement = o.toString(); //替换的内容 runText = matcher.replaceFirst(replacement); logger.debug("----变量替换成为：" + replacement); run.setText(runText, 0); logger.debug(">>>片段替换成为：" + runText); } } } } } /** * 替换表格里面的变量 */ public void replaceInTable() { Iterator<XWPFTable> iterator = doc.getTablesIterator(); XWPFTable table; List<XWPFTableRow> rows; List<XWPFTableCell> cells; List<XWPFParagraph> paras; while (iterator.hasNext()) { table = iterator.next(); rows = table.getRows(); for (XWPFTableRow row : rows) { cells = row.getTableCells(); for (XWPFTableCell cell : cells) { paras = cell.getParagraphs(); for (XWPFParagraph para : paras) { this.replaceInPara(para); } } } } } /** * 关闭输入流 */ public void closeInputStream() { if (is != null) { try { is.close(); } catch (Exception e) { e.printStackTrace(); } } } /** * 关闭输出流 * * @param os */ public void closeOutputStream(OutputStream os) { if (os != null) { try { os.close(); } catch (Exception e) { e.printStackTrace(); } } } public void addTablesRows(List<List<String>> data, int tableIndex, int rowIndex) { List<XWPFTable> list = doc.getTables(); System.out.println("----" + list.size()); XWPFTable xt = list.get(tableIndex); if (rowIndex < 0 || (rowIndex + 1) > xt.getNumberOfRows()) { rowIndex = xt.getNumberOfRows() - 1; } XWPFTableRow row1 = xt.getRow(rowIndex + 1); if (row1 == null) { row1 = xt.createRow(); addTablesRows(data, tableIndex, rowIndex); return; } for (int i = 0; i < data.size(); i++) { XWPFTableRow row2 = xt.getRow(rowIndex + i); if (row2 == null) { row2 = xt.createRow(); } List<XWPFTableCell> cells = row2.getTableCells(); List<String> clist = data.get(i); for (int k = 0; k < clist.size(); k++) { XWPFTableCell cell = row2.getCell(k); cell.setText(clist.get(k)); } } } } |
根据已知假期列表，计算N个工作日之后是哪一天
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
HolidayVo where = new HolidayVo(); int guessHoliday = 0; for (int i = 0; i < day / 5; i++) { guessHoliday += 2; } Date guessEnd = DateUtils.addDays(date, day + guessHoliday); String startYear = DateFormatUtils.format(date, "yyyy"); String guessEndYear = DateFormatUtils.format(guessEnd, "yyyy"); boolean b = startYear.equalsIgnoreCase( guessEndYear); where.setYear(startYear); List < HolidayVo > allHoliday = null; if (b) { allHoliday = this.getAllHoliday(where); } else { allHoliday = new ArrayList < > (); for (int year = Integer.valueOf(startYear); year >= Integer.valueOf(guessEndYear); year++) { where.setYear(String.valueOf(year)); allHoliday.addAll(this.getAllHoliday(where)); } } Set < String > holidaySet = allHoliday.stream().map(Holiday::getDate).collect(Collectors.toSet()); int passWorkDay = 0; Date testDate = date; while (passWorkDay == day) { testDate = DateUtils.addDays(testDate, 1); if (!holidaySet.contains(DateFormatUtils.format(testDate, "yyyy-MM-dd"))) { passWorkDay++; } } return testDate; |
jmap 导出 java 进程内存状态
例如导出hallSysten线程堆栈信息到文件： [crayon-5d83748216ed0107086603 … Read morejmap 导出 java 进程内存状态
rabbitmq 远程连接
java 程序访问需要注意： 配置文件中NODE_IP_ADDRESS不要给值，就可以允许远程连接了。默认ra … Read morerabbitmq 远程连接
JAVA 获取网卡信息
|
1 2 3 4 5 6 7 8 9 10 11 12 |
Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces(); while (networkInterfaces.hasMoreElements()) { NetworkInterface networkInterface = networkInterfaces.nextElement(); if (networkInterface.isLoopback() || networkInterface.isVirtual()) { continue; } System.out.println(ToStringBuilder.reflectionToString(networkInterface, ToStringStyle.MULTI_LINE_STYLE)); } NetworkInterface en0 = NetworkInterface.getByName("en0"); System.out.println(ToStringBuilder.reflectionToString(en0)); System.out.println(en0.getInterfaceAddresses().get(1).getAddress().getHostAddress()); |
Log4j 使用经验总结
在1.x 版本的 log4j 中，配置rootLogger的日志级别会限制其他logger 的日志级别，其他 … Read moreLog4j 使用经验总结
fastxml 的 jackson helper类，便于json转换
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 |
/* * Copyright (c) 2017 西安才多信息技术有限责任公司。 * 项目名称：dev * 文件名称：JsonObjectUtils.java * 日期：17-6-30 上午8:58 * 作者：yangyan * */ package cn.firegod.common.utils.json; import cn.firegod.codegen.bean.ColumnMeta; import com.fasterxml.jackson.core.JsonGenerationException; import com.fasterxml.jackson.core.JsonParseException; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.DeserializationConfig; import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import java.io.IOException; import java.util.List; import static com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES; public class JsonObjectUtils { public static ObjectMapper m = new ObjectMapper(); static { // 此配置的作用为当使用此工具将json中的属性还原到bean时，如果有bean中没有的属性，是否报错 m.configure(FAIL_ON_UNKNOWN_PROPERTIES, false); } /** * json 转换成 bean * * @param <T> * @param json * @param clazz * @return */ public static <T> T jsonToBean(String json, Class<T> clazz) { if (json == null || clazz == null) { return null; } try { return m.readValue(json, clazz); } catch (JsonParseException e) { e.printStackTrace(); } catch (JsonMappingException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } /** * json node 转换成bean * * @param node * @param clazz * @param <T> * @return */ public static <T> T nodeToBean(JsonNode node, Class<T> clazz) { if (node == null || clazz == null) { return null; } try { return m.treeToValue(node,clazz); } catch (JsonParseException e) { e.printStackTrace(); } catch (JsonMappingException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } /** * bean 转换成 json * * @param bean * @return */ public static String beanToJson(Object bean) { if (bean == null) { return null; } try { return m.writeValueAsString(bean); } catch (JsonGenerationException e) { e.printStackTrace(); } catch (JsonMappingException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } public static JsonNode stringToJsonNode(String jsonString) { if (jsonString == null) { return null; } try { return m.readTree(jsonString); } catch (JsonProcessingException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } public static <T, A extends List<T>> A jsonToList(String jsonString, TypeReference<List<ColumnMeta>> clazz) throws JsonParseException, JsonMappingException, IOException { return (A) m.readValue(jsonString, clazz); } } |
短信发送接口 – SubMail
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 |
public class SubMailSmsSender { private static Logger logger = LoggerFactory.getLogger(SubMailSmsSender.class); private String submailSendUrl; private String submailAppid; private String submailAppkey; public SubMailSmsSender(String submailSendUrl, String submailAppid, String submailAppkey) { this.submailSendUrl = submailSendUrl; this.submailAppid = submailAppid; this.submailAppkey = submailAppkey; } ObjectMapper objectMapper = new ObjectMapper(); /** * SUBMAIL 的短信一对多（即1条API请求发送多个号码，并可以灵活控制每个联系人的文本变量）和群发 API 。调用方需要确保 templateId 正确， smsList 中至少有一条 * * @param templateId 短信模板 * @param multi 批量发送列表json字符串 * @return 返回发送成功的接收方手机号列表 */ public List<String> multixsend(String templateId, String multi) { String info = null; boolean success = false; List<NameValuePair> params = new ArrayList<>(); params.add(new BasicNameValuePair("appid", submailAppid)); params.add(new BasicNameValuePair("project", templateId)); params.add(new BasicNameValuePair("multi", multi)); params.add(new BasicNameValuePair("signature", submailAppkey)); try { List<String> successPhoneList = new ArrayList<>(); HttpResponse post = HttpClientHelper.INSTANCE.post(submailSendUrl, params, "utf-8", null, null); info = EntityUtils.toString(post.getEntity(), "utf-8"); if (logger.isDebugEnabled()) { logger.debug("SUBMAIL 返回：" + info); } JsonNode jsonNode = objectMapper.readTree(info); Iterator<JsonNode> iterator = jsonNode.iterator(); while (iterator.hasNext()) { JsonNode next = iterator.next(); String status = next.get("status").asText(); String to = next.get("to").asText(); if ("success".equals(status)) { successPhoneList.add(to); if (logger.isInfoEnabled()) { logger.info("成功发送短信给[" + to + "]"); } } else { String logContent = "发送短信给[" + to + "]失败"; if (logger.isInfoEnabled()) { logger.error(logContent); } } } return successPhoneList; } catch (IOException e) { logger.error("请求 SubMail 服务器发送短信产生IO 错误", e); return Collections.emptyList(); } } /** * SUBMAIL 的短信一对多（即1条API请求发送多个号码，并可以灵活控制每个联系人的文本变量）和群发 API 。调用方需要确保 templateId 正确， smsList 中至少有一条 * * @param templateId 短信模板 * @param smsList 批量发送列表 * @return 返回发送成功的接收方手机号列表 */ public List<String> multixsend(String templateId, List<SubMailSms> smsList) { if (smsList == null || smsList.isEmpty()) { return Collections.emptyList(); } String multi = null; try { multi = objectMapper.writeValueAsString(smsList); } catch (JsonProcessingException e) { e.printStackTrace(); } return this.multixsend(templateId, multi); } /** * 短信发送信息 */ static class SubMailSms { private String to; private Map<String, String> vars; public String getTo() { return to; } public void setTo(String to) { this.to = to; } public Map<String, String> getVars() { return vars; } public void setVars(Map<String, String> vars) { this.vars = vars; } } } |
前几天，阿里发布了 java 代码规范
写的很不错，是多年的经验之谈，可以帮助 java 开发人员写出更出色的代码。点击下载：阿里官方Java 代码规 … Read more前几天，阿里发布了 java 代码规范
清除文本中的非数字内容
|
1 |
Pattern.compile("[^0-9]").matcher(string).replaceAll("") |
CAS 中央身份验证服务加单点登录和单点退出学习笔记
最近在学习CAS中央认证服务和web项目使用shiro整合，整体来说步骤还是比较多的，至今有一些问题也没有彻底 … Read moreCAS 中央身份验证服务加单点登录和单点退出学习笔记
修改keystore条目的密码
|
1 2 |
keytool -keypasswd --keystore clientkeystore -alias client |
freemarker中页面直接可以使用的内置对象
Request： 用于获取Request对象中的attribute对象。 例如：${Request[̶ … Read morefreemarker中页面直接可以使用的内置对象
java 替换掉emoji表情
今天做搜索功能的时候发现用户提交的emoji的符号上来搜索，导致mysql数据库中的字段like的时候发生字符 … Read morejava 替换掉emoji表情
分页Page对象
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 |
/** * 分页对象，包含页码，每页条数，总条数 User: yangyan Date: 13-11-18 Time: 下午8:59 To change this * template use File | Settings | File Templates. */ public class Page implements Serializable { private static final long serialVersionUID = -784438755770041677L; private int page = 1; private int pageSize = 50; private long total = 0; public int getOffset() { return (page - 1) * pageSize; } public int getStart() { return getOffset(); } public int getLimit() { return getPageSize(); } public int getTotalPage() { return (int) ((total + pageSize) / pageSize); } public Page() { } public Page(int page, int pageSize) { this.page = page; this.pageSize = pageSize; } public int getPage() { return page; } public void setPage(int page) { this.page = page; } public int getPageSize() { return pageSize; } public void setPageSize(int pageSize) { this.pageSize = pageSize; } public long getTotal() { return total; } public void setTotal(long total) { this.total = total; } /** * 另一种形式 */ public static class Offset extends Page { private static final long serialVersionUID = -4518025561523700841L; private int start = 0; private int limit = 50; public Offset() { } public Offset(int start, int limit) { super(1, limit); this.start = start; this.limit = limit; if (start < limit) { setPage(1); } else { setPage((start + limit * 2 - 1) / limit); } } public int getLimit() { return limit; } public int getStart() { return start; } public void setLimit(int limit) { this.limit = limit; if (start < limit) { setPage(1); } else { setPage((start + limit * 2 - 1) / limit); } } public void setStart(int start) { this.start = start; if (start < limit) { setPage(1); } else { setPage((start + limit * 2 - 1) / limit); } } } @Override public String toString() { return "(page:" + this.getPage() + " pageSize:" + this.getPageSize() + ")"; } } |
Jackson 配置
1、json串中有属性为test，但指定转换的指定类中未定义属性A，会抛异常Unrecognized fiel … Read moreJackson 配置
Word 转成HTML
来自CSDN的代码：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 |
import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import org.apache.poi.xwpf.converter.core.FileImageExtractor; import org.apache.poi.xwpf.converter.core.FileURIResolver; import org.apache.poi.xwpf.converter.xhtml.XHTMLConverter; import org.apache.poi.xwpf.converter.xhtml.XHTMLOptions; import org.apache.poi.xwpf.usermodel.XWPFDocument; import org.apache.poi.xwpf.usermodel.XWPFPictureData; import org.junit.Assert; import org.junit.Test; public class word07toHtml { @Test public void canExtractImage() throws IOException { File f = new File("d:/test/test.docx"); if (!f.exists()) { System.out.println("Sorry File does not Exists!"); } else { if (f.getName().endsWith(".docx") || f.getName().endsWith(".DOCX")) { // 1) Load DOCX into XWPFDocument InputStream in = new FileInputStream(f); XWPFDocument document = new XWPFDocument(in); // 2) Prepare XHTML options (here we set the IURIResolver to // load images from a "word/media" folder) File imageFolderFile = new File("d:/test/media"); XHTMLOptions options = XHTMLOptions.create().URIResolver( new FileURIResolver(imageFolderFile)); options.setExtractor(new FileImageExtractor(imageFolderFile)); // 3) Convert XWPFDocument to XHTML OutputStream out = new FileOutputStream(new File( "d:/test/test.htm")); XHTMLConverter.getInstance().convert(document, out, options); } else { System.out.println("Enter only MS Office 2007+ files"); } } } } |
短信发送接口 – www.yuntongxun.com
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 |
public class RonglianPhoneCodeProvider { Logger logger = LoggerFactory.getLogger(this.getClass()); private String sId = ""; //用户id private String appId = ""; //应用id private String token = ""; //用户token private String respUrl = ""; //语音短信结果回调url private boolean sanbox = true; //是否是调试环境 public void setSanbox(boolean sanbox) { this.sanbox = sanbox; } public void setRespUrl(String respUrl) { this.respUrl = respUrl; } public void setsId(String sId) { this.sId = sId; } public void setAppId(String appId) { this.appId = appId; } public void setToken(String token) { this.token = token; } public int sendSmsMsg(String phone, String msgTemplateId, String[] data) { HashMap<String, Object> result = null; CCPRestSDK restAPI = new CCPRestSDK(); if (sanbox) { restAPI.init("sandboxapp.cloopen.com", "8883");// 初始化服务器地址和端口，格式如下，服务器地址不需要写https:// } else { restAPI.init("app.cloopen.com", "8883");// 初始化服务器地址和端口，格式如下，服务器地址不需要写https:// } restAPI.setAccount(sId, token);// 初始化主帐号和主帐号TOKEN restAPI.setAppId(appId);// 初始化应用ID // TODO result = restAPI.sendTemplateSMS(phone, "1", data); if ("000000".equals(result.get("statusCode"))) { //成功 return 1; } else { //异常返回输出错误码和错误信息 String statusCode = result.get("statusCode").toString(); String statusMsg = result.get("statusMsg").toString(); this.onSmsMsgFailed(phone, msgTemplateId, statusCode, statusMsg); return -1; } } public int sendVoiceNumber(String phone, String number) { HashMap<String, Object> result = null; CCPRestSDK restAPI = new CCPRestSDK(); if (sanbox) { restAPI.init("sandboxapp.cloopen.com", "8883");// 初始化服务器地址和端口，格式如下，服务器地址不需要写https:// } else { restAPI.init("app.cloopen.com", "8883");// 初始化服务器地址和端口，格式如下，服务器地址不需要写https:// } restAPI.setAccount(sId, token);// 初始化主帐号和主帐号TOKEN restAPI.setAppId(appId);// 初始化应用ID String times = String.valueOf(3); result = restAPI.voiceVerify(String.valueOf(number), phone, null, times, respUrl, "zh", ""); if ("000000".equals(result.get("statusCode"))) { //成功 return 1; } else { //异常返回输出错误码和错误信息 String statusCode = result.get("statusCode").toString(); String statusMsg = result.get("statusMsg").toString(); this.onVoiceNumberFailed(phone, number, statusCode, statusMsg); return -1; } } public void onSmsMsgFailed(String phone, String msg, String errorCode, String errorMsg) { logger.error("短信【内容】消息[" + phone + "," + msg + "] 发送失败(" + errorCode + ")：" + errorMsg); if (errorCode.equals("111142") || errorCode.equals("111158") || errorCode.equals("160014")) { //欠费了，需要通知管理员缴费 } } public void onVoiceNumberFailed(String phone, String number, String errorCode, String errorMsg) { logger.error("语音【验证码】消息[" + phone + "," + number + "] 发送失败(" + errorCode + ")：" + errorMsg); if (errorCode.equals("111142") || errorCode.equals("111158") || errorCode.equals("160014")) { //欠费了，需要通知管理员缴费 } } } |
短信发送接口-luosimao
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 |
public class LuosimaoPhoneCodeProvider { Logger logger = LoggerFactory.getLogger(this.getClass()); private String smsCodeApiKey; private String voiceCodeApiKey; public void setSmsCodeApiKey(String smsCodeApiKey) { this.smsCodeApiKey = smsCodeApiKey; } public void setVoiceCodeApiKey(String voiceCodeApiKey) { this.voiceCodeApiKey = voiceCodeApiKey; } public int sendSmsMsg(String phone, String msgTemplateId) { // just replace key here Client client = Client.create(); client.addFilter(new HTTPBasicAuthFilter( "api", smsCodeApiKey)); WebResource webResource = client.resource( "http://sms-api.luosimao.com/v1/send.json"); MultivaluedMapImpl formData = new MultivaluedMapImpl(); formData.add("mobile", phone); formData.add("message", msgTemplateId); ClientResponse response = webResource.type(MediaType.APPLICATION_FORM_URLENCODED). post(ClientResponse.class, formData); String textEntity = response.getEntity(String.class); try { JsonNode jsonNode = JsonUtils.nonDefaultMapper().getMapper().readTree(textEntity); if (jsonNode.has("error") && jsonNode.get("error").intValue() == 0) { return 1; } else { if (jsonNode.has("error")) { String error = jsonNode.get("error").asText(); String errorMsg = jsonNode.get("msg").textValue(); onSmsMsgFailed(phone, msgTemplateId, error, errorMsg); } } } catch (Exception e) { // e.printStackTrace(); logger.error("短信【内容】消息[" + phone + "," + msgTemplateId + "] 发送失败,接口返回:" + textEntity, e); } return -1; } public int sendVoiceNumber(String phone, String number) { Client client = Client.create(); client.addFilter(new HTTPBasicAuthFilter( "api", voiceCodeApiKey)); WebResource webResource = client.resource( "http://voice-api.luosimao.com/v1/verify.json"); MultivaluedMapImpl formData = new MultivaluedMapImpl(); formData.add("mobile", phone); formData.add("code", number); ClientResponse response = webResource.type(MediaType.APPLICATION_FORM_URLENCODED). post(ClientResponse.class, formData); String textEntity = response.getEntity(String.class); try { JsonNode jsonNode = JsonUtils.nonDefaultMapper().getMapper().readTree(textEntity); if (jsonNode.has("error") && jsonNode.get("error").intValue() == 0) { return 1; } else { if (jsonNode.has("error")) { String error = jsonNode.get("error").asText(); String errorMsg = jsonNode.get("msg").textValue(); onVoiceNumberFailed(phone, number, error, errorMsg); } } } catch (Exception e) { // e.printStackTrace(); logger.error("语音【验证码】消息[" + phone + "," + number + "] 发送失败，接口返回:" + textEntity, e); } return -1; } public void onSmsMsgFailed(String phone, String msg, String errorCode, String errorMsg) { logger.error("短信【内容】消息[" + phone + "," + msg + "] 发送失败(" + errorCode + ")：" + errorMsg); if (errorCode.equals("-20")) { //欠费了，需要通知管理员缴费 } } public void onVoiceNumberFailed(String phone, String number, String errorCode, String errorMsg) { logger.error("语音【验证码】消息[" + phone + "," + number + "] 发送失败(" + errorCode + ")：" + errorMsg); if (errorCode.equals("-20")) { //欠费了，需要通知管理员缴费 } } /** * 查询第三方短信验证码接口的状态 * * @return */ private String smsApiStatus() { Client client = Client.create(); client.addFilter(new HTTPBasicAuthFilter( "api", smsCodeApiKey)); WebResource webResource = client.resource("http://sms-api.luosimao.com/v1/status.json"); MultivaluedMapImpl formData = new MultivaluedMapImpl(); ClientResponse response = webResource.get(ClientResponse.class); String textEntity = response.getEntity(String.class); int status = response.getStatus(); //System.out.print(status); //System.out.print(textEntity); return textEntity; } /** * 查询第三方语音验证码接口的状态 * * @return */ private String voiceApiStatus() { Client client = Client.create(); client.addFilter(new HTTPBasicAuthFilter( "api", voiceCodeApiKey)); WebResource webResource = client.resource("http://voice-api.luosimao.com/v1/status.json"); MultivaluedMapImpl formData = new MultivaluedMapImpl(); ClientResponse response = webResource.get(ClientResponse.class); String textEntity = response.getEntity(String.class); int status = response.getStatus(); //System.out.print(status); //System.out.print(textEntity); return textEntity; } } |