一、资金记录

（一）后端

（二）前端

二、个人中心

（一）后端

（二）前端

三、整合rabbitmq

（一）linux下rabbitmq 的安装

（二）整合rabbitmq发送短信

1、MQ服务器设置

2、创建rabbit-mq模块

3、service-base中创建SmsDTO

4、service-core中发送消息

5、service-sms中监听消息

一、资金记录

（一）后端

TransFlowController

@Api(tags = "资金记录")
@RestController
@RequestMapping("/api/core/transFlow")
@Slf4j
public class TransFlowController {@Resourceprivate TransFlowService transFlowService;@ApiOperation("获取列表")@GetMapping("/list")public R list(HttpServletRequest request) {String token = request.getHeader("token");Long userId = JwtUtils.getUserId(token);List<TransFlow> list = transFlowService.selectByUserId(userId);return R.ok().data("list", list);}
}

接口：TransFlowService

List<TransFlow> selectByUserId(Long userId);

实现：TransFlowServiceImpl

@Override
public List<TransFlow> selectByUserId(Long userId) {QueryWrapper<TransFlow> queryWrapper = new QueryWrapper<>();queryWrapper.eq("user_id", userId).orderByDesc("id");return baseMapper.selectList(queryWrapper);
}

（二）前端

脚本pages/user/fund.vue

fetchTransFlowList() {this.$axios.$get('/api/core/transFlow/list').then((response) => {this.transFlowList = response.data.list})
},

二、个人中心

（一）后端

创建VO

@Data
@ApiModel(description = "首页用户信息")
public class UserIndexVO {@ApiModelProperty(value = "用户id")private Long userId;@ApiModelProperty(value = "用户姓名")private String name;@ApiModelProperty(value = "用户昵称")private String nickName;@ApiModelProperty(value = "1：出借人 2：借款人")private Integer userType;@ApiModelProperty(value = "用户头像")private String headImg;@ApiModelProperty(value = "绑定状态（0：未绑定，1：绑定成功 -1：绑定失败）")private Integer bindStatus;@ApiModelProperty(value = "帐户可用余额")private BigDecimal amount;@ApiModelProperty(value = "冻结金额")private BigDecimal freezeAmount;@ApiModelProperty(value = "上次登录时间")private LocalDateTime lastLoginTime;}

UserInfoController

@ApiOperation("获取个人空间用户信息")
@GetMapping("/auth/getIndexUserInfo")
public R getIndexUserInfo(HttpServletRequest request) {String token = request.getHeader("token");Long userId = JwtUtils.getUserId(token);UserIndexVO userIndexVO = userInfoService.getIndexUserInfo(userId);return R.ok().data("userIndexVO", userIndexVO);
}

接口：UserInfoService

UserIndexVO getIndexUserInfo(Long userId);

实现：UserInfoServiceImpl

@Override
public UserIndexVO getIndexUserInfo(Long userId) {//用户信息UserInfo userInfo = baseMapper.selectById(userId);//账户信息QueryWrapper<UserAccount> userAccountQueryWrapper = new QueryWrapper<>();userAccountQueryWrapper.eq("user_id", userId);UserAccount userAccount = userAccountMapper.selectOne(userAccountQueryWrapper);//登录信息QueryWrapper<UserLoginRecord> userLoginRecordQueryWrapper = new QueryWrapper<>();userLoginRecordQueryWrapper.eq("user_id", userId).orderByDesc("id").last("limit 1");UserLoginRecord userLoginRecord = userLoginRecordMapper.selectOne(userLoginRecordQueryWrapper);result.put("userLoginRecord", userLoginRecord);//组装结果数据UserIndexVO userIndexVO = new UserIndexVO();userIndexVO.setUserId(userInfo.getId());userIndexVO.setUserType(userInfo.getUserType());userIndexVO.setName(userInfo.getName());userIndexVO.setNickName(userInfo.getNickName());userIndexVO.setHeadImg(userInfo.getHeadImg());userIndexVO.setBindStatus(userInfo.getBindStatus());userIndexVO.setAmount(userAccount.getAmount());userIndexVO.setFreezeAmount(userAccount.getFreezeAmount());userIndexVO.setLastLoginTime(userLoginRecord.getCreateTime());return userIndexVO;
}

（二）前端

pages/user/index.vue

fetchUserData() {this.$axios.$get('/api/core/userInfo/auth/getIndexUserInfo').then((response) => {this.userIndexVO = response.data.userIndexVO})
},

三、整合rabbitmq

（一）linux下rabbitmq 的安装

rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm

rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm

rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm

以上按顺序安装

启用管理插件

rabbitmq-plugins enable rabbitmq_management

启动rabbitmq

systemctl start rabbitmq-server.service

查看后台进程

ps -ef | grep rabbitmq

因为linux下开启rabbitmq，默认的guest账户只能在本地访问，因此我们要新建用户

//添加管理员账户和密码

rabbitmqctl add_user admin 123456

// 分配账号角色
rabbitmqctl set_user_tags admin administrator

// 修改密码（要修改一次密码，否则无法登录）

rabbitmqctl change_password admin admin

// 查看用户列表

rabbitmqctl list_users

（二）整合rabbitmq发送短信

1、MQ服务器设置

创建用户 srbuser，配置管理员权限

创建虚拟机 /srbhost，在Set permission中为新建的用户分配访问虚拟机 /srbhost 和 / 的权限

2、创建rabbit-mq模块

srb下创建rabbit-mq模块并引入依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency>
</dependencies>

MQConfig

@Configuration
public class MQConfig {@Beanpublic MessageConverter messageConverter(){//json字符串转换器return new Jackson2JsonMessageConverter();}
}

MQConst

public class MQConst {public static final String EXCHANGE_TOPIC_SMS = "exchange.topic.sms";//交换机public static final String ROUTING_SMS_ITEM = "routing.sms.item";//路由public static final String QUEUE_SMS_ITEM  = "queue.sms.item";//消息队列
}

MQService

@Service
@Slf4j
public class MQService {@Resourceprivate AmqpTemplate amqpTemplate;/***  发送消息* @param exchange 交换机* @param routingKey 路由* @param message 消息*/public boolean sendMessage(String exchange, String routingKey, Object message) {log.info("发送消息...........");amqpTemplate.convertAndSend(exchange, routingKey, message);return true;}
}

3、service-base中创建SmsDTO


@Data
@ApiModel(description = "短信")
public class SmsDTO {@ApiModelProperty(value = "手机号")private String mobile;@ApiModelProperty(value = "消息内容")private String message;
}

4、service-core中发送消息

引入依赖

<!--rabbitmq消息队列-->
<dependency><groupId>com.atguigu</groupId><artifactId>rabbit-mq</artifactId><version>0.0.1-SNAPSHOT</version>
</dependency>

yml配置

  #spring:rabbitmq:host: 192.168.100.103port: 5672virtual-host: /srbhostusername: srbuserpassword: 123456

根据bindCode获取手机号

UserInfoService接口：

String getMobileByBindCode(String bindCode);

UserInfoServiceImpl实现：

@Override
public String getMobileByBindCode(String bindCode) {QueryWrapper<UserInfo> userInfoQueryWrapper = new QueryWrapper<>();userInfoQueryWrapper.eq("bind_code", bindCode);UserInfo userInfo = baseMapper.selectOne(userInfoQueryWrapper);return userInfo.getMobile();
}

向MQ发送信息：UserAccountServiceImpl 充值回调方法的最后添加发送消息的代码：

@Resource
private UserInfoService userInfoService;
@Resource
private MQService mqService;@Transactional(rollbackFor = Exception.class)
@Override
public void notify(Map<String, Object> paramMap) {log.info("充值成功：" + JSONObject.toJSONString(paramMap));......//发消息log.info("发消息");String mobile = userInfoService.getMobileByBindCode(bindCode);SmsDTO smsDTO = new SmsDTO();smsDTO.setMobile(mobile);smsDTO.setMessage("充值成功");mqService.sendMessage(MQConst.EXCHANGE_TOPIC_SMS, MQConst.ROUTING_SMS_ITEM, smsDTO);
}

5、service-sms中监听消息

引入依赖

<!--rabbitmq消息队列-->
<dependency><groupId>com.atguigu</groupId><artifactId>rabbit-mq</artifactId><version>0.0.1-SNAPSHOT</version>
</dependency>

yml配置

  #spring:rabbitmq:host: 192.168.100.103port: 5672virtual-host: /srbhostusername: srbuserpassword: 123456

创建MQ监听器

package com.atguigu.srb.sms.receiver;@Component
@Slf4j
public class SmsReceiver {@Resourceprivate SmsService smsService;@RabbitListener(bindings = @QueueBinding(value = @Queue(value = MQConst.QUEUE_SMS_ITEM, durable = "true"),exchange = @Exchange(value = MQConst.EXCHANGE_TOPIC_SMS),key = {MQConst.ROUTING_SMS_ITEM}))public void send(SmsDTO smsDTO) throws IOException {log.info("SmsReceiver 消息监听");Map<String,Object> param = new HashMap<>();param.put("code", smsDTO.getMessage());smsService.send(smsDTO.getMobile(), SmsProperties.TEMPLATE_CODE, param);}
}

距尚融宝第一篇博客发布已经过去了一个半月，终于完成了尚融宝这个项目，这个项目主要是在业务上难以理解，后面的投资和放款，还款也涉及多张表的改动，需要保持头脑清晰，理清思路。

接下来继续沉淀，学习一下新的知识，复习旧知识夯实自己的基础。

山高路远，有缘再会！

尚融宝30（终）-资金记录和个人中心展示相关推荐

【金融项目】尚融宝项目（十五）
29.提现和还款 29.1.提现 29.1.1.需求放款成功后,借款人可以申请提现. 参考<汇付宝商户账户技术文档>3.15用户申请提现 29.1.2.前端整合 pages/user/w ...
【金融项目】尚融宝项目（十四）
27.放款 27.1.需求介绍 27.1.1.平台放款 1.需求描述标的募资时间到,平台会操作放款或撤标,如果达到放款条件则操作放款说明:撤标过程与放款过程一致,处理业务相对简单,只是将出借金额返 ...
【金融项目】尚融宝项目（十）
19.申请借款额度 19.1.需求介绍 19.1.1.借款人申请额度 1.需求描述平台管理员根据借款人个人信息设置积分,通过积分规则借款人可以获取额度. 2.相关数据库表 19.1.2.具体步骤 s ...
【金融项目】尚融宝项目（四）
6.Alibaba EasyExcel 6.1.EasyExcel简介 6.1.1.Excel导入导出的应用场景 6.1.1.1.数据导入减轻录入工作量 6.1.1.2.数据导出统计信息归档 6. ...
【金融项目】尚融宝项目（九）
18.账户绑定 18.1.需求介绍 18.1.1.运行汇付宝 1.数据库 hfb.sql 2.程序 hfb 3.数据库配置 application-dev.yml 中修改数据库配置 4.启动程序端口 ...
【金融项目】尚融宝项目（三）
5.管理平台前端搭建 5.1.搭建管理平台前端程序 5.1.1.vue-element-admin vue-element-admin是基于element-ui 的一套后台管理系统集成方案. GitH ...
【金融项目】尚融宝项目（十三）
25.充值 25.1.需求介绍 25.1.1.投资人充值 **1.需求描述 ** 标的产生后,平台展示标的,投资人就可以在平台投资标的,获取收益:投资人投资标的必须满足以下条件: 充值过程与绑定过程一 ...
微服务项目：尚融宝（53）（核心业务流程：投标（4））
认清现实,放弃幻想,准备斗争前端整合投资 pages/lend/_id.vue //投资commitInvest() {//校验用户是否登录let userInfo = cookie.get('u ...
【金融项目】尚融宝项目（一）
1.尚融宝项目简介 1.1.前言尚融宝项目是一个网络借贷信息中介服务平台,为个人投资者.个人融资用户和小微企业提供专业的线上信贷及出借撮合服务. 行业案例:人人贷 https://www.renre ...

尚融宝30（终）-资金记录和个人中心展示

一、资金记录

（一）后端

（二）前端

二、个人中心

（一）后端

（二）前端

三、整合rabbitmq

（一）linux下rabbitmq 的安装

（二）整合rabbitmq发送短信

1、MQ服务器设置

2、创建rabbit-mq模块

3、service-base中创建SmsDTO

4、service-core中发送消息

5、service-sms中监听消息

尚融宝30（终）-资金记录和个人中心展示相关推荐

最新文章

热门文章