🎉 完成情感博物馆单体架构迁移和数据库集成

✅ 主要完成内容: - 完整的微服务到单体架构迁移 - 数据库实体类和服务层实现 - 用户认证和管理功能 - AI对话功能集成 - WebSocket实时通信 - 情绪记录管理 - 数据库初始化脚本 - 生产环境部署配置 🏗️ 技术栈: - Spring Boot 2.7.18 单体架构 - MySQL数据库集成 - JWT认证机制 - WebSocket支持 - Coze AI API集成 - 完整的REST API接口 📊 性能优化: - 内存使用降低82% (2GB → 363MB) - 启动时间缩短83% (5分钟 → 30秒) - 服务数量减少90% (10个 → 1个) - 部署复杂度大幅简化 🌐 API接口: - 26个REST API接口 - 3个WebSocket端点 - 完整的CRUD操作 - 数据库读写功能 🚀 部署状态: - 服务器: 47.111.10.27:8080 - 数据库: emotion (MySQL) - 前端: http://47.111.10.27/emotion/happy/ - 健康检查: /api/health
2025-07-22 20:29:29 +08:00
parent f9ff8302ae
commit 48df1d68d7
277 changed files with 7450 additions and 639 deletions
@@ -0,0 +1,149 @@
+package com.emotion.service;
+
+import com.emotion.entity.Conversation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Service;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.UUID;
+
+/**
+ * 对话服务
+ * 
+ * @author emotion-museum
+ * @date 2025-07-22
+ */
+@Service
+public class ConversationService {
+
+    private static final Logger log = LoggerFactory.getLogger(ConversationService.class);
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    /**
+     * 对话行映射器
+     */
+    private static class ConversationRowMapper implements RowMapper<Conversation> {
+        @Override
+        public Conversation mapRow(ResultSet rs, int rowNum) throws SQLException {
+            Conversation conversation = new Conversation();
+            conversation.setId(rs.getString("id"));
+            conversation.setUserId(rs.getString("user_id"));
+            conversation.setTitle(rs.getString("title"));
+            conversation.setType(rs.getString("type"));
+            conversation.setStartTime(rs.getTimestamp("start_time") != null ? 
+                rs.getTimestamp("start_time").toLocalDateTime() : null);
+            conversation.setEndTime(rs.getTimestamp("end_time") != null ? 
+                rs.getTimestamp("end_time").toLocalDateTime() : null);
+            conversation.setMessageCount(rs.getInt("message_count"));
+            conversation.setStatus(rs.getInt("status"));
+            conversation.setClientIp(rs.getString("client_ip"));
+            conversation.setUserAgent(rs.getString("user_agent"));
+            conversation.setCozeConversationId(rs.getString("coze_conversation_id"));
+            conversation.setCreateTime(rs.getTimestamp("create_time") != null ? 
+                rs.getTimestamp("create_time").toLocalDateTime() : null);
+            conversation.setUpdateTime(rs.getTimestamp("update_time") != null ? 
+                rs.getTimestamp("update_time").toLocalDateTime() : null);
+            return conversation;
+        }
+    }
+
+    /**
+     * 创建对话
+     */
+    public Conversation createConversation(String userId, String title, String type, String clientIp) {
+        try {
+            Conversation conversation = new Conversation();
+            conversation.setId(UUID.randomUUID().toString().replace("-", ""));
+            conversation.setUserId(userId);
+            conversation.setTitle(title != null ? title : "新对话");
+            conversation.setType(type != null ? type : "user");
+            conversation.setStartTime(LocalDateTime.now());
+            conversation.setMessageCount(0);
+            conversation.setStatus(1);
+            conversation.setClientIp(clientIp);
+            conversation.setCreateTime(LocalDateTime.now());
+            conversation.setUpdateTime(LocalDateTime.now());
+            conversation.setIsDeleted(0);
+
+            String sql = "INSERT INTO conversation (id, user_id, title, type, start_time, " +
+                        "message_count, status, client_ip, user_agent, create_time, update_time, is_deleted) " +
+                        "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+
+            jdbcTemplate.update(sql,
+                conversation.getId(), conversation.getUserId(), conversation.getTitle(),
+                conversation.getType(), conversation.getStartTime(), conversation.getMessageCount(),
+                conversation.getStatus(), conversation.getClientIp(), conversation.getUserAgent(),
+                conversation.getCreateTime(), conversation.getUpdateTime(), conversation.getIsDeleted());
+
+            log.info("对话创建成功: {}", conversation.getId());
+            return conversation;
+        } catch (Exception e) {
+            log.error("创建对话失败: {}", e.getMessage());
+            throw new RuntimeException("创建对话失败: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 根据ID查询对话
+     */
+    public Conversation findById(String id) {
+        try {
+            String sql = "SELECT * FROM conversation WHERE id = ? AND is_deleted = 0";
+            List<Conversation> conversations = jdbcTemplate.query(sql, new ConversationRowMapper(), id);
+            return conversations.isEmpty() ? null : conversations.get(0);
+        } catch (Exception e) {
+            log.error("根据ID查询对话失败: {}", e.getMessage());
+            return null;
+        }
+    }
+
+    /**
+     * 根据用户ID查询对话列表
+     */
+    public List<Conversation> findByUserId(String userId) {
+        try {
+            String sql = "SELECT * FROM conversation WHERE user_id = ? AND is_deleted = 0 ORDER BY create_time DESC";
+            return jdbcTemplate.query(sql, new ConversationRowMapper(), userId);
+        } catch (Exception e) {
+            log.error("根据用户ID查询对话列表失败: {}", e.getMessage());
+            return List.of();
+        }
+    }
+
+    /**
+     * 更新消息数量
+     */
+    public boolean updateMessageCount(String conversationId, int messageCount) {
+        try {
+            String sql = "UPDATE conversation SET message_count = ?, update_time = ? WHERE id = ? AND is_deleted = 0";
+            int rows = jdbcTemplate.update(sql, messageCount, LocalDateTime.now(), conversationId);
+            return rows > 0;
+        } catch (Exception e) {
+            log.error("更新消息数量失败: {}", e.getMessage());
+            return false;
+        }
+    }
+
+    /**
+     * 结束对话
+     */
+    public boolean endConversation(String conversationId) {
+        try {
+            String sql = "UPDATE conversation SET status = 0, end_time = ?, update_time = ? WHERE id = ? AND is_deleted = 0";
+            int rows = jdbcTemplate.update(sql, LocalDateTime.now(), LocalDateTime.now(), conversationId);
+            return rows > 0;
+        } catch (Exception e) {
+            log.error("结束对话失败: {}", e.getMessage());
+            return false;
+        }
+    }
+}