package project.monitor.loan.internal;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.regex.Pattern;
import java.util.stream.Collectors;

import org.springframework.cglib.beans.BeanMap;
import org.springframework.jdbc.core.JdbcTemplate;

import kernel.exception.BusinessException;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.monitor.loan.LoanParam;
import project.monitor.loan.LoanService;
import project.monitor.loan.SimpleLoanOrder;
import project.party.model.Party;

/**
 * @author JORGE
 * @description 借贷服务接口实现类
 */
@SuppressWarnings("unchecked")
public class LoanServiceImpl implements LoanService{
	/**
	 * 借贷状态字典
	 */
	private static HashMap<Integer,String> stateMap;
	
	/**
	 * 付款方式字典
	 */
	private static HashMap<Integer,String> repayments;
	
	/**
	 * 逗号正则表达式
	 */
	private static Pattern commaPattern=Pattern.compile(",");
	
	/**
	 * 冒号正则表达式
	 */
	private static Pattern colonPattern=Pattern.compile(":");
	
	/**
	 * 放款机构字典
	 */
	private static HashMap<Integer,String> lendingInstitutions;
	
	public LoanServiceImpl() {
		stateMap=new HashMap<Integer,String>();
		repayments=new HashMap<Integer,String>();
		lendingInstitutions=new HashMap<Integer,String>();
		
		stateMap.put(1, "未审");
		stateMap.put(2, "通过");
		stateMap.put(3, "驳回");
		
		repayments.put(1,"到期还本息");
		repayments.put(2,"到期还本金");
		repayments.put(3,"到期还利息");
		
		lendingInstitutions.put(1,"LOAN1");
		lendingInstitutions.put(2,"LOAN2");
		lendingInstitutions.put(3,"LOAN3");
	}

	@Override
	public Boolean addLoanOrder(SimpleLoanOrder simpleLoanOrder) {
		Object primaryKey=ApplicationUtil.executeInsert(simpleLoanOrder);
		return null!=primaryKey;
	}

	@Override
	public HashMap<String,Object> getLoanParams(String uuid) {
		LoanParam loanParam=null;
		if(null==uuid || (uuid=uuid.trim()).isEmpty()) {
			List<LoanParam> loanParamList=ApplicationUtil.executeSelect(LoanParam.class);
			loanParam=(null==loanParamList || loanParamList.isEmpty())?null:loanParamList.get(0);
		}else {
			loanParam=ApplicationUtil.executeGet(uuid, LoanParam.class);
		}
		
		if(null==loanParam) return null;
		
		HashMap<String,Object> paramMap=new HashMap<String,Object>(BeanMap.create(loanParam));
		String term=(String)paramMap.get("term");
		if(null==term || (term=term.trim()).isEmpty()) {
			paramMap.put("termList",new Object[0]);
		}else {
			paramMap.put("termList",commaPattern.splitAsStream(term).map(tr->new String[] {tr,tr}).collect(Collectors.toList()));
		}
		
		String repayCycle=(String)paramMap.get("repayCycle");
		if(null==repayCycle || (repayCycle=repayCycle.trim()).isEmpty()) {
			paramMap.put("repayCycleList",new Object[0]);
		}else {
			paramMap.put("repayCycleList",commaPattern.splitAsStream(repayCycle).map(rc->new String[] {rc,rc}).collect(Collectors.toList()));
		}
		
		String dailyRate=(String)paramMap.get("dailyRate");
		if(null==dailyRate || (dailyRate=dailyRate.trim()).isEmpty()) {
			paramMap.put("dailyRateList",new Object[0]);
		}else {
			paramMap.put("dailyRateList",commaPattern.splitAsStream(dailyRate).map(dr->new String[] {dr,dr}).collect(Collectors.toList()));
		}
		
		String repayment=(String)paramMap.get("repayment");
		if(null==repayment || (repayment=repayment.trim()).isEmpty()) {
			paramMap.put("repaymentList",new Object[0]);
		}else {
			paramMap.put("repaymentList",commaPattern.splitAsStream(repayment).map(rep->colonPattern.split(rep)).collect(Collectors.toList()));
		}
		
		String lendingInstitution=(String)paramMap.get("lendingInstitution");
		if(null==lendingInstitution || (lendingInstitution=lendingInstitution.trim()).isEmpty()) {
			paramMap.put("lendingList",new Object[0]);
		}else {
			paramMap.put("lendingList",commaPattern.splitAsStream(lendingInstitution).map(led->colonPattern.split(led)).collect(Collectors.toList()));
		}
		
		paramMap.put("stateList",commaPattern.splitAsStream("1:未审,2:通过,3:驳回").map(stat->colonPattern.split(stat)).collect(Collectors.toList()));
		
		return paramMap;
	}

	@Override
	public Page pagedQuery(Map<String, Object> queryParams) {
		int pageSize=(Integer)queryParams.get("pageSize");
		int pageNo=(Integer)queryParams.get("pageNo");
		if (pageNo <= 0) pageNo = 1;
		
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		String userName=(String)queryParams.get("userName");
		String orderNo=(String)queryParams.get("orderNo");
		int status=(Integer)queryParams.get("status");
		
		ArrayList<Object> paramList=new ArrayList<Object>();
		StringBuilder whereStatement=new StringBuilder("WHERE 1=1 ");
		
		if(0!=status) {
			whereStatement.append("AND STATE=? ");
			paramList.add(status);
		}
		
		if(null!=orderNo && !(orderNo=orderNo.trim()).isEmpty()) {
			whereStatement.append("AND UUID=? ");
			paramList.add(orderNo);
		}
		
		if(null!=userName && !(userName=userName.trim()).isEmpty()) {
			whereStatement.append("AND PARTY_ID=(SELECT UUID FROM PAT_PARTY WHERE USERNAME=?) ");
			paramList.add(userName);
		}
		
		whereStatement.append("LIMIT ?,?");
		paramList.add(page.getFirstElementNumber());
		paramList.add(pageSize);
		
		List<SimpleLoanOrder> orderList=ApplicationUtil.executeSelect(SimpleLoanOrder.class,whereStatement.toString(),paramList.toArray(new Object[paramList.size()]));
		if(null==orderList || orderList.isEmpty()) return page;
		
		String partyIds=orderList.stream().map(order->order.getPartyId()).collect(Collectors.joining(","));
		List<Party> partyList=ApplicationUtil.executeSelect(Party.class,"WHERE FIND_IN_SET(UUID,?)",new Object[] {partyIds});
		Map<?,?> idToNameMap=partyList.stream().collect(Collectors.toMap(party->party.getId(),party->party.getUsername(),(oldname,newname)->newname));
		
		List<HashMap<String,Object>> transferList=orderList.stream().map(order->{
			Integer state=order.getState();
			Integer rep=order.getRepayment();
			String houseImgs=order.getHouseImgs();
			Integer led=order.getLendingInstitution();
			houseImgs=null==houseImgs?null:(houseImgs=houseImgs.trim()).isEmpty()?null:houseImgs;
			HashMap<String,Object> transferMap=new HashMap<String,Object>(BeanMap.create(order));
			transferMap.put("state", new Object[] {state,stateMap.get(state)});
			transferMap.put("userName", idToNameMap.get(order.getPartyId()));
			transferMap.put("repayment", new Object[] {rep,repayments.get(rep)});
			transferMap.put("houseImgs", null==houseImgs?null:commaPattern.split(houseImgs)[0]);
			transferMap.put("lendingInstitution", new Object[] {led,lendingInstitutions.get(led)});
			return transferMap;
		}).collect(Collectors.toList());
		
		page.setElements(transferList);
		
		return page;
	}

	@Override
	public boolean deleteLoanOrder(String orderId) {
		if(null==orderId || (orderId=orderId.trim()).isEmpty()) {
			throw new BusinessException("申请单ID不能为空!");
		}
		
		int count=ApplicationUtil.executeDel(orderId,SimpleLoanOrder.class);
		if(1!=count) {
			throw new BusinessException("根据申请单ID删除了多条记录,说明申请单ID重复!");
		}
		
		return count==1?true:false;
	}

	@Override
	public boolean updateLoanOrderState(String orderId, String status) {
		if(null==orderId || (orderId=orderId.trim()).isEmpty()) {
			throw new BusinessException("申请单ID不能为空!");
		}
		
		if(null==status || (status=status.trim()).isEmpty()) {
			throw new BusinessException("审核状态不能为空!");
		}
		
		int state="true".equalsIgnoreCase(status)?2:3;
		int count=ApplicationUtil.getBean(JdbcTemplate.class).update("UPDATE T_SIMPLE_LOAN_ORDER SET state=? WHERE UUID=?",state,orderId);
		if(1!=count) {
			throw new BusinessException("根据申请单ID修改了多条记录,说明申请单ID重复!");
		}
		
		return true;
	}

	@Override
	public Boolean modLoanOrder(SimpleLoanOrder simpleLoanOrder) {
		Serializable id=simpleLoanOrder.getId();
		if(null==id) {
			throw new BusinessException("申请单ID不能为空!");
		}
		
		Set<String> excludeFields=new HashSet<String>();
		excludeFields.add("id");
		excludeFields.add("partyId");
		excludeFields.add("state");
		excludeFields.add("houseImgs");
		excludeFields.add("incomeImg");
		
		int count=ApplicationUtil.executeUpdate(simpleLoanOrder,excludeFields);
		if(1!=count) {
			throw new BusinessException("根据申请单ID修改了多条记录,说明申请单ID重复!");
		}
		
		return true;
	}
	
	@Override
	public SimpleLoanOrder getLoanOrder(String orderId) {
		if(null==orderId || (orderId=orderId.trim()).isEmpty()) {
			throw new BusinessException("申请单ID不能为空!");
		}
		return ApplicationUtil.executeGet(orderId,SimpleLoanOrder.class);
	}
}