//根据查询udp包的所有历史记录表

whyclxw

2021-05-21 43fc1a20cb24d587ff32182a7fa978205324556c

//根据查询udp包的所有历史记录表

 DyEnvir_system/src/com/partinsystem/udpall/action/Partin_elemonitorAction.java

@@ -26,7 +26,12 @@
        result=tojson(model);
        return SUCCESS;
    }

  //根据查询udp包的所有历史记录表
    public String serchRecord() {
        ServiceModel model=service.serchRecord();
        result=tojson(model);
        return SUCCESS;
    }
    public String getResult() {
        return result;
    }

 DyEnvir_system/src/com/partinsystem/udpall/impl/Partin_elemonitorImpl.java

@@ -15,6 +15,7 @@
import com.fgkj.db.DBUtil;
import com.fgkj.partinsystem.dto.Ac230v_ups;
import com.fgkj.partinsystem.dto.Dcinsulation;
import com.fgkj.partinsystem.dto.Partinsystem_inf;
import com.partinsystem.udpall.dto.Ac230_elec;
import com.partinsystem.udpall.dto.Acmain_board;
import com.partinsystem.udpall.dto.Acreliable_board;
@@ -330,17 +331,67 @@
        });
        return list;
    }
	
    //根据查询udp包的所有历史记录表
    public List serchRecord() {
        String sql=" select table_name,table_rows from information_schema.tables "
                + " where table_schema='db_partinsystem_history'   and table_name like 'tb_partin_elemonitor_%'  "
                + " order by table_name asc ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List<String> list = new ArrayList<String>(){{
                    this.add("0");this.add("0");
                }};
                //List list=new ArrayList();
                try {
                    while(rs.next()){
                        if(rs.getRow()==1){
                            list.set(0,changeDateFrom(rs.getString("table_name")));
                            list.set(1,changeDateFrom(rs.getString("table_name")));
                        }
                        //if(Integer.parseInt(rs.getString("table_rows"))!=0){
                            list.set(1,changeDateFrom(rs.getString("table_name")));
                        //}
                    }
                    /*rs.first();
                    list.add(Devdata_historyImpl.changeDateFrom(rs.getString("table_name")));
                    rs.last();
                    list.add(Devdata_historyImpl.changeDateFrom(rs.getString("table_name")));*/
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        List l=new ArrayList();
        for (int i = 0; i < list.size(); i++) {
            l.add(list.get(i));
        }
        return l;
    }
     //历史数据表名取时间转"_"到"-"
    private static String changeDateFrom(String dateString){
        String markString="tb_partin_elemonitor_";
        dateString=dateString.substring(markString.length());
        dateString=dateString.replace("_", "-");
        //System.out.println(dateString);
        return dateString;
    }
    public static void main(String[] args) {
        Partin_elemonitorImpl pimpl=new Partin_elemonitorImpl();
        /*List<Partin_elemonitor> list=pimpl.searchAll();
        for (Partin_elemonitor p : list) {
            System.out.println(p);
        }*/
        Date date=new Date();
        /*Date date=new Date();
        List<Partin_elemonitor> list=pimpl.serchByCondition(date);
        for (Partin_elemonitor p : list) {
            System.out.println(p);
        }
        }*/
        changeDateFrom("tb_partin_elemonitor_2021_05_20");
    }

}

 DyEnvir_system/src/com/partinsystem/udpall/service/Partin_elemonitorService.java

@@ -5,6 +5,7 @@
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;
import com.partinsystem.udpall.impl.Partin_elemonitorImpl;

public class Partin_elemonitorService {
    private BaseDAO dao;
@@ -41,5 +42,17 @@
        }
        return model;
    }

    //根据查询udp包的所有历史记录表
    public ServiceModel serchRecord() {
        List list=((Partin_elemonitorImpl)dao).serchRecord();
        if(list!=null&&list.size()>0){
            model.setData(list);
            model.setCode(1);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }
        return model;
    }
}