itcsx/Docker
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ow

Browse Source
This commit is contained in:
itcsx committed 2026-09-21 21:31:16 +08:00
1 parent 7c8af2fb08
commit c10f8347e2
31 files changed
+358 -292
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

CloudBuilder.Topshelf/Task/RunTask.cs
+17 -9
View File
@@ -31,20 +31,24 @@ namespace CloudBuilder.Topshelf.Task
IRepository<SecurityScheduleTaskQueueEntity> taskRepository = service.GetRepository<IRepository<SecurityScheduleTaskQueueEntity>>();
SecurityScheduleTaskQueueEntity task = taskRepository.DetachedEntities.OrderBy(x => x.QueueId).FirstOrDefault();
SecurityScheduleTaskQueueEntity[] tasks = taskRepository.DetachedEntities.OrderBy(x => x.QueueId).ToArray();
if (task == null) return;
if (tasks == null || tasks.Length == 0) return;
foreach (var task in tasks)
{
IRepository<DmsFileEntity> repositoryDmsFile = service.GetRepository<IRepository<DmsFileEntity>>();
DmsFileEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.OrderKey == task.DocumentId).FirstOrDefault();
IRepository<DmsFileEntity> repositoryDmsFile = service.GetRepository<IRepository<DmsFileEntity>>();
DmsFileEntity dmsFile = repositoryDmsFile.DetachedEntities.Where(x => x.OrderKey == task.DocumentId).FirstOrDefault();
if (dmsFile == null) return;
if (dmsFile == null) return;
RunMyProcess(task.TaskId, task.TaskParam);
RunMyProcess(task.TaskId, task.TaskParam);
dmsFile.TranscodeIndc = YesNoPolicy.YES;
repositoryDmsFile.UpdateNow(dmsFile);
dmsFile.TranscodeIndc = YesNoPolicy.YES;
repositoryDmsFile.UpdateNow(dmsFile);
taskRepository.DeleteNow(task);
}
}
catch (Exception ex)
{
@@ -60,7 +64,11 @@ namespace CloudBuilder.Topshelf.Task
{
try
{
parameters = parameters.Replace("/app/data", "/vol1/1000/Docker/NET8/DEV/data");
//Dockerfile中定义的volumes的映射地址
var rf = service.Configuration["FileServiceSettings:RelativeFileDirectory"];
var af = service.Configuration["FileServiceSettings:AbsoluteFileDirectory"];
parameters = parameters.Replace(rf, af);
log.WriteToFile(exePath + parameters);