espocrm-extensions/espocrm-base
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix internal jobs

Browse Source
This commit is contained in:
yuri
2018-11-29 12:17:04 +02:00
parent c9bb6dfdde
commit 93f51f7087
1 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
application/Espo/Core/DataManager.php
+18 -5
View File
@@ -130,18 +130,21 @@ class DataManager
$metadata = $this->getContainer()->get('metadata');
$entityManager = $this->getContainer()->get('entityManager');
$jobs = $metadata->get(['entityDefs', 'ScheduledJob', 'jobs'], array());
$jobs = $metadata->get(['entityDefs', 'ScheduledJob', 'jobs'], []);
$systemJobNameList = [];
foreach ($jobs as $jobName => $defs) {
if ($jobName && !empty($defs['isSystem']) && !empty($defs['scheduling'])) {
$systemJobNameList[] = $jobName;
if (!$entityManager->getRepository('ScheduledJob')->where(array(
'job' => $jobName,
'status' => 'Active',
'scheduling' => $defs['scheduling']
))->findOne()) {
$job = $entityManager->getRepository('ScheduledJob')->where(array(
$job = $entityManager->getRepository('ScheduledJob')->where([
'job' => $jobName
))->findOne();
])->findOne();
if ($job) {
$entityManager->removeEntity($job);
}
@@ -150,17 +153,27 @@ class DataManager
$name = $defs['name'];
}
$job = $entityManager->getEntity('ScheduledJob');
$job->set(array(
$job->set([
'job' => $jobName,
'status' => 'Active',
'scheduling' => $defs['scheduling'],
'isInternal' => true,
'name' => $name
));
]);
$entityManager->saveEntity($job);
}
}
}
$internalScheduledJobList = $entityManager->getRepository('ScheduledJob')->where([
'isInternal' => true
])->find();
foreach ($internalScheduledJobList as $scheduledJob) {
$jobName = $scheduledJob->get('job');
if (!in_array($jobName, $systemJobNameList)) {
$entityManager->getRepository('ScheduledJob')->deleteFromDb($scheduledJob->id);
}
}
}
public function updateCacheTimestamp()