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

微信通知

2025-12-19 95
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 基于企业微信与小程序集成，实现通过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
数据库
游客vt33yqkn3w53i
目录
相关文章
游客vt33yqkn3w53i
|
2月前
|
Java 测试技术 API
从Google线上故障，谈灰度发布的重要性
2025年6月12日，Google Cloud因未灰度发布新配置导致全球服务中断7小时。本文分析故障根因，强调配置灰度发布重要性，并详解基于Nacos的IP与标签灰度实现方案，助力企业提升系统稳定性，防范类似风险。
游客vt33yqkn3w53i
102 5
阿里云云原生
|
2月前
|
存储 SQL JSON
打通可观测性的“任督二脉”：实体与关系的终极融合
阿里云推出图查询能力，基于 graph-match、graph-call、Cypher 三重引擎，实现服务依赖、故障影响、权限链路的秒级可视化与自动化分析，让可观测从‘看板时代’迈向‘图谱时代’。
阿里云云原生
361 55
阿里云云原生
|
2月前
|
监控 前端开发 数据可视化
Entity Explorer：基于 UModel 的实体探索平台
阿里云 Entity Explorer 正式发布：基于 UModel 的智能实体探索平台，实现亿级实体秒级检索、关系拓扑自动构建、详情页动态渲染，让可观测性从“数据堆砌”迈向“业务洞察”。
阿里云云原生
316 50
阿里云云原生
|
2月前
|
人工智能 运维 Serverless
一杯咖啡成本搞定多模态微调：FC DevPod + Llama-Factory 极速实战
告别显存不足、环境配置难、成本高昂的微调困境！基于阿里云函数计算FC与Llama-Factory，5分钟搭建微调流水线，一键完成多模态模型的微调。
阿里云云原生
367 20
龙蜥社区（OpenAnolis）
|
2月前
|
监控 Kubernetes 调度
干货推荐：容器可观测新视角—SysOM 延时抖动监控助力定位业务抖动原因
为了解决这一挑战，本文将结合实战案例，介绍如何在 Kubernetes 环境中使用 ack-sysom-monitor Exporter 对内核延迟进行可视化分析与定位，帮助你快速识别问题根因，并高效缓解由延迟引发的业务抖动。
龙蜥社区（OpenAnolis）
299 25
游客vt33yqkn3w53i
|
2月前
|
Ubuntu Java Linux
Docker
本文介绍Docker基础体系，涵盖镜像与容器操作、Dockerfile编写及自定义镜像构建。通过实例演示Java项目打包、编写Dockerfile、生成镜像、运行容器并做端口映射，最后验证服务运行状态，适合初学者快速掌握Docker部署流程。（238字）
游客vt33yqkn3w53i
81 0
后端程序员Annie
|
2月前
|
传感器 算法 安全
支持二次开发的移动机器人平台设备盘点与解析
移动机器人正从封闭走向开放平台化，本文盘点十大支持二次开发的主流设备，涵盖服务、工业、科研及商用场景。重点解析猎户星空豹小秘2的实时混核架构、松灵Scout系列的高开放底盘、Clearpath经典科研平台及思岚Apollo导航验证方案等，展现API化、数字孪生与功能安全并重的技术趋势，助力开发者精准选型。
后端程序员Annie
254 0
程序媛在线
|
2月前
|
人工智能 自然语言处理 数据可视化
阿里云AI智能建站系统万小智介绍、配置价格及版本功能支持说明
阿里云万小智AI建站，基于通义大模型，提供智能设计、内容创作、多语言支持等功能。三版可选：基础版698元/年，标准版980元/年，企业版1980元/年，买即赠CN域名。支持可视化编辑、电商支付、SSL加密等，集成CDN、短信服务，部署便捷，助力企业快速搭建安全官网。
程序媛在线
283 0
阿里云开发者
|
2月前
|
Kubernetes Cloud Native Nacos
MCP 网关实战：基于 Higress + Nacos 的零代码工具扩展方案
本文介绍一种基于开源 Higress 与 Nacos 的私有化 MCP 智能体网关架构，实现工具动态注册、Prompt 实时更新、多租户安全隔离，并支持在无外网、无 Helm 的生产环境中一键部署。
阿里云开发者
448 25
MCP 网关实战：基于 Higress + Nacos 的零代码工具扩展方案

热门文章

最新文章

  • 1
    CUDA和显卡驱动以及pytorch版本的对应关系
  • 2
    手把手教你SpringBoot轻松整合Minio
  • 3
    阿里云（一）云存储OSS的命令行osscmd的安装和使用
  • 4
    2018阿里云双11-云服务器ECS优惠活动最强解读
  • 5
    PostgreSQL 批量权限 管理方法
  • 6
    Android小项目合集（经典教程）包含十五个Android开发应用实例
  • 7
    Raid 0 1 5 10的原理、特点、性能区别
  • 8
    基于 ChatGLM-6B 搭建个人专属知识库
  • 9
    通过阿里云容器服务深度学习解决方案上手Caffe+多GPU训练
  • 10
    开放平台
  • 1
    抖音弹幕游戏开发之第4集：第一个WebSocket连接·优雅草云桧·卓伊凡
    26
  • 2
    一张表看懂！阿里云4核8G云服务器ECS全配置，附送参考价格，连夜整理
    36
  • 3
    不用懂代码？DeepSeek 个人网站搭建，新手0基础一看就会！
    40
  • 4
    别再群发拜年消息了！三步微调AI，让它学会你的“独家语气”
    56
  • 5
    春节祝福“AI味”太重？我用30分钟微调了一个能记住你我故事的专属模型
    42
  • 6
    为什么祝福场景里，关系证据比祝福模板重要得多
    39
  • 7
    MavenRunHelper.jar 使用步骤详解（附Maven命令执行与main方法运行）
    41
  • 8
    关系记忆不是越完整越好：chunk size 的隐性代价
    38
  • 9
    VMware17安装步骤详解（附虚拟机创建与常见问题解决）
    48
  • 10
    Prompt 缓存的四种策略：从精确匹配到语义检索
    39

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    第五届伏魔挑战赛如约来袭，诚邀各路高手来战！