1、 阿里云OSS

工具類

package com.sky.utils;import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import java.io.ByteArrayInputStream;@Data
@AllArgsConstructor
@Slf4j
public class AliOssUtil {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;/*** 文件上傳** @param bytes* @param objectName* @return*/public String upload(byte[] bytes, String objectName) {// 創建OSSClient實例。OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);try {// 創建PutObject請求。ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));} catch (OSSException oe) {System.out.println("Caught an OSSException, which means your request made it to OSS, "+ "but was rejected with an error response for some reason.");System.out.println("Error Message:" + oe.getErrorMessage());System.out.println("Error Code:" + oe.getErrorCode());System.out.println("Request ID:" + oe.getRequestId());System.out.println("Host ID:" + oe.getHostId());} catch (ClientException ce) {System.out.println("Caught an ClientException, which means the client encountered "+ "a serious internal problem while trying to communicate with OSS, "+ "such as not being able to access the network.");System.out.println("Error Message:" + ce.getMessage());} finally {if (ossClient != null) {ossClient.shutdown();}}//文件訪問路徑規則 https://BucketName.Endpoint/ObjectNameStringBuilder stringBuilder = new StringBuilder("https://");stringBuilder.append(bucketName).append(".").append(endpoint).append("/").append(objectName);log.info("文件上傳到:{}", stringBuilder.toString());return stringBuilder.toString();}
}

屬性類 可以通過在properties中根據前綴名稱匹配到

package com.sky.properties;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;@Component
@ConfigurationProperties(prefix = "sky.alioss")
@Data
public class AliOssProperties {private String endpoint;private String accessKeyId;private String accessKeySecret;private String bucketName;}

配置類 項目啟動時把工具類加載進來 只有一個即可

package com.sky.config;import com.sky.properties.AliOssProperties;
import com.sky.utils.AliOssUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.nio.charset.StandardCharsets;/*** @ClassName Myconfig* @Description 配置類 用于構建阿里云文件上傳工具類* @Author lukcy* @Date 2024/7/7 11:02* @Version 1.0*/@Configuration
@Slf4j
public class Myconfig {/*** 返回工具類 只用創建一個就行* @param aliOssProperties* @return*/@Bean@ConditionalOnMissingBeanpublic AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){log.info("創建文件上傳工具類:{}",aliOssProperties);return new AliOssUtil(aliOssProperties.getEndpoint(),aliOssProperties.getAccessKeyId(),aliOssProperties.getAccessKeySecret(),aliOssProperties.getBucketName());}
}

使用

package com.sky.controller.admin;import com.sky.annotation.AutoFilled;
import com.sky.constant.MessageConstant;
import com.sky.result.Result;
import com.sky.utils.AliOssUtil;
import io.swagger.annotations.Api;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.util.UUID;/*** @ClassName CommonController* @Description TODO* @Author lukcy* @Date 2024/7/7 10:46* @Version 1.0*/
@Api("通用接口")
@Slf4j
@RequestMapping("/admin/common")
@RestController
public class CommonController {/*** 文件上傳* @param file* @return*/@Autowiredprivate AliOssUtil aliOssUtil;@PostMapping("/upload")public Result<String> upload(MultipartFile file){try {String originalFilename = file.getOriginalFilename();String extension = null;if (originalFilename != null) {extension = originalFilename.substring(originalFilename.lastIndexOf("."));}String objectName = UUID.randomUUID().toString() + extension;String filePath = aliOssUtil.upload(file.getBytes(), objectName);return Result.success(filePath);} catch (IOException e) {}return Result.error(MessageConstant.UPLOAD_FAILED);}}

即可上傳到服務器 并且將地址回顯給前端 前端通過src就能顯示照片了

2、菜品分類查詢

    /*** 菜品分頁查詢* @param dishPageQueryDTO* @return*/@Overridepublic PageResult page(DishPageQueryDTO dishPageQueryDTO) {PageHelper.startPage(dishPageQueryDTO.getPage(), dishPageQueryDTO.getPageSize());Page<DishVO> page = dishMapper.page(dishPageQueryDTO);return new PageResult(page.getTotal(), page.getResult());}

主要前端需要的有一個分類名稱 這是DIsh里邊沒有的，我們需要根據分類id找到分類名稱，二表連接。

 <select id="page" resultType="com.sky.vo.DishVO">select d.*, c.name as categoryName from dish d left outer join category c on d.category_id = c.id<where><if test="name != null">and d.name like concat('%', #{name}, '%')</if><if test="categoryId != null">and d.category_id = #{categoryId}</if><if test="status != null">and d.status = #{status}</if></where>order by d.create_time desc</select>

命名為categoryName 是因為我們的VO里就是該名稱，mybatis可以幫我們set進去

package com.sky.vo;import com.sky.entity.DishFlavor;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class DishVO implements Serializable {private Long id;//菜品名稱private String name;//菜品分類idprivate Long categoryId;//菜品價格private BigDecimal price;//圖片private String image;//描述信息private String description;//0 停售 1 起售private Integer status;//更新時間private LocalDateTime updateTime;//分類名稱private String categoryName;//菜品關聯的口味private List<DishFlavor> flavors = new ArrayList<>();//private Integer copies;
}

這里我本來使用的是這個方法

 /*** 菜品分頁查詢* @param dishPageQueryDTO* @return*/@Overridepublic PageResult page(DishPageQueryDTO dishPageQueryDTO) {PageHelper.startPage(dishPageQueryDTO.getPage(),dishPageQueryDTO.getPageSize());//先獲取DISH的基本信息Page<Dish> page=dishMapper.page(dishPageQueryDTO);long total = page.getTotal();List<Dish> result = page.getResult();//將分類名稱給加上List<DishVO> dishVOS=result.stream().map((item->{DishVO dishVO=new DishVO();BeanUtils.copyProperties(item,dishVO);Long categoryId = item.getCategoryId();String Cname=categoryMapper.getNameByCID(categoryId);dishVO.setCategoryName(Cname);return dishVO;})).collect(Collectors.toList());return new PageResult(total,dishVOS);}

但是每個菜品都要查詢一次數據庫 查詢名稱 耗時
第一種方法 只用查詢一次即可。