【数据资产】
1、发起跨平台审批流程
Showing
6 changed files
with
60 additions
and
13 deletions
... | @@ -231,6 +231,15 @@ public class DemandRSVO { | ... | @@ -231,6 +231,15 @@ public class DemandRSVO { |
231 | 231 | ||
232 | @Schema(description = "加工单编号") | 232 | @Schema(description = "加工单编号") |
233 | private String processOrderNo; | 233 | private String processOrderNo; |
234 | |||
235 | @Schema(title = "专区名称") | ||
236 | private String zqName; | ||
237 | |||
238 | /** | ||
239 | * 跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销) | ||
240 | */ | ||
241 | @Schema(title = "跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)") | ||
242 | private String crossPlatformApproveState; | ||
234 | 243 | ||
235 | /******** 库表存储属性 需处理 *****/ | 244 | /******** 库表存储属性 需处理 *****/ |
236 | 245 | ... | ... |
... | @@ -188,6 +188,15 @@ public class EnterpriseRSVO { | ... | @@ -188,6 +188,15 @@ public class EnterpriseRSVO { |
188 | 188 | ||
189 | @Schema(description = "提交时间") | 189 | @Schema(description = "提交时间") |
190 | private Date createTime; | 190 | private Date createTime; |
191 | |||
192 | @Schema(title = "专区名称") | ||
193 | private String zqName; | ||
194 | |||
195 | /** | ||
196 | * 跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销) | ||
197 | */ | ||
198 | @Schema(title = "跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)") | ||
199 | private String crossPlatformApproveState; | ||
191 | 200 | ||
192 | /******** 库表存储属性 需处理 *****/ | 201 | /******** 库表存储属性 需处理 *****/ |
193 | 202 | ... | ... |
... | @@ -221,4 +221,13 @@ public class MfDemand extends BaseShardingDO { | ... | @@ -221,4 +221,13 @@ public class MfDemand extends BaseShardingDO { |
221 | @Name("加工单编号") | 221 | @Name("加工单编号") |
222 | private String processOrderNo; | 222 | private String processOrderNo; |
223 | 223 | ||
224 | @Name("资产Guid") | ||
225 | private String zqBizGuid; | ||
226 | |||
227 | @Name("专区名称") | ||
228 | private String zqName; | ||
229 | |||
230 | @Name("审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)") | ||
231 | private String crossPlatformApproveState; | ||
232 | |||
224 | } | 233 | } | ... | ... |
... | @@ -171,6 +171,15 @@ public class MfEnterprise extends BaseDO { | ... | @@ -171,6 +171,15 @@ public class MfEnterprise extends BaseDO { |
171 | */ | 171 | */ |
172 | @Name("授权委托书") | 172 | @Name("授权委托书") |
173 | private String authorizationLetter; | 173 | private String authorizationLetter; |
174 | |||
175 | @Name("资产Guid") | ||
176 | private String zqBizGuid; | ||
177 | |||
178 | @Name("专区名称") | ||
179 | private String zqName; | ||
180 | |||
181 | @Name("审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)") | ||
182 | private String crossPlatformApproveState; | ||
174 | 183 | ||
175 | /** | 184 | /** |
176 | * 业务审批状态【N 草稿中,A 审批中,Y 已通过,R 驳回,C 已撤销,D 已废弃; 默认 N】 | 185 | * 业务审批状态【N 草稿中,A 审批中,Y 已通过,R 驳回,C 已撤销,D 已废弃; 默认 N】 | ... | ... |
1 | package com.csbr.qingcloud.portal.service.impl; | 1 | package com.csbr.qingcloud.portal.service.impl; |
2 | 2 | ||
3 | import com.alibaba.fastjson.JSON; | ||
3 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; | 4 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
4 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; | 5 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
5 | import com.baomidou.mybatisplus.core.toolkit.Wrappers; | 6 | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
... | @@ -159,7 +160,7 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService | ... | @@ -159,7 +160,7 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService |
159 | MfDemand entity = convertToEntity(rqVO); | 160 | MfDemand entity = convertToEntity(rqVO); |
160 | entity.setRequirementOrderNo(configureFeign.newCode(new RuleDTO().setRuleName("demand-code").setRuleType("generate")).getData()); | 161 | entity.setRequirementOrderNo(configureFeign.newCode(new RuleDTO().setRuleName("demand-code").setRuleType("generate")).getData()); |
161 | // 发起审批流程或保存草稿 | 162 | // 发起审批流程或保存草稿 |
162 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity); | 163 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity, rqVO); |
163 | super.startWorkFlow(rqVO, approvalDTO, entity::setBizApproveState); | 164 | super.startWorkFlow(rqVO, approvalDTO, entity::setBizApproveState); |
164 | // 业务数据保存 | 165 | // 业务数据保存 |
165 | boolean flag = mfDemandService.save(entity); | 166 | boolean flag = mfDemandService.save(entity); |
... | @@ -201,7 +202,7 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService | ... | @@ -201,7 +202,7 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService |
201 | beforeUpdate(rqVO); | 202 | beforeUpdate(rqVO); |
202 | MfDemand entity = convertToEntity(rqVO); | 203 | MfDemand entity = convertToEntity(rqVO); |
203 | // 发起审批流程或保存草稿 | 204 | // 发起审批流程或保存草稿 |
204 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity); | 205 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity, rqVO); |
205 | super.startOrRestartWorkFlow(rqVO, rqVO.getBizApproveState(), approvalDTO, entity::setBizApproveState); | 206 | super.startOrRestartWorkFlow(rqVO, rqVO.getBizApproveState(), approvalDTO, entity::setBizApproveState); |
206 | if (rqVO.getIsRestart()) { | 207 | if (rqVO.getIsRestart()) { |
207 | // 重新提交 | 208 | // 重新提交 |
... | @@ -373,12 +374,14 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService | ... | @@ -373,12 +374,14 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService |
373 | 374 | ||
374 | /** | 375 | /** |
375 | * 获取发起流程参数 | 376 | * 获取发起流程参数 |
376 | * @author xcq | 377 | * |
377 | * @date 2024-12-31 18:46 | ||
378 | * @param entity | 378 | * @param entity |
379 | * @param rqVO | ||
379 | * @return com.csbr.cloud.workflow.domain.dto.appove.AddApprovalDTO | 380 | * @return com.csbr.cloud.workflow.domain.dto.appove.AddApprovalDTO |
381 | * @author xcq | ||
382 | * @date 2024-12-31 18:46 | ||
380 | */ | 383 | */ |
381 | private AddApprovalDTO getAddApprovalDTO(MfDemand entity) { | 384 | private AddApprovalDTO getAddApprovalDTO(MfDemand entity, DemandRQVO rqVO) { |
382 | AddApprovalDTO approvalDTO = new AddApprovalDTO(FLOW_TYPE, entity.getGuid()); | 385 | AddApprovalDTO approvalDTO = new AddApprovalDTO(FLOW_TYPE, entity.getGuid()); |
383 | // todo | 386 | // todo |
384 | approvalDTO.setFuncCode("SJXQ"); | 387 | approvalDTO.setFuncCode("SJXQ"); |
... | @@ -391,6 +394,10 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService | ... | @@ -391,6 +394,10 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService |
391 | approvalDTO.setParam3(null); | 394 | approvalDTO.setParam3(null); |
392 | approvalDTO.setParam4(null); | 395 | approvalDTO.setParam4(null); |
393 | 396 | ||
397 | // 增加跨服务审批字段 | ||
398 | rqVO.setGuid(entity.getGuid()); | ||
399 | approvalDTO.setBizData(JSON.toJSONString(rqVO)); | ||
400 | |||
394 | return approvalDTO; | 401 | return approvalDTO; |
395 | } | 402 | } |
396 | 403 | ... | ... |
... | @@ -6,10 +6,8 @@ import com.alibaba.fastjson.JSONObject; | ... | @@ -6,10 +6,8 @@ import com.alibaba.fastjson.JSONObject; |
6 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; | 6 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
7 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; | 7 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
8 | import com.csbr.cloud.common.enums.SystemError; | 8 | import com.csbr.cloud.common.enums.SystemError; |
9 | import com.csbr.cloud.common.enums.UserError; | ||
10 | import com.csbr.cloud.common.enums.WorkFlowBizEnum; | 9 | import com.csbr.cloud.common.enums.WorkFlowBizEnum; |
11 | import com.csbr.cloud.common.exception.CsbrSystemException; | 10 | import com.csbr.cloud.common.exception.CsbrSystemException; |
12 | import com.csbr.cloud.common.exception.CsbrUserException; | ||
13 | import com.csbr.cloud.common.util.CommonUtil; | 11 | import com.csbr.cloud.common.util.CommonUtil; |
14 | import com.csbr.cloud.common.util.CsbrBeanUtil; | 12 | import com.csbr.cloud.common.util.CsbrBeanUtil; |
15 | import com.csbr.cloud.common.util.MessageSourceUtil; | 13 | import com.csbr.cloud.common.util.MessageSourceUtil; |
... | @@ -21,7 +19,6 @@ import com.csbr.cloud.workflow.util.FlowAbstractImpl; | ... | @@ -21,7 +19,6 @@ import com.csbr.cloud.workflow.util.FlowAbstractImpl; |
21 | import com.csbr.qingcloud.portal.domain.vo.*; | 19 | import com.csbr.qingcloud.portal.domain.vo.*; |
22 | import com.csbr.qingcloud.portal.feign.ConfigureFeign; | 20 | import com.csbr.qingcloud.portal.feign.ConfigureFeign; |
23 | import com.csbr.qingcloud.portal.feign.PersonelFeign; | 21 | import com.csbr.qingcloud.portal.feign.PersonelFeign; |
24 | import com.csbr.qingcloud.portal.feign.UserFeign; | ||
25 | import com.csbr.qingcloud.portal.mybatis.entity.MfDemand; | 22 | import com.csbr.qingcloud.portal.mybatis.entity.MfDemand; |
26 | import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise; | 23 | import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise; |
27 | import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove; | 24 | import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove; |
... | @@ -40,6 +37,7 @@ import org.apache.commons.collections.CollectionUtils; | ... | @@ -40,6 +37,7 @@ import org.apache.commons.collections.CollectionUtils; |
40 | import org.apache.commons.lang3.StringUtils; | 37 | import org.apache.commons.lang3.StringUtils; |
41 | import org.springframework.stereotype.Service; | 38 | import org.springframework.stereotype.Service; |
42 | import org.springframework.transaction.annotation.Transactional; | 39 | import org.springframework.transaction.annotation.Transactional; |
40 | |||
43 | import java.util.ArrayList; | 41 | import java.util.ArrayList; |
44 | import java.util.List; | 42 | import java.util.List; |
45 | 43 | ||
... | @@ -199,7 +197,7 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris | ... | @@ -199,7 +197,7 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris |
199 | beforeSave(rqVO); | 197 | beforeSave(rqVO); |
200 | MfEnterprise entity = convertToEntity(rqVO); | 198 | MfEnterprise entity = convertToEntity(rqVO); |
201 | // 发起审批流程或保存草稿 | 199 | // 发起审批流程或保存草稿 |
202 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity); | 200 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity, rqVO); |
203 | super.startWorkFlow(rqVO, approvalDTO, entity::setBizApproveState); | 201 | super.startWorkFlow(rqVO, approvalDTO, entity::setBizApproveState); |
204 | // 业务数据保存 | 202 | // 业务数据保存 |
205 | boolean flag = mfEnterpriseService.save(entity); | 203 | boolean flag = mfEnterpriseService.save(entity); |
... | @@ -226,7 +224,7 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris | ... | @@ -226,7 +224,7 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris |
226 | beforeUpdate(rqVO); | 224 | beforeUpdate(rqVO); |
227 | MfEnterprise entity = convertToEntity(rqVO); | 225 | MfEnterprise entity = convertToEntity(rqVO); |
228 | // 发起审批流程或保存草稿 | 226 | // 发起审批流程或保存草稿 |
229 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity); | 227 | AddApprovalDTO approvalDTO = getAddApprovalDTO(entity, rqVO); |
230 | super.startOrRestartWorkFlow(rqVO, rqVO.getBizApproveState(), approvalDTO, entity::setBizApproveState); | 228 | super.startOrRestartWorkFlow(rqVO, rqVO.getBizApproveState(), approvalDTO, entity::setBizApproveState); |
231 | if (rqVO.getIsRestart()) { | 229 | if (rqVO.getIsRestart()) { |
232 | // 重新提交 | 230 | // 重新提交 |
... | @@ -435,12 +433,14 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris | ... | @@ -435,12 +433,14 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris |
435 | 433 | ||
436 | /** | 434 | /** |
437 | * 获取发起流程参数 | 435 | * 获取发起流程参数 |
438 | * @author xcq | 436 | * |
439 | * @date 2024-12-26 16:18 | ||
440 | * @param entity | 437 | * @param entity |
438 | * @param rqVO | ||
441 | * @return com.csbr.cloud.workflow.domain.dto.appove.AddApprovalDTO | 439 | * @return com.csbr.cloud.workflow.domain.dto.appove.AddApprovalDTO |
440 | * @author xcq | ||
441 | * @date 2024-12-26 16:18 | ||
442 | */ | 442 | */ |
443 | private AddApprovalDTO getAddApprovalDTO(MfEnterprise entity) { | 443 | private AddApprovalDTO getAddApprovalDTO(MfEnterprise entity, EnterpriseRQVO rqVO) { |
444 | AddApprovalDTO approvalDTO = new AddApprovalDTO(WorkFlowBizEnum.ENTERPRISE_APPLY.getValue(), entity.getGuid()); | 444 | AddApprovalDTO approvalDTO = new AddApprovalDTO(WorkFlowBizEnum.ENTERPRISE_APPLY.getValue(), entity.getGuid()); |
445 | // todo | 445 | // todo |
446 | approvalDTO.setFuncCode("QYRZ"); | 446 | approvalDTO.setFuncCode("QYRZ"); |
... | @@ -454,6 +454,10 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris | ... | @@ -454,6 +454,10 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris |
454 | approvalDTO.setParam3(entity.getSocialCreditCode()); | 454 | approvalDTO.setParam3(entity.getSocialCreditCode()); |
455 | approvalDTO.setParam4(String.format("%s_%s_%s",entity.getJuridicalPerson(),entity.getContacts(),entity.getContactTel())); | 455 | approvalDTO.setParam4(String.format("%s_%s_%s",entity.getJuridicalPerson(),entity.getContacts(),entity.getContactTel())); |
456 | 456 | ||
457 | // 增加跨服务审批字段 | ||
458 | rqVO.setGuid(entity.getGuid()); | ||
459 | approvalDTO.setBizData(JSON.toJSONString(rqVO)); | ||
460 | |||
457 | return approvalDTO; | 461 | return approvalDTO; |
458 | } | 462 | } |
459 | 463 | ... | ... |
-
Please register or sign in to post a comment