crss-metering-dev.yml 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228
  1. spring:
  2. datasource:
  3. url: jdbc:postgresql://localhost:5432/crss_metering
  4. username: crss_metering
  5. password: crss_metering
  6. driverClassName: org.postgresql.Driver
  7. hikari:
  8. connectionTimeout: 10000
  9. maximumPoolSize: 20
  10. jpa:
  11. database: POSTGRESQL
  12. properties:
  13. hibernate:
  14. dialect: org.hibernate.dialect.PostgreSQL94Dialect
  15. rabbitmq:
  16. username: guest
  17. password: guest
  18. host: localhost
  19. ports:
  20. - "5672:5672"
  21. - "15672:15672"
  22. server:
  23. port: 8084
  24. undertow:
  25. accesslog:
  26. dir: target
  27. enabled: true
  28. pattern: combined
  29. compression:
  30. enabled: true
  31. min-response-size: 1
  32. eureka:
  33. client:
  34. serviceUrl:
  35. defaultZone: http://localhost:8761/eureka/
  36. # healthcheck:
  37. # enabled: true
  38. # lease:
  39. # duration: 5
  40. # instance:
  41. # leaseRenewalIntervalInSeconds: 1
  42. # leaseExpirationDurationInSeconds: 2
  43. security:
  44. oauth2:
  45. client:
  46. accessTokenUri: http://localhost:8082/oauth/access_token
  47. userAuthorizationUri: http://localhost:8082/oauth/authorize
  48. clientId: crss
  49. clientSecret: crsssecret
  50. authorized-grant-types: authorization_code,refresh_token,password
  51. scope: openid
  52. access-token-validity-seconds: 3600
  53. resource:
  54. userInfoUri: http://localhost:8082/user
  55. mq:
  56. manifest:
  57. header:
  58. insert: >
  59. INSERT INTO TXN_MQ_MANIFEST_HEADER (HEADER_ID, TRANSACTION_ID, FILE_COUNT, TAIL_RECEIVED, CATEGORY, UPLOAD_BY, UPLOAD_DATETIME)
  60. VALUES (
  61. NEXTVAL('MQ_MANIFEST_HEADER_SEQ'), :transactionID, :fileCount, 'N', :category, :uploadedBy, :uploadDateTime
  62. )
  63. file:
  64. insert: >
  65. INSERT INTO TXN_MQ_MANIFEST_FILE (file_id, header_id, transaction_id, filename, filetype, filesize, checksum, upload_datetime)
  66. VALUES (
  67. NEXTVAL('MQ_MANIFEST_FILE_SEQ'), :headerID, :transactionID, :fileName, :fileType, :fileSize, :checksum, :uploadDateTime
  68. )
  69. meter:
  70. daily:
  71. insert: >
  72. INSERT INTO TXN_METER_DATA_DAILY (
  73. METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
  74. KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
  75. KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
  76. KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
  77. KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
  78. KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
  79. KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
  80. VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
  81. VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
  82. VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
  83. IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
  84. IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
  85. ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
  86. PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
  87. ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
  88. VALUES (
  89. NEXTVAL('MQ_DATA_DAILY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
  90. :kwd, :kwdChannelStatus, :kwdIntervalStatus,
  91. :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
  92. :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
  93. :kwr, :kwrChannelStatus, :kwrIntervalStatus,
  94. :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
  95. :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
  96. :van, :vanChannelStatus, :vanIntervalStatus,
  97. :vbn, :vbnChannelStatus, :vbnIntervalStatus,
  98. :vcn, :vcnChannelStatus, :vcnIntervalStatus,
  99. :ian, :ianChannelStatus, :ianIntervalStatus,
  100. :ibn, :ibnChannelStatus, :ibnIntervalStatus,
  101. :icn, :icnChannelStatus, :icnIntervalStatus,
  102. :pf, :pfChannelStatus, :pfIntervalStatus,
  103. :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
  104. monthly:
  105. insert: >
  106. INSERT INTO TXN_METER_DATA_MONTHLY (
  107. METER_DATA_ID, FILE_ID, SEIN, INTERVAL, READING_DATETIME,
  108. KWD, KWD_CHANNEL_STATUS, KWD_INTERVAL_STATUS,
  109. KWHD, KWHD_CHANNEL_STATUS, KWHD_INTERVAL_STATUS,
  110. KVARHD, KVARHD_CHANNEL_STATUS, KVARHD_INTERVAL_STATUS,
  111. KWR, KWR_CHANNEL_STATUS, KWR_INTERVAL_STATUS,
  112. KWHR, KWHR_CHANNEL_STATUS, KWHR_INTERVAL_STATUS,
  113. KVARHR, KVARHR_CHANNEL_STATUS, KVARHR_INTERVAL_STATUS,
  114. VAN, VAN_CHANNEL_STATUS, VAN_INTERVAL_STATUS,
  115. VBN, VBN_CHANNEL_STATUS, VBN_INTERVAL_STATUS,
  116. VCN, VCN_CHANNEL_STATUS, VCN_INTERVAL_STATUS,
  117. IAN, IAN_CHANNEL_STATUS, IAN_INTERVAL_STATUS,
  118. IBN, IBN_CHANNEL_STATUS, IBN_INTERVAL_STATUS,
  119. ICN, ICN_CHANNEL_STATUS, ICN_INTERVAL_STATUS,
  120. PF, PF_CHANNEL_STATUS, PF_INTERVAL_STATUS,
  121. ESTIMATION_FLAG, MSP_SHORTNAME, CATEGORY, CREATED_DATE_TIME)
  122. VALUES (
  123. NEXTVAL('MQ_DATA_MONTHLY_SEQ'), :fileID, :sein, :interval, :readingDateTime,
  124. :kwd, :kwdChannelStatus, :kwdIntervalStatus,
  125. :kwhd, :kwhdChannelStatus, :kwhdIntervalStatus,
  126. :kvarhd, :kvarhdChannelStatus, :kvarhdIntervalStatus,
  127. :kwr, :kwrChannelStatus, :kwrIntervalStatus,
  128. :kwhr, :kwhrChannelStatus, :kwhrIntervalStatus,
  129. :kvarhr, :kvarhrChannelStatus, :kvarhrIntervalStatus,
  130. :van, :vanChannelStatus, :vanIntervalStatus,
  131. :vbn, :vbnChannelStatus, :vbnIntervalStatus,
  132. :vcn, :vcnChannelStatus, :vcnIntervalStatus,
  133. :ian, :ianChannelStatus, :ianIntervalStatus,
  134. :ibn, :ibnChannelStatus, :ibnIntervalStatus,
  135. :icn, :icnChannelStatus, :icnIntervalStatus,
  136. :pf, :pfChannelStatus, :pfIntervalStatus,
  137. :estimationFlag, :mspShortName, :uploadType, :createdDateTime)
  138. bcq:
  139. manifest: >
  140. INSERT INTO TXN_BCQ_UPLOAD_FILE (
  141. FILE_ID,
  142. TRANSACTION_ID,
  143. FILE_NAME,
  144. FILE_SIZE,
  145. SUBMITTED_DATE,
  146. VALIDATION_STATUS)
  147. VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
  148. header:
  149. insert: >
  150. INSERT INTO TXN_BCQ_HEADER (
  151. BCQ_HEADER_ID,
  152. FILE_ID,
  153. SELLING_MTN,
  154. BILLING_ID,
  155. BUYING_PARTICIPANT_USER_ID,
  156. BUYING_PARTICIPANT_NAME,
  157. BUYING_PARTICIPANT_SHORT_NAME,
  158. SELLING_PARTICIPANT_USER_ID,
  159. SELLING_PARTICIPANT_NAME,
  160. SELLING_PARTICIPANT_SHORT_NAME,
  161. STATUS,
  162. TRADING_DATE,
  163. DEADLINE_DATE)
  164. VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
  165. update: >
  166. UPDATE TXN_BCQ_HEADER SET
  167. FILE_ID = ?,
  168. STATUS = ?,
  169. UPDATED_VIA = ?
  170. WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
  171. count: >
  172. SELECT COUNT(*) FROM TXN_BCQ_HEADER
  173. WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
  174. id: >
  175. SELECT BCQ_HEADER_ID FROM TXN_BCQ_HEADER
  176. WHERE SELLING_MTN = ? AND BILLING_ID = ? AND TRADING_DATE = ? AND SELLING_PARTICIPANT_SHORT_NAME = ?
  177. status: >
  178. UPDATE TXN_BCQ_HEADER SET STATUS = ? WHERE BCQ_HEADER_ID = ?
  179. data:
  180. insert: >
  181. INSERT INTO TXN_BCQ_DATA (
  182. BCQ_DATA_ID,
  183. BCQ_HEADER_ID,
  184. REFERENCE_MTN,
  185. START_TIME,
  186. END_TIME,
  187. BCQ)
  188. VALUES (NEXTVAL('HIBERNATE_SEQUENCE'), ?, ?, ?, ?, ?)
  189. update: >
  190. UPDATE TXN_BCQ_DATA SET
  191. REFERENCE_MTN = ?,
  192. BCQ = ?
  193. WHERE END_TIME = ? AND BCQ_HEADER_ID = ?
  194. details: >
  195. SELECT
  196. REFERENCE_MTN,
  197. END_TIME,
  198. BCQ
  199. FROM TXN_BCQ_DATA
  200. WHERE BCQ_HEADER_ID = ?
  201. display:
  202. data: >
  203. SELECT
  204. BCQ_HEADER_ID,
  205. SELLING_MTN,
  206. BILLING_ID,
  207. BUYING_PARTICIPANT_USER_ID,
  208. BUYING_PARTICIPANT_NAME,
  209. BUYING_PARTICIPANT_SHORT_NAME,
  210. SELLING_PARTICIPANT_USER_ID,
  211. SELLING_PARTICIPANT_NAME,
  212. SELLING_PARTICIPANT_SHORT_NAME,
  213. TRADING_DATE,
  214. DEADLINE_DATE,
  215. TRANSACTION_ID,
  216. SUBMITTED_DATE,
  217. STATUS,
  218. UPDATED_VIA
  219. FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
  220. count: >
  221. SELECT COUNT(*)
  222. FROM TXN_BCQ_HEADER A INNER JOIN TXN_BCQ_UPLOAD_FILE B ON A.FILE_ID = B.FILE_ID
  223. paginate: >
  224. {SELECT_QUERY} LIMIT ({PAGE_NO} + 1) * {PAGE_SIZE} OFFSET {PAGE_NO} * {PAGE_SIZE}