package com.hxzkoa.services;

import java.util.ArrayList;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.hxzkoa.json.User;
import com.hxzkoa.json.tb_achor;
import com.hxzkoa.json.tb_login;
import com.hxzkoa.json.tb_user;
import com.hxzkoa.json.tb_xunjianbaobiao;
import com.hxzkoa.util.Config;
import com.hxzkoa.util.ModifyConfig;

@Service
public class LoginService {
	@PersistenceContext
	private EntityManager em;

	public tb_user login(String username) {
		String sql = null;
		Query query = null;
		sql = "SELECT username,password,superuser,deleteq,alertq,deleteall,justlook,fenceq FROM tb_user WHERE username=:username";
		query = this.em.createNativeQuery(sql);
		query.setParameter("username", username);
		List resultList = query.getResultList();
		tb_user user = new tb_user();
		if (resultList.size() > 0) {
			Object[] obj = (Object[]) resultList.get(0);
			user.setUsername(obj[0] == null ? "" : obj[0].toString());
			user.setPassword(obj[1] == null ? "" : obj[1].toString());
			user.setSuperuser(obj[2] == null ? "" : obj[2].toString());
			user.setDeleteq(obj[3] == null ? "" : obj[3].toString());
			user.setAlertq(obj[4] == null ? "" : obj[4].toString());
			user.setDeleteall(obj[5] == null ? "" : obj[5].toString());
			user.setJustlook(obj[6] == null ? "" : obj[6].toString());
			user.setFenceq(obj[7] == null ? "" : obj[7].toString());
		}
		return user;
	}
	
	@Transactional
	public void login_add(tb_login login) {
		String sql = null;
		Query query = null;
		sql = "INSERT tb_login (ip,username,time) VALUES (:ip,:username,now())";
		query = this.em.createNativeQuery(sql);
		query.setParameter("ip", login.getIp());
		query.setParameter("username", login.getUsername());
		query.executeUpdate();
	}
	
	public List<tb_login> getloginManagement(int page) {
		String sql = null;
		Query query = null;
		sql = "SELECT id,ip,username,time FROM (SELECT id,ip,username,time FROM tb_login ORDER BY id DESC) s LIMIT :start,:end";
		query = this.em.createNativeQuery(sql);
		query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage")));
		query.setParameter("end", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage")));
		List resultList = query.getResultList();
		List<tb_login> tb_loginlist = new ArrayList<tb_login>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_login login = new tb_login();
				Object[] obj = (Object[]) resultList.get(i);
				login.setId((int) obj[0]);
				login.setIp(obj[1] == null ? "" : obj[1].toString());
				login.setUsername(obj[2] == null ? "" : obj[2].toString());
				login.setTime(obj[3] == null ? "" : obj[3].toString());
				tb_loginlist.add(login);
			}
		}
		return tb_loginlist;
	}
	
	public List<tb_login> getloginid(String username) {
		String sql = null;
		Query query = null;
		sql = "SELECT id,ip,username,time FROM tb_login WHERE username = :username";
		query = this.em.createNativeQuery(sql);
		query.setParameter("username", username);
		List resultList = query.getResultList();
		List<tb_login> tb_loginlist = new ArrayList<tb_login>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_login login = new tb_login();
				Object[] obj = (Object[]) resultList.get(i);
				login.setId((int) obj[0]);
				login.setIp(obj[1] == null ? "" : obj[1].toString());
				login.setUsername(obj[2] == null ? "" : obj[2].toString());
				login.setTime(obj[3] == null ? "" : obj[3].toString());
				tb_loginlist.add(login);
			}
		}
		return tb_loginlist;
	}
	
	public int getloginManagementCount() {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_login";
		query = this.em.createNativeQuery(sql);
		return Integer.parseInt(query.getSingleResult().toString());
	}
}