package project.cms.internal;

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

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

import kernel.bo.RecordObjectMapper;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.cms.AdminCmsService;
import project.cms.Cms;
import project.cms.CmsRedisKeys;
import project.cms.PropertiesUtilCms;
import project.redis.RedisHandler;

public class AdminCmsServiceImpl implements AdminCmsService {

	private JdbcTemplate jdbcTemplate;
	
	private RedisHandler redisHandler;
	
	/**
	 * 新增Cms记录
	 */
	public void saveCms(Cms entity) {
		String insertSql = "INSERT INTO T_CMS(UUID,TITLE,CONTENT,CREATE_TIME,MODEL,LANGUAGE,CONTENT_CODE) VALUES (?,?,?,?,?,?,?)";
		jdbcTemplate.update(insertSql,entity.getId(),entity.getTitle(),entity.getContent(),
				entity.getCreateTime(),entity.getModel(),entity.getLanguage(),entity.getContent_code());
		
		redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE_CONTENTCODE + entity.getLanguage() + entity.getContent_code(), entity);
		
		Map<String, Cms> cacheLanguage = (Map<String, Cms>) redisHandler.get(CmsRedisKeys.CMS_LANGUAGE + entity.getLanguage());
		if(cacheLanguage==null) {
			cacheLanguage =  new ConcurrentHashMap<String, Cms>();
		}
		cacheLanguage.put(entity.getContent_code(), entity);
		redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE+entity.getLanguage(),cacheLanguage);
	}
	
	public void update(Cms entity,String strOriginalLanguage,String strOriginalContentCode) {
		//清理 CMS_LANGUAGE_CONTENTCODE_?0?1（?0：language ?1：contentcode）
		String strRedisKey = CmsRedisKeys.CMS_LANGUAGE_CONTENTCODE + strOriginalLanguage + strOriginalContentCode;		
		redisHandler.remove(strRedisKey);
		
		//清理 CMS_LANGUAGE_?0（?0：language）
		Map<String, Cms> cacheLanguage = (Map<String, Cms>) redisHandler.get(CmsRedisKeys.CMS_LANGUAGE + strOriginalLanguage);
		if(null != cacheLanguage) {
			for(Map.Entry<String, Cms> it : cacheLanguage.entrySet()){
				Cms cms = it.getValue();
				if(null != cms) {
					String strContentCode = cms.getContent_code();
					if(!strContentCode.isEmpty()) {
						if(0 == strContentCode.compareTo(strOriginalContentCode)) {
							cacheLanguage.remove(strOriginalContentCode);
							redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE + strOriginalLanguage,cacheLanguage);
							break;
						}
					}
				}
			}		
		}	
		
		String updateSql = "UPDATE T_CMS SET TITLE=?, CONTENT=?, MODEL=?, LANGUAGE=?, CONTENT_CODE=? WHERE UUID=?";
		jdbcTemplate.update(updateSql,entity.getTitle(), entity.getContent(), entity.getModel(), 
				entity.getLanguage(), entity.getContent_code(), entity.getId());
		
		redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE_CONTENTCODE + entity.getLanguage() + entity.getContent_code(), entity);
		
		if(cacheLanguage==null) {
			cacheLanguage = new ConcurrentHashMap<String, Cms>();
		}
		cacheLanguage.put(entity.getContent_code(), entity);
		redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE + entity.getLanguage(), cacheLanguage);
		
	}

	public Page pagedQuery(int pageNo, int pageSize, String language, String title,String content_code_para) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		StringBuilder whereBuilder=new StringBuilder("WHERE 1=1 ");
		ArrayList<Object> params=new ArrayList<Object>();
		
		if (StringUtils.isNotEmpty(language)) {
			whereBuilder.append("AND LANGUAGE=? ");
			params.add(language);
		}
		
		if (StringUtils.isNotEmpty(title)) {
			whereBuilder.append("AND TITLE LIKE ? ");
			params.add("%"+title+"%");
		}
		
		if (StringUtils.isNotEmpty(content_code_para)) {
			whereBuilder.append("AND CONTENT_CODE=? ");
			params.add(content_code_para);
		}
		
		whereBuilder.append("ORDER BY CREATE_TIME DESC LIMIT ?,? ");
		params.add(page.getFirstElementNumber());
		params.add(pageSize);
		
		List<Cms> list=ApplicationUtil.executeSelect(Cms.class,whereBuilder.toString(),params.toArray(new Object[params.size()]));
		page.setElements(list);
		return page;
	}

	public Cms findById(String id) {
		List<Cms> list = jdbcTemplate.query("SELECT * FROM T_CMS WHERE UUID=?", RecordObjectMapper.newInstance(Cms.class), id);
		if (null != list && list.size() > 0) {
			return list.get(0);
        }
		return null;
	}

	public Map<String, String> getModelDatasDictionary() {
		String datas = PropertiesUtilCms.getProperty("system_cms_model_list");
		String[] splits = datas.split(",");
		Map<String, String> map = new HashMap<String, String>();
		for (String data : splits) {
			map.put(data, data);
		}
		return map;
	}

	public void delete(Cms cms) {
		if (cms != null) {
			jdbcTemplate.update("DELETE FROM T_CMS WHERE UUID=?", cms.getId());
			
			redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE_CONTENTCODE + cms.getLanguage() + cms.getContent_code(), null);
			Map<String, Cms> cacheLanguage = (Map<String, Cms>) redisHandler.get(CmsRedisKeys.CMS_LANGUAGE + cms.getLanguage());
			if (cacheLanguage != null) {
				cacheLanguage.remove(cms.getContent_code());
			}
			redisHandler.setSync(CmsRedisKeys.CMS_LANGUAGE + cms.getLanguage(), cacheLanguage);
		}
	}

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

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