mirror of
https://github.com/nocobase/nocobase
synced 2024-11-18 00:06:25 +00:00
49 lines
1002 B
TypeScript
49 lines
1002 B
TypeScript
|
import { JOB_STATUS } from "../constants";
|
||
|
|
import FlowNodeModel from "../models/FlowNode";
|
||
|
|
import { calculate } from "../calculators";
|
||
|
|
|
||
|
|
// @calculation: {
|
||
|
|
// calculator: 'concat',
|
||
|
|
// operands: [
|
||
|
|
// {
|
||
|
|
// type: 'calculation',
|
||
|
|
// options: {
|
||
|
|
// calculator: 'add',
|
||
|
|
// operands: [{ value: 1 }, { value: 2 }]
|
||
|
|
// }
|
||
|
|
// },
|
||
|
|
// {
|
||
|
|
// type: 'constant',
|
||
|
|
// value: '{{$context.data.title}}'
|
||
|
|
// },
|
||
|
|
// {
|
||
|
|
// type: 'context',
|
||
|
|
// options: {
|
||
|
|
// path: 'data.title'
|
||
|
|
// }
|
||
|
|
// },
|
||
|
|
// {
|
||
|
|
// type: 'constant',
|
||
|
|
// value: 1
|
||
|
|
// }
|
||
|
|
// ]
|
||
|
|
// }
|
||
|
|
|
||
|
|
export default {
|
||
|
|
async run(this: FlowNodeModel, prevJob, execution) {
|
||
|
|
const { calculation } = this.config || {};
|
||
|
|
|
||
|
|
const result = calculation
|
||
|
|
? calculate({
|
||
|
|
type: 'calculation',
|
||
|
|
options: execution.getParsedValue(calculation)
|
||
|
|
}, prevJob, execution)
|
||
|
|
: null;
|
||
|
|
|
||
|
|
return {
|
||
|
|
result,
|
||
|
|
status: JOB_STATUS.RESOLVED
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|