|
|
@@ -1,2 +1,184 @@
|
|
|
+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
|
|
|
+ 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}
|
Chris Lim