From c0b46a1fe1cc17944ec37ef92966a222964a1fff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E5=89=8D=E6=98=8E?= <909355014@qq.com> Date: Fri, 15 Jul 2022 13:49:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9rpj=5Faudit=5Fend?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/rpm/tasks.py | 48 ----------------------------------------------- 1 file changed, 48 deletions(-) diff --git a/apps/rpm/tasks.py b/apps/rpm/tasks.py index 8404af16..386ec9d8 100644 --- a/apps/rpm/tasks.py +++ b/apps/rpm/tasks.py @@ -4,51 +4,3 @@ from apps.hrm.models import Certificate, Employee from apps.rpm.models import Rcertificate, Remployee, Rpj, Rpjcertificate, Rpjmember from apps.utils.task import CustomTask from celery import shared_task - - -@shared_task(base=CustomTask) -def rpj_audit_start(ticket_id): - rpj = Rpj.objects.get(ticket__id=ticket_id) - if rpj.state == Rpj.RPJ_CREATE: - rpj.state = Rpj.RPJ_AUDIT - rpj.save() - - -@shared_task(base=CustomTask) -def rpj_audit_end(ticket_id): - rpj = Rpj.objects.get(ticket__id=ticket_id) - if rpj.state == Rpj.RPJ_AUDIT: - rpj.state = Rpj.RPJ_ENTER - rpj.save() - # 更新企业相关方人员库和证书库 - for i in Rpjmember.objects.filter(rpj=rpj): - remployee = i.remployee - ep = Employee.objects.filter(id_number=remployee.id_number).first() - if ep: - pass - else: - ep = Employee() - ep.name = remployee.name - ep.phone = remployee.phone - ep.photo = remployee.photo - ep.id_number = remployee.id_number - ep.type = 'remployee' - ep.save() - remployee.employee = ep - remployee.save() - - for i in Rpjcertificate.objects.filter(rpj_member__rpj=rpj): - ct = Certificate.objects.filter(number=i.number).first() - if ct: - pass - else: - ct = Certificate() - ct.name = i.name - ct.number = i.number - ct.type = i.type - ct.issue_date = i.issue_date - ct.expiration_date = i.expiration_date - ct.review_date = i.review_date - ct.file = i.file - ct.employee = i.rpj_member.remployee.employee - ct.save()