同步controller

qirong

2023-11-22 516fd8a4c6d998c2c4177f13421ed01b616f4d73

同步controller

 ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/controller/system/SynchronizationController.java

New file
@@ -0,0 +1,40 @@
package org.dromara.system.controller.system;

import cn.dev33.satoken.annotation.SaIgnore;
import cn.hutool.core.util.ObjectUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.common.core.domain.R;
import org.dromara.common.oss.entity.SynchronousRequest;
import org.dromara.system.domain.vo.SysOssVo;
import org.dromara.system.service.ISysOssService;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@SaIgnore
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/resource/synchronization")
public class SynchronizationController {

    private final ISysOssService ossService;

    /**
     * 上传同步
     * @param
     * @return
     */
    @PostMapping(value = "/upload")
    public R synchronization(SynchronousRequest request) {
        if (ObjectUtil.isNull(request.getFile())) {
            return R.fail("上传文件不能为空");
        }
        log.info("ossId:{},path:{}",request.getOssId(),request.getPath());
        SysOssVo oss = ossService.upload2(request);
        return R.ok();
    }
}

 ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/controller/system/SysOssController.java

@@ -159,18 +159,5 @@
        return R.ok("操作成功");
    }

    /**
     * 同步
     * @param
     * @return
     */
    @PostMapping(value = "/synchronization")
    public R synchronization(SynchronousRequest request) {
        if (ObjectUtil.isNull(request.getFile())) {
            return R.fail("上传文件不能为空");
        }
        log.info("ossId:{},path:{}",request.getOssId(),request.getPath());
        SysOssVo oss = ossService.upload2(request);
        return R.ok();
    }

}

 ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/service/impl/SysOssServiceImpl.java

@@ -251,7 +251,7 @@
            storage.delete(sysOss.getUrl());
            if(sysOss.getPassword().equals(password)){
                baseMapper.deleteById(sysOss.getOssId());
                HttpUtils.sendDeleteRequest("http://192.168.3.43/resource/oss",String.valueOf(sysOss.getOssId()),password);
                HttpUtils.sendDeleteRequest("http://192.168.3.43/resource/oss",new Long[]{sysOss.getOssId()},password);
                return true;
            }
            return false;
@@ -289,7 +289,7 @@

    private String post(SynchronousRequest request) throws IOException {
        HashMap<String, String> headers = new HashMap<>(3);
        String requestUrl = "http://192.168.3.43:8080/resource/oss/synchronization";
        String requestUrl = "http://192.168.3.43:8080/resource/synchronization/upload";
        ObjectMapper objectMapper = new ObjectMapper();
        String jsonString = "";
        try {

 ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/uitil/HttpUtils.java

@@ -148,15 +148,22 @@
    /**
     * 删除同步
     * @param url
     * @param parameter
//     * @param parameter
     * @throws Exception
     */
    public static void sendDeleteRequest(String url, String parameter, String password) throws Exception {
        // 拼接URL和参数
        String deleteUrl = url + "/" + parameter + "/" + password;
    public static void sendDeleteRequest(String url, Long[] parameters, String password) throws Exception {
        // 构建URL
        StringBuilder deleteUrl = new StringBuilder(url);
        deleteUrl.append("/");
        for (int i = 0; i < parameters.length; i++) {
            deleteUrl.append(parameters[i]);
            if (i < parameters.length - 1) {
                deleteUrl.append("/");
            }
        }

        // 创建URL对象和HttpURLConnection对象
        URL obj = new URL(deleteUrl);
        URL obj = new URL(deleteUrl.toString());
        HttpURLConnection con = (HttpURLConnection) obj.openConnection();

        // 设置请求方法为DELETE