From 08dec407c5cc8f223b5e876fefaeb1867df54537 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Mon, 24 Mar 2025 10:02:45 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E4=B8=80=E4=B8=AA=E8=B0=83=E7=94=A8=E9=9B=86=E6=88=90=E7=9A=84?= =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BD=9C=E4=B8=9A=E6=8F=92=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1383893813395456]增加一个调用集成的定时作业插件 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1383893813395456 --- .../framework/scheduler/IntegrationJob.java | 110 ++++++++++++++++++ 1 file changed, 110 insertions(+) create mode 100644 src/main/java/neatlogic/module/framework/scheduler/IntegrationJob.java diff --git a/src/main/java/neatlogic/module/framework/scheduler/IntegrationJob.java b/src/main/java/neatlogic/module/framework/scheduler/IntegrationJob.java new file mode 100644 index 000000000..301dff863 --- /dev/null +++ b/src/main/java/neatlogic/module/framework/scheduler/IntegrationJob.java @@ -0,0 +1,110 @@ +/* + * Copyright (C) 2025 深圳极向量科技有限公司 All Rights Reserved. + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see . + */ + +package neatlogic.module.framework.scheduler; + +import com.alibaba.fastjson.JSONObject; +import neatlogic.framework.exception.integration.IntegrationHandlerNotFoundException; +import neatlogic.framework.integration.core.IIntegrationHandler; +import neatlogic.framework.integration.core.IntegrationHandlerFactory; +import neatlogic.framework.integration.dao.mapper.IntegrationMapper; +import neatlogic.framework.integration.dto.IntegrationResultVo; +import neatlogic.framework.integration.dto.IntegrationVo; +import neatlogic.framework.matrix.exception.MatrixExternalAccessException; +import neatlogic.framework.scheduler.annotation.Param; +import neatlogic.framework.scheduler.annotation.Prop; +import neatlogic.framework.scheduler.core.PublicJobBase; +import neatlogic.framework.scheduler.dto.JobObject; +import neatlogic.module.framework.integration.handler.FrameworkRequestFrom; +import org.apache.commons.collections4.MapUtils; +import org.apache.commons.lang3.StringUtils; +import org.quartz.DisallowConcurrentExecution; +import org.quartz.JobExecutionContext; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +@Component +@DisallowConcurrentExecution +public class IntegrationJob extends PublicJobBase { + + static Logger logger = LoggerFactory.getLogger(IntegrationJob.class); + + @Resource + private IntegrationMapper integrationMapper; + + @Override + public String getName() { + return "定时调用集成作业"; + } + @Prop({ + @Param(name = "supplierIntegrationName", controlType = "text", dataType = "string", required = false, description = "获取数据集成名称", help = "每次执行作业时调用该集成", sort = 0), + @Param(name = "supplierIntegrationParam", controlType = "json", dataType = "json", required = false, description = "获取数据集成参数", help = "只支持json格式的参数，调用集成时传入该参数", sort = 1), + @Param(name = "consumerIntegrationName", controlType = "text", dataType = "string", required = false, description = "消费数据集成名称", help = "每次执行作业时调用该集成", sort = 2), + @Param(name = "consumerIntegrationParam", controlType = "json", dataType = "json", required = false, description = "消费数据集成参数", help = "只支持json格式的参数，调用集成时传入该参数，如果配置了获取数据集成，会把获取数据集成获取到的数据通过supplierData参数传递给消费数据集成", sort = 3) + }) + @Override + public void executeInternal(JobExecutionContext context, JobObject jobObject) throws Exception { + JSONObject supplierData = null; + Object supplierIntegrationName = jobObject.getProp("supplierIntegrationName"); + if (supplierIntegrationName != null) { + IntegrationVo supplierIntegrationVo = integrationMapper.getIntegrationByName(supplierIntegrationName.toString()); + if (supplierIntegrationVo != null) { + IIntegrationHandler handler = IntegrationHandlerFactory.getHandler(supplierIntegrationVo.getHandler()); + if (handler == null) { + throw new IntegrationHandlerNotFoundException(supplierIntegrationVo.getHandler()); + } + Object supplierIntegrationParam = jobObject.getProp("supplierIntegrationParam"); + if (supplierIntegrationParam != null) { + supplierIntegrationVo.getParamObj().putAll(JSONObject.parseObject(supplierIntegrationParam.toString())); + } + IntegrationResultVo resultVo = handler.sendRequest(supplierIntegrationVo, FrameworkRequestFrom.SCHEDULE); + if (StringUtils.isNotBlank(resultVo.getError())) { + logger.error(resultVo.getError()); + throw new MatrixExternalAccessException(supplierIntegrationVo.getName()); + } + handler.validate(resultVo); + supplierData = JSONObject.parseObject(resultVo.getTransformedResult()); + } + } + + Object consumerIntegrationName = jobObject.getProp("consumerIntegrationName"); + if (consumerIntegrationName != null) { + IntegrationVo consumerIntegrationVo = integrationMapper.getIntegrationByName(consumerIntegrationName.toString()); + if (consumerIntegrationVo != null) { + IIntegrationHandler handler = IntegrationHandlerFactory.getHandler(consumerIntegrationVo.getHandler()); + if (handler == null) { + throw new IntegrationHandlerNotFoundException(consumerIntegrationVo.getHandler()); + } + Object consumerIntegrationParam = jobObject.getProp("consumerIntegrationParam"); + if (consumerIntegrationParam != null) { + consumerIntegrationVo.getParamObj().putAll(JSONObject.parseObject(consumerIntegrationParam.toString())); + } + if (MapUtils.isNotEmpty(supplierData)) { + consumerIntegrationVo.getParamObj().put("supplierData", supplierData); + } + IntegrationResultVo resultVo = handler.sendRequest(consumerIntegrationVo, FrameworkRequestFrom.SCHEDULE); + if (StringUtils.isNotBlank(resultVo.getError())) { + logger.error(resultVo.getError()); + throw new MatrixExternalAccessException(consumerIntegrationVo.getName()); + } + } + } + } +} -- Gitee