【数据资产】

1、连接器入驻作废旧数据报错

@@ -167,7 +167,31 @@ public class DataPortServiceImpl implements DataPortService {
         log.info("======法人用户更新开始======");
         log.info("======法人用户更新开始======");
         MfEnterprise mfEnterprise = csbrBeanUtil.convert(entity, MfEnterprise.class);
         MfEnterprise mfEnterprise = csbrBeanUtil.convert(entity, MfEnterprise.class);
         EnterpriseRegisterRQVO enterpriseRegisterRQVO = beforeEnterprise(mfEnterprise);
         EnterpriseRegisterRQVO enterpriseRegisterRQVO = beforeEnterprise(mfEnterprise);
-        dataPortConnectUtil.postByAuthKey(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseUpdateUri());
+        ByteArrayResource resource = dataPortConnectUtil.postByAuthKeyForFile(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseUpdateUri());
+        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("======法人用户更新结束======");
         log.info("======法人用户更新结束======");
     }
     }