>> targetColumns(@RequestParam("table") String table) {
+ if (!table.matches("^[A-Za-z0-9_]+$")) {
+ return Result.error("非法表名");
+ }
+ return Result.OK(metaMapper.listTargetColumns(table));
+ }
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncConfig.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncConfig.java
new file mode 100644
index 00000000..32957fa2
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncConfig.java
@@ -0,0 +1,126 @@
+package org.jeecg.modules.xslmes.mcs.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * MES上辅机 中间表采集配置（通用）
+ * 按 bizType 区分不同业务（密炼动作/报警/配方等），供秒级定时采集统一复用
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】密炼动作秒级采集
+ */
+@Data
+@TableName("mes_xsl_mcs_sync_config")
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = false)
+@Schema(description = "MES上辅机中间表采集配置")
+public class MesXslMcsSyncConfig implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ @TableId(type = IdType.ASSIGN_ID)
+ @Schema(description = "主键")
+ private String id;
+
+ @Schema(description = "业务类型(采集任务唯一标识，如 MIX_ACT 密炼动作；通用配置可为空)")
+ private String bizType;
+
+ @Schema(description = "配置名称")
+ private String configName;
+
+ @Schema(description = "业务名称")
+ private String bizName;
+
+ @Schema(description = "源中间表名")
+ private String sourceTable;
+
+ @Schema(description = "源中间表注释")
+ private String sourceTableComment;
+
+ @Schema(description = "MES目标表名")
+ private String targetTable;
+
+ @Schema(description = "MES目标表注释")
+ private String targetTableComment;
+
+ @Schema(description = "采集时间间隔(秒)，默认1秒")
+ private Integer intervalSeconds;
+
+ @Schema(description = "采集状态(0停止,1运行)")
+ private String status;
+
+ @Schema(description = "采集模式(FULL全量匹配,TIME时间匹配,INCR增量匹配-标记位回写)")
+ private String syncMode;
+
+ @Schema(description = "时间列/标记列(源表列名)。TIME模式=时间列；INCR模式=同步标记列(为空表示未采集,采集后回写'1')")
+ private String incrColumn;
+
+ @Schema(description = "时间范围(TODAY当天,LAST7最近七天)")
+ private String timeWindow;
+
+ @Schema(description = "每轮最大采集行数(INCR模式TOP N)")
+ private Integer batchLimit;
+
+ @Schema(description = "增量采集高水位(INCR模式自动维护)")
+ private String lastWatermark;
+
+ @Schema(description = "增量标记采集条件(IS_NULL为空,EQ_EMPTY等于匹配值,NE_EMPTY不等于匹配值)，INCR模式用")
+ private String flagCondition;
+
+ //update-begin---author:GHT ---date:20260617 for：【MES上辅机】增量采集条件等于/不等于支持自定义匹配值-----------
+ @Schema(description = "增量标记采集条件比较值(EQ_EMPTY/NE_EMPTY 用，留空表示空字符串)，INCR模式用")
+ private String flagMatchValue;
+ //update-end---author:GHT ---date:20260617 for：【MES上辅机】增量采集条件等于/不等于支持自定义匹配值-----------
+
+ @Schema(description = "增量标记采集完成后回写值(默认1)，INCR模式用")
+ private String flagWriteValue;
+
+ @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ @Schema(description = "最近一次采集时间")
+ private Date lastSyncTime;
+
+ @Schema(description = "最近一次采集结果")
+ private String lastSyncResult;
+
+ @Schema(description = "备注")
+ private String remark;
+
+ @Schema(description = "租户ID")
+ private Integer tenantId;
+
+ private String createBy;
+
+ @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private Date createTime;
+
+ private String updateBy;
+
+ @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private Date updateTime;
+
+ private Integer delFlag;
+
+ @TableField(exist = false)
+ @Schema(description = "字段映射明细（主子保存/详情用）")
+ private List fieldList;
+
+ @TableField(exist = false)
+ @Schema(description = "采集任务是否运行中（运行态由调度器实时给出）")
+ private Boolean running;
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncField.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncField.java
new file mode 100644
index 00000000..436c305a
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/entity/MesXslMcsSyncField.java
@@ -0,0 +1,75 @@
+package org.jeecg.modules.xslmes.mcs.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * MES上辅机 采集字段映射（中间库源字段 → MES目标字段）
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+@Data
+@TableName("mes_xsl_mcs_sync_field")
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = false)
+@Schema(description = "MES上辅机采集字段映射")
+public class MesXslMcsSyncField implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ @TableId(type = IdType.ASSIGN_ID)
+ @Schema(description = "主键")
+ private String id;
+
+ @Schema(description = "采集配置ID")
+ private String configId;
+
+ @Schema(description = "中间库源字段名")
+ private String sourceField;
+
+ @Schema(description = "源字段注释")
+ private String sourceFieldComment;
+
+ @Schema(description = "源字段类型")
+ private String sourceFieldType;
+
+ @Schema(description = "MES目标字段名(接收字段)")
+ private String targetField;
+
+ @Schema(description = "MES目标字段注释")
+ private String targetFieldComment;
+
+ @Schema(description = "是否匹配键(0否,1是)")
+ private String matchKey;
+
+ @Schema(description = "排序")
+ private Integer sortNo;
+
+ @Schema(description = "租户ID")
+ private Integer tenantId;
+
+ private String createBy;
+
+ @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private Date createTime;
+
+ private String updateBy;
+
+ @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ private Date updateTime;
+
+ private Integer delFlag;
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/McsMetaMapper.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/McsMetaMapper.java
new file mode 100644
index 00000000..3e3480b9
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/McsMetaMapper.java
@@ -0,0 +1,58 @@
+package org.jeecg.modules.xslmes.mcs.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 中间库(SQL Server) / MES(MySQL) 表与字段元数据查询。
+ * 源表元数据走 sqlserver_mcs 数据源，目标表元数据走默认 MES 库。
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+public interface McsMetaMapper {
+
+ /**
+ * 中间库表清单（含表注释 MS_Description）
+ */
+ @DS("sqlserver_mcs")
+ @Select("SELECT t.name AS tableName, CAST(ep.value AS NVARCHAR(200)) AS tableComment "
+ + "FROM sys.tables t "
+ + "LEFT JOIN sys.extended_properties ep ON ep.major_id = t.object_id AND ep.minor_id = 0 AND ep.name = 'MS_Description' "
+ + "ORDER BY t.name")
+ List> listSourceTables();
+
+ /**
+ * 中间库表字段清单（含字段注释、类型）
+ */
+ @DS("sqlserver_mcs")
+ @Select("SELECT c.name AS columnName, ty.name AS dataType, CAST(ep.value AS NVARCHAR(200)) AS columnComment "
+ + "FROM sys.columns c "
+ + "JOIN sys.types ty ON c.user_type_id = ty.user_type_id "
+ + "LEFT JOIN sys.extended_properties ep ON ep.major_id = c.object_id AND ep.minor_id = c.column_id AND ep.name = 'MS_Description' "
+ + "WHERE c.object_id = OBJECT_ID(#{table}) "
+ + "ORDER BY c.column_id")
+ List> listSourceColumns(@Param("table") String table);
+
+ /**
+ * MES 业务表清单（仅 mes_xsl_ 前缀）
+ */
+ @Select("SELECT table_name AS tableName, table_comment AS tableComment "
+ + "FROM information_schema.tables "
+ + "WHERE table_schema = (SELECT DATABASE()) AND table_name LIKE 'mes\\_xsl\\_%' "
+ + "ORDER BY table_name")
+ List> listTargetTables();
+
+ /**
+ * MES 表字段清单（含字段注释、类型）
+ */
+ @Select("SELECT column_name AS columnName, data_type AS dataType, column_comment AS columnComment "
+ + "FROM information_schema.columns "
+ + "WHERE table_schema = (SELECT DATABASE()) AND table_name = #{table} "
+ + "ORDER BY ordinal_position")
+ List> listTargetColumns(@Param("table") String table);
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncConfigMapper.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncConfigMapper.java
new file mode 100644
index 00000000..8367f8a6
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncConfigMapper.java
@@ -0,0 +1,13 @@
+package org.jeecg.modules.xslmes.mcs.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncConfig;
+
+/**
+ * MES上辅机 中间表采集配置 Mapper
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】密炼动作秒级采集
+ */
+public interface MesXslMcsSyncConfigMapper extends BaseMapper {
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncFieldMapper.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncFieldMapper.java
new file mode 100644
index 00000000..689b057b
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/mapper/MesXslMcsSyncFieldMapper.java
@@ -0,0 +1,13 @@
+package org.jeecg.modules.xslmes.mcs.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncField;
+
+/**
+ * MES上辅机 采集字段映射 Mapper
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+public interface MesXslMcsSyncFieldMapper extends BaseMapper {
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/IMesXslMcsSyncConfigService.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/IMesXslMcsSyncConfigService.java
new file mode 100644
index 00000000..5ebc2f0f
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/IMesXslMcsSyncConfigService.java
@@ -0,0 +1,40 @@
+package org.jeecg.modules.xslmes.mcs.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncConfig;
+
+/**
+ * MES上辅机 中间表采集配置 Service（配置驱动：表/字段绑定 + 采集操作）
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+public interface IMesXslMcsSyncConfigService extends IService {
+
+ /**
+ * 获取配置详情（含字段映射明细 fieldList）
+ */
+ MesXslMcsSyncConfig getDetail(String id);
+
+ /**
+ * 按业务类型获取最近配置（密炼动作页用，bizType=MIX_ACT）
+ */
+ MesXslMcsSyncConfig getByBizType(String bizType);
+
+ /**
+ * 保存配置（头 + 字段映射明细，主子整存）
+ */
+ Result saveConfig(MesXslMcsSyncConfig config);
+
+ /**
+ * 删除配置及其字段映射，并停止采集
+ */
+ Result deleteConfig(String id);
+
+ /**
+ * 采集操作：维护是否采集、采集间隔、采集模式（全量/时间/增量）及其参数。
+ * status='1' 启动并按间隔重排，'0' 停止。
+ */
+ Result saveCollect(MesXslMcsSyncConfig body);
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/impl/MesXslMcsSyncConfigServiceImpl.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/impl/MesXslMcsSyncConfigServiceImpl.java
new file mode 100644
index 00000000..cda7cbd1
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/service/impl/MesXslMcsSyncConfigServiceImpl.java
@@ -0,0 +1,223 @@
+package org.jeecg.modules.xslmes.mcs.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.shiro.SecurityUtils;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.system.vo.LoginUser;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncConfig;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncField;
+import org.jeecg.modules.xslmes.mcs.mapper.MesXslMcsSyncConfigMapper;
+import org.jeecg.modules.xslmes.mcs.mapper.MesXslMcsSyncFieldMapper;
+import org.jeecg.modules.xslmes.mcs.service.IMesXslMcsSyncConfigService;
+import org.jeecg.modules.xslmes.mcs.sync.McsSyncScheduler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * MES上辅机 中间表采集配置 Service 实现
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+@Slf4j
+@Service
+public class MesXslMcsSyncConfigServiceImpl extends ServiceImpl
+ implements IMesXslMcsSyncConfigService {
+
+ @Autowired
+ private MesXslMcsSyncFieldMapper syncFieldMapper;
+
+ @Autowired
+ private McsSyncScheduler syncScheduler;
+
+ @Override
+ public MesXslMcsSyncConfig getDetail(String id) {
+ MesXslMcsSyncConfig cfg = getById(id);
+ if (cfg == null) {
+ return null;
+ }
+ cfg.setFieldList(listFields(id));
+ return cfg;
+ }
+
+ @Override
+ public MesXslMcsSyncConfig getByBizType(String bizType) {
+ return getOne(new LambdaQueryWrapper()
+ .eq(MesXslMcsSyncConfig::getBizType, bizType)
+ .eq(MesXslMcsSyncConfig::getDelFlag, 0)
+ .orderByDesc(MesXslMcsSyncConfig::getUpdateTime)
+ .last("LIMIT 1"), false);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Result saveConfig(MesXslMcsSyncConfig config) {
+ if (config == null) {
+ return Result.error("配置不能为空");
+ }
+ if (StringUtils.isBlank(config.getSourceTable())) {
+ return Result.error("请选择中间库源表");
+ }
+ if (StringUtils.isBlank(config.getTargetTable())) {
+ return Result.error("请选择MES目标表");
+ }
+ List fields = config.getFieldList() != null ? config.getFieldList() : new ArrayList<>();
+ // 至少一个有效映射
+ boolean hasValid = fields.stream().anyMatch(f -> StringUtils.isNotBlank(f.getSourceField())
+ && StringUtils.isNotBlank(f.getTargetField()));
+ if (!hasValid) {
+ return Result.error("请至少配置一个字段映射（源字段+接收字段）");
+ }
+
+ String username = currentUsername();
+ Date now = new Date();
+ if (config.getIntervalSeconds() == null || config.getIntervalSeconds() < 1) {
+ config.setIntervalSeconds(1);
+ }
+ if (config.getTenantId() == null) {
+ config.setTenantId(0);
+ }
+ config.setDelFlag(0);
+ config.setUpdateBy(username);
+ config.setUpdateTime(now);
+
+ boolean isUpdate = StringUtils.isNotBlank(config.getId());
+ if (isUpdate) {
+ MesXslMcsSyncConfig old = getById(config.getId());
+ if (old == null) {
+ return Result.error("配置不存在");
+ }
+ // 状态由采集操作维护，保存配置不改变运行状态
+ config.setStatus(old.getStatus());
+ updateById(config);
+ } else {
+ if (StringUtils.isBlank(config.getStatus())) {
+ config.setStatus("0");
+ }
+ config.setCreateBy(username);
+ config.setCreateTime(now);
+ save(config);
+ }
+
+ // 整存字段映射：先物理删除旧映射再插入
+ syncFieldMapper.delete(new LambdaQueryWrapper()
+ .eq(MesXslMcsSyncField::getConfigId, config.getId()));
+ int sort = 0;
+ for (MesXslMcsSyncField f : fields) {
+ if (StringUtils.isBlank(f.getSourceField())) {
+ continue;
+ }
+ f.setId(null);
+ f.setConfigId(config.getId());
+ f.setSortNo(sort++);
+ f.setTenantId(config.getTenantId());
+ f.setDelFlag(0);
+ f.setCreateBy(username);
+ f.setCreateTime(now);
+ f.setUpdateBy(username);
+ f.setUpdateTime(now);
+ syncFieldMapper.insert(f);
+ }
+
+ // 运行中则按新配置重排（间隔/映射即时生效）
+ if ("1".equals(config.getStatus())) {
+ syncScheduler.scheduleTask(getById(config.getId()));
+ }
+ return Result.OK(isUpdate ? "保存成功" : "新增成功");
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Result deleteConfig(String id) {
+ MesXslMcsSyncConfig cfg = getById(id);
+ if (cfg == null) {
+ return Result.error("配置不存在");
+ }
+ syncScheduler.cancelTask(id);
+ syncFieldMapper.delete(new LambdaQueryWrapper()
+ .eq(MesXslMcsSyncField::getConfigId, id));
+ removeById(id);
+ return Result.OK("删除成功");
+ }
+
+ @Override
+ public Result saveCollect(MesXslMcsSyncConfig body) {
+ if (body == null || StringUtils.isBlank(body.getId())) {
+ return Result.error("缺少配置ID");
+ }
+ MesXslMcsSyncConfig cfg = getById(body.getId());
+ if (cfg == null) {
+ return Result.error("配置不存在");
+ }
+ if (body.getIntervalSeconds() != null) {
+ if (body.getIntervalSeconds() < 1) {
+ return Result.error("采集间隔不能小于1秒");
+ }
+ cfg.setIntervalSeconds(body.getIntervalSeconds());
+ }
+ // 采集模式及参数
+ String mode = StringUtils.isBlank(body.getSyncMode()) ? "FULL" : body.getSyncMode().trim().toUpperCase();
+ cfg.setSyncMode(mode);
+ cfg.setIncrColumn(StringUtils.trimToNull(body.getIncrColumn()));
+ cfg.setTimeWindow(StringUtils.isBlank(body.getTimeWindow()) ? "TODAY" : body.getTimeWindow());
+ if (body.getBatchLimit() != null && body.getBatchLimit() > 0) {
+ cfg.setBatchLimit(body.getBatchLimit());
+ }
+ // INCR(标记回写)：采集条件 + 回写值（可视化配置，回写值默认"1"）
+ cfg.setFlagCondition(StringUtils.isBlank(body.getFlagCondition()) ? "IS_NULL" : body.getFlagCondition().trim().toUpperCase());
+ //update-begin---author:GHT ---date:20260617 for：【MES上辅机】增量采集条件等于/不等于支持自定义匹配值-----------
+ cfg.setFlagMatchValue(body.getFlagMatchValue());
+ //update-end---author:GHT ---date:20260617 for：【MES上辅机】增量采集条件等于/不等于支持自定义匹配值-----------
+ cfg.setFlagWriteValue(StringUtils.isBlank(body.getFlagWriteValue()) ? "1" : body.getFlagWriteValue());
+ if (("TIME".equals(mode) || "INCR".equals(mode)) && StringUtils.isBlank(cfg.getIncrColumn())) {
+ return Result.error("时间匹配/增量匹配需选择" + ("TIME".equals(mode) ? "时间列" : "标记列"));
+ }
+
+ boolean on = "1".equals(body.getStatus());
+ cfg.setStatus(on ? "1" : "0");
+ cfg.setUpdateBy(currentUsername());
+ cfg.setUpdateTime(new Date());
+ updateById(cfg);
+ if (on) {
+ syncScheduler.scheduleTask(cfg);
+ return Result.OK("已启动采集（" + modeText(mode) + "），间隔 " + cfg.getIntervalSeconds() + " 秒");
+ }
+ syncScheduler.cancelTask(cfg.getId());
+ return Result.OK("已停止采集");
+ }
+
+ private String modeText(String mode) {
+ switch (mode) {
+ case "TIME":
+ return "时间匹配";
+ case "INCR":
+ return "增量匹配";
+ default:
+ return "全量匹配";
+ }
+ }
+
+ private List listFields(String configId) {
+ return syncFieldMapper.selectList(new LambdaQueryWrapper()
+ .eq(MesXslMcsSyncField::getConfigId, configId)
+ .eq(MesXslMcsSyncField::getDelFlag, 0)
+ .orderByAsc(MesXslMcsSyncField::getSortNo));
+ }
+
+ private String currentUsername() {
+ try {
+ LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+ return user != null ? user.getUsername() : "system";
+ } catch (Exception e) {
+ return "system";
+ }
+ }
+}
diff --git a/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/sync/GenericMcsSyncEngine.java b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/sync/GenericMcsSyncEngine.java
new file mode 100644
index 00000000..9460efb6
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module/jeecg-module-xslmes/src/main/java/org/jeecg/modules/xslmes/mcs/sync/GenericMcsSyncEngine.java
@@ -0,0 +1,524 @@
+package org.jeecg.modules.xslmes.mcs.sync;
+
+import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.jeecg.modules.xslmes.mcs.datasource.McsDataSourceManager;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncConfig;
+import org.jeecg.modules.xslmes.mcs.entity.MesXslMcsSyncField;
+import org.jeecg.modules.xslmes.mcs.mapper.McsMetaMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.sql.DataSource;
+import java.sql.Timestamp;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.TreeMap;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * 通用中间表采集引擎（配置驱动，纯字段拷贝）。
+ * 支持三种采集模式，应对中间库不同规模的表：
+ *
+ * - FULL 全量匹配：全表读源+全表读目标→按匹配键 Upsert，仅写新增/变化行。适合小状态表、以更新为主。
+ * - TIME 时间匹配：按时间列只取窗口内数据（当天/最近七天）→按匹配键 Upsert，目标侧按窗口匹配键定向读取。避免全表扫描。
+ * - INCR 增量匹配（标记位回写）：源表选一「同步标记列」，仅采集该列为空（NULL/''）的行（TOP N 限流），
+ * 按匹配键 Upsert 到 MES 后，回写源表该列为 {@code '1'}，下轮不再重复采集。适合带 GUID 主键、无可靠递增列的流水表。
+ *
+ *
+ * @author GHT
+ * @date 2026-06-17 for：【MES上辅机】采集配置-表与字段绑定
+ */
+@Slf4j
+@Component
+public class GenericMcsSyncEngine {
+
+ public static final String MODE_FULL = "FULL";
+ public static final String MODE_TIME = "TIME";
+ public static final String MODE_INCR = "INCR";
+
+ /** 合法标识符（表名/列名），防止 SQL 注入 */
+ private static final Pattern IDENT = Pattern.compile("^[A-Za-z0-9_]+$");
+
+ /** 批量写入分批大小 */
+ private static final int BATCH_SIZE = 500;
+ /** IN 查询分块大小 */
+ private static final int IN_CHUNK = 1000;
+ /** INCR 默认每轮行数 */
+ private static final int DEFAULT_BATCH_LIMIT = 2000;
+ /** INCR 标记位回写后的已同步标识值 */
+ private static final String FLAG_SYNCED = "1";
+
+ @Autowired
+ private DataSource dataSource;
+
+ @Autowired
+ private McsMetaMapper metaMapper;
+
+ @Autowired
+ private org.jeecg.modules.xslmes.mcs.datasource.McsDataSourceManager mcsDataSourceManager;
+
+ //update-begin---author:GHT ---date:20260617 for：【MES上辅机】采集模式 全量/时间/增量-----------
+ public String sync(MesXslMcsSyncConfig cfg, List fields) {
+ String sourceTable = trim(cfg.getSourceTable());
+ String targetTable = trim(cfg.getTargetTable());
+ if (StringUtils.isBlank(sourceTable) || StringUtils.isBlank(targetTable)) {
+ return "未配置源表或目标表，跳过";
+ }
+ validateIdent(sourceTable);
+ validateIdent(targetTable);
+
+ List maps = fields == null ? List.of() : fields.stream()
+ .filter(f -> StringUtils.isNotBlank(f.getSourceField()) && StringUtils.isNotBlank(f.getTargetField()))
+ .collect(Collectors.toList());
+ if (maps.isEmpty()) {
+ return "无有效字段映射，跳过";
+ }
+ for (MesXslMcsSyncField f : maps) {
+ validateIdent(f.getSourceField());
+ validateIdent(f.getTargetField());
+ }
+
+ String mode = StringUtils.isBlank(cfg.getSyncMode()) ? MODE_FULL : cfg.getSyncMode().trim().toUpperCase();
+ JdbcTemplate sourceJt = new JdbcTemplate(getSourceDataSource());
+ JdbcTemplate targetJt = new JdbcTemplate(dataSource);
+
+ // 目标表标准字段探测 + 自动填充列
+ Set targetCols = metaMapper.listTargetColumns(targetTable).stream()
+ .map(m -> String.valueOf(m.get("columnName")).toLowerCase())
+ .collect(Collectors.toSet());
+ boolean hasDel = targetCols.contains("del_flag");
+
+ List keyMaps = maps.stream().filter(f -> "1".equals(f.getMatchKey())).collect(Collectors.toList());
+ Set keyTargetsLower = keyMaps.stream().map(k -> k.getTargetField().toLowerCase()).collect(Collectors.toSet());
+ List nonKeyMaps = maps.stream()
+ .filter(f -> !keyTargetsLower.contains(f.getTargetField().toLowerCase()))
+ .collect(Collectors.toList());
+
+ int tenantId = cfg.getTenantId() != null ? cfg.getTenantId() : 0;
+ Timestamp now = new Timestamp(System.currentTimeMillis());
+
+ AutoCols auto = buildAutoCols(targetCols, maps, tenantId, now);
+
+ // 1. 按模式读源数据
+ LinkedHashSet srcCols = maps.stream().map(MesXslMcsSyncField::getSourceField)
+ .collect(Collectors.toCollection(LinkedHashSet::new));
+ List> rows;
+
+ //update-begin---author:GHT ---date:20260617 for：【MES上辅机】增量匹配改为标记位回写-----------
+ // INCR(标记回写)模式：仅采集「标记列」为空的行，采完回写"1"，下轮不再重复采集
+ String flagCol = null;
+ boolean flagMode = MODE_INCR.equals(mode);
+
+ if (flagMode) {
+ flagCol = requireIncrColumn(cfg);
+ if (keyMaps.isEmpty()) {
+ return "增量(标记)采集需在字段映射中勾选至少一个匹配键作为回写主键（如 GUID）";
+ }
+ if (!mcsDataSourceManager.isWriteEnabled()) {
+ return "增量(标记)采集需开启中间库写入开关以回写同步标记，请在「中间库连接配置」开启写入";
+ }
+ srcCols.add(flagCol);
+ int limit = cfg.getBatchLimit() != null && cfg.getBatchLimit() > 0 ? cfg.getBatchLimit() : DEFAULT_BATCH_LIMIT;
+ String predicate = flagPredicate(flagCol, cfg.getFlagCondition(), cfg.getFlagMatchValue());
+ String sql = "SELECT TOP " + limit + " " + colList(srcCols) + " FROM [" + sourceTable + "]"
+ + " WHERE (" + predicate + ")";
+ rows = sourceJt.queryForList(sql);
+ if (rows.isEmpty()) {
+ return "增量采集：无待采集数据";
+ }
+ } else if (MODE_TIME.equals(mode)) {
+ String incrCol = requireIncrColumn(cfg);
+ Timestamp[] window = timeWindow(cfg.getTimeWindow(), now);
+ StringBuilder sql = new StringBuilder("SELECT ").append(colList(srcCols))
+ .append(" FROM [").append(sourceTable).append("] WHERE [").append(incrCol).append("] >= ?");
+ List