电商项目（五）--后台查询商品-蒲公英云

1. 创建backend_item项目

首先对新创建的项目，进行pom文件的修改。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>bz_parent</artifactId>
        <groupId>com.bjsxt</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>backend_item</artifactId>
    <dependencies>
        <!-- pojo-->
        <dependency>
            <groupId>com.bjsxt</groupId>
            <artifactId>common_pojo</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--Spring Boot Web Starter-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--Spring Cloud Eureka Client Starter-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--Spring Cloud OpenFeign Starter-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!-- utils -->
        <dependency>
            <groupId>com.bjsxt</groupId>
            <artifactId>common_utils</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

其次，对配置文件进行编写。

spring:
  application:
    name: backend_item
server:
  port: 9020
eureka:
  client:
    serviceUrl:
      defaultZone: http://eureka1:8761/eureka/

进而创建启动类；

package com.bjsxt.backenditem;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
/** * backenditem服务 * */
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients 
public class BackendItemApplication { 
    public static void main(String[] args) { 
        SpringApplication.run(BackendItemApplication.class,args);
    }
}

2. 开发商品管理接口

1. 实现商品查询的接口

1.1 在common_item服务中实现查询商品的服务

首先在common_utils项目中添加PageResult模型

package com.bjsxt.utils;
import java.io.Serializable;
import java.util.List;
import java.util.Objects;
/** * * 分页模型 */
public class PageResult implements Serializable { 
    private Integer pageIndex;//当前页
    private Long totalPage;//总页数
    private List result;//结果集
    public PageResult() { 
    }
    public PageResult(Integer pageIndex, Long totalPage, List result) { 
        this.pageIndex = pageIndex;
        this.totalPage = totalPage;
        this.result = result;
    }
    @Override
    public String toString() { 
        return "PageResult{" +
                "pageIndex=" + pageIndex +
                ", totalPage=" + totalPage +
                ", result=" + result +
                '}';
    }
    @Override
    public boolean equals(Object o) { 
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        PageResult that = (PageResult) o;
        return Objects.equals(pageIndex, that.pageIndex) &&
                Objects.equals(totalPage, that.totalPage) &&
                Objects.equals(result, that.result);
    }
    @Override
    public int hashCode() { 
        return Objects.hash(pageIndex, totalPage, result);
    }
    public Integer getPageIndex() { 
        return pageIndex;
    }
    public void setPageIndex(Integer pageIndex) { 
        this.pageIndex = pageIndex;
    }
    public Long getTotalPage() { 
        return totalPage;
    }
    public void setTotalPage(Long totalPage) { 
        this.totalPage = totalPage;
    }
    public List getResult() { 
        return result;
    }
    public void setResult(List result) { 
        this.result = result;
    }
}

创建controller层

package com.bjsxt.item.controller;
import com.bjsxt.item.service.ItemService;
import com.bjsxt.utils.PageResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/service/item")
public class ItemController { 
    @Autowired
    private ItemService itemService;
    /** * 查询商品的数据 * */
    @RequestMapping("/selectTbItemAllByPage")
    public PageResult selectTbItemAllByPage(@RequestParam Integer page,@RequestParam Integer rows){ 
        PageResult pageResult = itemService.selectTbItemAllByPage(page, rows);
        return pageResult;
    }
}

创建service层

package com.bjsxt.item.service;
import com.bjsxt.utils.PageResult;
public interface ItemService { 
    PageResult selectTbItemAllByPage(Integer page,Integer rows);
}

创建serviceImpl层

package com.bjsxt.item.service.impl;
import com.bjsxt.item.service.ItemService;
import com.bjsxt.mapper.TbItemMapper;
import com.bjsxt.pojo.TbItem;
import com.bjsxt.pojo.TbItemExample;
import com.bjsxt.utils.PageResult;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class ItemServiceImpl implements ItemService { 
    @Autowired
    private TbItemMapper tbItemMapper;
    //查询所有的商品信息
    @Override
    public PageResult selectTbItemAllByPage(Integer page, Integer rows) { 
        //开启分页插件
        PageHelper.startPage(page, rows);
        TbItemExample example = new TbItemExample();
        example.createCriteria().andStatusEqualTo((byte)1);
        List<TbItem> tbItems = tbItemMapper.selectByExample(example);
        PageInfo<TbItem> pageInfo = new PageInfo<>();
        PageResult pageResult = new PageResult();
        pageResult.setPageIndex(page);
        pageResult.setTotalPage(pageInfo.getTotal());
        pageResult.setResult(tbItems);
        System.out.println(pageResult);
        return pageResult;
    }
}

1.2 在backend_item服务中实现商品查询

创建controller

package com.bjsxt.backenditem.controller;
import com.bjsxt.backenditem.service.ItemService;
import com.bjsxt.utils.Result;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/backend/item")
public class ItemController { 
    @Autowired
    private ItemService itemService;
    /** * 查询商品且分页显示 */
    @RequestMapping("/selectTbItemAllByPage")
    public Result selectTbItemAllByPage(@RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "2") Integer rows){ 
        try{ 
            Result result = itemService.selectTbItemAllByPage(page, rows);
            return result;
        }catch (Exception e){ 
            e.printStackTrace();
        }
        return Result.build(500,"error");
    }
}

创建service

package com.bjsxt.backenditem.service;
import com.bjsxt.utils.Result;
public interface ItemService { 
    //查询所有的商品并分页
    Result selectTbItemAllByPage(Integer page,Integer rows);
}

创建serviceImpl

package com.bjsxt.backenditem.service.impl;
import com.bjsxt.backenditem.feign.CommonItemFeignClient;
import com.bjsxt.backenditem.service.ItemService;
import com.bjsxt.utils.PageResult;
import com.bjsxt.utils.Result;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class ItemServiceImpl implements ItemService { 
    @Autowired
    private CommonItemFeignClient commonItemFeignClient;
    @Override
    public Result selectTbItemAllByPage(Integer page, Integer rows) { 
        PageResult pageResult = commonItemFeignClient.selectTbItemAllByPage(page, rows);
        if(pageResult!=null && pageResult.getResult()!=null && pageResult.getResult().size()>0){ 
            return Result.ok(pageResult);
        }
        return Result.error("查无结果");
    }
}

创建FeignClient
在这里插入图片描述

package com.bjsxt.backenditem.feign;
import com.bjsxt.utils.PageResult;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
@FeignClient(value = "common-item")
public interface CommonItemFeignClient { 
    @GetMapping("/service/item/selectTbItemAllByPage")
     PageResult selectTbItemAllByPage(@RequestParam("page") Integer page, @RequestParam("rows") Integer rows);
    }