개정판 bede677a
issue #000 ConvertDocRepository 수정 및 Unit 테스트 파일 변경.
Change-Id: I774ab5147330b57f6afacc19033ad10d17f96210
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 |
} |
내보내기 Unified diff