AI 助理
备案控制台注册登录
开发者社区 云计算 文章 正文

微信通知

2025-07-17 59 发布于广东
版权
举报
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 本文介绍了通过企业微信发送消息至绑定小程序的具体实现，包括获取access_token、发送消息的代码示例及完整异步实现逻辑。

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<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);
    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<ExecutorService> 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<WXQYUser> getWXQYUserList(JSONObject hResponse) {
    List<JSONObject> wXQYUserList = (List<JSONObject>) hResponse.get("userlist");
    List<JSONObject> nmList = null;
    WXQYUser wxQYUser = null;
    JSONObject mm = null;
    List<WXQYUser> wxQYUserList = new ArrayList<WXQYUser>();
    for (JSONObject jsObject : wXQYUserList) {
        if (jsObject.containsKey("userid")) {
            if (jsObject.containsKey("extattr")) {
                mm = jsObject.getJSONObject("extattr");
                if (null != mm.get("attrs")) {
                    nmList = (List<JSONObject>) 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;
  }
}
文章标签：
小程序
林风豆
+关注
31文章
目录
打赏
0
0
0
0
9
分享
相关文章
林风豆
|
运维 NoSQL 测试技术
Redis：内存陡增100%深度复盘
本文深度分析了Redis内存陡增100%的一些细节和解决方案。
林风豆
116 1
Redis：内存陡增100%深度复盘
林风豆
|
28天前
|
存储 缓存 安全
多线程篇
多线程相关面试题
林风豆
57 0
xleesf
|
存储 分布式计算 数据管理
基于 Apache Hudi + dbt 构建开放的Lakehouse
基于 Apache Hudi + dbt 构建开放的Lakehouse
xleesf
231 3
阿里云瑶池数据库_
|
1月前
|
存储 关系型数据库 分布式数据库
客户说｜古茗选用阿里云PolarDB，以云端之力解锁茶饮数字化新高度
阿里云PolarDB将持续以“业务价值”为锚点，通过技术迭代与场景化解决方案，让每一笔交易更流畅，让每一份数据更智能，助力古茗实现“每天一杯喝不腻”的日常化国民茶饮愿景。
阿里云瑶池数据库_
93 0
林风豆
|
1月前
|
消息中间件 存储 缓存
6-MQ篇
本内容详细介绍了RabbitMQ、Kafka和EMQ三种消息中间件的应用场景及核心机制。包括RabbitMQ的消息可靠性传输、顺序性保障、死信处理；Kafka的高吞吐设计、数据清理机制与高性能实现；以及EMQ在物联网中的应用及其QoS保障机制。适用于微服务架构中异步通信、流量削峰和解耦场景，同时探讨了消息丢失、重复消费等问题的解决方案。
林风豆
37 0
林风豆
|
1月前
|
存储 SQL 关系型数据库
3-MySQL篇
本文介绍了MySQL数据库的关键知识点，包括查询语句的书写与执行顺序、多表查询方式、内连接与外连接的区别、CHAR与VARCHAR的差异、索引的类型与底层结构、存储引擎的区别、聚簇与非聚簇索引、回表查询与覆盖索引、左前缀原则、索引失效场景、索引优化建议、性能优化策略、超大分页处理、慢查询定位方法、SQL执行分析以及锁和分库分表等内容。这些内容系统地涵盖了MySQL开发与优化中的常见问题与解决方案，适合用于面试复习或技术提升。
林风豆
42 0
3-MySQL篇
林风豆
|
24天前
|
存储 安全 NoSQL
询律法律咨询平台：功能实现与技术架构详解
询律法律咨询平台是一个连接用户与律师的综合性服务平台，涵盖在线咨询、支付系统、知识专辑管理、直播课堂等功能。平台通过整合律师资源与技术手段，打破传统法律咨询的时空限制，提供便捷、专业的法律服务。项目采用WebSocket实时通信、分布式锁、ElasticSearch搜索、第三方支付等技术，构建了一套稳定高效的法律服务体系，保障高并发场景下的系统稳定性和数据安全。
林风豆
46 0
林风豆
|
1月前
|
存储 关系型数据库 MySQL
7-事务控制篇
数据库是存储和管理数据的核心工具，分为关系型和非关系型两种类型。关系型数据库基于表格结构，支持SQL查询、事务处理，适合需要强一致性和复杂查询的场景，如Oracle、MySQL等；而非关系型数据库（NoSQL）采用键值对、文档或列存储等模型，具备灵活的数据格式与高扩展性，适用于大数据和高并发读写场景，如Redis、MongoDB等。两者各有优劣，选择时需根据业务需求权衡性能、灵活性与一致性。
林风豆
44 0
光明顶阳顶天
|
9月前
|
IDE 开发工具 索引
在Python中安装第三方库
在Python中安装第三方库
光明顶阳顶天
2209 30

热门文章

最新文章

  • 1
    借力阿里云存储产品 延锋彼欧加速数字化重塑
    18
  • 2
    独家首发 | 阿里巴巴新基建洞察系列——《5G智能经济应用场景》研究报告正式发布
    12
  • 3
    PostgreSQL如何实现跨数据库访问？
    3208
  • 4
    linux中通用Netlink详解及使用剖析(附源码)
    7215
  • 5
    北京8分钟告诉你，阿里巴巴要打造的人工智能奥运真的要来！
    9390
  • 6
    claude国内怎么用？教你两种claude国内使用方法！
    301
  • 7
    还在使用MyBatis Generator？试试这个工具
    6
  • 8
    安谋科技（Arm China）马闯：Arm架构下性能分析与优化介绍
    45
  • 9
    pandas 打开没有列名的表格，并命名
    6189
  • 10
    大数据治理系统框架Apache Atlas实践
    8743
  • 1
    基于WOA-CNN-BiLSTM-Attention、CNN-BiLSTM-Attention、WOA-CNN-BiLSTM、CNN-BiLSTM、BiLSTM、CNN6模型单变量时序预测一键对比研究
    25
  • 2
    分享一个开源的MCP工具使用的AI Agent 支持常用的AI搜索/地图/金融/浏览器等工具
    77
  • 3
    《WASM驱动本地PDF与Excel预览组件的深度实践》
    25
  • 4
    《用Proxy解构前端壁垒：跨框架状态共享库的从零到优之路》
    25
  • 5
    当手环懂你心事：未来的可穿戴情感分析设备
    29
  • 6
    企业服务交付慢？运维技术其实就是“加速器”
    25
  • 7
    保险行业的“算命术”？——数据驱动的风险评估真相
    28
  • 8
    深入解析AI智能体记忆机制：八大策略与实现方案
    22

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    对象存储OSS
    目录
    AI助理

    你好，我是AI助理

    可以解答问题、推荐解决方案等

    登录插画

    登录以查看您的控制台资源

    管理云资源
    状态一览
    快捷访问
    快捷注册登录阿里云