【采集接口添加密钥】

src/main/java/com/zzsn/event/service/impl/ConfigurationMessageService.java

@@ -5,6 +5,7 @@ import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpRequest;
 import cn.hutool.http.HttpUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
@@ -123,10 +124,12 @@ public class ConfigurationMessageService {
     private String allInfosourcebindUrl;
     @Value("${caiji.allKeyWordsBind.url:http://1.95.79.85:8823/baseSourceInfo/api/subject/keywordSave}")
     private String allKeyWordsBindUrl;
-    @Value("${caiji.projectCode:zzsn}")
+    @Value("${caiji.projectCode:zzsn_test}")
     private String projectCode;
-    @Value("${caiji.projectName:克虏宝}")
+    @Value("${caiji.projectName:克虏宝测试}")
     private String projectName;
+    @Value("${caiji.secretKey:BsEHuAQTifhnMBDni5xjTMkThpmWlNWR3vvYp1rPstQGbE6nmfBX9VhpwrBPWxrU}")
+    private String secretKey;
 
     @Autowired(required = false)
     private RemoteModelService remoteModelService;
@@ -330,7 +333,7 @@ public class ConfigurationMessageService {
 
         log.info("专题关键词配置通知采集{}-{}",allKeyWordsBindUrl,keyWordsParam);
 
-        String post = HttpUtil.post(allKeyWordsBindUrl, keyWordsParam);
+        String post = doPost(allKeyWordsBindUrl, keyWordsParam);
         JSONObject entries = JSONUtil.parseObj(post);
         //获取code状态码
         Integer code = entries.getInt("code");
@@ -365,7 +368,7 @@ public class ConfigurationMessageService {
         }
 
         log.info("专题信息源配置通知采集{}-{}",allInfosourcebindUrl,getparam);
-        String post = HttpUtil.post(allInfosourcebindUrl, getparam);
+        String post =doPost(allInfosourcebindUrl, getparam);
         JSONObject entries = JSONUtil.parseObj(post);
         //获取code状态码
         Integer code = entries.getInt("code");
@@ -390,7 +393,14 @@ public class ConfigurationMessageService {
         param.put("keywordSign",byId.getId());
         param.put("collectWordExp",byId.getKeyWord());
         log.info("编辑关键词通知采集{}-{}",keyWordsEditUrl,JSONUtil.toJsonStr(param));
-        HttpUtil.post(keyWordsEditUrl,JSONUtil.toJsonStr(param));
+        String post = doPost(keyWordsEditUrl, JSONUtil.toJsonStr(param));
+        JSONObject entries = JSONUtil.parseObj(post);
+        //获取code状态码
+        Integer code = entries.getInt("code");
+        if (ObjectUtil.isEmpty(code) ||  code != 200) {
+            log.error("编辑关键词通知采集失败{}",post);
+            throw new RuntimeException("编辑关键词通知采集失败");
+        }
     }
 
     //获取专题绑定的所有信息源id
@@ -574,6 +584,15 @@ public class ConfigurationMessageService {
 
     }
 
+    private String doPost(String urlString, String body){
+
+        HttpRequest post = HttpUtil.createPost(urlString);
+        post.body(body);
+        post.header("Content-Type", "application/json");
+        post.header("authkey", secretKey);
+        return post.execute().body();
+    }
+
     //日期往前推 num 个月
     public static LocalDateTime getPreviousMonths(LocalDateTime date , int num) {
         return date.minusMonths(num);