暂存代码

pom.xml

@@ -128,7 +128,11 @@
             <groupId>cn.hutool</groupId>
             <artifactId>hutool-all</artifactId>
         </dependency>
-
+        <!-- 飞书SDK -->
+        <dependency>
+            <groupId>com.larksuite.oapi</groupId>
+            <artifactId>oapi-sdk</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

src/main/java/com/sfa/common/core/enums/ECode.java

@@ -9,6 +9,11 @@ import com.sfa.common.core.constant.StatusCode;
  */
 public enum ECode implements StatusCode {
 
+    /**
+     * 600+ :数据异常（不分模块）
+     */
+    DATA_NULL_ERROR(600, "数据失效或为空；"),
+
     /**
      * 700+ :SQL统一异常（不分模块）
      */
@@ -33,6 +38,7 @@ public enum ECode implements StatusCode {
      */
     KQMX_CURRENTLY_TYPE_KQ_HAS(900, "不可重复打卡；"),
     KQMX_CLOCK_IN_ERRPR(901, "考勤异常；"),
+    FS_CREATE_APPROVAL_ERROR(902, "%s"),
 
 
     /**

src/main/java/com/sfa/common/core/enums/promotion/PlanStatus.java

+package com.sfa.common.core.enums.promotion;
+
+/**
+ * @author : liqiulin
+ * @date : 2025-02-12 17
+ * @describe :
+ */
+public enum PlanStatus {
+    /**
+     * 是否执行：1:执行；0：未执行；
+     */
+    EXECUTION(1, "执行"),
+    NOT_EXECUTION(0, "未执行"),
+    PENDING(2, "审批中"),
+    REJECTED(3, "审批未通过"),
+    WAIT(4, "待审批"),
+    APPROVED(5, "已通过"),
+    ;
+
+    private final Integer code;
+    private final String desc;
+
+    PlanStatus(Integer code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+
+    public static String getDesc(Integer code) {
+        for (PlanStatus planStatus : PlanStatus.values()) {
+            if (planStatus.getCode().equals(code)) {
+                return planStatus.desc;
+            }
+        }
+        return null;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+}

src/main/java/com/sfa/common/core/utils/sdk/FeiShuUtil.java

+package com.sfa.common.core.utils.sdk;
+
+import cn.hutool.http.HttpUtil;
+import cn.hutool.http.Method;
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
+import com.google.gson.JsonParser;
+import com.lark.oapi.Client;
+import com.lark.oapi.core.request.RequestOptions;
+import com.lark.oapi.core.utils.Jsons;
+import com.lark.oapi.okhttp.*;
+import com.lark.oapi.service.approval.v4.model.*;
+import com.lark.oapi.service.authen.v1.model.GetUserInfoResp;
+import com.lark.oapi.service.authen.v1.model.GetUserInfoRespBody;
+import com.lark.oapi.service.contact.v3.enums.ChildrenDepartmentDepartmentIdTypeEnum;
+import com.lark.oapi.service.contact.v3.enums.FindByDepartmentUserDepartmentIdTypeEnum;
+import com.lark.oapi.service.contact.v3.enums.FindByDepartmentUserUserIdTypeEnum;
+import com.lark.oapi.service.contact.v3.model.ChildrenDepartmentReq;
+import com.lark.oapi.service.contact.v3.model.ChildrenDepartmentResp;
+import com.lark.oapi.service.contact.v3.model.FindByDepartmentUserReq;
+import com.lark.oapi.service.contact.v3.model.FindByDepartmentUserResp;
+import com.sfa.common.core.enums.ECode;
+import com.sfa.common.core.exception.ServiceException;
+import com.sfa.common.core.exception.auth.NotLoginException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author : liqiulin
+ * @date : 2024-12-06 16
+ * @describe :
+ */
+@Component
+public class FeiShuUtil {
+    private static final Logger log = LoggerFactory.getLogger(FeiShuUtil.class);
+    @Value("${feishu.luzx.app_id}")
+    private String appId;
+    @Value("${feishu.luzx.app_secret}")
+    private String appSecret;
+
+    @Value("${feishu.bot_1.app_id}")
+    private String botAppId1;
+    @Value("${feishu.bot_1.app_secret}")
+    private String botAppSecret1;
+
+    //飞书获取用户信息，注意值：最后的斜杆
+    @Value("${feishu.redirectUri}")
+    private String redirectUri;
+
+
+    private static final String UTF_8 = "UTF-8";
+    private static final String CONTENT_TYPE = "application/json; charset=utf-8";
+    private static final String SHEET_URL = "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/";
+    private static final String TENANT_ACCESS_TOKEN_URL = "https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal";
+    private static final String VALUES_APPEND = "/values_append";
+    private static final String VALUES_IMAGE = "/values_image";
+    private static final String VALUES_BATCH_GET = "/values_batch_get";
+    private static final String VALUES = "/values";
+    private static final String STYLE = "/style";
+
+
+    /**
+     * 根据用户的登录临时code获取useraccessToken
+     * 应用：链路中心
+     */
+    public String createUserAccessToken(String code) {
+        try {
+            HashMap<String, String> bodyMap = new HashMap<>();
+            bodyMap.put("grant_type", "authorization_code");
+            bodyMap.put("client_id", "cli_a7dbe3ec7d9e5013");
+            bodyMap.put("client_secret", "WxiT7uIJNDbDpEGfVCXEwNNfN1A3RgUo");
+            bodyMap.put("redirect_uri", redirectUri);
+
+            bodyMap.put("code", code);
+
+            OkHttpClient client = new OkHttpClient();
+            RequestBody body = RequestBody.create(MediaType.get("application/json"), JSONObject.toJSONString(bodyMap));
+            Request build = new Request.Builder().url("https://open.feishu.cn/open-apis/authen/v2/oauth/token").addHeader("Content-Type", "application/json; charset=utf-8").post(body).build();
+            Response execute = client.newCall(build).execute();
+            JSONObject rj = JSONObject.parseObject(execute.body().string());
+            if (!rj.containsKey("access_token")){
+                log.error("飞书用户获取失败！",rj.toString());
+                throw new NotLoginException(ECode.FEISHU_ACCESS_TOKEN_ERROR);
+            }
+            return rj.getString("access_token");
+        } catch (Exception e) {
+            throw new NotLoginException(ECode.FEISHU_ACCESS_TOKEN_ERROR);
+        }
+    }
+
+    /**
+     * 根据用户的userAccessToken获取用户信息
+     */
+    public GetUserInfoRespBody getUserInfo(String userAccessToken) {
+        try {
+            Client client = getClientLUZX();
+            GetUserInfoResp resp = client.authen().userInfo().get(RequestOptions.newBuilder()
+                    .userAccessToken(userAccessToken)
+                    .build());
+            if (!resp.success()) {
+                log.error(String.format("code:%s,msg:%s,reqId:%s, resp:%s",
+                        resp.getCode(), resp.getMsg(), resp.getRequestId(), Jsons.createGSON(true, false).toJson(JsonParser.parseString(new String(resp.getRawResponse().getBody(), "UTF-8")))));
+                return null;
+            }
+            return resp.getData();
+        } catch (Exception e) {
+            log.error("获取用户信息失败，停止执行！");
+            return null;
+        }
+    }
+
+
+    /**
+     * 根据部门父编码获取子部门
+     * 公司编码："0"
+     */
+    public JSONArray getDeptByParentId(String parentId) {
+        try {
+            Client client = getClientLUZX();
+            ChildrenDepartmentReq req = ChildrenDepartmentReq.newBuilder()
+                    .departmentId(parentId)
+                    .departmentIdType(ChildrenDepartmentDepartmentIdTypeEnum.DEPARTMENT_ID)
+                    .pageSize(50)
+                    .build();
+            ChildrenDepartmentResp resp = client.contact().department().children(req);
+            if (!resp.success()) {
+                log.error(String.format("%s,code:%s,msg:%s,reqId:%s, resp:%s","根据部门父编码获取子部门失败",
+                        resp.getCode(), resp.getMsg(), resp.getRequestId(), Jsons.createGSON(true, false).toJson(JsonParser.parseString(new String(resp.getRawResponse().getBody(), UTF_8)))));
+                return null;
+            }
+            JSONArray items = JSONObject.parse(Jsons.DEFAULT.toJson(resp.getData())).getJSONArray("items");
+            return items;
+        } catch (Exception e) {
+            log.error("获取子部门列表失败，停止执行！");
+        }
+        return null;
+    }
+
+    /**
+     * 获取部门用户
+     */
+    public JSONArray getUsersByDeptId(String deptCode) {
+        try {
+            Client client = getClientLUZX();
+            FindByDepartmentUserReq req = FindByDepartmentUserReq.newBuilder()
+                    .userIdType(FindByDepartmentUserUserIdTypeEnum.OPEN_ID)
+                    .departmentIdType(FindByDepartmentUserDepartmentIdTypeEnum.DEPARTMENT_ID)
+                    .departmentId(deptCode)
+                    .pageSize(50)
+                    .build();
+            FindByDepartmentUserResp resp = client.contact().user().findByDepartment(req);
+            if(!resp.success()) {
+                log.error(String.format("%s,code:%s,msg:%s,reqId:%s, resp:%s","获取部门用户",
+                        resp.getCode(), resp.getMsg(), resp.getRequestId(), Jsons.createGSON(true, false).toJson(JsonParser.parseString(new String(resp.getRawResponse().getBody(), UTF_8)))));
+                return null;
+            }
+            JSONArray items = JSONObject.parse(Jsons.DEFAULT.toJson(resp.getData())).getJSONArray("items");
+            return items;
+        } catch (Exception e) {
+            log.error("获取部门用户失败，停止执行！部门id：{}", deptCode);
+        }
+        return null;
+    }
+
+    /**
+     * 获取电子表格数据
+     */
+    public JSONArray pullSheet(String sheetToken, String autoToken, String ranges) {
+        try {
+            Map<String, Object> params = new HashMap<>();
+            params.put("ranges", ranges);
+            String result = HttpUtil.createGet(SHEET_URL + sheetToken + VALUES_BATCH_GET).form(params).auth("Bearer " + autoToken).contentType(CONTENT_TYPE).execute().body();
+            JSONObject resultJson = JSONObject.parseObject(result);
+            int code = resultJson.getInteger("code");
+            if (code != 0) {
+                throw new RuntimeException("获取飞书表格范围数据错误："+resultJson.getString("msg"));
+            }
+            return resultJson.getJSONObject("data").getJSONArray("valueRanges");
+        }catch (Exception e) {
+            log.error("拉取表格数据失败，停止执行！", e);
+        }
+        return new JSONArray();
+    }
+
+    /**
+     * 写入电子表格数据
+     */
+    public Integer pushSetToSheet(String range, List<Object> datas, String sheetToken, String autoToken) {
+        // 组装参数
+        Map<String, Map<String, Object>> bodyMap = new HashMap<>();
+        Map<String, Object> valueRange = new HashMap<>();
+        valueRange.put("range", range);
+        valueRange.put("values", datas);
+        bodyMap.put("valueRange", valueRange);
+        String bodyJson = JSONObject.toJSONString(bodyMap);
+
+        // body上传
+        String result = HttpUtil.createPost(SHEET_URL + sheetToken + VALUES_APPEND)
+                .auth("Bearer " + autoToken).contentType(CONTENT_TYPE)
+                .body(bodyJson)
+                .execute().body();
+
+        // 上传结果判断
+        JSONObject resultJson = JSONObject.parseObject(result);
+        return resultJson.getInteger("code");
+    }
+
+    /**
+     * 创建审批
+     */
+    public String createApproval(Map<String,Object> approval) {
+        try {
+            Client client = getClientLUZX();
+            CreateInstanceReq req = CreateInstanceReq.newBuilder()
+                    .instanceCreate(InstanceCreate.newBuilder()
+                            .approvalCode(approval.get("approval_code").toString())
+                            .form(JSONObject.toJSONString(approval.get("form")))
+                            .userId(approval.get("user_id").toString())
+                            .allowResubmit(Boolean.getBoolean(approval.get("allow_resubmit").toString()))
+                            .allowSubmitAgain(Boolean.getBoolean(approval.get("allow_submit_again").toString()))
+                            .build()
+                    ).build();
+            CreateInstanceResp resp = client.approval().v4().instance().create(req);
+            if(!resp.success()) {
+                throw new RuntimeException(String.format("%s,code:%s,msg:%s,reqId:%s, resp:%s","创建飞书审批失败",
+                        resp.getCode(), resp.getMsg(), resp.getRequestId(), Jsons.createGSON(true, false).toJson(JsonParser.parseString(new String(resp.getRawResponse().getBody(), UTF_8)))));
+            }
+            return JSONObject.parseObject(JSONObject.toJSONString(resp.getData())).getString("instance_code");
+        }catch (Exception e) {
+            throw new ServiceException(String.format(ECode.FS_CREATE_APPROVAL_ERROR.getMsg(),e.getMessage()), ECode.FS_CREATE_APPROVAL_ERROR.getCode());
+        }
+    }
+
+    public String getApprovalInfo(String approvalCode){
+        try {
+            Client client = getClientLUZX();
+            GetInstanceReq req = GetInstanceReq.newBuilder().instanceId(approvalCode).build();
+            GetInstanceResp resp = client.approval().v4().instance().get(req);
+            // 处理服务端错误
+            if(!resp.success()) {
+                throw new RuntimeException(String.format("%s,code:%s,msg:%s,reqId:%s, resp:%s","创建飞书审批失败",
+                        resp.getCode(), resp.getMsg(), resp.getRequestId(), Jsons.createGSON(true, false).toJson(JsonParser.parseString(new String(resp.getRawResponse().getBody(), UTF_8)))));
+            }
+            return JSONObject.toJSONString(resp.getData());
+        }catch (Exception e){
+            log.error(e.getMessage());
+            return null;
+        }
+    }
+
+    /**
+     * 创建飞书客户端
+     * 应用：王小卤链路中心
+     */
+    public Client getClientLUZX() {
+        return Client.newBuilder(appId, appSecret).build();
+    }
+
+    /**
+     * 创建飞书客户端
+     * 应用：飞书表格更新机器人_T1
+     */
+    public String getBotToken1() {
+        Map<String, Object> bodyMap = new HashMap<>();
+        bodyMap.put("app_id", botAppId1);
+        bodyMap.put("app_secret", botAppSecret1);
+        String bodyJson = JSONObject.toJSONString(bodyMap);
+
+        String result = HttpUtil.createPost(TENANT_ACCESS_TOKEN_URL)
+                .contentType(CONTENT_TYPE)
+                .body(bodyJson)
+                .execute().body();
+
+        JSONObject resultJson = JSONObject.parseObject(result);
+        int code = resultJson.getInteger("code");
+        if (code != 0) {
+            throw new RuntimeException("获取tenant_access_token错误");
+        }
+        return resultJson.getString("tenant_access_token");
+    }
+
+    public void appendStyle(String sheetToken, Map<String, Object> body,String autoToken) {
+        // body上传
+        String result = HttpUtil.createRequest(Method.PUT,SHEET_URL + sheetToken + STYLE)
+                .auth("Bearer " + autoToken).contentType(CONTENT_TYPE)
+                .body(JSONObject.toJSONString(body))
+                .execute().body();
+    }
+
+    public JSONObject pullSheetOneRange(String sheetToken, String botToken1, String ranges) {
+        return pullSheet(sheetToken, botToken1, ranges).getJSONObject(0);
+    }
+}