wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/feature/REQ-3581' into feature/REQ-3581

Browse Source
This commit is contained in:
yanglin 2025-02-26 16:16:39 +08:00
commit 3e9c347c67
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/workflow/process/CompleteVisaChangeStampHandler.java
View File

@ -46,6 +46,7 @@ public class CompleteVisaChangeStampHandler implements ProcessInstanceEventHandl
@Override
public void onCompleted(ProcessInstanceDTO dto) {
Long visaId = Long.valueOf(dto.getBusinessKey());
log.info("CompleteVisaChangeStampHandler visaId, {}", visaId);
Long operatorId = Optional.ofNullable(dto.getLastOperationAssigner())
.map(e -> Long.valueOf(e.getPersonId()))
.orElse(null);
@ -56,20 +57,23 @@ public class CompleteVisaChangeStampHandler implements ProcessInstanceEventHandl
.build();
List<ChangeRecordRelation> allRecordRelations = changeRecordRelationService.findByCondition(visaRelationDto);
log.info("CompleteVisaChangeStampHandler allRecordRelations, {}", JSON.toJSONString(allRecordRelations));
List<ChangeRecordRelation> changeRecordRelations = allRecordRelations.stream()
.filter(e -> Objects.equals(JSON.parseObject(e.getContent()).getString("approvalId"), dto.getProcessInstanceId()))
.collect(Collectors.toList());
if (CollectionUtils.isEmpty(changeRecordRelations)) {
log.warn("用印审核完成数据异常，未找到对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId());
log.warn("CompleteVisaChangeStampHandler 用印审核完成数据异常，未找到对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId());
return;
}
if (changeRecordRelations.size() > 1) {
log.warn("用印审核完成数据异常，找到多条对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId());
log.warn("CompleteVisaChangeStampHandler 用印审核完成数据异常，找到多条对应的用印申请记录，visaId,{}; processInstanceId,{}", visaId, dto.getProcessInstanceId());
}
ChangeRecordRelation changeRecordRelation = changeRecordRelations.stream()
.findFirst()
.get();
log.info("CompleteVisaChangeStampHandler changeRecordRelation, {}", JSON.toJSONString(changeRecordRelation));
ChangeRecordRelation update = new ChangeRecordRelation();
update.setId(changeRecordRelation.getId());