Преглед на файлове

[138737] Scheduler for failed batch upload.

Chris Lim преди 9 години
родител
ревизия
d2b43bee55
променени са 2 файла, в които са добавени 6 реда и са изтрити 2 реда
  1. 3 1
      crss-metering/application-oracle-query.yml
  2. 3 1
      crss-metering/application-pg-query.yml

+ 3 - 1
crss-metering/application-oracle-query.yml

@@ -55,7 +55,9 @@ mq:
           f.header_id = h.header_id and h.header_id=:headerID
         GROUP BY h.header_id, h.upload_datetime
       notif.status: >
-        UPDATE TXN_MQ_MANIFEST_HEADER SET NOTIFICATION_SENT = 'Y', NOTIFICATION_DATETIME = :dateTime WHERE HEADER_ID = :headerID;
+        UPDATE TXN_MQ_MANIFEST_HEADER SET NOTIFICATION_SENT = 'Y', NOTIFICATION_DATETIME = :dateTime WHERE HEADER_ID = :headerID
+      notif.stale: >
+        SELECT HEADER_ID FROM TXN_MQ_MANIFEST_HEADER WHERE NOTIFICATION_SENT = 'N' AND UPLOAD_DATETIME < CURRENT_DATE
       notif.target.department: MSP,METERING
     filter-by.status: >
         select * from txn_mq_manifest_file where status=:status and header_id=:headerID

+ 3 - 1
crss-metering/application-pg-query.yml

@@ -55,7 +55,9 @@ mq:
           f.header_id = h.header_id and h.header_id=:headerID
         GROUP BY h.header_id, h.upload_datetime
       notif.status: >
-        UPDATE TXN_MQ_MANIFEST_HEADER SET NOTIFICATION_SENT = 'Y', NOTIFICATION_DATETIME = :dateTime WHERE HEADER_ID = :headerID;
+        UPDATE TXN_MQ_MANIFEST_HEADER SET NOTIFICATION_SENT = 'Y', NOTIFICATION_DATETIME = :dateTime WHERE HEADER_ID = :headerID
+      notif.stale: >
+        SELECT HEADER_ID FROM TXN_MQ_MANIFEST_HEADER WHERE NOTIFICATION_SENT = 'N' AND UPLOAD_DATETIME < CURRENT_DATE
       notif.target.department: MSP,METERING
     filter-by.status: >
         select * from txn_mq_manifest_file where status=:status and header_id=:headerID