whyclj
2020-05-15 199388615bdbd461ca061e8f889925c0dba36747
后台添加设备实时告警记录查询[跨域]
3个文件已修改
89 ■■■■■ 已修改文件
gx_tieta/src/com/fgkj/actions/Batt_devalarm_dataAction.java 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/dao/impl/Batt_devalarm_dataImpl.java 56 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/services/Batt_devalarm_dataService.java 20 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
gx_tieta/src/com/fgkj/actions/Batt_devalarm_dataAction.java
@@ -81,6 +81,19 @@
    }
        
    
    /**
     * 查询设备实时告警记录(跨域新增)
     * @param obj
     * @return
     */
    public String searchDevAlarm_ky() {
        Batt_devalarm_data ddata=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Batt_devalarm_data.class);
        ServiceModel model = service.searchDevAlarm(ddata);
        result = tojson(model);
        return SUCCESS;
    }
    
    public String getResult() {
        return result;
gx_tieta/src/com/fgkj/dao/impl/Batt_devalarm_dataImpl.java
@@ -412,6 +412,62 @@
        }
        return list;
    }
    /**
     * 查询设备实时告警记录(跨域新增)
     * @param obj
     * @return
     */
    public List searchDevAlarm(Object obj){
        Batt_devalarm_data ddata=(Batt_devalarm_data) obj;
        Connection conn=DBUtil.getConn();
        String baseSql=" SELECT distinct tb_devalarm_data.num,dev_id,dev_ip,alm_type,alm_level,alm_start_time,alm_end_time,alm_is_confirmed,"
                + " alm_confirmed_time,alm_cleared_type,alm_value,db_battinf.tb_battinf.stationName,db_battinf.tb_battinf.stationName1,"
                + " db_battinf.tb_battinf.stationName2,db_battinf.tb_battinf.stationName5,db_battinf.tb_battinf.FbsDeviceName "
                + " FROM db_battinf.tb_battinf,db_alarm.tb_devalarm_data "
                + " WHERE db_alarm.tb_devalarm_data.dev_id = db_battinf.tb_battinf.FBSDeviceId "
                + " AND db_alarm.tb_devalarm_data.alm_cleared_type = 0 AND db_battinf.tb_battinf.station_install =1 " ;
        if(ddata.getDev_id() > 0){
            baseSql += " AND db_alarm.tb_devalarm_data.dev_id = " +ddata.getDev_id() ;
        }
        List<Batt_devalarm_data> list = DAOHelper.executeQueryLimit(baseSql, conn,null, new CallBack() {
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Batt_devalarm_data ddata=new Batt_devalarm_data();
                        ddata.setNum(rs.getInt("num"));
                        ddata.setDev_id(rs.getInt("dev_id"));
                        ddata.setDev_ip(rs.getString("dev_ip"));
                        ddata.setAlm_type(rs.getInt("alm_type"));
                        ddata.setAlm_level(rs.getInt("alm_level"));
                        ddata.setAlm_start_time(rs.getTimestamp("alm_start_time"));
                        ddata.setAlm_end_time(rs.getTimestamp("alm_end_time"));
                        ddata.setAlm_is_confirmed(rs.getInt("alm_is_confirmed"));
                        ddata.setAlm_confirmed_time(rs.getTimestamp("alm_confirmed_time"));
                        ddata.setAlm_cleared_type(rs.getInt("alm_cleared_type"));
                        ddata.setAlm_value(rs.getFloat("alm_value"));
                        ddata.setDev_name(rs.getString("FbsDeviceName"));
                        ddata.setStationName(rs.getString("stationName"));
                        ddata.setStationName1(rs.getString("stationName1"));
                        ddata.setStationName2(rs.getString("stationName2"));
                        ddata.setStationName5(rs.getString("stationName5"));
                        list.add(ddata);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        return list;
    }
    //查询设备告警总数
    /*public int searchNums() {
        String sql="select count(num) as nums  " +
gx_tieta/src/com/fgkj/services/Batt_devalarm_dataService.java
@@ -180,5 +180,25 @@
        }        
        return model;
    }
    /**
     * 查询设备实时告警记录(跨域新增)
     * @param obj
     * @return
     */
    public ServiceModel  searchDevAlarm(Object obj){
        List list=((Batt_devalarm_dataImpl)dao).searchDevAlarm(obj);
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }
        return model;
    }
}