market
/
cloud-market2
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

9.1 李雨欣测试购买记录接口

master
liyuxin 2024-09-01 15:54:32 +08:00 committed by bai
parent 18b7a1d9e3
commit b1656998bf
14 changed files with 338 additions and 65 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
cloud-market2-common/src/main/java/com/muyu/market/admain/Record.java 100644
View File

@ -0,0 +1,78 @@
package com.muyu.market.admain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.market.admain.request.RecordListReq;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.math.BigDecimal;
import java.util.Date;
@Data
@AllArgsConstructor
@SuperBuilder
@NoArgsConstructor
@TableName(value = "market_record",autoResultMap = true)
@EqualsAndHashCode(callSuper = true)
public class Record extends BaseEntity {
/**
* 记录表ID
*/
@TableId(value = "record_id",type = IdType.AUTO)
private Long recordId;
/**
* 用户名称
*/
@Schema(type = "String",description = "用户名称")
private String userName;
/**
* 商品名称
*/
@Schema(type = "String",description = "商品名称")
private String name;
/**
* 价格
*/
@Schema(type = "BigDecimal",description = "价格")
private BigDecimal price;
/**
* 购买时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "购买时间",type = "Date")
private Date buyTime;
private String createBy;
private Date createTime;
private String updateBy;
private Date updateTime;
private String remark;
public static Record SaveRecodeList(RecordListReq recodeListReq){
return Record
.builder()
.recordId(recodeListReq.getRecordId())
.userName(recodeListReq.getUserName())
.name(recodeListReq.getName())
.price(recodeListReq.getPrice())
.buyTime(recodeListReq.getBuyTime())
.build();
}
}

52
cloud-market2-common/src/main/java/com/muyu/market/admain/request/RecordListReq.java 100644
View File

@ -0,0 +1,52 @@
package com.muyu.market.admain.request;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.math.BigDecimal;
import java.util.Date;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "购买商品记录表", description = "购买商品记录表展示请求")
public class RecordListReq {
/**
* 记录表ID
*/
@TableId(value = "record_id",type = IdType.AUTO)
private Long recordId;
/**
* 用户名称
*/
@Schema(type = "String",description = "用户名称")
private String userName;
/**
* 商品名称
*/
@Schema(type = "String",description = "商品名称")
private String name;
/**
* 价格
*/
@Schema(type = "BigDecimal",description = "价格")
private BigDecimal price;
/**
* 购买时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "购买时间",type = "Date")
private Date buyTime;
}

67
cloud-market2-common/src/main/java/com/muyu/market/admain/response/RecordListResp.java 100644
View File

@ -0,0 +1,67 @@
package com.muyu.market.admain.response;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.muyu.market.admain.Record;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.math.BigDecimal;
import java.util.Date;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@Tag(name = "购买商品记录表", description = "购买商品记录表展示请求")
public class RecordListResp {
/**
* 记录表ID
*/
@TableId(value = "record_id",type = IdType.AUTO)
private Long recordId;
/**
* 用户名称
*/
@Schema(type = "String",description = "用户名称")
private String userName;
/**
* 商品名称
*/
@Schema(type = "String",description = "商品名称")
private String name;
/**
* 价格
*/
@Schema(type = "BigDecimal",description = "价格")
private BigDecimal price;
/**
* 购买时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Schema(description = "购买时间",type = "Date")
private Date buyTime;
public static RecordListResp selRecodeList(Record recode){
return RecordListResp
.builder()
.recordId(recode.getRecordId())
.userName(recode.getUserName())
.name(recode.getName())
.price(recode.getPrice())
.buyTime(recode.getBuyTime())
.build();
}
}

52
cloud-market2-server/src/main/java/com/muyu/market/server/controller/RecordController.java 100644
View File

@ -0,0 +1,52 @@
package com.muyu.market.server.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.market.admain.Record;
import com.muyu.market.admain.request.RecordListReq;
import com.muyu.market.admain.response.RecordListResp;
import com.muyu.market.server.service.RecordService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@Slf4j
@RestController
@RequestMapping("/recode")
@Tag(name = "购买记录控制层",description = "购买记录控制层")
@RequiredArgsConstructor
public class RecordController {
@Autowired
private RecordService recodeService;
/**
* 购买记录展示
* @param recodeListReq
* @return
*/
@RequestMapping(path = "/recodeList",method = RequestMethod.POST)
@Operation(summary = "购买记录展示",description = "根据接口数据可以购买记录展示")
public Result<List<RecordListResp>> findByrecodeList(@Validated @RequestBody RecordListReq recodeListReq){
return Result.success( recodeService.findByrecodeList( recodeListReq ));
}
/**
* 添加接口
* @param recodeListReq
* @return
*/
@PostMapping
@Operation(summary = "购买记录添加",description = "购买记录添加，添加成功才可以使用")
public Result<String> save(@Validated @RequestBody RecordListReq recodeListReq){
recodeService.save( Record.SaveRecodeList( recodeListReq ));
return Result.success(null,"操作成功");
}
}

4
cloud-market2-server/src/main/java/com/muyu/market/server/controller/SysLogininforController.java
View File

@ -1,4 +0,0 @@
//package com.muyu.market.server.controller;
//
//public class SysLogininforController {
//}

14
cloud-market2-server/src/main/java/com/muyu/market/server/controller/SysUserController.java
View File

@ -1,9 +1,6 @@
package com.muyu.market.server.controller;
import cn.hutool.http.useragent.UserAgentUtil;
import com.alibaba.fastjson.JSONObject;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.JwtUtils;
import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.common.system.domain.LoginUser;
import com.muyu.market.admain.SysUser;
@ -14,6 +11,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.math.BigDecimal;
@RestController
@RequestMapping("/sysUser")
@Tag( name = "个人信息控制层",description = "用于操作用户个人信息")
@ -31,19 +30,18 @@ public class SysUserController {
return Result.success(byId);
}
//充值
@PostMapping("/updSysUserMoney")
@Operation(summary = "充值",description = "通过修改余额达到充值效果")
public Result updSysUserMoney(@Validated @RequestBody SysUser sysUser){
Integer i = sysUserService.updSysUserMoney( sysUser );
return i>0?Result.success():Result.error(500,"充值失败 请联系管理员");
}
//充值
//支付
@PostMapping("/paySysUserMoney")
@Operation(summary = "支付",description = "通过修改余额达到支付效果")
public Result paySysUserMoney(@Validated @RequestBody SysUser sysUser){
Integer i = sysUserService.paySysUserMoney( sysUser );
public Result paySysUserMoney(@Validated @RequestParam("price") BigDecimal price){
Integer i = sysUserService.paySysUserMoney( price );
return i>0?Result.success():Result.error(500,"充值失败 请联系管理员");
}
// 在哪写
}

9
cloud-market2-server/src/main/java/com/muyu/market/server/mapper/RecordMapper.java 100644
View File

@ -0,0 +1,9 @@
package com.muyu.market.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.market.admain.Record;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface RecordMapper extends BaseMapper<Record> {
}

9
cloud-market2-server/src/main/java/com/muyu/market/server/mapper/SysLogininforMapper.java
View File

@ -1,9 +0,0 @@
//package com.muyu.market.server.mapper;
//
//import com.baomidou.mybatisplus.core.mapper.BaseMapper;
//import com.muyu.market.admain.SysLogininfor;
//import org.apache.ibatis.annotations.Mapper;
//
//@Mapper
//public interface SysLogininforMapper extends BaseMapper<SysLogininfor> {
//}

39
cloud-market2-server/src/main/java/com/muyu/market/server/service/Impl/RecordServiceImpl.java 100644
View File

@ -0,0 +1,39 @@
package com.muyu.market.server.service.Impl;
import com.alibaba.nacos.common.utils.StringUtils;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.market.admain.Record;
import com.muyu.market.admain.request.RecordListReq;
import com.muyu.market.admain.response.RecordListResp;
import com.muyu.market.server.mapper.RecordMapper;
import com.muyu.market.server.service.RecordService;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.stream.Collectors;
@Service
public class RecordServiceImpl extends ServiceImpl<RecordMapper, Record> implements RecordService {
@Override
public List<RecordListResp> findByrecodeList(RecordListReq recodeListReq) {
LambdaQueryWrapper<Record> lambdaQueryWrapperlist = new LambdaQueryWrapper<>();
/**
* 查询购买的API名称
*/
if (StringUtils.isNotBlank( recodeListReq.getName())) {
lambdaQueryWrapperlist.like( Record::getName, recodeListReq.getName());
}
List<Record> recodelist = this.list(lambdaQueryWrapperlist);
return recodelist.stream()
.map( RecordListResp::selRecodeList)
.collect(Collectors.toList());
}
}

20
cloud-market2-server/src/main/java/com/muyu/market/server/service/Impl/SysLogininforServiceImpl.java
View File

@ -1,20 +0,0 @@
//package com.muyu.market.server.service.Impl;
//
//import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
//import com.muyu.market.admain.SysLogininfor;
//
//import com.muyu.market.admain.response.SysLogininforResp;
//import com.muyu.market.server.mapper.SysLogininforMapper;
//import com.muyu.market.server.service.SysLogininforService;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
//@Service
//public class SysLogininforServiceImpl extends ServiceImpl<SysLogininforMapper,SysLogininfor> implements SysLogininforService {
// @Autowired
// private SysLogininforMapper sysLogininforMapper;
// @Override
// public SysLogininforResp selectLogininforByUserName(String userName) {
// return null;
// }
//}

20
cloud-market2-server/src/main/java/com/muyu/market/server/service/Impl/SysUserServiceImpl.java
View File

@ -11,6 +11,7 @@ import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.JwtUtils;
import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.common.system.domain.LoginUser;
import com.muyu.market.admain.Myapi;
import com.muyu.market.admain.SysUser;
import com.muyu.market.server.mapper.SysUserMapper;
import com.muyu.market.server.service.SysUserService;
@ -37,24 +38,25 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
eq( "user_id",loginUser.getUserid() );
return sysUserMapper.update( money );
}
//充值余额
//fufei
@Override
public Integer paySysUserMoney(SysUser sysUser) {
public Integer paySysUserMoney(BigDecimal price) {
// 获取操作人信息
LoginUser loginUser = SecurityUtils.getLoginUser();
// 编译执行器
UpdateWrapper<SysUser> sysUserUpdateWrapper = new UpdateWrapper<>();
//价钱
BigDecimal moneyReq = sysUser.getMoney();
//用户
SysUser user = selectByUserId( Math.toIntExact( sysUser.getUserId() ) );
// BigDecimal moneyReq = sysUser.getMoney();
//查询登录人信息
SysUser user = selectByUserId( Math.toIntExact( loginUser.getUserid() ) );
//用户余额
BigDecimal userMoney = user.getMoney();
int i = userMoney.compareTo( moneyReq );
int i = userMoney.compareTo( price );
if (i < 0) {
throw new RuntimeException("余额不足 请充值");
}
UpdateWrapper<SysUser> money = sysUserUpdateWrapper.setSql("money=money-"+sysUser.getMoney()).
eq( "user_id",loginUser.getUserid() );
UpdateWrapper<SysUser> money = sysUserUpdateWrapper.setSql("money=money-"+price).
eq( "user_id",user.getUserId() );
return sysUserMapper.update( money );
}
//回显用户信息

19
cloud-market2-server/src/main/java/com/muyu/market/server/service/RecordService.java 100644
View File

@ -0,0 +1,19 @@
package com.muyu.market.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.market.admain.Record;
import com.muyu.market.admain.request.RecordListReq;
import com.muyu.market.admain.response.RecordListResp;
import java.util.List;
public interface RecordService extends IService<Record> {
/**
* 查询商品接口
*
* @param recodeListReq
* @return
*/
List<RecordListResp> findByrecodeList(RecordListReq recodeListReq);
}

13
cloud-market2-server/src/main/java/com/muyu/market/server/service/SysLogininforService.java
View File

@ -1,13 +0,0 @@
//package com.muyu.market.server.service;
//
//import com.baomidou.mybatisplus.extension.service.IService;
//import com.muyu.market.admain.SysLogininfor;
//import com.muyu.market.admain.response.SysLogininforResp;
//
//
//public interface SysLogininforService extends IService<SysLogininfor> {
// /*
// 根据名字查询登录日志表
// */
// SysLogininforResp selectLogininforByUserName(String userName);
//}

7
cloud-market2-server/src/main/java/com/muyu/market/server/service/SysUserService.java
View File

@ -1,8 +1,11 @@
package com.muyu.market.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.market.admain.Myapi;
import com.muyu.market.admain.SysUser;
import java.math.BigDecimal;
public interface SysUserService extends IService<SysUser> {
/**
@ -15,10 +18,10 @@ public interface SysUserService extends IService<SysUser> {
/**
* 充值用户余额
*
* @param sysUser
* @param
* @return void
*/
Integer paySysUserMoney(SysUser sysUser);
Integer paySysUserMoney(BigDecimal price);
/**
* 回显用户余额