首页修改

81041

2018-10-22 4dfc0379caa108688f89cbdc595152c97ed3a7a8

首页修改

 gx_tieta/src/com/fgkj/actions/BattMap_informationAction.java

@@ -4,6 +4,7 @@


import com.fgkj.dao.UinfDaoFactory;

import com.fgkj.dto.BattMap_information;

import com.fgkj.dto.Page;

import com.fgkj.dto.ServiceModel;

import com.fgkj.dto.User_inf;

import com.fgkj.dto.User_log;

@@ -98,14 +99,31 @@
        result = tojson(model);

        return SUCCESS;

    }

    //9.1首页上查询已经添加物理信息的机房(用户管理的)  包括(告警总数落后总数延迟总数)

    //9.1首页上查询已经添加物理信息的机房(用户管理的,l查询全部打开页面)

    public String searchUserManageStation() {

        User_inf uinf=(User_inf) getUser();

        List list = service.searchUserManageStation(uinf);

        ServiceModel model = service.searchUserManageStation(uinf);

        result = tojson(model);

        return SUCCESS;

    }

    //9.1首页上查询已经添加物理信息的机房(用户管理的，分页刷新)

    public String searchUserManageStation2() {

        Page p=getGson().fromJson(json, Page.class);

        User_inf uinf=(User_inf) getUser();

        p.setPageAll(uinf.getUId());

        List list = service.searchUserManageStation2(p);

        result = tojson(list);

        return SUCCESS;

    }

	
    //9.1首页上查询已经添加物理信息的机房(用户管理的，3.根据具体id查询告警信息等)

    public String searchUserManageStation3() {

        BattMap_information binfor=getGson().fromJson(json, BattMap_information.class);

        User_inf uinf=(User_inf) getUser();

        binfor.setNum(uinf.getUId());

        List list = service.searchUserManageStation3(binfor);

        result = tojson(list);

        return SUCCESS;

    }

    //9.1电池寿命管理

    public String serchByStationid(){

        BattMap_information bmap = getGson().fromJson(json, BattMap_information.class);


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

@@ -1,5 +1,6 @@
package com.fgkj.dao.impl;



import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

@@ -9,6 +10,7 @@
import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.CallBack;

import com.fgkj.dao.DAOHelper;

import com.fgkj.dao.LimitNumberFactory;

import com.fgkj.db.DBUtil;

import com.fgkj.db.IDatabaseName;

import com.fgkj.dto.BattDischarge_plan;

@@ -16,6 +18,7 @@
import com.fgkj.dto.BattMap_information;

import com.fgkj.dto.Batt_Maint_Dealarm;

import com.fgkj.dto.Battalarm_data;

import com.fgkj.dto.Page;

import com.fgkj.dto.User_inf;



public class BattMap_informationImpl implements BaseDAO,CallBack{

@@ -127,7 +130,7 @@
        });

        return list;

    }

    //9.1查询已经添加物理信息的机房(用户管理的)

    //9.1查询已经添加物理信息的机房(用户管理的,l查询全部打开页面)

    public List serchInBattMapByUid(Object obj) {

        User_inf uinf=(User_inf) obj;

        String sql="select distinct tb_battmap_information.num,tb_battmap_information.StationId,tb_battmap_information.StationName,address,longitude,latitude,information,db_battinf.tb_battinf.FBSDeviceId  " +

@@ -139,7 +142,7 @@
                "  left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " +

                "  left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +

                "  left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +

                "  where db_user.tb_user_inf.uid=?  )";

                "  where db_user.tb_user_inf.uid=?  ) ";

        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{uinf.getUId()}, new CallBack() {

            

            public List getResults(ResultSet rs) {

@@ -166,6 +169,98 @@
        } );

        return list;

    }

    //9.1查询已经添加物理信息的机房(用户管理的，分页刷新)

    public List serchInBattMapByUid2(Object obj) {

        Page page=(Page) obj;

        int uid=page.getPageAll();

        Connection conn=DBUtil.getConn();

        String numberSql="SELECT FOUND_ROWS() number";//存放总数

        String sql="select SQL_CALC_FOUND_ROWS distinct tb_battmap_information.num,tb_battmap_information.StationId,tb_battmap_information.StationName,address,longitude,latitude,information,db_battinf.tb_battinf.FBSDeviceId  " +

                "  from web_site.tb_battmap_information,db_battinf.tb_battinf " +

                "  where  tb_battmap_information.StationId=db_battinf.tb_battinf.StationId " +

                "  and tb_battmap_information.StationId in (" +

                "  select distinct db_battinf.tb_battinf.stationid  " +

                "  from db_battinf.tb_battinf " +

                "  left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " +

                "  left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +

                "  left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +

                "  where db_user.tb_user_inf.uid=?  )  " +

                "  limit ?,?  " +

                "  order by tb_battmap_information.StationId ";

        List<BattMap_information> list=DAOHelper.executeQueryLimit(sql, conn,new Object[]{uid,(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattMap_information binformation=new BattMap_information();

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

                        binformation.setStationId(rs.getString("stationId"));

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

                        binformation.setAddress(rs.getString("address"));

                        binformation.setLongitude(rs.getDouble("longitude"));

                        binformation.setLatitude(rs.getDouble("latitude"));

                        binformation.setInformation(rs.getString("information"));

                        binformation.setFBSDeviceId(rs.getInt("fBSDeviceId"));

                        Page p=new Page();

                        binformation.setPage(p);

                        list.add(binformation);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        } );

        //去掉limit条件后的总数

        int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);

        //System.out.println("number: "+number);

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

            list.get(list.size()-1).getPage().setPageAll(number);

        }

        return list;

    }

    //9.1查询已经添加物理信息的机房(用户管理的，3.根据具体id查询告警信息等)

    public List serchInBattMapByUid3(Object obj) {

        BattMap_information binfor=(BattMap_information) obj;

        String sql="select distinct tb_battmap_information.num,tb_battmap_information.StationId,tb_battmap_information.StationName,address,longitude,latitude,information,db_battinf.tb_battinf.FBSDeviceId  " +

                "  from web_site.tb_battmap_information,db_battinf.tb_battinf " +

                "  where  tb_battmap_information.StationId=db_battinf.tb_battinf.StationId " +

                "  and tb_battmap_information.StationId in (" +

                "  select distinct db_battinf.tb_battinf.stationid  " +

                "  from db_battinf.tb_battinf " +

                "  left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.stationid=db_battinf.tb_battinf.stationid " +

                "  left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +

                "  left outer join db_user.tb_user_inf on tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +

                "  where db_user.tb_user_inf.uid=?  ) " +

                "  and tb_battmap_information.StationId=? ";

        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),new Object[]{binfor.getNum(),binfor.getStationId()}, new CallBack() {

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattMap_information binformation=new BattMap_information();

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

                        binformation.setStationId(rs.getString("stationId"));

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

                        binformation.setAddress(rs.getString("address"));

                        binformation.setLongitude(rs.getDouble("longitude"));

                        binformation.setLatitude(rs.getDouble("latitude"));

                        binformation.setInformation(rs.getString("information"));

                        binformation.setFBSDeviceId(rs.getInt("fBSDeviceId"));

                        list.add(binformation);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        } );

        return list;

    }

    //9.1查询机房所在的所有省份

    public List serchStationName1(){

        String sql="  SELECT  DISTINCT substring_index(substring_index(address,'-',2),'-',1) as stationname1  FROM web_site.tb_BattMap_information  " ;


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

@@ -111,12 +111,34 @@
        }

        return list;

    }



    //查询当前机房停电数

    public int serchByState() {

        String sql=" select count(*) as nums from db_ram_db.tb_bts_station_state where station_stat&2>1  ";

        List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        list.add(rs.getInt("nums"));

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        int nums=0;//总数

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

            nums=(Integer) list.get(list.size()-1);

        }

        return nums;

    }

    public List serchByInfo(Object obj) {

        // TODO Auto-generated method stub

        return null;

    }



    public static void main(String[] args) {

        Bts_station_stateImpl bimpl=new Bts_station_stateImpl();

        BattInf binf=new BattInf();

@@ -128,10 +150,14 @@
        p.setPageCurr(1);

        p.setPageSize(1);

        binf.setPage(p);

        List<Bts_station_state> list=bimpl.serchByCondition(binf);

        /*List<Bts_station_state> list=bimpl.serchByCondition(binf);

        for (Bts_station_state bs : list) {

            //System.out.println(bs.getStation_stat_diaozhan()+"  "+bs.getStation_stat_dooropen()+"  "+bs.getStation_stat_fadian()+"   "+bs.getStation_stat_xuhang()+"  "+bs.getStation_stat_poff());

            System.out.println(bs);

        }

        }*/

        int nums=bimpl.serchByState();

        System.out.println(nums);

    }



	
}


 gx_tieta/src/com/fgkj/dto/BattMap_information.java

@@ -11,7 +11,7 @@
    private Double latitude;                // 纬度

    private String information;            //备注

    private Integer FBSDeviceId;        //设备id

	
    private Page page;

    public BattMap_information() {

        super();

        

@@ -97,15 +97,27 @@
    }





    public Page getPage() {

        return page;

    }





    public void setPage(Page page) {

        this.page = page;

    }





    @Override

    public String toString() {

        return "BattMap_information [num=" + num + ", StationId=" + StationId

                + ", StationName=" + StationName + ", Address=" + Address

                + ", longitude=" + longitude + ", latitude=" + latitude

                + ", information=" + information + ", FBSDeviceId="

                + FBSDeviceId + "]";

                + FBSDeviceId + ", page=" + page + "]";

    }







    

    

}


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

@@ -86,10 +86,22 @@
        }

        return listAll;

    }

	
    //首页上查询用户管理的已经设置过位置的机房信息

    public List searchUserManageStation(Object obj){		
        List<BattMap_information> list = ((BattMap_informationImpl)dao).serchInBattMapByUid(obj);

    //首页上查询用户管理的已经设置过位置的机房信息(用户管理的,l查询全部打开页面)

    public ServiceModel searchUserManageStation(Object obj){		
        List list = ((BattMap_informationImpl)dao).serchInBattMapByUid(obj);

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

            model.setCode(1);

            model.setData(list);

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

        }else{

            model.setCode(0);

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

        }

        return model;

    }

    //首页上查询用户管理的已经设置过位置的机房信息(用户管理的，分页刷新)

    public List searchUserManageStation2(Object obj){		
        List<BattMap_information> list = ((BattMap_informationImpl)dao).serchInBattMapByUid2(obj);

        List listAll=new ArrayList();//存放最后的结果

        String state="";

        int numBadBatt=0;

@@ -131,7 +143,50 @@
        }

        return listAll;

    }

	
    //首页上查询用户管理的已经设置过位置的机房信息(用户管理的，3.根据具体id查询告警信息等)

    public List searchUserManageStation3(Object obj){		
        List<BattMap_information> list = ((BattMap_informationImpl)dao).serchInBattMapByUid3(obj);

        List listAll=new ArrayList();//存放最后的结果

        String state="";

        int numBadBatt=0;

        int numAlarm=0;

        int numPlan=0;

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

            for(int i=0;i<list.size();i++){

                state="item-normal";

                ServiceModel model=new ServiceModel();

                BattMap_information binformation = list.get(i);

                if(binformation.getFBSDeviceId()/100000==6185){

                    BattInf binf=new BattInf();

                    binf.setFBSDeviceId(binformation.getFBSDeviceId());

                    state=(new Fbs9100_stateImpl().seachDevNow(binf));

                }else{

                    numBadBatt=(new BadBatt_monImpl()).serchByStationId(binformation);                //落后总数

                    numAlarm=(new Battalarm_dataDAOImpl()).serchByStationId(binformation);        //告警总数

                    numPlan=(new BattDischarge_planImpl()).serchByStationId(binformation);    //延迟总数

                    if(numBadBatt>0){

                        state="item-behind";                                    //落后机房

                    }else{

                        if(numAlarm > 0){

                            state="item-warn";                                //告警机房

                        }else{

                            if(numPlan > 0){

                                state="item-timeout";                        //延迟机房

                            }

                        }

                    }

                }

                model.setData(list.get(i));

                model.setCode(numAlarm);        //告警总数

                model.setSum(numBadBatt);        //落后总数

                model.setNewsum(numPlan);        //延时总数

                model.setMsg(state);            //61850状态

                model.setMsgN(binformation.getFBSDeviceId().toString());

                listAll.add(model);

            }

        }

        return listAll;

    }

    //9.1百度地图定位根据省份查询所有该区域的机房

    public List serchByCondition(Object obj){

            List<BattMap_information> list =dao.serchByCondition(obj);