HaiNa---接口

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

@@ -3,6 +3,7 @@ package com.yuda.hainafacetofaceai.controller;
 import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -19,18 +20,23 @@ public class CallBackApiController {
     private JdbcTemplate DBOperator;
 
     @PostMapping("/interviewResultReceiver")
-    public void interviewResultsReceiver(@RequestBody String data){
-        JSONObject result =  JSONObject.parseObject(data);
-        String candidateConnectCode = result.getString("candidateConnectCode");
-        log.info("候选人链接码"+candidateConnectCode+"面试过程回调"+data);
-        String event = result.getString("event");
-        if(event.equals("aiExamCandidateReviewV2")){
-            try{
-                DBOperator.update("update candidate_exam set result_back = 1,interview_results = ? where candidate_connect_code = ?",new Object[]{data,candidateConnectCode});
-                log.info("候选人链接码"+candidateConnectCode+"面试结果入库完成");
-            }catch (Exception e){
-                log.info("候选人链接码"+candidateConnectCode+"面试结果入库回调出错");
+    public ResponseEntity interviewResultsReceiver(@RequestBody String data){
+        try{
+            JSONObject result =  JSONObject.parseObject(data);
+            String candidateConnectCode = result.getString("candidateConnectCode");
+            log.info("候选人链接码"+candidateConnectCode+"面试过程回调"+data);
+            String event = result.getString("event");
+            if(event.equals("aiExamCandidateReviewV2")){
+                try{
+                    DBOperator.update("update candidate_exam set result_back = 1,interview_results = ? where candidate_connect_code = ?",new Object[]{data,candidateConnectCode});
+                    log.info("候选人链接码"+candidateConnectCode+"面试结果入库完成");
+                }catch (Exception e){
+                    log.info("候选人链接码"+candidateConnectCode+"面试结果入库回调出错");
+                }
             }
+        }catch (Exception e){
+            return ResponseEntity.status(10000).body("错误的回调");
         }
+        return ResponseEntity.status(0).body("收到回调");
     }
 }