From da100df835f7eef4c4db483caa5aaf721b3ddbd7 Mon Sep 17 00:00:00 2001 From: heiferleaf <2044384845@qq.com> Date: Tue, 3 Jun 2025 14:49:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=B9=E8=AF=9D=E5=86=85=E5=AE=B9=E7=9A=84co?= =?UTF-8?q?ntent=E6=8F=90=E5=8F=96=E5=92=8C=E8=BE=A9=E8=AE=BA=E5=8E=86?= =?UTF-8?q?=E5=8F=B2=E8=AE=B0=E5=BD=95=E9=80=9A=E8=BF=87=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Debate_backend/pom.xml | 6 +++++ .../newdemo/controller/WxAIController.java | 3 +-- .../newdemo/service/WxDebateService.java | 2 +- .../service/impl/WxArgumentServiceImpl.java | 20 +++++++++----- .../service/impl/WxDebateServiceImpl.java | 26 +++++++++++++++++-- .../service/impl/WxReviewServiceImpl.java | 13 +++++++++- 6 files changed, 57 insertions(+), 13 deletions(-) diff --git a/Debate_backend/pom.xml b/Debate_backend/pom.xml index ff0631a..99b91ba 100644 --- a/Debate_backend/pom.xml +++ b/Debate_backend/pom.xml @@ -77,6 +77,12 @@ runtime + + org.json + json + 20240303 + + org.springframework.boot diff --git a/Debate_backend/src/main/java/com/learning/newdemo/controller/WxAIController.java b/Debate_backend/src/main/java/com/learning/newdemo/controller/WxAIController.java index 5966719..4952bd3 100644 --- a/Debate_backend/src/main/java/com/learning/newdemo/controller/WxAIController.java +++ b/Debate_backend/src/main/java/com/learning/newdemo/controller/WxAIController.java @@ -96,12 +96,11 @@ public class WxAIController { @PostMapping("/debate") public Result> debate(@RequestHeader ("Authorization") String token, @RequestBody Map params){ log.info("请求内容: {}", params); - String history = params.get("history"); String userMessage = params.get("userMessage"); conversationId = Long.parseLong(params.get("conversationId")); try { - String debate = wxDebateService.GetDebate(history, userMessage); + String debate = wxDebateService.GetDebate(conversationId, userMessage); if (debate == null) { return Result.error("辩论获取失败"); } diff --git a/Debate_backend/src/main/java/com/learning/newdemo/service/WxDebateService.java b/Debate_backend/src/main/java/com/learning/newdemo/service/WxDebateService.java index 43362d1..54a01f5 100644 --- a/Debate_backend/src/main/java/com/learning/newdemo/service/WxDebateService.java +++ b/Debate_backend/src/main/java/com/learning/newdemo/service/WxDebateService.java @@ -1,6 +1,6 @@ package com.learning.newdemo.service; public interface WxDebateService { - String GetDebate(String history, String userMessage); + String GetDebate(Long conversationId, String userMessage); long UpdateDebate(Long conversationId, String content, String userMessage, String token); } diff --git a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxArgumentServiceImpl.java b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxArgumentServiceImpl.java index a5a8e7b..683d748 100644 --- a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxArgumentServiceImpl.java +++ b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxArgumentServiceImpl.java @@ -1,19 +1,16 @@ package com.learning.newdemo.service.impl; +import org.json.JSONObject; +import org.json.JSONArray; import com.learning.newdemo.entity.WxArgument; import com.learning.newdemo.entity.WxConversation; import com.learning.newdemo.mapper.WxArgumentMapper; import com.learning.newdemo.mapper.WxConversationMapper; import com.learning.newdemo.service.WxArgumentService; import com.learning.newdemo.util.JwtUtil; -import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; -import org.springframework.http.HttpEntity; -import org.springframework.http.HttpHeaders; -import org.springframework.http.HttpMethod; -import org.springframework.http.MediaType; -import org.springframework.http.ResponseEntity; +import org.springframework.http.*; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; @@ -90,7 +87,16 @@ public class WxArgumentServiceImpl implements WxArgumentService { HttpEntity requestEntity = new HttpEntity<>(requestBody, headers); ResponseEntity response = _restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class); - return response.getBody(); + + if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) { + JSONObject json = new JSONObject(response.getBody()); + JSONArray choices = json.getJSONArray("choices"); + if (!choices.isEmpty()) { + JSONObject message = choices.getJSONObject(0).getJSONObject("message"); + return message.getString("content"); + } + } + return null; } catch (Exception e) { log.error("向AI获取立论失败", e); return null; diff --git a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxDebateServiceImpl.java b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxDebateServiceImpl.java index 6c119b9..380610c 100644 --- a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxDebateServiceImpl.java +++ b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxDebateServiceImpl.java @@ -7,6 +7,8 @@ import com.learning.newdemo.mapper.WxDebateMapper; import com.learning.newdemo.service.WxDebateService; import com.learning.newdemo.util.JwtUtil; import lombok.extern.slf4j.Slf4j; +import org.json.JSONArray; +import org.json.JSONObject; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.*; import org.springframework.stereotype.Service; @@ -48,12 +50,22 @@ public class WxDebateServiceImpl implements WxDebateService { } @Override - public String GetDebate(String history, String userMessage){ + public String GetDebate(Long conversationId, String userMessage){ try { HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); headers.set("Authorization", authorizationHeader); + String history; + + if(conversationId == -1){ + history = ""; + } + else { + history = wxDebateMapper.selectByConversationId(conversationId).stream() + .map(WxDebate::getContent) + .reduce("", (a, b) -> a + b); + } StringBuilder requestBodyBuilder = new StringBuilder(); requestBodyBuilder.append("{") .append("\"messages\": [") @@ -86,7 +98,17 @@ public class WxDebateServiceImpl implements WxDebateService { log.info("请求体：{}", requestBody); HttpEntity requestEntity = new HttpEntity<>(requestBody, headers); ResponseEntity response = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class); - return response.getBody(); + + if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) { + JSONObject json = new JSONObject(response.getBody()); + JSONArray choices = json.getJSONArray("choices"); + if (!choices.isEmpty()) { + JSONObject message = choices.getJSONObject(0).getJSONObject("message"); + return message.getString("content"); + } + } + return null; + } catch (Exception e){ log.error("模拟辩论获取失败", e); return null; diff --git a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxReviewServiceImpl.java b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxReviewServiceImpl.java index 49cf49d..c048a27 100644 --- a/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxReviewServiceImpl.java +++ b/Debate_backend/src/main/java/com/learning/newdemo/service/impl/WxReviewServiceImpl.java @@ -7,6 +7,8 @@ import com.learning.newdemo.mapper.WxReviewMapper; import com.learning.newdemo.service.WxReviewService; import com.learning.newdemo.util.JwtUtil; import lombok.extern.slf4j.Slf4j; +import org.json.JSONArray; +import org.json.JSONObject; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.*; import org.springframework.stereotype.Service; @@ -85,7 +87,16 @@ public class WxReviewServiceImpl implements WxReviewService { HttpEntity requestEntity = new HttpEntity<>(requestBody, headers); ResponseEntity response = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class); - return response.getBody(); + + if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) { + JSONObject json = new JSONObject(response.getBody()); + JSONArray choices = json.getJSONArray("choices"); + if (!choices.isEmpty()) { + JSONObject message = choices.getJSONObject(0).getJSONObject("message"); + return message.getString("content"); + } + } + return null; } catch (Exception e) { log.error("向AI获取立论失败", e); return null;