package project.wallet.internal;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.JdbcTemplate;

import kernel.web.ApplicationUtil;
import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.RedisKeys;
import project.redis.RedisHandler;
import project.wallet.WalletLog;
import project.wallet.WalletLogService;

public class WalletLogServiceImpl implements WalletLogService {
	
	private static final Logger logger = LoggerFactory.getLogger(WalletLogServiceImpl.class);
	
	private JdbcTemplate jdbcTemplate;
	private PagedQueryDao pagedQueryDao;
	private RedisHandler redisHandler;

	@Override
	public void save(WalletLog entity) {
		entity.setCreateTime(new Date());
		entity.setId(ApplicationUtil.getCurrentTimeUUID());
        Object[] jdbcParams = ApplicationUtil.getInsertStatement(entity);
        String insertUserSql = (String)jdbcParams[0];
        Object[] sqlParameters = (Object[])jdbcParams[1];
        jdbcTemplate.update(insertUserSql, sqlParameters);
		redisHandler.setSync(RedisKeys.WALLET_LOG_ORDERNO + entity.getOrder_no(), entity);
	}

	@Override
	public WalletLog find(String category, String order_no) {
		return find(order_no);
	}

	public WalletLog find(String order_no) {
		WalletLog walletLog = (WalletLog) redisHandler.get(RedisKeys.WALLET_LOG_ORDERNO + order_no);
		return walletLog;
	}

	@Override
	public void update(WalletLog entity) {
        Object[] jdbcParams = ApplicationUtil.getUpdateStatement(entity, "WHERE UUID=?", new Object[] {entity.getId()});
        String updateUserSql = (String)jdbcParams[0];
        Object[] sqlParameters = (Object[])jdbcParams[1];
        jdbcTemplate.update(updateUserSql, sqlParameters);
		redisHandler.setSync(RedisKeys.WALLET_LOG_ORDERNO + entity.getOrder_no(), entity);
	}

	public void updateStatus(String orderNo, int status) {
		// 日志状态更新
		WalletLog walletLog = this.find(orderNo);
		if (null == walletLog) {
			logger.error("walletLog is not exist,order_no:{}", orderNo);
		} else {
			walletLog.setStatus(status);
			this.update(walletLog);
		}
	}

	@Override
	public Page pagedQuery(int pageNo, int pageSize, String partyId, String category,String order_no_null) {
		Map<String, Object> parameters = new HashMap<String, Object>();
		StringBuffer queryString = new StringBuffer("SELECT ");
		queryString.append(
				"log.WALLETTYPE AS wallettype,log.AMOUNT AS amount,log.STATUS AS status,DATE_FORMAT(log.CREATE_TIME,'%Y-%m-%d %H:%i:%S') as createTimeStr, ");
		queryString.append("withdraw.FAILURE_MSG AS withdraw_failure_msg,"
				+ " recharge.DESCRIPTION AS recharge_failure_msg,log.ORDER_NO order_no ");
		queryString.append("FROM T_WALLET_LOG AS log ");
		queryString.append("LEFT JOIN T_WITHDRAW_ORDER AS withdraw ON withdraw.ORDER_NO = log.ORDER_NO ");
		queryString.append("LEFT JOIN T_RECHARGE_BLOCKCHAIN_ORDER AS recharge ON recharge.ORDER_NO = log.ORDER_NO ");

		queryString.append("WHERE 1=1  ");
		queryString.append(" and log.PARTY_ID = :partyId  ");
		parameters.put("partyId", partyId);

		if (StringUtils.isNotEmpty(category)) {
			queryString.append(" and log.CATEGORY = :category ");
			parameters.put("category", category);
		}
		if("1".equals(order_no_null)) {
			queryString.append(" and log.ORDER_NO is not null and log.ORDER_NO !='' ");
		}
		queryString.append(" order by log.CREATE_TIME desc ");

		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}

	@Override
	public Page pagedQueryWithdraw(int pageNo, int pageSize, String partyId,String order_no_null) {
		
		Map<String, Object> parameters = new HashMap<String, Object>();
		
		StringBuffer queryString = new StringBuffer("SELECT ");
		
		queryString.append(
				" log.ORDER_NO AS order_no, log.WALLETTYPE AS coin, log.AMOUNT AS amount, log.STATUS AS status, DATE_FORMAT(log.CREATE_TIME,'%Y-%m-%d %H:%i:%S') as createTime, ");
		queryString.append(" withdraw.AMOUNT_FEE AS fee, withdraw.CHAIN_ADDRESS AS 'to', withdraw.FAILURE_MSG AS failure_msg, "
				+ " withdraw.VOLUME AS volume, withdraw.METHOD AS coin_blockchain ");
		
		queryString.append("FROM T_WALLET_LOG AS log ");
		queryString.append("LEFT JOIN T_WITHDRAW_ORDER AS withdraw ON withdraw.ORDER_NO = log.ORDER_NO ");

		queryString.append("WHERE 1=1  ");
		
		queryString.append(" and log.PARTY_ID = :partyId  ");
		parameters.put("partyId", partyId);
		
		queryString.append(" and log.CATEGORY = :category ");
		parameters.put("category", "withdraw");

		if("1".equals(order_no_null)) {
			queryString.append(" and log.ORDER_NO is not null and log.ORDER_NO !='' ");
		}
		
		queryString.append(" order by log.CREATE_TIME desc ");

		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}

	@Override
	public Page pagedQueryRecharge(int pageNo, int pageSize, String partyId,String order_no_null) {
		
		Map<String, Object> parameters = new HashMap<String, Object>();
		
		StringBuffer queryString = new StringBuffer("SELECT ");
		
		queryString.append(
				"log.ORDER_NO AS order_no, log.WALLETTYPE AS coin, log.AMOUNT AS amount, log.STATUS AS status, DATE_FORMAT(log.CREATE_TIME,'%Y-%m-%d %H:%i:%S') as createTime, ");
		queryString.append("recharge.DESCRIPTION AS failure_msg, recharge.TX AS hash, recharge.ADDRESS AS address, recharge.CHANNEL_AMOUNT AS volume, ");
		queryString.append("recharge.COIN AS symbol, recharge.BLOCKCHAIN_NAME AS blockchain_name, recharge.TX AS tx ");
		
		queryString.append("FROM T_WALLET_LOG AS log ");
		queryString.append("LEFT JOIN T_RECHARGE_BLOCKCHAIN_ORDER AS recharge ON recharge.ORDER_NO = log.ORDER_NO ");

		queryString.append("WHERE 1=1  ");
		
		queryString.append(" and log.PARTY_ID = :partyId ");
		parameters.put("partyId", partyId);

		queryString.append(" and log.CATEGORY = :category ");
		parameters.put("category", "recharge");

		if("1".equals(order_no_null)) {
			queryString.append(" and log.ORDER_NO is not null and log.ORDER_NO !='' ");
		}
		
		queryString.append(" order by log.CREATE_TIME desc ");

		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}

	@Override
	public Page pagedQueryRecords(int pageNo, int pageSize, String partyId, String category, String start_time, String end_time, String wallet_type, Integer status) {
		
		Map<String, Object> parameters = new HashMap<String, Object>();
		
		StringBuffer queryString = new StringBuffer("SELECT ");
		
		queryString.append(
				"log.CATEGORY AS category, log.WALLETTYPE AS wallet_type, log.AMOUNT AS amount, log.STATUS AS status, log.ORDER_NO order_no, DATE_FORMAT(log.CREATE_TIME,'%Y-%m-%d %H:%i:%S') as createTimeStr, ");
		queryString.append("withdraw.FAILURE_MSG AS withdraw_failure_msg, recharge.DESCRIPTION AS recharge_failure_msg ");
		
		queryString.append("FROM T_WALLET_LOG AS log ");
		queryString.append("LEFT JOIN T_WITHDRAW_ORDER AS withdraw ON withdraw.ORDER_NO = log.ORDER_NO ");
		queryString.append("LEFT JOIN T_RECHARGE_BLOCKCHAIN_ORDER AS recharge ON recharge.ORDER_NO = log.ORDER_NO ");

		queryString.append("WHERE 1=1  ");
		
		queryString.append(" and log.ORDER_NO is not null and log.ORDER_NO != ''  ");
		
		queryString.append(" and log.PARTY_ID = :partyId  ");
		parameters.put("partyId", partyId);

		if (StringUtils.isNotEmpty(category)) {
			queryString.append(" and log.CATEGORY = :category ");
			parameters.put("category", category);
		} else {
			queryString.append(" and (log.CATEGORY = 'recharge' or log.CATEGORY = 'withdraw') ");
		}
		
		if (StringUtils.isNotEmpty(start_time)) {
			queryString.append(" and DATE(log.CREATE_TIME) >= DATE(:start_time)  ");
			parameters.put("start_time", start_time);			
		}
		
		if (StringUtils.isNotEmpty(end_time)) {
			queryString.append(" and DATE(log.CREATE_TIME) <= DATE(:end_time)  ");
			parameters.put("end_time", end_time);			
		}

		if (StringUtils.isNotEmpty(wallet_type)) {
			queryString.append(" and log.WALLETTYPE = :wallet_type ");
			parameters.put("wallet_type", wallet_type);
		}

		if (null != status) {
			queryString.append(" and log.STATUS = :status ");
			parameters.put("status", status);
		}
		
		queryString.append(" order by log.CREATE_TIME desc ");

		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}

	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

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

	public void setRedisHandler(RedisHandler redisHandler) {
		this.redisHandler = redisHandler;
	}

}