개정판 bede677a
issue #000 ConvertDocRepository 수정 및 Unit 테스트 파일 변경.
Change-Id: I774ab5147330b57f6afacc19033ad10d17f96210
| ConvertService/ServiceBase/Markus.Service.DataBase.Dapper/MixParameters.cs | ||
|---|---|---|
| 86 | 86 |
|
| 87 | 87 |
var dbType = param.DbType; |
| 88 | 88 |
var val = param.Value; |
| 89 |
string name = Clean(param.Name); |
|
| 90 |
var isCustomQueryParameter = val is SqlMapper.ICustomQueryParameter; |
|
| 89 |
string name = param.Name.ToLower(); |
|
| 90 |
|
|
| 91 |
if (command.CommandType == CommandType.StoredProcedure) |
|
| 92 |
name = Clean(param.Name); |
|
| 93 |
|
|
| 94 |
var isCustomQueryParameter = val is SqlMapper.ICustomQueryParameter; |
|
| 91 | 95 |
|
| 92 | 96 |
SqlMapper.ITypeHandler handler = null; |
| 93 | 97 |
if (dbType == null && val != null && !isCustomQueryParameter) |
| ConvertService/ServiceBase/Markus.Service.DataBase.Dapper/Repositories/ConvertDocRepository.cs | ||
|---|---|---|
| 15 | 15 |
{
|
| 16 | 16 |
} |
| 17 | 17 |
|
| 18 |
/// <summary> |
|
| 19 |
/// ??? |
|
| 20 |
/// </summary> |
|
| 21 |
/// <param name="PROJECT_NO"></param> |
|
| 22 |
/// <param name="DOCUMENT_URL"></param> |
|
| 23 |
/// <param name="DOCUMENT_ID"></param> |
|
| 24 |
/// <returns></returns> |
|
| 25 |
public async Task<string> CreateAsync(string PROJECT_NO, string DOCUMENT_URL, string DOCUMENT_ID) |
|
| 26 |
{
|
|
| 27 |
string result = null; |
|
| 28 |
try |
|
| 29 |
{
|
|
| 30 |
var tran = BeginTransaction(); |
|
| 31 |
|
|
| 32 |
var parameters = new MixParameters(DBMS); |
|
| 33 |
parameters.Add("@project_no", value: PROJECT_NO);
|
|
| 34 |
parameters.Add("@document_url", value: DOCUMENT_URL);
|
|
| 35 |
parameters.Add("@document_id", value: DOCUMENT_ID);
|
|
| 36 |
parameters.Add("@newid", direction: ParameterDirection.Output);
|
|
| 37 |
|
|
| 38 |
await base.ExecuteAsync("convert_insert_convertdoc", parameters, transaction: tran, commandType: CommandType.StoredProcedure);
|
|
| 39 |
|
|
| 40 |
tran.Commit(); |
|
| 41 |
|
|
| 42 |
result = parameters.Get<string>("newid");
|
|
| 43 |
} |
|
| 44 |
catch (Exception ex) |
|
| 45 |
{
|
|
| 46 |
|
|
| 47 |
throw ex; |
|
| 48 |
} |
|
| 49 |
return result; |
|
| 50 |
} |
|
| 51 |
|
|
| 52 |
/// <summary> |
|
| 53 |
/// ??? |
|
| 54 |
/// </summary> |
|
| 55 |
/// <param name="TakeCount"></param> |
|
| 56 |
/// <returns></returns> |
|
| 18 | 57 |
public async Task<List<ConvertDoc>> GetWaitorErrorAsync(int TakeCount) |
| 19 | 58 |
{
|
| 20 | 59 |
List<ConvertDoc> list = null; |
| 21 | 60 |
|
| 22 | 61 |
var parameters = new MixParameters(DBMS); |
| 23 |
parameters.Add("takecount", TakeCount);
|
|
| 62 |
parameters.Add("@takecount", TakeCount);
|
|
| 24 | 63 |
|
| 25 | 64 |
var result = await base.QueryAsync<ConvertDoc>("CONVERT_SELECT_WAITorERROR", parameters, commandType: CommandType.StoredProcedure);
|
| 26 | 65 |
if (result == null) return null; |
| ... | ... | |
| 29 | 68 |
return list; |
| 30 | 69 |
} |
| 31 | 70 |
|
| 71 |
/// <summary> |
|
| 72 |
/// ??? |
|
| 73 |
/// </summary> |
|
| 74 |
/// <param name="ProjectNo"></param> |
|
| 75 |
/// <param name="Status"></param> |
|
| 76 |
/// <param name="DocumentID"></param> |
|
| 77 |
/// <param name="ConvertID"></param> |
|
| 78 |
/// <returns></returns> |
|
| 79 |
/// <exception cref="Exception"></exception> |
|
| 32 | 80 |
public async Task<ConvertDoc> GetConvertDocSingleAsync(string ProjectNo = null, int Status = -1, string DocumentID = null, string ConvertID = null) |
| 33 | 81 |
{
|
| 34 | 82 |
string SQL = "SELECT * FROM CONVERTER_DOC WHERE "; |
| ... | ... | |
| 39 | 87 |
|
| 40 | 88 |
if (ProjectNo != null) |
| 41 | 89 |
{
|
| 42 |
whereSQL.Add("PROJECT_NO = PROJECT_NO");
|
|
| 43 |
parameters.Add("PROJECT_NO", ProjectNo);
|
|
| 90 |
whereSQL.Add("PROJECT_NO = @PROJECT_NO");
|
|
| 91 |
parameters.Add("@PROJECT_NO", ProjectNo);
|
|
| 44 | 92 |
} |
| 45 | 93 |
|
| 46 | 94 |
if (Status > -1) |
| 47 | 95 |
{
|
| 48 |
whereSQL.Add("STATUS = STATUS");
|
|
| 49 |
parameters.Add("STATUS", Status);
|
|
| 96 |
whereSQL.Add("STATUS = @STATUS");
|
|
| 97 |
parameters.Add("@STATUS", Status);
|
|
| 50 | 98 |
} |
| 51 | 99 |
|
| 52 | 100 |
if (ConvertID != null) |
| 53 | 101 |
{
|
| 54 |
whereSQL.Add("ID = ID");
|
|
| 55 |
parameters.Add("ID", ConvertID);
|
|
| 102 |
whereSQL.Add("ID = @ID");
|
|
| 103 |
parameters.Add("@ID", ConvertID);
|
|
| 56 | 104 |
} |
| 57 | 105 |
|
| 58 | 106 |
if (DocumentID != null) |
| 59 | 107 |
{
|
| 60 |
whereSQL.Add("DOCUMENT_ID = DOCUMENT_ID");
|
|
| 61 |
parameters.Add("DOCUMENT_ID", DocumentID);
|
|
| 108 |
whereSQL.Add("DOCUMENT_ID = @DOCUMENT_ID");
|
|
| 109 |
parameters.Add("@DOCUMENT_ID", DocumentID);
|
|
| 62 | 110 |
} |
| 63 | 111 |
|
| 64 | 112 |
SQL = SQL + string.Join(" AND ", whereSQL.ToArray());
|
| ... | ... | |
| 86 | 134 |
|
| 87 | 135 |
} |
| 88 | 136 |
|
| 137 |
/// <summary> |
|
| 138 |
/// ??? |
|
| 139 |
/// </summary> |
|
| 140 |
/// <param name="status"></param> |
|
| 141 |
/// <returns></returns> |
|
| 142 |
/// <exception cref="Exception"></exception> |
|
| 89 | 143 |
public async Task<IEnumerable<ConvertDoc>> GetConvertDocAsync(int status) |
| 90 | 144 |
{
|
| 91 |
string SQL = "SELECT * FROM CONVERTER_DOC WHERE STATUS = STATUS";
|
|
| 145 |
string SQL = "SELECT * FROM CONVERTER_DOC WHERE STATUS = @STATUS and DOC_ID = @DOC_ID";
|
|
| 92 | 146 |
|
| 93 | 147 |
var parameters = new MixParameters(DBMS); |
| 94 |
parameters.Add("STATUS", status);
|
|
| 148 |
parameters.Add("@STATUS", status);
|
|
| 95 | 149 |
|
| 96 | 150 |
var convertItems = await base.QueryAsync<Markus.Service.DataBase.Entities.ConvertDoc>(SQL, parameters); |
| 97 | 151 |
|
| ... | ... | |
| 121 | 175 |
} |
| 122 | 176 |
|
| 123 | 177 |
/// <summary> |
| 124 |
/// |
|
| 178 |
/// ???
|
|
| 125 | 179 |
/// </summary> |
| 126 | 180 |
/// <param name="TakeCount">-1??? ???</param> |
| 127 | 181 |
/// <returns></returns> |
| ... | ... | |
| 130 | 184 |
List<ConvertDoc> list = null; |
| 131 | 185 |
|
| 132 | 186 |
var parameters = new MixParameters(DBMS); |
| 133 |
parameters.Add("takecount", TakeCount);
|
|
| 187 |
parameters.Add("@takecount", TakeCount);
|
|
| 134 | 188 |
|
| 135 | 189 |
var result = await base.QueryAsync<ConvertDoc>("CONVERT_SELECT_CONVERTINGITEMS", parameters, commandType: CommandType.StoredProcedure);
|
| 136 | 190 |
|
| ... | ... | |
| 140 | 194 |
return list; |
| 141 | 195 |
} |
| 142 | 196 |
|
| 143 |
|
|
| 197 |
/// <summary> |
|
| 198 |
/// ??? |
|
| 199 |
/// </summary> |
|
| 200 |
/// <param name="convertID"></param> |
|
| 201 |
/// <param name="ReConvert"></param> |
|
| 202 |
/// <returns></returns> |
|
| 144 | 203 |
public async Task<int> SetCleanUpItemAsync(string convertID, int ReConvert) |
| 145 | 204 |
{
|
| 146 | 205 |
int result = -1; |
| 147 | 206 |
var tran = BeginTransaction(); |
| 148 | 207 |
|
| 149 | 208 |
var parameters = new MixParameters(DBMS); |
| 150 |
parameters.Add("converterdocid", convertID);
|
|
| 151 |
parameters.Add("reconvert", ReConvert);
|
|
| 152 |
parameters.Add("return", ReConvert,direction:ParameterDirection.ReturnValue);
|
|
| 209 |
parameters.Add("@converterdocid", convertID);
|
|
| 210 |
parameters.Add("@reconvert", ReConvert);
|
|
| 211 |
parameters.Add("@return", ReConvert,direction:ParameterDirection.ReturnValue);
|
|
| 153 | 212 |
|
| 154 | 213 |
await base.ExecuteAsync("CONVERT_UPDATE_CLEANUP_ITEM", parameters, tran, commandType: CommandType.StoredProcedure);
|
| 155 | 214 |
|
| ... | ... | |
| 160 | 219 |
return result; |
| 161 | 220 |
} |
| 162 | 221 |
|
| 163 |
|
|
| 164 |
public async Task<string> CreateAsync(string PROJECT_NO, string DOCUMENT_URL, string DOCUMENT_ID) |
|
| 165 |
{
|
|
| 166 |
string result = null; |
|
| 167 |
try |
|
| 168 |
{
|
|
| 169 |
var tran = BeginTransaction(); |
|
| 170 |
|
|
| 171 |
var parameters = new MixParameters(DBMS); |
|
| 172 |
parameters.Add("project_no", value: PROJECT_NO);
|
|
| 173 |
parameters.Add("document_url",value: DOCUMENT_URL);
|
|
| 174 |
parameters.Add("document_id",value: DOCUMENT_ID);
|
|
| 175 |
parameters.Add("newid", direction: ParameterDirection.Output);
|
|
| 176 |
|
|
| 177 |
await base.ExecuteAsync("convert_insert_convertdoc", parameters, transaction: tran, commandType: CommandType.StoredProcedure);
|
|
| 178 |
|
|
| 179 |
tran.Commit(); |
|
| 180 |
|
|
| 181 |
result = parameters.Get<string>("newid");
|
|
| 182 |
} |
|
| 183 |
catch (Exception ex) |
|
| 184 |
{
|
|
| 185 |
|
|
| 186 |
throw ex; |
|
| 187 |
} |
|
| 188 |
return result; |
|
| 189 |
} |
|
| 190 |
|
|
| 222 |
/// <summary> |
|
| 223 |
/// ??? |
|
| 224 |
/// </summary> |
|
| 225 |
/// <param name="PROJECT_NO"></param> |
|
| 226 |
/// <param name="DOCUMENT_URL"></param> |
|
| 227 |
/// <param name="DOCUMENT_ID"></param> |
|
| 228 |
/// <returns></returns> |
|
| 191 | 229 |
public async Task<string> Create(string PROJECT_NO, string DOCUMENT_URL, string DOCUMENT_ID) |
| 192 | 230 |
{
|
| 193 | 231 |
string result = null; |
| ... | ... | |
| 195 | 233 |
{
|
| 196 | 234 |
var tran = BeginTransaction(); |
| 197 | 235 |
|
| 198 |
|
|
| 199 | 236 |
var parameters = new MixParameters(DBMS); |
| 200 |
parameters.Add("project_no", value: PROJECT_NO);
|
|
| 201 |
parameters.Add("document_url", value: DOCUMENT_URL);
|
|
| 202 |
parameters.Add("document_id", value: DOCUMENT_ID);
|
|
| 203 |
parameters.Add("newid", direction: ParameterDirection.Output);
|
|
| 237 |
parameters.Add("@project_no", value: PROJECT_NO);
|
|
| 238 |
parameters.Add("@document_url", value: DOCUMENT_URL);
|
|
| 239 |
parameters.Add("@document_id", value: DOCUMENT_ID);
|
|
| 240 |
parameters.Add("@newid", direction: ParameterDirection.Output);
|
|
| 204 | 241 |
|
| 205 | 242 |
await base.ExecuteAsync("convert_insert_convertdoc", parameters, transaction: tran, commandType: CommandType.StoredProcedure);
|
| 206 | 243 |
|
| ... | ... | |
| 223 | 260 |
var tran = BeginTransaction(); |
| 224 | 261 |
|
| 225 | 262 |
var parameters = new MixParameters(DBMS); |
| 226 |
parameters.Add("SERVICE_ID", ServiceID);
|
|
| 227 |
parameters.Add("ID", ConvertDocID);
|
|
| 228 |
parameters.Add("STATUS", status);
|
|
| 229 |
parameters.Add("TOTAL_PAGE", totalPage);
|
|
| 230 |
parameters.Add("CURRENT_PAGE", currentPage);
|
|
| 231 |
parameters.Add("EXCEPTION", exception);
|
|
| 232 |
|
|
| 233 |
result = await base.ExecuteAsync("CONVERT_UPDATE_STATUS", parameters, transaction: tran, commandType: CommandType.StoredProcedure);
|
|
| 263 |
parameters.Add("@service_id", value: ServiceID);
|
|
| 264 |
parameters.Add("@id", value: ConvertDocID);
|
|
| 265 |
parameters.Add("@status", value: status);
|
|
| 266 |
parameters.Add("@total_page", value: totalPage);
|
|
| 267 |
parameters.Add("@current_page", value: currentPage);
|
|
| 268 |
parameters.Add("@exception", value: exception);
|
|
| 269 |
|
|
| 270 |
result = await base.ExecuteAsync("convert_update_status", parameters, transaction: tran, commandType: CommandType.StoredProcedure);
|
|
| 234 | 271 |
tran.Commit(); |
| 235 | 272 |
|
| 236 | 273 |
return result; |
| ConvertService/ServiceBase/Markus.Service.DataBase.Test/DataBaseConvertDoc.cs | ||
|---|---|---|
| 1 | 1 |
|
| 2 | 2 |
using NUnit.Framework; |
| 3 |
using NUnit.Framework.Interfaces; |
|
| 3 | 4 |
using System; |
| 4 | 5 |
using System.Collections.Generic; |
| 5 | 6 |
|
| ... | ... | |
| 9 | 10 |
{
|
| 10 | 11 |
public List<string> newConvertDocIDs = new List<string>(); |
| 11 | 12 |
|
| 13 |
/// <summary> |
|
| 14 |
/// 완료 |
|
| 15 |
/// </summary> |
|
| 12 | 16 |
[Test, Description("Craete Convert Doc MSSQL Test")]
|
| 13 |
public void CreateConvertDoc() |
|
| 17 |
public void CreateConvertDocAsync()
|
|
| 14 | 18 |
{
|
| 15 | 19 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 16 | 20 |
{
|
| ... | ... | |
| 25 | 29 |
Console.WriteLine($"new id : {newConvertDocID2}");
|
| 26 | 30 |
} |
| 27 | 31 |
|
| 28 |
GetConvertDocSingle(); |
|
| 32 |
|
|
| 29 | 33 |
} |
| 30 | 34 |
|
| 31 | 35 |
|
| 36 |
/// <summary> |
|
| 37 |
/// 완료 |
|
| 38 |
/// </summary> |
|
| 39 |
[Test, Description("Craete Convert Doc MSSQL Test")]
|
|
| 40 |
public void CreateConvertDoc() |
|
| 41 |
{
|
|
| 42 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 43 |
{
|
|
| 44 |
var newConvertDocID = repository.Create(ProjectNo, docUri, "111111").GetAwaiter().GetResult(); |
|
| 45 |
|
|
| 46 |
newConvertDocIDs.Add(newConvertDocID); |
|
| 47 |
Console.WriteLine($"new id : {newConvertDocID}");
|
|
| 48 |
|
|
| 49 |
var newConvertDocID2 = repository.Create(ProjectNo, docUri, "A1111111").GetAwaiter().GetResult(); |
|
| 50 |
|
|
| 51 |
newConvertDocIDs.Add(newConvertDocID2); |
|
| 52 |
Console.WriteLine($"new id : {newConvertDocID2}");
|
|
| 53 |
} |
|
| 54 |
} |
|
| 55 |
|
|
| 56 |
|
|
| 57 |
/// <summary> |
|
| 58 |
/// 완료 |
|
| 59 |
/// </summary> |
|
| 32 | 60 |
[Test, Description("GetConvertDocSingle Test")]
|
| 33 | 61 |
public void GetConvertDocSingle() |
| 34 | 62 |
{
|
| 35 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr,dbtype)) |
|
| 63 |
this.CreateConvertDoc(); |
|
| 64 |
|
|
| 65 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 36 | 66 |
{
|
| 37 | 67 |
foreach (var convertDocID in newConvertDocIDs) |
| 38 | 68 |
{
|
| ... | ... | |
| 41 | 71 |
Console.WriteLine($"ID : {convertDoc.ID} PROJECT_NO:{convertDoc.PROJECT_NO} DOCUMENT_URL:{convertDoc.DOCUMENT_URL} DOCUMENT_ID:{convertDoc.DOCUMENT_ID} ConvertPath:{convertDoc.ConvertPath} ");
|
| 42 | 72 |
break; |
| 43 | 73 |
} |
| 44 |
|
|
| 45 | 74 |
} |
| 46 | 75 |
} |
| 47 | 76 |
|
| 77 |
/// <summary> |
|
| 78 |
/// 완료 |
|
| 79 |
/// </summary> |
|
| 80 |
[Test, Description("Select waitOrError msSQL Test")]
|
|
| 81 |
public void SelectWaitOrError() |
|
| 82 |
{
|
|
| 83 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 84 |
{
|
|
| 85 |
var items = repository.GetWaitorErrorAsync(2).GetAwaiter().GetResult(); |
|
| 86 |
|
|
| 87 |
foreach (var item in items) |
|
| 88 |
{
|
|
| 89 |
NUnit.Framework.Assert.Pass(item.ID); |
|
| 90 |
} |
|
| 91 |
} |
|
| 92 |
} |
|
| 93 |
|
|
| 94 |
|
|
| 95 |
/// <summary> |
|
| 96 |
/// 완료. |
|
| 97 |
/// </summary> |
|
| 48 | 98 |
[Test, Description("Select Top 10 Convert Doc MS SQL Test")]
|
| 49 | 99 |
public void SelectTop10ConvertDoc() |
| 50 | 100 |
{
|
| ... | ... | |
| 54 | 104 |
+ "RECONVERTER FROM CONVERTER_DOC where CREATE_DATETIME >= @CREATE_DATETIME order by CREATE_DATETIME"; |
| 55 | 105 |
|
| 56 | 106 |
var parameter = new List<sqlParameter>(); |
| 107 |
|
|
| 57 | 108 |
parameter.Add(new sqlParameter("@CREATE_DATETIME", DateTime.Now.AddDays(-10), System.Data.DbType.DateTime));
|
| 58 | 109 |
|
| 59 | 110 |
var items = repository.GetAsync<Markus.Service.DataBase.Entities.ConvertDoc>(sql, parameter).GetAwaiter().GetResult(); |
| ... | ... | |
| 65 | 116 |
} |
| 66 | 117 |
} |
| 67 | 118 |
|
| 68 |
[Test, Description("Select waitOrError msSQL Test")]
|
|
| 69 |
public void SelectWaitOrError() |
|
| 119 |
|
|
| 120 |
/// <summary> |
|
| 121 |
/// 완료. |
|
| 122 |
/// </summary> |
|
| 123 |
[Test, Description("CONVERT_SELECT_CONVERTINGITEMS")]
|
|
| 124 |
public void CONVERT_SELECT_CONVERTINGITEMS() |
|
| 70 | 125 |
{
|
| 126 |
int TakeCount = 5; |
|
| 71 | 127 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 72 | 128 |
{
|
| 73 |
var items = repository.GetWaitorErrorAsync(2).GetAwaiter().GetResult();
|
|
| 129 |
var items = repository.GetConvertingItemAsync(TakeCount).GetAwaiter().GetResult();
|
|
| 74 | 130 |
|
| 75 | 131 |
foreach (var item in items) |
| 76 | 132 |
{
|
| ... | ... | |
| 78 | 134 |
} |
| 79 | 135 |
} |
| 80 | 136 |
} |
| 137 |
|
|
| 138 |
/// <summary> |
|
| 139 |
/// 완료. |
|
| 140 |
/// </summary> |
|
| 141 |
[Test, Description("SetCleanUpItem PostgreSQL Test")]
|
|
| 142 |
public void SelectSetCleanUpItem() |
|
| 143 |
{
|
|
| 144 |
this.CreateConvertDoc(); |
|
| 145 |
|
|
| 146 |
foreach (var item in newConvertDocIDs) |
|
| 147 |
{
|
|
| 148 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 149 |
{
|
|
| 150 |
var items = repository.SetCleanUpItemAsync(item, 1).GetAwaiter().GetResult(); |
|
| 151 |
|
|
| 152 |
Assert.Pass(item); |
|
| 153 |
} |
|
| 154 |
} |
|
| 155 |
} |
|
| 156 |
|
|
| 157 |
|
|
| 158 |
/// <summary> |
|
| 159 |
/// 완료. |
|
| 160 |
/// </summary> |
|
| 161 |
[Test, Description("UpdateStatusAsync")]
|
|
| 162 |
public void UpdateStatusAsync() |
|
| 163 |
{
|
|
| 164 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 165 |
{
|
|
| 166 |
var newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult(); |
|
| 167 |
|
|
| 168 |
var convertDoc = repository.GetConvertDocSingleAsync(ProjectNo, ConvertID: newConvertDocID).GetAwaiter().GetResult(); |
|
| 169 |
|
|
| 170 |
Console.WriteLine($"ID : {convertDoc.ID} PROJECT_NO:{convertDoc.PROJECT_NO} DOCUMENT_URL:{convertDoc.DOCUMENT_URL} DOCUMENT_ID:{convertDoc.DOCUMENT_ID} ConvertPath:{convertDoc.ConvertPath} ");
|
|
| 171 |
|
|
| 172 |
var items = repository.UpdateStatusAsync("", convertDoc.ID, convertDoc.STATUS, convertDoc.TOTAL_PAGE, convertDoc.CURRENT_PAGE, "").GetAwaiter().GetResult();
|
|
| 173 |
|
|
| 174 |
|
|
| 175 |
} |
|
| 176 |
} |
|
| 177 |
|
|
| 81 | 178 |
} |
| 82 | 179 |
} |
| ConvertService/ServiceBase/Markus.Service.DataBase.Test/DataBaseConvertDocPG.cs | ||
|---|---|---|
| 5 | 5 |
|
| 6 | 6 |
namespace Markus.Service.DataBase.Test |
| 7 | 7 |
{
|
| 8 |
/// <summary> |
|
| 9 |
/// PostgreSQL |
|
| 10 |
/// </summary> |
|
| 8 | 11 |
public class DataBaseConvertDocPG : TestBasePG |
| 9 | 12 |
{
|
| 10 | 13 |
public List<string> newConvertDocIDs = new List<string>(); |
| 11 |
[Test, Description("Craete Convert Doc MSSQL Test")]
|
|
| 12 |
public void CreateConvertDoc() |
|
| 14 |
/// <summary> |
|
| 15 |
/// 완료 |
|
| 16 |
/// </summary> |
|
| 17 |
[Test, Description("Craete Convert Doc Postgresql Test")]
|
|
| 18 |
public void CreateConvertDocAsync() |
|
| 13 | 19 |
{
|
| 14 | 20 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 15 | 21 |
{
|
| ... | ... | |
| 24 | 30 |
Console.WriteLine($"new id : {newConvertDocID2}");
|
| 25 | 31 |
} |
| 26 | 32 |
|
| 27 |
GetConvertDocSingle(); |
|
| 28 | 33 |
} |
| 29 | 34 |
|
| 30 | 35 |
|
| 36 |
/// <summary> |
|
| 37 |
/// 완료 |
|
| 38 |
/// </summary> |
|
| 39 |
[Test, Description("Craete Convert Doc MSSQL Test")]
|
|
| 40 |
public void CreateConvertDoc() |
|
| 41 |
{
|
|
| 42 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 43 |
{
|
|
| 44 |
var newConvertDocID = repository.Create(ProjectNo, docUri, "111111").GetAwaiter().GetResult(); |
|
| 45 |
|
|
| 46 |
newConvertDocIDs.Add(newConvertDocID); |
|
| 47 |
Console.WriteLine($"new id : {newConvertDocID}");
|
|
| 48 |
|
|
| 49 |
var newConvertDocID2 = repository.Create(ProjectNo, docUri, "A1111111").GetAwaiter().GetResult(); |
|
| 50 |
|
|
| 51 |
newConvertDocIDs.Add(newConvertDocID2); |
|
| 52 |
Console.WriteLine($"new id : {newConvertDocID2}");
|
|
| 53 |
} |
|
| 54 |
} |
|
| 55 |
|
|
| 56 |
/// <summary> |
|
| 57 |
/// 완료 |
|
| 58 |
/// </summary> |
|
| 31 | 59 |
[Test, Description("GetConvertDocSingle Test")]
|
| 32 | 60 |
public void GetConvertDocSingle() |
| 33 | 61 |
{
|
| 62 |
this.CreateConvertDoc(); |
|
| 63 |
|
|
| 34 | 64 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 35 | 65 |
{
|
| 36 | 66 |
foreach (var convertDocID in newConvertDocIDs) |
| ... | ... | |
| 43 | 73 |
} |
| 44 | 74 |
} |
| 45 | 75 |
|
| 76 |
/// <summary> |
|
| 77 |
/// 완료 |
|
| 78 |
/// </summary> |
|
| 79 |
[Test, Description("Select waitOrError PostgreSQL Test")]
|
|
| 80 |
public void SelectWaitOrError() |
|
| 81 |
{
|
|
| 82 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 83 |
{
|
|
| 84 |
var items = repository.GetWaitorErrorAsync(2).GetAwaiter().GetResult(); |
|
| 85 |
|
|
| 86 |
foreach (var item in items) |
|
| 87 |
{
|
|
| 88 |
Assert.Pass(item.ID); |
|
| 89 |
} |
|
| 90 |
} |
|
| 91 |
} |
|
| 92 |
|
|
| 93 |
|
|
| 94 |
/// <summary> |
|
| 95 |
/// 완료 |
|
| 96 |
/// </summary> |
|
| 46 | 97 |
[Test, Description("Select Top 10 Convert Doc PostgreSQL Test")]
|
| 47 | 98 |
public void SelectTop10ConvertDoc() |
| 48 | 99 |
{
|
| 49 | 100 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 50 | 101 |
{
|
| 51 | 102 |
string sql = @"SELECT ID, PROJECT_NO, DOCUMENT_URL, DOCUMENT_ID, CREATE_DATETIME, STATUS, TOTAL_PAGE, CURRENT_PAGE, EXCEPTION, END_DATETIME, START_DATETIME, SERVICE_ID," |
| 52 |
+ "RECONVERTER FROM CONVERTER_DOC where CREATE_DATETIME >= CREATE_DATETIME order by CREATE_DATETIME desc limit 10"; |
|
| 103 |
+ "RECONVERTER FROM CONVERTER_DOC where CREATE_DATETIME >= @CREATE_DATETIME order by CREATE_DATETIME desc limit 10";
|
|
| 53 | 104 |
|
| 54 | 105 |
var parameter = new List<sqlParameter>(); |
| 55 |
parameter.Add(new sqlParameter("CREATE_DATETIME", DateTime.Now.AddDays(-10), System.Data.DbType.DateTime));
|
|
| 106 |
parameter.Add(new sqlParameter("@CREATE_DATETIME", DateTime.Now.AddDays(-2), System.Data.DbType.DateTime));
|
|
| 56 | 107 |
|
| 57 | 108 |
var items = repository.GetAsync<Markus.Service.DataBase.Entities.ConvertDoc>(sql, parameter).GetAwaiter().GetResult(); |
| 58 | 109 |
|
| ... | ... | |
| 63 | 114 |
} |
| 64 | 115 |
} |
| 65 | 116 |
|
| 66 |
|
|
| 67 |
[Test, Description("Select waitOrError PostgreSQL Test")]
|
|
| 68 |
public void SelectWaitOrError() |
|
| 117 |
/// <summary> |
|
| 118 |
/// 완료 |
|
| 119 |
/// </summary> |
|
| 120 |
[Test, Description("CONVERT_SELECT_CONVERTINGITEMS")]
|
|
| 121 |
public void CONVERT_SELECT_CONVERTINGITEMS() |
|
| 69 | 122 |
{
|
| 123 |
int TakeCount = 5; |
|
| 70 | 124 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| 71 | 125 |
{
|
| 72 |
var items = repository.GetWaitorErrorAsync(2).GetAwaiter().GetResult();
|
|
| 126 |
var items = repository.GetConvertingItemAsync(TakeCount).GetAwaiter().GetResult();
|
|
| 73 | 127 |
|
| 74 | 128 |
foreach (var item in items) |
| 75 | 129 |
{
|
| ... | ... | |
| 78 | 132 |
} |
| 79 | 133 |
} |
| 80 | 134 |
|
| 135 |
/// <summary> |
|
| 136 |
/// 완료. |
|
| 137 |
/// </summary> |
|
| 81 | 138 |
[Test, Description("SetCleanUpItem PostgreSQL Test")]
|
| 82 | 139 |
public void SelectSetCleanUpItem() |
| 83 | 140 |
{
|
| 141 |
this.CreateConvertDoc(); |
|
| 142 |
|
|
| 84 | 143 |
foreach (var item in newConvertDocIDs) |
| 85 | 144 |
{
|
| 86 | 145 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
| ... | ... | |
| 91 | 150 |
} |
| 92 | 151 |
} |
| 93 | 152 |
} |
| 153 |
|
|
| 154 |
|
|
| 155 |
|
|
| 156 |
/// <summary> |
|
| 157 |
/// 완료. |
|
| 158 |
/// </summary> |
|
| 159 |
[Test, Description("UpdateStatusAsync")]
|
|
| 160 |
public void UpdateStatusAsync() |
|
| 161 |
{
|
|
| 162 |
using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype)) |
|
| 163 |
{
|
|
| 164 |
var newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult(); |
|
| 165 |
|
|
| 166 |
var convertDoc = repository.GetConvertDocSingleAsync(ProjectNo, ConvertID: newConvertDocID).GetAwaiter().GetResult(); |
|
| 167 |
|
|
| 168 |
Console.WriteLine($"ID : {convertDoc.ID} PROJECT_NO:{convertDoc.PROJECT_NO} DOCUMENT_URL:{convertDoc.DOCUMENT_URL} DOCUMENT_ID:{convertDoc.DOCUMENT_ID} ConvertPath:{convertDoc.ConvertPath} ");
|
|
| 169 |
|
|
| 170 |
var items = repository.UpdateStatusAsync("", convertDoc.ID, convertDoc.STATUS, convertDoc.TOTAL_PAGE, convertDoc.CURRENT_PAGE, "").GetAwaiter().GetResult();
|
|
| 171 |
|
|
| 172 |
|
|
| 173 |
} |
|
| 174 |
} |
|
| 175 |
|
|
| 94 | 176 |
} |
| 95 | 177 |
} |
내보내기 Unified diff
