参试设备实时数据的接口

whyclxw

2020-10-30 48c4cee4c9119ff7c1e7afe20db6138a960c7136

参试设备实时数据的接口

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

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

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Medvoldc_converter;
import com.fgkj.partinsystem.service.Medvoldc_converterService;
import com.fgkj.services.ServiceModel;

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

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

import com.fgkj.actions.ActionUtil;
import com.fgkj.partinsystem.dto.Reliable_board;
import com.fgkj.partinsystem.service.Reliable_boardService;
import com.fgkj.services.ServiceModel;

public class Reliable_boardAction extends ActionUtil{
    private Reliable_boardService service=new Reliable_boardService();
    private String json;
    private String result;
	
	
	
    //根据参试设备id查询设备的实时数据
    public String serchByCondition() {
        Reliable_board ac=ActionUtil.getGson(ActionUtil.time_yyyyMMddHHmmss).fromJson(json, Reliable_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/dao/BaseDAOFactory.java

@@ -58,7 +58,9 @@
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.Medvoldc_converterImpl;
import com.fgkj.partinsystem.impl.Partinsystem_infImpl;
import com.fgkj.partinsystem.impl.Reliable_boardImpl;
import com.fgkj.tmphum.impl.Tmphum_rtImpl;
import com.fgkj.watersystem.Impl.Water_alarmImpl;
import com.fgkj.watersystem.Impl.Water_brachImpl;
@@ -142,8 +144,8 @@
        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();
        case 63:return new Medvoldc_converterImpl();
        case 64:return new Reliable_boardImpl();
        default :return null;
        }
    }

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

@@ -65,16 +65,52 @@
                        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"));
                        m.setTcab_tmp(rs.getFloat("tcab_tmp"));
                        m.setErrcode(rs.getInt("errcode"));
                        m.setFlag(rs.getInt("flag"));
						
                        m.setVin1_vol(rs.getFloat("vin1_vol"));
                        m.setVin1_curr(rs.getFloat("vin1_curr"));
                        m.setVout1_vol(rs.getFloat("vout1_vol"));
                        m.setVohalf1_vol(rs.getFloat("vohalf1_vol"));
                        m.setIout1_curr(rs.getFloat("iout1_curr"));
                        m.setTwater_in1_tmp(rs.getFloat("twater_in1_tmp"));
                        m.setTwater_out1_tmp(rs.getFloat("twater_out1_tmp"));
                        m.setTscr1_tmp(rs.getFloat("tscr1_tmp"));
                        m.setTigbt_boost1_tmp(rs.getFloat("tigbt_boost1_tmp"));
                        m.setTigbt_buck1_tmp(rs.getFloat("tigbt_buck1_tmp"));
                        m.setTdiode1_tmp(rs.getFloat("tdiode1_tmp"));
                        m.setTlc1_tmp(rs.getFloat("tlc1_tmp"));
                        m.setTlo1_tmp(rs.getFloat("tlo1_tmp"));
                        m.setTro1_tmp(rs.getFloat("tro1_tmp"));
                        m.setM1_flag_state(rs.getInt("m1_flag_state"));
						
                        m.setVin10_vol(rs.getFloat("vin10_vol"));
                        m.setVin10_curr(rs.getFloat("vin10_curr"));
                        m.setVout10_vol(rs.getFloat("vout10_vol"));
                        m.setVohalf10_vol(rs.getFloat("vohalf10_vol"));
                        m.setIout10_curr(rs.getFloat("iout10_curr"));
                        m.setTwater_in10_tmp(rs.getFloat("twater_in10_tmp"));
                        m.setTwater_out10_tmp(rs.getFloat("twater_out10_tmp"));
                        m.setTscr10_tmp(rs.getFloat("tscr10_tmp"));
                        m.setTigbt_boost10_tmp(rs.getFloat("tigbt_boost10_tmp"));
                        m.setTigbt_buck10_tmp(rs.getFloat("tigbt_buck10_tmp"));
                        m.setTdiode10_tmp(rs.getFloat("tdiode10_tmp"));
                        m.setTlc10_tmp(rs.getFloat("tlc10_tmp"));
                        m.setTlo10_tmp(rs.getFloat("tlo10_tmp"));
                        m.setTro10_tmp(rs.getFloat("tro10_tmp"));
                        m.setM10_flag_state(rs.getInt("m10_flag_state"));
						
                        list.add(m);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return null;
                return list;
            }
        });
        return null;
        return list;
    }

    @Override

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

New file
@@ -0,0 +1,215 @@
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.Reliable_board;

public class Reliable_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) {
        Reliable_board rb=(Reliable_board) obj;
        String sql="select * from db_partinsystem.reliable_board where dev_id=? ";
        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rb.getDev_id()}, new CallBack() {
			
            @Override
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Reliable_board r=new Reliable_board();
                        r.setDev_id(rs.getInt("dev_id"));
                        r.setRecord_time(rs.getTimestamp("record_time"));
                        r.setThreeAB_vol(rs.getFloat("threeAB_vol"));
                        r.setThreeBC_vol(rs.getFloat("threeBC_vol"));
                        r.setThreeCA_vol(rs.getFloat("threeCA_vol"));
						
                        r.setQ1F(rs.getFloat("q1f"));
                        r.setQ1currA(rs.getFloat("q1currA"));
                        r.setQ1currB(rs.getFloat("q1currB"));
                        r.setQ1currC(rs.getFloat("q1currC"));
                        r.setQ1power_active(rs.getFloat("q1power_active"));
                        r.setQ1power_apparent(rs.getFloat("q1power_apparent"));
                        r.setQ1power_factor(rs.getFloat("q1power_factor"));
                        r.setQ1circuit_state(rs.getInt("q1circuit_state"));
                        r.setQ1ele_state(rs.getInt("q1ele_state"));
                        r.setQ1event_state(rs.getInt("q1event_state"));
						
                        r.setQ2F(rs.getFloat("q2f"));
                        r.setQ2currA(rs.getFloat("q2currA"));
                        r.setQ2currB(rs.getFloat("q2currB"));
                        r.setQ2currC(rs.getFloat("q2currC"));
                        r.setQ2power_active(rs.getFloat("q2power_active"));
                        r.setQ2power_apparent(rs.getFloat("q2power_apparent"));
                        r.setQ2power_factor(rs.getFloat("q2power_factor"));
                        r.setQ2circuit_state(rs.getInt("q2circuit_state"));
                        r.setQ2ele_state(rs.getInt("q2ele_state"));
                        r.setQ2event_state(rs.getInt("q2event_state"));


                        r.setQ3F(rs.getFloat("q3f"));
                        r.setQ3currA(rs.getFloat("q3currA"));
                        r.setQ3currB(rs.getFloat("q3currB"));
                        r.setQ3currC(rs.getFloat("q3currC"));
                        r.setQ3power_active(rs.getFloat("q3power_active"));
                        r.setQ3power_apparent(rs.getFloat("q3power_apparent"));
                        r.setQ3power_factor(rs.getFloat("q3power_factor"));
                        r.setQ3circuit_state(rs.getInt("q3circuit_state"));
                        r.setQ3ele_state(rs.getInt("q3ele_state"));
                        r.setQ3event_state(rs.getInt("q3event_state"));
						
                        r.setQ4F(rs.getFloat("q4f"));
                        r.setQ4currA(rs.getFloat("q4currA"));
                        r.setQ4currB(rs.getFloat("q4currB"));
                        r.setQ4currC(rs.getFloat("q4currC"));
                        r.setQ4power_active(rs.getFloat("q4power_active"));
                        r.setQ4power_apparent(rs.getFloat("q4power_apparent"));
                        r.setQ4power_factor(rs.getFloat("q4power_factor"));
                        r.setQ4circuit_state(rs.getInt("q4circuit_state"));
                        r.setQ4ele_state(rs.getInt("q4ele_state"));
                        r.setQ4event_state(rs.getInt("q4event_state"));
						
                        r.setQ5F(rs.getFloat("q5f"));
                        r.setQ5currA(rs.getFloat("q5currA"));
                        r.setQ5currB(rs.getFloat("q5currB"));
                        r.setQ5currC(rs.getFloat("q5currC"));
                        r.setQ5power_active(rs.getFloat("q5power_active"));
                        r.setQ5power_apparent(rs.getFloat("q5power_apparent"));
                        r.setQ5power_factor(rs.getFloat("q5power_factor"));
                        r.setQ5circuit_state(rs.getInt("q5circuit_state"));
                        r.setQ5ele_state(rs.getInt("q5ele_state"));
                        r.setQ5event_state(rs.getInt("q5event_state"));
						
                        r.setQ6F(rs.getFloat("q6f"));
                        r.setQ6currA(rs.getFloat("q6currA"));
                        r.setQ6currB(rs.getFloat("q6currB"));
                        r.setQ6currC(rs.getFloat("q6currC"));
                        r.setQ6power_active(rs.getFloat("q6power_active"));
                        r.setQ6power_apparent(rs.getFloat("q6power_apparent"));
                        r.setQ6power_factor(rs.getFloat("q6power_factor"));
                        r.setQ6circuit_state(rs.getInt("q6circuit_state"));
                        r.setQ6ele_state(rs.getInt("q6ele_state"));
                        r.setQ6event_state(rs.getInt("q6event_state"));
						
                        r.setQ7F(rs.getFloat("q7f"));
                        r.setQ7currA(rs.getFloat("q7currA"));
                        r.setQ7currB(rs.getFloat("q7currB"));
                        r.setQ7currC(rs.getFloat("q7currC"));
                        r.setQ7power_active(rs.getFloat("q7power_active"));
                        r.setQ7power_apparent(rs.getFloat("q7power_apparent"));
                        r.setQ7power_factor(rs.getFloat("q7power_factor"));
                        r.setQ7circuit_state(rs.getInt("q7circuit_state"));
                        r.setQ7ele_state(rs.getInt("q7ele_state"));
                        r.setQ7event_state(rs.getInt("q7event_state"));
						
                        r.setQ8F(rs.getFloat("q8f"));
                        r.setQ8currA(rs.getFloat("q8currA"));
                        r.setQ8currB(rs.getFloat("q8currB"));
                        r.setQ8currC(rs.getFloat("q8currC"));
                        r.setQ8power_active(rs.getFloat("q8power_active"));
                        r.setQ8power_apparent(rs.getFloat("q8power_apparent"));
                        r.setQ8power_factor(rs.getFloat("q8power_factor"));
                        r.setQ8circuit_state(rs.getInt("q8circuit_state"));
                        r.setQ8ele_state(rs.getInt("q8ele_state"));
                        r.setQ8event_state(rs.getInt("q8event_state"));
						
                        r.setQ9F(rs.getFloat("q9f"));
                        r.setQ9currA(rs.getFloat("q9currA"));
                        r.setQ9currB(rs.getFloat("q9currB"));
                        r.setQ9currC(rs.getFloat("q9currC"));
                        r.setQ9power_active(rs.getFloat("q9power_active"));
                        r.setQ9power_apparent(rs.getFloat("q9power_apparent"));
                        r.setQ9power_factor(rs.getFloat("q9power_factor"));
                        r.setQ9circuit_state(rs.getInt("q9circuit_state"));
                        r.setQ9ele_state(rs.getInt("q9ele_state"));
                        r.setQ9event_state(rs.getInt("q9event_state"));
						
                        r.setQ10F(rs.getFloat("q10f"));
                        r.setQ10currA(rs.getFloat("q10currA"));
                        r.setQ10currB(rs.getFloat("q10currB"));
                        r.setQ10currC(rs.getFloat("q10currC"));
                        r.setQ10power_active(rs.getFloat("q10power_active"));
                        r.setQ10power_apparent(rs.getFloat("q10power_apparent"));
                        r.setQ10power_factor(rs.getFloat("q10power_factor"));
                        r.setQ10circuit_state(rs.getInt("q10circuit_state"));
                        r.setQ10ele_state(rs.getInt("q10ele_state"));
                        r.setQ10event_state(rs.getInt("q10event_state"));
						
                        r.setQ11F(rs.getFloat("q11f"));
                        r.setQ11currA(rs.getFloat("q11currA"));
                        r.setQ11currB(rs.getFloat("q11currB"));
                        r.setQ11currC(rs.getFloat("q11currC"));
                        r.setQ11power_active(rs.getFloat("q11power_active"));
                        r.setQ11power_apparent(rs.getFloat("q11power_apparent"));
                        r.setQ11power_factor(rs.getFloat("q11power_factor"));
                        r.setQ11circuit_state(rs.getInt("q11circuit_state"));
                        r.setQ11ele_state(rs.getInt("q11ele_state"));
                        r.setQ11event_state(rs.getInt("q11event_state"));
						
                        r.setQ12F(rs.getFloat("q12f"));
                        r.setQ12currA(rs.getFloat("q12currA"));
                        r.setQ12currB(rs.getFloat("q12currB"));
                        r.setQ12currC(rs.getFloat("q12currC"));
                        r.setQ12power_active(rs.getFloat("q12power_active"));
                        r.setQ12power_apparent(rs.getFloat("q12power_apparent"));
                        r.setQ12power_factor(rs.getFloat("q12power_factor"));
                        r.setQ12circuit_state(rs.getInt("q12circuit_state"));
                        r.setQ12ele_state(rs.getInt("q12ele_state"));
                        r.setQ12event_state(rs.getInt("q12event_state"));
						
                        list.add(r);
                    }
                } 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/service/Medvoldc_converterService.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 Medvoldc_converterService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Medvoldc_converterService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.MEDVOLDC_CONVERTER);
        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/Reliable_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 Reliable_boardService {
    private BaseDAO dao;
    private ServiceModel model;
	
    public Reliable_boardService() {
        super();
        this.dao=BaseDAOFactory.getBaseDAO(BaseDAO.RELIABLE_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;
    }
	
}