同步代码

src/main/java/com/unissoft/policySystem/controller/PolicySystemController.java

@@ -0,0 +1,67 @@
+package com.unissoft.policySystem.controller;
+
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.unissoft.model.PolicySystem;
+import com.unissoft.policySystem.service.PolicySystemService;
+import com.unissoft.result.PageParam;
+import com.unissoft.result.ResultView;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author root
+ * @since 2020-12-15
+ */
+@Api(description = "系统管理政策制度")
+@RestController
+@RequestMapping("/policySystem")
+public class PolicySystemController {
+
+    @Autowired
+    private PolicySystemService policySystemService ;
+
+
+    @ApiOperation(value = "分页条件查询", notes = "提交参数：{\"pageIndex\":\"0\", \"pageSize\":\"h\", \"condition\":\"{\\\"asset_number\\\":\\\"\\\",\\\"equipment_category\\\":\\\"\\\",\\\"equipment_name\\\":\\\"\\\",\\\"standards_type\\\":\\\"\\\",\\\"arrival_time\\\":\\\"\\\"}\"}")
+    @PostMapping("/authority/getPage")
+    public ResultView getPage(@RequestBody PageParam pageParam) {
+        Page<PolicySystem> page = policySystemService.getPage(pageParam);
+        return ResultView.success(page);
+    }
+
+    @ApiOperation(value = "新增", notes = "")
+    @PostMapping("/authority_button/add")
+    public ResultView add(@RequestBody PolicySystem model) {
+        policySystemService.savePolicySystem(model);
+        return ResultView.success(model);
+    }
+
+    @ApiOperation(value = "上传附件", notes = "")
+    @PostMapping("/authority_button/upload")
+    public ResultView add(@RequestParam(name = "file") MultipartFile file, @RequestParam(name = "id") Integer id) throws Exception {
+        String attachmentPath = policySystemService.savePolicySystemAttachment(file, id);
+        return ResultView.success(attachmentPath);
+    }
+
+
+    @ApiOperation(value = "修改", notes = "")
+    @PostMapping("/authority_button/update")
+    public ResultView update(@RequestBody PolicySystem model) {
+        policySystemService.updateById(model);
+        return ResultView.success(model);
+    }
+
+    @ApiOperation(value = "根据id删除", notes = "")
+    @DeleteMapping("/authority_button/deleteById/{id}")
+    public ResultView deleteById(@PathVariable Integer id) {
+        policySystemService.deleteById(id);
+        return ResultView.success();
+    }
+}

src/main/java/com/unissoft/policySystem/service/PolicySystemService.java

@@ -0,0 +1,27 @@
+package com.unissoft.policySystem.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.unissoft.model.EquipmentStroe;
+import com.unissoft.model.PolicySystem;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.unissoft.result.PageParam;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author root
+ * @since 2020-12-15
+ */
+public interface PolicySystemService extends IService<PolicySystem> {
+    Page<PolicySystem> getPage(PageParam pageParam);
+
+    void deleteById(Integer id);
+
+
+    void savePolicySystem(PolicySystem model);
+
+    String savePolicySystemAttachment(MultipartFile file,Integer id) throws Exception;
+}

src/main/java/com/unissoft/policySystem/utils/minio/MinioConfig.java

@@ -0,0 +1,32 @@
+package com.unissoft.policySystem.utils.minio;
+
+import io.minio.MinioClient;
+import io.minio.errors.InvalidEndpointException;
+import io.minio.errors.InvalidPortException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 文件描述
+ *
+ * @author tongxi.xia
+ * @date 2020年12月04日 10:11
+ */
+@Configuration
+@EnableConfigurationProperties(MinioProp.class)
+public class MinioConfig {
+
+    @Autowired
+    MinioProp minioProp;
+
+    /**
+     * 获取MinioClient
+     */
+    @Bean
+    public MinioClient minioClient() throws InvalidPortException, InvalidEndpointException {
+        return new MinioClient(minioProp.getEndpoint(), minioProp.getAccesskey(), minioProp.getSecretkey());
+    }
+
+}

src/main/java/com/unissoft/policySystem/utils/minio/MinioProp.java

@@ -0,0 +1,29 @@
+package com.unissoft.policySystem.utils.minio;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 文件描述
+ *
+ * @author tongxi.xia
+ * @date 2020年12月04日 10:03
+ */
+@Data
+@Component
+@ConfigurationProperties(prefix = "minio")
+public class MinioProp {
+    /**
+     * 连接地址
+     */
+    private String endpoint;
+    /**
+     * 用户名
+     */
+    private String accesskey;
+    /**
+     * 密码
+     */
+    private String secretkey;
+}

src/main/java/com/unissoft/policySystem/utils/minio/MinioUtils.java

@@ -0,0 +1,162 @@
+package com.unissoft.policySystem.utils.minio;
+
+import io.minio.MinioClient;
+import io.minio.ObjectStat;
+import io.minio.errors.*;
+import io.minio.messages.Bucket;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+import org.xmlpull.v1.XmlPullParserException;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * 文件描述
+ *
+ * @author tongxi.xia
+ * @date 2020年12月04日 10:13
+ */
+@Service
+public class MinioUtils {
+
+    @Autowired
+    private MinioProp minioProp;
+
+    @Autowired
+    private MinioClient client;
+
+    /**
+     * 创建bucket
+     */
+    public void createBucket(String bucketName) throws Exception {
+        if (!client.bucketExists(bucketName)) {
+            client.makeBucket(bucketName);
+        }
+    }
+
+    /**
+     * 上传文件,返回文件名
+     */
+    public String uploadFile(MultipartFile file, String bucketName) throws Exception {
+        //判断文件是否为空
+        if (null == file || 0 == file.getSize()) {
+            return null;
+        }
+        //判断存储桶是否存在  不存在则创建
+        createBucket(bucketName);
+        //文件名
+        String originalFilename = file.getOriginalFilename();
+        //新的文件名 = 存储桶文件名_时间戳.后缀名
+        String filelName = bucketName + "_" +
+                System.currentTimeMillis() +
+                originalFilename.substring(originalFilename.lastIndexOf("."));
+        //开始上传
+        client.putObject(bucketName, filelName, file.getInputStream(), file.getContentType());
+        return filelName;
+    }
+
+    /**
+     * 获取全部bucket
+     */
+    public List<Bucket> getAllBuckets() throws Exception {
+        return client.listBuckets();
+    }
+
+    /**
+     * 根据bucketName获取信息
+     *
+     * @param bucketName bucket名称
+     */
+    public Optional<Bucket> getBucket(String bucketName) throws IOException, InvalidKeyException, NoSuchAlgorithmException, InsufficientDataException, InvalidResponseException, InternalException, NoResponseException, InvalidBucketNameException, XmlPullParserException, ErrorResponseException {
+        return client.listBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();
+    }
+
+    /**
+     * 根据bucketName删除信息
+     *
+     * @param bucketName bucket名称
+     */
+    public void removeBucket(String bucketName) throws Exception {
+        client.removeBucket(bucketName);
+    }
+
+    /**
+     * 获取⽂件外链
+     *
+     * @param bucketName bucket名称
+     * @param objectName ⽂件名称
+     * @param expires    过期时间 <=7
+     * @return url
+     */
+    public String getObjectURL(String bucketName, String objectName, Integer expires) throws Exception {
+        return client.presignedGetObject(bucketName, objectName, expires);
+    }
+
+    /**
+     * 获取⽂件
+     *
+     * @param bucketName bucket名称
+     * @param objectName ⽂件名称
+     * @return ⼆进制流
+     */
+    public InputStream getObject(String bucketName, String objectName) throws Exception {
+        return client.getObject(bucketName, objectName);
+    }
+
+    /**
+     * 上传⽂件
+     *
+     * @param bucketName bucket名称
+     * @param objectName ⽂件名称
+     * @param stream     ⽂件流
+     * @throws Exception https://docs.minio.io/cn/java-client-api-reference.html#putObject
+     */
+    public void putObject(String bucketName, String objectName, InputStream stream) throws
+            Exception {
+        client.putObject(bucketName, objectName, stream, stream.available(),
+                "application/octet-stream");
+    }
+
+    /**
+     * 上传⽂件
+     *
+     * @param bucketName  bucket名称
+     * @param objectName  ⽂件名称
+     * @param stream      ⽂件流
+     * @param size        ⼤⼩
+     * @param contextType 类型
+     * @throws Exception https://docs.minio.io/cn/java-client-api-reference.html#putObject
+     */
+    public void putObject(String bucketName, String objectName, InputStream stream, long
+            size, String contextType) throws Exception {
+        client.putObject(bucketName, objectName, stream, size, contextType);
+    }
+
+    /**
+     * 获取⽂件信息
+     *
+     * @param bucketName bucket名称
+     * @param objectName ⽂件名称
+     * @throws Exception https://docs.minio.io/cn/java-client-api-reference.html#statObject
+     */
+    public ObjectStat getObjectInfo(String bucketName, String objectName) throws Exception {
+        return client.statObject(bucketName, objectName);
+    }
+
+    /**
+     * 删除⽂件
+     *
+     * @param bucketName bucket名称
+     * @param objectName ⽂件名称
+     * @throws Exception https://docs.minio.io/cn/java-client-apireference.html#removeObject
+     */
+    public void removeObject(String bucketName, String objectName) throws Exception {
+        client.removeObject(bucketName, objectName);
+    }
+}