apps/edu/urls.py

@@ -11,7 +11,7 @@ router.register('question', QuestionViewSet, basename='question')
 router.register('paper', PaperViewSet, basename='paper')
 router.register('exam', ExamViewSet, basename='exam')
 router.register('examrecord', ExamRecordViewSet, basename='examrecord')
-router.register('training', TrainRecordViewSet, basename='training')
+router.register('training', TrainRecordViewSet, basename='examrecord')
 urlpatterns = [
     path(API_BASE_URL, include(router.urls)),
 ]

apps/inm/urls.py

@@ -13,10 +13,10 @@ router.register('warehouse', WarehouseVIewSet, basename='warehouse')
 router.register('materialbatch', MaterialBatchViewSet,
                 basename='materialbatch')
 router.register('mio', MIOViewSet, basename='mio')
-router.register('mio/do', MioDoViewSet, basename='mio_do')
+router.register('mio/do', MioDoViewSet)
-router.register('mio/sale', MioSaleViewSet, basename='mio_sale')
+router.register('mio/sale', MioSaleViewSet)
-router.register('mio/pur', MioPurViewSet, basename='mio_pur')
+router.register('mio/pur', MioPurViewSet)
-router.register('mio/other', MioOtherViewSet, basename='mio_other')
+router.register('mio/other', MioOtherViewSet)
 router.register('mioitem', MIOItemViewSet, basename='mioitem')
 router.register('mioitemw', MIOItemwViewSet, basename='mioitemw')
 # router.register('pack', PackViewSet, basename='pack')

apps/system/filters.py

@@ -7,7 +7,6 @@ from rest_framework.exceptions import ParseError
 class UserFilterSet(filters.FilterSet):
     ubelong_dept__name = filters.CharFilter(label='归属于该部门及以下(按名称)', method='filter_ubelong_dept__name')
     ubelong_dept = filters.CharFilter(label='归属于该部门及以下', method='filter_ubelong_dept')
-    has_perm = filters.CharFilter(label='拥有指定权限标识', method='filter_has_perm')
 
     class Meta:
         model = User
@@ -39,9 +38,6 @@ class UserFilterSet(filters.FilterSet):
             raise ParseError(f"部门ID错误: {value} {str(e)}")
         return queryset.filter(belong_dept__in=depts)
 
-    def filter_has_perm(self, queryset, name, value):
-        return queryset.filter(up_user__post__pr_post__role__perms__codes__contains=value)
-
 
 class DeptFilterSet(filters.FilterSet):
 

apps/system/migrations/0007_alter_dept_create_by_alter_dept_third_info_and_more.py

@@ -1,120 +0,0 @@
-# Generated by Django 4.2.27 on 2026-01-16 06:41
-
-from django.conf import settings
-from django.db import migrations, models
-import django.db.models.deletion
-
-
-class Migration(migrations.Migration):
-
-    dependencies = [
-        ('system', '0006_auto_20241213_1249'),
-    ]
-
-    operations = [
-        migrations.AlterField(
-            model_name='dept',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='dept',
-            name='third_info',
-            field=models.JSONField(blank=True, default=dict, verbose_name='三方系统信息'),
-        ),
-        migrations.AlterField(
-            model_name='dept',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='dictionary',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='dictionary',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='dicttype',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='dicttype',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='file',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='file',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='myschedule',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='myschedule',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='post',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='post',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='postrole',
-            name='post',
-            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='pr_post', to='system.post', verbose_name='关联岗位'),
-        ),
-        migrations.AlterField(
-            model_name='postrole',
-            name='role',
-            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='pr_role', to='system.role', verbose_name='关联角色'),
-        ),
-        migrations.AlterField(
-            model_name='role',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='role',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='user',
-            name='belong_dept',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_belong_dept', to='system.dept', verbose_name='所属部门'),
-        ),
-        migrations.AlterField(
-            model_name='user',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='user',
-            name='roles',
-            field=models.ManyToManyField(blank=True, to='system.role', verbose_name='关联角色'),
-        ),
-        migrations.AlterField(
-            model_name='user',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-    ]

apps/system/models.py

@@ -54,7 +54,7 @@ class Dept(ParentModel, CommonAModel):
     name = models.CharField('名称', max_length=60)
     type = models.CharField('类型', max_length=20, default='dept')
     sort = models.PositiveSmallIntegerField('排序标记', default=1)
-    third_info = models.JSONField('三方系统信息', default=dict, blank=True)
+    third_info = models.JSONField('三方系统信息', default=dict)
 
     class Meta:
         verbose_name = '部门'
@@ -107,9 +107,9 @@ class PostRole(BaseModel):
     data_range = models.PositiveSmallIntegerField('数据权限范围', choices=DataFilter.choices,
                                                   default=DataFilter.THISLEVEL_AND_BELOW)
     post = models.ForeignKey(Post, verbose_name='关联岗位',
-                             on_delete=models.CASCADE, related_name="pr_post")
+                             on_delete=models.CASCADE)
     role = models.ForeignKey(Role, verbose_name='关联角色',
-                             on_delete=models.CASCADE, related_name='pr_role')
+                             on_delete=models.CASCADE)
 
 
 class SoftDeletableUserManager(SoftDeletableManagerMixin, UserManager):
@@ -132,7 +132,7 @@ class User(AbstractUser, CommonBModel):
     posts = models.ManyToManyField(
         Post, through='system.userpost', related_name='user_posts')
     depts = models.ManyToManyField(Dept, through='system.userpost')
-    roles = models.ManyToManyField(Role, verbose_name='关联角色', blank=True)
+    roles = models.ManyToManyField(Role, verbose_name='关联角色')
 
     # 关联账号
     secret = models.CharField('密钥', max_length=100, null=True, blank=True)

apps/system/serializers.py

@@ -322,7 +322,7 @@ def phone_exist(phone):
 
 
 def user_exist(username):
-    if User.objects.get_queryset(all=True).filter(username=username).exists():
+    if User.objects.filter(username=username).exists():
         raise serializers.ValidationError(**USERNAME_EXIST)
     return username
 

apps/utils/mixins.py

@@ -300,15 +300,9 @@ class ComplexQueryMixin:
         page = self.paginate_queryset(new_qs)
         if page is not None:
             serializer = self.get_serializer(page, many=True)
-            rdata = serializer.data
+            return self.get_paginated_response(serializer.data)
-            if hasattr(self, 'add_info_for_list'):
-                rdata = self.add_info_for_list(rdata)
-            return self.get_paginated_response(rdata)
         serializer = self.get_serializer(new_qs, many=True)
-        rdata = serializer.data
+        return Response(serializer.data)
-        if hasattr(self, 'add_info_for_list'):
-            rdata = self.add_info_for_list(rdata)
-        return Response(rdata)
     
 class MyLoggingMixin(object):
     """Mixin to log requests"""

apps/utils/models.py

@@ -151,32 +151,6 @@ class BaseModel(models.Model):
                 time.sleep(0.1 * (attempt + 1))
         
         
-    @classmethod
-    def locked_get_or_create(cls, defaults: dict, **kwargs):
-        """
-        仅用于事务内
-        并发安全的 get_or_create
-        """
-        if not connection.in_atomic_block:
-            raise RuntimeError("locked_get_or_create 必须在事务中调用")
-
-        defaults = defaults or {}
-
-        qs = cls.objects.select_for_update().filter(**kwargs)
-
-        cnt = qs.count()
-        if cnt > 1:
-            raise RuntimeError(
-                f"{cls.__name__} 数据异常：定位条件 {kwargs} 命中 {cnt} 条"
-            )
-
-        if cnt == 1:
-            return qs.get(), False
-
-        params = {**kwargs, **defaults}
-        obj = cls.objects.create(**params)
-        return obj, True
-
     def handle_parent(self):
         pass
 

apps/wpm/filters.py

@@ -1,8 +1,8 @@
 from django_filters import rest_framework as filters
 from apps.wpm.models import (SfLog, StLog, WMaterial, Mlog, Mlogbw,
-                             Handover, Mgroup, Mlogb, Mtask, BatchSt, Handoverb)
+                             Handover, Mgroup, Mlogb, Mtask, BatchSt)
 from apps.mtm.models import Route, Material
-from django.db.models import Q, Exists, OuterRef
+from django.db.models import Q
 from rest_framework.exceptions import ParseError
 from datetime import datetime
 
@@ -43,7 +43,6 @@ class WMaterialFilter(filters.FilterSet):
     material__process__exclude = filters.CharFilter(field_name="material__process", lookup_expr="exact", exclude=True)
     mlog_date_start = filters.DateFilter(label="产出开始", method="filter_mlog_date_start")
     mlog_date_end = filters.DateFilter(label="产出结束", method="filter_mlog_date_end")
-    current_merged = filters.BooleanFilter(label="是否本工段新合成的批", method="filter_current_merged")
 
     def filter_mlog_date_start(self, queryset, name, value):
         mgroupId = self.data.get("mgroup", None)
@@ -102,18 +101,6 @@ class WMaterialFilter(filters.FilterSet):
             raise ParseError('生产路线不存在!')
         return queryset.filter(material=route.material_in)|queryset.filter(material__in=route.materials.all())
     
-    def filter_current_merged(self, queryset, name, value):
-        sub_qs = Handoverb.objects.filter(
-            wm_to=OuterRef("pk"),
-            handover__mtype=Handover.H_MERGE,
-            handover__submit_time__isnull=False
-        )
-        if value is True:
-            return queryset.annotate(_has_merge=Exists(sub_qs)).filter(_has_merge=True)
-        elif value is False:
-            return queryset.annotate(_has_merge=Exists(sub_qs)).filter(_has_merge=False)
-        return queryset
-
     class Meta:
         model = WMaterial
         fields = {
@@ -167,17 +154,11 @@ class MlogFilter(filters.FilterSet):
 class HandoverFilter(filters.FilterSet):
     cbatch = filters.CharFilter(label='批次号', method='filter_cbatch')
     mgroup = filters.CharFilter(label='MgroupId', method='filter_mgroup')
-    mgroupx = filters.CharFilter(label='MgroupId', method='filter_mgroupx')
     dept = filters.CharFilter(label='DeptId', method='filter_dept')
 
     def filter_mgroup(self, queryset, name, value):
         return queryset.filter(send_mgroup__id=value)|queryset.filter(recive_mgroup__id=value)
     
-    def filter_mgroupx(self, queryset, name, value):
-        dept = Mgroup.objects.get(id=value).belong_dept
-        return (queryset.filter(send_mgroup__id=value)|queryset.filter(recive_mgroup__id=value)|
-        queryset.filter(send_dept=dept, send_mgroup__isnull=True)|queryset.filter(recive_dept=dept, recive_mgroup__isnull=True))
-    
     def filter_dept(self, queryset, name, value):
         return queryset.filter(send_dept__id=value)|queryset.filter(recive_dept__id=value)
     
@@ -242,10 +223,6 @@ class MlogbFilter(filters.FilterSet):
 class BatchStFilter(filters.FilterSet):
     batch__startswith__in = filters.CharFilter(method='filter_batch')
     data__has_key = filters.CharFilter(method='filter_data')
-    with_source_near = filters.CharFilter(label='来源', method='filter_source_near')
-
-    def filter_source_near(self, queryset, name, value):
-        return queryset
 
     def filter_data(self, queryset, name, value):
         return queryset.filter(data__has_key=value)

apps/wpm/migrations/0127_handoverb_oinfo_json_alter_attlog_create_by_and_more.py

@@ -1,117 +0,0 @@
-# Generated by Django 4.2.27 on 2026-01-16 07:29
-
-from django.conf import settings
-from django.db import migrations, models
-import django.db.models.deletion
-
-
-class Migration(migrations.Migration):
-
-    dependencies = [
-        migrations.swappable_dependency(settings.AUTH_USER_MODEL),
-        ('system', '0007_alter_dept_create_by_alter_dept_third_info_and_more'),
-        ('wpm', '0126_auto_20251208_1337'),
-    ]
-
-    operations = [
-        migrations.AddField(
-            model_name='handoverb',
-            name='oinfo_json',
-            field=models.JSONField(blank=True, default=dict, verbose_name='其他信息'),
-        ),
-        migrations.AlterField(
-            model_name='attlog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='attlog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='fmlog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='fmlog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='handover',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='handover',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='mlog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='mlog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='otherlog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='otherlog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='sflog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='sflog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='sflogexp',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='sflogexp',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='stlog',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='stlog',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-        migrations.AlterField(
-            model_name='wmaterial',
-            name='belong_dept',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_belong_dept', to='system.dept', verbose_name='所属部门'),
-        ),
-        migrations.AlterField(
-            model_name='wmaterial',
-            name='create_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_create_by', to=settings.AUTH_USER_MODEL, verbose_name='创建人'),
-        ),
-        migrations.AlterField(
-            model_name='wmaterial',
-            name='update_by',
-            field=models.ForeignKey(blank=True, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='%(class)s_update_by', to=settings.AUTH_USER_MODEL, verbose_name='最后编辑人'),
-        ),
-    ]

apps/wpm/models.py

@@ -14,11 +14,9 @@ from django.db.models import Count
 from django.db import transaction
 from django.db.models import Max
 import re
-from django.db.models import Q, F
+from django.db.models import Q
 import django.utils.timezone as timezone
 from apps.utils.sql import query_all_dict
-import logging
-myLogger = logging.getLogger('log')
 
 # Create your models here.
 class SfLog(CommonADModel):
@@ -127,10 +125,6 @@ class WMaterial(CommonBDModel):
     material_ofrom = models.ForeignKey(Material, verbose_name='原料物料', on_delete=models.SET_NULL, null=True, blank=True, related_name='wm_mofrom')
     number_from = models.TextField("来源于个号", null=True, blank=True)
 
-    @property
-    def belong_dept_or_mgroup_id(self):
-        return self.mgroup.id if self.mgroup else self.belong_dept.id
-        
     @property
     def count_working(self):
         return Mlogb.objects.filter(wm_in=self, mlog__submit_time__isnull=True).aggregate(count=Sum('count_use'))['count'] or 0
@@ -168,30 +162,6 @@ class WMaterial(CommonBDModel):
                 state__in=[WMaterial.WM_OK, WMaterial.WM_REPAIR]
             )
     
-    @classmethod
-    def increase(cls, wm_id: str, user:User, count, count_eweight=None):
-        updates = {}
-        if count:
-            updates['count'] = F('count') + count
-        if count_eweight:
-            updates['count_eweight'] = count_eweight
-        if not updates:
-            return 0
-        updates["update_by"] = user
-        updates['update_time'] = timezone.now()
-        return cls.objects.filter(id=wm_id).update(**updates)
-
-    @classmethod
-    def decrease(cls, wm_id: str, user:User, count):
-        if not count:
-            return 0
-        updated = cls.objects.filter(id=wm_id, count__gte= count).update(
-            count=F('count') - count, update_by=user, update_time=timezone.now())
-        if updated == 0:
-            batch = WMaterial.objects.get(id=wm_id).batch
-            raise ParseError(f'{batch}_库存不足，无法完成扣减')
-        return updated
-    
 class Fmlog(CommonADModel):
     """TN: 父级生产日志
     """
@@ -669,7 +639,6 @@ class Handoverb(BaseModel):
     wm_to = models.ForeignKey(WMaterial, verbose_name='所到车间库存', on_delete=models.SET_NULL,
                            null=True, blank=True, related_name='handoverb_wm_to')
     count = models.DecimalField('送料数', default=0, max_digits=11, decimal_places=1)
-    oinfo_json = models.JSONField('其他信息', default=dict, blank=True)
 
     @property
     def handoverbw(self):
@@ -868,46 +837,41 @@ class BatchLog(BaseModel):
 
     @classmethod
     def batches_to(cls, batch:str):
+        
+        # query = """
+        #         SELECT batch FROM wpm_batchst 
+        #         WHERE batch ~ %s
+        #         """
         query = """
-        SELECT
+            SELECT batch
-            batch,
-            CAST(substring(batch FROM LENGTH(%s) + 2) AS INTEGER) AS batch_num
             FROM wpm_batchst 
-        WHERE batch LIKE %s  AND translate(
+            WHERE batch ~ %s 
-        substring(batch FROM LENGTH(%s) + 2),
+            ORDER BY 
-        '0123456789',
+                -- 先按前缀部分排序（例如 'A'）
-        ''
+                SUBSTRING(batch FROM '^(.*)-') DESC,
-      ) = ''
+                -- 再按后缀的数值部分排序（将 '2', '11' 转为整数）
-        ORDER BY batch_num DESC
+                CAST(SUBSTRING(batch FROM '-([0-9]+)$') AS INTEGER) DESC 
+            """ # 排序可在sql层处理
+        query_ = """SELECT batch FROM wpm_batchst WHERE batch ~ %s"""
+        pattern = f'^{batch}-[0-9]+$'
+
+        """可以用如下方法直接查询
         """
-
+        # batches = BatchLog.objects.filter(source__batch=batch, relation_type="split").values_list("target__batch", flat=True).distinct()
-        prefix = batch
+        # batches = sorted(list(batches), key=custom_key)
-        params = (
+        batches_r = query_all_dict(query_, params=(pattern,))
-            prefix,
+        batches = [b["batch"] for b in batches_r]
-            f"{prefix}-%",
+        batches = sorted(list(batches), key=custom_key)
-            prefix
+        last_batch_num = None
-        )
+        if batches:
-
+            last_batch = batches[-1]
+            last_batch_list = last_batch.split("-")
+            if last_batch_list:
                 try:
-            rows = query_all_dict(query, params=params)
+                    last_batch_num = int(last_batch_list[-1])
-        except Exception as e:
+                except Exception:
-            myLogger.error(f"BatchLog.batches_to error: {(str(e), query, params)}")
+                    pass
-            raise
+            return {"batches": batches, "last_batch_num": last_batch_num, "last_batch": last_batch}
-
+        return {"batches": [], "last_batch_num": None, "last_batch": None}
-        if not rows:
-            return {
-                "batches": [],
-                "last_batch_num": None,
-                "last_batch": None,
-            }
-
-        batches = [r["batch"] for r in rows]
-        last = rows[0]
-
-        return {
-            "batches": batches,
-            "last_batch_num": last["batch_num"],
-            "last_batch": last["batch"],
-        }
                     
         

apps/wpm/scripts/batch_gzerp.py

@@ -292,7 +292,7 @@ def main(batch: str, mgroup_obj=None):
         data["六车间交接领料_接料人"] = ";".join([item.name for item in data["六车间交接领料_接料人"]])
 
     # 六车间工段生产数据
-    mgroup_list = ["平头", "粘铁头", "粗中细磨", "平磨", "掏管", "抛光", "开槽", "倒角", "加工前检验", "中检"]
+    mgroup_list = ["平头", "粘铁头", "粗中细磨", "平磨", "掏管", "抛光", "开槽", "倒角"]
     for mgroup_name in mgroup_list:
         if mgroup_name == '粗中细磨':
             mgroups = Mgroup.objects.filter(name__in=['粗磨', '粗中磨', '粗中细磨'])

apps/wpm/scripts/wpr_bxerp.py

@@ -1,49 +1,17 @@
 from apps.wpmw.models import Wpr
-from apps.wpm.models import Mlogbw, Mlog, MlogUser
+from apps.wpm.models import Mlogbw
-from apps.qm.models import Ftest, FtestDefect, FtestItem, TestItem
+from apps.qm.models import Ftest, FtestDefect, FtestItem
 from rest_framework.exceptions import ParseError
 from apps.mtm.models import Mgroup
 
-def main(wprId, mgroup:Mgroup=None):
+def main(wprId, mgroup:Mgroup):
     wpr = Wpr.objects.get(id=wprId)
-    if mgroup is None:
-        mgroup_ids = Mlogbw.objects.filter(
-            wpr=wpr,
-            mlogb__mlog__submit_time__isnull=False,
-            mlogb__mlog__is_fix=False
-        ).values_list(
-            'mlogb__mlog__mgroup', 
-            flat=True
-        ).distinct()
-        mgroups = Mgroup.objects.filter(id__in=mgroup_ids)
-    else:
-        mgroups = [mgroup]
     data = {}
-    for mgroup in mgroups:
     mgroup_name = mgroup.name
-        mlogbw = Mlogbw.objects.filter(wpr=wpr, 
+    mlogbw = Mlogbw.objects.filter(wpr=wpr, mlogb__mlog__mgroup=mgroup, mlogb__mlog__submit_time__isnull=False).order_by("-update_time").first()
-            mlogb__mlog__mgroup=mgroup, 
-            mlogb__mlog__submit_time__isnull=False, mlogb__mlog__is_fix=False).order_by("-update_time").first()
     if mlogbw:
-            mlog:Mlog = mlogbw.mlogb.mlog
         data[f"{mgroup_name}_批次号"] = mlogbw.mlogb.batch
-            data[f"{mgroup_name}_设备编号"] = mlog.equipment.number if mlog.equipment else None
+        data[f"{mgroup_name}_日期"] = mlogbw.mlogb.mlog.handle_date.strftime("%Y-%m-%d")
-            data[f"{mgroup_name}_操作人"] = mlog.handle_user.name if mlog.handle_user else None
-            data[f"{mgroup_name}_日期"] = mlog.handle_date.strftime("%Y-%m-%d")
-            # 日志操作数据
-            if mlog.oinfo_json:
-                oinfo_keys = list(mlog.oinfo_json.keys())
-                oinfo_keys_qs = TestItem.objects.filter(id__in=oinfo_keys)
-                for item in oinfo_keys_qs:
-                    data[f"{mgroup_name}_操作项_{item.name}"] = mlog.oinfo_json[item.id]
-            # 子工序操作人和日期
-            mlogusers = MlogUser.objects.filter(mlog=mlog)
-            if mlogusers.exists():
-                datab = mlogusers.values("handle_user__name", "process__name", "handle_date")
-                for ind, item in enumerate(datab):
-                    data[f"{mgroup_name}_{item['process__name']}_操作人"] = item["handle_user__name"]
-                    data[f"{mgroup_name}_{item['process__name']}_日期"] = item["handle_date"].strftime("%Y-%m-%d")
-            # 检测数据
         ftestitems = FtestItem.objects.filter(ftest__mlogbw_ftest__wpr=wpr,
                                             ftest__mlogbw_ftest__mlogb__mlog__mgroup=mgroup,
                                             ftest__mlogbw_ftest__mlogb__mlog__submit_time__isnull=False,
@@ -57,6 +25,7 @@ def main(wprId, mgroup:Mgroup=None):
                                         ftest__mlogbw_ftest__mlogb__mlog__is_fix=False)
         for ftestdefect in ftestdefects:
             data[f"{mgroup_name}_缺陷项_{ftestdefect.defect.name}"] = 1 if ftestdefect.has is True else 0
+        
         old_data:dict = wpr.data
         if old_data:
             for item in list(old_data.keys()):

apps/wpm/serializers.py

@@ -1261,18 +1261,12 @@ class HandoverSerializer(CustomModelSerializer):
             next_mat = new_wm.material
             next_state = new_wm.state
             next_defect = new_wm.defect
-        deptOrmgroupId = None
         for ind, item in enumerate(attrs['handoverb']):
             if item["count"] > 0:
                 pass
             else:
                 raise ParseError(f'第{ind+1}行-交接数量必须大于0')
-            wm: WMaterial = item["wm"]
+            wm = item["wm"]
-            current_mdept_id = wm.belong_dept_or_mgroup_id
-            if deptOrmgroupId is None:
-                deptOrmgroupId = current_mdept_id
-            elif deptOrmgroupId != current_mdept_id:
-                raise ParseError(f'第{ind+1}行-交接物料所属工段/车间不一致')
             if mtype == Handover.H_MERGE:
                 if next_mat is None:
                     next_mat = wm.material

apps/wpm/services.py

@@ -22,7 +22,7 @@ from ..qm.models import Defect, Ftest
 from django.db.models import Count, Q
 from apps.utils.tasks import ctask_run
 from apps.mtm.models import Process
-from django.db.models import F
+from apps.utils.lock import lock_model_record_d_func
 
 myLogger = logging.getLogger('log')
 
@@ -150,12 +150,11 @@ def get_pcoal_heat(year_s: int, month_s: int, day_s: int):
             myLogger.error(f'获取煤粉热值失败，{e}, {year_s}, {month_s}, {day_s}', exc_info=True)
             return 25000
 
-
+# @lock_model_record_d_func(Mlog)
 def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     """
     生产日志提交后需要执行的操作
     """
-    mlog = Mlog.objects.select_for_update().get(id=mlog.id)
     if mlog.work_start_time and mlog.work_start_time > timezone.now():
         raise ParseError('操作开始时间不能晚于当前时间')
     if mlog.work_start_time and mlog.work_end_time and mlog.work_end_time < mlog.work_start_time:
@@ -224,7 +223,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
         # 需要判断领用数是否合理
         # 优先使用工段库存
         if isinstance(mlog_or_b, Mlogb) and mlog_or_b.wm_in:
-            wm = WMaterial.objects.select_for_update().get(id=mlog_or_b.wm_in.id)
+            wm_qs = WMaterial.objects.filter(id=mlog_or_b.wm_in.id)
         else:
             wm_qs = WMaterial.objects.filter(batch=mi_batch, material=mi_ma, mgroup=mgroup, state=WMaterial.WM_OK)
             if not wm_qs.exists():
@@ -232,7 +231,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
                                                     belong_dept=belong_dept, mgroup=None, state=WMaterial.WM_OK)
         count_x = wm_qs.count()
         if count_x == 1:
-                wm = WMaterial.objects.select_for_update().get(id=wm_qs.first().id)
+            wm = wm_qs.first()
         elif count_x == 0:
             raise ParseError(
                 f'{str(mi_ma)}-{mi_batch}-批次库存不存在!')
@@ -261,7 +260,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
                 if count <= 0:
                     raise ParseError('存在非正数!')
                 lookup = {'batch': batch, 'material': material, 'mgroup': mgroup, 'defect': defect, 'state': WMaterial.WM_NOTOK}
-                wm, is_create = WMaterial.locked_get_or_create(**lookup, defaults={"belong_dept": belong_dept})
+                wm, is_create = WMaterial.objects.get_or_create(**lookup, defaults={"belong_dept": belong_dept})
                 wm.count = wm.count + count
                 if is_create:
                     wm.create_by = user
@@ -344,7 +343,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
         else:
             lookup['belong_dept'] = belong_dept
 
-        wm, is_create2 = WMaterial.locked_get_or_create(**lookup, defaults={"belong_dept": belong_dept})
+        wm, is_create2 = WMaterial.objects.get_or_create(**lookup, defaults={**lookup, "belong_dept": belong_dept})
         wm.count = wm.count + mo_count
         wm.count_eweight = mo_count_eweight
         wm.update_by = user
@@ -402,17 +401,16 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     ana_batch_thread(xbatchs=xbatches, mgroup=mlog.mgroup)
 
     # 触发单个统计
-    wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, wpr__isnull=False).values_list('wpr__id', flat=True))
+    wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, wpr__isnull=False).values_list('wpr__id', flat=True))
     if wprIds:
         ana_wpr_thread(wprIds, mlog.mgroup)
 
-
+# @lock_model_record_d_func(Mlog)
 def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     """日志撤回
     """
     # if mlog.submit_time is None:
     #     return
-    mlog = Mlog.objects.select_for_update().get(id=mlog.id)
     if now is None:
         now = timezone.now()
 
@@ -508,8 +506,6 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
         else:
             raise ParseError(
                 f'{str(mo_ma)}-{mo_batch}-存在多个相同批次!')
-        
-        wm = WMaterial.objects.select_for_update().get(id=wm.id)
         wm.count = wm.count - mo_count
         if wm.count < 0:
             raise ParseError(f'{wm.batch} 车间库存不足, 产物无法回退')
@@ -551,7 +547,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
         if mi_count <= 0:
             raise ParseError('存在非正数!')
         if isinstance(mlog_or_b, Mlogb) and mlog_or_b.wm_in:
-            wm = WMaterial.objects.select_for_update().get(id=mlog_or_b.wm_in.id)
+            wm = WMaterial.objects.get(id=mlog_or_b.wm_in.id)
         else:
             # 针对光子的情况，实际上必须需要wm_in
             lookup = {'batch': mi_batch, 'material': mi_ma, 'mgroup': None, 'state': WMaterial.WM_OK}
@@ -561,7 +557,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
             else:
                 lookup['belong_dept'] = belong_dept
 
-            wm, _ = WMaterial.locked_get_or_create(**lookup, defaults={"belong_dept": belong_dept})
+            wm, _ = WMaterial.objects.get_or_create(**lookup, defaults={**lookup, "belong_dept": belong_dept})
         wm.count = wm.count + mi_count
         wm.update_by = user
         wm.save()
@@ -583,7 +579,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
                 lookup['mgroup'] = mgroup
             else:
                 lookup['belong_dept'] = belong_dept
-            wm, is_create = WMaterial.locked_get_or_create(**lookup, defaults={"belong_dept": belong_dept})
+            wm, is_create = WMaterial.objects.get_or_create(**lookup, defaults={**lookup, "belong_dept": belong_dept})
             wm.count = wm.count - count
             if wm.count < 0:
                 raise ParseError('加工前不良数量大于库存量')
@@ -623,7 +619,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
     ana_batch_thread(xbatches, mgroup=mlog.mgroup)
 
     # 触发单个统计
-    wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, wpr__isnull=False).values_list('wpr__id', flat=True))
+    wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, wpr__isnull=False).values_list('wpr__id', flat=True))
     if wprIds:
         ana_wpr_thread(wprIds, mlog.mgroup)
 
@@ -700,15 +696,11 @@ def update_mtask(mtask: Mtask, fill_way: int = 10):
             #     utask.state = Utask.UTASK_SUBMIT
             utask.save()
 
+@lock_model_record_d_func(Handover)
 def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime, None]):
     """
     交接提交后需要执行的操作
     """
-    handover = (
-        Handover.objects
-        .select_for_update()
-        .get(pk=handover.pk)
-    )
     if handover.submit_time is not None:
         return
     now = timezone.now()
@@ -752,11 +744,7 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
         wmId, xcount, handover_or_b = item
         if xcount <= 0:
             raise ParseError("存在非正数!")
-        wm_from = (
+        wm_from = WMaterial.objects.get(id=wmId)
-                WMaterial.objects
-                .select_for_update()
-                .get(id=wmId)
-            )
         mids.append(wm_from.material.id)
 
         # 合并为新批
@@ -780,17 +768,25 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
             batch = wm_from.batch
             batches.append(batch)
 
-        WMaterial.decrease(wm_id=wm_from.id, user=user, count=xcount)
+        if wm_from is None:
+            raise ParseError(f'{wm_from.batch} 找不到车间库存')
+        
+        count_x = wm_from.count - xcount
+        if count_x < 0:
+            raise ParseError(f'{wm_from.batch} 车间库存不足!')
+        else:
+            wm_from.count = count_x
+            wm_from.save()
 
         if need_add:
             # 开始变动
             if handover.type == Handover.H_NORMAL:
                 if mtype == Handover.H_MERGE and handover.new_wm:
-                    wm_to = WMaterial.objects.select_for_update().get(id=handover.new_wm.id)
+                    wm_to = handover.new_wm
                     if wm_to.state != wm_from.state or wm_to.material != wm_from.material or wm_to.defect != wm_from.defect:
                         raise ParseError("正常合并到的车间库存状态或物料异常")
                 else:
-                    wm_to, _ = WMaterial.locked_get_or_create(
+                    wm_to, _ = WMaterial.objects.get_or_create(
                         batch=batch,
                         material=material,
                         mgroup=recive_mgroup,
@@ -810,11 +806,11 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
                 recive_mgroup = handover.recive_mgroup
                 wm_state = WMaterial.WM_REPAIR
                 if mtype == Handover.H_MERGE and handover.new_wm:
-                    wm_to = WMaterial.objects.select_for_update().get(id=handover.new_wm.id)
+                    wm_to = handover.new_wm
                     if wm_to.state != WMaterial.WM_REPAIR or wm_to.material != wm_from.material or wm_to.defect != wm_from.defect:
                         raise ParseError("返修合并到的车间库存状态或物料异常")
                 elif recive_mgroup:
-                    wm_to, _ = WMaterial.locked_get_or_create(
+                    wm_to, _ = WMaterial.objects.get_or_create(
                         batch=batch,
                         material=material,
                         mgroup=recive_mgroup,
@@ -832,13 +828,28 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
                     )
                 else:
                     raise ParseError("返工交接必须指定接收工段")
+            elif handover.type == Handover.H_TEST:
+                raise ParseError("检验交接已废弃")
+                wm_to, _ = WMaterial.objects.get_or_create(
+                    batch=batch,
+                    material=material,
+                    mgroup=recive_mgroup,
+                    state=WMaterial.WM_TEST,
+                    belong_dept=recive_dept,
+                    defaults={
+                        "count_xtest": 0,
+                        "batch_ofrom": wm_from.batch_ofrom,
+                        "material_ofrom": wm_from.material_ofrom,
+                        "create_by": user
+                    },
+                )
             elif handover.type == Handover.H_SCRAP:
                 if mtype == Handover.H_MERGE and handover.new_wm:
-                    wm_to = WMaterial.objects.select_for_update().get(id=handover.new_wm.id)
+                    wm_to = handover.new_wm
                     if wm_to.state != WMaterial.WM_SCRAP or wm_to.material != wm_from.material or wm_to.defect != wm_from.defect:
                         raise ParseError("报废合并到的车间库存状态或物料异常")
                 elif recive_mgroup:
-                    wm_to, _ = WMaterial.locked_get_or_create(
+                    wm_to, _ = WMaterial.objects.get_or_create(
                         batch=batch,
                         material=material,
                         mgroup=recive_mgroup,
@@ -857,11 +868,11 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
                     raise ParseError("不支持非工段报废")
             elif handover.type == Handover.H_CHANGE:
                 if mtype == Handover.H_MERGE and handover.new_wm:
-                    wm_to = WMaterial.objects.select_for_update().get(id=handover.new_wm.id)
+                    wm_to = handover.new_wm
                     if wm_to.material != handover.material_changed or wm_to.state != handover.state_changed:
                         raise ParseError("改版合并到的车间库存状态或物料异常")
                 elif handover.recive_mgroup:
-                    wm_to, _ = WMaterial.locked_get_or_create(
+                    wm_to, _ = WMaterial.objects.get_or_create(
                         batch=batch,
                         material=handover.material_changed,
                         state=handover.state_changed,
@@ -884,9 +895,9 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
                 if wm_from and wm_from.state != WMaterial.WM_OK:
                     raise ParseError("仅合格品支持退回")
                 if mtype == Handover.H_MERGE and handover.new_wm:
-                    wm_to = WMaterial.objects.select_for_update().get(id=handover.new_wm.id)
+                    wm_to = handover.new_wm
                 else:
-                    wm_to, _ = WMaterial.locked_get_or_create(
+                    wm_to, _ = WMaterial.objects.get_or_create(
                         batch=batch,
                         material=material,
                         mgroup=recive_mgroup,
@@ -904,7 +915,9 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
             else:
                 raise ParseError("不支持该交接类型")
 
-            WMaterial.increase(wm_id=wm_to.id, user=user,count=xcount, count_eweight=handover.count_eweight if handover.count_eweight else None)
+            wm_to.count = wm_to.count + xcount
+            wm_to.count_eweight = handover.count_eweight  # 这行代码有隐患
+            wm_to.save()
             handover_or_b.wm_to = wm_to
             handover_or_b.save()
             if material.tracking == Material.MA_TRACKING_SINGLE:
@@ -919,8 +932,7 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
                 for item in handoverbws:
                     wpr:Wpr = item.wpr
                     Wpr.change_or_new(wpr=wpr, wm=wm_to, old_wm=wpr.wm, old_mb=wpr.mb)
-                db_count = WMaterial.objects.filter(id=wm_to.id).values_list("count", flat=True).get()
+                if wm_to.count != Wpr.objects.filter(wm=wm_to).count():
-                if db_count != Wpr.objects.filter(wm=wm_to).count():
                     raise ParseError("交接与明细数量不一致2,操作失败")
 
     handover.submit_user = user
@@ -931,8 +943,8 @@ def handover_submit(handover:Handover, user: User, now: Union[datetime.datetime,
     
     ana_batch_thread(xbatchs=batches)
 
+@lock_model_record_d_func(Handover)
 def handover_revert(handover:Handover, handler:User=None):
-    handover = Handover.objects.select_for_update().get(id=handover.id)
     if handover.submit_time is None:
         raise ParseError('该交接单未提交!')
     ticket:Ticket = handover.ticket
@@ -964,13 +976,16 @@ def handover_revert(handover:Handover, handler:User=None):
             # 此时是自己交给自己，不需要做任何操作
             pass
         else:
-            WMaterial.increase(wm_id=wm.id, user=handler, count=item.count)
+            wm.count = wm.count + item.count
-            WMaterial.decrease(wm_id=wm_to.id, user=handler, count=item.count)
+            wm.save()
+            wm_to.count = wm_to.count - item.count
+            if wm_to.count < 0:
+                raise ParseError('库存不足无法撤回!')
+            wm_to.save()
         if material.tracking == Material.MA_TRACKING_SINGLE:
                 handoverbws = Handoverbw.objects.filter(handoverb=item)
                 if handoverbws.count() != item.count:
                     raise ParseError("交接与明细数量不一致,操作失败")
-                wm = WMaterial.objects.get(id=wm.id)
                 for item in handoverbws:
                     wpr:Wpr = item.wpr
                     Wpr.change_or_new(wpr=wpr, wm=wm, old_wm=wpr.wm, old_mb=wpr.mb, add_version=False)

apps/wpm/urls.py

@@ -20,9 +20,9 @@ router.register('sflogexp', SfLogExpViewSet, basename='sflogexp')
 router.register('wmaterial', WMaterialViewSet, basename='wmaterial')
 router.register('fmlog', FmlogViewSet, basename='fmlog')
 router.register('mlog', MlogViewSet, basename='mlog')
-router.register('mlogb', MlogbViewSet, basename='mlogb')
+router.register('mlogb', MlogbViewSet)
-router.register('mlogb/in', MlogbInViewSet, basename='mlogb_in')
+router.register('mlogb/in', MlogbInViewSet)
-router.register('mlogb/out', MlogbOutViewSet, basename='mlogb_out')
+router.register('mlogb/out', MlogbOutViewSet)
 router.register('handover', HandoverViewSet, basename='handover')
 router.register('attlog', AttlogViewSet, basename='attlog')
 router.register('otherlog', OtherLogViewSet, basename='otherlog')

apps/wpm/views.py

@@ -1078,8 +1078,7 @@ class BatchStViewSet(CustomListModelMixin, ComplexQueryMixin, CustomGenericViewS
     filterset_class = BatchStFilter
 
     def add_info_for_list(self, data):
-        if  (self.request.query_params.get("with_source_near", None) == "yes" or
+        if  self.request.query_params.get("with_source_near", None) == "yes":
-            self.request.data.get("with_source_near", None) == "yes"):
             batchstIds = [ins["id"] for ins in data]
             batchlog_qs = BatchLog.objects.filter(target__id__in=batchstIds).values("id", "source", "target")
             source_data = BatchStSerializer(instance=BatchSt.objects.filter(id__in=[ins["source"] for ins in batchlog_qs]), many=True).data

apps/wpmw/filters.py

@@ -18,7 +18,6 @@ class WprFilter(filters.FilterSet):
             "wm": ["exact", "isnull"],
             "material__process": ["exact"],
             "material__name": ["exact", "contains"],
-            "wpr_from": ["exact", "isnull"],
             "state": ["exact"],
             "defects": ["exact"],
             "number": ["exact"]

apps/wpmw/views.py

@@ -1,6 +1,6 @@
 from rest_framework.decorators import action
 from apps.utils.viewsets import CustomModelViewSet, CustomGenericViewSet
-from apps.utils.mixins import CustomListModelMixin, CustomRetrieveModelMixin, ComplexQueryMixin
+from apps.utils.mixins import CustomListModelMixin, RetrieveModelMixin, ComplexQueryMixin
 
 from apps.wpmw.models import Wpr, WprDefect
 from apps.wpmw.serializers import WprSerializer, WprNewSerializer, WprDetailSerializer, WproutListSerializer, WprChangeNumberSerializer
@@ -13,7 +13,7 @@ from apps.utils.sql import query_one_dict
 from django.db.models.expressions import RawSQL
 
 
-class WprViewSet(CustomListModelMixin, CustomRetrieveModelMixin, ComplexQueryMixin, CustomGenericViewSet):
+class WprViewSet(CustomListModelMixin, RetrieveModelMixin, ComplexQueryMixin, CustomGenericViewSet):
     """动态产品
 
     动态产品
@@ -34,16 +34,6 @@ class WprViewSet(CustomListModelMixin, CustomRetrieveModelMixin, ComplexQueryMix
         "number_suffix": RawSQL("COALESCE(NULLIF(regexp_replace(wpmw_wpr.number, '.*?(\\d+)$', '\\1'), ''), '0')::bigint", []),
     }
 
-    def add_info_for_list(self, data):
-        parent_ids = [item["wpr_from"] for item in data if item.get("wpr_from", False)]
-        if parent_ids:
-            parent_data = Wpr.objects.filter(id__in=parent_ids).values("id", "number", "data")
-            parent_map = {item["id"]: item for item in parent_data}
-            for item in data:
-                if item["wpr_from"]:
-                    item["wpr_from_"] = parent_map[item["wpr_from"]]
-        return data
-
     def filter_queryset(self, queryset):
         qs = super().filter_queryset(queryset)
         if "mb__isnull" in self.request.query_params or "wm__isnull" in self.request.query_params:
@@ -102,20 +92,11 @@ class WprViewSet(CustomListModelMixin, CustomRetrieveModelMixin, ComplexQueryMix
         # 使用原始sql
         query = """
                 SELECT id, number_out FROM wpmw_wpr 
-                WHERE number_out LIKE %s
+                WHERE number_out ~ %s order by number_out desc limit 1
-                AND translate(
-        substring(number_out FROM LENGTH(%s) + 2),
-        '0123456789',
-        ''
-      ) = ''
-                order by number_out desc limit 1
                 """
-        params = (
+        pattern = f"^{prefix}[0-9]+$"
-            f"{prefix}-%",
-            prefix
-        )
         number_outs = []
-        wpr_qs_last = query_one_dict(query, [params])
+        wpr_qs_last = query_one_dict(query, [pattern])
         if wpr_qs_last:
             number_outs.append(wpr_qs_last["number_out"])
         # 查找未出库的记录
@@ -125,15 +106,9 @@ class WprViewSet(CustomListModelMixin, CustomRetrieveModelMixin, ComplexQueryMix
             query2 = """
                 select mioitemw.id, mioitemw.number_out from inm_mioitemw mioitemw left join inm_mioitem mioitem on mioitem.id = mioitemw.mioitem_id
                 left join inm_mio mio on mio.id = mioitem.mio_id
-                where mio.submit_time is null and mioitemw.number_out LIKE %s
+                where mio.submit_time is null and mioitemw.number_out ~ %s order by mioitemw.number_out desc limit 1
-                AND translate(
-        substring(mioitemw.number_out FROM LENGTH(%s) + 2),
-        '0123456789',
-        ''
-      ) = ''
-                order by mioitemw.number_out desc limit 1
                     """
-            mioitemw_last = query_one_dict(query2, [params])
+            mioitemw_last = query_one_dict(query2, [pattern])
             if mioitemw_last:
                 number_outs.append(mioitemw_last["number_out"])
         if number_outs:

requirements.txt

@@ -1,82 +1,37 @@
-# =======================
+celery==5.2.3
-# Core
+Django==3.2.12
-# =======================
+django-celery-beat==2.3.0
-Django==4.2.27
+django-celery-results==2.4.0
-
+django-cors-headers==3.11.0
-djangorestframework==3.16.1
+django-filter==21.1
-django-filter==23.5
+djangorestframework==3.13.1
-django-cors-headers==4.9.0
+djangorestframework-simplejwt==5.1.0
-
-djangorestframework-simplejwt==5.5.1
-django-restql==0.15.2
-
-# =======================
-# Celery
-# =======================
-celery==5.6.2
-django-celery-beat==2.8.1
-django-celery-results==2.6.0
-redis==7.1.0
-django-redis==6.0.0
-cron-descriptor==1.2.35
-
-# =======================
-# Channels / ASGI
-# =======================
-channels==4.3.2
-daphne==4.0.0
-channels-redis==4.3.0
-
-# =======================
-# API Docs
-# =======================
 drf-yasg==1.21.7
-
-# =======================
-# Auth / Utils
-# =======================
-user-agents==2.2.0
 psutil==5.9.0
-
+pillow==9.0.1
-# =======================
-# Media / Image / CV
-# =======================
-pillow==9.5.0
 opencv-python==4.5.5.62
+redis==4.4.0
+django-redis==5.2.0
+user-agents==2.2.0
+daphne==4.0.0
+channels-redis==4.0.0
+django-restql==0.15.2
 shapely==1.8.3
-
+aliyun-python-sdk-core==2.13.36
-# =======================
+baidu-aip==4.16.6
-# Network / RPC
+chardet==5.0.0
-# =======================
+requests==2.28.1
-requests==2.32.5
 grpcio==1.47.0
 grpcio-tools==1.47.0
 protobuf==3.20.1
-
-# =======================
-# Cloud SDK
-# =======================
-aliyun-python-sdk-core==2.13.36
-baidu-aip==4.16.6
-
-# =======================
-# Crypto
-# =======================
 pycryptodome==3.15.0
-
+aliyun-python-sdk-core==2.13.36
-# =======================
-# Excel / Docs
-# =======================
 xlwt==1.3.0
-openpyxl==3.1.5
+openpyxl==3.1.0
-docxtpl==0.16.7
+cron-descriptor==1.2.35
-
-# =======================
-# DB
-# =======================
 pymysql==1.0.3
-
+# face-recognition==1.3.0
-# =======================
+docxtpl==0.16.7
-# IoT / MQTT
-# =======================
 paho-mqtt==2.0.0
+# deepface==0.0.79
+# edge-tts==6.1.12

server/asgi.py

@@ -8,16 +8,13 @@ https://docs.djangoproject.com/en/3.0/howto/deployment/asgi/
 """
 
 import os
-import django
 from channels.routing import ProtocolTypeRouter, URLRouter
-
-os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'server.settings')
-django.setup()
-
 from django.core.asgi import get_asgi_application
 from apps.utils.middlewares import TokenAuthMiddleware
 import apps.ws.routing
 
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'server.settings')
+
 application = ProtocolTypeRouter({
     "http": get_asgi_application(),
     "websocket": TokenAuthMiddleware(