修改rpj_audit_end
This commit is contained in:
parent
50f5627a41
commit
43eb17cacf
|
|
@ -2,7 +2,7 @@ from threading import Thread
|
||||||
from apps.hrm.models import Certificate, Employee
|
from apps.hrm.models import Certificate, Employee
|
||||||
from apps.hrm.services import HrmService
|
from apps.hrm.services import HrmService
|
||||||
from apps.wf.models import Ticket, Transition
|
from apps.wf.models import Ticket, Transition
|
||||||
from apps.rpm.models import Rcertificate, Rfile, Rpj, Rpjfile, Rpjmember
|
from apps.rpm.models import Rcertificate, Rfile, Rpj, Rpjcertificate, Rpjfile, Rpjmember
|
||||||
|
|
||||||
|
|
||||||
def bind_rpj(ticket: Ticket, transition: Transition, new_ticket_data: dict):
|
def bind_rpj(ticket: Ticket, transition: Transition, new_ticket_data: dict):
|
||||||
|
|
@ -41,7 +41,7 @@ def rpj_audit_end(ticket):
|
||||||
# 同步至大华人员库并下发人脸
|
# 同步至大华人员库并下发人脸
|
||||||
HrmService.sync_dahua_employee(ep, '', rpj.come_time, rpj.leave_time)
|
HrmService.sync_dahua_employee(ep, '', rpj.come_time, rpj.leave_time)
|
||||||
# 更新入厂项目人员证书库
|
# 更新入厂项目人员证书库
|
||||||
for i in Rcertificate.objects.filter(rpj=rpj):
|
for i in Rpjcertificate.objects.filter(rpj=rpj):
|
||||||
ct = Certificate.objects.filter(number=i.number).first()
|
ct = Certificate.objects.filter(number=i.number).first()
|
||||||
if ct:
|
if ct:
|
||||||
pass
|
pass
|
||||||
|
|
|
||||||
|
|
@ -28,7 +28,7 @@ def run_task(ticket_id: str):
|
||||||
m = importlib.import_module(module)
|
m = importlib.import_module(module)
|
||||||
f = getattr(m, func)
|
f = getattr(m, func)
|
||||||
f(ticket)
|
f(ticket)
|
||||||
except Exception as e:
|
except Exception:
|
||||||
err_detail = traceback.format_exc()
|
err_detail = traceback.format_exc()
|
||||||
myLogger.error(err_detail)
|
myLogger.error(err_detail)
|
||||||
script_result = False
|
script_result = False
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue