package love.sola.netsupport.sql;

import love.sola.netsupport.enums.Status;
import love.sola.netsupport.pojo.Ticket;
import love.sola.netsupport.pojo.User;
import org.hibernate.Session;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.hibernate.envers.AuditReader;
import org.hibernate.envers.query.AuditEntity;

import java.util.List;

/**
 * ***********************************************
 * Created by Sola on 2015/12/6.
 * Don't modify this source without my agreement
 * ***********************************************
 */
public class TableTicket extends SQLCore {

	public static final String COLUMN_ID = "id";
	public static final String COLUMN_SID = "sid";
	public static final String COLUMN_DESC = "description";
	public static final String COLUMN_SUBMIT_TIME = "submittime";
	public static final String COLUMN_REMARK = "remark";
	public static final String COLUMN_UPDATE_TIME = "updatetime";
	public static final String COLUMN_OPSID = "opsid";
	public static final String COLUMN_STATUS = "status";


	public static Ticket latestOpen(User u) {
		try (Session s = SQLCore.sf.openSession()) {
			return (Ticket) s.createCriteria(Ticket.class)
					.addOrder(Order.desc(Ticket.PROPERTY_SUBMIT_TIME))
					.add(Restrictions.eq(Ticket.PROPERTY_USER, u))
					.add(Restrictions.ne(Ticket.PROPERTY_STATUS, Status.SOLVED))
					.setMaxResults(1)
					.uniqueResult();
		}
	}

	public static Ticket latest(User u) {
		try (Session s = SQLCore.sf.openSession()) {
			return (Ticket) s.createCriteria(Ticket.class)
					.addOrder(Order.desc(Ticket.PROPERTY_SUBMIT_TIME))
					.add(Restrictions.eq(Ticket.PROPERTY_USER, u))
					.setMaxResults(1)
					.uniqueResult();
		}
	}

	public static boolean hasOpen(User u) {
		try (Session s = SQLCore.sf.openSession()) {
			return (long) s.createCriteria(Ticket.class)
					.add(Restrictions.eq(Ticket.PROPERTY_USER, u))
					.add(Restrictions.ne(Ticket.PROPERTY_STATUS, Status.SOLVED))
					.setProjection(Projections.rowCount())
					.uniqueResult() > 0;
		}
	}

	@SuppressWarnings("unchecked")
	public static List<Ticket> unsolvedByBlock(int b) {
		try (Session s = SQLCore.sf.openSession()) {
			return s.createCriteria(Ticket.class)
					.add(Restrictions.ne(Ticket.PROPERTY_STATUS, Status.SOLVED))
					.createCriteria(Ticket.PROPERTY_USER)
					.add(Restrictions.between(User.PROPERTY_BLOCK, b * 10, (b + 1) * 10 - 1))
					.list();
		}
	}

	@SuppressWarnings("unchecked")
	public static List<Object[]> track(int tid) {
		try (Session s = SQLCore.sf.openSession()) {
			AuditReader reader = getAuditReader(s);
			return reader.createQuery()
					.forRevisionsOfEntity(Ticket.class, false, true)
					.addOrder(AuditEntity.revisionNumber().asc())
					.add(AuditEntity.id().eq(tid))
					.getResultList()
					;
		}
	}

}