81041
2018-10-22 4dfc0379caa108688f89cbdc595152c97ed3a7a8
首页修改
5个文件已修改
234 ■■■■■ 已修改文件
gx_tieta/src/com/fgkj/actions/BattMap_informationAction.java 24 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/dao/impl/BattMap_informationImpl.java 97 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/dao/impl/ram/Bts_station_stateImpl.java 32 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/dto/BattMap_information.java 16 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/services/BattMap_informationService.java 65 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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  " +
@@ -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);