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

三方接口处理问题

This commit is contained in:
曹前明 2022-10-04 09:03:31 +08:00
parent 7e9d5fe7b0
commit e3a94e9a72
4 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apps/ecm/tasks.py
View File

@ -18,7 +18,6 @@ import time
from django.core.cache import cache from django.core.cache import cache
@shared_task
def update_count_people(i: Area): def update_count_people(i: Area):
if i.third_info.get('xx_rail', None): if i.third_info.get('xx_rail', None):
railId = i.third_info['xx_rail']['id'] railId = i.third_info['xx_rail']['id']

5
apps/third/dahua.py
View File

@ -34,7 +34,6 @@ class DhClient:
self.isGetingToken = False self.isGetingToken = False
self.isRuning = True self.isRuning = True
self.token = None self.token = None
self.t = None # 线程
self.log = {} self.log = {}
self.setup() self.setup()
@ -55,15 +54,13 @@ class DhClient:
time.sleep(1200) time.sleep(1200)
def setup(self): def setup(self):
t = Thread(target=self._get_token_loop, args=(), daemon=True) Thread(target=DhClient._get_token_loop, args=(self, ), daemon=True).start()
t.start()
def __del__(self): def __del__(self):
""" """
自定义销毁 自定义销毁
""" """
self.isRuning = False self.isRuning = False
# self.t.join()
def request(self, url: str, method: str, params=dict(), json=dict(), timeout=120, def request(self, url: str, method: str, params=dict(), json=dict(), timeout=120,
file_path_rela=None, raise_exception=True): file_path_rela=None, raise_exception=True):

5
apps/third/speaker.py
View File

@ -32,7 +32,6 @@ class SpClient:
self.headers = {"Connection": "close"} self.headers = {"Connection": "close"}
self.isGetingToken = False self.isGetingToken = False
self.isRuning = True self.isRuning = True
self.t = None # 线程
self.log = {} self.log = {}
self.setup() self.setup()
@ -52,15 +51,13 @@ class SpClient:
time.sleep(1200) time.sleep(1200)
def setup(self): def setup(self):
t = Thread(target=self._get_token_loop, args=(), daemon=True) Thread(target=SpClient._get_token_loop, args=(self, ), daemon=True).start()
t.start()
def __del__(self): def __del__(self):
""" """
自定义销毁 自定义销毁
""" """
self.isRuning = False self.isRuning = False
# self.t.join()
def request(self, url: str, method: str, params=dict(), json=dict(), timeout=120, def request(self, url: str, method: str, params=dict(), json=dict(), timeout=120,
file_path_rela=None, raise_exception=True): file_path_rela=None, raise_exception=True):

5
apps/third/xunxi.py
View File

@ -30,7 +30,6 @@ class XxClient:
self.isRuning = True self.isRuning = True
self.token = '' self.token = ''
self.log = {} self.log = {}
self.t = None
self.setup() self.setup()
def _get_token_loop(self): def _get_token_loop(self):
@ -49,15 +48,13 @@ class XxClient:
self.isGetingToken = False self.isGetingToken = False
def setup(self): def setup(self):
self.t = Thread(target=self._get_token_loop, args=(), daemon=True) Thread(target=XxClient._get_token_loop, args=(self, ), daemon=True).start()
self.t.start()
def __del__(self): def __del__(self):
""" """
自定义销毁 自定义销毁
""" """
self.isRuning = False self.isRuning = False
# self.t.join()
def request(self, url: str, method: str = 'post', params=dict(), json=dict(), timeout=20, raise_exception=True): def request(self, url: str, method: str = 'post', params=dict(), json=dict(), timeout=20, raise_exception=True):
if not settings.XX_ENABLED: if not settings.XX_ENABLED: