//实时监测<-------跨域----------->组端单体实时

81041

2018-11-14 d21e316dcf8429e732d7d330813e12646438e05f

//实时监测<-------跨域----------->组端单体实时

 gx_tieta/src/com/fgkj/dao/impl/Batt_rtdataDAOImpl.java

@@ -65,6 +65,39 @@
            }

        });

    }

    //实时监测<-------跨域----------->

    public List serchByCondition_ky(Object obj) {

        Batt_rtdata br=(Batt_rtdata)obj;

        String sql="select num,BattGroupId,rec_datetime,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,mon_conn_res,mon_cap,mon_JH_curr from db_ram_db.tb_batt_rtdata where BattGroupId=?  order by mon_num";

        return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{br.getBattGroupId()}, new CallBack() {

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Batt_rtdata rtdata=new Batt_rtdata();

                        rtdata.setNum(rs.getInt("num"));

                        rtdata.setBattGroupId(rs.getInt("BattGroupId"));

                        rtdata.setRec_datetime(rs.getDate("rec_datetime"));

                        rtdata.setMon_num(rs.getInt("mon_num"));

                        rtdata.setMon_vol(rs.getFloat("mon_vol"));

                        rtdata.setMon_tmp(rs.getFloat("mon_tmp"));

                        rtdata.setMon_res(rs.getFloat("mon_res"));

                        rtdata.setMon_ser(rs.getFloat("mon_ser"));

                        rtdata.setMon_conn_res(rs.getFloat("mon_conn_res"));

                        rtdata.setMon_cap(rs.getFloat("mon_cap"));

                        rtdata.setMon_JH_curr(rs.getFloat("mon_JH_curr"));

                        //System.out.println(rtdata);

                        list.add(rtdata);

                    }

                } catch (SQLException e) {

                    e.printStackTrace();

                }

			
                return list;

            }

        });

    }

    // 电池组单体最大值和最小值

    public List serchByInfo(Object obj) {

        BattInf binf=(BattInf)obj;

@@ -167,7 +200,13 @@
        //binf.setBattGroupId(1000007);

        binf.setFBSDeviceId(910000001);

        binf.setGroupIndexInFBSDevice(0);

        List<Batt_rtdata> list=bimpl.serchByThirdBatt(binf);

        /*List<Batt_rtdata> list=bimpl.serchByThirdBatt(binf);

        for (Batt_rtdata b : list) {

            System.out.println(b);

        }*/

        Batt_rtdata br=new Batt_rtdata();

        br.setBattGroupId(1002101);

        List<Batt_rtdata> list=bimpl.serchByCondition_ky(br);

        for (Batt_rtdata b : list) {

            System.out.println(b);

        }


 gx_tieta/src/com/fgkj/services/Batt_rtdataService.java

@@ -16,13 +16,29 @@
        model=new ServiceModel();

        dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATT_RTDATA);

    }

	
    //实时监测

    public ServiceModel serchByCondition(Object obj){

        List list=dao.serchByCondition(obj);

        //System.out.println(list);

        if(list!=null && list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功!");

        }else{

            model.setCode(0);

            model.setMsg("查询失败!");

        }	
        return model;

    }

    //实时监测<-------跨域----------->

    public ServiceModel serchByCondition_ky(Object obj){

        List list=((Batt_rtdataDAOImpl)dao).serchByCondition_ky(obj);

        if(list!=null && list.size()>0){

            model.setCode(1);

            model.setData(list);

            model.setMsg("查询成功!");

        }else{

            model.setCode(0);

            model.setMsg("查询失败!");

        }        

        return model;

    }