package project.c2c.internal;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
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.DateUtils;
import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.Constants;
import project.c2c.*;
import project.log.LogService;
import security.SecUser;
import security.internal.SecUserService;

public class AdminC2cOrderServiceImpl implements AdminC2cOrderService {

	private PagedQueryDao pagedDao;
	private C2cOrderService c2cOrderService;
	private C2cPaymentMethodService c2cPaymentMethodService;	
	private SecUserService secUserService;
	private PasswordEncoder passwordEncoder;
	private LogService logService;
	private C2cAdvertService c2cAdvertService;

	public Page pagedQuery(int pageNo, int pageSize, Integer status_int, String order_no_para, String user_code_para, String rolename_para, 
			String c2c_user_code_para, Integer c2c_user_type_int, String c2c_user_party_code_para, String direction_para, String loginPartyId) {

		StringBuffer queryString = new StringBuffer();
		
		queryString.append(" SELECT ");
		queryString.append(" c2c_order.UUID id, c2c_order.C2C_USER_ID c2c_user_id, c2c_order.C2C_ADVERT_ID c2c_advert_id, ");
		queryString.append(" c2c_order.PAYMENT_METHOD_ID payment_method_id, c2c_order.ORDER_TYPE order_type, c2c_order.ORDER_NO order_no, c2c_order.STATE state, c2c_order.C2C_USER_TYPE c2c_user_type, ");
		queryString.append(" c2c_order.C2C_USER_CODE c2c_user_code, c2c_order.C2C_USER_NICK_NAME c2c_user_nick_name, c2c_order.C2C_USER_PARTY_ID c2c_user_party_id, ");
		queryString.append(" c2c_order.C2C_USER_PARTY_CODE c2c_user_party_code, c2c_order.C2C_USER_PARTY_NAME c2c_user_party_name, c2c_order.DIRECTION direction, ");
		queryString.append(" c2c_order.CURRENCY currency, c2c_order.SYMBOL symbol, c2c_order.PAY_RATE pay_rate, c2c_order.SYMBOL_VALUE symbol_value, ");
		queryString.append(" c2c_order.COIN_AMOUNT coin_amount, c2c_order.EXPIRE_TIME expire_time, c2c_order.AMOUNT amount, c2c_order.METHOD_TYPE method_type, ");
		queryString.append(" c2c_order.METHOD_NAME method_name, c2c_order.METHOD_IMG method_img, c2c_order.REAL_NAME real_name, ");
		queryString.append(" c2c_order.PARAM_NAME1 param_name1, c2c_order.PARAM_VALUE1 param_value1, c2c_order.PARAM_NAME2 param_name2, c2c_order.PARAM_VALUE2 param_value2, ");
		queryString.append(" c2c_order.PARAM_NAME3 param_name3, c2c_order.PARAM_VALUE3 param_value3, c2c_order.PARAM_NAME4 param_name4, c2c_order.PARAM_VALUE4 param_value4, ");
		queryString.append(" c2c_order.PARAM_NAME5 param_name5, c2c_order.PARAM_VALUE5 param_value5, c2c_order.PARAM_NAME6 param_name6, c2c_order.PARAM_VALUE6 param_value6, ");
		queryString.append(" c2c_order.PARAM_NAME7 param_name7, c2c_order.PARAM_VALUE7 param_value7, c2c_order.PARAM_NAME8 param_name8, c2c_order.PARAM_VALUE8 param_value8, ");
		queryString.append(" c2c_order.PARAM_NAME9 param_name9, c2c_order.PARAM_VALUE9 param_value9, c2c_order.PARAM_NAME10 param_name10, c2c_order.PARAM_VALUE10 param_value10, ");
		queryString.append(" c2c_order.PARAM_NAME11 param_name11, c2c_order.PARAM_VALUE11 param_value11, c2c_order.PARAM_NAME12 param_name12, c2c_order.PARAM_VALUE12 param_value12, ");
		queryString.append(" c2c_order.PARAM_NAME13 param_name13, c2c_order.PARAM_VALUE13 param_value13, c2c_order.PARAM_NAME14 param_name14, c2c_order.PARAM_VALUE14 param_value14, ");
		queryString.append(" c2c_order.PARAM_NAME15 param_name15, c2c_order.PARAM_VALUE15 param_value15, ");
		queryString.append(" c2c_order.QRCODE qrcode, c2c_order.REMARK remark, c2c_order.CREATE_TIME create_time, c2c_order.HANDLE_TIME handle_time, ");
		queryString.append(" c2c_order.CLOSE_TIME close_time, c2c_order.PAY_TIME pay_time, c2c_order.CANCEL_TIME cancel_time, ");
		queryString.append(" party.UUID party_id, party.USERCODE usercode, party.USERNAME username, party.ROLENAME rolename ");

		queryString.append(" FROM T_C2C_ORDER c2c_order ");
		queryString.append(" LEFT JOIN PAT_PARTY party ON party.UUID = c2c_order.PARTY_ID ");
		queryString.append(" LEFT JOIN T_C2C_USER c2c_user ON c2c_user.UUID = c2c_order.C2C_USER_ID ");
		queryString.append(" WHERE 1=1 ");

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

		if (status_int != null) {
			queryString.append(" AND c2c_order.STATE = :status_int  ");
			parameters.put("status_int", status_int);
		}
		
		if (StringUtils.isNotEmpty(order_no_para)) {
			queryString.append(" AND c2c_order.ORDER_NO = :order_no_para ");
			parameters.put("order_no_para", order_no_para);
		}

		if (StringUtils.isNotEmpty(user_code_para)) {
			queryString.append(" AND (party.USERNAME like :user_code_para OR party.USERCODE like :user_code_para) ");
			parameters.put("user_code_para", "%" + user_code_para + "%");
		}
		
		if (StringUtils.isNotEmpty(rolename_para)) {
			queryString.append(" AND party.ROLENAME = :rolename_para ");
			parameters.put("rolename_para", rolename_para);
		}

		if (StringUtils.isNotEmpty(c2c_user_code_para)) {
			queryString.append(" AND (c2c_order.C2C_USER_NICK_NAME like :c2c_user_code_para OR c2c_order.C2C_USER_CODE like :c2c_user_code_para) ");
			parameters.put("c2c_user_code_para", "%" + c2c_user_code_para + "%");
		}

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

		if (StringUtils.isNotEmpty(c2c_user_party_code_para)) {
			queryString.append(" AND (c2c_order.C2C_USER_PARTY_NAME like :c2c_user_party_code_para OR c2c_order.C2C_USER_PARTY_CODE like :c2c_user_party_code_para) ");
			parameters.put("c2c_user_party_code_para", "%" + c2c_user_party_code_para + "%");
		}
		
		if (StringUtils.isNotEmpty(direction_para)) {
			queryString.append(" AND c2c_order.DIRECTION = :direction_para ");
			parameters.put("direction_para", direction_para);
		}

		if (StringUtils.isNotEmpty(loginPartyId)) {
			queryString.append(" AND c2c_user.C2C_MANAGER_PARTY_ID = :loginPartyId ");
			parameters.put("loginPartyId", loginPartyId);
		}
		
		queryString.append(" order by FIELD(c2c_order.STATE, '0', '5','2','1') DESC, c2c_order.CREATE_TIME DESC ");

		Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		
		for (Map<String, Object> data : (List<Map<String, Object>>) page.getElements()) {
			data.put("coin_amount", new BigDecimal(data.get("coin_amount").toString()).toPlainString());
		}
		
		return page;
	}
	
	public void savePass(C2cOrder c2cOrder, String safeword, String operator_username) {
		
		SecUser sec = this.secUserService.findUserByLoginName(operator_username);
		String sysSafeword = sec.getSafeword();

		String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_username);
		if (!safeword_md5.equals(sysSafeword)) {
			throw new BusinessException("资金密码错误");
		}
		if ("3".equals(c2cOrder.getState())) {
			throw new BusinessException("订单已完成，无法放行");
		}
		if ("4".equals(c2cOrder.getState())) {
			throw new BusinessException("订单已取消，无法放行");
		}

		this.c2cOrderService.saveOrderPass(c2cOrder);
		
		SecUser order_user = this.secUserService.findUserByPartyId(c2cOrder.getPartyId());
		
		this.saveLog(order_user.getUsername(), operator_username, "订单放行", c2cOrder.getPartyId().toString());		
	}
	
	public void saveOrderPay(String order_no, String safeword, String operator_username, String payment_method_id_order_pay) {
		
		SecUser sec = this.secUserService.findUserByLoginName(operator_username);
		String sysSafeword = sec.getSafeword();
		
		String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_username);
		if (!safeword_md5.equals(sysSafeword)) {
			throw new BusinessException("资金密码错误");
		}
		
		C2cOrder c2cOrder = this.c2cOrderService.get(order_no);
		if (null == c2cOrder) {
			throw new BusinessException("订单不存在");
		}
		if (!Arrays.asList("0", "2").contains(c2cOrder.getState())) {
			throw new BusinessException("订单不处于待支付或申诉中状态，无法转账");
		}
		
		C2cPaymentMethod method = this.c2cPaymentMethodService.get(payment_method_id_order_pay);
		
		// 更新最终的支付方式
		c2cOrder.setPaymentMethodId(method.getId().toString());
		c2cOrder.setMethodType(method.getMethodType());
		c2cOrder.setMethodName(method.getMethodName());
		c2cOrder.setMethodImg(method.getMethodImg());
		c2cOrder.setRealName(method.getRealName());
		c2cOrder.setParamName1(method.getParamName1());
		c2cOrder.setParamValue1(method.getParamValue1());
		c2cOrder.setParamName2(method.getParamName2());
		c2cOrder.setParamValue2(method.getParamValue2());
		c2cOrder.setParamName3(method.getParamName3());
		c2cOrder.setParamValue3(method.getParamValue3());
		c2cOrder.setParamName4(method.getParamName4());
		c2cOrder.setParamValue4(method.getParamValue4());
		c2cOrder.setParamName5(method.getParamName5());
		c2cOrder.setParamValue5(method.getParamValue5());
		c2cOrder.setParamName6(method.getParamName6());
		c2cOrder.setParamValue6(method.getParamValue6());
		c2cOrder.setParamName7(method.getParamName7());
		c2cOrder.setParamValue7(method.getParamValue7());
		c2cOrder.setParamName8(method.getParamName8());
		c2cOrder.setParamValue8(method.getParamValue8());
		c2cOrder.setParamName9(method.getParamName9());
		c2cOrder.setParamValue9(method.getParamValue9());
		c2cOrder.setParamName10(method.getParamName10());
		c2cOrder.setParamValue10(method.getParamValue10());
		c2cOrder.setParamName11(method.getParamName11());
		c2cOrder.setParamValue11(method.getParamValue11());
		c2cOrder.setParamName12(method.getParamName12());
		c2cOrder.setParamValue12(method.getParamValue12());
		c2cOrder.setParamName13(method.getParamName13());
		c2cOrder.setParamValue13(method.getParamValue13());
		c2cOrder.setParamName14(method.getParamName14());
		c2cOrder.setParamValue14(method.getParamValue14());
		c2cOrder.setParamName15(method.getParamName15());
		c2cOrder.setParamValue15(method.getParamValue15());
		c2cOrder.setQrcode(method.getQrcode());
		
		c2cOrder.setState("1");
		c2cOrder.setPayTime(new Date());
		this.c2cOrderService.update(c2cOrder);
		
		this.c2cOrderService.c2cSendMessageByState(c2cOrder, "1");
		
		SecUser orderUser = this.secUserService.findUserByPartyId(c2cOrder.getPartyId());
		
		this.saveLog(orderUser.getUsername(), operator_username, "订单转账完成", c2cOrder.getPartyId());
	}
	
	public List<C2cPaymentMethod> getOrderPayments(String order_no) {
		
		C2cOrder c2cOrder = this.c2cOrderService.get(order_no);
		if (null == c2cOrder) {
			throw new BusinessException("订单不存在");
		}
		
		C2cAdvert c2cAdvert = this.c2cAdvertService.get(c2cOrder.getC2cAdvertId());
		if (null == c2cAdvert) {
			throw new BusinessException("广告不存在");
		}
				
		String[] types = c2cAdvert.getPayType().split(",");
		List<String> typeList = Arrays.asList(types);
				
		List<C2cPaymentMethod> list = new ArrayList<C2cPaymentMethod>();
		Map<String, C2cPaymentMethod> methodMap = this.c2cPaymentMethodService.getByPartyId(c2cOrder.getPartyId());
		for (String key : methodMap.keySet()) {
			C2cPaymentMethod method = methodMap.get(key);
			if (null != method) {
				list.add(method);
			}
		}
		
		C2cPaymentMethod cpm = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
		
		List<C2cPaymentMethod> listRet = new ArrayList<C2cPaymentMethod>();
		// 先添加订单记录的支付方式
		for (C2cPaymentMethod pay : list) {			
			if (c2cOrder.getPaymentMethodId().equals(pay.getId().toString())) {
				listRet.add(pay);
			}
		}
		// 再添加与订单记录的支付方式类型相同的支付方式
		for (C2cPaymentMethod pay : list) {
			if (!c2cOrder.getPaymentMethodId().equals(pay.getId().toString())) {
				if (cpm.getMethodConfigId().equals(pay.getMethodConfigId())) {
					listRet.add(pay);
				}
			}
		}
		// 最后添加与广告匹配的支付方式
		for (C2cPaymentMethod pay : list) {			
			if (!c2cOrder.getPaymentMethodId().equals(pay.getId().toString()) && !cpm.getMethodConfigId().equals(pay.getMethodConfigId())) {
				if (typeList.contains(pay.getMethodConfigId())) {
					listRet.add(pay);
				}
			}
		}
		
		for (int i = 0; i < listRet.size(); i++) {
			C2cPaymentMethod method = listRet.get(i);
			String methodType = String.valueOf(method.getMethodType());
			Map<String, String> pmtMap = this.c2cAdvertService.getC2cSyspara("c2c_payment_method_type");
			method.setMethodTypeName(pmtMap.containsKey(methodType) ? pmtMap.get(methodType) : methodType);
		}
		
		return listRet;
	}
	
	public Map<String, Object> detail(C2cOrder order) {	
		
		Map<String, String> pmtMap = this.c2cAdvertService.getC2cSyspara("c2c_payment_method_type");
		
		Map<String, Object> result = new HashMap<String, Object>();
		result.put("id", order.getId());
		result.put("party_id", order.getPartyId());
		result.put("c2c_user_id", order.getC2cUserId());
		result.put("c2c_advert_id", order.getC2cAdvertId());
		result.put("payment_method_id", order.getPaymentMethodId());
		result.put("order_type", order.getOrderType());
		result.put("order_no", order.getOrderNo());
		result.put("state", order.getState());
		result.put("c2c_user_type", order.getC2cUserType());
		result.put("c2c_user_code", order.getC2cUserCode());
		result.put("c2c_user_nick_name", order.getC2cUserNickName());
		result.put("c2c_user_party_id", order.getC2cUserPartyId());
		result.put("c2c_user_party_code", order.getC2cUserPartyCode());
		result.put("c2c_user_party_name", order.getC2cUserPartyName());
		result.put("direction", order.getDirection());
		result.put("currency", order.getCurrency());
		result.put("symbol", order.getSymbol().toUpperCase());
		result.put("pay_rate", order.getPayRate());
		result.put("symbol_value", order.getSymbolValue());
		result.put("coin_amount", order.getCoinAmount());
		result.put("expire_time", order.getExpireTime());
		result.put("amount", order.getAmount());
		result.put("method_type", order.getMethodType());
		String methodType = String.valueOf(order.getMethodType());
		result.put("method_type_name", pmtMap.containsKey(methodType) ? pmtMap.get(methodType) : methodType);
		result.put("method_name", order.getMethodName());
		result.put("method_img", order.getMethodImg());
		result.put("real_name", order.getRealName());
		result.put("param_name1", order.getParamName1());
		result.put("param_value1", order.getParamValue1());
		result.put("param_name2", order.getParamName2());
		result.put("param_value2", order.getParamValue2());
		result.put("param_name3", order.getParamName3());
		result.put("param_value3", order.getParamValue3());
		result.put("param_name4", order.getParamName4());
		result.put("param_value4", order.getParamValue4());
		result.put("param_name5", order.getParamName5());
		result.put("param_value5", order.getParamValue5());
		result.put("param_name6", order.getParamName6());
		result.put("param_value6", order.getParamValue6());
		result.put("param_name7", order.getParamName7());
		result.put("param_value7", order.getParamValue7());
		result.put("param_name8", order.getParamName8());
		result.put("param_value8", order.getParamValue8());
		result.put("param_name9", order.getParamName9());
		result.put("param_value9", order.getParamValue9());
		result.put("param_name10", order.getParamName10());
		result.put("param_value10", order.getParamValue10());
		result.put("param_name11", order.getParamName11());
		result.put("param_value11", order.getParamValue11());
		result.put("param_name12", order.getParamName12());
		result.put("param_value12", order.getParamValue12());
		result.put("param_name13", order.getParamName13());
		result.put("param_value13", order.getParamValue13());
		result.put("param_name14", order.getParamName14());
		result.put("param_value14", order.getParamValue14());
		result.put("param_name15", order.getParamName15());
		result.put("param_value15", order.getParamValue15());
		result.put("qrcode", order.getQrcode());
		result.put("remark", order.getRemark());
		result.put("create_time", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
		result.put("handle_time", DateUtils.format(order.getHandleTime(), DateUtils.DF_yyyyMMddHHmmss));
		result.put("close_time", DateUtils.format(order.getCloseTime(), DateUtils.DF_yyyyMMddHHmmss));
		result.put("pay_time", DateUtils.format(order.getPayTime(), DateUtils.DF_yyyyMMddHHmmss));
		result.put("cancel_time", DateUtils.format(order.getCancelTime(), DateUtils.DF_yyyyMMddHHmmss));		
		return result;
	}
	
	public void saveLog(String order_username, String operator, String context, String orderPartyId) {
		project.log.Log log = new project.log.Log();
		log.setCategory(Constants.LOG_CATEGORY_C2C);
		log.setUsername(order_username);
		log.setPartyId(orderPartyId);
		log.setOperator(operator);
		log.setLog(context);
		log.setCreateTime(new Date());
		logService.saveSync(log);
	}
		
//	public class PassDelayThread implements Runnable {
//		
//		private C2cOrderService c2cOrderService;
//		private C2cOrder order;
//
//		public void run() {
//			
//			try {
//				
//				while (true) {					
//					if (C2cOrderLock.add(order.getOrderNo())) {
//						this.c2cOrderService.saveOrderPass(order);
//						// 处理完退出
//						break;
//					}
//					ThreadUtils.sleep(200);
//				}
//
//			} catch (Throwable t) {
//				logger.error("error:", t);
//			} finally {
//				C2cOrderLock.remove(order.getOrderNo());
//			}
//
//		}
//
//		public PassDelayThread(C2cOrder order, C2cOrderService c2cOrderService) {
//			this.order = order;
//			this.c2cOrderService = c2cOrderService;
//		}
//		
//	}

	public void setPagedDao(PagedQueryDao pagedDao) {
		this.pagedDao = pagedDao;
	}

	public void setC2cOrderService(C2cOrderService c2cOrderService) {
		this.c2cOrderService = c2cOrderService;
	}

	public void setC2cPaymentMethodService(C2cPaymentMethodService c2cPaymentMethodService) {
		this.c2cPaymentMethodService = c2cPaymentMethodService;
	}

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

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

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

	public void setC2cAdvertService(C2cAdvertService c2cAdvertService) {
		this.c2cAdvertService = c2cAdvertService;
	}

}