增加与ai大模型对话

huimv-employment/fe-api/src/main/java/com/huimv/employment/controller/mp/AgentController.java

@@ -1,46 +0,0 @@
-package com.huimv.employment.controller.mp;
-
-import com.huimv.employment.common.web.R;
-import com.huimv.employment.security.LoginUser;
-import com.huimv.employment.security.LoginUserHolder;
-import com.huimv.employment.service.agent.AgentChatService;
-import com.huimv.employment.service.agent.dto.AgentMessageRequest;
-import com.huimv.employment.service.agent.dto.AgentMessageResponse;
-import io.swagger.v3.oas.annotations.Operation;
-import io.swagger.v3.oas.annotations.security.SecurityRequirement;
-import io.swagger.v3.oas.annotations.tags.Tag;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * 小程序智能体对话接口。
- * <p>
- * 封装大模型 Chat Completions 调用，返回统一 {@link R} 格式；底层复用 {@code fe-integration} 的 KB 代理。
- * </p>
- */
-@RestController
-@RequestMapping("/api/v1/mp/agent")
-@Tag(name = "智能体", description = "AI 对话，需 JWT 鉴权")
-@SecurityRequirement(name = "Authorization")
-public class AgentController {
-
-    private final AgentChatService agentChatService;
-
-    public AgentController(AgentChatService agentChatService) {
-        this.agentChatService = agentChatService;
-    }
-
-    @PostMapping("/messages")
-    @Operation(summary = "发送消息并获取 AI 回复",
-            description = "向智能体发送用户消息，返回 AI 回复文本及会话 ID。"
-                    + "conversationId 不传时服务端自动生成，后续多轮对话传入同一 ID 以保持上下文。")
-    public R<AgentMessageResponse> sendMessage(@Validated @RequestBody AgentMessageRequest request) {
-        LoginUser loginUser = LoginUserHolder.require();
-        AgentMessageResponse response = agentChatService.chat(
-                loginUser.getUserId(), loginUser.getUserType(), request);
-        return R.ok(response);
-    }
-}

huimv-employment/fe-integration/src/main/java/com/huimv/employment/integration/kb/ConsoleChatSseParser.java

@@ -1,72 +0,0 @@
-package com.huimv.employment.integration.kb;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.huimv.employment.common.exception.BizException;
-import com.huimv.employment.common.exception.ErrorCode;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.nio.charset.StandardCharsets;
-
-/**
- * 解析 {@code POST /api/console/chat} 返回的 SSE 事件，提取 assistant 文本。
- */
-public final class ConsoleChatSseParser {
-
-    private ConsoleChatSseParser() {
-    }
-
-    public static String extractAssistantText(InputStream sseStream, ObjectMapper objectMapper) throws IOException {
-        if (sseStream == null) {
-            throw new BizException(ErrorCode.AI_SERVICE_FAILED, "大模型返回空响应");
-        }
-        StringBuilder full = new StringBuilder();
-        try (BufferedReader reader = new BufferedReader(new InputStreamReader(sseStream, StandardCharsets.UTF_8))) {
-            String line;
-            while ((line = reader.readLine()) != null) {
-                if (!line.startsWith("data: ")) {
-                    continue;
-                }
-                String payload = line.substring(6).trim();
-                if (payload.isEmpty() || "[DONE]".equals(payload)) {
-                    continue;
-                }
-                JsonNode data = objectMapper.readTree(payload);
-                JsonNode error = data.get("error");
-                if (error != null && !error.isNull()) {
-                    String message = error.path("message").asText("大模型返回错误");
-                    throw new BizException(ErrorCode.AI_SERVICE_FAILED, message);
-                }
-                JsonNode output = data.get("output");
-                if (output == null || !output.isArray()) {
-                    continue;
-                }
-                for (JsonNode item : output) {
-                    if (!"assistant".equals(item.path("role").asText())) {
-                        continue;
-                    }
-                    JsonNode contents = item.get("content");
-                    if (contents == null || !contents.isArray()) {
-                        continue;
-                    }
-                    for (JsonNode content : contents) {
-                        if ("text".equals(content.path("type").asText()) && content.has("text")) {
-                            full.append(content.get("text").asText(""));
-                        }
-                    }
-                }
-            }
-        } catch (BizException ex) {
-            throw ex;
-        } catch (Exception ex) {
-            throw new BizException(ErrorCode.AI_SERVICE_FAILED, "解析大模型 SSE 响应失败");
-        }
-        if (full.length() == 0) {
-            throw new BizException(ErrorCode.AI_SERVICE_FAILED, "大模型未返回有效内容");
-        }
-        return full.toString();
-    }
-}

huimv-employment/fe-integration/src/main/java/com/huimv/employment/integration/kb/KbApiProperties.java

@@ -31,7 +31,7 @@ public class KbApiProperties {
     /** 方式一上传默认知识库标识 */
     private String defaultKnowledgeBase = "default";
 
-    /** agent/messages 等非透传场景默认模型 */
+    /** 默认模型标识（预留） */
     private String defaultModel = "default";
 
     /** 上游 {@code X-Agent-Id} 默认值（见智能体接口文档） */

huimv-employment/fe-integration/src/main/java/com/huimv/employment/integration/kb/KbOpenAiProxyService.java

@@ -13,6 +13,4 @@ public interface KbOpenAiProxyService {
     ResponseEntity<byte[]> getVersion();
 
     void streamConsoleChat(byte[] requestBody, String agentId, OutputStream output) throws IOException;
-
-    String collectConsoleChatReply(byte[] requestBody, String agentId);
 }

huimv-employment/fe-integration/src/main/java/com/huimv/employment/integration/kb/KbOpenAiProxyServiceImpl.java

@@ -33,14 +33,11 @@ public class KbOpenAiProxyServiceImpl implements KbOpenAiProxyService {
 
     private final KbApiProperties properties;
     private final RestTemplate restTemplate;
-    private final com.fasterxml.jackson.databind.ObjectMapper objectMapper;
 
     public KbOpenAiProxyServiceImpl(KbApiProperties properties,
-                                    @Qualifier("kbRestTemplate") RestTemplate restTemplate,
-                                    com.fasterxml.jackson.databind.ObjectMapper objectMapper) {
+                                    @Qualifier("kbRestTemplate") RestTemplate restTemplate) {
         this.properties = properties;
         this.restTemplate = restTemplate;
-        this.objectMapper = objectMapper;
     }
 
     @Override
@@ -96,45 +93,6 @@ public class KbOpenAiProxyServiceImpl implements KbOpenAiProxyService {
         }
     }
 
-    @Override
-    public String collectConsoleChatReply(byte[] requestBody, String agentId) {
-        ensureEnabled();
-        validateRequestBody(requestBody);
-        HttpURLConnection conn = null;
-        InputStream input = null;
-        try {
-            conn = openUpstreamConnection(requestBody.length);
-            conn.setRequestProperty(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
-            conn.setRequestProperty(HttpHeaders.ACCEPT, MediaType.TEXT_EVENT_STREAM_VALUE);
-            applyUpstreamAuth(conn, agentId);
-            conn.setDoOutput(true);
-            try (OutputStream upstreamOut = conn.getOutputStream()) {
-                upstreamOut.write(requestBody);
-            }
-            int status = conn.getResponseCode();
-            input = status >= 400 ? conn.getErrorStream() : conn.getInputStream();
-            if (status >= 400) {
-                throw upstreamHttpError(status, input);
-            }
-            return ConsoleChatSseParser.extractAssistantText(input, objectMapper);
-        } catch (BizException ex) {
-            throw ex;
-        } catch (Exception ex) {
-            throw new BizException(ErrorCode.AI_SERVICE_FAILED, "调用大模型失败");
-        } finally {
-            if (input != null) {
-                try {
-                    input.close();
-                } catch (IOException ignored) {
-                    // ignore
-                }
-            }
-            if (conn != null) {
-                conn.disconnect();
-            }
-        }
-    }
-
     private HttpURLConnection openUpstreamConnection(int contentLength) throws IOException {
         URL url = new URL(properties.baseUrl() + PATH_CHAT);
         HttpURLConnection conn = (HttpURLConnection) url.openConnection();
@@ -166,24 +124,6 @@ public class KbOpenAiProxyServiceImpl implements KbOpenAiProxyService {
         }
     }
 
-    private BizException upstreamHttpError(int status, InputStream input) throws IOException {
-        if (input != null) {
-            byte[] errBytes = StreamUtils.copyToByteArray(input);
-            if (errBytes.length > 0) {
-                String errText = new String(errBytes, StandardCharsets.UTF_8).trim();
-                if (status == 401) {
-                    String hint = properties.hasUpstreamAuth()
-                            ? "大模型鉴权失败，请检查 fe.kb.api-key"
-                            : "大模型鉴权失败";
-                    return new BizException(ErrorCode.AI_SERVICE_FAILED, hint);
-                }
-                return new BizException(ErrorCode.AI_SERVICE_FAILED,
-                        errText.length() > 200 ? errText.substring(0, 200) : errText);
-            }
-        }
-        return new BizException(ErrorCode.AI_SERVICE_FAILED, "上游返回 HTTP " + status);
-    }
-
     private String resolveAgentId(String agentId) {
         if (StringUtils.hasText(agentId)) {
             return agentId.trim();

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/agent/AgentChatService.java

@@ -1,73 +0,0 @@
-package com.huimv.employment.service.agent;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.node.ArrayNode;
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import com.huimv.employment.common.exception.BizException;
-import com.huimv.employment.common.exception.ErrorCode;
-import com.huimv.employment.integration.kb.KbApiProperties;
-import com.huimv.employment.integration.kb.KbOpenAiProxyService;
-import com.huimv.employment.service.agent.dto.AgentMessageRequest;
-import com.huimv.employment.service.agent.dto.AgentMessageResponse;
-import org.springframework.stereotype.Service;
-import org.springframework.util.StringUtils;
-
-import java.util.UUID;
-
-/**
- * 小程序智能体对话：封装 {@code POST /api/console/chat} 调用。
- */
-@Service
-public class AgentChatService {
-
-    private static final String SYSTEM_PROMPT =
-            "你是灵活用工智能助手，帮助企业主解答用工规范、成本测算、登记流程等问题。回答应简洁、专业、可操作。";
-
-    private final KbOpenAiProxyService kbOpenAiProxyService;
-    private final KbApiProperties kbApiProperties;
-    private final ObjectMapper objectMapper;
-
-    public AgentChatService(KbOpenAiProxyService kbOpenAiProxyService,
-                            KbApiProperties kbApiProperties,
-                            ObjectMapper objectMapper) {
-        this.kbOpenAiProxyService = kbOpenAiProxyService;
-        this.kbApiProperties = kbApiProperties;
-        this.objectMapper = objectMapper;
-    }
-
-    public AgentMessageResponse chat(Long userId, String userType, AgentMessageRequest request) {
-        String conversationId = StringUtils.hasText(request.getConversationId())
-                ? request.getConversationId()
-                : UUID.randomUUID().toString().replace("-", "");
-
-        byte[] body = buildChatRequest(userId, conversationId, request.getMessage());
-        String reply = kbOpenAiProxyService.collectConsoleChatReply(body, kbApiProperties.getDefaultAgentId());
-
-        AgentMessageResponse response = new AgentMessageResponse();
-        response.setReply(reply);
-        response.setConversationId(conversationId);
-        return response;
-    }
-
-    private byte[] buildChatRequest(Long userId, String sessionId, String userMessage) {
-        try {
-            ObjectNode root = objectMapper.createObjectNode();
-
-            ArrayNode input = root.putArray("input");
-            ObjectNode userMsg = input.addObject();
-            userMsg.put("role", "user");
-            ArrayNode userContent = userMsg.putArray("content");
-            ObjectNode userText = userContent.addObject();
-            userText.put("type", "text");
-            userText.put("text", SYSTEM_PROMPT + "\n\n" + userMessage);
-
-            root.put("session_id", sessionId);
-            root.put("user_id", String.valueOf(userId));
-            root.put("channel", "console");
-
-            return objectMapper.writeValueAsBytes(root);
-        } catch (Exception ex) {
-            throw new BizException(ErrorCode.INTERNAL_ERROR);
-        }
-    }
-}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/agent/dto/AgentMessageRequest.java

@@ -1,43 +0,0 @@
-package com.huimv.employment.service.agent.dto;
-
-import io.swagger.v3.oas.annotations.media.Schema;
-
-import javax.validation.constraints.NotBlank;
-
-@Schema(description = "智能体对话请求")
-public class AgentMessageRequest {
-
-    @Schema(description = "企业 ID（可选，预留多企业场景）", example = "1")
-    private Long enterpriseId;
-
-    @Schema(description = "会话 ID，不传则自动生成", example = "conv-abc123")
-    private String conversationId;
-
-    @Schema(description = "用户消息内容", example = "帮我起草一份临时工用工协议", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotBlank(message = "消息内容不能为空")
-    private String message;
-
-    public Long getEnterpriseId() {
-        return enterpriseId;
-    }
-
-    public void setEnterpriseId(Long enterpriseId) {
-        this.enterpriseId = enterpriseId;
-    }
-
-    public String getConversationId() {
-        return conversationId;
-    }
-
-    public void setConversationId(String conversationId) {
-        this.conversationId = conversationId;
-    }
-
-    public String getMessage() {
-        return message;
-    }
-
-    public void setMessage(String message) {
-        this.message = message;
-    }
-}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/agent/dto/AgentMessageResponse.java

@@ -1,51 +0,0 @@
-package com.huimv.employment.service.agent.dto;
-
-import io.swagger.v3.oas.annotations.media.Schema;
-
-@Schema(description = "智能体对话响应")
-public class AgentMessageResponse {
-
-    @Schema(description = "AI 回复文本", example = "好的，请提供用工岗位、工时和薪资等信息。")
-    private String reply;
-
-    @Schema(description = "会话 ID", example = "conv-abc123")
-    private String conversationId;
-
-    @Schema(description = "下一步动作（如 show_employment_draft），一期可为空")
-    private String nextAction;
-
-    @Schema(description = "关联草稿 ID，一期可为空")
-    private String draftId;
-
-    public String getReply() {
-        return reply;
-    }
-
-    public void setReply(String reply) {
-        this.reply = reply;
-    }
-
-    public String getConversationId() {
-        return conversationId;
-    }
-
-    public void setConversationId(String conversationId) {
-        this.conversationId = conversationId;
-    }
-
-    public String getNextAction() {
-        return nextAction;
-    }
-
-    public void setNextAction(String nextAction) {
-        this.nextAction = nextAction;
-    }
-
-    public String getDraftId() {
-        return draftId;
-    }
-
-    public void setDraftId(String draftId) {
-        this.draftId = draftId;
-    }
-}