更新案子查询语句
This commit is contained in:
@@ -1,4 +1,3 @@
|
|||||||
import concurrent.futures
|
|
||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
import math
|
import math
|
||||||
@@ -431,7 +430,8 @@ def main():
|
|||||||
while 1:
|
while 1:
|
||||||
session = MysqlSession()
|
session = MysqlSession()
|
||||||
# 查询需要识别的案子
|
# 查询需要识别的案子
|
||||||
phhds = session.query(ZxPhhd.pk_phhd).filter(ZxPhhd.exsuccess_flag == '1').limit(PHHD_BATCH_SIZE).all()
|
phhds = session.query(ZxPhhd.pk_phhd, ZxPhhd.exsuccess_flag).filter(ZxPhhd.exsuccess_flag == '1').limit(
|
||||||
|
PHHD_BATCH_SIZE).all()
|
||||||
# 将状态改为正在识别中
|
# 将状态改为正在识别中
|
||||||
for phhd in phhds:
|
for phhd in phhds:
|
||||||
phhd.exsuccess_flag = '2'
|
phhd.exsuccess_flag = '2'
|
||||||
|
|||||||
Reference in New Issue
Block a user