package project.c2c.internal;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.springframework.jdbc.core.JdbcTemplate;

import kernel.bo.RecordObjectMapper;
import project.RedisKeys;
import project.c2c.C2cPaymentMethod;
import project.c2c.C2cPaymentMethodService;
import project.redis.RedisHandler;

public class C2cPaymentMethodServiceImpl implements C2cPaymentMethodService {
	
	private RedisHandler redisHandler;
	private JdbcTemplate jdbcTemplate;

	@Override
	public C2cPaymentMethod get(String id) {
		return (C2cPaymentMethod) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_ID + id);
	}
	
	@Override
	public C2cPaymentMethod getC2cPaymentMethod(String id) {
		List<C2cPaymentMethod> list = jdbcTemplate.query("SELECT * FROM T_C2C_PAYMENT_METHOD WHERE UUID=?", RecordObjectMapper.newInstance(C2cPaymentMethod.class), id);
        if (null != list && list.size() > 0) {
        	return list.get(0);
        }
        return null;
	}
	
	@Override
	public Map<String, C2cPaymentMethod> getByPartyId(String partyId) {
		Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + partyId);
		if (null == map || 0 == map.size()) {
			return new HashMap<String, C2cPaymentMethod>();
		}
		return map;
	}
	
	@Override
	public Map<String, String> getMethodConfigMapByPartyId(String partyId) {		
		Map<String, String> res = new HashMap<String, String>();
		
		Map<String, C2cPaymentMethod> methodMap = this.getByPartyId(partyId);
		if (null == methodMap || 0 == methodMap.size()) {
			return res;
		}
		
		for (String key : methodMap.keySet()) {
			C2cPaymentMethod method = methodMap.get(key);
			if (null != method) {
				res.put(method.getMethodConfigId(), method.getMethodName());
			}
		}
		
		return res;
	}
	
	@Override
	public List<C2cPaymentMethod> getMethodConfigListByPartyId(String partyId) {		
		List<C2cPaymentMethod> res = new ArrayList<C2cPaymentMethod>();
		
		Map<String, C2cPaymentMethod> methodMap = this.getByPartyId(partyId);
		if (null == methodMap || 0 == methodMap.size()) {
			return res;
		}
		
		for (String key : methodMap.keySet()) {
			C2cPaymentMethod method = methodMap.get(key);
			if (null != method) {
				res.add(method);
			}
		}
		
		return res;		
	}
	
	@Override
	public Map<String, String> getMethodIdTypeMap() {
		Map<String, String> map = (Map<String, String>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE);
		if (null == map || map.isEmpty()) {
			return new HashMap<String, String>();
		}
		return map;
	}
	
	@Override
	public void save(C2cPaymentMethod entity) {
		String insertSql = "INSERT INTO T_C2C_PAYMENT_METHOD(UUID,PARTY_ID,METHOD_CONFIG_ID,METHOD_TYPE,METHOD_NAME,METHOD_IMG,"
				+ "REAL_NAME,PARAM_NAME1,PARAM_VALUE1,PARAM_NAME2,PARAM_VALUE2,PARAM_NAME3,PARAM_VALUE3,PARAM_NAME4,PARAM_VALUE4,"
				+ "PARAM_NAME5,PARAM_VALUE5,PARAM_NAME6,PARAM_VALUE6,PARAM_NAME7,PARAM_VALUE7,PARAM_NAME8,PARAM_VALUE8,PARAM_NAME9,"
				+ "PARAM_VALUE9,PARAM_NAME10,PARAM_VALUE10,PARAM_NAME11,PARAM_VALUE11,PARAM_NAME12,PARAM_VALUE12,PARAM_NAME13,"
				+ "PARAM_VALUE13,PARAM_NAME14,PARAM_VALUE14,PARAM_NAME15,PARAM_VALUE15,QRCODE,REMARK,CREATE_TIME,UPDATE_TIME) "
				+ "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
		jdbcTemplate.update(insertSql,entity.getId(),entity.getPartyId(),entity.getMethodConfigId(),entity.getMethodType(),entity.getMethodName(),
				entity.getMethodImg(),entity.getRealName(),entity.getParamName1(),entity.getParamValue1(),entity.getParamName2(),entity.getParamValue2(),
				entity.getParamName3(),entity.getParamValue3(),entity.getParamName4(),entity.getParamValue4(),entity.getParamName5(),entity.getParamValue5(),
				entity.getParamName6(),entity.getParamValue6(),entity.getParamName7(),entity.getParamValue7(),entity.getParamName8(),entity.getParamValue8(),
				entity.getParamName9(),entity.getParamValue9(),entity.getParamName10(),entity.getParamValue10(),entity.getParamName11(),entity.getParamValue11(),
				entity.getParamName12(),entity.getParamValue12(),entity.getParamName13(),entity.getParamValue13(),entity.getParamName14(),entity.getParamValue14(),
				entity.getParamName15(),entity.getParamValue15(),entity.getQrcode(),entity.getRemark(),entity.getCreateTime(),entity.getUpdateTime());
	}
	
	@Override
	public void delete(String id) {
		C2cPaymentMethod entity = this.get(id);
		if (entity != null) {
			jdbcTemplate.update("DELETE FROM T_C2C_PAYMENT_METHOD WHERE UUID=?", entity.getId());
			this.redisHandler.remove(RedisKeys.C2C_PAYMENT_METHOD_ID + entity.getId().toString());

			Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + entity.getPartyId().toString());
			if (map != null && !map.isEmpty()) {
				map.remove(id);
			} else {
				map = new ConcurrentHashMap<String, C2cPaymentMethod>();
			}
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + entity.getPartyId().toString(), map);

			Map<String, String> map1 = (Map<String, String>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE);
			if (map1 != null && !map1.isEmpty()) {
				map1.remove(id);
			} else {
				map1 = new ConcurrentHashMap<String, String>();
			}
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE, map1);
		}
	}

	@Override
	public boolean update(C2cPaymentMethod entity) {
		try {
			String updateSql = "UPDATE T_C2C_PAYMENT_METHOD SET PARTY_ID=?,METHOD_CONFIG_ID=?,METHOD_TYPE=?,METHOD_NAME=?,METHOD_IMG=?,REAL_NAME=?,"
					+ "PARAM_NAME1=?,PARAM_VALUE1=?,PARAM_NAME2=?,PARAM_VALUE2=?,PARAM_NAME3=?,PARAM_VALUE3=?,PARAM_NAME4=?,PARAM_VALUE4=?,"
					+ "PARAM_NAME5=?,PARAM_VALUE5=?,PARAM_NAME6=?,PARAM_VALUE6=?,PARAM_NAME7=?,PARAM_VALUE7=?,PARAM_NAME8=?,PARAM_VALUE8=?,"
					+ "PARAM_NAME9=?,PARAM_VALUE9=?,PARAM_NAME10=?,PARAM_VALUE10=?,PARAM_NAME11=?,PARAM_VALUE11=?,PARAM_NAME12=?,PARAM_VALUE12=?,"
					+ "PARAM_NAME13=?,PARAM_VALUE13=?,PARAM_NAME14=?,PARAM_VALUE14=?,PARAM_NAME15=?,PARAM_VALUE15=?,QRCODE=?,REMARK=?,UPDATE_TIME=? WHERE UUID=?";

			jdbcTemplate.update(updateSql,entity.getPartyId(),entity.getMethodConfigId(),entity.getMethodType(),entity.getMethodName(),
							entity.getMethodImg(),entity.getRealName(),entity.getParamName1(),entity.getParamValue1(),entity.getParamName2(),entity.getParamValue2(),
							entity.getParamName3(),entity.getParamValue3(),entity.getParamName4(),entity.getParamValue4(),entity.getParamName5(),entity.getParamValue5(),
							entity.getParamName6(),entity.getParamValue6(),entity.getParamName7(),entity.getParamValue7(),entity.getParamName8(),entity.getParamValue8(),
							entity.getParamName9(),entity.getParamValue9(),entity.getParamName10(),entity.getParamValue10(),entity.getParamName11(),entity.getParamValue11(),
							entity.getParamName12(),entity.getParamValue12(),entity.getParamName13(),entity.getParamValue13(),entity.getParamName14(),entity.getParamValue14(),
							entity.getParamName15(),entity.getParamValue15(),entity.getQrcode(),entity.getRemark(),entity.getUpdateTime(),entity.getId());
			return true;
		} catch(RuntimeException e) {
			return false;
		}
	}

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

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

}