49 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			Python
		
	
	
	
			
		
		
	
	
			49 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			Python
		
	
	
	
| from django.shortcuts import render
 | |
| from rest_framework.mixins import ListModelMixin, CreateModelMixin, UpdateModelMixin
 | |
| from rest_framework.decorators import action
 | |
| from apps.qm.models import QuaStat, TestItem
 | |
| from apps.qm.serializers import QuaStatSerializer, TestItemSerializer, QuaStatUpdateSerializer
 | |
| from apps.qm.tasks import cal_quastat_sflog
 | |
| from rest_framework.response import Response
 | |
| from apps.utils.mixins import BulkCreateModelMixin, BulkUpdateModelMixin
 | |
| import datetime
 | |
| 
 | |
| from apps.utils.viewsets import CustomGenericViewSet
 | |
| from apps.wpm.models import SfLog
 | |
| from apps.qm.filters import QuaStatFilter
 | |
| # Create your views here.
 | |
| class TestItemViewSet(ListModelMixin, CustomGenericViewSet):
 | |
|     """
 | |
|     list:质检项目
 | |
| 
 | |
|     质检项目
 | |
|     """
 | |
|     perms_map = {'get': '*'}
 | |
|     queryset = TestItem.objects.all()
 | |
|     serializer_class = TestItemSerializer
 | |
|     filterset_fields = []
 | |
|     ordering = ['id']
 | |
| 
 | |
| class QuaStatViewSet(ListModelMixin, BulkUpdateModelMixin, CustomGenericViewSet):
 | |
|     """
 | |
|     list:质量数据统计
 | |
| 
 | |
|     质量数据统计
 | |
|     """
 | |
|     perms_map = {'get': '*', 'put': 'quastat.update'}
 | |
|     queryset = QuaStat.objects.all()
 | |
|     serializer_class = QuaStatSerializer
 | |
|     update_serializer_class = QuaStatUpdateSerializer
 | |
|     filterset_class = QuaStatFilter
 | |
|     select_related_fields = ['belong_dept', 'material', 'testitem']
 | |
|     ordering = ['belong_dept__sort', 'material__sort', 'testitem__sort']
 | |
| 
 | |
|     def after_bulk_update(self, objs):
 | |
|         now = datetime.datetime.now()
 | |
|         sflogIds = []
 | |
|         for i in objs:
 | |
|             sflogIds.append(i['sflog'])
 | |
|         sflogIds = list(set(sflogIds))
 | |
|         SfLog.objects.filter(id__in=sflogIds).update(last_test_time=now)  # 更新质检记录时间
 | |
|         for sflogId in sflogIds:
 | |
|             cal_quastat_sflog.delay(sflogId) |