package com.xmzs.common.wechat.api;
|
|
import java.io.File;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Random;
|
|
import javax.activation.MimetypesFileTypeMap;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.http.Consts;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.entity.ContentType;
|
import org.apache.http.entity.mime.HttpMultipartMode;
|
import org.apache.http.entity.mime.MultipartEntityBuilder;
|
import org.apache.http.util.EntityUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.xmzs.common.wechat.beans.BaseMsg;
|
import com.xmzs.common.wechat.beans.RecommendInfo;
|
import com.xmzs.common.wechat.core.Core;
|
import com.xmzs.common.wechat.utils.Config;
|
import com.xmzs.common.wechat.utils.MyHttpClient;
|
import com.xmzs.common.wechat.utils.enums.StorageLoginInfoEnum;
|
import com.xmzs.common.wechat.utils.enums.URLEnum;
|
import com.xmzs.common.wechat.utils.enums.VerifyFriendEnum;
|
|
/**
|
* 消息处理类
|
*
|
* @author https://github.com/yaphone
|
* @date 创建时间：2017年4月23日 下午2:30:37
|
* @version 1.0
|
*
|
*/
|
public class MessageTools {
|
private static Logger LOG = LoggerFactory.getLogger(MessageTools.class);
|
private static Core core = Core.getInstance();
|
private static MyHttpClient myHttpClient = core.getMyHttpClient();
|
|
/**
|
* 根据UserName发送文本消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月4日 下午11:17:38
|
* @param msg
|
* @param toUserName
|
*/
|
private static void sendMsg(String text, String toUserName) {
|
if (text == null) {
|
return;
|
}
|
LOG.info(String.format("发送消息 %s: %s", toUserName, text));
|
webWxSendMsg(1, text, toUserName);
|
}
|
|
/**
|
* 根据ID发送文本消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月6日 上午11:45:51
|
* @param text
|
* @param id
|
*/
|
public static void sendMsgById(String text, String id) {
|
if (text == null) {
|
return;
|
}
|
sendMsg(text, id);
|
}
|
|
/**
|
* 根据NickName发送文本消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月4日 下午11:17:38
|
* @param text
|
* @param nickName
|
*/
|
public static boolean sendMsgByNickName(String text, String nickName) {
|
if (nickName != null) {
|
String toUserName = WechatTools.getUserNameByNickName(nickName);
|
if (toUserName != null) {
|
webWxSendMsg(1, text, toUserName);
|
return true;
|
}
|
}
|
return false;
|
|
}
|
|
/**
|
* 消息发送
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年4月23日 下午2:32:02
|
* @param msgType
|
* @param content
|
* @param toUserName
|
*/
|
public static void webWxSendMsg(int msgType, String content, String toUserName) {
|
String url = String.format(URLEnum.WEB_WX_SEND_MSG.getUrl(), core.getLoginInfo().get("url"));
|
Map<String, Object> msgMap = new HashMap<String, Object>();
|
msgMap.put("Type", msgType);
|
msgMap.put("Content", content);
|
msgMap.put("FromUserName", core.getUserName());
|
msgMap.put("ToUserName", toUserName == null ? core.getUserName() : toUserName);
|
msgMap.put("LocalID", new Date().getTime() * 10);
|
msgMap.put("ClientMsgId", new Date().getTime() * 10);
|
Map<String, Object> paramMap = core.getParamMap();
|
paramMap.put("Msg", msgMap);
|
paramMap.put("Scene", 0);
|
try {
|
String paramStr = JSON.toJSONString(paramMap);
|
HttpEntity entity = myHttpClient.doPost(url, paramStr);
|
EntityUtils.toString(entity, Consts.UTF_8);
|
} catch (Exception e) {
|
LOG.error("webWxSendMsg", e);
|
}
|
}
|
|
/**
|
* 上传多媒体文件到 微信服务器，目前应该支持3种类型: 1. pic 直接显示，包含图片，表情 2.video 3.doc 显示为文件，包含PDF等
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月7日 上午12:41:13
|
* @param filePath
|
* @return
|
*/
|
private static JSONObject webWxUploadMedia(String filePath) {
|
File file = new File(filePath);
|
if (!file.exists() && file.isFile()) {
|
LOG.info("file is not exist");
|
return null;
|
}
|
String url = String.format(URLEnum.WEB_WX_UPLOAD_MEDIA.getUrl(), core.getLoginInfo().get("fileUrl"));
|
String mimeType = new MimetypesFileTypeMap().getContentType(file);
|
String mediaType = "";
|
if (mimeType == null) {
|
mimeType = "text/plain";
|
} else {
|
mediaType = mimeType.split("/")[0].equals("image") ? "pic" : "doc";
|
}
|
String lastModifieDate = new SimpleDateFormat("yyyy MM dd HH:mm:ss").format(new Date());
|
long fileSize = file.length();
|
String passTicket = (String) core.getLoginInfo().get("pass_ticket");
|
String clientMediaId = new Date().getTime()
|
+ String.valueOf(new Random().nextLong()).substring(0, 4);
|
String webwxDataTicket = MyHttpClient.getCookie("webwx_data_ticket");
|
if (webwxDataTicket == null) {
|
LOG.error("get cookie webwx_data_ticket error");
|
return null;
|
}
|
|
Map<String, Object> paramMap = core.getParamMap();
|
|
paramMap.put("ClientMediaId", clientMediaId);
|
paramMap.put("TotalLen", fileSize);
|
paramMap.put("StartPos", 0);
|
paramMap.put("DataLen", fileSize);
|
paramMap.put("MediaType", 4);
|
|
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
|
builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
|
|
builder.addTextBody("id", "WU_FILE_0", ContentType.TEXT_PLAIN);
|
builder.addTextBody("name", filePath, ContentType.TEXT_PLAIN);
|
builder.addTextBody("type", mimeType, ContentType.TEXT_PLAIN);
|
builder.addTextBody("lastModifieDate", lastModifieDate, ContentType.TEXT_PLAIN);
|
builder.addTextBody("size", String.valueOf(fileSize), ContentType.TEXT_PLAIN);
|
builder.addTextBody("mediatype", mediaType, ContentType.TEXT_PLAIN);
|
builder.addTextBody("uploadmediarequest", JSON.toJSONString(paramMap), ContentType.TEXT_PLAIN);
|
builder.addTextBody("webwx_data_ticket", webwxDataTicket, ContentType.TEXT_PLAIN);
|
builder.addTextBody("pass_ticket", passTicket, ContentType.TEXT_PLAIN);
|
builder.addBinaryBody("filename", file, ContentType.create(mimeType), filePath);
|
HttpEntity reqEntity = builder.build();
|
HttpEntity entity = myHttpClient.doPostFile(url, reqEntity);
|
if (entity != null) {
|
try {
|
String result = EntityUtils.toString(entity, Consts.UTF_8);
|
return JSON.parseObject(result);
|
} catch (Exception e) {
|
LOG.error("webWxUploadMedia 错误： ", e);
|
}
|
|
}
|
return null;
|
}
|
|
/**
|
* 根据NickName发送图片消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月7日 下午10:32:45
|
* @param nackName
|
* @return
|
*/
|
public static boolean sendPicMsgByNickName(String nickName, String filePath) {
|
String toUserName = WechatTools.getUserNameByNickName(nickName);
|
if (toUserName != null) {
|
return sendPicMsgByUserId(toUserName, filePath);
|
}
|
return false;
|
}
|
|
/**
|
* 根据用户id发送图片消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月7日 下午10:34:24
|
* @param userId
|
* @param filePath
|
* @return
|
*/
|
public static boolean sendPicMsgByUserId(String userId, String filePath) {
|
JSONObject responseObj = webWxUploadMedia(filePath);
|
if (responseObj != null) {
|
String mediaId = responseObj.getString("MediaId");
|
if (mediaId != null) {
|
return webWxSendMsgImg(userId, mediaId);
|
}
|
}
|
return false;
|
}
|
|
/**
|
* 发送图片消息，内部调用
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月7日 下午10:38:55
|
* @return
|
*/
|
private static boolean webWxSendMsgImg(String userId, String mediaId) {
|
String url = String.format("%s/webwxsendmsgimg?fun=async&f=json&pass_ticket=%s", core.getLoginInfo().get("url"),
|
core.getLoginInfo().get("pass_ticket"));
|
Map<String, Object> msgMap = new HashMap<String, Object>();
|
msgMap.put("Type", 3);
|
msgMap.put("MediaId", mediaId);
|
msgMap.put("FromUserName", core.getUserSelf().getString("UserName"));
|
msgMap.put("ToUserName", userId);
|
String clientMsgId = String.valueOf(new Date().getTime())
|
+ String.valueOf(new Random().nextLong()).substring(1, 5);
|
msgMap.put("LocalID", clientMsgId);
|
msgMap.put("ClientMsgId", clientMsgId);
|
Map<String, Object> paramMap = core.getParamMap();
|
paramMap.put("BaseRequest", core.getParamMap().get("BaseRequest"));
|
paramMap.put("Msg", msgMap);
|
String paramStr = JSON.toJSONString(paramMap);
|
HttpEntity entity = myHttpClient.doPost(url, paramStr);
|
if (entity != null) {
|
try {
|
String result = EntityUtils.toString(entity, Consts.UTF_8);
|
return JSON.parseObject(result).getJSONObject("BaseResponse").getInteger("Ret") == 0;
|
} catch (Exception e) {
|
LOG.error("webWxSendMsgImg 错误： ", e);
|
}
|
}
|
return false;
|
|
}
|
|
/**
|
* 根据用户id发送文件
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月7日 下午11:57:36
|
* @param userId
|
* @param filePath
|
* @return
|
*/
|
public static boolean sendFileMsgByUserId(String userId, String filePath) {
|
String title = new File(filePath).getName();
|
Map<String, String> data = new HashMap<String, String>();
|
data.put("appid", Config.API_WXAPPID);
|
data.put("title", title);
|
data.put("totallen", "");
|
data.put("attachid", "");
|
data.put("type", "6"); // APPMSGTYPE_ATTACH
|
data.put("fileext", title.split("\\.")[1]); // 文件后缀
|
JSONObject responseObj = webWxUploadMedia(filePath);
|
if (responseObj != null) {
|
data.put("totallen", responseObj.getString("StartPos"));
|
data.put("attachid", responseObj.getString("MediaId"));
|
} else {
|
LOG.error("sednFileMsgByUserId 错误: ", data);
|
}
|
return webWxSendAppMsg(userId, data);
|
}
|
|
/**
|
* 根据用户昵称发送文件消息
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月10日 下午10:59:27
|
* @param nickName
|
* @param filePath
|
* @return
|
*/
|
public static boolean sendFileMsgByNickName(String nickName, String filePath) {
|
String toUserName = WechatTools.getUserNameByNickName(nickName);
|
if (toUserName != null) {
|
return sendFileMsgByUserId(toUserName, filePath);
|
}
|
return false;
|
}
|
|
/**
|
* 内部调用
|
*
|
* @author https://github.com/yaphone
|
* @date 2017年5月10日 上午12:21:28
|
* @param userId
|
* @param data
|
* @return
|
*/
|
private static boolean webWxSendAppMsg(String userId, Map<String, String> data) {
|
String url = String.format("%s/webwxsendappmsg?fun=async&f=json&pass_ticket=%s", core.getLoginInfo().get("url"),
|
core.getLoginInfo().get("pass_ticket"));
|
String clientMsgId = String.valueOf(new Date().getTime())
|
+ String.valueOf(new Random().nextLong()).substring(1, 5);
|
String content = "<appmsg appid='wxeb7ec651dd0aefa9' sdkver=''><title>" + data.get("title")
|
+ "</title><des></des><action></action><type>6</type><content></content><url></url><lowurl></lowurl>"
|
+ "<appattach><totallen>" + data.get("totallen") + "</totallen><attachid>" + data.get("attachid")
|
+ "</attachid><fileext>" + data.get("fileext") + "</fileext></appattach><extinfo></extinfo></appmsg>";
|
Map<String, Object> msgMap = new HashMap<String, Object>();
|
msgMap.put("Type", data.get("type"));
|
msgMap.put("Content", content);
|
msgMap.put("FromUserName", core.getUserSelf().getString("UserName"));
|
msgMap.put("ToUserName", userId);
|
msgMap.put("LocalID", clientMsgId);
|
msgMap.put("ClientMsgId", clientMsgId);
|
/*
|
* Map<String, Object> paramMap = new HashMap<String, Object>();
|
*
|
* @SuppressWarnings("unchecked") Map<String, Map<String, String>>
|
* baseRequestMap = (Map<String, Map<String, String>>)
|
* core.getLoginInfo() .get("baseRequest"); paramMap.put("BaseRequest",
|
* baseRequestMap.get("BaseRequest"));
|
*/
|
|
Map<String, Object> paramMap = core.getParamMap();
|
paramMap.put("Msg", msgMap);
|
paramMap.put("Scene", 0);
|
String paramStr = JSON.toJSONString(paramMap);
|
HttpEntity entity = myHttpClient.doPost(url, paramStr);
|
if (entity != null) {
|
try {
|
String result = EntityUtils.toString(entity, Consts.UTF_8);
|
return JSON.parseObject(result).getJSONObject("BaseResponse").getInteger("Ret") == 0;
|
} catch (Exception e) {
|
LOG.error("错误: ", e);
|
}
|
}
|
return false;
|
}
|
|
/**
|
* 被动添加好友
|
*
|
* @date 2017年6月29日 下午10:08:43
|
* @param msg
|
* @param accept
|
* true 接受 false 拒绝
|
*/
|
public static void addFriend(BaseMsg msg, boolean accept) {
|
if (!accept) { // 不添加
|
return;
|
}
|
int status = VerifyFriendEnum.ACCEPT.getCode(); // 接受好友请求
|
RecommendInfo recommendInfo = msg.getRecommendInfo();
|
String userName = recommendInfo.getUserName();
|
String ticket = recommendInfo.getTicket();
|
// 更新好友列表
|
// TODO 此处需要更新好友列表
|
// core.getContactList().add(msg.getJSONObject("RecommendInfo"));
|
|
String url = String.format(URLEnum.WEB_WX_VERIFYUSER.getUrl(), core.getLoginInfo().get("url"),
|
String.valueOf(System.currentTimeMillis() / 3158L), core.getLoginInfo().get("pass_ticket"));
|
|
List<Map<String, Object>> verifyUserList = new ArrayList<Map<String, Object>>();
|
Map<String, Object> verifyUser = new HashMap<String, Object>();
|
verifyUser.put("Value", userName);
|
verifyUser.put("VerifyUserTicket", ticket);
|
verifyUserList.add(verifyUser);
|
|
List<Integer> sceneList = new ArrayList<Integer>();
|
sceneList.add(33);
|
|
JSONObject body = new JSONObject();
|
body.put("BaseRequest", core.getParamMap().get("BaseRequest"));
|
body.put("Opcode", status);
|
body.put("VerifyUserListSize", 1);
|
body.put("VerifyUserList", verifyUserList);
|
body.put("VerifyContent", "");
|
body.put("SceneListCount", 1);
|
body.put("SceneList", sceneList);
|
body.put("skey", core.getLoginInfo().get(StorageLoginInfoEnum.skey.getKey()));
|
|
String result = null;
|
try {
|
String paramStr = JSON.toJSONString(body);
|
HttpEntity entity = myHttpClient.doPost(url, paramStr);
|
result = EntityUtils.toString(entity, Consts.UTF_8);
|
} catch (Exception e) {
|
LOG.error("webWxSendMsg", e);
|
}
|
|
if (StringUtils.isBlank(result)) {
|
LOG.error("被动添加好友失败");
|
}
|
|
LOG.debug(result);
|
|
}
|
|
}
|
