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

微信通知

2025-12-19 15
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 基于企业微信与小程序集成，通过API获取access_token，查询通讯录并匹配医生信息，异步发送小程序通知消息。需配置企业微信appId、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
数据库
游客gyr3h2epvizc2
目录
相关文章
阿里云安全_
|
1天前
|
数据采集 人工智能 安全
阿里云Web应用防火墙市场份额和技术能力双第一
喜报～～
阿里云安全_
1155 1
阿里云安全_
|
11天前
|
云安全 监控 安全
助力企业应对React框架高危漏洞，阿里云多款安全产品限时免费
领取限时免费产品，立即开始防护
阿里云安全_
3095 5
bailiantest1
|
2天前
|
自然语言处理 API
万相 Wan2.6 全新升级发布！人人都能当导演的时代来了
通义万相2.6全新升级，支持文生图、图生视频、文生视频，打造电影级创作体验。智能分镜、角色扮演、音画同步，让创意一键成片，大众也能轻松制作高质量短视频。
bailiantest1
938 150
游客ef5azsll4roeg
|
2天前
|
编解码 人工智能 机器人
通义万相2.6，模型使用指南
智能分镜 | 多镜头叙事 | 支持15秒视频生成 | 高品质声音生成 | 多人稳定对话
游客ef5azsll4roeg
453 7
modelscope
|
16天前
|
机器学习/深度学习 人工智能 自然语言处理
Z-Image：冲击体验上限的下一代图像生成模型
通义实验室推出全新文生图模型Z-Image，以6B参数实现“快、稳、轻、准”突破。Turbo版本仅需8步亚秒级生成，支持16GB显存设备，中英双语理解与文字渲染尤为出色，真实感和美学表现媲美国际顶尖模型，被誉为“最值得关注的开源生图模型之一”。
modelscope
1662 8
星哥玩云
|
7天前
|
人工智能 自然语言处理 API
一句话生成拓扑图！AI+Draw.io 封神开源组合，工具让你的效率爆炸
一句话生成拓扑图！next-ai-draw-io 结合 AI 与 Draw.io，通过自然语言秒出架构图，支持私有部署、免费大模型接口，彻底解放生产力，绘图效率直接爆炸。
星哥玩云
617 152
阿里云云原生
|
9天前
|
人工智能 安全 前端开发
AgentScope Java v1.0 发布，让 Java 开发者轻松构建企业级 Agentic 应用
AgentScope 重磅发布 Java 版本，拥抱企业开发主流技术栈。
阿里云云原生
587 15
修己xj
|
9天前
|
人工智能 自然语言处理 API
Next AI Draw.io:当AI遇见Draw.io图表绘制
Next AI Draw.io 是一款融合AI与图表绘制的开源工具，基于Next.js实现，支持自然语言生成架构图、流程图等专业图表。集成多款主流大模型，提供智能绘图、图像识别优化、版本管理等功能，部署简单，安全可控，助力技术文档与系统设计高效创作。
修己xj
672 151