프로젝트

일반

사용자정보

개정판 bede677a

IDbede677a05099bd4a9e9fa02e0c4bde076a15de5
상위 ffaddd56
하위 264f0f92, c1597feb

GeunHo Song 이(가) 약 2년 전에 추가함

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

클립보드 이미지 추가 (최대 크기: 500 MB)