文章目录
介绍
本篇将以springboot+mybatis-plus搭建一个简单的微服务项目，包括几个简单表用户表，商品表，订单表，库存表。以resttemplate进行模块之间的相互调用。
建表sql和数据
表脚本
-- test.`user` definition
CREATE TABLE `user` (
`user_id` int NOT NULL AUTO_INCREMENT COMMENT '用户Id',
`user_name` varchar(100) NOT NULL COMMENT '用户名字',
`user_age` int DEFAULT NULL COMMENT '用户年龄',
`user_phone` varchar(11) DEFAULT NULL COMMENT '联系电话',
`user_mail` varchar(100) DEFAULT NULL COMMENT '邮箱',
`user_address` varchar(100) DEFAULT NULL COMMENT '用户地址',
`user_status` varchar(1) DEFAULT NULL COMMENT '用户状态',
`update_by` varchar(100) DEFAULT NULL COMMENT '更新人',
`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`create_by` varchar(100) DEFAULT NULL COMMENT '创建人',
`update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`user_id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-- test.product definition
CREATE TABLE `product` (
`product_id` int NOT NULL AUTO_INCREMENT COMMENT '商品ID',
`product_name` varchar(100) DEFAULT NULL COMMENT '商品名称',
`product_type` varchar(10) DEFAULT NULL,
`product_price` decimal(10,0) DEFAULT NULL COMMENT '商品价格',
`create_by` varchar(100) DEFAULT NULL COMMENT '创建人',
`update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
`update_by` varchar(100) DEFAULT NULL COMMENT '更新人',
`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`product_id`),
KEY `product_product_type_IDX` (`product_type`,`product_name`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='商品表';
-- test.stock definition
CREATE TABLE `stock` (
`stock_id` int NOT NULL AUTO_INCREMENT COMMENT '库存主键',
`product_id` int NOT NULL COMMENT '商品ID',
`stock_num` int DEFAULT NULL COMMENT '库存数量',
`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`create_by` varchar(100) DEFAULT NULL COMMENT '创建人',
`update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
`update_by` varchar(100) DEFAULT NULL COMMENT '更新人',
PRIMARY KEY (`stock_id`),
KEY `stock_product_id_IDX` (`product_id`) USING BTREE,
CONSTRAINT `stock_FK` FOREIGN KEY (`product_id`) REFERENCES `product` (`product_id`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='库存表';
-- test.`order` definition
CREATE TABLE `order` (
`order_id` int NOT NULL AUTO_INCREMENT COMMENT '订单ID',
`order_no` int DEFAULT NULL COMMENT '订单号',
`product_id` int DEFAULT NULL COMMENT '产品id',
`user_id` int DEFAULT NULL COMMENT '用户ID',
`order_num` int DEFAULT NULL COMMENT '订单产品数量',
`order_amt` decimal(10,2) DEFAULT NULL COMMENT '订单金额',
`order_status` varchar(10) DEFAULT NULL COMMENT '订单状态',
`pay_status` varchar(10) DEFAULT NULL COMMENT '支付状态',
`create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
`create_user` varchar(10) DEFAULT NULL COMMENT '创建人',
`update_user` varchar(10) DEFAULT NULL COMMENT '更新人',
PRIMARY KEY (`order_id`)
) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='订单表';
表数据
INSERT INTO test.`user`
(user_id, user_name, user_age, user_phone, user_mail, user_address, user_status, update_by, create_time, create_by, update_time)
VALUES(1, 'elite', 24, '18388888888', '18388888888@163.com', 'xx省xx市xx区', '1', NULL, '2022-09-06 13:17:24', NULL, '2022-09-06 13:17:30');
INSERT INTO test.`user`
(user_id, user_name, user_age, user_phone, user_mail, user_address, user_status, update_by, create_time, create_by, update_time)
VALUES(3, 'test', 22, '18366666666', '18366666666@163.com', 'xx省xx市xx区', '1', NULL, '2022-09-06 15:10:59', NULL, '2022-09-06 15:10:59');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(1, '华为', '手机', 5999, NULL, '2022-09-06 15:12:29', NULL, '2022-09-06 15:12:29');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(2, '小米', '手机', 4999, NULL, '2022-09-06 15:12:29', NULL, '2022-09-06 15:12:29');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(3, 'OPPO', '手机', 3999, NULL, '2022-09-06 15:12:29', NULL, '2022-09-06 15:12:29');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(4, '联想拯救者', '电脑', 8999, NULL, '2022-09-06 15:13:43', NULL, '2022-09-06 15:13:43');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(5, 'Dell', '电脑', 6999, NULL, '2022-09-06 15:13:43', NULL, '2022-09-06 15:13:43');
INSERT INTO test.product
(product_id, product_name, product_type, product_price, create_by, update_time, update_by, create_time)
VALUES(6, '华为mate', '电脑', 7999, NULL, '2022-09-06 15:13:43', NULL, '2022-09-06 15:13:43');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(1, 1, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(6, 6, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(5, 5, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(4, 4, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(3, 3, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.stock
(stock_id, product_id, stock_num, create_time, create_by, update_time, update_by)
VALUES(2, 2, 100, '2022-09-06 15:19:18', 'elite', '2022-09-06 15:19:18', 'elite');
INSERT INTO test.`order`
(order_id, order_no, product_id, user_id, order_num, order_amt, order_status, pay_status, create_time, update_time, create_user, update_user)
VALUES(1, 1, 1, 1, 2, 0.00, '已发货', '支付完成', '2022-08-21 08:32:40', '2022-08-21 10:48:44', 'user1', 'user2');
INSERT INTO test.`order`
(order_id, order_no, product_id, user_id, order_num, order_amt, order_status, pay_status, create_time, update_time, create_user, update_user)
VALUES(3, 2, 2, 1, 2, 20.00, '取消下单', '未支付', '2022-08-21 11:20:29', '2022-08-21 11:20:29', 'annotation', 'annotation');
INSERT INTO test.`order`
(order_id, order_no, product_id, user_id, order_num, order_amt, order_status, pay_status, create_time, update_time, create_user, update_user)
VALUES(4, 4, 1, 1, 2, 20.00, '下单', '支付', '2022-08-21 11:25:09', '2022-08-21 11:25:09', 'annotation', 'annotation');
INSERT INTO test.`order`
(order_id, order_no, product_id, user_id, order_num, order_amt, order_status, pay_status, create_time, update_time, create_user, update_user)
VALUES(6, 3, 3, 3, 2, 30.00, '发货', '支付', '2022-08-22 00:38:30', '2022-08-22 00:38:30', 'plus', 'plus');
INSERT INTO test.`order`
(order_id, order_no, product_id, user_id, order_num, order_amt, order_status, pay_status, create_time, update_time, create_user, update_user)
VALUES(7, 3, 3, 3, 2, 30.00, '下单', '未支付', '2022-08-22 00:47:29', '2022-08-22 00:47:29', 'plus', 'plus');
项目结构
common模块
common存放公共的实体,这里只贴一个实体，其他的后续会上传。
/**
* 商品表
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("`product`")
public class Product {
/**
* 商品ID
*/
@TableId(value = "product_id", type = IdType.AUTO)
private Integer productId;
/**
* 商品名
*/
@TableField(value = "product_name")
private String productName;
/**
* 商品分类
*/
@TableField(value = "product_type")
private String productType;
/**
* 商品分类
*/
@TableField(value = "product_price")
private BigDecimal productPrice;
//创建人
@TableField(value = "create_by")
private String createBy;
//创建时间
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@TableField(value = "create_time",fill = FieldFill.INSERT)
private String createTime;
//更新人
@TableField(value = "update_by")
private String updateBy;
//更新时间
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@TableField(value = "update_time",fill = FieldFill.INSERT_UPDATE)
private String updateTime;
}
user服务模块
mybtias的部分就不多说了，不清楚可以看我前边的博客。Springboot整合MybatisPlus
controller代码：
/**
* <p>
* 前端控制器
* </p>
*
* @author elite
* @since 2022-09-06
*/
@RestController
@RequestMapping("/springcloud/user")
public class UserController {
@Autowired
IUserService userService;
/**
* 获取用户列表
* @return
*/
@GetMapping("/getUserList")
public List<User> getUserList(){
return userService.list();
}
/**
* 获取用户
* @param user_id
* @return
*/
@GetMapping("/getUserByUseId/{user_id}")
public User getUserByUseId(@PathVariable("user_id")Integer user_id){
return userService.getById(user_id);
}
}
商品服务模块
同理，这里只贴controller层代码.
/**
* /springcloud/product/getProductList
* <p>
* 商品表 前端控制器
* </p>
*
* @author elite
* @since 2022-09-06
*/
@RestController
@RequestMapping("/springcloud/product")
public class ProductController {
@Autowired
IProductService productService;
/**
* 获取商品列表
* @return
*/
@GetMapping("/getProductList")
public List<Product> getProductList(){
return productService.list();
}
/**
* 获取商品
* @param product_id
* @return
*/
@GetMapping("/getProductById/{product_id}")
public Product getProductById(@PathVariable("product_id")Integer product_id){
return productService.getById(product_id);
}
}
库存模块
/**
* <p>
* 库存表 前端控制器
* </p>
*
* @author elite
* @since 2022-09-06
*/
@RestController
@RequestMapping("/springcloud/stock")
public class StockController {
@Autowired
IStockService stockService;
/**
* 获取库存列表
* @return
*/
@GetMapping("/getStockList")
public List<Stock> getStockList(){
return stockService.list();
}
/**
* 获取库存ID
* @param stock_id
* @return
*/
@GetMapping("/getStockById/{stock_id}")
public Stock getStockById(@PathVariable("stock_id")Integer stock_id){
return stockService.getById(stock_id);
}
}
订单模块
订单模块，获取订单信息，获取对应的用户信息与商品信息。以resttemplate调用用户模块服务以及商品服务模块。
/**
* <p>
* 订单表 前端控制器
* </p>
*
* @author elite
* @since 2022-09-06
*/
@RestController
@RequestMapping("/springcloud/order")
public class OrderController {
@Autowired
IOrderService orderService;
@Autowired
RestTemplate restTemplate;
/**
* 获取订单列表
* @return
*/
@GetMapping("/getOrderList")
public List<Order> getOrderList(){
return orderService.list();
}
/**
* 获取订单列表
* @return
*/
@GetMapping("/getOrderById/{order_id}")
public HashMap<String,Object> getOrderById(@PathVariable("order_id")Integer order_id){
HashMap<String,Object> res = new HashMap<>();
//获取订单
Order order = orderService.getById(order_id);
res.put("order",order);
//获取用户
User user = restTemplate.getForObject("http://localhost:8081/springcloud/user/getUserByUseId/"+order.getUserId(), User.class);
res.put("user",user);
//获取商品信息
Product product = restTemplate.getForObject("http://localhost:8082/springcloud/product/getProductById/"+order.getProductId(), Product.class);
res.put("product",product);
return res;
}
}
测试
完整的订单信息，包括订单信息，用户信息，商品信息。
