mirror of
https://github.com/espocrm/espocrm.git
synced 2026-06-28 15:06:06 +00:00
job number
This commit is contained in:
@@ -367,12 +367,6 @@ class CronManager
|
||||
$methodNameDeprecated = $job->get('method');
|
||||
$methodName = $job->get('methodName');
|
||||
|
||||
$isDeprecated = false;
|
||||
if (!$methodName) {
|
||||
$isDeprecated = true;
|
||||
$methodName = $methodNameDeprecated;
|
||||
}
|
||||
|
||||
if (!$methodName) {
|
||||
throw new Error('Job with empty methodName.');
|
||||
}
|
||||
@@ -383,10 +377,6 @@ class CronManager
|
||||
|
||||
$data = $job->get('data');
|
||||
|
||||
if ($isDeprecated) {
|
||||
$data = Json::decode(Json::encode($data), true);
|
||||
}
|
||||
|
||||
$service->$methodName($data, $job->get('targetId'), $job->get('targetType'));
|
||||
}
|
||||
|
||||
|
||||
@@ -85,17 +85,15 @@ class Job
|
||||
'targetId',
|
||||
'targetType',
|
||||
'methodName',
|
||||
'method', // TODO remove deprecated
|
||||
'serviceName',
|
||||
'data',
|
||||
'queue'
|
||||
'data'
|
||||
],
|
||||
'whereClause' => [
|
||||
'status' => CronManager::PENDING,
|
||||
'executeTime<=' => date('Y-m-d H:i:s'),
|
||||
'queue' => $queue
|
||||
],
|
||||
'orderBy' => 'executeTime'
|
||||
'orderBy' => 'number'
|
||||
];
|
||||
if ($limit) {
|
||||
$selectParams['offset'] = 0;
|
||||
|
||||
@@ -33,7 +33,7 @@ use \Espo\Core\Exceptions;
|
||||
|
||||
class Cleanup extends \Espo\Core\Jobs\Base
|
||||
{
|
||||
protected $cleanupJobPeriod = '1 month';
|
||||
protected $cleanupJobPeriod = '10 days';
|
||||
|
||||
protected $cleanupActionHistoryPeriod = '15 days';
|
||||
|
||||
|
||||
@@ -13,6 +13,7 @@
|
||||
"data": "Data",
|
||||
"targetType": "Target Type",
|
||||
"targetId": "Target ID",
|
||||
"number": "Number",
|
||||
"queue": "Queue"
|
||||
},
|
||||
"options": {
|
||||
@@ -23,4 +24,4 @@
|
||||
"Failed": "Failed"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
"label":"",
|
||||
"rows":[
|
||||
[{"name":"name"}, {"name": "status"}],
|
||||
[{"name":"queue"}, false]
|
||||
[{"name":"queue"}, {"name":"number"}]
|
||||
]
|
||||
},
|
||||
{
|
||||
|
||||
@@ -20,16 +20,16 @@
|
||||
"type": "datetime",
|
||||
"required": true
|
||||
},
|
||||
"number": {
|
||||
"type": "autoincrement",
|
||||
"index": true,
|
||||
"dbType": "bigint"
|
||||
},
|
||||
"serviceName": {
|
||||
"type": "varchar",
|
||||
"required": true,
|
||||
"maxLength": 100
|
||||
},
|
||||
"method": {
|
||||
"type": "varchar",
|
||||
"required": true,
|
||||
"maxLength":100
|
||||
},
|
||||
"methodName": {
|
||||
"type": "varchar",
|
||||
"maxLength": 100
|
||||
@@ -86,7 +86,7 @@
|
||||
}
|
||||
},
|
||||
"collection": {
|
||||
"orderBy": "createdAt",
|
||||
"orderBy": "number",
|
||||
"order": "desc",
|
||||
"textFilterFields": ["name", "methodName", "serviceName", "scheduledJobName"]
|
||||
},
|
||||
|
||||
Reference in New Issue
Block a user