diff --git a/apps/rpm/services.py b/apps/rpm/services.py index d105f718..2953d4e0 100644 --- a/apps/rpm/services.py +++ b/apps/rpm/services.py @@ -2,7 +2,7 @@ from threading import Thread from apps.hrm.models import Certificate, Employee from apps.hrm.services import HrmService from apps.wf.models import Ticket, Transition -from apps.rpm.models import Rcertificate, Rpj, Rpjmember +from apps.rpm.models import Rcertificate, Rfile, Rpj, Rpjfile, Rpjmember def bind_rpj(ticket: Ticket, transition: Transition, new_ticket_data: dict): @@ -42,7 +42,7 @@ def rpj_audit_end(ticket): Thread(target=HrmService.sync_dahua_employee, args=(ep, '', rpj.come_time, rpj.leave_time)).start() # 更新入厂项目人员证书库 for i in Rcertificate.objects.filter(rpj=rpj): - ct = Certificate.objects.filter(number=i.number) + ct = Certificate.objects.filter(number=i.number).first() if ct: pass else: @@ -56,4 +56,15 @@ def rpj_audit_end(ticket): ct.file = i.file ct.employee = i.rpj_member.remployee.employee ct.save() + # 更新相关方资料库 + for i in Rpjfile.objects.filter(rpj=rpj): + rf = Rfile.objects.filter(file_cate=i.file_cate, rparty=i.rparty).first() + if rf: + pass + else: + rf = Rfile() + rf.rparty = i.rparty + rf.file_cate = i.file_cate + for m in i.files.all(): + rf.files.add(m) # 发送通知?