Sean/ARM64
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Remove Active from StopLimit.
All checks were successful
Build .NET Project / build (push) Successful in 4m45s
Details

Browse Source
This commit is contained in:
Sean
2025-12-12 09:32:53 -05:00
parent decccea743
commit e2a72df57d
5 changed files with 255 additions and 257 deletions
Download Patch File Download Diff File Expand all files Collapse all files

241
MarketData/MarketDataLib/DataAccess/StopLimitDA.cs Normal file
View File

@@ -0,0 +1,241 @@
using System.Text;
using MySql.Data.MySqlClient;
using MarketData.MarketDataModel;
using MarketData.Utils;
namespace MarketData.DataAccess
{
public class StopLimitDA
{
private StopLimitDA()
{
}
public static StopLimit GetStopLimit(String symbol)
{
MySqlConnection sqlConnection = null;
MySqlDataReader sqlDataReader = null;
MySqlCommand sqlCommand = null;
String strQuery = null;
try
{
StringBuilder sb = new StringBuilder();
if (null == symbol) return null;
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sb.Append("select symbol,stop_limit,shares,stop_type from stoplimits ");
sb.Append("where symbol='").Append(symbol).Append("'");
strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlDataReader = sqlCommand.ExecuteReader();
if (!sqlDataReader.Read()) return null;
StopLimit stopLimit = new StopLimit();
stopLimit.Symbol = sqlDataReader.GetString(0);
stopLimit.StopPrice = sqlDataReader.GetDouble(1);
stopLimit.Shares = sqlDataReader.GetDouble(2);
stopLimit.StopType = sqlDataReader.GetString(3);
return stopLimit;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return null;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlDataReader) { sqlDataReader.Close(); sqlDataReader.Dispose(); }
if (null != sqlConnection) sqlConnection.Close();
}
}
public static bool InsertUpdateStopLimit(StopLimit stopLimit)
{
if (null == stopLimit || null == stopLimit.Symbol || double.IsNaN(stopLimit.StopPrice)) return false;
if (!HasStopLimit(stopLimit.Symbol)) return InsertStopLimit(stopLimit);
return UpdateStopLimit(stopLimit);
}
private static bool InsertStopLimit(StopLimit stopLimit)
{
MySqlConnection sqlConnection = null;
MySqlTransaction sqlTransaction = null;
MySqlCommand sqlCommand = null;
String strQuery = null;
try
{
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sqlTransaction = sqlConnection.BeginTransaction(System.Data.IsolationLevel.ReadCommitted);
StringBuilder sb = new StringBuilder();
sb.Append("insert into stoplimits(symbol,stop_limit,shares,stop_type)values(");
sb.Append(SqlUtils.AddQuotes(stopLimit.Symbol)).Append(",");
sb.Append(stopLimit.StopPrice).Append(",");
sb.Append(stopLimit.Shares).Append(",");
if (null != stopLimit.StopType) sb.Append(SqlUtils.AddQuotes(stopLimit.StopType));
else sb.Append("null");
sb.Append(")");
strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection, sqlTransaction);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlCommand.ExecuteNonQuery();
sqlTransaction.Commit();
return true;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return false;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlTransaction) sqlTransaction.Dispose();
if (null != sqlConnection) sqlConnection.Close();
}
}
private static bool UpdateStopLimit(StopLimit stopLimit)
{
MySqlConnection sqlConnection = null;
MySqlTransaction sqlTransaction = null;
MySqlCommand sqlCommand = null;
String strQuery = null;
try
{
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sqlTransaction = sqlConnection.BeginTransaction(System.Data.IsolationLevel.ReadCommitted);
StringBuilder sb = new StringBuilder();
sb.Append("update stoplimits ");
sb.Append("set ");
if (null != stopLimit.StopType) sb.Append("stop_type=").Append(SqlUtils.AddQuotes(stopLimit.StopType)).Append(", ");
sb.Append("stop_limit=").Append(stopLimit.StopPrice).Append(", ");
sb.Append("shares=").Append(stopLimit.Shares);
sb.Append(" where symbol=").Append(SqlUtils.AddQuotes(stopLimit.Symbol));
strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection, sqlTransaction);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlCommand.ExecuteNonQuery();
sqlTransaction.Commit();
return true;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return false;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlConnection) sqlConnection.Close();
if (null != sqlTransaction) sqlTransaction.Dispose();
}
}
public static Dictionary<String, bool> HasStopLimit(List<String> symbols)
{
MySqlConnection sqlConnection = null;
MySqlDataReader sqlDataReader = null;
MySqlCommand sqlCommand = null;
Dictionary<String, bool> hasStopLimit = new Dictionary<String, bool>();
try
{
if (null == symbols || 0 == symbols.Count) return hasStopLimit;
StringBuilder sb = new StringBuilder();
if (null == symbols) return null;
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sb.Append("select symbol, count(*) from stoplimits ");
sb.Append("where symbol in ");
sb.Append(SqlUtils.CreateInClause(symbols));
sb.Append(" group by 1");
String strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlDataReader = sqlCommand.ExecuteReader();
while (sqlDataReader.Read())
{
String symbol = sqlDataReader.GetString(0);
symbol = symbol.ToUpper();
hasStopLimit.Add(symbol, true);
}
return hasStopLimit;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return null;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlDataReader) { sqlDataReader.Close(); sqlDataReader.Dispose(); }
if (null != sqlConnection) sqlConnection.Close();
}
}
public static bool HasStopLimit(String symbol)
{
MySqlConnection sqlConnection = null;
MySqlDataReader sqlDataReader = null;
MySqlCommand sqlCommand = null;
String strQuery = null;
try
{
StringBuilder sb = new StringBuilder();
if (null == symbol) return false;
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sb.Append("select count(*) from stoplimits ");
sb.Append("where symbol='").Append(symbol).Append("'");
strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlDataReader = sqlCommand.ExecuteReader();
if (!sqlDataReader.Read()) return false;
int count = sqlDataReader.GetInt32(0);
return count > 0 ? true : false;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return false;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlDataReader) { sqlDataReader.Close(); sqlDataReader.Dispose(); }
if (null != sqlConnection) sqlConnection.Close();
}
}
public static bool DeleteStopLimit(String symbol)
{
MySqlConnection sqlConnection = null;
MySqlCommand sqlCommand = null;
String strQuery = null;
try
{
StringBuilder sb = new StringBuilder();
if (null == symbol) return false;
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("portfolio_data"));
sb.Append("delete from stoplimits ");
sb.Append("where symbol='").Append(symbol).Append("'");
strQuery = sb.ToString();
sqlCommand = new MySqlCommand(strQuery, sqlConnection);
sqlCommand.CommandTimeout = SqlUtils.COMMAND_TIMEOUT;
sqlCommand.ExecuteNonQuery();
return true;
}
catch (Exception exception)
{
MDTrace.WriteLine(LogLevel.DEBUG, exception);
return false;
}
finally
{
if (null != sqlCommand) sqlCommand.Dispose();
if (null != sqlConnection) sqlConnection.Close();
}
}
}
}