企业 AI 应用平台，为什么不能只靠「套一层 API」

// === 1. AI 服务配置 ===
// application.yml
spring:
  ai:
    openai:
      api-key: ${OPENAI_API_KEY}
      base-url: https://api.openai.com  # 或国内代理地址
      chat:
        options:
          model: gpt-4o
          temperature: 0.3
  datasource:
    url: jdbc:mysql://localhost:3306/erp_main
    username: root
    password: ${DB_PASSWORD}

// === 2. 业务数据检索服务 ===
@Service
public class OrderQueryService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    /**
     * 查询指定区域指定季度的退货统计
     * AI 调用此方法获取实时业务数据
     */
    public String queryRefundStats(String region, String quarter) {
        String sql = """
            SELECT sku_code, sku_name, refund_rate
            FROM v_region_refund_stats
            WHERE region = ? AND quarter = ?
            ORDER BY refund_rate DESC
            LIMIT 10
            """;
        var rows = jdbcTemplate.queryForList(sql, region, quarter);
        // 转成 AI 可读的文本摘要
        StringBuilder sb = new StringBuilder("退货率排名：\n");
        for (var row : rows) {
            sb.append("- %s (%s): %.1f%%\n".formatted(
                row.get("sku_name"), row.get("sku_code"),
                (Double) row.get("refund_rate") * 100));
        }
        return sb.toString();
    }
}

// === 3. AI 对话服务——带业务数据注入 ===
@Service
public class BusinessChatService {

    @Autowired
    private ChatClient chatClient;  // Spring AI 的 ChatClient

    @Autowired
    private OrderQueryService orderQueryService;

    /**
     * 处理用户提问，自动判断是否需要查业务数据
     */
    public String chat(String userQuestion, String currentUserRegion) {
        // 构造系统提示，注入当前用户的业务上下文
        String systemPrompt = """
            你是 ERP 系统的智能助手。
            当前用户所属区域：%s。
            当需要查询业务数据时，请先说明要查什么，
            系统会自动检索并补充数据，你再基于数据回答。
            """.formatted(currentUserRegion);

        // 第一次调用：让 AI 表达查询意图
        ChatResponse firstCall = chatClient.call(
            new Prompt(List.of(
                new SystemMessage(systemPrompt),
                new UserMessage(userQuestion)
            ))
        );

        String aiResponse = firstCall.getResult().getOutput().getText();

        // 简化示例：如果问题涉及退货率，自动注入业务数据再二次调用
        if (aiResponse.contains("需要查询退货") || userQuestion.contains("退货")) {
            String bizData = orderQueryService.queryRefundStats(
                currentUserRegion, "2024Q3");
            String enrichedPrompt = """
                系统已检索到以下业务数据：
                %s

                请基于以上数据回答用户问题：%s
                """.formatted(bizData, userQuestion);

            ChatResponse secondCall = chatClient.call(
                new Prompt(List.of(
                    new SystemMessage(systemPrompt),
                    new UserMessage(enrichedPrompt)
                ))
            );
            return secondCall.getResult().getOutput().getText();
        }

        return aiResponse;
    }
}

// === 4. Controller——复用现有权限体系 ===
@RestController
@RequestMapping("/api/ai")
public class AiChatController {

    @Autowired
    private BusinessChatService chatService;

    /**
     * 通过现有 Spring Security 权限体系控制访问
     * 用户区域信息从认证上下文获取，无需额外配置
     */
    @PostMapping("/chat")
    @PreAuthorize("hasRole('AI_USER')")
    public ResponseEntity<String> chat(
            @RequestBody String question,
            @AuthenticationPrincipal UserDetails user) {

        // 从用户所属部门推导区域——和业务系统权限一致
        String region = getUserRegion(user);
        String answer = chatService.chat(question, region);
        return ResponseEntity.ok(answer);
    }

    private String getUserRegion(UserDetails user) {
        // 实际项目中从部门/角色映射，这里简化
        return user.getUsername().contains("east") ? "华东" : "全国";
    }
}