researchbean.java

电信的网厅的整站代码

    int i = 0;
    try {

        String sqlstr = "update tf_researchmain set Title=?,Desciption=?,ItemType=?,ObjectType=?,Gotta=?,ORDERNO=?,IssuanceState=?,GOTTACOUNT=? where RESEARCHID=?";
        Object[] _object = new Object[9];
        _object[0] = Title;
        _object[1] = Desciption;
        _object[2] = ItemType;
        _object[3] = ObjectType;
        _object[4] = Gotta;
        _object[5] = ORDERNO;
        _object[6] = IssuanceState;

        _object[7] = gottacount;
        _object[8] = ResearchId;

        i = _dac.executeUpdate(sqlstr, 10000, _object);

    } catch (Exception ex) {
        FileLogger.getLogger().warn("数据库修改出错！", ex);
    }
    return i;
}


    /**
     * WULL修改
     * 用于更新问卷的一些字段
     * @param CityCode
     * @param Title
     * @param Desciption
     * @param ObjectType
     * @param ORDERNO
     * @param IssuanceState
     * @param ResearchId
     * @return
     */
    public int updateMain(String Title, String Desciption,
                          String ObjectType, String ORDERNO,
                          String IssuanceState,String STARTTIME,String ENDTIME,
                          String ResearchId) {
        int i = 0;
        try {

            String sqlstr = "update tf_researchmain set Title=?,Desciption=?,ObjectType=?,ORDERNO=?,IssuanceState=?,STARTTIME=?,ENDTIME=? where RESEARCHID=?";
            Object[] _object = new Object[8];
           // _object[0] = CityCode;
            _object[0] = Title;
            _object[1] = Desciption;
            _object[2] = ObjectType;
            _object[3] = ORDERNO;
            _object[4] = IssuanceState;

            SimpleDateFormat sdt = new SimpleDateFormat("yyyy-MM-dd");
            //Date startdate = sdt.parse(starttime);
            if (STARTTIME == null || "".equalsIgnoreCase(STARTTIME) ||
                "null".equalsIgnoreCase(STARTTIME)) {
                _object[5] = null;
            } else {
                _object[5] = sdt.parse(STARTTIME);
            }
            if (ENDTIME == null || "".equalsIgnoreCase(ENDTIME) ||
                "null".equalsIgnoreCase(ENDTIME)) {
                _object[6] = null;
            } else {
                _object[6] = sdt.parse(ENDTIME);
            }
            _object[7] = ResearchId;
            i = _dac.executeUpdate(sqlstr, 10000, _object);

        } catch (Exception ex) {
            FileLogger.getLogger().warn("数据库修改出错！", ex);

        }
        return i;
    }



    /**
     * wull.2005.12.24
     * 更新题目的排列序号，业务
     * @param orderno String[]
     * @param ResearchId String[]
     * @return String
     */
    public String UpdateAbecedarian(String[] orderno, String[] ResearchId){
     int i = 0;
     if(orderno == null || ResearchId == null)return String.valueOf(i);
    try {
        for (int j=0; j < orderno.length; j++) {
           i = UpdateAbecedarian( orderno[j],  ResearchId[j]);
        }
    } catch (Exception ex) {
    }
     return String.valueOf(i);
  }
    /**
     * wull.数据库
     * 用来更新序列号。执行数据库。
     * @param orderno String
     * @param ResearchId String
     * @return String
     */
    public int UpdateAbecedarian(String orderno, String ResearchId) {
        int i = 0;
        try {
            String sqlstr =
                    "UPDATE TF_RESEARCHMAIN SET ORDERNO=? WHERE RESEARCHID=?";
            Object[] _object = new Object[2];
            _object[0] = orderno;
            _object[1] = ResearchId;
            i = _dac.executeUpdate(sqlstr, 10000, _object);

        } catch (Exception ex) {
            FileLogger.getLogger().warn("数据库修改出错！", ex);
        }
        return i;
    }


    /**
     * 删除题目
     * @param rid
     * @return
     */
    public int updateReDel(String rid) {
        int i = 0;
        try {
            Object[] _object = new Object[1];
            _object[0] = rid;
            //String sqlsub = "delete from tf_researchsub where ResearchId=?";
            String sql = "delete from tf_researchmain where ResearchId=?";

            //_dac.executeUpdate(sqlsub, 1000, _object);
            i = _dac.executeUpdate(sql, 1000, _object);


        } catch (Exception ex) {
            FileLogger.getLogger().warn("删除题目！", ex);
        }
        return i;
    }


    /**
     * 用来查询选项及投票数。
     * @param rid String
     * @param pageNo int
     * @return DataTable
     */
    public DataTable querySub(String rid, int pageNo) {
        //wull注：暂时不分页
        dt = null;
        try {
//            int start = (pagecount * (pageNo - 1))+1;
//            int end = pagecount * pageNo;
//            String sql = "select * from (select a.*,rownum num from"
//                         + "(select * from tf_researchsub where ResearchId=? order by OPTIONID)a)t where t.num between "
//                         + String.valueOf(start) + " and "
//                         + String.valueOf(end);
           // String sql = "select * from tf_researchsub where ResearchId=? order by ORDERNO,OPTIONID";

           String sql ="select a.*, nvl(b.countnum,0) countnum"+
                       " from tf_researchsub a,"+
                       " (select count(c.optionid) countnum, c.optionid"+
                       " from tf_researchresult c group by c.optionid) b"+
                       " where a.researchid = ? and a.optionid = b.optionid(+)"+
                       " order by a.ORDERNO, a.OPTIONID ";

            Object[] _object = new Object[1];
            _object[0] = rid;

            dt = _dac.executeQuery(sql, _object);
        } catch (Exception ex) {
            FileLogger.getLogger().warn("用来查询选项及投票数！", ex);
            dt = null;
        }
        return dt;
    }

    /**
     * 用于查询选项的记录
     * @param id
     * @return
     */
    public DataTable querySubRid(String id) {

        dt = null;
        try {
            String sql =
                    "select * from tf_researchsub  where OptionId=? order by OptionId";
            Object[] _object = new Object[1];
            _object[0] = id;
            dt = _dac.executeQuery(sql, _object);
        } catch (Exception ex) {
            FileLogger.getLogger().warn("用于查询选项的记录！", ex);
            dt = null;
        }
        return dt;
    }

    /**
     * 添加选项
     * @param ResearchId
     * @param Title
     * @param State
     * @param scale
     * @param OptionMode
     * @param OrderNo
     * @return
     */
    public int updateSubAdd(String ResearchId, String Title, String State,
                            String scale, String OptionMode, String OrderNo) { //OptionMode
        // 调查模式暂时不用
        int i = 0;
        try {
            String sql = "Insert into tf_researchsub(OPTIONID,ResearchId,Title,State,scale,OrderNo) values(seq_reseresuid.nextval,?,?,?,?,?)";
            Object[] _object = new Object[5];
            _object[0] = ResearchId;
            _object[1] = Title;
            _object[2] = State;
            _object[3] = scale;
            _object[4] = OrderNo;

            _dac.beginTransaction(10000);
            i = _dac.executeUpdate(sql, 10000, _object);
            _dac.endTransaction(true);
        } catch (Exception ex) {
            FileLogger.getLogger().warn("数据库入库出错！", ex);
            try {
                _dac.endTransaction(false);
            } catch (Exception ex1) {
            }

        }
        return i;
    }

    /**
     * wull.12.24
     * 删除选项以及提交的记录。
     * @param oid
     * @return
     */
    public int updateSubDel(String oid) {
        int i = 0;
        try {
            //选项
            String sql = "delete from tf_researchsub where OptionId=?";
            //被提交的调查记录。删除时先删除提交的内容。
            String sql2 = "delete from tf_researchresult where OptionId=?";
            Object[] _object = new Object[1];
            _object[0] = oid;
            _dac.beginTransaction(10000);
            i = _dac.executeUpdate(sql2, 1000, _object);
            i = _dac.executeUpdate(sql, 1000, _object);
            _dac.endTransaction(true);

        } catch (Exception ex) {
            FileLogger.getLogger().warn("选项删除出错！", ex);
            try {
                _dac.endTransaction(false);
            } catch (Exception ex1) {
                FileLogger.getLogger().warn("选项删除出错！", ex);
            }

        }
        return i;
    }

    /**
     * 修改选项
     * @param OptionId
     * @param ResearchId
     * @param Title
     * @param State
     * @param scale
     * @param OrderNo
     * @return
     */
    public int updateSub(String OptionId,String Title,
                          String State, String scale, String OrderNo) {
        int i = 0;
        try {
            String sqlstr = "update tf_researchsub set Title=?,State=?,scale=?,OrderNo=? where OptionId=?";
            Object[] _object = new Object[5];
            _object[0] = Title;
            _object[1] = State;
            _object[2] = scale;
            _object[3] = OrderNo;
            _object[4] = OptionId;

            i = _dac.executeUpdate(sqlstr, 0, _object);

        } catch (Exception ex) {
            FileLogger.getLogger().warn(
                    "数据库修改出错！" + ex.getMessage().toString(), ex);

        }
        return i;
    }


    /**
     * 用于查询问卷的名称
     * @param id
     * @return
     */
    public String queryQuestion(String id) {
        String str = null;
        dt = null;
        DataRow dr = null;
        try {
            String sql = "select Title from tf_researchmain where ResearchId=?";
            Object[] _object = new Object[1];
            _object[0] = id;
            dt = _dac.executeQuery(sql, _object);
            dr = dt.getRow(0);
            str = dr.getString(0);
        } catch (Exception ex) {
            FileLogger.getLogger().warn("数据库查询出错！", ex);
        }
        return str;
    }

    /**
     * 根据问问卷的ID号找到单条问卷的数据。
     * 用于查询问卷的名称
     * @param rid
     * @return
     */
    public String queryTitle(String rid) {
        String sql = "";
        try {
            sql = "select * from tf_researchmain where RESEARCHID=?";
            Object[] _object = new Object[1];
            _object[0] = rid;
            DataTable dt = _dac.executeQuery(sql, _object);
            sql = dt.getRow(0).getString("TITLE");
        } catch (Exception ex) {
            FileLogger.getLogger().warn("查询问卷的名称出错了！", ex);
        }
        return sql;

    }

    /**
     * 查询选项的title的值
     * @param rid
     * @return
     */
    public String querySubTitle(String rid) {
        String sql = "";
        try {
            sql = "select a.title from tf_researchmain a,(select UPRESEARCHID from tf_researchmain where researchid=?)t where a.researchid=t.UPRESEARCHID";
            Object[] _object = new Object[1];
            _object[0] = rid;
            DataTable dt = _dac.executeQuery(sql, _object);

            sql = dt.getRow(0).getString("title").toString();
        } catch (Exception ex) {