142 lines
5.1 KiB
Python
142 lines
5.1 KiB
Python
from sqlalchemy import Boolean, Column, ForeignKey, Integer, String, DateTime, Float, Numeric
|
|
from sqlalchemy.types import TypeDecorator, VARCHAR, Integer, CHAR
|
|
from sqlalchemy_utils import EmailType
|
|
from sqlalchemy.orm import relationship
|
|
#from models.database import Base
|
|
from sustApp.models.database import Base
|
|
|
|
import datetime
|
|
|
|
class TrimChar(TypeDecorator):
|
|
impl = CHAR
|
|
cache_key = False
|
|
|
|
def process_result_value(self, value, dialect):
|
|
if value:
|
|
value = value.strip()
|
|
return value
|
|
|
|
class NullCatchingString(TypeDecorator):
|
|
impl = VARCHAR
|
|
|
|
def process_result_value(self, value, dialect):
|
|
if value is None:
|
|
return ''
|
|
return value
|
|
|
|
class NullCatchingInteger(TypeDecorator):
|
|
impl = Integer
|
|
|
|
def process_result_value(self, value, dialect):
|
|
if value is None:
|
|
return ''
|
|
return value
|
|
|
|
class Members(Base):
|
|
__tablename__ = 'members'
|
|
|
|
id = Column(Integer, primary_key=True, index=True)
|
|
member_count = Column(Integer)
|
|
member_firstname = Column(String, index=True)
|
|
member_firstname_spouse = Column(NullCatchingString())
|
|
member_surname = Column(String, index=True)
|
|
member_suffix = Column(NullCatchingString(), nullable=True)
|
|
member_street = Column(NullCatchingString(), index=True)
|
|
member_streetnumber = Column(NullCatchingString(), nullable=True)
|
|
member_email = Column(EmailType, index=True)
|
|
member_zip = Column(NullCatchingInteger(), index=True)
|
|
member_city = Column(NullCatchingString(), index=True)
|
|
member_active = Column(Boolean, default=True)
|
|
member_gender = Column(String, nullable=True)
|
|
member_connected = Column(Integer, ForeignKey("members.id"), nullable=True)
|
|
created_date = Column(DateTime, default=datetime.datetime.utcnow)
|
|
updated_date = Column(DateTime, default=datetime.datetime.utcnow)
|
|
member_died = Column(DateTime)
|
|
member_membership_start = Column(DateTime)
|
|
member_printed = Column(Boolean, default=False)
|
|
#member_coordinates = Column(Geometry(geometry_type='POINT'))
|
|
member_geo_latitude = Column(Float, nullable=True)
|
|
member_geo_longitude = Column(Float, nullable=True)
|
|
member_deliveries = relationship('Deliveries', backref='members')
|
|
member_payments = relationship('Payments', backref='members')
|
|
#member_deliveries: Mapped[List["Deliveries"]] = relationship()
|
|
#current_state_code = Column(String, index=True)
|
|
#current_state_name = relationship('MemberStates', backref='state_code')
|
|
|
|
current_state_code = Column(TrimChar, index=True) # No foreign key
|
|
current_state_changed_at = Column(DateTime)
|
|
|
|
# Use primaryjoin to specify the join condition
|
|
current_state = relationship(
|
|
'MemberStates',
|
|
primaryjoin='Members.current_state_code == MemberStates.state_code',
|
|
foreign_keys=[current_state_code]
|
|
)
|
|
|
|
def __repr__(self):
|
|
return f'<Comment "{self.content[:20]}...">'
|
|
|
|
class Payments(Base):
|
|
__tablename__ = 'payments'
|
|
|
|
id = Column(Integer, primary_key=True, index=True)
|
|
payment_date = Column(DateTime, index=True)
|
|
member_id = Column(Integer, ForeignKey("members.id"))
|
|
payment_amount = Column(Numeric)
|
|
payment_year = Column(DateTime, index=True)
|
|
|
|
def __repr__(self):
|
|
return f'<Comment "{self.content[:20]}...">'
|
|
|
|
class Deliveries(Base):
|
|
__tablename__ = 'deliveries'
|
|
|
|
id = Column(Integer, primary_key=True, index=True)
|
|
delivery_date = Column(DateTime, index=True)
|
|
member_id = Column(Integer, ForeignKey("members.id"))
|
|
delivered_by_id = Column(Integer)
|
|
delivery_year = Column(DateTime, index=True)
|
|
|
|
def __repr__(self):
|
|
return f'<Comment "{self.content[:20]}...">'
|
|
|
|
""" delivered_by_id = Column(Integer, ForeignKey("members.id" ))
|
|
member = relationship("Members", foreign_keys=[member_id])
|
|
delivering_member = relationship("Members", foreign_keys=[member_id]) """
|
|
|
|
class Payments_CSV(Base):
|
|
__tablename__ = 'payments_csv'
|
|
|
|
id = Column(Integer, primary_key=True, index=True)
|
|
pc_valuta_date = Column(DateTime)
|
|
pc_client = Column(String)
|
|
pc_reference = Column(String)
|
|
pc_intended = Column(String)
|
|
pc_iban = Column(String)
|
|
pc_entry_date = Column(DateTime)
|
|
pc_amount = Column(Numeric)
|
|
pc_currency = Column(String)
|
|
pc_timestamp = Column(DateTime)
|
|
pc_processed = Column(Boolean, default=False)
|
|
|
|
class MemberStates(Base):
|
|
__tablename__ = 'member_states'
|
|
|
|
state_code = Column(TrimChar, primary_key=True, index=True)
|
|
state_name = Column(String(20), nullable=False)
|
|
description = Column(String)
|
|
created_at = Column(DateTime)
|
|
|
|
class MemberStateLog(Base):
|
|
__tablename__ = 'member_state_log'
|
|
|
|
log_id = Column(Integer, primary_key=True)
|
|
member_id = Column(Integer, ForeignKey('members.id'), nullable=False)
|
|
state_code = Column(String(1), ForeignKey('member_states.state_code'), nullable=False)
|
|
changed_at = Column(DateTime)
|
|
changed_by = Column(Integer) # Optional: user ID who made the change
|
|
reason = Column(String)
|
|
|
|
# Relationships
|
|
member = relationship('Members', backref='state_history')
|
|
state = relationship('MemberStates') |