devbox
Li_阴宅
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java 飞书机器人消息发送(简单demo)_java飞书机器人发消息

作者：Li_阴宅 | 2024-07-03 06:54:58

赞

踩

java飞书机器人发消息

w引入pom

  1.         <dependency>
  2.             <groupId>com.larksuite.oapi</groupId>
  3.             <artifactId>oapi-sdk</artifactId>
  4.             <version>2.1.3</version>
  5.         </dependency>

controller

  1.  
  2.     public Result<?> sendTextByGroupRobots() {
  3.         feiShuNotifyRequest.sendTextByGroupRobots(FeiShuConfig.WEB_HOOK_URL,"牛爷爷吃饭");
  4.         return Result.OK();
  5.     }
  6.  
  7.  
  8.     public Result<?> sendTextAboutUserByGroupRobots() {
  9.         feiShuNotifyRequest.sendTextAboutUserByGroupRobots(FeiShuConfig.WEB_HOOK_URL,"牛爷爷打游戏","ou_b406xxxxxxxxxxx221630");
  10.         return Result.OK();
  11.     }
  12.  
  13.     public Result<?> sendRichTextByGroupRobots() {
  14.         feiShuNotifyRequest.sendRichTextByGroupRobots(FeiShuConfig.WEB_HOOK_URL,"牛爷爷看电影","https://xxxxxxxxxxxxxxxxxxC0nVg","ou_b4xxxxxxxxxxxxx30");
  15.         return Result.OK();
  16.     }
  17.  
  18.  
  19.     public Result<?> sendMessageToUser() {
  20.         feiShuNotifyRequest.sendMessageToUser("ou_bxxxxxxxxxxxxxxxxxxx30","强壮的牛爷爷下班啦");
  21.         return Result.OK();
  22.     }
  23.  
  24.     public Result<?> sendImage() {
  25.         SendImageRequest request = new SendImageRequest();
  26.         try {
  27.             feiShuNotifyRequest.sendImage(request);
  28.         } catch (Exception e) {
  29.             e.printStackTrace();
  30.         }
  31.         return Result.OK();
  32.     }
  33.  
  34.     public Result<?> sendFile() {
  35.         SendFileRequest request = new SendFileRequest();
  36.         request.setFileType("xlsx");
  37.         request.setFileName("demo.xlsx");
  38.         request.setFile(new File("D:\\demo.xlsx"));
  39.         request.setReceiveIdType("open_id");
  40.         request.setReceiveId("ou_b4xxxxxxxxxxxxxxxxxxxxx1630");
  41.         try {
  42.             feiShuNotifyRequest.sendFile(request);
  43.         } catch (Exception e) {
  44.             e.printStackTrace();
  45.         }
  46.         return Result.OK();
  47.     }
  48.  
  49.  
  50.     public Result<?> sendFilePdf() {
  51.         SendFileRequest request = new SendFileRequest();
  52.         request.setFileType("pdf");
  53.         request.setFileName("高并发解决方案回答.pdf");
  54.         request.setFile(new File("E:\\高并发解决方案回答.pdf"));
  55.         request.setReceiveIdType("open_id");
  56.         request.setReceiveId("ou_b4xxxxxxxxxxxxxxxxxxxx1630");
  57.         try {
  58.             feiShuNotifyRequest.sendFile(request);
  59.         } catch (Exception e) {
  60.             e.printStackTrace();
  61.         }
  62.         return Result.OK();
  63.     }
  1.  
  2.  
  3. /**
  4.  * @author Sherry
  5.  * @description 文本消息
  6.  */
  7. @Data
  8. @Service
  9. public class FeiShuTextNotifyRequest implements FeiShuNotifyRequest {
  10.    private static final Client client = Client.newBuilder(FeiShuConfig.APP_ID, FeiShuConfig.APP_SECRET).build();
  11.  
  12.    @Override
  13.    public void sendTextByGroupRobots(String webhookUrl,String data) {
  14.       //请求的JSON数据，这里用map在工具类里转成json格式
  15.       JSONObject json=new JSONObject();
  16.       JSONObject text=new JSONObject();
  17.       json.put("msg_type", "text");
  18.       text.put("text", "项目告警通知：" + data);
  19.       json.put("content", text);
  20.  
  21.       String result = HttpRequest.post(webhookUrl).body(JSONObject.toJSONString(json), "application/json;charset=UTF-8").execute().body();
  22.       System.out.println(result);
  23.    }
  24.  
  25.    @Override
  26.    public void sendTextAboutUserByGroupRobots(String webhookUrl, String data, String userOpenId) {
  27.       JSONObject json=new JSONObject();
  28.       json.put("msg_type", "text");
  29.       json.put("content",  "{\"text\":\"<at user_id=\\\""+ userOpenId +"\\\"></at> "+data+"\"}");
  30.  
  31.       String result = HttpRequest.post(webhookUrl).body(JSONObject.toJSONString(json), "application/json;charset=UTF-8").execute().body();
  32.    }
  33.  
  34.    @Override
  35.    public void sendRichTextByGroupRobots(String webhookUrl, String data, String href, String userOpenId) {
  36.       RichText richText = new RichText();
  37.       richText.setMsg_type("post");
  38.  
  39.       JSONObject postJson = new JSONObject();
  40.  
  41.       JSONArray content = new JSONArray();
  42.       JSONArray contentArray = new JSONArray();
  43.  
  44.       JSONObject urlJson = new JSONObject();
  45.       urlJson.put("tag", "a");
  46.       urlJson.put("text","请查看");
  47.       urlJson.put("href", href);
  48.       contentArray.add(urlJson);
  49.  
  50.       JSONObject userJson = new JSONObject();
  51.       userJson.put("tag", "at");
  52.       userJson.put("user_id", userOpenId);
  53.       contentArray.add(userJson);
  54.       content.add(contentArray);
  55.  
  56.       HashMap<String, Object> title = new HashMap<>();
  57.  
  58.       JSONObject contentJson = new JSONObject();
  59.       contentJson.put("title", data);
  60.       contentJson.put("content", content);
  61.  
  62.       JSONObject zhCnJson = new JSONObject();
  63.       zhCnJson.put("zh_cn", contentJson);
  64.  
  65.  
  66.       postJson.put("post",zhCnJson);
  67.       richText.setContent(postJson);
  68.       String result = HttpRequest.post(webhookUrl).body(JSONObject.toJSONString(richText), "application/json;charset=UTF-8").execute().body();
  69.    }
  70.  
  71.    @Override
  72.    public void sendMessageToUser(String userOpenId,String message){
  73.          // 创建请求对象
  74.          CreateMessageReq req = CreateMessageReq.newBuilder()
  75.                  .receiveIdType("open_id")
  76.                  .createMessageReqBody(CreateMessageReqBody.newBuilder()
  77.                          .receiveId(userOpenId)
  78.                          .msgType("text")
  79.                          .content("{\"text\":\" "+message+"\"}")
  80.                          .uuid(UUIDGenerator.generate())
  81.                          .build())
  82.                  .build();
  83.          // 发起请求
  84.       CreateMessageResp resp = null;
  85.       try {
  86.          resp = client.im().message().create(req);
  87.       } catch (Exception e) {
  88.          e.printStackTrace();
  89.       }
  90.       // 处理服务端错误
  91.          if(!resp.success()) {
  92.             System.out.println(String.format("code:%s,msg:%s,reqId:%s", resp.getCode(), resp.getMsg(), resp.getRequestId()));
  93.             return;
  94.          }
  95.  
  96.          // 业务数据处理
  97.          System.out.println(Jsons.DEFAULT.toJson(resp.getData()));
  98.  
  99.    }
  100.  
  101.    /**
  102.     * 发送图片消息，使用到两个OpenAPI：
  103.     * 1. [上传图片](<a href="https://open.feishu.cn/document/server-docs/im-v1/image/create">...</a>)
  104.     * 2. [发送消息](<a href="https://open.feishu.cn/document/server-docs/im-v1/message/create">...</a>)
  105.     */
  106.    @Override
  107.    public BaseResponse<?> sendImage(SendImageRequest request) throws Exception {
  108.       request.setImage(new File("C:/Users/jhf/Pictures/Camera Roll/emo.jpg"));
  109.       request.setReceiveIdType("open_id");
  110.       request.setReceiveId("ou_b40xxxxxxxxxxxxxxxxxxxx21630");
  111.  
  112.  
  113.       // 上传图片
  114.       CreateImageReq req = CreateImageReq.newBuilder()
  115.               .createImageReqBody(CreateImageReqBody.newBuilder()
  116.                       .imageType("message")
  117.                       .image(request.getImage())
  118.                       .build())
  119.               .build();
  120.  
  121.       CreateImageResp createImageResp = client.im().image().create(req);
  122.       System.out.println(createImageResp);
  123.       if (!createImageResp.success()) {
  124.          System.out.printf("client.im.image.create failed, code: %d, msg: %s, logId: %s%n",
  125.                  createImageResp.getCode(), createImageResp.getMsg(), createImageResp.getRequestId());
  126.          return createImageResp;
  127.       }
  128.  
  129.       // 发送消息
  130.       CreateMessageReq createMessageReq = CreateMessageReq.newBuilder()
  131.               .receiveIdType(request.getReceiveIdType())
  132.               .createMessageReqBody(CreateMessageReqBody.newBuilder()
  133.                       .receiveId(request.getReceiveId())
  134.                       .msgType("image")
  135.                       .content(Jsons.DEFAULT.toJson(createImageResp.getData()))
  136.                       .uuid(request.getUuid())
  137.                       .build())
  138.               .build();
  139.  
  140.       CreateMessageResp createMessageResp = client.im().message().create(createMessageReq);
  141.       if (!createMessageResp.success()) {
  142.          System.out.printf("client.im.message.create failed, code: %d, msg: %s, logId: %s%n",
  143.                  createMessageResp.getCode(), createMessageResp.getMsg(), createMessageResp.getRequestId());
  144.          return createMessageResp;
  145.       }
  146.  
  147.       // 返回结果
  148.       SendImageResponse response = new SendImageResponse();
  149.       response.setCode(0);
  150.       response.setMsg("success");
  151.       response.setCreateImageResponse(createImageResp.getData());
  152.       response.setCreateMessageResponse(createMessageResp.getData());
  153.  
  154.       return response;
  155.    }
  156.  
  157.    @Override
  158.    public BaseResponse<?> sendFile(SendFileRequest request) throws Exception {
  159.       // 上传文件
  160.       CreateFileReq createFileReq = CreateFileReq.newBuilder()
  161.               .createFileReqBody(CreateFileReqBody.newBuilder()
  162.                       .fileType(request.getFileType())
  163.                       .fileName(request.getFileName())
  164.                       .duration(request.getDuration())
  165.                       .file(request.getFile())
  166.                       .build())
  167.               .build();
  168.  
  169.       CreateFileResp createFileResp = client.im().file().create(createFileReq);
  170.       if (!createFileResp.success()) {
  171.          System.out.printf("client.im.file.create failed, code: %d, msg: %s, logId: %s%n",
  172.                  createFileResp.getCode(), createFileResp.getMsg(), createFileResp.getRequestId());
  173.          return createFileResp;
  174.       }
  175.  
  176.       // 发送消息
  177.       CreateMessageReq createMessageReq = CreateMessageReq.newBuilder()
  178.               .receiveIdType(request.getReceiveIdType())
  179.               .createMessageReqBody(CreateMessageReqBody.newBuilder()
  180.                       .receiveId(request.getReceiveId())
  181.                       .msgType("file")
  182.                       .content(Jsons.DEFAULT.toJson(createFileResp.getData()))
  183.                       .uuid(request.getUuid())
  184.                       .build())
  185.               .build();
  186.  
  187.       CreateMessageResp createMessageResp = client.im().message().create(createMessageReq);
  188.       if (!createMessageResp.success()) {
  189.          System.out.printf("client.im.message.create failed, code: %d, msg: %s, logId: %s%n",
  190.                  createMessageResp.getCode(), createMessageResp.getMsg(), createMessageResp.getRequestId());
  191.          return createMessageResp;
  192.       }
  193.  
  194.       // 返回结果
  195.       SendFileResponse response = new SendFileResponse();
  196.       response.setCode(0);
  197.       response.setMsg("success");
  198.       response.setCreateFileResponse(createFileResp.getData());
  199.       response.setCreateMessageResponse(createMessageResp.getData());
  200.  
  201.       return response;
  202.    }
  203.  
  204.    @Override
  205.    public void sendWarnMessage(String userOpenId, String msgType, String content) throws Exception {
  206.       CreateMessageReq req = CreateMessageReq.newBuilder()
  207.               .receiveIdType("open_id")
  208.               .createMessageReqBody(CreateMessageReqBody.newBuilder()
  209.                       .receiveId(userOpenId)
  210.                       .msgType(msgType)
  211.                       .content(BuildCard())
  212.                       .build())
  213.               .build();
  214.  
  215.       CreateMessageResp resp = client.im().message().create(req);
  216.  
  217.       if (!resp.success()) {
  218.          throw new Exception(String.format("client.im.message.create failed, code: %d, msg: %s, logId: %s",
  219.                  resp.getCode(), resp.getMsg(), resp.getRequestId()));
  220.       }
  221.    }
  222.  
  223.    // 构建卡片
  224.    public static String BuildCard() throws Exception {
  225.  
  226.       // 获取卡片结构
  227.       File jsonFile = new File("E:\\Coding\\xxxxxxxxxxxxxxxxx\\card\\card.json");
  228.       FileReader fileReader = new FileReader(jsonFile);
  229.       Reader reader = new InputStreamReader(new FileInputStream(jsonFile), StandardCharsets.UTF_8);
  230.       int ch = 0;
  231.       StringBuilder sb = new StringBuilder();
  232.       while ((ch = reader.read()) != -1) {
  233.          sb.append((char) ch);
  234.       }
  235.       fileReader.close();
  236.       reader.close();
  237.       String card = sb.toString();
  238.  
  239.  
  240.       return card;
  241.    }
  242.  
  243. }
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Li_阴宅/article/detail/782288
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号