增加站点同步至飞书表格

jeecg-boot/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FastJsonUtil.java

@@ -0,0 +1,222 @@
+/**
+ *
+ */
+package org.jeecg.common.util;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+
+import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+public class FastJsonUtil {
+
+    /**
+     * 对单个JavaBean对象的解析
+     * @param jsonString 表示JSON数据的字符串
+     * @param clazz JavaBean 类型
+     * @return
+     */
+    public static <T> T parseObject(String jsonString, Class<T> clazz) {
+        T t = null;
+        try {
+            t = JSON.parseObject(jsonString, clazz);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return t;
+    }
+
+    public static <T> T parseObjectEnquiry(String jsonString, Class<T> clazz) {
+        T t = null;
+        try {
+            t = JSON.parseObject(jsonString, clazz);
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw e;
+        }
+        return t;
+    }
+
+    /**
+     * 对单个JavaBean对象的解析
+     * @param jsonString 表示JSON数据的字符串
+     * @param type JavaBean 类型
+     * @return
+     */
+    public static <T> T parseObject(String jsonString, Type type) {
+        T t = null;
+        try {
+            t = JSON.parseObject(jsonString, type);
+        } catch (Exception e) {
+            // TODO: handle exception
+            e.printStackTrace();
+        }
+        return t;
+    }
+
+    /**
+     * 对单个JavaBean对象的解析
+     * @param jsonString 表示JSON数据的字符串
+     * @return
+     */
+    public static <T> T parseObject(String jsonString, TypeReference<T> typeReference) {
+        T t = null;
+        try {
+            t = JSON.parseObject(jsonString, typeReference);
+        } catch (Exception e) {
+            // TODO: handle exception
+            e.printStackTrace();
+        }
+        return t;
+    }
+
+    /**
+     * 对单个JavaBean对象的解析
+     * @param jsonString 表示JSON数据的字符串
+     * @param clazz JavaBean 类型
+     * @return
+     */
+    public static <T> List<T> parseList(String jsonString, Class<T> clazz) {
+        List<T> tList = new ArrayList<T>();
+        try {
+            tList = JSON.parseArray(jsonString, clazz);
+        } catch (Exception e) {
+            // TODO: handle exception
+            throw e;
+        }
+        return tList;
+    }
+
+    /**
+     * 从表示集合元素的JSON字符串中获取指定类型的第一个元素对象
+     * @param jsonString 集合元素的JSON字符串
+     * @param clazz 指定类型
+     * @return
+     */
+    public static <T> T parseFirstFromJsonList(String jsonString, Class<T> clazz) {
+        T t = null;
+        try {
+            List<T> tempList = FastJsonUtil.parseList(jsonString, clazz);
+            if (null != tempList && tempList.size() > 0) {
+                t = tempList.get(0);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            // TODO: handle exception
+        }
+        return t;
+    }
+
+    /**
+     * 将对象转换为JSON字符串
+     * @param object 待转换对象
+     * @return
+     */
+    public static String toJSONString(Object object) {
+        String jsonString = "";
+        try {
+            jsonString = JSON.toJSONString(object);
+        } catch (Exception e) {
+            // TODO: handle exception
+            e.printStackTrace();
+        }
+        return jsonString;
+    }
+
+    /**
+     * 将对象转换为JSON字符串
+     * @param object 待转换对象
+     * @return
+     */
+    public static String toJSONString(Object object, SerializerFeature... features) {
+        String jsonString = "";
+        try {
+            jsonString = JSON.toJSONString(object, features);
+        } catch (Exception e) {
+            // TODO: handle exception
+            e.printStackTrace();
+        }
+        return jsonString;
+    }
+
+    /**
+     * 将对象转换为JSONObject对象
+     * @param object 待转换对象
+     * @return
+     */
+    public static JSONObject toJSON(Object object) {
+        JSONObject jsonObj = null;
+        try {
+            jsonObj = (JSONObject) JSON.toJSON(object);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return jsonObj;
+    }
+
+    /**
+     * 将对象转换为JSONArray对象
+     * @param object 待转换对象
+     * @return
+     */
+    public static JSONArray toJSONArray(Object object) {
+        JSONArray jsonArray = null;
+        try {
+            jsonArray = (JSONArray) JSON.toJSON(object);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return jsonArray;
+    }
+
+    /**
+     * JSON空值处理
+     * @param object
+     * @return
+     */
+    public static String toJsonArrayForNull(Object object) {
+        return toJSONString(object, SerializerFeature.WriteNullStringAsEmpty, SerializerFeature.WriteNullNumberAsZero);
+    }
+
+    /**
+     *
+     * @param list 原集合
+     * @param clazz 类
+     * @author 汤星鹏
+     * @Description 父子类复制对象
+     * @return java.util.List<T>
+     * @date 2019/11/11 14:10
+     */
+    public static <T> List<T> copyProperties(List list, Class<T> clazz) {
+        String toString = toJSONString(list);
+        return parseList(toString, clazz);
+    }
+
+    /**
+     *
+     * @param clazz
+     * @author 汤星鹏
+     * @Description 复制属性
+     * @return T
+     * @date 2020/3/10 16:46
+     */
+    public static <T> T copyProperty(Object o, Class<T> clazz) {
+        String strJson = toJSONString(o);
+        return parseObject(strJson, clazz);
+    }
+
+    /**
+     * 将对象转成map
+     * @param o
+     * @return
+     */
+    public static Map toMap(Object o) {
+        return copyProperty(o, Map.class);
+    }
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/controller/ShopApiController.java

@@ -1,18 +1,24 @@
 package org.jeecg.modules.okki.site.controller;
 
+import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpHeaders;
 import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.util.FastJsonUtil;
+import org.jeecg.modules.okki.site.dto.FeiShuRecordSheetDto;
 import org.jeecg.modules.okki.site.entity.OkkiSite;
 import org.jeecg.modules.okki.site.param.ChangeSiteStatusParam;
 import org.jeecg.modules.okki.site.param.OkkiSiteParam;
+import org.jeecg.modules.okki.site.service.IFeiShuSheetService;
 import org.jeecg.modules.okki.site.service.IOkkiSiteService;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+
 /**
  * @Description: 站点
  * @Author: Jack
- * @Date:   2024-04-29
+ * @Date: 2024-04-29
  * @Version: V1.0
  */
 @RestController
@@ -23,6 +29,9 @@ public class ShopApiController {
     @Autowired
     private IOkkiSiteService okkiSiteService;
 
+    @Autowired
+    private IFeiShuSheetService feiShuSheetService;
+
     @PostMapping(value = "/add")
     public Result<String> add(@RequestBody OkkiSiteParam okkiSiteParam, @RequestHeader(HttpHeaders.AUTHORIZATION) String authorization) {
         log.info("请求参数 param" + okkiSiteParam.toString() + "authorization" + authorization);
@@ -35,7 +44,7 @@ public class ShopApiController {
         log.info("请求成功，返回结果" + result);
         if (result) {
             return Result.OK("添加成功！");
-        }else {
+        } else {
             return Result.error("添加失败！");
         }
     }
@@ -51,7 +60,7 @@ public class ShopApiController {
         log.info("请求成功，返回结果" + result);
         if (result) {
             return Result.OK("编辑成功！");
-        }else {
+        } else {
             return Result.error("编辑失败！");
         }
     }
@@ -67,8 +76,27 @@ public class ShopApiController {
         log.info("请求成功，返回结果" + result);
         if (result == true) {
             return Result.OK("编辑成功！");
-        }else {
+        } else {
             return Result.error("编辑失败！");
         }
     }
+
+    /**
+     * 更新飞书表格：建站顾问、组建站专员和组资料员字段
+     *
+     * @param recordSheetDto
+     * @param authorization
+     * @return
+     */
+    @PostMapping(value = "/feishu/update/table/record")
+    public Result<?> feiShuUpdateTableRecord(FeiShuRecordSheetDto recordSheetDto, @RequestHeader(HttpHeaders.AUTHORIZATION) String authorization) {
+        log.info("请求参数 recordSheetDto:{}", FastJsonUtil.toJSONString(recordSheetDto));
+        log.info("请求参数 authorization:{}", authorization);
+        String Authorization = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6ImRlYW4iLCJleHAiOjE3MTQ0NjU5Njl9.QdCBYR8mioXcKGi1n5RdMQ5RbJHCSGbE8dkdwYuOXh4";
+        if (!authorization.equals(Authorization)) {
+            return Result.error("sign 验证不通过");
+        }
+        boolean res = feiShuSheetService.updateFeiShuTableSheetField(recordSheetDto);
+        return Result.ok(res);
+    }
 }

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/dto/FeiShuRecordSheetDto.java

@@ -0,0 +1,29 @@
+package org.jeecg.modules.okki.site.dto;
+
+import lombok.Data;
+
+/**
+ * @author Chen
+ */
+@Data
+public class FeiShuRecordSheetDto {
+    /**
+     * 记录id
+     */
+    private String recordId;
+
+    /**
+     * 站点id
+     */
+    private String siteId;
+
+    /**
+     * 建站小组名称
+     */
+    private String groupName;
+
+    /**
+     * 客户名称
+     */
+    private String customerName;
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/IFeiShuCommonService.java

@@ -0,0 +1,148 @@
+package org.jeecg.modules.okki.site.service;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.lark.oapi.Client;
+import com.lark.oapi.core.utils.Jsons;
+import com.lark.oapi.service.bitable.v1.model.AppTableRecord;
+import com.lark.oapi.service.bitable.v1.model.ListAppTableRecordReq;
+import com.lark.oapi.service.bitable.v1.model.ListAppTableRecordResp;
+import com.lark.oapi.service.bitable.v1.model.ListAppTableRecordRespBody;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.FastJsonUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * @author Chen
+ */
+@Slf4j
+@Service
+public class IFeiShuCommonService {
+
+    public static String APP_ID = "cli_a61c977059f01013";
+
+    public static String APP_SECRET = "saNlFj2YdMXZ0uEAucyRodfSEp5ZHikR";
+
+    public static String APP_TOKEN = "X16RbjCVCasCmds7fn0c0k21nju";
+
+    /**
+     * prod：项目分组ID
+     */
+    public static String PROJECT_TEAM_TABLE_ID = "tblzjztd3MnAAkGx";
+
+    /*
+      dev：项目分组ID
+     */
+//    public static String PROJECT_TEAM_TABLE_ID = "tblSkc8HfEYDL99U";
+
+    /**
+     * @param groupName
+     */
+    public Map<String, List<JSONObject>> getFeiShuTeamSheet(String groupName) {
+        List<Map<String, Object>> mapList = new ArrayList<>();
+        Client client = Client.newBuilder(APP_ID, APP_SECRET).build();
+
+        // 创建请求对象
+        ListAppTableRecordReq listAppTableRecordReq = ListAppTableRecordReq.newBuilder()
+                .appToken(APP_TOKEN).tableId(PROJECT_TEAM_TABLE_ID).build();
+
+        // 发起请求
+        ListAppTableRecordResp resp = null;
+        try {
+            resp = client.bitable().appTableRecord().list(listAppTableRecordReq);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+        // 处理服务端错误
+        if (!resp.success()) {
+            System.out.println(String.format("code:%s,msg:%s,reqId:%s", resp.getCode(), resp.getMsg(), resp.getRequestId()));
+        }
+
+        if (resp.success()) {
+            ListAppTableRecordRespBody recordRespBody = resp.getData();
+            AppTableRecord[] items = recordRespBody.getItems();
+            for (AppTableRecord item : items) {
+                mapList.add(item.getFields());
+            }
+        }
+
+        // 业务数据处理
+        System.out.println(Jsons.DEFAULT.toJson(resp.getData()));
+        log.info("mapList:{}", FastJsonUtil.toJSONString(mapList));
+
+        String jsonData = FastJsonUtil.toJSONString(mapList);
+        JSONArray jsonArray = JSON.parseArray(jsonData);
+        Map<String, List<JSONObject>> targetGroupData = new HashMap<>();
+        List<String> targetGroups = new ArrayList<>();
+        targetGroups.add(groupName);
+        targetGroups.add("UI设计");
+        targetGroups.add("质检组");
+        targetGroups.add("项目管理");
+        for (int i = 0; i < jsonArray.size(); i++) {
+            JSONObject jsonObject = jsonArray.getJSONObject(i);
+            String groupNameData = jsonObject.getString("组名");
+            if (targetGroups.contains(groupNameData)) {
+                if (!targetGroupData.containsKey(groupNameData)) {
+                    targetGroupData.put(groupNameData, new ArrayList<>());
+                }
+                targetGroupData.get(groupNameData).add(jsonObject);
+            }
+        }
+
+        log.info("targetGroupData:{}", FastJsonUtil.toJSONString(targetGroupData));
+        return targetGroupData;
+    }
+
+    public static Map<String, Object> convertMap(Map<String, List<String>> sourceMap) {
+        Map<String, Object> targetMap = new HashMap<>();
+
+        for (Map.Entry<String, List<String>> entry : sourceMap.entrySet()) {
+            String key = entry.getKey();
+            List<String> stringList = entry.getValue();
+
+            // 将 List<String> 转换为 List<Object>
+            List<Object> objectList = new ArrayList<>(stringList);
+
+            targetMap.put(key, objectList);
+        }
+
+        return targetMap;
+    }
+
+    /**
+     * @param sourceMap
+     * @return
+     */
+    public Map<String, List<Map<String, Object>>> convertMapList(Map<String, List<String>> sourceMap) {
+        // 创建结果数据的 Map
+        Map<String, List<Map<String, Object>>> resultData = new HashMap<>();
+
+        // 遍历原始数据
+        for (Map.Entry<String, List<String>> entry : sourceMap.entrySet()) {
+            String role = entry.getKey();
+            List<String> ids = entry.getValue();
+            List<Map<String, Object>> newArray = new ArrayList<>();
+
+            // 将每个 ID 转换为 {"id": "id_value"} 的格式
+            for (String id : ids) {
+                Map<String, Object> idObject = new HashMap<>();
+                idObject.put("id", id);
+                newArray.add(idObject);
+            }
+
+            // 将转换后的列表添加到结果数据中
+            resultData.put(role, newArray);
+        }
+
+        return resultData;
+    }
+
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/IFeiShuMsgService.java

@@ -0,0 +1,26 @@
+package org.jeecg.modules.okki.site.service;
+
+/**
+ * @author Chen
+ */
+public interface IFeiShuMsgService {
+
+    /**
+     * 发送同步-飞书消息
+     *
+     * @param customerName
+     * @param siteId
+     * @param planName
+     * @param syncStatus
+     */
+    public void sendSyncFeiShuSheetMsg(String customerName, String siteId, String planName, String syncStatus);
+
+    /**
+     * 发送更新-飞书消息
+     * @param customerName
+     * @param siteId
+     * @param groupName
+     * @param syncStatus
+     */
+    public void sendUpdateFeiShuSheetMsg(String customerName, String siteId, String groupName, String syncStatus);
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/IFeiShuSheetService.java

@@ -0,0 +1,27 @@
+package org.jeecg.modules.okki.site.service;
+
+import org.jeecg.modules.okki.site.dto.FeiShuRecordSheetDto;
+import org.jeecg.modules.okki.site.entity.OkkiSite;
+
+
+/**
+ * @author Chen
+ */
+public interface IFeiShuSheetService {
+
+    /**
+     * 同步信息至飞书表格
+     *
+     * @return
+     */
+    public void syncWebsiteToFeiShuSheet(OkkiSite okkiSite);
+
+
+    /**
+     * 更新飞书表格
+     *
+     * @param recordSheetDto
+     * @return
+     */
+    public boolean updateFeiShuTableSheetField(FeiShuRecordSheetDto recordSheetDto);
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/IOkkiSiteService.java

@@ -5,6 +5,9 @@ import org.jeecg.modules.okki.site.entity.OkkiSite;
 import org.jeecg.modules.okki.site.param.ChangeSiteStatusParam;
 import org.jeecg.modules.okki.site.param.OkkiSiteParam;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * @Description: 站点
  * @Author: jeecg-boot
@@ -20,10 +23,4 @@ public interface IOkkiSiteService extends IService<OkkiSite> {
     boolean okkiChangeStatus(ChangeSiteStatusParam param);
 
     boolean insertSite(OkkiSiteParam okkiSiteParam);
-
-    /**
-     * 同步信息至飞书表格
-     * @return
-     */
-    public void syncWebsiteToFeiShuSheet(OkkiSite okkiSite);
 }

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/impl/FeiShuMsgServiceImpl.java

@@ -0,0 +1,280 @@
+package org.jeecg.modules.okki.site.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.HttpClientUtil;
+import org.jeecg.modules.okki.site.service.IFeiShuMsgService;
+import org.springframework.stereotype.Service;
+
+
+/**
+ * @author Chen
+ */
+@Slf4j
+@Service
+public class FeiShuMsgServiceImpl implements IFeiShuMsgService {
+
+    /**
+     * 发送飞书消息
+     *
+     * @param customerName
+     * @param siteId
+     * @param planName
+     * @param syncStatus
+     */
+    public void sendSyncFeiShuSheetMsg(String customerName, String siteId, String planName, String syncStatus) {
+        String botUrl = "https://open.feishu.cn/open-apis/bot/v2/hook/f77f9317-5f15-4aa7-8036-32ce771f40c1";
+
+        String template = "{\n" +
+                "    \"config\": {\n" +
+                "        \"update_multi\": true\n" +
+                "    },\n" +
+                "    \"i18n_elements\": {\n" +
+                "        \"zh_cn\": [\n" +
+                "            {\n" +
+                "                \"tag\": \"markdown\",\n" +
+                "                \"content\": \"<at id=\\\"all\\\">所有人</at> \",\n" +
+                "                \"text_align\": \"left\",\n" +
+                "                \"text_size\": \"normal\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"column_set\",\n" +
+                "                \"flex_mode\": \"none\",\n" +
+                "                \"background_style\": \"default\",\n" +
+                "                \"horizontal_spacing\": \"8px\",\n" +
+                "                \"horizontal_align\": \"left\",\n" +
+                "                \"columns\": [\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"vertical_align\": \"top\",\n" +
+                "                        \"vertical_spacing\": \"8px\",\n" +
+                "                        \"background_style\": \"default\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**公司名称：**\\n${customerName}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            },\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**套餐名称：**\\n${planName}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"weight\": 1\n" +
+                "                    },\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"vertical_align\": \"top\",\n" +
+                "                        \"vertical_spacing\": \"8px\",\n" +
+                "                        \"background_style\": \"default\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**站点ID：**\\n${siteId}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            },\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**同步状态：**\\n${syncStatus}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"weight\": 1\n" +
+                "                    }\n" +
+                "                ],\n" +
+                "                \"margin\": \"16px 0px 0px 0px\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"hr\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"column_set\",\n" +
+                "                \"flex_mode\": \"none\",\n" +
+                "                \"horizontal_spacing\": \"default\",\n" +
+                "                \"background_style\": \"default\",\n" +
+                "                \"columns\": [\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"div\",\n" +
+                "                                \"text\": {\n" +
+                "                                    \"tag\": \"plain_text\",\n" +
+                "                                    \"content\": \"来自 OK项目组-文档机器人\",\n" +
+                "                                    \"text_size\": \"normal\",\n" +
+                "                                    \"text_align\": \"left\",\n" +
+                "                                    \"text_color\": \"default\"\n" +
+                "                                }\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"weight\": 1\n" +
+                "                    }\n" +
+                "                ]\n" +
+                "            }\n" +
+                "        ]\n" +
+                "    },\n" +
+                "    \"i18n_header\": {\n" +
+                "        \"zh_cn\": {\n" +
+                "            \"title\": {\n" +
+                "                \"tag\": \"plain_text\",\n" +
+                "                \"content\": \"【站点同步】OMS平台同步站点至飞书表格通知\"\n" +
+                "            },\n" +
+                "            \"subtitle\": {\n" +
+                "                \"tag\": \"plain_text\",\n" +
+                "                \"content\": \"\"\n" +
+                "            },\n" +
+                "            \"template\": \"green\"\n" +
+                "        }\n" +
+                "    }\n" +
+                "}";
+        template = template.replace("${customerName}", customerName);
+        template = template.replace("${siteId}", siteId);
+        template = template.replace("${planName}", planName);
+        template = template.replace("${syncStatus}", syncStatus);
+
+        JSONObject object = new JSONObject();
+        object.put("msg_type", "interactive");
+        object.put("card", template);
+        HttpClientUtil.doPostJson(botUrl, object.toJSONString());
+    }
+
+    /**
+     *
+     * @param customerName
+     * @param siteId
+     * @param planName
+     * @param status
+     */
+    public void sendUpdateFeiShuSheetMsg(String customerName, String siteId, String groupName, String status) {
+        String botUrl = "https://open.feishu.cn/open-apis/bot/v2/hook/f77f9317-5f15-4aa7-8036-32ce771f40c1";
+
+        String template = "{\n" +
+                "    \"config\": {\n" +
+                "        \"update_multi\": true\n" +
+                "    },\n" +
+                "    \"i18n_elements\": {\n" +
+                "        \"zh_cn\": [\n" +
+                "            {\n" +
+                "                \"tag\": \"markdown\",\n" +
+                "                \"content\": \"<at id=\\\"all\\\">所有人</at> \",\n" +
+                "                \"text_align\": \"left\",\n" +
+                "                \"text_size\": \"normal\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"column_set\",\n" +
+                "                \"flex_mode\": \"none\",\n" +
+                "                \"background_style\": \"default\",\n" +
+                "                \"horizontal_spacing\": \"8px\",\n" +
+                "                \"horizontal_align\": \"left\",\n" +
+                "                \"columns\": [\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"vertical_align\": \"top\",\n" +
+                "                        \"vertical_spacing\": \"8px\",\n" +
+                "                        \"background_style\": \"default\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**公司名称：**\\n${customerName}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            },\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**建站小组：**\\n${groupName}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"weight\": 1\n" +
+                "                    },\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"vertical_align\": \"top\",\n" +
+                "                        \"vertical_spacing\": \"8px\",\n" +
+                "                        \"background_style\": \"default\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**站点ID：**\\n${siteId}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            },\n" +
+                "                            {\n" +
+                "                                \"tag\": \"markdown\",\n" +
+                "                                \"content\": \"**更新状态：**\\n${status}\",\n" +
+                "                                \"text_align\": \"left\",\n" +
+                "                                \"text_size\": \"normal\"\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"weight\": 1\n" +
+                "                    }\n" +
+                "                ],\n" +
+                "                \"margin\": \"16px 0px 0px 0px\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"hr\"\n" +
+                "            },\n" +
+                "            {\n" +
+                "                \"tag\": \"column_set\",\n" +
+                "                \"flex_mode\": \"none\",\n" +
+                "                \"horizontal_spacing\": \"default\",\n" +
+                "                \"background_style\": \"default\",\n" +
+                "                \"columns\": [\n" +
+                "                    {\n" +
+                "                        \"tag\": \"column\",\n" +
+                "                        \"elements\": [\n" +
+                "                            {\n" +
+                "                                \"tag\": \"div\",\n" +
+                "                                \"text\": {\n" +
+                "                                    \"tag\": \"plain_text\",\n" +
+                "                                    \"content\": \"来自 OK项目组-文档机器人\",\n" +
+                "                                    \"text_size\": \"normal\",\n" +
+                "                                    \"text_align\": \"left\",\n" +
+                "                                    \"text_color\": \"default\"\n" +
+                "                                }\n" +
+                "                            }\n" +
+                "                        ],\n" +
+                "                        \"width\": \"weighted\",\n" +
+                "                        \"weight\": 1\n" +
+                "                    }\n" +
+                "                ]\n" +
+                "            }\n" +
+                "        ]\n" +
+                "    },\n" +
+                "    \"i18n_header\": {\n" +
+                "        \"zh_cn\": {\n" +
+                "            \"title\": {\n" +
+                "                \"tag\": \"plain_text\",\n" +
+                "                \"content\": \"${title}\"\n" +
+                "            },\n" +
+                "            \"subtitle\": {\n" +
+                "                \"tag\": \"plain_text\",\n" +
+                "                \"content\": \"\"\n" +
+                "            },\n" +
+                "            \"template\": \"green\"\n" +
+                "        }\n" +
+                "    }\n" +
+                "}";
+        template = template.replace("${title}", "【"+customerName+"】分配建站小组通知");
+        template = template.replace("${customerName}", customerName);
+        template = template.replace("${siteId}", siteId);
+        template = template.replace("${groupName}", groupName);
+        template = template.replace("${status}", status);
+
+        JSONObject object = new JSONObject();
+        object.put("msg_type", "interactive");
+        object.put("card", template);
+        HttpClientUtil.doPostJson(botUrl, object.toJSONString());
+    }
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/impl/FeiShuSheetServiceImpl.java

@@ -0,0 +1,269 @@
+package org.jeecg.modules.okki.site.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.lark.oapi.Client;
+import com.lark.oapi.core.utils.Jsons;
+import com.lark.oapi.service.bitable.v1.model.*;
+import com.lark.oapi.service.im.v1.model.*;
+import lombok.extern.slf4j.Slf4j;
+import org.checkerframework.checker.units.qual.A;
+import org.jeecg.common.util.FastJsonUtil;
+import org.jeecg.modules.okki.account.entity.OkkiAccount;
+import org.jeecg.modules.okki.account.service.IOkkiAccountService;
+import org.jeecg.modules.okki.site.dto.FeiShuRecordSheetDto;
+import org.jeecg.modules.okki.site.entity.OkkiSite;
+import org.jeecg.modules.okki.site.service.IFeiShuCommonService;
+import org.jeecg.modules.okki.site.service.IFeiShuMsgService;
+import org.jeecg.modules.okki.site.service.IFeiShuSheetService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author Chen
+ */
+@Slf4j
+@Service
+public class FeiShuSheetServiceImpl implements IFeiShuSheetService {
+
+    @Autowired
+    private IFeiShuMsgService feiShuMsgService;
+
+    @Autowired
+    private IFeiShuCommonService feiShuCommonService;
+
+    @Autowired
+    private IOkkiAccountService okkiAccountService;
+
+    public static String APP_ID = "cli_a61c977059f01013";
+
+    public static String APP_SECRET = "saNlFj2YdMXZ0uEAucyRodfSEp5ZHikR";
+
+    public static String APP_TOKEN = "X16RbjCVCasCmds7fn0c0k21nju";
+
+    /*
+      prod：客服团队表格ID
+     */
+    public static String KF_TABLE_ID = "tblSkc8HfEYDL99U";
+
+    /*
+     * dev：客服团队表格ID
+     */
+//    public static String KF_TABLE_ID = "tblqGDRNN9cDgCJm";
+
+
+    /**
+     * 同步站点信息到飞书表格
+     */
+    @Override
+    public void syncWebsiteToFeiShuSheet(OkkiSite okkiSite) {
+        Client client = Client.newBuilder(APP_ID, APP_SECRET).build();
+
+        Map<String, Object> map = new HashMap<>();
+        map.put("公司名称", okkiSite.getCompanyName());
+        map.put("网站ID", Integer.valueOf(okkiSite.getSiteId()));
+        map.put("服务套餐", okkiSite.getTcName());
+        map.put("状态", "正常");
+        CreateAppTableRecordReq req = CreateAppTableRecordReq.newBuilder().appToken(APP_TOKEN).tableId(KF_TABLE_ID)
+                .appTableRecord(AppTableRecord.newBuilder()
+                        .fields(map)
+                        .build())
+                .build();
+
+        // 发起请求
+        CreateAppTableRecordResp resp = null;
+        try {
+            resp = client.bitable().v1().appTableRecord().create(req);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+            throw new RuntimeException(e);
+        }
+
+        String syncStatus = "成功";
+        if (!resp.success()) {
+            log.error("执行 **** syncWebsiteToFeiShuSheet **** 同步站点信息到飞书表格 失败:{}", String.format("code:%s,msg:%s,reqId:%s", resp.getCode(), resp.getMsg(), resp.getRequestId()));
+            syncStatus = "失败";
+        }
+
+        feiShuMsgService.sendSyncFeiShuSheetMsg(okkiSite.getCompanyName(), okkiSite.getSiteId(), okkiSite.getTcName(), syncStatus);
+    }
+
+    /**
+     * 更新飞书表格
+     *
+     * @param recordSheetDto
+     */
+    @Override
+    public boolean updateFeiShuTableSheetField(FeiShuRecordSheetDto recordSheetDto) {
+        Map<String, List<JSONObject>> teamSheetMap = feiShuCommonService.getFeiShuTeamSheet(recordSheetDto.getGroupName());
+        log.info("teamSheetMap:{}", FastJsonUtil.toJSONString(teamSheetMap));
+
+        List<JSONObject> jzGroups = teamSheetMap.get(recordSheetDto.getGroupName());
+        log.info("jzGroups: {}", FastJsonUtil.toJSONString(jzGroups));
+
+        Map<String, List<String>> roleToIds = new HashMap<>();
+        roleToIds.put("项目顾问", new ArrayList<>());
+        roleToIds.put("建站专员", new ArrayList<>());
+        roleToIds.put("资料专员", new ArrayList<>());
+
+        for (JSONObject jsonObject : jzGroups) {
+            String role = jsonObject.getString("角色");
+            JSONArray personnelArray = jsonObject.getJSONArray("人员");
+            if (personnelArray != null) {
+                for (int i = 0; i < personnelArray.size(); i++) {
+                    JSONObject person = personnelArray.getJSONObject(i);
+                    String id = person.getString("id");
+                    if (id != null && !id.isEmpty()) {
+                        roleToIds.get(role).add(id);
+                    }
+                }
+            }
+        }
+
+        Map<String, List<Map<String, Object>>> formattedRoleToIds = feiShuCommonService.convertMapList(roleToIds);
+        log.info("formattedRoleToIds: {}", FastJsonUtil.toJSONString(formattedRoleToIds));
+
+        Map<String, Object> updateMap = new HashMap<>();
+        updateMap.put("建站顾问", formattedRoleToIds.get("项目顾问"));
+        updateMap.put("组建站专员", formattedRoleToIds.get("建站专员"));
+        updateMap.put("组资料员", formattedRoleToIds.get("资料专员"));
+        log.info("updateMap: {}", JSONObject.toJSONString(updateMap));
+
+        boolean result = sendUpdateRequestFeiShuSheet(updateMap, recordSheetDto);
+        if (result) {
+            List<String> omsAccountIds = new ArrayList<>();
+            for (Map.Entry<String, List<JSONObject>> entry : teamSheetMap.entrySet()) {
+                String groupName = entry.getKey();
+                List<JSONObject> groupList = entry.getValue();
+                System.out.println("组名: " + groupName);
+                for (JSONObject group : groupList) {
+                    String omsId = group.getString("OMS系统ID");
+                    System.out.println("OMS系统ID: " + omsId);
+                    omsAccountIds.add(omsId);
+                }
+            }
+            log.info("omsAccountIds:{}", FastJsonUtil.toJSONString(omsAccountIds));
+
+            for (int i = 0; i < omsAccountIds.size(); i++) {
+                String omsId = omsAccountIds.get(i);
+                log.info("~~~~~~~~~~~~~~~~~~");
+                log.info("开始执行 第{}个 omsId:{} 的用户，绑定新站点", i + 1, omsId);
+                OkkiAccount account = new OkkiAccount();
+                account.setId(omsId);
+
+                OkkiAccount okkiAccountInfo = okkiAccountService.getById(omsId);
+                String siteIds = okkiAccountInfo.getSiteIds();
+                StringBuilder sb = new StringBuilder(siteIds);
+                sb.append(",").append(recordSheetDto.getSiteId());
+                account.setSiteIds(sb.toString());
+
+                okkiAccountService.bindSites(account);
+                log.info("结束：第{}个 omsId:{} 的用户，绑定新站点", i + 1, omsId);
+                log.info("```````````````````");
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 发送飞书更新请求
+     *
+     * @param updateMap
+     * @return
+     */
+    public boolean sendUpdateRequestFeiShuSheet(Map<String, Object> updateMap, FeiShuRecordSheetDto recordSheetDto) {
+        Client client = Client.newBuilder(APP_ID, APP_SECRET).build();
+
+        UpdateAppTableRecordReq updateReq = UpdateAppTableRecordReq.newBuilder()
+                .appTableRecord(AppTableRecord.newBuilder()
+                        .fields(updateMap).build()).appToken(APP_TOKEN).tableId(KF_TABLE_ID).recordId(recordSheetDto.getRecordId())
+                .build();
+
+        // 发起请求
+        UpdateAppTableRecordResp updateResp = null;
+        try {
+            updateResp = client.bitable().appTableRecord().update(updateReq);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+        // 处理服务端错误
+        String status = "成功";
+        if (!updateResp.success()) {
+            log.error("执行 **** sendUpdateRequestFeiShuSheet **** 执行更新信息到飞书表格 失败:{}", String.format("code:%s,msg:%s,reqId:%s", updateResp.getCode(), updateResp.getMsg(), updateResp.getRequestId()));
+            status = "失败";
+        }
+
+        feiShuMsgService.sendUpdateFeiShuSheetMsg(recordSheetDto.getCustomerName(), recordSheetDto.getSiteId(), recordSheetDto.getGroupName(), status);
+        return updateResp.success();
+    }
+
+    /**
+     * 发送创建飞书群
+     *
+     * @return
+     */
+    public void sendCreateFeiShuGroupRequest() {
+        // 构建client
+        Client client = Client.newBuilder("YOUR_APP_ID", "YOUR_APP_SECRET").build();
+
+        // 创建请求对象
+        CreateChatReq req = CreateChatReq.newBuilder()
+                .createChatReqBody(CreateChatReqBody.newBuilder()
+                        .avatar("default-avatar_44ae0ca3-e140-494b-956f-78091e348435")
+                        .name("测试群名称")
+                        .description("测试群描述")
+                        .i18nNames(I18nNames.newBuilder()
+                                .zhCn("群聊")
+                                .enUs("group chat")
+                                .build())
+                        .ownerId("ou_7d8a6e6df7621556ce0d21922b676706ccs")
+                        .userIdList(new String[]{
+                                "ou_7d8a6e6df7621556ce0d21922b676706ccs"
+                        })
+                        .botIdList(new String[]{
+                                "cli_a10fbf7e94b8d01d"
+                        })
+                        .groupMessageType("chat")
+                        .chatMode("group")
+                        .chatType("private")
+                        .joinMessageVisibility("all_members")
+                        .leaveMessageVisibility("all_members")
+                        .membershipApproval("no_approval_required")
+                        .restrictedModeSetting(RestrictedModeSetting.newBuilder()
+                                .status(false)
+                                .screenshotHasPermissionSetting("all_members")
+                                .downloadHasPermissionSetting("all_members")
+                                .messageHasPermissionSetting("all_members")
+                                .build())
+                        .urgentSetting("all_members")
+                        .videoConferenceSetting("all_members")
+                        .editPermission("all_members")
+                        .hideMemberCountSetting("all_members")
+                        .build())
+                .build();
+
+        // 发起请求
+        CreateChatResp resp = null;
+        try {
+            resp = client.im().chat().create(req);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+        // 处理服务端错误
+        if (!resp.success()) {
+            System.out.println(String.format("code:%s,msg:%s,reqId:%s", resp.getCode(), resp.getMsg(), resp.getRequestId()));
+            return;
+        }
+
+        // 业务数据处理
+        System.out.println(Jsons.DEFAULT.toJson(resp.getData()));
+    }
+}

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/site/service/impl/OkkiSiteServiceImpl.java

@@ -1,14 +1,20 @@
 package org.jeecg.modules.okki.site.service.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.collection.ListUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.lark.oapi.Client;
-import com.lark.oapi.service.bitable.v1.model.AppTableRecord;
-import com.lark.oapi.service.bitable.v1.model.CreateAppTableRecordReq;
-import com.lark.oapi.service.bitable.v1.model.CreateAppTableRecordResp;
+import com.lark.oapi.core.request.RequestOptions;
+import com.lark.oapi.core.utils.Jsons;
+import com.lark.oapi.service.bitable.v1.model.*;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.jeecg.common.util.FastJsonUtil;
 import org.jeecg.common.util.HttpClientUtil;
 import org.jeecg.common.util.ThreadPoolUtil;
 import org.jeecg.modules.okki.site.entity.OkkiSite;
@@ -16,16 +22,16 @@ import org.jeecg.modules.okki.site.entity.OkkiSiteStatusChangeLog;
 import org.jeecg.modules.okki.site.mapper.OkkiSiteMapper;
 import org.jeecg.modules.okki.site.param.ChangeSiteStatusParam;
 import org.jeecg.modules.okki.site.param.OkkiSiteParam;
+import org.jeecg.modules.okki.site.service.IFeiShuSheetService;
 import org.jeecg.modules.okki.site.service.IOkkiSiteService;
 import org.jeecg.modules.okki.site.service.IOkkiSiteStatusChangeLogService;
 import org.jeecg.modules.okki.utils.HttpClientUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.TreeMap;
+import java.util.*;
 
 /**
  * @Description: 站点
@@ -49,6 +55,9 @@ public class OkkiSiteServiceImpl extends ServiceImpl<OkkiSiteMapper, OkkiSite> i
     @Resource
     private IOkkiSiteStatusChangeLogService okkiSiteStatusChangeLogService;
 
+    @Autowired
+    private IFeiShuSheetService feiShuSheetService;
+
     @Override
     public boolean updateBySiteId(OkkiSiteParam okkiSiteParam) {
         QueryWrapper<OkkiSite> okkiSiteQueryWrapper = new QueryWrapper<>();
@@ -160,176 +169,11 @@ public class OkkiSiteServiceImpl extends ServiceImpl<OkkiSiteMapper, OkkiSite> i
             okkiSite.setRemark(okkiSiteParam.getRemark());
             boolean result = super.save(okkiSite);
             if(result){
-                ThreadPoolUtil.execute(() -> {syncWebsiteToFeiShuSheet(okkiSite);});
+                ThreadPoolUtil.execute(() -> {
+                    feiShuSheetService.syncWebsiteToFeiShuSheet(okkiSite);}
+                );
             }
             return result;
         }
     }
-
-    /**
-     * 同步站点信息到飞书表格
-     */
-    @Override
-    public void syncWebsiteToFeiShuSheet(OkkiSite okkiSite) {
-        Client client = Client.newBuilder("cli_a61c977059f01013", "saNlFj2YdMXZ0uEAucyRodfSEp5ZHikR").build();
-
-        Map<String, Object> map = new HashMap<>();
-        map.put("公司名称", okkiSite.getCompanyName());
-        map.put("网站ID", Integer.valueOf(okkiSite.getSiteId()));
-        map.put("服务套餐", okkiSite.getTcName());
-        CreateAppTableRecordReq req = CreateAppTableRecordReq.newBuilder().appToken("X16RbjCVCasCmds7fn0c0k21nju").tableId("tblSkc8HfEYDL99U")
-                .appTableRecord(AppTableRecord.newBuilder()
-                        .fields(map)
-                        .build())
-                .build();
-
-        // 发起请求
-        CreateAppTableRecordResp resp = null;
-        try {
-            resp = client.bitable().v1().appTableRecord().create(req);
-        } catch (Exception e) {
-            log.error(e.getMessage(), e);
-            throw new RuntimeException(e);
-        }
-
-        String syncStatus = "成功";
-        if (!resp.success()) {
-            log.error("执行 **** syncWebsiteToFeiShuSheet **** 同步站点信息到飞书表格 失败:{}",String.format("code:%s,msg:%s,reqId:%s", resp.getCode(), resp.getMsg(), resp.getRequestId()));
-            syncStatus = "失败";
-        }
-
-        sendSyncFeiShuSheetMsg(okkiSite.getCompanyName(), okkiSite.getSiteId(), okkiSite.getTcName(), syncStatus);
-    }
-
-    /**
-     * 发送飞书消息
-     *
-     * @param customerName
-     * @param siteId
-     * @param planName
-     * @param syncStatus
-     */
-    public void sendSyncFeiShuSheetMsg(String customerName, String siteId, String planName,String syncStatus) {
-        String botUrl = "https://open.feishu.cn/open-apis/bot/v2/hook/f77f9317-5f15-4aa7-8036-32ce771f40c1";
-
-        String template = "{\n" +
-                "    \"config\": {\n" +
-                "        \"update_multi\": true\n" +
-                "    },\n" +
-                "    \"i18n_elements\": {\n" +
-                "        \"zh_cn\": [\n" +
-                "            {\n" +
-                "                \"tag\": \"markdown\",\n" +
-                "                \"content\": \"<at id=\\\"all\\\">所有人</at> \",\n" +
-                "                \"text_align\": \"left\",\n" +
-                "                \"text_size\": \"normal\"\n" +
-                "            },\n" +
-                "            {\n" +
-                "                \"tag\": \"column_set\",\n" +
-                "                \"flex_mode\": \"none\",\n" +
-                "                \"background_style\": \"default\",\n" +
-                "                \"horizontal_spacing\": \"8px\",\n" +
-                "                \"horizontal_align\": \"left\",\n" +
-                "                \"columns\": [\n" +
-                "                    {\n" +
-                "                        \"tag\": \"column\",\n" +
-                "                        \"width\": \"weighted\",\n" +
-                "                        \"vertical_align\": \"top\",\n" +
-                "                        \"vertical_spacing\": \"8px\",\n" +
-                "                        \"background_style\": \"default\",\n" +
-                "                        \"elements\": [\n" +
-                "                            {\n" +
-                "                                \"tag\": \"markdown\",\n" +
-                "                                \"content\": \"**公司名称：**\\n${customerName}\",\n" +
-                "                                \"text_align\": \"left\",\n" +
-                "                                \"text_size\": \"normal\"\n" +
-                "                            },\n" +
-                "                            {\n" +
-                "                                \"tag\": \"markdown\",\n" +
-                "                                \"content\": \"**套餐名称：**\\n${planName}\",\n" +
-                "                                \"text_align\": \"left\",\n" +
-                "                                \"text_size\": \"normal\"\n" +
-                "                            }\n" +
-                "                        ],\n" +
-                "                        \"weight\": 1\n" +
-                "                    },\n" +
-                "                    {\n" +
-                "                        \"tag\": \"column\",\n" +
-                "                        \"width\": \"weighted\",\n" +
-                "                        \"vertical_align\": \"top\",\n" +
-                "                        \"vertical_spacing\": \"8px\",\n" +
-                "                        \"background_style\": \"default\",\n" +
-                "                        \"elements\": [\n" +
-                "                            {\n" +
-                "                                \"tag\": \"markdown\",\n" +
-                "                                \"content\": \"**站点ID：**\\n${siteId}\",\n" +
-                "                                \"text_align\": \"left\",\n" +
-                "                                \"text_size\": \"normal\"\n" +
-                "                            },\n" +
-                "                            {\n" +
-                "                                \"tag\": \"markdown\",\n" +
-                "                                \"content\": \"**同步状态：**\\n${syncStatus}\",\n" +
-                "                                \"text_align\": \"left\",\n" +
-                "                                \"text_size\": \"normal\"\n" +
-                "                            }\n" +
-                "                        ],\n" +
-                "                        \"weight\": 1\n" +
-                "                    }\n" +
-                "                ],\n" +
-                "                \"margin\": \"16px 0px 0px 0px\"\n" +
-                "            },\n" +
-                "            {\n" +
-                "                \"tag\": \"hr\"\n" +
-                "            },\n" +
-                "            {\n" +
-                "                \"tag\": \"column_set\",\n" +
-                "                \"flex_mode\": \"none\",\n" +
-                "                \"horizontal_spacing\": \"default\",\n" +
-                "                \"background_style\": \"default\",\n" +
-                "                \"columns\": [\n" +
-                "                    {\n" +
-                "                        \"tag\": \"column\",\n" +
-                "                        \"elements\": [\n" +
-                "                            {\n" +
-                "                                \"tag\": \"div\",\n" +
-                "                                \"text\": {\n" +
-                "                                    \"tag\": \"plain_text\",\n" +
-                "                                    \"content\": \"来自 OK项目组-文档机器人\",\n" +
-                "                                    \"text_size\": \"normal\",\n" +
-                "                                    \"text_align\": \"left\",\n" +
-                "                                    \"text_color\": \"default\"\n" +
-                "                                }\n" +
-                "                            }\n" +
-                "                        ],\n" +
-                "                        \"width\": \"weighted\",\n" +
-                "                        \"weight\": 1\n" +
-                "                    }\n" +
-                "                ]\n" +
-                "            }\n" +
-                "        ]\n" +
-                "    },\n" +
-                "    \"i18n_header\": {\n" +
-                "        \"zh_cn\": {\n" +
-                "            \"title\": {\n" +
-                "                \"tag\": \"plain_text\",\n" +
-                "                \"content\": \"【站点同步】OMS平台同步站点至飞书表格通知\"\n" +
-                "            },\n" +
-                "            \"subtitle\": {\n" +
-                "                \"tag\": \"plain_text\",\n" +
-                "                \"content\": \"\"\n" +
-                "            },\n" +
-                "            \"template\": \"green\"\n" +
-                "        }\n" +
-                "    }\n" +
-                "}";
-        template = template.replace("${customerName}", customerName);
-        template = template.replace("${siteId}", siteId);
-        template = template.replace("${planName}", planName);
-        template = template.replace("${syncStatus}", syncStatus);
-
-        JSONObject object = new JSONObject();
-        object.put("msg_type", "interactive");
-        object.put("card", template);
-        HttpClientUtil.doPostJson(botUrl, object.toJSONString());
-    }
 }