million/Million
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Saved buyer Result 처리 완료(Get 까지 )

Browse Source
This commit is contained in:
kyh
2022-11-23 15:50:44 +09:00
parent 76532e1cd5
commit 335fde4cde
3 changed files with 144 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Million Buyer/MainForm.cs
View File

@@ -48,7 +48,7 @@ namespace Million_Buyer
private bool unlimitChecker = false;
private long second = 0;
private string mode = "Buyer";
private int cycleCount = 0;
private double cycleBuyMoney = 0;
@@ -78,9 +78,7 @@ namespace Million_Buyer
Million.DbManagement.DBConnection.QueryUpdateExcuter
(CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateMainLogTableQuery());
Million.DbManagement.DBConnection.QueryUpdateExcuter
(CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateSavedBuyerResultTableQuery());
(CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateSavedBuyerResultDataTableQuery());
_saveResultData = new SavedResultData
{
@@ -106,6 +104,7 @@ namespace Million_Buyer
/// <param name="e"></param>
private void rd_Realtime_CheckedChanged(object sender, EventArgs e)
{
mode = "RealTime";
RealTimeMode = true;
SetReadOnly(true);
}
@@ -117,6 +116,7 @@ namespace Million_Buyer
/// <param name="e"></param>
private void rd_buyer_CheckedChanged(object sender, EventArgs e)
{
mode = "Buyer";
RealTimeMode = false;
SetReadOnly(false);
}
@@ -664,6 +664,7 @@ namespace Million_Buyer
string str = "Sell : " + item + ",\r\n Sell Candle Data : " + JsonConvert.SerializeObject(recentlyData) + "\r\n";
LogManager.WriteLog(str, item);
//처리한 buyList는 삭제
buyList.Remove(buyItem);
InsertLog(buyItem.ConGoodsData.CoinFullName + " Market Data 판매 DateTime : " + time.ToString("yyyy-MM-dd HH:mm:ss"));
@@ -671,6 +672,9 @@ namespace Million_Buyer
{
try
{
//result data insert
DBConnection.QueryInsertExcuter_SavedBuyerResultData(cb_UserList.Text, mode, time, result);
//Grid 처리
TreeListNode buyNode = null;

102
Million/DbMangement/DBConnection.cs
View File

@@ -267,6 +267,58 @@ namespace Million.DbManagement
}
}
/// <summary>
/// Insert Saved Buyer Result Data
/// </summary>
/// <param name="userName"></param>
/// <param name="mode"></param>
/// <param name="savedDateTime"></param>
/// <param name="data"></param>
/// <returns></returns>
public static bool QueryInsertExcuter_SavedBuyerResultData(string userName, string mode, DateTime savedDateTime, SearchResult data)
{
var binaryFormatter = new BinaryFormatter();
var sqlQuery = DbServiceFunctions.InsertSavedBuyerResultDataQuery(userName, mode, savedDateTime);
var strDBCon = CommonProperty.DbConnectionResultData;
SqlConnection conn = null;
SqlDataReader rdr = null;
try
{
using (conn = new SqlConnection(strDBCon))
{
using (var cmd = new SqlCommand(sqlQuery, conn))
{
var setupListStream = new MemoryStream();
binaryFormatter.Serialize(setupListStream, data);
setupListStream.Position = 0;
cmd.Parameters.Add("@data", SqlDbType.VarBinary, (int)setupListStream.Length).Value = setupListStream.ToArray();
conn.Open();
using (rdr = cmd.ExecuteReader())
{
}
}
conn.Close();
}
return true;
}
catch (Exception e)
{
Console.WriteLine(" ============= exception ===============");
Console.WriteLine(e.Message);
if (rdr != null)
rdr.Close();
if (conn != null)
conn.Close();
return false;
}
}
/// <summary>
/// Insert SavedResultData
/// </summary>
@@ -529,6 +581,56 @@ namespace Million.DbManagement
}
}
/// <summary>
/// Saved Get Buyer Result Data
/// </summary>
/// <param name="userName"></param>
/// <param name="mode"></param>
/// <param name="startDate"></param>
/// <param name="endDate"></param>
/// <returns></returns>
public static List<SearchResult> QueryGetExcuter_SavedBuyerResultData(string userName, string mode, DateTime startDate, DateTime endDate)
{
var returnData = new List<SearchResult>();
var sqlQuery = string.Format(@"SELECT * FROM [ResultData].[dbo].[SavedBuyerResultData] WHERE [Mode] = '{0}' AND [UserName] = '{1}'
AND [SavedDateTime] >= '{2}' AND [SavedDateTime] <= '{3}';",
mode, userName, startDate.ToString("yyyy-MM-dd HH:mm:ss"), endDate.ToString("yyyy-MM-dd HH:mm:ss"));
var strDBCon = CommonProperty.DbConnectionResultData;
using (var conn = new SqlConnection(strDBCon))
{
using (var cmd = new SqlCommand(sqlQuery, conn))
{
try
{
conn.Open();
using (var rdr = cmd.ExecuteReader())
{
while (rdr.Read())
{
var data = new SearchResult();
data = (SearchResult)GetBinaryConvertClass(rdr, "Data");
returnData.Add(data);
}
}
conn.Close();
}
catch (Exception ex)
{
Console.WriteLine(" ============= exception ===============");
Console.WriteLine(ex.Message);
conn.Close();
return returnData;
}
}
}
return returnData;
}
/// <summary>
/// Get SavedResultData
/// idList가 null일 경우 전체 다 가져옴

34
Million/DbMangement/DBServiceFunctions.cs
View File

@@ -100,10 +100,10 @@ namespace Million.DbManagement
/// Create Saved Buyer Result Table
/// </summary>
/// <returns></returns>
public static string CreateSavedBuyerResultTableQuery()
public static string CreateSavedBuyerResultDataTableQuery()
{
return @"if not exists (select * from sysobjects where name='SavedBuyerResult' and xtype='U')
create table " + "\"SavedBuyerResult\"" + @"(
return @"if not exists (select * from sysobjects where name='SavedBuyerResultData' and xtype='U')
create table " + "\"SavedBuyerResultData\"" + @"(
UserName nvarchar(50) NOT NULL,
SavedDateTime datetime NULL,
Mode nvarchar(50) NOT NULL,
@@ -631,6 +631,34 @@ namespace Million.DbManagement
return str;
}
/// <summary>
/// Saved Buyer Result Query
/// </summary>
/// <param name="userName"></param>
/// <param name="mode"></param>
/// <param name="dateTime"></param>
/// <returns></returns>
public static string InsertSavedBuyerResultDataQuery(string userName, string mode, DateTime dateTime)
{
var str = string.Format(@"INSERT INTO [ResultData].[dbo].[SavedBuyerResultData]
(
[UserName],
[SavedDateTime],
[Mode],
[Data]
)VALUES(
'{0}',
'{1}',
'{2}',
@data);",
userName,
dateTime.ToString("yyyy-MM-dd HH:mm:ss"),
mode
);
return str;
}
/// <summary>
///
/// </summary>