thaifin.sources.finnomena

View Source 
from typing import Dict
from typing import List
from typing import Optional

from cachetools import cached, TTLCache
from tenacity import retry, stop_after_attempt, wait_exponential
import requests

from pydantic import BaseModel


class BaseResponse(BaseModel):
    statusOK: bool
    data: List[Dict]


class FinancialSheet(BaseModel):
    SecurityID: Optional[int]
    Fiscal: Optional[int]
    Quarter: Optional[int]
    Cash: Optional[float]
    DA: Optional[float]
    DebtToEquity: Optional[float]
    Equity: Optional[float]
    EarningPerShare: Optional[float]
    EarningPerShareYoY: Optional[float]
    EarningPerShareQoQ: Optional[float]
    GPM: Optional[float]
    GrossProfit: Optional[float]
    NetProfit: Optional[float]
    NetProfitYoY: Optional[float]
    NetProfitQoQ: Optional[float]
    NPM: Optional[float]
    Revenue: Optional[float]
    RevenueYoY: Optional[float]
    RevenueQoQ: Optional[float]
    ROA: Optional[float]
    ROE: Optional[float]
    SGA: Optional[float]
    SGAPerRevenue: Optional[float]
    TotalDebt: Optional[float]
    DividendYield: Optional[float]
    BookValuePerShare: Optional[float]
    Close: Optional[float]
    MKTCap: Optional[float]
    PriceEarningRatio: Optional[float]
    PriceBookValue: Optional[float]
    EVPerEbitDA: Optional[float]
    EbitDATTM: Optional[float]
    PaidUpCapital: Optional[float]
    CashCycle: Optional[float]
    OperatingActivities: Optional[float]
    InvestingActivities: Optional[float]
    FinancingActivities: Optional[float]
    Asset: Optional[float]


class FinancialSheetsResponse(BaseResponse):
    data: List[FinancialSheet]


@cached(cache=TTLCache(maxsize=12345, ttl=24 * 60 * 60))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_financial_sheet(securityID, fiscal=2009):
    url = "https://www.finnomena.com/fn3/api/stock/financial"

    querystring = {"securityID": str(securityID), "fiscal": str(fiscal)}

    payload = ""
    headers = {
        "connection": "keep-alive",
        "accept": "application/json, text/plain, */*",
        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.116 Safari/537.36 Edg/83.0.478.58",
        "sec-fetch-site": "same-origin",
        "sec-fetch-mode": "cors",
        "sec-fetch-dest": "empty",
        "referer": "https://www.finnomena.com/stock/SCB?bt_id=60",
        "accept-language": "en-US,en;q=0.9,th;q=0.8",
    }

    response = requests.request(
        "GET", url, data=payload, headers=headers, params=querystring
    )

    return FinancialSheetsResponse.parse_raw(response.text)


class StockInfo(BaseModel):
    name: str
    thName: str
    enName: str
    company_id: int
    security_id: int


class StockInfosResponse(BaseResponse):
    data: List[StockInfo]


@cached(cache=TTLCache(maxsize=1, ttl=24 * 60 * 60))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_stock_list() -> StockInfosResponse:
    url = "https://www.finnomena.com/fn3/api/stock/list"

    payload = ""
    headers = {
        "connection": "keep-alive",
        "accept": "application/json, text/plain, */*",
        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.116 Safari/537.36 Edg/83.0.478.58",
        "sec-fetch-site": "same-origin",
        "sec-fetch-mode": "cors",
        "sec-fetch-dest": "empty",
        "referer": "https://www.finnomena.com/stock/SCB?bt_id=60",
        "accept-language": "en-US,en;q=0.9,th;q=0.8",
        # 'cookie': "finnakies=5MLMJIS20200601; _ga=GA1.2.1303959403.1591006631; _fbp=fb.1.1591006631416.2138659500; PHPSESSID=on32ipkohq41hfv1dcu2eutuou; anspress_session=83fa3179f4e427a9e00e328d0d2ba568; _gid=GA1.2.1759981110.1594035335; terms_cond_accepted=false; _cbclose=1; _cbclose47370=1; _uid47370=595254B6.3; _ctout47370=1; verify=test; finnakies-ss=635VtLn20200706; _hjid=053a69da-8d52-4064-b1ce-82118f02ac68; _hjAbsoluteSessionInProgress=1; __cfduid=dad57d546f7805625889ebd80a183dc091594035361; _hjDonePolls=376740; visit_time=10"
    }

    response = requests.request("GET", url, data=payload, headers=headers)

    return StockInfosResponse.parse_raw(response.text)
class BaseResponse(pydantic.main.BaseModel):
View Source 
class BaseResponse(BaseModel):
    statusOK: bool
    data: List[Dict]
statusOK: bool
data: List[Dict]
Inherited Members
pydantic.main.BaseModel
BaseModel
dict
json
parse_obj
parse_raw
parse_file
from_orm
construct
copy
schema
schema_json
validate
update_forward_refs
fields
to_string
pydantic.main
Config
class FinancialSheet(pydantic.main.BaseModel):
View Source 
class FinancialSheet(BaseModel):
    SecurityID: Optional[int]
    Fiscal: Optional[int]
    Quarter: Optional[int]
    Cash: Optional[float]
    DA: Optional[float]
    DebtToEquity: Optional[float]
    Equity: Optional[float]
    EarningPerShare: Optional[float]
    EarningPerShareYoY: Optional[float]
    EarningPerShareQoQ: Optional[float]
    GPM: Optional[float]
    GrossProfit: Optional[float]
    NetProfit: Optional[float]
    NetProfitYoY: Optional[float]
    NetProfitQoQ: Optional[float]
    NPM: Optional[float]
    Revenue: Optional[float]
    RevenueYoY: Optional[float]
    RevenueQoQ: Optional[float]
    ROA: Optional[float]
    ROE: Optional[float]
    SGA: Optional[float]
    SGAPerRevenue: Optional[float]
    TotalDebt: Optional[float]
    DividendYield: Optional[float]
    BookValuePerShare: Optional[float]
    Close: Optional[float]
    MKTCap: Optional[float]
    PriceEarningRatio: Optional[float]
    PriceBookValue: Optional[float]
    EVPerEbitDA: Optional[float]
    EbitDATTM: Optional[float]
    PaidUpCapital: Optional[float]
    CashCycle: Optional[float]
    OperatingActivities: Optional[float]
    InvestingActivities: Optional[float]
    FinancingActivities: Optional[float]
    Asset: Optional[float]
SecurityID: Union[int, NoneType]
Fiscal: Union[int, NoneType]
Quarter: Union[int, NoneType]
Cash: Union[float, NoneType]
DA: Union[float, NoneType]
DebtToEquity: Union[float, NoneType]
Equity: Union[float, NoneType]
EarningPerShare: Union[float, NoneType]
EarningPerShareYoY: Union[float, NoneType]
EarningPerShareQoQ: Union[float, NoneType]
GPM: Union[float, NoneType]
GrossProfit: Union[float, NoneType]
NetProfit: Union[float, NoneType]
NetProfitYoY: Union[float, NoneType]
NetProfitQoQ: Union[float, NoneType]
NPM: Union[float, NoneType]
Revenue: Union[float, NoneType]
RevenueYoY: Union[float, NoneType]
RevenueQoQ: Union[float, NoneType]
ROA: Union[float, NoneType]
ROE: Union[float, NoneType]
SGA: Union[float, NoneType]
SGAPerRevenue: Union[float, NoneType]
TotalDebt: Union[float, NoneType]
DividendYield: Union[float, NoneType]
BookValuePerShare: Union[float, NoneType]
Close: Union[float, NoneType]
MKTCap: Union[float, NoneType]
PriceEarningRatio: Union[float, NoneType]
PriceBookValue: Union[float, NoneType]
EVPerEbitDA: Union[float, NoneType]
EbitDATTM: Union[float, NoneType]
PaidUpCapital: Union[float, NoneType]
CashCycle: Union[float, NoneType]
OperatingActivities: Union[float, NoneType]
InvestingActivities: Union[float, NoneType]
FinancingActivities: Union[float, NoneType]
Asset: Union[float, NoneType]
Inherited Members
pydantic.main.BaseModel
BaseModel
dict
json
parse_obj
parse_raw
parse_file
from_orm
construct
copy
schema
schema_json
validate
update_forward_refs
fields
to_string
pydantic.main
Config
class FinancialSheetsResponse(thaifin.sources.finnomena.BaseResponse):
View Source 
class FinancialSheetsResponse(BaseResponse):
    data: List[FinancialSheet]
Inherited Members
pydantic.main.BaseModel
BaseModel
dict
json
parse_obj
parse_raw
parse_file
from_orm
construct
copy
schema
schema_json
validate
update_forward_refs
fields
to_string
thaifin.sources.finnomena.BaseResponse
statusOK
pydantic.main
Config
@cached(cache=TTLCache(maxsize=12345, ttl=((24 * 60) * 60)))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_financial_sheet(securityID, fiscal=2009):
View Source 
@cached(cache=TTLCache(maxsize=12345, ttl=24 * 60 * 60))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_financial_sheet(securityID, fiscal=2009):
    url = "https://www.finnomena.com/fn3/api/stock/financial"

    querystring = {"securityID": str(securityID), "fiscal": str(fiscal)}

    payload = ""
    headers = {
        "connection": "keep-alive",
        "accept": "application/json, text/plain, */*",
        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.116 Safari/537.36 Edg/83.0.478.58",
        "sec-fetch-site": "same-origin",
        "sec-fetch-mode": "cors",
        "sec-fetch-dest": "empty",
        "referer": "https://www.finnomena.com/stock/SCB?bt_id=60",
        "accept-language": "en-US,en;q=0.9,th;q=0.8",
    }

    response = requests.request(
        "GET", url, data=payload, headers=headers, params=querystring
    )

    return FinancialSheetsResponse.parse_raw(response.text)
class StockInfo(pydantic.main.BaseModel):
View Source 
class StockInfo(BaseModel):
    name: str
    thName: str
    enName: str
    company_id: int
    security_id: int
name: str
thName: str
enName: str
company_id: int
security_id: int
Inherited Members
pydantic.main.BaseModel
BaseModel
dict
json
parse_obj
parse_raw
parse_file
from_orm
construct
copy
schema
schema_json
validate
update_forward_refs
fields
to_string
pydantic.main
Config
class StockInfosResponse(thaifin.sources.finnomena.BaseResponse):
View Source 
class StockInfosResponse(BaseResponse):
    data: List[StockInfo]
Inherited Members
pydantic.main.BaseModel
BaseModel
dict
json
parse_obj
parse_raw
parse_file
from_orm
construct
copy
schema
schema_json
validate
update_forward_refs
fields
to_string
thaifin.sources.finnomena.BaseResponse
statusOK
pydantic.main
Config
@cached(cache=TTLCache(maxsize=1, ttl=((24 * 60) * 60)))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_stock_list() -> thaifin.sources.finnomena.StockInfosResponse:
View Source 
@cached(cache=TTLCache(maxsize=1, ttl=24 * 60 * 60))
@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=10), reraise=True)
def get_stock_list() -> StockInfosResponse:
    url = "https://www.finnomena.com/fn3/api/stock/list"

    payload = ""
    headers = {
        "connection": "keep-alive",
        "accept": "application/json, text/plain, */*",
        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.116 Safari/537.36 Edg/83.0.478.58",
        "sec-fetch-site": "same-origin",
        "sec-fetch-mode": "cors",
        "sec-fetch-dest": "empty",
        "referer": "https://www.finnomena.com/stock/SCB?bt_id=60",
        "accept-language": "en-US,en;q=0.9,th;q=0.8",
        # 'cookie': "finnakies=5MLMJIS20200601; _ga=GA1.2.1303959403.1591006631; _fbp=fb.1.1591006631416.2138659500; PHPSESSID=on32ipkohq41hfv1dcu2eutuou; anspress_session=83fa3179f4e427a9e00e328d0d2ba568; _gid=GA1.2.1759981110.1594035335; terms_cond_accepted=false; _cbclose=1; _cbclose47370=1; _uid47370=595254B6.3; _ctout47370=1; verify=test; finnakies-ss=635VtLn20200706; _hjid=053a69da-8d52-4064-b1ce-82118f02ac68; _hjAbsoluteSessionInProgress=1; __cfduid=dad57d546f7805625889ebd80a183dc091594035361; _hjDonePolls=376740; visit_time=10"
    }

    response = requests.request("GET", url, data=payload, headers=headers)

    return StockInfosResponse.parse_raw(response.text)