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

微信通知

2025-12-30 3
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 本文介绍企业微信与小程序集成的消息推送实现，包括获取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
目录
相关文章
阿里云安全_
|
5天前
第五届伏魔挑战赛如约来袭，诚邀各路高手来战！
伏魔再启，等你来战！
阿里云安全_
1183 3
第五届伏魔挑战赛如约来袭，诚邀各路高手来战！
阿里云安全_
|
13天前
|
数据采集 人工智能 安全
阿里云Web应用防火墙市场份额和技术能力双第一
喜报～～
阿里云安全_
1234 11
bailiantest1
|
8天前
|
编解码 人工智能 自然语言处理
⚽阿里云百炼通义万相 2.6 视频生成玩法手册
通义万相Wan 2.6是全球首个支持角色扮演的AI视频生成模型，可基于参考视频形象与音色生成多角色合拍、多镜头叙事的15秒长视频，实现声画同步、智能分镜，适用于影视创作、营销展示等场景。
bailiantest1
666 4
AI未闻花名
|
8天前
|
机器学习/深度学习 人工智能 前端开发
构建AI智能体：七十、小树成林，聚沙成塔：随机森林与大模型的协同进化
随机森林是一种基于决策树的集成学习算法，通过构建多棵决策树并结合它们的预测结果来提高准确性和稳定性。其核心思想包括两个随机性：Bootstrap采样（每棵树使用不同的训练子集）和特征随机选择（每棵树分裂时只考虑部分特征）。这种方法能有效处理大规模高维数据，避免过拟合，并评估特征重要性。随机森林的超参数如树的数量、最大深度等可通过网格搜索优化。该算法兼具强大预测能力和工程化优势，是机器学习中的常用基础模型。
AI未闻花名
350 164
1346981540777417
|
7天前
|
机器学习/深度学习 自然语言处理 机器人
阿里云百炼大模型赋能｜打造企业级电话智能体与智能呼叫中心完整方案
畅信达基于阿里云百炼大模型推出MVB2000V5智能呼叫中心方案，融合LLM与MRCP+WebSocket技术，实现语音识别率超95%、低延迟交互。通过电话智能体与座席助手协同，自动化处理80%咨询，降本增效显著，适配金融、电商、医疗等多行业场景。
1346981540777417
359 155