|
@@ -57,15 +57,12 @@ class MissionService extends CrudService {
|
|
|
);
|
|
|
}
|
|
|
if (!mission.params) { throw new BusinessError(ErrorCode.DATA_INVALID, '任务信息缺少参数设置'); }
|
|
|
- const { project, service, method, body } = mission.params;
|
|
|
+ const { project, service, method, body, query } = mission.params;
|
|
|
assert(project, '任务信息中未找到需要执行的项目名称');
|
|
|
assert(service, '任务信息中未找到需要访问的服务');
|
|
|
assert(method, '任务信息中未找到要执行的方法');
|
|
|
try {
|
|
|
- this.toQueue(
|
|
|
- project,
|
|
|
- JSON.stringify({ ...body, missionid: id, project, service, method })
|
|
|
- );
|
|
|
+ this.toQueue(project, JSON.stringify({ ...body, missionid: id, project, service, method, query }));
|
|
|
} catch (error) {
|
|
|
console.error(error.toString());
|
|
|
await this.model.updateOne({ id }, { status: '3' });
|