greater_wms/bound/models.py

from django.db import models
from erp.models import InboundBill, MaterialDetail, OutboundBill,OutMaterialDetail
from django.db.models import Sum
from django.db.models.signals import post_save, post_delete, pre_save
from django.dispatch import receiver
from decimal import Decimal
class BoundListModel(models.Model):
    STATUS =( 
            ("100", '入库申请'), ("101", '入库同意'), ("102", '组盘中'), ("103", '部分入库'), ("104", '已入库'),
            ("111", '质检合格'),
            ("200", '出库申请'), ("201", '出库同意'), ("202", '出库中'), ("203", '部分出库'), ("204", '已出库'), 
            ("300", '完成')
            )
    
    audit_status = models.BooleanField(default=False, verbose_name='审核状态')

    bound_month = models.CharField(max_length=255, verbose_name="月份")
    bound_date = models.DateField(verbose_name="单据日期")

    bound_code = models.CharField(max_length=255, verbose_name="出入库编号",unique=True)
    bound_code_type = models.CharField(max_length=255, verbose_name="单据类型")
    bound_bs_type = models.CharField(max_length=255, verbose_name="业务类型")
    bound_type = models.CharField(max_length=255, verbose_name="出入库类型")
    bound_desc = models.CharField(default='', max_length=255, verbose_name="出入库描述")
    bound_department = models.CharField(max_length=255, verbose_name="部门")

    base_type = models.IntegerField(default=0, verbose_name="基准类型")

    bound_status = models.CharField(max_length=255, verbose_name="单据状态",choices=STATUS, default='100')
    note = models.CharField(default='', max_length=255, verbose_name="备注")

    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")
    relate_bill = models.ForeignKey(InboundBill, on_delete=models.CASCADE, verbose_name="关联单据", related_name='bound_list',null=True, blank=True)
    relate_out_bill = models.ForeignKey(OutboundBill, on_delete=models.CASCADE, verbose_name="关联出库单据", related_name='bound_out_list',null=True, blank=True)

    class Meta:
        db_table = 'boundlist'
        verbose_name = 'Bound List'
        verbose_name_plural = "Bound List"
        ordering = ['-id']

class BoundBatchModel(models.Model):

    CONTAINER_STATUS = (
        (0, '入库申请'),
        (1, '入库中'),
        (2, '部分入库'),
        (3, '在库'),
        (4, '出库中'),
        (5, '部分出库'),
        (6, '已出库'),

    )
    CHECK_STATUS=(
        (0, '未质检'),
        (1, '已质检'),
        (2, '质检不合格'),
    )

    bound_number = models.CharField(max_length=255, verbose_name="入库批次号",blank=False, null=False, unique=True)
    sourced_number = models.CharField(max_length=255, verbose_name="来源批次号",blank=True, null=True)
    bound_month = models.CharField(max_length=255, verbose_name="月份")
    bound_batch_order = models.IntegerField(default=0, verbose_name="批次顺序")
  
    warehouse_code = models.CharField(max_length=255, verbose_name="仓库编码")
    warehouse_name = models.CharField(max_length=255, verbose_name="仓库名称")
    goods_code = models.CharField(max_length=255, verbose_name="商品编码")
    goods_desc = models.CharField(max_length=255, verbose_name="商品描述")
    goods_std = models.CharField(default='待填写', max_length=255, verbose_name="商品标准",blank=True, null=True)
    goods_unit = models.CharField(default='待填写', max_length=255, verbose_name="商品单位")
    goods_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="商品数量")
    goods_package = models.CharField(default='待填写', max_length=255, verbose_name="商品包装")
    goods_in_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="组盘入库数量")
    goods_in_location_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'), verbose_name="库位入库数量")
    goods_out_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="出库数量")
    goods_reserve_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="预定出库数量")

    status = models.IntegerField(choices=CONTAINER_STATUS, default=0, verbose_name='批次状态')
    container_number = models.IntegerField( default=0, verbose_name="托盘数目")
    goods_weight = models.FloatField(default=0, verbose_name="商品单重")
    goods_total_weight = models.FloatField(default=0, verbose_name="商品总重")
    note = models.CharField(default='', max_length=255, verbose_name="备注")

    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")
    relate_material = models.ForeignKey(MaterialDetail, on_delete=models.CASCADE, verbose_name="关联物料", related_name='bound_batch',null=True, blank=True)
    
    check_status = models.IntegerField(choices=CHECK_STATUS, default=0, verbose_name='质检状态')
    check_user = models.CharField(default='', max_length=255, verbose_name="质检人")
    check_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="质检时间")


    class Meta:
        db_table = 'boundbatch'
        verbose_name = 'Bound Batch'
        verbose_name_plural = "Bound Batch"
        ordering = ['-id']

    def __str__(self):
        return f"{self.bound_number} - {self.goods_code} - {self.goods_desc}"
    


    
class OutBoundDemandModel(models.Model):
    OUT_TYPE = (
        (0, '发货出库'),
        (4, '其他出库'),
    )
    bound_list = models.ForeignKey(BoundListModel, on_delete=models.CASCADE, verbose_name="Bound List", related_name='out_demand')
    goods_code = models.CharField(max_length=255, verbose_name="商品编码")
    goods_desc = models.CharField(max_length=255, verbose_name="商品描述")
    goods_std = models.CharField(default='待填写', max_length=255, verbose_name="商品标准",blank=True, null=True)
    goods_unit = models.CharField(default='待填写', max_length=255, verbose_name="商品单位")
    goods_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="计划数量")
    working = models.BooleanField(default=False, verbose_name="是否在工作")
    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    out_type = models.IntegerField(choices=OUT_TYPE, default=4,  verbose_name="出库类型")

    class Meta:
        db_table = 'outbounddemand'
        verbose_name = '出库需求'
        verbose_name_plural = "出库需求"
        ordering = ['-id']

class MaterialStatistics(models.Model):
    goods_code = models.CharField(max_length=255, verbose_name="商品编码", unique=True)
    goods_desc = models.CharField(max_length=255, verbose_name="商品描述")
    goods_std = models.CharField(default='待填写', max_length=255, verbose_name="商品标准", blank=True, null=True)
    goods_unit = models.CharField(default='待填写', max_length=255, verbose_name="商品单位")
    total_quantity = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="在库数量")
    total_demanded_quantity = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'), verbose_name="需求数量")

    def __str__(self):
        return f"{self.goods_code} - {self.goods_desc}"

    @property
    def bound_batches(self):
        return BoundBatchModel.objects.filter(goods_code=self.goods_code).exclude(goods_in_location_qty=0).order_by('bound_batch_order')

    @classmethod
    def get_period_summary(cls, goods_code, start_date, end_date):
        """获取指定时间段的库存变动汇总"""
        period_data = cls.objects.filter(
            goods_code=goods_code,
            history_records__change_time__range=(start_date, end_date)
        ).annotate(
            period_in=Sum('history_records__in_quantity'),
            period_out=Sum('history_records__out_quantity'),
        ).first()
        
        if period_data:
            return {
                'period_in': period_data.period_in or Decimal('0'),
                'period_out': period_data.period_out or Decimal('0')
            }
        return {'period_in': Decimal('0'), 'period_out': Decimal('0')}
    
    class Meta:
        db_table = 'materialstatistics'
        verbose_name = '物料统计'
        verbose_name_plural = "物料统计"
        ordering = ['goods_code']







@receiver(pre_save, sender=BoundBatchModel)
def store_original_goods_code(sender, instance, **kwargs):
    """保存前记录原始物料编码（仅更新时生效）"""
    if not instance.pk:  # 新建对象无原始值
        return

    try:
        original = BoundBatchModel.objects.get(pk=instance.pk)
        # 将原始值存储在实例属性中供post_save使用
        instance._original_goods_code = original.goods_code  
    except BoundBatchModel.DoesNotExist:
        pass

@receiver([post_save, post_delete], sender=BoundBatchModel)
def update_material_statistics(sender, instance, **kwargs):
    # 处理删除/创建/更新操作的核心逻辑
    def refresh_stats(target_goods_code, force_desc=False):
        """刷新指定物料的统计数据"""
        stats, created = MaterialStatistics.objects.get_or_create(
            goods_code=target_goods_code,
            defaults={
                'goods_desc': instance.goods_desc,
                'goods_std': instance.goods_std or '待填写',
                'goods_unit': instance.goods_unit or '待填写',
            }
        )
        
        # 仅强制更新描述（用于当前物料）或新建时初始化
        if force_desc or created:
            stats.goods_desc = instance.goods_desc
            if instance.goods_std and instance.goods_std != '待填写':
                stats.goods_std = instance.goods_std
            if instance.goods_unit and instance.goods_unit != '待填写':
                stats.goods_unit = instance.goods_unit
        
        # 重新聚合统计数据（始终执行）
        agg = BoundBatchModel.objects.filter(goods_code=target_goods_code).aggregate(
            total=Sum('goods_in_location_qty'),
            total_out=Sum('goods_out_qty')
        )
        stats.total_quantity = agg['total'] or 0
        # 如果有出库统计字段需更新，可在此添加
        stats.save()

    # 情况1：删除操作直接更新当前物料
    if kwargs.get('signal') == post_delete:
        refresh_stats(instance.goods_code)
        return

    # 情况2：创建操作直接更新新物料
    if kwargs.get('created'):
        refresh_stats(instance.goods_code, force_desc=True)
        return

    # 情况3：更新操作（检测物料编码变更）
    original_code = getattr(instance, '_original_goods_code', None)
    current_code = instance.goods_code

    # 物料编码未变化时仅更新当前物料
    if original_code == current_code:
        refresh_stats(current_code, force_desc=True)
    # 物料编码变化时更新新旧两个物料
    else:
        refresh_stats(original_code)      # 更新旧物料（仅刷新数量）
        refresh_stats(current_code, force_desc=True)  # 更新新物料（全量刷新）

# 物料统计的扩展方法
def get_material_period_report(goods_code, start_date, end_date):
    """获取物料在特定时间段的变动报告"""
    stats = MaterialStatistics.objects.filter(goods_code=goods_code).first()
    if not stats:
        return None
    
    # 获取时间段的变动汇总
    period_summary = stats.get_period_summary(start_date, end_date)
    from container.models import MaterialChangeHistory
    # 计算期初数量（时间段开始前的最新库存）
    opening_record = MaterialChangeHistory.objects.filter(
        material_stats=stats,
        change_time__lt=start_date
    ).order_by('-change_time').first()
    
    opening_quantity = opening_record.closing_quantity if opening_record else Decimal('0')
    
    # 计算期末数量
    period_net = period_summary['period_in'] - period_summary['period_out']
    closing_quantity = opening_quantity + period_net
    
    return {
        'goods_code': goods_code,
        'goods_desc': stats.goods_desc,
        'opening_quantity': opening_quantity,
        'period_in': period_summary['period_in'],
        'period_out': period_summary['period_out'],
        'net_change': period_net,
        'closing_quantity': closing_quantity,
        'current_quantity': stats.total_quantity
    }

class OutBatchModel(models.Model):
    CONTAINER_STATUS = (
        (0, '申请'),
        (1, '在途'),
        (2, '已出库')
    )
    OUT_TYPE = (
        (0, '发货出库'),
        (4, '其他出库'),
    )
    bound_list = models.ForeignKey(BoundListModel, on_delete=models.CASCADE, verbose_name="Bound List", related_name='out_batch_list',blank=True, null=True)

    out_number = models.CharField(max_length=255, verbose_name="出库批次号",blank=False, null=False)

    batch_number = models.ForeignKey(BoundBatchModel, on_delete=models.CASCADE, verbose_name="批次号", related_name='out_batch')

    out_date = models.DateTimeField(verbose_name="出库日期")

    out_type = models.IntegerField(choices=OUT_TYPE, default=4,  verbose_name="出库类型")
    out_note = models.CharField(default='', max_length=255, verbose_name="出库备注")

    warehouse_code = models.CharField(max_length=255, verbose_name="仓库编码")
    warehouse_name = models.CharField(max_length=255, verbose_name="仓库名称")

    goods_code = models.CharField(max_length=255, verbose_name="商品编码")
    goods_desc = models.CharField(max_length=255, verbose_name="商品描述")
    goods_std = models.CharField(default='待填写', max_length=255, verbose_name="商品标准",blank=True, null=True)
    goods_unit = models.CharField(default='待填写', max_length=255, verbose_name="商品单位")
    goods_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="商品数量")
    goods_out_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'),  verbose_name="出库数量")


    status = models.IntegerField(choices=CONTAINER_STATUS, default=0, verbose_name='批次状态')

    container_number = models.IntegerField( default=0, verbose_name="托盘数目")
    goods_weight = models.FloatField(default=0, verbose_name="商品单重")
    goods_total_weight = models.FloatField(default=0, verbose_name="商品总重")

    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")
    relate_material = models.ForeignKey(OutMaterialDetail, on_delete=models.CASCADE, verbose_name="关联物料", related_name='out_batch',null=True, blank=True)

    class Meta:
        db_table = 'outbatch'
        verbose_name = 'Out Batch'
        verbose_name_plural = "Out Batch"
        ordering = ['-id']

@receiver([post_save, post_delete], sender=OutBatchModel)
def update_material_demanded(sender, instance, **kwargs):
    goods_code = instance.goods_code
    stats, created = MaterialStatistics.objects.get_or_create(
        goods_code=goods_code,
        defaults={
            'goods_desc': instance.goods_desc,
            'goods_std': instance.goods_std or '待填写',
            'goods_unit': instance.goods_unit or '待填写',
        }
    )
    
    # 更新物料信息为最新批次的信息（可选）
    stats.goods_desc = instance.goods_desc
    if instance.goods_std and instance.goods_std != '待填写':
        stats.goods_std = instance.goods_std
    if instance.goods_unit and instance.goods_unit != '待填写':
        stats.goods_unit = instance.goods_unit
    stats.save()

    # 计算总数量
    total = OutBatchModel.objects.filter(goods_code=goods_code,is_delete=False).aggregate(
        total=Sum('goods_out_qty')
    )['total'] or 0
    stats.total_demanded_quantity = total
    stats.save()

    batch_number = instance.batch_number
    batch_out_qty = OutBatchModel.objects.filter(batch_number=batch_number,goods_code=goods_code,is_delete=False).aggregate(
        total=Sum('goods_out_qty')
    )['total'] or 0
    batch_number.goods_reserve_qty = batch_out_qty
    batch_number.save()

# 利用创建好的批次来与申请单相对应       
class OutBoundDetailModel(models.Model):
    CONTAINER_STATUS = (
        (0, '出库申请'),
        (1, '出库中'),
        (2, '已出库'),
        (3, '入库中'),
        (4, '已入库')
    )

    bound_list = models.ForeignKey(BoundListModel, on_delete=models.CASCADE, verbose_name="Bound List", related_name='out_bound_detail')
    bound_batch = models.ForeignKey(OutBatchModel, on_delete=models.PROTECT, verbose_name="Bound Batch", related_name='out_bound_batch_detail')
    bound_batch_number = models.ForeignKey(BoundBatchModel, on_delete=models.CASCADE, verbose_name="Bound Batch Number", related_name='out_bound_batch_number_detail')
    status = models.IntegerField(choices=CONTAINER_STATUS, default=0, verbose_name='批次状态')
    
    detail_code = models.CharField(max_length=255, verbose_name="明细编号")
    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")

    class Meta:
        db_table = 'Outbounddetail'
        verbose_name = 'OutBound Detail'
        verbose_name_plural = "OutBound Detail"
        ordering = ['-id']

class BatchOperateLogModel(models.Model):
    BATCH_LOG_TYPE = (
        (0, '入库'),
        (1, '出库'),
        (2, '移库'),
        (9, '其他'),
        
    )
    batch_id  =models.ForeignKey(BoundBatchModel, on_delete=models.CASCADE, verbose_name="批次ID", related_name='batch_log')
    log_type = models.IntegerField(choices=BATCH_LOG_TYPE, default=9, verbose_name="日志类型")
    log_date = models.DateTimeField(verbose_name="日志日期")
    goods_code = models.CharField(max_length=255, verbose_name="商品编码")
    goods_desc = models.CharField(max_length=255, verbose_name="商品描述")
    goods_qty = models.DecimalField(max_digits=10, decimal_places=3, default=Decimal('0'), verbose_name="商品数量")
    log_content = models.CharField(max_length=255, verbose_name="日志内容")
    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")

    class Meta:
        db_table = 'batchlog'
        verbose_name = 'Batch Log'
        verbose_name_plural = "Batch Log"

# 利用创建好的批次来与申请单相对应       
class BoundDetailModel(models.Model):
    CONTAINER_STATUS = (
        (0, '入库申请'),
        (1, '入库中'),
        (2, '在库'),
        (3, '出库中'),
        (4, '已出库')
    )

    bound_list = models.ForeignKey(BoundListModel, on_delete=models.CASCADE, verbose_name="Bound List", related_name='bound_detail')
    bound_batch = models.ForeignKey(BoundBatchModel, on_delete=models.PROTECT, verbose_name="Bound Batch", related_name='bound_batch_detail')
    status = models.IntegerField(choices=CONTAINER_STATUS, default=0, verbose_name='批次状态')
    
    detail_code = models.CharField(max_length=255, verbose_name="明细编号",unique=True)
    creater = models.CharField(default='uesr', max_length=255, verbose_name="Who Created")
    openid = models.CharField(max_length=255, verbose_name="Openid")
    is_delete = models.BooleanField(default=False, verbose_name='Delete Label')
    create_time = models.DateTimeField(auto_now_add=True, verbose_name="Create Time")
    update_time = models.DateTimeField(auto_now=True, blank=True, null=True, verbose_name="Update Time")

    class Meta:
        db_table = 'bounddetail'
        verbose_name = 'Bound Detail'
        verbose_name_plural = "Bound Detail"
        ordering = ['-id']