package com.foreknow.service.impl;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

import com.foreknow.dao.UserDAO;
import com.foreknow.dao.impl.UserDAOImpl;
import com.foreknow.db.DBManager;
import com.foreknow.model.User;
import com.foreknow.service.UserService;

public class UserServiceImpl implements UserService {

    @Override
    public List<Object> isValidate(String username, String password) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        List<Object> list = null;
        try {
            list = userDAO.isLogin(username, password);
            connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return list;
    }

    @Override
    public boolean addInfo(User user) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        boolean isRight = false;
        // 调用dao中的方法
        try {
            isRight = userDAO.addUser(user);
            connection.commit();
        } catch (ClassNotFoundException e) {
            try {
                connection.rollback();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            e.printStackTrace();
        } catch (SQLException e) {
            try {
                connection.rollback();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            e.printStackTrace();
        }
        return isRight;
    }

    @Override
    public List<Object> getQueryById(int id) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        List<Object> list = null;
        try {
            list = userDAO.getById(id);
//          connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return list;

    }

    @Override
    public List<Object> getByName(String username) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        List<Object> list = null;
        try {
            username = "%" + username + "%";
            list = userDAO.getByName(username);
//          connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return list;
    }

    @Override
    public List<Object> getAll() {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        List<Object> list = null;
        try {
            list = userDAO.getAllMessage();
            connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return list;
    }

    @Override
    public boolean deleteById(int id) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        boolean isRight = false;
        try {
            isRight = userDAO.deleteById(id);
            connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return isRight;
    }

    @Override
    public boolean change(Object... values) {
        // 连接数据库
        DBManager dbManager = DBManager.getInstance();
        Connection connection = dbManager.getConnection();
        UserDAOImpl userDAO = new UserDAOImpl();
        userDAO.setConnection(connection);
        boolean isRight = false;
        try {
            isRight = userDAO.change(values);
            connection.commit();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return isRight;
    }

}