diff --git a/Txgy.FilesWatcher/model/UploadPostproFile.cs b/Txgy.FilesWatcher/model/UploadPostproFile.cs index 7f32241..569bf4b 100644 --- a/Txgy.FilesWatcher/model/UploadPostproFile.cs +++ b/Txgy.FilesWatcher/model/UploadPostproFile.cs @@ -70,9 +70,15 @@ namespace Txgy.FilesWatcher.model //重新编码,解决中文乱码问题 Encoder = JavaScriptEncoder.Create(UnicodeRanges.All) }; - sqlNumber = $"INSERT INTO {tbname} (EventTime, WorkAreaID, WaveData, JsonFile) VALUES('{EventTime}', '{workAreaId}', @mDatas, @jDatas);"; - MySqlCommand mycomm = new MySqlCommand(sqlNumber, conn); - res = conn.Execute(sqlNumber, new { mDatas = mseedDatas, jDatas = jsonDatas }); + sqlNumber = $"SELECT COUNT(*) FROM {tbname} WHERE EventTime = '{EventTime}'"; + MySqlCommand md = new MySqlCommand(sqlNumber, conn); + var count = conn.QueryFirst(sqlNumber); + if (count == 0) + { + sqlNumber = $"INSERT INTO {tbname} (EventTime, WorkAreaID, WaveData, JsonFile) VALUES('{EventTime}', '{workAreaId}', @mDatas, @jDatas);"; + MySqlCommand mycomm = new MySqlCommand(sqlNumber, conn); + res = conn.Execute(sqlNumber, new { mDatas = mseedDatas, jDatas = jsonDatas }); + } sqlNumber = $"INSERT INTO {uploadedtbname}(filename, uploadtime) VALUES('{file}', '{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}')"; res = conn.Execute(sqlNumber); } diff --git a/Txgy.FilesWatcher/model/UploadRealtimeFile.cs b/Txgy.FilesWatcher/model/UploadRealtimeFile.cs index 5f7a12b..1d360f8 100644 --- a/Txgy.FilesWatcher/model/UploadRealtimeFile.cs +++ b/Txgy.FilesWatcher/model/UploadRealtimeFile.cs @@ -76,10 +76,15 @@ namespace Txgy.FilesWatcher.model //重新编码,解决中文乱码问题 Encoder = JavaScriptEncoder.Create(UnicodeRanges.All) }; - - sqlNumber = $"INSERT INTO {tbname} (EventTime, WorkAreaID, WaveData, JsonFile) VALUES('{EventTime}', '{workAreaId}', @mDatas, @jDatas);"; - MySqlCommand mycomm = new MySqlCommand(sqlNumber,conn); - res = conn.Execute(sqlNumber, new { mDatas = mseedDatas, jDatas = jsonDatas }); + sqlNumber = $"SELECT COUNT(*) FROM {tbname} WHERE EventTime = '{EventTime}'"; + MySqlCommand md = new MySqlCommand(sqlNumber, conn); + var count = conn.QueryFirst(sqlNumber); + if (count == 0) + { + sqlNumber = $"INSERT INTO {tbname} (EventTime, WorkAreaID, WaveData, JsonFile) VALUES('{EventTime}', '{workAreaId}', @mDatas, @jDatas);"; + MySqlCommand mycomm = new MySqlCommand(sqlNumber, conn); + res = conn.Execute(sqlNumber, new { mDatas = mseedDatas, jDatas = jsonDatas }); + } sqlNumber = $"INSERT INTO {uploadedtbname}(filename, uploadtime) VALUES('{file}', '{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}')"; res = conn.Execute(sqlNumber); }