Skip to content
Toggle navigation
Toggle navigation
This project
Loading...
Sign in
csbr-daop
/
ms-data-circulation-portal-service
Go to a project
Toggle navigation
Toggle navigation pinning
Projects
Groups
Snippets
Help
Project
Activity
Repository
Pipelines
Graphs
Issues
0
Merge Requests
0
Wiki
Network
Create a new issue
Builds
Commits
Issue Boards
Files
Commits
Network
Compare
Branches
Tags
391682cb
authored
2025-09-24 10:34:21 +0800
by
xu
Browse Files
Options
Browse Files
Tag
Download
Email Patches
Plain Diff
可信空间连接器入住接口
1 parent
f89494e3
Show whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
110 additions
and
14 deletions
src/main/java/com/csbr/qingcloud/portal/controller/TdsConnectorIdentityManagementController.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/DemandRQVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/DemandRSVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseApproveRSVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseRQVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseRSVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/TdsConnectorIdentityManagementRSVO.java
src/main/java/com/csbr/qingcloud/portal/domain/vo/TdsConnectorIdentityManagementVoucherRQVO.java
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfDemand.java
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfEnterprise.java
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfEnterpriseChangeApprove.java
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfTdsConnectorIdentityManagement.java
src/main/java/com/csbr/qingcloud/portal/service/TdsConnectorIdentityManagementService.java
src/main/java/com/csbr/qingcloud/portal/service/impl/TdsConnectorIdentityManagementServiceImpl.java
src/main/java/com/csbr/qingcloud/portal/controller/TdsConnectorIdentityManagementController.java
View file @
391682c
package
com
.
csbr
.
qingcloud
.
portal
.
controller
;
import
com.csbr.cloud.common.response.CommonRes
;
import
com.csbr.qingcloud.portal.domain.vo.TdsConnectorIdentityManagementVoucherRQVO
;
import
csbr.cloud.entity.annotation.SystemLog
;
import
csbr.cloud.entity.domain.base.vo.PageListVO
;
import
com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO
;
...
...
@@ -85,6 +86,14 @@ public class TdsConnectorIdentityManagementController {
return
CommonRes
.
success
(
true
);
}
@PostMapping
(
"/update-voucher"
)
@SystemLog
(
value
=
"连接器身份管理-修改凭证信息"
)
@Operation
(
summary
=
"连接器身份管理-修改凭证信息"
,
hidden
=
true
)
public
CommonRes
<
Boolean
>
updateVoucher
(
@RequestBody
@Valid
TdsConnectorIdentityManagementVoucherRQVO
rqVO
)
{
tdsConnectorIdentityManagementService
.
updateVoucher
(
rqVO
);
return
CommonRes
.
success
(
true
);
}
//endregion
}
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/DemandRQVO.java
View file @
391682c
...
...
@@ -30,7 +30,7 @@ public class DemandRQVO extends FlowRQBaseVO {
@Schema
(
description
=
"需求类型"
)
private
String
requirementType
;
@Schema
(
title
=
"
专区
名称"
)
@Schema
(
title
=
"
节点
名称"
)
private
String
zqName
;
/**
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/DemandRSVO.java
View file @
391682c
...
...
@@ -233,7 +233,7 @@ public class DemandRSVO {
@Schema
(
description
=
"加工单编号"
)
private
String
processOrderNo
;
@Schema
(
title
=
"
专区
名称"
)
@Schema
(
title
=
"
节点
名称"
)
private
String
zqName
;
@Schema
(
description
=
"业务名称"
)
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseApproveRSVO.java
View file @
391682c
...
...
@@ -23,7 +23,7 @@ public class EnterpriseApproveRSVO extends ApproveVO {
@Schema
(
description
=
"跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)"
)
private
String
crossPlatformApproveState
;
@Schema
(
description
=
"
专区
名称"
)
@Schema
(
description
=
"
节点
名称"
)
private
String
zqName
;
/******** 子对象 *****/
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseRQVO.java
View file @
391682c
...
...
@@ -25,7 +25,7 @@ public class EnterpriseRQVO extends FlowRQBaseVO {
@Schema
(
description
=
"公司名称"
)
private
String
tenantName
;
@Schema
(
title
=
"
专区
名称"
)
@Schema
(
title
=
"
节点
名称"
)
private
String
zqName
;
/**
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/EnterpriseRSVO.java
View file @
391682c
...
...
@@ -189,7 +189,7 @@ public class EnterpriseRSVO {
@Schema
(
description
=
"提交时间"
)
private
Date
createTime
;
@Schema
(
title
=
"
专区
名称"
)
@Schema
(
title
=
"
节点
名称"
)
private
String
zqName
;
/**
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/TdsConnectorIdentityManagementRSVO.java
View file @
391682c
package
com
.
csbr
.
qingcloud
.
portal
.
domain
.
vo
;
import
com.alibaba.fastjson.JSONArray
;
import
io.swagger.v3.oas.annotations.media.Schema
;
import
com.fasterxml.jackson.annotation.JsonFormat
;
import
lombok.Data
;
...
...
@@ -23,9 +24,9 @@ public class TdsConnectorIdentityManagementRSVO {
private
String
guid
;
/**
*
专区
Guid
*
节点
Guid
*/
@Schema
(
description
=
"
专区
Guid"
)
@Schema
(
description
=
"
节点
Guid"
)
private
String
zqGuid
;
/**
...
...
@@ -57,7 +58,7 @@ public class TdsConnectorIdentityManagementRSVO {
* 凭证证书
*/
@Schema
(
description
=
"凭证证书"
)
private
String
certificate
;
private
JSONArray
certificate
;
/**
* 凭证有效期
...
...
src/main/java/com/csbr/qingcloud/portal/domain/vo/TdsConnectorIdentityManagementVoucherRQVO.java
0 → 100644
View file @
391682c
package
com
.
csbr
.
qingcloud
.
portal
.
domain
.
vo
;
import
com.alibaba.fastjson.JSONArray
;
import
com.fasterxml.jackson.annotation.JsonFormat
;
import
io.swagger.v3.oas.annotations.media.Schema
;
import
jakarta.validation.constraints.NotBlank
;
import
jakarta.validation.constraints.NotNull
;
import
lombok.Data
;
import
java.util.Date
;
import
java.util.Map
;
/**
* @program:
* @description: 连接器身份管理凭证信息参数
* @author: xup
* @create: 2025-09-23 15:45
**/
@Data
@Schema
(
title
=
"连接器身份管理凭证信息参数"
)
public
class
TdsConnectorIdentityManagementVoucherRQVO
{
/**
* 系统唯一标识
*/
@Schema
(
description
=
"系统唯一标识"
)
@NotBlank
(
message
=
"系统唯一标识为空。"
)
private
String
guid
;
/**
* Key标识私钥
*/
@Schema
(
description
=
"Key标识私钥"
)
@NotBlank
(
message
=
"Key标识私钥为空。"
)
private
String
privatekey
;
/**
* 凭证证书
*/
@Schema
(
description
=
"凭证证书"
)
@NotBlank
(
message
=
"凭证证书为空。"
)
private
JSONArray
certificate
;
/**
* 凭证有效期
*/
@Schema
(
description
=
"凭证有效期"
)
@JsonFormat
(
pattern
=
"yyyy-MM-dd"
,
timezone
=
"GMT+8"
)
@NotNull
(
message
=
"凭证有效期为空。"
)
private
Date
voucherExpirationTime
;
/******** 库表存储属性 需处理 *****/
/******** 自定义扩展 *****/
/******** 子对象 *****/
}
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfDemand.java
View file @
391682c
...
...
@@ -224,7 +224,7 @@ public class MfDemand extends BaseShardingDO {
@Name
(
"资产Guid"
)
private
String
zqBizGuid
;
@Name
(
"
专区
名称"
)
@Name
(
"
节点
名称"
)
private
String
zqName
;
@Name
(
"审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)"
)
...
...
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfEnterprise.java
View file @
391682c
...
...
@@ -175,7 +175,7 @@ public class MfEnterprise extends BaseDO {
@Name
(
"资产Guid"
)
private
String
zqBizGuid
;
@Name
(
"
专区
名称"
)
@Name
(
"
节点
名称"
)
private
String
zqName
;
@Name
(
"审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)"
)
...
...
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfEnterpriseChangeApprove.java
View file @
391682c
...
...
@@ -193,7 +193,7 @@ public class MfEnterpriseChangeApprove extends BaseDO {
@Name
(
"资产Guid"
)
private
String
zqBizGuid
;
@Name
(
"
专区
名称"
)
@Name
(
"
节点
名称"
)
private
String
zqName
;
@Name
(
"审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)"
)
...
...
src/main/java/com/csbr/qingcloud/portal/mybatis/entity/MfTdsConnectorIdentityManagement.java
View file @
391682c
package
com
.
csbr
.
qingcloud
.
portal
.
mybatis
.
entity
;
import
com.alibaba.fastjson.JSONArray
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler
;
import
csbr.cloud.entity.domain.base.dao.BaseDO
;
import
jdk.jfr.Name
;
import
lombok.Data
;
...
...
@@ -17,12 +21,13 @@ import java.util.Date;
@EqualsAndHashCode
(
callSuper
=
true
)
@Accessors
(
chain
=
true
)
@Name
(
"连接器身份管理"
)
@TableName
(
autoResultMap
=
true
)
public
class
MfTdsConnectorIdentityManagement
extends
BaseDO
{
/**
*
专区
Guid
*
节点
Guid
*/
@Name
(
"
专区
Guid"
)
@Name
(
"
节点
Guid"
)
private
String
zqGuid
;
/**
...
...
@@ -53,7 +58,8 @@ public class MfTdsConnectorIdentityManagement extends BaseDO {
* 凭证证书
*/
@Name
(
"凭证证书"
)
private
String
certificate
;
@TableField
(
typeHandler
=
FastjsonTypeHandler
.
class
)
private
JSONArray
certificate
;
/**
* 凭证有效期
...
...
src/main/java/com/csbr/qingcloud/portal/service/TdsConnectorIdentityManagementService.java
View file @
391682c
package
com
.
csbr
.
qingcloud
.
portal
.
service
;
import
com.csbr.qingcloud.portal.domain.vo.TdsConnectorIdentityManagementVoucherRQVO
;
import
csbr.cloud.entity.domain.base.vo.PageListVO
;
import
com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO
;
import
com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO
;
...
...
@@ -70,4 +71,9 @@ public interface TdsConnectorIdentityManagementService {
*/
void
flowCallBack
(
BizCallbackDTO
dto
);
/**
* 修改凭证信息
* @param rqVO
*/
void
updateVoucher
(
TdsConnectorIdentityManagementVoucherRQVO
rqVO
);
}
...
...
src/main/java/com/csbr/qingcloud/portal/service/impl/TdsConnectorIdentityManagementServiceImpl.java
View file @
391682c
...
...
@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import
com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper
;
import
com.csbr.cloud.common.enums.SystemError
;
import
com.csbr.cloud.common.enums.WorkFlowBizEnum
;
import
com.csbr.qingcloud.portal.domain.vo.TdsConnectorIdentityManagementVoucherRQVO
;
import
csbr.cloud.entity.enums.ApprovalStateEnum
;
import
com.csbr.cloud.common.exception.CsbrSystemException
;
import
com.csbr.cloud.common.util.CommonUtil
;
...
...
@@ -250,6 +251,21 @@ public class TdsConnectorIdentityManagementServiceImpl extends FlowAbstractImpl
}
}
@Override
public
void
updateVoucher
(
TdsConnectorIdentityManagementVoucherRQVO
rqVO
)
{
MfTdsConnectorIdentityManagement
entity
=
mfTdsConnectorIdentityManagementService
.
getById
(
rqVO
.
getGuid
());
if
(
entity
==
null
)
{
throw
new
CsbrSystemException
(
SystemError
.
DATA_NOT_EXISTS
,
messageSourceUtil
.
notExistsToSelectMessage
(
FUNCTION_NAME
));
}
if
(!
ApprovalStateEnum
.
PASSED
.
getValue
().
equals
(
entity
.
getBizApproveState
())){
throw
new
CsbrSystemException
(
SystemError
.
DATA_INPUT_ERROR
,
"非审批通过数据,无法修改凭证信息"
);
}
entity
.
setPrivatekey
(
rqVO
.
getPrivatekey
());
entity
.
setCertificate
(
rqVO
.
getCertificate
());
entity
.
setVoucherExpirationTime
(
rqVO
.
getVoucherExpirationTime
());
mfTdsConnectorIdentityManagementService
.
updateById
(
entity
);
}
/**
* 获取发起流程参数
* @author xup
...
...
Write
Preview
Styling with
Markdown
is supported
Attach a file
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to post a comment