修改

81041

2019-01-02 330af18d13ef884407a5e1b40e5fac4e52306c32

修改

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

@@ -90,6 +90,9 @@
                }

                maxb++;

                sql_str.add(sql);

                String baoji_sql="REPLACE into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) " + 
                         " SELECT baoji_group_id,'"+binf.getStationId()+"',"+binf.getBattGroupId()+" from  db_user.tb_user_battgroup_baojigroup_usr where uid="+((User_inf)ActionUtil.getUser()).getUId();

                sql_str.add(baoji_sql);

                {

                    String msg="添加"+binf.getStationName()+"机房"+binf.getBattGroupId()+"电池组的信息";

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


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

@@ -139,7 +139,7 @@
                        ",'"+binf.getBattProducer()+"','"+binf.getBattModel()+"','"+DAOHelper.sdf.format(binf.getBattProductDate())+"','"+DAOHelper.sdf.format(binf.getBattInUseDate())+"',"+binf.getLoad_curr()+",'"+binf.getInstall_user()+"',"+binf.getDisCurrMax()+",'"+binf.getStation_phone()+"',"+binf.getStation_install()+")";

                sql_str.add(sql_insert_binf);

                String baoji_sql="REPLACE into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) " + 

                                 " SELECT baoji_group_id,'"+binf.getStationId()+"',"+binf.getBattGroupId()+" from  db_user.tb_user_battgroup_baojigroup ";

                                 " SELECT baoji_group_id,'"+binf.getStationId()+"',"+binf.getBattGroupId()+" from  db_user.tb_user_battgroup_baojigroup_usr where uid="+bapply.getApply_uid();

                sql_str.add(baoji_sql);

                {

                    String msg="确认添加"+binf.getStationName()+"机房"+binf.getBattGroupId()+"电池组的信息";


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

@@ -11,8 +11,12 @@
import com.fgkj.dao.CallBack;

import com.fgkj.dao.DAOHelper;

import com.fgkj.dao.FBS9100_ComBase;

import com.fgkj.dao.UinfDaoFactory;

import com.fgkj.db.DBUtil;

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;



public class Fbs9100_sysparamImpl implements BaseDAO,CallBack{



@@ -33,6 +37,30 @@
                "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 updatePro(Object obj) {

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

        ArrayList sql_str=new ArrayList();

        List<User_log> listU=new ArrayList<User_log>();//存放user_log

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

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

                Fbs9100_sysparam fs=list.get(i);

                String sql="REPLACE  into db_ram_db.tb_fbs9100_sysparam(dev_id,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) "

                        + " values()";

                sql_str.add(sql);

                {

                    String msg="修改"+fs.getDev_id()+"机房系统参数";

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

                    listU.add(ulog);

                 }

            }

        }

		
        Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);

        (new User_logService()).addPro(listU);//将用户的操作记录下来

        return bl;

    }

    //查询系统参数前(如果没有默认数据要用REPLACE 添加一笔数据)

@@ -152,6 +180,40 @@
        }

        return res_exe;

    }

	
    //批量设置系统参数成功后读取命令的ACK

    public boolean getCmdAck(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;

        }

        String 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;

        boolean res_exe=false;

        try {

            ps = conn.prepareStatement(sql);

            rs=ps.executeQuery();

            if(rs.next())

            {

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

                {

                    res_exe = true;

                }

            }

        } catch (SQLException 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;