| | |
|---|
| | | |
|---|
| | | import java.io.InputStream; |
|---|
| | | import java.lang.reflect.Field; |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.nio.charset.StandardCharsets; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | |
|---|
| | | newV.put(task.getTaskDefinitionKey() + "&" + key, variables.get(key)); |
|---|
| | | //字典里有就放入流程变量中 |
|---|
| | | if (!CollectionUtils.isEmpty(dictList) && dictList.contains(key)) { |
|---|
| | | processVariables.put(key,variables.get(key)); |
|---|
| | | if ("money".equals(key)) { |
|---|
| | | // 万元转元 |
|---|
| | | Object w = variables.get(key); |
|---|
| | | BigDecimal y = new BigDecimal(w.toString()).multiply(new BigDecimal(10000)); |
|---|
| | | processVariables.put(key, y); |
|---|
| | | } else { |
|---|
| | | processVariables.put(key,variables.get(key)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | .list(); |
|---|
| | | |
|---|
| | | //扩展 获取这个流程实例的监控信息 key:TaskId value:实体类 |
|---|
| | | Map<String, ProcessCoding> processCodingMap = processCodingMapper |
|---|
| | | .selectList(new QueryWrapper<ProcessCoding>().eq("process_ins_id", procInsId)) |
|---|
| | | Map<String, ProcessCoding> processCodingMap = new LambdaQueryChainWrapper<>(processCodingMapper) |
|---|
| | | .eq(ProcessCoding::getProcessInsId, procInsId) |
|---|
| | | .list() |
|---|
| | | .stream() |
|---|
| | | .collect(Collectors.toMap(ProcessCoding::getTaskId, Function.identity())); |
|---|
| | | // 保存已经完成的流程节点编号 |
|---|
