import os
import re
import sys
import shutil
import time
import sqlite3
from datetime import datetime
from dateutil.relativedelta import relativedelta
from stock.crawler.FnGuideCrawler import FnGuideCrawler
from stock.crawler.MetaCrawler import MetaCrawler
from stock.crawler.StockCrawler import StockCrawler
from stock.analysis.AnalyzerSqlite import AnalyzerSqlite
from stock.util.TelegramBot import TelegramBot


class StockCrawlerDaily:

    PROJECT_HOME = None
    bot = None

    def __init__(self, PROJECT_HOME):
        self.PROJECT_HOME = PROJECT_HOME
        self.bot = TelegramBot()

        return

    def crawl(self):

        START_DATE = "2000.01.01"
        RESOURCE_PATH = os.path.join(self.PROJECT_HOME, 'resources')
        stockFileName = os.path.join(RESOURCE_PATH, 'stock.db')

        self.bot.sendMsg("1. start to crawl...")

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                # 재무제표는 3개월마다 다운로드를 한다.
                fnGuideCrawler = FnGuideCrawler(START_DATE)
                print("[KOSPI 상장기업 재무제표 다운로드]")
                fnGuideCrawler.crawl_fnguide(stockFileName)
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        metaCrawler = MetaCrawler(START_DATE)

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                print("\n[증시자금동향 (신용잔고, 펀드자금 잔고)]")
                metaCrawler.crawl_money_trend(stockFileName)
                self.bot.sendMsg("2. done meta data...")
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                print("\n[국내 시장금리]")
                metaCrawler.crawl_interest_rates(stockFileName)
                self.bot.sendMsg("3. done interest rates...")
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                print("\n[투자자별 매매동향(Trading_Trend)]")
                metaCrawler.crawl_trading_trend(stockFileName)
                self.bot.sendMsg("4. done trade trend...")
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                print("\n[환율 (USD, JPY, EUR, CNY, HKD, GBP, CAD, CHF, AUD, THB, INR, PHP, BRL, VND, RUB, TWD')]")
                metaCrawler.crawl_exchange(stockFileName)
                self.bot.sendMsg("5. done exchange data...")
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        ERROR_COUNT = 0
        while ERROR_COUNT < 3:
            try:
                print("\n[원유 (WTI), 국제금, COPPER, NATURALGAS, CORN, SOYBEAN 등]")
                metaCrawler.crawl_meterials(stockFileName)
                self.bot.sendMsg("6. done additional data...")
                break
            except:
                ERROR_COUNT += 1
                continue
        if ERROR_COUNT >= 3:
            exit()

        stockCrawler = StockCrawler(START_DATE)

        print("\n[국내 ETF 수집]")
        stockCrawler.crawl_etf_stocks(stockFileName)
        self.bot.sendMsg("7. done etf stocks...")

        print("\n[국내 종목 수집]")
        stockCrawler.crawl_stocks(stockFileName)
        self.bot.sendMsg("8. done stocks...")

        print("\n[US 종목 수집]")
        stockCrawler.crawl_special_stocks(stockFileName)
        self.bot.sendMsg("9. done US stocks...")

        analyzerSqlite = AnalyzerSqlite(stockFileName)

        print("\n[종목 분석]")
        # S: 분석까지 진행
        analyzerSqlite.analyzeDaily()
        analyzerSqlite.analyzeGrouping("weekly")
        analyzerSqlite.analyzeGrouping("monthly")
        self.bot.sendMsg("10. analyze...")

        print("\n[종목 결정]")
        # HTML 출력
        outPath = os.path.join(self.PROJECT_HOME, "resources", "analysis")
        if not os.path.isdir(outPath):
            os.mkdir(outPath)
        day = datetime.today().strftime("%Y%m%d")
        before_7_day = datetime.today() + relativedelta(days=-7)
        dayList = os.listdir(outPath)
        for dayDir in dayList:
            if dayDir[0] != '.' and dayDir < before_7_day.strftime("%Y%m%d"):
                if os.path.exists(os.path.join(outPath, dayDir)) and os.path.isdir(os.path.join(outPath, dayDir)):
                    shutil.rmtree(os.path.join(outPath, dayDir))
        outPath = os.path.join(outPath, day)
        if os.path.isdir(outPath):
            shutil.rmtree(outPath)
        os.mkdir(outPath)

        analyzerSqlite.findCandidates(outPath)
        self.bot.sendMsg("11. done decision...")

        return


if __name__ == "__main__":
    # DB Browser for SQLite: http://hleecaster.com/python-sqlite3/

    if len(sys.argv) == 2:
        PROJECT_HOME = sys.argv[1]
    else:
        PROJECT_HOME = os.getcwd()

    START_DATE = "2000.01.01"
    stockCrawlerDaily = StockCrawlerDaily(PROJECT_HOME)

    week = datetime.today().weekday()
    if week in (0, 1, 2, 3, 4, 5):  # 0:월, 1:화, 2:수, 3:목, 4:금, 5:토, 6:일
        start = time.time()
        stockCrawlerDaily.crawl()
        today = datetime.now().strftime("%Y-%m-%d")
        print("time : %6.2f 초", (time.time() - start))
        print("done...")