kecamatan.py

import colander
from deform import widget
from pyramid.view import view_config
from sqlalchemy import func

from . import BaseView
from ..models import PbbmDBSession, Kecamatan, Dati2


class ListSchema(colander.Schema):
    id = colander.SchemaNode(
        colander.String(),
        field=func.concat(
            Kecamatan.kd_propinsi,
            func.concat(
                Kecamatan.kd_dati2,
                Kecamatan.kd_kecamatan)
        ),
        title="Aksi"
    )
    kode = colander.SchemaNode(
        colander.String(),
        field=func.concat(Kecamatan.kd_propinsi, '.').concat(Kecamatan.kd_dati2).concat('.').concat(
            Kecamatan.kd_kecamatan),
    )
    nm_kecamatan = colander.SchemaNode(
        colander.String(),
        title="Nama Kecamatan",
    )


class AddSchema(colander.Schema):
    parent_kode = colander.SchemaNode(
        colander.String(),
        widget=widget.TextInputWidget(readonly=True),
        missing=colander.drop,
        oid="kd_dati2",
        title="Kab/Kota",
    )
    nm_dati2 = colander.SchemaNode(
        colander.String(),
        oid="nm_dati2",
        title="Nama Kab/Kota", )

    kd_kecamatan = colander.SchemaNode(
        colander.String(),
        widget=widget.TextInputWidget(
            min_len=7,
            max_len=7,
        ),
        oid="kd_kecamatan",
        title="Kode", )

    nm_kecamatan = colander.SchemaNode(
        colander.String(),
        oid="nm_kecamatan",
        title="Nama", )


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


class Views(BaseView):
    def __init__(self, request):
        super().__init__(request)
        self.list_schema = ListSchema
        self.add_schema = AddSchema
        self.edit_schema = EditSchema
        self.list_route = 'pbbm-kecamatan'
        self.table = Kecamatan
        self.db_session = PbbmDBSession
        self.list_buttons = ()

    @view_config(route_name='pbbm-kecamatan', renderer='templates/form.pt',
                 permission='pbbm-admin')
    def view_list(self):
        return super().view_list(allow_edit=False, allow_delete=False, new_buttons={"update": {"obj": "update",
                                                                                               "js": ""}})

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

    def query_id(self):
        q = self.table.query_id(self.req.matchdict['id'])
        return q

    def list_join(self, query):
        return query.order_by(Kecamatan.kd_kecamatan)

    def get_values(self, row, istime=False, null=False):
        d = super().get_values(row, istime, null)
        d["parent_kode"] = d["kd_propinsi"] + d["kd_dati2"]
        parent = Dati2.query_id(d["parent_kode"]).first()
        d["nm_dati2"] = parent.nm_dati2
        return d

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

    @view_config(route_name='pbbm-kecamatan-delete', renderer='templates/form.pt',
                 permission='pbbm-admin')
    def view_delete(self):
        return super().view_delete()

    @view_config(route_name='pbbm-kecamatan-edit', renderer='templates/form.pt',
                 permission='pbbm-admin')
    def view_edit(self):
        return super().view_edit()


def get_kecamatan_list():
    r = [("", "--Pilih Departemen--")]
    q = Kecamatan.query().order_by(Kecamatan.kd_kecamatan)
    for row in q:
        g = (row.kode, (f"{row.kode}/ {row.nm_kecamatan}"))
        r.append(g)
    return r


@colander.deferred
def kecamatan_widget(node, kw):
    values = kw.get('kecamatan_list', [])
    return widget.Select2Widget(values=values, placeholder="Pilih Kecamatan")

# import os
# import uuid
# #from ..tools import row2dict, xls_reader
# from datetime import datetime
# from sqlalchemy import not_, func
# from pyramid.view import (
#     view_config,
#     )
# from pyramid.httpexceptions import (
#     HTTPFound,
#     )
# import colander
# from deform import (
#     Form,
#     widget,
#     ValidationFailure,
#     )
# from . import ColumnDT, DataTables
# from ..models import (
#     PbbmDBSession as DBSession,
#     Kecamatan
#     )
# from ..tools import (
#     # open_rml_row, open_rml_pdf,
#     pdf_response, csv_response,
#     get_settings)
#
# SESS_ADD_FAILED = 'Tambah kecamatan gagal'
# SESS_EDIT_FAILED = 'Edit kecamatan gagal'
# from ..tools import FixKecamatan, FixDati2
# class AddSchema(colander.Schema):
#     kd_kota = colander.SchemaNode(
#                     colander.String(),
#                     widget=widget.TextInputWidget(readonly=True),
#                     missing = colander.drop,
#                     oid = "kd_kota",
#                     title = "Kota/Kab",
#                     )
#     kd_kecamatan = colander.SchemaNode(
#                     colander.String(),
#                     widget=widget.TextInputWidget(size=10),
#                     validator=colander.Length(max=3, min=3),
#                     oid = "kd_kecamatan",
#                     title = "Kode",)
#
#     nm_kecamatan = colander.SchemaNode(
#                     colander.String(),
#                     oid = "nm_kecamatan",
#                     title = "Nama",)
#
# class EditSchema(AddSchema):
#     id = colander.SchemaNode(colander.String(),
#             missing=colander.drop,
#             widget=widget.HiddenWidget(readonly=True))
#
# ########
# # List #
# ########
# @view_config(route_name='pbbm-kecamatan', renderer='templates/kecamatan/list.pt',
#              permission='pbbm-kecamatan')
# def view_list(request):
#     return dict(a={})
#
# ##########
# # Action #
# ##########
# @view_config(route_name='pbbm-kecamatan-act', renderer='json',
#              permission='pbbm-kecamatan-act')
# def view_act(request):
#     ses = request.session
#     req = request
#     params   = req.params
#     url_dict = req.matchdict
#
#     if url_dict['act']=='grid':
#         columns = [
#           ColumnDT(func.concat(Kecamatan.kd_propinsi,
#                    func.concat(Kecamatan.kd_dati2,
#                                Kecamatan.kd_kecamatan)), mData="id"),
#           ColumnDT(Kecamatan.kd_kecamatan, mData="kode"),
#           ColumnDT(Kecamatan.nm_kecamatan, mData="nama"),
#         ]
#         query = DBSession.query().select_from(Kecamatan)
#         rowTable = DataTables(req.GET, query, columns)
#         return rowTable.output_result()
#
# #######
# # Add #
# #######
# def form_validator(form, value):
#     pass
#     # if 'id' in form.request.matchdict:
#         # uid = form.request.matchdict['id']
#         # q = DBSession.query(kecamatan).filter_by(id=uid)
#         # kecamatan = q.first()
#     # else:
#         # kecamatan = None
#
# def get_form(request, class_form, row=None):
#     schema = class_form(validator=form_validator)
#     schema = schema.bind()
#     schema.request = request
#     if row:
#       schema.deserialize(row)
#     return Form(schema, buttons=('simpan','batal'))
#
# def save(values, user, row=None):
#     if not row:
#         row = Kecamatan()
#         settings = get_settings()
#         kd_kota = 'pbb_pemda' in settings and settings['pbb_pemda'] or '6110'
#         kd_kotas = FixDati2(kd_kota)
#         row.kd_propinsi = kd_kotas['kd_propinsi']
#         row.kd_dati2 = kd_kotas['kd_dati2']
#
#     row.from_dict(values)
#     kode = row.kd_propinsi+row.kd_dati2 + values['kd_kecamatan']
#     kodes = FixKecamatan(kode)
#     row.kd_kecamatan = kodes['kd_kecamatan']
#     row.kd_kecamatan = kodes['kd_kecamatan']
#     DBSession.add(row)
#     DBSession.flush()
#     return row
#
# def save_request(request, values, row=None):
#     if 'id' in request.matchdict:
#         values['id'] = request.matchdict['id']
#     row = save(values, request.user, row)
#     request.session.flash('kecamatan sudah disimpan.')
#
# def route_list(request):
#     return HTTPFound(location=request.route_url('pbbm-kecamatan'))
#
# def session_failed(request, session_name):
#     r = dict(form=request.session[session_name])
#     del request.session[session_name]
#     return r
#
# @view_config(route_name='pbbm-kecamatan-add', renderer='templates/kecamatan/add.pt',
#              permission='pbbm-kecamatan-add')
# def view_add(request):
#     req = request
#     ses = request.session
#     form = get_form(request, AddSchema)
#     if req.POST:
#         if 'simpan' in req.POST:
#             ctrls = list(req.POST.items())
#             try:
#                 c = form.validate(ctrls)
#             except ValidationFailure as e:
#                 #req.session[SESS_ADD_FAILED] = e.render()
#                 return dict(form=form)
#             save_request(request, dict(ctrls))
#         return route_list(request)
#     elif SESS_ADD_FAILED in req.session:
#         return session_failed(request,SESS_ADD_FAILED)
#
#     settings = get_settings()
#     kd_kota = 'pbb_pemda' in settings and settings['pbb_pemda'] or '6110'
#     kd_kotas = FixDati2(kd_kota)
#     values = dict(
#                 kd_kota = kd_kotas.get_dotted()
#               )
#     form.set_appstruct(values)
#     return dict(form=form)
#
#
# ########
# # Edit #
# ########
# def query_id(request):
#     return Kecamatan.query_id(request.matchdict['id'])
#
# def id_not_found(request):
#     msg = 'kecamatan ID %s Tidak Ditemukan.' % request.matchdict['id']
#     request.session.flash(msg, 'error')
#     return route_list(request)
#
# @view_config(route_name='pbbm-kecamatan-edt', renderer='templates/kecamatan/edit.pt',
#              permission='pbbm-kecamatan-edt')
# def view_edit(request):
#     #request = request
#     row = query_id(request).first()
#     if not row:
#         return id_not_found(request)
#     form = get_form(request, EditSchema)
#     if request.POST:
#         if 'simpan' in request.POST:
#             controls = list(request.POST.items())
#             try:
#                 c = form.validate(controls)
#             except ValidationFailure as e:
#                 request.session[SESS_EDIT_FAILED] = e.render()
#                 return HTTPFound(location=request.route_url('pbbm-kecamatan-edt',
#                                   id=row.id))
#             save_request(request, dict(controls), row)
#         return route_list(request)
#     elif SESS_EDIT_FAILED in request.session:
#         return session_failed(request,SESS_EDIT_FAILED)
#     values = row.to_dict()
#     values['kd_kecamatan'] = row.kd_kecamatan
#     values['kd_kota'] = row.kd_propinsi + '.' + row.kd_dati2
#     #return dict(form=form.render(appstruct=values))
#     form.set_appstruct(values)
#     return dict(form=form)
#
# ##########
# # Delete #
# ##########
# @view_config(route_name='pbbm-kecamatan-del', renderer='templates/kecamatan/delete.pt',
#              permission='pbbm-kecamatan-del')
# def view_delete(request):
#     request = request
#     q = Kecamatan.query_id(request.matchdict['id'])
#     row = q.first()
#
#     if not row:
#         return request.id_not_found(request)
#     form = Form(colander.Schema(), buttons=('hapus','batal'))
#     if request.POST:
#         if 'hapus' in request.POST:
#             msg = 'Kecamatan Kode %s %s sudah dihapus.' % (row.kd_kecamatan, row.nm_kecamatan)
#             try:
#               q.delete()
#               DBSession.flush()
#             except:
#               msg = 'kecamatan ID %d %s tidak dapat dihapus.' % (row.id, row.description)
#             request.session.flash(msg)
#         return route_list(request)
#     return dict(row=row,
#                  form=form.render())
#
# ##########
# # RPT    #
# ##########
# #@view_config(route_name='pbbm-kecamatan-rpt', renderer="json",
# #        permission='kecamatan-rpt')
# def view_rpt(request):
#     request = request
#     ses = request.session
#     req = request
#     params   = req.params
#     url_dict = req.matchdict
#     if url_dict['rpt']=='pdf' :
#         query = query_register()
#         _here = os.path.dirname(__file__)
#         path = os.path.join(os.path.dirname(_here), 'reports')
#         rml_row = open_rml_row(path+'/kecamatan.row.rml')
#
#         rows=[]
#         for r in query.all():
#             s = rml_row.format(kecamatan_name=r.kecamatan_name,
#                     description=r.description,
#                     member_count=r.member_count
#                     )
#             rows.append(s)
#
#             pdf, filename = open_rml_pdf(path+'/kecamatan.rml', rows=rows,
#                     company=request.company,
#                     departement = request.departement,
#                     address = request.address)
#             return pdf_response(request, pdf, filename)
#
#     elif url_dict['rpt']=='csv' :
#         query = query_register()
#         row = query.first()
#         header = row.keys()
#         rows = []
#         for item in query.all():
#             rows.append(list(item))
#
#             filename = 'kecamatan.csv'
#             value = {
#                     'header': header,
#                     'rows'  : rows,
#                     }
#             return csv_response(request, value, filename)
# def query_register():
#     return DBSession.query(kecamatan.kecamatan_name, kecamatan.description,
#                 kecamatan.member_count).order_by(kecamatan.kecamatan_name)