개정판 ff4b1e6e
데이터베이스 nuget으로 변경
Change-Id: I6167ddf20d4cdae727b0d9047dec4fdad0dcf81a
| ConvertService/ServiceBase/Markus.Service.DataBase/ConvertDatabase.cs | ||
|---|---|---|
| 1 |
using Markus.Message; |
|
| 1 |
using Markus.EntityModel; |
|
| 2 |
using Markus.Message; |
|
| 2 | 3 |
using Markus.Service.Extensions; |
| 3 | 4 |
using System; |
| 4 | 5 |
using System.Collections.Generic; |
| ... | ... | |
| 9 | 10 |
{
|
| 10 | 11 |
public class ConvertDatabase : IDisposable |
| 11 | 12 |
{
|
| 12 |
MarkusEntities entities;
|
|
| 13 |
Markus.EntityModel.MarkusModel entities;
|
|
| 13 | 14 |
|
| 14 | 15 |
public ConvertDatabase(string ConnectionString) |
| 15 | 16 |
{
|
| 16 | 17 |
try |
| 17 | 18 |
{
|
| 18 | 19 |
//해당 프로젝트의 데이터베이스 연결 |
| 19 |
string databaseDir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Database"); |
|
| 20 |
entities = new MarkusEntities(ConnectionString); |
|
| 20 |
entities = new Markus.EntityModel.MarkusModel(ConnectionString); |
|
| 21 | 21 |
} |
| 22 | 22 |
catch (Exception ex) |
| 23 | 23 |
{
|
| ... | ... | |
| 233 | 233 |
/// <param name="aliveItems"></param> |
| 234 | 234 |
/// <param name="TakeCount"></param> |
| 235 | 235 |
/// <returns></returns> |
| 236 |
public List<CONVERTER_DOC> GetWaitConvertItems(List<string> projectList, int TakeCount)
|
|
| 236 |
public IEnumerable<CONVERTER_DOC> GetWaitConvertItems(List<string> projectList, int TakeCount)
|
|
| 237 | 237 |
{
|
| 238 | 238 |
var convertWaitingItems = entities.CONVERTER_DOC.OrderBy(x => x.CREATE_DATETIME).Where( |
| 239 | 239 |
x => |
| ... | ... | |
| 243 | 243 |
.GroupBy(x=>x.DOCUMENT_ID).Select(x => x.FirstOrDefault()) |
| 244 | 244 |
.Take(TakeCount); |
| 245 | 245 |
|
| 246 |
return convertWaitingItems.ToList();
|
|
| 246 |
return convertWaitingItems; |
|
| 247 | 247 |
} |
| 248 | 248 |
|
| 249 | 249 |
public List<CONVERTER_DOC> GetConvertingItems(List<string> projectList) |
내보내기 Unified diff
