AI 助理
备案控制台
开发者社区 安全 文章 正文

微信通知

2025-12-30 4
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 本文介绍企业微信与小程序集成的消息推送实现，包括获取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;
  }
}
文章标签：
小程序
安全
游客u7eq6oja746ys
目录
相关文章
游客u7eq6oja746ys
|
1天前
|
安全
通过述职能发现自己"变"了
述职非形式，而是洞察成长与价值的管理机制。通过结构化思考、快慢思辨、积极主动、以终为始等思维与行动模式，提升个人成长与结果影响力，实现借事修人、价值呈现与自我突破。
游客u7eq6oja746ys
4 0
通过述职能发现自己"变"了
游客u7eq6oja746ys
|
2天前
|
Java 数据库连接 mybatis
1.常见配置
本文介绍了MyBatis的核心配置机制，包括属性加载优先级（方法参数 &gt; resource/url &gt; properties元素）、常见配置项如缓存、延迟加载、执行器类型等，并详解了多环境配置方式及事务管理（JDBC与MANAGED）。适用于需掌握MyBatis配置优先级与多数据源管理的开发者。
游客u7eq6oja746ys
7 0
1.常见配置
游客u7eq6oja746ys
|
1天前
|
前端开发 数据可视化
什么是低代码
该界面为低代码平台，用户可通过拖拽组件快速生成前端表单页面，提升开发效率。支持可视化操作，降低开发门槛，适用于快速搭建业务系统。参考文档提供详细说明。
游客u7eq6oja746ys
4 0
什么是低代码
游客u7eq6oja746ys
|
1天前
|
SQL 监控 机器人
钉钉通知
本文介绍如何通过Java代码调用钉钉机器人API，实现系统告警消息的实时推送。涵盖机器人创建、PostMan测试、Java代码编写及实际应用优化，如封装工具类、配置解耦等，并提供常见失败原因分析，助力高效集成钉钉告警通知。
游客u7eq6oja746ys
6 0
钉钉通知
游客u7eq6oja746ys
|
1天前
|
监控 Java 测试技术
OOM排查之路：一次曲折的线上故障复盘
本文记录了一次Paimon数据湖与RocksDB集成服务频繁OOM的排查历程。通过分析线程激增、堆外内存泄漏，最终定位到RocksDB JNI内存未释放问题，并借助Flink重构写入链路彻底解决。分享了MAT、NMT、async-profiler等工具的实战经验与系统性排查思路，为类似场景提供借鉴。（239字）
游客u7eq6oja746ys
4 0
OOM排查之路：一次曲折的线上故障复盘
游客u7eq6oja746ys
|
1天前
|
算法 调度 Unix
Thread.sleep(0) 到底有什么用(读完就懂)
本文深入解析Thread.Sleep的原理与应用，通过“分蛋糕”比喻生动讲解操作系统CPU调度机制。重点说明Sleep(1000)不保证精确唤醒时间，而Thread.Sleep(0)可触发CPU重新竞争，避免界面假死，帮助开发者正确理解线程休眠与系统调度的关系。
游客u7eq6oja746ys
4 0
Thread.sleep(0) 到底有什么用(读完就懂)
游客u7eq6oja746ys
|
1天前
|
自然语言处理 fastjson Java
FastJson：大面积故障规避案例
本文记录了一次由Kotlin语法误用引发的FastJson反序列化重大故障。因将 `{}` 错误赋值给 Java 对象字段，导致 FastJson 解析时触发 `kotlin_error` 静态标记位异常，进而使整个工程反序列化链路瘫痪。问题根源隐蔽，排查耗时两天，最终通过深入源码定位解决。反映出多语言混编下语法混淆风险及对第三方框架过度依赖的隐患，强调代码严谨性与灰度发布的重要性。
游客u7eq6oja746ys
3 0
FastJson：大面积故障规避案例
游客u7eq6oja746ys
|
1天前
|
NoSQL MongoDB 存储
1-MongoDB相关概念
MongoDB是一款高性能、无模式的文档型NoSQL数据库，适用于高并发读写、海量数据存储及高可用扩展场景。其灵活的BSON文档模型支持嵌套结构和动态 schema，广泛应用于社交、游戏、物联网等领域，尤其适合对事务要求不高但需快速迭代与水平扩展的业务系统。
游客u7eq6oja746ys
7 0
1-MongoDB相关概念
游客u7eq6oja746ys
|
1天前
|
存储 缓存 监控
EFC&CTO：缓存引发数据不一致问题排查与深度解析
EFC客户端在NAS场景下因缓存版本号回退，导致读取旧数据覆盖正常内容，引发CTO测试数据不一致。通过日志分析与复现实验，定位为分布式缓存中dv版本管理缺陷所致，修复后验证问题解决。
游客u7eq6oja746ys
4 0
EFC&CTO：缓存引发数据不一致问题排查与深度解析
游客u7eq6oja746ys
|
1天前
|
人工智能 JSON 安全
大模型应用开发中MCP与Function Call的关系与区别
MCP与Function Call是大模型应用中两大关键技术。MCP作为标准化协议，打通模型与外部工具的通用连接；Function Call则是模型调用外部功能的具体机制。前者如“桥梁”，后者似“工具”，二者互补协同，推动AI应用向更开放、灵活、安全的方向演进，构建“意图解析-协议传输-工具执行”的分层架构新范式。
游客u7eq6oja746ys
10 0