CREATE TABLE `def_supervisor` (
`Servicecode` char(100) NOT NULL,
`Package` VARCHAR(255) NOT NULL DEFAULT '',
`Module` VARCHAR(255) DEFAULT NULL,
`imapserver` char(255) DEFAULT NULL,
`Pause` char(1) DEFAULT 'N',
`imapport` char(255) DEFAULT NULL,
`Note` char(255) DEFAULT '',
`smtpport` char(10) DEFAULT '',
`WorkerIpSet` mediumtext DEFAULT NULL,
`CycleTime` float DEFAULT NULL,
`Status` char(255) DEFAULT '',
`VendorId` char(255) DEFAULT '',
`UpdateTime` datetime DEFAULT NULL,
`smtpserver` char(255) DEFAULT '',
`remoteurl_last` char(255) DEFAULT NULL,
`CampaignId` char(255) DEFAULT '',
`popserver` char(255) DEFAULT '',
`serviceid` char(10) DEFAULT '',
`Threads` int(11) DEFAULT 5,
`DispatcherIp` char(255) DEFAULT 'LOCALHOST',
`remotedir` char(255) DEFAULT '',
`Active` char(1) DEFAULT 'Y',
`remoteurllast` char(255) DEFAULT NULL,
`Processes` int(11) DEFAULT 1,
`dispatcherpid` int(11) DEFAULT NULL,
`Logging` char(10) DEFAULT 'OFF',
`Notes` longtext DEFAULT NULL,
`Deathtimer` char(255) DEFAULT NULL,
`LastSuccessTime` datetime DEFAULT NULL,
`Localdir` char(255) DEFAULT '',
`IsLive` char(1) DEFAULT 'N',
`Servicemethod` char(255) DEFAULT NULL,
`ServiceDescription` char(255) DEFAULT '',
`SleepTime` float DEFAULT 10,
`DispatcherId` int(11) DEFAULT NULL,
`sshport` char(10) DEFAULT '22',
`Archivetimer` char(255) DEFAULT '30 DAY',
`TransactionsPerCycle` int(11) DEFAULT 10,
PRIMARY KEY (`Servicecode`, `Package`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE={collation};
SELECT count(*)
FROM def_supervisor
WHERE servicecode = '{service_code}'
INSERT INTO def_supervisor
(ServiceCode, Status, Note, SleepTime)
VALUES
('{service_code}', '{status}', '{note}', '10')
UPDATE def_supervisor
SET Note = '{note}',
Status = (
CASE
WHEN Status = 'RUNNING' AND Pause = 'Y'
THEN 'PAUSED'
WHEN Status = 'PAUSED' AND Pause = 'Y'
THEN 'PAUSED'
ELSE '{status}'
END
),
UpdateTime = NOW()
WHERE ServiceCode = '{service_code}'
SELECT *
FROM def_Supervisor
WHERE Servicecode LIKE 'stage_{service}'
SELECT *
FROM stage_{service}
WHERE (Status IS NULL OR Status = '')
AND (TimeScheduled IS NULL
OR TimeScheduled <= NOW())
AND COALESCE(Package, '') IN ('', '0', '{package}')
UPDATE stage_{service}
SET Status = 'EXPIRED',
TimeCompleted = NOW()
WHERE (Status IS NULL OR Status = '')
AND datediff(now(), TimeScheduled) > 1
AND COALESCE(Package, '') IN ('', '0', '{package}')
SELECT count(*)
FROM stage_{service}
WHERE Status = '{status}'
SELECT Guid
FROM stage_{service}
WHERE Status = 'DONE'
SELECT Active
FROM def_supervisor
WHERE Servicecode = 'stage_{service}'
UPDATE stage_{service}
SET Status = ''
WHERE Status IN ('QUEUED', 'RUNNING', 'LAUNCH')