Organize metering service config

  - rename from <app.name>-[<profile>].yml to application.yml
    since it was already group by folder and searchPaths already
    set to '{application}'
  - separate query for each database to easily diff the changes of
    this 2 files
  - remove duplicate configurations

crss-metering/application-dev.yml

@@ -0,0 +1,43 @@
+spring:
+  profiles.include: pg-query
+  datasource:
+    url: jdbc:postgresql://localhost:5432/crss_metering
+    username: crss_metering
+    password: crss_metering
+    driverClassName: org.postgresql.Driver
+    hikari:
+      connectionTimeout: 10000
+      maximumPoolSize: 20
+  jpa:
+    database: POSTGRESQL
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.PostgreSQL94Dialect
+
+server:
+  port: 8084
+
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://localhost:8761/eureka/
+
+security:
+  oauth2:
+    client:
+      accessTokenUri: http://localhost:8082/oauth/access_token
+      userAuthorizationUri: http://localhost:8082/oauth/authorize
+      clientId: crss
+      clientSecret: crsssecret
+      authorized-grant-types: authorization_code,refresh_token,password
+      scope: openid
+      access-token-validity-seconds: 3600
+    resource:
+      userInfoUri: http://localhost:8082/user
+
+logging:
+  level:
+    com.pemc: DEBUG
+    com.netflix: WARN
+    org.springframework.cloud: WARN
+    org.hibernate.SQL: DEBUG

crss-metering/crss-metering.yml → crss-metering/application-oracle-query.yml

@@ -1,74 +1,3 @@
-spring:
-  datasource:
-    platform: oracle
-    url: jdbc:oracle:thin:@192.168.235.6:1521:ORCL
-    username: crss_metering
-    password: crss_metering
-    driverClassName: oracle.jdbc.OracleDriver
-    hikari:
-      connectionTimeout: 10000
-      maximumPoolSize: 20
-  jpa:
-    database: ORACLE
-    properties:
-      hibernate:
-        dialect: org.hibernate.dialect.Oracle10gDialect
-  rabbitmq:
-    host: pemc-oracle.ss.exist.com
-    ports:
-      - "5672:5672"
-      - "15672:15672"
-  http:
-    multipart:
-      enabled: true
-      maxFileSize: 5MB
-      maxRequestSize: 5MB
-      fileSizeThreshold: 5MB
-      resolveLazily: false
-
-server:
-  port: 8080
-  undertow:
-    accesslog:
-      dir: target
-      enabled: true
-      pattern: combined
-  compression:
-    enabled: true
-    min-response-size: 1
-
-eureka:
-  client:
-    serviceUrl:
-      defaultZone: http://discovery:8080/eureka/
-      #    healthcheck:
-      #      enabled: true
-#    lease:
-#      duration: 5
-#  instance:
-#    leaseRenewalIntervalInSeconds: 1
-#    leaseExpirationDurationInSeconds: 2
-
-security:
-  oauth2:
-    client:
-      accessTokenUri: http://app:8080/admin/oauth/access_token
-      userAuthorizationUri: http://app:8080/admin/oauth/authorize
-      clientId: crss
-      clientSecret: crsssecret
-      authorized-grant-types: authorization_code,refresh_token,password
-      scope: openid
-      access-token-validity-seconds: 3600
-    resource:
-      userInfoUri: http://app:8080/admin/user
-
-logging:
-  level:
-    com.pemc: DEBUG
-    com.netflix: WARN
-    org.springframework.cloud: WARN
-    org.hibernate.SQL: DEBUG
-
 mq:
   manifest:
     header:

crss-metering/crss-metering-dev.yml → crss-metering/application-pg-query.yml

@@ -1,61 +1,3 @@
-spring:
-  datasource:
-    url: jdbc:postgresql://localhost:5432/crss_metering
-    username: crss_metering
-    password: crss_metering
-    driverClassName: org.postgresql.Driver
-    hikari:
-      connectionTimeout: 10000
-      maximumPoolSize: 20
-  jpa:
-    database: POSTGRESQL
-    properties:
-      hibernate:
-        dialect: org.hibernate.dialect.PostgreSQL94Dialect
-  rabbitmq:
-    username: guest
-    password: guest
-    host: localhost
-    ports:
-      - "5672:5672"
-      - "15672:15672"
-
-server:
-  port: 8084
-  undertow:
-    accesslog:
-      dir: target
-      enabled: true
-      pattern: combined
-  compression:
-    enabled: true
-    min-response-size: 1
-
-eureka:
-  client:
-    serviceUrl:
-      defaultZone: http://localhost:8761/eureka/
-      #    healthcheck:
-      #      enabled: true
-#    lease:
-#      duration: 5
-#  instance:
-#    leaseRenewalIntervalInSeconds: 1
-#    leaseExpirationDurationInSeconds: 2
-
-security:
-  oauth2:
-    client:
-      accessTokenUri: http://localhost:8082/oauth/access_token
-      userAuthorizationUri: http://localhost:8082/oauth/authorize
-      clientId: crss
-      clientSecret: crsssecret
-      authorized-grant-types: authorization_code,refresh_token,password
-      scope: openid
-      access-token-validity-seconds: 3600
-    resource:
-      userInfoUri: http://localhost:8082/user
-
 mq:
   manifest:
     header:
@@ -64,12 +6,55 @@ mq:
         VALUES (
           NEXTVAL('MQ_MANIFEST_HEADER_SEQ'), :transactionID, :fileCount, 'N', :category, :uploadedBy, :uploadDateTime
         )
+      query: >
+        SELECT HEADER_ID AS headerID, TRANSACTION_ID AS transactionID, FILE_COUNT AS fileCount, CATEGORY AS category,
+        TAIL_RECEIVED AS tailReceived
+        FROM TXN_MQ_MANIFEST_HEADER WHERE HEADER_ID = :headerID
+    trailer:
+      update: >
+        UPDATE TXN_MQ_MANIFEST_HEADER SET TAIL_RECEIVED = 'Y' WHERE HEADER_ID = :headerID
     file:
       insert: >
         INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype, filesize, checksum, upload_datetime)
         VALUES (
           NEXTVAL('MQ_MANIFEST_FILE_SEQ'), :headerID, :transactionID, :fileName, :fileType, :fileSize, :checksum, :uploadDateTime
         )
+      query: >
+        SELECT A.FILE_ID as fileID,
+               A.HEADER_ID AS headerID,
+               A.TRANSACTION_ID AS transactionID,
+               A.FILENAME,
+               A.FILETYPE,
+               A.FILESIZE,
+               A.CHECKSUM,
+               A.UPLOAD_DATETIME AS uploadDateTime,
+               A.PROCESS_FLAG AS processFlag,
+               A.STATUS,
+               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
+    status: >
+      UPDATE TXN_MQ_MANIFEST_FILE SET PROCESS_FLAG = 'Y', STATUS = :status, ERROR_DETAILS = :errorDetail WHERE FILE_ID = :fileID
+    upload:
+      status: >
+         select count(*) from txn_mq_manifest_header h
+         where
+           file_count=(
+             select count(*) from txn_mq_manifest_file
+               where header_id=h.header_id and process_flag='Y')
+           and header_id=:headerID
+      report: >
+       select h.header_id as headerID, h.upload_by as uploadedBy, h.upload_datetime as uploadDateTime,
+          sum(case when status='ACCEPTED' then 1 else 0 end) as acceptedFileCount,
+          sum(case when status='REJECTED' then 1 else 0 end) as rejectedFileCount
+        from
+          txn_mq_manifest_header h, txn_mq_manifest_file f
+        where
+          f.header_id = h.header_id and h.header_id=:headerID
+        GROUP BY h.header_id, h.upload_datetime
+      notif.target.department: MSP,METERING
+    filter-by.status: >
+        select * from txn_mq_manifest_file where status=:status and header_id=:headerID
   meter:
     daily:
       insert: >

crss-metering/application-staging.yml

@@ -0,0 +1,34 @@
+spring:
+  profiles.include: pg-query
+  datasource:
+    url: jdbc:postgresql://192.168.241.62:5432/crss_metering
+    username: crss_metering
+    password: crss_metering
+    driverClassName: org.postgresql.Driver
+    hikari:
+      connectionTimeout: 10000
+      maximumPoolSize: 20
+  jpa:
+    database: POSTGRESQL
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.PostgreSQL94Dialect
+  rabbitmq:
+    host: 192.168.241.62
+
+security:
+  oauth2:
+    client:
+      accessTokenUri: http://app:8080/admin/oauth/access_token
+      userAuthorizationUri: http://app:8080/admin/oauth/authorize
+      clientId: crss
+      clientSecret: crsssecret
+      authorized-grant-types: authorization_code,refresh_token,password
+      scope: openid
+      access-token-validity-seconds: 3600
+    resource:
+      userInfoUri: http://app:8080/admin/user
+
+# currently staging and uat shared in one graylog which is not good
+#graylog:
+#  host: pemc.integration.exist.com

crss-metering/application-uat.yml

@@ -0,0 +1,33 @@
+spring:
+  profiles.include: pg-query
+  datasource:
+    url: jdbc:postgresql://192.168.235.6:5432/crss_metering
+    username: crss_metering
+    password: crss_metering
+    driverClassName: org.postgresql.Driver
+    hikari:
+      connectionTimeout: 10000
+      maximumPoolSize: 20
+  jpa:
+    database: POSTGRESQL
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.PostgreSQL94Dialect
+  rabbitmq:
+    host: pemc-oracle.ss.exist.com
+
+security:
+  oauth2:
+    client:
+      accessTokenUri: http://app:8080/admin/oauth/access_token
+      userAuthorizationUri: http://app:8080/admin/oauth/authorize
+      clientId: crss
+      clientSecret: crsssecret
+      authorized-grant-types: authorization_code,refresh_token,password
+      scope: openid
+      access-token-validity-seconds: 3600
+    resource:
+      userInfoUri: http://app:8080/admin/user
+
+graylog:
+  host: pemc.integration.exist.com

crss-metering/application.yml

@@ -0,0 +1,29 @@
+spring:
+  http.multipart:
+    enabled: true
+    maxFileSize: 5MB
+    maxRequestSize: 5MB
+    fileSizeThreshold: 5MB
+    resolveLazily: false
+
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://localhost:8761/eureka/
+#    healthcheck:
+      #      enabled: true
+#    lease:
+#      duration: 5
+#  instance:
+#    leaseRenewalIntervalInSeconds: 1
+#    leaseExpirationDurationInSeconds: 2
+
+server:
+  undertow:
+    accesslog:
+      dir: target
+      enabled: true
+      pattern: combined
+  compression:
+    enabled: true
+    min-response-size: 1

crss-metering/crss-metering-devoracle.yml

@@ -1,45 +0,0 @@
-# Experimental configuration to run metering in a developer's environment connecting to some staging services (database and messaging)
-spring:
-  rabbitmq:
-    username: guest
-    password: guest
-    host: localhost
-    ports:
-      - "5672:5672"
-      - "15672:15672"
-
-server:
-  port: 8084
-  undertow:
-    accesslog:
-      dir: target
-      enabled: true
-      pattern: combined
-  compression:
-    enabled: true
-    min-response-size: 1
-
-eureka:
-  client:
-    serviceUrl:
-      defaultZone: http://localhost:8761/eureka/
-      #    healthcheck:
-      #      enabled: true
-#    lease:
-#      duration: 5
-#  instance:
-#    leaseRenewalIntervalInSeconds: 1
-#    leaseExpirationDurationInSeconds: 2
-
-security:
-  oauth2:
-    client:
-      accessTokenUri: http://localhost:8082/oauth/access_token
-      userAuthorizationUri: http://localhost:8082/oauth/authorize
-      clientId: crss
-      clientSecret: crsssecret
-      authorized-grant-types: authorization_code,refresh_token,password
-      scope: openid
-      access-token-validity-seconds: 3600
-    resource:
-      userInfoUri: http://localhost:8082/user

crss-metering/crss-metering-staging.yml

@@ -1,184 +0,0 @@
-spring:
-  datasource:
-    url: jdbc:postgresql://192.168.241.62:5432/crss_metering
-    username: crss_metering
-    password: crss_metering
-    driverClassName: org.postgresql.Driver
-    hikari:
-      connectionTimeout: 10000
-      maximumPoolSize: 20
-  jpa:
-    database: POSTGRESQL
-    properties:
-      hibernate:
-        dialect: org.hibernate.dialect.PostgreSQL94Dialect
-
-graylog:
-  host: pemc.integration.exist.com
-
-mq:
-  manifest:
-    header:
-      insert: >
-        INSERT INTO TXN_MQ_MANIFEST_HEADER (HEADER_ID, TRANSACTION_ID, FILE_COUNT, TAIL_RECEIVED, CATEGORY, UPLOAD_BY, UPLOAD_DATETIME)
-        VALUES (
-          NEXTVAL('MQ_MANIFEST_HEADER_SEQ'), :transactionID, :fileCount, 'N', :category, :uploadedBy, :uploadDateTime
-        )
-    file:
-      insert: >
-        INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype, filesize, checksum, upload_datetime)
-        VALUES (
-          NEXTVAL('MQ_MANIFEST_FILE_SEQ'), :headerID, :transactionID, :fileName, :fileType, :fileSize, :checksum, :uploadDateTime
-        )
-  meter:
-    daily:
-      insert: >
-        INSERT INTO TXN_METER_DATA_DAILY (
-          METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
-          KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
-          KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
-          KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
-          KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
-          KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
-          KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
-          VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
-          VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
-          VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
-          IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
-          IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
-          ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
-          PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
-          ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
-        VALUES (
-          NEXTVAL('MQ_DATA_DAILY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
-          :kwd, :kwdChannelStatus, :kwdIntervalStatus,
-          :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
-          :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
-          :kwr, :kwrChannelStatus, :kwrIntervalStatus,
-          :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
-          :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
-          :van, :vanChannelStatus, :vanIntervalStatus,
-          :vbn, :vbnChannelStatus, :vbnIntervalStatus,
-          :vcn, :vcnChannelStatus, :vcnIntervalStatus,
-          :ian, :ianChannelStatus, :ianIntervalStatus,
-          :ibn, :ibnChannelStatus, :ibnIntervalStatus,
-          :icn, :icnChannelStatus, :icnIntervalStatus,
-          :pf, :pfChannelStatus, :pfIntervalStatus,
-          :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
-    monthly:
-      insert: >
-        INSERT INTO TXN_METER_DATA_MONTHLY (
-          METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
-          KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
-          KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
-          KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
-          KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
-          KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
-          KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
-          VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
-          VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
-          VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
-          IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
-          IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
-          ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
-          PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
-          ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
-        VALUES (
-          NEXTVAL('MQ_DATA_MONTHLY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
-          :kwd, :kwdChannelStatus, :kwdIntervalStatus,
-          :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
-          :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
-          :kwr, :kwrChannelStatus, :kwrIntervalStatus,
-          :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
-          :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
-          :van, :vanChannelStatus, :vanIntervalStatus,
-          :vbn, :vbnChannelStatus, :vbnIntervalStatus,
-          :vcn, :vcnChannelStatus, :vcnIntervalStatus,
-          :ian, :ianChannelStatus, :ianIntervalStatus,
-          :ibn, :ibnChannelStatus, :ibnIntervalStatus,
-          :icn, :icnChannelStatus, :icnIntervalStatus,
-          :pf, :pfChannelStatus, :pfIntervalStatus,
-          :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
-bcq:
-  manifest: >
-    INSERT INTO TXN_BCQ_UPLOAD_FILE (
-      FILE_ID,
-      TRANSACTION_ID,
-      FILE_NAME,
-      FILE_SIZE,
-      SUBMITTED_DATE,
-      VALIDATION_STATUS)
-    VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
-  header:
-    insert: >
-      INSERT INTO TXN_BCQ_HEADER (
-        BCQ_HEADER_ID,
-        FILE_ID,
-        SELLING_MTN,
-        BILLING_ID,
-        BUYING_PARTICIPANT_NAME,
-        BUYING_PARTICIPANT_SHORT_NAME,
-        SELLING_PARTICIPANT_NAME,
-        SELLING_PARTICIPANT_SHORT_NAME,
-        STATUS,
-        TRADING_DATE,
-        DEADLINE_DATE)
-      VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
-    update: >
-      UPDATE TXN_BCQ_HEADER SET
-        FILE_ID = ?,
-        STATUS = ?,
-        UPDATED_VIA = ?
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    count: >
-      SELECT COUNT(*) FROM TXN_BCQ_HEADER
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    id: >
-      SELECT BCQ_HEADER_ID FROM TXN_BCQ_HEADER
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    status: >
-      UPDATE TXN_BCQ_HEADER SET STATUS = ? WHERE BCQ_HEADER_ID = ?
-  data:
-    insert: >
-      INSERT INTO TXN_BCQ_DATA (
-        BCQ_DATA_ID,
-        BCQ_HEADER_ID,
-        REFERENCE_MTN,
-        START_TIME,
-        END_TIME,
-        BCQ)
-      VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
-    update: >
-      UPDATE TXN_BCQ_DATA SET
-        REFERENCE_MTN = ?,
-        BCQ = ?
-       WHERE END_TIME = ? AND BCQ_HEADER_ID = ?
-    details: >
-      SELECT
-        REFERENCE_MTN,
-        END_TIME,
-        BCQ
-      FROM TXN_BCQ_DATA
-      WHERE BCQ_HEADER_ID = ?
-  display:
-    data: >
-      SELECT
-        BCQ_HEADER_ID,
-        SELLING_MTN,
-        BILLING_ID,
-        BUYING_PARTICIPANT_NAME,
-        BUYING_PARTICIPANT_SHORT_NAME,
-        SELLING_PARTICIPANT_NAME,
-        SELLING_PARTICIPANT_SHORT_NAME,
-        TRADING_DATE,
-        DEADLINE_DATE,
-        TRANSACTION_ID,
-        SUBMITTED_DATE,
-        STATUS,
-        UPDATED_VIA
-      FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
-    count: >
-      SELECT COUNT(*)
-      FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
-    paginate: >
-      {SELECT_QUERY} LIMIT ({PAGE_NO} + 1) * {PAGE_SIZE} OFFSET {PAGE_NO}

crss-metering/crss_metering-uat.yml

@@ -1,184 +0,0 @@
-spring:
-  datasource:
-    url: jdbc:postgresql://192.168.235.6:5432/crss_metering
-    username: crss_metering
-    password: crss_metering
-    driverClassName: org.postgresql.Driver
-    hikari:
-      connectionTimeout: 10000
-      maximumPoolSize: 20
-  jpa:
-    database: POSTGRESQL
-    properties:
-      hibernate:
-        dialect: org.hibernate.dialect.PostgreSQL94Dialect
-
-graylog:
-  host: pemc.integration.exist.com
-
-mq:
-  manifest:
-    header:
-      insert: >
-        INSERT INTO TXN_MQ_MANIFEST_HEADER (HEADER_ID, TRANSACTION_ID, FILE_COUNT, TAIL_RECEIVED, CATEGORY, UPLOAD_BY, UPLOAD_DATETIME)
-        VALUES (
-          NEXTVAL('MQ_MANIFEST_HEADER_SEQ'), :transactionID, :fileCount, 'N', :category, :uploadedBy, :uploadDateTime
-        )
-    file:
-      insert: >
-        INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype, filesize, checksum, upload_datetime)
-        VALUES (
-          NEXTVAL('MQ_MANIFEST_FILE_SEQ'), :headerID, :transactionID, :fileName, :fileType, :fileSize, :checksum, :uploadDateTime
-        )
-  meter:
-    daily:
-      insert: >
-        INSERT INTO TXN_METER_DATA_DAILY (
-          METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
-          KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
-          KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
-          KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
-          KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
-          KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
-          KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
-          VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
-          VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
-          VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
-          IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
-          IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
-          ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
-          PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
-          ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
-        VALUES (
-          NEXTVAL('MQ_DATA_DAILY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
-          :kwd, :kwdChannelStatus, :kwdIntervalStatus,
-          :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
-          :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
-          :kwr, :kwrChannelStatus, :kwrIntervalStatus,
-          :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
-          :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
-          :van, :vanChannelStatus, :vanIntervalStatus,
-          :vbn, :vbnChannelStatus, :vbnIntervalStatus,
-          :vcn, :vcnChannelStatus, :vcnIntervalStatus,
-          :ian, :ianChannelStatus, :ianIntervalStatus,
-          :ibn, :ibnChannelStatus, :ibnIntervalStatus,
-          :icn, :icnChannelStatus, :icnIntervalStatus,
-          :pf, :pfChannelStatus, :pfIntervalStatus,
-          :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
-    monthly:
-      insert: >
-        INSERT INTO TXN_METER_DATA_MONTHLY (
-          METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
-          KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
-          KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
-          KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
-          KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
-          KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
-          KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
-          VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
-          VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
-          VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
-          IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
-          IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
-          ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
-          PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
-          ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
-        VALUES (
-          NEXTVAL('MQ_DATA_MONTHLY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
-          :kwd, :kwdChannelStatus, :kwdIntervalStatus,
-          :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
-          :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
-          :kwr, :kwrChannelStatus, :kwrIntervalStatus,
-          :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
-          :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
-          :van, :vanChannelStatus, :vanIntervalStatus,
-          :vbn, :vbnChannelStatus, :vbnIntervalStatus,
-          :vcn, :vcnChannelStatus, :vcnIntervalStatus,
-          :ian, :ianChannelStatus, :ianIntervalStatus,
-          :ibn, :ibnChannelStatus, :ibnIntervalStatus,
-          :icn, :icnChannelStatus, :icnIntervalStatus,
-          :pf, :pfChannelStatus, :pfIntervalStatus,
-          :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
-bcq:
-  manifest: >
-    INSERT INTO TXN_BCQ_UPLOAD_FILE (
-      FILE_ID,
-      TRANSACTION_ID,
-      FILE_NAME,
-      FILE_SIZE,
-      SUBMITTED_DATE,
-      VALIDATION_STATUS)
-    VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
-  header:
-    insert: >
-      INSERT INTO TXN_BCQ_HEADER (
-        BCQ_HEADER_ID,
-        FILE_ID,
-        SELLING_MTN,
-        BILLING_ID,
-        BUYING_PARTICIPANT_NAME,
-        BUYING_PARTICIPANT_SHORT_NAME,
-        SELLING_PARTICIPANT_NAME,
-        SELLING_PARTICIPANT_SHORT_NAME,
-        STATUS,
-        TRADING_DATE,
-        DEADLINE_DATE)
-      VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
-    update: >
-      UPDATE TXN_BCQ_HEADER SET
-        FILE_ID = ?,
-        STATUS = ?,
-        UPDATED_VIA = ?
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    count: >
-      SELECT COUNT(*) FROM TXN_BCQ_HEADER
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    id: >
-      SELECT BCQ_HEADER_ID FROM TXN_BCQ_HEADER
-      WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
-    status: >
-      UPDATE TXN_BCQ_HEADER SET STATUS = ? WHERE BCQ_HEADER_ID = ?
-  data:
-    insert: >
-      INSERT INTO TXN_BCQ_DATA (
-        BCQ_DATA_ID,
-        BCQ_HEADER_ID,
-        REFERENCE_MTN,
-        START_TIME,
-        END_TIME,
-        BCQ)
-      VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
-    update: >
-      UPDATE TXN_BCQ_DATA SET
-        REFERENCE_MTN = ?,
-        BCQ = ?
-       WHERE END_TIME = ? AND BCQ_HEADER_ID = ?
-    details: >
-      SELECT
-        REFERENCE_MTN,
-        END_TIME,
-        BCQ
-      FROM TXN_BCQ_DATA
-      WHERE BCQ_HEADER_ID = ?
-  display:
-    data: >
-      SELECT
-        BCQ_HEADER_ID,
-        SELLING_MTN,
-        BILLING_ID,
-        BUYING_PARTICIPANT_NAME,
-        BUYING_PARTICIPANT_SHORT_NAME,
-        SELLING_PARTICIPANT_NAME,
-        SELLING_PARTICIPANT_SHORT_NAME,
-        TRADING_DATE,
-        DEADLINE_DATE,
-        TRANSACTION_ID,
-        SUBMITTED_DATE,
-        STATUS,
-        UPDATED_VIA
-      FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
-    count: >
-      SELECT COUNT(*)
-      FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
-    paginate: >
-      {SELECT_QUERY} LIMIT ({PAGE_NO} + 1) * {PAGE_SIZE} OFFSET {PAGE_NO}