|
|
|
@ -7,11 +7,13 @@ using System.Data.SqlClient;
|
|
|
|
using System.Diagnostics;
|
|
|
|
using System.Diagnostics;
|
|
|
|
using System.IO;
|
|
|
|
using System.IO;
|
|
|
|
using System.Linq;
|
|
|
|
using System.Linq;
|
|
|
|
|
|
|
|
using System.Reflection;
|
|
|
|
using System.Runtime.Remoting.Contexts;
|
|
|
|
using System.Runtime.Remoting.Contexts;
|
|
|
|
using System.Text;
|
|
|
|
using System.Text;
|
|
|
|
using System.Threading;
|
|
|
|
using System.Threading;
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
using Txgy.EWS.Client.Common;
|
|
|
|
using Txgy.EWS.Client.Common;
|
|
|
|
|
|
|
|
using Txgy.EWS.Client.Common.Helpers;
|
|
|
|
using Txgy.EWS.Client.IDAL;
|
|
|
|
using Txgy.EWS.Client.IDAL;
|
|
|
|
using Txgy.EWS.Client.Models;
|
|
|
|
using Txgy.EWS.Client.Models;
|
|
|
|
using Txgy.Microseismic.BaseLib.Common;
|
|
|
|
using Txgy.Microseismic.BaseLib.Common;
|
|
|
|
@ -23,6 +25,7 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
{
|
|
|
|
{
|
|
|
|
public class RemoteMySQLDataAccess : IRemoteMySQLDataAccess
|
|
|
|
public class RemoteMySQLDataAccess : IRemoteMySQLDataAccess
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
private static readonly log4net.ILog logger = log4net.LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
|
|
|
IFreeSql fsql = FreeSqlTencent.tencentRemoteMySQL;
|
|
|
|
IFreeSql fsql = FreeSqlTencent.tencentRemoteMySQL;
|
|
|
|
public string saveWavePath = "";
|
|
|
|
public string saveWavePath = "";
|
|
|
|
public MySqlConnection RemoteConn { get; set; }
|
|
|
|
public MySqlConnection RemoteConn { get; set; }
|
|
|
|
@ -69,8 +72,9 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
logger.Error("数据库连接失败", ex);
|
|
|
|
return false;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -131,6 +135,7 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
logger.Error($"获取事件列表失败 - 开始时间:{startTime}, 结束时间:{endTime}, 页码:{pageIndex}, 每页数量:{perPageCount}", ex);
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -178,7 +183,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"获取事件列表失败 - 开始时间:{startTime}, 结束时间:{endTime}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -231,7 +237,7 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
//messagebox.show
|
|
|
|
logger.Error($"获取事件列表失败 - 开始时间:{startTime}, 结束时间:{endTime}, minML:{minML}, maxML:{maxML}", ex);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -309,7 +315,7 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
//throw ex;
|
|
|
|
logger.Error($"根据SQL查询事件失败 - QueryStr:{QueryStr}, SortTarget:{ssm}, SortMode:{sm}", ex);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -376,7 +382,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"获取最新事件失败 - MaxCnt:{MaxCnt}, PreCnt:{PreCnt}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -442,7 +449,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"下载波形数据失败 - 事件时间:{eventTime}, 保存路径:{savePath}, 保存名称:{saveName}, 表名:{tableName}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -498,7 +506,7 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
//messagebox.show
|
|
|
|
logger.Error($"获取事件详情失败 - 事件ID:{eventID}", ex);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -551,7 +559,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"获取事件详情失败 - 事件时间:{eventTime}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -604,7 +613,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error("获取最新事件失败", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -658,7 +668,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"获取最新事件失败 - 截止时间:{deadline}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -764,9 +775,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
logger.Error($"统计事件数量失败 - 开始时间:{startTime}, 结束时间:{endTime}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// 如果没有查询到数据,则返回空引用
|
|
|
|
// 如果没有查询到数据,则返回空引用
|
|
|
|
return 0;
|
|
|
|
return 0;
|
|
|
|
@ -837,9 +849,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
logger.Error($"异步下载波形数据失败 - 事件时间:{gier.EventTime}, 保存路径:{savePath}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -906,9 +919,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
logger.Error($"异步下载JSON数据失败 - 事件时间:{gier.EventTime}, 保存路径:{savePath}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"DownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -975,9 +989,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
_semaphore.Release();
|
|
|
|
_semaphore.Release();
|
|
|
|
|
|
|
|
logger.Error($"查询和下载数据失败 - 事件ID:{eventID}, 保存路径:{savePath}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -1043,9 +1058,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
_semaphore.Release();
|
|
|
|
_semaphore.Release();
|
|
|
|
|
|
|
|
logger.Error($"按ID查询和下载数据失败 - 事件ID:{eventID}, 保存路径:{savePath}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public async Task QueryEventByIDAsync(int eventID, string savePath, Action<GridItemEventResult> callback)
|
|
|
|
public async Task QueryEventByIDAsync(int eventID, string savePath, Action<GridItemEventResult> callback)
|
|
|
|
@ -1110,9 +1126,10 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
_semaphore.Release();
|
|
|
|
_semaphore.Release();
|
|
|
|
|
|
|
|
logger.Error($"按ID查询事件失败 - 事件ID:{eventID}, 保存路径:{savePath}", ex);
|
|
|
|
// 异常处理代码
|
|
|
|
// 异常处理代码
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
Console.WriteLine($"QueryAndDownloadDataAsync error: {ex.StackTrace}");
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public List<GridItemEventResult> GetLastEvents(int lastEventID)
|
|
|
|
public List<GridItemEventResult> GetLastEvents(int lastEventID)
|
|
|
|
@ -1205,7 +1222,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
throw ex;
|
|
|
|
logger.Error($"获取最新事件失败 - 数量:{QueryCount}", ex);
|
|
|
|
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -1261,8 +1279,8 @@ namespace Txgy.EWS.Client.DAL
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception ex)
|
|
|
|
catch (Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
//messagebox.show
|
|
|
|
logger.Error($"获取网格事件失败 - 开始时间:{startTime}, 结束时间:{endTime}, minML:{minML}, maxML:{maxML}", ex);
|
|
|
|
throw ex;
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
finally
|
|
|
|
finally
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|