script test dan log db

opensipkd/iso8583/bjb/samsat/banten/doc.py

@@ -465,24 +465,21 @@ class Doc(Transaction):
         return
         return
 
 
     def reversal_response_(self):
     def reversal_response_(self):
-        self.invoice_id_raw = self.from_iso.get_invoice_id_raw()[:16]
+        invoice_id_raw = self.from_iso.get_invoice_id_raw()[:16]
         ntb = self.from_iso.get_ntb()
         ntb = self.from_iso.get_ntb()
-        pay = None
-        #q = self.db_profile.query(models.IsoPayment).filter_by(
-        #    invoice_no=self.invoice_id_raw[:16].strip(),
-        #    # nik=self.invoice_id_raw[16:].strip(),
-        #    ntb=ntb)
-
-        # pay = q.first()
-        # if not pay:
-        #    return self.ack_payment_not_found()
-
-        # self.invoice_id_raw = ''.join([self.invoice_profile['Nomor Bayar'].strip(),
-        #                                self.invoice_profile['Nomor Identitas'].strip()])
-        #q = self.db_profile.query(models.IsoReversal).filter_by(id=pay.id)
-        #rev = q.first()
-        #if rev:
-        #    return self.ack_reversal_done()
+        q = DBSession.query(SamsatPayment).filter_by(
+            nomor_bayar=invoice_id_raw.strip(),
+            ntb=ntb)
+
+        pay = q.first()
+        if not pay:
+           return self.ack_payment_not_found()
+
+        # self.invoice_id_raw = self.from_iso.get_invoice_id_raw()
+        q = DBSession.query(SamsatReversal).filter_by(id=pay.id)
+        rev = q.first()
+        if rev:
+           return self.ack_reversal_done()
 
 
         result = self.execute_reversal()
         result = self.execute_reversal()
 
 
@@ -492,9 +489,8 @@ class Doc(Transaction):
         return self.save_reversal(pay, result['ntp'])
         return self.save_reversal(pay, result['ntp'])
 
 
     def reversal_response(self):
     def reversal_response(self):
-        self.reversal_response_()
         try:
         try:
-            pass
+            self.reversal_response_()
         except:
         except:
             self.ack_other('Ada kesalahan yang belum dipahami.')
             self.ack_other('Ada kesalahan yang belum dipahami.')
             f = StringIO()
             f = StringIO()
@@ -503,14 +499,14 @@ class Doc(Transaction):
             f.close()
             f.close()
 
 
     def save_reversal(self, pay, ntpd):
     def save_reversal(self, pay, ntpd):
-        #rev = models.IsoReversal()
-        #rev.id = pay.id
-        # rev.iso_request = self.from_iso.raw.upper()
-
-        # todo: seharusnya trnsaction_date_time
-        #rev.tgl = self.from_iso.get_transaction_date()
-        #rev.ntp = ntpd
-        #self.db_profile.commit(rev)
+        rev = SamsatReversal()
+        rev.id = pay.id
+        rev.iso_request = self.from_iso.raw.upper()
+        rev.tgl = self.from_iso.get_transaction_datetime()
+        rev.ntp = ntpd
+        DBSession.add(rev)
+        DBSession.flush()
+        transaction.commit()
         self.ack()
         self.ack()
 
 
     ###################
     ###################

opensipkd/iso8583/bjb/samsat/models.py

@@ -58,4 +58,5 @@ class SamsatReversal(Base, BaseModel):
     id = Column(Integer, ForeignKey(SamsatPayment.id), nullable=False,
     id = Column(Integer, ForeignKey(SamsatPayment.id), nullable=False,
                 primary_key=True)
                 primary_key=True)
     ntp = Column(String(32), nullable=False)
     ntp = Column(String(32), nullable=False)
-    tgl_reversal = Column(DateTime(timezone=False))
+    iso_request = Column(Text)
+    tgl = Column(DateTime(timezone=False))