中-107-PwrdevHistorydataGwMapper.xml;5行

lxw

2023-10-31 dbd762182a6fd0324c0aec5b3725f610a0032f82

中-107-PwrdevHistorydataGwMapper.xml;5行

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

@@ -8,7 +8,7 @@

public interface PwrdevHistorydataGwMapper extends CustomMapper<PwrdevHistorydataGw> {
    //判断表是否存在
    int judgeTable(@Param("table") String table);
    //int judgeTable(@Param("table") String table);

    //List<Integer> searchMaxNum2(Date startTime, Date stopTime, @Param("table") String table);


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

@@ -50,7 +50,8 @@
                String table = devId + "_" + ThreadLocalUtil.format(startTime,2);
                //System.err.println("finalII:" + finalII + ",table:" + table);
                //判断表是否存在
                int tableNum = mapper.judgeTable(table);
                //int tableNum = mapper.judgeTable(table);
                int tableNum = subService.judgeTable_pwr(table);
                List<PwrdevHistorydataGw> list = new ArrayList();
                if (tableNum > 0) {
                    //List<Integer> calcNumList = mapper.searchMaxNum2(startTime, stopTime, table);

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

@@ -627,8 +627,10 @@
        //List list=subService.serchCurrent(1000059);
        //List list=subService.getResInfoByBattGroupId(1000059);
        subService.deleteByTestRecordCount(1000059,1);*/
        /*93*/
        subService.truncate("db_batt_testdata","tb_battresdata_1000003");
        return  new Response().setII(1,true,0,null);
        /*93
        subService.truncate("db_batt_testdata","tb_battresdata_1000003");*/
        /*107*/
        int tableNum=subService.judgeTable_pwr("110000001_2023_04");
        return  new Response().setII(1,true,tableNum,null);
    }
}

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

@@ -1961,7 +1961,7 @@
        }
        sqlExecuteService.execute(sql);
    }
    //
    //100-StandardFeatureCurveMapper.xml;12行
    public void createTable(String titleNameUnion){
        String sql="CREATE TABLE `web_site`.`tb_standard_feature_curve_"+titleNameUnion+"` ( " +
                "        `id` INT NOT NULL AUTO_INCREMENT, " +
@@ -2247,7 +2247,7 @@
        return  list;
    }

    //
    //97-Ld9testdatastopMapper.xml;11行
    public List<Ld9testdatastop> serchByCondition(int testRecordCount, int battGroupId){
        String sql=" select num,BattGroupId,test_record_count,test_type,test_starttime,record_time,test_timelong,group_vol,test_curr,test_cap,mon_cap,mon_rest_cap,mon_num,mon_vol,test_monnum,max_monvol,min_monvol,test_stopreason " +
                "        from db_ld9_testdata.tb_ld9testdatastop_"+battGroupId+" " +
@@ -2435,7 +2435,7 @@
        }
        return maxNum;
    }
    //
    //105-BattRealdataMapper.xml;36行
    public  int searchMinNum(BattRealdata realdata){
        String sql="select min(num) as minNum " +
                "        from db_batt_history.tb_batt_realdata_"+realdata.getTableName()+" " +
@@ -3135,7 +3135,7 @@
        });
        return list;
    }
    //
    //96-BattResDataMapper.xml;18行
    public List<BattResData> getResInfoByBattGroupId( int battGroupId){
        String sql="select * from db_batt_testdata.tb_battresdata_"+battGroupId+" order by test_starttime desc";
        List<BattResData> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
@@ -3167,7 +3167,7 @@
        return list;
    }

    //
    //108-BattResDataMapper.xml;4行
    public void deleteByTestRecordCount(Integer battGroupId, Integer testRecordCount){
        String sql="delete from db_batt_testdata.tb_battresdata_"+battGroupId+" where test_record_count = "+testRecordCount+"";
        sqlExecuteService.execute(sql);
@@ -3179,4 +3179,30 @@
        sqlExecuteService.execute(sql);
    }

    //107-PwrdevHistorydataGwMapper.xml;5行
    public int judgeTable_pwr(String table){
        String sql=" select count(*) as tableNum " +
                "        from INFORMATION_SCHEMA.TABLES " +
                "        where TABLE_SCHEMA = 'db_pwrdev_data_history_gw' " +
                "          and TABLE_NAME = 'tb_pwrdev_historydata_gw_"+table+"';";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                LinkedList<Object> temp = new LinkedList<>();
                try {
                    while (rs.next())
                        temp.add(rs.getInt("tableNum"));
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                return temp;
            }
        });
        int tableNum =0;
        if(list!=null){
            tableNum= (int) list.get(0);
        }
        return tableNum;
    }

}

 src/main/resources/mapper/PwrdevHistorydataGwMapper.xml

@@ -2,12 +2,12 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.PwrdevHistorydataGwMapper">

    <select id="judgeTable" resultType="java.lang.Integer">
    <!--<select id="judgeTable" resultType="java.lang.Integer">
        select count(*) as tableNum
        from INFORMATION_SCHEMA.TABLES
        where TABLE_SCHEMA = 'db_pwrdev_data_history_gw'
          and TABLE_NAME = 'tb_pwrdev_historydata_gw_${table}';
    </select>
    </select>-->
    <!--<select id="searchMaxNum2" resultType="java.lang.Integer">
        (SELECT num
         FROM db_pwrdev_data_history_gw.tb_pwrdev_historydata_gw_${table}