개정판 4b33593a
issue #000000 datetime thread 충돌 수정
Change-Id: I819879ff73b14328ff57ed9613fcde413eebcdc1
ConvertService/ServiceBase/Markus.Service.Station/StationService/ServiceStationTask.cs | ||
---|---|---|
139 | 139 |
} |
140 | 140 |
|
141 | 141 |
/// <summary> |
142 |
/// DB에 있는 대기중인 Item을 가져온다. |
|
142 |
/// DB에 있는 대기중인 Item을 가져와서 프로세스 실행 |
|
143 |
/// |
|
143 | 144 |
/// </summary> |
144 | 145 |
public void setDataBaseWaitingList() |
145 | 146 |
{ |
... | ... | |
153 | 154 |
{ |
154 | 155 |
//ReflashSubService(); |
155 | 156 |
|
156 |
if (AliveConvertQueue.Count(x => x.ID == convert.ID || x.DOCUMENT_ID == convert.DOCUMENT_ID) == 0) |
|
157 |
if (AliveConvertQueue.Count(x => x.ID == convert.ID |
|
158 |
|| x.DOCUMENT_ID == convert.DOCUMENT_ID // 같은 경로로 다운로드 및 작업되어 추가 |
|
159 |
|| (x.STATUS <= (int)StatusCodeType.Wait && x.DOCUMENT_URL == convert.DOCUMENT_URL)) == 0) |
|
160 |
// 같은 url을 다운로드시 서버의 퍼포먼스가 좋지 않으면 다운로드 오류 발생하여 추가 |
|
157 | 161 |
{ |
158 | 162 |
if (convert.STATUS > (int)StatusCodeType.None) |
159 | 163 |
{ |
... | ... | |
173 | 177 |
#if DEBUG |
174 | 178 |
else |
175 | 179 |
{ |
180 |
if (AliveConvertQueue.Where(x => x.STATUS <= (int)StatusCodeType.Wait && x.DOCUMENT_URL == convert.DOCUMENT_URL) is var items) |
|
181 |
{ |
|
182 |
if (System.Environment.UserInteractive) |
|
183 |
{ |
|
184 |
if (items.Count() > 0) |
|
185 |
{ |
|
186 |
Console.WriteLine($"Same DOCUMENT_URL : {((StatusCodeType)items.First().STATUS).ToString()} - {items.First().DOCUMENT_URL}"); |
|
187 |
} |
|
188 |
} |
|
189 |
} |
|
190 |
|
|
176 | 191 |
if (AliveConvertQueue.Count(x => x.ID == convert.ID) > 0) |
177 | 192 |
{ |
178 | 193 |
if (System.Environment.UserInteractive) |
179 | 194 |
{ |
180 |
Console.WriteLine($"AliveConvertQueue.Count(x => x.ID == convert.ID) : {convert.ID}");
|
|
195 |
Console.WriteLine($"same convert.ID : {convert.ID}");
|
|
181 | 196 |
} |
182 | 197 |
} |
183 | 198 |
|
... | ... | |
185 | 200 |
{ |
186 | 201 |
if (System.Environment.UserInteractive) |
187 | 202 |
{ |
188 |
Console.WriteLine($"AliveConvertQueue.Count(x.DOCUMENT_ID == convert.DOCUMENT_ID) : {convert.DOCUMENT_ID}");
|
|
203 |
Console.WriteLine($"same convert.DOCUMENT_ID : {convert.DOCUMENT_ID}");
|
|
189 | 204 |
} |
190 | 205 |
} |
191 |
|
|
192 | 206 |
} |
193 | 207 |
#endif |
194 | 208 |
/// 2022.11.28 수정 |
내보내기 Unified diff