【数据资产】

1、返回文件流

 package com.csbr.qingcloud.portal.controller;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
 import com.csbr.cloud.common.response.CommonRes;
 import com.csbr.cloud.workflow.domain.dto.appove.FlowQueryDTO;
-import com.csbr.cloud.workflow.domain.dto.appove.FlowUpdateStateDTO;
+import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
 import com.csbr.qingcloud.portal.domain.vo.*;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.EnterpriseRegisterRQVO;
+import com.csbr.qingcloud.portal.service.DataPortService;
 import com.csbr.qingcloud.portal.service.EnterpriseChangeApproveService;
+import com.csbr.qingcloud.portal.service.EnterpriseService;
 import csbr.cloud.entity.annotation.SystemLog;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
-import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
-import com.csbr.qingcloud.portal.service.EnterpriseService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+
 import java.util.List;
 
 /**
@@ -219,6 +220,15 @@ public class EnterpriseController {
         return CommonRes.success(vo);
     }
 
+    @Autowired
+    private DataPortService dataPortService;
+
+    @PostMapping("/test")
+    public CommonRes test(@RequestBody EnterpriseRegisterRQVO enterpriseRegisterRQVO) {
+        dataPortService.test(enterpriseRegisterRQVO);
+        return CommonRes.success(true);
+    }
+
     //endregion
     
 }

 package com.csbr.qingcloud.portal.feign;
 
 import com.csbr.cloud.common.config.FastCallFeignConfiguration;
+import com.csbr.cloud.common.response.CommonRes;
 import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
 import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
 import org.springframework.cloud.openfeign.FeignClient;
@@ -10,6 +11,8 @@ import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RequestPart;
+import org.springframework.web.multipart.MultipartFile;
 
 /**
  * @program:
@@ -31,4 +34,12 @@ public interface DaopCommonFeign {
     @RequestMapping(value = "/obs/download-file-stream",method = RequestMethod.GET, produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
     ResponseEntity<ByteArrayResource> downloadFile(@RequestParam(value = "filePath", required = true) String filePath);
 
+    /**
+     * 上传
+     * @param image
+     * @return
+     */
+    @RequestMapping(value = "/obs/upload-image",method = RequestMethod.POST, produces = MediaType.MULTIPART_FORM_DATA_VALUE)
+    CommonRes uploadImage(@RequestPart MultipartFile image);
+
 }

 package com.csbr.qingcloud.portal.service;
 
-import com.csbr.qingcloud.portal.domain.vo.TdsConnectorIdentityRSVO;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.EnterpriseRegisterRQVO;
 import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
 import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
 import com.csbr.qingcloud.portal.mybatis.entity.MfTdsConnectorIdentity;
@@ -31,6 +31,8 @@ public interface DataPortService {
      */
     void enterpriseRegister(MfEnterprise entity);
 
+    void test(EnterpriseRegisterRQVO enterpriseRegisterRQVO);
+
     /**
      * 法人用户更新
      * @param entity

@@ -13,6 +13,7 @@ import com.csbr.cloud.external.util.DataPortConnectUtil;
 import com.csbr.qingcloud.portal.domain.vo.TdsConnectorAdditionalRSVO;
 import com.csbr.qingcloud.portal.domain.vo.TdsConnectorVerifiableRSVO;
 import com.csbr.qingcloud.portal.domain.vo.dataPort.*;
+import com.csbr.qingcloud.portal.feign.DaopCommonFeign;
 import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
 import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
 import com.csbr.qingcloud.portal.mybatis.entity.MfTdsConnectorIdentity;
@@ -22,12 +23,16 @@ import com.csbr.qingcloud.portal.service.TdsConnectorAdditionalService;
 import com.csbr.qingcloud.portal.service.TdsConnectorVerifiableService;
 import com.csbr.qingcloud.portal.util.InvokeUtil;
 import com.csbr.qingcloud.portal.util.ZQConfig;
+import csbr.cloud.entity.domain.easyexcel.MockMultipartFile;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.core.io.ByteArrayResource;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
 
+import java.io.FileOutputStream;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -60,6 +65,9 @@ public class DataPortServiceImpl implements DataPortService {
     private InvokeUtil invokeUtil;
 
     @Resource
+    private DaopCommonFeign daopCommonFeign;
+
+    @Resource
     private TdsConnectorAdditionalService tdsConnectorAdditionalService;
 
     @Resource
@@ -72,10 +80,7 @@ public class DataPortServiceImpl implements DataPortService {
     public void operatorRegister(MfEnterprise entity) {
         log.info("======经办人用户注册开始======");
         OperatorRegisterRQVO operatorRegisterRQVO = beforeOperator(entity);
-        String message = dataPortConnectUtil.postByAuthKey(operatorRegisterRQVO, dataPortConfig.getOperatorRegisterUri());
-        if (StringUtils.isNotEmpty(message) && !message.contains("经办人账号身份标识已存在，无法注册")) {
-            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, message);
-        }
+        dataPortConnectUtil.postByAuthKey(operatorRegisterRQVO, dataPortConfig.getOperatorRegisterUri());
         log.info("======经办人用户注册结束======");
     }
 
@@ -92,14 +97,46 @@ public class DataPortServiceImpl implements DataPortService {
     public void enterpriseRegister(MfEnterprise entity) {
         log.info("======法人用户注册开始======");
         EnterpriseRegisterRQVO enterpriseRegisterRQVO = beforeEnterprise(entity);
-        String message = dataPortConnectUtil.postByAuthKey(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
-        if (StringUtils.isNotEmpty(message) && !message.contains("统一社会信用代码已存在")) {
-            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, message);
+        Object message = dataPortConnectUtil.postByAuthKey(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
+        if (ObjectUtils.isNotEmpty(message)) {
+            String url = (String) daopCommonFeign.uploadImage((MultipartFile) message).getData();
         }
+
         log.info("======法人用户注册结束======");
     }
 
     @Override
+    public void test(EnterpriseRegisterRQVO enterpriseRegisterRQVO) {
+        ByteArrayResource resource = dataPortConnectUtil.postByAuthKeyForFile(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
+        if (ObjectUtils.isNotEmpty(resource)) {
+            byte[] resourceByteArray = resource.getByteArray();
+            String resp = new String(resourceByteArray);
+            log.info("======msg======, {}", resp);
+
+            // 判断
+            if (resp.contains("code")) {
+                JSONObject respJson = JSON.parseObject(resp);
+                Integer code = respJson.getInteger("code");
+                if (code != 200 && !resp.contains("统一社会信用代码已存在")) {
+                    throw new CsbrSystemException(SystemError.DATA_GET_ERROR, respJson.getString("message"));
+                }
+            } else {
+                MultipartFile multipartFile = new MockMultipartFile("测试.png", "测试,png", "application/octet-stream", resource.getByteArray());
+                String url = (String) daopCommonFeign.uploadImage(multipartFile).getData();
+                log.info("======url======, {}", url);
+                System.out.println(url);
+            }
+
+//            try (FileOutputStream fos = new FileOutputStream("/Users/xiaojie/Downloads/" + multipartFile.getOriginalFilename())) {
+//                fos.write(multipartFile.getBytes());
+//            } catch (Exception exception) {
+//                exception.printStackTrace();
+//            }
+
+        }
+    }
+
+    @Override
     public void enterpriseUpdate(MfEnterpriseChangeApprove entity) {
         log.info("======法人用户更新开始======");
         MfEnterprise mfEnterprise = csbrBeanUtil.convert(entity, MfEnterprise.class);