|
...
|
...
|
@@ -79,7 +79,7 @@ def get_task_status_1_from_database(): |
|
|
|
db = GetConnect()
|
|
|
|
cursor = db.cursor()
|
|
|
|
# sql= "select id from " + '''"''' + tbl + '''"'''+ ' ' + 'order by id desc '
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_type = 1 and id = {} '''.format(get_loot_task_id())
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_type = 1 and task_status = 1 and id = {} '''.format(get_loot_task_id())
|
|
|
|
# print(sql)
|
|
|
|
try:
|
|
|
|
cursor.execute(sql)
|
|
...
|
...
|
@@ -96,7 +96,23 @@ def get_task_status_2_from_database(): |
|
|
|
db = GetConnect()
|
|
|
|
cursor = db.cursor()
|
|
|
|
# sql= "select id from " + '''"''' + tbl + '''"'''+ ' ' + 'order by id desc '
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_type = 1 and id = {} '''.format(get_loot_task_id())
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_type = 1 and task_status = 2 and id = {} '''.format(get_loot_task_id())
|
|
|
|
print(sql)
|
|
|
|
try:
|
|
|
|
cursor.execute(sql)
|
|
|
|
result = cursor.fetchone()
|
|
|
|
return result[0]
|
|
|
|
except Exception as err:
|
|
|
|
# 发生错误时回滚
|
|
|
|
print(err)
|
|
|
|
db.rollback()
|
|
|
|
db.close()
|
|
|
|
#获取抢单任务单的状态:进行中
|
|
|
|
def get_task_status_3_from_database():
|
|
|
|
db = GetConnect()
|
|
|
|
cursor = db.cursor()
|
|
|
|
# sql= "select id from " + '''"''' + tbl + '''"'''+ ' ' + 'order by id desc '
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_type = 1 and task_status = 3 and id = {} '''.format(get_loot_task_id())
|
|
|
|
# print(sql)
|
|
|
|
try:
|
|
|
|
cursor.execute(sql)
|
|
...
|
...
|
@@ -107,14 +123,13 @@ def get_task_status_2_from_database(): |
|
|
|
print(err)
|
|
|
|
db.rollback()
|
|
|
|
db.close()
|
|
|
|
|
|
|
|
#获取任务单的状态:待确认
|
|
|
|
# #获取抢单任务单的状态:待确认
|
|
|
|
def get_task_status_7_from_database():
|
|
|
|
db = GetConnect()
|
|
|
|
cursor = db.cursor()
|
|
|
|
# sql= "select id from " + '''"''' + tbl + '''"'''+ ' ' + 'order by id desc '
|
|
|
|
sql = '''select id from tasks where company_id = 366 and task_status = 7 order by id desc'''
|
|
|
|
# print(sql)
|
|
|
|
sql = '''select task_status from tasks where company_id = 366 and task_status = 7 and id = {}'''.format(get_loot_task_id())
|
|
|
|
print(sql)
|
|
|
|
try:
|
|
|
|
cursor.execute(sql)
|
|
|
|
result = cursor.fetchone()
|
|
...
|
...
|
@@ -130,7 +145,7 @@ def get_task_status_4_from_database(): |
|
|
|
db = GetConnect()
|
|
|
|
cursor = db.cursor()
|
|
|
|
# sql= "select id from " + '''"''' + tbl + '''"'''+ ' ' + 'order by id desc '
|
|
|
|
sql = '''select id from tasks t where t.company_id = 366 and t.task_status = 4 and t.receiver_uid = '3247366011913216' order by id desc'''
|
|
|
|
sql = '''select id from tasks t where t.company_id = 366 and t.task_status = 4 and t.receiver_uid = '3248817613892608' and id = {}'''.format(get_loot_task_id())
|
|
|
|
# print(sql)
|
|
|
|
try:
|
|
|
|
cursor.execute(sql)
|
...
|
...
|
|
