package project.user.kyc.internal;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.Constants;
import project.log.Log;
import project.log.LogService;
import project.party.PartyService;
import project.party.model.Party;
import project.party.recom.UserRecomService;
import project.tip.TipService;
import project.user.kyc.AdminKycService;
import project.user.kyc.Kyc;
import project.user.kyc.KycService;
import security.SecUser;
import security.internal.SecUserService;

@SuppressWarnings("rawtypes")
public class AdminKycServiceImpl implements AdminKycService {
	
	protected KycService kycService;
	
	protected TipService tipService;
	
	protected LogService logService;
	
	protected PartyService partyService;
	
	protected SecUserService secUserService;
	
	protected UserRecomService userRecomService;

	@Override
	public Page pagedQuery(int pageNo, int pageSize, String name_para, String status_para, String rolename_para,String checkedPartyId,String idnumber_para,String email_para) {
		if (pageNo <= 0) pageNo = 1;
		
		StringBuilder sqlBuilder=new StringBuilder("SELECT party.UUID partyId,party.USERCODE usercode,party.USERNAME username,party.PHONE phone,party.EMAIL email,party.ROLENAME rolename,kyc.UUID id,kyc.IDNUMBER idnumber,");
		sqlBuilder.append("kyc.IDNAME idname,kyc.NAME name,kyc.IDIMG_1 idimg_1,kyc.IDIMG_2 idimg_2,kyc.IDIMG_3 idimg_3,kyc.APPLY_TIME apply_time,kyc.OPERATION_TIME operation_time,kyc.STATUS status,");
		sqlBuilder.append("kyc.MSG msg,kyc.nationality nationality ,party_parent.USERNAME username_parent FROM T_KYC kyc LEFT JOIN PAT_PARTY party ON kyc.PARTY_ID = party.UUID ");
		sqlBuilder.append("LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID WHERE 1=1 ");
		ArrayList<Object> params=new ArrayList<Object>();
		
		if (!StringUtils.isNullOrEmpty(checkedPartyId)) {
			sqlBuilder.append("AND FIND_IN_SET(party.UUID,?) ");
			List<String> checkedList = this.userRecomService.findChildren(checkedPartyId);
			checkedList.add(checkedPartyId);
			params.add(String.join(",",checkedList));
		}

		if (!StringUtils.isNullOrEmpty(status_para)) {
			sqlBuilder.append("AND kyc.STATUS=? ");
			params.add(status_para);
		}
		
		if (!StringUtils.isNullOrEmpty(rolename_para)) {
			sqlBuilder.append("AND party.ROLENAME=? ");
			params.add(rolename_para);
		}
		
		if (!StringUtils.isNullOrEmpty(name_para)) {
			sqlBuilder.append("AND (party.USERNAME LIKE ? OR party.USERCODE LIKE ? ) ");
			params.add("%"+name_para+"%");
			params.add("%"+name_para+"%");
		}
		
		if (!StringUtils.isNullOrEmpty(idnumber_para)) {
			sqlBuilder.append("AND kyc.IDNUMBER=? ");
			params.add(idnumber_para);
		}
		
		if (!StringUtils.isNullOrEmpty(email_para)) {
			sqlBuilder.append("AND (party.PHONE LIKE ? OR party.EMAIL LIKE ? ) ");
			params.add("%"+email_para+"%");
			params.add("%"+email_para+"%");
		}
		
		sqlBuilder.append("ORDER BY kyc.APPLY_TIME DESC LIMIT ?,?");
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		params.add(page.getFirstElementNumber());
		params.add(pageSize);
		
		List<HashMap> list=ApplicationUtil.executeDQL(sqlBuilder.toString(),params.toArray(new Object[params.size()]),HashMap.class);
		page.setElements(list);
		return page;
	}

	@Override
	public Kyc find(Serializable partyId) {
		List<Kyc> list = ApplicationUtil.executeSelect(Kyc.class,"WHERE PARTY_ID=?", new Object[] {partyId});
		return list.size()<=0?null:list.get(0);
	}

	@Override
	public void savePassed(String partyId) {
		Kyc kyc = find(partyId);
		if (kyc != null) {
			kyc.setStatus(2);
			kycService.save(kyc);
			tipService.deleteTip(kyc.getId().toString());
		}
		
		Party party = this.partyService.cachePartyBy(partyId, false);
		party.setKyc_authority(true);
		
		// 获取用户系统等级：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证； 4/用户高级认证；
		int userLevelSystem = this.partyService.getUserLevelByAuth(party);

		// 十进制个位表示系统级别：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证；4/用户高级认证；
		// 十进制十位表示自定义级别：对应在前端显示为如VIP1 VIP2等级、黄金 白银等级；
		// 如：级别11表示：新注册的前端显示为VIP1；
		int userLevel = party.getUser_level();
		party.setUser_level(((int) Math.floor(userLevel / 10)) * 10 + userLevelSystem);
		
		this.partyService.update(party);		
	}

	@Override
	public void saveFailed(String partyId, String msg) {
		Kyc kyc = find(partyId);
		if (kyc != null) {
			kyc.setStatus(3);
			kyc.setMsg(msg);
            kycService.saveNoIdNumOnly(kyc);
			tipService.deleteTip(kyc.getId().toString());
			
			SecUser secUser = secUserService.findUserByPartyId(partyId);
			Log log = new Log();
			log.setCategory(Constants.LOG_CATEGORY_OPERATION);
			log.setExtra(kyc.getIdnumber());
			log.setUsername(secUser.getUsername());
			log.setOperator(secUser.getUsername());
			log.setPartyId(secUser.getPartyId());
			log.setLog("管理员驳回用户[" + kyc.getIdname() + "]认证申请。驳回原因[" + msg + "]");
			logService.saveSync(log);
		}
		Party party = partyService.cachePartyBy(partyId, false);
		party.setKyc_authority(false);
		partyService.update(party);
	}

	@Override
	public void saveKycPic(String partyId, String imgId, String img) {
		Kyc kyc = find(partyId);
		if (kyc != null) {
			if ("1".equals(imgId)) {
				kyc.setIdimg_1(img);
			} else if ("2".equals(imgId)) {
				kyc.setIdimg_2(img);
			} else if ("3".equals(imgId)) {
				kyc.setIdimg_3(img);
			}
            kycService.saveNoIdNumOnly(kyc);
		}		
	}
	
	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

	public void setUserRecomService(UserRecomService userRecomService) {
		this.userRecomService = userRecomService;
	}

	public void setKycService(KycService kycService) {
		this.kycService = kycService;
	}

	public void setTipService(TipService tipService) {
		this.tipService = tipService;
	}

	public void setSecUserService(SecUserService secUserService) {
		this.secUserService = secUserService;
	}

	public void setLogService(LogService logService) {
		this.logService = logService;
	}
}