feat: 上传图片接口

“谢茂盛”
1 parent 8fa694a0
Showing 10 changed files with 470 additions and 7 deletions
sql/init.sql
src/main/java/com/order/erp/common/utils/FileUtil.java
src/main/java/com/order/erp/controller/LocalStorageController.java
src/main/java/com/order/erp/domain/dto/LocalStorageDO.java
src/main/java/com/order/erp/domain/vo/LocalStorageQueryVO.java
src/main/java/com/order/erp/domain/vo/LocalStorageVO.java
src/main/java/com/order/erp/mapper/LocalStorageMapper.java
src/main/java/com/order/erp/service/LocalStorageService.java
src/main/java/com/order/erp/service/impl/LocalStorageServiceImpl.java
src/main/resources/application-local.yml
@@ -369,7 +369,7 @@ INSERT INTO `admin_user_role` VALUES (1,1, 1);
 INSERT INTO `admin_user_role` VALUES (2,2, 2);
 COMMIT;
  
-
+DROP TABLE IF EXISTS `dictionary`;
 # 字典表
 CREATE TABLE `dictionary` (
           `id` bigint NOT NULL AUTO_INCREMENT,
@@ -409,4 +409,22 @@ CREATE TABLE `sys_log` (
   PRIMARY KEY (`id`) ,
   KEY `log_create_time_index` (`create_time`),
   KEY `inx_log_type` (`log_type`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='系统日志';
 \ No newline at end of file
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='系统日志';
+
+DROP TABLE IF EXISTS `local_storage`;
+CREATE TABLE `local_storage` (
+  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
+  `real_name` varchar(255) DEFAULT NULL COMMENT '文件真实的名称',
+  `name` varchar(255) DEFAULT NULL COMMENT '文件名',
+  `suffix` varchar(255) DEFAULT NULL COMMENT '后缀',
+  `path` varchar(255) DEFAULT NULL COMMENT '路径',
+  `type` varchar(255) DEFAULT NULL COMMENT '类型',
+  `size` varchar(100) DEFAULT NULL COMMENT '大小',
+  `enable_flag`    INT          NOT NULL COMMENT '是否可用 10-可用 20-删除',
+  `create_time`    DATETIME     NOT NULL COMMENT '创建时间',
+  `create_by`      varchar(64)  NOT NULL COMMENT '创建人',
+  `modify_time`    DATETIME     DEFAULT NULL COMMENT '修改时间',
+  `modify_by`      varchar(64)  DEFAULT NULL COMMENT '修改人',
+  `version`        INT          DEFAULT NULL COMMENT '版本号--乐观锁预留字段',
+  PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='本地存储';
 \ No newline at end of file
@@ -195,15 +195,15 @@ public class FileUtil extends cn.hutool.core.io.FileUtil {
         String video = "avi mpg mpe mpeg asf wmv mov qt rm mp4 flv m4v webm ogv ogg";
         String image = "bmp dib pcp dif wmf gif jpg tif eps psd cdr iff tga pcd mpt png jpeg";
         if (image.contains(type)) {
-            return "图片";
+            return "images";
         } else if (documents.contains(type)) {
-            return "文档";
+            return "docs";
         } else if (music.contains(type)) {
-            return "音乐";
+            return "musics";
         } else if (video.contains(type)) {
-            return "视频";
+            return "videos";
         } else {
-            return "其他";
+            return "others";
         }
     }
  
+package com.order.erp.controller;
+
+import com.order.erp.common.annotation.AnonymousAccess;
+import com.order.erp.common.constant.ServerResult;
+import com.order.erp.service.LocalStorageService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+/**
+ *
+ */
+@RestController
+@RequestMapping("/api/localStorage")
+public class LocalStorageController {
+
+    @Resource
+    private LocalStorageService localStorageService;
+
+    @ApiOperation("上传文件")
+    @PostMapping(value = "/upload")
+    @AnonymousAccess
+    public ServerResult upload(@RequestParam String name, @RequestParam("file") MultipartFile file) {
+        return localStorageService.create(name, file);
+    }
+
+}
 \ No newline at end of file
+package com.order.erp.domain.dto;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+
+/**
+ * 本地存储(LocalStorage)实体类
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:15
+ */
+@TableName("local_storage")
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class LocalStorageDO extends BaseDO implements Serializable {
+    private static final long serialVersionUID = 995302526235363711L;
+    /**
+     * ID
+     */
+    private Long id;
+    /**
+     * 文件真实的名称
+     */
+    private String realName;
+    /**
+     * 文件名
+     */
+    private String name;
+    /**
+     * 后缀
+     */
+    private String suffix;
+    /**
+     * 路径
+     */
+    private String path;
+    /**
+     * 类型
+     */
+    private String type;
+    /**
+     * 大小
+     */
+    private String size;
+
+}
+package com.order.erp.domain.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 本地存储(LocalStorage)实体类
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:31
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class LocalStorageQueryVO extends BasePageVO implements Serializable {
+    private static final long serialVersionUID = -64176392551926441L;
+
+    private List<Long> ids;
+
+    /**
+     * ID
+     */
+    private Long id;
+    /**
+     * 文件真实的名称
+     */
+    private String realName;
+    /**
+     * 文件名
+     */
+    private String name;
+    /**
+     * 后缀
+     */
+    private String suffix;
+    /**
+     * 路径
+     */
+    private String path;
+    /**
+     * 类型
+     */
+    private String type;
+    /**
+     * 大小
+     */
+    private String size;
+
+
+}
+
+package com.order.erp.domain.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+
+/**
+ * 本地存储(LocalStorage)实体类
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:27
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class LocalStorageVO implements Serializable {
+    private static final long serialVersionUID = 329772830619051307L;
+    /**
+     * ID
+     */
+    private Long id;
+    /**
+     * 文件真实的名称
+     */
+    private String realName;
+    /**
+     * 文件名
+     */
+    private String name;
+    /**
+     * 后缀
+     */
+    private String suffix;
+    /**
+     * 路径
+     */
+    private String path;
+    /**
+     * 类型
+     */
+    private String type;
+    /**
+     * 大小
+     */
+    private String size;
+
+
+}
+package com.order.erp.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.order.erp.domain.dto.LocalStorageDO;
+
+/**
+ * 本地存储(LocalStorage)表数据库访问层
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:35
+ */
+public interface LocalStorageMapper extends BaseMapper<LocalStorageDO> {
+
+
+}
+
+package com.order.erp.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.order.erp.common.constant.ServerResult;
+import com.order.erp.domain.dto.LocalStorageDO;
+import com.order.erp.domain.vo.LocalStorageQueryVO;
+import com.order.erp.domain.vo.LocalStorageVO;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * 本地存储(LocalStorage)表服务接口
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:36
+ */
+public interface LocalStorageService extends IService<LocalStorageDO> {
+
+
+    ServerResult create(String name, MultipartFile file);
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param localStorageQueryVO 主键
+     * @return 实例对象
+     */
+    ServerResult queryById(LocalStorageQueryVO localStorageQueryVO);
+
+    /**
+     * 分页查询
+     *
+     * @param localStorageQueryVO 筛选条件
+     * @return 查询结果
+     */
+    ServerResult list(LocalStorageQueryVO localStorageQueryVO);
+
+    /**
+     * 新增数据
+     *
+     * @param localStorageVO 数据VO
+     * @return 新增结果
+     */
+    ServerResult add(LocalStorageVO localStorageVO);
+
+    /**
+     * 修改数据
+     *
+     * @param localStorageVO 数据VO
+     * @return 编辑结果
+     */
+    ServerResult edit(LocalStorageVO localStorageVO);
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param localStorageQueryVO 筛选条件
+     * @return 是否成功
+     */
+    ServerResult deleteById(LocalStorageQueryVO localStorageQueryVO);
+
+}
+package com.order.erp.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.order.erp.common.constant.Constant;
+import com.order.erp.common.constant.ServerResult;
+import com.order.erp.common.exception.BusinessException;
+import com.order.erp.common.utils.FileUtil;
+import com.order.erp.common.utils.StringUtils;
+import com.order.erp.domain.dto.LocalStorageDO;
+import com.order.erp.domain.vo.LocalStorageQueryVO;
+import com.order.erp.domain.vo.LocalStorageVO;
+import com.order.erp.mapper.LocalStorageMapper;
+import com.order.erp.service.LocalStorageService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * 本地存储(LocalStorage)表服务实现类
+ *
+ * @author makejava
+ * @since 2023-10-08 14:52:36
+ */
+@Slf4j
+@Service
+public class LocalStorageServiceImpl extends ServiceImpl<LocalStorageMapper, LocalStorageDO> implements LocalStorageService {
+
+
+    @Value("${file.path}")
+    private String path;
+
+    @Value("${file.host}")
+    private String host;
+
+    @Value("${file.maxSize}")
+    private long maxSize;
+
+    @Override
+    public ServerResult create(String name, MultipartFile multipartFile) {
+        FileUtil.checkSize(maxSize, multipartFile.getSize());
+        String suffix = FileUtil.getExtensionName(multipartFile.getOriginalFilename());
+        String type = FileUtil.getFileType(suffix);
+        File file = FileUtil.upload(multipartFile, path + type + File.separator);
+        if (ObjectUtil.isNull(file)) {
+            throw new BusinessException("上传失败");
+        }
+        try {
+            name = StringUtils.isBlank(name) ? FileUtil.getFileNameNoEx(multipartFile.getOriginalFilename()) : name;
+            LocalStorageDO localStorage = LocalStorageDO.builder()
+                    .realName(file.getName())
+                    .name(name)
+                    .suffix(suffix)
+                    .path(file.getPath())
+                    .type(type)
+                    .size(FileUtil.getSize(multipartFile.getSize())).build();
+            save(localStorage);
+            return ServerResult.success(host + "/images/" + file.getName());
+        } catch (Exception e) {
+            FileUtil.del(file);
+            throw e;
+        }
+    }
+
+    /**
+     * 通过ID查询单条数据
+     * <p>
+     * localStorageQueryVO 主键
+     *
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult queryById(LocalStorageQueryVO localStorageQueryVO) {
+        if (Objects.isNull(localStorageQueryVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        LocalStorageDO LocalStorageDo = getById(localStorageQueryVO.getId());
+        if (Objects.isNull(LocalStorageDo)) {
+            return ServerResult.success(null);
+        }
+        return ServerResult.success(BeanUtil.copyProperties(LocalStorageDo, LocalStorageVO.class));
+    }
+
+    /**
+     * 分页查询
+     *
+     * @param localStorageQueryVO 筛选条件
+     * @return 查询结果
+     */
+    @Override
+    public ServerResult list(LocalStorageQueryVO localStorageQueryVO) {
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 新增数据
+     *
+     * @param localStorageVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult add(LocalStorageVO localStorageVO) {
+        //todo 校验
+        if (Objects.nonNull(localStorageVO.getId())) {
+            localStorageVO.setId(null);
+        }
+        LocalStorageDO localStorageDo = BeanUtil.copyProperties(localStorageVO, LocalStorageDO.class);
+
+        save(localStorageDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 修改数据
+     *
+     * @param localStorageVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult edit(LocalStorageVO localStorageVO) {
+        //todo 校验
+        if (Objects.isNull(localStorageVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        LocalStorageDO localStorageDo = BeanUtil.copyProperties(localStorageVO, LocalStorageDO.class);
+
+        updateById(localStorageDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param localStorageQueryVO 筛选条件
+     * @return 是否成功
+     */
+    @Override
+    public ServerResult deleteById(LocalStorageQueryVO localStorageQueryVO) {
+        List<Long> ids = localStorageQueryVO.getIds();
+        if (CollUtil.isEmpty(ids)) {
+            return ServerResult.fail("ids 参数不能为空");
+        }
+        List<LocalStorageDO> localStorageList = listByIds(ids);
+        if (CollUtil.isEmpty(localStorageList)) {
+            return ServerResult.success();
+        }
+        //todo 校验是否可以逻辑删除
+        LambdaUpdateWrapper<LocalStorageDO> updateWrapper = new LambdaUpdateWrapper<LocalStorageDO>()
+                .in(LocalStorageDO::getId, ids)
+                .set(LocalStorageDO::getEnableFlag, Constant.UNABLE_TWENTY);
+        update(updateWrapper);
+        return ServerResult.success();
+    }
+}
@@ -158,3 +158,12 @@ system:
  
 openai:
   token: Bearer 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
+
+# 文件存储路径
+file:
+  path: /home/canrd/order-erp/files/
+  host: http://39.108.227.113
+  avatar: /home/order-erp/avatar/
+  # 文件大小 /M
+  maxSize: 100
+  avatarMaxSize: 5