DyEnvir_system/src/com/fgkj/actions/CsvFileDownloadAction.java
@@ -25,11 +25,13 @@ import com.fgkj.elemachinery.impl.Motor_readdataImpl; import com.fgkj.partinsystem.dto.Ac230v_ups; import com.fgkj.partinsystem.dto.AcDistribution; import com.fgkj.partinsystem.dto.Acinsulation; import com.fgkj.partinsystem.dto.Battery_monitor; import com.fgkj.partinsystem.dto.Cabin_board; import com.fgkj.partinsystem.dto.Dc230v_batt; import com.fgkj.partinsystem.dto.Dc25v_batt; import com.fgkj.partinsystem.dto.DcDistribution; import com.fgkj.partinsystem.dto.Dcinsulation; import com.fgkj.partinsystem.dto.Electrical_monitor_station; import com.fgkj.partinsystem.dto.Inverter_ele; import com.fgkj.partinsystem.dto.Propulsion_motor; @@ -37,11 +39,13 @@ import com.fgkj.partinsystem.dto.Switch_board; import com.fgkj.partinsystem.impl.Ac230v_upsImpl; import com.fgkj.partinsystem.impl.AcDistributionImpl; import com.fgkj.partinsystem.impl.AcinsulationImpl; import com.fgkj.partinsystem.impl.Battery_monitorImpl; import com.fgkj.partinsystem.impl.Cabin_boardImpl; import com.fgkj.partinsystem.impl.Dc230v_battImpl; import com.fgkj.partinsystem.impl.Dc25v_battImpl; import com.fgkj.partinsystem.impl.DcDistributionImpl; import com.fgkj.partinsystem.impl.DcinsulationImpl; import com.fgkj.partinsystem.impl.Electrical_monitor_stationImpl; import com.fgkj.partinsystem.impl.Inverter_eleImpl; import com.fgkj.partinsystem.impl.Propulsion_motorImpl; @@ -388,6 +392,20 @@ sb.setRecord_time1(cs.getRecord_time1()); sb.setNote(cs.getTablists()); exportData=(new Switch_boardImpl()).serchCSV(sb); }else if(cs.getExport_num()==20){ //直流绝缘监测装置 Dcinsulation di=new Dcinsulation(); di.setDev_id(cs.getDev_id()); di.setRecord_time(cs.getRecord_time()); di.setRecord_time1(cs.getRecord_time1()); di.setNote(cs.getTablists()); exportData=(new DcinsulationImpl()).serchCSV(di); }else if(cs.getExport_num()==21){ //交流绝缘监测装置 Acinsulation ai=new Acinsulation(); ai.setDev_id(cs.getDev_id()); ai.setRecord_time(cs.getRecord_time()); ai.setRecord_time1(cs.getRecord_time1()); ai.setNote(cs.getTablists()); exportData=(new AcinsulationImpl()).serchCSV(ai); } if(exportData==null&&exportData.size()<=0){ Map row = new LinkedHashMap<String, String>(); DyEnvir_system/src/com/fgkj/actions/partinsystem/AcinsulationAction.java
New file @@ -0,0 +1,45 @@ package com.fgkj.actions.partinsystem; import com.fgkj.actions.ActionUtil; import com.fgkj.partinsystem.dto.Acinsulation; import com.fgkj.partinsystem.service.AcinsulationService; import com.fgkj.services.ServiceModel; public class AcinsulationAction extends ActionUtil{ private AcinsulationService service=new AcinsulationService(); private String json; private String result; //根据参试设备id查询设备的实时数据 public String serchByCondition() { Acinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Acinsulation.class); ServiceModel model=service.serchByCondition(ac); result=tojson(model); return SUCCESS; } //设备实时数据显示(前100笔数据服务器的时间) public String serchByInfo() { Acinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Acinsulation.class); ServiceModel model=service.serchByInfo(ac); result=tojson(model); return SUCCESS; } //设备历史数据查询 public String serchHistory() { Acinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Acinsulation.class); ServiceModel model=service.serchHistory(ac); result=tojson(model); return SUCCESS; } public String getResult() { return result; } public void setJson(String json) { this.json = json; } } DyEnvir_system/src/com/fgkj/actions/partinsystem/DcinsulationAction.java
New file @@ -0,0 +1,46 @@ package com.fgkj.actions.partinsystem; import com.fgkj.actions.ActionUtil; import com.fgkj.partinsystem.dto.Dcinsulation; import com.fgkj.partinsystem.service.DcinsulationService; import com.fgkj.services.ServiceModel; public class DcinsulationAction extends ActionUtil{ private DcinsulationService service=new DcinsulationService(); private String json; private String result; //根据参试设备id查询设备的实时数据 public String serchByCondition() { Dcinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Dcinsulation.class); ServiceModel model=service.serchByCondition(ac); result=tojson(model); return SUCCESS; } //设备实时数据显示(前100笔数据服务器的时间) public String serchByInfo() { Dcinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Dcinsulation.class); ServiceModel model=service.serchByInfo(ac); result=tojson(model); return SUCCESS; } //设备历史数据查询 public String serchHistory() { Dcinsulation ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Dcinsulation.class); ServiceModel model=service.serchHistory(ac); result=tojson(model); return SUCCESS; } public String getResult() { return result; } public void setJson(String json) { this.json = json; } } DyEnvir_system/src/com/fgkj/dao/BaseDAO.java
@@ -125,6 +125,8 @@ public static final int DCDISTRIBUTION=68; public static final int ACDISTRIBUTION=69; public static final int BATTALARM_DATA=70; public static final int DCINSULATION=71; public static final int ACINSULATION=72; public boolean add(Object obj); // 添加 DyEnvir_system/src/com/fgkj/dao/BaseDAOFactory.java
@@ -54,12 +54,14 @@ import com.fgkj.elemachinery.impl.Subject_motor_stateImpl; import com.fgkj.partinsystem.impl.Ac230v_upsImpl; import com.fgkj.partinsystem.impl.AcDistributionImpl; import com.fgkj.partinsystem.impl.AcinsulationImpl; import com.fgkj.partinsystem.impl.Battery_monitorImpl; import com.fgkj.partinsystem.impl.Cabin_boardImpl; import com.fgkj.partinsystem.impl.Centra_frequencyImpl; import com.fgkj.partinsystem.impl.Dc230v_battImpl; import com.fgkj.partinsystem.impl.Dc25v_battImpl; import com.fgkj.partinsystem.impl.DcDistributionImpl; import com.fgkj.partinsystem.impl.DcinsulationImpl; import com.fgkj.partinsystem.impl.Electrical_monitor_stationImpl; import com.fgkj.partinsystem.impl.Inverter_eleImpl; import com.fgkj.partinsystem.impl.Medvoldc_converterImpl; @@ -158,6 +160,8 @@ case 68:return new DcDistributionImpl(); case 69:return new AcDistributionImpl(); case 70:return new Battalarm_dataImpl(); case 71:return new DcinsulationImpl(); case 72:return new AcinsulationImpl(); default :return null; } } DyEnvir_system/src/com/fgkj/partinsystem/dto/Acinsulation.java
New file @@ -0,0 +1,358 @@ package com.fgkj.partinsystem.dto; import java.io.Serializable; import java.util.Date; public class Acinsulation implements Serializable{ private int num ;// private int dev_id ;//'设备id', private Date record_time ;// '记录时间', private Date record_time1 ;// '记录时间', private float ele_heater_contol_panel_q55 ;//'稳压器电加热控制屏(Q55)', private float control_reli_switchboard_12st_ar12 ;//'12号集成辅机控制与可靠分配电板AR12(Q72)', private float low_freq_power_cabinet ;//'低频电源柜(Q59)', private float refrigerator_control_panel ;//'制冷机控制屏(Q52)', private float control_reli_switchboard_11st_ar11 ;//'11号集成辅机控制与可靠分配电板AR11(Q71)', private float safe_injection_pump ;//'安全注射泵(Q51)', private float cool_pump_2st_q57 ;//'2号冷却剂泵(Q57)', private float cool_pump_3st_q58 ;//'3号冷却剂泵(Q58)', private float control_reli_switchboard_13st ;//'13号集成辅机控制与可靠分配电板(Q73)', private float inverter_power_1st ;//'1号大功率逆变电源(Q10)', private float control_cabin_switchboard_3st_ac53 ;//'V舱3号集成辅机控制与舱室配电板AC53(Q18)', private float control_cabin_switchboard_1st ;//'V舱1号集成辅机控制与舱室配电板(Q17)', private float cool_pump_2st_q11 ;//'2号冷却剂泵(Q11)', private float control_cabin_switchboard_ac60 ;//'Ⅵ舱集成辅机控制与舱室配电板AC60(Q19)', private float control_cabin_switchboard_4st_ac54 ;//'Ⅴ舱4号集成辅机控制与舱室配电板AC54(Q28)', private float control_cabin_switchboard_2st_ac52 ;//'Ⅴ舱2号集成辅机控制与舱室配电板AC52(Q27)', private float ele_heater_contol_panel_q29 ;//'稳压器电加器控制屏(Q29)', private float cool_pump_3st_q22 ;//'3号冷却剂泵(Q22)', private float inverter_power_2st ;//'2号大功率逆变电源(Q20)', private float cool_pump_1st_q67 ;//'1号冷却剂泵(q67)', private float cool_pump_4st_q68 ;//'4号冷却剂泵(Q68)', private float control_reli_switchboard_23st_ar23 ;//'23号集成辅机控制与可靠分配电板(Q83)', private float control_reli_switchboard_22st_ar22 ;//'22号集成辅机控制与可靠分配电板AR22(Q82)', private float control_reli_switchboard_21st_ar21 ;//'21号集成辅机控制与可靠分配电板AR21(Q81)', private float inverter_power_4st ;//'4号大功率逆变电源(Q40)', private float control_cabin_switchboard_Ⅱ_ac20 ;//'Ⅱ舱集成辅机控制与舱室配电板AC20(Q37)', private float cool_pump_1st_q33 ;//'1号冷却剂泵(Q33)', private float inverter_power_3st ;//'3号大功率逆变电源(Q30)', private float cool_pump_4st_q44 ;//'4号冷却剂泵(Q44)', private float control_cabin_switchboard_Ⅲ_ac30 ;//'Ⅲ舱集成辅机控制与舱室配电板AC30(Q48)', private float control_cabin_switchboard_Ⅰ_ac10 ;//'Ⅰ舱集成辅机控制与舱室配电板AC10(Q47)', private float back01 ;//'保留1', private float reli_insulat_res ;//'1号可靠绝缘电阻;2号可靠绝缘电阻', private float dc_distri_insulat_res1 ;//'1号交流主配绝缘电阻;3号交流主配绝缘电阻', private float dc_distri_insulat_res2 ;//'2号交流主配绝缘电阻;4号交流主配绝缘电阻', private float back02 ;//'保留2', private String note ;// '备用', public int getNum() { return num; } public void setNum(int num) { this.num = num; } public int getDev_id() { return dev_id; } public void setDev_id(int dev_id) { this.dev_id = dev_id; } public Date getRecord_time() { return record_time; } public void setRecord_time(Date record_time) { this.record_time = record_time; } public float getEle_heater_contol_panel_q55() { return ele_heater_contol_panel_q55; } public void setEle_heater_contol_panel_q55(float ele_heater_contol_panel_q55) { this.ele_heater_contol_panel_q55 = ele_heater_contol_panel_q55; } public float getControl_reli_switchboard_12st_ar12() { return control_reli_switchboard_12st_ar12; } public void setControl_reli_switchboard_12st_ar12( float control_reli_switchboard_12st_ar12) { this.control_reli_switchboard_12st_ar12 = control_reli_switchboard_12st_ar12; } public float getLow_freq_power_cabinet() { return low_freq_power_cabinet; } public void setLow_freq_power_cabinet(float low_freq_power_cabinet) { this.low_freq_power_cabinet = low_freq_power_cabinet; } public float getRefrigerator_control_panel() { return refrigerator_control_panel; } public void setRefrigerator_control_panel(float refrigerator_control_panel) { this.refrigerator_control_panel = refrigerator_control_panel; } public float getControl_reli_switchboard_11st_ar11() { return control_reli_switchboard_11st_ar11; } public void setControl_reli_switchboard_11st_ar11( float control_reli_switchboard_11st_ar11) { this.control_reli_switchboard_11st_ar11 = control_reli_switchboard_11st_ar11; } public float getSafe_injection_pump() { return safe_injection_pump; } public void setSafe_injection_pump(float safe_injection_pump) { this.safe_injection_pump = safe_injection_pump; } public float getCool_pump_2st_q57() { return cool_pump_2st_q57; } public void setCool_pump_2st_q57(float cool_pump_2st_q57) { this.cool_pump_2st_q57 = cool_pump_2st_q57; } public float getCool_pump_3st_q58() { return cool_pump_3st_q58; } public void setCool_pump_3st_q58(float cool_pump_3st_q58) { this.cool_pump_3st_q58 = cool_pump_3st_q58; } public float getControl_reli_switchboard_13st() { return control_reli_switchboard_13st; } public void setControl_reli_switchboard_13st(float control_reli_switchboard_13st) { this.control_reli_switchboard_13st = control_reli_switchboard_13st; } public float getInverter_power_1st() { return inverter_power_1st; } public void setInverter_power_1st(float inverter_power_1st) { this.inverter_power_1st = inverter_power_1st; } public float getControl_cabin_switchboard_3st_ac53() { return control_cabin_switchboard_3st_ac53; } public void setControl_cabin_switchboard_3st_ac53( float control_cabin_switchboard_3st_ac53) { this.control_cabin_switchboard_3st_ac53 = control_cabin_switchboard_3st_ac53; } public float getControl_cabin_switchboard_1st() { return control_cabin_switchboard_1st; } public void setControl_cabin_switchboard_1st(float control_cabin_switchboard_1st) { this.control_cabin_switchboard_1st = control_cabin_switchboard_1st; } public float getCool_pump_2st_q11() { return cool_pump_2st_q11; } public void setCool_pump_2st_q11(float cool_pump_2st_q11) { this.cool_pump_2st_q11 = cool_pump_2st_q11; } public float getControl_cabin_switchboard_ac60() { return control_cabin_switchboard_ac60; } public void setControl_cabin_switchboard_ac60( float control_cabin_switchboard_ac60) { this.control_cabin_switchboard_ac60 = control_cabin_switchboard_ac60; } public float getControl_cabin_switchboard_4st_ac54() { return control_cabin_switchboard_4st_ac54; } public void setControl_cabin_switchboard_4st_ac54( float control_cabin_switchboard_4st_ac54) { this.control_cabin_switchboard_4st_ac54 = control_cabin_switchboard_4st_ac54; } public float getControl_cabin_switchboard_2st_ac52() { return control_cabin_switchboard_2st_ac52; } public void setControl_cabin_switchboard_2st_ac52( float control_cabin_switchboard_2st_ac52) { this.control_cabin_switchboard_2st_ac52 = control_cabin_switchboard_2st_ac52; } public float getEle_heater_contol_panel_q29() { return ele_heater_contol_panel_q29; } public void setEle_heater_contol_panel_q29(float ele_heater_contol_panel_q29) { this.ele_heater_contol_panel_q29 = ele_heater_contol_panel_q29; } public float getCool_pump_3st_q22() { return cool_pump_3st_q22; } public void setCool_pump_3st_q22(float cool_pump_3st_q22) { this.cool_pump_3st_q22 = cool_pump_3st_q22; } public float getInverter_power_2st() { return inverter_power_2st; } public void setInverter_power_2st(float inverter_power_2st) { this.inverter_power_2st = inverter_power_2st; } public float getCool_pump_1st_q67() { return cool_pump_1st_q67; } public void setCool_pump_1st_q67(float cool_pump_1st_q67) { this.cool_pump_1st_q67 = cool_pump_1st_q67; } public float getCool_pump_4st_q68() { return cool_pump_4st_q68; } public void setCool_pump_4st_q68(float cool_pump_4st_q68) { this.cool_pump_4st_q68 = cool_pump_4st_q68; } public float getControl_reli_switchboard_23st_ar23() { return control_reli_switchboard_23st_ar23; } public void setControl_reli_switchboard_23st_ar23( float control_reli_switchboard_23st_ar23) { this.control_reli_switchboard_23st_ar23 = control_reli_switchboard_23st_ar23; } public float getControl_reli_switchboard_22st_ar22() { return control_reli_switchboard_22st_ar22; } public void setControl_reli_switchboard_22st_ar22( float control_reli_switchboard_22st_ar22) { this.control_reli_switchboard_22st_ar22 = control_reli_switchboard_22st_ar22; } public float getControl_reli_switchboard_21st_ar21() { return control_reli_switchboard_21st_ar21; } public void setControl_reli_switchboard_21st_ar21( float control_reli_switchboard_21st_ar21) { this.control_reli_switchboard_21st_ar21 = control_reli_switchboard_21st_ar21; } public float getInverter_power_4st() { return inverter_power_4st; } public void setInverter_power_4st(float inverter_power_4st) { this.inverter_power_4st = inverter_power_4st; } public float getControl_cabin_switchboard_Ⅱ_ac20() { return control_cabin_switchboard_Ⅱ_ac20; } public void setControl_cabin_switchboard_Ⅱ_ac20( float control_cabin_switchboard_Ⅱ_ac20) { this.control_cabin_switchboard_Ⅱ_ac20 = control_cabin_switchboard_Ⅱ_ac20; } public float getCool_pump_1st_q33() { return cool_pump_1st_q33; } public void setCool_pump_1st_q33(float cool_pump_1st_q33) { this.cool_pump_1st_q33 = cool_pump_1st_q33; } public float getInverter_power_3st() { return inverter_power_3st; } public void setInverter_power_3st(float inverter_power_3st) { this.inverter_power_3st = inverter_power_3st; } public float getCool_pump_4st_q44() { return cool_pump_4st_q44; } public void setCool_pump_4st_q44(float cool_pump_4st_q44) { this.cool_pump_4st_q44 = cool_pump_4st_q44; } public float getControl_cabin_switchboard_Ⅲ_ac30() { return control_cabin_switchboard_Ⅲ_ac30; } public void setControl_cabin_switchboard_Ⅲ_ac30( float control_cabin_switchboard_Ⅲ_ac30) { this.control_cabin_switchboard_Ⅲ_ac30 = control_cabin_switchboard_Ⅲ_ac30; } public float getControl_cabin_switchboard_Ⅰ_ac10() { return control_cabin_switchboard_Ⅰ_ac10; } public void setControl_cabin_switchboard_Ⅰ_ac10( float control_cabin_switchboard_Ⅰ_ac10) { this.control_cabin_switchboard_Ⅰ_ac10 = control_cabin_switchboard_Ⅰ_ac10; } public float getBack01() { return back01; } public void setBack01(float back01) { this.back01 = back01; } public float getReli_insulat_res() { return reli_insulat_res; } public void setReli_insulat_res(float reli_insulat_res) { this.reli_insulat_res = reli_insulat_res; } public float getDc_distri_insulat_res1() { return dc_distri_insulat_res1; } public void setDc_distri_insulat_res1(float dc_distri_insulat_res1) { this.dc_distri_insulat_res1 = dc_distri_insulat_res1; } public float getDc_distri_insulat_res2() { return dc_distri_insulat_res2; } public void setDc_distri_insulat_res2(float dc_distri_insulat_res2) { this.dc_distri_insulat_res2 = dc_distri_insulat_res2; } public float getBack02() { return back02; } public void setBack02(float back02) { this.back02 = back02; } public String getNote() { return note; } public void setNote(String note) { this.note = note; } public Date getRecord_time1() { return record_time1; } public void setRecord_time1(Date record_time1) { this.record_time1 = record_time1; } @Override public String toString() { return "Acinsulation [num=" + num + ", dev_id=" + dev_id + ", record_time=" + record_time + ", record_time1=" + record_time1 + ", ele_heater_contol_panel_q55=" + ele_heater_contol_panel_q55 + ", control_reli_switchboard_12st_ar12=" + control_reli_switchboard_12st_ar12 + ", low_freq_power_cabinet=" + low_freq_power_cabinet + ", refrigerator_control_panel=" + refrigerator_control_panel + ", control_reli_switchboard_11st_ar11=" + control_reli_switchboard_11st_ar11 + ", safe_injection_pump=" + safe_injection_pump + ", cool_pump_2st_q57=" + cool_pump_2st_q57 + ", cool_pump_3st_q58=" + cool_pump_3st_q58 + ", control_reli_switchboard_13st=" + control_reli_switchboard_13st + ", inverter_power_1st=" + inverter_power_1st + ", control_cabin_switchboard_3st_ac53=" + control_cabin_switchboard_3st_ac53 + ", control_cabin_switchboard_1st=" + control_cabin_switchboard_1st + ", cool_pump_2st_q11=" + cool_pump_2st_q11 + ", control_cabin_switchboard_ac60=" + control_cabin_switchboard_ac60 + ", control_cabin_switchboard_4st_ac54=" + control_cabin_switchboard_4st_ac54 + ", control_cabin_switchboard_2st_ac52=" + control_cabin_switchboard_2st_ac52 + ", ele_heater_contol_panel_q29=" + ele_heater_contol_panel_q29 + ", cool_pump_3st_q22=" + cool_pump_3st_q22 + ", inverter_power_2st=" + inverter_power_2st + ", cool_pump_1st_q67=" + cool_pump_1st_q67 + ", cool_pump_4st_q68=" + cool_pump_4st_q68 + ", control_reli_switchboard_23st_ar23=" + control_reli_switchboard_23st_ar23 + ", control_reli_switchboard_22st_ar22=" + control_reli_switchboard_22st_ar22 + ", control_reli_switchboard_21st_ar21=" + control_reli_switchboard_21st_ar21 + ", inverter_power_4st=" + inverter_power_4st + ", control_cabin_switchboard_Ⅱ_ac20=" + control_cabin_switchboard_Ⅱ_ac20 + ", cool_pump_1st_q33=" + cool_pump_1st_q33 + ", inverter_power_3st=" + inverter_power_3st + ", cool_pump_4st_q44=" + cool_pump_4st_q44 + ", control_cabin_switchboard_Ⅲ_ac30=" + control_cabin_switchboard_Ⅲ_ac30 + ", control_cabin_switchboard_Ⅰ_ac10=" + control_cabin_switchboard_Ⅰ_ac10 + ", back01=" + back01 + ", reli_insulat_res=" + reli_insulat_res + ", dc_distri_insulat_res1=" + dc_distri_insulat_res1 + ", dc_distri_insulat_res2=" + dc_distri_insulat_res2 + ", back02=" + back02 + ", note=" + note + "]"; } } DyEnvir_system/src/com/fgkj/partinsystem/dto/Dcinsulation.java
New file @@ -0,0 +1,329 @@ package com.fgkj.partinsystem.dto; import java.io.Serializable; import java.util.Date; public class Dcinsulation implements Serializable{ private int num;//, private int dev_id ;//'设备id', private Date record_time ;// '记录时间', private Date record_time1 ;// '记录时间', private float motor_branch1 ;// '推进电机支路1(Q108)', private float inverter_power_1st ;// '1号大功率逆变电源', private float back_branch1 ;// '备用支路1', private float dc25v_1st ;// '1号DC25V电源(Q105)', private float dc230v_1st ;// '1号DC230V电源(Q106)', private float waterpump1st_ark1 ;// '1号电动给水泵变频柜1(Q112)', private float waterpump1st_ark2 ;// '1号电动给水泵变频柜2(Q113)', private float inverter_power_stream_1st ;// '1号蒸汽隔舱阀逆变电源(Q109)', private float motor_branch2 ;// '推进电机支路2(Q208)', private float inverter_power_2st ;// '2号大功率逆变电源', private float back_branch2 ;// '备用支路2', private float dc230v_2st ;// '2号DC230V电源(Q206)', private float waterpump2st_ark1 ;// '2号电动给水泵变频电源柜1(Q212)', private float waterpump2st_ark2 ;// '2号电动给水泵变频电源柜2(Q213)', private float inverter_power_stream_2st ;// '2号蒸汽隔舱阀逆变电源(Q209)', private float control_power_1st ;// '1号不间断控制电源(Q207)', private float back_branch3 ;// '备用支路3', private float inverter_power_3st ;// '3号大功率逆变电源(Q303)', private float dc25v_3st ;// '3号DC25V电源(Q305)', private float dc230v_3st ;// '3号DC230V电源(Q306)', private float dc25v_2st ;// '2号DC25V电源(Q308)', private float balance_pump_inverter_ark ;// '均衡泵逆变电源柜(Q309)', private float control_power_2st ;// '2号不间断控制电源(Q307)', private float batt_switch_board_1st ;// '1号蓄电池开关板(Q310)', private float back_branch4 ;// '备用支路4', private float inverter_power_4st ;// '4号大功率逆变电源()', private float dc25v_4st ;// '4号DC25V电源(Q405)', private float dc230v_4st ;// '4号DC230V电源(Q406)', private float ele_water_oxygen_generator ;// '电解水制氧机(409)', private float batt_switch_board_2st ;// '2号蓄电池开关板(Q410)', private float back01 ;// '保留1', private float back02 ;// '保留2', private float dc_distri_insulat_res1 ;// '3号直流主配电板绝缘电阻;1号直流主配电板电阻', private float dc_distri_insulat_res2 ;// '4号直流主配电板绝缘电阻;2号直流主配电板电阻', private float back03 ;// '保留3', private float back04 ;// '保留4', private String note ;//, public int getNum() { return num; } public void setNum(int num) { this.num = num; } public int getDev_id() { return dev_id; } public void setDev_id(int dev_id) { this.dev_id = dev_id; } public Date getRecord_time() { return record_time; } 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 float getMotor_branch1() { return motor_branch1; } public void setMotor_branch1(float motor_branch1) { this.motor_branch1 = motor_branch1; } public float getInverter_power_1st() { return inverter_power_1st; } public void setInverter_power_1st(float inverter_power_1st) { this.inverter_power_1st = inverter_power_1st; } public float getBack_branch1() { return back_branch1; } public void setBack_branch1(float back_branch1) { this.back_branch1 = back_branch1; } public float getDc25v_1st() { return dc25v_1st; } public void setDc25v_1st(float dc25v_1st) { this.dc25v_1st = dc25v_1st; } public float getDc230v_1st() { return dc230v_1st; } public void setDc230v_1st(float dc230v_1st) { this.dc230v_1st = dc230v_1st; } public float getWaterpump1st_ark1() { return waterpump1st_ark1; } public void setWaterpump1st_ark1(float waterpump1st_ark1) { this.waterpump1st_ark1 = waterpump1st_ark1; } public float getWaterpump1st_ark2() { return waterpump1st_ark2; } public void setWaterpump1st_ark2(float waterpump1st_ark2) { this.waterpump1st_ark2 = waterpump1st_ark2; } public float getInverter_power_stream_1st() { return inverter_power_stream_1st; } public void setInverter_power_stream_1st(float inverter_power_stream_1st) { this.inverter_power_stream_1st = inverter_power_stream_1st; } public float getMotor_branch2() { return motor_branch2; } public void setMotor_branch2(float motor_branch2) { this.motor_branch2 = motor_branch2; } public float getInverter_power_2st() { return inverter_power_2st; } public void setInverter_power_2st(float inverter_power_2st) { this.inverter_power_2st = inverter_power_2st; } public float getBack_branch2() { return back_branch2; } public void setBack_branch2(float back_branch2) { this.back_branch2 = back_branch2; } public float getDc230v_2st() { return dc230v_2st; } public void setDc230v_2st(float dc230v_2st) { this.dc230v_2st = dc230v_2st; } public float getWaterpump2st_ark1() { return waterpump2st_ark1; } public void setWaterpump2st_ark1(float waterpump2st_ark1) { this.waterpump2st_ark1 = waterpump2st_ark1; } public float getWaterpump2st_ark2() { return waterpump2st_ark2; } public void setWaterpump2st_ark2(float waterpump2st_ark2) { this.waterpump2st_ark2 = waterpump2st_ark2; } public float getInverter_power_stream_2st() { return inverter_power_stream_2st; } public void setInverter_power_stream_2st(float inverter_power_stream_2st) { this.inverter_power_stream_2st = inverter_power_stream_2st; } public float getControl_power_1st() { return control_power_1st; } public void setControl_power_1st(float control_power_1st) { this.control_power_1st = control_power_1st; } public float getBack_branch3() { return back_branch3; } public void setBack_branch3(float back_branch3) { this.back_branch3 = back_branch3; } public float getInverter_power_3st() { return inverter_power_3st; } public void setInverter_power_3st(float inverter_power_3st) { this.inverter_power_3st = inverter_power_3st; } public float getDc25v_3st() { return dc25v_3st; } public void setDc25v_3st(float dc25v_3st) { this.dc25v_3st = dc25v_3st; } public float getDc230v_3st() { return dc230v_3st; } public void setDc230v_3st(float dc230v_3st) { this.dc230v_3st = dc230v_3st; } public float getDc25v_2st() { return dc25v_2st; } public void setDc25v_2st(float dc25v_2st) { this.dc25v_2st = dc25v_2st; } public float getBalance_pump_inverter_ark() { return balance_pump_inverter_ark; } public void setBalance_pump_inverter_ark(float balance_pump_inverter_ark) { this.balance_pump_inverter_ark = balance_pump_inverter_ark; } public float getControl_power_2st() { return control_power_2st; } public void setControl_power_2st(float control_power_2st) { this.control_power_2st = control_power_2st; } public float getBatt_switch_board_1st() { return batt_switch_board_1st; } public void setBatt_switch_board_1st(float batt_switch_board_1st) { this.batt_switch_board_1st = batt_switch_board_1st; } public float getBack_branch4() { return back_branch4; } public void setBack_branch4(float back_branch4) { this.back_branch4 = back_branch4; } public float getInverter_power_4st() { return inverter_power_4st; } public void setInverter_power_4st(float inverter_power_4st) { this.inverter_power_4st = inverter_power_4st; } public float getDc25v_4st() { return dc25v_4st; } public void setDc25v_4st(float dc25v_4st) { this.dc25v_4st = dc25v_4st; } public float getDc230v_4st() { return dc230v_4st; } public void setDc230v_4st(float dc230v_4st) { this.dc230v_4st = dc230v_4st; } public float getEle_water_oxygen_generator() { return ele_water_oxygen_generator; } public void setEle_water_oxygen_generator(float ele_water_oxygen_generator) { this.ele_water_oxygen_generator = ele_water_oxygen_generator; } public float getBatt_switch_board_2st() { return batt_switch_board_2st; } public void setBatt_switch_board_2st(float batt_switch_board_2st) { this.batt_switch_board_2st = batt_switch_board_2st; } public float getBack01() { return back01; } public void setBack01(float back01) { this.back01 = back01; } public float getBack02() { return back02; } public void setBack02(float back02) { this.back02 = back02; } public float getDc_distri_insulat_res1() { return dc_distri_insulat_res1; } public void setDc_distri_insulat_res1(float dc_distri_insulat_res1) { this.dc_distri_insulat_res1 = dc_distri_insulat_res1; } public float getDc_distri_insulat_res2() { return dc_distri_insulat_res2; } public void setDc_distri_insulat_res2(float dc_distri_insulat_res2) { this.dc_distri_insulat_res2 = dc_distri_insulat_res2; } public float getBack03() { return back03; } public void setBack03(float back03) { this.back03 = back03; } public float getBack04() { return back04; } public void setBack04(float back04) { this.back04 = back04; } public String getNote() { return note; } public void setNote(String note) { this.note = note; } @Override public String toString() { return "Dcinsulation [num=" + num + ", dev_id=" + dev_id + ", record_time=" + record_time + ", record_time1=" + record_time1 + ", motor_branch1=" + motor_branch1 + ", inverter_power_1st=" + inverter_power_1st + ", back_branch1=" + back_branch1 + ", dc25v_1st=" + dc25v_1st + ", dc230v_1st=" + dc230v_1st + ", waterpump1st_ark1=" + waterpump1st_ark1 + ", waterpump1st_ark2=" + waterpump1st_ark2 + ", inverter_power_stream_1st=" + inverter_power_stream_1st + ", motor_branch2=" + motor_branch2 + ", inverter_power_2st=" + inverter_power_2st + ", back_branch2=" + back_branch2 + ", dc230v_2st=" + dc230v_2st + ", waterpump2st_ark1=" + waterpump2st_ark1 + ", waterpump2st_ark2=" + waterpump2st_ark2 + ", inverter_power_stream_2st=" + inverter_power_stream_2st + ", control_power_1st=" + control_power_1st + ", back_branch3=" + back_branch3 + ", inverter_power_3st=" + inverter_power_3st + ", dc25v_3st=" + dc25v_3st + ", dc230v_3st=" + dc230v_3st + ", dc25v_2st=" + dc25v_2st + ", balance_pump_inverter_ark=" + balance_pump_inverter_ark + ", control_power_2st=" + control_power_2st + ", batt_switch_board_1st=" + batt_switch_board_1st + ", back_branch4=" + back_branch4 + ", inverter_power_4st=" + inverter_power_4st + ", dc25v_4st=" + dc25v_4st + ", dc230v_4st=" + dc230v_4st + ", ele_water_oxygen_generator=" + ele_water_oxygen_generator + ", batt_switch_board_2st=" + batt_switch_board_2st + ", back01=" + back01 + ", back02=" + back02 + ", dc_distri_insulat_res1=" + dc_distri_insulat_res1 + ", dc_distri_insulat_res2=" + dc_distri_insulat_res2 + ", back03=" + back03 + ", back04=" + back04 + ", note=" + note + "]"; } } DyEnvir_system/src/com/fgkj/partinsystem/impl/AcinsulationImpl.java
New file @@ -0,0 +1,311 @@ package com.fgkj.partinsystem.impl; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.Date; import java.util.List; 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.Acinsulation; public class AcinsulationImpl implements BaseDAO,CallBack{ @Override public List getResults(ResultSet rs) { // TODO Auto-generated method stub return null; } @Override public boolean add(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean update(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean del(Object obj) { // TODO Auto-generated method stub return false; } @Override public List searchAll() { // TODO Auto-generated method stub return null; } //根据参试设备id查询设备的实时数据 @Override public List serchByCondition(Object obj) { Acinsulation ai=(Acinsulation) obj; String sql=" select * from db_partinsystem.acinsulation where dev_id=? "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ai.getDev_id()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Acinsulation a=new Acinsulation(); a.setDev_id(rs.getInt("dev_id")); a.setRecord_time(rs.getTimestamp("record_time")); a.setEle_heater_contol_panel_q55(rs.getFloat("ele_heater_contol_panel_q55")); a.setControl_reli_switchboard_12st_ar12(rs.getFloat("control_reli_switchboard_12st_ar12")); a.setLow_freq_power_cabinet(rs.getFloat("low_freq_power_cabinet")); a.setRefrigerator_control_panel(rs.getFloat("refrigerator_control_panel")); a.setControl_reli_switchboard_11st_ar11(rs.getFloat("control_reli_switchboard_11st_ar11")); a.setSafe_injection_pump(rs.getFloat("safe_injection_pump")); a.setCool_pump_2st_q57(rs.getFloat("cool_pump_2st_q57")); a.setCool_pump_3st_q58(rs.getFloat("cool_pump_3st_q58")); a.setControl_reli_switchboard_13st(rs.getFloat("control_reli_switchboard_13st")); a.setInverter_power_1st(rs.getFloat("inverter_power_1st")); a.setControl_cabin_switchboard_3st_ac53(rs.getFloat("control_cabin_switchboard_3st_ac53")); a.setControl_cabin_switchboard_1st(rs.getFloat("control_cabin_switchboard_1st")); a.setCool_pump_2st_q11(rs.getFloat("cool_pump_2st_q11")); a.setControl_cabin_switchboard_ac60(rs.getFloat("control_cabin_switchboard_ac60")); a.setControl_cabin_switchboard_4st_ac54(rs.getFloat("control_cabin_switchboard_4st_ac54")); a.setControl_cabin_switchboard_2st_ac52(rs.getFloat("control_cabin_switchboard_2st_ac52")); a.setEle_heater_contol_panel_q29(rs.getFloat("ele_heater_contol_panel_q29")); a.setCool_pump_3st_q22(rs.getFloat("cool_pump_3st_q22")); a.setInverter_power_2st(rs.getFloat("inverter_power_2st")); a.setCool_pump_1st_q67(rs.getFloat("cool_pump_1st_q67")); a.setCool_pump_4st_q68(rs.getFloat("cool_pump_4st_q68")); a.setControl_reli_switchboard_23st_ar23(rs.getFloat("control_reli_switchboard_23st_ar23")); a.setControl_reli_switchboard_22st_ar22(rs.getFloat("control_reli_switchboard_22st_ar22")); a.setControl_reli_switchboard_21st_ar21(rs.getFloat("control_reli_switchboard_21st_ar21")); a.setInverter_power_4st(rs.getFloat("inverter_power_4st")); a.setControl_cabin_switchboard_Ⅱ_ac20(rs.getFloat("control_cabin_switchboard_Ⅱ_ac20")); a.setCool_pump_1st_q33(rs.getFloat("cool_pump_1st_q33")); a.setInverter_power_3st(rs.getFloat("inverter_power_3st")); a.setCool_pump_4st_q44(rs.getFloat("cool_pump_4st_q44")); a.setControl_cabin_switchboard_Ⅲ_ac30(rs.getFloat("control_cabin_switchboard_Ⅲ_ac30")); a.setControl_cabin_switchboard_Ⅰ_ac10(rs.getFloat("control_cabin_switchboard_Ⅰ_ac10")); a.setBack01(rs.getFloat("back01")); a.setReli_insulat_res(rs.getFloat("reli_insulat_res")); a.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); a.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); a.setBack02(rs.getFloat("back02")); list.add(a); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //设备实时数据显示(前100笔数据服务器的时间) @Override public List serchByInfo(Object obj) { Acinsulation ai=(Acinsulation) obj; Date date=new Date(); String table=DAOHelper.sdf_withOut.format(date); String sql=" select * from db_partinsystem_history.acinsulation_"+ai.getDev_id()+"_"+table+" where dev_id=? limit 0,100"; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ai.getDev_id()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Acinsulation a=new Acinsulation(); a.setDev_id(rs.getInt("dev_id")); a.setRecord_time(rs.getTimestamp("record_time")); a.setEle_heater_contol_panel_q55(rs.getFloat("ele_heater_contol_panel_q55")); a.setControl_reli_switchboard_12st_ar12(rs.getFloat("control_reli_switchboard_12st_ar12")); a.setLow_freq_power_cabinet(rs.getFloat("low_freq_power_cabinet")); a.setRefrigerator_control_panel(rs.getFloat("refrigerator_control_panel")); a.setControl_reli_switchboard_11st_ar11(rs.getFloat("control_reli_switchboard_11st_ar11")); a.setSafe_injection_pump(rs.getFloat("safe_injection_pump")); a.setCool_pump_2st_q57(rs.getFloat("cool_pump_2st_q57")); a.setCool_pump_3st_q58(rs.getFloat("cool_pump_3st_q58")); a.setControl_reli_switchboard_13st(rs.getFloat("control_reli_switchboard_13st")); a.setInverter_power_1st(rs.getFloat("inverter_power_1st")); a.setControl_cabin_switchboard_3st_ac53(rs.getFloat("control_cabin_switchboard_3st_ac53")); a.setControl_cabin_switchboard_1st(rs.getFloat("control_cabin_switchboard_1st")); a.setCool_pump_2st_q11(rs.getFloat("cool_pump_2st_q11")); a.setControl_cabin_switchboard_ac60(rs.getFloat("control_cabin_switchboard_ac60")); a.setControl_cabin_switchboard_4st_ac54(rs.getFloat("control_cabin_switchboard_4st_ac54")); a.setControl_cabin_switchboard_2st_ac52(rs.getFloat("control_cabin_switchboard_2st_ac52")); a.setEle_heater_contol_panel_q29(rs.getFloat("ele_heater_contol_panel_q29")); a.setCool_pump_3st_q22(rs.getFloat("cool_pump_3st_q22")); a.setInverter_power_2st(rs.getFloat("inverter_power_2st")); a.setCool_pump_1st_q67(rs.getFloat("cool_pump_1st_q67")); a.setCool_pump_4st_q68(rs.getFloat("cool_pump_4st_q68")); a.setControl_reli_switchboard_23st_ar23(rs.getFloat("control_reli_switchboard_23st_ar23")); a.setControl_reli_switchboard_22st_ar22(rs.getFloat("control_reli_switchboard_22st_ar22")); a.setControl_reli_switchboard_21st_ar21(rs.getFloat("control_reli_switchboard_21st_ar21")); a.setInverter_power_4st(rs.getFloat("inverter_power_4st")); a.setControl_cabin_switchboard_Ⅱ_ac20(rs.getFloat("control_cabin_switchboard_Ⅱ_ac20")); a.setCool_pump_1st_q33(rs.getFloat("cool_pump_1st_q33")); a.setInverter_power_3st(rs.getFloat("inverter_power_3st")); a.setCool_pump_4st_q44(rs.getFloat("cool_pump_4st_q44")); a.setControl_cabin_switchboard_Ⅲ_ac30(rs.getFloat("control_cabin_switchboard_Ⅲ_ac30")); a.setControl_cabin_switchboard_Ⅰ_ac10(rs.getFloat("control_cabin_switchboard_Ⅰ_ac10")); a.setBack01(rs.getFloat("back01")); a.setReli_insulat_res(rs.getFloat("reli_insulat_res")); a.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); a.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); a.setBack02(rs.getFloat("back02")); list.add(a); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //设备历史数据查询 public List serchHistory(Object obj) { Acinsulation ai=(Acinsulation) obj; String table=DAOHelper.sdf_withOut.format(ai.getRecord_time()); String sql=" select * from db_partinsystem_history.acinsulation_"+ai.getDev_id()+"_"+table+" " + " where dev_id=? and record_time >= ? and record_time <= ? order by record_time asc "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ai.getDev_id(),ai.getRecord_time(),ai.getRecord_time1()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Acinsulation a=new Acinsulation(); a.setDev_id(rs.getInt("dev_id")); a.setRecord_time(rs.getTimestamp("record_time")); a.setEle_heater_contol_panel_q55(rs.getFloat("ele_heater_contol_panel_q55")); a.setControl_reli_switchboard_12st_ar12(rs.getFloat("control_reli_switchboard_12st_ar12")); a.setLow_freq_power_cabinet(rs.getFloat("low_freq_power_cabinet")); a.setRefrigerator_control_panel(rs.getFloat("refrigerator_control_panel")); a.setControl_reli_switchboard_11st_ar11(rs.getFloat("control_reli_switchboard_11st_ar11")); a.setSafe_injection_pump(rs.getFloat("safe_injection_pump")); a.setCool_pump_2st_q57(rs.getFloat("cool_pump_2st_q57")); a.setCool_pump_3st_q58(rs.getFloat("cool_pump_3st_q58")); a.setControl_reli_switchboard_13st(rs.getFloat("control_reli_switchboard_13st")); a.setInverter_power_1st(rs.getFloat("inverter_power_1st")); a.setControl_cabin_switchboard_3st_ac53(rs.getFloat("control_cabin_switchboard_3st_ac53")); a.setControl_cabin_switchboard_1st(rs.getFloat("control_cabin_switchboard_1st")); a.setCool_pump_2st_q11(rs.getFloat("cool_pump_2st_q11")); a.setControl_cabin_switchboard_ac60(rs.getFloat("control_cabin_switchboard_ac60")); a.setControl_cabin_switchboard_4st_ac54(rs.getFloat("control_cabin_switchboard_4st_ac54")); a.setControl_cabin_switchboard_2st_ac52(rs.getFloat("control_cabin_switchboard_2st_ac52")); a.setEle_heater_contol_panel_q29(rs.getFloat("ele_heater_contol_panel_q29")); a.setCool_pump_3st_q22(rs.getFloat("cool_pump_3st_q22")); a.setInverter_power_2st(rs.getFloat("inverter_power_2st")); a.setCool_pump_1st_q67(rs.getFloat("cool_pump_1st_q67")); a.setCool_pump_4st_q68(rs.getFloat("cool_pump_4st_q68")); a.setControl_reli_switchboard_23st_ar23(rs.getFloat("control_reli_switchboard_23st_ar23")); a.setControl_reli_switchboard_22st_ar22(rs.getFloat("control_reli_switchboard_22st_ar22")); a.setControl_reli_switchboard_21st_ar21(rs.getFloat("control_reli_switchboard_21st_ar21")); a.setInverter_power_4st(rs.getFloat("inverter_power_4st")); a.setControl_cabin_switchboard_Ⅱ_ac20(rs.getFloat("control_cabin_switchboard_Ⅱ_ac20")); a.setCool_pump_1st_q33(rs.getFloat("cool_pump_1st_q33")); a.setInverter_power_3st(rs.getFloat("inverter_power_3st")); a.setCool_pump_4st_q44(rs.getFloat("cool_pump_4st_q44")); a.setControl_cabin_switchboard_Ⅲ_ac30(rs.getFloat("control_cabin_switchboard_Ⅲ_ac30")); a.setControl_cabin_switchboard_Ⅰ_ac10(rs.getFloat("control_cabin_switchboard_Ⅰ_ac10")); a.setBack01(rs.getFloat("back01")); a.setReli_insulat_res(rs.getFloat("reli_insulat_res")); a.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); a.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); a.setBack02(rs.getFloat("back02")); list.add(a); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //文件导出时的历史查询 public List serchCSV(Object obj) { final Acinsulation ai=(Acinsulation) obj; String tablists=ai.getNote()+",record_time"; String table=DAOHelper.sdf_withOut.format(ai.getRecord_time()); String table1=DAOHelper.sdf_withOut.format(ai.getRecord_time1()); String SqlAll=""; String sql=" (select "+tablists+" from db_partinsystem_history.acinsulation_"+ai.getDev_id()+"_"+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.acinsulation_"+ai.getDev_id()+"_"+table1+" " + " where record_time >= ? and record_time <= ? order by record_time asc )"; Object[] strarr=null; List list=new ArrayList(); String st=ai.getDev_id()+"_"+table; String st1=ai.getDev_id()+"_"+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(ai.getRecord_time()),DAOHelper.sdf.format(ai.getRecord_time1())}; }else{ SqlAll=sql+sql_union+sql1; strarr=new Object[]{DAOHelper.sdf.format(ai.getRecord_time()),DAOHelper.sdfwithOut.format(ai.getRecord_time())+" 23:59:59",DAOHelper.sdfwithOut.format(ai.getRecord_time())+" 00:00:00",DAOHelper.sdf.format(ai.getRecord_time1())}; } } //存在一个表 if(size>0&&size1<=0){ SqlAll=sql; strarr=new Object[]{DAOHelper.sdf.format(ai.getRecord_time()),DAOHelper.sdfwithOut.format(ai.getRecord_time())+" 23:59:59"}; } if(size<=0&&size1>0){ SqlAll=sql1; strarr=new Object[]{DAOHelper.sdfwithOut.format(ai.getRecord_time1())+" 00:00:00",DAOHelper.sdf.format(ai.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=ai.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; } } DyEnvir_system/src/com/fgkj/partinsystem/impl/DcinsulationImpl.java
New file @@ -0,0 +1,316 @@ package com.fgkj.partinsystem.impl; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.Date; import java.util.List; 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; public class DcinsulationImpl implements BaseDAO,CallBack{ @Override public List getResults(ResultSet rs) { // TODO Auto-generated method stub return null; } @Override public boolean add(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean update(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean del(Object obj) { // TODO Auto-generated method stub return false; } @Override public List searchAll() { // TODO Auto-generated method stub return null; } //根据参试设备id查询设备的实时数据 @Override public List serchByCondition(Object obj) { Dcinsulation di=(Dcinsulation) obj; String sql=" select * from db_partinsystem.dcinsulation where dev_id=? "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{di.getDev_id()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Dcinsulation d=new Dcinsulation(); d.setDev_id(rs.getInt("dev_id")); d.setRecord_time(rs.getTimestamp("record_time")); d.setMotor_branch1(rs.getFloat("motor_branch1")); d.setInverter_power_1st(rs.getFloat("inverter_power_1st")); d.setBack_branch1(rs.getFloat("back_branch1")); d.setDc25v_1st(rs.getFloat("dc25v_1st")); d.setDc230v_1st(rs.getFloat("dc230v_1st")); d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1")); d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2")); d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st")); d.setMotor_branch2(rs.getFloat("motor_branch2")); d.setInverter_power_2st(rs.getFloat("inverter_power_2st")); d.setBack_branch2(rs.getFloat("back_branch2")); d.setDc230v_2st(rs.getFloat("dc230v_2st")); d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1")); d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2")); d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st")); d.setControl_power_1st(rs.getFloat("control_power_1st")); d.setBack_branch3(rs.getFloat("back_branch3")); d.setInverter_power_3st(rs.getFloat("inverter_power_3st")); d.setDc25v_3st(rs.getFloat("dc25v_3st")); d.setDc230v_3st(rs.getFloat("dc230v_3st")); d.setDc25v_2st(rs.getFloat("dc25v_2st")); d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark")); d.setControl_power_2st(rs.getFloat("control_power_2st")); d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st")); d.setBack_branch4(rs.getFloat("back_branch4")); d.setInverter_power_4st(rs.getFloat("inverter_power_4st")); d.setDc25v_4st(rs.getFloat("dc25v_4st")); d.setDc230v_4st(rs.getFloat("dc230v_4st")); d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator")); d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st")); d.setBack01(rs.getFloat("back01")); d.setBack02(rs.getFloat("back02")); d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); d.setBack03(rs.getFloat("back03")); d.setBack04(rs.getFloat("back04")); list.add(d); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //设备实时数据显示(前100笔数据服务器的时间) @Override public List serchByInfo(Object obj) { Dcinsulation di=(Dcinsulation) obj; Date date=new Date(); String table=DAOHelper.sdf_withOut.format(date); String sql=" select * from db_partinsystem_history.dcinsulation_"+di.getDev_id()+"_"+table+" where dev_id=? limit 0,100"; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{di.getDev_id()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Dcinsulation d=new Dcinsulation(); d.setDev_id(rs.getInt("dev_id")); d.setRecord_time(rs.getTimestamp("record_time")); d.setMotor_branch1(rs.getFloat("motor_branch1")); d.setInverter_power_1st(rs.getFloat("inverter_power_1st")); d.setBack_branch1(rs.getFloat("back_branch1")); d.setDc25v_1st(rs.getFloat("dc25v_1st")); d.setDc230v_1st(rs.getFloat("dc230v_1st")); d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1")); d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2")); d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st")); d.setMotor_branch2(rs.getFloat("motor_branch2")); d.setInverter_power_2st(rs.getFloat("inverter_power_2st")); d.setBack_branch2(rs.getFloat("back_branch2")); d.setDc230v_2st(rs.getFloat("dc230v_2st")); d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1")); d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2")); d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st")); d.setControl_power_1st(rs.getFloat("control_power_1st")); d.setBack_branch3(rs.getFloat("back_branch3")); d.setInverter_power_3st(rs.getFloat("inverter_power_3st")); d.setDc25v_3st(rs.getFloat("dc25v_3st")); d.setDc230v_3st(rs.getFloat("dc230v_3st")); d.setDc25v_2st(rs.getFloat("dc25v_2st")); d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark")); d.setControl_power_2st(rs.getFloat("control_power_2st")); d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st")); d.setBack_branch4(rs.getFloat("back_branch4")); d.setInverter_power_4st(rs.getFloat("inverter_power_4st")); d.setDc25v_4st(rs.getFloat("dc25v_4st")); d.setDc230v_4st(rs.getFloat("dc230v_4st")); d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator")); d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st")); d.setBack01(rs.getFloat("back01")); d.setBack02(rs.getFloat("back02")); d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); d.setBack03(rs.getFloat("back03")); d.setBack04(rs.getFloat("back04")); list.add(d); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //设备历史数据查询 public List serchHistory(Object obj) { Dcinsulation di=(Dcinsulation) obj; String table=DAOHelper.sdf_withOut.format(di.getRecord_time()); String sql=" select * from db_partinsystem_history.dcinsulation_"+di.getDev_id()+"_"+table+" " + " where dev_id=? and record_time >= ? and record_time <= ? order by record_time asc "; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{di.getDev_id(),di.getRecord_time(),di.getRecord_time1()}, new CallBack() { @Override public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Dcinsulation d=new Dcinsulation(); d.setDev_id(rs.getInt("dev_id")); d.setRecord_time(rs.getTimestamp("record_time")); d.setMotor_branch1(rs.getFloat("motor_branch1")); d.setInverter_power_1st(rs.getFloat("inverter_power_1st")); d.setBack_branch1(rs.getFloat("back_branch1")); d.setDc25v_1st(rs.getFloat("dc25v_1st")); d.setDc230v_1st(rs.getFloat("dc230v_1st")); d.setWaterpump1st_ark1(rs.getFloat("waterpump1st_ark1")); d.setWaterpump1st_ark2(rs.getFloat("waterpump1st_ark2")); d.setInverter_power_stream_1st(rs.getFloat("inverter_power_stream_1st")); d.setMotor_branch2(rs.getFloat("motor_branch2")); d.setInverter_power_2st(rs.getFloat("inverter_power_2st")); d.setBack_branch2(rs.getFloat("back_branch2")); d.setDc230v_2st(rs.getFloat("dc230v_2st")); d.setWaterpump2st_ark1(rs.getFloat("waterpump2st_ark1")); d.setWaterpump2st_ark2(rs.getFloat("waterpump2st_ark2")); d.setInverter_power_stream_2st(rs.getFloat("inverter_power_stream_2st")); d.setControl_power_1st(rs.getFloat("control_power_1st")); d.setBack_branch3(rs.getFloat("back_branch3")); d.setInverter_power_3st(rs.getFloat("inverter_power_3st")); d.setDc25v_3st(rs.getFloat("dc25v_3st")); d.setDc230v_3st(rs.getFloat("dc230v_3st")); d.setDc25v_2st(rs.getFloat("dc25v_2st")); d.setBalance_pump_inverter_ark(rs.getFloat("balance_pump_inverter_ark")); d.setControl_power_2st(rs.getFloat("control_power_2st")); d.setBatt_switch_board_1st(rs.getFloat("batt_switch_board_1st")); d.setBack_branch4(rs.getFloat("back_branch4")); d.setInverter_power_4st(rs.getFloat("inverter_power_4st")); d.setDc25v_4st(rs.getFloat("dc25v_4st")); d.setDc230v_4st(rs.getFloat("dc230v_4st")); d.setEle_water_oxygen_generator(rs.getFloat("ele_water_oxygen_generator")); d.setBatt_switch_board_2st(rs.getFloat("batt_switch_board_2st")); d.setBack01(rs.getFloat("back01")); d.setBack02(rs.getFloat("back02")); d.setDc_distri_insulat_res1(rs.getFloat("dc_distri_insulat_res1")); d.setDc_distri_insulat_res2(rs.getFloat("dc_distri_insulat_res2")); d.setBack03(rs.getFloat("back03")); d.setBack04(rs.getFloat("back04")); list.add(d); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } //文件导出时的历史查询 public List serchCSV(Object obj) { final Dcinsulation di=(Dcinsulation) obj; String tablists=di.getNote()+",record_time"; String table=DAOHelper.sdf_withOut.format(di.getRecord_time()); String table1=DAOHelper.sdf_withOut.format(di.getRecord_time1()); String SqlAll=""; String sql=" (select "+tablists+" from db_partinsystem_history.dcinsulation_"+di.getDev_id()+"_"+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.dcinsulation_"+di.getDev_id()+"_"+table1+" " + " where record_time >= ? and record_time <= ? order by record_time asc )"; Object[] strarr=null; List list=new ArrayList(); String st=di.getDev_id()+"_"+table; String st1=di.getDev_id()+"_"+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(di.getRecord_time()),DAOHelper.sdf.format(di.getRecord_time1())}; }else{ SqlAll=sql+sql_union+sql1; strarr=new Object[]{DAOHelper.sdf.format(di.getRecord_time()),DAOHelper.sdfwithOut.format(di.getRecord_time())+" 23:59:59",DAOHelper.sdfwithOut.format(di.getRecord_time())+" 00:00:00",DAOHelper.sdf.format(di.getRecord_time1())}; } } //存在一个表 if(size>0&&size1<=0){ SqlAll=sql; strarr=new Object[]{DAOHelper.sdf.format(di.getRecord_time()),DAOHelper.sdfwithOut.format(di.getRecord_time())+" 23:59:59"}; } if(size<=0&&size1>0){ SqlAll=sql1; strarr=new Object[]{DAOHelper.sdfwithOut.format(di.getRecord_time1())+" 00:00:00",DAOHelper.sdf.format(di.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=di.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; } } DyEnvir_system/src/com/fgkj/partinsystem/service/AcinsulationService.java
New file @@ -0,0 +1,59 @@ package com.fgkj.partinsystem.service; import java.util.List; import com.fgkj.dao.BaseDAO; import com.fgkj.dao.BaseDAOFactory; import com.fgkj.partinsystem.impl.AcinsulationImpl; import com.fgkj.services.ServiceModel; public class AcinsulationService { private BaseDAO dao; private ServiceModel model; public AcinsulationService() { super(); this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.ACINSULATION); this.model=new ServiceModel(); } //根据参试设备id查询设备的实时数据 public ServiceModel serchByCondition(Object obj) { List list=dao.serchByCondition(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setData(list); model.setMsg("查询成功!"); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } //设备实时数据显示(前100笔数据服务器的时间) 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; } //设备历史数据查询 public ServiceModel serchHistory(Object obj) { List list=((AcinsulationImpl)dao).serchHistory(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setData(list); model.setMsg("查询成功!"); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } } DyEnvir_system/src/com/fgkj/partinsystem/service/DcinsulationService.java
New file @@ -0,0 +1,59 @@ package com.fgkj.partinsystem.service; import java.util.List; import com.fgkj.dao.BaseDAO; import com.fgkj.dao.BaseDAOFactory; import com.fgkj.partinsystem.impl.DcinsulationImpl; import com.fgkj.services.ServiceModel; public class DcinsulationService { private BaseDAO dao; private ServiceModel model; public DcinsulationService() { super(); this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.DCINSULATION); this.model=new ServiceModel(); } //根据参试设备id查询设备的实时数据 public ServiceModel serchByCondition(Object obj) { List list=dao.serchByCondition(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setData(list); model.setMsg("查询成功!"); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } //设备实时数据显示(前100笔数据服务器的时间) 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; } //设备历史数据查询 public ServiceModel serchHistory(Object obj) { List list=((DcinsulationImpl)dao).serchHistory(obj); if(list!=null&&list.size()>0){ model.setCode(1); model.setData(list); model.setMsg("查询成功!"); }else{ model.setCode(0); model.setMsg("查询失败!"); } return model; } }