reportdaoimpl.java

一套完整的工商12315的源程序jsp部分在12315里,后台JAVA部分在gs12315src里,没有打包数据库.

            rs.getString("report_extent"))));
        reportPageModelTemp.setReportDate(PubFunc.nullToStr(PubFunc.decodeGB(rs.
            getString("report_date"))));
        reportPageModelTemp.setOperator(PubFunc.nullToStr(PubFunc.decodeGB(rs.
            getString("operator"))));
        reportPageList.add(reportPageModelTemp);
      }
    }
    catch (SQLException sqle) {
      Debug.println("[ReportDAOImpl]getReportBuildPage--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }
    Debug.println(
        "[ReportDAOImpl]getReportBuildPage--->>>reportPageList.size():" +
        reportPageList.size());
    return reportPageList;
  }

  /**
   * 添加报表记录数据
   * 应用:报表生成形成报表记录数据
   */
  public String addReportBuildPage(ReportPageModel reportPageModel) throws
      AppException {
    boolean flag = false;
    String sql = null;
    String code = "";
    CLOB myCLOB = null;
    PreparedStatement stmtPrepa = null;
    try {
      //得到code
      code = getTableSN(TableNameUtil.UNIVERSAL_REPORT, "code");
      Debug.println("code:" + code);

//          conn = Common.getConnection();
//          //conn.setAutoCommit(false);
//          stmt = conn.createStatement();
      /*
                   try{
          Class.forName("oracle.jdbc.driver.OracleDriver");
          conn = DriverManager.getConnection(SystemConfig.getProperty("databaseConnectionUrl"),SystemConfig.getProperty("databaseConnectionUser"),
              SystemConfig.getProperty("databaseConnectionUserPassword"));

          //conn.setAutoCommit(false);
          stmt = conn.createStatement();

          myCLOB = getCLOB(PubFunc.toSql(reportPageModel.getContent(),0),conn);
                   } catch(Exception ex){
          Debug.println("[ReportDAOImpl]addReportBuildPage--->>>connection error:" + ex.getMessage());
                   }
       */
      String s_content = "";
      try {
        conn = com.gs.db.dbimp.DbConnectionManager.getConnection();
        //myCLOB = getCLOB(PubFunc.toSql(reportPageModel.getContent(), 0), conn);
       /*
        Debug.println(
           "[ReportDAOImpl]addReportBuildPage--->>>toSql:" +
           PubFunc.toSql(reportPageModel.getContent(), 0));
       */
       //s_content = getContent(PubFunc.toSql(reportPageModel.getContent(), 0), conn);
       s_content = reportPageModel.getContent();
      }
      catch (Exception ex) {
        Debug.println(
            "[ReportDAOImpl]addReportBuildPage--->>>connection error:" +
            ex.getMessage());
      }
      /*
      Debug.println(
          "[ReportDAOImpl]addReportBuildPage--->>>s_content:" +
          s_content);
       */
      //是否正常数据
      if (reportPageModel == null) {
        Debug.println(
            "[ReportDAOImpl]addReportBuildPage----->ReportPageModel is null!");
        return code;
      }

      /*
                   code 编号
                   page_code 表名
                   explain 说明
                   content 内容
                   build_date 生成日期
                   report_unit 报表单位
                   report_from 起始日期
                   report_to 终止日期
                   report_type 期别
                   report_remark 报表备注
                   report_extent 报表范围
                   report_date报出日期
                   operator 填表人
       */

      sql = "insert into "
          + TableNameUtil.UNIVERSAL_REPORT
          + " (code,page_code,report_explain,content,build_date,report_unit,report_from,report_to,report_type,report_remark,report_extent,report_date,operator)values('"
          + code
          + "','"
          + PubFunc.toSql(reportPageModel.getPageCode(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getExplain(), 0)
          + "',"
          + "?,'"
          + PubFunc.toSql(reportPageModel.getBuildDate(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportUnit(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportFrom(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportTo(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportType(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportRemark(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportExtent(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getReportDate(), 0)
          + "','"
          + PubFunc.toSql(reportPageModel.getOperator(), 0)
          + "')"
          ;
      Debug.println("[ReportDAOImpl]addReportBuildPage--->>>sql:" + sql);

      stmtPrepa = conn.prepareStatement(sql);
      //stmtPrepa.setClob(1, myCLOB);
      stmtPrepa.setString(1, s_content);
      stmtPrepa.executeUpdate();
   //   conn.commit();

    }
    catch (SQLException sqle) {
      Debug.println("[ReportDAOImpl]addReportBuildPage--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }

    return code;
  }

  /**
   * 修改报表记录数据
   *应用:修改生成形成报表记录数据
   */
  public boolean editeReportBuildPage(ReportPageModel reportPageModel) throws
      AppException {
    boolean flag = false;
    String sql = null;
    try {
      conn = Common.getConnection();
      //conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (reportPageModel == null ||
          PubFunc.toSql(reportPageModel.getPageCode(), 0) == null ||
          "".equals(PubFunc.toSql(reportPageModel.getPageCode(), 0))) {
        Debug.println(
            "[ReportDAOImpl]addReportBuildPage----->ReportPageModel is null!");
        return flag;
      }

      /*
                   code 编号
                   page_code 表名
                   report_explain 说明
                   content 内容
                   build_date 生成日期
                   report_unit 报表单位
                   report_from 起始日期
                   report_to 终止日期
                   report_type 期别
                   report_remark 报表备注
                   report_extent 报表范围
                   report_date报出日期
                   operator 填表人
       */

      sql = "update "
          + TableNameUtil.UNIVERSAL_REPORT
          + "set page_code='"
          + PubFunc.toSql(reportPageModel.getPageCode(), 0)
          + "',report_explain='"
          + PubFunc.toSql(reportPageModel.getExplain(), 0)
//               + "',content='"
//                + PubFunc.toSql(reportPageModel.getContent(),0)
          + "',build_date='"
          + PubFunc.toSql(reportPageModel.getBuildDate(), 0)
          + "',report_unit='"
          + PubFunc.toSql(reportPageModel.getReportUnit(), 0)
          + "',report_from='"
          + PubFunc.toSql(reportPageModel.getReportFrom(), 0)
          + "',report_to='"
          + PubFunc.toSql(reportPageModel.getReportTo(), 0)
          + "',report_type='"
          + PubFunc.toSql(reportPageModel.getReportType(), 0)
          + "',report_remark='"
          + PubFunc.toSql(reportPageModel.getReportRemark(), 0)
          + "',report_extent='"
          + PubFunc.toSql(reportPageModel.getExplain(), 0)
          + "',report_date='"
          + PubFunc.toSql(reportPageModel.getReportDate(), 0)
          + "',operator='"
          + PubFunc.toSql(reportPageModel.getOperator(), 0)
          + "' where code='"
          + PubFunc.toSql(reportPageModel.getCode(), 0)
          + "'"
          ;

      Debug.println("[ReportDAOImpl]editeReportBuildPage--->>>sql:" + sql);

      stmt.executeUpdate(sql);

    //  conn.commit();
      flag = true;
    }
    catch (SQLException sqle) {
      Debug.println("[ReportDAOImpl]editeReportBuildPage--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }

    return flag;
  }

  /**
   * 删除报表记录数据
   *应用: code
   */
  public boolean dellReportBuildPage(String code) throws
      AppException {
    boolean flag = false;
    String sql = null;
    try {
      conn = Common.getConnection();
      //conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (code == null || "".equals(code)) {
        Debug.println(
            "[ReportDAOImpl]dellReportBuildPage----->code is null!");
        return flag;
      }

      sql = "delete from "
          + TableNameUtil.UNIVERSAL_REPORT
          + " where code='"
          + PubFunc.toSql(code, 0)
          + "'"
          ;
      Debug.println("[ReportDAOImpl]dellReportBuildPage--->>>sql:" + sql);

      stmt.executeUpdate(sql);
    //  conn.commit();
      flag = true;
    }
    catch (SQLException sqle) {
      Debug.println("[ReportDAOImpl]dellReportBuildPage--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }

    return flag;
  }

  /**
   * 得到报表数据[UNIVERSAL_REPORT_DATA] getReportBuildData
   * 应用:得到报表数据[UNIVERSAL_REPORT_DATA] getReportBuildData
   */
  public ReportPageDataModel getReportBuildData(String code) throws
      AppException {
    String sql = null;
    ReportPageDataModel reportPageDataModel = new ReportPageDataModel();
    try {
      conn = Common.getConnection();
      //conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (code == null) {
        Debug.println(
            "[ReportDAOImpl]getReportBuildData----->code is null!");
        return reportPageDataModel;
      }

      /*
        CODE	//报表编号
        REPORT_CODE//报表编号
        PAGE_CODE	//页面编号
        CONTENT	//内容
        TABLE_ROW	//行号
        TABLE_COL	//列号
        ROWCOLENDPOINT//是否行结束
       */

      sql = "select * from  "
          + TableNameUtil.UNIVERSAL_REPORT_DATA
          + " where code='"
          + code
          + "'  order by code desc"
          ;
      Debug.println("[ReportDAOImpl]getReportBuildData--->>>sql:" + sql);
      rs = stmt.executeQuery(sql);
     // conn.commit();

      if (rs.next()) {
        reportPageDataModel.setCode(PubFunc.decodeGB(rs.getString("code")));
        reportPageDataModel.setReportCode(PubFunc.decodeGB(rs.getString(
            "page_code")));
        reportPageDataModel.setPageCode(PubFunc.decodeGB(rs.getString("explain")));
        reportPageDataModel.setContent(PubFunc.decodeGB(rs.getString("content")));
        reportPageDataModel.setTableRow(PubFunc.decodeGB(rs.getString(
            "table_row")));
        reportPageDataModel.setTableCol(PubFunc.decodeGB(rs.getString(
            "table_col")));
        reportPageDataModel.setRowColEndPoint(PubFunc.decodeGB(rs.getString(
            "rowcolendpoint")));
      }
    }
    catch (SQLException sqle) {
      Debug.println("[ReportDAOImpl]getReportBuildData--->>>Exception:" +
                    sqle.getMessage());
    }

    finally {
      try {
        this.closePreparedStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeResultSet();
      }
      catch (Exception e) {
      }
      try {
        this.closeStatement();
      }
      catch (Exception e) {
      }
      try {
        this.closeConnection();
      }
      catch (Exception e) {
      }
    }
    return reportPageDataModel;
  }

  /**
   * 得到报表数据[UNIVERSAL_REPORT_DATA]
   * 应用:得到报表数据[report_data] getReportBuildData
   */
  public ArrayList getReportBuildData(ReportPageDataModel reportPageDataModel) throws
      AppException {
    boolean flag = false;
    String sql = null;
    ArrayList reportPageDataList = new ArrayList();
    ReportPageDataModel reportPageDataModelTemp = null;
    try {

      conn = Common.getConnection();
      //conn.setAutoCommit(false);
      stmt = conn.createStatement();

      //是否正常数据
      if (reportPageDataModel == null) {
        Debug.println(
            "[ReportDAOImpl]getReportBuildData----->reportPageDataModel is null!");
        return reportPageDataList;
      }

      /*
           String code;
           String reportCode;
           String pageCode;
           String content;
           String table_row;
           String table_col;