haejun
/
AWX_collector_dummy
forked from YujinChu/AWX_collector
1
0
Fork 0
Code Pull Requests Activity

timestamp fix

This commit is contained in:
YujinChu 2023-09-08 08:17:36 +00:00
parent a47ea039de
commit dec65d35de
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
AWX_collector.py
View File

@ -185,7 +185,7 @@ def cwt_thread(evt, chip_index, port_a_ai_id , port_a_do_id, port_b_ai_id , port
-> 데이터를 어떻게 할 것이냐 -> 데이터를 어떻게 할 것이냐
-> 이전 데이터가 있다면, 이전 데이터를 가지고 더미 데이터로 사용하는 방법 => 안하기로 했었음 -> 이전 데이터가 있다면, 이전 데이터를 가지고 더미 데이터로 사용하는 방법 => 안하기로 했었음
''' '''
timenow = int(time.time()*1000) timenow_a = int(time.time()*1000)
isSuccess = True isSuccess = True
# PORT A # PORT A
@ -205,6 +205,7 @@ def cwt_thread(evt, chip_index, port_a_ai_id , port_a_do_id, port_b_ai_id , port
except: except:
None None
timenow_b = int(time.time()*1000)
# PORT B # PORT B
port_b_do_value = list(b[17:32]) port_b_do_value = list(b[17:32])
try: try:
@ -224,8 +225,8 @@ def cwt_thread(evt, chip_index, port_a_ai_id , port_a_do_id, port_b_ai_id , port
None None
if isSuccess: if isSuccess:
queue_a.put([timenow,prev_a_ai, port_a_do_value]) queue_a.put([timenow_a,prev_a_ai, port_a_do_value])
queue_b.put([timenow,prev_b_ai, port_b_do_value]) queue_b.put([timenow_b,prev_b_ai, port_b_do_value])
else: else:
queue_a.put([0,prev_a_ai, port_a_do_value]) queue_a.put([0,prev_a_ai, port_a_do_value])
queue_b.put([0,prev_b_ai, port_b_do_value]) queue_b.put([0,prev_b_ai, port_b_do_value])