增加站点同步至飞书表格

jeecg-boot/jeecg-boot-base-core/pom.xml

@@ -270,6 +270,11 @@
 			<groupId>cn.hutool</groupId>
 			<artifactId>hutool-crypto</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>com.larksuite.oapi</groupId>
+			<artifactId>oapi-sdk</artifactId>
+			<version>2.3.2</version>
+		</dependency>
 	</dependencies>
 
 </project>

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

@@ -0,0 +1,314 @@
+package org.jeecg.common.util;
+
+import org.apache.commons.codec.binary.Base64;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.springframework.util.StringUtils;
+
+import javax.net.ssl.HttpsURLConnection;
+import java.io.*;
+import java.net.ConnectException;
+import java.net.URI;
+import java.net.URL;
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+public class HttpClientUtil {
+
+    public static String doGet(String url, Map<String, String> param) {
+
+        return doGet(url, param, null, null);
+    }
+
+    public static String doGet(String url, Map<String, String> param, String userName, String password) {
+
+        // 创建Httpclient对象
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+
+        String resultString = "";
+        CloseableHttpResponse response = null;
+        try {
+            // 创建uri
+            URIBuilder builder = new URIBuilder(url);
+            if (param != null) {
+                for (String key : param.keySet()) {
+                    builder.addParameter(key, param.get(key));
+                }
+            }
+            URI uri = builder.build();
+
+            // 创建http GET请求
+            HttpGet httpGet = new HttpGet(uri);
+            if(!StringUtils.isEmpty(userName) && !StringUtils.isEmpty(password)){
+                String baseAuth = getHeader(userName, password);
+                httpGet.addHeader("Authorization", baseAuth);
+            }
+
+            // 执行请求
+            response = httpclient.execute(httpGet);
+            // 判断返回状态是否为200
+            if (response.getStatusLine().getStatusCode() == 200) {
+                resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (response != null) {
+                    response.close();
+                }
+                httpclient.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return resultString;
+    }
+
+    public static String doGet(String url) {
+        return doGet(url, null);
+    }
+
+    public static String doPost(String url, Map<String, String> param) {
+        // 创建Httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        CloseableHttpResponse response = null;
+        String resultString = "";
+        try {
+            // 创建Http Post请求
+            HttpPost httpPost = new HttpPost(url);
+            // 创建参数列表
+            if (param != null) {
+                List<NameValuePair> paramList = new ArrayList<>();
+                for (String key : param.keySet()) {
+                    paramList.add(new BasicNameValuePair(key, param.get(key)));
+                }
+                // 模拟表单
+                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
+                httpPost.setEntity(entity);
+            }
+            // 执行http请求
+            response = httpClient.execute(httpPost);
+            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                response.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        return resultString;
+    }
+
+    public static String doPostByObject(String url, Map<String, Object> param) {
+        // 创建Httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        CloseableHttpResponse response = null;
+        String resultString = "";
+        try {
+            // 创建Http Post请求
+            HttpPost httpPost = new HttpPost(url);
+            // 创建参数列表
+            if (param != null) {
+                List<NameValuePair> paramList = new ArrayList<>();
+                for (String key : param.keySet()) {
+                    if(param.get(key) instanceof Boolean){
+                        paramList.add(new BasicNameValuePair(key, String.valueOf(param.get(key))));
+                    } else if(param.get(key) instanceof String) {
+                        paramList.add(new BasicNameValuePair(key, param.get(key).toString()));
+                    }
+                }
+                // 模拟表单
+                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
+                httpPost.setEntity(entity);
+            }
+            // 执行http请求
+            response = httpClient.execute(httpPost);
+            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                response.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        return resultString;
+    }
+
+    public static String doPost(String url) {
+        return doPost(url, null);
+    }
+
+    public static String doPostJson(String url, String json, Map<String, String> headers) {
+        // 创建Httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        CloseableHttpResponse response = null;
+        String resultString = "";
+        try {
+            // 创建Http Post请求
+            HttpPost httpPost = new HttpPost(url);
+            if(headers != null){
+                for (String key : headers.keySet()) {
+                    httpPost.addHeader(key, headers.get(key));
+                }
+            }
+            // 创建请求内容
+            StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
+            httpPost.setEntity(entity);
+            // 执行http请求
+            response = httpClient.execute(httpPost);
+            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                response.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        return resultString;
+    }
+
+    public static String doPostJsonByBasicAuth(String url, String json, String userName, String password) {
+
+        // 创建Httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        CloseableHttpResponse response = null;
+        String resultString = "";
+        try {
+            // 创建Http Post请求
+            HttpPost httpPost = new HttpPost(url);
+            if(!StringUtils.isEmpty(userName) && !StringUtils.isEmpty(password)){
+                String baseAuth = getHeader(userName, password);
+                httpPost.addHeader("Authorization", baseAuth);
+            }
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(15 * 60 * 1000).setConnectionRequestTimeout(15 * 60 * 1000)
+                    .setSocketTimeout(15 * 60 * 1000).build();
+            httpPost.setConfig(requestConfig);
+            // 创建请求内容
+            StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
+            httpPost.setEntity(entity);
+            // 执行http请求
+            response = httpClient.execute(httpPost);
+            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (response != null) {
+                    response.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return resultString;
+    }
+
+    public static String doPostJson(String url, String json) {
+        return doPostJsonByBasicAuth(url, json, null, null);
+    }
+
+    public static String httpsRequest(String requestUrl, String requestMethod, String outputStr) {
+        try {
+            URL url = new URL(requestUrl);
+            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
+            conn.setDoOutput(true);
+            conn.setDoInput(true);
+            conn.setUseCaches(false);
+            // 设置请求方式（GET/POST）
+            conn.setRequestMethod(requestMethod);
+            conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
+            // 当outputStr不为null时向输出流写数据
+            if (null != outputStr) {
+                OutputStream outputStream = conn.getOutputStream();
+                // 注意编码格式
+                outputStream.write(outputStr.getBytes("UTF-8"));
+                outputStream.close();
+            }
+            // 从输入流读取返回内容
+            InputStream inputStream = conn.getInputStream();
+            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
+            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
+            String str = null;
+            StringBuffer buffer = new StringBuffer();
+            while ((str = bufferedReader.readLine()) != null) {
+                buffer.append(str);
+            }
+            // 释放资源
+            bufferedReader.close();
+            inputStreamReader.close();
+            inputStream.close();
+            conn.disconnect();
+            return buffer.toString();
+        } catch (ConnectException ce) {
+            System.out.println("连接超时：{}");
+        } catch (Exception e) {
+            System.out.println("https请求异常：{}");
+        }
+        return null;
+    }
+
+    /**
+     * 构造Basic Auth认证头信息
+     *
+     * @return
+     */
+    private static String getHeader(String userName, String password) {
+        String auth = userName + ":" + password;
+        byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(Charset.forName("US-ASCII")));
+        String authHeader = "Basic " + new String(encodedAuth);
+        return authHeader;
+    }
+
+    public static String doPostText(String url, String param) {
+
+        // 创建Httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        CloseableHttpResponse response = null;
+        String resultString = "";
+        try {
+            // 创建Http Post请求
+            HttpPost httpPost = new HttpPost(url);
+            // 创建请求内容
+            StringEntity entity = new StringEntity(param, ContentType.DEFAULT_TEXT);
+            httpPost.setEntity(entity);
+            // 执行http请求
+            response = httpClient.execute(httpPost);
+            resultString = EntityUtils.toString(response.getEntity(), "utf-8");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                response.close();
+            } catch (IOException e) {
+
+                e.printStackTrace();
+            }
+        }
+        return resultString;
+    }
+
+}

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

@@ -0,0 +1,32 @@
+package org.jeecg.common.util;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * 线程池辅助类，整个应用程序就只有一个线程池去管理线程。 可以设置核心线程数、最大线程数、额外线程空状态生存时间，阻塞队列长度来优化线程池。
+ * 下面的数据都是参考Android的AsynTask里的数据。
+ *
+ * @author liyl
+ */
+public class ThreadPoolUtil {
+
+    private ThreadPoolUtil() {
+
+    }
+
+    /**
+     * 无界缓存线程池
+     */
+    private static ExecutorService threadPool = Executors.newFixedThreadPool(10);
+
+    /**
+     * 从线程池中抽取线程，执行指定的Runnable对象
+     *
+     * @param runnable
+     */
+    public static void execute(Runnable runnable) {
+        threadPool.execute(runnable);
+    }
+
+}

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

@@ -20,4 +20,10 @@ 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/OkkiSiteServiceImpl.java

@@ -4,7 +4,13 @@ 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 lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.HttpClientUtil;
+import org.jeecg.common.util.ThreadPoolUtil;
 import org.jeecg.modules.okki.site.entity.OkkiSite;
 import org.jeecg.modules.okki.site.entity.OkkiSiteStatusChangeLog;
 import org.jeecg.modules.okki.site.mapper.OkkiSiteMapper;
@@ -152,7 +158,178 @@ public class OkkiSiteServiceImpl extends ServiceImpl<OkkiSiteMapper, OkkiSite> i
             okkiSite.setTcPeriod(okkiSiteParam.getTc_period());
             okkiSite.setTcLanguage(okkiSiteParam.getTc_language());
             okkiSite.setRemark(okkiSiteParam.getRemark());
-            return super.save(okkiSite);
+            boolean result = super.save(okkiSite);
+            if(result){
+                ThreadPoolUtil.execute(() -> {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());
+    }
 }