File size: 13,218 Bytes
9d4bd7c
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
project/
β”œβ”€β”€ main.py
β”œβ”€β”€ routers/
β”‚   β”œβ”€β”€ stocks/
β”‚   β”‚   β”œβ”€β”€ __init__.py
β”‚   β”‚   β”œβ”€β”€ models.py
β”‚   β”‚   β”œβ”€β”€ schemas.py
β”‚   β”‚   β”œβ”€β”€ service.py
β”‚   β”‚   └── routes.py
β”‚   β”œβ”€β”€ utt/
β”‚   β”‚   β”œβ”€β”€ __init__.py
β”‚   β”‚   β”œβ”€β”€ models.py
β”‚   β”‚   β”œβ”€β”€ schemas.py
β”‚   β”‚   β”œβ”€β”€ service.py
β”‚   β”‚   └── routes.py
β”‚   └── tasks/
β”‚       β”œβ”€β”€ __init__.py
β”‚       β”œβ”€β”€ models.py
β”‚       β”œβ”€β”€ schemas.py
β”‚       └── routes.py

# main.py
from fastapi import FastAPI, Request, HTTPException
from fastapi.responses import JSONResponse
fromApp.routers.stocks.routes import router as stocks_router
fromApp.routers.utt.routes import router as utt_router
fromApp.routers.tasks.routes import router as tasks_router

app = FastAPI()

@app.exception_handler(HTTPException)
async def http_exception_handler(request: Request, exc: HTTPException):
    return JSONResponse(status_code=exc.status_code, content={"success": False, "message": exc.detail})

@app.exception_handler(Exception)
async def generic_exception_handler(request: Request, exc: Exception):
    return JSONResponse(status_code=500, content={"success": False, "message": str(exc)})

app.include_router(stocks_router)
app.include_router(utt_router)
app.include_router(tasks_router)

# routers/tasks/models.py
from tortoise import fields, models
from enum import Enum

class TaskStatus(str, Enum):
    PENDING = "pending"
    RUNNING = "running"
    COMPLETED = "completed"
    FAILED = "failed"

class ImportTask(models.Model):
    id = fields.IntField(pk=True)
    task_type = fields.CharField(max_length=50)
    status = fields.CharEnumField(TaskStatus, default=TaskStatus.PENDING)
    details = fields.JSONField(null=True)
    created_at = fields.DatetimeField(auto_now_add=True)
    updated_at = fields.DatetimeField(auto_now=True)

    class Meta:
        table = "import_tasks"

# routers/tasks/schemas.py
from pydantic import BaseModel
from datetime import datetime
from enum import Enum

class TaskStatus(str, Enum):
    PENDING = "pending"
    RUNNING = "running"
    COMPLETED = "completed"
    FAILED = "failed"

class ImportTaskResponse(BaseModel):
    id: int
    task_type: str
    status: TaskStatus
    details: dict | None
    created_at: datetime
    updated_at: datetime

class ResponseModel(BaseModel):
    success: bool
    message: str
    data: dict | list | None = None

# routers/tasks/routes.py
from fastapi import APIRouter, HTTPException
from .models import ImportTask
from .schemas import ImportTaskResponse, ResponseModel

router = APIRouter(prefix="/tasks", tags=["Tasks"])

@router.get("/", response_model=ResponseModel)
async def list_tasks():
    tasks = await ImportTask.all().order_by("-created_at")
    return ResponseModel(success=True, message="List of tasks", data=[task for task in tasks])

@router.get("/{task_id}", response_model=ResponseModel)
async def get_task(task_id: int):
    task = await ImportTask.get_or_none(id=task_id)
    if not task:
        raise HTTPException(status_code=404, detail="Task not found")
    return ResponseModel(success=True, message="Task found", data=task)

# You would follow the same modular structure for stocks and utt
# Including their own models.py, schemas.py, routes.py, service.py
# The routes would queue background tasks and use task_id for status tracking.



project/
β”œβ”€β”€ main.py
β”œβ”€β”€ routers/
β”‚   β”œβ”€β”€ stocks/
β”‚   β”‚   β”œβ”€β”€ __init__.py
β”‚   β”‚   β”œβ”€β”€ models.py
β”‚   β”‚   β”œβ”€β”€ schemas.py
β”‚   β”‚   β”œβ”€β”€ service.py
β”‚   β”‚   └── routes.py
β”‚   β”œβ”€β”€ utt/
β”‚   β”‚   β”œβ”€β”€ __init__.py
β”‚   β”‚   β”œβ”€β”€ models.py
β”‚   β”‚   β”œβ”€β”€ schemas.py
β”‚   β”‚   β”œβ”€β”€ service.py
β”‚   β”‚   └── routes.py
β”‚   └── tasks/
β”‚       β”œβ”€β”€ __init__.py
β”‚       β”œβ”€β”€ models.py
β”‚       β”œβ”€β”€ schemas.py
β”‚       └── routes.py

# routers/stocks/models.py
from tortoise import fields, models

class Stock(models.Model):
    id = fields.IntField(pk=True)
    symbol = fields.CharField(max_length=10, unique=True)
    name = fields.CharField(max_length=100)
    sector = fields.CharField(max_length=100, null=True)

class StockPriceData(models.Model):
    id = fields.IntField(pk=True)
    stock = fields.ForeignKeyField("models.Stock", related_name="prices")
    date = fields.DateField()
    opening_price = fields.FloatField()
    closing_price = fields.FloatField()
    high = fields.FloatField()
    low = fields.FloatField()
    volume = fields.IntField()
    turnover = fields.BigIntField()
    shares_in_issue = fields.BigIntField()
    market_cap = fields.BigIntField()

    class Meta:
        unique_together = ("stock", "date")

# routers/stocks/schemas.py
from pydantic import BaseModel
from datetime import date
from typing import List, Optional
fromApp.routers.tasks.schemas import ResponseModel

class StockBase(BaseModel):
    symbol: str
    name: str
    sector: Optional[str] = None

class StockResponse(StockBase):
    id: int

class StockPriceResponse(BaseModel):
    date: date
    opening_price: float
    closing_price: float
    high: float
    low: float
    volume: int
    turnover: int
    shares_in_issue: int
    market_cap: int

class StockPriceListResponse(BaseModel):
    stock: StockResponse
    prices: List[StockPriceResponse]

# routers/stocks/service.py
from datetime import datetime

async def fetch_stock_data(symbol: str):
    import httpx
    url = f"https://dse.co.tz/api/get/market/prices/for/range/duration?security_code={symbol}&days=5000&class=EQUITY"
    async with httpx.AsyncClient() as client:
        response = await client.get(url)
        if response.status_code == 200:
            return response.json().get("data", [])
        return []

def parse_stock_api_row(row: dict) -> dict:
    return {
        "date": datetime.fromisoformat(row["trade_date"]).date(),
        "opening_price": row["opening_price"],
        "closing_price": row["closing_price"],
        "high": row["high"],
        "low": row["low"],
        "volume": row["volume"],
        "turnover": row["turnover"],
        "shares_in_issue": row["shares_in_issue"],
        "market_cap": row["market_cap"],
    }

# routers/stocks/routes.py
from fastapi import APIRouter, HTTPException, BackgroundTasks
from tortoise.transactions import in_transaction
from .models import Stock, StockPriceData
from .schemas import StockResponse, StockPriceListResponse, ResponseModel
from .service import fetch_stock_data, parse_stock_api_row
fromApp.routers.tasks.models import ImportTask
from typing import List

router = APIRouter(prefix="/stocks", tags=["Stocks"])

@router.get("/", response_model=ResponseModel)
async def list_stocks():
    stocks = await Stock.all()
    return ResponseModel(success=True, message="List of stocks", data=stocks)

@router.get("/{symbol}", response_model=ResponseModel)
async def get_stock_prices(symbol: str):
    stock = await Stock.get_or_none(symbol=symbol)
    if not stock:
        raise HTTPException(status_code=404, detail="Stock not found")
    prices = await StockPriceData.filter(stock=stock).order_by("-date")
    return ResponseModel(success=True, message="Stock price data", data={"stock": stock, "prices": prices})

@router.post("/import/{symbol}", response_model=ResponseModel)
async def queue_import_stock(symbol: str, background_tasks: BackgroundTasks):
    task = await ImportTask.create(task_type="stocks", status="pending", details={"symbol": symbol})
    background_tasks.add_task(run_stock_import_task, task.id, symbol)
    return ResponseModel(success=True, message="Stock import task queued", data={"task_id": task.id})

async def run_stock_import_task(task_id: int, symbol: str):
    try:
        await ImportTask.filter(id=task_id).update(status="running")
        raw_data = await fetch_stock_data(symbol)
        if not raw_data:
            await ImportTask.filter(id=task_id).update(status="failed", details={"error": "No data"})
            return

        first = raw_data[0]
        stock, _ = await Stock.get_or_create(symbol=first["company"], defaults={"name": first["fullName"]})

        existing_dates = set(await StockPriceData.filter(stock=stock).values_list("date", flat=True))

        records = []
        for row in raw_data:
            parsed = parse_stock_api_row(row)
            if parsed["date"] not in existing_dates:
                records.append(StockPriceData(stock=stock, **parsed))

        async with in_transaction():
            await StockPriceData.bulk_create(records, ignore_conflicts=True)

        await ImportTask.filter(id=task_id).update(status="completed")
    except Exception as e:
        await ImportTask.filter(id=task_id).update(status="failed", details={"error": str(e)})


# routers/utt/models.py
from tortoise import fields, models

class UTTFund(models.Model):
    id = fields.IntField(pk=True)
    symbol = fields.CharField(max_length=20, unique=True)
    name = fields.CharField(max_length=100)

class UTTFundData(models.Model):
    id = fields.IntField(pk=True)
    fund = fields.ForeignKeyField("models.UTTFund", related_name="data")
    date = fields.DateField()
    nav_per_unit = fields.FloatField()
    sale_price_per_unit = fields.FloatField()
    repurchase_price_per_unit = fields.FloatField()
    outstanding_number_of_units = fields.BigIntField()
    net_asset_value = fields.BigIntField()

    class Meta:
        unique_together = ("fund", "date")

# routers/utt/schemas.py
from pydantic import BaseModel
from datetime import date
from typing import List
fromApp.routers.tasks.schemas import ResponseModel

class UTTFundResponse(BaseModel):
    id: int
    symbol: str
    name: str

class UTTFundDataResponse(BaseModel):
    date: date
    nav_per_unit: float
    sale_price_per_unit: float
    repurchase_price_per_unit: float
    outstanding_number_of_units: int
    net_asset_value: int

class UTTFundListResponse(BaseModel):
    fund: UTTFundResponse
    data: List[UTTFundDataResponse]

# routers/utt/service.py
from datetime import datetime
import httpx

async def fetch_all_utt_data():
    url = "https://example.com/utt/api"  # Placeholder
    async with httpx.AsyncClient() as client:
        response = await client.get(url)
        if response.status_code == 200:
            return response.json().get("data", [])
        return []

def parse_utt_api_row(row: dict) -> dict:
    return {
        "date": datetime.strptime(row["date_valued"], "%d-%m-%Y").date(),
        "nav_per_unit": float(row["nav_per_unit"]),
        "sale_price_per_unit": float(row["sale_price_per_unit"]),
        "repurchase_price_per_unit": float(row["repurchase_price_per_unit"]),
        "outstanding_number_of_units": int(float(row["outstanding_number_of_units"])),
        "net_asset_value": int(float(row["net_asset_value"]))
    }

# routers/utt/routes.py
from fastapi import APIRouter, BackgroundTasks, HTTPException
from .models import UTTFund, UTTFundData
from .schemas import UTTFundResponse, UTTFundListResponse, ResponseModel
from .service import fetch_all_utt_data, parse_utt_api_row
fromApp.routers.tasks.models import ImportTask

router = APIRouter(prefix="/utt", tags=["UTT"])

@router.get("/", response_model=ResponseModel)
async def list_funds():
    funds = await UTTFund.all()
    return ResponseModel(success=True, message="List of UTT funds", data=funds)

@router.get("/{symbol}", response_model=ResponseModel)
async def get_fund_data(symbol: str):
    fund = await UTTFund.get_or_none(symbol=symbol)
    if not fund:
        raise HTTPException(status_code=404, detail="Fund not found")
    data = await UTTFundData.filter(fund=fund).order_by("-date")
    return ResponseModel(success=True, message="Fund data", data={"fund": fund, "data": data})

@router.post("/import-all", response_model=ResponseModel)
async def queue_import_utt(background_tasks: BackgroundTasks):
    task = await ImportTask.create(task_type="utt", status="pending", details={})
    background_tasks.add_task(run_utt_import_task, task.id)
    return ResponseModel(success=True, message="UTT import task queued", data={"task_id": task.id})

async def run_utt_import_task(task_id: int):
    from tortoise.transactions import in_transaction
    try:
        await ImportTask.filter(id=task_id).update(status="running")
        raw_data = await fetch_all_utt_data()
        if not raw_data:
            await ImportTask.filter(id=task_id).update(status="failed", details={"error": "No data"})
            return

        for row in raw_data:
            symbol = row["internal_name"]
            name = row["scheme_name"]
            fund, _ = await UTTFund.get_or_create(symbol=symbol, defaults={"name": name})

            parsed = parse_utt_api_row(row)
            exists = await UTTFundData.exists(fund=fund, date=parsed["date"])
            if not exists:
                await UTTFundData.create(fund=fund, **parsed)

        await ImportTask.filter(id=task_id).update(status="completed")
    except Exception as e:
        await ImportTask.filter(id=task_id).update(status="failed", details={"error": str(e)})