后台管理系统CMS模块-后端实现

比眉伴天荒 2021-07-25 02:48 412阅读 0赞

# 一 数据库设计 #

## 1 数据库 ##

创建数据库：guli\_cms

## 2 脚本 ##

# 广告
    CREATE TABLE `cms_ad` (
      `id` char(19) NOT NULL DEFAULT '' COMMENT 'ID',
      `title` varchar(20) DEFAULT '' COMMENT '标题',
      `type_id` char(19) NOT NULL COMMENT '类型ID',
      `image_url` varchar(500) NOT NULL DEFAULT '' COMMENT '图片地址',
      `color` varchar(10) DEFAULT NULL COMMENT '背景颜色',
      `link_url` varchar(500) DEFAULT '' COMMENT '链接地址',
      `sort` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '排序',
      `gmt_create` datetime NOT NULL COMMENT '创建时间',
      `gmt_modified` datetime NOT NULL COMMENT '更新时间',
      PRIMARY KEY (`id`),
      UNIQUE KEY `uk_name` (`title`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='广告推荐';
    
    # 广告位
    CREATE TABLE `cms_ad_type` (
      `id` char(19) NOT NULL COMMENT 'ID',
      `title` varchar(20) NOT NULL COMMENT '标题',
      `gmt_create` datetime NOT NULL COMMENT '创建时间',
      `gmt_modified` datetime NOT NULL COMMENT '更新时间',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='推荐位';

# 二 创建内容管理微服务 #

## 1 创建模块 ##

service\_cms

## 2 配置pom.xml ##

<build>
        
        <resources>
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
        </resources>
    </build>

## 3 配置application.yml ##

server:
      port: 8140 # 服务端口
    
    spring:
      profiles:
        active: dev # 环境设置
      application:
        name: service-cms # 服务名
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848 # nacos服务地址
        sentinel:
          transport:
            port: 8081
            dashboard: localhost:8080
    
      datasource: # mysql数据库连接
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/guli_cms?serverTimezone=GMT%2B8
        username: root
        password: 123456
    #spring:
      jackson: #返回json的全局时间格式
        date-format: yyyy-MM-dd HH:mm:ss
        time-zone: GMT+8
    
    mybatis-plus:
      configuration:
        log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #mybatis日志
      mapper-locations: classpath:com/atguigu/guli/service/cms/mapper/xml/*.xml
    
    ribbon:
      ConnectTimeout: 10000 #连接建立的超时时长，默认1秒
      ReadTimeout: 10000 #处理请求的超时时间，默认为1秒
    
    feign:
      sentinel:
        enabled: true

## 4 logback-spring.xml ##

修改日志路径为 guli\_log/cms

## 5 创建启动类 ##

@SpringBootApplication
    @ComponentScan({"com.atguigu.guli"})
    // 启动 OpenFeign 远程调用
    @EnableFeignClients
    @EnableDiscoveryClient
    public class ServiceEduApplication {
        public static void main(String[] args) {
            SpringApplication.run(ServiceEduApplication.class, args);
        }
    }

## 6 创建代码生成器并执行 ##

# 三 后台管理AdType #

## 1 控制器 ##

@CrossOrigin // 解决跨域问题
    @Api(description = "推荐位管理")
    @RestController
    @RequestMapping("/admin/cms/ad-type")
    @Slf4j
    public class AdTypeController {
    
        @Autowired
        private AdTypeService adTypeService;
    
        /**
         * 功能描述：所有推荐类别列表
         *
         * @return R 返回给前端的数据
         * @author cakin
         * @date 2020/12/20
         */
        @ApiOperation("所有推荐类别列表")
        @GetMapping("list")
        public R listAll() {
            List<AdType> list = adTypeService.list();
            return R.ok().data("items", list);
        }
    
        /**
         * 功能描述：推荐类别分页列表
         *
         * @param page  当前页码
         * @param limit 每页记录数
         * @return R 返回给前端的数据
         * @author cakin
         * @date 2020/12/20
         */
        @ApiOperation("推荐类别分页列表")
        @GetMapping("list/{page}/{limit}")
        public R listPage(@ApiParam(value = "当前页码", required = true) @PathVariable Long page,
                          @ApiParam(value = "每页记录数", required = true) @PathVariable Long limit) {
            Page<AdType> pageParam = new Page<>(page, limit);
            IPage<AdType> pageModel = adTypeService.page(pageParam);
            List<AdType> records = pageModel.getRecords();
            long total = pageModel.getTotal();
            return R.ok().data("total", total).data("rows", records);
        }
    
        /**
         * 功能描述：根据ID删除推荐类别
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 推荐类别ID
         * @return R 返回给前端的数据
         */
        @ApiOperation(value = "根据ID删除推荐类别")
        @DeleteMapping("remove/{id}")
        public R removeById(@ApiParam(value = "推荐类别ID", required = true) @PathVariable String id) {
            boolean result = adTypeService.removeById(id);
            if (result) {
                return R.ok().message("删除成功");
            } else {
                return R.error().message("数据不存在");
            }
        }
    
        /**
         * 功能描述：新增推荐类别
         *
         * @author cakin
         * @date 2020/12/20
         * @param adType 推荐类别对象
         * @return R 返回给前端的数据
         */
        @ApiOperation("新增推荐类别")
        @PostMapping("save")
        public R save(@ApiParam(value = "推荐类别对象", required = true) @RequestBody AdType adType) {
            boolean result = adTypeService.save(adType);
            if (result) {
                return R.ok().message("保存成功");
            } else {
                return R.error().message("保存失败");
            }
        }
    
        /**
         * 功能描述：更新推荐类别
         *
         * @author cakin
         * @date 2020/12/20
         * @param adType 推荐类别对象
         * @return R 返回给前端的数据
         */
        @ApiOperation("更新推荐类别")
        @PutMapping("update")
        public R updateById(@ApiParam(value = "讲师推荐类别", required = true) @RequestBody AdType adType) {
            boolean result = adTypeService.updateById(adType);
            if (result) {
                return R.ok().message("修改成功");
            } else {
                return R.error().message("数据不存在");
            }
        }
    
        /**
         * 功能描述：根据id获取推荐类别信息
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 推荐类别ID
         * @return R 返回给前端的数据
         */
        @ApiOperation("根据id获取推荐类别信息")
        @GetMapping("get/{id}")
        public R getById(@ApiParam(value = "推荐类别ID", required = true) @PathVariable String id) {
            AdType adType = adTypeService.getById(id);
            if (adType != null) {
                return R.ok().data("item", adType);
            } else {
                return R.error().message("数据不存在");
            }
        }
    }

# 四 后台管理Ad #

## 1 vo ##

@Data
    public class AdVo implements Serializable {
    
        private static final long serialVersionUID=1L;
        /**
         * id
         */
        private String id;
        /**
         * 标题
         */
        private String title;
        /**
         * 排序方式
         */
        private Integer sort;
        /**
         * 广告类别
         */
        private String type;
    }

## 2 控制器 ##

@CrossOrigin //解决跨域问题
    @Api(description = "广告推荐管理")
    @RestController
    @RequestMapping("/admin/cms/ad")
    @Slf4j
    public class AdController {
    
        @Autowired
        private AdService adService;
    
        /**
         * 功能描述：根据ID删除推荐
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 广告id
         * @return R 返回该前端的数据
         */
        @ApiOperation(value = "根据ID删除推荐")
        @DeleteMapping("remove/{id}")
        public R removeById(@ApiParam(value = "推荐ID", required = true) @PathVariable String id) {
            // 删除图片
            adService.removeAdImageById(id);
            // 删除推荐
            boolean result = adService.removeById(id);
            if (result) {
                return R.ok().message("删除成功");
            } else {
                return R.error().message("数据不存在");
            }
        }
    
        /**
         * 功能描述：推荐分页列表
         *
         * @author cakin
         * @date 2020/12/20
         * @param page 当前页码
         * @param limit 每页记录数
         * @return 返回给前端的数据
         */
        @ApiOperation("推荐分页列表")
        @GetMapping("list/{page}/{limit}")
        public R listPage(@ApiParam(value = "当前页码", required = true) @PathVariable Long page,
                          @ApiParam(value = "每页记录数", required = true) @PathVariable Long limit) {
            IPage<AdVo> pageModel = adService.selectPage(page, limit);
            List<AdVo> records = pageModel.getRecords();
            long total = pageModel.getTotal();
            return R.ok().data("total", total).data("rows", records);
        }
    
        /**
         * 功能描述：新增推荐
         *
         * @author cakin
         * @date 2020/12/20
         * @param ad 广告
         * @return R 返回给前端的数据
         */
        @ApiOperation("新增推荐")
        @PostMapping("save")
        public R save(@ApiParam(value = "推荐对象", required = true) @RequestBody Ad ad) {
            boolean result = adService.save(ad);
            if (result) {
                return R.ok().message("保存成功");
            } else {
                return R.error().message("保存失败");
            }
        }
    
        /**
         * 功能描述：更新推荐
         *
         * @author cakin
         * @date 2020/12/20
         * @param ad 广告
         * @return R 返回给前端的数据
         */
        @ApiOperation("更新推荐")
        @PutMapping("update")
        public R updateById(@ApiParam(value = "讲师推荐", required = true) @RequestBody Ad ad) {
            boolean result = adService.updateById(ad);
            if (result) {
                return R.ok().message("修改成功");
            } else {
                return R.error().message("数据不存在");
            }
        }
    
        /**
         * 功能描述：根据id获取推荐信息
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 广告id
         * @return R 返回给前端的数据
         */
        @ApiOperation("根据id获取推荐信息")
        @GetMapping("get/{id}")
        public R getById(@ApiParam(value = "推荐ID", required = true) @PathVariable String id) {
            Ad ad = adService.getById(id);
            if (ad != null) {
                return R.ok().data("item", ad);
            } else {
                return R.error().message("数据不存在");
            }
        }
    }

## 3 service ##

接口

public interface AdService extends IService<Ad> {
    
        /**
         * 功能描述：广告分页查询
         *
         * @author cakin
         * @date 2020/12/20
         * @param page 当前页码
         * @param limit 每页记录数
         * @return IPage<AdVo> 分页信息
         */
        IPage<AdVo> selectPage(Long page, Long limit);
    
        /**
         * 功能描述：删除广告图像
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 广告id
         * @return boolean 删除是否成功
         */
        boolean removeAdImageById(String id);
    }

实现

@Service
    public class AdServiceImpl extends ServiceImpl<AdMapper, Ad> implements AdService {
    
    
        @Autowired
        private OssFileService ossFileService;
        /**
         * 功能描述：广告分页查询
         *
         * @author cakin
         * @date 2020/12/20
         * @param page 当前页码
         * @param limit 每页记录数
         * @return IPage<AdVo> 分页信息
         */
        @Override
        public IPage<AdVo> selectPage(Long page, Long limit) {
            QueryWrapper<AdVo> queryWrapper = new QueryWrapper<>();
            queryWrapper.orderByAsc("a.type_id", "a.sort");
            Page<AdVo> pageParam = new Page<>(page, limit);
            // 需传递分页参数和条件查询参数
            List<AdVo> records = baseMapper.selectPageByQueryWrapper(pageParam, queryWrapper);
            pageParam.setRecords(records);
            return pageParam;
        }
        /**
         * 功能描述：删除广告图像
         *
         * @author cakin
         * @date 2020/12/20
         * @param id 广告id
         * @return boolean 删除是否成功
         */
        @Override
        public boolean removeAdImageById(String id) {
            Ad ad = baseMapper.selectById(id);
            if(ad != null) {
                String imagesUrl = ad.getImageUrl();
                if(!StringUtils.isEmpty(imagesUrl)){
                    // 删除图片，远程调用oss服务中的删除文件
                    R r = ossFileService.removeFile(imagesUrl);
                    return r.getSuccess();
                }
            }
            return false;
        }
    }

## 4 mapper ##

接口

public interface AdMapper extends BaseMapper<Ad> {
    
    
        /**
         * 功能描述：广告分页查询
         *
         * @author cakin
         * @date 2020/12/20
         * @param pageParam 分页参数
         * @return queryWrapper 条件查询参数
         */
        List<AdVo> selectPageByQueryWrapper(
                Page<AdVo> pageParam,
                @Param(Constants.WRAPPER) QueryWrapper<AdVo> queryWrapper);
    }

XML

<select id="selectPageByQueryWrapper" resultType="com.atguigu.guli.service.cms.entity.vo.AdVo">
        SELECT
          a.id,
          a.title,
          a.sort,
          t.title AS type
        FROM cms_ad a
        LEFT JOIN cms_ad_type t ON a.type_id = t.id
        ${ew.customSqlSegment}
    </select>

## 5 feign ##

接口

@Service
    @FeignClient(value = "service-oss", fallback = OssFileServiceFallBack.class)
    public interface OssFileService {
        /**
         * 功能描述：远程删除文件
         *
         * @author cakin
         * @date 2020/12/20
         * @param url
         * @return R 前端返回结果
         */
        @DeleteMapping("/admin/oss/file/remove")
        R removeFile(@RequestBody String url);
    }

降级实现

/**
    * @className: OssFileServiceFallBack
    * @description: 文件服务远程调用失败降级处理
    * @date: 2020/12/20
    * @author: cakin
    */
    @Service
    @Slf4j
    public class OssFileServiceFallBack implements OssFileService {
    
    
        /**
         * 功能描述：文件服务远程调用失败降级处理
         *
         * @author cakin
         * @date 2020/12/20
         * @param url 文件url地址
         * @return R 远程调用返回的结果
         */
        @Override
        public R removeFile(String url) {
            log.info("熔断保护");
            return R.error().message("调用超时");
        }
    }