zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refector: 刷卡推送优化detail添加channelCode

This commit is contained in:
caoqianming 2023-03-15 23:45:11 +08:00
parent 5dc43246e2
commit 379f27fe48
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/hrm/services.py
View File

@ -211,8 +211,8 @@ class HrmService:
""" """
id_number = data['info']['extend'].get('paperNumber', None) id_number = data['info']['extend'].get('paperNumber', None)
if id_number: if id_number:
detail = {'id':data['info']['extend']['id']}
nodeCode = data['info']['extend']['acsChannelCode'] nodeCode = data['info']['extend']['acsChannelCode']
detail = {'id':data['info']['extend']['id'], 'channelCode': nodeCode}
swip_time = data['info']['extend']['swingTime'] swip_time = data['info']['extend']['swingTime']
e_type = data['info']['extend']['enterOrExit'] e_type = data['info']['extend']['enterOrExit']
cls.swipe_next(nodeCode, id_number, swip_time, e_type, detail) cls.swipe_next(nodeCode, id_number, swip_time, e_type, detail)
@ -224,8 +224,8 @@ class HrmService:
for i in data['infoArray']: for i in data['infoArray']:
id_number = i.get('paperNumber', None) id_number = i.get('paperNumber', None)
if id_number: if id_number:
detail = {'id':i['id']}
nodeCode = i['acsChannelCode'] nodeCode = i['acsChannelCode']
detail = {'id':i['id'], 'channelCode': nodeCode}
swip_time = i['swingTime'] swip_time = i['swingTime']
e_type = i['enterOrExit'] e_type = i['enterOrExit']
cls.swipe_next(nodeCode, id_number, swip_time, e_type, detail) cls.swipe_next(nodeCode, id_number, swip_time, e_type, detail)

6
apps/hrm/tasks.py
View File

@ -50,7 +50,11 @@ def correct_swip_task(start_time="", end_time=""):
_, res = dhClient.request(**dhapis['swipe_list'], json=data) _, res = dhClient.request(**dhapis['swipe_list'], json=data)
for i in res['pageData']: for i in res['pageData']:
if 'paperNumber' in i: if 'paperNumber' in i:
HrmService.swipe_next(i['channelCode'], i['paperNumber'], i['swingTime'], i['enterOrExit'], {'id': i['id']}) detail = {
'id': i['id'],
'channelCode': i['channelCode']
}
HrmService.swipe_next(i['channelCode'], i['paperNumber'], i['swingTime'], i['enterOrExit'], detail)
# ClockRecord.objects.filter(type=30).delete() # ClockRecord.objects.filter(type=30).delete()
@shared_task @shared_task