import os, time, datetime, struct, pathlib, sys
from datetime import datetime
from pathlib import Path
from pythonnet import load

load("coreclr")
import clr, System

##透過Clr引用系統標準函式
clr.AddReference('System.Collections')
from System.Collections.Generic import List

##宣告增加模組、DLL的路徑(windows可抓取當前路徑 Linux跟MAC需指定路徑)
sys.path.append(Path(pathlib.Path(__file__).parent.resolve()))
if sys.platform == "win32":
    os.add_dll_directory(Path(pathlib.Path(__file__).parent.resolve()))

##透過Clr引用YuantaSparkAPI.dll
##pythonnet引用元件不用加附檔名
try:
    clr.AddReference("YuantaSparkAPI")
except Exception as e:
    print(f"Error loading YuantaSparkAPI: {e}")
from YuantaOneAPI import (YuantaSparkAPITrader, enumLogType, 
                        enumMarketType, enumEnvironmentMode, enumStkTickSelectType)

# 建立 API 物件
objYuantaSparkAPI = YuantaSparkAPITrader()
objYuantaSparkAPI.SetLogType(enumLogType.COMMON)

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using YuantaOneAPI;

YuantaSparkAPITrader objYuantaSparkAPI = new YuantaSparkAPITrader();
string Account = "S98875005091";
string Password = "1234";
enumEnvironmentMode enumEvenMode = enumEnvironmentMode.UAT;

objYuantaSparkAPI.OnResponse += objApi_OnResponse;
objYuantaSparkAPI.SetLogType(enumLogType.ALL);

objYuantaSparkAPI.Open(enumEvenMode);
Thread.Sleep(1000);

objYuantaSparkAPI.Login(Account, Password);
Thread.Sleep(1000);

// 策略類型：1:停損利 2:移動鎖利 3:二擇一 4:母子單 5:多條件
int strategyType = 4;
string stk = " ";                           // 空白表示查全部，填股票代號則查指定股票
string sDate = "2025/01/01";               // 查詢起始日期
string eDate = "2025/03/31";               // 查詢結束日期

objYuantaSparkAPI.GetHisConditionStrategy(Account, strategyType, stk, sDate, eDate);
Thread.Sleep(2000);

def on_response(intMark, dwIndex, strIndex, objHandle, objValue):
    try:
        result = ''
        match intMark:
            case 0:  # 系統回應資訊
                result = str(objValue)
            case 1:  # 查詢回應資訊
                match strIndex:
                    case 'Login':
                        loginResult = objValue
                        status = loginResult.LoginStatus
                        strMsgCode = status.MsgCode # 訊息代碼
                        strMsgContent = status.MsgContent # 訊息內容
                        intCount = status.Count # 筆數
                        result = '{0},{1},帳號筆數:{2}\r\n'.format(strMsgCode,strMsgContent, str(intCount))
                        if strMsgCode == '0001' or strMsgCode == '00001' or intCount > 0 :
                            for i in objValue.LoginList:
                                result += f"{i.Account},{i.Name},{i.InvestorID},{i.SellerNo}\n"

                    case 'GetHisConditionStrategy':
                        GResult = objValue
                        gResult = GResult.HisConditionStrategyList

                        result = ''
                        result += "歷史策略查詢結果:\r\n"

                        for i in range(gResult.Count):
                            result += '{0},{1},{2},{3},{4},{5},{6},{7},{8},{9},{10},{11},{12},{13},{14},{15},{16},{17},{18},{19},{20}\r\n'.format(
                                gResult[i].Account,gResult[i].StrategyType,gResult[i].StrategyNo,gResult[i].OrdDateTime,gResult[i].TermiateDate,
                                gResult[i].CancelDate,gResult[i].StrategyStatus,gResult[i].OrdStatus,gResult[i].MarketType,gResult[i].StkCode,
                                gResult[i].Condition,gResult[i].OrderKind,gResult[i].Price,gResult[i].OrderQty,gResult[i].DealQty,
                                gResult[i].RestQty,gResult[i].SDate,gResult[i].EDate,gResult[i].OrderTypeMsg,gResult[i].HighPx,gResult[i].TriggerPx)
                            dList = gResult[i].DetailList
                            for j in range(dList.Count):
                                result += '  {0},{1},{2},{3},{4},{5},{6}\r\n'.format(
                                    dList[j].DealTime,dList[j].OrderPrice,dList[j].AveragePrice,dList[j].DealQty,
                                    dList[j].Memo,dList[j].TrigTime,dList[j].TrigCondition)

        if result:
            print('##================================================##\n')
            print(result)

    except Exception as error:
        print(f"處理回應時發生錯誤: {error}")

objYuantaSparkAPI.OnResponse += on_response
#測試環境帳號:UAT 正式環境:PROD
objYuantaSparkAPI.Open(enumEnvironmentMode.UAT)
time.sleep(2)

objYuantaSparkAPI.Login('S98875005091', '1234')
time.sleep(2)
objYuantaSparkAPI.GetHisConditionStrategy('S98875005091', 1, " ", "2025/03/01", "2025/04/30") # 策略類型: 1:停損利 2:移動鎖利 3:二擇一 4:母子單 5:多條件 6:全部

while True:
    time.sleep(2)

void objApi_OnResponse(int intMark, uint dwIndex, string strIndex, object objHandle, object objValue)
{
    try
    {
        string strResult = "";
        if (intMark == 0)
        {
            Console.WriteLine(Convert.ToString(objValue));
            return;
        }

        if (intMark == 1)
        {
            if (strIndex == "Login")
            {
                var result = (LoginResult)objValue;
                string strMsgCode = result.LoginStatus.MsgCode;
                string strMsgContent = result.LoginStatus.MsgContent;
                int intCount = result.LoginStatus.Count;

                strResult += $"{strMsgCode}, {strMsgContent}{Environment.NewLine}";
                if (strMsgCode == "0001" || strMsgCode == "00001")
                {
                    strResult += $"帳號筆數: {intCount}{Environment.NewLine}";
                    result.LoginList.ForEach(r => strResult += $"{r.Account},{r.Name},{r.InvestorID},{r.SellerNo}\r\n");
                }
                else
                {
                    Account = "";
                }

                Console.WriteLine("\n======================");
                Console.WriteLine(strResult);
                Console.WriteLine("======================\n");
                return;
            }

            if (strIndex == "GetHisConditionStrategy")
            {
                var result = (HisConditionStrategyResult)objValue;
                try
                {
                    strResult += "歷史策略查詢:\r\n";
                    result.HisConditionStrategyList?.ForEach(c =>
                    {
                        strResult += $"{c.Account} {c.StrategyType.GetDescriptionName()} {c.StrategyNo} " +
                                    $"{c.OrdDateTime:yyyy/MM/dd HH:mm:ss} {c.TermiateDate} {c.CancelDate} " +
                                    $"{c.StrategyStatus.GetDescriptionName()} {c.OrdStatus} {c.MarketType} " +
                                    $"{c.StkCode} {c.Condition} {c.OrderKind} {c.Price} {c.OrderQty} " +
                                    $"{c.DealQty} {c.RestQty} {c.SDate} {c.EDate} " +
                                    $"{c.OrderTypeMsg} {c.HighPx} {c.TriggerPx}\r\n";

                        c.DetailList.ForEach(d =>
                        {
                            strResult += $"  [{d.DealTime} {d.OrderPrice} {d.AveragePrice} " +
                                        $"{d.DealQty} {d.Memo} {d.TrigTime} {d.TrigCondition}]\r\n";
                        });
                    });
                }
                catch
                {
                    strResult = "";
                }

                Console.WriteLine("\n======================");
                Console.WriteLine(strResult);
                Console.WriteLine("======================\n");
                return;
            }
        }
        Console.WriteLine($"[{strIndex}] {Convert.ToString(objValue)}");
    }
    catch (Exception exc)
    {
        Console.WriteLine("OnResponse Error: " + exc.Message);
    }
}