package com.originspark.drp.service.projects.costs;

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

import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;

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

import com.originspark.drp.dao.BaseDAOSupport;
import com.originspark.drp.models.projects.costs.StockInCost;
import com.originspark.drp.models.projects.costs.AbstractCost.COLUMNS;
import com.originspark.drp.util.json.FilterRequest;

@Transactional
@Service
public class StockInCostServiceBean extends BaseDAOSupport<StockInCost> implements
        StockInCostService {

    @Override
    public List<StockInCost> pagedDataSet(int start, int limit,
            List<FilterRequest> filters) {
        CriteriaBuilder cb = em.getCriteriaBuilder();
        CriteriaQuery<StockInCost> dataQuery = cb.createQuery(StockInCost.class);

        Root<StockInCost> stockInCost = dataQuery.from(StockInCost.class);

        dataQuery.select(stockInCost);

        Predicate[] predicates = toPredicates(cb, stockInCost, filters);

        if (predicates != null) {
            dataQuery.where(cb.and(predicates));
        }
        dataQuery.orderBy(cb.desc(stockInCost.get("id")));

        return em.createQuery(dataQuery).setFirstResult(start)
                .setMaxResults(limit).getResultList();
    }

    @Override
    public Long pagedDataCount(List<FilterRequest> filters) {
        CriteriaBuilder cb = em.getCriteriaBuilder();
        CriteriaQuery<Long> countQuery = cb.createQuery(Long.class);
        Root<StockInCost> stockInCost = countQuery.from(StockInCost.class);
        countQuery.select(cb.count(stockInCost));

        Predicate[] predicates = toPredicates(cb, stockInCost, filters);

        if (predicates != null) {
            countQuery.where(cb.and(predicates));
        }

        return em.createQuery(countQuery).getSingleResult();
    }

    public static Predicate[] toPredicates(CriteriaBuilder cb, Root<StockInCost> stockInCost,
            List<FilterRequest> filters) {
        List<Predicate> criteria = new ArrayList<Predicate>();

        try {
            for (FilterRequest filter : filters) {
                
                COLUMNS column = COLUMNS.valueOf(filter.getProperty()
                        .toUpperCase());
                
                String value = filter.getValue();
                
                switch (column) {
                case INVOICE:
                    if(value != null && !value.equals("")){
                        criteria.add(cb.equal(stockInCost.get("invoice").<Long>get("id"),Long.parseLong(value)));
                    }
                    break;
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }

        if (criteria.size() == 0) {
            return null;
        } else {
            Predicate[] predicates = new Predicate[criteria.size()];
            predicates = criteria.toArray(predicates);
            return predicates;
        }
    }

    @Override
    public Map<String, String> validate() {
        // TODO
        /**
         * 对ware的数据进行验证
         */
        return null;
    }

}
