<!-- 七牛云SDK -->
<dependency>
    <groupId>com.qiniu</groupId>
    <artifactId>qiniu-java-sdk</artifactId>
    <version>7.7.0</version>
</dependency>

public class QiniuUtils {
    public static String accessKey = "你的AK";
    public static String secretKey = "你的SK";
    public static String bucket = "你的存儲(chǔ)空間名";
    // 文件路徑上傳
    public static void upload2Qiniu(String filePath,String fileName){
        Configuration cfg = new Configuration(Zone.zone2()); //你自己存儲(chǔ)空間的存儲(chǔ)區(qū)域
        UploadManager uploadManager = new UploadManager(cfg);
        Auth auth = Auth.create(accessKey, secretKey);
        String upToken = auth.uploadToken(bucket);
        try {
            Response response = uploadManager.put(filePath, fileName, upToken);
            DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
        } catch (QiniuException ex) {
            ex.printStackTrace();
        }
    }
    // 字節(jié)數(shù)組上傳
    public static void upload2Qiniu(byte[] bytes, String fileName){
        Configuration cfg = new Configuration(Zone.zone2());
        UploadManager uploadManager = new UploadManager(cfg);
        Auth auth = Auth.create(accessKey, secretKey);
        String upToken = auth.uploadToken(bucket);
        try {
            Response response = uploadManager.put(bytes, fileName, upToken);
            DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
        } catch (QiniuException ex) {
            ex.printStackTrace();
        }
    }
    // 刪除文件
    public static void deleteFileFromQiniu(String fileName){
        Configuration cfg = new Configuration(Zone.zone2());
        Auth auth = Auth.create(accessKey, secretKey);
        BucketManager bucketManager = new BucketManager(auth, cfg);
        try {
            bucketManager.delete(bucket, fileName);
        } catch (QiniuException ex) {
            System.err.println(ex.code());
        }
    }
}
?

handleCreate(){
  this.resetForm();
  this.dialogFormVisible = true;
  // 查詢所有檢查組
  axios.get("/checkgroup/findAll.do").then((res)=>{
    if(res.data.flag){
      this.tableData = res.data.data;
    }else{
      this.$message.error(res.data.message);
    }
  });
}

<el-upload
  class="avatar-uploader"
  action="/setmeal/upload.do"
  :auto-upload="autoUpload"
  name="imgFile"
  :show-file-list="false"
  :on-success="handleAvatarSuccess"
  :before-upload="beforeAvatarUpload">
  <img v-if="imageUrl" :src="imageUrl" class="avatar">
  <i v-else class="el-icon-plus avatar-uploader-icon"></i>
</el-upload>

beforeAvatarUpload(file){
  const isJPG = file.type === 'image/jpeg';
  const isLt2M = file.size / 1024 / 1024 < 2;
  if(!isJPG) this.$message.error("只能上傳JPG格式！");
  if(!isLt2M) this.$message.error("圖片大小不能超過2MB！");
  return isJPG && isLt2M;
}

@Controller
@RequestMapping("/setmeal")
public class SetmealController {
    @Autowired
    private JedisPool jedisPool;

    // 圖片上傳
    @RequestMapping("/upload")
    @ResponseBody
    public Result upload(@RequestParam("imgFile") MultipartFile imgFile){
        try {
            String originalFilename = imgFile.getOriginalFilename();
            String extention = originalFilename.substring(originalFilename.lastIndexOf("."));
            String fileName = UUID.randomUUID().toString() + extention;
            // 上傳七牛云
            QiniuUtils.upload2Qiniu(imgFile.getBytes(),fileName);
            // 存入Redis（所有上傳圖片）
            jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_RESOURCES,fileName);
            return new Result(true, MessageConstant.PIC_UPLOAD_SUCCESS,fileName);
        } catch (Exception e) {
            e.printStackTrace();
            return new Result(false, MessageConstant.PIC_UPLOAD_FAIL);
        }
    }
}

@Service
@Transactional
public class SetmealServiceImpl implements SetmealService {
    @Autowired
    private SetmealDao setmealDao;

    @Override
    public void add(Setmeal setmeal, Integer[] checkgroupIds) {
        // 新增套餐基本信息
        setmealDao.add(setmeal);
        Integer setmealId = setmeal.getId();
        // 設(shè)置套餐與檢查組關(guān)聯(lián)
        this.setSetmealAndCheckgroup(setmealId,checkgroupIds);
    }

    // 維護(hù)多對(duì)多關(guān)系
    private void setSetmealAndCheckgroup(Integer setmealId, Integer[] checkgroupIds) {
        if(checkgroupIds != null && checkgroupIds.length > 0){
            for (Integer checkgroupId : checkgroupIds) {
                Map<String,Integer> map = new HashMap<>();
                map.put("setmealId",setmealId);
                map.put("checkgroupId",checkgroupId);
                setmealDao.setSetmealAndCheckGroup(map);
            }
        }
    }
}

@RequestMapping("/add")
@ResponseBody
public Result add(@RequestBody Setmeal setmeal, Integer[] checkgroupIds){
    try {
        setmealService.add(setmeal,checkgroupIds);
        // 存入Redis（已保存到數(shù)據(jù)庫的圖片）
        jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_DB_RESOURCES,setmeal.getImg());
        return new Result(true, MessageConstant.ADD_SETMEAL_SUCCESS);
    }catch (Exception e){
        e.printStackTrace();
        return new Result(false, MessageConstant.ADD_SETMEAL_FAIL);
    }
}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

@Configuration
public class QuartzConfig {
    @Bean    //job：干什么事
    public MethodInvokingJobDetailFactoryBean jobDetail(ClearImgJob clearImgJob){
        MethodInvokingJobDetailFactoryBean bean = new MethodInvokingJobDetailFactoryBean();
        bean.setTargetObject(clearImgJob);
        bean.setTargetMethod("clearImg");
        return bean;
    }

    @Bean    //trigger：什么時(shí)候
    public CronTriggerFactoryBean trigger(MethodInvokingJobDetailFactoryBean jobDetail){
        CronTriggerFactoryBean bean = new CronTriggerFactoryBean();
        bean.setCronExpression("0 0 2 * * ?"); // 每天凌晨2點(diǎn)
        bean.setJobDetail(jobDetail.getObject());
        return bean;
    }

    @Bean    //scheduler：什么時(shí)候干什么事
    public SchedulerFactoryBean scheduler(CronTriggerFactoryBean trigger){
        SchedulerFactoryBean bean = new SchedulerFactoryBean();
        bean.setTriggers(trigger.getObject());
        return bean;
    }
}

?

@Component
public class ClearImgJob {
    @Autowired
    private JedisPool jedisPool;

    public void clearImg(){
        // 計(jì)算差集
        Set<String> garbageImg = jedisPool.getResource().sdiff(
                RedisConstant.SETMEAL_PIC_RESOURCES,
                RedisConstant.SETMEAL_PIC_DB_RESOURCES);

        if(garbageImg != null){
            for (String imgName : garbageImg) {
                // 刪除七牛云文件
                QiniuUtils.deleteFileFromQiniu(imgName);
                // 刪除Redis記錄
                jedisPool.getResource().srem(RedisConstant.SETMEAL_PIC_RESOURCES,imgName);
                System.out.println("清理垃圾圖片：" + imgName);
            }
        }
    }
}

?