修改

whyclxw

2020-10-30 64baa19cebaf8d29a89e5e163b0b34193e30a623

修改

 DyEnvir_system/src/com/fgkj/actions/partinsystem/Ac230v_upsAction.java

New file
@@ -0,0 +1,36 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Ac230v_ups;
import com.fgkj.partinsystem.service.Ac230v_upsService;
import com.fgkj.services.ServiceModel;

public class Ac230v_upsAction extends ActionUtil{
    private Ac230v_upsService service=new Ac230v_upsService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Ac230v_ups ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Ac230v_ups.class);
        ServiceModel model=service.serchByCondition(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/Cabin_boardAction.java

New file
@@ -0,0 +1,35 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Cabin_board;
import com.fgkj.partinsystem.service.Cabin_boardService;
import com.fgkj.services.ServiceModel;

public class Cabin_boardAction extends ActionUtil{
    private Cabin_boardService service=new Cabin_boardService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Cabin_board ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Cabin_board.class);
        ServiceModel model=service.serchByCondition(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/Centra_frequencyAction.java

New file
@@ -0,0 +1,35 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Centra_frequency;
import com.fgkj.partinsystem.service.Centra_frequencyService;
import com.fgkj.services.ServiceModel;

public class Centra_frequencyAction extends ActionUtil{
    private Centra_frequencyService service=new Centra_frequencyService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Centra_frequency ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Centra_frequency.class);
        ServiceModel model=service.serchByCondition(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/Dc230v_battAction.java

New file
@@ -0,0 +1,34 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Dc230v_batt;
import com.fgkj.partinsystem.service.Dc230v_battService;
import com.fgkj.services.ServiceModel;

public class Dc230v_battAction extends ActionUtil{
    private Dc230v_battService service=new Dc230v_battService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Dc230v_batt ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Dc230v_batt.class);
        ServiceModel model=service.serchByCondition(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/Dc25v_battAction.java

New file
@@ -0,0 +1,35 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Dc25v_batt;
import com.fgkj.partinsystem.service.Dc25v_battService;
import com.fgkj.services.ServiceModel;

public class Dc25v_battAction extends ActionUtil{
    private Dc25v_battService service=new Dc25v_battService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Dc25v_batt ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Dc25v_batt.class);
        ServiceModel model=service.serchByCondition(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/Electrical_monitor_stationAction.java

New file
@@ -0,0 +1,35 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Electrical_monitor_station;
import com.fgkj.partinsystem.service.Electrical_monitor_stationService;
import com.fgkj.services.ServiceModel;

public class Electrical_monitor_stationAction extends ActionUtil{
    private Electrical_monitor_stationService service=new Electrical_monitor_stationService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Electrical_monitor_station ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Electrical_monitor_station.class);
        ServiceModel model=service.serchByCondition(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/Inverter_eleAction.java

New file
@@ -0,0 +1,34 @@
package com.fgkj.actions.partinsystem;

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Inverter_ele;
import com.fgkj.partinsystem.service.Inverter_eleService;
import com.fgkj.services.ServiceModel;

public class Inverter_eleAction extends ActionUtil{
    private Inverter_eleService service=new Inverter_eleService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Inverter_ele ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Inverter_ele.class);
        ServiceModel model=service.serchByCondition(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

@@ -110,6 +110,15 @@
    
    //参试设备
    public static final int  PARTINSYSTEM_INF=55;
    public static final int  AC230V_UPS=56;
    public static final int  CABIN_BOARD=57;
    public static final int  CENTRA_FREQUENCY=58;
    public static final int  DC230V_BATT=59;
    public static final int  DC25V_BATT=60;
    public static final int  ELECTRICAL_MONITOR_STATION=61;
    public static final int  INVERTER_ELE=62;
    public static final int  MEDVOLDC_CONVERTER=63;
    public static final int  RELIABLE_BOARD=64;
    
        
    public boolean add(Object obj); // 添加

 DyEnvir_system/src/com/fgkj/dao/BaseDAOFactory.java

@@ -51,6 +51,13 @@
import com.fgkj.elemachinery.impl.Motor_infImpl;
import com.fgkj.elemachinery.impl.Motor_readdataImpl;
import com.fgkj.elemachinery.impl.Subject_motor_stateImpl;
import com.fgkj.partinsystem.impl.Ac230v_upsImpl;
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.Electrical_monitor_stationImpl;
import com.fgkj.partinsystem.impl.Inverter_eleImpl;
import com.fgkj.partinsystem.impl.Partinsystem_infImpl;
import com.fgkj.tmphum.impl.Tmphum_rtImpl;
import com.fgkj.watersystem.Impl.Water_alarmImpl;
@@ -128,6 +135,15 @@
        
        //参试设备
        case 55:return new Partinsystem_infImpl();
        case 56:return new Ac230v_upsImpl();
        case 57:return new Cabin_boardImpl();
        case 58:return new Centra_frequencyImpl();
        case 59:return new Dc230v_battImpl();
        case 60:return new Dc25v_battImpl();
        case 61:return new Electrical_monitor_stationImpl();
        case 62:return new Inverter_eleImpl();
        case 63:return new Partinsystem_infImpl();
        case 64:return new Partinsystem_infImpl();
        default :return null;
        }
    }

 DyEnvir_system/src/com/fgkj/partinsystem/dto/Ac230v_ups.java

@@ -1,11 +1,12 @@
package com.fgkj.partinsystem.dto;

import java.io.Serializable;
import java.util.Date;

public class Ac230v_ups implements Serializable{
      private int num  ;//,
      private int dev_id ;// '设备id',
      private float record_time  ;//'2000-01-01 00:00:00' ON UPDATE CURRENT_TIMESTAMP,
      private Date record_time  ;//'2000-01-01 00:00:00' ON UPDATE CURRENT_TIMESTAMP,
      private float DCInput_vol;// '直流输入电压',
      private float ACInput_vol;// '交流输入电压',
      private float batt_vol;// '蓄电池电压',
@@ -37,10 +38,11 @@
    public void setDev_id(int dev_id) {
        this.dev_id = dev_id;
    }
    public float getRecord_time() {
	
    public Date getRecord_time() {
        return record_time;
    }
    public void setRecord_time(float record_time) {
    public void setRecord_time(Date record_time) {
        this.record_time = record_time;
    }
    public float getDCInput_vol() {

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Ac230v_upsImpl.java

New file
@@ -0,0 +1,97 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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;

public class Ac230v_upsImpl 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) {
        Ac230v_ups ac=(Ac230v_ups) obj;
        String sql=" select * from db_partinsystem.ac230v_ups where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ac.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Ac230v_ups a=new Ac230v_ups();
                        a.setDev_id(rs.getInt("dev_id"));
                        a.setRecord_time(rs.getTimestamp("record_time"));
                        a.setDCInput_vol(rs.getFloat("dCInput_vol"));
                        a.setACInput_vol(rs.getFloat("aCInput_vol"));
                        a.setBatt_vol(rs.getFloat("batt_vol"));
                        a.setBatt_curr(rs.getFloat("batt_curr"));
                        a.setACOutput_vol(rs.getFloat("aCOutput_vol"));
                        a.setACOutput_curr(rs.getFloat("aCOutput_curr"));
                        a.setDCOutput_vol(rs.getFloat("dCOutput_vol"));
                        a.setDCBus_vol(rs.getFloat("dCBus_vol"));
                        a.setRadiator_tmp(rs.getFloat("radiator_tmp"));
                        a.setThyristor_tmp(rs.getFloat("thyristor_tmp"));
                        a.setTransfor_tmp(rs.getFloat("transfor_tmp"));
                        a.setACInduc_tmp(rs.getFloat("aCInduc_tmp"));
                        a.setDCInduc_tmp(rs.getFloat("dCInduc_tmp"));
                        a.setEnviron_tmp(rs.getFloat("environ_tmp"));
                        a.setPower_state_code(rs.getInt("power_state_code"));
                        a.setError_code(rs.getInt("error_code"));
                        a.setWork_state(rs.getInt("work_state"));
                        a.setFault_state(rs.getInt("fault_state"));

                        list.add(a);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Cabin_boardImpl.java

New file
@@ -0,0 +1,213 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Cabin_board;

public class Cabin_boardImpl 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) {
        Cabin_board cb=(Cabin_board) obj;
        String sql=" select * from db_partinsystem.cabin_board where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{cb.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Cabin_board c=new Cabin_board();
                        c.setDev_id(rs.getInt("dev_id"));
                        c.setRecord_time(rs.getTimestamp("record_time"));
                        c.setThreeAB_vol(rs.getFloat("threeAB_vol"));
                        c.setThreeBC_vol(rs.getFloat("threeBC_vol"));
                        c.setThreeCA_vol(rs.getFloat("threeCA_vol"));
                        c.setQ1F(rs.getFloat("q1f"));
                        c.setQ1currA(rs.getFloat("q1currA"));
                        c.setQ1currB(rs.getFloat("q1currB"));
                        c.setQ1currC(rs.getFloat("q1currC"));
                        c.setQ1power_active(rs.getFloat("q1power_active"));
                        c.setQ1power_apparent(rs.getFloat("q1power_apparent"));
                        c.setQ1power_factor(rs.getFloat("q1power_factor"));
                        c.setQ1circuit_state(rs.getInt("q1circuit_state"));
                        c.setQ1ele_state(rs.getInt("q1ele_state"));
                        c.setQ1event_state(rs.getInt("q1event_state"));

                        c.setQ1F(rs.getFloat("q2f"));
                        c.setQ2currA(rs.getFloat("q2currA"));
                        c.setQ2currB(rs.getFloat("q2currB"));
                        c.setQ2currC(rs.getFloat("q2currC"));
                        c.setQ2power_active(rs.getFloat("q2power_active"));
                        c.setQ2power_apparent(rs.getFloat("q2power_apparent"));
                        c.setQ2power_factor(rs.getFloat("q2power_factor"));
                        c.setQ2circuit_state(rs.getInt("q2circuit_state"));
                        c.setQ2ele_state(rs.getInt("q2ele_state"));
                        c.setQ2event_state(rs.getInt("q2event_state"));
						
                        c.setQ3F(rs.getFloat("q3f"));
                        c.setQ3currA(rs.getFloat("q3currA"));
                        c.setQ3currB(rs.getFloat("q3currB"));
                        c.setQ3currC(rs.getFloat("q3currC"));
                        c.setQ3power_active(rs.getFloat("q3power_active"));
                        c.setQ3power_apparent(rs.getFloat("q3power_apparent"));
                        c.setQ3power_factor(rs.getFloat("q3power_factor"));
                        c.setQ3circuit_state(rs.getInt("q3circuit_state"));
                        c.setQ3ele_state(rs.getInt("q3ele_state"));
                        c.setQ3event_state(rs.getInt("q3event_state"));
						
                        c.setQ4F(rs.getFloat("q4f"));
                        c.setQ4currA(rs.getFloat("q4currA"));
                        c.setQ4currB(rs.getFloat("q4currB"));
                        c.setQ4currC(rs.getFloat("q4currC"));
                        c.setQ4power_active(rs.getFloat("q4power_active"));
                        c.setQ4power_apparent(rs.getFloat("q4power_apparent"));
                        c.setQ4power_factor(rs.getFloat("q4power_factor"));
                        c.setQ4circuit_state(rs.getInt("q4circuit_state"));
                        c.setQ4ele_state(rs.getInt("q4ele_state"));
                        c.setQ4event_state(rs.getInt("q4event_state"));
						
                        c.setQ5F(rs.getFloat("q5f"));
                        c.setQ5currA(rs.getFloat("q5currA"));
                        c.setQ5currB(rs.getFloat("q5currB"));
                        c.setQ5currC(rs.getFloat("q5currC"));
                        c.setQ5power_active(rs.getFloat("q5power_active"));
                        c.setQ5power_apparent(rs.getFloat("q5power_apparent"));
                        c.setQ5power_factor(rs.getFloat("q5power_factor"));
                        c.setQ5circuit_state(rs.getInt("q5circuit_state"));
                        c.setQ5ele_state(rs.getInt("q5ele_state"));
                        c.setQ5event_state(rs.getInt("q5event_state"));
						
                        c.setQ6F(rs.getFloat("q6f"));
                        c.setQ6currA(rs.getFloat("q6currA"));
                        c.setQ6currB(rs.getFloat("q6currB"));
                        c.setQ6currC(rs.getFloat("q6currC"));
                        c.setQ6power_active(rs.getFloat("q6power_active"));
                        c.setQ6power_apparent(rs.getFloat("q6power_apparent"));
                        c.setQ6power_factor(rs.getFloat("q6power_factor"));
                        c.setQ6circuit_state(rs.getInt("q6circuit_state"));
                        c.setQ6ele_state(rs.getInt("q6ele_state"));
                        c.setQ6event_state(rs.getInt("q6event_state"));
						
                        c.setQ7F(rs.getFloat("q7f"));
                        c.setQ7currA(rs.getFloat("q7currA"));
                        c.setQ7currB(rs.getFloat("q7currB"));
                        c.setQ7currC(rs.getFloat("q7currC"));
                        c.setQ7power_active(rs.getFloat("q7power_active"));
                        c.setQ7power_apparent(rs.getFloat("q7power_apparent"));
                        c.setQ7power_factor(rs.getFloat("q7power_factor"));
                        c.setQ7circuit_state(rs.getInt("q7circuit_state"));
                        c.setQ7ele_state(rs.getInt("q7ele_state"));
                        c.setQ7event_state(rs.getInt("q7event_state"));
						
                        c.setQ8F(rs.getFloat("q8f"));
                        c.setQ8currA(rs.getFloat("q8currA"));
                        c.setQ8currB(rs.getFloat("q8currB"));
                        c.setQ8currC(rs.getFloat("q8currC"));
                        c.setQ8power_active(rs.getFloat("q8power_active"));
                        c.setQ8power_apparent(rs.getFloat("q8power_apparent"));
                        c.setQ8power_factor(rs.getFloat("q8power_factor"));
                        c.setQ8circuit_state(rs.getInt("q8circuit_state"));
                        c.setQ8ele_state(rs.getInt("q8ele_state"));
                        c.setQ8event_state(rs.getInt("q8event_state"));
						
                        c.setQ9F(rs.getFloat("q9f"));
                        c.setQ9currA(rs.getFloat("q9currA"));
                        c.setQ9currB(rs.getFloat("q9currB"));
                        c.setQ9currC(rs.getFloat("q9currC"));
                        c.setQ9power_active(rs.getFloat("q9power_active"));
                        c.setQ9power_apparent(rs.getFloat("q9power_apparent"));
                        c.setQ9power_factor(rs.getFloat("q9power_factor"));
                        c.setQ9circuit_state(rs.getInt("q9circuit_state"));
                        c.setQ9ele_state(rs.getInt("q9ele_state"));
                        c.setQ9event_state(rs.getInt("q9event_state"));
						
                        c.setQ10F(rs.getFloat("q10f"));
                        c.setQ10currA(rs.getFloat("q10currA"));
                        c.setQ10currB(rs.getFloat("q10currB"));
                        c.setQ10currC(rs.getFloat("q10currC"));
                        c.setQ10power_active(rs.getFloat("q10power_active"));
                        c.setQ10power_apparent(rs.getFloat("q10power_apparent"));
                        c.setQ10power_factor(rs.getFloat("q10power_factor"));
                        c.setQ10circuit_state(rs.getInt("q10circuit_state"));
                        c.setQ10ele_state(rs.getInt("q10ele_state"));
                        c.setQ10event_state(rs.getInt("q10event_state"));
						
                        c.setQ11F(rs.getFloat("q11f"));
                        c.setQ11currA(rs.getFloat("q11currA"));
                        c.setQ11currB(rs.getFloat("q11currB"));
                        c.setQ11currC(rs.getFloat("q11currC"));
                        c.setQ11power_active(rs.getFloat("q11power_active"));
                        c.setQ11power_apparent(rs.getFloat("q11power_apparent"));
                        c.setQ11power_factor(rs.getFloat("q11power_factor"));
                        c.setQ11circuit_state(rs.getInt("q11circuit_state"));
                        c.setQ11ele_state(rs.getInt("q11ele_state"));
                        c.setQ11event_state(rs.getInt("q11event_state"));
						
                        c.setQ12F(rs.getFloat("q12f"));
                        c.setQ12currA(rs.getFloat("q12currA"));
                        c.setQ12currB(rs.getFloat("q12currB"));
                        c.setQ12currC(rs.getFloat("q12currC"));
                        c.setQ12power_active(rs.getFloat("q12power_active"));
                        c.setQ12power_apparent(rs.getFloat("q12power_apparent"));
                        c.setQ12power_factor(rs.getFloat("q12power_factor"));
                        c.setQ12circuit_state(rs.getInt("q12circuit_state"));
                        c.setQ12ele_state(rs.getInt("q12ele_state"));
                        c.setQ12event_state(rs.getInt("q12event_state"));
						
                        list.add(c);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Centra_frequencyImpl.java

New file
@@ -0,0 +1,135 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Centra_frequency;

public class Centra_frequencyImpl 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) {
        Centra_frequency cf=(Centra_frequency) obj;
        String sql=" select * from db_partinsystem.centra_frequency where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{cf.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Centra_frequency c=new Centra_frequency();
                        c.setDev_id(rs.getInt("dev_id"));
                        c.setRecord_time(rs.getTimestamp("record_time"));
                        c.setUin1_vol(rs.getFloat("uin1_vol"));
                        c.setUin2_vol(rs.getFloat("uin2_vol"));
                        c.setIin1_curr(rs.getFloat("iin1_curr"));
                        c.setIin2_curr(rs.getFloat("iin2_curr"));
                        c.setProtigbt1_tmp(rs.getFloat("protigbt1_tmp"));
                        c.setProtigbt2_tmp(rs.getFloat("protigbt2_tmp"));
                        c.setProtigbt8_tmp(rs.getFloat("protigbt8_tmp"));
                        c.setTl1_tmp(rs.getFloat("tl1_tmp"));
                        c.setTl2_tmp(rs.getFloat("tl2_tmp"));
                        c.setTcab_tmp(rs.getFloat("tcab_tmp"));
                        c.setFlag(rs.getInt("flag"));
						
                        c.setVdc_up1_vol(rs.getFloat("vdc_up1_vol"));
                        c.setVdc_down1_vol(rs.getFloat("vdc_down1_vol"));
                        c.setUm1_in_vol(rs.getFloat("um1_in_vol"));
                        c.setIla1_curr(rs.getFloat("ila1_curr"));
                        c.setIlb1_curr(rs.getFloat("ilb1_curr"));
                        c.setIlc1_curr(rs.getFloat("ilc1_curr"));
                        c.setIoa1_curr(rs.getFloat("ioa1_curr"));
                        c.setIob1_curr(rs.getFloat("iob1_curr"));
                        c.setIoc1_curr(rs.getFloat("ioc1_curr"));
                        c.setUoab1_vol(rs.getFloat("uoab1_vol"));
                        c.setUobc1_vol(rs.getFloat("uobc1_vol"));
                        c.setUoca1_vol(rs.getFloat("uoca1_vol"));
                        c.setTigbt1_tmp(rs.getFloat("tigbt1_tmp"));
                        c.setTdiode1_tmp(rs.getFloat("tdiode1_tmp"));
                        c.setTlac1_tmp(rs.getFloat("tlac1_tmp"));
                        c.setTcac1_tmp(rs.getFloat("tcac1_tmp"));
                        c.setTcdc1_tmp(rs.getFloat("tcdc1_tmp"));
                        c.setM1_flag_state(rs.getInt("m1_flag_state"));
                        c.setPower1(rs.getFloat("power1"));
                        c.setF1(rs.getFloat("f1"));
                        c.setErrcode1(rs.getInt("errcode1"));
						
                        c.setVdc_up8_vol(rs.getFloat("vdc_up8_vol"));
                        c.setVdc_down8_vol(rs.getFloat("vdc_down8_vol"));
                        c.setUm_in8_vol(rs.getFloat("um_in8_vol"));
                        c.setIla8_curr(rs.getFloat("ila8_curr"));
                        c.setIlb8_curr(rs.getFloat("ilb8_curr"));
                        c.setIlc8_curr(rs.getFloat("ilc8_curr"));
                        c.setIoa8_curr(rs.getFloat("ioa8_curr"));
                        c.setIob8_curr(rs.getFloat("iob8_curr"));
                        c.setIoc8_curr(rs.getFloat("ioc8_curr"));
                        c.setUoab8_vol(rs.getFloat("uoab8_vol"));
                        c.setUobc8_vol(rs.getFloat("uobc8_vol"));
                        c.setUoca8_vol(rs.getFloat("uoca8_vol"));
                        c.setTigbt8_tmp(rs.getFloat("tigbt8_tmp"));
                        c.setTdiode8_tmp(rs.getFloat("tdiode8_tmp"));
                        c.setTlac8_tmp(rs.getFloat("tlac8_tmp"));
                        c.setTcac8_tmp(rs.getFloat("tcac8_tmp"));
                        c.setTcdc8_tmp(rs.getFloat("tcdc8_tmp"));
                        c.setM8_flag_state(rs.getInt("m8_flag_state"));
                        c.setPower8(rs.getFloat("power8"));
                        c.setF8(rs.getFloat("f8"));
                        c.setErrcode8(rs.getInt("errcode8"));
						
						
                        list.add(c);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Dc230v_battImpl.java

New file
@@ -0,0 +1,91 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Dc230v_batt;

public class Dc230v_battImpl 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) {
        Dc230v_batt dc=(Dc230v_batt) obj;
        String sql=" select * from db_partinsystem.dc230v_batt where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dc.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Dc230v_batt d=new Dc230v_batt();
                        d.setDev_id(rs.getInt("dev_id"));
                        d.setRecord_time(rs.getTimestamp("record_time"));
                        d.setOutput_vol(rs.getFloat("output_vol"));
                        d.setOutput_curr(rs.getFloat("output_curr"));
                        d.setInput_vol(rs.getFloat("input_vol"));
                        d.setInput_curr(rs.getFloat("input_curr"));
                        d.setBconn_CAN_comstate(rs.getInt("bconn_CAN_comstate"));
                        d.setWork_state(rs.getInt("work_state"));
                        d.setUnder_vol_alarm(rs.getInt("under_vol_alarm"));
                        d.setOver_vol_alarm(rs.getInt("over_vol_alarm"));
                        d.setOver_load_alarm(rs.getInt("over_load_alarm"));
                        d.setOver_tmp_alarm(rs.getInt("over_tmp_alarm"));
                        d.setShort_out_alarm(rs.getInt("short_out_alarm"));
						
						
                        list.add(d);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Dc25v_battImpl.java

New file
@@ -0,0 +1,92 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Dc230v_batt;
import com.fgkj.partinsystem.dto.Dc25v_batt;

public class Dc25v_battImpl 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查询设备的实时信息
    public List serchByCondition(Object obj) {
        Dc25v_batt dc=(Dc25v_batt) obj;
        String sql=" select * from db_partinsystem.dc25v_batt where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{dc.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Dc25v_batt d=new Dc25v_batt();
                        d.setDev_id(rs.getInt("dev_id"));
                        d.setRecord_time(rs.getTimestamp("record_time"));
                        d.setOutput_vol(rs.getFloat("output_vol"));
                        d.setOutput_curr(rs.getFloat("output_curr"));
                        d.setInput_vol(rs.getFloat("input_vol"));
                        d.setInput_curr(rs.getFloat("input_curr"));
                        d.setWork_state(rs.getInt("work_state"));
                        d.setUnder_vol_alarm(rs.getInt("under_vol_alarm"));
                        d.setOver_vol_alarm(rs.getInt("over_vol_alarm"));
                        d.setOver_load_alarm(rs.getInt("over_load_alarm"));
                        d.setOver_tmp_alarm(rs.getInt("over_tmp_alarm"));
                        d.setShort_out_alarm(rs.getInt("short_out_alarm"));
						
						
                        list.add(d);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }


    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Electrical_monitor_stationImpl.java

New file
@@ -0,0 +1,104 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Electrical_monitor_station;

public class Electrical_monitor_stationImpl 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) {
        Electrical_monitor_station ems=(Electrical_monitor_station) obj;
        String sql=" select * from db_partinsystem.electrical_monitor_station where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ems.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Electrical_monitor_station e=new Electrical_monitor_station();
                        e.setDev_id(rs.getInt("dev_id"));
                        e.setRecord_time(rs.getTimestamp("record_time"));
                        e.setIOc(rs.getFloat("iOc"));
                        e.setUObc(rs.getFloat("uObc"));
                        e.setUdc(rs.getFloat("udc"));
                        e.setF(rs.getFloat("f"));
                        e.setErrCode(rs.getFloat("errCode"));
                        e.setFlag(rs.getInt("flag"));
                        e.setUin1(rs.getFloat("uin1"));
                        e.setUin2(rs.getFloat("uin2"));
                        e.setLin1(rs.getFloat("lin1"));
                        e.setLin2(rs.getFloat("lin2"));
                        e.setUOab(rs.getFloat("uOab"));
                        e.setUOca(rs.getFloat("uOca"));
                        e.setIOa(rs.getFloat("iOa"));
                        e.setIOb(rs.getFloat("iOb"));
                        e.setPower(rs.getFloat("power"));
                        e.setCosa(rs.getFloat("cosa"));
                        e.setTScr1(rs.getFloat("tScr1"));
                        e.setTIgbta(rs.getFloat("tIgbta"));
                        e.setTIgbtb(rs.getFloat("tIgbtb"));
                        e.setTIgbtc(rs.getFloat("tIgbtc"));
                        e.setTLa(rs.getFloat("tLa"));
                        e.setTLb(rs.getFloat("tLb"));
                        e.setTLc(rs.getFloat("tLc"));
                        e.setTInyCup(rs.getFloat("tInyCup"));
                        e.setTTranCup(rs.getFloat("tTranCup"));
                        e.setTTran(rs.getFloat("tTran"));
                        list.add(e);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Inverter_eleImpl.java

New file
@@ -0,0 +1,136 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Inverter_ele;

public class Inverter_eleImpl 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) {
        Inverter_ele ie=(Inverter_ele) obj;
        String sql=" select * from db_partinsystem.inverter_ele where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ie.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Inverter_ele i=new Inverter_ele();
                        i.setDev_id(rs.getInt("dev_id"));
                        i.setRecord_time(rs.getTimestamp("record_time"));
                        i.setUin1_vol(rs.getFloat("uin1_vol"));
                        i.setUin2_vol(rs.getFloat("uin2_vol"));
                        i.setIin1_curr(rs.getFloat("iin1_curr"));
                        i.setIin2_curr(rs.getFloat("iin2_curr"));
                        i.setUgrid_output_vol(rs.getFloat("ugrid_output_vol"));
                        i.setTscr1_tmp(rs.getFloat("tscr1_tmp"));
                        i.setTscr2_tmp(rs.getFloat("tscr2_tmp"));
                        i.setTtr1_tmp(rs.getFloat("ttr1_tmp"));
                        i.setTtr2_tmp(rs.getFloat("ttr2_tmp"));
                        i.setTwater_in_tmp(rs.getFloat("twater_in_tmp"));
                        i.setTwater_out_tmp(rs.getFloat("twater_out_tmp"));
                        i.setFlux1_flow(rs.getFloat("flux1_flow"));
                        i.setFlux2_flow(rs.getFloat("flux2_flow"));
                        i.setHumi_tmp(rs.getFloat("humi_tmp"));
                        i.setTcab_tmp(rs.getFloat("tcab_tmp"));
                        i.setPower_output(rs.getFloat("power_output"));
                        i.setPower_cosa(rs.getFloat("power_cosa"));
                        i.setFo_output(rs.getFloat("fo_output"));
                        i.setErrcode(rs.getInt("errcode"));
                        i.setFlag(rs.getInt("flag"));
						
                        i.setVdc_up1_vol(rs.getFloat("vdc_up1_vol"));
                        i.setVdc_down1_vol(rs.getFloat("vdc_down1_vol"));
                        i.setUm1_in_vol(rs.getFloat("um1_in_vol"));
                        i.setIla1_curr(rs.getFloat("ila1_curr"));
                        i.setIlb1_curr(rs.getFloat("ilb1_curr"));
                        i.setIlc1_curr(rs.getFloat("ilc1_curr"));
                        i.setIoa1_curr(rs.getFloat("ioa1_curr"));
                        i.setIob1_curr(rs.getFloat("iob1_curr"));
                        i.setIoc1_curr(rs.getFloat("ioc1_curr"));
                        i.setUoab1_vol(rs.getFloat("uoab1_vol"));
                        i.setUobc1_vol(rs.getFloat("uobc1_vol"));
                        i.setTigbt1_tmp(rs.getFloat("tigbt1_tmp"));
                        i.setTdiode1_tmp(rs.getFloat("tdiode1_tmp"));
                        i.setTlac1_tmp(rs.getFloat("tlac1_tmp"));
                        i.setTcac1_tmp(rs.getFloat("tcac1_tmp"));
                        i.setTcdc1_tmp(rs.getFloat("tcdc1_tmp"));
                        i.setM1_flag_state(rs.getInt("m1_flag_state"));
						
                        i.setVdc_up8_vol(rs.getFloat("vdc_up8_vol"));
                        i.setVdc_down8_vol(rs.getFloat("vdc_down8_vol"));
                        i.setUm_in8_vol(rs.getFloat("um_in8_vol"));
                        i.setIla8_curr(rs.getFloat("ila8_curr"));
                        i.setIlb8_curr(rs.getFloat("ilb8_curr"));
                        i.setIlc8_curr(rs.getFloat("ilc8_curr"));
                        i.setIoa8_curr(rs.getFloat("ioa8_curr"));
                        i.setIob8_curr(rs.getFloat("iob8_curr"));
                        i.setIoc8_curr(rs.getFloat("ioc8_curr"));
                        i.setUoab8_vol(rs.getFloat("uoab8_vol"));
                        i.setUobc8_vol(rs.getFloat("uobc8_vol"));
                        i.setTigbt8_tmp(rs.getFloat("tigbt8_tmp"));
                        i.setTdiode8_tmp(rs.getFloat("tdiode8_tmp"));
                        i.setTlac8_tmp(rs.getFloat("tlac8_tmp"));
                        i.setTcac8_tmp(rs.getFloat("tcac8_tmp"));
                        i.setTcdc8_tmp(rs.getFloat("tcdc8_tmp"));
                        i.setM8_flag_state(rs.getInt("m8_flag_state"));
						
						
                        list.add(i);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/impl/Medvoldc_converterImpl.java

New file
@@ -0,0 +1,86 @@
package com.fgkj.partinsystem.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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.Medvoldc_converter;

public class Medvoldc_converterImpl 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) {
        Medvoldc_converter mc=(Medvoldc_converter) obj;
        String sql=" select * from db_partinsystem.medvoldc_converter where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{mc.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Medvoldc_converter m=new Medvoldc_converter();
                        m.setDev_id(rs.getInt("dev_id"));
                        m.setRecord_time(rs.getTimestamp("record_time"));
                        m.setUin_vol(rs.getFloat("uin_vol"));
                        m.setUout_vol(rs.getFloat("uout_vol"));
                        m.setIin_curr(rs.getFloat("iin_curr"));
                        m.setIout_curr(rs.getFloat("iout_curr"));
                        m.setDcin_tmp(rs.getFloat("dcin_tmp"));
                        m.setTwater_in_tmp(rs.getFloat("twater_in_tmp"));
                        m.setTwater_out_tmp(rs.getFloat("twater_out_tmp"));
                        m.setHumi_tmp(rs.getFloat("humi_tmp"));
                        list.add(m);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return null;
            }
        });
        return null;
    }

    @Override
    public List serchByInfo(Object obj) {
        // TODO Auto-generated method stub
        return null;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Ac230v_upsService.java

New file
@@ -0,0 +1,33 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Ac230v_upsService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Ac230v_upsService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.AC230V_UPS);
        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;
    }
	

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Cabin_boardService.java

New file
@@ -0,0 +1,32 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Cabin_boardService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Cabin_boardService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.CABIN_BOARD);
        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;
    }

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Centra_frequencyService.java

New file
@@ -0,0 +1,33 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Centra_frequencyService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Centra_frequencyService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.CENTRA_FREQUENCY);
        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;
    }
	

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Dc230v_battService.java

New file
@@ -0,0 +1,32 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Dc230v_battService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Dc230v_battService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.DC230V_BATT);
        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;
    }
	
}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Dc25v_battService.java

New file
@@ -0,0 +1,33 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Dc25v_battService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Dc25v_battService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.DC25V_BATT);
        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;
    }
	

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Electrical_monitor_stationService.java

New file
@@ -0,0 +1,33 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Electrical_monitor_stationService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Electrical_monitor_stationService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.ELECTRICAL_MONITOR_STATION);
        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;
    }
	

}

 DyEnvir_system/src/com/fgkj/partinsystem/service/Inverter_eleService.java

New file
@@ -0,0 +1,33 @@
package com.fgkj.partinsystem.service;

import java.util.List;

import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.services.ServiceModel;

public class Inverter_eleService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Inverter_eleService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.INVERTER_ELE);
        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;
    }
	

}

 DyEnvir_system/src/struts.xml

@@ -12,6 +12,9 @@
    
    
    <package name="default" namespace="/" extends="json-default" >
        <action name="*_prt_*" class="com.fgkj.actions.partinsystem.{1}" method="{2}">
            <result type="json"></result>
        </action> 
        <action name="*_thm_*" class="com.fgkj.actions.tmphum.{1}" method="{2}">
            <result type="json"></result>
        </action>