完成清除/删除操作

whycxzp

2021-07-09 489cc658a7f1a166058138bd4c57b6ce3e64ca72

完成清除/删除操作

 pom.xml

@@ -50,12 +50,6 @@
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--shiro-->
        <dependency>
            <groupId>org.apache.shiro</groupId>
            <artifactId>shiro-spring-boot-web-starter</artifactId>
            <version>1.5.3</version>
        </dependency>
        <!--<dependency>-->
        <!--    <groupId>org.springframework.boot</groupId>-->
        <!--    <artifactId>spring-boot-starter-thymeleaf</artifactId>-->

 src/main/java/com/whyc/Application.java

@@ -15,6 +15,8 @@
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
import org.springframework.web.servlet.view.InternalResourceViewResolver;

import static java.lang.Thread.sleep;

/**
 * @Description : 启动类
 * @date 2020/10/15
@@ -30,6 +32,16 @@
        ApplicationContext applicationContext = SpringUtil.getApplicationContext();
        ClearTableService service = (ClearTableService) applicationContext.getBean("clearTableService");
        service.clearTable();
        service.dropTable();
        int sleepSeconds = 5;
        System.out.println("清除/删除操作完成,"+sleepSeconds+"秒后自动退出程序...");
        try {
            sleep(sleepSeconds*1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("程序终止");
        System.exit(1);
    }

}

 src/main/java/com/whyc/anotation/Realm.java

File was deleted

 src/main/java/com/whyc/config/ShiroConfig.java

File was deleted

 src/main/java/com/whyc/dto/TableDTO.java

New file
@@ -0,0 +1,28 @@
package com.whyc.dto;

public class TableDTO {

    private String dbName;
    private String tableName;

    public TableDTO(String dbName, String tableName) {
        this.dbName = dbName;
        this.tableName = tableName;
    }

    public String getDbName() {
        return dbName;
    }

    public void setDbName(String dbName) {
        this.dbName = dbName;
    }

    public String getTableName() {
        return tableName;
    }

    public void setTableName(String tableName) {
        this.tableName = tableName;
    }
}

 src/main/java/com/whyc/filter/CrossDomainFilter.java

File was deleted

 src/main/java/com/whyc/filter/KickedOutFilter.java

File was deleted

 src/main/java/com/whyc/filter/LoginFilter.java

File was deleted

 src/main/java/com/whyc/filter/RolesOrAuthorizationFilter.java

File was deleted

 src/main/java/com/whyc/mapper/ClearTableMapper.java

@@ -1,12 +1,14 @@
package com.whyc.mapper;

import com.whyc.pojo.User_inf;
import org.apache.ibatis.annotations.Select;
import com.whyc.dto.TableDTO;

import java.util.List;

public interface ClearTableMapper{

    @Select("select * from db_user.tb_user_inf limit 1")
    List<User_inf> clearTable();
    void clearTable(List<TableDTO> tableList);

    void dropTable(List<TableDTO> tableList);

    List<TableDTO> findTableListLike(List<TableDTO> tableList);
}

 src/main/java/com/whyc/mapper/PermissionMapper.java

File was deleted

 src/main/java/com/whyc/mapper/RoleMapper.java

File was deleted

 src/main/java/com/whyc/mapper/RoleMenuMapper.java

File was deleted

 src/main/java/com/whyc/mapper/RolePermissionMapper.java

File was deleted

 src/main/java/com/whyc/mapper/UserMapper.java

File was deleted

 src/main/java/com/whyc/mapper/UserRoleMapper.java

File was deleted

 src/main/java/com/whyc/pojo/Menu.java

File was deleted

 src/main/java/com/whyc/pojo/Permission.java

File was deleted

 src/main/java/com/whyc/pojo/Role.java

File was deleted

 src/main/java/com/whyc/pojo/RoleMenu.java

File was deleted

 src/main/java/com/whyc/pojo/RolePermission.java

File was deleted

 src/main/java/com/whyc/pojo/User.java

File was deleted

 src/main/java/com/whyc/pojo/UserRole.java

File was deleted

 src/main/java/com/whyc/pojo/User_inf.java

File was deleted

 src/main/java/com/whyc/properties/PropertiesUtil.java

File was deleted

 src/main/java/com/whyc/realm/CustomRealm.java

File was deleted

 src/main/java/com/whyc/service/ClearTableService.java

@@ -1,10 +1,11 @@
package com.whyc.service;

import com.whyc.dto.TableDTO;
import com.whyc.mapper.ClearTableMapper;
import com.whyc.pojo.User_inf;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.LinkedList;
import java.util.List;

@Service
@@ -14,9 +15,139 @@
    private ClearTableMapper mapper;

    public void clearTable(){
        List<User_inf> userInfList = mapper.clearTable();
        System.out.println(userInfList);
        System.out.println("清除表完成");
        List<TableDTO> tableList = new LinkedList<>();
        //传入需要清空的表对应的库名,表名
        tableList.add(new TableDTO("db_alarm","tb_battalarm_data"));
        tableList.add(new TableDTO("db_alarm","tb_battalarm_data_history"));
        tableList.add(new TableDTO("db_alarm","tb_bts_station_event"));
        tableList.add(new TableDTO("db_alarm","tb_devalarm_data"));
        tableList.add(new TableDTO("db_alarm","tb_devalarm_data_history"));
        tableList.add(new TableDTO("db_app_sys","tb_app_bts_battgroup"));
        tableList.add(new TableDTO("db_app_sys","tb_app_bts_comm_task"));
        tableList.add(new TableDTO("db_app_sys","tb_dashboard_chart_type"));
        tableList.add(new TableDTO("db_app_sys","tb_dashboard_module"));
        tableList.add(new TableDTO("db_app_sys","tb_dashboard_module_chart"));
        tableList.add(new TableDTO("db_app_sys","tb_fbsdev_statechange_inf"));
        tableList.add(new TableDTO("db_batt_history","tb_btsstaechange_inf"));
        tableList.add(new TableDTO("db_batt_testdata","tb_battresdata_inf"));
        tableList.add(new TableDTO("db_batt_testdata","tb_batttestdata_inf"));
        tableList.add(new TableDTO("db_battinf","tb_batt_alm_param"));
        tableList.add(new TableDTO("db_battinf","tb_batt_maint_inf"));
        tableList.add(new TableDTO("db_battinf","tb_batt_maint_process"));
        tableList.add(new TableDTO("db_battinf","tb_battcurr_inf"));
        tableList.add(new TableDTO("db_battinf","tb_battinf"));
        tableList.add(new TableDTO("db_battinf","tb_battinf_apply"));
        tableList.add(new TableDTO("db_battinf","tb_battinf_ex"));
        tableList.add(new TableDTO("db_battinf","tb_battinf_rebuild"));
        tableList.add(new TableDTO("db_battinf","tb_battmon_testcap"));
        tableList.add(new TableDTO("db_battinf","tb_deverror_record"));
        tableList.add(new TableDTO("db_ld9_testdata","tb_ld9testdata_inf"));
        tableList.add(new TableDTO("db_param","tb_alarm_param"));
        tableList.add(new TableDTO("db_param","tb_dev_param"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_alarm"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_alarm_history"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_alarm_param"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_time_adj_alarm"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_time_out_alarm"));
        tableList.add(new TableDTO("db_pwrdev_data_history","tb_pwrdev_acdata"));
        tableList.add(new TableDTO("db_pwrdev_data_rt","tb_pwrdev_acdcdata"));
        tableList.add(new TableDTO("db_pwrdev_data_rt","tb_pwrdev_dcdata"));
        tableList.add(new TableDTO("db_pwrdev_inf","tb_pwrdev_inf"));
        tableList.add(new TableDTO("db_ram_db","cmcc_power_data"));
        tableList.add(new TableDTO("db_ram_db","tb_61850_jhstate"));
        tableList.add(new TableDTO("db_ram_db","tb_batt_rsalarm"));
        tableList.add(new TableDTO("db_ram_db","tb_batt_rtalarm"));
        tableList.add(new TableDTO("db_ram_db","tb_batt_rtdata"));
        tableList.add(new TableDTO("db_ram_db","tb_batt_rtstate"));
        tableList.add(new TableDTO("db_ram_db","tb_bpm7100_state"));
        tableList.add(new TableDTO("db_ram_db","tb_bts_gprs_state"));
        tableList.add(new TableDTO("db_ram_db","tb_bts_station_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_battparam"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_chargerstate"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_collectionstate"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_insulatstate"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_offlineyhplan"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_offlineyhplan"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100_sysparam"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100s_dcdc_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100s_dfu_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100s_fod_param"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100s_fod_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9100s_nibian_state"));
        tableList.add(new TableDTO("db_ram_db","tb_fbs9600_state"));
        tableList.add(new TableDTO("db_ram_db","tb_hard_dev_sms_state"));
        tableList.add(new TableDTO("db_ram_db","tb_ld9_concentrateparam"));
        tableList.add(new TableDTO("db_ram_db","tb_ld9_concentratestate"));
        tableList.add(new TableDTO("db_ram_db","tb_ld9_setparam"));
        tableList.add(new TableDTO("db_ram_db","tb_ld9_state"));
        tableList.add(new TableDTO("db_ram_db","tb_ld9_updatestatue"));
        tableList.add(new TableDTO("db_ram_db","tb_lithium_data"));
        tableList.add(new TableDTO("db_ram_db","tb_socketclient_state"));
        tableList.add(new TableDTO("db_user","tb_user_battgroup_baojigroup_battgroup"));
        tableList.add(new TableDTO("db_user","tb_user_battmaint_check"));
        tableList.add(new TableDTO("db_user","tb_user_battmaint_check_process"));
        tableList.add(new TableDTO("db_user","tb_user_face"));
        tableList.add(new TableDTO("db_user","tb_user_jiejiari"));
        tableList.add(new TableDTO("db_user","tb_user_limit"));
        tableList.add(new TableDTO("db_user","tb_user_log"));
        tableList.add(new TableDTO("db_user","tb_user_paixiu"));
        tableList.add(new TableDTO("db_user","tb_user_sms"));
        tableList.add(new TableDTO("db_user","tb_user_sms_format"));
        tableList.add(new TableDTO("db_user","tb_user_task"));
        tableList.add(new TableDTO("db_user","tb_user_task_batt_check"));
        tableList.add(new TableDTO("db_user","tb_user_task_batt_template"));
        tableList.add(new TableDTO("db_user","tb_user_task_batt_test"));
        tableList.add(new TableDTO("db_user","tb_user_task_change"));
        tableList.add(new TableDTO("db_user","tb_user_task_param"));
        tableList.add(new TableDTO("db_user","tb_user_task_template"));
        tableList.add(new TableDTO("db_user","tb_user_task_user_list"));
        tableList.add(new TableDTO("web_site","mac_license"));
        tableList.add(new TableDTO("web_site","tb_3d_station"));
        tableList.add(new TableDTO("web_site","tb_announce"));
        tableList.add(new TableDTO("web_site","tb_avoid_plan"));
        tableList.add(new TableDTO("web_site","tb_badbatt_mon"));
        tableList.add(new TableDTO("web_site","tb_badbatt_mon_flag"));
        tableList.add(new TableDTO("web_site","tb_batt_attention"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_cm"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_cm1"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_ct"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_ct1"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_cu"));
        tableList.add(new TableDTO("web_site","tb_batt_devdischarge_cu1"));
        tableList.add(new TableDTO("web_site","tb_batt_discharge"));
        tableList.add(new TableDTO("web_site","tb_batt_electricity"));
        tableList.add(new TableDTO("web_site","tb_batt_electricity1"));
        tableList.add(new TableDTO("web_site","tb_batt_electricity2"));
        tableList.add(new TableDTO("web_site","tb_batt_endurance"));
        tableList.add(new TableDTO("web_site","tb_batt_replace"));
        tableList.add(new TableDTO("web_site","tb_battdischarge_plan"));
        tableList.add(new TableDTO("web_site","tb_battinf_change"));
        tableList.add(new TableDTO("web_site","tb_battmap_information"));
        tableList.add(new TableDTO("web_site","tb_battpower_off"));
        tableList.add(new TableDTO("web_site","tb_dev_restart_plan"));
        tableList.add(new TableDTO("web_site","tb_devstate_usr"));
        tableList.add(new TableDTO("web_site","tb_devtmp_record"));
        tableList.add(new TableDTO("web_site","tb_stationtraffic"));

        mapper.clearTable(tableList);
    }

    public void dropTable(){
        List<TableDTO> tableList = new LinkedList<>();
        tableList.add(new TableDTO("db_batt_history","tb_batt_realdata_"));
        tableList.add(new TableDTO("db_pwrdev_alarm","tb_pwrdev_alarm_param_"));
        tableList.add(new TableDTO("db_pwrdev_data_history","tb_pwrdev_historydata_"));
        //查询库中需要删除的表名
        List<TableDTO> resTableList = findTableListLike(tableList);
        //传入需要删除的表对应的库名,表名
        if(!resTableList.isEmpty()){
            mapper.dropTable(resTableList);
        }
    }

    private List<TableDTO> findTableListLike(List<TableDTO> tableList) {
        return mapper.findTableListLike(tableList);
    }

}

 src/main/java/com/whyc/service/LoginService.java

File was deleted

 src/main/java/com/whyc/service/PermissionService.java

File was deleted

 src/main/java/com/whyc/service/RoleMenuService.java

File was deleted

 src/main/java/com/whyc/service/RolePermissionService.java

File was deleted

 src/main/java/com/whyc/service/RoleService.java

File was deleted

 src/main/java/com/whyc/service/UserBridgeService.java

File was deleted

 src/main/java/com/whyc/service/UserRoleService.java

File was deleted

 src/main/java/com/whyc/service/UserService.java

File was deleted

 src/main/java/com/whyc/util/CommonUtil.java

File was deleted

 src/main/java/com/whyc/util/DigestsUtil.java

File was deleted

 src/main/java/com/whyc/util/EncodesUtil.java

File was deleted

 src/main/java/com/whyc/util/ShiroUtil.java

File was deleted

 src/main/resources/config/application.yml

@@ -10,7 +10,7 @@
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3360/db_3.5mw_web?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
#    url: jdbc:mysql://192.168.10.221:3360/db_3.5mw_web?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
#    url: jdbc:mysql://192.168.10.71:3360/db_user?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
#    url: jdbc:mysql://192.168.10.221:3360?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
#    url: jdbc:mysql://192.168.10.222:3360/db_user?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
#    url: jdbc:mysql://118.89.139.230:3360/db_user?characterEncoding=utf8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
@@ -46,18 +46,6 @@
  reasonable: true
  support-methods-arguments: true
  params: count=countSql
#swagger是否激活,swagger的UI界面地址为 localhost:8080/swagger-ui.html
#swagger:
#  enabled: true
#  ui-config:
#    operations-sorter: method
#  title: 武汉源畅-3.5WM电机系统
#  authorization:
#    type: None
#    auth-regex: none
#  base-package: com.whyc.controller
knife:
  enable: true
#  enable: fase




 src/main/resources/config/authentication.properties

File was deleted

 src/main/resources/mapper/ClearTableMapper.xml

@@ -3,4 +3,21 @@
<mapper namespace="com.whyc.mapper.ClearTableMapper" >


    <update id="clearTable">
        <foreach collection="list" item="item" separator=";">
            truncate ${item.dbName}.${item.tableName}
        </foreach>
    </update>

    <select id="findTableListLike" resultType="com.whyc.dto.TableDTO">
        <foreach collection="list" item="item" separator=" union ">
            select TABLE_SCHEMA as dbName,TABLE_NAME as tableName from information_schema.TABLES t where t.TABLE_SCHEMA =#{item.dbName} and t.TABLE_NAME like concat('%',#{item.tableName},'%')
        </foreach>
    </select>

    <update id="dropTable">
        <foreach collection="list" item="item" separator=";">
            drop table if exists ${item.dbName}.${item.tableName}
        </foreach>
    </update>
</mapper>

 src/main/resources/mapper/RoleMenuMapper.xml

File was deleted

 src/main/resources/mapper/RolePermissionMapper.xml

File was deleted

 src/main/resources/mapper/UserMapper.xml

File was deleted

 src/main/resources/mapper/UserRoleMapper.xml

File was deleted