researchbean.java

电信的网厅的整站代码

            FileLogger.getLogger().warn("查询问卷的选项出错了！", ex);
            sql = "";
        }
        return sql;

    }


    /*
     * 下拉框中的数据
     */
    public String buildPageOptions(int page_count, int pageNo) {
        String optionHTML = "";
        for (int i = 1; i <= page_count; i++) {
            if (pageNo == i || pageNo == 0)
                optionHTML += "<option value='" + i + "' selected/>" + i;
            else
                optionHTML += "<option value='" + i + "'/>" + i;
        }
        return optionHTML;
    }

    /**
     * 删除问卷
     * @param rid String
     * @return String
     */
    public int DelResearch(String rid) {

        int i = 0;
        String sqlstr_main = " DELETE FROM TF_RESEARCHMAIN WHERE RESEARCHID=?";
        try {

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

            i = _dac.executeUpdate(sqlstr_main, 10000, main_object);

        } catch (Exception ex) {
            FileLogger.getLogger().warn("删除问卷出错了！", ex);
        }

        return i;
    }


    /**
     * wull.2005.12.25
     * 删除问卷删除问卷，题目，选项
     * @param rid String
     * @return String
     */
    public String DelResMain(String rid) {
        DataTable r_dt = queryRe(rid,123);
        String i = "0";
        String sub_id = null;
        try {
             _dac.beginTransaction(10000);
            for (int j = 0; j < r_dt.getRows().getCount(); j++) {
                DataRow dr_opt = r_dt.getRow(j);
                sub_id = dr_opt.getString("RESEARCHID");
                //取出题目的ID号删除题目。
                i = DelSubAndOpt(sub_id);
            }
            i = String.valueOf(DelResearch(rid));
            _dac.endTransaction(true);
        } catch (Exception ex) {
            try {
               _dac.endTransaction(false);
           } catch (Exception ex1) {
               FileLogger.getLogger().warn("删除问卷，题目，选项出错了！", ex);
           }

            FileLogger.getLogger().warn("删除问卷，题目，选项出错了！", ex);
        }
        return i;
    }

    /**
     * wull 2005-12-25
     *  删除题目，选项，以及用户提票的东东
     * @param subid String题目的ID号
     * @return String
     */
    public String DelSubAndOpt(String subid) {
        //先搜出选项。然后再根据选项ID到调查表里删除。
        DataTable sub_dt = querySub(subid, 1);
        int i = 0;
        String option_id = null;
        try {
             _dac.beginTransaction(10000);
            for (int j = 0; j < sub_dt.getRows().getCount(); j++) {
                DataRow dr_opt = sub_dt.getRow(j);
                option_id = dr_opt.getString("OPTIONID");
                //删除
                i = updateSubDel(option_id);
            }
            //删除题目
            i = updateReDel(subid);
            _dac.endTransaction(true);
        } catch (Exception ex) {
            try {
               _dac.endTransaction(false);
           } catch (Exception ex1) {
               FileLogger.getLogger().warn("删除题目，选项出错了！", ex);
           }

             FileLogger.getLogger().warn("删除题目，选项出错了！", ex);
        }
        return String.valueOf(i);
    }

    /**
     * wull 12.24
     * 更新，题目，选项。
     * @param map Map
     * @return String
     */
    public String UpdateResearchAndSub(Map map){
        //查看有没有父ID号,如果没有说是是问卷
       /*通过该ID号查看是否是问卷,还是题目.如果是问卷则入0.否入传过来的ID号.说明是题目*/
       String UPRESEARCHID = (String) map.get("UPRESEARCHID");
       String RESEARCHID = (String) map.get("RESEARCHID");//题目ID号
       String TITLE = (String)map.get("TITLE");
       String DESCIPTION = (String) map.get("DESCIPTION");
       String ITEMTYPE = (String) map.get("ITEMTYPE");
       String OBJECTTYPE = (String) map.get("OBJECTTYPE");
       String GOTTA = (String) map.get("GOTTA");
       String ORDERNO = (String) map.get("ORDERNO");
       String ISSUANCESTATE = (String) map.get("ISSUANCESTATE");
       String GOTTACOUNT = (String) map.get("GOTTACOUNT");
       //

       //是否同时更新选项
       String isOption = (String) map.get("isOption");

       String[] OPTIONID_SUB = (String[]) map.get("OPTIONID_SUB");
       String[] TITLE_SUB = (String[]) map.get("TITLE_SUB");
       String[] ISSUANCESTATE_SUB = (String[]) map.get("ISSUANCESTATE_SUB");
       String[] SCALE_SUB = (String[]) map.get("SCALE_SUB");
       String[] ORDERNO_SUB = (String[]) map.get("ORDERNO_SUB");


       //更新题目
       int re = 0;
       try {
           _dac.beginTransaction(10000);

           re = updateRe(TITLE, DESCIPTION, ITEMTYPE, OBJECTTYPE, GOTTA,
                         ORDERNO, ISSUANCESTATE, RESEARCHID,GOTTACOUNT);
           //更新选项,如果状态为1时更改。
           if("1".equals(isOption)){
               for (int i = 0; i < OPTIONID_SUB.length; i++) {
                   if (!"".equals(OPTIONID_SUB[i])) {
                       re = updateSub(OPTIONID_SUB[i], TITLE_SUB[i],
                                      ISSUANCESTATE_SUB[i],
                                      SCALE_SUB[i], ORDERNO_SUB[i]);
                   } else {
                       //如果ID为“”。则是新加入的选项。
                       re = updateSubAdd(RESEARCHID, TITLE_SUB[i],
                                         ISSUANCESTATE_SUB[i],
                                         SCALE_SUB[i], "", ORDERNO_SUB[i]);
                   }
               }
           }
            _dac.endTransaction(true);
       } catch (Exception ex) {
           try{
               _dac.endTransaction(false);
               FileLogger.getLogger().warn("更新，题目，选项！", ex);
           }catch (Exception ex1) {
               FileLogger.getLogger().warn("更新，题目，选项！", ex1);
           }
       }
       return String.valueOf(re);
    }

    /**
     * wull
     * 增加数据，问卷，问题，选择项
     * @param map HashMap
     * @return Map
     */
    public Map InsertResearchAndSub(Map map){

        String CITYCODE = (String) map.get("CITYCODE");
        String TITLE_MAIN = (String) map.get("TITLE_MAIN");
        String DESCIPTION_MAIN = (String) map.get("DESCIPTION_MAIN");
        String OBJECTTYPE_MAIN = (String) map.get("OBJECTTYPE_MAIN");
        String ISSUANCESTATE_MAIN = (String) map.get("ISSUANCESTATE_MAIN");
        String ORDERNO_MAIN = (String) map.get("ORDERNO_MAIN");
        String STARTTIME = (String) map.get("STARTTIME");
        String ENDTIME = (String) map.get("ENDTIME");



        String TITLE = (String)map.get("TITLE");

        //查看有没有父ID号,如果没有说是是问卷
        /*通过该ID号查看是否是问卷,还是题目.如果是问卷则入0.否入传过来的ID号.说明是题目*/
        String UPRESEARCHID = (String)map.get("UPRESEARCHID");


        String DESCIPTION = (String)map.get("DESCIPTION");
        String ITEMTYPE = (String)map.get("ITEMTYPE");
        String OBJECTTYPE = (String)map.get("OBJECTTYPE");
        String GOTTA = (String)map.get("GOTTA");
        String ORDERNO = (String)map.get("ORDERNO");
        String ISSUANCESTATE =  (String)map.get("ISSUANCESTATE");
        String GOTTACOUNT =  (String)map.get("GOTTACOUNT");


        String[] TITLE_SUB = (String[])map.get("TITLE_SUB");
        String[] ISSUANCESTATE_SUB = (String[])map.get("ISSUANCESTATE_SUB");
        String[] SCALE_SUB = (String[])map.get("SCALE_SUB");
        String[] ORDERNO_SUB = (String[])map.get("ORDERNO_SUB");

        int i = 0;
        String id_main = null;
        String sqlstr_main = " INSERT INTO TF_RESEARCHMAIN(RESEARCHID,CITYCODE,TITLE,DESCIPTION,CREATETIME,OBJECTTYPE,ORDERNO,ISSUANCESTATE,UPRESEARCHID,STARTTIME,ENDTIME)"+
                             " VALUES(?,?,?,?,SYSDATE,?,?,?,?,?,?)";

        String sqlstr = "INSERT INTO TF_RESEARCHMAIN(RESEARCHID,CITYCODE,TITLE,DESCIPTION,CREATETIME,ITEMTYPE,OBJECTTYPE,GOTTA,UPRESEARCHID,ORDERNO,ISSUANCESTATE,GOTTACOUNT)"+
               " VALUES(?,?,?,?,SYSDATE,?,?,?,?,?,?,?)";
        String sql_sub = "INSERT INTO TF_RESEARCHSUB(OPTIONID,RESEARCHID,TITLE,STATE,SCALE,ORDERNO) VALUES(SEQ_RESERESUID.NEXTVAL,?,?,?,?,?)";


        try {
           _dac.beginTransaction(10000);

          /*当父ID为空时,入问卷.*/
           if (UPRESEARCHID == null || "null".equalsIgnoreCase(UPRESEARCHID)) {
               long mainid = (long) _dac.getSequence("seq_researchid");
               Long main_long = new Long(mainid);

               id_main = main_long.toString();

               Object[] main_object = new Object[10];
               main_object[0] = id_main;
               main_object[1] = CITYCODE;
               main_object[2] = TITLE_MAIN;
               main_object[3] = DESCIPTION_MAIN;
               main_object[4] = OBJECTTYPE_MAIN;
               main_object[5] = ORDERNO_MAIN;
               main_object[6] = ISSUANCESTATE_MAIN;
               main_object[7] = "0";
               SimpleDateFormat sdt = new SimpleDateFormat("yyyy-MM-dd");
               //Date startdate = sdt.parse(starttime);
               if(STARTTIME== null || "".equalsIgnoreCase(STARTTIME) || "null".equalsIgnoreCase(STARTTIME)){
                   main_object[8] = null;
               }else{
                  main_object[8] = sdt.parse(STARTTIME);
               }
               if(ENDTIME== null || "".equalsIgnoreCase(ENDTIME) || "null".equalsIgnoreCase(ENDTIME)){
                   main_object[9] = null;
               }else{
                  main_object[9] = sdt.parse(ENDTIME);
               }

               i = _dac.executeUpdate(sqlstr_main, 10000, main_object);

           }

           //题目.
           long id = (long) _dac.getSequence("seq_researchid");
           Long _long = new Long(id);
           //int sql_id = _long.intValue();

           String sql_str = _long.toString();

           Object[] _object = new Object[11];
           _object[0] = sql_str;
           _object[1] = CITYCODE;
           _object[2] = TITLE;
           _object[3] = DESCIPTION;
           _object[4] = ITEMTYPE;
           _object[5] = OBJECTTYPE;
           _object[6] = GOTTA;

           /*如果入第一题时,是用问卷的ID号.如果是第二次入则是传入父ID*/
           if (UPRESEARCHID == null || "null".equalsIgnoreCase(UPRESEARCHID)) {
               _object[7] = id_main;
           }else{
               _object[7] = UPRESEARCHID;
           }
           _object[8] = ORDERNO;
           _object[9] = ISSUANCESTATE;
           _object[10] = GOTTACOUNT;

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

          //选项
          for (int z = 0; z<TITLE_SUB.length; z++) {
              Object[] sub_object = new Object[5];
              sub_object[0] = sql_str;
              sub_object[1] = TITLE_SUB[z];
              sub_object[2] = ISSUANCESTATE_SUB[z];
              sub_object[3] = SCALE_SUB[z];
              sub_object[4] = ORDERNO_SUB[z];

              i = _dac.executeUpdate(sql_sub, 10000, sub_object);

          }


          _dac.endTransaction(true);

        } catch (Exception ex) {
            try{
                _dac.endTransaction(true);
            } catch (Exception ex1) {
               FileLogger.getLogger().warn("同时输入问卷与题目回滚出错了！", ex);
            }
            FileLogger.getLogger().warn("同时输入问卷与题目出错了！", ex);
        }

      Map re = new HashMap();
      re.put("result",String.valueOf(i));

      if (UPRESEARCHID == null || "null".equalsIgnoreCase(UPRESEARCHID)) {
          re.put("rid", id_main);
      } else {
          re.put("rid", UPRESEARCHID);
      }

      return re;
    }

    /**
     * 查询某researchId下的所有评论情况。
     * @param researchId		查询问卷ID
     * @return DataTable
     * @author zengzc
     * @date   2006-1-10
     */
    public DataTable getRearchReview(String researchId) {
        StringBuffer sql = new StringBuffer();
        Object[] _object = null;

        sql.append("select * from (");
        sql.append("select t.* from (");
        sql.append("SELECT RESEARCHREVIEWID, USERID, RESEARCHID, REVIEWCONTENT,to_char(REVIEWTIME,'yyyy-mm-dd HH24:MI') REVIEWTIMER ");
        sql.append(
                "FROM Tf_ResearchReview WHERE RESEARCHID=?  order by REVIEWTIME) t)");

        _object = new Object[1];
        _object[0] = new Long(researchId);

        DataTable dt = null;
        try {
            dt = _dac.executeQuery(sql.toString(), _object);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return dt;
    }


}