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;

  }

}