[144572] [MQ] Fixed unprocessed file count.

crss-metering/application-oracle-query.yml

@@ -51,6 +51,12 @@ mq:
                A.ERROR_DETAILS AS errorDetails
         FROM TXN_MQ_MANIFEST_FILE A INNER JOIN TXN_MQ_MANIFEST_HEADER B ON A.HEADER_ID = B.HEADER_ID
         WHERE B.HEADER_ID = :headerID
+      unprocessed: >
+        SELECT A.FILE_COUNT - COUNT(B.HEADER_ID) AS UNPROCESSED_COUNT
+        FROM TXN_MQ_MANIFEST_HEADER A
+        INNER JOIN TXN_MQ_MANIFEST_FILE B ON A.HEADER_ID = B.HEADER_ID
+        WHERE A.HEADER_ID = :headerID
+        GROUP BY A.HEADER_ID
     status: >
       UPDATE TXN_MQ_MANIFEST_FILE SET PROCESS_FLAG = 'Y', STATUS = :status, ERROR_DETAILS = :errorDetail, PROCESS_DATETIME = :processDateTime
       WHERE FILE_ID = :fileID

crss-metering/application-pg-query.yml

@@ -51,6 +51,12 @@ mq:
                A.ERROR_DETAILS AS errorDetails
         FROM TXN_MQ_MANIFEST_FILE A INNER JOIN TXN_MQ_MANIFEST_HEADER B ON A.HEADER_ID = B.HEADER_ID
         WHERE B.HEADER_ID = :headerID
+      unprocessed: >
+        SELECT A.FILE_COUNT - COUNT(B.HEADER_ID) AS UNPROCESSED_COUNT
+        FROM TXN_MQ_MANIFEST_HEADER A
+        INNER JOIN TXN_MQ_MANIFEST_FILE B ON A.HEADER_ID = B.HEADER_ID
+        WHERE A.HEADER_ID = :headerID
+        GROUP BY A.HEADER_ID
     status: >
       UPDATE TXN_MQ_MANIFEST_FILE SET PROCESS_FLAG = 'Y', STATUS = :status, ERROR_DETAILS = :errorDetail, PROCESS_DATETIME = :processDateTime
       WHERE FILE_ID = :fileID