desa.py 9.29 KB
import os
import colander
from deform import (widget, )
from opensipkd.models import DBSession, ResDesa, kategori_desa, ResKecamatan, ResProvinsi, ResDati2
from . import BaseView, btn_upload
from opensipkd.tools.buttons import btn_close, btn_add
from pyramid.i18n import TranslationStringFactory
from pyramid.view import (view_config, )
from . import BaseView, btn_upload
from pyramid.path import AssetResolver
from . import BaseView, button_import, get_params
from opensipkd.tools.report import csv_response, file_response
from .dati2 import dati2_widget
from opensipkd.tools import get_random_string
from .kecamatan import kecamatan_widget
from .provinsi import provinsi_widget
from ..views import BaseView

_ = TranslationStringFactory("opensipkd")

SESS_ADD_FAILED = 'Tambah desa gagal'
SESS_EDIT_FAILED = 'Edit desa gagal'

def get_desa_list():
    # r = [("", "--Pilih Desa--")]
    r = []
    q = DBSession.query(ResDesa).order_by(ResDesa.nama)
    for row in q:
        g = (str(row.id), (f"{row.kode}/ {row.nama}"))
        r.append(g)
    return r

@colander.deferred
def desa_widget(node, kw):
    values = kw.get('desa_list', [])
    return widget.Select2Widget(values=values,
                                placeholder="Pilih Desa/Kelurahan")


class AddSchema(colander.Schema):
    provinsi_id = colander.SchemaNode(colander.String(),
                                      widget=provinsi_widget,
                                      validator=colander.Length(max=32),
                                      oid="provinsi_id",
                                      slave="dati2_id",
                                      slave_url="/dati2/select/act?provinsi_id=",
                                      title="Provinsi",
                                      )
    dati2_id = colander.SchemaNode(colander.String(),
                                   widget=dati2_widget,
                                   validator=colander.Length(max=32),
                                   oid="dati2_id",
                                   slave="kecamatan_id",
                                   slave_url="/kecamatan/select/act?dati2_id=",
                                   title="Kabupaten/Kota",
                                   )
    kecamatan_id = colander.SchemaNode(colander.String(),
                                       widget=kecamatan_widget,
                                       validator=colander.Length(max=32),
                                       oid="kecamatan_id",
                                       title="Kecamatan")
    kode = colander.SchemaNode(colander.String(),
                               validator=colander.Length(max=32), oid="kode")
    kategori = colander.SchemaNode(colander.String(),
                                   widget=widget.SelectWidget(values=kategori_desa),
                                   validator=colander.Length(max=32), oid="kode")

    nama = colander.SchemaNode(colander.String(),
                               validator=colander.Length(max=128), 
                               oid="nama")


class EditSchema(AddSchema):
    id = colander.SchemaNode(colander.String(), missing=colander.drop,
                             widget=widget.HiddenWidget(readonly=True))


class ListSchema(colander.Schema):
    id = colander.SchemaNode(colander.Integer(),
                             title=_("action", default="Action"))
    kode = colander.SchemaNode(colander.String(), width='100pt', title="Kode")
    nama = colander.SchemaNode(colander.String(), title="Nama")
    kecamatan = colander.SchemaNode(colander.String(), field=ResKecamatan.nama)


class ViewDesa(BaseView):
    def __init__(self, request):
        super(ViewDesa, self).__init__(request)
        self.form_scripts = ""
        self.form_params = dict(scripts="")
        self.list_url = 'desa'
        self.list_route = 'desa'
        self.add_schema = AddSchema
        self.edit_schema = EditSchema
        self.table = ResDesa
        self.list_schema = ListSchema
        self.list_buttons = self.list_buttons + self.list_report + (btn_upload,)
        path = os.path.dirname(__file__)
        path = os.path.dirname(path)
        self.report_file = os.path.join(path, 'reports', 'desa.jrxml')

    # Mendapatkan path gambar
    def get_module_path(self, module_name):
        a = AssetResolver(module_name)
        resolver = a.resolve('')
        return resolver.abspath()

    def pdf_response(self, **kwargs):
        # print("PDF RESPONSE======================================")
        from opensipkd.base.tools.report import jasper_export
        logo = self.get_module_path('opensipkd.base')
        logo = os.path.join(logo, 'static', 'img', 'logo.png')
        parameters = {
            "judul": get_params('company', "openSIPKD"),
            "alamat_lengkap": get_params('address', "Bekasi"), 
            "logo": logo
            }
        print(parameters)
        filename = jasper_export(self.report_file, parameters=parameters)
        return file_response(self.req, filename=filename[0])
    
    @staticmethod
    def query_register():
        return DBSession.query(ResDesa.kecamatan_id, ResDesa.kode, ResDesa.kategori,ResDesa.nama).order_by(ResDesa.kecamatan_id)


    def csv_response(self, **kwargs):
        query = self.query_register()
        row = query.first()
        header = row._mapping.keys()
        rows = [list(item) for item in query.all()]
        filename = f"{get_random_string(16)}.csv"
        value = {
            'header': header,
            'rows': rows,
        }
        return csv_response(self.req, value, filename)

    def form_validator(self, form, value):
        def err_kode():
            raise colander.Invalid(form, 'Kode %s sudah digunakan oleh %s' % (
                value['kode'], found.nama))

        def err_nama():
            raise colander.Invalid(form,
                                   'Uraian %s sudah digunakan oleh kode %s' % (
                                       value['nama'], found.kode))

        if 'id' in form.request.matchdict:
            uid = form.request.matchdict['id']
            q = DBSession.query(ResDesa).filter_by(id=uid)
            row = q.first()
        else:
            row = None

        q = ResDesa.query_kode(value['kode']) \
            .filter(ResDesa.kecamatan_id == value["kecamatan_id"])
        found = q.first()
        if row:
            if found and found.id != row.id:
                err_kode()
        elif found:
            err_kode()

        found = ResDesa.query_nama(value['nama']) \
            .filter(ResDesa.kecamatan_id == value["kecamatan_id"]).first()
        if found:
            if found and found.id != row.id:
                err_nama()
        elif found:
            err_nama()

    def get_bindings(self, row=None):
        provinsi_list = ResProvinsi.get_list()
        kecamatan = row and row.kecamatan or None
        kecamatan_list = kecamatan and ResKecamatan.get_list(kecamatan.dati2_id) or []
        dati2 = kecamatan and kecamatan.dati2 or None
        dati2_list = dati2 and ResDati2.get_list(dati2.provinsi_id) or []
        return dict(
            provinsi_list=provinsi_list,
            dati2_list=dati2_list,
            kecamatan_list=kecamatan_list,
        )

    def get_values(self, row, istime=False):
        d = super().get_values(row, istime)
        kecamatan = row and row.kecamatan or None
        d["dati2_id"] = kecamatan and kecamatan.dati2_id or None
        dati2 = kecamatan and kecamatan.dati2 or None
        d["provinsi_id"] = dati2 and dati2.provinsi_id or None
        return d

    @view_config(route_name='desa-view',
                 renderer='templates/form.pt', permission='wilayah')
    def view_view(self):
        return super().view_view()

    @view_config(route_name='desa',
                 renderer='templates/table.pt',
                 permission='wilayah')
    def view_list(self):
        return super(ViewDesa, self).view_list()

    def list_join(self, query):
        return query.outerjoin(ResKecamatan)

    @view_config(route_name='desa-act', renderer='json',
                 permission='view')
    def view_act(self):
        return super().view_act()

    def next_act(self):
        request = self.req
        url_dict = request.matchdict
        if url_dict['act'] == 'select':
            kecamatan_id = request.params["kecamatan_id"]
            data = ResDesa.get_list(kecamatan_id)
            result = {f"{k[0]}": k[1] for k in data}
            return result

    @view_config(route_name='desa-add',
                 renderer='templates/form.pt', permission='wilayah')
    def view_add(self):
        return super(ViewDesa, self).view_add()

    @view_config(route_name='desa-edit',
                 renderer='templates/form.pt', permission='wilayah')
    def view_edt(self):
        return super(ViewDesa, self).view_edit()

    @view_config(route_name='desa-delete',
                 renderer='templates/form.pt', permission='wilayah')
    def view_delete(self):
        return super(ViewDesa, self).view_delete()
    
    @view_config(route_name='desa-upload',
                 renderer='templates/form.pt', permission='wilayah')
    def view_upload(self):
        return super().view_upload(exts=('.csv', ".tsv"))