微信通知

简介: 本文介绍了企业微信与小程序集成下,通过API获取access_token并发送消息的完整流程。包含前置条件、请求示例、代码实现及异步调用建议,适用于企业内部系统与微信生态对接场景。(239字)

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;
  }
}
相关文章
|
3月前
|
SQL 缓存 Java
第八章 Mybatis及MybatisPlus
本文系统介绍MyBatis核心架构与执行流程,涵盖配置文件、SqlSessionFactory构建、SQL执行机制及结果映射;详解resultType、resultMap、@Param等参数传递与映射方式;介绍一级缓存、二级缓存机制及PageHelper、MyBatis Plus分页插件应用,助力高效开发。
第八章 Mybatis及MybatisPlus
|
3月前
|
JSON 前端开发 Java
第六章 SpringMVC框架
Spring MVC核心组件包括DispatcherServlet、HandlerMapping、HandlerAdapter、Handler及ViewResolver,协同完成请求分发、处理与视图渲染。其请求流程为:用户请求→DispatcherServlet→HandlerMapping映射→HandlerAdapter执行→Handler处理→ViewResolver解析视图→响应返回。开发中常用注解如@RequestMapping、@RequestBody、@ResponseBody等实现请求映射与数据绑定。
 第六章 SpringMVC框架
|
3月前
|
机器学习/深度学习 存储 算法
第二章 基础算法
本文系统介绍了加密算法、排序算法及字符串处理等核心技术。涵盖对称与非对称加密、哈希摘要、常见排序算法原理与优化,以及字符串匹配和回溯算法应用,内容详实,适合技术学习与面试准备。
第二章 基础算法
|
3月前
|
缓存 NoSQL 调度
项目《神领物流》
本项目为基于微服务架构的智能物流系统,涵盖用户端、快递员端、司机端及管理端。采用Spring Cloud、RabbitMQ、Redis、MongoDB、Neo4j等技术,实现智能调度、路线规划、运费计算、权限管理、多级缓存与分布式事务等功能,提升运输效率,降低运营成本。
|
3月前
|
Java 测试技术 Linux
生产环境发布管理
本文介绍大型团队中多环境自动化发布流程,涵盖DEV、TEST、PRE、PROD各环境职责,结合CI/CD平台实现Jenkins+K8S自动化部署,支持分支管理、一键发布与日志链路追踪,提升发布效率与系统稳定性。
|
3月前
|
开发者
业务架构图
本文介绍了业务架构图的核心概念与绘制方法,涵盖业务定义、架构域分类,强调业务架构是技术、应用与数据架构的基础。通过分层、分模块、分功能三步法,梳理业务逻辑,明确模块边界与信息流,帮助客户与开发者清晰理解系统结构,提升协作效率。
 业务架构图
|
3月前
|
SQL 运维 分布式计算
如何做好SQL质量监控
SLS推出用户级SQL质量监控功能,集成于CloudLens for SLS,提供健康分、服务指标、运行明细、SQL Pattern分析及优化建议五大维度,助力用户全面掌握SQL使用情况,提升日志分析效率与治理能力。
 如何做好SQL质量监控
|
3月前
|
Java 开发工具 数据安全/隐私保护
项目《中州养老》
《中州养老》是一个面向养老院的后台管理系统,涵盖预约、入住、健康监测等核心功能。系统分为员工管理端与家属小程序端,采用Vue3、SpringBoot等技术栈,集成阿里云IOT实现智能设备数据采集与异常报警,并通过RBAC权限模型保障系统安全。
项目《中州养老》
|
3月前
|
运维 Devops 开发工具
生产环境缺陷管理
git-poison基于go-git实现分布式bug追溯,解决多分支开发中漏修复、漏发布等问题。通过“投毒-解毒-银针”机制,自动化卡点发布流程,降低协同成本,避免人为失误,提升发布安全性与效率,已在大型团队落地应用。
|
3月前
|
缓存 NoSQL Java
逐字稿实例(22K*18
李二,3年Java开发经验,熟悉SpringBoot、SpringCloud、MySQL、Redis等技术栈。主导过“触见”买药送药项目,负责AI智能助手、电子处方、优惠券等核心模块设计与实现,具备高并发场景下的系统优化能力。

热门文章

最新文章