title score

etl-core/src/main/java/com/tzld/crawler/etl/service/impl/EtlServiceImpl.java

@@ -25,6 +25,7 @@
 package com.tzld.crawler.etl.service.impl;
 
 import com.ctrip.framework.apollo.spring.annotation.ApolloJsonValue;
+import com.google.common.base.Strings;
 import com.google.common.collect.Lists;
 import com.tzld.commons.aliyun.oss.AliyunOssManager;
 import com.tzld.crawler.etl.common.base.CommonResponse;
@@ -179,8 +180,18 @@ public class EtlServiceImpl implements EtlService {
             // 7.视频写入飞书
             pool.execute(() -> {
                 try {
-                    String fsResp = FeishuUtils.insertRows(feishuAppid, feishuAppsecret, feishuSheetTokenMap.get(platform),
-                            feishuSheetIdMap.get(platform), 1, 2);
+                    String sheetToken = feishuSheetTokenMap.get(platform);
+                    if (Strings.isNullOrEmpty(sheetToken)) {
+                        log.error("feishu.sheet.token.map config of {} is null", platform);
+                        return;
+                    }
+                    String sheetId = feishuSheetIdMap.get(platform);
+                    if (Strings.isNullOrEmpty(sheetToken)) {
+                        log.error("feishu.sheet.id.map config of {} is null", platform);
+                        return;
+                    }
+                    String fsResp = FeishuUtils.insertRows(feishuAppid, feishuAppsecret, sheetToken,
+                            sheetId, 1, 2);
                     log.debug("insert columns to feishu sheet response is {}", fsResp);
 
                     List<List<Object>> values = new ArrayList<>();
@@ -207,7 +218,7 @@ public class EtlServiceImpl implements EtlService {
                     value.add(data.getVideoUrl());
                     values.add(value);
 
-                    fsResp = FeishuUtils.updateValues(feishuAppid, feishuAppsecret, feishuSheetTokenMap.get(platform),
+                    fsResp = FeishuUtils.updateValues(feishuAppid, feishuAppsecret, sheetToken,
                             feishuRangeMap.get(platform), values);
                     log.debug("update feishu sheet value response is {}", fsResp);
 

etl-server/src/main/resources/application-dev.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8080
+  port: 8081
 
 spring:
   datasource: