系统参数设置

81041

2018-11-01 5d2527e2c6b3fe7f5880e258c22aea9dcc200f35

系统参数设置

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

New file
@@ -0,0 +1,58 @@
package com.fgkj.actions.ram;



import java.util.List;



import com.fgkj.actions.ActionUtil;

import com.fgkj.dao.FBS9100_ComBase;

import com.fgkj.dao.UinfDaoFactory;

import com.fgkj.dto.BattInf;

import com.fgkj.dto.ServiceModel;

import com.fgkj.dto.User_log;

import com.fgkj.dto.ram.Fbs9100_setparam;

import com.fgkj.dto.ram.Fbs9100_sysparam;

import com.fgkj.services.User_logService;

import com.fgkj.services.ram.Fbs9100_sysparamService;

import com.google.gson.reflect.TypeToken;



public class Fbs9100_sysparamAction extends ActionUtil{

    private Fbs9100_sysparamService service=new Fbs9100_sysparamService();

    private User_logService uservice=new User_logService();

    private String json;

    private String result;

	
    //修改系统参数

    public String update() {

        Fbs9100_sysparam sys = getGson().fromJson(json, Fbs9100_sysparam.class);

        ServiceModel model = service.update(sys);

        {   String msg="";

            if(sys.getNum()==FBS9100_ComBase.CMD_SetDischargeParm){

                 msg="修改"+sys.getDev_id()+"的设备放电参数";

            }else if(sys.getNum()==FBS9100_ComBase.CMD_Start){

                 msg="启动"+sys.getDev_id()+"的设备放电";

            }else if(sys.getNum()==FBS9100_ComBase.CMD_Stop){

                 msg="停止"+sys.getDev_id()+"的设备放电";

            }

            User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);

            uservice.add(ulog);//将用户的操作记录下来

        }

        result = tojson(model);		
        return SUCCESS;	
    }

    //根据设备id查询系统参数(一定是被管理的)

    public String serchByCondition(){

        Fbs9100_sysparam sys= getGson().fromJson(json, Fbs9100_sysparam.class);

        ServiceModel model = service.serchByCondition(sys);

        result = tojson(model);

        return SUCCESS;

    }

	
    public String getResult() {

        return result;

    }

    public void setJson(String json) {

        this.json = json;

    }

	
	


}


 gx_tieta/src/com/fgkj/dao/BaseDAO.java

@@ -194,6 +194,8 @@
    

    public static final int  STATIONTRAFFIC=95;

    

    public static final int  FBS9100_SYSPARAM=96;

	
    public boolean add(Object obj); // 添加



    public boolean update(Object obj); // 更新


 gx_tieta/src/com/fgkj/dao/BaseDAOFactory.java

@@ -84,6 +84,7 @@
import com.fgkj.dao.impl.ram.Bts_station_stateImpl;

import com.fgkj.dao.impl.ram.Fbs9100_setparamImpl;

import com.fgkj.dao.impl.ram.Fbs9100_stateImpl;

import com.fgkj.dao.impl.ram.Fbs9100_sysparamImpl;

import com.fgkj.dao.impl.ram.Fbs9100s_dcdc_stateImpl;

import com.fgkj.dao.impl.ram.Fbs9100s_dfu_stateImpl;

import com.fgkj.dao.impl.ram.Fbs9600_stateImpl;

@@ -200,6 +201,7 @@
            case 93:return new Battinf_exImpl();

            case 94:return new Deverror_recordImpl();

            case 95:return new  StationtrafficImpl();

            case 96:return new  Fbs9100_sysparamImpl();

            default :return null;

        }

    }


 gx_tieta/src/com/fgkj/dao/FBS9100_ComBase.java

@@ -29,6 +29,13 @@
    //FBS9600S设备内阻测试的启动命令

    final public static  int CMD_9600_Start=1;

    

    //系统参数命令

    public static final int     CMD_GetSYSSetParamAck            =    0x7E; //126

    public static final int     CMD_SetSYSSetParamAck            =    0x7F; //127

    public static final int     CMD_GetSYSSetParam                =    0x80;//获取系统参数128

    public static final int     CMD_SetSYSSetParam                =    0x81;//设置系统参数129

    public static final int     CMD_ResetSystemAck                =     0x0F;//15

    public static final int     CMD_ResetSystem                    =     0x10;//重启16

    

    //6185设备工作状态对应关系workstate

    final public static  int DEV_ONLINE_CHARGE=0;  //在线浮充


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

@@ -244,6 +244,7 @@
            case FBS9100_ComBase.CMD_GetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_GetDischargeParmAck; break;

            case FBS9100_ComBase.CMd_SetIp_Tem: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;

            case FBS9100_ComBase.CMd_SetIp_Per: m_cmd_ack = FBS9100_ComBase.CMd_SetIpAck; break;

            case FBS9100_ComBase.CMD_ResetSystem: m_cmd_ack = FBS9100_ComBase.CMD_ResetSystemAck; break;

            default: return false;

        }

        String sql_end = "";


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

New file
@@ -0,0 +1,162 @@
package com.fgkj.dao.impl.ram;



import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;



import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.CallBack;

import com.fgkj.dao.DAOHelper;

import com.fgkj.dao.FBS9100_ComBase;

import com.fgkj.db.DBUtil;

import com.fgkj.dto.ram.Fbs9100_sysparam;



public class Fbs9100_sysparamImpl implements BaseDAO,CallBack{



    public List getResults(ResultSet rs) {

        // TODO Auto-generated method stub

        return null;

    }

    
    public boolean add(Object obj) {

        // TODO Auto-generated method stub

        return false;

    }

    //修改系统参数

    public boolean update(Object obj) {

        Fbs9100_sysparam sys=(Fbs9100_sysparam) obj;

        String sql=" update db_ram_db.tb_fbs9100_sysparam set IPADDR=?,SubIPADDR=?,NetGateADDR=?,GroupVolRange=?,GroupVolSorce=?,CurrentRange=?,CurrentTyte=?,MonomerOrder=?,BackLightTime=?" +

                ",MACADDR=?,LoaderCount=?,DtCardCount=?,PowerBreakChargeCurr=?,MajorBattGroupNum=?,POF_BG_Boost_Cnt=?,POF_BG_Boost_VolStop=?,POF_BG_Boost_VolStart=? " +

                "where dev_id=? ";

        boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sys.getIPADDR(),sys.getSubIPADDR(),sys.getNetGateADDR(),sys.getGroupVolRange(),sys.getGroupVolSorce(),sys.getCurrentRange(),sys.getCurrentTyte(),sys.getMonomerOrder(),sys.getBackLightTime()

            ,sys.getMACADDR(),sys.getLoaderCount(),sys.getDtCardCount(),sys.getPowerBreakChargeCurr(),sys.getMajorBattGroupNum(),sys.getPOF_BG_Boost_Cnt(),sys.getPOF_BG_Boost_VolStop(),sys.getPOF_BG_Boost_VolStart(),sys.getDev_id()});

        return bl;

    }



    public boolean del(Object obj) {

        // TODO Auto-generated method stub

        return false;

    }



    public List searchAll() {

        // TODO Auto-generated method stub

        return null;

    }

    //根据设备id查询系统参数(一定是被管理的)

    public List serchByCondition(Object obj) {

        Fbs9100_sysparam sys=(Fbs9100_sysparam) obj;

        String sql=" select distinct dev_ip,dev_id,op_cmd,IPADDR,SubIPADDR,NetGateADDR,GroupVolRange,GroupVolSorce,CurrentRange,CurrentTyte,MonomerOrder,BackLightTime" +

                " ,MACADDR,LoaderCount,DtCardCount,PowerBreakChargeCurr,MajorBattGroupNum,POF_BG_Boost_Cnt,POF_BG_Boost_VolStop,POF_BG_Boost_VolStart" +

                " ,db_battinf.tb_battinf.FBSDeviceName,db_battinf.tb_battinf.StationName " +

                " from db_ram_db.tb_fbs9100_sysparam,db_battinf.tb_battinf " +

                " where db_ram_db.tb_fbs9100_sysparam.dev_id=db_battinf.tb_battinf.FBSDeviceId " +

                " and db_ram_db.tb_fbs9100_sysparam.dev_id=?  " ;

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

			
            public List getResults(ResultSet rs) {

                List list=new ArrayList();

                try {

                    while(rs.next()){

                        Fbs9100_sysparam fbs_sys=new Fbs9100_sysparam();

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

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

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

                        fbs_sys.setIPADDR(rs.getString("iPADDR"));

                        fbs_sys.setSubIPADDR(rs.getString("subIPADDR"));

                        fbs_sys.setNetGateADDR(rs.getString("netGateADDR"));

                        fbs_sys.setGroupVolRange(rs.getInt("groupVolRange"));

                        fbs_sys.setGroupVolSorce(rs.getInt("groupVolSorce"));

                        fbs_sys.setCurrentRange(rs.getInt("currentRange"));

                        fbs_sys.setCurrentTyte(rs.getInt("currentTyte"));

                        fbs_sys.setMonomerOrder(rs.getInt("monomerOrder"));

                        fbs_sys.setBackLightTime(rs.getInt("backLightTime"));

                        fbs_sys.setMACADDR(rs.getString("mACADDR"));

                        fbs_sys.setLoaderCount(rs.getInt("loaderCount"));

                        fbs_sys.setDtCardCount(rs.getInt("dtCardCount"));

                        fbs_sys.setPowerBreakChargeCurr(rs.getFloat("powerBreakChargeCurr"));

                        fbs_sys.setMajorBattGroupNum(rs.getInt("majorBattGroupNum"));

                        fbs_sys.setPOF_BG_Boost_Cnt(rs.getInt("pOF_BG_Boost_Cnt"));

                        fbs_sys.setPOF_BG_Boost_VolStop(rs.getFloat("pOF_BG_Boost_VolStop"));

                        fbs_sys.setPOF_BG_Boost_VolStart(rs.getFloat("pOF_BG_Boost_VolStart"));

                        fbs_sys.setFBSDeviceName(rs.getString("FBSDeviceName"));

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

                        list.add(fbs_sys);

                    }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

						
                return list;

            }

        });

        return list;

    }

    //系统参数命令操作设备时的cmd和ack校验	
    public boolean sendCmdToFBS9100Dev(int cmd,int dev_id)

    { 
        int m_cmd = cmd;

        int m_cmd_ack = cmd;

        switch(m_cmd) {

            case FBS9100_ComBase.CMD_GetSYSSetParam: m_cmd_ack = FBS9100_ComBase.CMD_GetSYSSetParamAck; break;

            case FBS9100_ComBase.CMD_SetSYSSetParam: m_cmd_ack = FBS9100_ComBase.CMD_SetSYSSetParamAck; break;

            default: return false;

        }

        boolean res_exe = false;

        String sql = "UPDATE db_ram_db.tb_fbs9100_sysparam  SET "

                        + " op_cmd=? " 
                        + " WHERE dev_id=? ";

        Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{m_cmd,dev_id});

        if(true == bl)

        {

            sql = "SELECT op_cmd FROM db_ram_db.tb_fbs9100_sysparam "+

                        " WHERE dev_id="+dev_id;

            Connection conn=DBUtil.getConn();

            PreparedStatement ps = null;

            ResultSet rs = null;

            for(int n=0; n<20; n++)

            {

              try {

                    ps = conn.prepareStatement(sql);

                    rs=ps.executeQuery();

                        if(rs.next())

                        {

                            if(rs.getInt("op_cmd") == m_cmd_ack)

                            {

                                res_exe = true;

                                break;

                            }

                        }

                } catch (SQLException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

			  
                try {

                    Thread.sleep(250);

                } catch (InterruptedException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

            }

            DBUtil.close(rs, ps, conn);

        }

        return res_exe;

    }

    public List serchByInfo(Object obj) {

        // TODO Auto-generated method stub

        return null;

    }

	
    public static void main(String[] args) {

        Fbs9100_sysparamImpl fimpl=new Fbs9100_sysparamImpl();

        Fbs9100_sysparam sys=new Fbs9100_sysparam();

        sys.setDev_id(910000011);

        List list=fimpl.serchByCondition(sys);

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

    }



}


 gx_tieta/src/com/fgkj/dto/ram/Fbs9100_sysparam.java

New file
@@ -0,0 +1,197 @@
package com.fgkj.dto.ram;



import java.io.Serializable;



public class Fbs9100_sysparam implements Serializable{

    private int num;

    private String dev_ip;

    private int dev_id;

    private int op_cmd;

    private String IPADDR;

    private String SubIPADDR;

    private String NetGateADDR;

    private int GroupVolRange;

    private int GroupVolSorce;

    private int CurrentRange;

    private int CurrentTyte;

    private int MonomerOrder;

    private int BackLightTime;

    private String MACADDR;

    private int LoaderCount;

    private int DtCardCount;

    private float PowerBreakChargeCurr;

    private int MajorBattGroupNum;

    private int POF_BG_Boost_Cnt;

    private float POF_BG_Boost_VolStop;

    private float POF_BG_Boost_VolStart;

    private String stationName;

    private String FBSDeviceName;

    private String note;

    public int getNum() {

        return num;

    }

    public void setNum(int num) {

        this.num = num;

    }

    public String getDev_ip() {

        return dev_ip;

    }

    public void setDev_ip(String dev_ip) {

        this.dev_ip = dev_ip;

    }

    public int getDev_id() {

        return dev_id;

    }

    public void setDev_id(int dev_id) {

        this.dev_id = dev_id;

    }

    public int getOp_cmd() {

        return op_cmd;

    }

    public void setOp_cmd(int op_cmd) {

        this.op_cmd = op_cmd;

    }

    public String getIPADDR() {

        return IPADDR;

    }

    public void setIPADDR(String iPADDR) {

        IPADDR = iPADDR;

    }

    public String getSubIPADDR() {

        return SubIPADDR;

    }

    public void setSubIPADDR(String subIPADDR) {

        SubIPADDR = subIPADDR;

    }

    public String getNetGateADDR() {

        return NetGateADDR;

    }

    public void setNetGateADDR(String netGateADDR) {

        NetGateADDR = netGateADDR;

    }

    public int getGroupVolRange() {

        return GroupVolRange;

    }

    public void setGroupVolRange(int groupVolRange) {

        GroupVolRange = groupVolRange;

    }

    public int getGroupVolSorce() {

        return GroupVolSorce;

    }

    public void setGroupVolSorce(int groupVolSorce) {

        GroupVolSorce = groupVolSorce;

    }

    public int getCurrentRange() {

        return CurrentRange;

    }

    public void setCurrentRange(int currentRange) {

        CurrentRange = currentRange;

    }

    public int getCurrentTyte() {

        return CurrentTyte;

    }

    public void setCurrentTyte(int currentTyte) {

        CurrentTyte = currentTyte;

    }

    public int getMonomerOrder() {

        return MonomerOrder;

    }

    public void setMonomerOrder(int monomerOrder) {

        MonomerOrder = monomerOrder;

    }

    public int getBackLightTime() {

        return BackLightTime;

    }

    public void setBackLightTime(int backLightTime) {

        BackLightTime = backLightTime;

    }

    public String getMACADDR() {

        return MACADDR;

    }

    public void setMACADDR(String mACADDR) {

        MACADDR = mACADDR;

    }

    public int getLoaderCount() {

        return LoaderCount;

    }

    public void setLoaderCount(int loaderCount) {

        LoaderCount = loaderCount;

    }

    public int getDtCardCount() {

        return DtCardCount;

    }

    public void setDtCardCount(int dtCardCount) {

        DtCardCount = dtCardCount;

    }

    public float getPowerBreakChargeCurr() {

        return PowerBreakChargeCurr;

    }

    public void setPowerBreakChargeCurr(float powerBreakChargeCurr) {

        PowerBreakChargeCurr = powerBreakChargeCurr;

    }

    public int getMajorBattGroupNum() {

        return MajorBattGroupNum;

    }

    public void setMajorBattGroupNum(int majorBattGroupNum) {

        MajorBattGroupNum = majorBattGroupNum;

    }

    public int getPOF_BG_Boost_Cnt() {

        return POF_BG_Boost_Cnt;

    }

    public void setPOF_BG_Boost_Cnt(int pOF_BG_Boost_Cnt) {

        POF_BG_Boost_Cnt = pOF_BG_Boost_Cnt;

    }

    public float getPOF_BG_Boost_VolStop() {

        return POF_BG_Boost_VolStop;

    }

    public void setPOF_BG_Boost_VolStop(float pOF_BG_Boost_VolStop) {

        POF_BG_Boost_VolStop = pOF_BG_Boost_VolStop;

    }

    public float getPOF_BG_Boost_VolStart() {

        return POF_BG_Boost_VolStart;

    }

    public void setPOF_BG_Boost_VolStart(float pOF_BG_Boost_VolStart) {

        POF_BG_Boost_VolStart = pOF_BG_Boost_VolStart;

    }

    public String getStationName() {

        return stationName;

    }

    public void setStationName(String stationName) {

        this.stationName = stationName;

    }

	
    public String getNote() {

        return note;

    }

    public void setNote(String note) {

        this.note = note;

    }

    public String getFBSDeviceName() {

        return FBSDeviceName;

    }

    public void setFBSDeviceName(String fBSDeviceName) {

        FBSDeviceName = fBSDeviceName;

    }

    @Override

    public String toString() {

        return "Fbs9100_sysparam [num=" + num + ", dev_ip=" + dev_ip

                + ", dev_id=" + dev_id + ", op_cmd=" + op_cmd + ", IPADDR="

                + IPADDR + ", SubIPADDR=" + SubIPADDR + ", NetGateADDR="

                + NetGateADDR + ", GroupVolRange=" + GroupVolRange

                + ", GroupVolSorce=" + GroupVolSorce + ", CurrentRange="

                + CurrentRange + ", CurrentTyte=" + CurrentTyte

                + ", MonomerOrder=" + MonomerOrder + ", BackLightTime="

                + BackLightTime + ", MACADDR=" + MACADDR + ", LoaderCount="

                + LoaderCount + ", DtCardCount=" + DtCardCount

                + ", PowerBreakChargeCurr=" + PowerBreakChargeCurr

                + ", MajorBattGroupNum=" + MajorBattGroupNum

                + ", POF_BG_Boost_Cnt=" + POF_BG_Boost_Cnt

                + ", POF_BG_Boost_VolStop=" + POF_BG_Boost_VolStop

                + ", POF_BG_Boost_VolStart=" + POF_BG_Boost_VolStart

                + ", stationName=" + stationName + ", FBSDeviceName="

                + FBSDeviceName + ", note=" + note + "]";

    }

	
    
    
}


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

New file
@@ -0,0 +1,63 @@
package com.fgkj.services.ram;



import java.util.ArrayList;

import java.util.List;



import com.fgkj.dao.BaseDAO;

import com.fgkj.dao.BaseDAOFactory;

import com.fgkj.dao.FBS9100_ComBase;

import com.fgkj.dao.impl.ram.Fbs9100_setparamImpl;

import com.fgkj.dao.impl.ram.Fbs9100_sysparamImpl;

import com.fgkj.dto.ServiceModel;

import com.fgkj.dto.ram.Fbs9100_sysparam;



public class Fbs9100_sysparamService {

    private BaseDAO dao;

    private ServiceModel model;

	
    public Fbs9100_sysparamService() {

        super();

        dao=BaseDAOFactory.getBaseDAO(BaseDAO.FBS9100_SYSPARAM);

        model=new ServiceModel();

    }

    //修改系统参数

    public ServiceModel update(Object obj) {

        Fbs9100_sysparam fbs_sys=(Fbs9100_sysparam) obj;

        Boolean b=dao.update(obj);

        boolean bl=false;

        if(b){

            if(fbs_sys.getNum()==FBS9100_ComBase.CMD_ResetSystem){//重启

                bl=(new Fbs9100_setparamImpl()).sendCmdToFBS9100Dev(fbs_sys.getNum(),0, fbs_sys.getDev_id());

            }else{

                bl=((Fbs9100_sysparamImpl)dao).sendCmdToFBS9100Dev(fbs_sys.getNum(), fbs_sys.getDev_id());

            }

            if(bl){

                model.setCode(1);

                model.setMsg("修改成功!");

            }else{

                model.setCode(0);

                model.setMsg("设置9100参数失败,请检查网络!");

            }

        }else{

            model.setCode(0);

            model.setMsg("修改失败!");

        }	
        return model;	
    }

	
    //根据设备id查询系统参数(一定是被管理的)

    public ServiceModel serchByCondition(Object obj){

        List list = dao.serchByCondition(obj);

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

            model.setCode(1);

            model.setData(list);

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

        }else{

            model.setCode(0);

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

        }

        return model;

    } 
	


}