idea新建springCloud项目（4）- 商品服务

为什么80%的码农都做不了架构师？>>>   

需要实现商品服务的这4个功能：

1.先从商品api文档入手,查看商品结构，如下：

请求方式：GET    请求URL：/product/list    返回参数： {     "code": 0,     "msg": "成功",     "data": [         {             "name": "热榜",             "type": 1,             "foods": [                 {                     "id": "123456",                     "name": "皮蛋粥",                     "price": 1.2,                     "description": "好吃的皮蛋粥",                     "icon": "http://xxx.com",                 }             ]         },         {             "name": "好吃的",             "type": 2,             "foods": [                 {                     "id": "123457",                     "name": "慕斯蛋糕",                     "price": 10.9,                     "description": "美味爽口",                     "icon": "http://xxx.com",                 }             ]         }     ] }

2.新建数据库

3.新建类目、商品表

-- 商品 create table `product_info` (     `product_id` varchar(32) not null,     `product_name` varchar(64) not null comment '商品名称',     `product_price` decimal(8,2) not null comment '单价',     `product_stock` int not null comment '库存',     `product_description` varchar(64) comment '描述',     `product_icon` varchar(512) comment '小图',     `product_status` tinyint(3) DEFAULT '0' COMMENT '商品状态,0正常1下架',     `category_type` int not null comment '类目编号',     `create_time` timestamp not null default current_timestamp comment '创建时间',     `update_time` timestamp not null default current_timestamp on update current_timestamp comment '修改时间',     primary key (`product_id`) ); INSERT INTO `product_info` (`product_id`, `product_name`, `product_price`, `product_stock`, `product_description`, `product_icon`, `product_status`, `category_type`, `create_time`, `update_time`) VALUES     ('157875196366160022','皮蛋粥',0.01,39,'好吃的皮蛋粥','//fuss10.elemecdn.com/0/49/65d10ef215d3c770ebb2b5ea962a7jpeg.jpeg',0,1,'2017-03-28 19:39:15','2017-07-02 11:45:44'),     ('157875227953464068','慕斯蛋糕',10.90,200,'美味爽口','//fuss10.elemecdn.com/9/93/91994e8456818dfe7b0bd95f10a50jpeg.jpeg',1,1,'2017-03-28 19:35:54','2017-04-21 10:05:57'),     ('164103465734242707','蜜汁鸡翅',0.02,982,'好吃','//fuss10.elemecdn.com/7/4a/f307f56216b03f067155aec8b124ejpeg.jpeg',0,1,'2017-03-30 17:11:56','2017-06-24 19:20:54');

4.在IDEA新建springCloud项目-商品服务

修改版本，和之前建的eureka项目版本一致，修改完记得刷新：

删除掉不需要的文件：

5.把商品服务注册到eureka上去，启动项目

将application.properties修改为application.yml

记得加上这个注解，再启动项目：

打开8761的eureka，有如下页面则成功将商品服务注册到8761的eureka上：

6.商品业务实现

在pom.xml添加spring-boot-starter-data-jpa和mysql-connector-java依赖，且刷新：

在application.yml配置数据库信息

新建ResultVO.java——http请求返回的最外层对象

ResultVO.java

/**  * http请求返回的最外层对象  */ @Data public class ResultVO<T> {     /**      * 错误码      */     private Integer code;     /**      * 提示信息      */     private String msg;     /**      * 具体内容      */     private T data; }

测试类，不需每次都去拷贝这2个注解了，，直接用@Component注解，且继承公共测试类：

新建ResultVOUtil.java

ResultVOUtil.java

public class ResultVOUtil {     public static ResultVO success(Object object) {         ResultVO resultVO = new ResultVO();         resultVO.setData(object);         resultVO.setCode(0);         resultVO.setMsg("成功");         return resultVO;     } }

 

1） model 配置表对应的实体类，类名、字段最好和表中一致

a.使用这个插件，可以省略getter/setter方法

在pom.xml加入lombok依赖 还需要在idea下载这个插件 只需要在实体类加上@Data注解，就可以不用在实体类生成getter/setter方法了

新建实体类ProductInfo.java、ProductCategory.java

ProductInfo.java

@Data //@Table(name = "T_proxxx") @Entity public class ProductInfo {     @Id     private String productId;     /** 名字. */     private String productName;     /** 单价. */     private BigDecimal productPrice;     /** 库存. */     private Integer productStock;     /** 描述. */     private String productDescription;     /** 小图. */     private String productIcon;     /** 状态, 0正常1下架. */     private Integer productStatus;     /** 类目编号. */     private Integer categoryType;     private Date createTime;     private Date updateTime; }

 

ProductCategory.java

@Data @Entity public class ProductCategory {     @Id     @GeneratedValue     private Integer categoryId;     /** 类目名字. */     private String categoryName;     /** 类目编号. */     private Integer categoryType;     private Date createTime;     private Date updateTime; }

 

2） dao

接口1：查询所有在架的商品——新建dao,ProductInfoRepository.java

可以单元测试一下:

 

接口2：查询类目type列表——新建dao,ProductCategoryRepository.java

3） service 

新建ProductService.java、ProductServiceImpl.java

ProductService.java

public interface ProductService {     /**      * 查询所有在架商品列表      */     List<ProductInfo> findUpAll();     /**      * 查询商品列表      * @param productIdList      * @return      */     List<ProductInfoOutput> findList(List<String> productIdList); }

ProductServiceImpl.java

@Service public class ProductServiceImpl implements ProductService {     @Autowired     private ProductInfoRepository productInfoRepository;     @Override     public List<ProductInfo> findUpAll() {         return productInfoRepository.findByProductStatus(ProductStatusEnum.UP.getCode());     }     @Override     public List<ProductInfoOutput> findList(List<String> productIdList) {         return productInfoRepository.findByProductIdIn(productIdList).stream()                 .map(e -> {                     ProductInfoOutput output = new ProductInfoOutput();                     BeanUtils.copyProperties(e, output);                     return output;                 })                 .collect(Collectors.toList());     } }

新建CategoryService.java、CategoryServiceImpl.java

CategoryService.java

public interface CategoryService {     List<ProductCategory> findByCategoryTypeIn(List<Integer> categoryTypeList); }

CategoryServiceImpl.java

@Service public class CategoryServiceImpl implements CategoryService {     @Autowired     private ProductCategoryRepository productCategoryRepository;     @Override     public List<ProductCategory> findByCategoryTypeIn(List<Integer> categoryTypeList) {         return productCategoryRepository.findByCategoryTypeIn(categoryTypeList);     } }

4） vo 

新建ProductVO.java、ProductInfoVO.java 

ProductVO.java

@Data public class ProductVO {     @JsonProperty("name") //@JsonProperty返回给前端的字段     private String categoryName;     @JsonProperty("type")     private Integer categoryType;     @JsonProperty("foods")     List<ProductInfoVO> productInfoVOList; }

ProductInfoVO.java

@Data public class ProductInfoVO {     @JsonProperty("id")     private String productId;     @JsonProperty("name")     private String productName;     @JsonProperty("price")     private BigDecimal productPrice;     @JsonProperty("description")     private String productDescription;     @JsonProperty("icon")     private String productIcon; }

5)  controller 

新建ProductController.java 

ProductController.java 

@RestController @RequestMapping("/product") public class ProductController {     @Autowired     private ProductService productService;     @Autowired     private CategoryService categoryService;     /**      * 1. 查询所有在架的商品      * 2. 获取类目type列表      * 3. 查询类目      * 4. 构造数据      */     @GetMapping("/list")     public ResultVO<ProductVO> list() {         //1. 查询所有在架的商品         List<ProductInfo> productInfoList = productService.findUpAll();         //2. 获取类目type列表         List<Integer> categoryTypeList = productInfoList.stream()                 .map(ProductInfo::getCategoryType)                 .collect(Collectors.toList());         //3. 从数据库查询类目         List<ProductCategory> categoryList = categoryService.findByCategoryTypeIn(categoryTypeList);         //4. 构造数据         List<ProductVO> productVOList = new ArrayList<>();         for (ProductCategory productCategory: categoryList) {             ProductVO productVO = new ProductVO();             productVO.setCategoryName(productCategory.getCategoryName());             productVO.setCategoryType(productCategory.getCategoryType());             List<ProductInfoVO> productInfoVOList = new ArrayList<>();             for (ProductInfo productInfo: productInfoList) {                 if (productInfo.getCategoryType().equals(productCategory.getCategoryType())) {                     ProductInfoVO productInfoVO = new ProductInfoVO();                     BeanUtils.copyProperties(productInfo, productInfoVO);                     productInfoVOList.add(productInfoVO);                 }             }             productVO.setProductInfoVOList(productInfoVOList);             productVOList.add(productVO);         }         return ResultVOUtil.success(productVOList);     }     /**      * 获取商品列表(给订单服务用的)      *      * @param productIdList      * @return      */     @PostMapping("/listForOrder")     public List<ProductInfoOutput> listForOrder(@RequestBody List<String> productIdList) {         try {             Thread.sleep(2000);         } catch (InterruptedException e) {             e.printStackTrace();         }         return productService.findList(productIdList);     }     @PostMapping("/decreaseStock")     public void decreaseStock(@RequestBody List<DecreaseStockInput> decreaseStockInputList) {         productService.decreaseStock(decreaseStockInputList);     } }

 

7.访问成功

转载于:https://my.oschina.net/monroe/blog/1927698