ERP-EIP-OA-Portal

Development Platform:
Java

SkhfkDaoImpl.java：Code Content
							package com.dao;
import com.tool.SQLCode;
import java.util.List;
import com.tool.JDBConnection;
import com.domain.SkhfkForm;
import java.util.ArrayList;
import java.sql.ResultSet;
import java.sql.*;
import com.domain.CountForm;
//对客户服务的操作
//客户反馈信息（tb_Client_khfk）
public class SkhfkDaoImpl
    implements SkhfkDao {
  private JDBConnection connection = new JDBConnection();
  //查询操作
  public List skhfkSelect() {
    List list = new ArrayList();
    SkhfkForm form = null;
    String sql = SQLCode.getSQLCode("sql.khfk.select");
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new SkhfkForm();
        form.setKhfk_id(rs.getString(1));
         form.setKhfk_fkbt(rs.getString(2));
         form.setKhfk_khmc(rs.getString(3));
         form.setKhfk_fknr(rs.getString(4));
         form.setKhfk_fkrq(rs.getString(5));
         form.setKhfk_fkslr(rs.getString(6));
         form.setKhfk_khmyd(rs.getString(7));
         form.setKhfk_bz(rs.getString(8));
         form.setId(Integer.valueOf(rs.getString(9)));
        list.add(form);
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return list;
  }
//以客户反馈编号去查询的操作
  public SkhfkForm skhfkSelectOne(SkhfkForm skhfk) {
    SkhfkForm form = null;
    String sql = SQLCode.getSQLCode("sql.khfk.selectOne");
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id());
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new SkhfkForm();
        form.setKhfk_id(rs.getString(1));
        form.setKhfk_fkbt(rs.getString(2));
        form.setKhfk_khmc(rs.getString(3));
        form.setKhfk_fknr(rs.getString(4));
        form.setKhfk_fkrq(rs.getString(5));
        form.setKhfk_fkslr(rs.getString(6));
        form.setKhfk_khmyd(rs.getString(7));
        form.setKhfk_bz(rs.getString(8));
        form.setId(Integer.valueOf(rs.getString(9)));
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return form;
  }
//删除操作
  public void skhfkDelete(SkhfkForm skhfk) {
    String sql = SQLCode.getSQLCode("sql.khfk.delete");
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id());
    connection.executeQuery(sql);
    connection.close();
  }
//修改操作
  public void skhfkUpdate(SkhfkForm skhfk) {
    String sql = SQLCode.getSQLCode("sql.khfk.update");
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkbt());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmc());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fknr());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkrq());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkslr());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_bz());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id());
    connection.executeQuery(sql);
    connection.close();
  }
//插入操作
  public void skhfkInsert(SkhfkForm skhfk) {
    String sql = SQLCode.getSQLCode("sql.khfk.insert");
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkbt());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmc());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fknr());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkrq());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkslr());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd());
    sql = connection.editSqlCode(sql, skhfk.getKhfk_bz());
    connection.executeQuery(sql);
  }
//#--查出流水号，以便做帐号存贮--
  public int skhfkCount() {
    int iCount = 0;
    String sql = SQLCode.getSQLCode("sql.khfk.count");
    ResultSet rs = null;
    try {
      rs = connection.executeQuery(sql);
      while (rs.next()) {
        iCount = rs.getInt("t");
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return iCount + 1;
  }
//根据客户的满意度去查询
  public List skhfkSelectMyd(SkhfkForm skhfk) {
    List list = new ArrayList();
    SkhfkForm form = null;
    String sql = SQLCode.getSQLCode("sql.khfk.myd");
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd());
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new SkhfkForm();
        form.setKhfk_id(rs.getString(1));
        form.setKhfk_fkbt(rs.getString(2));
        form.setKhfk_khmc(rs.getString(3));
        form.setKhfk_fknr(rs.getString(4));
        form.setKhfk_fkrq(rs.getString(5));
        form.setKhfk_fkslr(rs.getString(6));
        form.setKhfk_khmyd(rs.getString(7));
        form.setKhfk_bz(rs.getString(8));
        form.setId(Integer.valueOf(rs.getString(9)));
        list.add(form);
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return list;
  }
//根据客户的满意程度去查找数据
  public List skhfkMyd() {
    List list = new ArrayList();
    String sql = SQLCode.getSQLCode("sql.khfk.mydAnthor");
    System.out.println("sql=" + sql);
    CountForm form = null;
    ResultSet rs = null;
    try {
      rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new CountForm();
        form.setMyd(rs.getString(1));
        form.setNumber(Integer.valueOf(rs.getString(2)));
        list.add(form);
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return list;
  }
//查询多少记录
  public int skhfkNumber() {
    int iCount = 0;
    String sql = SQLCode.getSQLCode("sql.khfk.number");
    ResultSet rs = null;
    try {
      rs = connection.executeQuery(sql);
      while (rs.next()) {
        iCount = rs.getInt("t");
        System.out.println("iCount="+iCount);
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return iCount;
  }
}

						