From d417f29e323fedaaef1c305cb7a9f93f68083af4 Mon Sep 17 00:00:00 2001 From: Alex Zaw Date: Wed, 25 Feb 2026 23:06:03 +0000 Subject: [PATCH] Update Function SFP_GET_HOURLY_PRODUCTION --- .../Functions/SFP_GET_HOURLY_PRODUCTION.sql | 516 +++++++++++++++++- 1 file changed, 515 insertions(+), 1 deletion(-) diff --git a/RESTAPI/Functions/SFP_GET_HOURLY_PRODUCTION.sql b/RESTAPI/Functions/SFP_GET_HOURLY_PRODUCTION.sql index 84f42bd..80be8b6 100644 --- a/RESTAPI/Functions/SFP_GET_HOURLY_PRODUCTION.sql +++ b/RESTAPI/Functions/SFP_GET_HOURLY_PRODUCTION.sql @@ -1 +1,515 @@ -@@\@^@ % %@@@@Kmmm@M@ %m@M]@]@ %@M]@@@ %@@ %@Kmmm@ %@@ %@@@ %@@@@ %@@@@~@\@k@ %@~@\@k@ %@~@\@k@ %@~@Mk@k@]@k@ %@~@\@k@ %@~@\@k@ %@~@\@k@ %@~@\@@@ %@ %@@@M@@]@@}}@^@ %@m@@^@ %@mm@@M@@]@@}}@^@ %@m@@M@@]@@}}@^@ %@m@@M@@]@@}}@^@ %@mm@@M@@k@@]@@@^@ %@mmm@@M@@k@@]@@@^@ %@@@M@@]@@}}@^@ %@mm@@M@@@]@@}}@^@ %``@ř@@@ %@m@@M@@]@@}}@^@ %@m@@@@^@ %@m@@M@@]@@}}@^@ %@mm@@@@^@ %@mm@@@@^@ %``@Ö@@@@@ %@@@@@}}@@``@ɕ@@ %@ %@m@~@}}@^@ %@@@@m@~@m@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %@@@@@}}@@``@դ@@@@ %@ %@m@~@}}@^@ %@@@@m@~@m@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %@@@@@}}@@``@Ֆ@@@ %@ %@m@~@}}@^@ %@m@~@}Ֆ@@@@@@}@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %@@@@@}}@@``@Ֆ@@ %@ %@m@~@}}@^@ %@@@@m@~@m@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %@@@@@}}@@``@ւ@@@ %@ %@m@~@}}@^@ %@@@@m@~@m@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %@@@@@ %@ %@@@@ %m@~@m@k@ %m@~@mm@k@m@~@m@^@ %@mm@~@@^@ %@mm@~@@^@ %@^@ %``@ׁ@@@@M@@@@ɕmׁ]@ %@mm@~@@M@m@M@m@k@}[K}@]@k@}}@]@^@ %@m@~@@M@m@M@m@k@}[K}@ \ No newline at end of file +SET PATH *LIBL ; + +CREATE OR REPLACE FUNCTION RESTAPI.SFP_GET_HOURLY_PRODUCTION ( + IN_PARM CLOB(2147483647) ) + RETURNS CLOB(2147483647) + LANGUAGE SQL + SPECIFIC RESTAPI.SFP_GET_HOURLY_PRODUCTION + NOT DETERMINISTIC + MODIFIES SQL DATA + CALLED ON NULL INPUT + SET OPTION ALWBLK = *ALLREAD , + ALWCPYDTA = *OPTIMIZE , + COMMIT = *NONE , + DECRESULT = (31, 31, 00) , + DLYPRP = *NO , + DYNDFTCOL = *NO , + DYNUSRPRF = *USER , + SRTSEQ = *HEX + BEGIN +DECLARE ENV VARCHAR ( 20 ) DEFAULT '' ; +DECLARE V_DATE DATE ; +DECLARE V_DATE_STR VARCHAR ( 10 ) DEFAULT '' ; +DECLARE V_WC VARCHAR ( 5 ) DEFAULT '' ; +DECLARE V_SITE VARCHAR ( 3 ) DEFAULT '' ; +DECLARE V_DATE_CY DECIMAL ( 7 , 0 ) DEFAULT 0 ; +DECLARE V_DATE_PRIOR_CY DECIMAL ( 7 , 0 ) DEFAULT 0 ; +DECLARE LL VARCHAR ( 1024 ) DEFAULT '' ; +DECLARE V_IN_PARM CLOB ( 2 G ) DEFAULT '' ; +-- Error handling variables +DECLARE V_SQLSTATE CHAR ( 5 ) DEFAULT '00000' ; +DECLARE V_SQLCODE INTEGER DEFAULT 0 ; +DECLARE V_ERRMSG VARCHAR ( 500 ) DEFAULT '' ; +DECLARE V_HTTP_STATUS INTEGER DEFAULT 200 ; +DECLARE V_HAS_ERROR INTEGER DEFAULT 0 ; +-- Continue handlers for error capture +DECLARE CONTINUE HANDLER FOR SQLSTATE '22007' -- Invalid datetime +BEGIN +SET V_SQLSTATE = '22007' ; +GET DIAGNOSTICS CONDITION 1 V_ERRMSG = MESSAGE_TEXT ; +SET V_HTTP_STATUS = 400 ; +SET V_HAS_ERROR = 1 ; +END ; +DECLARE CONTINUE HANDLER FOR SQLSTATE '22003' -- Numeric out of range +BEGIN +SET V_SQLSTATE = '22003' ; +GET DIAGNOSTICS CONDITION 1 V_ERRMSG = MESSAGE_TEXT ; +SET V_HTTP_STATUS = 400 ; +SET V_HAS_ERROR = 1 ; +END ; +DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' -- No data found +BEGIN +SET V_SQLSTATE = '02000' ; +SET V_ERRMSG = 'No data found for the specified criteria' ; +SET V_HTTP_STATUS = 404 ; +SET V_HAS_ERROR = 1 ; +END ; +DECLARE CONTINUE HANDLER FOR SQLSTATE '42501' -- Not authorized +BEGIN +SET V_SQLSTATE = '42501' ; +GET DIAGNOSTICS CONDITION 1 V_ERRMSG = MESSAGE_TEXT ; +SET V_HTTP_STATUS = 403 ; +SET V_HAS_ERROR = 1 ; +END ; +DECLARE CONTINUE HANDLER FOR SQLSTATE '42704' -- Object not found +BEGIN +SET V_SQLSTATE = '42704' ; +GET DIAGNOSTICS CONDITION 1 V_ERRMSG = MESSAGE_TEXT ; +SET V_HTTP_STATUS = 404 ; +SET V_HAS_ERROR = 1 ; +END ; +DECLARE CONTINUE HANDLER FOR SQLEXCEPTION +BEGIN +GET DIAGNOSTICS CONDITION 1 +V_SQLSTATE = RETURNED_SQLSTATE , +V_SQLCODE = DB2_RETURNED_SQLCODE , V_ERRMSG = MESSAGE_TEXT ; +SET V_HTTP_STATUS = 500 ; +SET V_HAS_ERROR = 1 ; +END ; +-- Parse input parameters first (before env extraction modifies In_Parm) +SET V_DATE_STR = COALESCE ( JSON_VALUE ( IN_PARM , '$.date' ) , '' ) ; +SET V_WC = COALESCE ( JSON_VALUE ( IN_PARM , '$.workcenter' ) , '' ) ; +SET V_SITE = COALESCE ( JSON_VALUE ( IN_PARM , '$.site' ) , '' ) ; +-- Parse date - set to Current_Date if not provided +IF V_DATE_STR <> '' THEN +SET V_DATE = DATE ( V_DATE_STR ) ; +ELSE +SET V_DATE = CURRENT_DATE ; +END IF ; +-- Extract env handling all input formats (object, array, string) +SET V_IN_PARM = IN_PARM ; +WHILE CISTOOLS . JSON_TYPE ( V_IN_PARM ) IN ( 'object' , 'array' , 'string' ) +DO +SET V_IN_PARM = +CASE CISTOOLS . JSON_TYPE ( V_IN_PARM ) +WHEN 'object' THEN JSON_VALUE ( V_IN_PARM , '$.env' ) +WHEN 'array' THEN JSON_VALUE ( V_IN_PARM , '$[0]' ) +WHEN 'string' THEN REPLACE ( V_IN_PARM , '"' , '' ) +ELSE TRIM ( V_IN_PARM ) +END ; +END WHILE ; +SET ENV = V_IN_PARM ; +SET LL = CISTOOLS . SET_LIBRARY_LIST ( ENV ) ; +-- Validate environment was set +IF ENV = '' +OR ENV IS NULL THEN +RETURN +JSON_OBJECT ( +'error' : JSON_OBJECT ( +'http_status' : 400 , 'sqlstate' : '22001' , +'message' : 'Environment parameter is required' +) +) ; +END IF ; +-- Check for errors from library list setup +IF V_HAS_ERROR = 1 THEN +RETURN +JSON_OBJECT ( +'error' : JSON_OBJECT ( +'http_status' : V_HTTP_STATUS , 'sqlstate' : V_SQLSTATE , +'message' : V_ERRMSG +) +) ; +END IF ; +-- Calculate CYYMMDD dates +SET V_DATE_CY = ZONED ( V_DATE ) - 19000000 ; +SET V_DATE_PRIOR_CY = ZONED ( V_DATE - 1 DAY ) - 19000000 ; +RETURN +WITH +-- Get ON transactions (job starts) +ON_TRANSACTIONS AS ( +SELECT T . ORDNO , T . CLDT , T . OPSEQ , T . EMPNO , T . BADGE , T . WKCTR , +T . TDATE AS ON_DATE , T . TTIME AS ON_TIME , T . RUNCD , +T . ITNBR , COALESCE ( T . EMPNO , T . BADGE ) AS EMP_KEY , +M . STID , +TO_DATE ( +ZONED ( CISTOOLS . CYMD2DATE ( T . TDATE ) ) || +LPAD ( T . TTIME , 6 , '0' ) , 'YYYYMMDDHH24MISS' ) +AS ON_TS , +ROW_NUMBER ( ) OVER ( +PARTITION BY T . ORDNO , T . OPSEQ , COALESCE ( +T . EMPNO , T . BADGE ) , T . RUNCD +ORDER BY T . TDATE , T . TTIME +) AS SEQ +FROM MOTRAN T +JOIN MOMAST M +ON T . ORDNO = M . ORDNO +WHERE T . TCODE = 'ON' +AND T . WKCTR = COALESCE ( NULLIF ( V_WC , '' ) , T . WKCTR ) +AND M . STID = COALESCE ( NULLIF ( V_SITE , '' ) , M . STID ) +AND T . ACREC = 'A' +AND T . TDATE BETWEEN V_DATE_PRIOR_CY AND V_DATE_CY +) , +-- Get OFF transactions (job ends with quantities) +OFF_TRANSACTIONS AS ( +SELECT T . ORDNO , T . CLDT , T . OPSEQ , T . EMPNO , T . BADGE , +T . TDATE AS OFF_DATE , T . TTIME AS OFF_TIME , T . QTCOM , +T . QTSCP , T . RUNCD , T . WKCTR , +COALESCE ( T . EMPNO , T . BADGE ) AS EMP_KEY , M . STID , +TO_DATE ( +ZONED ( CISTOOLS . CYMD2DATE ( T . TDATE ) ) || +LPAD ( T . TTIME , 6 , '0' ) , 'YYYYMMDDHH24MISS' ) +AS OFF_TS , +ROW_NUMBER ( ) OVER ( +PARTITION BY T . ORDNO , T . OPSEQ , COALESCE ( +T . EMPNO , T . BADGE ) , T . RUNCD +ORDER BY T . TDATE , T . TTIME +) AS SEQ +FROM MOTRAN T +JOIN MOMAST M +ON T . ORDNO = M . ORDNO +WHERE T . TCODE = 'OF' +AND T . WKCTR = COALESCE ( NULLIF ( V_WC , '' ) , T . WKCTR ) +AND M . STID = COALESCE ( NULLIF ( V_SITE , '' ) , M . STID ) +AND T . ACREC = 'A' +AND T . TDATE = V_DATE_CY +) , +-- Current time as default end time +CURRENT_END AS ( +SELECT +CASE +WHEN V_DATE = CURRENT_DATE THEN CURRENT_TIMESTAMP +ELSE +TO_DATE ( +ZONED ( V_DATE ) || '235959' , 'YYYYMMDDHH24MISS' ) +END AS DEFAULT_END_TS +FROM SYSIBM . SYSDUMMY1 +) , +-- Match ON with OF by order/operation/employee/runcode +MATCHED_TRANS AS ( +SELECT ON_T . ORDNO , ON_T . ITNBR , ON_T . RUNCD , ON_T . ON_DATE , +ON_T . ON_TIME , ON_T . ON_TS AS START_TS , ON_T . WKCTR , +ON_T . STID , +COALESCE ( OFF_T . OFF_TS , CE . DEFAULT_END_TS ) AS END_TS , +COALESCE ( OFF_T . OFF_DATE , V_DATE_CY ) AS OFF_DATE , +COALESCE ( +OFF_T . OFF_TIME , +CASE +WHEN +V_DATE = CURRENT_DATE +THEN ZONED ( CURRENT_TIME ) +ELSE 235959 +END ) AS OFF_TIME , +COALESCE ( OFF_T . QTCOM , 0 ) AS QTY_COMPLETE , +COALESCE ( OFF_T . QTSCP , 0 ) AS QTY_SCRAP , +COALESCE ( R . SRLHU , 0 ) AS STD_RUN_HRS , +COALESCE ( R . TBCDE , ' ' ) AS TIME_BASIS +FROM ON_TRANSACTIONS ON_T +CROSS JOIN CURRENT_END CE +LEFT JOIN OFF_TRANSACTIONS OFF_T +ON ON_T . ORDNO = OFF_T . ORDNO +AND ON_T . OPSEQ = OFF_T . OPSEQ +AND ON_T . EMP_KEY = OFF_T . EMP_KEY +AND ON_T . RUNCD = OFF_T . RUNCD +AND ON_T . SEQ = OFF_T . SEQ +AND ON_T . WKCTR = OFF_T . WKCTR +AND ON_T . STID = OFF_T . STID +LEFT JOIN MOROUT R +ON ON_T . ORDNO = R . ORDNO +AND ON_T . OPSEQ = R . OPSEQ +WHERE ON_T . RUNCD = 'R' -- Run transactions only +) , +-- Calculate pieces per minute +TRANS_WITH_RATE AS ( +SELECT M . * , +DEC ( +CASE +TIME_BASIS +WHEN +' ' +THEN +CASE +WHEN +STD_RUN_HRS > 0 +THEN 1.0 / STD_RUN_HRS / 60 +ELSE 0 +END +WHEN 'P' THEN STD_RUN_HRS / 60 +WHEN +'M' +THEN +CASE +WHEN +STD_RUN_HRS > 0 +THEN 1.0 / STD_RUN_HRS +ELSE 0 +END +WHEN +'1' +THEN +CASE +WHEN +STD_RUN_HRS > 0 +THEN 10.0 / STD_RUN_HRS / 60 +ELSE 0 +END +WHEN +'2' +THEN +CASE +WHEN +STD_RUN_HRS > 0 +THEN 100.0 / STD_RUN_HRS / 60 +ELSE 0 +END +WHEN +'3' +THEN +CASE +WHEN +STD_RUN_HRS > 0 +THEN 1000.0 / STD_RUN_HRS / 60 +ELSE 0 +END +ELSE 0 +END , 15 , 8 ) AS PCS_PER_MIN +FROM MATCHED_TRANS M +) , +-- Get distinct workcenter/site combinations +WC_SITE_LIST AS ( +SELECT DISTINCT WKCTR , STID +FROM TRANS_WITH_RATE +) , +-- Generate hours for the date (0-23) with proper timestamps +ALL_HOURS AS ( +SELECT HR AS HOUR_NUM , +TO_DATE ( +ZONED ( V_DATE ) || LPAD ( HR * 10000 , 6 , '0' ) , +'YYYYMMDDHH24MISS' ) AS HR_START_TS , +CASE +WHEN +HR = 23 +THEN +TO_DATE ( +ZONED ( V_DATE + 1 DAY ) || '000000' , +'YYYYMMDDHH24MISS' ) +ELSE +TO_DATE ( +ZONED ( V_DATE ) || +LPAD ( ( HR + 1 ) * 10000 , 6 , '0' ) , +'YYYYMMDDHH24MISS' ) +END AS HR_END_TS +FROM ( +VALUES ( 0 ) , ( 1 ) , ( 2 ) , ( 3 ) , ( 4 ) , ( 5 ) , ( 6 ) , ( 7 ) , ( 8 ) ,( 9 ) , ( 10 ) , ( 11 ) , ( 12 ) , ( 13 ) , ( 14 ) , ( 15 ) , +( 16 ) , ( 17 ) , ( 18 ) , ( 19 ) , ( 20 ) , ( 21 ) , ( 22 ) , +( 23 ) +) T ( HR ) +) , +-- Calculate time per hour for each transaction +HOURLY_BREAKDOWN AS ( +SELECT T . ORDNO , T . ITNBR , T . QTY_COMPLETE , T . QTY_SCRAP , +T . PCS_PER_MIN , T . START_TS , T . END_TS , T . OFF_DATE , +T . OFF_TIME , T . WKCTR , T . STID , H . HOUR_NUM , +GREATEST ( +0 , TIMESTAMPDIFF ( +2 , CHAR ( +LEAST ( T . END_TS , H . HR_END_TS ) - +GREATEST ( T . START_TS , H . HR_START_TS ) ) ) ) +AS SECONDS_IN_HR +FROM TRANS_WITH_RATE T , ALL_HOURS H +WHERE T . START_TS < H . HR_END_TS +AND T . END_TS > H . HR_START_TS +) , +-- Aggregate by hour, workcenter, site +HOURLY_AGG AS ( +SELECT HOUR_NUM , WKCTR , STID , +SUM ( SECONDS_IN_HR ) AS TOTAL_SECONDS , +DEC ( +SUM ( DEC ( SECONDS_IN_HR , 15 , 4 ) * PCS_PER_MIN / 60 ) , +15 , 4 ) AS EXPECTED_QTY , +SUM ( +CASE +WHEN +HOUR ( +TO_DATE ( +ZONED ( CISTOOLS . CYMD2DATE ( OFF_DATE ) ) || +LPAD ( OFF_TIME , 6 , '0' ) , +'YYYYMMDDHH24MISS' ) ) = HOUR_NUM +AND CISTOOLS . CYMD2DATE ( OFF_DATE ) = V_DATE +THEN QTY_COMPLETE +ELSE 0 +END ) AS ACTUAL_QTY , +SUM ( +CASE +WHEN +HOUR ( +TO_DATE ( +ZONED ( CISTOOLS . CYMD2DATE ( OFF_DATE ) ) || +LPAD ( OFF_TIME , 6 , '0' ) , +'YYYYMMDDHH24MISS' ) ) = HOUR_NUM +AND CISTOOLS . CYMD2DATE ( OFF_DATE ) = V_DATE +THEN QTY_SCRAP +ELSE 0 +END ) AS SCRAP_QTY , +COUNT ( DISTINCT ORDNO ) AS ORDER_COUNT +FROM HOURLY_BREAKDOWN +WHERE SECONDS_IN_HR > 0 +GROUP BY HOUR_NUM , WKCTR , STID +) , +-- Get distinct order/item per hour/wkctr/stid +HOURLY_ITEMS AS ( +SELECT DISTINCT HOUR_NUM , WKCTR , STID , ORDNO , ITNBR +FROM HOURLY_BREAKDOWN +WHERE SECONDS_IN_HR > 0 +) , +-- Aggregate items into JSON array +HOURLY_ITEMS_AGG AS ( +SELECT HOUR_NUM , WKCTR , STID , +JSON_ARRAYAGG ( +JSON_OBJECT ( +'orderNumber' : CAST ( +CAST ( TRIM ( ORDNO ) AS VARCHAR ( 15 ) CCSID 37 ) AS +VARCHAR ( 15 ) CCSID 1208 ) , 'itemNumber' : CAST ( +CAST ( TRIM ( ITNBR ) AS VARCHAR ( 15 ) CCSID 37 ) AS +VARCHAR ( 15 ) CCSID 1208 ) +) FORMAT JSON +) AS ITEMS +FROM HOURLY_ITEMS +GROUP BY HOUR_NUM , WKCTR , STID +) , +-- Cross join hours with workcenter/site list, then left join aggregated data +HOURLY_FULL AS ( +SELECT A . HOUR_NUM , W . WKCTR , W . STID , +COALESCE ( H . TOTAL_SECONDS , 0 ) AS TOTAL_SECONDS , +COALESCE ( H . EXPECTED_QTY , DEC ( 0 , 15 , 4 ) ) +AS EXPECTED_QTY , +COALESCE ( H . ACTUAL_QTY , DEC ( 0 , 15 , 4 ) ) AS ACTUAL_QTY , +COALESCE ( H . SCRAP_QTY , DEC ( 0 , 15 , 4 ) ) AS SCRAP_QTY , +COALESCE ( H . ORDER_COUNT , 0 ) AS ORDER_COUNT , +I . ITEMS AS ITEMS , +SUM ( COALESCE ( H . EXPECTED_QTY , DEC ( 0 , 15 , 4 ) ) ) OVER ( +PARTITION BY W . WKCTR , W . STID +ORDER BY A . HOUR_NUM ROWS UNBOUNDED PRECEDING +) AS CUM_EXPECTED , +SUM ( COALESCE ( H . ACTUAL_QTY , DEC ( 0 , 15 , 4 ) ) ) OVER ( +PARTITION BY W . WKCTR , W . STID +ORDER BY A . HOUR_NUM ROWS UNBOUNDED PRECEDING +) AS CUM_ACTUAL , +SUM ( COALESCE ( H . SCRAP_QTY , DEC ( 0 , 15 , 4 ) ) ) OVER ( +PARTITION BY W . WKCTR , W . STID +ORDER BY A . HOUR_NUM ROWS UNBOUNDED PRECEDING +) AS CUM_SCRAP +FROM ALL_HOURS A +CROSS JOIN WC_SITE_LIST W +LEFT JOIN HOURLY_AGG H +ON A . HOUR_NUM = H . HOUR_NUM +AND W . WKCTR = H . WKCTR +AND W . STID = H . STID +LEFT JOIN HOURLY_ITEMS_AGG I +ON A . HOUR_NUM = I . HOUR_NUM +AND W . WKCTR = I . WKCTR +AND W . STID = I . STID +) , +-- Build hour JSON objects +JSON_HOURS AS ( +SELECT WKCTR , STID , +JSON_OBJECT ( +'hour' : HOUR_NUM , 'hourLabel' : +CASE +WHEN HOUR_NUM = 0 THEN '12AM' +WHEN +HOUR_NUM < 12 THEN VARCHAR ( HOUR_NUM ) || 'AM' +WHEN HOUR_NUM = 12 THEN '12PM' +ELSE VARCHAR ( HOUR_NUM - 12 ) || 'PM' +END , 'runMinutes' : INT ( TOTAL_SECONDS / 60 ) , +'items' : COALESCE ( ITEMS , JSON_ARRAY ( ) ) FORMAT JSON , +'orderCount' : ORDER_COUNT , 'expectedQty' : DEC ( +EXPECTED_QTY , 10 , 2 ) , 'actualQty' : DEC ( +ACTUAL_QTY , 10 , 2 ) , 'scrapQty' : DEC ( +SCRAP_QTY , 10 , 2 ) , 'cumulativeExpected' : DEC ( +CUM_EXPECTED , 10 , 2 ) , 'cumulativeActual' : DEC ( +CUM_ACTUAL , 10 , 2 ) , 'cumulativeScrap' : DEC ( +CUM_SCRAP , 10 , 2 ) , 'variance' : DEC ( +CUM_ACTUAL - CUM_EXPECTED , 10 , 2 ) , +'performancePercentage' : +CASE +WHEN +CUM_EXPECTED > 0 +THEN +INT ( +( CUM_ACTUAL / CUM_EXPECTED * 100 ) + +0.5 ) +ELSE 0 +END +) AS HOUR_OBJ , HOUR_NUM +FROM HOURLY_FULL +) , +-- Calculate totals per workcenter/site +WC_TOTALS AS ( +SELECT WKCTR , STID , MAX ( CUM_ACTUAL ) AS TOTAL_ACTUAL , +MAX ( CUM_EXPECTED ) AS TOTAL_EXPECTED , +MAX ( CUM_SCRAP ) AS TOTAL_SCRAP +FROM HOURLY_FULL +GROUP BY WKCTR , STID +) , +-- Build workcenter JSON objects with nested hours array +JSON_WORKCENTERS AS ( +SELECT +JSON_OBJECT ( +'workcenter' : CAST ( +CAST ( T . WKCTR AS VARCHAR ( 5 ) CCSID 37 ) AS VARCHAR ( +5 ) CCSID 1208 ) , 'site' : CAST ( +CAST ( T . STID AS VARCHAR ( 3 ) CCSID 37 ) AS VARCHAR ( 3 ) +CCSID 1208 ) , 'hours' : ( SELECT JSON_ARRAYAGG ( +H . HOUR_OBJ FORMAT JSON +ORDER BY H . HOUR_NUM +) +FROM JSON_HOURS H +WHERE H . WKCTR = T . WKCTR +AND H . STID = T . STID ) FORMAT JSON , +'totals' : JSON_OBJECT ( +'actualQty' : DEC ( +COALESCE ( T . TOTAL_ACTUAL , DEC ( 0 , 15 , 4 ) ) , 10 , +2 ) , 'expectedQty' : DEC ( +COALESCE ( T . TOTAL_EXPECTED , DEC ( 0 , 15 , 4 ) ) , 10 , +2 ) , +'scrapQty' : DEC ( +COALESCE ( T . TOTAL_SCRAP , DEC ( 0 , 15 , 4 ) ) , 10 , 2 +) , 'variance' : DEC ( +COALESCE ( +T . TOTAL_ACTUAL - T . TOTAL_EXPECTED , DEC ( +0 , 15 , 4 ) ) , 10 , 2 ) , +'performancePercentage' : +CASE +WHEN +T . TOTAL_EXPECTED > 0 +THEN +INT ( +( T . TOTAL_ACTUAL / T . TOTAL_EXPECTED * +100 ) + 0.5 ) +ELSE 0 +END +) +) AS WC_OBJ +FROM WC_TOTALS T +ORDER BY T . WKCTR , T . STID ) SELECT JSON_ARRAY ( +JSON_OBJECT ( +'date' : TO_CHAR ( V_DATE , 'YYYY-MM-DD' ) , 'workcenters' : ( +SELECT JSON_ARRAYAGG ( +WC_OBJ FORMAT JSON +) +FROM JSON_WORKCENTERS ) FORMAT JSON , +'dataSource' : 'MOTRAN (Live)' , 'generatedAt' : TO_CHAR ( +CURRENT_TIMESTAMP , 'YYYY-MM-DD HH24:MI:SS' ) +) ) +FROM SYSIBM . SYSDUMMY1 ; +END ; + +GRANT ALTER , EXECUTE +ON SPECIFIC FUNCTION RESTAPI.SFP_GET_HOURLY_PRODUCTION +TO AMAPICS WITH GRANT OPTION ; + +GRANT EXECUTE +ON SPECIFIC FUNCTION RESTAPI.SFP_GET_HOURLY_PRODUCTION +TO PUBLIC ; +