处理设备单表名特殊字符

Lius

2025-01-09 d69da9b903c107251f77450aac986d2477a5f4c5

 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/TransferTableDataJob.java

@@ -27,6 +27,15 @@
@Slf4j
public class TransferTableDataJob implements Job {

    /**
     * 若参数变量名修改 QuartzJobController中也需对应修改  迁移时间  例： 30
     */
    private String parameter;

    public void setParameter(String parameter) {
        this.parameter = parameter;
    }

    @Resource
    private ISysQuartzLogService sysQuartzLogService;

@@ -48,6 +57,7 @@
        if (byJobClassName != null && !byJobClassName.isEmpty()) {
            quartzLog.setJobId(byJobClassName.get(0).getId());
        }
        quartzLog.setParams(this.parameter);
        log.info("数据迁移任务 TransferTableDataJob start!  时间:" + DateUtils.getNow());
        long startTime = System.currentTimeMillis();
        try {
@@ -55,18 +65,23 @@
            Equipment info = new Equipment();
            info.setSavetablename("EquipmentLog");
            list.add(info);
            String day = DateUtils.format(DateUtils.plusTime(DateUtils.getNow(), -30), DateUtils.STR_DATE_TIME_SMALL);
            int dayNum = 30;
            if (StringUtils.isNotBlank(this.parameter)) {
                try {
                    dayNum = Integer.parseInt(this.parameter);
                } catch (Exception e) {
                    log.error("参数格式不对", e);
                }
            }
            String day = DateUtils.format(DateUtils.plusTime(DateUtils.getNow(), -dayNum), DateUtils.STR_DATE_TIME_SMALL);
            for (Equipment equipment : list) {
                if (StringUtils.isNotBlank(equipment.getSavetablename())) {
                    String tableName = equipmentService.checkTableExists(equipment.getSavetablename());
                    if (StringUtils.isNotBlank(tableName)) {
                        String backupTableName = equipmentService.checkTableExists(equipment.getSavetablename() + "_backup");
                        if (StringUtils.isNotBlank(backupTableName)) {
                            Integer num = equipmentService.checkTableDataNum(equipment.getSavetablename(), day);
                            if (num > 0) {
                                equipmentService.insertTableData(backupTableName, tableName, day);
                                equipmentService.deleteTableData(tableName, day);
                            }
                            equipmentService.insertTableData(backupTableName, tableName, day);
                            equipmentService.deleteTableData(tableName, day);
                        } else {
                            //备份表不存在创建备份表并迁移数据
                            equipmentService.insertNoTableData(tableName + "_backup", tableName, day);