Fix Lane Status
This commit is contained in:
b.makharadze
parent
826b94c0cc
commit
cbd91276d9
File diff suppressed because one or more lines are too long
138
MTN6_SCADA/ignition/named-query/Status/Lane Status/query.sql
Normal file
138
MTN6_SCADA/ignition/named-query/Status/Lane Status/query.sql
Normal file
@ -0,0 +1,138 @@
|
||||
WITH DesiredLanes AS (
|
||||
SELECT lane_number
|
||||
FROM (
|
||||
SELECT 101 + n AS lane_number FROM (
|
||||
SELECT a.N + b.N * 10 AS n
|
||||
FROM (SELECT 0 AS N UNION SELECT 1 UNION SELECT 2 UNION SELECT 3 UNION SELECT 4 UNION SELECT 5 UNION SELECT 6 UNION SELECT 7 UNION SELECT 8 UNION SELECT 9) a,
|
||||
(SELECT 0 AS N UNION SELECT 1 UNION SELECT 2) b
|
||||
) numbers WHERE n <= 28 -- 101 to 129
|
||||
UNION
|
||||
SELECT 201 + n FROM (
|
||||
SELECT a.N + b.N * 10 AS n
|
||||
FROM (SELECT 0 AS N UNION SELECT 1 UNION SELECT 2 UNION SELECT 3 UNION SELECT 4 UNION SELECT 5 UNION SELECT 6 UNION SELECT 7 UNION SELECT 8 UNION SELECT 9) a,
|
||||
(SELECT 0 AS N UNION SELECT 1 UNION SELECT 2) b
|
||||
) numbers WHERE n <= 28 -- 201 to 229
|
||||
) lanes
|
||||
),
|
||||
AlarmData AS (
|
||||
SELECT DISTINCT
|
||||
ae.id AS record_id,
|
||||
ae.eventid AS event_uuid,
|
||||
ae.source,
|
||||
ae.eventtime AS active_time,
|
||||
(SELECT MIN(eventtime)
|
||||
FROM alarm_events ae2
|
||||
WHERE ae2.eventid = ae.eventid
|
||||
AND ae2.eventtype = 1
|
||||
AND ae2.eventtime >= ae.eventtime
|
||||
) AS clear_time
|
||||
FROM alarm_events ae
|
||||
WHERE
|
||||
ae.eventtime BETWEEN :startDate AND :endDate
|
||||
AND ae.eventtype = 0
|
||||
AND (ae.source LIKE '%Chute%' OR ae.source LIKE '%ChuteStatus%')
|
||||
),
|
||||
LaneMapping AS (
|
||||
SELECT
|
||||
id AS record_id,
|
||||
strvalue AS tag_value,
|
||||
CASE
|
||||
WHEN strvalue LIKE '%Chute[%' THEN
|
||||
CAST(SUBSTRING(strvalue, LOCATE('Chute[', strvalue) + 6,
|
||||
LOCATE(']', strvalue, LOCATE('Chute[', strvalue)) - LOCATE('Chute[', strvalue) - 6) AS UNSIGNED)
|
||||
WHEN strvalue LIKE '%Chute[_%' THEN
|
||||
CAST(SUBSTRING(strvalue, LOCATE('Chute_', strvalue) + 6) AS UNSIGNED)
|
||||
WHEN strvalue LIKE '%Chute%' THEN
|
||||
CAST(REGEXP_SUBSTR(strvalue, '[0-9]+') AS UNSIGNED)
|
||||
ELSE NULL
|
||||
END AS plc_index,
|
||||
CASE
|
||||
WHEN strvalue LIKE '%Chute[%' THEN
|
||||
CASE
|
||||
WHEN CAST(SUBSTRING(strvalue, LOCATE('Chute[', strvalue) + 6,
|
||||
LOCATE(']', strvalue, LOCATE('Chute[', strvalue)) - LOCATE('Chute[', strvalue) - 6) AS UNSIGNED) BETWEEN 1 AND 29
|
||||
THEN 101 + (CAST(SUBSTRING(strvalue, LOCATE('Chute[', strvalue) + 6,
|
||||
LOCATE(']', strvalue, LOCATE('Chute[', strvalue)) - LOCATE('Chute[', strvalue) - 6) AS UNSIGNED) - 1)
|
||||
WHEN CAST(SUBSTRING(strvalue, LOCATE('Chute[', strvalue) + 6,
|
||||
LOCATE(']', strvalue, LOCATE('Chute[', strvalue)) - LOCATE('Chute[', strvalue) - 6) AS UNSIGNED) BETWEEN 30 AND 59
|
||||
THEN 201 + (CAST(SUBSTRING(strvalue, LOCATE('Chute[', strvalue) + 6,
|
||||
LOCATE(']', strvalue, LOCATE('Chute[', strvalue)) - LOCATE('Chute[', strvalue) - 6) AS UNSIGNED) - 31)
|
||||
ELSE NULL
|
||||
END
|
||||
WHEN strvalue LIKE '%Chute[_%' THEN
|
||||
CASE
|
||||
WHEN CAST(SUBSTRING(strvalue, LOCATE('Chute_', strvalue) + 6) AS UNSIGNED) BETWEEN 1 AND 29
|
||||
THEN 101 + (CAST(SUBSTRING(strvalue, LOCATE('Chute_', strvalue) + 6) AS UNSIGNED) - 1)
|
||||
WHEN CAST(SUBSTRING(strvalue, LOCATE('Chute_', strvalue) + 6) AS UNSIGNED) BETWEEN 30 AND 59
|
||||
THEN 201 + (CAST(SUBSTRING(strvalue, LOCATE('Chute_', strvalue) + 6) AS UNSIGNED) - 31)
|
||||
ELSE NULL
|
||||
END
|
||||
WHEN strvalue LIKE '%Chute%' THEN
|
||||
CASE
|
||||
WHEN CAST(REGEXP_SUBSTR(strvalue, '[0-9]+') AS UNSIGNED) BETWEEN 1 AND 29
|
||||
THEN 101 + (CAST(REGEXP_SUBSTR(strvalue, '[0-9]+') AS UNSIGNED) - 1)
|
||||
WHEN CAST(REGEXP_SUBSTR(strvalue, '[0-9]+') AS UNSIGNED) BETWEEN 30 AND 59
|
||||
THEN 201 + (CAST(REGEXP_SUBSTR(strvalue, '[0-9]+') AS UNSIGNED) - 31)
|
||||
ELSE NULL
|
||||
END
|
||||
ELSE NULL
|
||||
END AS lane_number
|
||||
FROM alarm_event_data
|
||||
WHERE propname = 'Tag' AND strvalue LIKE '%Chute%'
|
||||
),
|
||||
-- Pre-aggregate jam and full events separately to avoid cross-joins
|
||||
JamEvents AS (
|
||||
SELECT
|
||||
lm.lane_number,
|
||||
ad.event_uuid,
|
||||
ad.active_time,
|
||||
ad.clear_time
|
||||
FROM LaneMapping lm
|
||||
INNER JOIN AlarmData ad ON lm.record_id = ad.record_id
|
||||
INNER JOIN alarm_event_data aed ON ad.record_id = aed.id
|
||||
WHERE aed.propname = 'Jam' AND aed.strvalue = '1'
|
||||
),
|
||||
FullEvents AS (
|
||||
SELECT
|
||||
lm.lane_number,
|
||||
ad.event_uuid,
|
||||
ad.active_time,
|
||||
ad.clear_time
|
||||
FROM LaneMapping lm
|
||||
INNER JOIN AlarmData ad ON lm.record_id = ad.record_id
|
||||
INNER JOIN alarm_event_data aed ON ad.record_id = aed.id
|
||||
WHERE aed.propname = 'Full' AND aed.strvalue = '1'
|
||||
),
|
||||
Aggregated AS (
|
||||
SELECT
|
||||
CONCAT('S02_', dl.lane_number, 'CH') AS lane,
|
||||
COALESCE(j.jam_count, 0) AS jam_count,
|
||||
COALESCE(f.full_count, 0) AS full_count,
|
||||
COALESCE(j.jam_duration_seconds, 0) AS jam_duration_seconds,
|
||||
COALESCE(f.full_duration_seconds, 0) AS full_duration_seconds
|
||||
FROM DesiredLanes dl
|
||||
LEFT JOIN (
|
||||
SELECT
|
||||
lane_number,
|
||||
COUNT(DISTINCT event_uuid) AS jam_count,
|
||||
SUM(TIMESTAMPDIFF(SECOND, active_time, COALESCE(clear_time, NOW()))) AS jam_duration_seconds
|
||||
FROM JamEvents
|
||||
GROUP BY lane_number
|
||||
) j ON dl.lane_number = j.lane_number
|
||||
LEFT JOIN (
|
||||
SELECT
|
||||
lane_number,
|
||||
COUNT(DISTINCT event_uuid) AS full_count,
|
||||
SUM(TIMESTAMPDIFF(SECOND, active_time, COALESCE(clear_time, NOW()))) AS full_duration_seconds
|
||||
FROM FullEvents
|
||||
GROUP BY lane_number
|
||||
) f ON dl.lane_number = f.lane_number
|
||||
)
|
||||
SELECT
|
||||
lane,
|
||||
jam_count,
|
||||
full_count,
|
||||
COALESCE(SEC_TO_TIME(jam_duration_seconds), '00:00:00') AS jam_duration,
|
||||
COALESCE(SEC_TO_TIME(full_duration_seconds), '00:00:00') AS full_duration
|
||||
FROM Aggregated
|
||||
ORDER BY lane;
|
||||
@ -0,0 +1,46 @@
|
||||
{
|
||||
"scope": "DG",
|
||||
"version": 2,
|
||||
"restricted": false,
|
||||
"overridable": true,
|
||||
"files": [
|
||||
"query.sql"
|
||||
],
|
||||
"attributes": {
|
||||
"useMaxReturnSize": false,
|
||||
"autoBatchEnabled": false,
|
||||
"fallbackValue": "",
|
||||
"maxReturnSize": 100,
|
||||
"cacheUnit": "SEC",
|
||||
"type": "Query",
|
||||
"enabled": true,
|
||||
"cacheAmount": 1,
|
||||
"cacheEnabled": false,
|
||||
"database": "MariaDB",
|
||||
"fallbackEnabled": false,
|
||||
"lastModificationSignature": "85e4db79c801fef9b6b254b5156b0eac5a3f6c66ca2fea85c0616ce67592448a",
|
||||
"permissions": [
|
||||
{
|
||||
"zone": "",
|
||||
"role": ""
|
||||
}
|
||||
],
|
||||
"lastModification": {
|
||||
"actor": "admin",
|
||||
"timestamp": "2025-05-28T13:42:10Z"
|
||||
},
|
||||
"syntaxProvider": "class com.adbs.syntax.MySQLSyntaxProvider",
|
||||
"parameters": [
|
||||
{
|
||||
"type": "Parameter",
|
||||
"identifier": "startDate",
|
||||
"sqlType": 8
|
||||
},
|
||||
{
|
||||
"type": "Parameter",
|
||||
"identifier": "endDate",
|
||||
"sqlType": 8
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
Loading…
x
Reference in New Issue
Block a user