package com.yeshi.fanli.service.impl.help;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;

import javax.annotation.Resource;

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.tencentcloud.COSManager;

import com.yeshi.fanli.dao.mybatis.help.HelpCenterMapper;
import com.yeshi.fanli.entity.AppVersionInfo;
import com.yeshi.fanli.entity.bus.help.HelpCenter;
import com.yeshi.fanli.entity.bus.help.HelpInfo;
import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl;
import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;
import com.yeshi.fanli.exception.config.HelpCenterException;
import com.yeshi.fanli.service.inter.help.HelpCenterService;
import com.yeshi.fanli.service.inter.homemodule.AdActivityVersionControlService;
import com.yeshi.fanli.util.FilePathEnum;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.db.MongoDBManager;

@Service
public class HelpCenterServiceImpl implements HelpCenterService {

	@Resource
	private HelpCenterMapper helpCenterMapper;

	@Resource
	private MongoDBManager mongoDBManager;

	@Resource
	private AdActivityVersionControlService adActivityVersionControlService;

	@Override
	public int updateByPrimaryKey(HelpCenter record) {
		return helpCenterMapper.updateByPrimaryKey(record);
	}

	@Override
	public int updateByPrimaryKeySelective(HelpCenter record) {
		return helpCenterMapper.updateByPrimaryKeySelective(record);
	}

	@Override
	public HelpCenter selectByPrimaryKey(Long id) {
		return helpCenterMapper.selectByPrimaryKey(id);
	}

	@Override
	public HelpCenter selectByPrimaryKeyCache(Long id) {
		return selectByPrimaryKey(id);
	}

	@Override
	public String save(HelpCenter helpCenter, String content, String html) throws HelpCenterException, Exception {
		if (StringUtil.isNullOrEmpty(helpCenter.getTitle()))
			throw new HelpCenterException(1, "标题不能为空");

		if (helpCenter.getHelpClass() == null || helpCenter.getHelpClass().getId() <= 0)
			throw new HelpCenterException(1, "分类题不能为空");

		Integer state = helpCenter.getState();
		if (state == null) {
			helpCenter.setState(0);
		}

		Integer weight = helpCenter.getWeight();
		if (weight == null) {
			helpCenter.setWeight(0);
		}

		helpCenter.setUpdatetime(new Date());
		Long id = helpCenter.getId();
		if (id == null) {
			helpCenter.setCreatetime(new Date());
			helpCenterMapper.insert(helpCenter);
		} else {
			HelpCenter result = helpCenterMapper.selectByPrimaryKey(id);
			if (result == null)
				throw new HelpCenterException(1, "此类内容已不存在，请刷新");

			helpCenter.setCreatetime(result.getCreatetime());
			helpCenterMapper.updateByPrimaryKey(helpCenter);
		}

		List<Map<String, Object>> positions = getPosition(html);
		if (positions != null && positions.size() > 0) {
			@SuppressWarnings("restriction")
			sun.misc.BASE64Decoder decoder = new sun.misc.BASE64Decoder();

			for (int i = 0; i < positions.size(); i++) {
				Map<String, Object> map = positions.get(i);
				String base64Img = (String) map.get("base64Img");
				byte[] b = decoder.decodeBuffer(base64Img);
				for (int j = 0; j < b.length; ++j) {
					if (b[j] < 0) {
						b[j] += 256;
					}
				}

				String type = (String) map.get("type");
				// 上传文件相对位置
				String fileUrl = FilePathEnum.helpCenterContent + UUID.randomUUID().toString().replace("-", "") + "."
						+ type;
				/* 上传新图片 */
				String uploadFilePath = COSManager.getInstance().uploadFileByte(b, fileUrl).getUrl();

				if (!StringUtil.isNullOrEmpty(uploadFilePath)) {
					String header = (String) map.get("header");
					html = html.replace(header, uploadFilePath);
				}
			}
		}

		String replaceHtml = replaceIframe(html);
		Long backId = helpCenter.getId();
		HelpInfo helpInfo = new HelpInfo(backId, content, replaceHtml);
		mongoDBManager.saveHelpInfo(helpInfo);
		return html;
	}

	public List<Map<String, Object>> getPosition(String content) {

		List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>();

		// 需要对比的字符串
		String compareStr = "base64";
		String compareStrStart = "data:image/";
		// 字符串查找初始从0开始查找
		int indexStart = 0;
		int indexTypeStart = 0;
		// 获取查找字符串的长度，这里有个规律：第二次查找出字符串的起始位置等于 第一次ab字符串出现的位置+ab的长度
		int compareStrLength = compareStr.length();

		while (true) {
			Map<String, Object> place = new HashMap<String, Object>();

			int tm = content.indexOf(compareStr, indexStart);
			int typetm = content.indexOf(compareStrStart, indexTypeStart);

			if (tm <= 0) {
				// 直到没有匹配结果为止
				break;
			} else {
				// 没查找一次就从新计算下次开始查找的位置
				indexStart = tm + compareStrLength;
				indexTypeStart = typetm + compareStrLength;

				// System.out.println(indexStart);
				// System.out.println(indexTypeStart);

				place.put("start", tm + 7);

				String suffix = content.substring(typetm + 11, tm - 1);
				place.put("type", suffix);

				String newContent = content.substring(tm + 7, content.length());

				char qmark = '"';
				int end = newContent.indexOf(qmark);
				place.put("end", end);

				String base64Img = newContent.substring(0, end);
				place.put("base64Img", base64Img);

				String header = compareStrStart + suffix + ";" + compareStr + "," + base64Img;
				place.put("header", header);

				listMap.add(place);
			}
		}

		return listMap;
	}

	public String replaceIframe(String html) {

		String result = html;

		// 字符串查找初始从0开始查找
		int indexStart = 0;
		// 需要对比的字符串
		String compareStr = "<iframe";

		int compareStrLength = compareStr.length();

		while (true) {

			int tm = html.indexOf(compareStr, indexStart);

			if (tm <= 0) {
				// 直到没有匹配结果为止
				break;
			} else {
				// 起始位置
				indexStart = tm + compareStrLength;

				// 结束位置
				String newContent = html.substring(tm, html.length());
				int end = newContent.indexOf("</iframe>");

				// 替换指定字段 <iframe src=""></iframe>
				String replaceStr = html.substring(tm, tm + end + 9);

				char qmark = '"';
				// src 起始位置
				int srcindex = replaceStr.indexOf("src=", 0);

				String replaceSrc = replaceStr.substring(srcindex + 5, replaceStr.length());
				// src "结束位置
				int endsrc = replaceSrc.indexOf(qmark, 0);

				String src = replaceSrc.substring(0, endsrc + 1);

				String voide = "<video src=\"" + src + " controls=\"controls\"> 您的浏览器不支持video标签，请更新浏览器</video>";

				result = html.replace(replaceStr, voide);
			}
		}

		return result;
	}

	@Override
	public List<HelpCenter> query(int pageIndex, int pageSize, String key, Long cid, Integer orderMode, Integer state) {
		return helpCenterMapper.query(pageIndex, pageSize, key, cid, orderMode, state);
	}

	@Override
	public long countQuery(String key, Long cid, Integer state) {
		return helpCenterMapper.countQuery(key, cid, state);
	}

	@Override
	@Cacheable(value = "helpCenterCache", key = "'queryIdAndTitle-'+#pageId+'-'+#key+'-'+#cid")
	public List<HelpCenter> listValid(long pageId, int pageSize, String key, Long cid) {
		return helpCenterMapper.listValid(pageId, pageSize, key, cid);
	}

	@Override
	public int deleteBatchById(List<String> idList) {
		return helpCenterMapper.deleteBatchById(idList);
	}

	@Override
	public HelpInfo getHelpInfo(Long id) {
		return mongoDBManager.getHelpInfo(id);
	}

	@Override
	@Cacheable(value = "helpCenterCache", key = "'getHelpInfoCache-'+#id")
	public HelpInfo getHelpInfoCache(Long id) {
		return getHelpInfo(id);
	}

	@Override
	@Transactional(rollbackFor = Exception.class)
	public void deleteInfoBatchById(List<String> idList) {
		if (idList != null) {
			for (String id : idList) {
				mongoDBManager.removeHelpInfo(Long.parseLong(id));
			}
		}
	}

	@Transactional(rollbackFor = Exception.class)
	@Override
	public void setVersions(Long id, List<Long> versions) throws HelpCenterException {
		HelpCenter helpCenter = helpCenterMapper.selectByPrimaryKey(id);
		if (helpCenter == null) {
			throw new HelpCenterException(1, "此信息不存在，请刷新重试");
		}

		Set<Long> oldSet = new HashSet<>();
		List<AdActivityVersionControl> versionList = adActivityVersionControlService
				.listByTypeAndSourceId(AdActivityType.helpCenter, id);
		if (versionList != null) {
			for (AdActivityVersionControl control : versionList)
				oldSet.add(control.getVersion().getId());
		}

		Set<Long> newSet = new HashSet<>();
		for (Long version : versions) {
			newSet.add(version);
		}

		Set<Long> delSet = new HashSet<>();
		delSet.addAll(oldSet);
		delSet.removeAll(newSet);
		for (Long versionId : delSet) {
			adActivityVersionControlService.deleteBySourceAndVersion(id, AdActivityType.helpCenter, versionId);
		}

		Set<Long> addSet = new HashSet<>();
		addSet.addAll(newSet);
		addSet.removeAll(oldSet);

		// 添加映射
		for (Long versionId : addSet) {
			AdActivityVersionControl control = new AdActivityVersionControl();
			control.setCreateTime(new Date());
			control.setSourceId(id);
			control.setType(AdActivityType.helpCenter);
			control.setVersion(new AppVersionInfo(versionId));
			try {
				adActivityVersionControlService.addVersionControl(control);
			} catch (Exception e) {
				throw new HelpCenterException(2, e.getMessage());
			}
		}
	}
}