DyEnvir_system/src/com/fgkj/actions/CsvFileDownloadAction.java
@@ -58,6 +58,8 @@ import com.fgkj.watersystem.Impl.Water_realdataImpl; import com.fgkj.watersystem.dto.Water_realdata; import com.google.gson.reflect.TypeToken; import com.partinsystem.udpall.dto.Partin_elemonitor; import com.partinsystem.udpall.impl.Partin_elemonitorImpl; public class CsvFileDownloadAction extends ActionUtil{ private String json; @@ -418,6 +420,12 @@ ai.setRecord_time1(cs.getRecord_time1()); ai.setNote(cs.getTablists()); exportData=(new AcinsulationImpl()).serchCSV(ai); }else if(cs.getExport_num()==22){ //udp发包参试设备 Partin_elemonitor pe=new Partin_elemonitor(); pe.setRecord_time(cs.getRecord_time()); pe.setRecord_time1(cs.getRecord_time1()); pe.setNote(cs.getTablists()); exportData=(new Partin_elemonitorImpl()).serchCSV(pe); } if(exportData==null&&exportData.size()<=0){ Map row = new LinkedHashMap<String, String>(); DyEnvir_system/src/com/partinsystem/udpall/action/Partin_elemonitorAction.java
@@ -4,6 +4,7 @@ import com.fgkj.actions.ActionUtil; import com.fgkj.services.ServiceModel; import com.partinsystem.udpall.dto.Partin_elemonitor; import com.partinsystem.udpall.service.Partin_elemonitorService; public class Partin_elemonitorAction extends ActionUtil{ @@ -18,7 +19,13 @@ result=tojson(model); return SUCCESS; } //查询历史数据一天之类的所有数据 public String serchByInfo() { Partin_elemonitor partin_elemonitor=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Partin_elemonitor.class); ServiceModel model=service.serchByInfo(partin_elemonitor); result=tojson(model); return SUCCESS; } public String getResult() { return result; DyEnvir_system/src/com/partinsystem/udpall/dto/Partin_elemonitor.java
@@ -6,6 +6,7 @@ public class Partin_elemonitor implements Serializable{ private int num ; private Date record_time;//'记录时间', private Date record_time1;//'记录时间', private int dc_insulation_low_alarm ;//'直流绝缘低报警', @@ -39,6 +40,14 @@ public void setRecord_time(Date record_time) { this.record_time = record_time; } public Date getRecord_time1() { return record_time1; } public void setRecord_time1(Date record_time1) { this.record_time1 = record_time1; } public int getDc_insulation_low_alarm() { @@ -163,13 +172,13 @@ @Override public String toString() { return "Partin_elemonitor [num=" + num + ", record_time=" + record_time + ", dc_insulation_low_alarm=" + dc_insulation_low_alarm + ", ac230_elec=" + ac230_elec + ", acmain_board=" + acmain_board + ", acreliable_board=" + acreliable_board + ", batt=" + batt + ", cabin_bump=" + cabin_bump + ", dc230_converter=" + dc230_converter + ", dc25_converter=" + dc25_converter + ", dcmain_board=" + dcmain_board + ", inverter=" + inverter + ", propulsion_motor=" + propulsion_motor + ", shore=" + shore + ", switch_value=" + switch_value + ", turbogenerator=" + turbogenerator + ", note=" + note + "]"; return "Partin_elemonitor [num=" + num + ", record_time=" + record_time + ", record_time1=" + record_time1 + ", dc_insulation_low_alarm=" + dc_insulation_low_alarm + ", ac230_elec=" + ac230_elec + ", acmain_board=" + acmain_board + ", acreliable_board=" + acreliable_board + ", batt=" + batt + ", cabin_bump=" + cabin_bump + ", dc230_converter=" + dc230_converter + ", dc25_converter=" + dc25_converter + ", dcmain_board=" + dcmain_board + ", inverter=" + inverter + ", propulsion_motor=" + propulsion_motor + ", shore=" + shore + ", switch_value=" + switch_value + ", turbogenerator=" + turbogenerator + ", note=" + note + "]"; } @@ -177,4 +186,5 @@ } DyEnvir_system/src/com/partinsystem/udpall/impl/Partin_elemonitorImpl.java
@@ -8,10 +8,13 @@ import javax.swing.plaf.synth.SynthScrollPaneUI; import com.fgkj.actions.ActionUtil; import com.fgkj.dao.BaseDAO; import com.fgkj.dao.CallBack; import com.fgkj.dao.DAOHelper; import com.fgkj.db.DBUtil; import com.fgkj.partinsystem.dto.Ac230v_ups; import com.fgkj.partinsystem.dto.Dcinsulation; import com.partinsystem.udpall.dto.Ac230_elec; import com.partinsystem.udpall.dto.Acmain_board; import com.partinsystem.udpall.dto.Acreliable_board; @@ -35,6 +38,8 @@ try { while(rs.next()) { Partin_elemonitor partin_elemonitor=new Partin_elemonitor(); partin_elemonitor.setRecord_time(rs.getTimestamp("Record_time")); partin_elemonitor.setDc_insulation_low_alarm(rs.getInt("dc_insulation_low_alarm")); Ac230_elec ac230_elec=new Ac230_elec(); ac230_elec.setAc230_eleccurr_one(rs.getFloat("Ac230_eleccurr_one")); @@ -242,11 +247,88 @@ List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[] {}, new Partin_elemonitorImpl()); return list; } //查询历史数据一天之类的所有数据 @Override public List serchByInfo(Object obj) { // TODO Auto-generated method stub return null; Partin_elemonitor pe=(Partin_elemonitor) obj; String dateString=DAOHelper.sdf_withOut.format(pe.getRecord_time()); String sql=" select * from db_partinsystem_history.tb_partin_elemonitor_"+dateString+" " + " where record_time >= ? and record_time <= ? order by record_time asc "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{pe.getRecord_time(),pe.getRecord_time1()},new Partin_elemonitorImpl() ); return list; } //文件导出时的历史查询 public List serchCSV(Object obj) { final Partin_elemonitor pe=(Partin_elemonitor) obj; String tablists=pe.getNote()+",record_time"; String table=DAOHelper.sdf_withOut.format(pe.getRecord_time()); String table1=DAOHelper.sdf_withOut.format(pe.getRecord_time1()); String SqlAll=""; String sql=" (select "+tablists+" from db_partinsystem_history.tb_partin_elemonitor_"+table+" " + " where record_time >= ? and record_time <= ? order by record_time asc )"; String sql_union=" union all "; String sql1= " (select "+tablists+" from db_partinsystem_history.tb_partin_elemonitor_"+table1+" " + " where record_time >= ? and record_time <= ? order by record_time asc )"; Object[] strarr=null; List list=new ArrayList(); String st="_"+table; String st1="_"+table1; int size=DAOHelper.serchTable(st); int size1=DAOHelper.serchTable(st1); //表都存在 if(size>0&&size1>0){ if(table.equals(table1)){ SqlAll=sql; strarr=new Object[]{DAOHelper.sdf.format(pe.getRecord_time()),DAOHelper.sdf.format(pe.getRecord_time1())}; }else{ SqlAll=sql+sql_union+sql1; strarr=new Object[]{DAOHelper.sdf.format(pe.getRecord_time()),DAOHelper.sdfwithOut.format(pe.getRecord_time())+" 23:59:59",DAOHelper.sdfwithOut.format(pe.getRecord_time())+" 00:00:00",DAOHelper.sdf.format(pe.getRecord_time1())}; } } //存在一个表 if(size>0&&size1<=0){ SqlAll=sql; strarr=new Object[]{DAOHelper.sdf.format(pe.getRecord_time()),DAOHelper.sdfwithOut.format(pe.getRecord_time())+" 23:59:59"}; } if(size<=0&&size1>0){ SqlAll=sql1; strarr=new Object[]{DAOHelper.sdfwithOut.format(pe.getRecord_time1())+" 00:00:00",DAOHelper.sdf.format(pe.getRecord_time1())}; } //表都不存在 if(size<=0&&size1<=0){ return list; } list=DAOHelper.executeQuery(SqlAll, DBUtil.getConn(), strarr, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); String[] state=pe.getNote().split(","); try { while(rs.next()){ List row=new ArrayList(); row.add(ActionUtil.chageDateToString(rs.getTimestamp("record_time"), ActionUtil.time_yyyyMMddHHmmss).trim()); for (int i = 0; i < state.length; i++) { row.add(rs.getFloat(state[i])); } list.add(row); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } public static void main(String[] args) { Partin_elemonitorImpl pimpl=new Partin_elemonitorImpl(); DyEnvir_system/src/com/partinsystem/udpall/service/Partin_elemonitorService.java
@@ -28,6 +28,18 @@ } return model; } //查询历史数据一天之类的所有数据 public ServiceModel serchByInfo(Object obj) { List list=dao.serchByInfo(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setData(list); model.setMsg("查询成功"); }else{ model.setCode(0); model.setMsg("查询失败"); } return model; } }
