springboot集成微软teams的实例代码

2024-04-02 19:04:59 203人浏览安东尼

Python 官方文档：入门教程 => 点击学习

摘要

前言最近做了一个有关微软的平台teams开发，在国内用微软teams聊天工具的少之又少，整个亚洲也没什么开发的实例，官方文档写的有点乱，在没有第三方支持下开发有点头疼。需求是做一个

前言

最近做了一个有关微软的平台teams开发，在国内用微软teams聊天工具的少之又少，整个亚洲也没什么开发的实例，官方文档写的有点乱，在没有第三方支持下开发有点头疼。需求是做一个管理后台跟teams打通，支持各种通告发送，以及撤回。没时间具体些，用的东西丢在上面用上的可以参考。

添加依赖

<dependency>
           <groupId>com.microsoft.graph</groupId>
           <artifactId>microsoft-graph</artifactId>
           <version>2.3.2</version>
       </dependency>
       <dependency>
           <groupId>com.microsoft.graph</groupId>
           <artifactId>microsoft-graph-core</artifactId>
           <version>1.0.5</version>
       </dependency>
 
       <dependency>
           <groupId>com.microsoft.graph</groupId>
           <artifactId>microsoft-graph-auth</artifactId>
           <version>0.3.0-SNAPSHOT</version>
       </dependency>
       <dependency>
           <groupId>com.microsoft.Azure</groupId>
           <artifactId>msal4j</artifactId>
           <version>1.0.0</version>
       </dependency>

业务逻辑层

package com.tg.admin.service;
 
import com.tg.admin.utils.CommonResult;
import java.util.Map;

public interface SplGraphService {
    
    String getToken();
     * 获取用户所属团队
     * @return 结果
    CommonResult<Map<String, Object>> getTeamsInfo();
     * 获取用户所属渠道
     * @param teamsId 团队ID
    CommonResult<Map<String, Object>> getChannel(String teamsId);
     * 根据teamsId、channelId获取用户信息
     * @param teamsId   团队ID
     * @param channelId 渠道ID
    CommonResult<Map<String, Object>> getMember(String teamsId, String channelId);
     * 发送消息
     * @param content   消息内容
     * @param teamId    团队ID
    CommonResult<Map<String, Object>> sendMs(String content, String teamId, String channelId);
     * 添加渠道
     * @param displayName 渠道名称
     * @param description 渠道备注
     * @param teamId      渠道ID
     * @return 渠道ID
    CommonResult<Map<String, Object>> addChannel(String displayName, String description, String teamId);
     * 添加成员
     * @param userNum   用户名称
    CommonResult<Map<String, Object>> addMembers(String teamId, String channelId, String userNum);
}

业务逻辑实现

package com.tg.admin.service.impl;
 
import com.alibaba.fastJSON.jsONArray;
import com.alibaba.fastjson.JSONObject;
import com.microsoft.graph.models.extensions.IGraphServiceClient;
import com.microsoft.graph.requests.extensions.GraphServiceClient;
import com.tg.admin.service.ChannelUserLogService;
import com.tg.admin.service.SplGraphService;
import com.tg.admin.utils.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.Http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.WEB.client.RestTemplate;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
@Slf4j
public class SplGraphServiceImpl implements SplGraphService {
    @Value("#{'${teams.graph.scopes}'.split(',')}")
    private List<String> scopes;
    @Value("${teams.graph.clientId}")
    private String clientId;
    @Value("${teams.graph.team.url}")
    private String teamsUrl;
    @Value("${teams.graph.channel.url}")
    private String channelUrl;
    @Value("${teams.graph.add.channel.url}")
    private String addChannelUrl;
    @Value("${teams.graph.ms.url}")
    private String msUrl;
    @Value("${teams.graph.member.url}")
    private String memberUrl;
    @Value("${teams.graph.add.channel.members.url}")
    private String addChannelMembersUrl;
    @Value("${teams.graph.account}")
    private String account;
    @Value("${teams.graph.passWord}")
    private String password;
    private RedisUtil redisUtil;
    private RestTemplate restTemplate;
    private ChannelUserLogService channelUserLogService;
    public SplGraphServiceImpl(RestTemplate restTemplate, RedisUtil redisUtil, @Lazy ChannelUserLogService channelUserLogService) {
        this.restTemplate = restTemplate;
        this.redisUtil = redisUtil;
        this.channelUserLogService = channelUserLogService;
    }
    @Override
    public String getToken() {
        Object token = redisUtil.get(Constants.ADMIN_TOKEN_KEY + account);
        try {
            if (token == null) {
                MyAuthenticationProvider authProvider = new MyAuthenticationProvider(clientId, scopes, account, password);
                IGraphServiceClient graphClient = GraphServiceClient.builder().authenticationProvider(authProvider).buildClient();
                graphClient.me().buildRequest().get();
                token = authProvider.getToken();
                redisUtil.set(Constants.ADMIN_TOKEN_KEY + account, token, Constants.TOKEN_EXPIRES_TIME);
            }
        } catch (Exception e) {
            log.info("获取teams-graph，获取token接口异常", e);
        }
        return token.toString();
    public CommonResult<Map<String, Object>> getTeamsInfo() {
        JSONArray value = null;
        Map<String, Object> result = new HashMap<>();
        JSONObject jsonObject = new JSONObject();
            log.info("调用temas获取团队信息:teamsUrl{}", teamsUrl);
            //设置请求头
            HttpHeaders headers = new HttpHeaders();
            headers.set("Authorization", getToken());
            headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
            jsonObject = RestTemplateUtils.requestByGet(teamsUrl, null, restTemplate, headers);
            log.info("返回值：jsonObject:{}", jsonObject.toJSONString());
            value = jsonObject.getJSONArray("value");
            result.put("value", value);
            e.printStackTrace();
        return CommonResult.ok(result);
    public CommonResult<Map<String, Object>> getChannel(String teamId) {
        JSONArray array = null;
            String url = channelUrl.replace("{team-id}", teamId);
            log.info("调用teams获取用户渠道url:{}", url);
            jsonObject = RestTemplateUtils.requestByGet(url, null, restTemplate, headers);
            log.info("返回结果：jsonObject:{}", jsonObject.toJSONString());
            array = jsonObject.getJSONArray("value");
            result.put("value", array);
    public CommonResult<Map<String, Object>> getMember(String teamsId, String channelId) {
            String url = memberUrl.replace("{team-id}", teamsId).replace("{channel-id}", channelId);
            log.info("调用teams获取渠道成员:url:{}", url);
    public CommonResult<Map<String, Object>> sendMs(String content, String teamId, String channelId) {
            String url = msUrl.replace("{team-id}", teamId).replace("{channel-id}", channelId);
            log.info("调用teams发送消息:url:{}", url);
            Map<String, Object> map = new HashMap<String, Object>();
            Map<String, Object> body = new HashMap<>();
            map.put("content", content);
            map.put("contentType", "html");
            body.put("body", map);
            jsonObject = RestTemplateUtils.requestByPost(url, body, restTemplate, headers);
            log.info("返回结果:jsonObject:{}", jsonObject.toJSONString());
        return CommonResult.ok();
    public CommonResult<Map<String, Object>> addChannel(String displayName, String description, String teamId) {
            String url = addChannelUrl.replace("{id}", teamId);
            log.info("调用teams添加渠道:url:{}", url);
            map.put("displayName", displayName);
            map.put("description", description);
            jsonObject = RestTemplateUtils.requestByPost(url, map, restTemplate, headers);
            if (jsonObject != null) {
                result.put("id", jsonObject.getString("id"));
    public CommonResult<Map<String, Object>> addMembers(String teamId, String channelId, String userNum) {
            String url = addChannelMembersUrl.replace("{team-id}", teamId).replace("{channel-id}", channelId);
            log.info("调用teams添加成员:url:{}", url);
            map.put("@odata.type", "#microsoft.graph.aadUserConversationMember");
            JSONArray roles = new JSONArray();
            roles.add("owner");
            map.put("roles", roles);
}

RestTemplateUtils 工具类

package com.tg.admin.utils;
 
import com.alibaba.fastjson.JSONObject;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponentsBuilder;
 
import java.util.HashMap;
import java.util.Map;
 

@Component
public class RestTemplateUtils {
 
 
    
    public static JSONObject requestByGet(String url, HashMap<String, Object> map, RestTemplate restTemplate, HttpHeaders headers) {
 
        // header填充
        HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity(null, headers);
 
        UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(url);
        //ResponseEntity responseEntity;
        ResponseEntity<JSONObject> responseEntity;
        //如果存在參數
        if (map != null) {
            for (Map.Entry<String, Object> e :
                    map.entrySet()) {
                //构建查询参数
                builder.queryParam(e.geTKEy(), e.getValue());
            }
            //拼接好参数后的URl//test.com/url?param1={param1}&param2={param2};
            String reallyUrl = builder.build().toString();
            responseEntity = restTemplate.exchange(reallyUrl, HttpMethod.GET, request, JSONObject.class);
        } else {
            responseEntity = restTemplate.exchange(url, HttpMethod.GET, request, JSONObject.class);
        }
 
        return responseEntity.getBody();
    }
 
 
    
    public static JSONObject requestByPost(String url, Map<String, Object> map, RestTemplate restTemplate, HttpHeaders headers) {
        // header填充,map填充
        HttpEntity<Map<String, Object>> request = new HttpEntity<Map<String, Object>>(map, headers);
        ResponseEntity<JSONObject> entity = restTemplate.postForEntity(url, request, JSONObject.class);
        return entity.getBody();
    }
 
}

测试接口

package com.tg.admin.controller;
 
import com.tg.admin.service.SplGraphService;
import com.tg.admin.utils.CommonResult;
import io.swagger.annotations.api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.*;
@Api(description = "teams-graph模块(第三方测试接口)")
@RestController
@RequestMapping("/graph")
@RefreshScope
@Slf4j
@Deprecated //添加过期注解，接口保留方便后期异常排查
public class GraphController {
    private SplGraphService tgService;
    public GraphController(SplGraphService tgService) {
        this.tgService = tgService;
    }
    @ApiOperation("获取所属团队信息")
    @GetMapping("/getTeamsInfo")
    public CommonResult getTeamsInfo() {
        return tgService.getTeamsInfo();
    @ApiOperation("获取token")
    @GetMapping("/getToken")
    public CommonResult getToken() {
        return CommonResult.ok(tgService.getToken());
    @ApiOperation("获取用户所属渠道")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "teamId", value = "团队Id", dataType = "string", required = true)
    })
    @GetMapping("/getChannel")
    public CommonResult getChannel(@RequestParam(value = "teamId") String teamId) {
        return tgService.getChannel(teamId);
    @ApiOperation("获取渠道下的成员")
            @ApiImplicitParam(name = "teamId", value = "团队Id", dataType = "string", required = true),
            @ApiImplicitParam(name = "channelId", value = "渠道Id", dataType = "string", required = true)
    @GetMapping("/getMember")
    public CommonResult getMember(@RequestParam(value = "teamId") String teamId,
                                  @RequestParam(value = "channelId") String channelId) {
        return tgService.getMember(teamId, channelId);
    @ApiOperation("创建团队下的渠道(备用接口)")
            @ApiImplicitParam(name = "displayName", value = "渠道名称", dataType = "string", required = true),
            @ApiImplicitParam(name = "description", value = "渠道备注", dataType = "string", required = true)
    @PostMapping("/addChannel")
    public CommonResult addChannel(@RequestParam(value = "teamId") String teamId,
                                   @RequestParam(value = "displayName") String displayName,
                                   @RequestParam(value = "description") String description
    ) {
        return tgService.addChannel(displayName, description, teamId);
    @ApiOperation("向渠道里面添加成员(备用接口)")
            @ApiImplicitParam(name = "channelId", value = "渠道ID", dataType = "string", required = true),
            @ApiImplicitParam(name = "userNum", value = "用户Id", dataType = "string", required = true)
    @PostMapping("/addMembers")
    public CommonResult addMembers(@RequestParam(value = "teamId") String teamId,
                                   @RequestParam(value = "channelId") String channelId,
                                   @RequestParam(value = "userNum") String userNum
        return tgService.addMembers(teamId, channelId, userNum);
    @ApiOperation("通过teamId,channelId发送消息")
    @PostMapping("/sendMs")
            @ApiImplicitParam(name = "content", value = "内容", dataType = "string", required = true),
    public CommonResult sendMs(@RequestParam(value = "teamId") String teamId,
                               @RequestParam(value = "content") String content,
                               @RequestParam(value = "channelId") String channelId) {
        return tgService.sendMs(content, teamId, channelId);
}

yml 配置

teams:
  graph:
    #微软master账号，密码
    account: 管理员账号
    password: 管理员密码
    add:
      channel:
        members:
          url: https://graph.microsoft.com/v1.0/teams/{team-id}/channels/{channel-id}/members
        url: https://graph.microsoft.com/v1.0/teams/{id}/channels
    channel:
      url: https://graph.microsoft.com/v1.0/teams/{team-id}/channels
    clientId: e730901a-8bf3-472b-93Dd-afe79713bc5b
    member:
      url: https://graph.microsoft.com/v1.0/teams/{team-id}/channels/{channel-id}/members
    ms:
      url: https://graph.microsoft.com/v1.0/teams/{team-id}/channels/{channel-id}/messages
    scopes: Group.Read.All,User.Read
    team:
      url: https://graph.microsoft.com/v1.0/me/joinedTeams

到此这篇关于SpringBoot集成微软teams的文章就介绍到这了,更多相关springboot集成微软teams内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: springboot集成微软teams的实例代码

本文链接: https://www.lsjlt.com/news/163243.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

springboot集成微软teams的实例代码

前言最近做了一个有关微软的平台teams开发，在国内用微软teams聊天工具的少之又少，整个亚洲也没什么开发的实例，官方文档写的有点乱，在没有第三方支持下开发有点头疼。需求是做一个...

99+

2024-04-02
SpringBoot集成Druid的实例代码

快速开始依赖 <dependency> <groupId>com.alibaba</groupId> ...

99+

2024-04-02
SpringBoot集成redis的示例代码

目录前言一、redis是什么二、集成redis步骤三、代码演示前言 redis想必小伙伴们即使没有用过，也是经常听到的，在工作中，redis用到的频率非常高，今天详细介绍一下Spr...

99+

2024-04-02
SpringBoot集成ElasticSearch的示例代码

目录一、Elasticseach介绍1.简单介绍2.对比关系：3.详细说明：4.查出数据的解释二、SpringBoot集成Elasticseach1.引入依赖2.添加配置...

99+

2024-04-02
springboot集成teams的方法是什么

本篇内容主要讲解“springboot集成teams的方法是什么”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“springboot集成teams的方法是什么”吧!添加依赖<dependen...

99+

2023-06-28
SpringBoot集成Auth0 JWT的示例代码

目录前言session认证与Token认证session认证Token认证JWT简介JWT定义JWT的类库具体实现JWT配置JWT工具类测试接口前言说说JWT，先说下互联网服务常见...

99+

2024-04-02
微软 Windows 11 Build 23481 预览版已移除 Teams Chat 集成

6 月 15 日消息，微软今天面向 Dev 频道的 Windows Insider 项目成员，发布了 Win11 Build 23481 预览版更新，其亮点之一是移除了集成的 Teams Chat 按钮。用户在升级到 Win11 Build...

99+

2023-07-12
SpringBoot集成MyBatis的分页插件PageHelper实例代码

昨天给各位总结了本人学习springboot整合mybatis第一阶段的一些学习心得和源码，主要就算是敲了一下SpringBoot的门儿，希望能给各位的入门带给一点儿捷径，今天给各位温习一下MyBatis的分页插件PageHelper和Sp...

99+

2023-05-31

springboot mybatis pagehelper
Springboot集成ProtoBuf的实例

目录Springboot集成ProtoBuf1、pom.xml引入相关依赖2、新建序列化工具类ProtoBufUtil.java3、新建实体类User.java4、使用方式Proto...

99+

2024-04-02
SpringBoot集成ElasticSearch的代码是什么

这篇“SpringBoot集成ElasticSearch的代码是什么”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Sprin...

99+

2023-06-29
SpringBoot集成Mybatis-plus并实现自动生成相关文件的示例代码

Mybatis-Plus是一个优秀的Mybatis增强工具，目前更新到3.1.1。Mybatis-Plus原生提供了很多单表操作的方法，极大简化了繁琐的curd的操作，同时又支持xm...

99+

2024-04-02
SpringBoot集成drools的实现示例

目录1、背景2、需求3、实现3.1 引入jar包3.2 编写drools配置类3.3 编写Person对象3.4 编写drl文件3.5 编写kmodule.xml文件3.6 编写Co...

99+

2024-04-02
springboot集成camunda的实现示例

目录1、说明2、配置实战3、生成数据库表说明1、说明 camunda使用Java开的工作流引擎。这里使用springboot 2.2.6.release + camunda 3.4...

99+

2024-04-02
Springboot集成minio实现文件存储的实现代码

目录1. 安装部署1.1 Linux 简单部署1.2 Docker 部署2. Spring boot 整合3. 问题记录4. 项目地址在我们平时做项目的时候，文件存储是个很常见的需求...

99+

2024-04-02
SpringBoot集成Redis实现验证码的简单案例

目录一、下载安装Redis二、代码部分总结前言一次学习过程中简单的记录一、下载安装Redis 这里就不多说了，下载安装好Redis，最好是把Redis Desktop Manag...

99+

2024-04-02
SpringBoot集成GraphqlQuery实战示例

目录概述场景模拟开发实战创建一个SpringBoot项目建立Java实体类编写Schema文件编写业务逻辑配置Graphql 端点测试安装插件查询小结概述 REST作为一种现代网络应...

99+

2024-04-02
SpringBoot集成极光推送完整实现代码

目录1.pom.xml2.application.yml3.MyJPushClient4.test工作中经常会遇到服务器向App推送消息的需求，一般企业中选择用极光推送的比较多，在集...

99+

2024-04-02
springcloud集成ribbon负载均衡的实例代码

本文比较简单集成ribbon，如需要更详细，请查看我的更多博客内容。首先创建两个服务提供者服务一，集成的nacos注册中心，这块随便写一个同名接口端口配置8301 服务二...

99+

2024-04-02
SpringBoot 实现微信推送模板的示例代码

导读　　由于最近手头上需要做个Message Gateway，涉及到：邮件(点我直达)、短信、公众号等推送功能，网上学习下，整理下来以备以后使用。添加依赖　　在SpringBo...

99+

2024-04-02
Springboot2.x集成kafka2.2.0的示例代码

目录引言基本环境代码编写1、基本引用pom2、基本配置3、实体类4、生产者端5、消费者6、测试效果展示遇到的问题引言 kafka近几年更新非常快，也可以看出kafka在企业中是用的频...

99+

2024-04-02