package com.ruoyi.common.utils;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.json.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
|
import me.chanjar.weixin.cp.api.impl.WxCpServiceImpl;
|
import me.chanjar.weixin.cp.bean.message.WxCpMessage;
|
import me.chanjar.weixin.cp.bean.message.WxCpMessageSendResult;
|
import me.chanjar.weixin.cp.config.impl.WxCpDefaultConfigImpl;
|
|
import java.io.*;
|
import java.net.MalformedURLException;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
import java.util.Base64;
|
import java.util.List;
|
|
/**
|
* @Author: chenxiangfeng
|
* @Date: 2021/7/20 10:35
|
*/
|
public class WxCpUtils {
|
|
public static final String CORP_ID = "wwa423654b975441ac";
|
public static final String CORP_SECRET = "snXq8qwA5tGu0YN1PlSDQqr6u9x3A0c_jQDmt8CN8Vs";
|
public static final Integer AGENT_ID = 1000515;
|
|
/**
|
* @param user 例：ZT-033268|ZT-028629，多个中间用|隔开
|
* @param content 传文本内容
|
* @param imageFile 图片
|
* @throws Exception
|
*/
|
public static void inform(String user, String content, File imageFile) throws Exception {
|
return;
|
// WxCpDefaultConfigImpl config = new WxCpDefaultConfigImpl();
|
// // 注册的企业信息
|
// config.setCorpId(CORP_ID);
|
// config.setCorpSecret(CORP_SECRET);
|
//
|
// WxCpServiceImpl wxCpService = new WxCpServiceImpl();
|
// wxCpService.setWxCpConfigStorage(config);
|
//
|
// WxCpMessage message;
|
// WxCpMessageSendResult result;
|
// // 发送文本
|
// if (StringUtils.isNotBlank(content)) {
|
// message = WxCpMessage.TEXT()
|
// .content(content)
|
// // 用户id
|
// .toUser(user)
|
// // 应用id
|
// .agentId(AGENT_ID)
|
// .build();
|
// result = wxCpService.getMessageService().send(message);
|
// }
|
// // 发送文件
|
// if (imageFile != null) {
|
// // 获取文件id
|
// WxMediaUploadResult imgResult = wxCpService.getMediaService().upload("file", imageFile);
|
// message = WxCpMessage.IMAGE()
|
// .mediaId(imgResult.getMediaId())
|
// // 用户id
|
// .toUser(user)
|
// // 应用id
|
// .agentId(AGENT_ID)
|
// .build();
|
// result = wxCpService.getMessageService().send(message);
|
// }
|
}
|
|
/**
|
* 推送群消息
|
*
|
* @param webHookList 企业微信机器人地址
|
* @param file 图片
|
* @throws Exception
|
*/
|
public static void informWebHook(List<String> webHookList, File file) throws Exception {
|
return;
|
// JSONObject json = new JSONObject();
|
// json.putOpt("msgtype", "image");
|
// JSONObject image = new JSONObject();
|
// image.putOpt("base64", getBase64(file));
|
// image.putOpt("md5", getMd5(file));
|
// json.putOpt("image", image);
|
//
|
// webHookList.stream().forEach(webHook -> {
|
// String result = HttpRequest.post(webHook)
|
// .header("Content-Type", "application/json")
|
// .body(json.toString())
|
// .execute().body();
|
// });
|
}
|
|
/**
|
* 推送群消息
|
*
|
* @param webHook 企业微信机器人地址
|
* @param content 数据
|
* @throws Exception
|
*/
|
public static String informWebHook(String webHook, String content) {
|
return "";
|
// return informWebHook(webHook, content,"text");
|
}
|
|
/**
|
* 推送群消息
|
*
|
* @param webHook 企业微信机器人地址
|
* @param content 数据
|
* @param msgType 消息类型
|
* @throws Exception
|
*/
|
public static String informWebHook(String webHook, String content,String msgType) {
|
return "";
|
// JSONObject jsonObject = new JSONObject()
|
// .accumulate("msgtype", msgType)
|
// .accumulate(msgType, new JSONObject()
|
// .accumulate("content", content));
|
// return HttpRequest.post(webHook).header("Content-Type", "application/json").body(jsonObject.toString()).execute().body();
|
}
|
|
public static String getMd5(File file) {
|
String name = "";
|
try {
|
InputStream inputStream = new BufferedInputStream(new FileInputStream(file));
|
byte[] bytes = new byte[1024];
|
int len = 0;
|
MessageDigest messagedigest = MessageDigest.getInstance("MD5");
|
while ((len = inputStream.read(bytes)) > 0) {
|
messagedigest.update(bytes, 0, len);
|
}
|
name = Md5Util.bufferToHex(messagedigest.digest());
|
inputStream.close();
|
} catch (MalformedURLException e) {
|
} catch (IOException e) {
|
} catch (NoSuchAlgorithmException e) {
|
}
|
return name;
|
|
}
|
|
public static String getBase64(File file) {
|
FileInputStream inputStream = null;
|
String base64Str = "";
|
try {
|
inputStream = new FileInputStream(file);
|
Base64.Encoder encoder = Base64.getEncoder();
|
int available = inputStream.available();
|
byte[] bytes = new byte[available];
|
inputStream.read(bytes);
|
base64Str = encoder.encodeToString(bytes);
|
inputStream.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
inputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return base64Str;
|
}
|
|
}
|
