电商项目（五）--后台查询商品

女爷i 2023-07-03 02:57 16阅读 0赞

## 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>
    
            
            <dependency>
                <groupId>com.bjsxt</groupId>
                <artifactId>common_pojo</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
    
            
            <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  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]

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);
    
        }

注意：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]  
效果图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200202102509560.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200202102655489.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200202102743845.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ==,size_16,color_FFFFFF,t_70