yfwlwCut/script_file/jk_status.py

# -*- coding: utf-8 -*-
# File Name:mqtt_chat_client.py
# Python Version:3.5.1

import os
import django
import sys
from qcloudsms_py import SmsSingleSender
from qcloudsms_py.httpclient import HTTPError
from qcloudsms_py import SmsMultiSender

BASE_DIR = os.path.dirname(os.path.abspath(__file__))  # 定位到你的django根目录
sys.path.append(os.path.abspath(os.path.join(BASE_DIR, os.pardir)))

os.environ.setdefault("DJANGO_SETTINGS_MODULE",
                      "yfwlw_pro.settings")  # project_name 项目名称
django.setup()

import json
from apps.AppInfoManage.models import Equip, Equip_type, MyUser, CBDphoto, CBDstatus, QXZdata, SCDstatus, CBDstatus, Equip_SimInfo, CBDdata, BZYphoto, RecentCBDdata,RecentSCDdata,\
Msg_Conf, Msg_Send, JKphoto, JKdata, JKtoken
import re
import datetime
import time
import random
from apps.SimInfo.views import get_siminfo
from apps.ReportManage.all_dict import insect_dict_new, transpont_equip_scd
import shutil
import requests
import math
# math.ceil 向上取整
# math.floor 向下取整


token = JKtoken.objects.get(account="ysy_haikang").token

url = "https://open.ys7.com/api/lapp/device/list"
live_data = {"accessToken":token}
live_res = requests.post(url,data=live_data)
live_res = eval(live_res.text)




if live_res['code'] == "200":
    print("token获取成功")
# 如果返回其他 则重新获取token
else:
    print("token过期重新获取")
    token_url = 'https://open.ys7.com/api/lapp/token/get'
    token_data = {"appKey":"e8ec0d52b4b14628a3daf4b88cbcca2a",
            "appSecret":"d4565abea1cd0b90b59917111dcb37bd"}
    token_res = requests.post(token_url,data=token_data,timeout=3)
    print("token_res1:",token_res.text)
    token_res = eval(token_res.text)
    if token_res["code"] == "200":
        token_obj = JKtoken.objects.get(account="ysy_haikang")
        token_obj.token = token_res["data"]["accessToken"]
        token_obj.upl_time = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
        token_obj.save()
        token = token_obj.token
        print("-----------------token保存成功")


token = JKtoken.objects.get(account="ysy_haikang").token

url = "https://open.ys7.com/api/lapp/device/list"
live_data = {"accessToken":token}
live_res = requests.post(url,data=live_data)
live_res = eval(live_res.text)

aa = live_res["page"]["total"] / 10
aa = math.ceil(aa)
for i in range(aa):
    live_data = {"accessToken":token,"pageStart":i}
    live_res = requests.post(url,data=live_data)
    live_res = eval(live_res.text)
    print("live_res2:",live_res)
    for ii in live_res["data"]:
        if JKdata.objects.filter(equip_id_id=ii["deviceSerial"]).exists():
            print("监控存在")
            print(ii["status"])
            jk_obj = JKdata.objects.get(equip_id_id=ii["deviceSerial"])
            jk_obj.is_online = ii["status"]
            jk_obj.save()
            print("保存成功")