#include "common/pch.h"
#include "SellManager.h"
#include "../common/NetworkApi.h"
#include "../common/JsonUtil.h"
#include "ConfigUtil.h"
#include "../common/JsonUtil.h"
#include "../common/TimeUtil.h"
#include <iostream>
#include <ctime>


SellSetting* SellManager::getSellSetting(string code)
{
	if (sellSettingMap.find(code) != sellSettingMap.end())
	{
		return sellSettingMap[code];
	}
	return nullptr;
}



CodePosition* SellManager::getCodePosition(string code)
{
	if (codePositionMap.find(code) != codePositionMap.end())
	{
		return codePositionMap[code];
	}
	return nullptr;
}

int SellManager::sell(string code, int sellPriceType)
{

	if (sellSettingMap.find(code) == sellSettingMap.end()) {
		throw wstring(L"ÉÐδÉèÖÃÂô³ö¹æÔò");
	}
	//»ñÈ¡³Ö²ÖÐÅÏ¢
	if (codePositionMap.find(code) == codePositionMap.end()) {
		throw wstring(L"ÉÐδ»ñÈ¡µ½³Ö²Ö");
	}

	int money = computeCurrentMoney(code);

	if (money <= 0) {
		throw wstring(L"¿ÉÂô³öÁ¿Îª0");
	}

	int volume = sellMoneyToVolume(money, codePositionMap[code]->costPrice);
	if (volume > codePositionMap[code]->available) {
		volume = codePositionMap[code]->available;
	}
	return	sell(code, volume, sellPriceType);
}

int SellManager::sell(string code, int volume, int sellPriceType)
{
	string result = NetworkApi::sell(code, volume, sellPriceType, true);
	CString msg(code.c_str());
	msg.Append(L"£º");
	auto doc = JsonUtil::parseUTF16(result);
	if (doc.IsObject() && doc.HasMember(L"code")) {
		if (doc[L"code"] == 0) {
			if (doc[L"data"].HasMember(L"orderRef")) {
				msg.Append(_T("Ìá½»Âô³É¹¦"));
				int orderRef = doc[L"data"][L"orderRef"].GetInt();
				return orderRef;
			}
			else if (doc[L"data"].HasMember(L"orderStatusMsg")) {
				msg.Append(doc[L"data"][L"orderStatusMsg"].GetString());
				throw wstring(msg);
			}
		}
		else {
			if (doc.HasMember(L"msg")) {
				msg.Append(doc[L"msg"].GetString());
				throw wstring(msg);
			}
		}
	}
	else {
		msg.Append(L"½âÎö½á¹û³ö´í");
		throw wstring(msg);
	}


}

void SellManager::lockVolume(string code, int volume)
{
}

void SellManager::unLockVolume(string code)
{
}

int SellManager::computeCurrentMoney(string code)
{
	SellSetting* sellSetting = sellSettingMap[code];
	CodePosition* pos = codePositionMap[code];

	//if (pos->available <= 0) {
	//	return 0;
	//}

	int sell_count_100 = 0;
	int available_100 = pos->available / 100;

	if (!sellSetting->lock)
	{
		if (sellSetting->setting_mode == SETTING_MODE_RATE) {
			list<UINT> volumeList = distributeVolume(pos->total / 100, sellSetting->mode1_rate_index);
			sell_count_100 = computeSellVolume(volumeList, pos->sell_orders);
		}
		else {
			int first_percent = (sellSetting->mode2_first_index + 1) * 10;
			int second_count = (sellSetting->mode2_left_index + 1);
			int total_100 = pos->total / 100;

			if (pos->sell_orders.size() == 0) {
				sell_count_100 = total_100 * first_percent / 100;
				if (total_100 * first_percent % 100 != 0) {
					sell_count_100 += 1;
				}
			}
			else {
				// ×ֲּܳõÈ¥µÚÒ»´ÎµÄ³Ö²Ö
				list<UINT> volumeList = distributeVolume(total_100 - *(pos->sell_orders.begin()) / 100, second_count);
				list<UINT>::iterator el = volumeList.begin();
				advance(el, pos->sell_orders.size() - 1);
				if (el != volumeList.end()) {
					sell_count_100 = *el;
				}
				else {
					sell_count_100 = 0;
				}
			}
		}
	}
	else {
		if (sellSetting->lockMoney <= 0) {
			CString msg = L"Ëø¶¨Á¿´íÎó:";
			msg.Append(to_wstring(sellSetting->lockMoney).c_str());
			throw wstring(msg);
		}
		// µ±Ç°Ê±¼äÔÚ09:30Ö®ºó£¬Ëø¶¨Ê±¼äÔÚ09:30֮ǰµÄ¾Í·µ»ØĬÈÏÖµ
		/*auto nowTime = stoi(TimeUtil::getNowTime("%H%M%S").c_str());
		if (nowTime >= 93000 && sellSetting->lockTime < 93000) {
			return	ConfigUtil::getSellMoney();
		}*/
		return sellSetting->lockMoney;
	}

	if (sell_count_100 > available_100) {
		sell_count_100 = available_100;
	}


	return (int) round(sell_count_100 * 100 * pos->costPrice);
}

void SellManager::syncSettingToFile(string code)
{
	
    // ¶ÔÏóתΪjson
	
	if (sellSettingMap.find(code)== sellSettingMap.end())
	{
		return;
	}

	SellSetting* sellSetting = sellSettingMap[code];
	auto nowDate = getNowDate();
	string key = string("sell_setting-").append(nowDate).append("-").append(code);

	rapidjson::StringBuffer buf;
	rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(buf);
	writer.StartObject();
	writer.Key("setting_mode");
	writer.Int(sellSetting->setting_mode);
	writer.Key("lock");
	writer.Bool(sellSetting->lock);
	writer.Key("lockMoney");
	writer.Int(sellSetting->lockMoney);
	writer.Key("lockBuy");
	writer.Bool(sellSetting->lockBuy);
	writer.Key("lockBuyMoney");
	writer.Int(sellSetting->lockBuyMoney);
	writer.Key("mode1_rate_index");
	writer.Int(sellSetting->mode1_rate_index);
	writer.Key("mode2_first_index");
	writer.Int(sellSetting->mode2_first_index);
	writer.Key("mode2_left_index");
	writer.Int(sellSetting->mode2_left_index);
	writer.EndObject();
	const char* json_content = buf.GetString();
	ConfigUtil::setStringConfig(key.c_str(), json_content);
}

void SellManager::clearPreSettings()
{
	list<string> keys = ConfigUtil::getKeys();

	auto nowDate = getNowDate();
	string prefix = string("sell_setting-");
	string prefix_today = string("sell_setting-").append(nowDate);

	for (list<string>::iterator e = keys.begin(); e != keys.end(); e++) {
		string key = *e;
		if (key.find(prefix) == 0 && key.find(prefix_today) < 0) {
			ConfigUtil::delKey(key);
		}
	}
}


string SellManager::getNowDate()
{
	std::time_t now = std::time(nullptr);
	// ʹÓñ¾µØʱ¼äת»»µ±Ç°Ê±¼ä
	std::tm currentDate;
	localtime_s(&currentDate,&now);
	// ¶¨ÒåÈÕÆÚ¸ñʽ
	char buffer[80];
	std::strftime(buffer, sizeof(buffer), "%Y%m%d", &currentDate);
	return string(buffer);
}

SellSetting* SellManager::loadSettingFromFile(string code)
{

	auto nowDate = getNowDate();
	string key = string("sell_setting-").append(nowDate).append("-").append(code);
	try {
		string result = ConfigUtil::readStringConfig(key.c_str());
		auto doc = JsonUtil::parseUTF8(result);
		SellSetting* setting = new SellSetting();
		setting->lock = doc["lock"].GetBool();
		setting->lockMoney = doc["lockMoney"].GetInt();
		setting->lockBuy = doc["lockBuy"].GetBool();
		setting->lockBuyMoney = doc["lockBuyMoney"].GetInt();
		setting->setting_mode = doc["setting_mode"].GetInt()==0? SETTING_MODE_RATE: SETTING_MODE_PERCENT;
		setting->mode2_first_index = doc["mode2_first_index"].GetInt();
		setting->mode2_left_index = doc["mode2_left_index"].GetInt();
		setting->mode1_rate_index = doc["mode1_rate_index"].GetInt();
		return setting;
	}
	catch (...) {
	
	}



	return nullptr;
}

list<UINT> SellManager::distributeVolume(UINT total, UINT percent)
{
	list<UINT> volumeList;
	UINT base = total / percent;
	UINT left = total % percent;
	for (UINT i = 0; i < percent; i++) {
		if (i + 1 <= left) {
			volumeList.push_back(base + 1);
		}
		else {
			volumeList.push_back(base);
		}
	}
	return volumeList;
}

UINT SellManager::computeSellVolume(list<UINT> volumeList, list<int> sell_volumes)
{
	if (sell_volumes.size() >= volumeList.size()) {
		return 0;
	}
	list<UINT>::iterator el = volumeList.begin();
	advance(el, sell_volumes.size());
	if (el != volumeList.end()) {
		return *el;
	}
	return 0;
}


int SellManager::sellMoneyToVolume(int money, double price)
{
	int volume = ((int)round((money / price) * 100)) / 100;
	volume = volume < 0 ? 0 : volume;
	return volume / 100 * 100;
}

void SellManager::init(string code)
{
	// ³õʼ»¯´úÂë
	if (getSellSetting(code) == nullptr) {
		SellSetting* setting = loadSettingFromFile(code);
		if (setting == nullptr) {
			setting = new SellSetting();
			setting->lock = true;
			setting->lockMoney = ConfigUtil::getSellMoney();
			setting->lockBuy = true;
			setting->lockTime = stoi(TimeUtil::getNowTime("%H%M%S").c_str());
			setting->lockBuyMoney = 0;
			setting->setting_mode = SETTING_MODE_RATE;
			setting->mode1_rate_index = 4;
		}
		sellSettingMap[code] = setting;
	}

	if (getCodePosition(code) == nullptr) {
		CodePosition* codePosition = new CodePosition();
		codePosition->available = 0;
		codePosition->costPrice = 0.0f;
		codePosition->total = 0;
		codePosition->sell_rules_count = 0;
		codePosition->sell_orders = list<int>();
		codePositionMap[code] = codePosition;
	}
}