package com.dao;

import java.util.List;
import com.domain.KhtsForm;
import java.util.ArrayList;
import com.tool.JDBConnection;
import java.sql.ResultSet;
import com.tool.SQLCode;
import java.sql.*;
import com.domain.CountForm;

//客戶投訴
public class KhtsDaoImpl
    implements KhtsDao {
  private JDBConnection connection = new JDBConnection();
  //查詢操作
  public List select() {
    List list = new ArrayList();
    KhtsForm khts = null;
    String sql = SQLCode.getSQLCode("sql.khts.select");

    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        khts = new KhtsForm();
        khts.setKhts_id(rs.getString(1));
        khts.setKhts_qymc(rs.getString(2));
        khts.setKhts_tsr(rs.getString(3));
        khts.setKhts_tszt(rs.getString(4));
        khts.setKhts_tsnr(rs.getString(5));
        khts.setKhts_tsrq(rs.getString(6));
        khts.setKhts_clbf(rs.getString(7));
        khts.setKhts_khmyd(rs.getString(8));
        khts.setKhts_tsslr(rs.getString(9));
        khts.setKhts_bz(rs.getString(10));
        khts.setId(Integer.valueOf(rs.getString(11)));
        list.add(khts);
      }
    }
    catch (SQLException ex) {
    }
    return list;
  }

//插入操作
  public void Insert(KhtsForm form) {
    String sql = SQLCode.getSQLCode("sql.khts.insert");
    sql = connection.editSqlCode(sql, form.getKhts_id());

    sql = connection.editSqlCode(sql, form.getKhts_qymc());

    sql = connection.editSqlCode(sql, form.getKhts_tsr());

    sql = connection.editSqlCode(sql, form.getKhts_tszt());

    sql = connection.editSqlCode(sql, form.getKhts_tsnr());

    sql = connection.editSqlCode(sql, form.getKhts_tsrq());

    sql = connection.editSqlCode(sql, form.getKhts_clbf());

    sql = connection.editSqlCode(sql, form.getKhts_khmyd());

    sql = connection.editSqlCode(sql, form.getKhts_tsslr());

    sql = connection.editSqlCode(sql, form.getKhts_bz());

    connection.executeUpdate(sql);
    connection.close();

  }

//刪除操作
  public void Delete(KhtsForm form) {
    String sql = SQLCode.getSQLCode("sql.khts.delete");
    sql = connection.editSqlCode(sql, form.getId());
    connection.executeUpdate(sql);
    connection.close();
  }

//修改操作
  public void Update(KhtsForm form) {
    String sql = SQLCode.getSQLCode("sql.khts.update");
    sql = connection.editSqlCode(sql, form.getKhts_id());
    sql = connection.editSqlCode(sql, form.getKhts_qymc());
    sql = connection.editSqlCode(sql, form.getKhts_tsr());
    sql = connection.editSqlCode(sql, form.getKhts_tszt());
    sql = connection.editSqlCode(sql, form.getKhts_tsnr());
    sql = connection.editSqlCode(sql, form.getKhts_tsrq());
    sql = connection.editSqlCode(sql, form.getKhts_clbf());
    sql = connection.editSqlCode(sql, form.getKhts_khmyd());
    sql = connection.editSqlCode(sql, form.getKhts_tsslr());
    sql = connection.editSqlCode(sql, form.getKhts_bz());
    sql = connection.editSqlCode(sql, form.getId());
    connection.executeUpdate(sql);
    connection.close();
  }

//單一查詢操作
  public KhtsForm SelectOne(KhtsForm form) {
    KhtsForm khts = null;
    String sql = SQLCode.getSQLCode("sql.khts.selectOne");
    sql = connection.editSqlCode(sql, form.getId());
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        khts = new KhtsForm();
        khts.setKhts_id(rs.getString(1));
        khts.setKhts_qymc(rs.getString(2));
        khts.setKhts_tsr(rs.getString(3));
        khts.setKhts_tszt(rs.getString(4));
        khts.setKhts_tsnr(rs.getString(5));
        khts.setKhts_tsrq(rs.getString(6));
        khts.setKhts_clbf(rs.getString(7));
        khts.setKhts_khmyd(rs.getString(8));
        khts.setKhts_tsslr(rs.getString(9));
        khts.setKhts_bz(rs.getString(10));
        khts.setId(Integer.valueOf(rs.getString(11)));

      }
    }
    catch (SQLException ex) {
    }
    return khts;

  }

//唯一性
  public int countID() {
    int iCount = 0;
    String sql = SQLCode.getSQLCode("sql.khts.countID");
    ResultSet rs = null;
    try {
      rs = connection.executeQuery(sql);
      while (rs.next()) {

        iCount = rs.getInt("t");
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return iCount + 1;

  }

  //刪除受理
  public void DeleteSl(KhtsForm form) {
    String sql = SQLCode.getSQLCode("sql.khts.deleteSl");

    sql = connection.editSqlCode(sql, form.getKhts_clbf());
    sql = connection.editSqlCode(sql, form.getKhts_khmyd());
    sql = connection.editSqlCode(sql, form.getKhts_tsslr());

    sql = connection.editSqlCode(sql, form.getId());
    connection.executeUpdate(sql);
    connection.close();
  }
  //根據客戶的滿意程度去查找數據
  public List skhfkMyd() {
    List list = new ArrayList();
    String sql = SQLCode.getSQLCode("sql.khts.pricture");

    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;

  }

}