package project.c2c.internal;

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

import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.c2c.AdminC2cUserService;
import project.c2c.C2cUser;
import project.c2c.C2cUserService;
import project.syspara.Syspara;
import project.syspara.SysparaService;

public class AdminC2cUserServiceImpl implements AdminC2cUserService {

	private PagedQueryDao pagedDao;
	private SysparaService sysparaService;
	private C2cUserService c2cUserService;

	public Page pagedQuery(int pageNo, int pageSize, String c2c_user_id, Integer c2c_user_type_int, String c2c_user_party_id, String c2c_manager_name_para, String loginPartyId) {

		StringBuffer queryString = new StringBuffer();
		
		queryString.append(" SELECT ");
		queryString.append(" cu.UUID id, cu.NICK_NAME nick_name, cu.HEAD_IMG head_img, cu.DEPOSIT deposit, cu.DEPOSIT_OPEN deposit_open, cu.DEPOSIT_GIFT_RATE deposit_gift_rate, ");
		queryString.append(" cu.C2C_USER_TYPE c2c_user_type, cu.C2C_USER_CODE c2c_user_code, cu.C2C_USER_PARTY_ID c2c_user_party_id, ");
		queryString.append(" cu.THIRTY_DAYS_ORDER thirty_days_order, cu.THIRTY_DAYS_ORDER_RATIO thirty_days_order_ratio, cu.THIRTY_DAYS_PASS_AVERAGE_TIME thirty_days_pass_average_time, cu.THIRTY_DAYS_PAY_AVERAGE_TIME thirty_days_pay_average_time, ");
		queryString.append(" cu.THIRTY_DAYS_AMOUNT thirty_days_amount, cu.BUY_AMOUNT buy_amount, cu.SELL_AMOUNT sell_amount, cu.TOTAL_AMOUNT total_amount, cu.ACCOUNT_CREATE_DAYS account_create_days, cu.FIRST_EXCHANGE_DAYS first_exchange_days, cu.EXCHANGE_USERS exchange_users, ");
		queryString.append(" cu.BUY_SUCCESS_ORDERS buy_success_orders, cu.SELL_SUCCESS_ORDERS sell_success_orders, cu.TOTAL_SUCCESS_ORDERS total_success_orders, ");
		queryString.append(" cu.APPRAISE_GOOD appraise_good, cu.APPRAISE_BAD appraise_bad, ");
		queryString.append(" cu.ORDER_MAIL_NOTICE_OPEN order_mail_notice_open, cu.ORDER_SMS_NOTICE_OPEN order_sms_notice_open, cu.ORDER_APP_NOTICE_OPEN order_app_notice_open, ");
		queryString.append(" cu.APPEAL_MAIL_NOTICE_OPEN appeal_mail_notice_open, cu.APPEAL_SMS_NOTICE_OPEN appeal_sms_notice_open, cu.APPEAL_APP_NOTICE_OPEN appeal_app_notice_open, cu.CHAT_APP_NOTICE_OPEN chat_app_notice_open, ");
		queryString.append(" cu.SECURITY_MAIL_NOTICE_OPEN security_mail_notice_open, cu.SECURITY_SMS_NOTICE_OPEN security_sms_notice_open, cu.SECURITY_APP_NOTICE_OPEN security_app_notice_open, ");
		queryString.append(" cu.REMARK remark, cu.CREATE_TIME create_time, cu.UPDATE_TIME update_time, ");
		queryString.append(" manager.UUID manager_id, manager.USERNAME manager_name, party.USERNAME user_name, party.USERCODE user_code, party.PHONE_AUTHORITY phone_authority, party.EMAIL_AUTHORITY email_authority, party.KYC_AUTHORITY kyc_authority, party.KYC_HIGHLEVEL_AUTHORITY kyc_highlevel_authority ");

		queryString.append(" FROM T_C2C_USER cu ");
		queryString.append(" LEFT JOIN PAT_PARTY party ON cu.C2C_USER_PARTY_ID = party.UUID ");
		queryString.append(" LEFT JOIN SCT_USER manager ON cu.C2C_MANAGER_PARTY_ID = manager.UUID ");
		queryString.append(" WHERE 1=1 ");

		Map<String, Object> parameters = new HashMap<String, Object>();

		if (!StringUtils.isNullOrEmpty(loginPartyId)) {
			queryString.append(" AND cu.C2C_MANAGER_PARTY_ID = :loginPartyId ");
			parameters.put("loginPartyId", loginPartyId);
		}

		if (!StringUtils.isNullOrEmpty(c2c_manager_name_para)) {
			queryString.append(" AND manager.USERNAME like :c2c_manager_name_para ");
			parameters.put("c2c_manager_name_para", "%" + c2c_manager_name_para + "%");
		}

		if (StringUtils.isNotEmpty(c2c_user_id)) {
			queryString.append(" AND (cu.NICK_NAME like :c2c_user_id OR cu.C2C_USER_CODE like :c2c_user_id ) ");
			parameters.put("c2c_user_id", "%" + c2c_user_id + "%");
		}
		
		if (StringUtils.isNotEmpty(c2c_user_party_id)) {
			queryString.append(" AND (party.USERNAME like :c2c_user_party_id OR party.USERCODE like :c2c_user_party_id ) ");
			parameters.put("c2c_user_party_id", "%" + c2c_user_party_id + "%");
		}

		if (c2c_user_type_int != null) {
			queryString.append(" AND cu.C2C_USER_TYPE = :c2c_user_type_int ");
			parameters.put("c2c_user_type_int", c2c_user_type_int);
		}

		queryString.append(" order by cu.CREATE_TIME desc ");

		Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		
		return page;
	}
	
	public void save(C2cUser c2cUser) {
		c2cUser.setC2cUserCode(this.getUsercode());	
		this.c2cUserService.save(c2cUser);
	}
	
	public void update(C2cUser c2cUser) {
		this.c2cUserService.update(c2cUser);
	}

	public void delete(String id) {
		this.c2cUserService.delete(id);
	}

	public C2cUser findById(Serializable id) {
		return this.c2cUserService.get(id.toString());
	}
	
	private String getUsercode() {
		Syspara syspara = this.sysparaService.find("c2c_user_uid_sequence");
		int random = (int) (Math.random() * 3 + 1);
		int user_uid_sequence = syspara.getInteger() + random;
		syspara.setValue(user_uid_sequence);
		this.sysparaService.update(syspara);
		String usercode = String.valueOf(user_uid_sequence);
		return usercode;
	}
	
	/*
	 * 获取C2C管理员下级承兑商
	 */
	public List<Map<String, Object>> getC2cManagerC2cUser(String manager_id) {
		
		StringBuffer queryString = new StringBuffer();
		Map<String, Object> parameters = new HashMap<String, Object>();
		parameters.put("manager_id", manager_id);
		
		queryString.append(" SELECT c2c_user.UUID id, c2c_user.NICK_NAME nick_name, c2c_user.C2C_USER_CODE c2c_user_code, "
				+ "c2c_user.C2C_USER_TYPE c2c_user_type, c2c_user.DEPOSIT_OPEN deposit_open, c2c_user.DEPOSIT deposit "
				+ "FROM T_C2C_USER c2c_user WHERE c2c_user.C2C_MANAGER_PARTY_ID = :manager_id ");
		Page page = this.pagedDao.pagedQuerySQL(1, 1000000, queryString.toString(), parameters);

		if (null == page) {
			return new ArrayList<Map<String,Object>>();
		} else {
			return (List<Map<String, Object>>) page.getElements();
		}
	}
	
	/*
	 * 获取所有C2C管理员
	 */
	public Map<String, Object> getAllC2cManager() {
		
		StringBuffer queryString = new StringBuffer();		
		Map<String, Object> parameters = new HashMap<String, Object>();
		parameters.put("role_uuid", "SECURITY_ROLE_C2C");
		
		queryString.append(" SELECT user.UUID id, user.USERNAME user_name FROM SCT_USER user LEFT JOIN SCT_USER_ROLE user_role ON user_role.USER_UUID = user.UUID WHERE user_role.ROLE_UUID = :role_uuid ");
		Page page = this.pagedDao.pagedQuerySQL(1, 1000000, queryString.toString(), parameters);

		Map<String, Object> mapRet = new HashMap<String, Object>();
		for (Map<String, Object> data : (List<Map<String, Object>>) page.getElements()) {
			mapRet.put(data.get("id").toString(), data.get("user_name"));
		}	
		return mapRet;
	}
	
	public void setPagedDao(PagedQueryDao pagedDao) {
		this.pagedDao = pagedDao;
	}

	public void setSysparaService(SysparaService sysparaService) {
		this.sysparaService = sysparaService;
	}

	public void setC2cUserService(C2cUserService c2cUserService) {
		this.c2cUserService = c2cUserService;
	}

}