【数据资产】

1、下载文件流

@@ -220,15 +220,6 @@ 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
     
 }

@@ -3,6 +3,7 @@ package com.csbr.qingcloud.portal.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.csbr.cloud.common.enums.RedisKeyEnum;
 import com.csbr.cloud.common.enums.SystemError;
 import com.csbr.cloud.common.exception.CsbrSystemException;
@@ -17,6 +18,7 @@ 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;
+import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseService;
 import com.csbr.qingcloud.portal.mybatis.service.MfTdsConnectorIdentityService;
 import com.csbr.qingcloud.portal.service.DataPortService;
 import com.csbr.qingcloud.portal.service.TdsConnectorAdditionalService;
@@ -68,6 +70,9 @@ public class DataPortServiceImpl implements DataPortService {
     private DaopCommonFeign daopCommonFeign;
 
     @Resource
+    private MfEnterpriseService mfEnterpriseService;
+
+    @Resource
     private TdsConnectorAdditionalService tdsConnectorAdditionalService;
 
     @Resource
@@ -97,9 +102,30 @@ public class DataPortServiceImpl implements DataPortService {
     public void enterpriseRegister(MfEnterprise entity) {
         log.info("======法人用户注册开始======");
         EnterpriseRegisterRQVO enterpriseRegisterRQVO = beforeEnterprise(entity);
-        Object message = dataPortConnectUtil.postByAuthKey(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
-        if (ObjectUtils.isNotEmpty(message)) {
-            String url = (String) daopCommonFeign.uploadImage((MultipartFile) message).getData();
+        ByteArrayResource resource = dataPortConnectUtil.postByAuthKeyForFile(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
+        if (ObjectUtils.isNotEmpty(resource)) {
+            byte[] resourceByteArray = resource.getByteArray();
+            String resp = new String(resourceByteArray);
+
+            // 判断返回值
+            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 {
+                String fileName = "身份凭证.png";
+                MultipartFile image = new MockMultipartFile(fileName, fileName, "application/octet-stream", resourceByteArray);
+                String url = (String) daopCommonFeign.uploadImage(image).getData();
+                log.info("======url======, {}", url);
+                LambdaUpdateWrapper<MfEnterprise> updateWrapper = new LambdaUpdateWrapper<>();
+                updateWrapper.set(MfEnterprise::getTrustedIdentityCredential, url);
+                updateWrapper.set(MfEnterprise::getCredentialTime, new Date());
+                updateWrapper.eq(MfEnterprise::getGuid, entity.getGuid());
+                mfEnterpriseService.update(updateWrapper);
+
+            }
         }
 
         log.info("======法人用户注册结束======");