| 81 | serializer_class = serializers.JobClosedSerializer |
| 82 | |
| 83 | def put(self, request, **kwargs): |
| 84 | get_object_or_404(models.Project, id=kwargs["project_id"]) |
| 85 | slz = self.get_serializer(data=request.data) |
| 86 | if slz.is_valid(raise_exception=True): |
| 87 | logger.info("[Job: %d] 开始执行回调..." % kwargs["job_id"]) |
| 88 | try: |
| 89 | core.JobCloseHandler.job_closed( |
| 90 | kwargs["job_id"], slz.validated_data["result_code"], slz.validated_data["result_msg"], |
| 91 | slz.validated_data["result_data"], slz.validated_data.get("result_path")) |
| 92 | return Response("job_closed") |
| 93 | except CDErrorBase as e: |
| 94 | return Response(e.data, status=status.HTTP_400_BAD_REQUEST) |
| 95 | |
| 96 | |
| 97 | class ProjectScanJobInitApiView(generics.GenericAPIView, ProjectBaseAPIView): |