一、项目背景与意义随着中国资本市场的快速发展与个人投资者数量的激增投资者对于专业、及时、个性化的投资咨询服务需求日益旺盛。传统的投资咨询模式存在信息不对称、服务效率低、覆盖范围有限等问题。东财投资咨询管理系统旨在利用现代互联网技术与大数据分析能力构建一个集信息聚合、智能分析、客户管理、服务交付于一体的综合性平台。项目意义提升服务效率通过系统化管理咨询师、客户与投资标的自动化处理大量重复性工作释放人力专注于高价值分析。实现精准服务基于用户画像与行为数据实现投资建议、市场资讯的个性化推送提升客户满意度与粘性。强化风控合规系统化记录咨询过程与建议满足金融行业的合规要求为服务留痕与责任追溯提供依据。促进业务创新为开发新的数字化投资顾问产品、组合分析工具等增值服务提供底层支撑。二、技术栈选型与架构设计2.1 后端技术栈核心框架Spring Boot 2.7.x (提供快速启动、自动配置、简化部署)安全框架Spring Security JWT (实现用户认证、授权与API安全)数据访问Spring Data JPA (简化数据库操作) MyBatis-Plus (复杂SQL与动态查询)数据库MySQL 8.0 (主业务数据存储) Redis (缓存会话、热点数据)消息队列RabbitMQ (用于异步处理通知、报告生成等任务)API文档Swagger2 / Knife4j (自动生成与测试API接口文档)任务调度Spring Scheduler / XXL-Job (定时同步市场数据、生成日报)2.2 前端技术栈基础框架Vue 3.x Element Plus (构建现代化、响应式管理后台)状态管理Pinia (替代Vuex提供更简洁的状态管理)构建工具Vite (极速的开发服务器与构建体验)HTTP客户端Axios (处理HTTP请求与拦截)2.3 系统架构图概念flowchart TD A[用户/管理员] -- B[Vue3前端] B -- C[Nginx网关] C -- D[SpringBoot应用集群] D -- E[Spring Security JWT] D -- F[业务逻辑层] F -- G[数据访问层 JPA/MyBatis] G -- H[(MySQL)] D -- I[缓存 Redis] D -- J[消息队列 RabbitMQ] J -- K[异步任务服务] K -- L[生成PDF报告] K -- M[发送邮件/SMS] D -- N[第三方数据接口 行情/新闻]三、核心功能模块设计用户中心客户与投资顾问的注册、登录、个人信息管理、风险测评。客户管理顾问对名下客户的档案管理、服务关系绑定、服务记录追踪。投资标的库股票、基金、债券等金融产品的基础信息、行情数据管理。咨询管理核心模块。包含咨询记录创建、投资建议生成与审核、报告模板管理、建议书推送。知识库与资讯投资知识文章、市场研报、新闻资讯的发布与管理。系统管理角色权限管理管理员、首席顾问、顾问、客户、操作日志、系统参数配置。四、核心代码实现解析4.1 统一响应封装与全局异常处理响应体封装 (R.java)import lombok.Data; import java.io.Serializable; Data public class RT implements Serializable { private Integer code; private String msg; private T data; public static lt;Tgt; Rlt;Tgt; ok() { return ok(null); } public static lt;Tgt; Rlt;Tgt; ok(T data) { Rlt;Tgt; r new Rlt;gt;(); r.setCode(200); r.setMsg(success); r.setData(data); return r; } public static lt;Tgt; Rlt;Tgt; error(String msg) { return error(500, msg); } public static lt;Tgt; Rlt;Tgt; error(Integer code, String msg) { Rlt;Tgt; r new Rlt;gt;(); r.setCode(code); r.setMsg(msg); return r; } }全局异常处理器 (GlobalExceptionHandler.java)import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.RestControllerAdvice; import javax.servlet.http.HttpServletRequest; Slf4j RestControllerAdvice public class GlobalExceptionHandler { ExceptionHandler(Exception.class) public Rlt;Objectgt; handleException(Exception e, HttpServletRequest request) { log.error(请求URI: {} 异常信息: , request.getRequestURI(), e); // 可根据e的类型返回更具体的错误码如BusinessException return R.error(500, 系统繁忙请稍后重试); } ExceptionHandler(BusinessException.class) public Rlt;Objectgt; handleBusinessException(BusinessException e) { return R.error(e.getCode(), e.getMessage()); } }4.2 基于JWT的认证与授权JWT工具类 (JwtUtil.java)import io.jsonwebtoken.Claims; import io.jsonwebtoken.Jwts; import io.jsonwebtoken.SignatureAlgorithm; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import java.util.Date; import java.util.HashMap; import java.util.Map; Component public class JwtUtil { Value(${jwt.secret}) private String secret; Value(${jwt.expiration}) private Long expiration; public String generateToken(String username, String role) { Maplt;String, Objectgt; claims new HashMaplt;gt;(); claims.put(username, username); claims.put(role, role); return Jwts.builder() .setClaims(claims) .setSubject(username) .setIssuedAt(new Date()) .setExpiration(new Date(System.currentTimeMillis() expiration)) .signWith(SignatureAlgorithm.HS512, secret) .compact(); } public Claims parseToken(String token) { return Jwts.parser() .setSigningKey(secret) .parseClaimsJws(token) .getBody(); } // 验证、刷新等方法略... }Spring Security配置 (SecurityConfig.java) 核心片段Configuration EnableWebSecurity EnableGlobalMethodSecurity(prePostEnabled true) public class SecurityConfig extends WebSecurityConfigurerAdapter { Autowired private JwtAuthenticationFilter jwtAuthenticationFilter; Override protected void configure(HttpSecurity http) throws Exception { http.csrf().disable() .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS) .and() .authorizeRequests() .antMatchers(/api/auth/login, /api/auth/register).permitAll() .antMatchers(/api/admin/).hasRole(ADMIN) .antMatchers(/api/advisor/).hasAnyRole(ADVISOR, CHIEF_ADVISOR) .antMatchers(/api/client/**).hasRole(CLIENT) .anyRequest().authenticated() .and() .addFilterBefore(jwtAuthenticationFilter, UsernamePasswordAuthenticationFilter.class); } }4.3 咨询建议生成服务 (核心业务逻辑)服务接口与实现 (AdvisoryService.java)public interface AdvisoryService { /** * 生成投资建议 * param request 包含客户ID、风险等级、投资偏好、金额等 * return 建议书草稿 */ AdvisoryDraft generateAdvisory(AdvisoryRequest request); /** * 审核投资建议 * param draftId 建议书ID * param approved 是否通过 * param comment 审核意见 */ void reviewAdvisory(Long draftId, boolean approved, String comment); } Service Slf4j public class AdvisoryServiceImpl implements AdvisoryService { Autowired private ClientRepository clientRepository; Autowired private ProductRepository productRepository; Autowired private AdvisoryTemplateRepository templateRepository; Autowired private RabbitTemplate rabbitTemplate; Override Transactional public AdvisoryDraft generateAdvisory(AdvisoryRequest request) { // 1. 获取客户信息与风险画像 Client client clientRepository.findById(request.getClientId()) .orElseThrow(() - new BusinessException(客户不存在)); // 2. 根据风险等级与偏好从产品库筛选匹配的产品组合 Listlt;FinancialProductgt; candidateProducts productRepository .findByRiskLevelAndCategory(client.getRiskLevel(), request.getPreference()); // 3. 应用资产配置模型简化示例按比例分配 Maplt;FinancialProduct, BigDecimalgt; allocation simpleAllocationModel(candidateProducts, request.getAmount()); // 4. 选择报告模板并填充数据 AdvisoryTemplate template templateRepository.findByRiskLevel(client.getRiskLevel()); AdvisoryDraft draft new AdvisoryDraft(); draft.setClient(client); draft.setAdvisor(request.getAdvisorId()); draft.setProductAllocation(allocation); draft.setContent(template.fillContent(client, allocation)); draft.setStatus(DraftStatus.PENDING_REVIEW); advisoryDraftRepository.save(draft); // 5. 异步通知审核人员 rabbitTemplate.convertAndSend(advisory.exchange, review.routing.key, draft.getId()); log.info(投资建议草稿已生成ID: {}, draft.getId()); return draft; } // 其他方法略... }4.4 使用MyBatis-Plus实现复杂查询Mapper接口与XML配置示例// Service层调用 Service public class ClientServiceImpl implements ClientService { Autowired private ClientMapper clientMapper; public Pagelt;ClientVOgt; getClientsByAdvisor(Long advisorId, ClientQueryDTO queryDTO) { Pagelt;Clientgt; page new Pagelt;gt;(queryDTO.getPageNum(), queryDTO.getPageSize()); return clientMapper.selectPageByAdvisor(page, advisorId, queryDTO); } } // Mapper接口 public interface ClientMapper extends BaseMapperClient { PageClientVO selectPageByAdvisor(Param(page) PageClient page, Param(advisorId) Long advisorId, Param(query) ClientQueryDTO queryDTO); }!-- ClientMapper.xml -- select idselectPageByAdvisor resultTypecom.dongcai.advisory.vo.ClientVO SELECT c.id, c.name, c.risk_level, c.total_assets, COUNT(a.id) as advisory_count, MAX(a.create_time) as last_advisory_time FROM client c LEFT JOIN advisory_draft a ON c.id a.client_id AND a.status DELIVERED WHERE c.advisor_id #{advisorId} if testquery.name ! null and query.name ! AND c.name LIKE CONCAT(%, #{query.name}, %) /if if testquery.minAsset ! null AND c.total_assets #{query.minAsset} /if GROUP BY c.id ORDER BY c.create_time DESC /select五、总结与展望本文详细阐述了基于SpringBoot的东财投资咨询管理系统的设计背景、技术选型与核心代码实现。系统采用前后端分离架构后端以SpringBoot为核心整合了安全、数据访问、缓存、消息队列等组件确保了系统的高性能、安全性与可扩展性。核心业务模块如基于JWT的认证授权、投资建议的生成与审核流程均提供了可落地的代码示例。未来可扩展方向智能化升级引入机器学习模型对市场数据与客户行为进行深度分析提供更精准的资产配置建议。微服务化改造随着业务复杂度的提升可将用户中心、产品中心、咨询中心拆分为独立微服务。移动端适配开发小程序或APP为客户提供更便捷的移动端服务体验。开放API对外提供标准化的API接口支持与第三方理财平台、交易所系统进行对接。