目录
一、资金记录
（一）后端
TransFlowController
@Api(tags = "资金记录")
@RestController
@RequestMapping("/api/core/transFlow")
@Slf4j
public class TransFlowController {
@Resource
private 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 {
@Bean
public 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 {
@Resource
private 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.103
port: 5672
virtual-host: /srbhost
username: srbuser
password: 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.103
port: 5672
virtual-host: /srbhost
username: srbuser
password: 123456创建MQ监听器
package com.atguigu.srb.sms.receiver;
@Component
@Slf4j
public class SmsReceiver {
@Resource
private 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);
}
}
