Added config for metering.

crss-metering/crss-metering-dev.yml

@@ -0,0 +1,90 @@
+spring:
+  datasource:
+    url: jdbc:postgresql://localhost:5432/crss_metering
+    username: crss_metering
+    password: crss_metering
+    driverClassName: org.postgresql.Driver
+    hikari:
+      connectionTimeout: 10000
+      maximumPoolSize: 20
+  rabbitmq:
+#    TODO: Need to finalize username/password
+    username: guest
+    password: guest
+
+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
+
+logging:
+  level:
+    com.pemc: DEBUG
+    com.netflix: WARN
+    org.springframework.cloud: WARN
+    org.hibernate.SQL: DEBUG
+
+mq:
+  manifest:
+    header: >
+      INSERT INTO TXN_MQ_MANIFEST_HEADER (header_id, transaction_id, msp_id, file_count, category,
+      upload_by, upload_datetime) VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?)
+    trailer: >
+      UPDATE TXN_MQ_MANIFEST_HEADER SET tail_received = 'Y' WHERE transaction_id = ?
+    file: >
+      INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype,
+      filesize, checksum) VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?)
+  meter:
+    daily: >
+      INSERT INTO TXN_METER_DATA_DAILY VALUES(
+      NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
+      ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+    monthly: >
+      INSERT INTO TXN_METER_DATA_MONTHLY VALUES(
+      NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
+      ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+bcq:
+  manifest: >
+    INSERT INTO TXN_BCQ_UPLOAD_FILE (FILE_ID, TRANSACTION_ID, FILE_NAME, FILE_SIZE, STATUS, SUBMITTED_DATE)
+    VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
+  data:
+    insert: >
+      INSERT INTO TXN_BCQ_DATA (BCQ_DATA_ID, FILE_ID, SELLING_MTN, BUYING_PARTICIPANT, REFERENCE_MTN, START_TIME,
+      END_TIME, BCQ) VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?)
+    update: >
+      UPDATE TXN_BCQ_DATA SET FILE_ID = ?, REFERENCE_MTN = ?, BCQ = ?
+      WHERE SELLING_MTN = ? AND BUYING_PARTICIPANT = ? AND END_TIME = ?
+    exists: >
+      SELECT EXISTS(SELECT 1 FROM TXN_BCQ_DATA WHERE SELLING_MTN = ? AND BUYING_PARTICIPANT = ? AND END_TIME = ?)
+      AS EXISTS

crss-metering/crss-metering.yml

@@ -0,0 +1,94 @@
+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
+  rabbitmq:
+#    TODO: Need to finalize username/password
+    username: guest
+    password: guest
+
+server:
+  port: 8084
+  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: >
+      INSERT INTO TXN_MQ_MANIFEST_HEADER (header_id, transaction_id, msp_id, file_count, category,
+      upload_by, upload_datetime) VALUES (HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?, ?)
+    trailer: >
+      UPDATE TXN_MQ_MANIFEST_HEADER SET tail_received = 'Y' WHERE transaction_id = ?
+    file: >
+      INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype,
+      filesize, checksum) VALUES (HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?, ?)
+  meter:
+    # TODO: Reduce redundant codes
+    daily: >
+      INSERT INTO TXN_METER_DATA_DAILY VALUES(
+      HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
+      ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+    monthly: >
+      INSERT INTO TXN_METER_DATA_MONTHLY VALUES(
+      HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
+      ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+bcq:
+  manifest: >
+    INSERT INTO TXN_BCQ_UPLOAD_FILE (FILE_ID, TRANSACTION_ID, FILE_NAME, FILE_SIZE, STATUS, SUBMITTED_DATE)
+    VALUES (HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?)
+  data:
+    insert: >
+      INSERT INTO TXN_BCQ_DATA (BCQ_DATA_ID, FILE_ID, SELLING_MTN, BUYING_PARTICIPANT, REFERENCE_MTN, START_TIME,
+      END_TIME, BCQ) VALUES (HIBERNATE_SEQUENCE.NEXTVAL, ?, ?, ?, ?, ?, ?, ?)
+    update: >
+      UPDATE TXN_BCQ_DATA SET FILE_ID = ?, REFERENCE_MTN = ?, BCQ = ?
+      WHERE SELLING_MTN = ? AND BUYING_PARTICIPANT = ? AND END_TIME = ?
+    exists: >
+      SELECT CASE
+      WHEN COUNT(*) > 0 THEN 'Y' ELSE 'N' END
+      FROM TXN_BCQ_DATA
+      WHERE SELLING_MTN = ? AND BUYING_PARTICIPANT = ? AND END_TIME = ?