kedong/scripts/test/qx_ctrl_config.py

import os
import sys
import time
import django
local_path = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
print(local_path)
if local_path not in sys.path:
    sys.path.append(local_path)
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "kedong.settings")
django.setup()
from django.conf import settings
from smartfarming.models.device import MongoDevice, MongoDeviceConfig
import json
import requests
import pymongo
from urllib import parse


my_client = pymongo.MongoClient(host="8.136.98.49", port=27017, username="root", password="yfkj@6020")
my_col = my_client['smartfarming']['sa_device']

qx_device = {
"861551055315402",
"861551056086671",
"861551056088693",
"861551056088479",
"861551056088719",
"861551055313365",
"861551056086614",
"861551056093800",
"861551056095367",
"861551056102502",
"861551056096621",
"861551056101785",
"861551056086549",
"861551055354120",
"861551055353536",
"861551056092018",
"861551055319586",
"861551056088875",
"861551055324651",
"861551055313423"
}


def dsj_qxz_conf_info():
    # 初始化气象站与墒情站时间间隔配置
    cmd = '{"cmd": "config", "ext": {"interval": 1}}'
    for k in qx_device:
        in_d_id = MongoDevice.objects.get(device_id=k).id
        config, is_created = MongoDeviceConfig.objects.get_or_create(
                d_id=in_d_id,
                defaults={
                    "device_config": cmd,
                    "cmd": "config",
                    "addtime": int(time.time()),
                    "uptime": int(time.time())
                }
            )
        print(f"设备: {k} 是否新建  {is_created} ")
    return True


if __name__ == "__main__":
    dsj_qxz_conf_info()