Compare commits

..

No commits in common. "f9ab24fcea034e4023f5a94a138175ad4450b0a0" and "b85c2ac09733b7976658c719f7533b058bb9389f" have entirely different histories.

7 changed files with 20 additions and 56 deletions

View File

@ -93,10 +93,4 @@ public class CategoryCreateDTO {
@ApiModelProperty(value = "版本号")
private Integer version;
/**
* 自定替换未设置的变量为空串
*/
@ApiModelProperty(value = "是否自动替换变量为空串默认false")
private Boolean autoReplaceVariables;
}

View File

@ -47,9 +47,6 @@ public class CategoryItemVO {
@ApiModelProperty(value = "版本号")
private Integer version;
@ApiModelProperty(value = "自定替换未设置的变量为空串")
private Boolean autoReplaceVariables;
@ApiModelProperty(value = "更新时间")
private Date updateAt;
}

View File

@ -273,10 +273,15 @@ public class CustomGetProcessInstanceVariablesToObjectCmd extends AbstractComman
groupVariables.forEach(group -> {
if (!CollectionUtils.isEmpty(group.getVars())) {
group.getVars().forEach(variable -> {
Object value = bizVariables.getOrDefault(variable.getCode(), null);
if (Objects.isNull(value)) {
// 目前为了减少 wps 替换耗时所以将没有值的变量直接踢出
return;
}
variables.add(VariableObjectDTO.builder()
.key(variable.getCode())
.desc(group.getGroupName() + variable.getName())
.value(bizVariables.getOrDefault(variable.getCode(), null))
.value(value)
.type(convert(variable.getType()))
.build());
});

View File

@ -84,9 +84,4 @@ public class ExtAxDict extends BaseEntity<ExtAxDict> {
* 版本号
*/
private Integer version;
/**
* 自定替换未设置的变量为空串
*/
private Boolean autoReplaceVariables;
}

View File

@ -119,7 +119,6 @@ public class CategoryServiceImpl extends ServiceImpl<ExtAxDictMapper, ExtAxDict>
dict.setIcon(dto.getIcon());
dict.setDisplayInitiateMenu(dto.getDisplayInitiateMenu());
dict.setVersion(dto.getVersion());
dict.setAutoReplaceVariables(Boolean.TRUE.equals(dto.getAutoReplaceVariables()));
}
@Override

View File

@ -31,7 +31,6 @@ import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.util.Collection;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.Objects;
@ -244,26 +243,20 @@ public class WpsUtil {
* @return 返回替换变量后的文件oss fileKey
*/
public String wpsFileVariableReplace(List<VariableObjectDTO> wpsVariables,
String fileCode, String fileKey, String fileName, Boolean autoReplaceVariables) {
List<VariableObjectDTO> variables = wpsVariables.stream()
.filter(i -> Objects.equals(i.getType().name(), VariableObjectDTO.Type.img.name()) || Objects.equals(i.getType().name(), VariableObjectDTO.Type.text.name()))
.filter(i -> {
if (Objects.equals(Boolean.TRUE, autoReplaceVariables)) {
return true;
} else {
return Objects.nonNull(i.getValue());
}
}).collect(Collectors.toList());
List<FileReplaceContent> fileReplaceContents = BeanMapper.copyList(variables, FileReplaceContent.class, (s, t) -> {
String fileCode, String fileKey, String fileName) {
List<FileReplaceContent> fileReplaceContents = BeanMapper.copyList(wpsVariables.stream()
.filter(i -> Objects.nonNull(i.getValue()) && checkNotEmptyColl(i))
.filter(i -> !(Objects.equals(i.getType().name(), "img") && !StringUtils.hasText(i.getValue().toString())))
.filter(i -> Objects.equals(i.getType().name(), "img") || Objects.equals(i.getType().name(), "text"))
.collect(Collectors.toList()), FileReplaceContent.class, (s, t) -> {
t.setKey(s.getDesc());
if (Objects.equals(s.getType().name(), VariableObjectDTO.Type.img.name())) {
List<UploadFieldDTO> uploadFieldDTOS = new ArrayList<>();
if (Objects.equals(s.getType().name(), "img")) {
if (isJson(s.getValue().toString())) {
uploadFieldDTOS.addAll(JSON.parseArray(s.getValue().toString(), UploadFieldDTO.class));
t.setContent(JSON.parseArray(s.getValue().toString(), UploadFieldDTO.class).get(0).getFileUrl());
} else {
uploadFieldDTOS.addAll(JSON.parseArray(JSON.toJSONString(s.getValue()), UploadFieldDTO.class));
t.setContent(JSON.parseArray(JSON.toJSONString(s.getValue()), UploadFieldDTO.class).get(0).getFileUrl());
}
t.setContent(CollectionUtils.isEmpty(uploadFieldDTOS) ? "" : uploadFieldDTOS.get(0).getFileUrl());
} else {
t.setContent(Objects.nonNull(s.getValue()) ? s.getValue().toString() : "");
}
@ -271,17 +264,6 @@ public class WpsUtil {
t.setPrefix("[");
t.setSuffix("]");
});
// 处理空值
if (Objects.equals(Boolean.TRUE, autoReplaceVariables)) {
fileReplaceContents.stream()
.filter(i -> !StringUtils.hasText(i.getContent()))
.forEach(i -> {
// TODO 将变量替换未空串
});
}
if (StringUtils.hasText(fileCode)) {
FileTemplateReplaceRequest request = new FileTemplateReplaceRequest();
request.setFileCode(fileCode);

View File

@ -4,14 +4,12 @@ import cn.axzo.workflow.common.enums.FileTypeEnum;
import cn.axzo.workflow.common.model.dto.SignFileDTO;
import cn.axzo.workflow.common.model.dto.VariableObjectDTO;
import cn.axzo.workflow.common.model.request.bpmn.BpmnSignConf;
import cn.axzo.workflow.common.model.response.category.CategoryItemVO;
import cn.axzo.workflow.core.common.context.ProcessOperationContext;
import cn.axzo.workflow.core.common.utils.BpmnMetaParserHelper;
import cn.axzo.workflow.core.listener.AbstractBpmnEventListener;
import cn.axzo.workflow.core.listener.BpmnProcessEventListener;
import cn.axzo.workflow.core.repository.entity.ExtAxDocContent;
import cn.axzo.workflow.core.repository.entity.ExtAxProcessSign;
import cn.axzo.workflow.core.service.CategoryService;
import cn.axzo.workflow.core.service.ExtAxDocContentService;
import cn.axzo.workflow.core.service.ExtAxModelDocService;
import cn.axzo.workflow.core.service.ExtAxProcessSignService;
@ -37,8 +35,6 @@ import java.util.Objects;
import java.util.Optional;
import java.util.stream.Collectors;
import static cn.axzo.workflow.common.constant.BpmnConstants.BPM_MODEL_CATEGORY;
/**
* 签署业务审批完成后进行文件归档并对所有工人发送业务待办
*
@ -59,8 +55,6 @@ public class FileArchiveProcessEventListener extends AbstractBpmnEventListener<P
@Resource
private ExtAxDocContentService extAxDocContentService;
@Resource
private CategoryService categoryService;
@Resource
private WpsUtil wpsUtil;
@ -77,21 +71,19 @@ public class FileArchiveProcessEventListener extends AbstractBpmnEventListener<P
HistoricProcessInstance instance = historyService.createHistoricProcessInstanceQuery()
.processInstanceId(processInstanceId).includeProcessVariables().singleResult();
CategoryItemVO category = categoryService.get(BPM_MODEL_CATEGORY, mainProcess.getId()).orElse(new CategoryItemVO());
// 文件归档将审批过程中产生的数据全部替换文档模板变量
archiveFinalDocs(instance, category.getAutoReplaceVariables());
archiveFinalDocs(instance);
}
private void archiveFinalDocs(HistoricProcessInstance instance, Boolean autoReplaceVariables) {
private void archiveFinalDocs(HistoricProcessInstance instance) {
ProcessEngineConfigurationImpl processEngineConfiguration = (ProcessEngineConfigurationImpl) getEngineConfiguration();
ExtAxProcessSign processSign = extAxProcessSignService.findByProcessInstanceId(instance.getId());
List<VariableObjectDTO> wpsReplaceVariables = wpsUtil.getWpsReplaceVariables(processEngineConfiguration, instance.getId());
processSign.getFileArchive().stream().filter(i -> Objects.equals(i.getFileType(), FileTypeEnum.WORD)
|| Objects.equals(i.getFileType(), FileTypeEnum.EXCEL))
.filter(i -> Boolean.TRUE.equals(i.getNeedReplaceVariables()))
.forEach(docBaseVO -> {
String newFileKey = wpsUtil.wpsFileVariableReplace(wpsReplaceVariables, null, docBaseVO.getFileKey(), docBaseVO.getTemplateName() + docBaseVO.getFileType().getSuffix(), autoReplaceVariables);
String newFileKey = wpsUtil.wpsFileVariableReplace(wpsReplaceVariables, null, docBaseVO.getFileKey(), docBaseVO.getTemplateName() + docBaseVO.getFileType().getSuffix());
docBaseVO.setFileKey(newFileKey);
});
// 删除非 WPS 的临时文档
@ -124,6 +116,6 @@ public class FileArchiveProcessEventListener extends AbstractBpmnEventListener<P
@Override
public int getOrder() {
return Integer.MIN_VALUE + 99;
return Integer.MIN_VALUE + 3;
}
}