From d69da9b903c107251f77450aac986d2477a5f4c5 Mon Sep 17 00:00:00 2001 From: Lius <Lius2225@163.com> Date: 星期四, 09 一月 2025 09:52:28 +0800 Subject: [PATCH] 处理设备单表名特殊字符 --- lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/EquipmentMapper.java | 29 +++++++++++++++++++++++++++-- 1 files changed, 27 insertions(+), 2 deletions(-) diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/EquipmentMapper.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/EquipmentMapper.java index 18e4ae8..2268dc4 100644 --- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/EquipmentMapper.java +++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/mapper/EquipmentMapper.java @@ -1,8 +1,15 @@ package org.jeecg.modules.mdc.mapper; -import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Delete; +import org.apache.ibatis.annotations.Insert; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; import org.jeecg.modules.mdc.entity.Equipment; +import org.jeecg.modules.mdc.vo.WsEquipmentStatus; +import org.jeecg.modules.mdc.vo.WsEquipmentUtilizationRate; + +import java.util.List; /** * @Description: 閲囬泦璁惧琛� @@ -10,7 +17,25 @@ * @Date: 2023-03-23 * @Version: V1.0 */ -@DS("multi-datasource1") + public interface EquipmentMapper extends BaseMapper<Equipment> { + @Select(" SELECT name FROM SysObjects Where XType='U' AND name = '${saveTableName}' ") + String checkTableExists(@Param("saveTableName") String saveTableName); + + @Select(" SELECT COUNT(CollectTime) num FROM [${saveTableName}] WHERE CollectTime < '${day}' ") + Integer checkTableDataNum(@Param("saveTableName") String saveTableName, @Param("day") String day); + + @Insert(" INSERT INTO [${tableName}] SELECT * FROM [${lastTableName}] WHERE CollectTime < '${date}' ") + void insertTableData(@Param("tableName") String tableName, @Param("lastTableName") String lastTableName, @Param("date") String date); + + @Delete(" delete from [${tableName}] where CollectTime < '${day}' ") + void deleteTableData(@Param("tableName") String saveTableName, @Param("day") String day); + + @Insert(" SELECT * INTO [${tableName}] FROM [${lastTableName}] WHERE CollectTime < '${date}' ") + void insertNoTableData(@Param("tableName") String tableName, @Param("lastTableName") String lastTableName, @Param("date") String date); + + List<WsEquipmentStatus> selectEquipmentStatus(); + + List<WsEquipmentUtilizationRate> selectEquipmentRate(@Param("date") String date); } -- Gitblit v1.9.3