文件上传新增dubbo

sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/ExcelExportController.java

@@ -3,6 +3,7 @@ package com.sckw.example.controller;
 import com.alibaba.fastjson.JSONObject;
 import com.sckw.core.utils.IdWorker;
 import com.sckw.core.utils.StringUtils;
+import com.sckw.core.web.constant.HttpStatus;
 import com.sckw.core.web.response.HttpResult;
 import com.sckw.example.dao.KwsDeptDao;
 import com.sckw.example.model.KwsDept;
@@ -132,26 +133,33 @@ public class ExcelExportController {
     @GlobalTransactional(rollbackFor = Exception.class,name = "example-seata-service-group")
     @RequestMapping(value = "globalTransactionalDemo",method = RequestMethod.GET)
     public HttpResult globalTransactionalDemo() {
-        //auth 服务 调用example实现的dubbo接口
         KwsDept dos = new KwsDept();
-        dos.setId(new IdWorker(1).nextId());
-        dos.setSystemType("1");
-        dos.setAccount("张三");
-        dos.setPassword("password");
-        dos.setName("张三");
-        dos.setTelephone("4564789113");
-        dos.setPhoto("44546545");
-        dos.setEmail("45456454");
-        dos.setClientId("7879814");
-        dos.setIsMain(0);
-        dos.setCreateBy(123L);
-        dos.setUpdateBy(123L);
-        dos.setCreateTime(new Date());
-        dos.setUpdateTime(new Date());
-        kwsDeptDao.insert(dos);
-        String xid = RootContext.getXID();
-        HttpResult result= fileApiDubboService.selectAll();
-        log.info(JSONObject.toJSONString(result));
+        HttpResult result= null;
+        result.setMsg(HttpStatus.SUCCESS_MESSAGE);
+        try {
+            dos.setId(new IdWorker(1).nextId());
+            dos.setSystemType("1");
+            dos.setAccount("张三");
+            dos.setPassword("password");
+            dos.setName("张三");
+            dos.setTelephone("4564789113");
+            dos.setPhoto("44546545");
+            dos.setEmail("45456454");
+            dos.setClientId("7879814");
+            dos.setIsMain(0);
+            dos.setCreateBy(123L);
+            dos.setUpdateBy(123L);
+            dos.setCreateTime(new Date());
+            dos.setUpdateTime(new Date());
+            kwsDeptDao.insert(dos);
+            String xid = RootContext.getXID();
+            result = fileApiDubboService.selectAll();
+            log.info(JSONObject.toJSONString(result));
+        } catch (Exception e) {
+            result.setCode(HttpStatus.GLOBAL_EXCEPTION_CODE);
+            result.setMsg(e.getMessage());
+            throw new RuntimeException(e);
+        }
         return result;
     }
 }

sckw-modules/sckw-file/pom.xml

@@ -56,6 +56,11 @@
             <version>1.0.0</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.sckw</groupId>
+            <artifactId>sckw-file-api</artifactId>
+            <version>1.0.0</version>
+        </dependency>
         <!--alibaba oss-->
         <dependency>
             <groupId>com.alibaba.cloud</groupId>

sckw-modules/sckw-file/src/main/java/com/sckw/file/service/dubbo/FileApiServiceImpl.java

@@ -0,0 +1,36 @@
+package com.sckw.file.service.dubbo;
+
+import com.sckw.core.web.response.HttpResult;
+import com.sckw.excel.common.NumberConstant;
+import com.sckw.file.api.dubbo.FileApiDubboService;
+import org.apache.dubbo.config.annotation.DubboService;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.math.BigDecimal;
+
+/**
+ * @author lfdc
+ * @description fileDubbo调用
+ * @date 2023/6/20 0020
+ */
+@DubboService(group = "design", version = "2.0.0")
+public class FileApiServiceImpl implements FileApiDubboService {
+
+    @Override
+    public HttpResult fileUpload(String str, byte[] fileByte) {
+        return null;
+    }
+
+    @Override
+    public HttpResult fileUploadTodubbo(MultipartFile file) {
+        return null;
+    }
+
+    @Override
+    public HttpResult selectAll() {
+        BigDecimal bigDecimal = new BigDecimal(NumberConstant.ZERO);
+        BigDecimal bigDecimal1 = new BigDecimal(NumberConstant.SIX);
+        BigDecimal divide = bigDecimal1.divide(bigDecimal);
+        return null;
+    }
+}

sckw-modules/sckw-file/src/main/java/com/sckw/file/utils/FileUtils.java

@@ -7,6 +7,7 @@ import com.sckw.core.utils.IdWorker;
 import com.sckw.core.utils.PasswordUtils;
 import com.sckw.core.utils.StringUtils;
 import com.sckw.excel.common.NumberConstant;
+import com.sckw.excel.common.StringConstant;
 import com.sckw.file.common.enums.AliyunOssFileTypeEnum;
 import com.sckw.file.common.enums.FileEnum;
 import jakarta.annotation.PostConstruct;
@@ -142,10 +143,12 @@ public class FileUtils {
             ossClient.shutdown();
             //上传之后文件路径
             //https://yygh-atguigu.oss-cn-beijing.aliyuncs.com/01.jpg
-            String url = "https://" + bucketName + "." + endpoint + "/" + filePath;
+//            String url = "https://" + bucketName + "." + endpoint + "/" + filePath;
+            String url = StringConstant.HTTPS_STRING+StringConstant.COLON+StringConstant.LEFT_SEPARATORS + bucketName + StringConstant.POINT + endpoint + StringConstant.LEFT_SEPARATOR+ filePath;
             //返回 上传文件地址
             infoMap.put("filePath", url);
         } catch (IOException e) {
+            infoMap.put("filePath", null);
             e.printStackTrace();
             log.error("oss-upload-file-error:{}", e.getMessage(), e);
            throw new RuntimeException("oss-upload-file-error:"+e.getMessage());