import "org/killbill/billing/util/entity/dao/EntitySqlDao.sql.stg"

tableName() ::= "invoices"

tableFields(prefix) ::= <<
  <prefix>account_id
, <prefix>invoice_date
, <prefix>target_date
, <prefix>currency
, <prefix>status
, <prefix>migrated
, <prefix>parent_invoice
, <prefix>created_by
, <prefix>created_date
>>

tableValues() ::= <<
  :accountId
, :invoiceDate
, :targetDate
, :currency
, :status
, :migrated
, :parentInvoice
, :createdBy
, :createdDate
>>

extraTableFieldsWithComma(prefix) ::= <<
, <prefix>record_id as invoice_number
>>

getInvoicesBySubscription() ::= <<
  SELECT <allTableFields("i.")>
  FROM <tableName()> i
  JOIN invoice_items ii ON i.id = ii.invoice_id
  WHERE ii.subscription_id = :subscriptionId AND i.migrated = '0'
  <AND_CHECK_TENANT("i.")>
  <AND_CHECK_TENANT("ii.")>
  ;
>>

searchQuery(prefix) ::= <<
     <idField(prefix)> = :searchKey
  or <prefix>account_id = :searchKey
  or <prefix>currency = :searchKey
>>

getInvoiceIdByPaymentId() ::= <<
  SELECT i.id
    FROM <tableName()> i, invoice_payments ip
   WHERE ip.invoice_id = i.id
     AND ip.payment_id = :paymentId
   <AND_CHECK_TENANT("i.")>
   <AND_CHECK_TENANT("ip.")>
>>

updateStatus() ::= <<
    UPDATE <tableName()>
    SET status = :status
    WHERE id = :id
    <AND_CHECK_TENANT("")>;
>>

getParentDraftInvoice() ::= <<
  SELECT <allTableFields("")>
    FROM <tableName()>
   WHERE account_id = :accountId
     AND status = 'DRAFT'
   <AND_CHECK_TENANT("")>
   <defaultOrderBy("")>
>>

getEarliestDraftInvoiceByAccount() ::= <<
  SELECT <allTableFields("")>
    FROM <tableName()>
   WHERE <accountRecordIdField("")> = :accountRecordId
     AND status = 'DRAFT'
   <AND_CHECK_TENANT("")>
   <defaultOrderBy("")>
   limit 1
;
>>

getByIds(ids) ::= <<
select
  <allTableFields("t.")>
from <tableName()> t
where <idField("t.")> in (<ids>)
<AND_CHECK_TENANT("t.")>
;
>>
