//11.1FBS9100设备通信状态查询<-------跨域----------->

81041

2018-11-14 bc8eacc7f4412a274f64c79d79b702bca588ee8e

//11.1FBS9100设备通信状态查询<-------跨域----------->

 gx_tieta/src/com/fgkj/dao/impl/ram/Fbs9100_stateImpl.java

@@ -312,6 +312,73 @@
        }

        return list;

    }

    //11.1FBS9100设备通信状态查询<-------跨域----------->

    public List serchByCondition_ky() {

        String sql="";

        String baseSql="select  distinct tb_fbs9100_state.num,tb_fbs9100_state.dev_ip,tb_fbs9100_state.dev_version,record_datetime,tb_fbs9100_state.dev_id,op_cmd,dev_datetime,dev_testtype,dev_testgroupnum," +

                "dev_workstate,dev_alarmstate,dev_res_test_state,dev_onlinevollow,dev_eachgroup_battsum,dev_captest_onlinevol,dev_captest_groupvol,dev_captest_curr," +

                "dev_captest_cap,dev_captest_timelong,dev_restest_moncount,dev_restest_monindex,dev_commcount,dev_errcommcount,db_ram_db.tb_fbs9100_state.dev_61850alarms,dev_last_captest_stop_type, " +

                "db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FbsDeviceName," +

                "COUNT(DISTINCT db_battinf.tb_battinf.BattGroupId) as cnt," +

                "group_CONCAT(db_ram_db.tb_batt_rtstate.online_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as online_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_curr ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_currs  " +

                "from db_ram_db.tb_Fbs9100_state " +

                "left outer join db_battinf.tb_battinf ON tb_fbs9100_state.dev_id=db_battinf.tb_battinf.FBSDeviceId  " +

                "LEFT OUTER JOIN db_ram_db.tb_batt_rtstate ON db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid ";

        //分组

        String groupSql=" GROUP BY tb_fbs9100_state.dev_id ";

        //最后结果

        sql=baseSql+groupSql;

        //System.out.println(sql);

        List<Fbs9100_state> list=DAOHelper.executeQueryLimit(sql, DBUtil.getConn(), null, new CallBack() {

            List list=new ArrayList();

            public List getResults(ResultSet rs) {

                try {

                    while(rs.next()){

                        Fbs9100_state fstate=new Fbs9100_state();

                        fstate.setNum(rs.getInt("cnt"));//关联电池组个数

                        fstate.setDev_ip(rs.getString("dev_ip"));

                        fstate.setDev_version(rs.getString("dev_version"));

                        fstate.setDev_id(rs.getInt("dev_id"));

                        fstate.setOp_cmd(rs.getInt("op_cmd"));

                        fstate.setRecord_datetime(rs.getString("record_datetime"));

                        fstate.setDev_datetime(rs.getString("dev_datetime"));

                        fstate.setDev_testtype(rs.getInt("dev_testtype"));

                        fstate.setDev_testgroupnum(rs.getInt("dev_testgroupnum"));

                        fstate.setDev_workstate(rs.getInt("dev_workstate"));

                        fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));

                        fstate.setDev_res_test_state(rs.getInt("dev_res_test_state"));

                        fstate.setDev_onlinevollow(rs.getInt("dev_onlinevollow"));

                        fstate.setDev_eachgroup_battsum(rs.getInt("dev_eachgroup_battsum"));

                        fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_onlinevol"));

                        fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));

                        fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));

                        fstate.setDev_captest_cap(rs.getFloat("dev_captest_cap"));

                        fstate.setDev_captest_timelong(rs.getInt("dev_captest_timelong"));

                        fstate.setDev_restest_moncount(rs.getInt("dev_restest_moncount"));

                        fstate.setDev_restest_monindex(rs.getInt("dev_restest_monindex"));

                        fstate.setDev_commcount(rs.getInt("dev_commcount"));

                        fstate.setDev_errcommcount(rs.getInt("dev_errcommcount"));

						
                        fstate.setStationName(rs.getString("stationName"));

                        fstate.setDeviceName(rs.getString("FbsDeviceName"));

                        fstate.setOnline_vols(rs.getString("online_vols"));

                        fstate.setGroup_vols(rs.getString("group_vols"));

                        fstate.setGroup_currs(rs.getString("group_currs"));

                        fstate.setDev_61850alarms(rs.getString("dev_61850alarms"));

                        fstate.setDev_last_captest_stop_type(rs.getInt("dev_last_captest_stop_type"));

                        //System.out.println(fstate);

                        list.add(fstate);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

	
    //判断机房实时数据中该机房有没有连接到服务器

    public int judgeSatationInState(int dev_id) {

        String sql=" SELECT count(num) as nums from db_ram_db.tb_fbs9100_state where dev_id=? LIMIT 1 ";

@@ -839,6 +906,11 @@
        for(Fbs9100_state f:list){

            System.out.println(f);

        }*/

        List<Fbs9100_state> list=fi.serchByCondition_ky();

        System.out.println(list.size());

        for(Fbs9100_state f:list){

            System.out.println(f);

        }

        /*BattInf binf=new BattInf();

        binf.setBattGroupId(1005069);

        List list=fi.serchByInfo(binf);

@@ -848,11 +920,11 @@
       //List<Fbs9100_state> list=fi.searchByUid(uinf);

       // List<Fbs9100_state> list=fi.searchDevWorkstate(fs);

       // List<Fbs9100_state> list=fi.seach6185Nuclear_cap(uinf);

        List<Fbs9100_state> list=fi.seachNuclear_cap(uinf);

       /* List<Fbs9100_state> list=fi.seachNuclear_cap(uinf);

        System.out.println(list.size());

        for(Fbs9100_state f:list){

            System.out.println(f);

        }

        }*/

    }



}


 gx_tieta/src/com/fgkj/services/ram/Fbs9100_stateService.java

@@ -71,10 +71,21 @@
    }

    //11.1FBS9100设备通信状态查询

    public ServiceModel serchByCondition(Object obj){

        List list=new ArrayList();

        Fbs9100_state fs=(Fbs9100_state) obj;

        //FBS9100数据

        list = dao.serchByCondition(fs);

        List list = dao.serchByCondition(obj);

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

            model.setCode(1);

            model.setData(list);

        }else{

            model.setCode(0);

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

        }

        return model;

    } 
    //11.1FBS9100设备通信状态查询<-------跨域----------->

    public ServiceModel serchByCondition_ky(){

        //FBS9100数据

        List  list = ((Fbs9100_stateImpl)dao).serchByCondition_ky();

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

            model.setCode(1);

            model.setData(list);