package com.fendo.service.imp;

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

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

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;

import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.transaction.Transactional;

import org.springframework.stereotype.Service;

import com.fendo.dao.FamilyDao;
import com.fendo.entity.FamilyMember;
import com.fendo.service.FamilyService;
import com.fendo.util.PageUtils;

@Service
@Transactional
public class FamilyServiceImp implements FamilyService{

	@Autowired
	public FamilyDao familyDao;
		
	@Override
	public List<FamilyMember> getAll() throws Exception {
		return (List<FamilyMember>) this.familyDao.findAll();
	}

	@Override
	public FamilyMember save(FamilyMember familyMember) throws Exception {
		return familyDao.save(familyMember);
	}

	/**
     * 查询用户信息列表(支持分页和多条件查询)。
     * 
     */
	@Override
    public Map<String, Object> getUserBySearch(Map<String, String> familyArgs, final String sortType) throws Exception {

        // 获得分页对象pageable，并且在pageable中页码是从0开始，设定按照sortType升序排列
        Pageable pageable = PageUtils.buildPageRequest(Integer.valueOf(familyArgs.get("pageNum")),
                Integer.valueOf(familyArgs.get("pageSize")), sortType);
        Page<FamilyMember> objPage = familyDao.findAll(new Specification<FamilyMember>() {

            public Predicate toPredicate(Root<FamilyMember> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
                List<Predicate> lstPredicates = new ArrayList<Predicate>();

                if (StringUtils.isNotBlank(familyArgs.get("FamilyName"))) {
                    lstPredicates.add(cb.like(root.get("familyName").as(String.class), "%" + familyArgs.get("FamilyName") + "%"));
                }
                if (StringUtils.isNotBlank(familyArgs.get("Mobile"))) {
                    lstPredicates.add(cb.like(root.get("mobile").as(String.class), "%" + familyArgs.get("Mobile") + "%"));
                }
               
                Predicate[] arrayPredicates = new Predicate[lstPredicates.size()];
                return cb.and(lstPredicates.toArray(arrayPredicates));
            }
        }, pageable);

        return PageUtils.getPageMap(objPage);
    }

}