40 lines
1.2 KiB
Python
40 lines
1.2 KiB
Python
import time
|
|
import logging
|
|
import threading
|
|
import requests
|
|
from .config import SALARY_DETECT_URL, SALARY_DETECT_HEADERS, get_random_salary_payload
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
class SalaryDetect:
|
|
def __init__(self):
|
|
self._running = False
|
|
self._thread = None
|
|
|
|
def _run(self):
|
|
while self._running:
|
|
logger.info(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] Detecting salary...")
|
|
try:
|
|
payload = get_random_salary_payload()
|
|
response = requests.post(SALARY_DETECT_URL, headers=SALARY_DETECT_HEADERS, json=payload)
|
|
logger.info(f"POST {SALARY_DETECT_URL} status: {response.status_code}, response: {response.text}")
|
|
except Exception as e:
|
|
logger.error(f"Error during POST: {e}")
|
|
logger.info(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] Salary detection complete")
|
|
time.sleep(120)
|
|
|
|
def start(self):
|
|
if not self._running:
|
|
self._running = True
|
|
self._thread = threading.Thread(target=self._run, daemon=True)
|
|
self._thread.start()
|
|
|
|
def stop(self):
|
|
self._running = False
|
|
if self._thread:
|
|
self._thread.join()
|
|
|
|
|
|
|