user_dep.py 6 KB
import colander
import logging
from deform import widget
from pyramid.view import view_config
from . import BaseView, button_import
from ...models import User, DepartemenUser, Departemen, DBSession
from .departemen import get_departemen_list
from .user import user_list
from pyramid.i18n import TranslationStringFactory

_ = TranslationStringFactory('myapp')
log = logging.getLogger(__name__)

@colander.deferred
def departemen_widget(node, kw):
    values = kw.get('departemen_list', [])
    return widget.CheckboxChoiceWidget(values=values, multiple=True, placeholder='Pilih Departemen')

class ListSchema(colander.Schema):
    id = colander.SchemaNode(
        colander.Integer(),
        title="Action"
    )
    user_name = colander.SchemaNode(
        colander.String(),
        field=User.user_name,
        title="User"
    )
    departemen_name = colander.SchemaNode(
        colander.String(),
        field=Departemen.nama,
        title="Departemen"
    )

@colander.deferred
def departemen_checkbox_widget(node, kw):
    values = kw.get('departemen_list', [])
    return widget.CheckboxChoiceWidget(values=values, multiple=True)

class AddSchema(colander.Schema):
    user_id = colander.SchemaNode(
        colander.Integer(),
        widget=widget.SelectWidget(values=User.get_list()),
        oid="user_id",
        title="User",
    )
    departemen_id = colander.SchemaNode(
        colander.Set(),
        widget=departemen_checkbox_widget,
        oid="departemen_id",
        title="Departemen",
    )

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.request = request
        self.list_schema = ListSchema
        self.add_schema = AddSchema
        self.edit_schema = EditSchema
        self.list_route = 'user-departemen'
        self.table = DepartemenUser
        self.list_buttons = self.list_buttons + (button_import,)

    def list_join(self, query, **kwargs):
        return query.outerjoin(Departemen, Departemen.id == self.table.departemen_id) \
            .outerjoin(User, User.id == self.table.user_id)

    @view_config(route_name='user-departemen', renderer='templates/table.pt',
                 permission='user-view')
    def view_list(self, **kwargs):
        return super().view_list(**kwargs)

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

    def get_bindings(self, row=None):
        bindings = {
            "departemen_list": get_departemen_list(),
            "user_list": user_list()
        }
        if row and hasattr(row, 'user_id'):
            existing_depts = self.get_existing_departemen(row.user_id)
            bindings["default_values"] = {
                "user_id": row.user_id,
                "departemen_id": list(existing_depts)
            }
        return bindings

    @view_config(route_name='user-departemen-add', renderer='templates/form.pt',
                 permission='user-edit')
    def view_add(self):
        return super().view_add()

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

    @view_config(route_name='user-departemen-delete', renderer='templates/form.pt',
                 permission='user-edit')
    def view_delete(self):
        return super().view_delete()

    @view_config(route_name='user-departemen-edit', renderer='templates/form.pt',
                 permission='user-edit')
    def view_edit(self):
        return super().view_edit()
        
    @view_config(route_name='user-departemen-upload',
                 renderer='templates/form.pt', permission='user-upload')
    def view_upload(self):
        self.upload_keys = ["user_id"]
        return super(Views, self).view_upload(exts=(".csv", ".tsv"))

    def save_request(self, values, row=None):
        user_id = values.get("user_id")
        if not user_id:
            return None

        if "departemen_id" in values:
            selected_departemen = set(
                str(departemen_id) for departemen_id in values["departemen_id"]
                if departemen_id is not None and str(departemen_id) != "None"
            )
            # Batasi ke maksimal dua pilihan
            selected_list = sorted(selected_departemen)[:2]  # Ambil dua yang pertama
            dept1 = int(selected_list[0]) if selected_list else None
            dept2 = int(selected_list[1]) if len(selected_list) > 1 else None

            existing_row = DBSession.query(DepartemenUser).filter_by(user_id=user_id).first()
            if selected_list:
                if existing_row:
                    # Update jika sudah ada
                    existing_row.departemen_id = dept1
                    existing_row.sub_departemen = dept2
                else:
                    # Tambah baru jika belum ada
                    new_row = DepartemenUser(
                        user_id=user_id,
                        departemen_id=dept1,
                        sub_departemen=dept2
                    )
                    DBSession.add(new_row)
            else:
                # Jika tidak ada pilihan, hapus row yang ada
                if existing_row:
                    DBSession.delete(existing_row)

        DBSession.flush()
        return row

    def get_existing_departemen(self, user_id):
        row = DBSession.query(DepartemenUser).filter_by(user_id=user_id).first()
        result = set()
        if row:
            if row.departemen_id:
                result.add(str(row.departemen_id))
            if row.sub_departemen:
                result.add(str(row.sub_departemen))
        return result

    def get_values(self, row, istime=False):
        d = super(Views, self).get_values(row, istime)
        d["departemen_id"] = self.get_existing_departemen(row.user_id)
        return d