aa.gusti

proses-harian.py

@@ -13,12 +13,17 @@ from opensipkd.models import DBSession, Base
 from opensipkd.eis.models import Chart, ChartItem
 from opensipkd.eis_sipkd.models import (
         EisSipkdArPayment as SipkdArPayment, 
-        EisSipkdApPayment as SipkdApPayment,)
+        EisSipkdApPayment as SipkdApPayment,
+        Harian as SipkdHarian,)
 from datetime import datetime
 
 
 now = datetime.now()
 tahun = now.strftime('%Y')
+bulan = now.strftime('%m')
+hari  = now.strftime('%d')
+tanggal = now.date()
+
 print('start')
 def process_pie():
     print('PIE')
@@ -79,12 +84,35 @@ def process_barline():
                  for i in range(2,13):
                      field = 'value'+str(i).rjust(2,'_')
                      values[field] = values[field] + values['value'+str(i-1).rjust(2,'_')]
-            print('************', chart_item.nama, chart.chart_type, values)
             chart_item.from_dict(values)
-            print('************', chart_item.to_dict())
             DBSession.add(chart_item) 
             DBSession.flush()
 
+def process_grid():
+    print('HARIAN', tanggal)
+    harians = DBSession.query(SipkdHarian).\
+            filter_by(status=1)
+    for harian in harians.all():
+        rekening_kd = harian.kode
+        if rekening_kd[:1] == '4':
+            qry = DBSession.query(func.sum(SipkdArPayment.jumlah)).\
+                            filter_by(tahun = tahun,
+                                      kode = rekening_kd)
+            qry_kini = qry.filter(func.to_char(SipkdArPayment.tanggal,'MM')==bulan)
+            qry_lalu = qry.filter(func.to_char(SipkdArPayment.tanggal,'MM')<bulan)
+        elif rekening_kd[:1] == '5':
+            qry = DBSession.query(func.sum(SipkdApPayment.jumlah)).\
+                    filter_by(tahun = tahun,
+                           kode = rekening_kd)
+            qry_kini = qry.filter(func.to_char(SipkdApPayment.tanggal,'MM')==bulan)
+            qry_lalu = qry.filter(func.to_char(SipkdApPayment.tanggal,'MM')<bulan)
+
+        harian.amt_hari = qry.filter_by(tanggal = tanggal).scalar() or 0
+        harian.amt_minggu = qry_kini.scalar() or 0
+        harian.amt_bulan = qry_lalu.scalar() or 0
+        harian.amt_tahun = harian.amt_minggu+harian.amt_bulan
+        DBSession.add(harian)
+        DBSession.flush()
 
 #conf_file = 'conf.py'
 #conf_table = None
@@ -136,6 +164,7 @@ def main(argv=sys.argv):
     # initial_data.insert()
     process_pie()
     process_barline()
+    process_grid()
     transaction.commit()
     #call modules script 
 main()