修改话题审核回调接口

liwei2917
1 parent 5968d32a
Showing 1 changed file with 7 additions and 2 deletions
src/main/java/com/cnlive/shenhe/api/TopicControllerApi.java
@@ -124,7 +124,7 @@ public class TopicControllerApi {
  
     @PostMapping("/callback")
     @ResponseBody
-    public void callback(@RequestBody String param) {
+    public ResponseBean callback(@RequestBody String param) {
         logger.info("话题回调通知，param=====" + param);
         JSONObject json = JSONObject.parseObject(param);
         //获取中转服务器消息
@@ -150,7 +150,12 @@ public class TopicControllerApi {
     		topic.setShenhe_status(CommonConst.AUDIT_INTT);
     		topic.setShenhe_type(CommonConst.AUDIT_TYPE_USER);
         }
-        topicService.updateshyTopic(shyTopic);
+        boolean rs = topicService.updateshyTopic(shyTopic);
+        if(rs){
+        	return new ResponseBean(ErrorEnum.SUCCESS,new JSONObject().put("topic_id", topic_id));
+        }
+        
+        return new ResponseBean(300,"话题送审回调成功，入库失败",new JSONObject().put("topic_id", topic_id));
      }