HaiNa---接口

src/main/java/com/yuda/hainafacetofaceai/controller/CallBackApiController.java

@@ -20,6 +20,7 @@ public class CallBackApiController {
 
     @PostMapping("/interviewResultReceiver")
     public void interviewResultsReceiver(@RequestBody String data){
+        log.info(data);
         JSONObject result =  JSONObject.parseObject(data);
         String candidateConnectCode = result.getString("candidateConnectCode");
         try{

src/main/java/com/yuda/hainafacetofaceai/controller/ScriptInterfaceController.java

@@ -3,6 +3,7 @@ package com.yuda.hainafacetofaceai.controller;
 import com.yuda.hainafacetofaceai.constant.AppThirdPartUrls;
 import com.yuda.hainafacetofaceai.entity.CandidateCreateQuery;
 import com.yuda.hainafacetofaceai.entity.CandidateExam;
+import com.yuda.hainafacetofaceai.entity.ExamQuery;
 import com.yuda.hainafacetofaceai.service.impl.ScriptInterfaceServiceImpl;
 import com.yuda.hainafacetofaceai.util.AppUtil;
 import com.yuda.hainafacetofaceai.util.ExcelUtil;
@@ -15,12 +16,17 @@ import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpMethod;
 import org.springframework.http.ResponseEntity;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.RestTemplate;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.HashMap;
 import java.util.List;
 import java.util.UUID;
 
@@ -123,9 +129,27 @@ public class ScriptInterfaceController {
    }
 
    @PostMapping("/genBatchJsonFile")
-   public ResponseEntity GenBatchJsonFile(@RequestBody String connecto){
-
-      return null;
+   public ResponseEntity GenBatchJsonFile(@RequestBody String examConnectionCode){
+      List<CandidateExam> results = DBOperator.query("select * from candidate_exam where  exam_connection_code = ? and result_back = 1",new Object[]{examConnectionCode},new BeanPropertyRowMapper<>(CandidateExam.class));
+      if(!results.isEmpty()){
+         for (int i = 0; i < results.size(); i++) {
+           String jsonString =  results.get(i).getInterviewResults();
+           try {
+               // 解析字段中的 JSON 字符串
+               JSONObject jsonObject = new JSONObject(jsonString);
+               String candidateConnectCode = jsonObject.getString("candidate_connect_code");
+               // 生成一个单独的 JSON 文件，每条记录一个文件
+               File outputFile = new File("D:/jsonResults/"+examConnectionCode+"/"+candidateConnectCode+ ".json");
+               // 使用 FileWriter 将 JSONObject 写入文件
+               try (FileWriter fileWriter = new FileWriter(outputFile)) {
+                  fileWriter.write(jsonObject.toString(4)); // 美化输出，4为缩进空格数
+               }
+            } catch (IOException e) {
+               e.printStackTrace();
+            }
+         }
+      }
+      return ResponseEntity.ok("");
    }
 
 }