升级页面的操作

81041

2018-11-13 bef2e20154a3f27e4e7bfb5d8a2cc5971dc565e3

升级页面的操作

 gx_tieta/src/com/fgkj/actions/ram/Fbs9100s_dfu_stateAction.java

@@ -3,6 +3,7 @@
import java.util.List;



import com.fgkj.actions.ActionUtil;

import com.fgkj.dto.BattInf;

import com.fgkj.dto.ServiceModel;

import com.fgkj.dto.ram.Fbs9100_state;

import com.fgkj.dto.ram.Fbs9100s_dfu_state;

@@ -21,6 +22,29 @@
        result=tojson(model);

        return SUCCESS;

    }

    //升级插入

    public String addPro(){

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class);

        ServiceModel model=service.addPro(binf);

        result=tojson(model);

        return SUCCESS;

    }

    //表格显示批量插入的机房信息

    public String serchInserStation(){

        BattInf binf=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json,BattInf.class);

        ServiceModel model=service.serchInserStation(binf);

        result=tojson(model);

        return SUCCESS;

    }

	
    //批量升级前验证升级的设备必须处于在线监测状态(9100state的workstate为0)

    public String judgeStation(){

        List<Integer>  list=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json,new TypeToken<List<Integer>>(){}.getType());

        ServiceModel model=service.judgeStation(list);

        result=tojson(model);

        return SUCCESS;

    }

	
    //升级确认

    public String update(){

        Fbs9100s_dfu_state dfu=getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100s_dfu_state.class);


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

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

import com.fgkj.dao.UinfDaoFactory;

import com.fgkj.db.DBUtil;

import com.fgkj.dto.BattInf;

import com.fgkj.dto.User_log;

import com.fgkj.dto.ram.Fbs9100s_dfu_state;

import com.fgkj.services.User_logService;

@@ -23,11 +24,135 @@
    //升级插入

    public boolean add(Object obj) {

        Fbs9100s_dfu_state dfu=(Fbs9100s_dfu_state) obj;

        String sql="REPLACE into db_ram_db.tb_fbs9100s_dfu_state (dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) values (?,?,?,?)";

        String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state (dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) values (?,?,?,?)";

        boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{dfu.getDev_id(),dfu.getDfu_file(),dfu.getDfu_wr_stat(),dfu.getDfu_data_blocknum()});

        return bl;

    }

    //升级确认

    //批量升级插入(所有属性传到stationName中)

    public boolean addPro(Object obj) {

        BattInf binf=(BattInf) obj;

        String sql=" REPLACE into db_ram_db.tb_fbs9100s_dfu_state(dev_id,dfu_file,dfu_wr_stat,dfu_data_blocknum) " +

                " SELECT  DISTINCT fBSDeviceId,'avr_dfu.uc3',1,1 FROM  db_battinf.tb_battinf " +

                " where ";

        //条件

        String sql0=" stationid=? "; //具体机房

        String sql1=" stationname1=? ";//省

        String sql2=" stationname2=? ";//市

        String sql5=" stationname5=? ";//区县

        switch (binf.getNum()) {

        case 0:

            sql+=sql0;

            break;

        case 1:

            sql+=sql1;

            break;

        case 2:

            sql+=sql2;

            break;

        case 5:

            sql+=sql5;

             break;

        default:

            return false;

        }

        //System.out.println(sql);

        boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{binf.getStationName()});

        return bl;

    }

    //表格显示批量插入的机房信息

    public List serchInserStation(Object obj){

        BattInf binf=(BattInf) obj; 
        String sql="SELECT  DISTINCT fBSDeviceId,stationname,stationname1,stationname2,stationname3,stationname5 from db_battinf.tb_battinf " +

                " where ";

        //条件

        String sql0=" stationid=? "; //具体机房

        String sql1=" stationname1=? ";//省

        String sql2=" stationname2=? ";//市

        String sql5=" stationname5=? ";//区县

        switch (binf.getNum()) {

        case 0:

            sql+=sql0;

            break;

        case 1:

            sql+=sql1;

            break;

        case 2:

            sql+=sql2;

            break;

        case 5:

            sql+=sql5;

             break;

        default:

            return null;

        }

        String endSql="  order by fBSDeviceId ";

        sql+=endSql;

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

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattInf binf=new BattInf();

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

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

                        binf.setStationName1(rs.getString("stationName1"));

                        binf.setStationName2(rs.getString("stationName2"));

                        binf.setStationName3(rs.getString("stationName3"));

                        binf.setStationName5(rs.getString("stationName5"));

                        list.add(binf);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return list;

    }

    //批量升级前验证升级的设备必须处于在线监测状态(9100state的workstate为0)

    public List judgeStation(Object obj){

        List<Integer> list=(List<Integer>) obj;

        String sql=" select distinct dev_id,db_battinf.tb_battinf.stationname3 from db_ram_db.tb_fbs9100_state,db_battinf.tb_battinf  " +

                " where db_ram_db.tb_fbs9100_state.dev_id=db_battinf.tb_battinf.fBSDeviceId  and dev_workstate=0 and dev_id in(";

        String devSql="";

        Object[] object=new Object[list.size()];

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

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

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

                if(i==(list.size()-1)){

                    devSql+="?)";

                }else{

                    devSql+="?,";

                }

                object[i]=list.get(i);

            }

        }

        sql+=devSql;

        String endSql="  order by dev_id";

        sql+=endSql;

        List listAll=DAOHelper.executeQuery(sql, DBUtil.getConn(), object, new CallBack() {

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        BattInf binf=new BattInf();

                        binf.setFBSDeviceId(rs.getInt("dev_id"));

                        binf.setStationName3(rs.getString("stationName3"));

                        list.add(binf);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                return list;

            }

        });

        return listAll;

    }

    //升级确认

    public boolean update(Object obj) {

        Fbs9100s_dfu_state dfu=(Fbs9100s_dfu_state) obj;

        String sql="update db_ram_db.tb_fbs9100s_dfu_state set dfu_en=true,dfu_wr_stat=1, dfu_data_blocknum=1 where dev_id=?";

@@ -119,15 +244,30 @@
        // TODO Auto-generated method stub

        return null;

    }

   public static void main(String[] args) {

    public static void main(String[] args) {

    Fbs9100s_dfu_stateImpl fimpl=new Fbs9100s_dfu_stateImpl();

    List list=new ArrayList();

    list.add(910000013);

    list.add(910000002);

    list.add(910000577);

    list.add(910000534);

    List<Fbs9100s_dfu_state> listAll=fimpl.serchByCondition(list);

    BattInf binf=new BattInf();

    binf.setNum(1);

    binf.setStationName("湖北省");

	
    /*List<Fbs9100s_dfu_state> listAll=fimpl.serchByCondition(list);

    for (Fbs9100s_dfu_state dfu : listAll) {

        System.out.println(dfu);

    }*/

    /*List<BattInf> listAll=fimpl.judgeStation(list);

    for (BattInf binf : listAll) {

        System.out.println(binf.getStationName3()+" "+binf.getFBSDeviceId());

    }*/

    /*

    boolean bl=fimpl.addPro(binf);

    System.out.println(bl);*/

    List<BattInf> listAll=fimpl.serchInserStation(binf);

    for (BattInf b : listAll) {

        System.out.println(b.getStationName3()+" "+b.getFBSDeviceId());

    }

}

}


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

@@ -29,6 +29,44 @@
        }

        return model;

    }

    //批量升级插入(所有属性传到stationName中)

    public ServiceModel addPro(Object obj) {

        boolean bl=((Fbs9100s_dfu_stateImpl)dao).addPro(obj);

        if(bl){

            model.setCode(1);

            model.setMsg("批量添加成功!");

        }else{

            model.setCode(0);

            model.setMsg("批量添加失败!");

        }

        return model;

    }

    //表格显示批量插入的机房信息

    public ServiceModel serchInserStation(Object obj){

        List  list=((Fbs9100s_dfu_stateImpl)dao).serchInserStation(obj);

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

            model.setCode(1);

            model.setData(list);

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

        }else{

            model.setCode(0);

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

        }

        return model;

    }

    //批量升级前验证升级的设备必须处于在线监测状态(9100state的workstate为0)

    public ServiceModel judgeStation(Object obj){

        List  list=((Fbs9100s_dfu_stateImpl)dao).judgeStation(obj);

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

            model.setCode(1);

            model.setData(list);

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

        }else{

            model.setCode(0);

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

        }

        return model;

    }

    //升级确认

    public ServiceModel update(Object obj) {

        boolean bl=dao.update(obj);