package project.web.admin.impl.user;

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

import org.springframework.security.providers.encoding.PasswordEncoder;

import kernel.exception.BusinessException;
import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.Constants;
import project.log.Log;
import project.log.LogService;
import project.party.PartyService;
import project.party.model.Party;
import project.party.model.UserRecom;
import project.party.recom.UserRecomService;
import project.user.Agent;
import project.user.UserDataService;
import project.web.admin.service.user.AdminAgentService;
import project.web.admin.service.user.AdminUserRecomService;
import security.SecUser;
import security.internal.SecUserService;

public class AdminUserRecomServiceImpl implements AdminUserRecomService {
	
	protected LogService logService;
	
	protected PartyService partyService;

    protected PagedQueryDao pagedQueryDao;

    protected SecUserService secUserService;
    
    protected UserDataService userDataService;
    
    protected PasswordEncoder passwordEncoder;
	
    protected UserRecomService userRecomService;
	
    protected AdminAgentService adminAgentService;
	
    @Override
    public Page pagedQuery(int pageNo, int pageSize, String usernameOrUid,String parentUsername,String loginPartyId) {
        StringBuffer queryString = new StringBuffer(" SELECT ");
        queryString.append(" recom.UUID id ,info.USERNAME username,info.UUID partyId,info.ROLENAME rolename ,info.USERCODE usercode,parent_info.USERNAME parent_username ");
        queryString.append(" FROM ");
        queryString.append(" PAT_PARTY info  LEFT JOIN PAT_USER_RECOM recom  ON info.UUID =   recom.PARTY_ID ");
        queryString.append(" LEFT JOIN PAT_PARTY parent_info ON recom.RECO_ID = parent_info.UUID ");
        queryString.append(" where 1=1 ");
        Map<String, Object> parameters = new HashMap<String, Object>();
        
        
    	if (!StringUtils.isNullOrEmpty(loginPartyId)) {
			List<String> children = this.userRecomService.findChildren(loginPartyId);
			if (children.size() == 0) {
				return new Page();
			}
			queryString.append(" and info.UUID in (:children) ");
			parameters.put("children", children);
		}

        if (!StringUtils.isNullOrEmpty(usernameOrUid)) {
			queryString.append("AND (info.USERNAME like:username OR info.USERCODE like:username ) ");
			parameters.put("username","%"+usernameOrUid+"%");
		}
        if (!StringUtils.isNullOrEmpty(parentUsername)) {
			queryString.append("AND parent_info.USERNAME like:parentUsername ");
			parameters.put("parentUsername","%"+parentUsername+"%");
		}
        queryString.append("AND info.ROLENAME !=:no_rolename ");
		parameters.put("no_rolename",Constants.SECURITY_ROLE_TEST);
        queryString.append(" order by info.CREATE_TIME desc ");
     
        return pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
    }

    public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
        this.pagedQueryDao = pagedQueryDao;
    }

    @Override
    public UserRecom get(String id) {
    	return ApplicationUtil.executeGet(id,UserRecom.class);
    }
    
    /**
	 * 验证登录人资金密码
	 * @param operatorUsername
	 * @param loginSafeword
	 */
	protected void checkLoginSafeword(String operatorUsername,String loginSafeword) {
		SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
		String sysSafeword = sec.getSafeword();
		String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
		if (!safeword_md5.equals(sysSafeword)) {
			throw new BusinessException("登录人资金密码错误");
		}
	}

    @Override
    public void update(String partyId, String reco_username,String operator_name,String ip,String loginSafeword) {
    	checkLoginSafeword(operator_name,loginSafeword);
    	SecUser SecUser =  secUserService.findUserByLoginName(reco_username);
        if (SecUser == null || StringUtils.isNullOrEmpty(SecUser.getPartyId())) {
            throw new BusinessException("无法找到推荐用户");
        }
        if(partyId.equals(SecUser.getPartyId()) ) {
        	throw new BusinessException("推荐人UID错误");
        }
        UserRecom userRecom = findByPartyId(partyId);
        String user_last = null;
        if(userRecom == null) {
        	userRecom = new UserRecom();
        	userRecom.setPartyId(partyId);
            userRecom.setReco_id(SecUser.getPartyId());
            this.userRecomService.save(userRecom);
        }else {
        	user_last = userRecom.getReco_id().toString();
             userRecom.setReco_id(SecUser.getPartyId());
             this.userRecomService.update(partyId,SecUser.getPartyId());
        }
        SecUser SecUser_user =  secUserService.findUserByPartyId(partyId);
        Party party_parent = this.partyService.cachePartyBy(SecUser.getPartyId(),true);
        Party party_user = this.partyService.cachePartyBy(SecUser_user.getPartyId(),true);
        /**
         * 如果2个都是代理商，则同时修改代理商关系表
         */
        if((Constants.SECURITY_ROLE_AGENT.equals(party_user.getRolename()) ||Constants.SECURITY_ROLE_AGENTLOW.equals(party_user.getRolename()) )
        		&& (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRolename())||Constants.SECURITY_ROLE_AGENTLOW.equals(party_parent.getRolename()))) {
        	Agent agent = this.adminAgentService.findByPartyId(party_user.getId());
        	agent.setParent_partyId(party_parent.getId());
        	this.adminAgentService.update(agent);
        }
        String username_user = SecUser_user.getUsername();
        
        /**
         * 前推荐人
         */
        String username_last = null;
        if(user_last != null) {
        	SecUser SecUser_last =  secUserService.findUserByPartyId(user_last);
        	username_last = SecUser_last.getUsername();
        }else {
        	username_last="无";
        }
        Log log = new Log();
        log.setUsername(username_user);
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		log.setOperator(operator_name);
		log.setLog("ip:["+ip+"],修改推荐关系，"
				+ "原推荐人[" +username_last + "]，"
						+ "修改后的推荐人[" +SecUser.getUsername() + "]");

		logService.saveSync(log);
		this.userDataService.saveRegister(partyId);
    }
    
    public UserRecom findById(Serializable id) {
    	return ApplicationUtil.executeGet(id,UserRecom.class);
	}
    
	protected UserRecom findByPartyId(String partyId) {
		List<UserRecom> list=ApplicationUtil.executeSelect(UserRecom.class,"WHERE PARTY_ID=?",new Object[] {partyId});
		return list.size()<=0?null:list.get(0);
	}

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

	public void setUserDataService(UserDataService userDataService) {
		this.userDataService = userDataService;
	}

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

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

	public void setAdminAgentService(AdminAgentService adminAgentService) {
		this.adminAgentService = adminAgentService;
	}

	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

	public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
		this.passwordEncoder = passwordEncoder;
	}
}