package project.c2c.internal;

import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.apache.commons.lang3.StringUtils;

import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.RedisKeys;
import project.c2c.AdminC2cPaymentMethodService;
import project.c2c.C2cPaymentMethod;
import project.c2c.C2cPaymentMethodService;
import project.redis.RedisHandler;

public class AdminC2cPaymentMethodServiceImpl implements AdminC2cPaymentMethodService {
	
	private PagedQueryDao pagedDao;
	private C2cPaymentMethodService c2cPaymentMethodService;
	private RedisHandler redisHandler;

	public void save(C2cPaymentMethod entity) {		
		this.c2cPaymentMethodService.save(entity);
		C2cPaymentMethod methodSaved = c2cPaymentMethodService.getC2cPaymentMethod(entity.getId().toString());
		if (null != methodSaved) {
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_ID + methodSaved.getId().toString(), methodSaved);

			Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + methodSaved.getPartyId().toString());
			if (null == map) {
				map = new ConcurrentHashMap<String, C2cPaymentMethod>();
			}
			map.put(methodSaved.getId().toString(), methodSaved);
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + methodSaved.getPartyId().toString(), map);	
			
			Map<String, String> map1 = (Map<String, String>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE);
			if (null == map1) {
				map1 = new ConcurrentHashMap<String, String>();
			}
			map1.put(methodSaved.getId().toString(), String.valueOf(methodSaved.getMethodType()));
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE, map1);
		}
	}

	public Page pagedQuery(int pageNo, int pageSize, String user_code, Integer method_type_int, String method_name, String loginPartyId) {
		
		StringBuffer queryString = new StringBuffer();
		
		queryString.append(" SELECT ");
		queryString.append(" cpm.UUID id, cpm.METHOD_TYPE method_type, cpm.METHOD_NAME method_name, cpm.METHOD_IMG method_img, cpm.REAL_NAME real_name, ");
		queryString.append(" cpm.PARAM_NAME1 param_name1, cpm.PARAM_VALUE1 param_value1, cpm.PARAM_NAME2 param_name2, cpm.PARAM_VALUE2 param_value2, ");
		queryString.append(" cpm.PARAM_NAME3 param_name3, cpm.PARAM_VALUE3 param_value3, cpm.PARAM_NAME4 param_name4, cpm.PARAM_VALUE4 param_value4, ");
		queryString.append(" cpm.PARAM_NAME5 param_name5, cpm.PARAM_VALUE5 param_value5, cpm.PARAM_NAME6 param_name6, cpm.PARAM_VALUE6 param_value6, ");
		queryString.append(" cpm.PARAM_NAME7 param_name7, cpm.PARAM_VALUE7 param_value7, cpm.PARAM_NAME8 param_name8, cpm.PARAM_VALUE8 param_value8, ");
		queryString.append(" cpm.PARAM_NAME9 param_name9, cpm.PARAM_VALUE9 param_value9, cpm.PARAM_NAME10 param_name10, cpm.PARAM_VALUE10 param_value10, ");
		queryString.append(" cpm.PARAM_NAME11 param_name11, cpm.PARAM_VALUE11 param_value11, cpm.PARAM_NAME12 param_name12, cpm.PARAM_VALUE12 param_value12, ");
		queryString.append(" cpm.PARAM_NAME13 param_name13, cpm.PARAM_VALUE13 param_value13, cpm.PARAM_NAME14 param_name14, cpm.PARAM_VALUE14 param_value14, ");
		queryString.append(" cpm.PARAM_NAME15 param_name15, cpm.PARAM_VALUE15 param_value15, ");
		queryString.append(" cpm.QRCODE qrcode, cpm.REMARK remark, cpm.CREATE_TIME create_time, cpm.UPDATE_TIME update_time, ");
		queryString.append(" party.UUID party_id, party.USERCODE user_code, party.USERNAME user_name ");

		queryString.append(" FROM T_C2C_PAYMENT_METHOD cpm ");
		queryString.append(" LEFT JOIN PAT_PARTY party ON cpm.PARTY_ID = party.UUID ");
		queryString.append(" LEFT JOIN T_C2C_USER cu ON cu.C2C_USER_PARTY_ID = party.UUID ");
		queryString.append(" WHERE 1=1 ");

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

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

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

		if (method_type_int != null) {
			queryString.append(" AND cpm.METHOD_TYPE = :method_type_int  ");
			parameters.put("method_type_int", method_type_int);
		}
		
		if (StringUtils.isNotEmpty(method_name)) {
			queryString.append(" AND cpm.METHOD_NAME like :method_name ");
			parameters.put("method_name", "%" + method_name + "%");
		}

		queryString.append(" order by cpm.CREATE_TIME desc ");
		
		Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}

	public C2cPaymentMethod findById(Serializable id) {
		return this.c2cPaymentMethodService.get(id.toString());
	}

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

	public void update(C2cPaymentMethod entity) {
		boolean state = this.c2cPaymentMethodService.update(entity);
		if (state) {
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_ID + entity.getId().toString(), entity);
			
			Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) this.redisHandler.get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + entity.getPartyId().toString());
			if (null == map) {
				map = new ConcurrentHashMap<String, C2cPaymentMethod>();
			} else {
				map.remove(entity.getId().toString());
			}
			map.put(entity.getId().toString(), entity);
			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 (null == map1) {
				map1 = new ConcurrentHashMap<String, String>();
			} else {
				map1.remove(entity.getId().toString());
			}
			map1.put(entity.getId().toString(), String.valueOf(entity.getMethodType()));
			this.redisHandler.setSync(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE, map1);
		}
	}

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

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

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