更新入厂项目人员库

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)
         # 发送通知?