AI 助理
备案控制台
开发者社区 数据库 文章 正文

微信通知

2025-12-30 4
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 基于企业微信与小程序集成，通过API获取access_token并发送消息。需配置corpid、secret及小程序信息，异步查询通讯录并推送订单提醒至指定医生，支持动态参数替换与日志记录，确保高效安全的消息触达。

1.前置条件
● 企业微信appId
● 企业微信secret
● 企业微信绑定小程序
● 小程序的appId
2.发送示例
2.1 获取access_token(HTTPS-GET)

请求URL：
https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=corpid&corpsecret=corpsecret

示例入参：
corpid=wx161we55e1fe5e4fr
corpsecret=Rspav9pmjem3zve8fkjqe6yTtCs78Rwdabn6tNdU1g

public class AccessToken {
// 获取到的凭证
private String token;
// 凭证有效时间，单位：秒
private int expiresIn;

public String getToken() {
    return token;
}

public void setToken(String token) {
    this.token = token;
}

public int getExpiresIn() {
    return expiresIn;
}

public void setExpiresIn(int expiresIn) {
    this.expiresIn = expiresIn;
}

}
// url就是上述的，完整如下：
// https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=wx161we55e1fe5e4fr&corpsecret=Rspav9pmjem3zve8fkjqe6yTtCs78Rwdabn6tNdU1g
public static AccessToken getAccessToken(String url) {
logger.info("[WeixinUtil.getAccessToken]:start getAccessToken,url:" + url);
AccessToken accessToken = null;
JSONObject jsonObject = httpRequest(url, "GET", null);
if (jsonObject != null) {
try {
accessToken = new AccessToken();
accessToken.setToken(jsonObject.getString("access_token"));
accessToken.setExpiresIn(jsonObject.getInteger("expires_in"));
} catch (JSONException e) {
accessToken = null;
logger.error("[WeixinUtil.getAccessToken]:getAccessToken occured an JSONException,errcode:"

                     + jsonObject.getInteger("errcode") + ",errmsg:" + jsonObject.getString("errmsg") + ",JSONException:" + e);
    }
}
logger.info("[WeixinUtil.getAccessToken]:end getAccessToken.");
return accessToken;

}

2.2 发送
logger.info("发送企业号获取Token结束：" + accessTokenUrl + "，accessToken：" + JSONObject.toJSONString(accessToken));
// 查询通讯录分组，分组ID：在线咨询医生
String getDeptUserUrl = null;
if(10000 == hospitalId) {
getDeptUserUrl = WechatUtil.QY_GET_DEPT_USER_URL_XMHA.replace("ACCESS_TOKEN", accessToken.getToken())
.replace("DEPARTMENT_ID", "123").replace("FETCH_CHILD", "1");
} else if(10001 == hospitalId) {
getDeptUserUrl = WechatUtil.QY_GET_DEPT_USER_URL_XMHA.replace("ACCESS_TOKEN", accessToken.getToken())
.replace("DEPARTMENT_ID", "124").replace("FETCH_CHILD", "1");
}

JSONObject hResponse = WechatUtil.httpRequest(getDeptUserUrl, "GET", null);
if (null == hResponse) {
logger.info("未能成功获取到通讯录");
return;
}
String docNo = getDoctorNo(doctorNo);
WXQYUser toWXQYUser = null;
List wXQYUserList = getWXQYUserList(hResponse);
for (WXQYUser wxQYUser : wXQYUserList) {
if (docNo.equals(wxQYUser.getHisid())) {
// 发消息
toWXQYUser = wxQYUser;
break;
}
}

if (null != toWXQYUser) {
String toUserId = toWXQYUser.getUserid();
String time = DateUtil.formatDate("MM-dd HH:mm", new Date());
String descTime = time.split(" ")[0].substring(0, 2) + "月" +
time.split(" ")[0].substring(3) + "日 " +
time.split(" ")[1];

String appIdForMiniProgram = imSystemConfigService.getImSystemConfig(hospitalId, HUUtil.APP_ID_FOR_MINI_PROGRAM);

String jsonParam = "{\"touser\": \"" + toUserId + "\",\"toparty\":\"\",\"totag\":\"\",\"msgtype\":\"miniprogram_notice\",\"miniprogram_notice\":" +
    "{\"appid\":\"" +appIdForMiniProgram +  "\",\"page\":\"pages/index/chat/trade-start/trade-start?orderNo=" + orderNo +"\"," +
    "\"title\":\"新订单接诊提醒\",\"description\": \"" + descTime + "\",\"emphasis_first_item\":true," +
    "\"content_item\":[{\"key\":\"接诊通知\",\"value\":\"来新咨询订单了\"},{\"key\":\"咨询人\",\"value\":\""+subTitle+"\"},{\"key\":\"病情描述\",\"value\":\""+content+"\"}]},\"enable_id_trans\":0," +
    "\"enable_duplicate_check\":0,\"duplicate_check_interval\":1800}";

logger.info("开始发送微信企业号消息，入参：" + jsonParam);

String imsServiceDomainConfigStr = imSystemConfigService.getImSystemConfig(hospitalId,
                                                                           HUUtil.IMS_SERVICE_WECHAT_QYH_TEMPLATE_DOMAIN_CONFIG_KEY);
if (null == imsServiceDomainConfigStr || "".equals(imsServiceDomainConfigStr)) {
    logger.info("IMS发送微信企业号消息服务地址配置信息不存在：" + hospitalId);
    return;
}

imsServiceDomainConfigStr = imsServiceDomainConfigStr + "?access_token=" + accessToken.getToken();
String result = HUHttpUtil.sendJsonPostRequest(imsServiceDomainConfigStr, jsonParam, 0);
logger.info("开始发送微信企业号消息，结果：" + result);

} else {
logger.info("该医生" + doctorNo + "在企业号通讯录中不存在，终止发送企业号消息");
}
完整代码示例(建议异步)
private static final ThreadLocal synExecuteService = ThreadLocal.withInitial(() -> Executors.newFixedThreadPool(200));

private final static String QY_ACCESS_TOKEN_URL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=CORPID&corpsecret=SECRET";

private final static String QY_GET_DEPT_USER_URL = "https://qyapi.weixin.qq.com/cgi-bin/user/list?access_token=ACCESS_TOKEN&department_id=DEPARTMENT_ID&fetch_child=FETCH_CHILD";

public void sendOpenWxMsg(final String doctorNo, final String title, final String subTitle, final String content, final String toUrl,
final String orderNo, final long hospitalId) {
synExecuteService.submit(() -> {
String appIdAppSecretConfigStr = imSystemConfigService.getImSystemConfig(hospitalId, HUUtil.WEIXIN_QY_APPID_SECRET_CONFIG_FOR_MINI_PROGRAM);
if (null == appIdAppSecretConfigStr || "".equals(appIdAppSecretConfigStr)) {
logger.info("未查询到APPID信息：" + hospitalId + "，KEY：" + HUUtil.WEIXIN_QY_APPID_SECRET_CONFIG);
return;
}
String accessTokenUrl = WechatUtil.QY_ACCESS_TOKEN_URL_XMHA.replace("CORPID", appIdAppSecretConfigStr.split("=")[0])
.replace("SECRET", appIdAppSecretConfigStr.split("=")[1]);
AccessToken accessToken = WechatUtil.getAccessToken(accessTokenUrl);
if (null == accessToken) {
logger.info("未能成功获取到AccessToken");
return;
}

    logger.info("发送企业号获取Token结束：" + accessTokenUrl + "，accessToken：" + JSONObject.toJSONString(accessToken));
    // 查询通讯录分组，分组ID：在线咨询医生
    String getDeptUserUrl = null;
    // 不同医院部门编号不一样，对应部门编号在企业微信查看
    if(10000 == hospitalId) {
        getDeptUserUrl = WechatUtil.QY_GET_DEPT_USER_URL_XMHA.replace("ACCESS_TOKEN", accessToken.getToken())
            .replace("DEPARTMENT_ID", "123").replace("FETCH_CHILD", "1");
    } else if(10001 == hospitalId) {
        getDeptUserUrl = WechatUtil.QY_GET_DEPT_USER_URL_XMHA.replace("ACCESS_TOKEN", accessToken.getToken())
            .replace("DEPARTMENT_ID", "124").replace("FETCH_CHILD", "1");
    }

    JSONObject hResponse = WechatUtil.httpRequest(getDeptUserUrl, "GET", null);
    if (null == hResponse) {
        logger.info("未能成功获取到通讯录");
        return;
    }
    String docNo = getDoctorNo(doctorNo);
    WXQYUser toWXQYUser = null;
    List<WXQYUser> wXQYUserList = getWXQYUserList(hResponse);
    for (WXQYUser wxQYUser : wXQYUserList) {
        if (docNo.equals(wxQYUser.getHisid())) {
            // 发消息
            toWXQYUser = wxQYUser;
            break;
        }
    }

    if (null != toWXQYUser) {
        String toUserId = toWXQYUser.getUserid();
        String time = DateUtil.formatDate("MM-dd HH:mm", new Date());
        String descTime = time.split(" ")[0].substring(0, 2) + "月" +
            time.split(" ")[0].substring(3) + "日  " +
            time.split(" ")[1];

        String appIdForMiniProgram = imSystemConfigService.getImSystemConfig(hospitalId, HUUtil.APP_ID_FOR_MINI_PROGRAM);

        String jsonParam = "{\"touser\": \"" + toUserId + "\",\"toparty\":\"\",\"totag\":\"\",\"msgtype\":\"miniprogram_notice\",\"miniprogram_notice\":" +
            "{\"appid\":\"" +appIdForMiniProgram +  "\",\"page\":\"pages/index/chat/trade-start/trade-start?orderNo=" + orderNo +"\"," +
            "\"title\":\"新订单接诊提醒\",\"description\": \"" + descTime + "\",\"emphasis_first_item\":true," +
            "\"content_item\":[{\"key\":\"接诊通知\",\"value\":\"来新咨询订单了\"},{\"key\":\"咨询人\",\"value\":\""+subTitle+"\"},{\"key\":\"病情描述\",\"value\":\""+content+"\"}]},\"enable_id_trans\":0," +
            "\"enable_duplicate_check\":0,\"duplicate_check_interval\":1800}";

        logger.info("开始发送微信企业号消息，入参：" + jsonParam);
        // 微信企业号消息发送服务地址 http://ip:port/mp-api/wechat/enterprise/message/send
        String imsServiceDomainConfigStr = imSystemConfigService.getImSystemConfig(hospitalId, HUUtil.IMS_SERVICE_WECHAT_QYH_TEMPLATE_DOMAIN_CONFIG_KEY);
        if (null == imsServiceDomainConfigStr || "".equals(imsServiceDomainConfigStr)) {
            logger.info("IMS发送微信企业号消息服务地址配置信息不存在：" + hospitalId);
            return;
        }

        imsServiceDomainConfigStr = imsServiceDomainConfigStr + "?access_token=" + accessToken.getToken();
        String result = HUHttpUtil.sendJsonPostRequest(imsServiceDomainConfigStr, jsonParam, 0);
        logger.info("开始发送微信企业号消息，结果：" + result);
    } else {
        logger.info("该医生" + doctorNo + "在企业号通讯录中不存在，终止发送企业号消息");
    }
});

}

/**

 * 发送GET请求
 *
 * @param requestUrl
 * @param requestMethod
 * @param outputStr
 * @return
 */

public static JSONObject httpRequest(String requestUrl, String requestMethod, String outputStr) {
logger.info("[WeixinUtil.httpRequest]：请求入参：" + requestUrl);
String respStr = HUHttpUtil.sendGet(requestUrl, null);
logger.info("[WeixinUtil.httpRequest]：请求响应：" + respStr);
try {
return JSON.parseObject(respStr);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}

private List getWXQYUserList(JSONObject hResponse) {
List wXQYUserList = (List) hResponse.get("userlist");
List nmList = null;
WXQYUser wxQYUser = null;
JSONObject mm = null;
List wxQYUserList = new ArrayList();
for (JSONObject jsObject : wXQYUserList) {
if (jsObject.containsKey("userid")) {
if (jsObject.containsKey("extattr")) {
mm = jsObject.getJSONObject("extattr");
if (null != mm.get("attrs")) {
nmList = (List) mm.get("attrs");
for (JSONObject nmObject : nmList) {
if (nmObject.containsKey("name") && "hisid".equals(nmObject.getString("name"))
&& null != nmObject.getString("value") && !"".equals(nmObject.getString("value"))) {
wxQYUser = new WXQYUser();
wxQYUser.setUserid(jsObject.getString("userid"));
wxQYUser.setName(jsObject.getString("name"));
wxQYUser.setMobile(jsObject.getString("mobile"));
wxQYUser.setHisid(nmObject.getString("value"));
wxQYUserList.add(wxQYUser);
}
}
}
}
}
}
return wxQYUserList;
}

// 企业微信存储12345，数据库存储：医院ID+12345，随意这里做截取再去匹配
private String getDoctorNo(String doctorNo) {
if (doctorNo.startsWith("10000")) {
return doctorNo.substring(5, doctorNo.length());
}
if (doctorNo.startsWith("10001")) {
return doctorNo.substring(5, doctorNo.length());
}

return doctorNo;

}
class WXQYUser { 

private String userid;

private String name;

private String mobile;

private String hisid;

public String getUserid() {
    return userid;
}

public void setUserid(String userid) {
    this.userid = userid;
}

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

public String getMobile() {
    return mobile;
}

public void setMobile(String mobile) {
    this.mobile = mobile;
}

public String getHisid() {
    return hisid;
}

public void setHisid(String hisid) {
    this.hisid = hisid;
}

}

文章标签：
小程序
存储
安全
API
数据库
游客unhwokcj7szf2
目录
相关文章
阿里云安全_
|
5天前
第五届伏魔挑战赛如约来袭，诚邀各路高手来战！
伏魔再启，等你来战！
阿里云安全_
1179 3
第五届伏魔挑战赛如约来袭，诚邀各路高手来战！
阿里云安全_
|
13天前
|
数据采集 人工智能 安全
阿里云Web应用防火墙市场份额和技术能力双第一
喜报～～
阿里云安全_
1232 11
bailiantest1
|
8天前
|
编解码 人工智能 自然语言处理
⚽阿里云百炼通义万相 2.6 视频生成玩法手册
通义万相Wan 2.6是全球首个支持角色扮演的AI视频生成模型，可基于参考视频形象与音色生成多角色合拍、多镜头叙事的15秒长视频，实现声画同步、智能分镜，适用于影视创作、营销展示等场景。
bailiantest1
652 4
AI未闻花名
|
8天前
|
机器学习/深度学习 人工智能 前端开发
构建AI智能体：七十、小树成林，聚沙成塔：随机森林与大模型的协同进化
随机森林是一种基于决策树的集成学习算法，通过构建多棵决策树并结合它们的预测结果来提高准确性和稳定性。其核心思想包括两个随机性：Bootstrap采样（每棵树使用不同的训练子集）和特征随机选择（每棵树分裂时只考虑部分特征）。这种方法能有效处理大规模高维数据，避免过拟合，并评估特征重要性。随机森林的超参数如树的数量、最大深度等可通过网格搜索优化。该算法兼具强大预测能力和工程化优势，是机器学习中的常用基础模型。
AI未闻花名
350 164
1346981540777417
|
7天前
|
机器学习/深度学习 自然语言处理 机器人
阿里云百炼大模型赋能｜打造企业级电话智能体与智能呼叫中心完整方案
畅信达基于阿里云百炼大模型推出MVB2000V5智能呼叫中心方案，融合LLM与MRCP+WebSocket技术，实现语音识别率超95%、低延迟交互。通过电话智能体与座席助手协同，自动化处理80%咨询，降本增效显著，适配金融、电商、医疗等多行业场景。
1346981540777417
359 155

热门文章

最新文章

  • 1
    《自己动手写Docker》书摘之三： Linux UnionFS
  • 2
    全球首个成人搜索引擎Boodigo比谷歌还厉害
  • 3
    【深度】生态红利即将爆发，剖析阿里云市场软件交易与交付新战略
  • 4
    EDAS——如何快速定位OOM问题
  • 5
    TFS分布式文件系统应用
  • 6
    阿里云logo设计入口(在线一键生成)
  • 7
    【AI大模型应用开发】【综合实战】AI+搜索，手把手带你实现属于你的AI搜索引擎（附完整代码）
  • 8
    aswing学习笔记4-通过调用面板中的按钮实现主界面动态切换皮肤的问题！
  • 9
    Active Directory 回收站配置篇
  • 10
    C#学习笔记——接口
  • 1
    基于 YOLOv8 的驾驶员疲劳状态识别系统实战（含完整源码与可视化界面）
    55
  • 2
    基于 YOLOv8 的交通标识与设施识别系统（含完整源码）
    60
  • 3
    阿里云免费云服务器领取教程及阿里云免费云产品全解析：从资源配置到实用指南
    64
  • 4
    金融量化场景下阿里云服务器 ECS 实例规格族选择指南
    54
  • 5
    阿里云万小智 AI 建站系统全解析：版本功能、价格体系与场景适配
    67
  • 6
    别再当冤大头！知识管理工具避坑指南，选择真·提效神器
    46
  • 7
    阿里云 CDN 计费体系全解析：基础服务、增值服务与选型指南
    66
  • 8
    向量搜索升级指南：FAISS 到 Qdrant 迁移方案与代码实现
    34
  • 9
    租用阿里云服务器一年要多少钱？今年新手必看最新阿里云服务器价格表
    45
  • 10
    阿里云 DNS 云解析全解析：免费版与付费版差异对比及选型指南
    54

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    基于Python+Vue开发的口腔牙科预约管理系统