Java – 平凡之火

Word 模板动态数据合成

2019-01-012018-06-05 by wind

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

* 项目名称：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个工作日之后是哪一天

2019-01-012018-05-24 by wind

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 进程内存状态

2019-01-012018-03-27 by wind

例如导出hallSysten线程堆栈信息到文件： [crayon-5d32112a32ffe350045813 … Read morejmap 导出 java 进程内存状态

rabbitmq 远程连接

2019-01-012017-12-30 by wind

java 程序访问需要注意：配置文件中NODE_IP_ADDRESS不要给值，就可以允许远程连接了。默认ra … Read morerabbitmq 远程连接

JAVA 获取网卡信息

2019-01-012017-07-30 by wind

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 使用经验总结

2019-01-012017-07-20 by wind

在1.x 版本的 log4j 中，配置rootLogger的日志级别会限制其他logger 的日志级别，其他 … Read moreLog4j 使用经验总结

fastxml 的 jackson helper类，便于json转换

2019-01-012017-06-30 by wind

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

* 项目名称：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

2019-01-012017-02-15 by wind

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();

}

/**

* @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 代码规范

2019-01-012017-02-11 by wind

写的很不错，是多年的经验之谈，可以帮助 java 开发人员写出更出色的代码。点击下载：阿里官方Java 代码规 … Read more前几天，阿里发布了 java 代码规范

清除文本中的非数字内容

2019-01-012017-01-24 by wind

1	Pattern.compile("[^0-9]").matcher(string).replaceAll("")

CAS 中央身份验证服务加单点登录和单点退出学习笔记

2019-01-012016-10-10 by wind

最近在学习CAS中央认证服务和web项目使用shiro整合，整体来说步骤还是比较多的，至今有一些问题也没有彻底 … Read moreCAS 中央身份验证服务加单点登录和单点退出学习笔记

修改keystore条目的密码

2019-01-012016-09-20 by wind

1 2	keytool -keypasswd --keystore clientkeystore -alias client

freemarker中页面直接可以使用的内置对象

2019-01-012016-08-31 by wind

Request：用于获取Request对象中的attribute对象。例如：${Request[&#822 … Read morefreemarker中页面直接可以使用的内置对象

java 替换掉emoji表情

2019-01-012016-08-31 by wind

今天做搜索功能的时候发现用户提交的emoji的符号上来搜索，导致mysql数据库中的字段like的时候发生字符 … Read morejava 替换掉emoji表情

分页Page对象

2019-01-012016-05-26 by wind

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 配置

2019-01-012016-03-31 by wind

1、json串中有属性为test，但指定转换的指定类中未定义属性A，会抛异常Unrecognized fiel … Read moreJackson 配置

Word 转成HTML

2019-01-012015-12-02 by wind

来自CSDN的代码：

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

2019-01-012015-10-21 by wind

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

2019-01-012015-10-21 by wind

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;

}

查询手机归属地接口

2019-01-012015-10-21 by wind

@Test

public void testGetProvince() {

String phoneNumber = "18629020328";

String url = "http://apis.baidu.com/apistore/mobilephoneservice/mobilephone?apikey=6e825bd531b8b1839fc1cda66b19edb9&tel="+phoneNumber;

try {

HttpResponse resp = HttpClientHelper.INSTANCE.get(url, null, new Header[]{new BasicHeader("apikey", "6e825bd531b8b1839fc1cda66b19edb9")});

String s = EntityUtils.toString(resp.getEntity(), "UTF-8");

System.out.println(s);

JsonNode jsonNode = JsonObjectUtils.stringToJsonNode(s);

if (jsonNode.get("retMsg").getTextValue().equals("success")) {

System.out.println(jsonNode.get("retData").get("supplier").getTextValue());

System.out.println(jsonNode.get("retData").get("province").getTextValue());

System.out.println(jsonNode.get("retData").get("city").getTextValue());

System.out.println(jsonNode.get("retData").get("suit").getTextValue());

}

} catch (IOException e) {

e.printStackTrace();

}