【数据资产】

1、企业增加是否认证字段

@@ -34,6 +34,7 @@ import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.core.io.ByteArrayResource;
 import org.springframework.core.io.ByteArrayResource;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
+import org.springframework.util.Base64Utils;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartFile;
 
 
 import java.io.FileOutputStream;
 import java.io.FileOutputStream;
@@ -223,6 +224,19 @@ public class DataPortServiceImpl implements DataPortService {
         ConnectorRegisterRSVO connectorRegisterRSVO = JSON.parseObject(JSON.toJSONString(object), ConnectorRegisterRSVO.class);
         ConnectorRegisterRSVO connectorRegisterRSVO = JSON.parseObject(JSON.toJSONString(object), ConnectorRegisterRSVO.class);
         log.info("object, {}", object);
         log.info("object, {}", object);
         log.info("connectorRegisterRSVO, {}", connectorRegisterRSVO);
         log.info("connectorRegisterRSVO, {}", connectorRegisterRSVO);
+
+        // 身份凭证base64转换为图片
+        String connectorCert = connectorRegisterRSVO.getConnectorCert();
+        if (StringUtils.isNotEmpty(connectorCert)) {
+            String connectorName = String.format("%s.png", entity.getConnectorName());
+            MultipartFile image = new MockMultipartFile(connectorName, connectorName, "application/octet-stream", Base64Utils.decodeFromString(connectorCert));
+            String url = (String) daopCommonFeign.uploadFile(image, connectorName).getData();
+            log.info("======url======, {}", url);
+            if (StringUtils.isNotEmpty(url)) {
+                entity.setTrustedIdentityCredential(url);
+            }
+        }
+
         // 修改接入连接器身份标识
         // 修改接入连接器身份标识
         entity.setConnectorIdentity(connectorRegisterRSVO.getIdentityCode());
         entity.setConnectorIdentity(connectorRegisterRSVO.getIdentityCode());
         mfTdsConnectorIdentityService.updateById(entity);
         mfTdsConnectorIdentityService.updateById(entity);