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 0000000000000000000000000000000000000000..301dff8634dc2bc0094053ebe000938c0a55e29f
--- /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 <http://www.gnu.org/licenses/>.
+ */
+
+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());
+                }
+            }
+        }
+    }
+}