DyEnvir_system/.settings/org.eclipse.jdt.core.prefs
@@ -1,9 +1,9 @@ eclipse.preferences.version=1 org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled org.eclipse.jdt.core.compiler.codegen.methodParameters=do not generate org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8 org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7 org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve org.eclipse.jdt.core.compiler.compliance=1.8 org.eclipse.jdt.core.compiler.compliance=1.7 org.eclipse.jdt.core.compiler.debug.lineNumber=generate org.eclipse.jdt.core.compiler.debug.localVariable=generate org.eclipse.jdt.core.compiler.debug.sourceFile=generate @@ -12,4 +12,4 @@ org.eclipse.jdt.core.compiler.problem.enumIdentifier=error org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning org.eclipse.jdt.core.compiler.release=disabled org.eclipse.jdt.core.compiler.source=1.8 org.eclipse.jdt.core.compiler.source=1.7 DyEnvir_system/src/com/fgkj/actions/electric2mwsystem/Device_connectstateAction.java
@@ -2,6 +2,7 @@ import com.fgkj.actions.ActionUtil; import com.fgkj.electric2mwsystem.Service.Device_connectstateService; import com.fgkj.electric2mwsystem.dto.Device_connectstate; import com.fgkj.services.ServiceModel; public class Device_connectstateAction extends ActionUtil{ @@ -16,7 +17,14 @@ return SUCCESS; } //文件管理---根据设备id查询所有文件 public String serchByCondition() { Device_connectstate dc=ActionUtil.getGson().fromJson(json, Device_connectstate.class); ServiceModel model=service.serchByCondition(dc); result=tojson(model); return SUCCESS; } public String getResult() { DyEnvir_system/src/com/fgkj/electric2mwsystem/Impl/Device_connectstateImpl.java
@@ -13,6 +13,13 @@ public class Device_connectstateImpl implements BaseDAO,CallBack{ //历史数据表名取时间转"_"到"-" private static String changeDateFrom(int dev_id, String dateString){ String devStr=String.valueOf(dev_id)+"_"; dateString=dateString.substring(dateString.indexOf(devStr)+5); dateString=dateString.replace("_", "-"); return dateString; } @Override public List getResults(ResultSet rs) { // TODO Auto-generated method stub @@ -62,11 +69,46 @@ }); return list; } //文件管理---根据设备id查询所有文件 @Override public List serchByCondition(Object obj) { // TODO Auto-generated method stub return null; final Device_connectstate dc=(Device_connectstate) obj; String table_schema=""; String table_name=String.valueOf(dc.getDev_id()); switch (dc.getNum()) { case 1:table_schema="db_dynamicsystem";break;//负载 case 2:table_schema="db_motor_realhistory";break;//电机 case 3:table_schema="db_batt_testdata";break;//电池----暂时不用 case 4:table_schema="db_electricsystem";break;//4MW case 5:table_schema="db_watersystem";break;//水冷 case 6:table_schema="db_electric2mwsystem";break;//2MW default:break; } String sql=" select table_name,data_length,index_length from information_schema.tables " + " where table_schema=? and table_name like ? " + " order by table_name asc "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{table_schema,"%"+table_name+"%"}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Device_connectstate d=new Device_connectstate(); d.setTable_name(Device_connectstateImpl.changeDateFrom(dc.getDev_id(),rs.getString("table_name"))); d.setData_length(rs.getInt("data_length")); d.setIndex_length(rs.getInt("index_length")); list.add(d); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } @Override DyEnvir_system/src/com/fgkj/electric2mwsystem/Service/Device_connectstateService.java
@@ -28,5 +28,17 @@ } return model; } //文件管理---根据设备id查询所有文件 public ServiceModel serchByCondition(Object obj) { List list=dao.serchByCondition(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setMsg("查询成功!"); model.setData(list); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } } DyEnvir_system/src/com/fgkj/electric2mwsystem/dto/Device_connectstate.java
@@ -9,6 +9,10 @@ private int connect_en; private Date record_time; private String note; private String table_name;//表名 private int data_length;//表文件的大小 private int index_length;//表文件的大小 public int getNum() { return num; } @@ -39,13 +43,32 @@ public void setNote(String note) { this.note = note; } public String getTable_name() { return table_name; } public void setTable_name(String table_name) { this.table_name = table_name; } public int getData_length() { return data_length; } public void setData_length(int data_length) { this.data_length = data_length; } public int getIndex_length() { return index_length; } public void setIndex_length(int index_length) { this.index_length = index_length; } @Override public String toString() { return "Device_connectstate [num=" + num + ", dev_id=" + dev_id + ", connect_en=" + connect_en + ", record_time=" + record_time + ", note=" + note + "]"; return "Device_connectstate [num=" + num + ", dev_id=" + dev_id + ", connect_en=" + connect_en + ", record_time=" + record_time + ", note=" + note + ", table_name=" + table_name + ", data_length=" + data_length + ", index_length=" + index_length + "]"; } }
